org.apache.flink.streaming.api.datastream

Class DataStream.Collector<T>

java.lang.Object

org.apache.flink.streaming.api.datastream.DataStream.Collector<T>

Type Parameters:

T - the element type

Enclosing class:

DataStream<T>

@Experimental
public static class DataStream.Collector<T>
extends Object

This class acts as an accessor to elements collected via DataStream.collectAsync(Collector).

Constructor Summary

Constructors

Constructor and Description
Collector()

Method Summary

Modifier and Type	Method and Description
CloseableIterator<T>	getOutput() Returns an iterator over the collected elements.

Methods inherited from class java.lang.Object

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

Constructor Detail

Collector

public Collector()

Method Detail

getOutput

public CloseableIterator<T> getOutput()

Returns an iterator over the collected elements. The returned iterator must only be used once the job execution was triggered.

This method will always return the same iterator instance.

Returns:

iterator over collected elements