File tree 2 files changed +7
-4
lines changed
cpp-ch/local-engine/Storages
2 files changed +7
-4
lines changed Original file line number Diff line number Diff line change 24
24
#include < Storages/MergeTree/KeyCondition.h>
25
25
#include < Storages/MergeTree/RPNBuilder.h>
26
26
#include < Storages/Parquet/ParquetConverter.h>
27
+ #include < fmt/ranges.h>
27
28
#include < parquet/schema.h>
28
29
#include < parquet/statistics.h>
29
30
#include < Common/logger_useful.h>
@@ -371,7 +372,8 @@ struct ASCENDING : BoundaryOrder
371
372
[&](const Bounds & b)
372
373
{
373
374
return builder.filter (
374
- [&](const Int32 i) {
375
+ [&](const Int32 i)
376
+ {
375
377
return i < b.lower || i > b.upper || comparator.compareValueToMin (i) != 0
376
378
|| comparator.compareValueToMax (i) != 0 ;
377
379
});
@@ -524,7 +526,8 @@ struct DESCENDING : BoundaryOrder
524
526
[&](const Bounds & b)
525
527
{
526
528
return builder.filter (
527
- [&](const Int32 i) {
529
+ [&](const Int32 i)
530
+ {
528
531
return i < b.lower || i > b.upper || comparator.compareValueToMin (i) != 0
529
532
|| comparator.compareValueToMin (i) != 0 ;
530
533
});
Original file line number Diff line number Diff line change @@ -907,8 +907,8 @@ std::unique_ptr<DB::ReadBuffer> ReadBufferBuilder::wrapWithParallelIfNeeded(
907
907
LOG_TRACE (
908
908
getLogger (" ReadBufferBuilder" ),
909
909
" Using ParallelReadBuffer with {} workers with chunks of {} bytes" ,
910
- max_download_threads,
911
- max_download_buffer_size);
910
+ max_download_threads. value ,
911
+ max_download_buffer_size. value );
912
912
913
913
return wrapInParallelReadBufferIfSupported (
914
914
{std::move (in)},
You can’t perform that action at this time.
0 commit comments