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

Class RowDirectLink

java.lang.Object

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

edu.iu.dsc.tws.tset.links.BaseTLinkWithSchema<Row,Row>

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

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

All Implemented Interfaces:

BatchRowTLink, TBase, Buildable, BuildableTLink, java.io.Serializable

public class RowDirectLink
extends RowBatchTLinkImpl

See Also:

Serialized Form

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
Edge	getEdge()
RowDirectLink	setName(java.lang.String name) Sets the name for the TBase
RowDirectLink	useDisk()

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

cache, compute, compute, flatmap, forEach, getTSetEnv, lazyCache, lazyForEach, lazyPersist, map, persist, 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

RowDirectLink

public RowDirectLink(BatchEnvironment tSetEnv,
                     int sourceParallelism,
                     RowSchema schema)

RowDirectLink

public RowDirectLink(BatchEnvironment tSetEnv,
                     java.lang.String name,
                     int sourceParallelism,
                     RowSchema schema)

Method Detail

setName

public RowDirectLink setName(java.lang.String name)

Description copied from interface: TBase

Sets the name for the TBase

getEdge

public Edge getEdge()

useDisk

public RowDirectLink useDisk()