Package org.apache.hadoop.hbase.procedure2.store

Class ProcedureTree

java.lang.Object

org.apache.hadoop.hbase.procedure2.store.ProcedureTree

@Private
public final class ProcedureTree
extends Object

Used to build the tree for procedures.

We will group the procedures with the root procedure, and then validate each group. For each group of procedures(with the same root procedure), we will collect all the stack ids, if the max stack id is n, then all the stack ids should be from 0 to n, non-repetition and non-omission. If not, we will consider all the procedures in this group as corrupted. Please see the code in 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.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static final class	ProcedureTree.Entry

Field Summary

Fields

Modifier and Type	Field	Description
private final List<ProtoAndProcedure>	corruptedProcs
private static final org.slf4j.Logger	LOG
private final List<ProtoAndProcedure>	validProcs

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ProcedureTree(Map<Long,ProcedureTree.Entry> procMap)

Method Summary

Modifier and Type	Method	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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOG

private static final org.slf4j.Logger LOG

validProcs

private final List<ProtoAndProcedure> validProcs

corruptedProcs

private final List<ProtoAndProcedure> corruptedProcs

Constructor Details

ProcedureTree

private ProcedureTree(Map<Long,ProcedureTree.Entry> procMap)

Method Details

buildTree

private List<ProcedureTree.Entry> buildTree(Map<Long,ProcedureTree.Entry> procMap)

collectStackId

private void collectStackId(ProcedureTree.Entry entry,
 Map<Integer,List<ProcedureTree.Entry>> stackId2Proc,
 org.apache.commons.lang3.mutable.MutableInt maxStackId)

addAllToCorruptedAndRemoveFromProcMap

private void addAllToCorruptedAndRemoveFromProcMap(ProcedureTree.Entry entry,
 Map<Long,ProcedureTree.Entry> remainingProcMap)

addAllToValidAndRemoveFromProcMap

private void addAllToValidAndRemoveFromProcMap(ProcedureTree.Entry entry,
 Map<Long,ProcedureTree.Entry> remainingProcMap)

checkReady

private void checkReady(ProcedureTree.Entry rootEntry,
 Map<Long,ProcedureTree.Entry> remainingProcMap)

checkOrphan

private void checkOrphan(Map<Long,ProcedureTree.Entry> procMap)

getValidProcs

public ProcedureStore.ProcedureIterator getValidProcs()

getCorruptedProcs

public ProcedureStore.ProcedureIterator getCorruptedProcs()

build

public static ProcedureTree build(Collection<org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.Procedure> procedures)