edu.iu.dsc.tws.tset.ops.row

Class RowSinkOp

java.lang.Object

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

edu.iu.dsc.tws.tset.ops.row.RowSinkOp

All Implemented Interfaces:

Closable, Collector, Receptor, ICompute<Table>, INode, java.io.Serializable

public class RowSinkOp
extends BaseOp
implements ICompute<Table>, Closable, Collector

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RowSinkOp()
RowSinkOp(SinkFunc<Row> sink, BaseTSet originTSet, java.util.Map<java.lang.String,java.lang.String> receivableTSets)

Method Summary

Modifier and Type	Method and Description
void	close() Close method for cleaning up the resources
boolean	execute(IMessage<Table> content) Execute with an incoming message
DataPartition<?>	get(java.lang.String name) returns the collected data partition only when it matches the provided name
IONames	getCollectibleNames() This method should return a set of collectible names, that can be collected from this collector.
void	prepare(Config cfg, TaskContext ctx) Prepare the task to be executed

Methods inherited from class edu.iu.dsc.tws.tset.ops.BaseOp

add, getReceivableNames, 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.nodes.ICompute

endExecute

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

reset

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

get

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

add

Constructor Detail

RowSinkOp

public RowSinkOp()

RowSinkOp

public RowSinkOp(SinkFunc<Row> sink,
                 BaseTSet originTSet,
                 java.util.Map<java.lang.String,java.lang.String> receivableTSets)

Method Detail

prepare

public void prepare(Config cfg,
                    TaskContext ctx)

Description copied from interface: INode

Prepare the task to be executed

Specified by:

prepare in interface INode

Parameters:

cfg - the configuration

ctx - the task context, this has runtime information about the task

execute

public boolean execute(IMessage<Table> content)

Description copied from interface: ICompute

Execute with an incoming message

Specified by:

execute in interface ICompute<Table>

close

public void close()

Description copied from interface: Closable

Close method for cleaning up the resources

Specified by:

close in interface Closable

get

public DataPartition<?> get(java.lang.String name)

returns the collected data partition only when it matches the provided name

Specified by:

get in interface Collector

Parameters:

name - name of the value to collect

Returns:

the partition of the data

getCollectibleNames

public IONames getCollectibleNames()

Description copied from interface: Collector

This method should return a set of collectible names, that can be collected from this collector. 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:

getCollectibleNames in interface Collector

Returns:

set of names of collectbles