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

[CP] fix window func ndv bug

Browse Source
This commit is contained in:
akaError
2024-04-07 02:50:40 +00:00
committed by ob-robot
parent cbd974b7b6
commit 2faf43844b
1 changed files with 15 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
src/sql/optimizer/ob_opt_selectivity.cpp
View File

@ -2404,8 +2404,21 @@ int ObOptSelectivity::calculate_special_ndv(const OptTableMetas &table_metas,
}
} else if (T_FUN_MIN == win_expr->get_func_type()||
T_FUN_MEDIAN == win_expr->get_func_type()||
T_WIN_FUN_MAX == win_expr->get_func_type() ||
T_WIN_FUN_NTH_VALUE == win_expr->get_func_type() ||
T_FUN_MAX == win_expr->get_func_type()) {
ObSEArray<ObRawExpr *, 4> param_exprs;
ObAggFunRawExpr* aggr_expr = win_expr->get_agg_expr();
double param_ndv = 1.0;
if (OB_ISNULL(aggr_expr)) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("unexpected null pointer", K(aggr_expr), K(ret));
} else if (OB_FAIL(param_exprs.assign(aggr_expr->get_real_param_exprs()))) {
LOG_WARN("fail to assign exprs", K(ret));
} else if (OB_FAIL(SMART_CALL(calculate_distinct(table_metas, ctx, param_exprs, origin_rows, param_ndv, false)))) {
LOG_WARN("failed to calculate_distinct", K(ret));
} else {
special_ndv = std::min(part_order_ndv, param_ndv);
}
} else if (T_WIN_FUN_NTH_VALUE == win_expr->get_func_type() ||
T_WIN_FUN_FIRST_VALUE == win_expr->get_func_type() ||
T_WIN_FUN_LAST_VALUE == win_expr->get_func_type()) {
ObSEArray<ObRawExpr *, 4> param_exprs;