类 com.taobao.metamorphosis.cluster.Partition
的使用

使用 Partition 的软件包

com.taobao.metamorphosis
com.taobao.metamorphosis.client
com.taobao.metamorphosis.client.consumer
com.taobao.metamorphosis.client.consumer.storage
com.taobao.metamorphosis.client.extension.producer
com.taobao.metamorphosis.client.extension.spring
com.taobao.metamorphosis.client.producer
com.taobao.metamorphosis.cluster
com.taobao.metamorphosis.metaslave
com.taobao.metamorphosis.tools.monitor.core
com.taobao.metamorphosis.tools.query
com.taobao.metamorphosis.tools.shell
com.taobao.metamorphosis.utils

com.taobao.metamorphosis 中 Partition 的使用

返回 Partition 的 com.taobao.metamorphosis 中的方法

Partition

Message.getPartition() Returns message's partition in broker,if it was sent fail,it would be null.

参数类型为 Partition 的 com.taobao.metamorphosis 中的方法

static void

MessageAccessor.setPartition(Message message, Partition partition)

com.taobao.metamorphosis.client 中 Partition 的使用

类型参数类型为 Partition 的 com.taobao.metamorphosis.client 中的字段

protected List<Partition>

MetaTopicBrowser.Itr.partitions

返回变量类型为 Partition 的类型的 com.taobao.metamorphosis.client 中的方法

List<Partition>	TopicBrowser.getPartitions() Returns topic's all alive partitions.
List<Partition>	MetaTopicBrowser.getPartitions()
List<Partition>	MetaMessageSessionFactory.getPartitionsForTopic(String topic)
List<Partition>	MessageSessionFactory.getPartitionsForTopic(String topic) Get partitions list for topic

类型变量类型为 Partition 的 com.taobao.metamorphosis.client 中的构造方法参数

MetaTopicBrowser.Itr(List<Partition> partitions)

MetaTopicBrowser(String topic, int maxSize, long timeoutInMills, MessageConsumer consumer, List<Partition> partitions)

com.taobao.metamorphosis.client.consumer 中 Partition 的使用

返回 Partition 的 com.taobao.metamorphosis.client.consumer 中的方法

Partition	TopicPartitionRegInfo.getPartition()
Partition	FetchRequest.getPartitionObject()

返回变量类型为 Partition 的类型的 com.taobao.metamorphosis.client.consumer 中的方法

Map<String,Set<Partition>>

ConsumerZooKeeper.ZKLoadRebalanceListener.getTopicPartitions() Returns current topic-partitions info.

参数类型为 Partition 的 com.taobao.metamorphosis.client.consumer 中的方法

MessageIterator	SimpleMessageConsumer.get(String topic, Partition partition, long offset, int maxSize)
MessageIterator	MessageConsumer.get(String topic, Partition partition, long offset, int maxSize) 获取指定topic和分区下面的消息，默认超时10秒
MessageIterator	SimpleMessageConsumer.get(String topic, Partition partition, long offset, int maxSize, long timeout, TimeUnit timeUnit)
MessageIterator	MessageConsumer.get(String topic, Partition partition, long offset, int maxSize, long timeout, TimeUnit timeUnit) 获取指定topic和分区下面的消息，在指定时间内没有返回则抛出异常
void	TopicPartitionRegInfo.setPartition(Partition partition)

参数类型为 Partition 的 com.taobao.metamorphosis.client.consumer 中的构造方法

TopicPartitionRegInfo(String topic, Partition partition, long offset)

TopicPartitionRegInfo(String topic, Partition partition, long offset, long messageId)

com.taobao.metamorphosis.client.consumer.storage 中 Partition 的使用

参数类型为 Partition 的 com.taobao.metamorphosis.client.consumer.storage 中的方法

