Modifier and Type | Interface and Description |
---|---|
interface |
BulkDecodingFormat<T>
|
Modifier and Type | Class and Description |
---|---|
static class |
CsvFileFormatFactory.CsvBulkDecodingFormat
CsvBulkDecodingFormat which implements
FileBasedStatisticsReportableInputFormat . |
Modifier and Type | Class and Description |
---|---|
class |
CanalJsonDecodingFormat
DecodingFormat for Canal using JSON encoding. |
Modifier and Type | Class and Description |
---|---|
class |
DebeziumJsonDecodingFormat
DecodingFormat for Debezium using JSON encoding. |
Modifier and Type | Class and Description |
---|---|
class |
MaxwellJsonDecodingFormat
DecodingFormat for Maxwell using JSON encoding. |
Modifier and Type | Class and Description |
---|---|
class |
OggJsonDecodingFormat
DecodingFormat for Ogg using JSON encoding. |
Modifier and Type | Class and Description |
---|---|
static class |
ParquetFileFormatFactory.ParquetBulkDecodingFormat
ParquetBulkDecodingFormat which implements
FileBasedStatisticsReportableInputFormat . |
Modifier and Type | Class and Description |
---|---|
class |
PbDecodingFormat
DecodingFormat for protobuf decoding. |
class |
PbEncodingFormat
EncodingFormat for protobuf encoding. |
Modifier and Type | Class and Description |
---|---|
static class |
OrcFileFormatFactory.OrcBulkDecodingFormat
OrcBulkDecodingFormat which implements
FileBasedStatisticsReportableInputFormat . |
Modifier and Type | Class and Description |
---|---|
protected static class |
UpsertKafkaDynamicTableFactory.DecodingFormatWrapper
It is used to wrap the decoding format and expose the desired changelog mode.
|
protected static class |
UpsertKafkaDynamicTableFactory.EncodingFormatWrapper
It is used to wrap the encoding format and expose the desired changelog mode.
|
Modifier and Type | Interface and Description |
---|---|
interface |
DecodingFormat<I>
A
Format for a DynamicTableSource for reading rows. |
interface |
EncodingFormat<I>
A
Format for a DynamicTableSink for writing rows. |
interface |
ProjectableDecodingFormat<I>
Extension of
DecodingFormat which is able to produce projected rows. |
Modifier and Type | Class and Description |
---|---|
class |
ChangelogCsvFormat
The
ChangelogCsvFormat is a decoding format that uses a DeserializationSchema
during runtime. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.