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()
Derives the format schema from the table's schema.
|
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" or "\r\n" 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)
Sets the format schema with field names and the types.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.