org.apache.flink.streaming.runtime.io

Interface StreamInputProcessor

All Superinterfaces:

AutoCloseable, AvailabilityProvider, Closeable

All Known Implementing Classes:

StreamMultipleInputProcessor, StreamOneInputProcessor, StreamTwoInputProcessor

@Internal
public interface StreamInputProcessor
extends AvailabilityProvider, Closeable

Interface for processing records by StreamTask.

Nested Class Summary

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
CompletableFuture<Void>	prepareSnapshot(ChannelStateWriter channelStateWriter, long checkpointId)
InputStatus	processInput()

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

getAvailableFuture, isApproximatelyAvailable, isAvailable

Methods inherited from interface java.io.Closeable

close

Method Detail

processInput

InputStatus processInput()
                  throws Exception

Returns:

input status to estimate whether more records can be processed immediately or not. If there are no more records available at the moment and the caller should check finished state and/or AvailabilityProvider.getAvailableFuture().

Throws:

Exception

prepareSnapshot

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

Throws:

IOException