edu.iu.dsc.tws.tset.ops

Class BaseOp

java.lang.Object

edu.iu.dsc.tws.tset.ops.BaseOp

All Implemented Interfaces:

Receptor, java.io.Serializable

Direct Known Subclasses:

BaseComputeOp, RowSinkOp, SinkOp, SourceOp

public abstract class BaseOp
extends java.lang.Object
implements Receptor, java.io.Serializable

Every tset op is a Receptor. This class handles that. This also takes care of creating/updating TSetContext.

See Also:

Serialized Form

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BaseOp()
protected	BaseOp(BaseTSet originTSet)
protected	BaseOp(BaseTSet originTSet, java.util.Map<java.lang.String,java.lang.String> receivableTSets)

Method Summary

Modifier and Type	Method and Description
void	add(java.lang.String key, DataPartition<?> data)
IONames	getReceivableNames() This method should return a set of receivable names, that are expected by this receptor.
protected TSetContext	gettSetContext()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface edu.iu.dsc.tws.api.compute.modifiers.Receptor

add

Constructor Detail

BaseOp

protected BaseOp()

BaseOp

protected BaseOp(BaseTSet originTSet)

BaseOp

protected BaseOp(BaseTSet originTSet,
                 java.util.Map<java.lang.String,java.lang.String> receivableTSets)

Method Detail

add

public void add(java.lang.String key,
                DataPartition<?> data)

Specified by:

add in interface Receptor

getReceivableNames

public IONames getReceivableNames()

Description copied from interface: Receptor

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.

Specified by:

getReceivableNames in interface Receptor

Returns:

get the set of names

gettSetContext

protected TSetContext gettSetContext()