Package org.apache.iceberg.connect.events

Class CommitComplete

java.lang.Object
org.apache.iceberg.connect.events.CommitComplete
All Implemented Interfaces:
org.apache.avro.generic.GenericContainer, org.apache.avro.generic.IndexedRecord, Payload
public class CommitComplete extends Object implements Payload
A control event payload for events sent by a coordinator that indicates it has completed a commit cycle. Events with this payload are not consumed by the sink, they are informational and can be used by consumers to trigger downstream processes.

  • Constructor Details

    • CommitComplete

      public CommitComplete(org.apache.avro.Schema avroSchema)

    • CommitComplete

      public CommitComplete(UUID commitId, OffsetDateTime validThroughTs)

  • Method Details

    • type

      public PayloadType type()
      Specified by:
      type in interface Payload

    • commitId

      public UUID commitId()

    • validThroughTs

      public OffsetDateTime validThroughTs()
      Valid-through timestamp, which is the min-of-max record timestamps across all workers for the commit.

    • writeSchema

      public Types.StructType writeSchema()
      Specified by:
      writeSchema in interface Payload

    • getSchema

      public org.apache.avro.Schema getSchema()
      Specified by:
      getSchema in interface org.apache.avro.generic.GenericContainer

    • put

      public void put(int i, Object v)
      Specified by:
      put in interface org.apache.avro.generic.IndexedRecord

    • get

      public Object get(int i)
      Specified by:
      get in interface org.apache.avro.generic.IndexedRecord