Method deserialize

src/Processors/QueryPlan/BuildRuntimeFilterStep.cpp:164–202

}

QueryPlanStepPtr BuildRuntimeFilterStep::deserialize(Deserialization & ctx)
{
    if (ctx.input_headers.size() != 1)
        throw Exception(ErrorCodes::INCORRECT_DATA, "BuildRuntimeFilterStep must have one input stream");

    String filter_column_name;
    readStringBinary(filter_column_name, ctx.in);

    DataTypePtr filter_column_type = decodeDataType(ctx.in);

    String filter_name;
    readStringBinary(filter_name, ctx.in);

    bool allow_to_use_not_exact_filter = false;
    readBinary(allow_to_use_not_exact_filter, ctx.in);

    const UInt64 exact_values_limit = ctx.settings[QueryPlanSerializationSetting::join_runtime_filter_exact_values_limit];
    const UInt64 bloom_filter_bytes = ctx.settings[QueryPlanSerializationSetting::join_runtime_bloom_filter_bytes];
    const UInt64 bloom_filter_hash_functions = ctx.settings[QueryPlanSerializationSetting::join_runtime_bloom_filter_hash_functions];
    const Float64 pass_ratio_threshold_for_disabling = ctx.settings[QueryPlanSerializationSetting::join_runtime_filter_pass_ratio_threshold_for_disabling];
    const Float64 blocks_to_skip_before_reenabling = static_cast<Float64>(ctx.settings[QueryPlanSerializationSetting::join_runtime_filter_blocks_to_skip_before_reenabling]);
    const Float64 max_ratio_of_set_bits_in_bloom_filter = ctx.settings[QueryPlanSerializationSetting::join_runtime_bloom_filter_max_ratio_of_set_bits];

    /// A deserialized step carries no random lookup key (it is never serialized); runtime filters are
    /// re-derived per plan build. If such a step is ever executed, `finish()` no-ops on the empty key.
    return std::make_unique<BuildRuntimeFilterStep>(
        ctx.input_headers.front(),
        std::move(filter_column_name),
        filter_column_type,
        std::move(filter_name),
        /*filter_key_=*/String{},
        exact_values_limit,
        bloom_filter_bytes,
        bloom_filter_hash_functions,
        pass_ratio_threshold_for_disabling,
        blocks_to_skip_before_reenabling,
        max_ratio_of_set_bits_in_bloom_filter,
        allow_to_use_not_exact_filter);
}

QueryPlanStepPtr BuildRuntimeFilterStep::clone() const
{