PushingAsyncDataInput (Flink : Streaming Java 1.19.3-cp1 API)

All Superinterfaces:

org.apache.flink.runtime.io.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 org.apache.flink.runtime.io.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 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
  org.apache.flink.runtime.io.AvailabilityProvider.AvailabilityHelper

Field Summary
- Fields inherited from interface org.apache.flink.runtime.io.AvailabilityProvider
  AVAILABLE

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	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
getAvailableFuture, isApproximatelyAvailable, isAvailable

- 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