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 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 CommitToTable(java.util.UUID commitId, TableReference tableReference, java.lang.Long snapshotId, java.time.OffsetDateTime validThroughTs)
CommitToTable(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)
java.lang.Long
snapshotId()
TableReference
tableReference()
PayloadType
type()
java.time.OffsetDateTime
validThroughTs()
Types.StructType
writeSchema()
-
-
-
Constructor Detail
-
CommitToTable
public CommitToTable(org.apache.avro.Schema avroSchema)
-
CommitToTable
public CommitToTable(java.util.UUID commitId, TableReference tableReference, java.lang.Long snapshotId, java.time.OffsetDateTime validThroughTs)
-
-
Method Detail
-
type
public PayloadType type()
-
commitId
public java.util.UUID commitId()
-
tableReference
public TableReference tableReference()
-
snapshotId
public java.lang.Long snapshotId()
-
validThroughTs
public java.time.OffsetDateTime validThroughTs()
-
writeSchema
public Types.StructType writeSchema()
- Specified by:
writeSchema
in interfacePayload
-
getSchema
public org.apache.avro.Schema getSchema()
- Specified by:
getSchema
in interfaceorg.apache.avro.generic.GenericContainer
-
put
public void put(int i, java.lang.Object v)
- Specified by:
put
in interfaceorg.apache.avro.generic.IndexedRecord
-
get
public java.lang.Object get(int i)
- Specified by:
get
in interfaceorg.apache.avro.generic.IndexedRecord
-
-