| 46 | } |
| 47 | |
| 48 | void applyQueryLimit(std::optional<UInt64> & effective_limit, const std::optional<size_t> & query_limit) |
| 49 | { |
| 50 | if (!query_limit) |
| 51 | return; |
| 52 | |
| 53 | const UInt64 query_limit_64 = static_cast<UInt64>(*query_limit); |
| 54 | effective_limit = std::min(effective_limit.value_or(query_limit_64), query_limit_64); |
| 55 | } |
| 56 | |
| 57 | void addNullSource(Pipe & pipe, SharedHeader header) |
| 58 | { |