public final class LeaseCheckDocumentStoreWrapper extends Object implements DocumentStore, RevisionListener
| Constructor and Description |
|---|
LeaseCheckDocumentStoreWrapper(DocumentStore delegate,
ClusterNodeInfo clusterNodeInfo) |
| Modifier and Type | Method and Description |
|---|---|
<T extends Document> |
create(Collection<T> collection,
List<UpdateOp> updateOps)
Try to create a list of documents.
|
<T extends Document> |
createOrUpdate(Collection<T> collection,
List<UpdateOp> updateOps)
Create or unconditionally update a number of documents.
|
<T extends Document> |
createOrUpdate(Collection<T> collection,
UpdateOp update)
Atomically checks if the document exists and updates it, otherwise the
document is created (aka upsert).
|
long |
determineServerTimeDifferenceMillis() |
void |
dispose()
Dispose this instance.
|
<T extends Document> |
find(Collection<T> collection,
String key)
Get the document with the given
key. |
<T extends Document> |
find(Collection<T> collection,
String key,
int maxCacheAge)
Get the document with the
key. |
<T extends Document> |
findAndUpdate(Collection<T> collection,
UpdateOp update)
Performs a conditional update (e.g.
|
Iterable<CacheStats> |
getCacheStats() |
<T extends Document> |
getIfCached(Collection<T> collection,
String key)
Fetches the cached document.
|
Map<String,String> |
getMetadata() |
Map<String,String> |
getStats()
Returns statistics about the underlying storage.
|
CacheInvalidationStats |
invalidateCache()
Invalidate the document cache.
|
<T extends Document> |
invalidateCache(Collection<T> collection,
String key)
Invalidate the document cache for the given key.
|
CacheInvalidationStats |
invalidateCache(Iterable<String> keys)
Invalidate the document cache but only with entries that match one
of the keys provided.
|
<T extends Document> |
query(Collection<T> collection,
String fromKey,
String toKey,
int limit)
Get a list of documents where the key is greater than a start value and
less than an end value.
|
<T extends Document> |
query(Collection<T> collection,
String fromKey,
String toKey,
String indexedProperty,
long startValue,
int limit)
Get a list of documents where the key is greater than a start value and
less than an end value and the given "indexed property" is greater
or equals the specified value.
|
<T extends Document> |
remove(Collection<T> collection,
List<String> keys)
Batch remove documents with given keys.
|
<T extends Document> |
remove(Collection<T> collection,
Map<String,Long> toRemove)
Batch remove documents with given keys and corresponding equal conditions
on
NodeDocument.MODIFIED_IN_SECS values. |
<T extends Document> |
remove(Collection<T> collection,
String key)
Remove a document.
|
<T extends Document> |
remove(Collection<T> collection,
String indexedProperty,
long startValue,
long endValue)
Batch remove documents where the given "indexed property" is within the given
range (exclusive) -
(startValue, endValue). |
void |
setReadWriteMode(String readWriteMode)
Set the level of guarantee for read and write operations, if supported by this backend.
|
void |
updateAccessedRevision(RevisionVector revision,
int currentClusterId) |
public LeaseCheckDocumentStoreWrapper(DocumentStore delegate, ClusterNodeInfo clusterNodeInfo)
public final <T extends Document> T find(Collection<T> collection, String key)
DocumentStorekey. This is a convenience method
and equivalent to DocumentStore.find(Collection, String, int) with a
maxCacheAge of Integer.MAX_VALUE.
The returned document is immutable.
find in interface DocumentStoreT - the document typecollection - the collectionkey - the keypublic final <T extends Document> T find(Collection<T> collection, String key, int maxCacheAge)
DocumentStorekey. The implementation may serve the
document from a cache, but the cached document must not be older than
the given maxCacheAge in milliseconds. An implementation must
invalidate a cached document when it detects it is outdated. That is, a
subsequent call to DocumentStore.find(Collection, String) must return the
newer version of the document.
The returned document is immutable.
find in interface DocumentStoreT - the document typecollection - the collectionkey - the keymaxCacheAge - the maximum age of the cached document (in ms)public final <T extends Document> List<T> query(Collection<T> collection, String fromKey, String toKey, int limit)
DocumentStoreThe returned documents are sorted by key and are immutable.
query in interface DocumentStoreT - the document typecollection - the collectionfromKey - the start value (excluding)toKey - the end value (excluding)limit - the maximum number of entries to return (starting with the lowest key)public final <T extends Document> List<T> query(Collection<T> collection, String fromKey, String toKey, String indexedProperty, long startValue, int limit)
DocumentStore
The indexed property can either be a Long value, in which case numeric
comparison applies, or a Boolean value, in which case "false" is mapped
to "0" and "true" is mapped to "1".
The returned documents are sorted by key and are immutable.
query in interface DocumentStoreT - the document typecollection - the collectionfromKey - the start value (excluding)toKey - the end value (excluding)indexedProperty - the name of the indexed property (optional)startValue - the minimum value of the indexed propertylimit - the maximum number of entries to returnpublic final <T extends Document> void remove(Collection<T> collection, String key)
DocumentStore
In case of a DocumentStoreException, the document with the given
key may or may not have been removed from the store. It is the
responsibility of the caller to check whether it still exists. The
implementation however ensures that the result of the operation is
properly reflected in the document cache. That is, an implementation
could simply evict the document with the given key.
remove in interface DocumentStoreT - the document typecollection - the collectionkey - the keypublic final <T extends Document> void remove(Collection<T> collection, List<String> keys)
DocumentStorekeys may have been
removed.
In case of a DocumentStoreException, the documents with the given
keys may or may not have been removed from the store. It may also be
possible that only some have been removed from the store. It is the
responsibility of the caller to check which documents still exist. The
implementation however ensures that the result of the operation is
properly reflected in the document cache. That is, an implementation
could simply evict documents with the given keys from the cache.
remove in interface DocumentStoreT - the document typecollection - the collectionkeys - list of keyspublic final <T extends Document> int remove(Collection<T> collection, Map<String,Long> toRemove)
DocumentStoreNodeDocument.MODIFIED_IN_SECS values. Keys for documents that
do not exist are simply ignored. A document is only removed if the
corresponding condition is met.
In case of a DocumentStoreException, the documents with the given
keys may or may not have been removed from the store. It may also be
possible that only some have been removed from the store. It is the
responsibility of the caller to check which documents still exist. The
implementation however ensures that the result of the operation is
properly reflected in the document cache. That is, an implementation
could simply evict documents with the given keys from the cache.
remove in interface DocumentStoreT - the document typecollection - the collection.toRemove - the keys of the documents to remove with the corresponding
timestamps.public <T extends Document> int remove(Collection<T> collection, String indexedProperty, long startValue, long endValue) throws DocumentStoreException
DocumentStore(startValue, endValue).
The indexed property is a Long value and numeric comparison applies.
In case of a DocumentStoreException, the documents with the given
keys may or may not have been removed from the store. It may also be
possible that only some have been removed from the store. It is the
responsibility of the caller to check which documents still exist. The
implementation however ensures that the result of the operation is
properly reflected in the document cache. That is, an implementation
could simply evict documents with the given keys from the cache.
remove in interface DocumentStoreT - the document typecollection - the collection.indexedProperty - the name of the indexed propertystartValue - the minimum value of the indexed property (exclusive)endValue - the maximum value of the indexed property (exclusive)DocumentStoreException - if the operation failed. E.g. because of
an I/O error.public final <T extends Document> boolean create(Collection<T> collection, List<UpdateOp> updateOps)
DocumentStoretrue iff
none of the documents existed before and the create was successful. This
method will return false if one of the documents already exists
in the store. Some documents may still have been created in the store.
An implementation does not have to guarantee an atomic create of all the
documents described in the updateOps. It is the responsibility of
the caller to check, which documents were created and take appropriate
action. The same is true when this method throws
DocumentStoreException (e.g. when a communication error occurs).
In this case only some documents may have been created.create in interface DocumentStoreT - the document typecollection - the collectionupdateOps - the list of documents to add (where UpdateOp.Conditions are not allowed)public final <T extends Document> T createOrUpdate(Collection<T> collection, UpdateOp update)
DocumentStore
If this method fails with a DocumentStoreException, then the
document may or may not have been created or updated. It is the
responsibility of the caller to check the result e.g. by calling
DocumentStore.find(Collection, String). The implementation however ensures
that the result of the operation is properly reflected in the document
cache. That is, an implementation could simply evict documents with the
given keys from the cache.
createOrUpdate in interface DocumentStoreT - the document typecollection - the collectionupdate - the update operation (where UpdateOp.Conditions are not allowed)null if it didn't exist before.public <T extends Document> List<T> createOrUpdate(Collection<T> collection, List<UpdateOp> updateOps)
DocumentStore
In case of a DocumentStoreException (e.g. when a communication
error occurs) only some changes may have been applied. In this case it is
the responsibility of the caller to check which UpdateOps
were applied and take appropriate action. The implementation however
ensures that the result of the operations are properly reflected in the
document cache. That is, an implementation could simply evict documents
related to the given update operations from the cache.
createOrUpdate in interface DocumentStoreT - the document typecollection - the collectionupdateOps - the update operation listnull values if they didn't exist
before (see DocumentStore.createOrUpdate(Collection, UpdateOp)), where the order
reflects the order in the "updateOps" parameterpublic final <T extends Document> T findAndUpdate(Collection<T> collection, UpdateOp update)
DocumentStoreUpdateOp.Condition.Type.EXISTS and only updates the
document if the condition is true. The returned document is
immutable.
In case of a DocumentStoreException (e.g. when a communication
error occurs) the update may or may not have been applied. In this case
it is the responsibility of the caller to check whether the update was
applied and take appropriate action. The implementation however ensures
that the result of the operation is properly reflected in the document
cache. That is, an implementation could simply evict the document related
to the given update operation from the cache.
findAndUpdate in interface DocumentStoreT - the document typecollection - the collectionupdate - the update operation with the conditionnull if the condition is not met or
if the document wasn't foundpublic final CacheInvalidationStats invalidateCache()
DocumentStoreDocumentStore.getIfCached(Collection, String)
returns a non-null value for a key.
An implementation is allowed to perform lazy invalidation and only check
whether a document is up-to-date when it is accessed after this method
is called. However, this also includes a call to DocumentStore.getIfCached(Collection, String),
which must only return the document if it was up-to-date at the time
this method was called. Similarly, a call to DocumentStore.find(Collection, String)
must guarantee the returned document reflects all the changes done up to
when invalidateCache() was called.
In some implementations this method can be a NOP because documents can
only be modified through a single instance of a DocumentStore.
invalidateCache in interface DocumentStorenull if none are
available.public final CacheInvalidationStats invalidateCache(Iterable<String> keys)
DocumentStoreDocumentStore.invalidateCache() for the general contract of cache
invalidation.invalidateCache in interface DocumentStorekeys - the keys of the documents to invalidate.null if none are
available.public final <T extends Document> void invalidateCache(Collection<T> collection, String key)
DocumentStoreDocumentStore.invalidateCache() for the general contract of cache
invalidation.invalidateCache in interface DocumentStorecollection - the collectionkey - the keypublic final void dispose()
DocumentStoredispose in interface DocumentStorepublic final <T extends Document> T getIfCached(Collection<T> collection, String key)
DocumentStorenull will be returned. This method is consistent with other find
methods that may return cached documents and will return null
even when the implementation has a negative cache for documents that
do not exist. This method will never return NodeDocument.NULL.getIfCached in interface DocumentStoreT - the document typecollection - the collectionkey - the keynull.public final void setReadWriteMode(String readWriteMode)
DocumentStoresetReadWriteMode in interface DocumentStorereadWriteMode - the read/write modepublic final Iterable<CacheStats> getCacheStats()
getCacheStats in interface DocumentStorepublic final Map<String,String> getMetadata()
getMetadata in interface DocumentStore@Nonnull public Map<String,String> getStats()
DocumentStoregetStats in interface DocumentStorepublic long determineServerTimeDifferenceMillis()
determineServerTimeDifferenceMillis in interface DocumentStorepublic void updateAccessedRevision(RevisionVector revision, int currentClusterId)
updateAccessedRevision in interface RevisionListenerCopyright © 2012–2018 The Apache Software Foundation. All rights reserved.