org.apache.flink.streaming.runtime.io

Class StreamTaskExternallyInducedSourceInput<T>

java.lang.Object

org.apache.flink.streaming.runtime.io.StreamTaskSourceInput<T>

org.apache.flink.streaming.runtime.io.StreamTaskExternallyInducedSourceInput<T>

All Implemented Interfaces:

Closeable, AutoCloseable, AvailabilityProvider, CheckpointableInput, PushingAsyncDataInput<T>, StreamTaskInput<T>

public class StreamTaskExternallyInducedSourceInput<T>
extends StreamTaskSourceInput<T>

A subclass of StreamTaskSourceInput for ExternallyInducedSourceReader.

Nested Class Summary

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

PushingAsyncDataInput.DataOutput<T>

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

AvailabilityProvider.AvailabilityHelper

Field Summary

Fields inherited from interface org.apache.flink.streaming.runtime.io.StreamTaskInput

UNSPECIFIED

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

AVAILABLE

Constructor Summary

Constructors

Constructor and Description
StreamTaskExternallyInducedSourceInput(SourceOperator<T,?> operator, java.util.function.Consumer<Long> checkpointTriggeringHook, int inputGateIndex, int inputIndex)

Method Summary

Modifier and Type	Method and Description
InputStatus	emitNext(PushingAsyncDataInput.DataOutput<T> output) Pushes the next element 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 class org.apache.flink.streaming.runtime.io.StreamTaskSourceInput

blockConsumption, checkpointStarted, checkpointStopped, close, getAvailableFuture, getChannelInfos, getInputGateIndex, getInputIndex, getNumberOfInputChannels, getOperatorID, prepareSnapshot, resumeConsumption

Methods inherited from class java.lang.Object

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

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

and, isApproximatelyAvailable, isAvailable, or

Constructor Detail

StreamTaskExternallyInducedSourceInput

public StreamTaskExternallyInducedSourceInput(SourceOperator<T,?> operator,
                                              java.util.function.Consumer<Long> checkpointTriggeringHook,
                                              int inputGateIndex,
                                              int inputIndex)

Method Detail

emitNext

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

Description copied from interface: PushingAsyncDataInput

Pushes the next element 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.

Specified by:

emitNext in interface PushingAsyncDataInput<T>

Overrides:

emitNext in class StreamTaskSourceInput<T>

Throws:

Exception