edu.iu.dsc.tws.tset.ops

Class KeyedSourceOp<K,V>

java.lang.Object

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

edu.iu.dsc.tws.tset.ops.SourceOp<Tuple<K,V>>

edu.iu.dsc.tws.tset.ops.KeyedSourceOp<K,V>

Type Parameters:

K -

V -

All Implemented Interfaces:

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

public class KeyedSourceOp<K,V>
extends SourceOp<Tuple<K,V>>

Identical to SourceOp. Only difference is that it would write to edges by calling multiEdgeOpAdapter keyedWriteToEdges method

See Also:

Serialized Form

Field Summary

Fields inherited from class edu.iu.dsc.tws.tset.ops.SourceOp

multiEdgeOpAdapter, source

Constructor Summary

Constructors

Constructor and Description
KeyedSourceOp()
KeyedSourceOp(SourceFunc<Tuple<K,V>> src, BaseTSet originTSet, java.util.Map<java.lang.String,java.lang.String> receivables)

Method Summary

Modifier and Type	Method and Description
void	execute() Execute without an incoming message

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

close, prepare

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

Constructor Detail

KeyedSourceOp

public KeyedSourceOp()

KeyedSourceOp

public KeyedSourceOp(SourceFunc<Tuple<K,V>> src,
                     BaseTSet originTSet,
                     java.util.Map<java.lang.String,java.lang.String> receivables)

Method Detail

execute

public void execute()

Description copied from interface: ISource

Execute without an incoming message

Specified by:

execute in interface ISource

Overrides:

execute in class SourceOp<Tuple<K,V>>