Uses of Package
org.apache.flink.runtime.io

Packages that use org.apache.flink.runtime.io

Package	Description
org.apache.flink.changelog.fs
org.apache.flink.runtime.io
org.apache.flink.runtime.io.network.api.writer
org.apache.flink.runtime.io.network.buffer
org.apache.flink.runtime.io.network.partition
org.apache.flink.runtime.io.network.partition.consumer
org.apache.flink.runtime.state.changelog
org.apache.flink.runtime.taskmanager
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.operators.sort
org.apache.flink.streaming.runtime.io
org.apache.flink.streaming.runtime.io.checkpointing
org.apache.flink.streaming.runtime.io.recovery
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.

Classes in org.apache.flink.runtime.io used by org.apache.flink.changelog.fs

Class and Description
AvailabilityProvider Interface defining couple of essential methods for listening on data availability using CompletableFuture.

Classes in org.apache.flink.runtime.io used by org.apache.flink.runtime.io

Class and Description
AvailabilityProvider Interface defining couple of essential methods for listening on data availability using CompletableFuture.
PullingAsyncDataInput.EndOfDataStatus Status for describing if we have reached the end of data.

Classes in org.apache.flink.runtime.io used by org.apache.flink.runtime.io.network.api.writer

Class and Description
AvailabilityProvider Interface defining couple of essential methods for listening on data availability using CompletableFuture.

Classes in org.apache.flink.runtime.io used by org.apache.flink.runtime.io.network.buffer

Class and Description
AvailabilityProvider Interface defining couple of essential methods for listening on data availability using CompletableFuture.

Classes in org.apache.flink.runtime.io used by org.apache.flink.runtime.io.network.partition

Class and Description
AvailabilityProvider Interface defining couple of essential methods for listening on data availability using CompletableFuture.

Classes in org.apache.flink.runtime.io used by org.apache.flink.runtime.io.network.partition.consumer

Class and Description
AvailabilityProvider Interface defining couple of essential methods for listening on data availability using CompletableFuture.
AvailabilityProvider.AvailabilityHelper A availability implementation for providing the helpful functions of resetting the available/unavailable states.
PullingAsyncDataInput Interface defining couple of essential methods for asynchronous and non blocking data polling.
PullingAsyncDataInput.EndOfDataStatus Status for describing if we have reached the end of data.

Classes in org.apache.flink.runtime.io used by org.apache.flink.runtime.state.changelog

Class and Description
AvailabilityProvider Interface defining couple of essential methods for listening on data availability using CompletableFuture.

Classes in org.apache.flink.runtime.io used by org.apache.flink.runtime.taskmanager

Class and Description
AvailabilityProvider Interface defining couple of essential methods for listening on data availability using CompletableFuture.
PullingAsyncDataInput Interface defining couple of essential methods for asynchronous and non blocking data polling.
PullingAsyncDataInput.EndOfDataStatus Status for describing if we have reached the end of data.

Classes in org.apache.flink.runtime.io used by org.apache.flink.streaming.api.operators

Class and Description
AvailabilityProvider Interface defining couple of essential methods for listening on data availability using CompletableFuture.

Classes in org.apache.flink.runtime.io used by org.apache.flink.streaming.api.operators.sort

Class and Description
AvailabilityProvider Interface defining couple of essential methods for listening on data availability using CompletableFuture.

Classes in org.apache.flink.runtime.io used by org.apache.flink.streaming.runtime.io

Class and Description
AvailabilityProvider Interface defining couple of essential methods for listening on data availability using CompletableFuture.

Classes in org.apache.flink.runtime.io used by org.apache.flink.streaming.runtime.io.checkpointing

Class and Description
AvailabilityProvider Interface defining couple of essential methods for listening on data availability using CompletableFuture.
PullingAsyncDataInput Interface defining couple of essential methods for asynchronous and non blocking data polling.
PullingAsyncDataInput.EndOfDataStatus Status for describing if we have reached the end of data.

Classes in org.apache.flink.runtime.io used by org.apache.flink.streaming.runtime.io.recovery

Class and Description
AvailabilityProvider Interface defining couple of essential methods for listening on data availability using CompletableFuture.

Classes in org.apache.flink.runtime.io used by org.apache.flink.streaming.runtime.tasks

Class and Description
AvailabilityProvider Interface defining couple of essential methods for listening on data availability using CompletableFuture.