1010import org .openjdk .jmh .annotations .Benchmark ;
1111import org .openjdk .jmh .annotations .Scope ;
1212import org .openjdk .jmh .annotations .State ;
13+ import org .openjdk .jmh .infra .Blackhole ;
1314import org .slf4j .Logger ;
1415import org .slf4j .LoggerFactory ;
1516
@@ -20,7 +21,7 @@ public class QueryClient extends BenchmarkBase {
2021 private static final Logger LOGGER = LoggerFactory .getLogger (QueryClient .class );
2122
2223 @ Benchmark
23- public void queryV1 (DataState dataState ) {
24+ public void queryV1 (DataState dataState , Blackhole blackhole ) {
2425 try {
2526 try (ClickHouseResponse response = clientV1 .read (getServer ())
2627 .query (BenchmarkRunner .getSelectQuery (dataState .tableNameFilled ))
@@ -29,7 +30,7 @@ public void queryV1(DataState dataState) {
2930 .executeAndWait ()) {
3031 for (ClickHouseRecord record : response .records ()) {//Compiler optimization avoidance
3132 for (int i = 0 ; i < dataState .dataSet .getSchema ().getColumns ().size (); i ++) {
32- isNotNull (record .getValue (i ), false );
33+ blackhole . consume (record .getValue (i ). asObject () );
3334 }
3435 }
3536 }
@@ -39,13 +40,13 @@ public void queryV1(DataState dataState) {
3940 }
4041
4142 @ Benchmark
42- public void queryV2 (DataState dataState ) {
43+ public void queryV2 (DataState dataState , Blackhole blackhole ) {
4344 try {
4445 try (QueryResponse response = clientV2 .query (BenchmarkRunner .getSelectQuery (dataState .tableNameFilled )).get ()) {
4546 ClickHouseBinaryFormatReader reader = clientV2 .newBinaryFormatReader (response );
4647 while (reader .next () != null ) {//Compiler optimization avoidance
4748 for (int i = 1 ; i <= dataState .dataSet .getSchema ().getColumns ().size (); i ++) {
48- isNotNull (reader .readValue (1 ), false );
49+ blackhole . consume (reader .readValue (1 ));
4950 }
5051 }
5152 }
0 commit comments