Package | Description |
---|---|
org.apache.flink.table.descriptors |
Modifier and Type | Method and Description |
---|---|
Csv |
Csv.allowComments()
Ignores comment lines that start with '#' (disabled by default).
|
Csv |
Csv.arrayElementDelimiter(String delimiter)
Sets the array element delimiter string for separating array or row element values (";" by
default).
|
Csv |
Csv.deriveSchema()
Deprecated.
Derivation format schema from table's schema is the default behavior now. So
there is no need to explicitly declare to derive schema.
|
Csv |
Csv.disableQuoteCharacter()
Disable the quote character for enclosing field values.
|
Csv |
Csv.escapeCharacter(char escapeCharacter)
Sets the escape character for escaping values (disabled by default).
|
Csv |
Csv.fieldDelimiter(char delimiter)
Sets the field delimiter character (',' by default).
|
Csv |
Csv.ignoreParseErrors()
Skip fields and rows with parse errors instead of failing.
|
Csv |
Csv.lineDelimiter(String delimiter)
Sets the line delimiter ("\n" by default; otherwise "\r", "\r\n", or "" are allowed).
|
Csv |
Csv.nullLiteral(String nullLiteral)
Sets the null literal string that is interpreted as a null value (disabled by default).
|
Csv |
Csv.quoteCharacter(char quoteCharacter)
Sets the quote character for enclosing field values ('"' by default).
|
Csv |
Csv.schema(TypeInformation<Row> schemaType)
Deprecated.
Csv supports derive schema from table schema by default, it is no longer
necessary to explicitly declare the format schema. This method will be removed in the
future. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.