File tree Expand file tree Collapse file tree 2 files changed +2
-5
lines changed
performance/src/test/com/clickhouse/benchmark Expand file tree Collapse file tree 2 files changed +2
-5
lines changed Original file line number Diff line number Diff line change @@ -45,7 +45,7 @@ public static void main(String[] args) throws Exception {
4545 .jvmArgs ("-Xms8g" , "-Xmx8g" )
4646 .measurementTime (TimeValue .seconds (isCloud () ? 30 : 10 ))
4747 .resultFormat (ResultFormatType .JSON )
48- .output (String .format ("jmh-results-%s-%s.out" , isCloud () ? "cloud" : "local" , System .currentTimeMillis ()))
48+ // .output(String.format("jmh-results-%s-%s.out", isCloud() ? "cloud" : "local", System.currentTimeMillis()))
4949 .result (String .format ("jmh-results-%s-%s.json" , isCloud () ? "cloud" : "local" , System .currentTimeMillis ()))
5050 .build ();
5151
Original file line number Diff line number Diff line change @@ -140,13 +140,11 @@ public void insertV1RowBinary(DataState dataState) {
140140 .data (out -> {
141141 ClickHouseDataProcessor p = dataState .dataSet .getClickHouseDataProcessor ();
142142 ClickHouseSerializer [] serializers = p .getSerializers (clientV1 .getConfig (), p .getColumns ());
143-
144143 for (ClickHouseRecord record : dataState .dataSet .getClickHouseRecords ()) {
145144 for (int i = 0 ; i < serializers .length ; i ++) {
146145 serializers [i ].serialize (record .getValue (i ), out );
147146 }
148147 }
149-
150148 })
151149 .executeAndWait ()) {
152150 response .getSummary ();
@@ -161,7 +159,6 @@ public void insertV2RowBinary(DataState dataState) {
161159 try {
162160 try (InsertResponse response = clientV2 .insert (dataState .tableNameEmpty , out -> {
163161 RowBinaryFormatWriter w = new RowBinaryFormatWriter (out , dataState .dataSet .getSchema (), ClickHouseFormat .RowBinary );
164- List <ClickHouseColumn > columns = dataState .dataSet .getSchema ().getColumns ();
165162 for (List <Object > row : dataState .dataSet .getRowsOrdered ()) {
166163 int index = 1 ;
167164 for (Object value : row ) {
@@ -172,7 +169,7 @@ public void insertV2RowBinary(DataState dataState) {
172169 }
173170 out .flush ();
174171
175- }, ClickHouseFormat .RowBinaryWithDefaults , new InsertSettings (). compressClientRequest ( true ) ).get ()) {
172+ }, ClickHouseFormat .RowBinaryWithDefaults , new InsertSettings ()).get ()) {
176173 response .getWrittenRows ();
177174 }
178175 } catch (Exception e ) {
You can’t perform that action at this time.
0 commit comments