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) |
List<TopicRange> |
FixedRangeGenerator.range(TopicMetadata metadata,
int parallelism) |
List<TopicRange> |
RangeGenerator.range(TopicMetadata metadata,
int parallelism)
Generate range for the given topic.
|
List<TopicRange> |
FullRangeGenerator.range(TopicMetadata metadata,
int parallelism) |
List<TopicRange> |
SplitRangeGenerator.range(TopicMetadata metadata,
int parallelism) |
List<TopicRange> |
FixedKeysRangeGenerator.range(TopicMetadata metadata,
int parallelism) |