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

Class TextValueInputFormat

  • 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<org.apache.flink.types.StringValue,​org.apache.flink.core.fs.FileInputSplit>, org.apache.flink.core.io.InputSplitSource<org.apache.flink.core.fs.FileInputSplit>
    @Deprecated
@PublicEvolving
public class TextValueInputFormat
extends org.apache.flink.api.common.io.DelimitedInputFormat<org.apache.flink.types.StringValue>
    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.
    Input format that reads text files.
    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

    • Constructor Summary

      Constructors 
      Constructor Description
      TextValueInputFormat​(org.apache.flink.core.fs.Path filePath)
      Deprecated.
       

    • Method Summary

      All Methods Instance Methods Concrete Methods Deprecated Methods 
      Modifier and Type Method Description
      void configure​(org.apache.flink.configuration.Configuration parameters)
      Deprecated.
       
      String getCharsetName()
      Deprecated.
       
      boolean isSkipInvalidLines()
      Deprecated.
       
      org.apache.flink.types.StringValue readRecord​(org.apache.flink.types.StringValue reuse, byte[] bytes, int offset, int numBytes)
      Deprecated.
       
      void setCharsetName​(String charsetName)
      Deprecated.
       
      void setSkipInvalidLines​(boolean skipInvalidLines)
      Deprecated.
       
      boolean supportsMultiPaths()
      Deprecated.
       
      String toString()
      Deprecated.
       

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

        close, getBufferSize, getCharset, getCurrentState, getDelimiter, getLineLengthLimit, getNumLineSamples, getStatistics, initializeSplit, 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, getSupportedCompressionFormats, registerInflaterInputStreamFactory, setFilePath, setFilePath, setFilePaths, setFilePaths, setFilesFilter, setMinSplitSize, setNestedFileEnumeration, setNumSplits, setOpenTimeout, testForUnsplittable

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

        closeInputFormat, getRuntimeContext, openInputFormat, setRuntimeContext

    • Constructor Detail

      • TextValueInputFormat

        public TextValueInputFormat​(org.apache.flink.core.fs.Path filePath)
        Deprecated.

    • Method Detail

      • getCharsetName

        public String getCharsetName()
        Deprecated.

      • setCharsetName

        public void setCharsetName​(String charsetName)
        Deprecated.

      • isSkipInvalidLines

        public boolean isSkipInvalidLines()
        Deprecated.

      • setSkipInvalidLines

        public void setSkipInvalidLines​(boolean skipInvalidLines)
        Deprecated.

      • configure

        public void configure​(org.apache.flink.configuration.Configuration parameters)
        Deprecated.
        Specified by:
        configure in interface org.apache.flink.api.common.io.InputFormat<org.apache.flink.types.StringValue,​org.apache.flink.core.fs.FileInputSplit>
        Overrides:
        configure in class org.apache.flink.api.common.io.DelimitedInputFormat<org.apache.flink.types.StringValue>

      • readRecord

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

      • toString

        public String toString()
        Deprecated.
        Overrides:
        toString in class org.apache.flink.api.common.io.FileInputFormat<org.apache.flink.types.StringValue>

      • supportsMultiPaths

        public boolean supportsMultiPaths()
        Deprecated.
        Overrides:
        supportsMultiPaths in class org.apache.flink.api.common.io.FileInputFormat<org.apache.flink.types.StringValue>