Uses of Class
org.apache.jackrabbit.oak.plugins.document.Document
-
Packages that use Document Package Description org.apache.jackrabbit.oak.plugins.document org.apache.jackrabbit.oak.plugins.document.memory org.apache.jackrabbit.oak.plugins.document.mongo org.apache.jackrabbit.oak.plugins.document.rdb Implementations ofDocumentStore
andBlobStore
for relational databases.org.apache.jackrabbit.oak.plugins.document.util -
-
Uses of Document in org.apache.jackrabbit.oak.plugins.document
Classes in org.apache.jackrabbit.oak.plugins.document with type parameters of type Document Modifier and Type Class Description class
Collection<T extends Document>
The collection types.Subclasses of Document in org.apache.jackrabbit.oak.plugins.document Modifier and Type Class Description class
ClusterNodeInfoDocument
A document storing cluster node info.class
JournalEntry
Keeps track of changes performed between two consecutive background updates.class
NodeDocument
A document storing data about a node.Fields in org.apache.jackrabbit.oak.plugins.document with type parameters of type Document Modifier and Type Field Description static Collection<Document>
Collection. BLOBS
The 'blobs' collection contains data from the blob store.static Collection<Document>
Collection. SETTINGS
The 'settings' collection contains setting/state data required for DocumentNodeStoreMethods in org.apache.jackrabbit.oak.plugins.document with type parameters of type Document Modifier and Type Method Description <T extends Document>
booleanDocumentStore. create(Collection<T> collection, java.util.List<UpdateOp> updateOps)
Try to create a list of documents.<T extends Document>
java.util.List<T>DocumentStore. createOrUpdate(Collection<T> collection, java.util.List<UpdateOp> updateOps)
Create or unconditionally update a number of documents.<T extends Document>
TDocumentStore. createOrUpdate(Collection<T> collection, UpdateOp update)
Atomically checks if the document exists and updates it, otherwise the document is created (aka "upsert"), unless the update operation requires the document to be present (seeUpdateOp.isNew()
).<T extends Document>
TDocumentStore. find(Collection<T> collection, java.lang.String key)
Get the document with the givenkey
.<T extends Document>
TDocumentStore. find(Collection<T> collection, java.lang.String key, int maxCacheAge)
Get the document with thekey
.default <T extends Document>
@NotNull java.util.List<T>DocumentStore. findAndUpdate(@NotNull Collection<T> collection, @NotNull java.util.List<UpdateOp> updateOps)
Performs a conditional update (e.g.<T extends Document>
TDocumentStore. findAndUpdate(Collection<T> collection, UpdateOp update)
Performs a conditional update (e.g.<T extends Document>
TDocumentStore. getIfCached(Collection<T> collection, java.lang.String key)
Fetches the cached document.<T extends Document>
voidDocumentStore. invalidateCache(Collection<T> collection, java.lang.String key)
Invalidate the document cache for the given key.default <T extends Document>
voidDocumentStore. prefetch(Collection<T> collection, java.lang.Iterable<java.lang.String> keys)
optional method indicating the DocumentStore should prefetch, in the most optimal way eg by batching, a bunch of keys as they might soon be needed.<T extends Document>
@NotNull java.util.List<T>DocumentStore. query(Collection<T> collection, java.lang.String fromKey, java.lang.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>
@NotNull java.util.List<T>DocumentStore. query(Collection<T> collection, java.lang.String fromKey, java.lang.String toKey, java.lang.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.default <T extends Document>
@NotNull java.util.List<T>DocumentStore. query(Collection<T> collection, java.lang.String fromKey, java.lang.String toKey, java.lang.String indexedProperty, long startValue, int limit, java.util.List<java.lang.String> projection)
Get a list of documents with only projected fields (as mentioned in projections param) along with "_id" field and 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>
voidDocumentStore. remove(Collection<T> collection, java.lang.String key)
Remove a document.<T extends Document>
intDocumentStore. remove(Collection<T> collection, java.lang.String indexedProperty, long startValue, long endValue)
Batch remove documents where the given "indexed property" is within the given range (exclusive) -(startValue, endValue)
.<T extends Document>
voidDocumentStore. remove(Collection<T> collection, java.util.List<java.lang.String> keys)
Batch remove documents with given keys.<T extends Document>
intDocumentStore. remove(Collection<T> collection, java.util.Map<java.lang.String,java.lang.Long> toRemove)
Batch remove documents with given keys and corresponding equal conditions onNodeDocument.MODIFIED_IN_SECS
values.Methods in org.apache.jackrabbit.oak.plugins.document with parameters of type Document Modifier and Type Method Description static void
UpdateUtils. applyChanges(@NotNull Document doc, @NotNull UpdateOp update)
Apply the changes to the in-memory document.static boolean
UpdateUtils. checkConditions(@NotNull Document doc, @NotNull java.util.Map<UpdateOp.Key,UpdateOp.Condition> conditions)
void
Document. deepCopy(Document target)
Performs a deep copy of the data within this document to the given target.Method parameters in org.apache.jackrabbit.oak.plugins.document with type arguments of type Document Modifier and Type Method Description void
DocumentStoreStats. doneCreate(long timeTakenNanos, Collection<? extends Document> collection, java.util.List<java.lang.String> ids, boolean insertSuccess)
void
DocumentStoreStatsCollector. doneCreate(long timeTakenNanos, Collection<? extends Document> collection, java.util.List<java.lang.String> ids, boolean insertSuccess)
Called when a document is created in the given collectionvoid
ThrottlingStatsCollector. doneCreate(long throttlingTimeNanos, Collection<? extends Document> collection, java.util.List<java.lang.String> ids, boolean insertSuccess)
Called when a document is created in the given collectionvoid
ThrottlingStatsCollectorImpl. doneCreate(long throttlingTimeNanos, Collection<? extends Document> collection, java.util.List<java.lang.String> ids, boolean insertSuccess)
void
DocumentStoreStats. doneCreateOrUpdate(long timeTakenNanos, Collection<? extends Document> collection, java.util.List<java.lang.String> ids)
void
DocumentStoreStatsCollector. doneCreateOrUpdate(long timeTakenNanos, Collection<? extends Document> collection, java.util.List<java.lang.String> ids)
Called when multiple document are either created or updated.void
ThrottlingStatsCollector. doneCreateOrUpdate(long throttlingTimeNanos, Collection<? extends Document> collection, java.util.List<java.lang.String> ids)
Called when multiple document are either created or updated.void
ThrottlingStatsCollectorImpl. doneCreateOrUpdate(long throttlingTimeNanos, Collection<? extends Document> collection, java.util.List<java.lang.String> ids)
void
DocumentStoreStats. doneFindAndModify(long timeTakenNanos, Collection<? extends Document> collection, java.lang.String key, boolean newEntry, boolean success, int retryCount)
void
DocumentStoreStats. doneFindAndModify(long timeTakenNanos, Collection<? extends Document> collection, java.util.List<java.lang.String> ids, boolean success, int retryCount)
void
DocumentStoreStatsCollector. doneFindAndModify(long timeTakenNanos, Collection<? extends Document> collection, java.lang.String key, boolean newEntry, boolean success, int retryCount)
Called when a update operation was completed which affected single document.void
DocumentStoreStatsCollector. doneFindAndModify(long timeTakenNanos, Collection<? extends Document> collection, java.util.List<java.lang.String> ids, boolean success, int retryCount)
Called when a update operation was completed which could have affected multiple documents.void
ThrottlingStatsCollector. doneFindAndModify(long throttlingTimeNanos, Collection<? extends Document> collection, java.lang.String key, boolean newEntry, boolean success, int retryCount)
Called when a update operation was completed which affected single document.void
ThrottlingStatsCollector. doneFindAndModify(long throttlingTimeNanos, Collection<? extends Document> collection, java.util.List<java.lang.String> ids, boolean success, int retryCount)
Called when a update operation was completed which could have affected multiple documents.void
ThrottlingStatsCollectorImpl. doneFindAndModify(long throttlingTimeNanos, Collection<? extends Document> collection, java.lang.String key, boolean newEntry, boolean success, int retryCount)
void
ThrottlingStatsCollectorImpl. doneFindAndModify(long throttlingTimeNanos, Collection<? extends Document> collection, java.util.List<java.lang.String> ids, boolean success, int retryCount)
void
DocumentStoreStats. doneFindCached(Collection<? extends Document> collection, java.lang.String key)
void
DocumentStoreStatsCollector. doneFindCached(Collection<? extends Document> collection, java.lang.String key)
Called when a document with given key is found from the cachevoid
DocumentStoreStats. doneFindUncached(long timeTakenNanos, Collection<? extends Document> collection, java.lang.String key, boolean docFound, boolean isSlaveOk)
void
DocumentStoreStatsCollector. doneFindUncached(long timeTakenNanos, Collection<? extends Document> collection, java.lang.String key, boolean docFound, boolean isSlaveOk)
Called when a document with given key is read from remote storevoid
DocumentStoreStats. donePrefetch(long timeTakenNanos, Collection<? extends Document> collection, java.util.List<java.lang.String> ids)
void
DocumentStoreStatsCollector. donePrefetch(long timeTakenNanos, Collection<? extends Document> collection, java.util.List<java.lang.String> ids)
Called when a prefetch operation for documents was completed.void
DocumentStoreStats. doneQuery(long timeTakenNanos, Collection<? extends Document> collection, java.lang.String fromKey, java.lang.String toKey, boolean indexedProperty, int resultSize, long lockTime, boolean isSlaveOk)
void
DocumentStoreStatsCollector. doneQuery(long timeTakenNanos, Collection<? extends Document> collection, java.lang.String fromKey, java.lang.String toKey, boolean indexedProperty, int resultSize, long lockTime, boolean isSlaveOk)
Called when query with given parameters is performedvoid
DocumentStoreStats. doneRemove(long timeTakenNanos, Collection<? extends Document> collection, int removeCount)
void
DocumentStoreStatsCollector. doneRemove(long timeTakenNanos, Collection<? extends Document> collection, int removeCount)
Called when a remove operation for documents was completed.void
ThrottlingStatsCollector. doneRemove(long throttlingTimeNanos, Collection<? extends Document> collection)
Called when a remove operation for documents was completed.void
ThrottlingStatsCollectorImpl. doneRemove(long throttlingTimeNanos, Collection<? extends Document> collection)
-
Uses of Document in org.apache.jackrabbit.oak.plugins.document.memory
Methods in org.apache.jackrabbit.oak.plugins.document.memory with type parameters of type Document Modifier and Type Method Description <T extends Document>
booleanMemoryDocumentStore. create(Collection<T> collection, java.util.List<UpdateOp> updateOps)
<T extends Document>
java.util.List<T>MemoryDocumentStore. createOrUpdate(Collection<T> collection, java.util.List<UpdateOp> updateOps)
<T extends Document>
TMemoryDocumentStore. createOrUpdate(Collection<T> collection, UpdateOp update)
<T extends Document>
TMemoryDocumentStore. find(Collection<T> collection, java.lang.String key)
<T extends Document>
TMemoryDocumentStore. find(Collection<T> collection, java.lang.String key, int maxCacheAge)
<T extends Document>
TMemoryDocumentStore. findAndUpdate(Collection<T> collection, UpdateOp update)
<T extends Document>
TMemoryDocumentStore. getIfCached(Collection<T> collection, java.lang.String key)
protected <T extends Document>
java.util.concurrent.ConcurrentSkipListMap<java.lang.String,T>MemoryDocumentStore. getMap(Collection<T> collection)
Get the in-memory map for this collection.<T extends Document>
voidMemoryDocumentStore. invalidateCache(Collection<T> collection, java.lang.String key)
<T extends Document>
@NotNull java.util.List<T>MemoryDocumentStore. query(Collection<T> collection, java.lang.String fromKey, java.lang.String toKey, int limit)
<T extends Document>
@NotNull java.util.List<T>MemoryDocumentStore. query(Collection<T> collection, java.lang.String fromKey, java.lang.String toKey, java.lang.String indexedProperty, long startValue, int limit)
<T extends Document>
voidMemoryDocumentStore. remove(Collection<T> collection, java.lang.String key)
<T extends Document>
intMemoryDocumentStore. remove(Collection<T> collection, java.lang.String indexedProperty, long startValue, long endValue)
<T extends Document>
voidMemoryDocumentStore. remove(Collection<T> collection, java.util.List<java.lang.String> keys)
<T extends Document>
intMemoryDocumentStore. remove(Collection<T> collection, java.util.Map<java.lang.String,java.lang.Long> toRemove)
-
Uses of Document in org.apache.jackrabbit.oak.plugins.document.mongo
Methods in org.apache.jackrabbit.oak.plugins.document.mongo with type parameters of type Document Modifier and Type Method Description protected <T extends Document>
TMongoDocumentStore. convertFromDBObject(@NotNull Collection<T> collection, @Nullable com.mongodb.DBObject n)
static <T extends Document>
TMongoDocumentStoreHelper. convertFromDBObject(MongoDocumentStore store, Collection<T> col, com.mongodb.DBObject obj)
<T extends Document>
booleanMongoDocumentStore. create(Collection<T> collection, java.util.List<UpdateOp> updateOps)
<T extends Document>
@Nullable java.util.List<T>MongoDocumentStore. createOrUpdate(Collection<T> collection, java.util.List<UpdateOp> updateOps)
Try to apply all theUpdateOp
s with at least MongoDB requests as possible.<T extends Document>
TMongoDocumentStore. createOrUpdate(Collection<T> collection, UpdateOp update)
<T extends Document>
TMongoDocumentStore. find(Collection<T> collection, java.lang.String key)
<T extends Document>
TMongoDocumentStore. find(Collection<T> collection, java.lang.String key, int maxCacheAge)
<T extends Document>
@NotNull java.util.List<T>MongoDocumentStore. findAndUpdate(@NotNull Collection<T> collection, @NotNull java.util.List<UpdateOp> updateOps)
Try to apply all theUpdateOp
s with at least MongoDB requests as possible.<T extends Document>
TMongoDocumentStore. findAndUpdate(Collection<T> collection, UpdateOp update)
protected <T extends Document>
TMongoDocumentStore. findUncached(Collection<T> collection, java.lang.String key, org.apache.jackrabbit.oak.plugins.document.mongo.MongoDocumentStore.DocumentReadPreference docReadPref)
<T extends Document>
CloseableIterable<T>MongoDocumentTraverser. getAllDocuments(Collection<T> collection, TraversingRange traversingRange, java.util.function.Predicate<java.lang.String> filter)
static <T extends Document>
com.mongodb.client.MongoCollection<com.mongodb.BasicDBObject>MongoDocumentStoreHelper. getDBCollection(MongoDocumentStore store, Collection<T> c)
<T extends Document>
TMongoDocumentStore. getIfCached(Collection<T> collection, java.lang.String key)
<T extends Document>
voidMongoDocumentStore. invalidateCache(Collection<T> collection, java.lang.String key)
<T extends Document>
voidMongoDocumentStore. prefetch(Collection<T> collection, java.lang.Iterable<java.lang.String> keysToPrefetch)
<T extends Document>
@NotNull java.util.List<T>MongoDocumentStore. query(Collection<T> collection, java.lang.String fromKey, java.lang.String toKey, int limit)
<T extends Document>
@NotNull java.util.List<T>MongoDocumentStore. query(Collection<T> collection, java.lang.String fromKey, java.lang.String toKey, java.lang.String indexedProperty, long startValue, int limit)
<T extends Document>
@NotNull java.util.List<T>MongoDocumentStore. query(Collection<T> collection, java.lang.String fromKey, java.lang.String toKey, java.lang.String indexedProperty, long startValue, int limit, java.util.List<java.lang.String> projection)
protected <T extends Document>
@NotNull java.util.List<T>MongoDocumentStore. queryInternal(Collection<T> collection, java.lang.String fromKey, java.lang.String toKey, java.lang.String indexedProperty, long startValue, int limit, java.util.List<java.lang.String> projection, long maxQueryTime)
<T extends Document>
voidMongoDocumentStore. remove(Collection<T> collection, java.lang.String key)
<T extends Document>
intMongoDocumentStore. remove(Collection<T> collection, java.lang.String indexedProperty, long startValue, long endValue)
<T extends Document>
voidMongoDocumentStore. remove(Collection<T> collection, java.util.List<java.lang.String> keys)
<T extends Document>
intMongoDocumentStore. remove(Collection<T> collection, java.util.Map<java.lang.String,java.lang.Long> toRemove)
<T extends Document>
java.util.List<java.lang.Long>DocumentStoreSplitter. split(Collection<T> collection, long modifiedSinceLowerLimit, int parts)
Method parameters in org.apache.jackrabbit.oak.plugins.document.mongo with type arguments of type Document Modifier and Type Method Description static com.mongodb.ReadPreference
MongoDocumentStoreHelper. getConfiguredReadPreference(MongoDocumentStore mongoStore, Collection<? extends Document> collection)
-
Uses of Document in org.apache.jackrabbit.oak.plugins.document.rdb
Methods in org.apache.jackrabbit.oak.plugins.document.rdb with type parameters of type Document Modifier and Type Method Description protected <T extends Document>
TRDBDocumentStore. convertFromDBObject(@NotNull Collection<T> collection, @NotNull RDBRow row)
<T extends Document>
booleanRDBDocumentStore. create(Collection<T> collection, java.util.List<UpdateOp> updateOps)
<T extends Document>
java.util.List<T>RDBDocumentStore. createOrUpdate(Collection<T> collection, java.util.List<UpdateOp> updateOps)
<T extends Document>
TRDBDocumentStore. createOrUpdate(Collection<T> collection, UpdateOp update)
<T extends Document>
TRDBDocumentStore. find(Collection<T> collection, java.lang.String id)
<T extends Document>
TRDBDocumentStore. find(Collection<T> collection, java.lang.String id, int maxCacheAge)
<T extends Document>
TRDBDocumentStore. findAndUpdate(Collection<T> collection, UpdateOp update)
<T extends Document>
TRDBDocumentSerializer. fromRow(@NotNull Collection<T> collection, @NotNull RDBRow row)
<T extends Document>
TRDBDocumentStore. getIfCached(Collection<T> collection, java.lang.String id)
protected <T extends Document>
longRDBDocumentStore. getMinValue(Collection<T> collection, java.lang.String field, java.lang.String fromKey, java.lang.String toKey, java.util.List<java.lang.String> excludeKeyPatterns, java.util.List<RDBDocumentStore.QueryCondition> conditions)
protected <T extends Document>
@NotNull org.apache.jackrabbit.oak.plugins.document.rdb.RDBDocumentStore.RDBTableMetaDataRDBDocumentStore. getTable(Collection<T> collection)
<T extends Document>
java.util.Set<java.lang.String>RDBDocumentStoreJDBC. insert(java.sql.Connection connection, org.apache.jackrabbit.oak.plugins.document.rdb.RDBDocumentStore.RDBTableMetaData tmd, java.util.List<T> documents)
<T extends Document>
voidRDBDocumentStore. invalidateCache(Collection<T> collection, java.lang.String id)
<T extends Document>
@NotNull java.util.List<T>RDBDocumentStore. query(Collection<T> collection, java.lang.String fromKey, java.lang.String toKey, int limit)
<T extends Document>
@NotNull java.util.List<T>RDBDocumentStore. query(Collection<T> collection, java.lang.String fromKey, java.lang.String toKey, java.lang.String indexedProperty, long startValue, int limit)
protected <T extends Document>
@NotNull java.util.List<T>RDBDocumentStore. query(Collection<T> collection, java.lang.String fromKey, java.lang.String toKey, java.util.List<java.lang.String> excludeKeyPatterns, java.util.List<RDBDocumentStore.QueryCondition> conditions, int limit)
protected <T extends Document>
java.lang.Iterable<T>RDBDocumentStore. queryAsIterable(Collection<T> collection, java.lang.String fromKey, java.lang.String toKey, java.util.List<java.lang.String> excludeKeyPatterns, java.util.List<RDBDocumentStore.QueryCondition> conditions, int limit, java.lang.String sortBy)
protected <T extends Document>
longRDBDocumentStore. queryCount(Collection<T> collection, java.lang.String fromKey, java.lang.String toKey, java.util.List<java.lang.String> excludeKeyPatterns, java.util.List<RDBDocumentStore.QueryCondition> conditions)
<T extends Document>
voidRDBDocumentStore. remove(Collection<T> collection, java.lang.String id)
<T extends Document>
intRDBDocumentStore. remove(Collection<T> collection, java.lang.String indexedProperty, long startValue, long endValue)
<T extends Document>
voidRDBDocumentStore. remove(Collection<T> collection, java.util.List<java.lang.String> ids)
<T extends Document>
intRDBDocumentStore. remove(Collection<T> collection, java.util.Map<java.lang.String,java.lang.Long> toRemove)
<T extends Document>
java.util.Set<java.lang.String>RDBDocumentStoreJDBC. update(java.sql.Connection connection, org.apache.jackrabbit.oak.plugins.document.rdb.RDBDocumentStore.RDBTableMetaData tmd, java.util.List<T> documents, boolean upsert)
Update a list of documents using JDBC batches.Methods in org.apache.jackrabbit.oak.plugins.document.rdb with parameters of type Document Modifier and Type Method Description java.lang.String
RDBDocumentSerializer. asString(@NotNull Document doc, java.util.Set<java.lang.String> columnProperties)
Serializes all non-column properties of theDocument
into a JSON string. -
Uses of Document in org.apache.jackrabbit.oak.plugins.document.util
Methods in org.apache.jackrabbit.oak.plugins.document.util with type parameters of type Document Modifier and Type Method Description <T extends Document>
booleanLeaseCheckDocumentStoreWrapper. create(Collection<T> collection, java.util.List<UpdateOp> updateOps)
<T extends Document>
booleanLoggingDocumentStoreWrapper. create(Collection<T> collection, java.util.List<UpdateOp> updateOps)
<T extends Document>
booleanSynchronizingDocumentStoreWrapper. create(Collection<T> collection, java.util.List<UpdateOp> updateOps)
<T extends Document>
booleanThrottlingDocumentStoreWrapper. create(Collection<T> collection, java.util.List<UpdateOp> updateOps)
<T extends Document>
booleanTimingDocumentStoreWrapper. create(Collection<T> collection, java.util.List<UpdateOp> updateOps)
<T extends Document>
java.util.List<T>LeaseCheckDocumentStoreWrapper. createOrUpdate(Collection<T> collection, java.util.List<UpdateOp> updateOps)
<T extends Document>
TLeaseCheckDocumentStoreWrapper. createOrUpdate(Collection<T> collection, UpdateOp update)
<T extends Document>
java.util.List<T>LoggingDocumentStoreWrapper. createOrUpdate(Collection<T> collection, java.util.List<UpdateOp> updateOps)
<T extends Document>
TLoggingDocumentStoreWrapper. createOrUpdate(Collection<T> collection, UpdateOp update)
<T extends Document>
java.util.List<T>SynchronizingDocumentStoreWrapper. createOrUpdate(Collection<T> collection, java.util.List<UpdateOp> updateOps)
<T extends Document>
TSynchronizingDocumentStoreWrapper. createOrUpdate(Collection<T> collection, UpdateOp update)
<T extends Document>
java.util.List<T>ThrottlingDocumentStoreWrapper. createOrUpdate(Collection<T> collection, java.util.List<UpdateOp> updateOps)
<T extends Document>
TThrottlingDocumentStoreWrapper. createOrUpdate(Collection<T> collection, UpdateOp update)
<T extends Document>
java.util.List<T>TimingDocumentStoreWrapper. createOrUpdate(Collection<T> collection, java.util.List<UpdateOp> updateOps)
<T extends Document>
TTimingDocumentStoreWrapper. createOrUpdate(Collection<T> collection, UpdateOp update)
<T extends Document>
TLeaseCheckDocumentStoreWrapper. find(Collection<T> collection, java.lang.String key)
<T extends Document>
TLeaseCheckDocumentStoreWrapper. find(Collection<T> collection, java.lang.String key, int maxCacheAge)
<T extends Document>
TLoggingDocumentStoreWrapper. find(Collection<T> collection, java.lang.String key)
<T extends Document>
TLoggingDocumentStoreWrapper. find(Collection<T> collection, java.lang.String key, int maxCacheAge)
<T extends Document>
TSynchronizingDocumentStoreWrapper. find(Collection<T> collection, java.lang.String key)
<T extends Document>
TSynchronizingDocumentStoreWrapper. find(Collection<T> collection, java.lang.String key, int maxCacheAge)
<T extends Document>
TThrottlingDocumentStoreWrapper. find(Collection<T> collection, java.lang.String key)
<T extends Document>
TThrottlingDocumentStoreWrapper. find(Collection<T> collection, java.lang.String key, int maxCacheAge)
<T extends Document>
TTimingDocumentStoreWrapper. find(Collection<T> collection, java.lang.String key)
<T extends Document>
TTimingDocumentStoreWrapper. find(Collection<T> collection, java.lang.String key, int maxCacheAge)
<T extends Document>
@NotNull java.util.List<T>LeaseCheckDocumentStoreWrapper. findAndUpdate(@NotNull Collection<T> collection, @NotNull java.util.List<UpdateOp> updateOps)
<T extends Document>
TLeaseCheckDocumentStoreWrapper. findAndUpdate(Collection<T> collection, UpdateOp update)
<T extends Document>
java.util.List<T>LoggingDocumentStoreWrapper. findAndUpdate(@NotNull Collection<T> collection, @NotNull java.util.List<UpdateOp> updateOps)
<T extends Document>
TLoggingDocumentStoreWrapper. findAndUpdate(Collection<T> collection, UpdateOp update)
<T extends Document>
@NotNull java.util.List<T>SynchronizingDocumentStoreWrapper. findAndUpdate(@NotNull Collection<T> collection, @NotNull java.util.List<UpdateOp> updateOps)
<T extends Document>
TSynchronizingDocumentStoreWrapper. findAndUpdate(Collection<T> collection, UpdateOp update)
<T extends Document>
@NotNull java.util.List<T>ThrottlingDocumentStoreWrapper. findAndUpdate(@NotNull Collection<T> collection, @NotNull java.util.List<UpdateOp> updateOps)
<T extends Document>
TThrottlingDocumentStoreWrapper. findAndUpdate(Collection<T> collection, UpdateOp update)
<T extends Document>
@NotNull java.util.List<T>TimingDocumentStoreWrapper. findAndUpdate(@NotNull Collection<T> collection, @NotNull java.util.List<UpdateOp> updateOps)
<T extends Document>
TTimingDocumentStoreWrapper. findAndUpdate(Collection<T> collection, UpdateOp update)
<T extends Document>
TLeaseCheckDocumentStoreWrapper. getIfCached(Collection<T> collection, java.lang.String key)
<T extends Document>
TLoggingDocumentStoreWrapper. getIfCached(Collection<T> collection, java.lang.String key)
<T extends Document>
TSynchronizingDocumentStoreWrapper. getIfCached(Collection<T> collection, java.lang.String key)
<T extends Document>
TThrottlingDocumentStoreWrapper. getIfCached(Collection<T> collection, java.lang.String key)
<T extends Document>
TTimingDocumentStoreWrapper. getIfCached(Collection<T> collection, java.lang.String key)
<T extends Document>
voidLeaseCheckDocumentStoreWrapper. invalidateCache(Collection<T> collection, java.lang.String key)
<T extends Document>
voidLoggingDocumentStoreWrapper. invalidateCache(Collection<T> collection, java.lang.String key)
<T extends Document>
voidSynchronizingDocumentStoreWrapper. invalidateCache(Collection<T> collection, java.lang.String key)
<T extends Document>
voidThrottlingDocumentStoreWrapper. invalidateCache(Collection<T> collection, java.lang.String key)
<T extends Document>
voidTimingDocumentStoreWrapper. invalidateCache(Collection<T> collection, java.lang.String key)
<T extends Document>
voidLeaseCheckDocumentStoreWrapper. prefetch(Collection<T> collection, java.lang.Iterable<java.lang.String> keys)
<T extends Document>
java.util.List<T>LeaseCheckDocumentStoreWrapper. query(Collection<T> collection, java.lang.String fromKey, java.lang.String toKey, int limit)
<T extends Document>
java.util.List<T>LeaseCheckDocumentStoreWrapper. query(Collection<T> collection, java.lang.String fromKey, java.lang.String toKey, java.lang.String indexedProperty, long startValue, int limit)
<T extends Document>
@NotNull java.util.List<T>LeaseCheckDocumentStoreWrapper. query(Collection<T> collection, java.lang.String fromKey, java.lang.String toKey, java.lang.String indexedProperty, long startValue, int limit, java.util.List<java.lang.String> projection)
<T extends Document>
@NotNull java.util.List<T>LoggingDocumentStoreWrapper. query(Collection<T> collection, java.lang.String fromKey, java.lang.String toKey, int limit)
<T extends Document>
@NotNull java.util.List<T>LoggingDocumentStoreWrapper. query(Collection<T> collection, java.lang.String fromKey, java.lang.String toKey, java.lang.String indexedProperty, long startValue, int limit)
<T extends Document>
@NotNull java.util.List<T>LoggingDocumentStoreWrapper. query(Collection<T> collection, java.lang.String fromKey, java.lang.String toKey, java.lang.String indexedProperty, long startValue, int limit, java.util.List<java.lang.String> projection)
<T extends Document>
@NotNull java.util.List<T>SynchronizingDocumentStoreWrapper. query(Collection<T> collection, java.lang.String fromKey, java.lang.String toKey, int limit)
<T extends Document>
@NotNull java.util.List<T>SynchronizingDocumentStoreWrapper. query(Collection<T> collection, java.lang.String fromKey, java.lang.String toKey, java.lang.String indexedProperty, long startValue, int limit)
<T extends Document>
@NotNull java.util.List<T>SynchronizingDocumentStoreWrapper. query(Collection<T> collection, java.lang.String fromKey, java.lang.String toKey, java.lang.String indexedProperty, long startValue, int limit, java.util.List<java.lang.String> projection)
<T extends Document>
@NotNull java.util.List<T>ThrottlingDocumentStoreWrapper. query(Collection<T> collection, java.lang.String fromKey, java.lang.String toKey, int limit)
<T extends Document>
@NotNull java.util.List<T>ThrottlingDocumentStoreWrapper. query(Collection<T> collection, java.lang.String fromKey, java.lang.String toKey, java.lang.String indexedProperty, long startValue, int limit)
<T extends Document>
@NotNull java.util.List<T>ThrottlingDocumentStoreWrapper. query(Collection<T> collection, java.lang.String fromKey, java.lang.String toKey, java.lang.String indexedProperty, long startValue, int limit, java.util.List<java.lang.String> projection)
<T extends Document>
@NotNull java.util.List<T>TimingDocumentStoreWrapper. query(Collection<T> collection, java.lang.String fromKey, java.lang.String toKey, int limit)
<T extends Document>
@NotNull java.util.List<T>TimingDocumentStoreWrapper. query(Collection<T> collection, java.lang.String fromKey, java.lang.String toKey, java.lang.String indexedProperty, long startValue, int limit)
<T extends Document>
@NotNull java.util.List<T>TimingDocumentStoreWrapper. query(Collection<T> collection, java.lang.String fromKey, java.lang.String toKey, java.lang.String indexedProperty, long startValue, int limit, java.util.List<java.lang.String> projection)
<T extends Document>
voidLeaseCheckDocumentStoreWrapper. remove(Collection<T> collection, java.lang.String key)
<T extends Document>
intLeaseCheckDocumentStoreWrapper. remove(Collection<T> collection, java.lang.String indexedProperty, long startValue, long endValue)
<T extends Document>
voidLeaseCheckDocumentStoreWrapper. remove(Collection<T> collection, java.util.List<java.lang.String> keys)
<T extends Document>
intLeaseCheckDocumentStoreWrapper. remove(Collection<T> collection, java.util.Map<java.lang.String,java.lang.Long> toRemove)
<T extends Document>
voidLoggingDocumentStoreWrapper. remove(Collection<T> collection, java.lang.String key)
<T extends Document>
intLoggingDocumentStoreWrapper. remove(Collection<T> collection, java.lang.String indexedProperty, long startValue, long endValue)
<T extends Document>
voidLoggingDocumentStoreWrapper. remove(Collection<T> collection, java.util.List<java.lang.String> keys)
<T extends Document>
intLoggingDocumentStoreWrapper. remove(Collection<T> collection, java.util.Map<java.lang.String,java.lang.Long> toRemove)
<T extends Document>
voidSynchronizingDocumentStoreWrapper. remove(Collection<T> collection, java.lang.String key)
<T extends Document>
intSynchronizingDocumentStoreWrapper. remove(Collection<T> collection, java.lang.String indexedProperty, long startValue, long endValue)
<T extends Document>
voidSynchronizingDocumentStoreWrapper. remove(Collection<T> collection, java.util.List<java.lang.String> keys)
<T extends Document>
intSynchronizingDocumentStoreWrapper. remove(Collection<T> collection, java.util.Map<java.lang.String,java.lang.Long> toRemove)
<T extends Document>
voidThrottlingDocumentStoreWrapper. remove(Collection<T> collection, java.lang.String key)
<T extends Document>
intThrottlingDocumentStoreWrapper. remove(Collection<T> collection, java.lang.String indexedProperty, long startValue, long endValue)
<T extends Document>
voidThrottlingDocumentStoreWrapper. remove(Collection<T> collection, java.util.List<java.lang.String> keys)
<T extends Document>
intThrottlingDocumentStoreWrapper. remove(Collection<T> collection, java.util.Map<java.lang.String,java.lang.Long> toRemove)
<T extends Document>
voidTimingDocumentStoreWrapper. remove(Collection<T> collection, java.lang.String key)
<T extends Document>
intTimingDocumentStoreWrapper. remove(Collection<T> collection, java.lang.String indexedProperty, long startValue, long endValue)
<T extends Document>
voidTimingDocumentStoreWrapper. remove(Collection<T> collection, java.util.List<java.lang.String> keys)
<T extends Document>
intTimingDocumentStoreWrapper. remove(Collection<T> collection, java.util.Map<java.lang.String,java.lang.Long> toRemove)
Methods in org.apache.jackrabbit.oak.plugins.document.util that return types with arguments of type Document Modifier and Type Method Description static java.util.function.BiPredicate<Collection<? extends Document>,java.lang.Integer>
StatsCollectorUtil. isNodesCollectionUpdated()
Method parameters in org.apache.jackrabbit.oak.plugins.document.util with type arguments of type Document Modifier and Type Method Description void
CreateMetricUpdater. update(Collection<? extends Document> collection, long timeTakenNanos, java.util.List<java.lang.String> ids, boolean insertSuccess, java.util.function.BiPredicate<Collection<? extends Document>,java.lang.Integer> isNodesCollectionUpdated, TriStatsConsumer triStatsConsumer, java.util.function.Predicate<Collection<? extends Document>> isJournalCollection, BiStatsConsumer journalBiStatsConsumer)
void
CreateMetricUpdater. update(Collection<? extends Document> collection, long timeTakenNanos, java.util.List<java.lang.String> ids, boolean insertSuccess, java.util.function.BiPredicate<Collection<? extends Document>,java.lang.Integer> isNodesCollectionUpdated, TriStatsConsumer triStatsConsumer, java.util.function.Predicate<Collection<? extends Document>> isJournalCollection, BiStatsConsumer journalBiStatsConsumer)
void
CreateMetricUpdater. update(Collection<? extends Document> collection, long timeTakenNanos, java.util.List<java.lang.String> ids, boolean insertSuccess, java.util.function.BiPredicate<Collection<? extends Document>,java.lang.Integer> isNodesCollectionUpdated, TriStatsConsumer triStatsConsumer, java.util.function.Predicate<Collection<? extends Document>> isJournalCollection, BiStatsConsumer journalBiStatsConsumer)
void
ModifyMetricUpdater. update(Collection<? extends Document> collection, int retryCount, long timeTakenNanos, boolean isSuccess, boolean newEntry, java.util.List<java.lang.String> ids, java.util.function.BiPredicate<Collection<? extends Document>,java.lang.Integer> isNodesCollectionUpdated, BiStatsConsumer createBiStatsConsumer, BiStatsConsumer updateBiStatsConsumer, java.util.function.ObjIntConsumer<MeterStats> retryNodesConsumer, java.util.function.Consumer<MeterStats> failureNodesConsumer)
void
ModifyMetricUpdater. update(Collection<? extends Document> collection, int retryCount, long timeTakenNanos, boolean isSuccess, boolean newEntry, java.util.List<java.lang.String> ids, java.util.function.BiPredicate<Collection<? extends Document>,java.lang.Integer> isNodesCollectionUpdated, BiStatsConsumer createBiStatsConsumer, BiStatsConsumer updateBiStatsConsumer, java.util.function.ObjIntConsumer<MeterStats> retryNodesConsumer, java.util.function.Consumer<MeterStats> failureNodesConsumer)
void
RemoveMetricUpdater. update(Collection<? extends Document> collection, int removeCount, long timeTakenNanos, java.util.function.BiPredicate<Collection<? extends Document>,java.lang.Integer> isNodesCollectionUpdated, BiStatsConsumer removeBiStatsConsumer)
void
RemoveMetricUpdater. update(Collection<? extends Document> collection, int removeCount, long timeTakenNanos, java.util.function.BiPredicate<Collection<? extends Document>,java.lang.Integer> isNodesCollectionUpdated, BiStatsConsumer removeBiStatsConsumer)
void
UpsertMetricUpdater. update(Collection<? extends Document> collection, long timeTakenNanos, java.util.List<java.lang.String> ids, java.util.function.BiPredicate<Collection<? extends Document>,java.lang.Integer> isNodesCollectionUpdated, TriStatsConsumer upsertStatsConsumer)
void
UpsertMetricUpdater. update(Collection<? extends Document> collection, long timeTakenNanos, java.util.List<java.lang.String> ids, java.util.function.BiPredicate<Collection<? extends Document>,java.lang.Integer> isNodesCollectionUpdated, TriStatsConsumer upsertStatsConsumer)
-