Modifier and Type | Method and Description |
---|---|
PulsarSourceBuilder<OUT> |
PulsarSourceBuilder.setRangeGenerator(RangeGenerator rangeGenerator)
Set a topic range generator for Key_Shared subscription.
|
Constructor and Description |
---|
PulsarSourceEnumerator(PulsarSubscriber subscriber,
StartCursor startCursor,
StopCursor stopCursor,
RangeGenerator rangeGenerator,
SourceConfiguration sourceConfiguration,
SplitEnumeratorContext<PulsarPartitionSplit> context) |
PulsarSourceEnumerator(PulsarSubscriber subscriber,
StartCursor startCursor,
StopCursor stopCursor,
RangeGenerator rangeGenerator,
SourceConfiguration sourceConfiguration,
SplitEnumeratorContext<PulsarPartitionSplit> context,
PulsarSourceEnumState enumState) |
Modifier and Type | Method and Description |
---|---|
Set<TopicPartition> |
PulsarSubscriber.getSubscribedTopicPartitions(org.apache.pulsar.client.admin.PulsarAdmin pulsarAdmin,
RangeGenerator rangeGenerator,
int parallelism)
Get a set of subscribed
TopicPartition s. |
Modifier and Type | Method and Description |
---|---|
Set<TopicPartition> |
TopicListSubscriber.getSubscribedTopicPartitions(org.apache.pulsar.client.admin.PulsarAdmin pulsarAdmin,
RangeGenerator rangeGenerator,
int parallelism) |
Set<TopicPartition> |
TopicPatternSubscriber.getSubscribedTopicPartitions(org.apache.pulsar.client.admin.PulsarAdmin pulsarAdmin,
RangeGenerator rangeGenerator,
int parallelism) |
Modifier and Type | Class and Description |
---|---|
class |
FixedRangeGenerator
Always return the same range set for all topics.
|
class |
FullRangeGenerator
Default implementation for
SubscriptionType.Shared , SubscriptionType.Failover and
SubscriptionType.Exclusive subscription. |
class |
UniformRangeGenerator
This range generator would divide the range by the flink source parallelism.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.