public static class KMeansConnectedDataflowExample.KMeansSourceTask extends BaseSource implements Receptor
Constructor and Description |
---|
KMeansSourceTask() |
KMeansSourceTask(int dim) |
Modifier and Type | Method and Description |
---|---|
void |
add(java.lang.String name,
DataObject<?> data)
This method is called when the data is available
|
void |
add(java.lang.String name,
DataPartition<?> data) |
void |
execute()
Execute without an incoming message
|
IONames |
getReceivableNames()
This method should return a set of receivable names, that are expected by this receptor.
|
void |
prepare(Config cfg,
TaskContext context)
Prepare the task to be executed
|
public KMeansSourceTask()
public KMeansSourceTask(int dim)
public void execute()
ISource
public void add(java.lang.String name, DataObject<?> data)
Receptor
public void add(java.lang.String name, DataPartition<?> data)
public IONames getReceivableNames()
Receptor
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.
getReceivableNames
in interface Receptor
public void prepare(Config cfg, TaskContext context)
INode