Package org.apache.iceberg.connect
Interface Committer
- All Known Implementing Classes:
CommitterImpl
public interface Committer
-
Method Summary
Modifier and TypeMethodDescriptiondefault void
close
(Collection<org.apache.kafka.common.TopicPartition> closedPartitions) default void
open
(Catalog catalog, IcebergSinkConfig config, org.apache.kafka.connect.sink.SinkTaskContext context, Collection<org.apache.kafka.common.TopicPartition> addedPartitions) void
save
(Collection<org.apache.kafka.connect.sink.SinkRecord> sinkRecords) void
start
(Catalog catalog, IcebergSinkConfig config, org.apache.kafka.connect.sink.SinkTaskContext context) Deprecated.will be removed in 2.0.0.void
stop()
Deprecated.will be removed in 2.0.0.
-
Method Details
-
start
@Deprecated void start(Catalog catalog, IcebergSinkConfig config, org.apache.kafka.connect.sink.SinkTaskContext context) Deprecated.will be removed in 2.0.0. Useopen(Catalog, IcebergSinkConfig, SinkTaskContext, Collection)
instead. -
open
default void open(Catalog catalog, IcebergSinkConfig config, org.apache.kafka.connect.sink.SinkTaskContext context, Collection<org.apache.kafka.common.TopicPartition> addedPartitions) -
stop
Deprecated.will be removed in 2.0.0. Useclose(Collection)
instead. -
close
-
save
-