move directory

Author: BiteTheDDDDt

be/CMakeLists.txt

@@ -501,6 +501,7 @@ set(DORIS_LINK_LIBS
     IO
     Olap
     Runtime
+    RuntimeFilter
     Service
     Udf
     Util
@@ -766,6 +767,7 @@ add_subdirectory(${SRC_DIR}/http)
 add_subdirectory(${SRC_DIR}/io)
 add_subdirectory(${SRC_DIR}/olap)
 add_subdirectory(${SRC_DIR}/runtime)
+add_subdirectory(${SRC_DIR}/runtime_filter)
 add_subdirectory(${SRC_DIR}/service) # this include doris_be
 add_subdirectory(${SRC_DIR}/udf)
 add_subdirectory(${SRC_DIR}/cloud)

be/src/exprs/bitmapfilter_predicate.h

@@ -19,10 +19,10 @@
 
 #include <algorithm>
 
-#include "exprs/runtime_filter/runtime_filter_definitions.h"
 #include "gutil/integral_types.h"
 #include "runtime/define_primitive_type.h"
 #include "runtime/primitive_type.h"
+#include "runtime_filter/runtime_filter_definitions.h"
 #include "util/bitmap_value.h"
 
 namespace doris {

be/src/exprs/bloom_filter_func.h

@@ -20,8 +20,8 @@
 #include "common/exception.h"
 #include "common/status.h"
 #include "exprs/block_bloom_filter.hpp"
-#include "exprs/runtime_filter/runtime_filter_definitions.h"
 #include "olap/rowset/segment_v2/bloom_filter.h" // IWYU pragma: keep
+#include "runtime_filter/runtime_filter_definitions.h"
 #include "vec/columns/column_dictionary.h"
 #include "vec/columns/column_nullable.h"
 #include "vec/common/string_ref.h"

be/src/exprs/hybrid_set.h

@@ -18,8 +18,8 @@
 #pragma once
 
 #include "common/object_pool.h"
-#include "exprs/runtime_filter/utils.h"
 #include "runtime/primitive_type.h"
+#include "runtime_filter/utils.h"
 #include "vec/columns/column_nullable.h"
 #include "vec/columns/column_string.h"
 #include "vec/columns/column_vector.h"

be/src/exprs/minmax_predicate.h

@@ -17,8 +17,8 @@
 
 #pragma once
 
-#include "exprs/runtime_filter/utils.h"
 #include "runtime/type_limit.h"
+#include "runtime_filter/utils.h"
 #include "vec/columns/column_nullable.h"
 #include "vec/columns/column_string.h"
 

be/src/pipeline/common/runtime_filter_consumer_operator.cpp

@@ -17,8 +17,8 @@
 
 #include "pipeline/common/runtime_filter_consumer_operator.h"
 
-#include "exprs/runtime_filter/runtime_filter_consumer.h"
 #include "pipeline/pipeline_task.h"
+#include "runtime_filter/runtime_filter_consumer.h"
 
 namespace doris::pipeline {
 

be/src/pipeline/dependency.cpp

@@ -21,12 +21,12 @@
 #include <mutex>
 
 #include "common/logging.h"
-#include "exprs/runtime_filter/runtime_filter_consumer.h"
 #include "pipeline/exec/multi_cast_data_streamer.h"
 #include "pipeline/pipeline_fragment_context.h"
 #include "pipeline/pipeline_task.h"
 #include "runtime/exec_env.h"
 #include "runtime/memory/mem_tracker.h"
+#include "runtime_filter/runtime_filter_consumer.h"
 #include "vec/exprs/vectorized_agg_fn.h"
 #include "vec/exprs/vslot_ref.h"
 #include "vec/spill/spill_stream_manager.h"

be/src/pipeline/exec/datagen_operator.cpp

@@ -19,10 +19,10 @@
 
 #include <memory>
 
-#include "exprs/runtime_filter/runtime_filter_consumer.h"
 #include "pipeline/common/data_gen_functions/vdata_gen_function_inf.h"
 #include "pipeline/common/data_gen_functions/vnumbers_tvf.h"
 #include "pipeline/exec/operator.h"
+#include "runtime_filter/runtime_filter_consumer.h"
 #include "util/runtime_profile.h"
 
 namespace doris {

be/src/pipeline/exec/hashjoin_build_sink.h

@@ -17,9 +17,9 @@
 
 #pragma once
 
-#include "exprs/runtime_filter/runtime_filter_slots.h"
 #include "join_build_sink_operator.h"
 #include "operator.h"
+#include "runtime_filter/runtime_filter_slots.h"
 
 namespace doris::pipeline {
 #include "common/compile_check_begin.h"

be/src/pipeline/exec/nested_loop_join_build_operator.cpp

@@ -19,8 +19,8 @@
 
 #include <memory>
 
-#include "exprs/runtime_filter/runtime_filter_slots_cross.h"
 #include "pipeline/exec/operator.h"
+#include "runtime_filter/runtime_filter_slots_cross.h"
 
 namespace doris::pipeline {
 #include "common/compile_check_begin.h"

be/src/pipeline/exec/nested_loop_join_build_operator.h

@@ -19,9 +19,9 @@
 
 #include <stdint.h>
 
-#include "exprs/runtime_filter/runtime_filter_slots_cross.h"
 #include "operator.h"
 #include "pipeline/exec/join_build_sink_operator.h"
+#include "runtime_filter/runtime_filter_slots_cross.h"
 
 namespace doris::pipeline {
 #include "common/compile_check_begin.h"

be/src/runtime/fragment_mgr.cpp

@@ -19,7 +19,6 @@
 
 #include <brpc/controller.h>
 #include <bvar/latency_recorder.h>
-#include <exprs/runtime_filter/runtime_filter_consumer.h>
 #include <fmt/format.h>
 #include <gen_cpp/DorisExternalService_types.h>
 #include <gen_cpp/FrontendService.h>
@@ -45,7 +44,6 @@
 #include <cstddef>
 #include <ctime>
 
-#include "common/status.h"
 // IWYU pragma: no_include <bits/chrono.h>
 #include <chrono> // IWYU pragma: keep
 #include <cstdint>
@@ -60,6 +58,7 @@
 #include "common/config.h"
 #include "common/logging.h"
 #include "common/object_pool.h"
+#include "common/status.h"
 #include "common/utils.h"
 #include "io/fs/stream_load_pipe.h"
 #include "pipeline/pipeline_fragment_context.h"
@@ -80,6 +79,7 @@
 #include "runtime/workload_group/workload_group.h"
 #include "runtime/workload_group/workload_group_manager.h"
 #include "runtime/workload_management/workload_query_info.h"
+#include "runtime_filter/runtime_filter_consumer.h"
 #include "service/backend_options.h"
 #include "util/brpc_client_cache.h"
 #include "util/debug_points.h"

be/src/runtime/runtime_filter_mgr.cpp

@@ -32,15 +32,15 @@
 #include "common/config.h"
 #include "common/logging.h"
 #include "common/status.h"
-#include "exprs/runtime_filter/runtime_filter.h"
-#include "exprs/runtime_filter/runtime_filter_consumer.h"
-#include "exprs/runtime_filter/runtime_filter_merger.h"
-#include "exprs/runtime_filter/runtime_filter_producer.h"
 #include "runtime/exec_env.h"
 #include "runtime/memory/mem_tracker.h"
 #include "runtime/query_context.h"
 #include "runtime/runtime_state.h"
 #include "runtime/thread_context.h"
+#include "runtime_filter/runtime_filter.h"
+#include "runtime_filter/runtime_filter_consumer.h"
+#include "runtime_filter/runtime_filter_merger.h"
+#include "runtime_filter/runtime_filter_producer.h"
 #include "util/brpc_client_cache.h"
 #include "util/ref_count_closure.h"
 

be/src/runtime_filter/CMakeLists.txt

@@ -0,0 +1,27 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License.  You may obtain a copy of the License at
+#
+#   http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied.  See the License for the
+# specific language governing permissions and limitations
+# under the License.
+
+# where to put generated libraries
+set(LIBRARY_OUTPUT_PATH "${BUILD_DIR}/src/runtime_filter")
+
+# where to put generated binaries
+set(EXECUTABLE_OUTPUT_PATH "${BUILD_DIR}/src/runtime_filter")
+
+file(GLOB_RECURSE SRC_FILES CONFIGURE_DEPENDS *.cpp *.cc)
+add_library(RuntimeFilter STATIC ${SRC_FILES})
+
+pch_reuse(RuntimeFilter)

be/src/exprs/runtime_filter/runtime_filter.cpp be/src/runtime_filter/runtime_filter.cpp

@@ -15,16 +15,16 @@
 // specific language governing permissions and limitations
 // under the License.
 
-#include "exprs/runtime_filter/runtime_filter.h"
+#include "runtime_filter/runtime_filter.h"
 
 #include "common/status.h"
 #include "exprs/bitmapfilter_predicate.h"
 #include "exprs/create_predicate_function.h"
 #include "exprs/hybrid_set.h"
 #include "exprs/minmax_predicate.h"
-#include "exprs/runtime_filter/runtime_filter_consumer.h"
-#include "exprs/runtime_filter/runtime_filter_merger.h"
-#include "exprs/runtime_filter/runtime_filter_producer.h"
+#include "runtime_filter/runtime_filter_consumer.h"
+#include "runtime_filter/runtime_filter_merger.h"
+#include "runtime_filter/runtime_filter_producer.h"
 #include "util/brpc_client_cache.h"
 #include "util/ref_count_closure.h"
 #include "vec/exprs/vbitmap_predicate.h"

be/src/exprs/runtime_filter/runtime_filter.h be/src/runtime_filter/runtime_filter.h

@@ -20,11 +20,11 @@
 #include <gen_cpp/PaloInternalService_types.h>
 
 #include "common/status.h"
-#include "exprs/runtime_filter/runtime_filter_definitions.h"
-#include "exprs/runtime_filter/runtime_filter_wrapper.h"
-#include "exprs/runtime_filter/utils.h"
 #include "pipeline/dependency.h"
 #include "runtime/query_context.h"
+#include "runtime_filter/runtime_filter_definitions.h"
+#include "runtime_filter/runtime_filter_wrapper.h"
+#include "runtime_filter/utils.h"
 
 namespace doris {
 class RuntimePredicateWrapper;

be/src/exprs/runtime_filter/runtime_filter_consumer.cpp be/src/runtime_filter/runtime_filter_consumer.cpp

@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-#include "exprs/runtime_filter/runtime_filter_consumer.h"
+#include "runtime_filter/runtime_filter_consumer.h"
 
 #include "exprs/bitmapfilter_predicate.h"
 

be/src/exprs/runtime_filter/runtime_filter_consumer.h be/src/runtime_filter/runtime_filter_consumer.h

@@ -17,7 +17,7 @@
 
 #pragma once
 
-#include "exprs/runtime_filter/runtime_filter.h"
+#include "runtime_filter/runtime_filter.h"
 
 namespace doris {
 

be/src/exprs/runtime_filter/runtime_filter_definitions.h be/src/runtime_filter/runtime_filter_definitions.h

@@ -17,7 +17,7 @@
 
 #pragma once
 
-#include "exprs/runtime_filter/runtime_filter.h"
+#include "runtime_filter/runtime_filter.h"
 
 namespace doris {
 

be/src/exprs/runtime_filter/runtime_filter_merger.h be/src/runtime_filter/runtime_filter_merger.h

@@ -15,10 +15,10 @@
 // specific language governing permissions and limitations
 // under the License.
 
-#include "exprs/runtime_filter/runtime_filter_producer.h"
+#include "runtime_filter/runtime_filter_producer.h"
 
-#include "exprs/runtime_filter/runtime_filter_consumer.h"
-#include "exprs/runtime_filter/runtime_filter_merger.h"
+#include "runtime_filter/runtime_filter_consumer.h"
+#include "runtime_filter/runtime_filter_merger.h"
 #include "util/brpc_client_cache.h"
 #include "util/ref_count_closure.h"
 

be/src/exprs/runtime_filter/runtime_filter_producer.cpp be/src/runtime_filter/runtime_filter_producer.cpp

@@ -17,7 +17,7 @@
 
 #pragma once
 
-#include "exprs/runtime_filter/runtime_filter.h"
+#include "runtime_filter/runtime_filter.h"
 
 namespace doris {
 

be/src/exprs/runtime_filter/runtime_filter_producer.h be/src/runtime_filter/runtime_filter_producer.h

@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-#include "exprs/runtime_filter/runtime_filter_slots.h"
+#include "runtime_filter/runtime_filter_slots.h"
 
 #include "pipeline/pipeline_task.h"
 

be/src/exprs/runtime_filter/runtime_filter_slots.cpp be/src/runtime_filter/runtime_filter_slots.cpp

@@ -18,10 +18,10 @@
 #pragma once
 
 #include "common/status.h"
-#include "exprs/runtime_filter/runtime_filter.h"
-#include "exprs/runtime_filter/runtime_filter_producer.h"
 #include "runtime/runtime_filter_mgr.h"
 #include "runtime/runtime_state.h"
+#include "runtime_filter/runtime_filter.h"
+#include "runtime_filter/runtime_filter_producer.h"
 #include "vec/core/block.h" // IWYU pragma: keep
 #include "vec/exprs/vexpr_context.h"
 #include "vec/runtime/shared_hash_table_controller.h"

be/src/exprs/runtime_filter/runtime_filter_slots.h be/src/runtime_filter/runtime_filter_slots.h

@@ -20,10 +20,10 @@
 #include <vector>
 
 #include "common/status.h"
-#include "exprs/runtime_filter/runtime_filter.h"
-#include "exprs/runtime_filter/runtime_filter_slots.h"
 #include "runtime/runtime_filter_mgr.h"
 #include "runtime/runtime_state.h"
+#include "runtime_filter/runtime_filter.h"
+#include "runtime_filter/runtime_filter_slots.h"
 #include "vec/core/block.h"
 #include "vec/exprs/vexpr.h"
 #include "vec/exprs/vexpr_context.h"

be/src/exprs/runtime_filter/runtime_filter_slots_cross.h be/src/runtime_filter/runtime_filter_slots_cross.h

@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-#include "exprs/runtime_filter/runtime_filter_wrapper.h"
+#include "runtime_filter/runtime_filter_wrapper.h"
 
 #include <gen_cpp/Opcodes_types.h>
 #include <gen_cpp/PaloInternalService_types.h>

be/src/exprs/runtime_filter/runtime_filter_wrapper.cpp be/src/runtime_filter/runtime_filter_wrapper.cpp

@@ -19,8 +19,8 @@
 
 #include "common/status.h"
 #include "exprs/bloom_filter_func.h"
-#include "exprs/runtime_filter/runtime_filter_definitions.h"
 #include "runtime/runtime_state.h"
+#include "runtime_filter/runtime_filter_definitions.h"
 #include "vec/exprs/vexpr_fwd.h"
 #include "vec/exprs/vruntimefilter_wrapper.h"
 

be/src/exprs/runtime_filter/runtime_filter_wrapper.h be/src/runtime_filter/runtime_filter_wrapper.h

@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-#include "exprs/runtime_filter/utils.h"
+#include "runtime_filter/utils.h"
 
 #include "vec/exprs/vexpr.h"
 #include "vec/exprs/vliteral.h"

be/src/exprs/runtime_filter/utils.cpp be/src/runtime_filter/utils.cpp

@@ -21,9 +21,9 @@
 #include <gen_cpp/PlanNodes_types.h>
 #include <gen_cpp/internal_service.pb.h>
 
-#include "exprs/runtime_filter/runtime_filter_definitions.h"
 #include "runtime/large_int_value.h"
 #include "runtime/types.h"
+#include "runtime_filter/runtime_filter_definitions.h"
 #include "vec/core/types.h"
 #include "vec/core/wide_integer.h"
 #include "vec/exprs/vexpr_fwd.h"

be/src/exprs/runtime_filter/utils.h be/src/runtime_filter/utils.h

@@ -26,7 +26,7 @@
 #include <vector>
 
 #include "common/status.h"
-#include "exprs/runtime_filter/runtime_filter_definitions.h"
+#include "runtime_filter/runtime_filter_definitions.h"
 #include "vec/core/block.h"
 
 namespace doris {

be/src/vec/runtime/shared_hash_table_controller.h

@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-#include "exprs/runtime_filter/runtime_filter.h"
+#include "runtime_filter/runtime_filter.h"
 
 #include <array>
 #include <memory>