org.apache.flink.connector.pulsar.source.enumerator.topic

Class TopicPartition

java.lang.Object

org.apache.flink.connector.pulsar.source.enumerator.topic.TopicPartition

All Implemented Interfaces:

Serializable

@PublicEvolving
public class TopicPartition
extends Object
implements Serializable

Topic partition is the basic topic information used by SplitReader, we create this topic metas for a specified topic by subscription type and convert it into a partition split.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TopicPartition(String topic, int partitionId)
TopicPartition(String topic, int partitionId, TopicRange range)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
String	getFullTopicName() Pulsar split the topic partition into a bunch of small topics, we would get the real topic name by using this method.
int	getPartitionId()
org.apache.pulsar.client.api.Range	getPulsarRange()
TopicRange	getRange()
String	getTopic()
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

TopicPartition

public TopicPartition(String topic,
                      int partitionId)

TopicPartition

public TopicPartition(String topic,
                      int partitionId,
                      TopicRange range)

Method Detail

getTopic

public String getTopic()

getPartitionId

public int getPartitionId()

getFullTopicName

public String getFullTopicName()

Pulsar split the topic partition into a bunch of small topics, we would get the real topic name by using this method.

getRange

public TopicRange getRange()

getPulsarRange

public org.apache.pulsar.client.api.Range getPulsarRange()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object