Package org.apache.iceberg.connect
Class IcebergSinkTask
- java.lang.Object
-
- org.apache.kafka.connect.sink.SinkTask
-
- org.apache.iceberg.connect.IcebergSinkTask
-
- All Implemented Interfaces:
org.apache.kafka.connect.connector.Task
public class IcebergSinkTask extends org.apache.kafka.connect.sink.SinkTask
-
-
Constructor Summary
Constructors Constructor Description IcebergSinkTask()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)
void
flush(java.util.Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> currentOffsets)
void
open(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)
java.util.Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata>
preCommit(java.util.Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> currentOffsets)
void
put(java.util.Collection<org.apache.kafka.connect.sink.SinkRecord> sinkRecords)
void
start(java.util.Map<java.lang.String,java.lang.String> props)
void
stop()
java.lang.String
version()
-
-
-
Method Detail
-
version
public java.lang.String version()
-
start
public void start(java.util.Map<java.lang.String,java.lang.String> props)
- Specified by:
start
in interfaceorg.apache.kafka.connect.connector.Task
- Specified by:
start
in classorg.apache.kafka.connect.sink.SinkTask
-
open
public void open(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)
- Overrides:
open
in classorg.apache.kafka.connect.sink.SinkTask
-
close
public void close(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)
- Overrides:
close
in classorg.apache.kafka.connect.sink.SinkTask
-
put
public void put(java.util.Collection<org.apache.kafka.connect.sink.SinkRecord> sinkRecords)
- Specified by:
put
in classorg.apache.kafka.connect.sink.SinkTask
-
flush
public void flush(java.util.Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> currentOffsets)
- Overrides:
flush
in classorg.apache.kafka.connect.sink.SinkTask
-
preCommit
public java.util.Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> preCommit(java.util.Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> currentOffsets)
- Overrides:
preCommit
in classorg.apache.kafka.connect.sink.SinkTask
-
stop
public void stop()
- Specified by:
stop
in interfaceorg.apache.kafka.connect.connector.Task
- Specified by:
stop
in classorg.apache.kafka.connect.sink.SinkTask
-
-