@@ -57,7 +57,6 @@ public void insertV1(DataState dataState) {
5757 try (ClickHouseResponse response = clientV1 .read (getServer ())
5858 .write ()
5959 .option (ClickHouseClientOption .ASYNC , false )
60- .option (ClickHouseClientOption .DECOMPRESS , false )
6160 .format (format )
6261 .query (BenchmarkRunner .getInsertQuery (dataState .tableNameEmpty ))
6362 .data (out -> {
@@ -81,7 +80,7 @@ public void insertV2(DataState dataState) {
8180 out .write (bytes );
8281 }
8382 out .close ();
84- }, format , new InsertSettings (). compressClientRequest ( false ) ).get ()) {
83+ }, format , new InsertSettings ()).get ()) {
8584 response .getWrittenRows ();
8685 }
8786 } catch (Exception e ) {
@@ -120,7 +119,8 @@ public void insertV2Compressed(DataState dataState) {
120119 out .write (bytes );
121120 }
122121 out .close ();
123- }, format , new InsertSettings ()).get ()) {
122+ }, format , new InsertSettings ()
123+ .compressClientRequest (true )).get ()) {
124124 response .getWrittenRows ();
125125 }
126126 } catch (Exception e ) {
@@ -136,7 +136,6 @@ public void insertV1RowBinary(DataState dataState) {
136136 .write ()
137137 .option (ClickHouseClientOption .ASYNC , false )
138138 .format (format )
139- .option (ClickHouseClientOption .DECOMPRESS , false )
140139 .query (BenchmarkRunner .getInsertQuery (dataState .tableNameEmpty ))
141140 .data (out -> {
142141 ClickHouseDataProcessor p = dataState .dataSet .getClickHouseDataProcessor ();
@@ -171,8 +170,7 @@ public void insertV2RowBinary(DataState dataState) {
171170 }
172171 out .flush ();
173172
174- }, ClickHouseFormat .RowBinaryWithDefaults , new InsertSettings ()
175- .compressClientRequest (false )).get ()) {
173+ }, ClickHouseFormat .RowBinaryWithDefaults , new InsertSettings ()).get ()) {
176174 response .getWrittenRows ();
177175 }
178176 } catch (Exception e ) {
0 commit comments