CopyingListCollector (Flink : Core 1.18.1-cp1 API)

java.lang.Object
- org.apache.flink.api.common.functions.util.CopyingListCollector<T>

Type Parameters:

T - The type of the collected elements.

All Implemented Interfaces:

Collector<T>
```
@Internal
public class CopyingListCollector<T>
extends Object
implements Collector<T>
```
A Collector that collects deep copies of its elements in a list.

- Constructor Summary
  
  Constructors
  Constructor Description
  
  CopyingListCollector(List<T> list, TypeSerializer<T> serializer)
- Method Summary
  
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method Description
  
  void close()
  Closes the collector.
  
  void collect(T record)
  Emits a record.
  - Methods inherited from class java.lang.Object
    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - CopyingListCollector
```
public CopyingListCollector(List<T> list,
                            TypeSerializer<T> serializer)
```
- Method Detail
  - collect
```
public void collect(T record)
```
    Description copied from interface: Collector
    
    Emits a record.
    
    Specified by:
    
    collect in interface Collector<T>
    
    Parameters:
    
    record - The record to collect.
  - close
```
public void close()
```
    Description copied from interface: Collector
    
    Closes the collector. If any data was buffered, that data will be flushed.
    
    Specified by:
    
    close in interface Collector<T>