update

Author: BiteTheDDDDt

be/src/exprs/bitmapfilter_predicate.h

@@ -19,7 +19,7 @@
 
 #include <algorithm>
 
-#include "exprs/runtime_filter/runtime_filter.h"
+#include "exprs/runtime_filter/runtime_filter_definitions.h"
 #include "gutil/integral_types.h"
 #include "runtime/define_primitive_type.h"
 #include "runtime/primitive_type.h"

be/src/exprs/bloom_filter_func.h

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

be/src/exprs/hybrid_set.h

@@ -17,8 +17,13 @@
 
 #pragma once
 
-#include "exprs/runtime_filter/runtime_filter.h"
+#include "common/object_pool.h"
 #include "exprs/runtime_filter/utils.h"
+#include "runtime/primitive_type.h"
+#include "vec/columns/column_nullable.h"
+#include "vec/columns/column_string.h"
+#include "vec/columns/column_vector.h"
+#include "vec/common/hash_table/phmap_fwd_decl.h"
 
 namespace doris {
 

be/src/exprs/minmax_predicate.h

@@ -17,10 +17,13 @@
 
 #pragma once
 
-#include "exprs/runtime_filter/runtime_filter.h"
 #include "exprs/runtime_filter/utils.h"
+#include "runtime/type_limit.h"
+#include "vec/columns/column_nullable.h"
+#include "vec/columns/column_string.h"
 
 namespace doris {
+
 // only used in Runtime Filter
 class MinMaxFuncBase : public RuntimeFilterFuncBase {
 public:

be/src/exprs/runtime_filter/runtime_filter.cpp

@@ -26,10 +26,8 @@
 #include "util/ref_count_closure.h"
 #include "vec/exprs/vbitmap_predicate.h"
 #include "vec/exprs/vbloom_predicate.h"
-#include "vec/exprs/vdirect_in_predicate.h"
 #include "vec/exprs/vexpr.h"
 #include "vec/exprs/vexpr_context.h"
-#include "vec/exprs/vliteral.h"
 #include "vec/exprs/vruntimefilter_wrapper.h"
 
 namespace doris {

be/src/exprs/runtime_filter/runtime_filter_wrapper.cpp

@@ -15,47 +15,33 @@
 // specific language governing permissions and limitations
 // under the License.
 
-#include "runtime_filter_wrapper.h"
+#include "exprs/runtime_filter/runtime_filter_wrapper.h"
 
 #include <gen_cpp/Opcodes_types.h>
 #include <gen_cpp/PaloInternalService_types.h>
 #include <gen_cpp/PlanNodes_types.h>
 #include <gen_cpp/Types_types.h>
 #include <gen_cpp/internal_service.pb.h>
 
-#include <algorithm>
-// IWYU pragma: no_include <bits/chrono.h>
 #include <chrono> // IWYU pragma: keep
-#include <map>
 #include <memory>
-#include <mutex>
 #include <ostream>
-#include <utility>
 
-#include "agent/be_exec_version_manager.h"
 #include "common/logging.h"
 #include "common/status.h"
-#include "exprs/bitmapfilter_predicate.h"
 #include "exprs/bloom_filter_func.h"
 #include "exprs/create_predicate_function.h"
 #include "exprs/hybrid_set.h"
-#include "gutil/strings/substitute.h"
-#include "pipeline/dependency.h"
 #include "runtime/define_primitive_type.h"
-#include "runtime/large_int_value.h"
 #include "runtime/primitive_type.h"
 #include "runtime/runtime_filter_mgr.h"
 #include "util/bitmap_value.h"
-#include "util/brpc_client_cache.h"
-#include "util/ref_count_closure.h"
-#include "util/runtime_profile.h"
 #include "util/string_parser.hpp"
 #include "vec/columns/column.h"
 #include "vec/columns/column_complex.h"
 #include "vec/columns/column_nullable.h"
 #include "vec/common/assert_cast.h"
 #include "vec/core/wide_integer.h"
-#include "vec/core/wide_integer_to_string.h"
 #include "vec/exprs/vbitmap_predicate.h"
 #include "vec/exprs/vbloom_predicate.h"
 #include "vec/exprs/vdirect_in_predicate.h"
@@ -64,6 +50,7 @@
 #include "vec/exprs/vliteral.h"
 #include "vec/exprs/vruntimefilter_wrapper.h"
 #include "vec/runtime/shared_hash_table_controller.h"
+
 namespace doris {
 
 Status RuntimePredicateWrapper::get_push_exprs(

be/src/exprs/runtime_filter/runtime_filter_wrapper.h

@@ -20,6 +20,8 @@
 #include "common/status.h"
 #include "exprs/bloom_filter_func.h"
 #include "exprs/runtime_filter/runtime_filter_definitions.h"
+#include "vec/exprs/vexpr_fwd.h"
+#include "vec/exprs/vruntimefilter_wrapper.h"
 
 namespace doris {
 

be/src/olap/bitmap_filter_predicate.h

@@ -20,14 +20,10 @@
 #include <cstdint>
 
 #include "exprs/bitmapfilter_predicate.h"
-#include "exprs/runtime_filter/runtime_filter.h"
 #include "olap/column_predicate.h"
 #include "olap/wrapper_field.h"
-#include "vec/columns/column_dictionary.h"
 #include "vec/columns/column_nullable.h"
-#include "vec/columns/column_vector.h"
 #include "vec/columns/predicate_column.h"
-#include "vec/exprs/vruntimefilter_wrapper.h"
 
 namespace doris {
 template <PrimitiveType T>

be/src/olap/bloom_filter_predicate.h

@@ -18,7 +18,6 @@
 #pragma once
 
 #include "exprs/bloom_filter_func.h"
-#include "exprs/runtime_filter/runtime_filter.h"
 #include "olap/column_predicate.h"
 #include "runtime/primitive_type.h"
 #include "vec/columns/column_dictionary.h"

be/src/olap/tablet.cpp

@@ -62,7 +62,6 @@
 #include "common/logging.h"
 #include "common/signal_handler.h"
 #include "common/status.h"
-#include "exprs/runtime_filter/runtime_filter.h"
 #include "gutil/ref_counted.h"
 #include "gutil/strings/substitute.h"
 #include "io/fs/file_reader.h"

be/src/vec/exec/format/orc/vorc_reader.cpp

@@ -54,6 +54,7 @@
 #include "runtime/define_primitive_type.h"
 #include "runtime/descriptors.h"
 #include "runtime/primitive_type.h"
+#include "runtime/runtime_state.h"
 #include "runtime/thread_context.h"
 #include "util/runtime_profile.h"
 #include "util/slice.h"

be/src/vec/exec/format/parquet/vparquet_group_reader.cpp

@@ -36,6 +36,7 @@
 #include "gutil/stringprintf.h"
 #include "runtime/define_primitive_type.h"
 #include "runtime/descriptors.h"
+#include "runtime/runtime_state.h"
 #include "runtime/thread_context.h"
 #include "runtime/types.h"
 #include "schema_desc.h"