Package org.apache.iceberg.connect.events

Class CommitToTable

java.lang.Object

org.apache.iceberg.connect.events.CommitToTable

All Implemented Interfaces:

org.apache.avro.generic.GenericContainer, org.apache.avro.generic.IndexedRecord, Payload

public class CommitToTable
extends 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
CommitToTable(UUID commitId, TableReference tableReference, Long snapshotId, OffsetDateTime validThroughTs)
CommitToTable(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)
Long	snapshotId()
TableReference	tableReference()
PayloadType	type()
OffsetDateTime	validThroughTs()
Types.StructType	writeSchema()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CommitToTable

public CommitToTable(org.apache.avro.Schema avroSchema)

CommitToTable

public CommitToTable(UUID commitId,
 TableReference tableReference,
 Long snapshotId,
 OffsetDateTime validThroughTs)

Method Details

type

public PayloadType type()

Specified by:

type in interface Payload

commitId

public UUID commitId()

tableReference

public TableReference tableReference()

snapshotId

public Long snapshotId()

validThroughTs

public OffsetDateTime validThroughTs()

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