public class UniformRangeGenerator extends Object implements RangeGenerator
SubscriptionType.Key_Shared
subscription.Constructor and Description |
---|
UniformRangeGenerator() |
Modifier and Type | Method and Description |
---|---|
List<TopicRange> |
range(TopicMetadata metadata,
int parallelism)
Generate range for the given topic.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
open, open
public List<TopicRange> range(TopicMetadata metadata, int parallelism)
RangeGenerator
range
in interface RangeGenerator
metadata
- The metadata of the topic.parallelism
- The reader size for this topic.Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.