Modifier and Type | Interface and Description |
---|---|
interface |
BulkReaderFormatFactory
Base interface for configuring a
BulkFormat for file system connector. |
interface |
BulkWriterFormatFactory
Base interface for configuring a
BulkWriter.Factory for file system connector. |
Modifier and Type | Class and Description |
---|---|
class |
AvroFileFormatFactory
Avro format factory for file system.
|
class |
AvroFormatFactory
Table format factory for providing configured instances of Avro to RowData
SerializationSchema and DeserializationSchema . |
Modifier and Type | Class and Description |
---|---|
class |
RegistryAvroFormatFactory
Table format factory for providing configured instances of Schema Registry Avro to RowData
SerializationSchema and DeserializationSchema . |
Modifier and Type | Class and Description |
---|---|
class |
DebeziumAvroFormatFactory
Format factory for providing configured instances of Debezium Avro to RowData
DeserializationSchema . |
Modifier and Type | Class and Description |
---|---|
class |
CsvFileFormatFactory
CSV format factory for file system.
|
class |
CsvFormatFactory
Format factory for providing configured instances of CSV to RowData
SerializationSchema
and DeserializationSchema . |
Modifier and Type | Class and Description |
---|---|
class |
JsonFormatFactory
Table format factory for providing configured instances of JSON to RowData
SerializationSchema and DeserializationSchema . |
Modifier and Type | Class and Description |
---|---|
class |
CanalJsonFormatFactory
Format factory for providing configured instances of Canal JSON to RowData
DeserializationSchema . |
Modifier and Type | Class and Description |
---|---|
class |
DebeziumJsonFormatFactory
Format factory for providing configured instances of Debezium JSON to RowData
DeserializationSchema . |
Modifier and Type | Class and Description |
---|---|
class |
MaxwellJsonFormatFactory
Format factory for providing configured instances of Maxwell JSON to RowData
DeserializationSchema . |
Modifier and Type | Class and Description |
---|---|
class |
OggJsonFormatFactory
Format factory for providing configured instances of Ogg JSON to RowData
DeserializationSchema . |
Modifier and Type | Class and Description |
---|---|
class |
ParquetFileFormatFactory
Parquet format factory for file system.
|
Modifier and Type | Class and Description |
---|---|
class |
PbFormatFactory
Table format factory for providing configured instances of Protobuf to RowData
SerializationSchema and DeserializationSchema . |
Modifier and Type | Class and Description |
---|---|
class |
RawFormatFactory
Format factory for raw format which allows to read and write raw (byte based) values as a single
column.
|
Modifier and Type | Class and Description |
---|---|
class |
OrcFileFormatFactory
Orc format factory for file system.
|
Modifier and Type | Class and Description |
---|---|
class |
ChangelogCsvFormatFactory
The
ChangelogCsvFormatFactory translates format-specific options to a format. |
Modifier and Type | Interface and Description |
---|---|
interface |
DecodingFormatFactory<I>
|
interface |
DeserializationFormatFactory
Factory for creating a
DecodingFormat for DeserializationSchema . |
interface |
EncodingFormatFactory<I>
Base interface for configuring an
EncodingFormat for a DynamicTableSink . |
interface |
SerializationFormatFactory
Factory for creating a
EncodingFormat for SerializationSchema . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.