Package org.apache.flink.cdc.connectors.iceberg.sink.v2
-
Class Summary Class Description IcebergCommitter ACommitterfor Apache Iceberg.IcebergSink ASinkimplementation for Apache Iceberg.IcebergWriter ASinkWriterfor Apache Iceberg.IcebergWriterState The state of theIcebergWriter.IcebergWriterStateSerializer TableMetric Metrics of commit message for each table.TableSchemaWrapper A Wrapper forSchema.WriteResultWrapper A wrapper class forWriteResultandTableId.