svn commit: r1762825 - /jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/mongo/MongoVersionGCSupport.java

[mreutegg]

Author: mreutegg
Date: Thu Sep 29 18:52:58 2016
New Revision: 1762825

URL: http://svn.apache.org/viewvc?rev=1762825&view=rev
Log:
OAK-4863: Reduce query batch size for deleted documents

Modified:
    
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/mongo/MongoVersionGCSupport.java

Modified: 
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/mongo/MongoVersionGCSupport.java
URL: 
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/mongo/MongoVersionGCSupport.java?rev=1762825&r1=1762824&r2=1762825&view=diff
==============================================================================
--- 
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/mongo/MongoVersionGCSupport.java
 (original)
+++ 
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/mongo/MongoVersionGCSupport.java
 Thu Sep 29 18:52:58 2016
@@ -63,6 +63,12 @@ public class MongoVersionGCSupport exten
     private final boolean disableIndexHint =
             Boolean.getBoolean("oak.mongo.disableVersionGCIndexHint");
 
+    /**
+     * The batch size for the query of possibly deleted docs.
+     */
+    private final int batchSize = Integer.getInteger(
+            "oak.mongo.queryDeletedDocsBatchSize", 1000);
+
     public MongoVersionGCSupport(MongoDocumentStore store) {
         super(store);
         this.store = store;
@@ -76,6 +82,7 @@ public class MongoVersionGCSupport exten
                                 
.put(NodeDocument.MODIFIED_IN_SECS).lessThan(NodeDocument.getModifiedInSecs(lastModifiedTime))
                         .get();
         DBCursor cursor = 
getNodeCollection().find(query).setReadPreference(ReadPreference.secondaryPreferred());
+        cursor.batchSize(batchSize);
         if (!disableIndexHint) {
             cursor.hint(new BasicDBObject(NodeDocument.DELETED_ONCE, 1));
         }