SolutionSetFastUpdateOutputCollector (Flink : 2.0-preview1 API)

java.lang.Object
- org.apache.flink.runtime.iterative.io.SolutionSetFastUpdateOutputCollector<T>

All Implemented Interfaces:

Collector<T>
```
public class SolutionSetFastUpdateOutputCollector<T>
extends Object
implements Collector<T>
```
A Collector to update the solution set of a workset iteration.
The records are written to a hash table to allow in-memory point updates.
Assumption for fast updates: the build side iterator of the hash table is already positioned for the update. This is for example the case when a solution set update happens directly after a solution set join. If this assumption doesn't hold, use SolutionSetUpdateOutputCollector, which probes the hash table before updating.

Constructor Summary

Constructors
Constructor	Description
`SolutionSetFastUpdateOutputCollector(CompactingHashTable<T> solutionSet)`
`SolutionSetFastUpdateOutputCollector(CompactingHashTable<T> solutionSet, Collector<T> delegate)`

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
  - SolutionSetFastUpdateOutputCollector
```
public SolutionSetFastUpdateOutputCollector(CompactingHashTable<T> solutionSet)
```
  - SolutionSetFastUpdateOutputCollector
```
public SolutionSetFastUpdateOutputCollector(CompactingHashTable<T> solutionSet,
                                            Collector<T> delegate)
```
- 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>