类的使用
org.joyqueue.client.internal.metadata.domain.PartitionMetadata

使用PartitionMetadata的程序包

程序包	说明
io.openmessaging.joyqueue.extension
org.joyqueue.client.internal.metadata.converter
org.joyqueue.client.internal.metadata.domain
org.joyqueue.client.internal.producer
org.joyqueue.client.internal.producer.helper
org.joyqueue.client.internal.producer.support

io.openmessaging.joyqueue.extension中PartitionMetadata的使用

参数类型为PartitionMetadata的io.openmessaging.joyqueue.extension中的构造器

构造器和说明
PartitionAdapter(PartitionMetadata partitionMetadata)

org.joyqueue.client.internal.metadata.converter中PartitionMetadata的使用

返回PartitionMetadata的org.joyqueue.client.internal.metadata.converter中的方法

限定符和类型	方法和说明
static PartitionMetadata	ClusterMetadataConverter.convertPartitionMetadata(String topic, TopicPartition topicPartition, int partitionGroupId, BrokerNode leader)

org.joyqueue.client.internal.metadata.domain中PartitionMetadata的使用

返回PartitionMetadata的org.joyqueue.client.internal.metadata.domain中的方法

限定符和类型	方法和说明
PartitionMetadata	TopicMetadata.getPartition(short partition)

返回变量类型为PartitionMetadata的类型的org.joyqueue.client.internal.metadata.domain中的方法

限定符和类型	方法和说明
List<PartitionMetadata>	TopicMetadata.getBrokerPartitions(int brokerId)
List<PartitionMetadata>	UnmodifiableTopicMetadata.getPartitions() 已过时。
Map<Short,PartitionMetadata>	PartitionGroupMetadata.getPartitions()
List<PartitionMetadata>	TopicMetadata.getPartitions()

类型变量类型为PartitionMetadata的org.joyqueue.client.internal.metadata.domain中的构造器参数

构造器和说明
PartitionGroupMetadata(int id, BrokerNode leader, Map<Short,PartitionMetadata> partitions)
TopicMetadata(String topic, org.joyqueue.domain.ProducerPolicy producerPolicy, org.joyqueue.domain.ConsumerPolicy consumerPolicy, org.joyqueue.domain.TopicType type, List<PartitionGroupMetadata> partitionGroups, List<PartitionMetadata> partitions, Map<Short,PartitionMetadata> partitionMap, Map<Integer,PartitionGroupMetadata> partitionGroupMap, List<BrokerNode> brokers, List<BrokerNode> nearbyBrokers, Map<Integer,BrokerNode> brokerMap, Map<Integer,List<PartitionMetadata>> brokerPartitions, Map<Integer,List<PartitionGroupMetadata>> brokerPartitionGroups, boolean allAvailable, org.joyqueue.exception.JoyQueueCode code)
TopicMetadata(String topic, org.joyqueue.domain.ProducerPolicy producerPolicy, org.joyqueue.domain.ConsumerPolicy consumerPolicy, org.joyqueue.domain.TopicType type, List<PartitionGroupMetadata> partitionGroups, List<PartitionMetadata> partitions, Map<Short,PartitionMetadata> partitionMap, Map<Integer,PartitionGroupMetadata> partitionGroupMap, List<BrokerNode> brokers, List<BrokerNode> nearbyBrokers, Map<Integer,BrokerNode> brokerMap, Map<Integer,List<PartitionMetadata>> brokerPartitions, Map<Integer,List<PartitionGroupMetadata>> brokerPartitionGroups, boolean allAvailable, org.joyqueue.exception.JoyQueueCode code)
TopicMetadata(String topic, org.joyqueue.domain.ProducerPolicy producerPolicy, org.joyqueue.domain.ConsumerPolicy consumerPolicy, org.joyqueue.domain.TopicType type, List<PartitionGroupMetadata> partitionGroups, List<PartitionMetadata> partitions, Map<Short,PartitionMetadata> partitionMap, Map<Integer,PartitionGroupMetadata> partitionGroupMap, List<BrokerNode> brokers, List<BrokerNode> nearbyBrokers, Map<Integer,BrokerNode> brokerMap, Map<Integer,List<PartitionMetadata>> brokerPartitions, Map<Integer,List<PartitionGroupMetadata>> brokerPartitionGroups, boolean allAvailable, org.joyqueue.exception.JoyQueueCode code)
UnmodifiableTopicMetadata(String topic, org.joyqueue.domain.ProducerPolicy producerPolicy, org.joyqueue.domain.ConsumerPolicy consumerPolicy, org.joyqueue.domain.TopicType type, List<PartitionGroupMetadata> partitionGroups, List<PartitionMetadata> partitions, Map<Short,PartitionMetadata> partitionMap, Map<Integer,PartitionGroupMetadata> partitionGroupMap, List<BrokerNode> brokers, List<BrokerNode> nearbyBrokers, Map<Integer,BrokerNode> brokerMap, Map<Integer,List<PartitionMetadata>> brokerPartitions, Map<Integer,List<PartitionGroupMetadata>> brokerPartitionGroups, boolean allAvailable, org.joyqueue.exception.JoyQueueCode code) 已过时。
UnmodifiableTopicMetadata(String topic, org.joyqueue.domain.ProducerPolicy producerPolicy, org.joyqueue.domain.ConsumerPolicy consumerPolicy, org.joyqueue.domain.TopicType type, List<PartitionGroupMetadata> partitionGroups, List<PartitionMetadata> partitions, Map<Short,PartitionMetadata> partitionMap, Map<Integer,PartitionGroupMetadata> partitionGroupMap, List<BrokerNode> brokers, List<BrokerNode> nearbyBrokers, Map<Integer,BrokerNode> brokerMap, Map<Integer,List<PartitionMetadata>> brokerPartitions, Map<Integer,List<PartitionGroupMetadata>> brokerPartitionGroups, boolean allAvailable, org.joyqueue.exception.JoyQueueCode code) 已过时。
UnmodifiableTopicMetadata(String topic, org.joyqueue.domain.ProducerPolicy producerPolicy, org.joyqueue.domain.ConsumerPolicy consumerPolicy, org.joyqueue.domain.TopicType type, List<PartitionGroupMetadata> partitionGroups, List<PartitionMetadata> partitions, Map<Short,PartitionMetadata> partitionMap, Map<Integer,PartitionGroupMetadata> partitionGroupMap, List<BrokerNode> brokers, List<BrokerNode> nearbyBrokers, Map<Integer,BrokerNode> brokerMap, Map<Integer,List<PartitionMetadata>> brokerPartitions, Map<Integer,List<PartitionGroupMetadata>> brokerPartitionGroups, boolean allAvailable, org.joyqueue.exception.JoyQueueCode code) 已过时。

