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