T
- type of datapublic class SAllGatherTLink<T> extends StreamingGatherLink<T>
Constructor and Description |
---|
SAllGatherTLink(StreamingEnvironment tSetEnv,
int sourceParalellism,
Schema schema) |
Modifier and Type | Method and Description |
---|---|
Edge |
getEdge() |
SAllGatherTLink<T> |
setName(java.lang.String n)
Name of the TSet and return the same tlink
|
flatmap, forEach, map, mapToTuple
compute, compute, compute, compute, countWindow, countWindow, getTSetEnv, sink, timeWindow, timeWindow
getSchema
addChildToGraph, equals, getId, getName, getSourceParallelism, getTargetParallelism, hashCode, rename, setTSetEnv, toString
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
build
generateID, getTBaseGraph
public SAllGatherTLink(StreamingEnvironment tSetEnv, int sourceParalellism, Schema schema)
public Edge getEdge()
public SAllGatherTLink<T> setName(java.lang.String n)
TLink
n
- name