org.apache.flink.runtime.iterative.io

Class WorksetUpdateOutputCollector<T>

java.lang.Object

org.apache.flink.runtime.iterative.io.WorksetUpdateOutputCollector<T>

All Implemented Interfaces:

Collector<T>

public class WorksetUpdateOutputCollector<T>
extends Object
implements Collector<T>

A 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 Summary

Constructors

Constructor and Description
WorksetUpdateOutputCollector(DataOutputView outputView, TypeSerializer<T> serializer)
WorksetUpdateOutputCollector(DataOutputView outputView, TypeSerializer<T> serializer, Collector<T> delegate)

Method Summary

Modifier and Type	Method and Description
void	close() Closes the collector.
void	collect(T record) Emits a record.
long	getElementsCollectedAndReset()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WorksetUpdateOutputCollector

public WorksetUpdateOutputCollector(DataOutputView outputView,
                                    TypeSerializer<T> serializer)

WorksetUpdateOutputCollector

public WorksetUpdateOutputCollector(DataOutputView outputView,
                                    TypeSerializer<T> serializer,
                                    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.

getElementsCollectedAndReset

public long getElementsCollectedAndReset()

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>