Method fromProto

src/QueryPlan/MergeSortingStep.cpp:161–192

}

std::shared_ptr<MergeSortingStep> MergeSortingStep::fromProto(const Protos::MergeSortingStep & proto, ContextPtr context)
{
    auto [step_description, base_input_stream] = ITransformingStep::deserializeFromProtoBase(proto.query_plan_base());
    SortDescription description;
    for (const auto & proto_element : proto.description())
    {
        SortColumnDescription element;
        element.fillFromProto(proto_element);
        description.emplace_back(std::move(element));
    }
    auto max_merged_block_size = proto.max_merged_block_size();
    auto limit = proto.limit();
    auto max_bytes_before_remerge = proto.max_bytes_before_remerge();
    auto remerge_lowered_memory_bytes_ratio = proto.remerge_lowered_memory_bytes_ratio();
    auto max_bytes_before_external_sort = proto.max_bytes_before_external_sort();
    auto enable_adaptive_spill = proto.enable_adaptive_spill();
    VolumePtr tmp_volume = context ? context->getTemporaryVolume() : nullptr;
    auto min_free_disk_space = proto.min_free_disk_space();
    auto step = std::make_shared<MergeSortingStep>(
        base_input_stream,
        description,
        max_merged_block_size,
        limit,
        max_bytes_before_remerge,
        remerge_lowered_memory_bytes_ratio,
        max_bytes_before_external_sort,
        tmp_volume,
        min_free_disk_space,
        enable_adaptive_spill);
    step->setStepDescription(step_description);
    return step;
}
}