Uses of Package
org.apache.flink.cdc.debezium.table
-
Classes in org.apache.flink.cdc.debezium.table used by org.apache.flink.cdc.connectors.db2.table Class Description MetadataConverter A converter convertsSourceRecordmetadata into Flink internal data structures. -
Classes in org.apache.flink.cdc.debezium.table used by org.apache.flink.cdc.connectors.mongodb.table Class Description MetadataConverter A converter convertsSourceRecordmetadata into Flink internal data structures. -
Classes in org.apache.flink.cdc.debezium.table used by org.apache.flink.cdc.connectors.mysql.source Class Description DebeziumChangelogMode Changelog modes used to encode changes from Debezium to Flink internal structure. -
Classes in org.apache.flink.cdc.debezium.table used by org.apache.flink.cdc.connectors.mysql.table Class Description DeserializationRuntimeConverterFactory Factory to createDeserializationRuntimeConverteraccording toLogicalType.MetadataConverter A converter convertsSourceRecordmetadata into Flink internal data structures. -
Classes in org.apache.flink.cdc.debezium.table used by org.apache.flink.cdc.connectors.oracle.source Class Description DebeziumChangelogMode Changelog modes used to encode changes from Debezium to Flink internal structure. -
Classes in org.apache.flink.cdc.debezium.table used by org.apache.flink.cdc.connectors.oracle.table Class Description DeserializationRuntimeConverterFactory Factory to createDeserializationRuntimeConverteraccording toLogicalType.MetadataConverter A converter convertsSourceRecordmetadata into Flink internal data structures. -
Classes in org.apache.flink.cdc.debezium.table used by org.apache.flink.cdc.connectors.postgres.source Class Description DebeziumChangelogMode Changelog modes used to encode changes from Debezium to Flink internal structure. -
Classes in org.apache.flink.cdc.debezium.table used by org.apache.flink.cdc.connectors.postgres.source.config Class Description DebeziumChangelogMode Changelog modes used to encode changes from Debezium to Flink internal structure. -
Classes in org.apache.flink.cdc.debezium.table used by org.apache.flink.cdc.connectors.postgres.table Class Description DebeziumChangelogMode Changelog modes used to encode changes from Debezium to Flink internal structure.DeserializationRuntimeConverterFactory Factory to createDeserializationRuntimeConverteraccording toLogicalType.MetadataConverter A converter convertsSourceRecordmetadata into Flink internal data structures.RowDataDebeziumDeserializeSchema.ValueValidator Custom validator to validate the row value. -
Classes in org.apache.flink.cdc.debezium.table used by org.apache.flink.cdc.connectors.sqlserver.source Class Description DebeziumChangelogMode Changelog modes used to encode changes from Debezium to Flink internal structure. -
Classes in org.apache.flink.cdc.debezium.table used by org.apache.flink.cdc.connectors.sqlserver.table Class Description DeserializationRuntimeConverterFactory Factory to createDeserializationRuntimeConverteraccording toLogicalType.MetadataConverter A converter convertsSourceRecordmetadata into Flink internal data structures. -
Classes in org.apache.flink.cdc.debezium.table used by org.apache.flink.cdc.debezium.event Class Description DebeziumChangelogMode Changelog modes used to encode changes from Debezium to Flink internal structure.DeserializationRuntimeConverter Runtime converter that converts objects of Debezium into objects of Flink Table & SQL internal data structures. -
Classes in org.apache.flink.cdc.debezium.table used by org.apache.flink.cdc.debezium.table Class Description DebeziumChangelogMode Changelog modes used to encode changes from Debezium to Flink internal structure.DeserializationRuntimeConverter Runtime converter that converts objects of Debezium into objects of Flink Table & SQL internal data structures.DeserializationRuntimeConverterFactory Factory to createDeserializationRuntimeConverteraccording toLogicalType.MetadataConverter A converter convertsSourceRecordmetadata into Flink internal data structures.RowDataDebeziumDeserializeSchema Deserialization schema from Debezium object to Flink Table/SQL internal data structureRowData.RowDataDebeziumDeserializeSchema.Builder Builder ofRowDataDebeziumDeserializeSchema.RowDataDebeziumDeserializeSchema.ValueValidator Custom validator to validate the row value.