org.joyqueue.client.internal.producer中PartitionMetadata的使用

返回PartitionMetadata的org.joyqueue.client.internal.producer中的方法

限定符和类型	方法和说明
PartitionMetadata	PartitionSelector.select(ProduceMessage message, TopicMetadata topicMetadata, List<PartitionMetadata> partitions)

类型变量类型为PartitionMetadata的org.joyqueue.client.internal.producer中的方法参数

限定符和类型	方法和说明
PartitionMetadata	PartitionSelector.select(ProduceMessage message, TopicMetadata topicMetadata, List<PartitionMetadata> partitions)

org.joyqueue.client.internal.producer.helper中PartitionMetadata的使用

返回PartitionMetadata的org.joyqueue.client.internal.producer.helper中的方法

限定符和类型	方法和说明
static PartitionMetadata	ProducerHelper.dispatchPartitions(List<ProduceMessage> messages, TopicMetadata topicMetadata, List<PartitionMetadata> partitions, PartitionSelector partitionSelector)

返回变量类型为PartitionMetadata的类型的org.joyqueue.client.internal.producer.helper中的方法

限定符和类型	方法和说明
static List<PartitionMetadata>	ProducerHelper.filterBlackList(List<PartitionMetadata> partitions, List<PartitionMetadata> blackPartitionList)

类型变量类型为PartitionMetadata的org.joyqueue.client.internal.producer.helper中的方法参数

限定符和类型	方法和说明
static PartitionMetadata	ProducerHelper.dispatchPartitions(List<ProduceMessage> messages, TopicMetadata topicMetadata, List<PartitionMetadata> partitions, PartitionSelector partitionSelector)
static List<PartitionMetadata>	ProducerHelper.filterBlackList(List<PartitionMetadata> partitions, List<PartitionMetadata> blackPartitionList)
static List<PartitionMetadata>	ProducerHelper.filterBlackList(List<PartitionMetadata> partitions, List<PartitionMetadata> blackPartitionList)

org.joyqueue.client.internal.producer.support中PartitionMetadata的使用

返回PartitionMetadata的org.joyqueue.client.internal.producer.support中的方法

