Uses of Class
org.apache.jackrabbit.oak.plugins.document.Collection

Packages that use Collection

Package	Description
org.apache.jackrabbit.oak.index.indexer.document.flatfile.pipelined
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 of DocumentStore and BlobStore for relational databases.
org.apache.jackrabbit.oak.plugins.document.util

Uses of Collection in org.apache.jackrabbit.oak.index.indexer.document.flatfile.pipelined

Constructors in org.apache.jackrabbit.oak.index.indexer.document.flatfile.pipelined with parameters of type Collection

Constructor	Description
NodeDocumentCodec(MongoDocumentStore store, Collection<NodeDocument> collection, MongoDocumentFilter documentFilter, org.bson.codecs.configuration.CodecRegistry defaultRegistry)

Uses of Collection in org.apache.jackrabbit.oak.plugins.document

Fields in org.apache.jackrabbit.oak.plugins.document declared as Collection

Modifier and Type	Field	Description
static Collection<Document>	Collection.BLOBS	The 'blobs' collection contains data from the blob store.
static Collection<ClusterNodeInfoDocument>	Collection.CLUSTER_NODES	The 'clusterNodes' collection contains the list of currently running cluster nodes.
static Collection<JournalEntry>	Collection.JOURNAL	The 'journal' collection contains documents with consolidated diffs for changes performed by a cluster node between two background updates.
static Collection<NodeDocument>	Collection.NODES	The 'nodes' collection.
static Collection<Document>	Collection.SETTINGS	The 'settings' collection contains setting/state data required for DocumentNodeStore

Methods in org.apache.jackrabbit.oak.plugins.document with parameters of type Collection

