Package org.apache.iceberg.connect.transforms
package org.apache.iceberg.connect.transforms
-
ClassDescriptionCopyValue<R extends org.apache.kafka.connect.connector.ConnectRecord<R>>DebeziumTransform<R extends org.apache.kafka.connect.connector.ConnectRecord<R>>DmsTransform<R extends org.apache.kafka.connect.connector.ConnectRecord<R>>JsonToMapTransform<R extends org.apache.kafka.connect.connector.ConnectRecord<R>>Debezium Mongo Connector generates the CDC before/after fields as BSON strings.