| Package | Description |
|---|---|
| com.ververica.cdc.debezium | |
| com.ververica.cdc.debezium.internal | |
| com.ververica.cdc.debezium.table |
| Class and Description |
|---|
| DebeziumDeserializationSchema
The deserialization schema describes how to turn the Debezium SourceRecord into data types
(Java/Scala objects) that are processed by Flink.
|
| Validator
Validator to validate the connected database satisfies the cdc connector's requirements.
|
| Class and Description |
|---|
| DebeziumDeserializationSchema
The deserialization schema describes how to turn the Debezium SourceRecord into data types
(Java/Scala objects) that are processed by Flink.
|
| Class and Description |
|---|
| DebeziumDeserializationSchema
The deserialization schema describes how to turn the Debezium SourceRecord into data types
(Java/Scala objects) that are processed by Flink.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.