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 java.lang.Object
implements Committer

Constructor Summary

Constructors

Constructor	Description
CommitterImpl()

Method Summary

Modifier and Type	Method	Description
void	save(java.util.Collection<org.apache.kafka.connect.sink.SinkRecord> sinkRecords)
void	start(Catalog catalog, IcebergSinkConfig config, org.apache.kafka.connect.sink.SinkTaskContext context)
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

CommitterImpl

public CommitterImpl()

Method Detail

start

public void start(Catalog catalog,
                  IcebergSinkConfig config,
                  org.apache.kafka.connect.sink.SinkTaskContext context)

Specified by:

start in interface Committer

save

public void save(java.util.Collection<org.apache.kafka.connect.sink.SinkRecord> sinkRecords)

Specified by:

save in interface Committer

stop

public void stop()

Specified by:

stop in interface Committer