@PublicEvolving public class FullRangeGenerator extends Object implements RangeGenerator
SubscriptionType.Shared
, SubscriptionType.Failover
and
SubscriptionType.Exclusive
subscription.RangeGenerator.KeySharedMode
Constructor and Description |
---|
FullRangeGenerator() |
Modifier and Type | Method and Description |
---|---|
RangeGenerator.KeySharedMode |
keyShareMode(TopicMetadata metadata,
int parallelism)
Defines the default behavior for Key_Shared subscription in Flink.
|
List<TopicRange> |
range(TopicMetadata metadata,
int parallelism)
Generate range for the given topic.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
open, open
public List<TopicRange> range(TopicMetadata metadata, int parallelism)
RangeGenerator
range
in interface RangeGenerator
metadata
- The metadata of the topic.parallelism
- The reader size for this topic.public RangeGenerator.KeySharedMode keyShareMode(TopicMetadata metadata, int parallelism)
RangeGenerator
RangeGenerator.KeySharedMode
for the detailed usage of the key share mode.keyShareMode
in interface RangeGenerator
metadata
- The metadata of the topic.parallelism
- The reader size for this topic.Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.