org.apache.iceberg.connect.data

Class IcebergWriter

java.lang.Object

org.apache.iceberg.connect.data.IcebergWriter

All Implemented Interfaces:

java.lang.Cloneable, RecordWriter

public class IcebergWriter
extends java.lang.Object
implements RecordWriter

Constructor Summary

Constructors

Constructor and Description
IcebergWriter(Table table, java.lang.String tableName, IcebergSinkConfig config)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

IcebergWriter

public IcebergWriter(Table table,
                     java.lang.String tableName,
                     IcebergSinkConfig config)

Method Detail

write

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

Specified by:

write in interface RecordWriter

complete

public java.util.List<WriterResult> complete()

Specified by:

complete in interface RecordWriter

close

public void close()

Specified by:

close in interface RecordWriter