edu.iu.dsc.tws.tset.ops

Class SourceOp<T>

java.lang.Object

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

edu.iu.dsc.tws.tset.ops.SourceOp<T>

All Implemented Interfaces:

Closable, Receptor, INode, ISource, java.io.Serializable

Direct Known Subclasses:

CheckpointedSourceOp, KeyedSourceOp, RowSourceOp

public class SourceOp<T>
extends BaseOp
implements ISource, Closable

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected MultiEdgeOpAdapter	multiEdgeOpAdapter
protected SourceFunc<T>	source

Constructor Summary

Constructors

Constructor and Description
SourceOp()
SourceOp(SourceFunc<T> src, BaseTSet originTSet, java.util.Map<java.lang.String,java.lang.String> receivables)

Method Summary

Modifier and Type	Method and Description
void	close() Close method for cleaning up the resources
void	execute() Execute without an incoming message
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.modifiers.Closable

reset

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

add

Field Detail

multiEdgeOpAdapter

protected MultiEdgeOpAdapter multiEdgeOpAdapter

source

protected SourceFunc<T> source

Constructor Detail

SourceOp

public SourceOp()

SourceOp

public SourceOp(SourceFunc<T> src,
                BaseTSet originTSet,
                java.util.Map<java.lang.String,java.lang.String> receivables)

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 void execute()

Description copied from interface: ISource

Execute without an incoming message

Specified by:

execute in interface ISource

close

public void close()

Description copied from interface: Closable

Close method for cleaning up the resources

Specified by:

close in interface Closable