Package org.apache.flink.streaming.runtime.io

Interface RecoverableStreamTaskInput<T>

All Superinterfaces:

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

All Known Implementing Classes:

RescalingStreamTaskNetworkInput

public interface RecoverableStreamTaskInput<T>
extends StreamTaskInput<T>

A StreamTaskInput used during recovery of in-flight data. It's converted to a more efficient StreamTaskInput after recovery finished.

Nested Class Summary

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

AvailabilityProvider.AvailabilityHelper

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

PushingAsyncDataInput.DataOutput<T>

Field Summary

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

AVAILABLE

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

UNSPECIFIED

Method Summary

Modifier and Type	Method	Description
StreamTaskInput<T>	finishRecovery()

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

getAvailableFuture, isApproximatelyAvailable, isAvailable

Methods inherited from interface java.io.Closeable

close

Methods inherited from interface org.apache.flink.streaming.runtime.io.PushingAsyncDataInput

emitNext

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

getInputIndex, prepareSnapshot

Method Detail

finishRecovery

StreamTaskInput<T> finishRecovery()
                           throws IOException

Throws:

IOException