Package org.apache.iceberg.connect.data

Class SinkWriter

java.lang.Object

org.apache.iceberg.connect.data.SinkWriter

public class SinkWriter
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
SinkWriter(Catalog catalog, IcebergSinkConfig config)

Method Summary

Modifier and Type	Method	Description
void	close()
SinkWriterResult	completeWrite()
void	save(java.util.Collection<org.apache.kafka.connect.sink.SinkRecord> sinkRecords)

Methods inherited from class java.lang.Object

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

Constructor Detail

SinkWriter

public SinkWriter(Catalog catalog,
                  IcebergSinkConfig config)

Method Detail

close

public void close()

completeWrite

public SinkWriterResult completeWrite()

save

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