Class DataComplete

java.lang.Object
org.apache.iceberg.connect.events.DataComplete
All Implemented Interfaces:
org.apache.avro.generic.GenericContainer, org.apache.avro.generic.IndexedRecord, Payload

public class DataComplete extends Object implements Payload
A control event payload for events sent by a worker that indicates it has finished sending all data for a commit request.
  • Constructor Details

    • DataComplete

      public DataComplete(org.apache.avro.Schema avroSchema)
    • DataComplete

      public DataComplete(UUID commitId, List<TopicPartitionOffset> assignments)
  • Method Details

    • type

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

      public UUID commitId()
    • assignments

      public List<TopicPartitionOffset> assignments()
    • 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