edu.iu.dsc.tws.tset.links.batch

Class KeyedGatherTLink<K,V>

java.lang.Object

edu.iu.dsc.tws.tset.links.BaseTLink<T1,T0>

edu.iu.dsc.tws.tset.links.BaseTLinkWithSchema<T1,T0>

edu.iu.dsc.tws.tset.links.batch.BatchTLinkImpl<java.util.Iterator<T>,T>

edu.iu.dsc.tws.tset.links.batch.BatchIteratorLink<Tuple<K,V>>

edu.iu.dsc.tws.tset.links.batch.KeyedBatchIteratorLinkWrapper<K,V>

edu.iu.dsc.tws.tset.links.batch.KeyedGatherUngroupedTLink<K,java.util.Iterator<V>>

edu.iu.dsc.tws.tset.links.batch.KeyedGatherTLink<K,V>

All Implemented Interfaces:

BatchTLink<java.util.Iterator<Tuple<K,java.util.Iterator<V>>>,Tuple<K,java.util.Iterator<V>>>, TLink<java.util.Iterator<Tuple<K,java.util.Iterator<V>>>,Tuple<K,java.util.Iterator<V>>>, StoringData<Tuple<K,java.util.Iterator<V>>>, TBase, Buildable, BuildableTLink, java.io.Serializable

public class KeyedGatherTLink<K,V>
extends KeyedGatherUngroupedTLink<K,java.util.Iterator<V>>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
KeyedGatherTLink(BatchEnvironment tSetEnv, int sourceParallelism, TupleSchema schema)
KeyedGatherTLink(BatchEnvironment tSetEnv, PartitionFunc<K> partitionFn, int sourceParallelism, java.util.Comparator<K> keyCompartor, TupleSchema schema)
KeyedGatherTLink(BatchEnvironment tSetEnv, PartitionFunc<K> partitionFn, int sourceParallelism, TupleSchema schema)

Method Summary

Modifier and Type	Method and Description
KeyedGatherTLink<K,V>	setName(java.lang.String n) Name of the TSet and return the same tlink
KeyedGatherTLink<K,V>	useDisk()

Methods inherited from class edu.iu.dsc.tws.tset.links.batch.KeyedGatherUngroupedTLink

getEdge

Methods inherited from class edu.iu.dsc.tws.tset.links.batch.KeyedBatchIteratorLinkWrapper

cache, getSchema, lazyCache, lazyPersist, persist

Methods inherited from class edu.iu.dsc.tws.tset.links.batch.BatchIteratorLink

flatmap, forEach, lazyForEach, map, mapToTuple

Methods inherited from class edu.iu.dsc.tws.tset.links.batch.BatchTLinkImpl

compute, compute, compute, compute, getTSetEnv, sink

Methods inherited from class edu.iu.dsc.tws.tset.links.BaseTLink

addChildToGraph, equals, getId, getName, getSourceParallelism, getTargetParallelism, hashCode, rename, 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.links.BuildableTLink

build

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

generateID, getTBaseGraph

Constructor Detail

KeyedGatherTLink

public KeyedGatherTLink(BatchEnvironment tSetEnv,
                        int sourceParallelism,
                        TupleSchema schema)

KeyedGatherTLink

public KeyedGatherTLink(BatchEnvironment tSetEnv,
                        PartitionFunc<K> partitionFn,
                        int sourceParallelism,
                        TupleSchema schema)

KeyedGatherTLink

public KeyedGatherTLink(BatchEnvironment tSetEnv,
                        PartitionFunc<K> partitionFn,
                        int sourceParallelism,
                        java.util.Comparator<K> keyCompartor,
                        TupleSchema schema)

Method Detail

useDisk

public KeyedGatherTLink<K,V> useDisk()

Overrides:

useDisk in class KeyedGatherUngroupedTLink<K,java.util.Iterator<V>>

setName

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

Description copied from interface: TLink

Name of the TSet and return the same tlink

Specified by:

setName in interface BatchTLink<java.util.Iterator<Tuple<K,java.util.Iterator<V>>>,Tuple<K,java.util.Iterator<V>>>

Specified by:

setName in interface TLink<java.util.Iterator<Tuple<K,java.util.Iterator<V>>>,Tuple<K,java.util.Iterator<V>>>

Specified by:

setName in interface TBase

Overrides:

setName in class KeyedGatherUngroupedTLink<K,java.util.Iterator<V>>

Parameters:

n - name

Returns:

this tlink