| 172 | } |
| 173 | |
| 174 | BlockIO ExecutableDictionarySource::loadKeys(const Columns & key_columns, const VectorWithMemoryTracking<size_t> & requested_rows) |
| 175 | { |
| 176 | LOG_TRACE(log, "loadKeys {} size = {}", toString(), requested_rows.size()); |
| 177 | |
| 178 | auto block = blockForKeys(dict_struct, key_columns, requested_rows); |
| 179 | BlockIO io; |
| 180 | io.pipeline = getStreamForBlock(block); |
| 181 | return io; |
| 182 | } |
| 183 | |
| 184 | QueryPipeline ExecutableDictionarySource::getStreamForBlock(const Block & block) |
| 185 | { |
nothing calls this directly
no test coverage detected