svn commit: r1760871 - /jackrabbit/oak/trunk/oak-run/src/main/java/org/apache/jackrabbit/oak/benchmark/HybridIndexTest.java

[ch...@apache.org]

Author: chetanm
Date: Thu Sep 15 07:21:17 2016
New Revision: 1760871

URL: http://svn.apache.org/viewvc?rev=1760871&view=rev
Log:
OAK-4412 - Lucene hybrid index

Benchmarking - Introduce flags for
-- useOakCodec - To disable compression. This speeds up the query side for property indexes quite a bit
-- indexingMode - To allow selecting between nrt and sync

Modified:
    jackrabbit/oak/trunk/oak-run/src/main/java/org/apache/jackrabbit/oak/benchmark/HybridIndexTest.java

Modified: jackrabbit/oak/trunk/oak-run/src/main/java/org/apache/jackrabbit/oak/benchmark/HybridIndexTest.java
URL: http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-run/src/main/java/org/apache/jackrabbit/oak/benchmark/HybridIndexTest.java?rev=1760871&r1=1760870&r2=1760871&view=diff
==============================================================================
--- jackrabbit/oak/trunk/oak-run/src/main/java/org/apache/jackrabbit/oak/benchmark/HybridIndexTest.java (original)
+++ jackrabbit/oak/trunk/oak-run/src/main/java/org/apache/jackrabbit/oak/benchmark/HybridIndexTest.java Thu Sep 15 07:21:17 2016
@@ -121,6 +121,8 @@ public class HybridIndexTest extends Abs
     private int asyncInterval = Integer.getInteger("asyncInterval", 5);
     private int queueSize = Integer.getInteger("queueSize", 1000);
     private boolean hybridIndexEnabled = Boolean.getBoolean("hybridIndexEnabled");
+    private boolean useOakCodec = Boolean.getBoolean("useOakCodec");
+    private String indexingMode = System.getProperty("indexingMode", "nrt");
 
     private boolean searcherEnabled = Boolean.parseBoolean(System.getProperty("searcherEnabled", "true"));
     private File indexCopierDir;
@@ -232,16 +234,18 @@ public class HybridIndexTest extends Abs
             nrtIndexFactory.close();
         }
 
-        dumpStats();
-
         if (indexCopierDir != null) {
             FileUtils.deleteDirectory(indexCopierDir);
         }
         System.out.printf("numOfIndexes: %d, refreshDeltaMillis: %d, asyncInterval: %d, queueSize: %d , " +
-                        "hybridIndexEnabled: %s, metricStatsEnabled: %s %n", numOfIndexes, refreshDeltaMillis,
-                asyncInterval, queueSize, hybridIndexEnabled, metricStatsEnabled);
-        System.out.printf("Searcher: %d, Mutator: %d, indexedNodeCount: %d %n", searcher.resultSize, mutator
-                .mutationCount, indexedNodeCount.get());
+                        "hybridIndexEnabled: %s, metricStatsEnabled: %s, indexingMode: %s, " +
+                        "useOakCodec: %s %n",
+                numOfIndexes, refreshDeltaMillis, asyncInterval, queueSize, hybridIndexEnabled,
+                metricStatsEnabled, indexingMode, useOakCodec);
+        System.out.printf("Searcher: %d, Mutator: %d, indexedNodeCount: %d %n", searcher.resultSize,
+                mutator.mutationCount, indexedNodeCount.get());
+
+        dumpStats();
     }
 
     private void dumpStats() {
@@ -375,9 +379,11 @@ public class HybridIndexTest extends Abs
 
             IndexDefinitionBuilder defnBuilder = new IndexDefinitionBuilder();
             defnBuilder.evaluatePathRestrictions();
-            defnBuilder.async("async", "sync");
+            defnBuilder.async("async", indexingMode);
             defnBuilder.indexRule("nt:base").property(indexedPropName).propertyIndex();
-            //defnBuilder.codec("oakCodec");
+            if (useOakCodec) {
+                defnBuilder.codec("oakCodec");
+            }
 
             for (int i = 0; i < numOfIndexes - 1; i++) {
                 defnBuilder.indexRule("nt:base").property(indexedPropName + i).propertyIndex();