限定符和类型	方法和说明
PartitionMetadata	MessageProducerInner.dispatchPartitions(List<ProduceMessage> messages, TopicMetadata topicMetadata, List<PartitionMetadata> partitions)
PartitionMetadata	MessageProducerInner.dispatchPartitions(List<ProduceMessage> messages, TopicMetadata topicMetadata, List<PartitionMetadata> partitions, List<PartitionMetadata> blackPartitionList)
protected PartitionMetadata	AbstractPartitionSelector.hashPartition(ProduceMessage message, TopicMetadata topicMetadata, List<PartitionMetadata> partitions)
protected abstract PartitionMetadata	AbstractPartitionSelector.nextPartition(ProduceMessage message, TopicMetadata topicMetadata, List<PartitionMetadata> partitions)
protected PartitionMetadata	WeightedRoundRobinPartitionSelector.nextPartition(ProduceMessage message, TopicMetadata topicMetadata, List<PartitionMetadata> partitions)
PartitionMetadata	AbstractPartitionSelector.select(ProduceMessage message, TopicMetadata topicMetadata, List<PartitionMetadata> partitions)
protected PartitionMetadata	AbstractPartitionSelector.selectPartition(ProduceMessage message, TopicMetadata topicMetadata, List<PartitionMetadata> partitions)

返回变量类型为PartitionMetadata的类型的org.joyqueue.client.internal.producer.support中的方法

限定符和类型	方法和说明
List<PartitionMetadata>	MessageProducerInner.getBrokerPartitions(TopicMetadata topicMetadata, List<BrokerNode> brokerNodes)

参数类型为PartitionMetadata的org.joyqueue.client.internal.producer.support中的方法

限定符和类型	方法和说明
List<SendResult>	MessageProducerInner.doBatchSend(List<ProduceMessage> messages, TopicMetadata topicMetadata, PartitionMetadata partition, List<PartitionMetadata> partitions, String txId, long timeout, TimeUnit timeoutUnit, boolean isOneway, boolean failover, AsyncBatchProduceCallback callback)
protected List<SendResult>	MessageProducerInner.doBatchSendInternal(List<ProduceMessage> messages, TopicMetadata topicMetadata, PartitionMetadata partition, List<PartitionMetadata> partitions, String txId, long timeout, TimeUnit timeoutUnit, boolean isOneway, boolean failover, AsyncBatchProduceCallback callback)
protected SendPrepareResult	DefaultTransactionMessageProducer.doPrepare(PartitionMetadata partition)

类型变量类型为PartitionMetadata的org.joyqueue.client.internal.producer.support中的方法参数

限定符和类型	方法和说明
PartitionMetadata	MessageProducerInner.dispatchPartitions(List<ProduceMessage> messages, TopicMetadata topicMetadata, List<PartitionMetadata> partitions)
PartitionMetadata	MessageProducerInner.dispatchPartitions(List<ProduceMessage> messages, TopicMetadata topicMetadata, List<PartitionMetadata> partitions, List<PartitionMetadata> blackPartitionList)
PartitionMetadata	MessageProducerInner.dispatchPartitions(List<ProduceMessage> messages, TopicMetadata topicMetadata, List<PartitionMetadata> partitions, List<PartitionMetadata> blackPartitionList)
List<SendResult>	MessageProducerInner.doBatchSend(List<ProduceMessage> messages, TopicMetadata topicMetadata, PartitionMetadata partition, List<PartitionMetadata> partitions, String txId, long timeout, TimeUnit timeoutUnit, boolean isOneway, boolean failover, AsyncBatchProduceCallback callback)
protected List<SendResult>	MessageProducerInner.doBatchSendInternal(List<ProduceMessage> messages, TopicMetadata topicMetadata, PartitionMetadata partition, List<PartitionMetadata> partitions, String txId, long timeout, TimeUnit timeoutUnit, boolean isOneway, boolean failover, AsyncBatchProduceCallback callback)
protected int	WeightedRoundRobinPartitionSelector.getMaxGcd(List<PartitionMetadata> partitions)
protected int	WeightedRoundRobinPartitionSelector.getMaxWeight(List<PartitionMetadata> partitions)
protected PartitionMetadata	AbstractPartitionSelector.hashPartition(ProduceMessage message, TopicMetadata topicMetadata, List<PartitionMetadata> partitions)
protected abstract PartitionMetadata	AbstractPartitionSelector.nextPartition(ProduceMessage message, TopicMetadata topicMetadata, List<PartitionMetadata> partitions)
protected PartitionMetadata	WeightedRoundRobinPartitionSelector.nextPartition(ProduceMessage message, TopicMetadata topicMetadata, List<PartitionMetadata> partitions)
PartitionMetadata	AbstractPartitionSelector.select(ProduceMessage message, TopicMetadata topicMetadata, List<PartitionMetadata> partitions)
protected PartitionMetadata	AbstractPartitionSelector.selectPartition(ProduceMessage message, TopicMetadata topicMetadata, List<PartitionMetadata> partitions)