[Pipeline](projection) Support projection on pipeline engine (#15220)

2022-12-21 15:47:29 +08:00
parent a447121fc3
commit af54299b26
16 changed files with 142 additions and 29 deletions
--- a/be/src/vec/exec/vtable_function_node.cpp
+++ b/be/src/vec/exec/vtable_function_node.cpp
@ -86,7 +86,13 @@ Status VTableFunctionNode::get_next(RuntimeState* state, Block* block, bool* eos
    if (need_more_input_data()) {
        while (_child_block.rows() == 0 && !_child_eos) {
            RETURN_IF_ERROR_AND_CHECK_SPAN(
-                    child(0)->get_next_after_projects(state, &_child_block, &_child_eos),
+                    child(0)->get_next_after_projects(
+                            state, &_child_block, &_child_eos,
+                            std::bind((Status(ExecNode::*)(RuntimeState*, vectorized::Block*,
+                                                           bool*)) &
+                                              ExecNode::get_next,
+                                      _children[0], std::placeholders::_1, std::placeholders::_2,
+                                      std::placeholders::_3)),
                    child(0)->get_next_span(), _child_eos);
        }
        if (_child_eos && _child_block.rows() == 0) {