added a blackhole to query tests

Author: chernser

performance/src/test/com/clickhouse/benchmark/BenchmarkRunner.java

@@ -33,9 +33,9 @@ public static void main(String[] args) throws Exception {
 
         Options opt = new OptionsBuilder()
                 .include(QueryClient.class.getSimpleName())
-                .include(InsertClient.class.getSimpleName())
-                .include(Compression.class.getSimpleName())
-                .include(Serializers.class.getSimpleName())
+//                .include(InsertClient.class.getSimpleName())
+//                .include(Compression.class.getSimpleName())
+//                .include(Serializers.class.getSimpleName())
                 .include(Deserializers.class.getSimpleName())
                 .forks(1) // must be a fork. No fork only for debugging
                 .mode(Mode.SampleTime)

performance/src/test/com/clickhouse/benchmark/clients/QueryClient.java

@@ -10,6 +10,7 @@
 import org.openjdk.jmh.annotations.Benchmark;
 import org.openjdk.jmh.annotations.Scope;
 import org.openjdk.jmh.annotations.State;
+import org.openjdk.jmh.infra.Blackhole;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -20,7 +21,7 @@ public class QueryClient extends BenchmarkBase {
     private static final Logger LOGGER = LoggerFactory.getLogger(QueryClient.class);
 
     @Benchmark
-    public void queryV1(DataState dataState) {
+    public void queryV1(DataState dataState, Blackhole blackhole) {
         try {
             try (ClickHouseResponse response = clientV1.read(getServer())
                     .query(BenchmarkRunner.getSelectQuery(dataState.tableNameFilled))
@@ -29,7 +30,7 @@ public void queryV1(DataState dataState) {
                     .executeAndWait()) {
                 for (ClickHouseRecord record: response.records()) {//Compiler optimization avoidance
                     for (int i = 0; i < dataState.dataSet.getSchema().getColumns().size(); i++) {
-                        isNotNull(record.getValue(i), false);
+                        blackhole.consume(record.getValue(i).asObject());
                     }
                 }
             }
@@ -39,13 +40,13 @@ public void queryV1(DataState dataState) {
     }
 
     @Benchmark
-    public void queryV2(DataState dataState) {
+    public void queryV2(DataState dataState, Blackhole blackhole) {
         try {
             try(QueryResponse response = clientV2.query(BenchmarkRunner.getSelectQuery(dataState.tableNameFilled)).get()) {
                 ClickHouseBinaryFormatReader reader = clientV2.newBinaryFormatReader(response);
                 while (reader.next() != null) {//Compiler optimization avoidance
                     for (int i = 1; i <= dataState.dataSet.getSchema().getColumns().size(); i++) {
-                        isNotNull(reader.readValue(1), false);
+                        blackhole.consume(reader.readValue(1));
                     }
                 }
             }