public interface CheckpointStorage extends CheckpointStorageCoordinatorView, CheckpointStorageWorkerView
CheckpointStorageCoordinatorView
. And also implement
methods acting as a worker role, which defined in CheckpointStorageWorkerView
.hasDefaultSavepointLocation, initializeBaseLocations, initializeLocationForCheckpoint, initializeLocationForSavepoint, resolveCheckpoint, supportsHighlyAvailableStorage
createTaskOwnedStateStream, resolveCheckpointStorageLocation
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.