org.apache.flink.streaming.runtime.io

Class StreamTaskSourceInput<T>

java.lang.Object

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

All Implemented Interfaces:

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

Direct Known Subclasses:

StreamTaskExternallyInducedSourceInput

@Internal
public class StreamTaskSourceInput<T>
extends Object
implements StreamTaskInput<T>

Implementation of StreamTaskInput that reads data from the SourceOperator and returns the InputStatus to indicate whether the source state is available, unavailable or finished.

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
StreamTaskSourceInput(SourceOperator<T,?> operator)

Method Summary

Modifier and Type	Method and Description
void	close()
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.
CompletableFuture<?>	getAvailableFuture()
int	getInputIndex() This method is invalid and never called by the one/source input processor.
CompletableFuture<Void>	prepareSnapshot(ChannelStateWriter channelStateWriter, long checkpointId) Prepares to spill the in-flight input buffers as checkpoint snapshot.

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

isApproximatelyAvailable, isAvailable

Constructor Detail

StreamTaskSourceInput

public StreamTaskSourceInput(SourceOperator<T,?> operator)

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>

Throws:

Exception

getAvailableFuture

public CompletableFuture<?> getAvailableFuture()

Specified by:

getAvailableFuture in interface AvailabilityProvider

Returns:

a future that is completed if the respective provider is available.

getInputIndex

public int getInputIndex()

This method is invalid and never called by the one/source input processor.

Specified by:

getInputIndex in interface StreamTaskInput<T>

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

prepareSnapshot

public CompletableFuture<Void> prepareSnapshot(ChannelStateWriter channelStateWriter,
                                               long checkpointId)

Description copied from interface: StreamTaskInput

Prepares to spill the in-flight input buffers as checkpoint snapshot.

Specified by:

prepareSnapshot in interface StreamTaskInput<T>