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

Class SKeyedTSet<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.SKeyedTSet<K,V>

Type Parameters:

K - key type

V - data (value) type

All Implemented Interfaces:

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

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

Attaches a key to the oncoming data.

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
SKeyedTSet(StreamingEnvironment tSetEnv, TFunction<Tuple<K,V>,?> mapFn, int parallelism, Schema inputSchema)

Method Summary

Modifier and Type	Method and Description
ICompute	getINode()
SKeyedTSet<K,V>	setName(java.lang.String name) Name of the tset
SKeyedTSet<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

SKeyedTSet

public SKeyedTSet(StreamingEnvironment tSetEnv,
                  TFunction<Tuple<K,V>,?> mapFn,
                  int parallelism,
                  Schema inputSchema)

Method Detail

setName

public SKeyedTSet<K,V> setName(java.lang.String name)

Description copied from interface: StreamingTupleTSet

Name of the tset

Parameters:

name - name

Returns:

this tset

withSchema

public SKeyedTSet<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 ICompute getINode()