T
- type of datapublic class AllReduceTLink<T> extends BatchSingleLink<T>
Constructor and Description |
---|
AllReduceTLink(BatchEnvironment tSetEnv,
ReduceFunc<T> rFn,
int sourceParallelism,
Schema schema) |
Modifier and Type | Method and Description |
---|---|
CachedTSet<T> |
cache()
Runs this TSet and caches the data to an in-memory
DataPartition and exposes the data as another TSet. |
Edge |
getEdge() |
CachedTSet<T> |
lazyCache()
Performs caching lazily.
|
PersistedTSet<T> |
lazyPersist()
Performs persisting lazily.
|
PersistedTSet<T> |
persist()
Similar to cache, but the data is stored in a disk based
DataPartition . |
AllReduceTLink<T> |
setName(java.lang.String n)
Name of the TSet and return the same tlink
|
flatmap, forEach, lazyForEach, map, mapToTuple
compute, compute, compute, compute, getTSetEnv, sink
getSchema
addChildToGraph, equals, getId, getName, getSourceParallelism, getTargetParallelism, hashCode, rename, setTSetEnv, toString
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
build
generateID, getTBaseGraph
public AllReduceTLink(BatchEnvironment tSetEnv, ReduceFunc<T> rFn, int sourceParallelism, Schema schema)
public Edge getEdge()
public AllReduceTLink<T> setName(java.lang.String n)
TLink
n
- namepublic CachedTSet<T> lazyCache()
StoringData
TSet
is evaluated explicitly.lazyCache
in interface StoringData<T>
lazyCache
in class BatchSingleLink<T>
public CachedTSet<T> cache()
StoringData
DataPartition
and exposes the data as another TSet.cache
in interface StoringData<T>
cache
in class BatchSingleLink<T>
public PersistedTSet<T> lazyPersist()
StoringData
lazyPersist
in interface StoringData<T>
lazyPersist
in class BatchSingleLink<T>
public PersistedTSet<T> persist()
StoringData
DataPartition
. This method would also expose the
checkpointing ability to TSet
s.persist
in interface StoringData<T>
persist
in class BatchSingleLink<T>