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

Class PrimitiveInputFormat<OT>

  • All Implemented Interfaces:
    Serializable, org.apache.flink.api.common.io.CheckpointableInputFormat<org.apache.flink.core.fs.FileInputSplit,​Long>, org.apache.flink.api.common.io.InputFormat<OT,​org.apache.flink.core.fs.FileInputSplit>, org.apache.flink.core.io.InputSplitSource<org.apache.flink.core.fs.FileInputSplit>
    @Deprecated
@PublicEvolving
public class PrimitiveInputFormat<OT>
extends org.apache.flink.api.common.io.DelimitedInputFormat<OT>
    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.
    An input format that reads single field primitive data from a given file. The difference between this and CsvInputFormat is that it won't go through Tuple1.
    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.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.DelimitedInputFormat

        currBuffer, currLen, currOffset, RECORD_DELIMITER

      • 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

    • Method Summary

      All Methods Instance Methods Concrete Methods Deprecated Methods 
      Modifier and Type Method Description
      protected void initializeSplit​(org.apache.flink.core.fs.FileInputSplit split, Long offset)
      Deprecated.
       
      OT readRecord​(OT reuse, byte[] bytes, int offset, int numBytes)
      Deprecated.
       

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

        close, configure, getBufferSize, getCharset, getCurrentState, getDelimiter, getLineLengthLimit, getNumLineSamples, getStatistics, loadConfigParameters, loadGlobalConfigParams, nextRecord, open, reachedEnd, readLine, reopen, setBufferSize, setCharset, setDelimiter, setDelimiter, setDelimiter, setLineLengthLimit, setNumLineSamples

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

        acceptFile, createInputSplits, 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

      • PrimitiveInputFormat

        public PrimitiveInputFormat​(org.apache.flink.core.fs.Path filePath,
                            Class<OT> primitiveClass)
        Deprecated.

      • PrimitiveInputFormat

        public PrimitiveInputFormat​(org.apache.flink.core.fs.Path filePath,
                            String delimiter,
                            Class<OT> primitiveClass)
        Deprecated.

    • Method Detail

      • initializeSplit

        protected void initializeSplit​(org.apache.flink.core.fs.FileInputSplit split,
                               Long offset)
                        throws IOException
        Deprecated.
        Overrides:
        initializeSplit in class org.apache.flink.api.common.io.DelimitedInputFormat<OT>
        Throws:
        IOException

      • readRecord

        public OT readRecord​(OT reuse,
                     byte[] bytes,
                     int offset,
                     int numBytes)
              throws IOException
        Deprecated.
        Specified by:
        readRecord in class org.apache.flink.api.common.io.DelimitedInputFormat<OT>
        Throws:
        IOException