svn commit: r1818768 - in /jackrabbit/oak/trunk: oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/progress/IndexingProgressReporter.java oak-run/src/main/java/org/apache/jackrabbit/oak/index/indexer/document/DocumentStoreIndexer.java

[chetanm]

Author: chetanm
Date: Wed Dec 20 09:55:10 2017
New Revision: 1818768

URL: http://svn.apache.org/viewvc?rev=1818768&view=rev
Log:
OAK-7099 - DocumentStoreIndexer should log estimate of ETA for dumping phase

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

Modified: 
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/progress/IndexingProgressReporter.java
URL: 
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/progress/IndexingProgressReporter.java?rev=1818768&r1=1818767&r2=1818768&view=diff
==============================================================================
--- 
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/progress/IndexingProgressReporter.java
 (original)
+++ 
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/progress/IndexingProgressReporter.java
 Wed Dec 20 09:55:10 2017
@@ -172,6 +172,10 @@ public class IndexingProgressReporter im
         this.nodeCountEstimator = nodeCountEstimator;
     }
 
+    public void setEstimatedCount(long estimatedCount) {
+        this.estimatedCount = estimatedCount;
+    }
+
     public void reset(){
         watch = Stopwatch.createStarted();
         traversalCount = 0;

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=1818768&r1=1818767&r2=1818768&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
 Wed Dec 20 09:55:10 2017
@@ -144,6 +144,7 @@ public class DocumentStoreIndexer implem
         long nodesCount = getEstimatedDocumentCount();
         if (nodesCount > 0) {
             progressReporter.setNodeCountEstimator((String basePath, 
Set<String> indexPaths) -> nodesCount);
+            progressReporter.setEstimatedCount(nodesCount);
             log.info("Estimated number of documents in Mongo are {}", 
nodesCount);
         }
     }