@PublicEvolving public class RowCsvInputFormat extends CsvInputFormat<Row> implements ResultTypeQueryable<Row>
Row.FileInputFormat.FileBaseStatistics, FileInputFormat.InputSplitOpenThreadDEFAULT_FIELD_DELIMITER, DEFAULT_LINE_DELIMITER, parsedValuescommentCount, commentPrefix, fieldIncluded, invalidLineCount, lineDelimiterIsLinebreakcurrBuffer, currLen, currOffset, RECORD_DELIMITERcurrentSplit, ENUMERATE_NESTED_FILES_FLAG, enumerateNestedFiles, filePath, INFLATER_INPUT_STREAM_FACTORIES, minSplitSize, numSplits, openTimeout, READ_WHOLE_SPLIT_FLAG, splitLength, splitStart, stream, unsplittable| Constructor and Description |
|---|
RowCsvInputFormat(Path filePath,
TypeInformation[] fieldTypes) |
RowCsvInputFormat(Path filePath,
TypeInformation[] fieldTypes,
boolean emptyColumnAsNull) |
RowCsvInputFormat(Path filePath,
TypeInformation[] fieldTypes,
int[] selectedFields) |
RowCsvInputFormat(Path filePath,
TypeInformation[] fieldTypes,
String lineDelimiter,
String fieldDelimiter) |
RowCsvInputFormat(Path filePath,
TypeInformation[] fieldTypes,
String lineDelimiter,
String fieldDelimiter,
int[] selectedFields) |
RowCsvInputFormat(Path filePath,
TypeInformation[] fieldTypeInfos,
String lineDelimiter,
String fieldDelimiter,
int[] selectedFields,
boolean emptyColumnAsNull) |
| Modifier and Type | Method and Description |
|---|---|
protected Row |
fillRecord(Row reuse,
Object[] parsedValues) |
TypeInformation<Row> |
getProducedType()
Gets the data type (as a
TypeInformation) produced by this function or input format. |
protected boolean |
parseRecord(Object[] holders,
byte[] bytes,
int offset,
int numBytes) |
createDefaultMask, getFieldTypes, initializeSplit, nextRecord, readRecord, toBooleanMask, toStringcheckAndCoSort, checkForMonotonousOrder, close, enableQuotedStringParsing, getCommentPrefix, getFieldDelimiter, getFieldParsers, getGenericFieldTypes, getNumberOfFieldsTotal, getNumberOfNonNullFields, isLenient, isSkippingFirstLineAsHeader, setCharset, setCommentPrefix, setFieldDelimiter, setFieldsGeneric, setFieldsGeneric, setFieldTypesGeneric, setLenient, setSkipFirstLineAsHeader, skipFields, supportsMultiPathsconfigure, getBufferSize, getCharset, getCurrentState, getDelimiter, getLineLengthLimit, getNumLineSamples, getStatistics, loadConfigParameters, loadGlobalConfigParams, open, reachedEnd, readLine, reopen, setBufferSize, setDelimiter, setDelimiter, setDelimiter, setLineLengthLimit, setNumLineSamplesacceptFile, 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, testForUnsplittablecloseInputFormat, getRuntimeContext, openInputFormat, setRuntimeContextpublic RowCsvInputFormat(Path filePath, TypeInformation[] fieldTypeInfos, String lineDelimiter, String fieldDelimiter, int[] selectedFields, boolean emptyColumnAsNull)
public RowCsvInputFormat(Path filePath, TypeInformation[] fieldTypes, String lineDelimiter, String fieldDelimiter, int[] selectedFields)
public RowCsvInputFormat(Path filePath, TypeInformation[] fieldTypes, String lineDelimiter, String fieldDelimiter)
public RowCsvInputFormat(Path filePath, TypeInformation[] fieldTypes, int[] selectedFields)
public RowCsvInputFormat(Path filePath, TypeInformation[] fieldTypes, boolean emptyColumnAsNull)
public RowCsvInputFormat(Path filePath, TypeInformation[] fieldTypes)
protected Row fillRecord(Row reuse, Object[] parsedValues)
fillRecord in class CsvInputFormat<Row>protected boolean parseRecord(Object[] holders, byte[] bytes, int offset, int numBytes) throws ParseException
parseRecord in class GenericCsvInputFormat<Row>ParseExceptionpublic TypeInformation<Row> getProducedType()
ResultTypeQueryableTypeInformation) produced by this function or input format.getProducedType in interface ResultTypeQueryable<Row>Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.