Package | Description |
---|---|
org.apache.flink.connector.pulsar.source.enumerator.subscriber.impl | |
org.apache.flink.connector.pulsar.source.enumerator.topic.range |
Modifier and Type | Method and Description |
---|---|
protected TopicMetadata |
BasePulsarSubscriber.queryTopicMetadata(org.apache.pulsar.client.admin.PulsarAdmin pulsarAdmin,
String topicName) |
Modifier and Type | Method and Description |
---|---|
protected List<TopicPartition> |
BasePulsarSubscriber.toTopicPartitions(TopicMetadata metadata,
List<TopicRange> ranges) |
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) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.