Modifier and Type	Method	Description
<T extends Document> boolean	DocumentStore.create(Collection<T> collection, List<UpdateOp> updateOps)	Try to create a list of documents.
<T extends Document> List<T>	DocumentStore.createOrUpdate(Collection<T> collection, List<UpdateOp> updateOps)	Create or unconditionally update a number of documents.
<T extends Document> T	DocumentStore.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 (see UpdateOp.isNew()).
void	DocumentStoreStats.doneCreate(long timeTakenNanos, Collection<? extends Document> collection, List<String> ids, boolean insertSuccess)
void	DocumentStoreStatsCollector.doneCreate(long timeTakenNanos, Collection<? extends Document> collection, List<String> ids, boolean insertSuccess)	Called when a document is created in the given collection
void	ThrottlingStatsCollector.doneCreate(long throttlingTimeNanos, Collection<? extends Document> collection, List<String> ids, boolean insertSuccess)	Called when a document is created in the given collection
void	ThrottlingStatsCollectorImpl.doneCreate(long throttlingTimeNanos, Collection<? extends Document> collection, List<String> ids, boolean insertSuccess)
void	DocumentStoreStats.doneCreateOrUpdate(long timeTakenNanos, Collection<? extends Document> collection, List<String> ids)
void	DocumentStoreStatsCollector.doneCreateOrUpdate(long timeTakenNanos, Collection<? extends Document> collection, List<String> ids)	Called when multiple document are either created or updated.
void	ThrottlingStatsCollector.doneCreateOrUpdate(long throttlingTimeNanos, Collection<? extends Document> collection, List<String> ids)	Called when multiple document are either created or updated.
void	ThrottlingStatsCollectorImpl.doneCreateOrUpdate(long throttlingTimeNanos, Collection<? extends Document> collection, List<String> ids)
void	DocumentStoreStats.doneFindAndModify(long timeTakenNanos, Collection<? extends Document> collection, String key, boolean newEntry, boolean success, int retryCount)
void	DocumentStoreStats.doneFindAndModify(long timeTakenNanos, Collection<? extends Document> collection, List<String> ids, boolean success, int retryCount)
void	DocumentStoreStatsCollector.doneFindAndModify(long timeTakenNanos, Collection<? extends Document> collection, 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, List<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, 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, List<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, String key, boolean newEntry, boolean success, int retryCount)
void	ThrottlingStatsCollectorImpl.doneFindAndModify(long throttlingTimeNanos, Collection<? extends Document> collection, List<String> ids, boolean success, int retryCount)
void	DocumentStoreStats.doneFindCached(Collection<? extends Document> collection, String key)
void	DocumentStoreStatsCollector.doneFindCached(Collection<? extends Document> collection, String key)	Called when a document with given key is found from the cache
void	DocumentStoreStats.doneFindUncached(long timeTakenNanos, Collection<? extends Document> collection, String key, boolean docFound, boolean isSlaveOk)
void	DocumentStoreStatsCollector.doneFindUncached(long timeTakenNanos, Collection<? extends Document> collection, String key, boolean docFound, boolean isSlaveOk)	Called when a document with given key is read from remote store
void	DocumentStoreStats.donePrefetch(long timeTakenNanos, Collection<? extends Document> collection, List<String> ids)
void	DocumentStoreStatsCollector.donePrefetch(long timeTakenNanos, Collection<? extends Document> collection, List<String> ids)	Called when a prefetch operation for documents was completed.
void	DocumentStoreStats.doneQuery(long timeTakenNanos, Collection<? extends Document> collection, String fromKey, String toKey, boolean indexedProperty, int resultSize, long lockTime, boolean isSlaveOk)
void	DocumentStoreStatsCollector.doneQuery(long timeTakenNanos, Collection<? extends Document> collection, String fromKey, String toKey, boolean indexedProperty, int resultSize, long lockTime, boolean isSlaveOk)	Called when query with given parameters is performed
void	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)
<T extends Document> T	DocumentStore.find(Collection<T> collection, String key)	Get the document with the given key.
<T extends Document> T	DocumentStore.find(Collection<T> collection, String key, int maxCacheAge)	Get the document with the key.
default <T extends Document> @NotNull List<T>	DocumentStore.findAndUpdate(@NotNull Collection<T> collection, @NotNull List<UpdateOp> updateOps)	Performs a conditional update (e.g.
<T extends Document> T	DocumentStore.findAndUpdate(Collection<T> collection, UpdateOp update)	Performs a conditional update (e.g.
<T extends Document> T	DocumentStore.getIfCached(Collection<T> collection, String key)	Fetches the cached document.
<T extends Document> void	DocumentStore.invalidateCache(Collection<T> collection, String key)	Invalidate the document cache for the given key.
default <T extends Document> void	DocumentStore.prefetch(Collection<T> collection, Iterable<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 List<T>	DocumentStore.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> @NotNull List<T>	DocumentStore.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.
default <T extends Document> @NotNull List<T>	DocumentStore.query(Collection<T> collection, String fromKey, String toKey, String indexedProperty, long startValue, int limit, List<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> void	DocumentStore.remove(Collection<T> collection, String key)	Remove a document.
<T extends Document> int	DocumentStore.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).
<T extends Document> void	DocumentStore.remove(Collection<T> collection, List<String> keys)	Batch remove documents with given keys.
<T extends Document> int	DocumentStore.remove(Collection<T> collection, Map<String,Long> toRemove)	Batch remove documents with given keys and corresponding equal conditions on NodeDocument.MODIFIED_IN_SECS values.

Uses of Collection in org.apache.jackrabbit.oak.plugins.document.memory

Methods in org.apache.jackrabbit.oak.plugins.document.memory with parameters of type Collection

Modifier and Type	Method	Description
<T extends Document> boolean	MemoryDocumentStore.create(Collection<T> collection, List<UpdateOp> updateOps)
<T extends Document> List<T>	MemoryDocumentStore.createOrUpdate(Collection<T> collection, List<UpdateOp> updateOps)
<T extends Document> T	MemoryDocumentStore.createOrUpdate(Collection<T> collection, UpdateOp update)
<T extends Document> T	MemoryDocumentStore.find(Collection<T> collection, String key)
<T extends Document> T	MemoryDocumentStore.find(Collection<T> collection, String key, int maxCacheAge)
<T extends Document> T	MemoryDocumentStore.findAndUpdate(Collection<T> collection, UpdateOp update)
<T extends Document> T	MemoryDocumentStore.getIfCached(Collection<T> collection, String key)
protected <T extends Document> ConcurrentSkipListMap<String,T>	MemoryDocumentStore.getMap(Collection<T> collection)	Get the in-memory map for this collection.
<T extends Document> void	MemoryDocumentStore.invalidateCache(Collection<T> collection, String key)
<T extends Document> @NotNull List<T>	MemoryDocumentStore.query(Collection<T> collection, String fromKey, String toKey, int limit)
<T extends Document> @NotNull List<T>	MemoryDocumentStore.query(Collection<T> collection, String fromKey, String toKey, String indexedProperty, long startValue, int limit)
<T extends Document> void	MemoryDocumentStore.remove(Collection<T> collection, String key)
<T extends Document> int	MemoryDocumentStore.remove(Collection<T> collection, String indexedProperty, long startValue, long endValue)
<T extends Document> void	MemoryDocumentStore.remove(Collection<T> collection, List<String> keys)
<T extends Document> int	MemoryDocumentStore.remove(Collection<T> collection, Map<String,Long> toRemove)

Uses of Collection in org.apache.jackrabbit.oak.plugins.document.mongo

Methods in org.apache.jackrabbit.oak.plugins.document.mongo with parameters of type Collection

Modifier and Type	Method	Description
protected <T extends Document> T	MongoDocumentStore.convertFromDBObject(@NotNull Collection<T> collection, @Nullable com.mongodb.DBObject n)
static <T extends Document> T	MongoDocumentStoreHelper.convertFromDBObject(MongoDocumentStore store, Collection<T> col, com.mongodb.DBObject obj)
<T extends Document> boolean	MongoDocumentStore.create(Collection<T> collection, List<UpdateOp> updateOps)
<T extends Document> @Nullable List<T>	MongoDocumentStore.createOrUpdate(Collection<T> collection, List<UpdateOp> updateOps)	Try to apply all the UpdateOps with at least MongoDB requests as possible.
<T extends Document> T	MongoDocumentStore.createOrUpdate(Collection<T> collection, UpdateOp update)
<T extends Document> T	MongoDocumentStore.find(Collection<T> collection, String key)
<T extends Document> T	MongoDocumentStore.find(Collection<T> collection, String key, int maxCacheAge)
<T extends Document> @NotNull List<T>	MongoDocumentStore.findAndUpdate(@NotNull Collection<T> collection, @NotNull List<UpdateOp> updateOps)	Try to apply all the UpdateOps with at least MongoDB requests as possible.
<T extends Document> T	MongoDocumentStore.findAndUpdate(Collection<T> collection, UpdateOp update)
protected <T extends Document> T	MongoDocumentStore.findUncached(Collection<T> collection, String key, org.apache.jackrabbit.oak.plugins.document.mongo.MongoDocumentStore.DocumentReadPreference docReadPref)
<T extends Document> CloseableIterable<T>	MongoDocumentTraverser.getAllDocuments(Collection<T> collection, TraversingRange traversingRange, Predicate<String> filter)
static com.mongodb.ReadPreference	MongoDocumentStoreHelper.getConfiguredReadPreference(MongoDocumentStore mongoStore, Collection<? extends Document> collection)
static <T extends Document> com.mongodb.client.MongoCollection<com.mongodb.BasicDBObject>	MongoDocumentStoreHelper.getDBCollection(MongoDocumentStore store, Collection<T> c)
<T extends Document> T	MongoDocumentStore.getIfCached(Collection<T> collection, String key)
<T extends Document> void	MongoDocumentStore.invalidateCache(Collection<T> collection, String key)
<T extends Document> void	MongoDocumentStore.prefetch(Collection<T> collection, Iterable<String> keysToPrefetch)
<T extends Document> @NotNull List<T>	MongoDocumentStore.query(Collection<T> collection, String fromKey, String toKey, int limit)
<T extends Document> @NotNull List<T>	MongoDocumentStore.query(Collection<T> collection, String fromKey, String toKey, String indexedProperty, long startValue, int limit)
<T extends Document> @NotNull List<T>	MongoDocumentStore.query(Collection<T> collection, String fromKey, String toKey, String indexedProperty, long startValue, int limit, List<String> projection)
protected <T extends Document> @NotNull List<T>	MongoDocumentStore.queryInternal(Collection<T> collection, String fromKey, String toKey, String indexedProperty, long startValue, int limit, List<String> projection, long maxQueryTime)
<T extends Document> void	MongoDocumentStore.remove(Collection<T> collection, String key)
<T extends Document> int	MongoDocumentStore.remove(Collection<T> collection, String indexedProperty, long startValue, long endValue)
<T extends Document> void	MongoDocumentStore.remove(Collection<T> collection, List<String> keys)
<T extends Document> int	MongoDocumentStore.remove(Collection<T> collection, Map<String,Long> toRemove)

Uses of Collection in org.apache.jackrabbit.oak.plugins.document.rdb

Methods in org.apache.jackrabbit.oak.plugins.document.rdb with parameters of type Collection

Modifier and Type	Method	Description
protected <T extends Document> T	RDBDocumentStore.convertFromDBObject(@NotNull Collection<T> collection, @NotNull RDBRow row)
<T extends Document> boolean	RDBDocumentStore.create(Collection<T> collection, List<UpdateOp> updateOps)
<T extends Document> List<T>	RDBDocumentStore.createOrUpdate(Collection<T> collection, List<UpdateOp> updateOps)
<T extends Document> T	RDBDocumentStore.createOrUpdate(Collection<T> collection, UpdateOp update)
<T extends Document> T	RDBDocumentStore.find(Collection<T> collection, String id)
<T extends Document> T	RDBDocumentStore.find(Collection<T> collection, String id, int maxCacheAge)
<T extends Document> T	RDBDocumentStore.findAndUpdate(Collection<T> collection, UpdateOp update)
<T extends Document> T	RDBDocumentSerializer.fromRow(@NotNull Collection<T> collection, @NotNull RDBRow row)	Reconstructs a Document based on the persisted RDBRow.
<T extends Document> T	RDBDocumentStore.getIfCached(Collection<T> collection, String id)
protected <T extends Document> long	RDBDocumentStore.getMinValue(Collection<T> collection, String field, String fromKey, String toKey, List<String> excludeKeyPatterns, List<RDBDocumentStore.QueryCondition> conditions)
protected <T extends Document> @NotNull org.apache.jackrabbit.oak.plugins.document.rdb.RDBDocumentStore.RDBTableMetaData	RDBDocumentStore.getTable(Collection<T> collection)
<T extends Document> void	RDBDocumentStore.invalidateCache(Collection<T> collection, String id)
<T extends Document> @NotNull List<T>	RDBDocumentStore.query(Collection<T> collection, String fromKey, String toKey, int limit)
<T extends Document> @NotNull List<T>	RDBDocumentStore.query(Collection<T> collection, String fromKey, String toKey, String indexedProperty, long startValue, int limit)
protected <T extends Document> @NotNull List<T>	RDBDocumentStore.query(Collection<T> collection, String fromKey, String toKey, List<String> excludeKeyPatterns, List<RDBDocumentStore.QueryCondition> conditions, int limit)
protected <T extends Document> Iterable<T>	RDBDocumentStore.queryAsIterable(Collection<T> collection, String fromKey, String toKey, List<String> excludeKeyPatterns, List<RDBDocumentStore.QueryCondition> conditions, int limit, String sortBy)
protected <T extends Document> long	RDBDocumentStore.queryCount(Collection<T> collection, String fromKey, String toKey, List<String> excludeKeyPatterns, List<RDBDocumentStore.QueryCondition> conditions)
<T extends Document> void	RDBDocumentStore.remove(Collection<T> collection, String id)
<T extends Document> int	RDBDocumentStore.remove(Collection<T> collection, String indexedProperty, long startValue, long endValue)
<T extends Document> void	RDBDocumentStore.remove(Collection<T> collection, List<String> ids)
<T extends Document> int	RDBDocumentStore.remove(Collection<T> collection, Map<String,Long> toRemove)

Uses of Collection in org.apache.jackrabbit.oak.plugins.document.util

Methods in org.apache.jackrabbit.oak.plugins.document.util that return types with arguments of type Collection

Modifier and Type	Method	Description
static BiPredicate<Collection<? extends Document>,Integer>	StatsCollectorUtil.isNodesCollectionUpdated()

Methods in org.apache.jackrabbit.oak.plugins.document.util with parameters of type Collection

Modifier and Type	Method	Description
<T extends Document> boolean	LeaseCheckDocumentStoreWrapper.create(Collection<T> collection, List<UpdateOp> updateOps)
<T extends Document> boolean	LoggingDocumentStoreWrapper.create(Collection<T> collection, List<UpdateOp> updateOps)
<T extends Document> boolean	SynchronizingDocumentStoreWrapper.create(Collection<T> collection, List<UpdateOp> updateOps)
<T extends Document> boolean	ThrottlingDocumentStoreWrapper.create(Collection<T> collection, List<UpdateOp> updateOps)
<T extends Document> boolean	TimingDocumentStoreWrapper.create(Collection<T> collection, List<UpdateOp> updateOps)
<T extends Document> List<T>	LeaseCheckDocumentStoreWrapper.createOrUpdate(Collection<T> collection, List<UpdateOp> updateOps)
<T extends Document> T	LeaseCheckDocumentStoreWrapper.createOrUpdate(Collection<T> collection, UpdateOp update)
<T extends Document> List<T>	LoggingDocumentStoreWrapper.createOrUpdate(Collection<T> collection, List<UpdateOp> updateOps)
<T extends Document> T	LoggingDocumentStoreWrapper.createOrUpdate(Collection<T> collection, UpdateOp update)
<T extends Document> List<T>	SynchronizingDocumentStoreWrapper.createOrUpdate(Collection<T> collection, List<UpdateOp> updateOps)
<T extends Document> T	SynchronizingDocumentStoreWrapper.createOrUpdate(Collection<T> collection, UpdateOp update)
<T extends Document> List<T>	ThrottlingDocumentStoreWrapper.createOrUpdate(Collection<T> collection, List<UpdateOp> updateOps)
<T extends Document> T	ThrottlingDocumentStoreWrapper.createOrUpdate(Collection<T> collection, UpdateOp update)
<T extends Document> List<T>	TimingDocumentStoreWrapper.createOrUpdate(Collection<T> collection, List<UpdateOp> updateOps)
<T extends Document> T	TimingDocumentStoreWrapper.createOrUpdate(Collection<T> collection, UpdateOp update)
<T extends Document> T	LeaseCheckDocumentStoreWrapper.find(Collection<T> collection, String key)
<T extends Document> T	LeaseCheckDocumentStoreWrapper.find(Collection<T> collection, String key, int maxCacheAge)
<T extends Document> T	LoggingDocumentStoreWrapper.find(Collection<T> collection, String key)
<T extends Document> T	LoggingDocumentStoreWrapper.find(Collection<T> collection, String key, int maxCacheAge)
<T extends Document> T	SynchronizingDocumentStoreWrapper.find(Collection<T> collection, String key)
<T extends Document> T	SynchronizingDocumentStoreWrapper.find(Collection<T> collection, String key, int maxCacheAge)
<T extends Document> T	ThrottlingDocumentStoreWrapper.find(Collection<T> collection, String key)
<T extends Document> T	ThrottlingDocumentStoreWrapper.find(Collection<T> collection, String key, int maxCacheAge)
<T extends Document> T	TimingDocumentStoreWrapper.find(Collection<T> collection, String key)
<T extends Document> T	TimingDocumentStoreWrapper.find(Collection<T> collection, String key, int maxCacheAge)
<T extends Document> @NotNull List<T>	LeaseCheckDocumentStoreWrapper.findAndUpdate(@NotNull Collection<T> collection, @NotNull List<UpdateOp> updateOps)
<T extends Document> T	LeaseCheckDocumentStoreWrapper.findAndUpdate(Collection<T> collection, UpdateOp update)
<T extends Document> List<T>	LoggingDocumentStoreWrapper.findAndUpdate(@NotNull Collection<T> collection, @NotNull List<UpdateOp> updateOps)
<T extends Document> T	LoggingDocumentStoreWrapper.findAndUpdate(Collection<T> collection, UpdateOp update)
<T extends Document> @NotNull List<T>	SynchronizingDocumentStoreWrapper.findAndUpdate(@NotNull Collection<T> collection, @NotNull List<UpdateOp> updateOps)
<T extends Document> T	SynchronizingDocumentStoreWrapper.findAndUpdate(Collection<T> collection, UpdateOp update)
<T extends Document> @NotNull List<T>	ThrottlingDocumentStoreWrapper.findAndUpdate(@NotNull Collection<T> collection, @NotNull List<UpdateOp> updateOps)
<T extends Document> T	ThrottlingDocumentStoreWrapper.findAndUpdate(Collection<T> collection, UpdateOp update)
<T extends Document> @NotNull List<T>	TimingDocumentStoreWrapper.findAndUpdate(@NotNull Collection<T> collection, @NotNull List<UpdateOp> updateOps)
<T extends Document> T	TimingDocumentStoreWrapper.findAndUpdate(Collection<T> collection, UpdateOp update)
<T extends Document> T	LeaseCheckDocumentStoreWrapper.getIfCached(Collection<T> collection, String key)
<T extends Document> T	LoggingDocumentStoreWrapper.getIfCached(Collection<T> collection, String key)
<T extends Document> T	SynchronizingDocumentStoreWrapper.getIfCached(Collection<T> collection, String key)
<T extends Document> T	ThrottlingDocumentStoreWrapper.getIfCached(Collection<T> collection, String key)
<T extends Document> T	TimingDocumentStoreWrapper.getIfCached(Collection<T> collection, String key)
<T extends Document> void	LeaseCheckDocumentStoreWrapper.invalidateCache(Collection<T> collection, String key)
<T extends Document> void	LoggingDocumentStoreWrapper.invalidateCache(Collection<T> collection, String key)
<T extends Document> void	SynchronizingDocumentStoreWrapper.invalidateCache(Collection<T> collection, String key)
<T extends Document> void	ThrottlingDocumentStoreWrapper.invalidateCache(Collection<T> collection, String key)
<T extends Document> void	TimingDocumentStoreWrapper.invalidateCache(Collection<T> collection, String key)
<T extends Document> void	LeaseCheckDocumentStoreWrapper.prefetch(Collection<T> collection, Iterable<String> keys)
<T extends Document> List<T>	LeaseCheckDocumentStoreWrapper.query(Collection<T> collection, String fromKey, String toKey, int limit)
<T extends Document> List<T>	LeaseCheckDocumentStoreWrapper.query(Collection<T> collection, String fromKey, String toKey, String indexedProperty, long startValue, int limit)
<T extends Document> @NotNull List<T>	LeaseCheckDocumentStoreWrapper.query(Collection<T> collection, String fromKey, String toKey, String indexedProperty, long startValue, int limit, List<String> projection)
<T extends Document> @NotNull List<T>	LoggingDocumentStoreWrapper.query(Collection<T> collection, String fromKey, String toKey, int limit)
<T extends Document> @NotNull List<T>	LoggingDocumentStoreWrapper.query(Collection<T> collection, String fromKey, String toKey, String indexedProperty, long startValue, int limit)
<T extends Document> @NotNull List<T>	LoggingDocumentStoreWrapper.query(Collection<T> collection, String fromKey, String toKey, String indexedProperty, long startValue, int limit, List<String> projection)
<T extends Document> @NotNull List<T>	SynchronizingDocumentStoreWrapper.query(Collection<T> collection, String fromKey, String toKey, int limit)
<T extends Document> @NotNull List<T>	SynchronizingDocumentStoreWrapper.query(Collection<T> collection, String fromKey, String toKey, String indexedProperty, long startValue, int limit)
<T extends Document> @NotNull List<T>	SynchronizingDocumentStoreWrapper.query(Collection<T> collection, String fromKey, String toKey, String indexedProperty, long startValue, int limit, List<String> projection)
<T extends Document> @NotNull List<T>	ThrottlingDocumentStoreWrapper.query(Collection<T> collection, String fromKey, String toKey, int limit)
<T extends Document> @NotNull List<T>	ThrottlingDocumentStoreWrapper.query(Collection<T> collection, String fromKey, String toKey, String indexedProperty, long startValue, int limit)
<T extends Document> @NotNull List<T>	ThrottlingDocumentStoreWrapper.query(Collection<T> collection, String fromKey, String toKey, String indexedProperty, long startValue, int limit, List<String> projection)
<T extends Document> @NotNull List<T>	TimingDocumentStoreWrapper.query(Collection<T> collection, String fromKey, String toKey, int limit)
<T extends Document> @NotNull List<T>	TimingDocumentStoreWrapper.query(Collection<T> collection, String fromKey, String toKey, String indexedProperty, long startValue, int limit)
<T extends Document> @NotNull List<T>	TimingDocumentStoreWrapper.query(Collection<T> collection, String fromKey, String toKey, String indexedProperty, long startValue, int limit, List<String> projection)
<T extends Document> void	LeaseCheckDocumentStoreWrapper.remove(Collection<T> collection, String key)
<T extends Document> int	LeaseCheckDocumentStoreWrapper.remove(Collection<T> collection, String indexedProperty, long startValue, long endValue)
<T extends Document> void	LeaseCheckDocumentStoreWrapper.remove(Collection<T> collection, List<String> keys)
<T extends Document> int	LeaseCheckDocumentStoreWrapper.remove(Collection<T> collection, Map<String,Long> toRemove)
<T extends Document> void	LoggingDocumentStoreWrapper.remove(Collection<T> collection, String key)
<T extends Document> int	LoggingDocumentStoreWrapper.remove(Collection<T> collection, String indexedProperty, long startValue, long endValue)
<T extends Document> void	LoggingDocumentStoreWrapper.remove(Collection<T> collection, List<String> keys)
<T extends Document> int	LoggingDocumentStoreWrapper.remove(Collection<T> collection, Map<String,Long> toRemove)
<T extends Document> void	SynchronizingDocumentStoreWrapper.remove(Collection<T> collection, String key)
<T extends Document> int	SynchronizingDocumentStoreWrapper.remove(Collection<T> collection, String indexedProperty, long startValue, long endValue)
<T extends Document> void	SynchronizingDocumentStoreWrapper.remove(Collection<T> collection, List<String> keys)
<T extends Document> int	SynchronizingDocumentStoreWrapper.remove(Collection<T> collection, Map<String,Long> toRemove)
<T extends Document> void	ThrottlingDocumentStoreWrapper.remove(Collection<T> collection, String key)
<T extends Document> int	ThrottlingDocumentStoreWrapper.remove(Collection<T> collection, String indexedProperty, long startValue, long endValue)
<T extends Document> void	ThrottlingDocumentStoreWrapper.remove(Collection<T> collection, List<String> keys)
<T extends Document> int	ThrottlingDocumentStoreWrapper.remove(Collection<T> collection, Map<String,Long> toRemove)
<T extends Document> void	TimingDocumentStoreWrapper.remove(Collection<T> collection, String key)
<T extends Document> int	TimingDocumentStoreWrapper.remove(Collection<T> collection, String indexedProperty, long startValue, long endValue)
<T extends Document> void	TimingDocumentStoreWrapper.remove(Collection<T> collection, List<String> keys)
<T extends Document> int	TimingDocumentStoreWrapper.remove(Collection<T> collection, Map<String,Long> toRemove)
void	CreateMetricUpdater.update(Collection<? extends Document> collection, long timeTakenNanos, List<String> ids, boolean insertSuccess, BiPredicate<Collection<? extends Document>,Integer> isNodesCollectionUpdated, TriStatsConsumer triStatsConsumer, Predicate<Collection<? extends Document>> isJournalCollection, BiStatsConsumer journalBiStatsConsumer)
void	ModifyMetricUpdater.update(Collection<? extends Document> collection, int retryCount, long timeTakenNanos, boolean isSuccess, boolean newEntry, List<String> ids, BiPredicate<Collection<? extends Document>,Integer> isNodesCollectionUpdated, BiStatsConsumer createBiStatsConsumer, BiStatsConsumer updateBiStatsConsumer, ObjIntConsumer<MeterStats> retryNodesConsumer, Consumer<MeterStats> failureNodesConsumer)
void	RemoveMetricUpdater.update(Collection<? extends Document> collection, int removeCount, long timeTakenNanos, BiPredicate<Collection<? extends Document>,Integer> isNodesCollectionUpdated, BiStatsConsumer removeBiStatsConsumer)
void	UpsertMetricUpdater.update(Collection<? extends Document> collection, long timeTakenNanos, List<String> ids, BiPredicate<Collection<? extends Document>,Integer> isNodesCollectionUpdated, TriStatsConsumer upsertStatsConsumer)

Method parameters in org.apache.jackrabbit.oak.plugins.document.util with type arguments of type Collection

Modifier and Type	Method	Description
void	CreateMetricUpdater.update(Collection<? extends Document> collection, long timeTakenNanos, List<String> ids, boolean insertSuccess, BiPredicate<Collection<? extends Document>,Integer> isNodesCollectionUpdated, TriStatsConsumer triStatsConsumer, Predicate<Collection<? extends Document>> isJournalCollection, BiStatsConsumer journalBiStatsConsumer)
void	CreateMetricUpdater.update(Collection<? extends Document> collection, long timeTakenNanos, List<String> ids, boolean insertSuccess, BiPredicate<Collection<? extends Document>,Integer> isNodesCollectionUpdated, TriStatsConsumer triStatsConsumer, Predicate<Collection<? extends Document>> isJournalCollection, BiStatsConsumer journalBiStatsConsumer)
void	ModifyMetricUpdater.update(Collection<? extends Document> collection, int retryCount, long timeTakenNanos, boolean isSuccess, boolean newEntry, List<String> ids, BiPredicate<Collection<? extends Document>,Integer> isNodesCollectionUpdated, BiStatsConsumer createBiStatsConsumer, BiStatsConsumer updateBiStatsConsumer, ObjIntConsumer<MeterStats> retryNodesConsumer, Consumer<MeterStats> failureNodesConsumer)
void	RemoveMetricUpdater.update(Collection<? extends Document> collection, int removeCount, long timeTakenNanos, BiPredicate<Collection<? extends Document>,Integer> isNodesCollectionUpdated, BiStatsConsumer removeBiStatsConsumer)
void	UpsertMetricUpdater.update(Collection<? extends Document> collection, long timeTakenNanos, List<String> ids, BiPredicate<Collection<? extends Document>,Integer> isNodesCollectionUpdated, TriStatsConsumer upsertStatsConsumer)