You are viewing a plain text version of this content. The canonical link for it is here.
Posted to oak-commits@jackrabbit.apache.org by mr...@apache.org on 2017/07/03 07:11:36 UTC
svn commit: r1800596 -
/jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/mongo/MongoDocumentStore.java
Author: mreutegg
Date: Mon Jul 3 07:11:36 2017
New Revision: 1800596
URL: http://svn.apache.org/viewvc?rev=1800596&view=rev
Log:
OAK-6180: Tune cursor batch/limit size
Modified:
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/mongo/MongoDocumentStore.java
Modified: jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/mongo/MongoDocumentStore.java
URL: http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/mongo/MongoDocumentStore.java?rev=1800596&r1=1800595&r2=1800596&view=diff
==============================================================================
--- jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/mongo/MongoDocumentStore.java (original)
+++ jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/mongo/MongoDocumentStore.java Mon Jul 3 07:11:36 2017
@@ -612,6 +612,9 @@ public class MongoDocumentStore implemen
}
try {
DBCursor cursor = dbCollection.find(query).sort(BY_ID_ASC);
+ if (limit >= 0) {
+ cursor.limit(limit);
+ }
if (!disableIndexHint && !hasModifiedIdCompoundIndex) {
cursor.hint(hint);
}