diff --git a/src/sql/engine/window_function/ob_window_function_op.cpp b/src/sql/engine/window_function/ob_window_function_op.cpp index 98de76525..665a8b529 100644 --- a/src/sql/engine/window_function/ob_window_function_op.cpp +++ b/src/sql/engine/window_function/ob_window_function_op.cpp @@ -70,7 +70,9 @@ OB_SERIALIZE_MEMBER((ObWindowFunctionSpec, ObOpSpec), rd_sort_cmp_funcs_, rd_pby_sort_cnt_, role_type_, - wf_aggr_status_expr_); + wf_aggr_status_expr_, + input_rows_mem_bound_ratio_, + estimated_part_cnt_); OB_SERIALIZE_MEMBER(ObWindowFunctionOpInput, local_task_count_, total_task_count_, wf_participator_shared_info_); diff --git a/src/sql/engine/window_function/ob_window_function_op.h b/src/sql/engine/window_function/ob_window_function_op.h index 7f4ac1138..0d44232fe 100644 --- a/src/sql/engine/window_function/ob_window_function_op.h +++ b/src/sql/engine/window_function/ob_window_function_op.h @@ -227,7 +227,9 @@ public: rd_sort_cmp_funcs_(alloc), rd_pby_sort_cnt_(0), role_type_(0), - wf_aggr_status_expr_(NULL) + wf_aggr_status_expr_(NULL), + input_rows_mem_bound_ratio_(0.5), + estimated_part_cnt_(1) { } DECLARE_VIRTUAL_TO_STRING; @@ -288,6 +290,9 @@ public: int64_t rd_pby_sort_cnt_; int64_t role_type_; ObExpr *wf_aggr_status_expr_; + // The percentage of memory used by input_rows to the total memory used by input_rows and res_rows + double input_rows_mem_bound_ratio_; + int64_t estimated_part_cnt_; private: // disallow copy