org.joyqueue.client.internal.producer.support

类 AbstractPartitionSelector

java.lang.Object

org.joyqueue.client.internal.producer.support.AbstractPartitionSelector

所有已实现的接口:

com.jd.laf.extension.Type<String>, PartitionSelector

直接已知子类:

AdaptivePartitionSelector, WeightedPartitionSelector

public abstract class AbstractPartitionSelector
extends Object
implements PartitionSelector

AbstractPartitionSelector author: gaohaoxiang date: 2018/12/10

构造器概要

构造器

构造器和说明
AbstractPartitionSelector()

方法概要

限定符和类型	方法和说明
protected PartitionNode	hashPartition(ProduceMessage message, TopicMetadata topicMetadata, List<BrokerNode> brokerNodes)
protected abstract PartitionNode	nextPartition(ProduceMessage message, TopicMetadata topicMetadata, List<BrokerNode> brokerNodes)
protected PartitionMetadata	randomSelectPartition(TopicMetadata topicMetadata, BrokerNode brokerNode)
protected PartitionNode	randomSelectPartitionNode(TopicMetadata topicMetadata, BrokerNode brokerNode)
PartitionNode	select(ProduceMessage message, TopicMetadata topicMetadata, List<BrokerNode> brokerNodes)
protected PartitionNode	selectPartition(ProduceMessage message, TopicMetadata topicMetadata, List<BrokerNode> brokerNodes)

从类继承的方法 java.lang.Object

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

从接口继承的方法 com.jd.laf.extension.Type

type

构造器详细资料

AbstractPartitionSelector

public AbstractPartitionSelector()

方法详细资料

select

public PartitionNode select(ProduceMessage message,
                            TopicMetadata topicMetadata,
                            List<BrokerNode> brokerNodes)

指定者:

select 在接口中 PartitionSelector

selectPartition

protected PartitionNode selectPartition(ProduceMessage message,
                                        TopicMetadata topicMetadata,
                                        List<BrokerNode> brokerNodes)

hashPartition

protected PartitionNode hashPartition(ProduceMessage message,
                                      TopicMetadata topicMetadata,
                                      List<BrokerNode> brokerNodes)

randomSelectPartitionNode

protected PartitionNode randomSelectPartitionNode(TopicMetadata topicMetadata,
                                                  BrokerNode brokerNode)

randomSelectPartition

protected PartitionMetadata randomSelectPartition(TopicMetadata topicMetadata,
                                                  BrokerNode brokerNode)

nextPartition

protected abstract PartitionNode nextPartition(ProduceMessage message,
                                               TopicMetadata topicMetadata,
                                               List<BrokerNode> brokerNodes)