Class TopicPartitionOffset

java.lang.Object
org.apache.iceberg.connect.events.TopicPartitionOffset
All Implemented Interfaces:
org.apache.avro.generic.GenericContainer, org.apache.avro.generic.IndexedRecord

public class TopicPartitionOffset extends Object implements org.apache.avro.generic.IndexedRecord
Element representing an offset, with topic name, partition number, and offset.
  • Field Details Link icon

  • Constructor Details Link icon

    • TopicPartitionOffset Link icon

      public TopicPartitionOffset(org.apache.avro.Schema avroSchema)
    • TopicPartitionOffset Link icon

      public TopicPartitionOffset(String topic, int partition, Long offset, OffsetDateTime timestamp)
  • Method Details Link icon

    • topic Link icon

      public String topic()
    • partition Link icon

      public Integer partition()
    • offset Link icon

      public Long offset()
    • timestamp Link icon

      public OffsetDateTime timestamp()
    • getSchema Link icon

      public org.apache.avro.Schema getSchema()
      Specified by:
      getSchema in interface org.apache.avro.generic.GenericContainer
    • put Link icon

      public void put(int i, Object v)
      Specified by:
      put in interface org.apache.avro.generic.IndexedRecord
    • get Link icon

      public Object get(int i)
      Specified by:
      get in interface org.apache.avro.generic.IndexedRecord