Class | Description |
---|---|
AbstractCsvInputFormat<T> |
Input format that reads csv.
|
CsvFileFormatFactory |
CSV format factory for file system.
|
CsvFileFormatFactory.CsvBulkDecodingFormat |
CsvBulkDecodingFormat which implements
FileBasedStatisticsReportableInputFormat . |
CsvFormatFactory |
Format factory for providing configured instances of CSV to RowData
SerializationSchema
and DeserializationSchema . |
CsvFormatOptions |
Options for CSV format.
|
CsvReaderFormat<T> |
A
StreamFormat for reading CSV files. |
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 | Deprecated
The format was developed for the Table API users and will not be maintained for
DataStream API users anymore.
|
CsvRowDeserializationSchema.Builder |
A builder for creating a
CsvRowDeserializationSchema . |
CsvRowSchemaConverter |
Converter functions that covert Flink's type information to Jackson's
CsvSchema . |
CsvRowSerializationSchema | Deprecated
The format was developed for the Table API users and will not be maintained for
DataStream API users anymore.
|
CsvRowSerializationSchema.Builder |
A builder for creating a
CsvRowSerializationSchema . |
CsvToRowDataConverters |
Tool class used to convert from CSV-format
JsonNode to RowData . |
PythonCsvUtils |
Utilities for using CSV format in PyFlink.
|
RowCsvInputFormat |
Input format that reads csv into
Row . |
RowCsvInputFormat.Builder |
A builder for creating a
RowCsvInputFormat . |
RowDataToCsvConverters |
Tool class used to convert from
RowData to CSV-format JsonNode . |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.