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 java.lang.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 Summary

Constructors
Constructor	Description
`CommitComplete(java.util.UUID commitId, java.time.OffsetDateTime validThroughTs)`
`CommitComplete(org.apache.avro.Schema avroSchema)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`java.util.UUID`	`commitId()`
`java.lang.Object`	`get(int i)`
`org.apache.avro.Schema`	`getSchema()`
`void`	`put(int i, java.lang.Object v)`
`PayloadType`	`type()`
`java.time.OffsetDateTime`	`validThroughTs()`	Valid-through timestamp, which is the min-of-max record timestamps across all workers for the commit.
`Types.StructType`	`writeSchema()`

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

- Constructor Detail
  - CommitComplete
```
public CommitComplete(org.apache.avro.Schema avroSchema)
```
  - CommitComplete
```
public CommitComplete(java.util.UUID commitId,
                      java.time.OffsetDateTime validThroughTs)
```
- Method Detail
  - type
```
public PayloadType type()
```
    Specified by:
    
    type in interface Payload
  - commitId
```
public java.util.UUID commitId()
```
  - validThroughTs
```
public java.time.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,
                java.lang.Object v)
```
    Specified by:
    
    put in interface org.apache.avro.generic.IndexedRecord
  - get
```
public java.lang.Object get(int i)
```
    Specified by:
    
    get in interface org.apache.avro.generic.IndexedRecord