Package org.apache.iceberg.connect.data

Class IcebergWriterFactory

java.lang.Object

org.apache.iceberg.connect.data.IcebergWriterFactory

public class IcebergWriterFactory
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
IcebergWriterFactory(Catalog catalog, IcebergSinkConfig config)

Method Summary

Modifier and Type	Method	Description
RecordWriter	createWriter(java.lang.String tableName, org.apache.kafka.connect.sink.SinkRecord sample, boolean ignoreMissingTable)

Methods inherited from class java.lang.Object

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

Constructor Detail

IcebergWriterFactory

public IcebergWriterFactory(Catalog catalog,
                            IcebergSinkConfig config)

Method Detail

createWriter

public RecordWriter createWriter(java.lang.String tableName,
                                 org.apache.kafka.connect.sink.SinkRecord sample,
                                 boolean ignoreMissingTable)