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 Summary

Constructors

Constructor

Description

DataComplete(UUID commitId, List<TopicPartitionOffset> assignments)

DataComplete(org.apache.avro.Schema avroSchema)
Method Summary

Modifier and Type

Method

Description

List<TopicPartitionOffset>

assignments()

UUID

commitId()

Object

get(int i)

org.apache.avro.Schema

getSchema()

void

put(int i, Object v)

PayloadType

type()

Types.StructType

writeSchema()

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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