Uses of Package
org.apache.flink.core.io
-
Classes in org.apache.flink.core.io used by org.apache.flink.api.common.distributions Class Description IOReadableWritable This interface must be implemented by every class whose objects have to be serialized to their binary representation and vice-versa. -
Classes in org.apache.flink.core.io used by org.apache.flink.api.common.io Class Description GenericInputSplit A generic input split that has only a partition number.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 theInputSplits among the instances on which a data source exists.InputSplitSource InputSplitSources createInputSplits that define portions of data to be produced byInputFormats.IOReadableWritable This interface must be implemented by every class whose objects have to be serialized to their binary representation and vice-versa.LocatableInputSplit A locatable input split is an input split referring to input data which is located on one or more hosts. -
Classes in org.apache.flink.core.io used by org.apache.flink.api.connector.sink Class Description SimpleVersionedSerializer A simple serializer interface for versioned serialization. -
Classes in org.apache.flink.core.io used by org.apache.flink.api.connector.sink2 Class Description SimpleVersionedSerializer A simple serializer interface for versioned serialization. -
Classes in org.apache.flink.core.io used by org.apache.flink.api.connector.source Class Description InputStatus AnInputStatusindicates the availability of data from an asynchronous input.SimpleVersionedSerializer A simple serializer interface for versioned serialization. -
Classes in org.apache.flink.core.io used by org.apache.flink.api.connector.source.lib Class Description SimpleVersionedSerializer A simple serializer interface for versioned serialization. -
Classes in org.apache.flink.core.io used by org.apache.flink.api.connector.source.lib.util Class Description InputStatus AnInputStatusindicates the availability of data from an asynchronous input. -
Classes in org.apache.flink.core.io used by org.apache.flink.api.connector.source.util.ratelimit Class Description InputStatus AnInputStatusindicates the availability of data from an asynchronous input. -
Classes in org.apache.flink.core.io used by org.apache.flink.configuration Class Description IOReadableWritable This interface must be implemented by every class whose objects have to be serialized to their binary representation and vice-versa. -
Classes in org.apache.flink.core.io used by org.apache.flink.core.fs Class Description InputSplit This interface must be implemented by all kind of input splits that can be assigned to input formats.IOReadableWritable This interface must be implemented by every class whose objects have to be serialized to their binary representation and vice-versa.LocatableInputSplit A locatable input split is an input split referring to input data which is located on one or more hosts.SimpleVersionedSerializer A simple serializer interface for versioned serialization. -
Classes in org.apache.flink.core.io used by org.apache.flink.core.fs.local Class Description SimpleVersionedSerializer A simple serializer interface for versioned serialization. -
Classes in org.apache.flink.core.io used by org.apache.flink.core.io Class 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 theInputSplits among the instances on which a data source exists.InputStatus AnInputStatusindicates the availability of data from an asynchronous input.IOReadableWritable This interface must be implemented by every class whose objects have to be serialized to their binary representation and vice-versa.SimpleVersionedSerializer A simple serializer interface for versioned serialization.Versioned This interface is implemented by classes that provide a version number.VersionedIOReadableWritable This is the abstract base class forIOReadableWritablewhich allows to differentiate between serialization versions. -
Classes in org.apache.flink.core.io used by org.apache.flink.types Class Description IOReadableWritable This interface must be implemented by every class whose objects have to be serialized to their binary representation and vice-versa. -
Classes in org.apache.flink.core.io used by org.apache.flink.util Class Description IOReadableWritable This interface must be implemented by every class whose objects have to be serialized to their binary representation and vice-versa.