public class RowCheckpointedTSet extends RowPersistedTSet
BaseTSet.StateType
storedSource
Constructor and Description |
---|
RowCheckpointedTSet(BatchEnvironment tSetEnv,
DiskPartitionBackedSource<Row> sourceFn,
int parallelism,
RowSchema inputSchema) |
Modifier and Type | Method and Description |
---|---|
INode |
getINode()
Reuses the
DiskPartitionBackedSourceWrapper from non-keyed operations because there
will be no keyed writes to edges. |
RowSourceTSet |
getStoredSourceTSet()
retrieve data saved in the TSet
|
addInput, cache, lazyCache, lazyPersist, persist, setName, withSchema
direct, getData, getInputSchema, join, partition
getTSetEnv, pipe, withSchema
getOutputSchema, setOutputSchema
addChildToGraph, addChildToGraph, equals, getId, getInputs, getName, getParallelism, getStateType, hashCode, isMutable, rename, setMutable, setStateType, setTSetEnv, toString
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
getDataObject
build
generateID, getTBaseGraph
public RowCheckpointedTSet(BatchEnvironment tSetEnv, DiskPartitionBackedSource<Row> sourceFn, int parallelism, RowSchema inputSchema)
public RowSourceTSet getStoredSourceTSet()
StorableTBase
getStoredSourceTSet
in interface StorableTBase<Row>
getStoredSourceTSet
in class RowStoredTSet
public INode getINode()
DiskPartitionBackedSourceWrapper
from non-keyed operations because there
will be no keyed writes to edges. This will only expose the
DataPartition
that will be called by the
TaskExecutor
getINode
in interface BuildableTSet
getINode
in class RowPersistedTSet