@InterfaceAudience.Private public final class ProcedureTree extends Object
checkReady(Entry, Map)
method.
For the procedures not in any group, i.e, can not find the root procedure for these procedures,
we will also consider them as corrupted. Please see the code in checkOrphan(Map)
method.Modifier and Type | Class and Description |
---|---|
private static class |
ProcedureTree.Entry |
Modifier and Type | Field and Description |
---|---|
private List<ProtoAndProcedure> |
corruptedProcs |
private static org.slf4j.Logger |
LOG |
private List<ProtoAndProcedure> |
validProcs |
Modifier | Constructor and Description |
---|---|
private |
ProcedureTree(Map<Long,ProcedureTree.Entry> procMap) |
Modifier and Type | Method and Description |
---|---|
private void |
addAllToCorruptedAndRemoveFromProcMap(ProcedureTree.Entry entry,
Map<Long,ProcedureTree.Entry> remainingProcMap) |
private void |
addAllToValidAndRemoveFromProcMap(ProcedureTree.Entry entry,
Map<Long,ProcedureTree.Entry> remainingProcMap) |
static ProcedureTree |
build(Collection<org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.Procedure> procedures) |
private List<ProcedureTree.Entry> |
buildTree(Map<Long,ProcedureTree.Entry> procMap) |
private void |
checkOrphan(Map<Long,ProcedureTree.Entry> procMap) |
private void |
checkReady(ProcedureTree.Entry rootEntry,
Map<Long,ProcedureTree.Entry> remainingProcMap) |
private void |
collectStackId(ProcedureTree.Entry entry,
Map<Integer,List<ProcedureTree.Entry>> stackId2Proc,
org.apache.commons.lang3.mutable.MutableInt maxStackId) |
ProcedureStore.ProcedureIterator |
getCorruptedProcs() |
ProcedureStore.ProcedureIterator |
getValidProcs() |
private static final org.slf4j.Logger LOG
private final List<ProtoAndProcedure> validProcs
private final List<ProtoAndProcedure> corruptedProcs
private ProcedureTree(Map<Long,ProcedureTree.Entry> procMap)
private List<ProcedureTree.Entry> buildTree(Map<Long,ProcedureTree.Entry> procMap)
private void collectStackId(ProcedureTree.Entry entry, Map<Integer,List<ProcedureTree.Entry>> stackId2Proc, org.apache.commons.lang3.mutable.MutableInt maxStackId)
private void addAllToCorruptedAndRemoveFromProcMap(ProcedureTree.Entry entry, Map<Long,ProcedureTree.Entry> remainingProcMap)
private void addAllToValidAndRemoveFromProcMap(ProcedureTree.Entry entry, Map<Long,ProcedureTree.Entry> remainingProcMap)
private void checkReady(ProcedureTree.Entry rootEntry, Map<Long,ProcedureTree.Entry> remainingProcMap)
private void checkOrphan(Map<Long,ProcedureTree.Entry> procMap)
public ProcedureStore.ProcedureIterator getValidProcs()
public ProcedureStore.ProcedureIterator getCorruptedProcs()
public static ProcedureTree build(Collection<org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.Procedure> procedures)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.