| Class | Description |
|---|---|
| DebeziumChangeConsumer |
Consume debezium change events.
|
| DebeziumChangeFetcher<T> |
A Handler that convert change messages from
DebeziumEngine to data in Flink. |
| DebeziumOffset |
The state that the Flink Debezium Consumer holds for each instance.
|
| DebeziumOffsetSerializer |
Serializer implementation for a
DebeziumOffset. |
| FlinkDatabaseHistory |
Inspired from
MemoryDatabaseHistory but we will store the
HistoryRecords in Flink's state for persistence. |
| FlinkDatabaseSchemaHistory |
The
FlinkDatabaseSchemaHistory only stores the latest schema of the monitored tables. |
| FlinkOffsetBackingStore |
A implementation of
OffsetBackingStore backed on Flink's state mechanism. |
| Handover |
The Handover is a utility to hand over data (a buffer of records) and exception from a
producer thread to a consumer thread.
|
| SchemaRecord |
The Record represents a schema change event, it contains either one
HistoryRecord or
TableChanges.TableChange. |
| Exception | Description |
|---|---|
| Handover.ClosedException |
An exception thrown by the Handover in the
Handover.pollNext() or Handover.produce(List)
method, after the Handover was closed via Handover.close(). |
Copyright © 2022 The Apache Software Foundation. All rights reserved.