| 98 | } |
| 99 | |
| 100 | BlockIO ExecutablePoolDictionarySource::loadKeys(const Columns & key_columns, const VectorWithMemoryTracking<size_t> & requested_rows) |
| 101 | { |
| 102 | LOG_TRACE(log, "loadKeys {} size = {}", toString(), requested_rows.size()); |
| 103 | |
| 104 | auto block = blockForKeys(dict_struct, key_columns, requested_rows); |
| 105 | BlockIO io; |
| 106 | io.pipeline = getStreamForBlock(block); |
| 107 | return io; |
| 108 | } |
| 109 | |
| 110 | QueryPipeline ExecutablePoolDictionarySource::getStreamForBlock(const Block & block) |
| 111 | { |
nothing calls this directly
no test coverage detected