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.field(String fieldName,
TypeInformation<?> fieldType)
Adds a field with the field name and the type 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.