@Internal public static class CsvRowDataDeserializationSchema.Builder extends Object
CsvRowDataDeserializationSchema
.Constructor and Description |
---|
Builder(RowType rowReadType,
RowType rowResultType,
TypeInformation<RowData> resultTypeInfo)
Creates a CSV deserialization schema for the given
TypeInformation with optional
parameters. |
Builder(RowType rowType,
TypeInformation<RowData> resultTypeInfo)
Creates a CSV deserialization schema for the given
TypeInformation with optional
parameters. |
Modifier and Type | Method and Description |
---|---|
CsvRowDataDeserializationSchema |
build() |
CsvRowDataDeserializationSchema.Builder |
disableQuoteCharacter() |
CsvRowDataDeserializationSchema.Builder |
setAllowComments(boolean allowComments) |
CsvRowDataDeserializationSchema.Builder |
setArrayElementDelimiter(String delimiter) |
CsvRowDataDeserializationSchema.Builder |
setEscapeCharacter(char c) |
CsvRowDataDeserializationSchema.Builder |
setFieldDelimiter(char delimiter) |
CsvRowDataDeserializationSchema.Builder |
setIgnoreParseErrors(boolean ignoreParseErrors) |
CsvRowDataDeserializationSchema.Builder |
setNullLiteral(String nullLiteral) |
CsvRowDataDeserializationSchema.Builder |
setQuoteCharacter(char c) |
public Builder(RowType rowReadType, RowType rowResultType, TypeInformation<RowData> resultTypeInfo)
TypeInformation
with optional
parameters.rowReadType
- The RowType
used for reading CSV rows.rowResultType
- The RowType
of the produced results. It can be different
from the rowReadType
if the underlying converter supports the discrepancy
(for instance for filtering/projection pushdown).resultTypeInfo
- The result type info.public Builder(RowType rowType, TypeInformation<RowData> resultTypeInfo)
TypeInformation
with optional
parameters.public CsvRowDataDeserializationSchema.Builder setFieldDelimiter(char delimiter)
public CsvRowDataDeserializationSchema.Builder setAllowComments(boolean allowComments)
public CsvRowDataDeserializationSchema.Builder setArrayElementDelimiter(String delimiter)
public CsvRowDataDeserializationSchema.Builder disableQuoteCharacter()
public CsvRowDataDeserializationSchema.Builder setQuoteCharacter(char c)
public CsvRowDataDeserializationSchema.Builder setEscapeCharacter(char c)
public CsvRowDataDeserializationSchema.Builder setNullLiteral(String nullLiteral)
public CsvRowDataDeserializationSchema.Builder setIgnoreParseErrors(boolean ignoreParseErrors)
public CsvRowDataDeserializationSchema build()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.