diff --git a/be/src/exec/common/hash_table/hash_table_set_build.h b/be/src/exec/common/hash_table/hash_table_set_build.h index 7ad20a5942ece4..dad349a1a1d1c0 100644 --- a/be/src/exec/common/hash_table/hash_table_set_build.h +++ b/be/src/exec/common/hash_table/hash_table_set_build.h @@ -17,9 +17,10 @@ #include "core/column/column.h" #include "exec/operator/set_sink_operator.h" -#include "runtime/runtime_state.h" namespace doris { + +class RuntimeState; #include "common/compile_check_begin.h" constexpr size_t CHECK_FRECUENCY = 65536; template diff --git a/be/src/exec/runtime_filter/runtime_filter_producer_helper_cross.h b/be/src/exec/runtime_filter/runtime_filter_producer_helper_cross.h index d13e8b76b090eb..30b4cf1007e0c4 100644 --- a/be/src/exec/runtime_filter/runtime_filter_producer_helper_cross.h +++ b/be/src/exec/runtime_filter/runtime_filter_producer_helper_cross.h @@ -24,9 +24,10 @@ #include "exec/runtime_filter/runtime_filter_producer_helper.h" #include "exprs/vexpr.h" #include "exprs/vexpr_context.h" -#include "runtime/runtime_state.h" namespace doris { + +class RuntimeState; #include "common/compile_check_begin.h" // this class used in cross join node class RuntimeFilterProducerHelperCross : public RuntimeFilterProducerHelper { diff --git a/be/src/exec/runtime_filter/runtime_filter_producer_helper_set.h b/be/src/exec/runtime_filter/runtime_filter_producer_helper_set.h index 9def71af0ebbb1..69f89009c8969e 100644 --- a/be/src/exec/runtime_filter/runtime_filter_producer_helper_set.h +++ b/be/src/exec/runtime_filter/runtime_filter_producer_helper_set.h @@ -25,9 +25,10 @@ #include "exec/runtime_filter/runtime_filter_producer_helper.h" #include "exprs/vexpr.h" #include "exprs/vexpr_context.h" -#include "runtime/runtime_state.h" namespace doris { + +class RuntimeState; #include "common/compile_check_begin.h" // this class used in set sink node class RuntimeFilterProducerHelperSet : public RuntimeFilterProducerHelper { diff --git a/be/src/exec/sink/tablet_sink_hash_partitioner.cpp b/be/src/exec/sink/tablet_sink_hash_partitioner.cpp index 5c68b444f0fea5..3970c7756d0d50 100644 --- a/be/src/exec/sink/tablet_sink_hash_partitioner.cpp +++ b/be/src/exec/sink/tablet_sink_hash_partitioner.cpp @@ -22,6 +22,7 @@ #include #include "exec/operator/operator.h" +#include "runtime/runtime_state.h" namespace doris { #include "common/compile_check_begin.h" diff --git a/be/src/exec/sink/tablet_sink_hash_partitioner.h b/be/src/exec/sink/tablet_sink_hash_partitioner.h index ee594814074462..98aaf1d228a82e 100644 --- a/be/src/exec/sink/tablet_sink_hash_partitioner.h +++ b/be/src/exec/sink/tablet_sink_hash_partitioner.h @@ -23,10 +23,11 @@ #include "exec/sink/vrow_distribution.h" #include "exec/sink/vtablet_block_convertor.h" #include "exec/sink/vtablet_finder.h" -#include "runtime/runtime_state.h" #include "storage/tablet_info.h" namespace doris { + +class RuntimeState; #include "common/compile_check_begin.h" class TabletSinkHashPartitioner final : public PartitionerBase { public: diff --git a/be/src/exprs/lambda_function/lambda_function.h b/be/src/exprs/lambda_function/lambda_function.h index c76a71e86dcd16..218f316e24a401 100644 --- a/be/src/exprs/lambda_function/lambda_function.h +++ b/be/src/exprs/lambda_function/lambda_function.h @@ -21,9 +21,10 @@ #include "core/block/block.h" #include "exprs/vexpr.h" #include "exprs/vexpr_context.h" -#include "runtime/runtime_state.h" namespace doris { + +class RuntimeState; class VExpr; class LambdaFunction { public: diff --git a/be/src/exprs/short_circuit_evaluation_expr.cpp b/be/src/exprs/short_circuit_evaluation_expr.cpp index 1ebc4bfa3254be..431aae67e081c5 100644 --- a/be/src/exprs/short_circuit_evaluation_expr.cpp +++ b/be/src/exprs/short_circuit_evaluation_expr.cpp @@ -36,6 +36,7 @@ #include "core/field.h" #include "exprs/short_circuit_util.h" #include "exprs/vexpr.h" +#include "runtime/runtime_state.h" namespace doris { diff --git a/be/src/exprs/short_circuit_evaluation_expr.h b/be/src/exprs/short_circuit_evaluation_expr.h index bd845cb1cca1ab..2ec51d36c26bc9 100644 --- a/be/src/exprs/short_circuit_evaluation_expr.h +++ b/be/src/exprs/short_circuit_evaluation_expr.h @@ -22,10 +22,11 @@ #include "common/status.h" #include "exprs/vexpr.h" #include "exprs/vexpr_context.h" -#include "runtime/runtime_state.h" namespace doris { +class RuntimeState; + class Block; class VExprContext; struct ColumnAndSelector; diff --git a/be/src/exprs/vcolumn_ref.h b/be/src/exprs/vcolumn_ref.h index b1f94e5d1c0a8d..4a30996302c96a 100644 --- a/be/src/exprs/vcolumn_ref.h +++ b/be/src/exprs/vcolumn_ref.h @@ -21,9 +21,10 @@ #include "exprs/function/function.h" #include "exprs/vexpr.h" #include "runtime/descriptors.h" -#include "runtime/runtime_state.h" namespace doris { + +class RuntimeState; class VColumnRef final : public VExpr { ENABLE_FACTORY_CREATOR(VColumnRef); diff --git a/be/src/exprs/vcondition_expr.cpp b/be/src/exprs/vcondition_expr.cpp index 66966ee36973b2..804ce4096d9956 100644 --- a/be/src/exprs/vcondition_expr.cpp +++ b/be/src/exprs/vcondition_expr.cpp @@ -22,6 +22,7 @@ #include "core/column/column.h" #include "core/column/column_const.h" #include "exprs/function_context.h" +#include "runtime/runtime_state.h" #include "util/simd/bits.h" namespace doris { diff --git a/be/src/exprs/vcondition_expr.h b/be/src/exprs/vcondition_expr.h index 956ed746348a8d..2b2abcf2db40dc 100644 --- a/be/src/exprs/vcondition_expr.h +++ b/be/src/exprs/vcondition_expr.h @@ -27,7 +27,6 @@ #include "exprs/vexpr_context.h" #include "exprs/vliteral.h" #include "exprs/vslot_ref.h" -#include "runtime/runtime_state.h" namespace doris { class RowDescriptor; class RuntimeState; diff --git a/be/src/exprs/vectorized_fn_call.h b/be/src/exprs/vectorized_fn_call.h index 979a0d5c1f8750..12b61f3bfcc3cf 100644 --- a/be/src/exprs/vectorized_fn_call.h +++ b/be/src/exprs/vectorized_fn_call.h @@ -29,7 +29,6 @@ #include "exprs/vexpr_context.h" #include "exprs/vliteral.h" #include "exprs/vslot_ref.h" -#include "runtime/runtime_state.h" #include "storage/index/ann/ann_range_search_runtime.h" namespace doris { diff --git a/be/src/exprs/vexpr_context.h b/be/src/exprs/vexpr_context.h index 5b6aaafdddda34..c6b3c8a480e091 100644 --- a/be/src/exprs/vexpr_context.h +++ b/be/src/exprs/vexpr_context.h @@ -34,7 +34,6 @@ #include "exec/runtime_filter/runtime_filter_selectivity.h" #include "exprs/function_context.h" #include "exprs/vexpr_fwd.h" -#include "runtime/runtime_state.h" #include "storage/index/ann/ann_range_search_runtime.h" #include "storage/index/ann/ann_search_params.h" #include "storage/index/inverted/inverted_index_reader.h" diff --git a/be/src/exprs/vtopn_pred.h b/be/src/exprs/vtopn_pred.h index 899a3877526e1c..fb7986e55b556c 100644 --- a/be/src/exprs/vtopn_pred.h +++ b/be/src/exprs/vtopn_pred.h @@ -30,9 +30,10 @@ #include "exprs/vslot_ref.h" #include "runtime/query_context.h" #include "runtime/runtime_predicate.h" -#include "runtime/runtime_state.h" namespace doris { + +class RuntimeState; #include "common/compile_check_begin.h" // only used for dynamic topn filter diff --git a/be/src/runtime/task_execution_context.cpp b/be/src/runtime/task_execution_context.cpp index 91ed58135102dc..f74e1bc2aeb151 100644 --- a/be/src/runtime/task_execution_context.cpp +++ b/be/src/runtime/task_execution_context.cpp @@ -21,6 +21,8 @@ #include +#include "runtime/runtime_state.h" + namespace doris { void TaskExecutionContext::ref_task_execution_ctx() { ++_has_task_execution_ctx_ref_count; diff --git a/be/src/runtime/task_execution_context.h b/be/src/runtime/task_execution_context.h index f84bcc0ceb1fd0..c7e972cc5b98e6 100644 --- a/be/src/runtime/task_execution_context.h +++ b/be/src/runtime/task_execution_context.h @@ -21,8 +21,6 @@ #include #include -#include "runtime/runtime_state.h" - namespace doris { class RuntimeState; diff --git a/be/src/storage/compaction/collection_statistics.cpp b/be/src/storage/compaction/collection_statistics.cpp index 16decc2b15f12b..b4e3120c500208 100644 --- a/be/src/storage/compaction/collection_statistics.cpp +++ b/be/src/storage/compaction/collection_statistics.cpp @@ -25,6 +25,7 @@ #include "exprs/vexpr_context.h" #include "exprs/vliteral.h" #include "exprs/vslot_ref.h" +#include "runtime/runtime_state.h" #include "storage/index/index_file_reader.h" #include "storage/index/index_reader_helper.h" #include "storage/index/inverted/analyzer/analyzer.h" diff --git a/be/src/storage/compaction/collection_statistics.h b/be/src/storage/compaction/collection_statistics.h index e51d5750db64d2..3fd7115c0d30ec 100644 --- a/be/src/storage/compaction/collection_statistics.h +++ b/be/src/storage/compaction/collection_statistics.h @@ -22,12 +22,13 @@ #include "common/be_mock_util.h" #include "exprs/vexpr_fwd.h" -#include "runtime/runtime_state.h" #include "storage/index/inverted/query/query_info.h" #include "storage/olap_common.h" #include "storage/predicate_collector.h" namespace doris { + +class RuntimeState; #include "common/compile_check_begin.h" namespace io { diff --git a/be/src/storage/index/ann/ann_topn_runtime.h b/be/src/storage/index/ann/ann_topn_runtime.h index 6d40a32b349f53..88a602c74cae24 100644 --- a/be/src/storage/index/ann/ann_topn_runtime.h +++ b/be/src/storage/index/ann/ann_topn_runtime.h @@ -44,8 +44,10 @@ #include "exprs/vexpr_context.h" #include "exprs/vexpr_fwd.h" #include "exprs/vslot_ref.h" -#include "runtime/runtime_state.h" +namespace doris { +class RuntimeState; +} // namespace doris namespace doris::segment_v2 { #include "common/compile_check_begin.h" struct AnnIndexStats; diff --git a/be/src/storage/rowset/rowset_reader_context.h b/be/src/storage/rowset/rowset_reader_context.h index e44733367c8441..1cf62ad77c58ec 100644 --- a/be/src/storage/rowset/rowset_reader_context.h +++ b/be/src/storage/rowset/rowset_reader_context.h @@ -24,7 +24,6 @@ #include "exprs/vexpr.h" #include "exprs/vexpr_context.h" #include "io/io_common.h" -#include "runtime/runtime_state.h" #include "storage/index/ann/ann_topn_runtime.h" #include "storage/olap_common.h" #include "storage/predicate/column_predicate.h" @@ -32,6 +31,8 @@ namespace doris { +class RuntimeState; + class RowCursor; class DeleteBitmap; class DeleteHandler;