Package org.apache.flink.api.java.io

Class TypeSerializerInputFormat<T>

  • Type Parameters:
    T -
    All Implemented Interfaces:
    Serializable, org.apache.flink.api.common.io.CheckpointableInputFormat<org.apache.flink.core.fs.FileInputSplit,​org.apache.flink.api.java.tuple.Tuple2<Long,​Long>>, org.apache.flink.api.common.io.InputFormat<T,​org.apache.flink.core.fs.FileInputSplit>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>, org.apache.flink.core.io.InputSplitSource<org.apache.flink.core.fs.FileInputSplit>
    @Deprecated
@PublicEvolving
public class TypeSerializerInputFormat<T>
extends org.apache.flink.api.common.io.BinaryInputFormat<T>
implements org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>
    Deprecated.
    All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
    Reads elements by deserializing them with a given type serializer.
    See Also:
    FLIP-131: Consolidate the user-facing Dataflow SDKs/APIs (and deprecate the DataSet API, Serialized Form

    • Nested Class Summary

      • Nested classes/interfaces inherited from class org.apache.flink.api.common.io.BinaryInputFormat

        org.apache.flink.api.common.io.BinaryInputFormat.BlockBasedInput

      • Nested classes/interfaces inherited from class org.apache.flink.api.common.io.FileInputFormat

        org.apache.flink.api.common.io.FileInputFormat.FileBaseStatistics, org.apache.flink.api.common.io.FileInputFormat.InputSplitOpenThread

    • Field Summary

      • Fields inherited from class org.apache.flink.api.common.io.BinaryInputFormat

        BLOCK_SIZE_PARAMETER_KEY, NATIVE_BLOCK_SIZE

      • Fields inherited from class org.apache.flink.api.common.io.FileInputFormat

        currentSplit, ENUMERATE_NESTED_FILES_FLAG, enumerateNestedFiles, filePath, INFLATER_INPUT_STREAM_FACTORIES, minSplitSize, numSplits, openTimeout, READ_WHOLE_SPLIT_FLAG, splitLength, splitStart, stream, unsplittable

    • Constructor Summary

      Constructors 
      Constructor Description
      TypeSerializerInputFormat​(org.apache.flink.api.common.typeinfo.TypeInformation<T> resultType)
      Deprecated.
       

    • Method Summary

      All Methods Instance Methods Concrete Methods Deprecated Methods 
      Modifier and Type Method Description
      protected T deserialize​(T reuse, org.apache.flink.core.memory.DataInputView dataInput)
      Deprecated.
       
      org.apache.flink.api.common.typeinfo.TypeInformation<T> getProducedType()
      Deprecated.
       

      • Methods inherited from class org.apache.flink.api.common.io.BinaryInputFormat

        configure, createBlockInfo, createInputSplits, createStatistics, getBlockSize, getCurrentState, getFiles, getInputSplits, getStatistics, nextRecord, open, reachedEnd, reopen, setBlockSize

      • Methods inherited from class org.apache.flink.api.common.io.FileInputFormat

        acceptFile, close, decorateInputStream, extractFileExtension, getFilePath, getFilePaths, getFileStats, getFileStats, getInflaterInputStreamFactory, getInputSplitAssigner, getMinSplitSize, getNestedFileEnumeration, getNumSplits, getOpenTimeout, getSplitLength, getSplitStart, registerInflaterInputStreamFactory, setFilePath, setFilePath, setFilePaths, setFilePaths, setFilesFilter, setMinSplitSize, setNestedFileEnumeration, setNumSplits, setOpenTimeout, supportsMultiPaths, testForUnsplittable, toString

      • Methods inherited from class org.apache.flink.api.common.io.RichInputFormat

        closeInputFormat, getRuntimeContext, openInputFormat, setRuntimeContext

    • Constructor Detail

      • TypeSerializerInputFormat

        public TypeSerializerInputFormat​(org.apache.flink.api.common.typeinfo.TypeInformation<T> resultType)
        Deprecated.

    • Method Detail

      • deserialize

        protected T deserialize​(T reuse,
                        org.apache.flink.core.memory.DataInputView dataInput)
                 throws IOException
        Deprecated.
        Specified by:
        deserialize in class org.apache.flink.api.common.io.BinaryInputFormat<T>
        Throws:
        IOException

      • getProducedType

        public org.apache.flink.api.common.typeinfo.TypeInformation<T> getProducedType()
        Deprecated.
        Specified by:
        getProducedType in interface org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>