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);
             }