Package | Description |
---|---|
alluxio.master.lineage.meta | |
alluxio.master.lineage.recompute |
Modifier and Type | Method and Description |
---|---|
static Lineage |
Lineage.fromJournalEntry(Lineage.LineageEntry entry)
Converts the entry to a
Lineage . |
Lineage |
LineageStore.getLineage(long lineageId)
Gets the lineage.
|
Lineage |
LineageStore.getLineageOfOutputFile(long fileId)
Gets the lineage that has the given output file.
|
Modifier and Type | Method and Description |
---|---|
List<Lineage> |
LineageStore.getAllInTopologicalOrder() |
List<Lineage> |
LineageStoreView.getAllLineagesInTopologicalOrder() |
List<Lineage> |
LineageStoreView.getChildren(Lineage lineage) |
List<Lineage> |
LineageStore.getChildren(Lineage lineage)
Gets all the children of a given lineage.
|
List<Lineage> |
LineageStore.getParents(Lineage lineage)
Gets all the parents of a given lineage.
|
List<Lineage> |
LineageStoreView.getRootLineage() |
List<Lineage> |
LineageStore.getRootLineages() |
List<Lineage> |
LineageStore.sortLineageTopologically(Set<Lineage> lineages)
Sorts a given set of lineages topologically.
|
Modifier and Type | Method and Description |
---|---|
List<Lineage> |
LineageStoreView.getChildren(Lineage lineage) |
List<Lineage> |
LineageStore.getChildren(Lineage lineage)
Gets all the children of a given lineage.
|
static List<Long> |
LineageStateUtils.getLostFiles(Lineage lineage,
FileSystemMasterView fileSystemMasterView) |
List<Lineage> |
LineageStore.getParents(Lineage lineage)
Gets all the parents of a given lineage.
|
static boolean |
LineageStateUtils.isCompleted(Lineage lineage,
FileSystemMasterView fileSystemMasterView)
Checks if all the output files of the given lineage are completed.
|
static boolean |
LineageStateUtils.isInCheckpointing(Lineage lineage,
FileSystemMasterView fileSystemMasterView) |
static boolean |
LineageStateUtils.isPersisted(Lineage lineage,
FileSystemMasterView fileSystemMasterView) |
static boolean |
LineageStateUtils.needRecompute(Lineage lineage,
FileSystemMasterView fileSystemMasterView) |
Modifier and Type | Method and Description |
---|---|
List<Lineage> |
LineageStore.sortLineageTopologically(Set<Lineage> lineages)
Sorts a given set of lineages topologically.
|
Modifier and Type | Method and Description |
---|---|
List<Lineage> |
RecomputePlan.getLineageToRecompute() |
Constructor and Description |
---|
RecomputePlan(List<Lineage> toRecompute)
Creates a new instance of
RecomputePlan . |
Copyright © 2023. All Rights Reserved.