StartCommit

java.lang.Object

org.apache.iceberg.connect.events.StartCommit

All Implemented Interfaces:: org.apache.avro.generic.GenericContainer, org.apache.avro.generic.IndexedRecord, Payload

public class StartCommit extends Object implements Payload

A control event payload for events sent by a coordinator to request workers to send back the table data that has been written and is ready to commit.

Constructor Summary

Constructors

Constructor

Description

StartCommit(UUID commitId)

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

Modifier and Type

Method

Description

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
- StartCommit
  
  public StartCommit(org.apache.avro.Schema avroSchema)
- StartCommit
  
  public StartCommit(UUID commitId)
Method Details
- type
  
  public PayloadType type()
  
  Specified by:
  
  type in interface Payload
- commitId
  
  public UUID commitId()
- 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