edu.iu.dsc.tws.api.tset

Interface StoringData<T>

Type Parameters:

T - tset type

All Known Subinterfaces:

BatchRowTSet, BatchTLink<T1,T0>, BatchTSet<T>, BatchTupleTSet<K,V>

All Known Implementing Classes:

AllGatherTLink, AllReduceTLink, BatchGatherLink, BatchIteratorLink, BatchIteratorLinkWrapper, BatchRowTSetImpl, BatchSingleLink, BatchTLinkImpl, BatchTSetImpl, BatchTupleTSetImpl, CachedTSet, CheckpointedTSet, ComputeTSet, DirectTLink, GatherTLink, JoinTLink, KeyedBatchIteratorLinkWrapper, KeyedCachedTSet, KeyedCheckpointedTSet, KeyedDirectTLink, KeyedGatherTLink, KeyedGatherUngroupedTLink, KeyedPartitionTLink, KeyedPersistedTSet, KeyedPipeTLink, KeyedReduceTLink, KeyedSourceTSet, KeyedStoredTSet, KeyedTSet, PartitionTLink, PersistedTSet, PipeTLink, ReduceTLink, ReplicateTLink, RowCachedTSet, RowCheckpointedTSet, RowComputeTSet, RowPersistedTSet, RowSourceTSet, RowStoredTSet, SourceTSet, StoredTSet

public interface StoringData<T>

Adds the capability to to store data for TSets.

Method Summary

Modifier and Type	Method and Description
StorableTBase<T>	cache() Runs this TSet and caches the data to an in-memory DataPartition and exposes the data as another TSet.
StorableTBase<T>	lazyCache() Performs caching lazily.
StorableTBase<T>	lazyPersist() Performs persisting lazily.
StorableTBase<T>	persist() Similar to cache, but the data is stored in a disk based DataPartition.

Method Detail

cache

StorableTBase<T> cache()

Runs this TSet and caches the data to an in-memory DataPartition and exposes the data as another TSet.

Returns:

Cached TSet

lazyCache

StorableTBase<T> lazyCache()

Performs caching lazily. i.e. cache operation would only be performed when the TSet is evaluated explicitly.

Returns:

Cached TSet

persist

StorableTBase<T> persist()

Similar to cache, but the data is stored in a disk based DataPartition. This method would also expose the checkpointing ability to TSets.

Returns:

Persisted / Checkpointed TSets

lazyPersist

StorableTBase<T> lazyPersist()

Performs persisting lazily.

Returns:

Persisted / Checkpointed TSets