CheckpointStore Interface
public interface CheckpointStore
An interface that defines the operations for storing and retrieving partition ownership information and checkpoint details for each partition.
Method Summary
Modifier and Type | Method and Description |
---|---|
abstract
Flux<Partition |
claimOwnership(List<PartitionOwnership> requestedPartitionOwnerships)
Called to claim ownership of a list of partitions. |
abstract Flux<Checkpoint> |
listCheckpoints(String fullyQualifiedNamespace, String eventHubName, String consumerGroup)
Called to get the list of checkpoints from the underlying data store. |
abstract
Flux<Partition |
listOwnership(String fullyQualifiedNamespace, String eventHubName, String consumerGroup)
Called to get the list of all existing partition ownership from the underlying data store. |
abstract Mono<Void> |
updateCheckpoint(Checkpoint checkpoint)
Updates the checkpoint in the data store for a partition. |
Method Details
claimOwnership
public abstract Flux
Called to claim ownership of a list of partitions. This will return the list of partitions that were owned successfully.
Parameters:
Returns:
listCheckpoints
public abstract Flux
Called to get the list of checkpoints from the underlying data store. This method could return empty results if there are no checkpoints available in the data store.
Parameters:
Returns:
listOwnership
public abstract Flux
Called to get the list of all existing partition ownership from the underlying data store. Could return empty results if there are is no existing ownership information.
Parameters:
Returns:
updateCheckpoint
public abstract Mono
Updates the checkpoint in the data store for a partition.
Parameters:
Returns:
Applies to
Azure SDK for Java
피드백
https://aka.ms/ContentUserFeedback
출시 예정: 2024년 내내 콘텐츠에 대한 피드백 메커니즘으로 GitHub 문제를 단계적으로 폐지하고 이를 새로운 피드백 시스템으로 바꿀 예정입니다. 자세한 내용은 다음을 참조하세요.다음에 대한 사용자 의견 제출 및 보기