Package org.apache.flink.table.sources.format

Class CsvInputFormat<OUT>

  • Type Parameters:
    OUT -
    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<OUT,​org.apache.flink.core.fs.FileInputSplit>, org.apache.flink.core.io.InputSplitSource<org.apache.flink.core.fs.FileInputSplit>
    Direct Known Subclasses:
    RowCsvInputFormat
    @Deprecated
@Internal
public abstract class CsvInputFormat<OUT>
extends org.apache.flink.api.common.io.GenericCsvInputFormat<OUT>
    Deprecated.
    InputFormat that reads csv files.

    This class is copied from flink-java module and should be removed later.

    See Also:
    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 
      Modifier and Type Field Description
      static String DEFAULT_FIELD_DELIMITER
      Deprecated.
       
      static String DEFAULT_LINE_DELIMITER
      Deprecated.
       
      protected Object[] parsedValues
      Deprecated.
       

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

        commentCount, commentPrefix, fieldIncluded, invalidLineCount, lineDelimiterIsLinebreak

      • 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, enumerateNestedFiles, INFLATER_INPUT_STREAM_FACTORIES, minSplitSize, numSplits, openTimeout, READ_WHOLE_SPLIT_FLAG, splitLength, splitStart, stream, unsplittable

    • Constructor Summary

      Constructors 
      Modifier Constructor Description
      protected CsvInputFormat​(org.apache.flink.core.fs.Path filePath)
      Deprecated.
       

    • Method Summary

      All Methods Static Methods Instance Methods Abstract Methods Concrete Methods Deprecated Methods 
      Modifier and Type Method Description
      protected static boolean[] createDefaultMask​(int size)
      Deprecated.
       
      protected abstract OUT fillRecord​(OUT reuse, Object[] parsedValues)
      Deprecated.
       
      Class<?>[] getFieldTypes()
      Deprecated.
       
      protected void initializeSplit​(org.apache.flink.core.fs.FileInputSplit split, Long offset)
      Deprecated.
       
      OUT nextRecord​(OUT record)
      Deprecated.
       
      OUT readRecord​(OUT reuse, byte[] bytes, int offset, int numBytes)
      Deprecated.
       
      protected static boolean[] toBooleanMask​(int[] sourceFieldIndices)
      Deprecated.
       
      String toString()
      Deprecated.
       

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

        checkAndCoSort, checkForMonotonousOrder, close, enableQuotedStringParsing, getCommentPrefix, getFieldDelimiter, getFieldParsers, getGenericFieldTypes, getNumberOfFieldsTotal, getNumberOfNonNullFields, isLenient, isSkippingFirstLineAsHeader, parseRecord, setCharset, setCommentPrefix, setFieldDelimiter, setFieldsGeneric, setFieldsGeneric, setFieldTypesGeneric, setLenient, setSkipFirstLineAsHeader, skipFields

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

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

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

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

    • Field Detail

      • parsedValues

        protected transient Object[] parsedValues
        Deprecated.

    • Constructor Detail

      • CsvInputFormat

        protected CsvInputFormat​(org.apache.flink.core.fs.Path filePath)
        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.GenericCsvInputFormat<OUT>
        Throws:
        IOException

      • nextRecord

        public OUT nextRecord​(OUT record)
               throws IOException
        Deprecated.
        Specified by:
        nextRecord in interface org.apache.flink.api.common.io.InputFormat<OUT,​org.apache.flink.core.fs.FileInputSplit>
        Overrides:
        nextRecord in class org.apache.flink.api.common.io.DelimitedInputFormat<OUT>
        Throws:
        IOException

      • readRecord

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

      • fillRecord

        protected abstract OUT fillRecord​(OUT reuse,
                                  Object[] parsedValues)
        Deprecated.

      • getFieldTypes

        public Class<?>[] getFieldTypes()
        Deprecated.

      • createDefaultMask

        protected static boolean[] createDefaultMask​(int size)
        Deprecated.

      • toBooleanMask

        protected static boolean[] toBooleanMask​(int[] sourceFieldIndices)
        Deprecated.

      • toString

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