public static interface ProcedureStore.ProcedureLoader
Modifier and Type | Method and 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.
|
void setMaxProcId(long maxProcId)
maxProcId
- the highest proc-id in the storevoid load(ProcedureStore.ProcedureIterator procIter) throws IOException
procIter
- iterator over the procedures ready to be added to the executor.IOException
void handleCorrupted(ProcedureStore.ProcedureIterator procIter) throws IOException
procIter
- iterator over the procedures not ready to be added to the executor, corruptedIOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.