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 theInputSplit
s among the instances on which a data source exists.InputSplitSource<T extends InputSplit> InputSplitSources createInputSplit
s that define portions of data to be produced byInputFormat
s.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 AVersionedIOReadableWritable
which allows to differentiate whether the previous data was versioned with aVersionedIOReadableWritable
.SimpleVersionedSerialization Simple serialization / deserialization methods for theSimpleVersionedSerializer
.SimpleVersionedSerializerAdapter<T> Adapter forTypeSerializer
toSimpleVersionedSerializer
.SimpleVersionedSerializerTypeSerializerProxy<T> ATypeSerializer
that delegates to an underlyingSimpleVersionedSerializer
.VersionedIOReadableWritable This is the abstract base class forIOReadableWritable
which allows to differentiate between serialization versions. -
Enum Summary Enum Description InputStatus AnInputStatus
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.