Function addReadFromQueryResultCacheStep

src/Planner/Planner.cpp:1834–1850

}

void addReadFromQueryResultCacheStep(
    QueryPlan & query_plan,
    std::unique_ptr<SourceFromChunks> source,
    std::unique_ptr<SourceFromChunks> source_totals,
    std::unique_ptr<SourceFromChunks> source_extremes)
{
    auto pipe = Pipe();
    if (source)
        pipe.addSource(std::shared_ptr<SourceFromChunks>(source.release()));
    if (source_totals)
        pipe.addTotalsSource(std::shared_ptr<SourceFromChunks>(source_totals.release()));
    if (source_extremes)
        pipe.addExtremesSource(std::shared_ptr<SourceFromChunks>(source_extremes.release()));

    auto read_from_query_result_cache_step = std::make_unique<ReadFromQueryResultCacheStep>(std::move(pipe));
    query_plan.addStep(std::move(read_from_query_result_cache_step));
}

}