hcq/oceanbase
hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

TOPK operator not implement for material in static type engine

Browse Source
This commit is contained in:
bx0 2022-03-11 16:07:16 +08:00 committed by LINxiansheng
parent 9596e12cf9
commit 6d4f2da966
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/sql/engine/basic/ob_topk_op.cpp
View File

@ -14,6 +14,7 @@
#include "sql/engine/basic/ob_topk_op.h"
#include "sql/engine/basic/ob_limit_op.h"
#include "sql/engine/sort/ob_sort_op.h"
#include "sql/engine/basic/ob_material_op.h"
#include "sql/engine/aggregate/ob_hash_groupby_op.h"
namespace oceanbase {
@ -101,15 +102,15 @@ int ObTopKOp::get_topk_final_count()
ObPhyOperatorType op_type = child_->get_spec().get_type();
switch (op_type) {
case PHY_SORT: {
ObSortOp* sort_op = static_cast<ObSortOp*>(child_);
if (OB_FAIL(row_count = sort_op->get_sort_row_count())) {
LOG_WARN("get sort row count failed", K(ret));
}
ObSortOp *sort_op = static_cast<ObSortOp *>(child_);
row_count = sort_op->get_sort_row_count();
break;
}
case PHY_MATERIAL: {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("material not implimented yet", K(ret));
ObMaterialOp *mtrl_op = static_cast<ObMaterialOp *>(child_);
if (OB_FAIL(mtrl_op->get_material_row_count(row_count))) {
LOG_WARN("get material row count failed", K(ret));
}
break;
}
case PHY_HASH_GROUP_BY: {