Modifier and Type | Method and Description |
---|---|
protected List<TopicPartition> |
BasePulsarSubscriber.toTopicPartitions(String topic,
int partitionId,
List<TopicRange> ranges,
RangeGenerator.KeySharedMode mode) |
protected List<TopicPartition> |
BasePulsarSubscriber.toTopicPartitions(TopicMetadata metadata,
List<TopicRange> ranges,
RangeGenerator.KeySharedMode mode) |
Modifier and Type | Method and Description |
---|---|
RangeGenerator.KeySharedMode |
TopicPartition.getMode()
This method is internal used for key shared mode.
|
Constructor and Description |
---|
TopicPartition(String topic,
int partitionId,
List<TopicRange> ranges,
RangeGenerator.KeySharedMode mode) |
Modifier and Type | Method and Description |
---|---|
RangeGenerator.KeySharedMode |
FixedRangeGenerator.keyShareMode(TopicMetadata metadata,
int parallelism) |
default RangeGenerator.KeySharedMode |
RangeGenerator.keyShareMode(TopicMetadata metadata,
int parallelism)
Defines the default behavior for Key_Shared subscription in Flink.
|
RangeGenerator.KeySharedMode |
FullRangeGenerator.keyShareMode(TopicMetadata metadata,
int parallelism) |
RangeGenerator.KeySharedMode |
SplitRangeGenerator.keyShareMode(TopicMetadata metadata,
int parallelism) |
RangeGenerator.KeySharedMode |
FixedKeysRangeGenerator.keyShareMode(TopicMetadata metadata,
int parallelism) |
static RangeGenerator.KeySharedMode |
RangeGenerator.KeySharedMode.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static RangeGenerator.KeySharedMode[] |
RangeGenerator.KeySharedMode.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
FixedKeysRangeGenerator.FixedKeysRangeGeneratorBuilder |
FixedKeysRangeGenerator.FixedKeysRangeGeneratorBuilder.keySharedMode(RangeGenerator.KeySharedMode sharedMode)
Override the default
KeySharedMode#JOIN to the mode your have provided. |
static void |
TopicRangeUtils.validateTopicRanges(List<TopicRange> ranges,
RangeGenerator.KeySharedMode sharedMode)
Make sure all the ranges should be valid in Pulsar Key Shared Policy.
|
Constructor and Description |
---|
FixedRangeGenerator(List<TopicRange> ranges,
RangeGenerator.KeySharedMode sharedMode) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.