Package edu.iu.dsc.tws.api.tset.fn

Interface Summary

Interface	Description
ApplyFunc<T>	Applies a function to data
ComputeCollectorFunc<O,I>	Computes an output of type O based on an input of type I and the output would be passed on to a RecordCollector object.
ComputeFunc<O,I>	Computes an output of type O based on an input of type I
FlatMapFunc<O,I>	Flat map function
MapFunc<O,I>	Map function, one input and one output
PartitionFunc<T>	Given a data, give the partition index
RecordCollector<T>	Record collector that will be passed on to a ComputeCollectorFunc or FlatMapFunc.
ReduceFunc<T>	Reduce function wrapping the IFunction from the communication layer
SelectorFunc<K,V>	Given a data T, selects a Key K
SinkFunc<T>	Adds data sink at the end of the graph.
SourceFunc<T>	Represents a source producing values
TFunction<O,I>	Base class for all the functions in TSet implementation

Class Summary

Class	Description
BaseApplyFunc<T>
BaseComputeCollectorFunc<O,I>	Extended ComputeCollectorFunc with access to TSetContext
BaseComputeFunc<O,I>	Extended ComputeFunc with access to TSetContext
BaseMapFunc<O,I>	Extended MapFunc with access to TSetContext
BaseSinkFunc<T>	Extended SinkFunc with access to TSetContext
BaseSourceFunc<T>	Extended SourceFunc with access to TSetContext
BaseTFunction<O,I>