This is an automated email from the ASF dual-hosted git repository.
jacktengg pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 10697d0d1d9 [chore](join) delete code that's useless (#37016)
10697d0d1d9 is described below
commit 10697d0d1d9d9e5002fa28bb2687dc6b298e2b5c
Author: TengJianPing <18241664+jackte...@users.noreply.github.com>
AuthorDate: Thu Jul 4 10:32:47 2024 +0800
[chore](join) delete code that's useless (#37016)
---
be/src/pipeline/exec/hashjoin_probe_operator.cpp | 9 ---------
be/src/pipeline/exec/hashjoin_probe_operator.h | 2 --
2 files changed, 11 deletions(-)
diff --git a/be/src/pipeline/exec/hashjoin_probe_operator.cpp
b/be/src/pipeline/exec/hashjoin_probe_operator.cpp
index 17493d07983..374cf506861 100644
--- a/be/src/pipeline/exec/hashjoin_probe_operator.cpp
+++ b/be/src/pipeline/exec/hashjoin_probe_operator.cpp
@@ -160,14 +160,6 @@ bool
HashJoinProbeLocalState::_need_probe_null_map(vectorized::Block& block,
return false;
}
-void HashJoinProbeLocalState::init_for_probe(RuntimeState* state) {
- if (_probe_inited) {
- return;
- }
-
- _probe_inited = true;
-}
-
void HashJoinProbeLocalState::add_tuple_is_null_column(vectorized::Block*
block) {
DCHECK(_parent->cast<HashJoinProbeOperatorX>()._is_outer_join);
if (!_parent->cast<HashJoinProbeOperatorX>()._use_specific_projections) {
@@ -235,7 +227,6 @@ HashJoinProbeOperatorX::HashJoinProbeOperatorX(ObjectPool*
pool, const TPlanNode
Status HashJoinProbeOperatorX::pull(doris::RuntimeState* state,
vectorized::Block* output_block,
bool* eos) const {
auto& local_state = get_local_state(state);
- local_state.init_for_probe(state);
SCOPED_TIMER(local_state._probe_timer);
if (local_state._shared_state->short_circuit_for_probe) {
// If we use a short-circuit strategy, should return empty block
directly.
diff --git a/be/src/pipeline/exec/hashjoin_probe_operator.h
b/be/src/pipeline/exec/hashjoin_probe_operator.h
index 0b4298f55ff..c1a53c0c1f3 100644
--- a/be/src/pipeline/exec/hashjoin_probe_operator.h
+++ b/be/src/pipeline/exec/hashjoin_probe_operator.h
@@ -57,7 +57,6 @@ public:
void prepare_for_next();
void add_tuple_is_null_column(vectorized::Block* block) override;
- void init_for_probe(RuntimeState* state);
Status filter_data_and_build_output(RuntimeState* state,
vectorized::Block* output_block,
bool* eos, vectorized::Block*
temp_block,
bool check_rows_count = true);
@@ -92,7 +91,6 @@ private:
uint32_t _build_index = 0;
bool _ready_probe = false;
bool _probe_eos = false;
- std::atomic<bool> _probe_inited = false;
int _last_probe_match;
// For mark join, last probe index of null mark
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
