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

Class WALProcedureMap

java.lang.Object

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

@InterfaceAudience.Private
class WALProcedureMap
extends Object

This class is used to track the active procedures when loading procedures from proc wal file.

We will read proc wal files from new to old, but when reading a proc wal file, we will still read from top to bottom, so there are two groups of methods for this class.

The first group is add(ProcedureProtos.Procedure) and remove(long). It is used when reading a proc wal file. In these methods, for the same procedure, typically the one comes later should win, please see the comment for isIncreasing(ProcedureProtos.Procedure, ProcedureProtos.Procedure) to see the exceptions.

The second group is merge(WALProcedureMap). We will have a global WALProcedureMap to hold global the active procedures, and a local WALProcedureMap to hold the active procedures for the current proc wal file. And when we finish reading a proc wal file, we will merge the local one into the global one, by calling the merge(WALProcedureMap) method of the global one and pass the local one in. In this method, for the same procedure, the one comes earlier will win, as we read the proc wal files from new to old(the reverse order).

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG
private long	maxModifiedProcId
private long	minModifiedProcId
private Map<Long,org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.Procedure>	procMap

Constructor Summary

Constructors

Constructor and Description
WALProcedureMap()

Method Summary

Modifier and Type	Method and Description
void	add(org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.Procedure proc)
boolean	contains(long procId)
long	getMaxModifiedProcId()
long	getMinModifiedProcId()
Collection<org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.Procedure>	getProcedures()
boolean	isEmpty()
private static boolean	isIncreasing(org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.Procedure current, org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.Procedure candidate)
void	merge(WALProcedureMap other) Merge the given WALProcedureMap into this one.
void	remove(long procId)
private void	trackProcId(long procId)

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

procMap

private final Map<Long,org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.Procedure> procMap

minModifiedProcId

private long minModifiedProcId

maxModifiedProcId

private long maxModifiedProcId

Constructor Detail

WALProcedureMap

WALProcedureMap()

Method Detail

trackProcId

private void trackProcId(long procId)

isIncreasing

private static boolean isIncreasing(org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.Procedure current,
                                    org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.Procedure candidate)

Returns:

True if this new procedure is 'richer' than the current one else false and we log this incidence where it appears that the WAL has older entries appended after newer ones. See HBASE-18152.

add

public void add(org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.Procedure proc)

remove

public void remove(long procId)

isEmpty

public boolean isEmpty()

contains

public boolean contains(long procId)

merge

public void merge(WALProcedureMap other)

Merge the given WALProcedureMap into this one. The WALProcedureMap passed in will be cleared after merging.

getProcedures

public Collection<org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.Procedure> getProcedures()

getMinModifiedProcId

public long getMinModifiedProcId()

getMaxModifiedProcId

public long getMaxModifiedProcId()