Package org.apache.iceberg.connect.data

Class SinkWriter

java.lang.Object

org.apache.iceberg.connect.data.SinkWriter

public class SinkWriter
extends Object

Constructor Summary

Constructors

Constructor	Description
SinkWriter(Catalog catalog, IcebergSinkConfig config)

Method Summary

Modifier and Type	Method	Description
void	close()
SinkWriterResult	completeWrite()
void	save(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 Details

SinkWriter

public SinkWriter(Catalog catalog,
 IcebergSinkConfig config)

Method Details

close

public void close()

completeWrite

public SinkWriterResult completeWrite()

save

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