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

Class GatherTLink<T>

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<Tuple<java.lang.Integer,T>>,T>

edu.iu.dsc.tws.tset.links.batch.BatchGatherLink<T>

edu.iu.dsc.tws.tset.links.batch.GatherTLink<T>

Type Parameters:

T - the type of data

All Implemented Interfaces:

BatchTLink<java.util.Iterator<Tuple<java.lang.Integer,T>>,T>, TLink<java.util.Iterator<Tuple<java.lang.Integer,T>>,T>, StoringData<T>, TBase, Buildable, BuildableTLink, java.io.Serializable

public class GatherTLink<T>
extends BatchGatherLink<T>

Create a gather data set

Gather comms message content signature is Iterator<Tuple<Integer, T>>. Here, the tuple is artificially created by the comms layer, and users would have very little idea about it. Hence, the tuple, needs to be broken apart, and only values need to be considered for compute operations like map, flatmap, foreach etc.

but, for the generic compute, Iterator<Tuple<Integer, T>> messages are valid.

Because of this reason, we can not use, IteratorLink<Tuple<Integer, T>>

Same logic applies to AllGather TLink

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GatherTLink(BatchEnvironment tSetEnv, int sourceParallelism, Schema schema)

Method Summary

Modifier and Type	Method and Description
Edge	getEdge()
GatherTLink<T>	setName(java.lang.String n) Name of the TSet and return the same tlink
GatherTLink<T>	useDisk()

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

cache, flatmap, forEach, lazyCache, lazyForEach, lazyPersist, map, mapToTuple, persist

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.BaseTLinkWithSchema

getSchema

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

GatherTLink

public GatherTLink(BatchEnvironment tSetEnv,
                   int sourceParallelism,
                   Schema schema)

Method Detail

getEdge

public Edge getEdge()

setName

public GatherTLink<T> setName(java.lang.String n)

Description copied from interface: TLink

Name of the TSet and return the same tlink

Parameters:

n - name

Returns:

this tlink

useDisk

public GatherTLink<T> useDisk()