update

apache · Nov 20, 2023 · 42b7206 · 42b7206
1 parent 25b7773
commit 42b7206
Show file tree

Hide file tree

Showing 5 changed files with 2 additions and 10 deletions.
diff --git a/be/src/pipeline/exec/exchange_sink_operator.h b/be/src/pipeline/exec/exchange_sink_operator.h
@@ -70,8 +70,6 @@ class ExchangeSinkQueueDependency final : public WriteDependency {
     ExchangeSinkQueueDependency(int id, int node_id)
             : WriteDependency(id, node_id, "ResultQueueDependency") {}
     ~ExchangeSinkQueueDependency() override = default;
-
-    void* shared_state() override { return nullptr; }
 };
 
 class BroadcastDependency final : public WriteDependency {
@@ -125,7 +123,6 @@ class LocalExchangeChannelDependency final : public WriteDependency {
     LocalExchangeChannelDependency(int id, int node_id)
             : WriteDependency(id, node_id, "LocalExchangeChannelDependency") {}
     ~LocalExchangeChannelDependency() override = default;
-    void* shared_state() override { return nullptr; }
     // TODO(gabriel): blocked by memory
 };
 

diff --git a/be/src/pipeline/exec/exchange_source_operator.h b/be/src/pipeline/exec/exchange_source_operator.h
@@ -56,7 +56,6 @@ struct ExchangeDataDependency final : public Dependency {
     ExchangeDataDependency(int id, int node_id,
                            vectorized::VDataStreamRecvr::SenderQueue* sender_queue)
             : Dependency(id, node_id, "DataDependency"), _always_done(false) {}
-    void* shared_state() override { return nullptr; }
 
     void set_always_done() {
         _always_done = true;

diff --git a/be/src/pipeline/exec/hashjoin_build_sink.h b/be/src/pipeline/exec/hashjoin_build_sink.h
@@ -52,8 +52,6 @@ class SharedHashTableDependency final : public WriteDependency {
     SharedHashTableDependency(int id, int node_id)
             : WriteDependency(id, node_id, "SharedHashTableDependency") {}
     ~SharedHashTableDependency() override = default;
-
-    void* shared_state() override { return nullptr; }
 };
 
 class HashJoinBuildSinkLocalState final

diff --git a/be/src/pipeline/exec/result_sink_operator.h b/be/src/pipeline/exec/result_sink_operator.h
@@ -49,8 +49,6 @@ class ResultSinkDependency final : public WriteDependency {
     ResultSinkDependency(int id, int node_id)
             : WriteDependency(id, node_id, "ResultSinkDependency") {}
     ~ResultSinkDependency() override = default;
-
-    void* shared_state() override { return nullptr; }
 };
 
 class ResultSinkLocalState final : public PipelineXSinkLocalState<> {

diff --git a/be/src/pipeline/exec/scan_operator.h b/be/src/pipeline/exec/scan_operator.h
@@ -62,8 +62,6 @@ class ScanDependency final : public Dependency {
     ScanDependency(int id, int node_id)
             : Dependency(id, node_id, "ScanDependency"), _scanner_ctx(nullptr) {}
 
-    void* shared_state() override { return nullptr; }
-
     // TODO(gabriel):
     [[nodiscard]] Dependency* read_blocked_by(PipelineXTask* task) override {
         if (_scanner_ctx && _scanner_ctx->get_num_running_scanners() == 0 &&
@@ -73,6 +71,8 @@ class ScanDependency final : public Dependency {
         return Dependency::read_blocked_by(task);
     }
 
+    bool push_to_blocking_queue() override { return true; }
+
     void block_reading() override {
         if (_eos) {
             return;