Uses of Interface
org.apache.flink.table.connector.format.DecodingFormat

Packages that use DecodingFormat

Package	Description
org.apache.flink.formats.avro
org.apache.flink.formats.avro.registry.confluent
org.apache.flink.formats.avro.registry.confluent.debezium
org.apache.flink.formats.csv
org.apache.flink.formats.json
org.apache.flink.formats.json.canal
org.apache.flink.formats.json.debezium
org.apache.flink.formats.json.maxwell
org.apache.flink.formats.raw
org.apache.flink.streaming.connectors.kafka.table
org.apache.flink.streaming.connectors.kinesis.table
org.apache.flink.table.connector.format
org.apache.flink.table.examples.java.connectors
org.apache.flink.table.factories
org.apache.flink.table.filesystem

Uses of DecodingFormat in org.apache.flink.formats.avro

Methods in org.apache.flink.formats.avro that return DecodingFormat

Modifier and Type	Method and Description
DecodingFormat<DeserializationSchema<RowData>>	AvroFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

Uses of DecodingFormat in org.apache.flink.formats.avro.registry.confluent

Methods in org.apache.flink.formats.avro.registry.confluent that return DecodingFormat

Modifier and Type	Method and Description
DecodingFormat<DeserializationSchema<RowData>>	RegistryAvroFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

Uses of DecodingFormat in org.apache.flink.formats.avro.registry.confluent.debezium

Methods in org.apache.flink.formats.avro.registry.confluent.debezium that return DecodingFormat

Modifier and Type	Method and Description
DecodingFormat<DeserializationSchema<RowData>>	DebeziumAvroFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

Uses of DecodingFormat in org.apache.flink.formats.csv

Methods in org.apache.flink.formats.csv that return DecodingFormat

Modifier and Type	Method and Description
DecodingFormat<DeserializationSchema<RowData>>	CsvFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

Uses of DecodingFormat in org.apache.flink.formats.json

Methods in org.apache.flink.formats.json that return DecodingFormat

Modifier and Type	Method and Description
DecodingFormat<DeserializationSchema<RowData>>	JsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

Uses of DecodingFormat in org.apache.flink.formats.json.canal

Classes in org.apache.flink.formats.json.canal that implement DecodingFormat

Modifier and Type	Class and Description
class	CanalJsonDecodingFormat DecodingFormat for Canal using JSON encoding.

Methods in org.apache.flink.formats.json.canal that return DecodingFormat

Modifier and Type	Method and Description
DecodingFormat<DeserializationSchema<RowData>>	CanalJsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

Uses of DecodingFormat in org.apache.flink.formats.json.debezium

Classes in org.apache.flink.formats.json.debezium that implement DecodingFormat

Modifier and Type	Class and Description
class	DebeziumJsonDecodingFormat DecodingFormat for Debezium using JSON encoding.

Methods in org.apache.flink.formats.json.debezium that return DecodingFormat

Modifier and Type	Method and Description
DecodingFormat<DeserializationSchema<RowData>>	DebeziumJsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

Uses of DecodingFormat in org.apache.flink.formats.json.maxwell

Classes in org.apache.flink.formats.json.maxwell that implement DecodingFormat

Modifier and Type	Class and Description
class	MaxwellJsonDecodingFormat DecodingFormat for Maxwell using JSON encoding.

Methods in org.apache.flink.formats.json.maxwell that return DecodingFormat

Modifier and Type	Method and Description
DecodingFormat<DeserializationSchema<RowData>>	MaxwellJsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

Uses of DecodingFormat in org.apache.flink.formats.raw

Methods in org.apache.flink.formats.raw that return DecodingFormat

Modifier and Type	Method and Description
DecodingFormat<DeserializationSchema<RowData>>	RawFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

Uses of DecodingFormat in org.apache.flink.streaming.connectors.kafka.table

Classes in org.apache.flink.streaming.connectors.kafka.table that implement DecodingFormat

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.

Fields in org.apache.flink.streaming.connectors.kafka.table declared as DecodingFormat

Modifier and Type	Field and Description
protected DecodingFormat<DeserializationSchema<RowData>>	KafkaDynamicSource.keyDecodingFormat Optional format for decoding keys from Kafka.
protected DecodingFormat<DeserializationSchema<RowData>>	KafkaDynamicSource.valueDecodingFormat Format for decoding values from Kafka.

Methods in org.apache.flink.streaming.connectors.kafka.table with parameters of type DecodingFormat

Modifier and Type	Method and Description
protected KafkaDynamicSource	KafkaDynamicTableFactory.createKafkaTableSource(DataType physicalDataType, DecodingFormat<DeserializationSchema<RowData>> keyDecodingFormat, DecodingFormat<DeserializationSchema<RowData>> valueDecodingFormat, int[] keyProjection, int[] valueProjection, String keyPrefix, List<String> topics, Pattern topicPattern, Properties properties, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis, String tableIdentifier)
protected KafkaDynamicSource	KafkaDynamicTableFactory.createKafkaTableSource(DataType physicalDataType, DecodingFormat<DeserializationSchema<RowData>> keyDecodingFormat, DecodingFormat<DeserializationSchema<RowData>> valueDecodingFormat, int[] keyProjection, int[] valueProjection, String keyPrefix, List<String> topics, Pattern topicPattern, Properties properties, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis, String tableIdentifier)

