Package org.apache.iceberg.connect.data

Interface RecordWriter

All Superinterfaces:

java.lang.Cloneable

All Known Implementing Classes:

IcebergWriter, NoOpWriter

public interface RecordWriter
extends java.lang.Cloneable

Method Summary

Modifier and Type	Method	Description
void	close()
java.util.List<WriterResult>	complete()
void	write(org.apache.kafka.connect.sink.SinkRecord record)

Method Detail

write

void write(org.apache.kafka.connect.sink.SinkRecord record)

complete

java.util.List<WriterResult> complete()

close

void close()