public class WorksetUpdateOutputCollector<T> extends Object implements Collector<T>
Collector
to update the iteration workset (partial solution for bulk iterations).
The records are written to a DataOutputView
to allow in-memory data exchange.
Constructor and Description |
---|
WorksetUpdateOutputCollector(DataOutputView outputView,
TypeSerializer<T> serializer) |
WorksetUpdateOutputCollector(DataOutputView outputView,
TypeSerializer<T> serializer,
Collector<T> delegate) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the collector.
|
void |
collect(T record)
Emits a record.
|
long |
getElementsCollectedAndReset() |
public WorksetUpdateOutputCollector(DataOutputView outputView, TypeSerializer<T> serializer)
public WorksetUpdateOutputCollector(DataOutputView outputView, TypeSerializer<T> serializer, Collector<T> delegate)
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.