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

Class RowBatchTLinkImpl

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

All Implemented Interfaces:

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

Direct Known Subclasses:

RowDirectLink, RowPartitionTLink, RowPipeTLink

public abstract class RowBatchTLinkImpl
extends BaseTLinkWithSchema<Row,Row>
implements BatchRowTLink

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
StorableTBase<Row>	cache()
RowComputeTSet	compute(ComputeCollectorFunc<Row,java.util.Iterator<Row>> computeFunction)
protected RowComputeTSet	compute(java.lang.String n, ComputeCollectorFunc<Row,java.util.Iterator<Row>> computeFunction)
BatchRowTSet	flatmap(FlatMapFunc<Row,Row> mapFn)
void	forEach(ApplyFunc<Row> applyFunction)
BatchEnvironment	getTSetEnv() tset env
StorableTBase<Row>	lazyCache()
BatchRowTSet	lazyForEach(ApplyFunc<Row> applyFunction)
StorableTBase<Row>	lazyPersist()
BatchRowTSet	map(MapFunc<Row,Row> mapFn)
StorableTBase<Row>	persist()
RowSinkTSet	sink(SinkFunc<Row> sinkFunction)

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

Methods inherited from interface edu.iu.dsc.tws.tset.links.BuildableTLink

build, getEdge

Methods inherited from interface edu.iu.dsc.tws.tset.Buildable

generateID, getTBaseGraph

Method Detail

getTSetEnv

public BatchEnvironment getTSetEnv()

Description copied from interface: Buildable

tset env

Specified by:

getTSetEnv in interface Buildable

Overrides:

getTSetEnv in class BaseTLink<Row,Row>

Returns:

tset env

compute

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

compute

public RowComputeTSet compute(ComputeCollectorFunc<Row,java.util.Iterator<Row>> computeFunction)

Specified by:

compute in interface BatchRowTLink

map

public BatchRowTSet map(MapFunc<Row,Row> mapFn)

Specified by:

map in interface BatchRowTLink

flatmap

public BatchRowTSet flatmap(FlatMapFunc<Row,Row> mapFn)

Specified by:

flatmap in interface BatchRowTLink

forEach

public void forEach(ApplyFunc<Row> applyFunction)

Specified by:

forEach in interface BatchRowTLink

lazyForEach

public BatchRowTSet lazyForEach(ApplyFunc<Row> applyFunction)

Specified by:

lazyForEach in interface BatchRowTLink

lazyCache

public StorableTBase<Row> lazyCache()

lazyPersist

public StorableTBase<Row> lazyPersist()

sink

public RowSinkTSet sink(SinkFunc<Row> sinkFunction)

Specified by:

sink in interface BatchRowTLink

cache

public StorableTBase<Row> cache()

persist

public StorableTBase<Row> persist()