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 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 and Description
CommitComplete(org.apache.avro.Schema avroSchema)
CommitComplete(java.util.UUID commitId, java.time.OffsetDateTime validThroughTs)

Method Summary

Modifier and Type	Method and 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