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