public static class KMeansConnectedDataflowExample.KMeansAllReduceTask extends BaseCompute implements Collector
Constructor and Description |
---|
KMeansAllReduceTask() |
Modifier and Type | Method and Description |
---|---|
boolean |
execute(IMessage message)
Execute with an incoming message
|
DataPartition<double[][]> |
get()
get the collected valued
|
IONames |
getCollectibleNames()
This method should return a set of collectible names, that can be collected from this
collector.
|
void |
prepare(Config cfg,
TaskContext context)
Prepare the task to be executed
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
endExecute
public boolean execute(IMessage message)
ICompute
public DataPartition<double[][]> get()
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
public void prepare(Config cfg, TaskContext context)
INode