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

Interface ProcedureStore.ProcedureLoader

All Known Subinterfaces:

ProcedureWALFormat.Loader

Enclosing interface:

ProcedureStore

public static interface ProcedureStore.ProcedureLoader

Interface passed to the ProcedureStore.load() method to handle the store-load events.

Method Summary

Modifier and Type	Method	Description
void	handleCorrupted(ProcedureStore.ProcedureIterator procIter)	Called by the ProcedureStore.load() in case we have procedures not-ready to be added to the executor, which probably means they are corrupted since some information/link is missing.
void	load(ProcedureStore.ProcedureIterator procIter)	Called by the ProcedureStore.load() every time a set of procedures are ready to be executed.
void	setMaxProcId(long maxProcId)	Called by ProcedureStore.load() to notify about the maximum proc-id in the store.

Method Details

setMaxProcId

void setMaxProcId(long maxProcId)

Called by ProcedureStore.load() to notify about the maximum proc-id in the store.

Parameters:

maxProcId - the highest proc-id in the store

load

void load(ProcedureStore.ProcedureIterator procIter)
   throws IOException

Called by the ProcedureStore.load() every time a set of procedures are ready to be executed. The ProcedureIterator passed to the method, has the procedure sorted in replay-order.

Parameters:

procIter - iterator over the procedures ready to be added to the executor.

Throws:

IOException

handleCorrupted

void handleCorrupted(ProcedureStore.ProcedureIterator procIter)
              throws IOException

Called by the ProcedureStore.load() in case we have procedures not-ready to be added to the executor, which probably means they are corrupted since some information/link is missing.

Parameters:

procIter - iterator over the procedures not ready to be added to the executor, corrupted

Throws:

IOException