Interface | Description |
---|---|
RangeGenerator |
A generator for generating the
TopicRange for given topic. |
Class | Description |
---|---|
FixedKeysRangeGenerator |
Pulsar didn't expose the key hash range method.
|
FixedKeysRangeGenerator.FixedKeysRangeGeneratorBuilder |
The builder for
FixedKeysRangeGenerator . |
FixedRangeGenerator |
Always return the same range set for all topics.
|
FullRangeGenerator |
Default implementation for
SubscriptionType.Shared , SubscriptionType.Failover and
SubscriptionType.Exclusive subscription. |
SplitRangeGenerator |
This range generator would divide the range by the flink source parallelism.
|
TopicRangeUtils |
This is the helper class for Pulsar's
Range , used in Key Shared mode. |
Enum | Description |
---|---|
RangeGenerator.KeySharedMode |
Different Key_Shared mode means different split assignment behaviors.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.