Package org.apache.hadoop.hbase.procedure2

Class ProcedureTestingUtility.LoadCounter

java.lang.Object

org.apache.hadoop.hbase.procedure2.ProcedureTestingUtility.LoadCounter

All Implemented Interfaces:

org.apache.hadoop.hbase.procedure2.store.ProcedureStore.ProcedureLoader

Enclosing class:

ProcedureTestingUtility

public static class ProcedureTestingUtility.LoadCounter
extends Object
implements org.apache.hadoop.hbase.procedure2.store.ProcedureStore.ProcedureLoader

Field Summary

Fields

Modifier and Type	Field	Description
private final ArrayList<org.apache.hadoop.hbase.procedure2.Procedure>	completed
private final ArrayList<org.apache.hadoop.hbase.procedure2.Procedure>	corrupted
private long	maxProcId
private Set<Long>	procIds
private final ArrayList<org.apache.hadoop.hbase.procedure2.Procedure>	runnable

Constructor Summary

Constructors

Constructor	Description
LoadCounter()
LoadCounter(Set<Long> procIds)

Method Summary

Modifier and Type	Method	Description
ArrayList<org.apache.hadoop.hbase.procedure2.Procedure>	getCompleted()
int	getCompletedCount()
ArrayList<org.apache.hadoop.hbase.procedure2.Procedure>	getCorrupted()
int	getCorruptedCount()
int	getLoadedCount()
long	getMaxProcId()
int	getRunnableCount()
ArrayList<org.apache.hadoop.hbase.procedure2.Procedure>	getRunnables()
void	handleCorrupted(org.apache.hadoop.hbase.procedure2.store.ProcedureStore.ProcedureIterator procIter)
boolean	isRunnable(long procId)
void	load(org.apache.hadoop.hbase.procedure2.store.ProcedureStore.ProcedureIterator procIter)
void	reset()
void	reset(Set<Long> procIds)
void	setMaxProcId(long maxProcId)

Methods inherited from class java.lang.Object

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

Field Details

corrupted

private final ArrayList<org.apache.hadoop.hbase.procedure2.Procedure> corrupted

completed

private final ArrayList<org.apache.hadoop.hbase.procedure2.Procedure> completed

runnable

private final ArrayList<org.apache.hadoop.hbase.procedure2.Procedure> runnable

procIds

private Set<Long> procIds

maxProcId

private long maxProcId

Constructor Details

LoadCounter

public LoadCounter()

LoadCounter

public LoadCounter(Set<Long> procIds)

Method Details

reset

public void reset()

reset

public void reset(Set<Long> procIds)

getMaxProcId

public long getMaxProcId()

getRunnables

public ArrayList<org.apache.hadoop.hbase.procedure2.Procedure> getRunnables()

getRunnableCount

public int getRunnableCount()

getCompleted

public ArrayList<org.apache.hadoop.hbase.procedure2.Procedure> getCompleted()

getCompletedCount

public int getCompletedCount()

getLoadedCount

public int getLoadedCount()

getCorrupted

public ArrayList<org.apache.hadoop.hbase.procedure2.Procedure> getCorrupted()

getCorruptedCount

public int getCorruptedCount()

isRunnable

public boolean isRunnable(long procId)

setMaxProcId

public void setMaxProcId(long maxProcId)

Specified by:

setMaxProcId in interface org.apache.hadoop.hbase.procedure2.store.ProcedureStore.ProcedureLoader

load

public void load(org.apache.hadoop.hbase.procedure2.store.ProcedureStore.ProcedureIterator procIter)
          throws IOException

Specified by:

load in interface org.apache.hadoop.hbase.procedure2.store.ProcedureStore.ProcedureLoader

Throws:

IOException

handleCorrupted

public void handleCorrupted(org.apache.hadoop.hbase.procedure2.store.ProcedureStore.ProcedureIterator procIter)
                     throws IOException

Specified by:

handleCorrupted in interface org.apache.hadoop.hbase.procedure2.store.ProcedureStore.ProcedureLoader

Throws:

IOException