diff --git a/be/src/vec/exec/runtime_filter_consumer.h b/be/src/vec/exec/runtime_filter_consumer.h index fcb6ed3c839f45..ead8ae4fc1ec95 100644 --- a/be/src/vec/exec/runtime_filter_consumer.h +++ b/be/src/vec/exec/runtime_filter_consumer.h @@ -54,7 +54,6 @@ class RuntimeFilterConsumer { // For runtime filters struct RuntimeFilterContext { - RuntimeFilterContext() : apply_mark(false), runtime_filter(nullptr) {} RuntimeFilterContext(IRuntimeFilter* rf) : apply_mark(false), runtime_filter(rf) {} // set to true if this runtime filter is already applied to vconjunct_ctx_ptr bool apply_mark; diff --git a/be/src/vec/exprs/vruntimefilter_wrapper.cpp b/be/src/vec/exprs/vruntimefilter_wrapper.cpp index 1d498f610000f1..968bad5fedb1ff 100644 --- a/be/src/vec/exprs/vruntimefilter_wrapper.cpp +++ b/be/src/vec/exprs/vruntimefilter_wrapper.cpp @@ -47,13 +47,6 @@ namespace doris::vectorized { VRuntimeFilterWrapper::VRuntimeFilterWrapper(const TExprNode& node, const VExprSPtr& impl) : VExpr(node), _impl(impl), _always_true(false), _filtered_rows(0), _scan_rows(0) {} -VRuntimeFilterWrapper::VRuntimeFilterWrapper(const VRuntimeFilterWrapper& vexpr) - : VExpr(vexpr), - _impl(vexpr._impl), - _always_true(vexpr._always_true), - _filtered_rows(vexpr._filtered_rows.load()), - _scan_rows(vexpr._scan_rows.load()) {} - Status VRuntimeFilterWrapper::prepare(RuntimeState* state, const RowDescriptor& desc, VExprContext* context) { RETURN_IF_ERROR_OR_PREPARED(_impl->prepare(state, desc, context)); @@ -71,10 +64,6 @@ void VRuntimeFilterWrapper::close(VExprContext* context, _impl->close(context, scope); } -bool VRuntimeFilterWrapper::is_constant() const { - return _impl->is_constant(); -} - Status VRuntimeFilterWrapper::execute(VExprContext* context, Block* block, int* result_column_id) { if (_always_true) { auto res_data_column = ColumnVector::create(block->rows(), 1); diff --git a/be/src/vec/exprs/vruntimefilter_wrapper.h b/be/src/vec/exprs/vruntimefilter_wrapper.h index 288ad831a73c73..642e669288f55b 100644 --- a/be/src/vec/exprs/vruntimefilter_wrapper.h +++ b/be/src/vec/exprs/vruntimefilter_wrapper.h @@ -45,14 +45,12 @@ class VRuntimeFilterWrapper final : public VExpr { public: VRuntimeFilterWrapper(const TExprNode& node, const VExprSPtr& impl); - VRuntimeFilterWrapper(const VRuntimeFilterWrapper& vexpr); ~VRuntimeFilterWrapper() override = default; Status execute(VExprContext* context, Block* block, int* result_column_id) override; Status prepare(RuntimeState* state, const RowDescriptor& desc, VExprContext* context) override; Status open(RuntimeState* state, VExprContext* context, FunctionContext::FunctionStateScope scope) override; std::string debug_string() const override { return _impl->debug_string(); } - bool is_constant() const override; void close(VExprContext* context, FunctionContext::FunctionStateScope scope) override; const std::string& expr_name() const override; const VExprSPtrs& children() const override { return _impl->children(); }