org.apache.iceberg.connect.events

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 java.lang.Object
implements org.apache.avro.generic.IndexedRecord

Element representing an offset, with topic name, partition number, and offset.

Field Summary

Fields

Modifier and Type	Field and Description
static Types.StructType	ICEBERG_SCHEMA

Constructor Summary

Constructors

Constructor and Description
TopicPartitionOffset(org.apache.avro.Schema avroSchema)
TopicPartitionOffset(java.lang.String topic, int partition, java.lang.Long offset, java.time.OffsetDateTime timestamp)

Method Summary

Modifier and Type	Method and Description
java.lang.Object	get(int i)
org.apache.avro.Schema	getSchema()
java.lang.Long	offset()
java.lang.Integer	partition()
void	put(int i, java.lang.Object v)
java.time.OffsetDateTime	timestamp()
java.lang.String	topic()

Methods inherited from class java.lang.Object

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

Field Detail

ICEBERG_SCHEMA

public static final Types.StructType ICEBERG_SCHEMA

Constructor Detail

TopicPartitionOffset

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

TopicPartitionOffset

public TopicPartitionOffset(java.lang.String topic,
                            int partition,
                            java.lang.Long offset,
                            java.time.OffsetDateTime timestamp)

Method Detail

topic

public java.lang.String topic()

partition

public java.lang.Integer partition()

offset

public java.lang.Long offset()

timestamp

public java.time.OffsetDateTime timestamp()

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