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

Class DirectTLink<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<T>,T>

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

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

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

All Implemented Interfaces:

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

public class DirectTLink<T>
extends BatchIteratorLinkWrapper<T>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DirectTLink(BatchEnvironment tSetEnv, int sourceParallelism, Schema schema)
DirectTLink(BatchEnvironment tSetEnv, java.lang.String name, int sourceParallelism, Schema schema)

Method Summary

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

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

cache, 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.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

DirectTLink

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

DirectTLink

public DirectTLink(BatchEnvironment tSetEnv,
                   java.lang.String name,
                   int sourceParallelism,
                   Schema schema)

Method Detail

setName

public DirectTLink<T> setName(java.lang.String name)

Description copied from interface: TLink

Name of the TSet and return the same tlink

Parameters:

name - name

Returns:

this tlink

getEdge

public Edge getEdge()

useDisk

public DirectTLink<T> useDisk()