Package org.apache.iceberg.connect

Interface Committer

All Known Implementing Classes:
CommitterImpl
public interface Committer

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    save(Collection<org.apache.kafka.connect.sink.SinkRecord> sinkRecords)
     
    void
    start(Catalog catalog, IcebergSinkConfig config, org.apache.kafka.connect.sink.SinkTaskContext context)
     
    void
    stop()
     

  • Method Details

    • start

      void start(Catalog catalog, IcebergSinkConfig config, org.apache.kafka.connect.sink.SinkTaskContext context)

    • stop

      void stop()

    • save

      void save(Collection<org.apache.kafka.connect.sink.SinkRecord> sinkRecords)