| Interface | Description |
|---|---|
| DebeziumDeserializationSchema<T> |
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 | Description |
|---|---|
| DebeziumSourceFunction<T> |
The
DebeziumSourceFunction is a streaming data source that pulls captured change data
from databases into Flink. |
| JsonDebeziumDeserializationSchema |
A JSON format implementation of
DebeziumDeserializationSchema which deserializes the
received SourceRecord to JSON String. |
| StringDebeziumDeserializationSchema |
A simple implementation of
DebeziumDeserializationSchema which converts the received
SourceRecord into String. |
Copyright © 2022 The Apache Software Foundation. All rights reserved.