You are viewing a plain text version of this content. The canonical link for it is here.
Posted to oak-commits@jackrabbit.apache.org by ch...@apache.org on 2017/12/21 05:02:37 UTC

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

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