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

Interface RecordCollector<T>

Type Parameters:

T - input type

public interface RecordCollector<T>

Record collector that will be passed on to a ComputeCollectorFunc or FlatMapFunc. Acts as an intermediary between the data transformation and writing the output to the following edges of the data flow graph.

Method Summary

Modifier and Type	Method and Description
void	close() Closes the collector
void	collect(T record) Collects the record

Method Detail

collect

void collect(T record)

Collects the record

Parameters:

record - data record

close

void close()

Closes the collector