@ThreadSafe public final class LineageStoreView extends Object
LineageStore
to checkpoint schedulers and
recompute planners.
TODO(yupeng): return a lineage view for protectionConstructor and Description |
---|
LineageStoreView(LineageStore lineageStore)
Creates a new instance of
LineageStoreView . |
Modifier and Type | Method and Description |
---|---|
List<Lineage> |
getAllLineagesInTopologicalOrder() |
List<Lineage> |
getChildren(Lineage lineage) |
List<Lineage> |
getRootLineage() |
public LineageStoreView(LineageStore lineageStore)
LineageStoreView
.lineageStore
- the underlying lineage store to construct the view forpublic List<Lineage> getChildren(Lineage lineage) throws LineageDoesNotExistException
lineage
- the lineage to get the children fromLineageDoesNotExistException
- if the lineage does not existCopyright © 2023. All Rights Reserved.