Package | Description |
---|---|
org.apache.flink.table.sources |
Modifier and Type | Method and Description |
---|---|
static CsvTableSource.Builder |
CsvTableSource.builder()
Return a new builder that builds a CsvTableSource.
|
CsvTableSource.Builder |
CsvTableSource.Builder.commentPrefix(String prefix)
Sets a prefix to indicate comments, null by default.
|
CsvTableSource.Builder |
CsvTableSource.Builder.emptyColumnAsNull()
Treat empty column as null, false by default.
|
CsvTableSource.Builder |
CsvTableSource.Builder.field(String fieldName,
DataType fieldType)
Adds a field with the field name and the data type.
|
CsvTableSource.Builder |
CsvTableSource.Builder.field(String fieldName,
TypeInformation<?> fieldType)
Deprecated.
This method will be removed in future versions as it uses the old type
system. It is recommended to use
field(String, DataType) instead which uses
the new type system based on DataTypes . Please make sure to use either the
old or the new type system consistently to avoid unintended behavior. See the website
documentation for more information. |
CsvTableSource.Builder |
CsvTableSource.Builder.fieldDelimiter(String delim)
Sets the field delimiter, "," by default.
|
CsvTableSource.Builder |
CsvTableSource.Builder.ignoreFirstLine()
Ignore the first line.
|
CsvTableSource.Builder |
CsvTableSource.Builder.ignoreParseErrors()
Skip records with parse error instead to fail.
|
CsvTableSource.Builder |
CsvTableSource.Builder.lineDelimiter(String delim)
Sets the line delimiter, "\n" by default.
|
CsvTableSource.Builder |
CsvTableSource.Builder.path(String path)
Sets the path to the CSV file.
|
CsvTableSource.Builder |
CsvTableSource.Builder.quoteCharacter(Character quote)
Sets a quote character for String values, null by default.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.