public static class TaskSchedulerClassTest.TestSink extends BaseCompute implements Collector
Constructor and Description |
---|
TestSink() |
TestSink(java.lang.String inputkey) |
Modifier and Type | Method and Description |
---|---|
boolean |
execute(IMessage message)
Execute with an incoming message
|
DataPartition<?> |
get()
get the collected valued
|
DataPartition<?> |
get(java.lang.String name)
get the collected valued
|
IONames |
getCollectibleNames()
This method should return a set of collectible names, that can be collected from this
collector.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
endExecute
public boolean execute(IMessage message)
ICompute
public DataPartition<?> get()
Collector
public DataPartition<?> get(java.lang.String name)
Collector
public IONames getCollectibleNames()
Collector
If Collector
C of task graph TG1 collects variable "var1" and C's parallelism is n, If
Receptor
R of task graph TG2 is interested in receiving "var1", R's parallelism should
be equal to n and, R should have the same distribution as C among the workers.
getCollectibleNames
in interface Collector