| 3302 | } |
| 3303 | |
| 3304 | QueryPlanStepPtr ReadFromMergeTree::clone() const |
| 3305 | { |
| 3306 | AnalysisResultPtr analysis_result_copy; |
| 3307 | if (analyzed_result_ptr) |
| 3308 | analysis_result_copy = std::make_shared<AnalysisResult>(*analyzed_result_ptr); |
| 3309 | |
| 3310 | auto cloned_step = std::make_unique<ReadFromMergeTree>( |
| 3311 | prepared_parts, |
| 3312 | mutations_snapshot, |
| 3313 | all_column_names, |
| 3314 | data, |
| 3315 | data_settings, |
| 3316 | query_info, |
| 3317 | storage_snapshot, |
| 3318 | context, |
| 3319 | block_size.max_block_size_rows, |
| 3320 | requested_num_streams, |
| 3321 | max_block_numbers_to_read, |
| 3322 | log, |
| 3323 | std::move(analysis_result_copy), |
| 3324 | is_parallel_reading_from_replicas, |
| 3325 | all_ranges_callback, |
| 3326 | read_task_callback, |
| 3327 | number_of_current_replica); |
| 3328 | cloned_step->allow_query_condition_cache = allow_query_condition_cache; |
| 3329 | cloned_step->enable_remove_parts_from_snapshot_optimization = enable_remove_parts_from_snapshot_optimization; |
| 3330 | return cloned_step; |
| 3331 | } |
| 3332 | |
| 3333 | std::unique_ptr<LazilyReadFromMergeTree> ReadFromMergeTree::keepOnlyRequiredColumnsAndCreateLazyReadStep(const NameSet & required_outputs) |
| 3334 | { |
no outgoing calls
no test coverage detected