Serialized Form

Package com.ververica.cdc.debezium

Class com.ververica.cdc.debezium.DebeziumSourceFunction extends org.apache.flink.streaming.api.functions.source.RichSourceFunction<T> implements Serializable

serialVersionUID:

-5808108641062931623L

Serialized Fields

deserializer

DebeziumDeserializationSchema<T> deserializer

The schema to convert from Debezium's messages into Flink's objects.

properties

Properties properties

User-supplied properties for Kafka. *

specificOffset

DebeziumOffset specificOffset

The specific binlog offset to read from when the first startup.

pendingOffsetsToCommit

org.apache.commons.collections.map.LinkedMap pendingOffsetsToCommit

Data for pending but uncommitted offsets.

debeziumStarted

boolean debeziumStarted

Flag indicating whether the Debezium Engine is started.

validator

Validator validator

Validator to validate the connected database satisfies the cdc connector's requirements.

Class com.ververica.cdc.debezium.JsonDebeziumDeserializationSchema extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

includeSchema

Boolean includeSchema

Configuration whether to enable JsonConverterConfig.SCHEMAS_ENABLE_CONFIG to include schema in messages.

customConverterConfigs

Map<K,V> customConverterConfigs

The custom configurations for JsonConverter.

Class com.ververica.cdc.debezium.StringDebeziumDeserializationSchema extends Object implements Serializable

serialVersionUID:

-3168848963265670603L

Package com.ververica.cdc.debezium.internal

Class com.ververica.cdc.debezium.internal.DebeziumOffset extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

sourcePartition

Map<K,V> sourcePartition

sourceOffset

Map<K,V> sourceOffset

Class com.ververica.cdc.debezium.internal.Handover.ClosedException extends Exception implements Serializable

serialVersionUID:

1L

Package com.ververica.cdc.debezium.table

Class com.ververica.cdc.debezium.table.AppendMetadataCollector extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

metadataConverters

MetadataConverter[] metadataConverters

Class com.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema extends Object implements Serializable

serialVersionUID:

2L

Serialized Fields

resultTypeInfo

org.apache.flink.api.common.typeinfo.TypeInformation<T> resultTypeInfo

TypeInformation of the produced RowData. *

physicalConverter

DeserializationRuntimeConverter physicalConverter

Runtime converter that converts Kafka SourceRecords into RowData consisted of physical column values.

hasMetadata

boolean hasMetadata

Whether the deserializer needs to handle metadata columns.

appendMetadataCollector

AppendMetadataCollector appendMetadataCollector

A wrapped output collector which is used to append metadata columns after physical columns.

validator

RowDataDebeziumDeserializeSchema.ValueValidator validator

Validator to validate the row value.

Package io.debezium.embedded

Class io.debezium.embedded.StopConnectorException extends io.debezium.DebeziumException implements Serializable

serialVersionUID:

1L