Class AsyncIndexUpdate.AsyncUpdateCallback
java.lang.Object
org.apache.jackrabbit.oak.plugins.index.AsyncIndexUpdate.AsyncUpdateCallback
- All Implemented Interfaces:
IndexUpdateCallback
,NodeTraversalCallback
- Enclosing class:
- AsyncIndexUpdate
protected static class AsyncIndexUpdate.AsyncUpdateCallback
extends Object
implements IndexUpdateCallback, NodeTraversalCallback
Index update callback that tries to raise the async status flag when
the first index change is detected.
- See Also:
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.apache.jackrabbit.oak.plugins.index.NodeTraversalCallback
NodeTraversalCallback.PathSource
-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final int
Interval in terms of number of nodes traversed after which time would be checked for lease expiryFields inherited from interface org.apache.jackrabbit.oak.plugins.index.IndexUpdateCallback
NOOP
Fields inherited from interface org.apache.jackrabbit.oak.plugins.index.NodeTraversalCallback
NOOP
-
Constructor Summary
ConstructorsConstructorDescriptionAsyncUpdateCallback
(NodeStore store, String name, long leaseTimeOut, String checkpoint, org.apache.jackrabbit.oak.plugins.index.AsyncIndexUpdate.AsyncIndexStats indexStats, AtomicBoolean forcedStop) -
Method Summary
Modifier and TypeMethodDescriptionprotected long
getTime()
void
Invoked by theIndexEditor
for every NodeState indexed it.protected void
protected void
void
setCheckpoint
(String checkpoint) void
setValidatorProviders
(List<ValidatorProvider> validatorProviders) void
traversedNode
(NodeTraversalCallback.PathSource pathSource)
-
Field Details
-
LEASE_CHECK_INTERVAL
public static final int LEASE_CHECK_INTERVALInterval in terms of number of nodes traversed after which time would be checked for lease expiry- See Also:
-
-
Constructor Details
-
AsyncUpdateCallback
public AsyncUpdateCallback(NodeStore store, String name, long leaseTimeOut, String checkpoint, org.apache.jackrabbit.oak.plugins.index.AsyncIndexUpdate.AsyncIndexStats indexStats, AtomicBoolean forcedStop)
-
-
Method Details
-
initLease
- Throws:
CommitFailedException
-
prepare
- Throws:
CommitFailedException
-
indexUpdate
Description copied from interface:IndexUpdateCallback
Invoked by theIndexEditor
for every NodeState indexed it.- Specified by:
indexUpdate
in interfaceIndexUpdateCallback
- Throws:
CommitFailedException
-
traversedNode
- Specified by:
traversedNode
in interfaceNodeTraversalCallback
- Throws:
CommitFailedException
-
getTime
protected long getTime() -
setCheckpoint
-
setValidatorProviders
-