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

Class RowPartitionTLink

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

All Implemented Interfaces:

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

public class RowPartitionTLink
extends RowBatchTLinkImpl

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RowPartitionTLink(BatchEnvironment tSetEnv, int sourceParallelism, RowSchema schema)
RowPartitionTLink(BatchEnvironment tSetEnv, PartitionFunc<Row> parFn, int sourceParallelism, int targetParallelism, RowSchema schema)
RowPartitionTLink(BatchEnvironment tSetEnv, PartitionFunc<Row> parFn, int sourceParallelism, RowSchema schema)

Method Summary

Modifier and Type	Method and Description
protected RowComputeTSet	compute(java.lang.String n, ComputeCollectorFunc<Row,java.util.Iterator<Row>> computeFunction)
Edge	getEdge()
TBase	setName(java.lang.String name) Sets the name for the TBase
RowPartitionTLink	useDisk()

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

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

RowPartitionTLink

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

RowPartitionTLink

public RowPartitionTLink(BatchEnvironment tSetEnv,
                         PartitionFunc<Row> parFn,
                         int sourceParallelism,
                         RowSchema schema)

RowPartitionTLink

public RowPartitionTLink(BatchEnvironment tSetEnv,
                         PartitionFunc<Row> parFn,
                         int sourceParallelism,
                         int targetParallelism,
                         RowSchema schema)

Method Detail

compute

protected RowComputeTSet compute(java.lang.String n,
                                 ComputeCollectorFunc<Row,java.util.Iterator<Row>> computeFunction)

Overrides:

compute in class RowBatchTLinkImpl

getEdge

public Edge getEdge()

useDisk

public RowPartitionTLink useDisk()

setName

public TBase setName(java.lang.String name)

Description copied from interface: TBase

Sets the name for the TBase