Updated query tests to use blackhole.

Author: chernser

client-v2/src/main/java/com/clickhouse/client/api/data_formats/internal/BinaryStreamReader.java

@@ -127,11 +127,11 @@ public <T> T readValue(ClickHouseColumn column, Class<?> typeHint) throws IOExce
                 case UInt8:
                     return (T) Short.valueOf(readUnsignedByte());
                 case Int16:
-                    return (T) Short.valueOf(readShortLE());
+                    return (T) (Short)readShortLE();
                 case UInt16:
-                    return (T) Integer.valueOf(readUnsignedShortLE());
+                    return (T) (Integer)readUnsignedShortLE();
                 case Int32:
-                    return (T) Integer.valueOf(readIntLE());
+                    return (T) (Integer)readIntLE();
                 case UInt32:
                     return (T) (Long)(readUnsignedIntLE());
                 case Int64:

client-v2/src/main/java/com/clickhouse/client/api/internal/ClickHouseLZ4InputStream.java

@@ -90,6 +90,8 @@ private boolean readFully(byte[] b, int off, int len) throws IOException {
         return true;
     }
 
+    private byte[] cachedBuff = null;
+
     private int refill() throws IOException {
 
         // read header
@@ -109,7 +111,9 @@ private int refill() throws IOException {
         int uncompressedSize = getInt32(headerBuff, 21);
 
         int offset = 9;
-        final byte[] block =  new byte[compressedSizeWithHeader];
+        final byte[] block = cachedBuff == null || cachedBuff.length <= uncompressedSize ?
+                new byte[compressedSizeWithHeader] : cachedBuff;
+        cachedBuff = block;
         block[0] = MAGIC;
         setInt32(block, 1, compressedSizeWithHeader);
         setInt32(block, 5, uncompressedSize);

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

@@ -47,9 +47,9 @@ public static void main(String[] args) throws Exception {
 //                .addProfiler(JavaFlightRecorderProfiler.class)
                 .warmupIterations(0)
                 .warmupTime(TimeValue.seconds(10))
-                .measurementIterations(10)
+                .measurementIterations(1)
                 .jvmArgs("-Xms8g", "-Xmx8g")
-                .measurementTime(TimeValue.seconds(isCloud() ? 30 : 10))
+                .measurementTime(TimeValue.seconds(isCloud() ? 30 : 120))
                 .resultFormat(ResultFormatType.JSON)
 //                .output(String.format("jmh-results-%s-%s.out", isCloud() ? "cloud" : "local", System.currentTimeMillis()))
                 .result(String.format("jmh-results-%s-%s.json", isCloud() ? "cloud" : "local", System.currentTimeMillis()))

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

@@ -21,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))
@@ -30,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());
                     }
                 }
             }
@@ -46,7 +46,7 @@ public void queryV2(DataState dataState, Blackhole blackhole) {
                 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));
                     }
                 }
             }