T
- type of datapublic class AllGatherTLink<T> extends BatchGatherLink<T>
Constructor and Description |
---|
AllGatherTLink(BatchEnvironment tSetEnv,
int sourceParallelism,
Schema schema) |
Modifier and Type | Method and Description |
---|---|
Edge |
getEdge() |
AllGatherTLink<T> |
setName(java.lang.String n)
Name of the TSet and return the same tlink
|
AllGatherTLink<T> |
useDisk() |
cache, flatmap, forEach, lazyCache, lazyForEach, lazyPersist, map, mapToTuple, persist
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 AllGatherTLink(BatchEnvironment tSetEnv, int sourceParallelism, Schema schema)
public Edge getEdge()
public AllGatherTLink<T> setName(java.lang.String n)
TLink
n
- namepublic AllGatherTLink<T> useDisk()