update

apache · Feb 27, 2024 · 63b5f92 · 63b5f92
1 parent 289aca7
commit 63b5f92
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 6 deletions.
diff --git a/be/src/pipeline/exec/union_source_operator.cpp b/be/src/pipeline/exec/union_source_operator.cpp
@@ -181,10 +181,6 @@ Status UnionSourceOperatorX::get_block(RuntimeState* state, vectorized::Block* b
     return Status::OK();
 }
 
-bool UnionSourceOperatorX::need_data_from_children(RuntimeState* state) const {
-    return !_has_data(state);
-}
-
 Status UnionSourceOperatorX::get_next_const(RuntimeState* state, vectorized::Block* block) {
     DCHECK_EQ(state->per_fragment_instance_idx(), 0);
     auto& local_state = state->get_local_state(operator_id())->cast<UnionSourceLocalState>();

diff --git a/be/src/pipeline/exec/union_source_operator.h b/be/src/pipeline/exec/union_source_operator.h
@@ -131,8 +131,6 @@ class UnionSourceOperatorX final : public OperatorX<UnionSourceLocalState> {
     }
     [[nodiscard]] int get_child_count() const { return _child_size; }
 
-    bool need_data_from_children(RuntimeState* state) const override;
-
 private:
     bool _has_data(RuntimeState* state) const {
         auto& local_state = state->get_local_state(operator_id())->cast<UnionSourceLocalState>();