added compressed insert as separate benchmark

Author: chernser

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

@@ -32,7 +32,7 @@ public static void main(String[] args) throws Exception {
         Options opt = new OptionsBuilder()
                 .include(QueryClient.class.getSimpleName())
                 .include(InsertClient.class.getSimpleName())
-                .include(Components.class.getSimpleName())
+//                .include(Components.class.getSimpleName())
                 .forks(1) // must be a fork. No fork only for debugging
                 .mode(Mode.SampleTime)
                 .timeUnit(TimeUnit.MILLISECONDS)

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

@@ -78,11 +78,10 @@ public static class DataState {
         int limit;
         @Param({"data_filled"})
         String tableNameFilled;
+
         @Param({"data_empty"})
         String tableNameEmpty;
 
-        @Param({"true"})
-        boolean useClientCompression = true;
         DataSet dataSet;
 
         public void setDataSet(DataSet dataSet) {

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

@@ -42,7 +42,7 @@ public void insertV1(DataState dataState) {
             try (ClickHouseResponse response = clientV1.read(getServer())
                     .write()
                     .option(ClickHouseClientOption.ASYNC, false)
-                    .option(ClickHouseClientOption.DECOMPRESS, dataState.useClientCompression)
+                    .option(ClickHouseClientOption.DECOMPRESS, false)
                     .format(format)
                     .query(BenchmarkRunner.getInsertQuery(dataState.tableNameEmpty))
                     .data(out -> {
@@ -66,7 +66,46 @@ public void insertV2(DataState dataState) {
                     out.write(bytes);
                 }
                 out.close();
-            }, format, new InsertSettings().compressClientRequest(dataState.useClientCompression)).get()) {
+            }, format, new InsertSettings().compressClientRequest(false)).get()) {
+                response.getWrittenRows();
+            }
+        } catch (Exception e) {
+            LOGGER.error("Error: ", e);
+        }
+    }
+
+    @Benchmark
+    public void insertV1Compressed(DataState dataState) {
+        try {
+            ClickHouseFormat format = dataState.dataSet.getFormat();
+            try (ClickHouseResponse response = clientV1.read(getServer())
+                    .write()
+                    .option(ClickHouseClientOption.ASYNC, false)
+                    .option(ClickHouseClientOption.DECOMPRESS, true)
+                    .format(format)
+                    .query(BenchmarkRunner.getInsertQuery(dataState.tableNameEmpty))
+                    .data(out -> {
+                        for (byte[] bytes: dataState.dataSet.getBytesList(format)) {
+                            out.write(bytes);
+                        }
+                    }).executeAndWait()) {
+                response.getSummary();
+            }
+        } catch (Exception e) {
+            LOGGER.error("Error: ", e);
+        }
+    }
+
+    @Benchmark
+    public void insertV2Compressed(DataState dataState) {
+        try {
+            ClickHouseFormat format = dataState.dataSet.getFormat();
+            try (InsertResponse response = clientV2.insert(dataState.tableNameEmpty, out -> {
+                for (byte[] bytes: dataState.dataSet.getBytesList(format)) {
+                    out.write(bytes);
+                }
+                out.close();
+            }, format, new InsertSettings()).get()) {
                 response.getWrittenRows();
             }
         } catch (Exception e) {
@@ -82,6 +121,7 @@ public void insertV1RowBinary(DataState dataState) {
                     .write()
                     .option(ClickHouseClientOption.ASYNC, false)
                     .format(format)
+                    .option(ClickHouseClientOption.DECOMPRESS, false)
                     .query(BenchmarkRunner.getInsertQuery(dataState.tableNameEmpty))
                     .data(out -> {
                         ClickHouseDataProcessor p = dataState.dataSet.getClickHouseDataProcessor();
@@ -116,7 +156,8 @@ public void insertV2RowBinary(DataState dataState) {
                 }
                 out.flush();
 
-            }, ClickHouseFormat.RowBinaryWithDefaults, new InsertSettings()).get()) {
+            }, ClickHouseFormat.RowBinaryWithDefaults, new InsertSettings()
+                    .compressClientRequest(false)).get()) {
                 response.getWrittenRows();
             }
         } catch (Exception e) {