Function deserializeQueryPlan

src/QueryPipeline/DistributedPlanExecutor.cpp:600–605

}

static QueryPlan deserializeQueryPlan(const String & serialized_query_plan, ContextPtr context)
{
    ReadBufferFromString in(serialized_query_plan);
    auto plan_and_sets = QueryPlan::deserialize(in, context);
    return QueryPlan::makeSets(std::move(plan_and_sets), context);
}

void doExecuteTask(const DistributedQueryTaskDescription & task_description, ObjectStoragePtr object_storage,
    const String & object_storage_path, const String & distributed_query_id, ContextMutablePtr context,