Class CommitterImpl

java.lang.Object
org.apache.iceberg.connect.channel.CommitterImpl
All Implemented Interfaces:
Committer

public class CommitterImpl extends Object implements Committer
  • Constructor Details

    • CommitterImpl

      public CommitterImpl()
  • Method Details

    • start

      public void start(Catalog icebergCatalog, IcebergSinkConfig icebergSinkConfig, org.apache.kafka.connect.sink.SinkTaskContext sinkTaskContext)
      Specified by:
      start in interface Committer
    • open

      public void open(Catalog icebergCatalog, IcebergSinkConfig icebergSinkConfig, org.apache.kafka.connect.sink.SinkTaskContext sinkTaskContext, Collection<org.apache.kafka.common.TopicPartition> addedPartitions)
      Specified by:
      open in interface Committer
    • stop

      public void stop()
      Specified by:
      stop in interface Committer
    • close

      public void close(Collection<org.apache.kafka.common.TopicPartition> closedPartitions)
      Specified by:
      close in interface Committer
    • save

      public void save(Collection<org.apache.kafka.connect.sink.SinkRecord> sinkRecords)
      Specified by:
      save in interface Committer