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 Description

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

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	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