edu.iu.dsc.tws.api.compute.modifiers

Interface Receptor

All Known Subinterfaces:

IReceptor<T>

All Known Implementing Classes:

BaseComputeOp, BaseOp, BasicComputation.SourceTask, CheckpointedSourceOp, ComputeCollectorOp, ComputeCollectorToTupleOp, ComputeOp, ComputeToTupleOp, ConnectedSource, CSVInputFormatTest.TestSource, InputDataStreamer, IterativeDataStream, IterativePredictionDataStreamer, IterativeStreamingCompute, IterativeStreamingDataStreamer, KeyedSourceOp, KMeansComputeJob.KMeansSourceTask, KMeansConnectedDataflowExample.KMeansSourceTask, PredictionSourceTask, RowComupteCollectorOp, RowItrComputeCollectorOp, RowSinkOp, RowSourceOp, SinkOp, SourceOp, TaskSchedulerClassTest.TestSource, WindowComputeOp

public interface Receptor

Add input to a task graph

Method Summary

Modifier and Type	Method and Description
default void	add(java.lang.String name, DataObject<?> data) Deprecated. Use add(String, DataPartition) instead
default void	add(java.lang.String name, DataPartition<?> data)
default IONames	getReceivableNames() This method should return a set of receivable names, that are expected by this receptor.

Method Detail

add

@Deprecated
default void add(java.lang.String name,
                             DataObject<?> data)

Deprecated. Use add(String, DataPartition) instead

This method is called when the data is available

Parameters:

name - name of the input

data - input data

add

default void add(java.lang.String name,
                 DataPartition<?> data)

getReceivableNames

default IONames getReceivableNames()

This method should return a set of receivable names, that are expected by this receptor. These names will be used by task plan builder to cross validate parallelism between two task graphs.

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.

Returns:

get the set of names