edu.iu.dsc.tws.api.tset.link.batch

Interface BatchRowTLink

All Superinterfaces:

java.io.Serializable, TBase

All Known Implementing Classes:

RowBatchTLinkImpl, RowDirectLink, RowPartitionTLink, RowPipeTLink

public interface BatchRowTLink
extends TBase

Table based communication links.

Method Summary

Modifier and Type	Method and Description
BatchRowTSet	compute(ComputeCollectorFunc<Row,java.util.Iterator<Row>> computeFunction)
BatchRowTSet	flatmap(FlatMapFunc<Row,Row> mapFn)
void	forEach(ApplyFunc<Row> applyFunction)
BatchRowTSet	lazyForEach(ApplyFunc<Row> applyFunction)
BatchRowTSet	map(MapFunc<Row,Row> mapFn)
TBase	sink(SinkFunc<Row> sinkFunction)

Methods inherited from interface edu.iu.dsc.tws.api.tset.TBase

getId, getName, setName

Method Detail

compute

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

map

BatchRowTSet map(MapFunc<Row,Row> mapFn)

flatmap

BatchRowTSet flatmap(FlatMapFunc<Row,Row> mapFn)

sink

TBase sink(SinkFunc<Row> sinkFunction)

forEach

void forEach(ApplyFunc<Row> applyFunction)

lazyForEach

BatchRowTSet lazyForEach(ApplyFunc<Row> applyFunction)