fix some typo error
This commit is contained in:
@ -140,7 +140,7 @@ namespace sql
|
|||||||
ObRelIds R_TES_;
|
ObRelIds R_TES_;
|
||||||
//left degenerate set,用于检查join condition为退化谓词的合法性,存放的是左子树的所有表集
|
//left degenerate set,用于检查join condition为退化谓词的合法性,存放的是左子树的所有表集
|
||||||
ObRelIds L_DS_;
|
ObRelIds L_DS_;
|
||||||
//right degnerate set,存放的是右子树的所有表集
|
//right degenerate set,存放的是右子树的所有表集
|
||||||
ObRelIds R_DS_;
|
ObRelIds R_DS_;
|
||||||
bool is_degenerate_pred_;
|
bool is_degenerate_pred_;
|
||||||
//当前join是否可交换左右表
|
//当前join是否可交换左右表
|
||||||
@ -1674,7 +1674,7 @@ struct NullAwareAntiJoinInfo {
|
|||||||
bool &sort_match);
|
bool &sort_match);
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 检查是否是intersting order
|
* 检查是否是interesting order
|
||||||
* @keys 索引列
|
* @keys 索引列
|
||||||
* @stmt
|
* @stmt
|
||||||
* @interest_column_ids 匹配的索引列的id
|
* @interest_column_ids 匹配的索引列的id
|
||||||
|
|||||||
@ -455,7 +455,7 @@ int ObLogInsert::generate_multi_part_partition_id_expr()
|
|||||||
ObRawExprCopier copier(get_plan()->get_optimizer_context().get_expr_factory());
|
ObRawExprCopier copier(get_plan()->get_optimizer_context().get_expr_factory());
|
||||||
if (OB_ISNULL(index_info)) {
|
if (OB_ISNULL(index_info)) {
|
||||||
ret = OB_ERR_UNEXPECTED;
|
ret = OB_ERR_UNEXPECTED;
|
||||||
LOG_WARN("replae dml info is null", K(ret));
|
LOG_WARN("replace dml info is null", K(ret));
|
||||||
} else if (OB_FAIL(generate_old_calc_partid_expr(*index_info))) {
|
} else if (OB_FAIL(generate_old_calc_partid_expr(*index_info))) {
|
||||||
LOG_WARN("failed to generate calc partid expr", K(ret));
|
LOG_WARN("failed to generate calc partid expr", K(ret));
|
||||||
} else if (!is_heap_table && OB_FAIL(ObLogTableScan::replace_gen_column(get_plan(),
|
} else if (!is_heap_table && OB_FAIL(ObLogTableScan::replace_gen_column(get_plan(),
|
||||||
@ -478,7 +478,7 @@ int ObLogInsert::generate_multi_part_partition_id_expr()
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
} else if (get_insert_up()) {
|
} else if (get_insert_up()) {
|
||||||
// generate the calc_part_id_expr_ of update caluse
|
// generate the calc_part_id_expr_ of update clause
|
||||||
for (int64_t i = 0; OB_SUCC(ret) && i < get_insert_up_index_dml_infos().count(); ++i) {
|
for (int64_t i = 0; OB_SUCC(ret) && i < get_insert_up_index_dml_infos().count(); ++i) {
|
||||||
IndexDMLInfo *dml_info = get_insert_up_index_dml_infos().at(i);
|
IndexDMLInfo *dml_info = get_insert_up_index_dml_infos().at(i);
|
||||||
ObSqlSchemaGuard *schema_guard = NULL;
|
ObSqlSchemaGuard *schema_guard = NULL;
|
||||||
|
|||||||
@ -344,7 +344,7 @@ int ObLogUnpivot::compute_fd_item_set()
|
|||||||
/*do nothing*/
|
/*do nothing*/
|
||||||
} else if (OB_NOT_NULL(fd_item_set) && // rollup 时 fd_item_set is null
|
} else if (OB_NOT_NULL(fd_item_set) && // rollup 时 fd_item_set is null
|
||||||
OB_FAIL(deduce_const_exprs_and_ft_item_set(*fd_item_set))) {
|
OB_FAIL(deduce_const_exprs_and_ft_item_set(*fd_item_set))) {
|
||||||
LOG_WARN("falied to deduce fd item set", K(ret));
|
LOG_WARN("failed to deduce fd item set", K(ret));
|
||||||
} else {
|
} else {
|
||||||
set_fd_item_set(fd_item_set);
|
set_fd_item_set(fd_item_set);
|
||||||
}
|
}
|
||||||
|
|||||||
@ -208,7 +208,7 @@ public:
|
|||||||
static bool same_exprs(const common::ObIArray<ObRawExpr*> &src_exprs,
|
static bool same_exprs(const common::ObIArray<ObRawExpr*> &src_exprs,
|
||||||
const common::ObIArray<ObRawExpr*> &target_exprs);
|
const common::ObIArray<ObRawExpr*> &target_exprs);
|
||||||
|
|
||||||
//for topk, non terminal expr with agg params need to be deep copyed to prevent sum being replaced
|
//for topk, non terminal expr with agg params need to be deep copied to prevent sum being replaced
|
||||||
//with sum(sum)
|
//with sum(sum)
|
||||||
static int clone_expr_for_topk(ObRawExprFactory &expr_factory, ObRawExpr* src, ObRawExpr* &dst);
|
static int clone_expr_for_topk(ObRawExprFactory &expr_factory, ObRawExpr* src, ObRawExpr* &dst);
|
||||||
|
|
||||||
@ -1592,7 +1592,7 @@ int ObOptimizerUtil::intersect(const ObIArray<T> &first,
|
|||||||
/**
|
/**
|
||||||
* @brief intersect, to reduce the assign cost when computing many sets' overlap.
|
* @brief intersect, to reduce the assign cost when computing many sets' overlap.
|
||||||
* @param sets the element sets to calculate the overlap.
|
* @param sets the element sets to calculate the overlap.
|
||||||
* @param result the reuslt of the overlap
|
* @param result the result of the overlap
|
||||||
* @return
|
* @return
|
||||||
*/
|
*/
|
||||||
template <class T>
|
template <class T>
|
||||||
|
|||||||
@ -114,7 +114,7 @@ int ObShardingInfo::init_partition_info(ObOptimizerContext &ctx,
|
|||||||
}
|
}
|
||||||
// virtual table can't get part idx from mock list table schema
|
// virtual table can't get part idx from mock list table schema
|
||||||
// so don't call extract_all_partition_indexes,
|
// so don't call extract_all_partition_indexes,
|
||||||
// and not used pwj enhence on virtual table
|
// and not used pwj enhance on virtual table
|
||||||
if (is_virtual_table(ref_table_id)) {
|
if (is_virtual_table(ref_table_id)) {
|
||||||
// do nothing
|
// do nothing
|
||||||
} else if (OB_FAIL(ObPwjComparer::extract_all_partition_indexes(phy_table_location_info,
|
} else if (OB_FAIL(ObPwjComparer::extract_all_partition_indexes(phy_table_location_info,
|
||||||
@ -160,7 +160,7 @@ int ObShardingInfo::set_partition_key(
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
} else if (OB_FAIL(partition_keys.push_back(part_expr))) {
|
} else if (OB_FAIL(partition_keys.push_back(part_expr))) {
|
||||||
LOG_WARN("Failed to add partiton column expr", K(ret));
|
LOG_WARN("Failed to add partition column expr", K(ret));
|
||||||
} else { }
|
} else { }
|
||||||
}
|
}
|
||||||
return ret;
|
return ret;
|
||||||
@ -471,7 +471,7 @@ int ObShardingInfo::check_if_match_partition_wise(const EqualSets &equal_sets,
|
|||||||
is_partition_wise))) {
|
is_partition_wise))) {
|
||||||
LOG_WARN("failed to check if match partition wise join", K(ret));
|
LOG_WARN("failed to check if match partition wise join", K(ret));
|
||||||
} else if (is_partition_wise) {
|
} else if (is_partition_wise) {
|
||||||
LOG_TRACE("suceed to check if match partition wise join", K(is_partition_wise));
|
LOG_TRACE("succeed to check if match partition wise join", K(is_partition_wise));
|
||||||
} else if (OB_FAIL(append(left_sharding, left_weak_sharding)) ||
|
} else if (OB_FAIL(append(left_sharding, left_weak_sharding)) ||
|
||||||
OB_FAIL(append(right_sharding, right_weak_sharding))) {
|
OB_FAIL(append(right_sharding, right_weak_sharding))) {
|
||||||
LOG_WARN("failed to append sharding info", K(ret));
|
LOG_WARN("failed to append sharding info", K(ret));
|
||||||
@ -546,7 +546,7 @@ int ObShardingInfo::check_if_match_extended_partition_wise(const EqualSets &equa
|
|||||||
is_ext_partition_wise))) {
|
is_ext_partition_wise))) {
|
||||||
LOG_WARN("failed to check if match extended partition wise join", K(ret));
|
LOG_WARN("failed to check if match extended partition wise join", K(ret));
|
||||||
} else if (is_ext_partition_wise) {
|
} else if (is_ext_partition_wise) {
|
||||||
LOG_TRACE("suceed to check if match extended partition wise join", K(is_ext_partition_wise));
|
LOG_TRACE("succeed to check if match extended partition wise join", K(is_ext_partition_wise));
|
||||||
} else if (OB_FAIL(append(left_sharding, left_weak_sharding)) ||
|
} else if (OB_FAIL(append(left_sharding, left_weak_sharding)) ||
|
||||||
OB_FAIL(append(right_sharding, right_weak_sharding))) {
|
OB_FAIL(append(right_sharding, right_weak_sharding))) {
|
||||||
LOG_WARN("failed to append sharding info", K(ret));
|
LOG_WARN("failed to append sharding info", K(ret));
|
||||||
|
|||||||
Reference in New Issue
Block a user