Skip to content

Commit 904787d

Browse files
committed
cleanup compress settings to have pure default tests
1 parent cdc7122 commit 904787d

1 file changed

Lines changed: 4 additions & 6 deletions

File tree

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

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -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

Comments
 (0)