Package org.apache.beam.runners.spark.translation.streaming

Class Checkpoint

java.lang.Object

org.apache.beam.runners.spark.translation.streaming.Checkpoint

public class Checkpoint
extends Object

Checkpoint data to make it available in future pipeline runs.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Checkpoint.CheckpointDir	Checkpoint dir tree.

Constructor Summary

Constructors

Constructor	Description
Checkpoint()

Method Summary

Modifier and Type	Method	Description
static <T> T	readObject(FileSystem fileSystem, Path checkpointfilePath)
static void	writeObject(FileSystem fileSystem, Path checkpointFilePath, Object value)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Checkpoint

public Checkpoint()

Method Details

writeObject

public static void writeObject(FileSystem fileSystem,
 Path checkpointFilePath,
 Object value)
                        throws IOException

Throws:

IOException

readObject

public static <T> T readObject(FileSystem fileSystem,
 Path checkpointfilePath)
                        throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException