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.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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()
-
-
-
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 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
-
-