org.apache.flink.util

Interface Collector<T>

All Known Subinterfaces:

OperatorChain.WatermarkGaugeExposingOutput<T>, Output<T>, TableAggregateFunction.RetractableCollector<T>

All Known Implementing Classes:

AbstractStatelessFunctionOperator.StreamRecordCRowWrappingCollector, AbstractStatelessFunctionOperator.StreamRecordRowDataWrappingCollector, ChainedAllReduceDriver, ChainedDriver, ChainedFlatMapDriver, ChainedMapDriver, ChainedReduceCombineDriver, ChainedTerminationCriterionDriver, CopyingDirectedOutput, CopyingListCollector, CountingCollector, CountingOutput, DirectedOutput, ListCollector, NoOpChainedDriver, OutputCollector, RecordWriterOutput, SolutionSetFastUpdateOutputCollector, SolutionSetObjectsUpdateOutputCollector, SolutionSetUpdateOutputCollector, StreamRecordCollector, SynchronousChainedCombineDriver, TableFunctionCollector, TimestampedCollector, Tuple3WrappingCollector, TupleWrappingCollector, WorksetUpdateOutputCollector, WrappingCollector

@Public
public interface Collector<T>

Collects a record and forwards it. The collector is the "push" counterpart of the Iterator, which "pulls" data in.

Method Summary

Modifier and Type	Method and Description
void	close() Closes the collector.
void	collect(T record) Emits a record.

Method Detail

collect

void collect(T record)

Emits a record.

Parameters:

record - The record to collect.

close

void close()

Closes the collector. If any data was buffered, that data will be flushed.