SolutionSetObjectsUpdateOutputCollector (Flink : 2.0-SNAPSHOT API)

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

All Implemented Interfaces:

Collector<T>
```
public class SolutionSetObjectsUpdateOutputCollector<T>
extends Object
implements Collector<T>
```
A Collector to update the solution set of a workset iteration.
The records are written to a HashTable hash table to allow in-memory point updates.
Records will only be collected, if there is a match after probing the hash table. If the build side iterator is already positioned for the update, use SolutionSetFastUpdateOutputCollector to the save re-probing.

See Also:

SolutionSetFastUpdateOutputCollector

Constructor Summary

Constructors
Constructor	Description
`SolutionSetObjectsUpdateOutputCollector(JoinHashMap<T> hashMap)`
`SolutionSetObjectsUpdateOutputCollector(JoinHashMap<T> hashMap, 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
  - SolutionSetObjectsUpdateOutputCollector
```
public SolutionSetObjectsUpdateOutputCollector(JoinHashMap<T> hashMap)
```
  - SolutionSetObjectsUpdateOutputCollector
```
public SolutionSetObjectsUpdateOutputCollector(JoinHashMap<T> hashMap,
                                               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>