Class SinkWriterResult


  • public class SinkWriterResult
    extends java.lang.Object
    • Constructor Detail

      • SinkWriterResult

        public SinkWriterResult​(java.util.List<IcebergWriterResult> writerResults,
                                java.util.Map<org.apache.kafka.common.TopicPartition,​Offset> sourceOffsets)
    • Method Detail

      • sourceOffsets

        public java.util.Map<org.apache.kafka.common.TopicPartition,​Offset> sourceOffsets()