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 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

Description

Event(String groupId, Payload payload)

Event(org.apache.avro.Schema avroSchema)
Method Summary

Modifier and Type

Method

Description

Object

get(int i)

org.apache.avro.Schema

getSchema()

String

groupId()

UUID

id()

Payload

payload()

void

put(int i, Object v)

OffsetDateTime

timestamp()

PayloadType

type()

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- Event
  
  public Event(org.apache.avro.Schema avroSchema)
- Event
  
  public Event(String groupId, Payload payload)
Method Details
- id
  
  public UUID id()
- type
  
  public PayloadType type()
- timestamp
  
  public OffsetDateTime timestamp()
- payload
  
  public Payload payload()
- groupId
  
  public 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, 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