Package org.apache.flink.core.io

Interface Summary

Interface	Description
InputSplit	This interface must be implemented by all kind of input splits that can be assigned to input formats.
InputSplitAssigner	An input split assigner distributes the InputSplits among the instances on which a data source exists.
InputSplitSource<T extends InputSplit>	InputSplitSources create InputSplits that define portions of data to be produced by InputFormats.
IOReadableWritable	This interface must be implemented by every class whose objects have to be serialized to their binary representation and vice-versa.
SimpleVersionedSerializer<E>	A simple serializer interface for versioned serialization.
Versioned	This interface is implemented by classes that provide a version number.

Class Summary

Class	Description
GenericInputSplit	A generic input split that has only a partition number.
LocatableInputSplit	A locatable input split is an input split referring to input data which is located on one or more hosts.
PostVersionedIOReadableWritable	A VersionedIOReadableWritable which allows to differentiate whether the previous data was versioned with a VersionedIOReadableWritable.
SimpleVersionedSerialization	Simple serialization / deserialization methods for the SimpleVersionedSerializer.
SimpleVersionedSerializerTypeSerializerProxy<T>	A TypeSerializer that delegates to an underlying SimpleVersionedSerializer.
VersionedIOReadableWritable	This is the abstract base class for IOReadableWritable which allows to differentiate between serialization versions.

Enum Summary

Enum	Description
InputStatus	An InputStatus indicates the availability of data from an asynchronous input.

Exception Summary

Exception	Description
VersionMismatchException	This exception signals that incompatible versions have been found during serialization.