org.apache.iceberg.connect.events

Class Event

java.lang.Object

org.apache.iceberg.connect.events.Event

All Implemented Interfaces:

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

public class Event
extends java.lang.Object
implements org.apache.avro.generic.IndexedRecord

Class representing all events produced to the control topic. Different event types have different payloads.

Constructor Summary

Constructors

Constructor and Description
Event(org.apache.avro.Schema avroSchema)
Event(java.lang.String groupId, Payload payload)

Method Summary

Modifier and Type	Method and Description
java.lang.Object	get(int i)
org.apache.avro.Schema	getSchema()
java.lang.String	groupId()
java.util.UUID	id()
Payload	payload()
void	put(int i, java.lang.Object v)
java.time.OffsetDateTime	timestamp()
PayloadType	type()

Methods inherited from class java.lang.Object

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

Constructor Detail

Event

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

Event

public Event(java.lang.String groupId,
             Payload payload)

Method Detail

id

public java.util.UUID id()

type

public PayloadType type()

timestamp

public java.time.OffsetDateTime timestamp()

payload

public Payload payload()

groupId

public java.lang.String groupId()

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