void	ZkOffsetStorage.initOffset(String topic, String group, Partition partition, long offset)
void	TairOffsetStorage.initOffset(String topic, String group, Partition partition, long offset)
void	OffsetStorage.initOffset(String topic, String group, Partition partition, long offset) 初始化offset
void	MysqlOffsetStorage.initOffset(String topic, String group, Partition partition, long offset)
void	LocalOffsetStorage.initOffset(String topic, String group, Partition partition, long offset)
TopicPartitionRegInfo	ZkOffsetStorage.load(String topic, String group, Partition partition)
TopicPartitionRegInfo	TairOffsetStorage.load(String topic, String group, Partition partition)
TopicPartitionRegInfo	OffsetStorage.load(String topic, String group, Partition partition) 加载一条消费者的订阅信息，如果不存在返回null
TopicPartitionRegInfo	MysqlOffsetStorage.load(String topic, String group, Partition partition)
TopicPartitionRegInfo	LocalOffsetStorage.load(String topic, String group, Partition partition)

com.taobao.metamorphosis.client.extension.producer 中 Partition 的使用

返回 Partition 的 com.taobao.metamorphosis.client.extension.producer 中的方法

protected abstract Partition	OrderedMessagePartitionSelector.choosePartition(String topic, List<Partition> partitions, Message message)
Partition	OrderedMessagePartitionSelector.getPartition(String topic, List<Partition> partitions, Message message)

返回变量类型为 Partition 的类型的 com.taobao.metamorphosis.client.extension.producer 中的方法

List<Partition>	ConfigPartitionsSupport.getConfigPartitions(String topic)
List<Partition>	ConfigPartitionsAware.getConfigPartitions(String topic) 获取某个topic消息的总体分区信息
Map<String,List<Partition>>	ProducerDiamondManager.getPartitions()

参数类型为 Partition 的 com.taobao.metamorphosis.client.extension.producer 中的方法

void	MessageRecoverManager.append(Message message, Partition partition) 存入消息
void	LocalMessageStorageManager.append(Message message, Partition partition)
protected String	LocalMessageStorageManager.generateKey(String topic, Partition partition)
int	MessageRecoverManager.getMessageCount(String topic, Partition partition) 消息条数
int	LocalMessageStorageManager.getMessageCount(String topic, Partition partition)
protected Store	LocalMessageStorageManager.getOrCreateStore(String topic, Partition partition)
protected BooleanCommand	AsyncMetaMessageProducer.invokeToGroup(String serverUrl, Partition partition, PutCommand putCommand, Message message, long timeout, TimeUnit unit)
boolean	OrderedLocalMessageStorageManager.recover(String topic, Partition partition, MessageRecoverManager.MessageRecoverer recoverer) 触发恢复一个主题一个分区的消息,可多次调用(保证对某主题的恢复任务最多只有一个在运行)
boolean	MessageRecoverManager.recover(String topic, Partition partition, MessageRecoverManager.MessageRecoverer recoverer) 触发恢复一个主题一个分区的消息
boolean	LocalMessageStorageManager.recover(String topic, Partition partition, MessageRecoverManager.MessageRecoverer recoverer) 触发恢复一个主题一个分区的消息,可多次调用(保证对某主题的恢复任务最多只有一个在运行)

类型变量类型为 Partition 的 com.taobao.metamorphosis.client.extension.producer 中的方法参数

protected abstract Partition	OrderedMessagePartitionSelector.choosePartition(String topic, List<Partition> partitions, Message message)
Partition	OrderedMessagePartitionSelector.getPartition(String topic, List<Partition> partitions, Message message)
void	ConfigPartitionsSupport.setConfigPartitions(Map<String,List<Partition>> map)
void	ConfigPartitionsAware.setConfigPartitions(Map<String,List<Partition>> map) 设置顺序消息配置的总体分区信息

com.taobao.metamorphosis.client.extension.spring 中 Partition 的使用

返回 Partition 的 com.taobao.metamorphosis.client.extension.spring 中的方法

Partition

MetaqMessage.getPartition()

com.taobao.metamorphosis.client.producer 中 Partition 的使用

返回 Partition 的 com.taobao.metamorphosis.client.producer 中的方法

Partition	SendResult.getPartition() 消息发送所到达的分区
Partition	PartitionSelector.getPartition(String topic, List<Partition> partitions, Message message) 根据topic、message从partitions列表中选择分区
Partition	AbstractPartitionSelector.getPartition(String topic, List<Partition> partitions, Message message)
Partition	RoundRobinPartitionSelector.getPartition0(String topic, List<Partition> partitions, Message message)
Partition	RandomPartitionSelector.getPartition0(String topic, List<Partition> partitions, Message message)
abstract Partition	AbstractPartitionSelector.getPartition0(String topic, List<Partition> partitions, Message message)
Partition	ProducerZooKeeper.selectPartition(String topic, Message message, PartitionSelector partitionSelector) 根据topic和message选择分区

