Method work

src/Processors/Sources/LazyReadReplacingFinalSource.cpp:326–340

}

void LazyReadReplacingFinalSource::work()
{
    auto & reading = shared_state->reading_step;
    chassert(reading);

    auto plan = buildPlanFromReadingStep(std::move(reading), metadata_snapshot, data, query_context);

    auto builder = plan.buildQueryPipeline(QueryPlanOptimizationSettings(query_context), BuildQueryPipelineSettings(query_context));

    auto pipe = QueryPipelineBuilder::getPipe(std::move(*builder), resources);
    pipe.resize(1);

    pipeline_output = pipe.getOutputPort(0);
    processors = Pipe::detachProcessors(std::move(pipe));
}

IProcessor::PipelineUpdate LazyReadReplacingFinalSource::updatePipeline()
{