Class CommitterImpl
java.lang.Object
org.apache.iceberg.connect.channel.CommitterImpl
- All Implemented Interfaces:
Committer
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
close
(Collection<org.apache.kafka.common.TopicPartition> closedPartitions) void
open
(Catalog icebergCatalog, IcebergSinkConfig icebergSinkConfig, org.apache.kafka.connect.sink.SinkTaskContext sinkTaskContext, Collection<org.apache.kafka.common.TopicPartition> addedPartitions) void
save
(Collection<org.apache.kafka.connect.sink.SinkRecord> sinkRecords) void
start
(Catalog icebergCatalog, IcebergSinkConfig icebergSinkConfig, org.apache.kafka.connect.sink.SinkTaskContext sinkTaskContext) void
stop()
-
Constructor Details
-
CommitterImpl
public CommitterImpl()
-
-
Method Details
-
start
public void start(Catalog icebergCatalog, IcebergSinkConfig icebergSinkConfig, org.apache.kafka.connect.sink.SinkTaskContext sinkTaskContext) -
open
public void open(Catalog icebergCatalog, IcebergSinkConfig icebergSinkConfig, org.apache.kafka.connect.sink.SinkTaskContext sinkTaskContext, Collection<org.apache.kafka.common.TopicPartition> addedPartitions) -
stop
public void stop() -
close
-
save
-