edu.iu.dsc.tws.tset.sets.batch

Class KeyedTSet<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.batch.BatchTupleTSetImpl<K,V>

edu.iu.dsc.tws.tset.sets.batch.KeyedTSet<K,V>

Type Parameters:

K - key type

V - data (value) type

All Implemented Interfaces:

AcceptingData<Tuple<K,V>>, BatchTupleTSet<K,V>, TupleTSet<K,V>, StoringData<Tuple<K,V>>, TBase, Buildable, BuildableTSet, java.io.Serializable

public class KeyedTSet<K,V>
extends BatchTupleTSetImpl<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
KeyedTSet(BatchEnvironment tSetEnv, TFunction<Tuple<K,V>,?> mapFunc, int parallelism, Schema inputSchema) NOTE: KeyedTSets input usually comes from a non keyed TLink.

Method Summary

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

Methods inherited from class edu.iu.dsc.tws.tset.sets.batch.BatchTupleTSetImpl

addInput, cache, getOutputSchema, getTSetEnv, join, join, keyedDirect, keyedGather, keyedGather, keyedGather, keyedGatherUngrouped, keyedGatherUngrouped, keyedGatherUngrouped, keyedPartition, keyedPipe, keyedReduce, lazyCache, lazyPersist, persist

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

KeyedTSet

public KeyedTSet(BatchEnvironment tSetEnv,
                 TFunction<Tuple<K,V>,?> mapFunc,
                 int parallelism,
                 Schema inputSchema)

NOTE: KeyedTSets input usually comes from a non keyed TLink. Hence the input schema is a not a KeyedSchema

Method Detail

setName

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

Description copied from interface: BatchTupleTSet

Name of the tset

Specified by:

setName in interface BatchTupleTSet<K,V>

Specified by:

setName in interface TupleTSet<K,V>

Specified by:

setName in interface TBase

Overrides:

setName in class BatchTupleTSetImpl<K,V>

Parameters:

n - name

Returns:

this set

withSchema

public KeyedTSet<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 BatchTupleTSetImpl<K,V>

Parameters:

schema - data type as a MessageType

Returns:

this TupleTSet

getINode

public ICompute getINode()