Constructors in org.apache.flink.streaming.connectors.kafka.table with parameters of type DecodingFormat

Constructor and Description
DecodingFormatWrapper(DecodingFormat<DeserializationSchema<RowData>> innerDecodingFormat)
KafkaDynamicSource(DataType physicalDataType, DecodingFormat<DeserializationSchema<RowData>> keyDecodingFormat, DecodingFormat<DeserializationSchema<RowData>> valueDecodingFormat, int[] keyProjection, int[] valueProjection, String keyPrefix, List<String> topics, Pattern topicPattern, Properties properties, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis, boolean upsertMode, String tableIdentifier)
KafkaDynamicSource(DataType physicalDataType, DecodingFormat<DeserializationSchema<RowData>> keyDecodingFormat, DecodingFormat<DeserializationSchema<RowData>> valueDecodingFormat, int[] keyProjection, int[] valueProjection, String keyPrefix, List<String> topics, Pattern topicPattern, Properties properties, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis, boolean upsertMode, String tableIdentifier)

Uses of DecodingFormat in org.apache.flink.streaming.connectors.kinesis.table

Constructors in org.apache.flink.streaming.connectors.kinesis.table with parameters of type DecodingFormat

Constructor and Description
KinesisDynamicSource(DataType physicalDataType, String stream, Properties consumerProperties, DecodingFormat<DeserializationSchema<RowData>> decodingFormat)
KinesisDynamicSource(DataType physicalDataType, String stream, Properties consumerProperties, DecodingFormat<DeserializationSchema<RowData>> decodingFormat, DataType producedDataType, List<RowDataKinesisDeserializationSchema.Metadata> requestedMetadataFields)

Uses of DecodingFormat in org.apache.flink.table.connector.format

Subinterfaces of DecodingFormat in org.apache.flink.table.connector.format

Modifier and Type	Interface and Description
interface	BulkDecodingFormat<T> A Format for a DynamicTableSource for reading rows by BulkFormat.

Uses of DecodingFormat in org.apache.flink.table.examples.java.connectors

Classes in org.apache.flink.table.examples.java.connectors that implement DecodingFormat

Modifier and Type	Class and Description
class	ChangelogCsvFormat The ChangelogCsvFormat is a decoding format that uses a DeserializationSchema during runtime.

Methods in org.apache.flink.table.examples.java.connectors that return DecodingFormat

Modifier and Type	Method and Description
DecodingFormat<DeserializationSchema<RowData>>	ChangelogCsvFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

Constructors in org.apache.flink.table.examples.java.connectors with parameters of type DecodingFormat

Constructor and Description
SocketDynamicTableSource(String hostname, int port, byte byteDelimiter, DecodingFormat<DeserializationSchema<RowData>> decodingFormat, DataType producedDataType)

Uses of DecodingFormat in org.apache.flink.table.factories

Methods in org.apache.flink.table.factories that return DecodingFormat

Modifier and Type	Method and Description
DecodingFormat<I>	DecodingFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions) Creates a format from the given context and format options.
<I,F extends DecodingFormatFactory<I>> DecodingFormat<I>	FactoryUtil.TableFactoryHelper.discoverDecodingFormat(Class<F> formatFactoryClass, ConfigOption<String> formatOption) Discovers a DecodingFormat of the given type using the given option as factory identifier.

Methods in org.apache.flink.table.factories that return types with arguments of type DecodingFormat

Modifier and Type	Method and Description
<I,F extends DecodingFormatFactory<I>> Optional<DecodingFormat<I>>	FactoryUtil.TableFactoryHelper.discoverOptionalDecodingFormat(Class<F> formatFactoryClass, ConfigOption<String> formatOption) Discovers a DecodingFormat of the given type using the given option (if present) as factory identifier.

Uses of DecodingFormat in org.apache.flink.table.filesystem

Constructors in org.apache.flink.table.filesystem with parameters of type DecodingFormat

Constructor and Description
FileSystemTableSource(DynamicTableFactory.Context context, DecodingFormat<BulkFormat<RowData,FileSourceSplit>> bulkReaderFormat, DecodingFormat<DeserializationSchema<RowData>> deserializationFormat, FileSystemFormatFactory formatFactory)
FileSystemTableSource(DynamicTableFactory.Context context, DecodingFormat<BulkFormat<RowData,FileSourceSplit>> bulkReaderFormat, DecodingFormat<DeserializationSchema<RowData>> deserializationFormat, FileSystemFormatFactory formatFactory)