Uses of Interface
org.apache.flink.api.common.io.InputFormat
-
Packages that use InputFormat Package Description org.apache.flink.api.common.io org.apache.flink.api.common.operators org.apache.flink.api.java.typeutils -
-
Uses of InputFormat in org.apache.flink.api.common.io
Classes in org.apache.flink.api.common.io that implement InputFormat Modifier and Type Class Description classBinaryInputFormat<T>Base class for all input formats that use blocks of fixed size.classDelimitedInputFormat<OT>Base implementation for input formats that split the input at a delimiter into records.classFileInputFormat<OT>The base class forRichInputFormats that read from files.classGenericCsvInputFormat<OT>classGenericInputFormat<OT>Generic base class for all Rich inputs that are not based on files.classReplicatingInputFormat<OT,S extends InputSplit>A ReplicatingInputFormat replicates anyInputFormatto all parallel instances of a DataSource, i.e., the full input of the replicated InputFormat is completely processed by each parallel instance of the DataSource.classRichInputFormat<OT,T extends InputSplit>An abstract stub implementation for Rich input formats.classSerializedInputFormat<T extends IOReadableWritable>Reads elements by deserializing them with their regular serialization/deserialization functionality.Methods in org.apache.flink.api.common.io that return InputFormat Modifier and Type Method Description InputFormat<OT,S>ReplicatingInputFormat. getReplicatedInputFormat()Constructors in org.apache.flink.api.common.io with parameters of type InputFormat Constructor Description ReplicatingInputFormat(InputFormat<OT,S> wrappedIF) -
Uses of InputFormat in org.apache.flink.api.common.operators
Classes in org.apache.flink.api.common.operators with type parameters of type InputFormat Modifier and Type Class Description classGenericDataSourceBase<OUT,T extends InputFormat<OUT,?>>Abstract superclass for data sources in a Pact plan. -
Uses of InputFormat in org.apache.flink.api.java.typeutils
Methods in org.apache.flink.api.java.typeutils with parameters of type InputFormat Modifier and Type Method Description static <IN> TypeInformation<IN>TypeExtractor. getInputFormatTypes(InputFormat<IN,?> inputFormatInterface)
-