database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[pipelineX](refactor) remove source state from operator functions (#31435)

Browse Source
This commit is contained in:
Gabriel
2024-02-27 17:06:51 +08:00
committed by yiguolei
parent 7b3377d474
commit 2f6251ccde
78 changed files with 360 additions and 482 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
be/src/pipeline/exec/table_function_operator.cpp
View File

@ -144,8 +144,7 @@ bool TableFunctionLocalState::_is_inner_and_empty() {
}
Status TableFunctionLocalState::get_expanded_block(RuntimeState* state,
vectorized::Block* output_block,
SourceState& source_state) {
vectorized::Block* output_block, bool* eos) {
auto& p = _parent->cast<TableFunctionOperatorX>();
vectorized::MutableBlock m_block = vectorized::VectorizedUtils::build_mutable_mem_reuse_block(
output_block, p._output_slots);
@ -211,9 +210,7 @@ Status TableFunctionLocalState::get_expanded_block(RuntimeState* state,
RETURN_IF_ERROR(vectorized::VExprContext::filter_block(_conjuncts, output_block,
output_block->columns()));
if (_child_source_state == SourceState::FINISHED && _cur_child_offset == -1) {
source_state = SourceState::FINISHED;
}
*eos = _child_eos && _cur_child_offset == -1;
return Status::OK();
}