org.joyqueue.client.internal.producer.support

类 AbstractPartitionSelector

java.lang.Object

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

所有已实现的接口:

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

直接已知子类:

WeightedRoundRobinPartitionSelector

public abstract class AbstractPartitionSelector
extends Object
implements PartitionSelector

AbstractPartitionSelector author: gaohaoxiang date: 2018/12/10

构造器概要

构造器

构造器和说明
AbstractPartitionSelector()

方法概要

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

从类继承的方法 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 PartitionMetadata select(ProduceMessage message,
                                TopicMetadata topicMetadata,
                                List<PartitionMetadata> partitions)

指定者:

select 在接口中 PartitionSelector

selectPartition

protected PartitionMetadata selectPartition(ProduceMessage message,
                                            TopicMetadata topicMetadata,
                                            List<PartitionMetadata> partitions)

hashPartition

protected PartitionMetadata hashPartition(ProduceMessage message,
                                          TopicMetadata topicMetadata,
                                          List<PartitionMetadata> partitions)

nextPartition

protected abstract PartitionMetadata nextPartition(ProduceMessage message,
                                                   TopicMetadata topicMetadata,
                                                   List<PartitionMetadata> partitions)