public class SKeyedPartitionTLink<K,V> extends StreamingSingleLink<Tuple<K,V>>
Constructor and Description |
---|
SKeyedPartitionTLink(StreamingEnvironment tSetEnv,
PartitionFunc<K> parFn,
int sourceParallelism,
KeyedSchema schema) |
Modifier and Type | Method and Description |
---|---|
Edge |
getEdge() |
protected KeyedSchema |
getSchema() |
SKeyedPartitionTLink<K,V> |
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
addChildToGraph, equals, getId, getName, getSourceParallelism, getTargetParallelism, hashCode, rename, setTSetEnv, toString
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
build
generateID, getTBaseGraph
public SKeyedPartitionTLink(StreamingEnvironment tSetEnv, PartitionFunc<K> parFn, int sourceParallelism, KeyedSchema schema)
public Edge getEdge()
public SKeyedPartitionTLink<K,V> setName(java.lang.String n)
TLink
n
- nameprotected KeyedSchema getSchema()