[performance](pipelineX) optimize pipelineX (#25713)

2023-10-25 10:13:17 +08:00
parent 6b2eed779c
commit 552091f21f
88 changed files with 507 additions and 485 deletions
--- a/be/src/pipeline/exec/table_function_operator.cpp
+++ b/be/src/pipeline/exec/table_function_operator.cpp
@ -243,8 +243,8 @@ Status TableFunctionLocalState::process_next_child_row() {
 }

 TableFunctionOperatorX::TableFunctionOperatorX(ObjectPool* pool, const TPlanNode& tnode,
-                                               const DescriptorTbl& descs)
-        : Base(pool, tnode, descs) {}
+                                               int operator_id, const DescriptorTbl& descs)
+        : Base(pool, tnode, operator_id, descs) {}

 Status TableFunctionOperatorX::_prepare_output_slot_ids(const TPlanNode& tnode) {
    // Prepare output slot ids