Collector (Flink : Core 2.2.0 API)

All Known Implementing Classes:

CopyingListCollector, ListCollector
```
@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.