Modifier and Type | Method and Description |
---|---|
protected List<TopicPartition> |
BasePulsarSubscriber.toTopicPartitions(TopicMetadata metadata,
List<TopicRange> ranges) |
Modifier and Type | Method and Description |
---|---|
static TopicRange |
TopicRange.createFullRange()
Create a topic range which contains the fully hash range.
|
TopicRange |
TopicPartition.getRange() |
Constructor and Description |
---|
TopicPartition(String topic,
int partitionId,
TopicRange range) |
Modifier and Type | Method and Description |
---|---|
List<TopicRange> |
FixedRangeGenerator.range(TopicMetadata metadata,
int parallelism) |
List<TopicRange> |
RangeGenerator.range(TopicMetadata metadata,
int parallelism)
Generate range for the given topic.
|
List<TopicRange> |
UniformRangeGenerator.range(TopicMetadata metadata,
int parallelism) |
List<TopicRange> |
FullRangeGenerator.range(TopicMetadata metadata,
int parallelism) |
Constructor and Description |
---|
FixedRangeGenerator(List<TopicRange> ranges) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.