edu.iu.dsc.tws.tset.sets.batch.row

Class RowCheckpointedTSet

java.lang.Object

edu.iu.dsc.tws.tset.sets.BaseTSet<T>

edu.iu.dsc.tws.tset.sets.BaseTSetWithSchema<Row>

edu.iu.dsc.tws.tset.sets.batch.row.BatchRowTSetImpl

edu.iu.dsc.tws.tset.sets.batch.row.RowStoredTSet

edu.iu.dsc.tws.tset.sets.batch.row.RowPersistedTSet

edu.iu.dsc.tws.tset.sets.batch.row.RowCheckpointedTSet

All Implemented Interfaces:

AcceptingData<Row>, BatchRowTSet, StorableTBase<Row>, StoringData<Row>, TBase, Buildable, BuildableTSet, java.io.Serializable

public class RowCheckpointedTSet
extends RowPersistedTSet

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class edu.iu.dsc.tws.tset.sets.BaseTSet

BaseTSet.StateType

Field Summary

Fields inherited from class edu.iu.dsc.tws.tset.sets.batch.row.RowStoredTSet

storedSource

Constructor Summary

Constructors

Constructor and Description
RowCheckpointedTSet(BatchEnvironment tSetEnv, DiskPartitionBackedSource<Row> sourceFn, int parallelism, RowSchema inputSchema)

Method Summary

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

Methods inherited from class edu.iu.dsc.tws.tset.sets.batch.row.RowPersistedTSet

addInput, cache, lazyCache, lazyPersist, persist, setName, withSchema

Methods inherited from class edu.iu.dsc.tws.tset.sets.batch.row.RowStoredTSet

direct, getData, getInputSchema, join, partition

Methods inherited from class edu.iu.dsc.tws.tset.sets.batch.row.BatchRowTSetImpl

getTSetEnv, pipe, withSchema

Methods inherited from class edu.iu.dsc.tws.tset.sets.BaseTSetWithSchema

getOutputSchema, setOutputSchema

Methods inherited from class edu.iu.dsc.tws.tset.sets.BaseTSet

addChildToGraph, addChildToGraph, equals, getId, getInputs, getName, getParallelism, getStateType, hashCode, isMutable, rename, setMutable, setStateType, setTSetEnv, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface edu.iu.dsc.tws.api.tset.sets.StorableTBase

getDataObject

Methods inherited from interface edu.iu.dsc.tws.api.tset.TBase

getId, getName

Methods inherited from interface edu.iu.dsc.tws.tset.sets.BuildableTSet

build

Methods inherited from interface edu.iu.dsc.tws.tset.Buildable

generateID, getTBaseGraph

Constructor Detail

RowCheckpointedTSet

public RowCheckpointedTSet(BatchEnvironment tSetEnv,
                           DiskPartitionBackedSource<Row> sourceFn,
                           int parallelism,
                           RowSchema inputSchema)

Method Detail

getStoredSourceTSet

public RowSourceTSet getStoredSourceTSet()

Description copied from interface: StorableTBase

retrieve data saved in the TSet

Specified by:

getStoredSourceTSet in interface StorableTBase<Row>

Overrides:

getStoredSourceTSet in class RowStoredTSet

Returns:

dataObject

getINode

public INode getINode()

Reuses the 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

Specified by:

getINode in interface BuildableTSet

Overrides:

getINode in class RowPersistedTSet

Returns:

INode