org.apache.hadoop.hbase.procedure2.store

Class ProcedureStoreTracker

java.lang.Object

org.apache.hadoop.hbase.procedure2.store.ProcedureStoreTracker

@InterfaceAudience.Private
@InterfaceStability.Evolving
public class ProcedureStoreTracker
extends Object

Keeps track of live procedures. It can be used by the ProcedureStore to identify which procedures are already deleted/completed to avoid the deserialization step on restart.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ProcedureStoreTracker.BitSetNode
static class	ProcedureStoreTracker.DeleteState

Constructor Summary

Constructors

Constructor and Description
ProcedureStoreTracker()

Method Summary

Methods

Modifier and Type	Method and Description
void	delete(long procId)
void	dump()
long	getMinProcId()
long	getUpdatedMaxProcId()
long	getUpdatedMinProcId()
void	insert(long procId)
void	insert(long procId, long[] subProcIds)
ProcedureStoreTracker.DeleteState	isDeleted(long procId)
boolean	isEmpty()
boolean	isTracking(long minId, long maxId)
boolean	isUpdated()
void	readFrom(InputStream stream)
void	reset()
void	resetUpdates()
void	setDeleted(long procId, boolean isDeleted)
void	setKeepDeletes(boolean keepDeletes)
void	setPartialFlag(boolean isPartial)
void	undeleteAll()
void	update(long procId)
void	writeTo(OutputStream stream)

Methods inherited from class java.lang.Object

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

Constructor Detail

ProcedureStoreTracker

public ProcedureStoreTracker()

Method Detail

insert

public void insert(long procId)

insert

public void insert(long procId,
          long[] subProcIds)

update

public void update(long procId)

delete

public void delete(long procId)

getUpdatedMinProcId

public long getUpdatedMinProcId()

getUpdatedMaxProcId

public long getUpdatedMaxProcId()

setDeleted

@InterfaceAudience.Private
public void setDeleted(long procId,
                                        boolean isDeleted)

reset

public void reset()

isDeleted

public ProcedureStoreTracker.DeleteState isDeleted(long procId)

getMinProcId

public long getMinProcId()

setKeepDeletes

public void setKeepDeletes(boolean keepDeletes)

setPartialFlag

public void setPartialFlag(boolean isPartial)

isEmpty

public boolean isEmpty()

isUpdated

public boolean isUpdated()

isTracking

public boolean isTracking(long minId,
                 long maxId)

resetUpdates

public void resetUpdates()

undeleteAll

public void undeleteAll()

dump

public void dump()

writeTo

public void writeTo(OutputStream stream)
             throws IOException

Throws:

IOException

readFrom

public void readFrom(InputStream stream)
              throws IOException

Throws:

IOException