Package org.apache.iceberg.connect.channel

Class CommitterImpl

java.lang.Object

org.apache.iceberg.connect.channel.CommitterImpl

All Implemented Interfaces:

Committer

public class CommitterImpl
extends Object
implements Committer

Constructor Summary

Constructors

Constructor	Description
CommitterImpl()

Method Summary

Modifier and Type	Method	Description
void	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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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