org.apache.hadoop.hbase.procedure2.store.wal

Class WALProcedureTree

java.lang.Object

org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureTree

@InterfaceAudience.Private
public final class WALProcedureTree
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 and Description
private static class	WALProcedureTree.Entry
private static class	WALProcedureTree.Iter
private static class	WALProcedureTree.ProtoAndProc

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
private void	addAllToCorruptedAndRemoveFromProcMap(WALProcedureTree.Entry entry, Map<Long,WALProcedureTree.Entry> remainingProcMap)
private void	addAllToValidAndRemoveFromProcMap(WALProcedureTree.Entry entry, Map<Long,WALProcedureTree.Entry> remainingProcMap)
static WALProcedureTree	build(Collection<org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.Procedure> procedures)
private List<WALProcedureTree.Entry>	buildTree(Map<Long,WALProcedureTree.Entry> procMap)
private void	checkOrphan(Map<Long,WALProcedureTree.Entry> procMap)
private void	checkReady(WALProcedureTree.Entry rootEntry, Map<Long,WALProcedureTree.Entry> remainingProcMap)
private void	collectStackId(WALProcedureTree.Entry entry, Map<Integer,List<WALProcedureTree.Entry>> stackId2Proc, org.apache.commons.lang3.mutable.MutableInt maxStackId)
ProcedureStore.ProcedureIterator	getCorruptedProcs()
ProcedureStore.ProcedureIterator	getValidProcs()
private static boolean	isFinished(org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.Procedure proc)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

validProcs

private final List<WALProcedureTree.ProtoAndProc> validProcs

corruptedProcs

private final List<WALProcedureTree.ProtoAndProc> corruptedProcs

Constructor Detail

WALProcedureTree

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

Method Detail

isFinished

private static boolean isFinished(org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.Procedure proc)

buildTree

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

collectStackId

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

addAllToCorruptedAndRemoveFromProcMap

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

addAllToValidAndRemoveFromProcMap

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

checkReady

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

checkOrphan

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

getValidProcs

public ProcedureStore.ProcedureIterator getValidProcs()

getCorruptedProcs

public ProcedureStore.ProcedureIterator getCorruptedProcs()

build

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