Class | Description |
---|---|
AbstractCsvInputFormat<T> |
Input format that reads csv.
|
CsvFileSystemFormatFactory |
CSV format factory for file system.
|
CsvFileSystemFormatFactory.CsvInputFormat |
InputFormat that reads csv record into
RowData . |
CsvFormatFactory |
Format factory for providing configured instances of CSV to RowData
SerializationSchema
and DeserializationSchema . |
CsvOptions |
Options for CSV format.
|
CsvRowDataDeserializationSchema |
Deserialization schema from CSV to Flink Table & SQL internal data structures.
|
CsvRowDataDeserializationSchema.Builder |
A builder for creating a
CsvRowDataDeserializationSchema . |
CsvRowDataSerializationSchema |
Serialization schema that serializes an object of Flink Table & SQL internal data structure into
a CSV bytes.
|
CsvRowDataSerializationSchema.Builder |
A builder for creating a
CsvRowDataSerializationSchema . |
CsvRowDeserializationSchema |
Deserialization schema from CSV to Flink types.
|
CsvRowDeserializationSchema.Builder |
A builder for creating a
CsvRowDeserializationSchema . |
CsvRowFormatFactory |
Table format factory for providing configured instances of CSV-to-row
SerializationSchema
and DeserializationSchema . |
CsvRowSchemaConverter |
Converter functions that covert Flink's type information to Jackson's
CsvSchema . |
CsvRowSerializationSchema |
Serialization schema that serializes an object of Flink types into a CSV bytes.
|
CsvRowSerializationSchema.Builder |
A builder for creating a
CsvRowSerializationSchema . |
RowCsvInputFormat |
Input format that reads csv into
Row . |
RowCsvInputFormat.Builder |
A builder for creating a
RowCsvInputFormat . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.