edu.iu.dsc.tws.tset.sets.streaming

Class SKeyedSourceTSet<K,V>

java.lang.Object

edu.iu.dsc.tws.tset.sets.BaseTSet<T>

edu.iu.dsc.tws.tset.sets.BaseTSetWithSchema<V>

edu.iu.dsc.tws.tset.sets.streaming.StreamingTupleTSetImpl<K,V>

edu.iu.dsc.tws.tset.sets.streaming.SKeyedSourceTSet<K,V>

All Implemented Interfaces:

StreamingTupleTSet<K,V>, TupleTSet<K,V>, TBase, Buildable, BuildableTSet, java.io.Serializable

public class SKeyedSourceTSet<K,V>
extends StreamingTupleTSetImpl<K,V>

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class edu.iu.dsc.tws.tset.sets.BaseTSet

BaseTSet.StateType

Constructor Summary

Constructors

Constructor and Description
SKeyedSourceTSet(StreamingEnvironment tSetEnv, SourceFunc<Tuple<K,V>> src, int parallelism)
SKeyedSourceTSet(StreamingEnvironment tSetEnv, java.lang.String name, SourceFunc<Tuple<K,V>> src, int parallelism)

Method Summary

Modifier and Type	Method and Description
INode	getINode()
SKeyedSourceTSet<K,V>	setName(java.lang.String n) Name of the tset
SKeyedSourceTSet<K,V>	withSchema(TupleSchema schema) Sets the data type of the TupleTSet output.

Methods inherited from class edu.iu.dsc.tws.tset.sets.streaming.StreamingTupleTSetImpl

getOutputSchema, getTSetEnv, keyedDirect, keyedPartition

Methods inherited from class edu.iu.dsc.tws.tset.sets.BaseTSetWithSchema

getInputSchema, setOutputSchema

Methods inherited from class edu.iu.dsc.tws.tset.sets.BaseTSet

addChildToGraph, addChildToGraph, equals, getId, getInputs, getName, getParallelism, getStateType, hashCode, isMutable, rename, setMutable, setStateType, setTSetEnv, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface edu.iu.dsc.tws.api.tset.TBase

getId, getName

Methods inherited from interface edu.iu.dsc.tws.tset.sets.BuildableTSet

build

Methods inherited from interface edu.iu.dsc.tws.tset.Buildable

generateID, getTBaseGraph

Constructor Detail

SKeyedSourceTSet

public SKeyedSourceTSet(StreamingEnvironment tSetEnv,
                        SourceFunc<Tuple<K,V>> src,
                        int parallelism)

SKeyedSourceTSet

public SKeyedSourceTSet(StreamingEnvironment tSetEnv,
                        java.lang.String name,
                        SourceFunc<Tuple<K,V>> src,
                        int parallelism)

Method Detail

setName

public SKeyedSourceTSet<K,V> setName(java.lang.String n)

Description copied from interface: StreamingTupleTSet

Name of the tset

Parameters:

n - name

Returns:

this tset

withSchema

public SKeyedSourceTSet<K,V> withSchema(TupleSchema schema)

Description copied from interface: TupleTSet

Sets the data type of the TupleTSet output. This will be used in the packers for efficient SER-DE operations in the following TLinks

Specified by:

withSchema in interface TupleTSet<K,V>

Overrides:

withSchema in class StreamingTupleTSetImpl<K,V>

Parameters:

schema - data type as a MessageType

Returns:

this TupleTSet

getINode

public INode getINode()