public class SolutionSetFastUpdateOutputCollector<T> extends Object implements Collector<T>
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 and Description |
---|
SolutionSetFastUpdateOutputCollector(CompactingHashTable<T> solutionSet) |
SolutionSetFastUpdateOutputCollector(CompactingHashTable<T> solutionSet,
Collector<T> delegate) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the collector.
|
void |
collect(T record)
Emits a record.
|
public SolutionSetFastUpdateOutputCollector(CompactingHashTable<T> solutionSet)
public SolutionSetFastUpdateOutputCollector(CompactingHashTable<T> solutionSet, Collector<T> delegate)
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.