org.apache.flink.streaming.runtime.io

Interface PushingAsyncDataInput<T>

All Superinterfaces:

AvailabilityProvider

All Known Subinterfaces:

RecoverableStreamTaskInput<T>, StreamTaskInput<T>

All Known Implementing Classes:

AbstractStreamTaskNetworkInput, MultiInputSortingDataInput, RescalingStreamTaskNetworkInput, SortingDataInput, SourceOperator, StreamTaskExternallyInducedSourceInput, StreamTaskFinishedOnRestoreSourceInput, StreamTaskNetworkInput, StreamTaskSourceInput

@Internal
public interface PushingAsyncDataInput<T>
extends AvailabilityProvider

The variant of PullingAsyncDataInput that is defined for handling both network input and source input in a unified way via emitNext(DataOutput) instead of returning Optional.empty() via PullingAsyncDataInput.pollNext().

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	PushingAsyncDataInput.DataOutput<T> Basic data output interface used in emitting the next element from data input.

Nested classes/interfaces inherited from interface org.apache.flink.runtime.io.AvailabilityProvider

AvailabilityProvider.AvailabilityHelper

Field Summary

Fields inherited from interface org.apache.flink.runtime.io.AvailabilityProvider

AVAILABLE

Method Summary

Modifier and Type	Method and Description
DataInputStatus	emitNext(PushingAsyncDataInput.DataOutput<T> output) Pushes elements to the output from current data input, and returns the input status to indicate whether there are more available data in current input.

Methods inherited from interface org.apache.flink.runtime.io.AvailabilityProvider

and, getAvailableFuture, isApproximatelyAvailable, isAvailable, or

Method Detail

emitNext

DataInputStatus emitNext(PushingAsyncDataInput.DataOutput<T> output)
                  throws Exception

Pushes elements to the output from current data input, and returns the input status to indicate whether there are more available data in current input.

This method should be non blocking.

Throws:

Exception