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–2020 The Apache Software Foundation. All rights reserved.