svn commit: r1818257 - /jackrabbit/oak/trunk/oak-run/src/main/java/org/apache/jackrabbit/oak/index/indexer/document/DocumentStoreIndexer.java

[chetanm]

Author: chetanm
Date: Fri Dec 15 10:11:58 2017
New Revision: 1818257

URL: http://svn.apache.org/viewvc?rev=1818257&view=rev
Log:
OAK-6353 - Use Document order traversal for reindexing performed on 
DocumentNodeStore setups

Configure the indexer paths again

Modified:
    
jackrabbit/oak/trunk/oak-run/src/main/java/org/apache/jackrabbit/oak/index/indexer/document/DocumentStoreIndexer.java

Modified: 
jackrabbit/oak/trunk/oak-run/src/main/java/org/apache/jackrabbit/oak/index/indexer/document/DocumentStoreIndexer.java
URL: 
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-run/src/main/java/org/apache/jackrabbit/oak/index/indexer/document/DocumentStoreIndexer.java?rev=1818257&r1=1818256&r2=1818257&view=diff
==============================================================================
--- 
jackrabbit/oak/trunk/oak-run/src/main/java/org/apache/jackrabbit/oak/index/indexer/document/DocumentStoreIndexer.java
 (original)
+++ 
jackrabbit/oak/trunk/oak-run/src/main/java/org/apache/jackrabbit/oak/index/indexer/document/DocumentStoreIndexer.java
 Fri Dec 15 10:11:58 2017
@@ -22,6 +22,7 @@ package org.apache.jackrabbit.oak.index.
 import java.io.Closeable;
 import java.io.IOException;
 import java.util.ArrayList;
+import java.util.HashSet;
 import java.util.List;
 import java.util.Set;
 
@@ -65,6 +66,7 @@ public class DocumentStoreIndexer implem
     private final IndexerSupport indexerSupport;
     private IndexingProgressReporter progressReporter =
             new IndexingProgressReporter(IndexUpdateCallback.NOOP, 
NodeTraversalCallback.NOOP);
+    private final Set<String> indexerPaths = new HashSet<>();
 
     public DocumentStoreIndexer(IndexHelper indexHelper, IndexerSupport 
indexerSupport) throws IOException {
         this.indexHelper = indexHelper;
@@ -149,6 +151,10 @@ public class DocumentStoreIndexer implem
         } else {
             log.info("Number of entries in flat file store are unknown");
         }
+
+        for (String indexerPath : indexerPaths){
+            progressReporter.registerIndex(indexerPath, true, -1);
+        }
     }
 
     private void configureTraversalRateEstimator(IndexingProgressReporter 
progressReporter) {
@@ -198,6 +204,7 @@ public class DocumentStoreIndexer implem
                     indexers.add(indexer);
                     closer.register(indexer);
                     progressReporter.registerIndex(indexPath, true, -1);
+                    indexerPaths.add(indexPath);
                 }
             }
         }