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

[chetanm]

Author: chetanm
Date: Thu Dec 21 05:02:37 2017
New Revision: 1818880

URL: http://svn.apache.org/viewvc?rev=1818880&view=rev
Log:
OAK-7102 - Refactor DocumentIndexer logic to enable different sort approaches

Log the time taken only for indexing phase

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=1818880&r1=1818879&r2=1818880&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
 Thu Dec 21 05:02:37 2017
@@ -27,6 +27,7 @@ import java.util.List;
 import java.util.Set;
 
 import com.codahale.metrics.MetricRegistry;
+import com.google.common.base.Stopwatch;
 import com.google.common.collect.ImmutableList;
 import com.google.common.io.Closer;
 import org.apache.jackrabbit.oak.api.CommitFailedException;
@@ -118,6 +119,7 @@ public class DocumentStoreIndexer implem
 
         progressReporter.reindexingTraversalStart("/");
 
+        Stopwatch indexerWatch = Stopwatch.createStarted();
         for (NodeStateEntry entry : flatFileStore) {
             reportDocumentRead(entry.getPath());
             indexer.index(entry);
@@ -125,6 +127,7 @@ public class DocumentStoreIndexer implem
 
         progressReporter.reindexingTraversalEnd();
         progressReporter.logReport();
+        log.info("Completed the indexing in {}", indexerWatch);
 
         copyOnWriteStore.merge(builder, EmptyHook.INSTANCE, CommitInfo.EMPTY);