Package | Description |
---|---|
org.apache.flink.changelog.fs |
Class and Description |
---|
AbstractStateChangeFsUploader
Base implementation of StateChangeUploader.
|
ChangelogStorageMetricGroup
Metrics related to the Changelog Storage used by the Changelog State Backend.
|
FsStateChangelogStorageForRecovery
Filesystem-based implementation of
StateChangelogStorage just for recovery. |
RetryPolicy
Retry policy to use by
RetryingExecutor . |
StateChangeSet
A set of changes made to some state(s) by a single state backend during a single checkpoint.
|
StateChangeUploader
The purpose of this interface is to abstract the different implementations of uploading state
changelog parts.
|
StateChangeUploader.UploadTasksResult
Result of executing one or more
upload tasks . |
StateChangeUploadScheduler
Schedules
upload tasks on a StateChangeUploader . |
StateChangeUploadScheduler.UploadTask
Upload Task for
StateChangeUploadScheduler . |
TaskChangelogRegistry
TM-side registry of
StateObjects , each
representing one or more changelog segments. |
UploadResult
Result of uploading state changes.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.