@ThreadSafe public final class CheckpointLatestPlanner extends Object implements CheckpointPlanner
CheckpointPlanner.Factory
Constructor and Description |
---|
CheckpointLatestPlanner(LineageStoreView lineageStoreView,
FileSystemMasterView fileSystemMasterView)
Creates a new instance of
CheckpointLatestPlanner , which does not use the lineage store
view. |
Modifier and Type | Method and Description |
---|---|
CheckpointPlan |
generatePlan(LineageStoreView store,
FileSystemMasterView fileSystemMasterView)
Generates a plan to decide what lineages to checkpoint.
|
public CheckpointLatestPlanner(LineageStoreView lineageStoreView, FileSystemMasterView fileSystemMasterView)
CheckpointLatestPlanner
, which does not use the lineage store
view.lineageStoreView
- a view of a lineage storefileSystemMasterView
- a view of the file system masterpublic CheckpointPlan generatePlan(LineageStoreView store, FileSystemMasterView fileSystemMasterView)
CheckpointPlanner
This method returns null if the planner fails to propose a feasible plan to find the lineages to checkpoint. If the checkpoint plan has no lineages, it indicates that the planner has no actions to take and the requirement is already met.
generatePlan
in interface CheckpointPlanner
store
- a readonly view of the lineage storefileSystemMasterView
- a readonly view of the file system masterCopyright © 2023. All Rights Reserved.