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

Class RowPipeTLink

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

All Implemented Interfaces:

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

public class RowPipeTLink
extends RowBatchTLinkImpl

See Also:

Serialized Form

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
Edge	getEdge()
RowPipeTLink	setName(java.lang.String name) Sets the name for the TBase
RowPipeTLink	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

RowPipeTLink

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

RowPipeTLink

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

Method Detail

setName

public RowPipeTLink setName(java.lang.String name)

Description copied from interface: TBase

Sets the name for the TBase

getEdge

public Edge getEdge()

useDisk

public RowPipeTLink useDisk()