Package org.apache.iceberg.connect.data
Class SinkWriterResult
- java.lang.Object
-
- org.apache.iceberg.connect.data.SinkWriterResult
-
public class SinkWriterResult extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description SinkWriterResult(java.util.List<IcebergWriterResult> writerResults, java.util.Map<org.apache.kafka.common.TopicPartition,Offset> sourceOffsets)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.Map<org.apache.kafka.common.TopicPartition,Offset>
sourceOffsets()
java.util.List<IcebergWriterResult>
writerResults()
-
-
-
Constructor Detail
-
SinkWriterResult
public SinkWriterResult(java.util.List<IcebergWriterResult> writerResults, java.util.Map<org.apache.kafka.common.TopicPartition,Offset> sourceOffsets)
-
-
Method Detail
-
writerResults
public java.util.List<IcebergWriterResult> writerResults()
-
sourceOffsets
public java.util.Map<org.apache.kafka.common.TopicPartition,Offset> sourceOffsets()
-
-