Collector (Flink : 2.0-SNAPSHOT API)

All Known Subinterfaces:

Output<T>, OutputWithChainingCheck<OUT>, TableAggregateFunction.RetractableCollector<T>, WatermarkGaugeExposingOutput<T>

All Known Implementing Classes:

BroadcastingOutput, ChainedAllReduceDriver, ChainedDriver, ChainedFlatMapDriver, ChainedMapDriver, ChainedReduceCombineDriver, CopyingBroadcastingOutput, CopyingFirstInputOfTwoInputStreamOperatorOutput, CopyingListCollector, CopyingOneInputStreamOperatorOutput, CopyingSecondInputOfTwoInputStreamOperatorOutput, CountingCollector, CountingOutput, FinishedOnRestoreMainOperatorOutput, FirstInputOfTwoInputStreamOperatorOutput, ListCollector, ListenableCollector, NoOpChainedDriver, OneInputStreamOperatorOutput, OutputBase, OutputCollector, RecordWriterOutput, RunnerOutputCollector, SecondInputOfTwoInputStreamOperatorOutput, SolutionSetFastUpdateOutputCollector, SolutionSetObjectsUpdateOutputCollector, SolutionSetUpdateOutputCollector, StreamRecordCollector, StreamRecordRowDataWrappingCollector, SynchronousChainedCombineDriver, TableFunctionCollector, TimestampedCollector, 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
  
  All Methods Instance Methods Abstract Methods
  Modifier and Type Method 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.