File tree Expand file tree Collapse file tree 1 file changed +2
-4
lines changed
performance/src/test/com/clickhouse/benchmark/clients Expand file tree Collapse file tree 1 file changed +2
-4
lines changed Original file line number Diff line number Diff line change @@ -86,7 +86,6 @@ public void close() {
8686 @ Benchmark
8787 public void SerializerOutputStreamV1 (DataState dataState ) {
8888 OutputStream empty = createEmptyOutputStream ();
89-
9089 try {
9190 ClickHouseOutputStream chos = ClickHouseOutputStream .of (empty );
9291 ClickHouseDataProcessor p = dataState .dataSet .getClickHouseDataProcessor ();
@@ -107,11 +106,10 @@ public void SerializerOutputStreamV2(DataState dataState) {
107106 OutputStream empty = createEmptyOutputStream ();
108107 try {
109108 RowBinaryFormatWriter w = new RowBinaryFormatWriter (empty , dataState .dataSet .getSchema (), ClickHouseFormat .RowBinary );
110- List <ClickHouseColumn > columns = dataState .dataSet .getSchema ().getColumns ();
111109 for (List <Object > row : dataState .dataSet .getRowsOrdered ()) {
112- int index = 0 ;
110+ int index = 1 ;
113111 for (Object value : row ) {
114- w .setValue (columns . get ( index ). getColumnName () , value );
112+ w .setValue (index , value );
115113 index ++;
116114 }
117115 w .commitRow ();
You can’t perform that action at this time.
0 commit comments