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–2020 The Apache Software Foundation. All rights reserved.