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

Interface TFunction<O,I>

All Superinterfaces:

java.io.Serializable

All Known Subinterfaces:

AggregateFunc<T>, ApplyFunc<T>, ComputeCollectorFunc<O,I>, ComputeFunc<O,I>, FlatMapFunc<O,I>, MapFunc<O,I>, ReduceFunc<T>, SelectorFunc<K,V>, SinkFunc<T>, SourceFunc<T>, WindowComputeFunc<O,I>

All Known Implementing Classes:

AccuracyAverager, ApplyFunctions.ApplyFuncImpl, ArrowBasedSinkFunction, ArrowBasedSourceFunction, AssignWindowsFunction, BaseApplyFunc, BaseComputeCollectorFunc, BaseComputeFunc, BaseDiskPersistIterSink, BaseMapFunc, BaseSinkFunc, BaseSourceFunc, BaseTFunction, BaseTSetBatchWorker.TestBaseSource, ByteToWindowFunction, CacheGatherSink, CacheIterSink, CacheSingleSink, CollectionSource, ComputeFunctions.ComputeFuncImpl, ComputeWithCollectorFunctions.ComputeFuncImpl, CSVBasedSourceFunction, DataLoadingTask, DataPartitionSourceFunc, DiskPartitionBackedSource, DiskPartitionBackedSourceWrapper, DiskPersistGatherIterSink, DiskPersistIterIterSink, DiskPersistSingleSink, DoFnFunction, FileIterSink, FileSink, FileSource, FlatMapCompute, FlatMapFunctions.FlatMapFuncImpl, FlatMapIterCompute, ForEachCompute, ForEachIterCompute, GatherFlatMapCompute, GatherForEachCompute, GatherMapCompute, GroupByWindowFunction, HadoopSource, HadoopSourceWithMap, IdentityFunction, IdentitySelector, KMeansTsetJob.CenterSource, ListBasedSourceFunction, MapBasedSourceFunction, MapCompute, MapIterCompute, MapToTupleFunction, ModelAverager, OutputTagFilter, ProcessWindowCompute, PyTSetKeyedSource, PyTSetSource, ReduceFunctions.ReduceFuncImpl, RowFlatMapCompute, RowForEachCompute, RowMapCompute, SideInputSinkFunction, StoreIterSink, StreamingCacheSink, StreamingDiskPersistSink, SvmTestMap, SvmTrainMap, TextBasedSourceFunction, Twister2BoundedSource, Twister2SinkFunction, WeightVectorAverager, WeightVectorLoad

public interface TFunction<O,I>
extends java.io.Serializable

Base class for all the functions in TSet implementation

Method Summary

Modifier and Type	Method and Description
default void	close()
default void	end() Calls at the end of the message stream
default void	prepare(TSetContext context) Prepare the function.

Method Detail

prepare

default void prepare(TSetContext context)

Prepare the function. Use this context in case you need to add/get inputs

Parameters:

context - CONTEXT

end

default void end()

Calls at the end of the message stream

close

default void close()