Constructor and Description |
---|
SplitsAssignmentState(StopCursor stopCursor,
SourceConfiguration sourceConfiguration) |
SplitsAssignmentState(StopCursor stopCursor,
SourceConfiguration sourceConfiguration,
PulsarSourceEnumState sourceEnumState) |
Modifier and Type | Method and Description |
---|---|
void |
appendTopicPartitions(Set<TopicPartition> fetchedPartitions)
Append the new fetched partitions to current state.
|
Optional<SplitsAssignment<PulsarPartitionSplit>> |
assignSplits(List<Integer> pendingReaders) |
boolean |
containsTopic(String topicName) |
boolean |
noMoreNewPartitionSplits() |
void |
putSplitsBackToPendingList(List<PulsarPartitionSplit> splits,
int readerId)
Put these splits back to pending list.
|
PulsarSourceEnumState |
snapshotState() |
public SplitsAssignmentState(StopCursor stopCursor, SourceConfiguration sourceConfiguration)
public SplitsAssignmentState(StopCursor stopCursor, SourceConfiguration sourceConfiguration, PulsarSourceEnumState sourceEnumState)
public PulsarSourceEnumState snapshotState()
public void appendTopicPartitions(Set<TopicPartition> fetchedPartitions)
SplitEnumeratorContext
don't support put the
split back to enumerator, we don't support partition deletion.fetchedPartitions
- The partitions from the PulsarSubscriber
.public boolean containsTopic(String topicName)
public void putSplitsBackToPendingList(List<PulsarPartitionSplit> splits, int readerId)
public Optional<SplitsAssignment<PulsarPartitionSplit>> assignSplits(List<Integer> pendingReaders)
public boolean noMoreNewPartitionSplits()
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.