参数类型为 Partition 的 com.taobao.metamorphosis.client.producer 中的方法

protected BooleanCommand	SimpleMessageProducer.invokeToGroup(String serverUrl, Partition partition, PutCommand putCommand, Message message, long timeout, TimeUnit unit)
String	ProducerZooKeeper.selectBroker(String topic, Partition partition) 根据partition寻找broker url

类型变量类型为 Partition 的 com.taobao.metamorphosis.client.producer 中的方法参数

Partition	PartitionSelector.getPartition(String topic, List<Partition> partitions, Message message) 根据topic、message从partitions列表中选择分区
Partition	AbstractPartitionSelector.getPartition(String topic, List<Partition> partitions, Message message)
Partition	RoundRobinPartitionSelector.getPartition0(String topic, List<Partition> partitions, Message message)
Partition	RandomPartitionSelector.getPartition0(String topic, List<Partition> partitions, Message message)
abstract Partition	AbstractPartitionSelector.getPartition0(String topic, List<Partition> partitions, Message message)

参数类型为 Partition 的 com.taobao.metamorphosis.client.producer 中的构造方法

SendResult(boolean success, Partition partition, long offset, String errorMessage)

类型变量类型为 Partition 的 com.taobao.metamorphosis.client.producer 中的构造方法参数

ProducerZooKeeper.BrokersInfo(Map<Integer,String> oldBrokerStringMap, Map<String,List<Partition>> oldTopicPartitionMap)

com.taobao.metamorphosis.cluster 中 Partition 的使用

声明为 Partition 的 com.taobao.metamorphosis.cluster 中的字段

static Partition

Partition.RandomPartiton

返回 Partition 的 com.taobao.metamorphosis.cluster 中的方法

Partition

Partition.duplicate() 返回此partition对象的复制品

参数类型为 Partition 的 com.taobao.metamorphosis.cluster 中的方法

int	Partition.compareTo(Partition o)

com.taobao.metamorphosis.metaslave 中 Partition 的使用

参数类型为 Partition 的 com.taobao.metamorphosis.metaslave 中的方法

void	SlaveOffsetStorage.initOffset(String topic, String group, Partition partition, long offset)
TopicPartitionRegInfo	SlaveOffsetStorage.load(String topic, String group, Partition partition)

com.taobao.metamorphosis.tools.monitor.core 中 Partition 的使用

返回 Partition 的 com.taobao.metamorphosis.tools.monitor.core 中的方法

Partition

ReveiceResult.getPartition()

参数类型为 Partition 的 com.taobao.metamorphosis.tools.monitor.core 中的方法

ReveiceResult	MsgReceiver.get(String topic, Partition partition) 同步的方式接收消息.
long	MsgReceiver.getOffset(Partition partition)
void	MsgReceiver.setOffset(Partition partition, long offset)

com.taobao.metamorphosis.tools.query 中 Partition 的使用

参数类型为 Partition 的 com.taobao.metamorphosis.tools.query 中的方法

String

Query.getOffsetPath(String group, String topic, Partition partition)

com.taobao.metamorphosis.tools.shell 中 Partition 的使用

参数类型为 Partition 的 com.taobao.metamorphosis.tools.shell 中的方法

void	ZkManager.setOffset(String topic, String group, Partition partition, String srcOffset)

com.taobao.metamorphosis.utils 中 Partition 的使用

返回变量类型为 Partition 的类型的 com.taobao.metamorphosis.utils 中的方法

Map<String,List<Partition>>	MetaZookeeper.getPartitionsForSubTopicsFromMaster(Collection<String> topics, int brokerId) 返回一个master 下的topic到partition映射的map
Map<String,List<Partition>>	MetaZookeeper.getPartitionsForTopicsFromMaster(Collection<String> topics) 返回master的topic到partition映射的map

类型变量类型为 Partition 的 com.taobao.metamorphosis.utils 中的方法参数

static void

DiamondUtils.getPartitions(Properties properties, Map<String,List<Partition>> ret) 获取某些topic分区总数的信息(某topic共有哪些分区)