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.IndexedRecordClass representing all events produced to the control topic. Different event types have different payloads.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.Objectget(int i)org.apache.avro.SchemagetSchema()java.lang.StringgroupId()java.util.UUIDid()Payloadpayload()voidput(int i, java.lang.Object v)java.time.OffsetDateTimetimestamp()PayloadTypetype()
-
-
-
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:
getSchemain interfaceorg.apache.avro.generic.GenericContainer
-
put
public void put(int i, java.lang.Object v)- Specified by:
putin interfaceorg.apache.avro.generic.IndexedRecord
-
get
public java.lang.Object get(int i)
- Specified by:
getin interfaceorg.apache.avro.generic.IndexedRecord
-
-