Package 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 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	Description
static final Types.StructType	ICEBERG_SCHEMA

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

ICEBERG_SCHEMA

public static final Types.StructType ICEBERG_SCHEMA

Constructor Details

TopicPartitionOffset

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

TopicPartitionOffset

public TopicPartitionOffset(String topic,
 int partition,
 Long offset,
 OffsetDateTime timestamp)

Method Details

topic

public String topic()

partition

public Integer partition()

offset

public Long offset()

timestamp

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