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

Interface StreamingTupleTSet<K,V>

Type Parameters:

K -

V -

All Superinterfaces:

java.io.Serializable, TBase, TupleTSet<K,V>

All Known Implementing Classes:

SKeyedSourceTSet, SKeyedTSet, StreamingTupleTSetImpl

public interface StreamingTupleTSet<K,V>
extends TupleTSet<K,V>

Streaming extension of TupleTSet interface.

Method Summary

Modifier and Type	Method and Description
StreamingTLink<Tuple<K,V>,Tuple<K,V>>	keyedPartition(PartitionFunc<K> partitionFn) Partitions data using a PartitionFunc based on keys
StreamingTupleTSet<K,V>	setName(java.lang.String name) Name of the tset

Methods inherited from interface edu.iu.dsc.tws.api.tset.sets.TupleTSet

keyedDirect, withSchema

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

getId, getName

Method Detail

setName

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

Name of the tset

Specified by:

setName in interface TBase

Specified by:

setName in interface TupleTSet<K,V>

Parameters:

name - name

Returns:

this tset

keyedPartition

StreamingTLink<Tuple<K,V>,Tuple<K,V>> keyedPartition(PartitionFunc<K> partitionFn)

Partitions data using a PartitionFunc based on keys

Specified by:

keyedPartition in interface TupleTSet<K,V>

Parameters:

partitionFn - partition function

Returns:

Streaming Keyed Partition TLink