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

Interface ComputeCollectorFunc<O,I>

Type Parameters:

O - output type

I - input type

All Superinterfaces:

java.io.Serializable, TFunction<O,I>

All Known Implementing Classes:

AssignWindowsFunction, BaseComputeCollectorFunc, ComputeWithCollectorFunctions.ComputeFuncImpl, DoFnFunction, FlatMapCompute, FlatMapIterCompute, GatherFlatMapCompute, GatherMapCompute, MapIterCompute, OutputTagFilter, RowFlatMapCompute, RowForEachCompute, RowMapCompute

public interface ComputeCollectorFunc<O,I>
extends TFunction<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.

Method Summary

Modifier and Type	Method and Description
void	compute(I input, RecordCollector<O> output)

Methods inherited from interface edu.iu.dsc.tws.api.tset.fn.TFunction

close, end, prepare

Method Detail

compute

void compute(I input,
             RecordCollector<O> output)