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

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

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 KeyedSourceTSet<K,V>
extends BatchTupleTSetImpl<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
KeyedSourceTSet(BatchEnvironment tSetEnv, SourceFunc<Tuple<K,V>> src, int parallelism)
KeyedSourceTSet(BatchEnvironment tSetEnv, java.lang.String name, SourceFunc<Tuple<K,V>> src, int parallelism)

Method Summary

Modifier and Type	Method and Description
KeyedSourceTSet<K,V>	addInput(java.lang.String key, StorableTBase<?> input) Adds inputs to BatchTupleTSets
INode	getINode()
KeyedSourceTSet<K,V>	setName(java.lang.String name) Name of the tset
KeyedSourceTSet<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

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

KeyedSourceTSet

public KeyedSourceTSet(BatchEnvironment tSetEnv,
                       SourceFunc<Tuple<K,V>> src,
                       int parallelism)

KeyedSourceTSet

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

Method Detail

addInput

public KeyedSourceTSet<K,V> addInput(java.lang.String key,
                                     StorableTBase<?> input)

Description copied from interface: BatchTupleTSet

Adds inputs to BatchTupleTSets

Specified by:

addInput in interface AcceptingData<Tuple<K,V>>

Specified by:

addInput in interface BatchTupleTSet<K,V>

Overrides:

addInput in class BatchTupleTSetImpl<K,V>

Parameters:

key - identifier for the input

input - input tset

Returns:

this tset

withSchema

public KeyedSourceTSet<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 INode getINode()

setName

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

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:

name - name

Returns:

this set