Modifier and Type | Method and Description |
---|---|
Set<TopicPartition> |
PulsarSourceEnumState.getAppendedPartitions() |
Constructor and Description |
---|
PulsarSourceEnumState(Set<TopicPartition> appendedPartitions) |
Modifier and Type | Method and Description |
---|---|
List<TopicPartition> |
KeySharedSplitAssigner.registerTopicPartitions(Set<TopicPartition> fetchedPartitions) |
List<TopicPartition> |
SplitAssigner.registerTopicPartitions(Set<TopicPartition> fetchedPartitions)
Add the current available partitions into assigner.
|
Modifier and Type | Method and Description |
---|---|
List<TopicPartition> |
KeySharedSplitAssigner.registerTopicPartitions(Set<TopicPartition> fetchedPartitions) |
List<TopicPartition> |
SplitAssigner.registerTopicPartitions(Set<TopicPartition> fetchedPartitions)
Add the current available partitions into assigner.
|
Modifier and Type | Method and Description |
---|---|
default void |
StopCursor.open(org.apache.pulsar.client.admin.PulsarAdmin admin,
TopicPartition partition)
The open method for the cursor initializer.
|
Modifier and Type | Method and Description |
---|---|
void |
LatestMessageStopCursor.open(org.apache.pulsar.client.admin.PulsarAdmin admin,
TopicPartition partition) |
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) |
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 |
---|---|
void |
PulsarOrderedFetcherManager.acknowledgeMessages(Map<TopicPartition,org.apache.pulsar.client.api.MessageId> cursorsToCommit) |
Modifier and Type | Method and Description |
---|---|
void |
PulsarOrderedPartitionSplitReader.notifyCheckpointComplete(TopicPartition partition,
org.apache.pulsar.client.api.MessageId offsetsToCommit) |
Modifier and Type | Method and Description |
---|---|
TopicPartition |
PulsarPartitionSplitSerializer.deserializeTopicPartition(int version,
DataInputStream in) |
TopicPartition |
PulsarPartitionSplit.getPartition() |
TopicPartition |
PulsarPartitionSplitState.getPartition() |
Modifier and Type | Method and Description |
---|---|
void |
PulsarPartitionSplitSerializer.serializeTopicPartition(DataOutputStream out,
TopicPartition partition) |
Constructor and Description |
---|
PulsarPartitionSplit(TopicPartition partition,
StopCursor stopCursor) |
PulsarPartitionSplit(TopicPartition partition,
StopCursor stopCursor,
org.apache.pulsar.client.api.MessageId latestConsumedId,
org.apache.pulsar.client.api.transaction.TxnID uncommittedTransactionId) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.