edu.iu.dsc.tws.checkpointing.task

Class CheckpointingSGatherSink

java.lang.Object

edu.iu.dsc.tws.checkpointing.task.CheckpointingSGatherSink

All Implemented Interfaces:

ICompute<java.util.Iterator<Tuple<java.lang.Integer,java.lang.Long>>>, INode, java.io.Serializable

public class CheckpointingSGatherSink
extends java.lang.Object
implements ICompute<java.util.Iterator<Tuple<java.lang.Integer,java.lang.Long>>>

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	FT_GATHER_EDGE

Constructor Summary

Constructors

Constructor and Description
CheckpointingSGatherSink(java.lang.String parentTaskName)

Method Summary

Modifier and Type	Method and Description
boolean	execute(IMessage<java.util.Iterator<Tuple<java.lang.Integer,java.lang.Long>>> content) Execute with an incoming message
int	getParentTaskId()
void	prepare(Config cfg, TaskContext context) Prepare the task to be executed

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

Field Detail

FT_GATHER_EDGE

public static final java.lang.String FT_GATHER_EDGE

See Also:

Constant Field Values

Constructor Detail

CheckpointingSGatherSink

public CheckpointingSGatherSink(java.lang.String parentTaskName)

Method Detail

getParentTaskId

public int getParentTaskId()

prepare

public void prepare(Config cfg,
                    TaskContext context)

Description copied from interface: INode

Prepare the task to be executed

Specified by:

prepare in interface INode

Parameters:

cfg - the configuration

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

execute

public boolean execute(IMessage<java.util.Iterator<Tuple<java.lang.Integer,java.lang.Long>>> content)

Description copied from interface: ICompute

Execute with an incoming message

Specified by:

execute in interface ICompute<java.util.Iterator<Tuple<java.lang.Integer,java.lang.Long>>>