Package org.apache.iceberg.connect

Interface Committer

All Known Implementing Classes:

CommitterImpl

public interface Committer

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()

Method Detail

start

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

stop

void stop()

save

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