1#ifndef ITEM_SUM_INCLUDED
2#define ITEM_SUM_INCLUDED
53#include "mysqld_error.h"
569 if (item ==
nullptr)
return nullptr;
593 bool eq(
const Item *item,
bool binary_cmp)
const override;
787 snprintf(buff,
sizeof(buff),
"%s as window function",
func_name());
900 void clear()
override;
902 void endup()
override;
995 return static_cast<double>(
val_int());
1039 void clear()
override;
1040 bool add()
override;
1060 void clear()
override;
1061 bool add()
override;
1136 pointer_cast<Check_function_as_value_generator_parameters *>(args);
1200 return "sum_bit_field";
1223 template <
typename... Args>
1225 Args &&... parent_args);
1261 const char *
func_name()
const override {
return "json_arrayagg"; }
1262 void clear()
override;
1263 bool add()
override;
1297 const char *
func_name()
const override {
return "json_objectagg"; }
1298 void clear()
override;
1299 bool add()
override;
1323 void clear()
override;
1324 bool add()
override;
1362 return "variance_field";
1366 pointer_cast<Check_function_as_value_generator_parameters *>(args);
1460 void clear()
override;
1461 bool add()
override;
1469 return sample ?
"var_samp" :
"variance";
1497 pointer_cast<Check_function_as_value_generator_parameters *>(args);
1517 return sample ?
"stddev_samp" :
"std";
1655 void clear()
override;
1681 bool add()
override;
1831 void clear()
override;
1853 bool add()
override;
1908 const char *
func_name()
const override {
return "bit_and"; }
1920 const char *
func_name()
const override {
return "bit_xor"; }
1955 if (
udf.
fix_fields(thd,
this, this->arg_count, this->args))
return true;
1961 void clear()
override;
1962 bool add()
override;
2031 const char *end_not_used;
2035 &end_not_used, &err_not_used)
2046 return cs->cset->strtoll10(
cs, res->
ptr(), &
end, &err_not_used);
2164 const char *
func_name()
const override {
return "group_concat"; }
2167 void clear()
override;
2168 bool add()
override;
2179 const char *end_ptr = res->
ptr() + res->
length();
2207 context = pointer_cast<Item_ident::Change_context *>(arg)->m_context;
2271 const char *
func_name()
const override {
return "row_number"; }
2284 void clear()
override;
2319 return m_dense ?
"dense_rank" :
"rank";
2342 void clear()
override;
2355 const char *
func_name()
const override {
return "cume_dist"; }
2396 const char *
func_name()
const override {
return "percent_rank"; }
2408 void clear()
override;
2498 void clear()
override;
2567 return m_is_first ?
"first_value" :
"last_value";
2575 void clear()
override;
2636 const char *
func_name()
const override {
return "nth_value"; }
2643 void clear()
override;
2694 const char *
func_name()
const override {
return "grouping"; }
2713 :
Item_sum((*sum_func_per_level)[0]),
2715 args = (*THR_MALLOC)->ArrayAlloc<
Item *>(sum_func_per_level->
size());
2717 for (
Item &item : *sum_func_per_level) {
2736 const char *
func_name()
const override {
return "rollup_sum_switcher"; }
2753 void clear()
override;
2777 Item *ret =
nullptr;
2796 return down_cast<Item_sum *>(
args[i]);
2841 return aggr ? false :
true;
2859 bool add()
override;
2864 void clear()
override;
2865 const char *
func_name()
const override {
return "st_collect"; }
The distinct aggregator.
Definition: item_sum.h:802
uint tree_key_length
Definition: item_sum.h:855
uint32 * field_lengths
Definition: item_sum.h:832
bool arg_is_null(bool use_null_value) override
NULLness of being-aggregated argument.
Definition: item_sum.cc:2147
bool endup_done
Definition: item_sum.h:813
Const_distinct
Definition: item_sum.h:857
@ CONST_NULL
Set to true if the result is known to be always NULL.
Definition: item_sum.h:868
@ CONST_NOT_NULL
Set to true if count distinct is on only const items.
Definition: item_sum.h:875
@ NOT_CONST
Definition: item_sum.h:858
static int composite_key_cmp(const void *arg, const void *a, const void *b)
Correctly compare composite keys.
Definition: item_sum.cc:954
void endup() override
Calculate the aggregate function value.
Definition: item_sum.cc:1326
~Aggregator_distinct() override
Definition: item_sum.cc:2097
bool use_distinct_values
When feeding back the data in endup() from Unique/temp table back to Item_sum::add() methods we must ...
Definition: item_sum.h:886
double arg_val_real() override
Floating point value of being-aggregated argument.
Definition: item_sum.cc:2142
void clear() override
Invalidate calculated value and clear the distinct rows.
Definition: item_sum.cc:1225
bool setup(THD *) override
Called before feeding the first row.
Definition: item_sum.cc:1025
bool unique_walk_function(void *element)
Aggregate a distinct row from the distinct hash table.
Definition: item_sum.cc:2090
Unique * tree
Definition: item_sum.h:847
Temp_table_param * tmp_table_param
Definition: item_sum.h:838
bool add() override
Process incoming row.
Definition: item_sum.cc:1257
TABLE * table
Definition: item_sum.h:824
Aggregator_type Aggrtype() override
Definition: item_sum.h:897
my_decimal * arg_val_decimal(my_decimal *value) override
Decimal value of being-aggregated argument.
Definition: item_sum.cc:2137
enum Aggregator_distinct::Const_distinct const_distinct
Aggregator_distinct(Item_sum *sum)
Definition: item_sum.h:889
The pass-through aggregator.
Definition: item_sum.h:916
void clear() override
Called when we need to wipe out all the data from the aggregator: all the values accumulated and all ...
Definition: item_sum.h:922
Aggregator_simple(Item_sum *sum)
Definition: item_sum.h:918
bool setup(THD *thd) override
Called before adding the first row.
Definition: item_sum.h:921
Aggregator_type Aggrtype() override
Definition: item_sum.h:919
my_decimal * arg_val_decimal(my_decimal *value) override
Decimal value of being-aggregated argument.
Definition: item_sum.cc:2114
void endup() override
Called when there are no more data and the final value is to be retrieved.
Definition: item_sum.h:924
double arg_val_real() override
Floating point value of being-aggregated argument.
Definition: item_sum.cc:2118
bool add() override
Called when there's a new value to be aggregated.
Definition: item_sum.h:923
bool arg_is_null(bool use_null_value) override
NULLness of being-aggregated argument.
Definition: item_sum.cc:2122
The abstract base class for the Aggregator_* classes.
Definition: item_sum.h:100
Item_sum * item_sum
Definition: item_sum.h:112
virtual bool arg_is_null(bool use_null_value)=0
NULLness of being-aggregated argument.
Aggregator_type
Definition: item_sum.h:118
@ SIMPLE_AGGREGATOR
Definition: item_sum.h:118
@ DISTINCT_AGGREGATOR
Definition: item_sum.h:118
virtual bool add()=0
Called when there's a new value to be aggregated.
virtual void endup()=0
Called when there are no more data and the final value is to be retrieved.
virtual Aggregator_type Aggrtype()=0
virtual ~Aggregator()=default
virtual my_decimal * arg_val_decimal(my_decimal *value)=0
Decimal value of being-aggregated argument.
virtual void clear()=0
Called when we need to wipe out all the data from the aggregator: all the values accumulated and all ...
Aggregator(Item_sum *arg)
Definition: item_sum.h:115
virtual double arg_val_real()=0
Floating point value of being-aggregated argument.
virtual bool setup(THD *)=0
Called before adding the first row.
Definition: item_cmpfunc.h:139
void set(const DTCollation &dt)
Definition: item.h:193
Definition: item_sum.h:1166
const char * func_name() const override
Definition: item_sum.h:1176
uint prec_increment
Definition: item_sum.h:1169
uint f_precision
Definition: item_sum.h:1168
uint dec_bin_size
Definition: item_sum.h:1168
uint f_scale
Definition: item_sum.h:1168
my_decimal * val_decimal(my_decimal *) override
Definition: item_sum.cc:3687
String * val_str(String *) override
Definition: item_sum.cc:3702
bool resolve_type(THD *) override
Resolve type-related information for this item, such as result field type, maximum size,...
Definition: item_sum.h:1175
enum Type type() const override
Definition: item_sum.h:1171
double val_real() override
Definition: item_sum.cc:3672
Item_avg_field(Item_result res_type, Item_sum_avg *item)
Definition: item_sum.cc:3653
CUME_DIST window function, cf.
Definition: item_sum.h:2349
Item_cume_dist(const POS &pos, PT_window *w)
Definition: item_sum.h:2353
Item_non_framing_wf super
Definition: item_sum.h:2350
double val_real() override
Definition: item_sum.cc:4859
enum Sumfunctype sum_func() const override
Definition: item_sum.h:2356
void clear() override
Definition: item_sum.h:2367
const char * func_name() const override
Definition: item_sum.h:2355
bool needs_partition_cardinality() const override
Return true if we need to make two passes over the rows in the partition - either because we need the...
Definition: item_sum.h:2366
String * val_str(String *) override
Definition: item_sum.cc:4879
bool check_wf_semantics1(THD *thd, Query_block *select, Window_evaluation_requirements *reqs) override
Only relevant for aggregates qua window functions.
Definition: item_sum.cc:4849
longlong val_int() override
Definition: item_sum.cc:4871
bool resolve_type(THD *thd) override
Resolve type-related information for this item, such as result field type, maximum size,...
Definition: item_sum.h:2358
my_decimal * val_decimal(my_decimal *buffer) override
Definition: item_sum.cc:4883
Item_result result_type() const override
Definition: item_sum.h:2372
FIRST_VALUE/LAST_VALUE window functions, cf.
Definition: item_sum.h:2548
enum Sumfunctype sum_func() const override
Definition: item_sum.h:2570
bool resolve_type(THD *thd) override
Resolve type-related information for this item, such as result field type, maximum size,...
Definition: item_sum.cc:5083
void reset_field() override
Definition: item_sum.h:2589
const char * func_name() const override
Definition: item_sum.h:2566
bool setup_first_last()
Definition: item_sum.cc:5120
double val_real() override
Definition: item_sum.cc:5169
String * val_str(String *str) override
Definition: item_sum.cc:5224
void update_after_wf_arguments_changed(THD *thd) override
Signal to the function that its arguments may have changed, and that any internal caches etc.
Definition: item_sum.cc:5137
bool check_wf_semantics1(THD *thd, Query_block *select, Window_evaluation_requirements *reqs) override
Only relevant for aggregates qua window functions.
Definition: item_sum.cc:5069
bool compute()
Core logic of FIRST/LAST_VALUE window functions.
Definition: item_sum.cc:5141
int64 cnt
used when evaluating on-the-fly (non-buffered processing)
Definition: item_sum.h:2553
Item_result m_hybrid_type
Definition: item_sum.h:2551
enum Item_result result_type() const override
Definition: item_sum.h:2578
Item_cache * m_value
Definition: item_sum.h:2552
bool val_json(Json_wrapper *wr) override
Get a JSON value from an Item.
Definition: item_sum.cc:5200
void update_field() override
Definition: item_sum.h:2590
enum_null_treatment m_null_treatment
Definition: item_sum.h:2550
Item_sum super
Definition: item_sum.h:2554
void clear() override
Definition: item_sum.cc:5131
bool uses_only_one_row() const override
Only for framing window functions.
Definition: item_sum.h:2598
void split_sum_func(THD *thd, Ref_item_array ref_item_array, mem_root_deque< Item * > *fields) override
See comments in Item_cmp_func::split_sum_func()
Definition: item_sum.cc:5112
bool add() override
Definition: item_sum.h:2591
Item_first_last_value(const POS &pos, bool first, Item *a, enum_null_treatment null_treatment, PT_window *w)
Definition: item_sum.h:2557
bool m_is_first
if true, the function is FIRST_VALUE, else LAST_VALUE
Definition: item_sum.h:2549
longlong val_int() override
Definition: item_sum.cc:5159
my_decimal * val_decimal(my_decimal *decimal_buffer) override
Definition: item_sum.cc:5210
bool get_time(MYSQL_TIME *ltime) override
Definition: item_sum.cc:5190
bool fix_fields(THD *thd, Item **items) override
Definition: item_sum.cc:5093
bool get_date(MYSQL_TIME *ltime, my_time_flags_t fuzzydate) override
Definition: item_sum.cc:5179
Definition: item_sum.h:2093
void clear() override
Definition: item_sum.cc:4349
bool m_result_finalized
True if result has been written to output buffer.
Definition: item_sum.h:2134
String result
Definition: item_sum.h:2110
Item_func_group_concat * original
Following is 0 normal object and pointer to original one for copy (to correctly free resources)
Definition: item_sum.h:2139
longlong val_int() override
Definition: item_sum.h:2175
const String * get_separator_str() const noexcept
Definition: item_sum.h:2193
uint32_t get_group_concat_max_len() const noexcept
Definition: item_sum.h:2194
my_decimal * val_decimal(my_decimal *decimal_value) override
Definition: item_sum.h:2182
friend int dump_leaf_key(void *key_arg, element_count count, void *item_arg)
Append data from current leaf to item->result.
Definition: item_sum.cc:4095
uint row_count
Definition: item_sum.h:2125
void make_unique() override
Definition: item_sum.cc:4624
bool change_context_processor(uchar *arg) override
Definition: item_sum.h:2206
bool setup(THD *thd) override
Definition: item_sum.cc:4502
bool itemize(Parse_context *pc, Item **res) override
The same as contextualize() but with additional parameter.
Definition: item_sum.cc:4223
Item_sum super
Definition: item_sum.h:2094
bool distinct
True if GROUP CONCAT has the DISTINCT attribute.
Definition: item_sum.h:2097
TABLE * table
Temporary table used to perform group concat.
Definition: item_sum.h:2123
friend int group_concat_key_cmp_with_distinct(const void *arg, const void *key1, const void *key2)
Compares the values for fields in expr list of GROUP_CONCAT.
Definition: item_sum.cc:4017
double val_real() override
Definition: item_sum.cc:4632
enum Sumfunctype sum_func() const override
Definition: item_sum.h:2163
String * val_str(String *str) override
Definition: item_sum.cc:4639
friend int group_concat_key_cmp_with_order(const void *arg, const void *key1, const void *key2)
function of sort for syntax: GROUP_CONCAT(expr,... ORDER BY col,... )
Definition: item_sum.cc:4052
bool force_copy_fields
Definition: item_sum.h:2132
bool fix_fields(THD *, Item **) override
Definition: item_sum.cc:4410
bool get_date(MYSQL_TIME *ltime, my_time_flags_t fuzzydate) override
Definition: item_sum.h:2185
Unique * unique_filter
If DISTINCT is used with this GROUP_CONCAT, this member is used to filter out duplicates.
Definition: item_sum.h:2121
bool check_wf_semantics1(THD *, Query_block *, Window_evaluation_requirements *) override
Only relevant for aggregates qua window functions.
Definition: item_sum.h:2211
void no_rows_in_result() override
Mark an aggregate as having no rows.
Definition: item_sum.cc:4347
Mem_root_array< ORDER > order_array
Definition: item_sum.h:2124
TREE tree_base
Definition: item_sum.h:2111
void update_field() override
Definition: item_sum.h:2170
void print(const THD *thd, String *str, enum_query_type query_type) const override
This method is used for to:
Definition: item_sum.cc:4664
bool always_null
True if the result is always NULL.
Definition: item_sum.h:2099
Temp_table_param * tmp_table_param
Describes the temporary table used to perform group concat.
Definition: item_sum.h:2109
void cleanup() override
Called for every Item after use (preparation and execution).
Definition: item_sum.cc:4276
Item * copy_or_same(THD *thd) override
Definition: item_sum.cc:4339
const char * func_name() const override
Definition: item_sum.h:2164
Item_result result_type() const override
Definition: item_sum.h:2165
Field * make_string_field(TABLE *table_arg) const override
Create a field to hold a string value from an item.
Definition: item_sum.cc:4306
uint m_order_arg_count
The number of ORDER BY items.
Definition: item_sum.h:2101
TREE * tree
Definition: item_sum.h:2112
Item_func_group_concat(const POS &pos, bool is_distinct, PT_item_list *select_list, PT_order_list *opt_order_list, String *separator, PT_window *w)
Constructor of Item_func_group_concat.
Definition: item_sum.cc:4185
bool has_distinct() const noexcept
Definition: item_sum.h:2192
bool add() override
Definition: item_sum.cc:4361
Name_resolution_context * context
Resolver context, points to containing query block.
Definition: item_sum.h:2105
void reset_field() override
Definition: item_sum.h:2169
uint m_field_arg_count
The number of selected items, aka the concat field list.
Definition: item_sum.h:2103
uint group_concat_max_len
The maximum permitted result length in bytes as set in group_concat_max_len system variable.
Definition: item_sum.h:2130
bool get_time(MYSQL_TIME *ltime) override
Definition: item_sum.h:2188
bool warning_for_row
Definition: item_sum.h:2131
String * separator
String containing separator between group items.
Definition: item_sum.h:2107
~Item_func_group_concat() override
Definition: item_sum.h:2156
const Mem_root_array< ORDER > & get_order_array() const noexcept
Definition: item_sum.h:2197
Class for implementation of the GROUPING function.
Definition: item_sum.h:2689
bool aggregate_check_group(uchar *arg) override
This function is expected to check if GROUPING function with its arguments is "group-invariant".
Definition: item_sum.cc:6253
longlong val_int() override
Evaluation of the GROUPING function.
Definition: item_sum.cc:6202
Item_func_grouping(const POS &pos, PT_item_list *a)
Definition: item_sum.h:2691
const char * func_name() const override
Definition: item_sum.h:2694
bool fix_fields(THD *thd, Item **ref) override
Resolve the fields in the GROUPING function.
Definition: item_sum.cc:6147
bool aggregate_check_distinct(uchar *arg) override
Used by Distinct_check::check_query to determine whether an error should be returned if the GROUPING ...
Definition: item_sum.cc:6223
void update_used_tables() override
Updates used tables, not null tables information and accumulates properties up the item tree,...
Definition: item_sum.cc:6265
enum Functype functype() const override
Definition: item_sum.h:2695
Definition: item_func.h:93
Item ** args
Array of pointers to arguments.
Definition: item_func.h:100
virtual Item * get_arg(uint i)
Get the i'th argument of the function that this object represents.
Definition: item_func.h:438
Functype
Definition: item_func.h:178
@ GROUPING_FUNC
Definition: item_func.h:231
virtual uint argument_count() const
Definition: item_func.h:126
table_map used_tables_cache
Value used in calculation of result of used_tables()
Definition: item_func.h:164
bool param_type_is_default(THD *thd, uint start, uint end, uint step, enum_field_types def)
For arguments of this Item_func ("args" array), in range [start, start+step, start+2*step,...
Definition: item_func.cc:516
bool propagate_type(THD *thd, const Type_properties &type) override
Default implementation for all functions: Propagate base_item's type into all arguments.
Definition: item_func.cc:492
Item ** arguments() const
Definition: item_func.h:127
virtual void fix_num_length_and_dec()
Definition: item_func.cc:832
const char * original_db_name() const
Definition: item.h:3982
void set_original_field_name(const char *name_arg)
Definition: item.h:3979
const char * original_table_name() const
Definition: item.h:3983
Definition: item_func.h:928
LEAD/LAG window functions, cf.
Definition: item_sum.h:2456
bool fix_fields(THD *thd, Item **items) override
Definition: item_sum.cc:5495
bool has_value() const
Definition: item_sum.h:2529
bool m_is_lead
if true, the function is LEAD, else LAG
Definition: item_sum.h:2458
bool needs_partition_cardinality() const override
Return true if we need to make two passes over the rows in the partition - either because we need the...
Definition: item_sum.h:2513
const char * func_name() const override
Definition: item_sum.h:2490
bool get_date(MYSQL_TIME *ltime, my_time_flags_t fuzzydate) override
Definition: item_sum.cc:5616
void set_use_default(bool value)
Definition: item_sum.h:2531
String * val_str(String *str) override
Definition: item_sum.cc:5608
bool m_use_default
execution state: use default value for current row
Definition: item_sum.h:2473
enum Item_result result_type() const override
Definition: item_sum.h:2502
Item_cache * m_default
Definition: item_sum.h:2462
bool compute()
Core logic of LEAD/LAG window functions.
Definition: item_sum.cc:5643
Item_lead_lag(const POS &pos, bool lead, PT_item_list *opt_list, enum_null_treatment null_treatment, PT_window *w)
Definition: item_sum.h:2477
bool check_wf_semantics1(THD *thd, Query_block *select, Window_evaluation_requirements *reqs) override
Only relevant for aggregates qua window functions.
Definition: item_sum.cc:5555
enum Sumfunctype sum_func() const override
Definition: item_sum.h:2493
bool get_time(MYSQL_TIME *ltime) override
Definition: item_sum.cc:5625
enum_null_treatment m_null_treatment
Definition: item_sum.h:2457
void clear() override
Definition: item_sum.cc:5567
bool use_default() const
Definition: item_sum.h:2532
bool m_has_value
Execution state: if set, we already have a value for current row.
Definition: item_sum.h:2472
longlong val_int() override
Definition: item_sum.cc:5579
my_decimal * val_decimal(my_decimal *decimal_buffer) override
Definition: item_sum.cc:5595
bool check_wf_semantics2(Window_evaluation_requirements *reqs) override
Like check_wf_semantics1.
Definition: item_sum.cc:5504
Item_result m_hybrid_type
Definition: item_sum.h:2460
int64 m_n
canonicalized offset value
Definition: item_sum.h:2459
double val_real() override
Definition: item_sum.cc:5587
void set_has_value(bool value)
Definition: item_sum.h:2528
bool resolve_type(THD *thd) override
Resolve type-related information for this item, such as result field type, maximum size,...
Definition: item_sum.cc:5442
bool val_json(Json_wrapper *wr) override
Get a JSON value from an Item.
Definition: item_sum.cc:5633
bool setup_lead_lag()
Definition: item_sum.cc:5539
Item_cache * m_value
Definition: item_sum.h:2461
void split_sum_func(THD *thd, Ref_item_array ref_item_array, mem_root_deque< Item * > *fields) override
See comments in Item_cmp_func::split_sum_func()
Definition: item_sum.cc:5532
Item_non_framing_wf super
Definition: item_sum.h:2474
void update_after_wf_arguments_changed(THD *thd) override
Signal to the function that its arguments may have changed, and that any internal caches etc.
Definition: item_sum.cc:5574
Common parent class for window functions that always work on the entire partition,...
Definition: item_sum.h:2227
Item_non_framing_wf(const POS &pos, PT_window *w)
Definition: item_sum.h:2231
bool add() override
Definition: item_sum.h:2248
bool get_time(MYSQL_TIME *ltime) override
Definition: item_sum.h:2242
Item_non_framing_wf(const POS &pos, Item *a, PT_window *w)
Definition: item_sum.h:2232
Item_non_framing_wf(const POS &pos, PT_item_list *opt_list, PT_window *w)
Definition: item_sum.h:2234
Item_sum super
Definition: item_sum.h:2228
Item_non_framing_wf(THD *thd, Item_non_framing_wf *i)
Definition: item_sum.h:2236
bool get_date(MYSQL_TIME *ltime, my_time_flags_t fuzzydate) override
Definition: item_sum.h:2238
void update_field() override
Definition: item_sum.h:2247
void reset_field() override
Definition: item_sum.h:2246
bool framing() const override
All aggregates are framing, i.e.
Definition: item_sum.h:2255
bool fix_fields(THD *thd, Item **items) override
Definition: item_sum.cc:4700
NTH_VALUE window function, cf.
Definition: item_sum.h:2614
int64 m_cnt
used when evaluating on-the-fly (non-buffered processing)
Definition: item_sum.h:2621
void update_field() override
Definition: item_sum.h:2661
bool compute()
Core logic of NTH_VALUE window functions.
Definition: item_sum.cc:5335
String * val_str(String *str) override
Definition: item_sum.cc:5402
Item_sum super
Definition: item_sum.h:2623
bool check_wf_semantics2(Window_evaluation_requirements *reqs) override
Like check_wf_semantics1.
Definition: item_sum.cc:4963
enum Item_result result_type() const override
Definition: item_sum.h:2649
Item_result m_hybrid_type
Definition: item_sum.h:2618
void split_sum_func(THD *thd, Ref_item_array ref_item_array, mem_root_deque< Item * > *fields) override
See comments in Item_cmp_func::split_sum_func()
Definition: item_sum.cc:5287
my_decimal * val_decimal(my_decimal *decimal_buffer) override
Definition: item_sum.cc:5388
bool get_time(MYSQL_TIME *ltime) override
Definition: item_sum.cc:5422
bool setup_nth()
Definition: item_sum.cc:5294
bool fix_fields(THD *thd, Item **items) override
Definition: item_sum.cc:5247
enum_field_types m_hybrid_field_type
Definition: item_sum.h:2619
int64 m_n
The N of the function.
Definition: item_sum.h:2616
double val_real() override
Definition: item_sum.cc:5378
bool m_from_last
true iff FROM_LAST was specified
Definition: item_sum.h:2617
Item_cache * m_value
Definition: item_sum.h:2620
bool val_json(Json_wrapper *wr) override
Get a JSON value from an Item.
Definition: item_sum.cc:5432
enum_null_treatment m_null_treatment
Definition: item_sum.h:2615
void reset_field() override
Definition: item_sum.h:2660
longlong val_int() override
Definition: item_sum.cc:5368
Item_nth_value(const POS &pos, PT_item_list *a, bool from_last, enum_null_treatment null_treatment, PT_window *w)
Definition: item_sum.h:2626
void clear() override
Definition: item_sum.cc:5305
bool resolve_type(THD *thd) override
Resolve type-related information for this item, such as result field type, maximum size,...
Definition: item_sum.cc:5234
enum Sumfunctype sum_func() const override
Definition: item_sum.h:2637
void update_after_wf_arguments_changed(THD *thd) override
Signal to the function that its arguments may have changed, and that any internal caches etc.
Definition: item_sum.cc:5311
bool add() override
Definition: item_sum.h:2662
const char * func_name() const override
Definition: item_sum.h:2636
bool get_date(MYSQL_TIME *ltime, my_time_flags_t fuzzydate) override
Definition: item_sum.cc:5412
bool check_wf_semantics1(THD *thd, Query_block *select, Window_evaluation_requirements *reqs) override
Only relevant for aggregates qua window functions.
Definition: item_sum.cc:5315
bool uses_only_one_row() const override
Only for framing window functions.
Definition: item_sum.h:2669
NTILE window function, cf.
Definition: item_sum.h:2419
void clear() override
Definition: item_sum.h:2449
Item_non_framing_wf super
Definition: item_sum.h:2420
String * val_str(String *) override
Definition: item_sum.cc:5038
bool resolve_type(THD *thd) override
Resolve type-related information for this item, such as result field type, maximum size,...
Definition: item_sum.h:2432
const char * func_name() const override
Definition: item_sum.h:2429
bool needs_partition_cardinality() const override
Return true if we need to make two passes over the rows in the partition - either because we need the...
Definition: item_sum.h:2450
bool check_wf_semantics2(Window_evaluation_requirements *reqs) override
Like check_wf_semantics1.
Definition: item_sum.cc:5053
bool fix_fields(THD *thd, Item **items) override
Definition: item_sum.cc:4981
double val_real() override
Definition: item_sum.cc:5033
longlong val_int() override
Definition: item_sum.cc:4987
longlong m_value
Definition: item_sum.h:2421
my_decimal * val_decimal(my_decimal *buff) override
Definition: item_sum.cc:5040
Item_ntile(const POS &pos, Item *a, PT_window *w)
Definition: item_sum.h:2424
enum Sumfunctype sum_func() const override
Definition: item_sum.h:2430
bool check_wf_semantics1(THD *thd, Query_block *select, Window_evaluation_requirements *reqs) override
Only relevant for aggregates qua window functions.
Definition: item_sum.cc:5045
Item_result result_type() const override
Definition: item_sum.h:2448
PERCENT_RANK window function, cf.
Definition: item_sum.h:2378
String * val_str(String *) override
Definition: item_sum.cc:4946
Item_percent_rank(const POS &pos, PT_window *w)
Definition: item_sum.h:2389
ulonglong m_rank_ctr
Increment when window order columns change.
Definition: item_sum.h:2381
const char * func_name() const override
Definition: item_sum.h:2396
Item_result result_type() const override
Definition: item_sum.h:2413
~Item_percent_rank() override
bool check_wf_semantics1(THD *thd, Query_block *select, Window_evaluation_requirements *reqs) override
Only relevant for aggregates qua window functions.
Definition: item_sum.cc:4888
ulonglong m_peers
Needed to make PERCENT_RANK same for peers.
Definition: item_sum.h:2382
double val_real() override
Definition: item_sum.cc:4912
Item_non_framing_wf super
Definition: item_sum.h:2379
bool resolve_type(THD *thd) override
Resolve type-related information for this item, such as result field type, maximum size,...
Definition: item_sum.h:2399
enum Sumfunctype sum_func() const override
Definition: item_sum.h:2397
bool needs_partition_cardinality() const override
Return true if we need to make two passes over the rows in the partition - either because we need the...
Definition: item_sum.h:2406
bool m_last_peer_visited
Set when the last peer has been visited.
Definition: item_sum.h:2386
void clear() override
Definition: item_sum.cc:4955
my_decimal * val_decimal(my_decimal *buffer) override
Definition: item_sum.cc:4950
longlong val_int() override
Definition: item_sum.cc:4938
RANK or DENSE_RANK window function, cf.
Definition: item_sum.h:2298
Item_result result_type() const override
Definition: item_sum.h:2343
void update_after_wf_arguments_changed(THD *thd) override
Signal to the function that its arguments may have changed, and that any internal caches etc.
Definition: item_sum.cc:4755
bool check_wf_semantics1(THD *thd, Query_block *select, Window_evaluation_requirements *reqs) override
Only relevant for aggregates qua window functions.
Definition: item_sum.cc:4768
ulonglong m_duplicates
Needed to make RANK different from DENSE_RANK.
Definition: item_sum.h:2303
bool m_dense
If true, the object represents DENSE_RANK.
Definition: item_sum.h:2300
longlong val_int() override
Definition: item_sum.cc:4786
enum Sumfunctype sum_func() const override
Definition: item_sum.h:2322
~Item_rank() override
Definition: item_sum.cc:4842
bool resolve_type(THD *thd) override
Resolve type-related information for this item, such as result field type, maximum size,...
Definition: item_sum.h:2326
Item_rank(const POS &pos, bool dense, PT_window *w)
Definition: item_sum.h:2307
my_decimal * val_decimal(my_decimal *buff) override
Definition: item_sum.cc:4821
const char * func_name() const override
Definition: item_sum.h:2318
double val_real() override
Definition: item_sum.cc:4814
String * val_str(String *) override
Definition: item_sum.cc:4819
ulonglong m_rank_ctr
Increment when window order columns change.
Definition: item_sum.h:2302
void clear() override
Clear state for a new partition.
Definition: item_sum.cc:4826
Mem_root_array< Cached_item * > m_previous
Values of previous row's ORDER BY items.
Definition: item_sum.h:2305
Item_non_framing_wf super
Definition: item_sum.h:2299
Item with result field.
Definition: item.h:5566
longlong llrint_with_overflow_check(double realval)
Definition: item.h:5617
void cleanup() override
Called for every Item after use (preparation and execution).
Definition: item.cc:10588
virtual const char * func_name() const =0
A wrapper Item that contains a number of aggregate items, one for each level of rollup (see Item_roll...
Definition: item_sum.h:2710
table_map used_tables() const override
Definition: item_sum.h:2737
Field * create_tmp_field(bool group, TABLE *table) override
Definition: item_sum.cc:6342
void update_field() override
Definition: item_sum.h:2752
bool resolve_type(THD *) override
Resolve type-related information for this item, such as result field type, maximum size,...
Definition: item_sum.h:2739
Item * get_arg(uint i) override
Get the i'th argument of the function that this object represents.
Definition: item_sum.h:2774
Item * set_arg(THD *thd, uint i, Item *new_val) override
Definition: item_sum.h:2776
bool is_null() override
The method allows to determine nullness of a complex expression without fully evaluating it,...
Definition: item_sum.cc:6328
void set_current_rollup_level(int level)
Definition: item_sum.h:2786
bool get_date(MYSQL_TIME *ltime, my_time_flags_t fuzzydate) override
Definition: item_sum.cc:6282
void print(const THD *thd, String *str, enum_query_type query_type) const override
This method is used for to:
Definition: item_sum.cc:6333
bool aggregator_setup(THD *thd) override
Called to initialize the aggregator.
Definition: item_sum.cc:6375
Item_result result_type() const override
Definition: item_sum.h:2738
String * val_str(String *str) override
Definition: item_sum.cc:6307
int set_aggregator(Aggregator::Aggregator_type aggregator) override
Definition: item_sum.cc:6364
Item_sum * unwrap_sum() override
Non-const version.
Definition: item_sum.h:2791
longlong val_int() override
Definition: item_sum.cc:6300
void reset_field() override
Definition: item_sum.h:2751
const Item_sum * unwrap_sum() const override
In case we are an Item_rollup_sum_switcher, return the underlying Item_sum, otherwise,...
Definition: item_sum.h:2790
Item_rollup_sum_switcher(List< Item > *sum_func_per_level)
Definition: item_sum.h:2712
bool get_time(MYSQL_TIME *ltime) override
Definition: item_sum.cc:6288
bool aggregator_add_all()
Definition: item_sum.h:2763
Item * current_arg() const
Definition: item_sum.cc:6277
Item_sum * master() const
Definition: item_sum.h:2787
Item_sum * child(size_t i) const
Definition: item_sum.h:2795
enum Sumfunctype real_sum_func() const override
Definition: item_sum.h:2748
bool is_rollup_sum_wrapper() const override
Overridden by Item_rollup_sum_switcher.
Definition: item_sum.h:2789
enum Sumfunctype sum_func() const override
Definition: item_sum.h:2747
const char * func_name() const override
Definition: item_sum.h:2736
int m_current_rollup_level
Definition: item_sum.h:2800
double val_real() override
Definition: item_sum.cc:6293
bool val_json(Json_wrapper *result) override
Get a JSON value from an Item.
Definition: item_sum.cc:6321
uint argument_count() const override
Definition: item_sum.h:2783
my_decimal * val_decimal(my_decimal *dec) override
Definition: item_sum.cc:6314
bool add() override
Definition: item_sum.h:2754
void clear() override
Definition: item_sum.cc:6346
bool reset_and_add_for_rollup(int last_unchanged_group_item_idx)
Definition: item_sum.cc:6352
const int m_num_levels
Definition: item_sum.h:2799
const Item * get_arg(uint i) const override
Get the i'th argument of the function that this object represents.
Definition: item_sum.h:2775
ROW_NUMBER window function, cf.
Definition: item_sum.h:2261
ulonglong m_ctr
Increment for each row in partition.
Definition: item_sum.h:2263
bool resolve_type(THD *thd) override
Resolve type-related information for this item, such as result field type, maximum size,...
Definition: item_sum.h:2274
enum Sumfunctype sum_func() const override
Definition: item_sum.h:2272
bool check_wf_semantics1(THD *, Query_block *, Window_evaluation_requirements *) override
Only relevant for aggregates qua window functions.
Definition: item_sum.h:2288
Item_row_number(const POS &pos, PT_window *w)
Definition: item_sum.h:2266
my_decimal * val_decimal(my_decimal *buff) override
Definition: item_sum.cc:4748
Item_result result_type() const override
Definition: item_sum.h:2286
String * val_str(String *) override
Definition: item_sum.cc:4744
longlong val_int() override
Definition: item_sum.cc:4725
void clear() override
Definition: item_sum.cc:4753
const char * func_name() const override
Definition: item_sum.h:2271
double val_real() override
Definition: item_sum.cc:4739
Definition: item_sum.h:1484
enum Type type() const override
Definition: item_sum.h:1487
Item_std_field(Item_sum_std *item)
Definition: item_sum.cc:3800
bool check_function_as_value_generator(uchar *args) override
Check if this item is allowed for a virtual column or inside a default expression.
Definition: item_sum.h:1495
enum Item_result result_type() const override
Definition: item_sum.h:1490
double val_real() override
Definition: item_sum.cc:3803
const char * func_name() const override
Definition: item_sum.h:1491
my_decimal * val_decimal(my_decimal *) override
Definition: item_sum.cc:3811
Definition: item_sum.h:1902
Item_sum_and(const POS &pos, Item *item_par, PT_window *w)
Definition: item_sum.h:1904
const char * func_name() const override
Definition: item_sum.h:1908
Item_sum_and(THD *thd, Item_sum_and *item)
Definition: item_sum.h:1907
Item * copy_or_same(THD *thd) override
Definition: item_sum.cc:3268
Definition: item_sum.h:1305
bool resolve_type(THD *thd) override
Resolve type-related information for this item, such as result field type, maximum size,...
Definition: item_sum.cc:2215
void clear() override
Definition: item_sum.cc:2270
String * val_str(String *str) override
Definition: item_sum.cc:2389
const char * func_name() const override
Definition: item_sum.h:1335
void update_field() override
calc next value and merge it with field_value.
Definition: item_sum.cc:3497
Item_sum_sum super
Definition: item_sum.h:1309
Item * result_item(Field *) override
Definition: item_sum.h:1332
double val_real() override
Definition: item_sum.cc:2279
void cleanup() override
Called for every Item after use (preparation and execution).
Definition: item_sum.h:1338
Item_sum_avg(const POS &pos, Item *item_par, bool distinct, PT_window *w)
Definition: item_sum.h:1313
Field * create_tmp_field(bool group, TABLE *table) override
Definition: item_sum.cc:2248
my_decimal m_avg_dec
Definition: item_sum.h:1310
uint f_scale
Definition: item_sum.h:1308
enum Sumfunctype sum_func() const override
Definition: item_sum.h:1320
double m_avg
Definition: item_sum.h:1311
longlong val_int() override
Definition: item_sum.h:1327
Item * copy_or_same(THD *thd) override
Definition: item_sum.cc:2241
my_decimal * val_decimal(my_decimal *) override
Definition: item_sum.cc:2304
void reset_field() override
Definition: item_sum.cc:3397
uint prec_increment
Definition: item_sum.h:1307
uint dec_bin_size
Definition: item_sum.h:1308
bool add() override
Definition: item_sum.cc:2272
Item_sum_avg(THD *thd, Item_sum_avg *item)
Definition: item_sum.h:1316
uint f_precision
Definition: item_sum.h:1308
This is used in connection with an Item_sum_bit,.
Definition: item_sum.h:1183
double val_real() override
Definition: item_sum.cc:3743
enum Type type() const override
Definition: item_sum.h:1197
ulonglong reset_bits
Definition: item_sum.h:1185
Item_sum_bit_field(Item_result res_type, Item_sum_bit *item, ulonglong reset_bits)
Definition: item_sum.cc:3708
bool resolve_type(THD *) override
Resolve type-related information for this item, such as result field type, maximum size,...
Definition: item_sum.h:1194
my_decimal * val_decimal(my_decimal *) override
Definition: item_sum.cc:3760
bool get_date(MYSQL_TIME *ltime, my_time_flags_t fuzzydate) override
Definition: item_sum.cc:3786
longlong val_int() override
Definition: item_sum.cc:3728
bool get_time(MYSQL_TIME *ltime) override
Definition: item_sum.cc:3793
String * val_str(String *) override
Definition: item_sum.cc:3768
const char * func_name() const override
Definition: item_sum.h:1198
Base class used to implement BIT_AND, BIT_OR and BIT_XOR.
Definition: item_sum.h:1733
bool get_date(MYSQL_TIME *ltime, my_time_flags_t fuzzydate) override
Definition: item_sum.cc:3157
bool add_bits(const String *s1, ulonglong b1)
Accumulate the value of 's1' (if in string mode) or of 'b1' (if in integer mode).
Definition: item_sum.cc:1588
void cleanup() override
Called for every Item after use (preparation and execution).
Definition: item_sum.h:1842
void remove_bits(const String *s1, ulonglong b1)
For windowing: perform inverse aggregation.
Definition: item_sum.cc:1510
const char initial_value_buff_storage[1]
Buffer used to avoid String allocation in the constructor.
Definition: item_sum.h:1744
static constexpr uint DIGIT_CNT_CARD
Definition: item_sum.h:1787
enum Sumfunctype sum_func() const override
Definition: item_sum.h:1829
bool resolve_type(THD *) override
Resolve type-related information for this item, such as result field type, maximum size,...
Definition: item_sum.cc:1454
bool m_is_xor
true iff BIT_XOR
Definition: item_sum.h:1790
void clear() override
Definition: item_sum.cc:3240
Item * result_item(Field *) override
Definition: item_sum.h:1825
bool fix_fields(THD *thd, Item **ref) override
Definition: item_sum.cc:1429
longlong val_int() override
Definition: item_sum.cc:3215
Item_sum super
Definition: item_sum.h:1734
ulonglong * m_digit_cnt
Execution state (windowing): Used for AND, OR to be able to invert window functions in optimized mode...
Definition: item_sum.h:1779
Item_result hybrid_type
Stores the Item's result type. Can only be INT_RESULT or STRING_RESULT.
Definition: item_sum.h:1742
ulonglong reset_bits
Stores the neutral element for function.
Definition: item_sum.h:1736
Item_sum_bit(const POS &pos, Item *item_par, ulonglong reset_arg, PT_window *w)
Definition: item_sum.h:1793
bool is_and() const
Definition: item_sum.h:1855
void reset_field() override
Definition: item_sum.cc:3425
ulonglong m_count
Execution state (windowing): this is for counting rows entering and leaving the window frame,...
Definition: item_sum.h:1750
bool get_time(MYSQL_TIME *ltime) override
Definition: item_sum.cc:3164
double val_real() override
Definition: item_sum.cc:3189
bool add() override
Common implementation of Item_sum_or::add, Item_sum_and:add and Item_sum_xor::add.
Definition: item_sum.cc:1672
my_decimal * val_decimal(my_decimal *decimal_value) override
Definition: item_sum.cc:3171
enum Item_result result_type() const override
Definition: item_sum.h:1830
uint m_digit_cnt_card
Definition: item_sum.h:1785
Item_sum_bit(THD *thd, Item_sum_bit *item)
Copy constructor, used for executing subqueries with temporary tables.
Definition: item_sum.h:1806
String * val_str(String *str) override
Definition: item_sum.cc:3126
void update_field() override
Definition: item_sum.cc:3435
ulonglong bits
Stores the result value for the INT_RESULT.
Definition: item_sum.h:1738
ulonglong m_frame_null_count
Execution state (windowing): this is for counting NULLs of rows entering and leaving the window frame...
Definition: item_sum.h:1758
String value_buff
Stores the result value for the STRING_RESULT.
Definition: item_sum.h:1740
Implements ST_Collect which aggregates geometries into Multipoints, Multilinestrings,...
Definition: item_sum.h:2805
bool add() override
Definition: item_sum.cc:6450
void clear() override
Definition: item_sum.cc:6444
void read_result_field()
Definition: item_sum.cc:6502
bool fix_fields(THD *thd, Item **ref) override
Definition: item_sum.cc:6413
bool get_date(MYSQL_TIME *, my_time_flags_t) override
Definition: item_sum.h:2825
std::optional< gis::srid_t > srid
Definition: item_sum.h:2807
Item_sum_collect(const POS &pos, Item *a, PT_window *w, bool distinct)
Definition: item_sum.h:2816
void update_field() override
Definition: item_sum.cc:6592
longlong val_int() override
Definition: item_sum.h:2823
bool get_time(MYSQL_TIME *) override
Definition: item_sum.h:2826
std::unique_ptr< gis::Geometrycollection > m_geometrycollection
Definition: item_sum.h:2808
String * val_str(String *str) override
Definition: item_sum.cc:6545
void reset_field() override
Definition: item_sum.cc:6655
Item_sum_collect(THD *thd, Item_sum *item)
Definition: item_sum.h:2813
void store_result_field()
Definition: item_sum.cc:6598
my_decimal * val_decimal(my_decimal *decimal_buffer) override
Definition: item_sum.cc:6650
bool check_wf_semantics1(THD *thd, Query_block *, Window_evaluation_requirements *r) override
Only relevant for aggregates qua window functions.
Definition: item_sum.cc:6435
const char * func_name() const override
Definition: item_sum.h:2865
void pop_front()
Definition: item_sum.cc:6538
enum Sumfunctype sum_func() const override
Definition: item_sum.h:2827
Item_result result_type() const override
Definition: item_sum.h:2828
int set_aggregator(Aggregator::Aggregator_type) override
Definition: item_sum.h:2829
double val_real() override
Definition: item_sum.h:2824
Item * copy_or_same(THD *thd) override
Definition: item_sum.cc:6497
Definition: item_sum.h:1055
longlong count
Definition: item_sum.h:1056
bool resolve_type(THD *thd) override
Resolve type-related information for this item, such as result field type, maximum size,...
Definition: item_sum.h:1087
longlong val_int() override
Definition: item_sum.cc:2177
void update_field() override
Definition: item_sum.cc:3488
Item * copy_or_same(THD *thd) override
Definition: item_sum.cc:2158
enum Sumfunctype sum_func() const override
Definition: item_sum.h:1084
void cleanup() override
Called for every Item after use (preparation and execution).
Definition: item_sum.cc:2209
void make_const(longlong count_arg)
Definition: item_sum.h:1094
void reset_field() override
Definition: item_sum.cc:3389
Item_sum_count(Item_int *number)
Definition: item_sum.h:1067
Item_sum_count(THD *thd, Item_sum_count *item)
Definition: item_sum.h:1082
Item_sum_count(const POS &pos, PT_item_list *list, PT_window *w)
Constructs an instance for COUNT(DISTINCT)
Definition: item_sum.h:1078
void clear() override
Definition: item_sum.cc:2166
const char * func_name() const override
Definition: item_sum.h:1101
Item_sum_count(const POS &pos, Item *item_par, PT_window *w)
Definition: item_sum.h:1065
void no_rows_in_result() override
Mark an aggregate as having no rows.
Definition: item_sum.h:1093
bool add() override
Definition: item_sum.cc:2168
This is used in connection which a parent Item_sum:
Definition: item_sum.h:1118
void cleanup() override
Called for every Item after use (preparation and execution).
Definition: item_sum.h:1140
Item_result hybrid_type
Stores the Item's result type.
Definition: item_sum.h:1123
enum Item_result result_type() const override
Definition: item_sum.h:1126
bool check_function_as_value_generator(uchar *args) override
Check if this item is allowed for a virtual column or inside a default expression.
Definition: item_sum.h:1134
Field * field
The tmp table's column containing the value of the set function.
Definition: item_sum.h:1121
bool mark_field_in_map(uchar *arg) override
Mark underlying field in read or write map of a table.
Definition: item_sum.h:1127
Abstract base class for the MIN and MAX aggregate functions.
Definition: item_sum.h:1529
Item * copy_or_same(THD *thd) override
Definition: item_sum.cc:3079
void no_rows_in_result() override
Mark an aggregate as having no rows.
Definition: item_sum.cc:3074
bool setup_hybrid(Item *item, Item *value_arg)
MIN/MAX function setup.
Definition: item_sum.cc:1764
bool uses_only_one_row() const override
Only for framing window functions.
Definition: item_sum.h:1680
virtual Item_sum_hybrid * clone_hybrid(THD *thd) const =0
Create a clone of this object.
bool add() override
Definition: item_sum.cc:3109
const bool m_is_min
Tells if this is the MIN function (true) or the MAX function (false).
Definition: item_sum.h:1536
bool get_time(MYSQL_TIME *ltime) override
Definition: item_sum.cc:3012
bool compute()
This function implements the optimized version of retrieving min/max value.
Definition: item_sum.cc:2814
void min_max_update_int_field()
Definition: item_sum.cc:3619
longlong val_int() override
Definition: item_sum.cc:2947
bool get_date(MYSQL_TIME *ltime, my_time_flags_t fuzzydate) override
Definition: item_sum.cc:3002
void reset_field() override
Definition: item_sum.cc:3292
void clear() override
Definition: item_sum.cc:2765
int64 m_saved_last_value_at
Execution state: keeps track of at which row we saved a non-null last value.
Definition: item_sum.h:1576
Item_cache * arg_cache
Definition: item_sum.h:1545
void cleanup() override
Called for every Item after use (preparation and execution).
Definition: item_sum.cc:3060
void min_max_update_json_field()
Definition: item_sum.cc:3572
void update_field() override
Definition: item_sum.cc:3533
longlong val_date_temporal() override
Return date value of item in packed longlong format.
Definition: item_sum.cc:2973
void update_after_wf_arguments_changed(THD *thd) override
Signal to the function that its arguments may have changed, and that any internal caches etc.
Definition: item_sum.cc:2775
bool keep_field_type() const override
Definition: item_sum.h:1669
my_decimal * val_decimal(my_decimal *) override
Definition: item_sum.cc:2985
int64 m_cnt
Execution state: keeps track if this is the first row in the frame when buffering is not needed.
Definition: item_sum.h:1570
void min_max_update_real_field()
Definition: item_sum.cc:3606
Item_sum_hybrid(THD *thd, const Item_sum_hybrid *item)
Definition: item_sum.h:1640
bool any_value()
Definition: item_sum.h:1677
Item_result hybrid_type
Definition: item_sum.h:1547
bool was_values
Definition: item_sum.h:1548
longlong val_time_temporal() override
Return time value of item in packed longlong format.
Definition: item_sum.cc:2961
bool m_optimize
Set to true when min/max can be optimized using window's ordering.
Definition: item_sum.h:1556
Item_sum_hybrid(const POS &pos, Item *item_par, bool is_min, PT_window *w)
Definition: item_sum.h:1624
Item_sum_hybrid(Item *item_par, bool is_min)
Definition: item_sum.h:1608
Item_sum super
Definition: item_sum.h:1530
void min_max_update_temporal_field()
Definition: item_sum.cc:3554
bool check_wf_semantics1(THD *thd, Query_block *select, Window_evaluation_requirements *r) override
Only relevant for aggregates qua window functions.
Definition: item_sum.cc:2780
bool fix_fields(THD *, Item **) override
Definition: item_sum.cc:1733
String * val_str(String *) override
Definition: item_sum.cc:3022
Arg_comparator * cmp
Definition: item_sum.h:1546
void min_max_update_str_field()
Definition: item_sum.cc:3590
enum Item_result result_type() const override
Definition: item_sum.h:1670
void min_max_update_decimal_field()
Definition: item_sum.cc:3637
double val_real() override
Definition: item_sum.cc:2933
Field * create_tmp_field(bool group, TABLE *table) override
Definition: item_sum.cc:1781
bool m_want_first
For min() - Set to true when results are ordered in ascending and false when descending.
Definition: item_sum.h:1564
Item_cache * value
Definition: item_sum.h:1545
bool m_nulls_first
Set to true if the window is ordered ascending.
Definition: item_sum.h:1552
void split_sum_func(THD *thd, Ref_item_array ref_item_array, mem_root_deque< Item * > *fields) override
See comments in Item_cmp_func::split_sum_func()
Definition: item_sum.cc:3049
TYPELIB * get_typelib() const override
Get the typelib information for an item of type set or enum.
Definition: item_sum.h:1671
bool val_json(Json_wrapper *wr) override
Get a JSON value from an Item.
Definition: item_sum.cc:3035
Definition: item_sum.h:973
Item_sum_int(const POS &pos, Item *item_par, PT_window *w)
Definition: item_sum.h:975
bool get_date(MYSQL_TIME *ltime, my_time_flags_t fuzzydate) override
Definition: item_sum.h:999
Item_sum_int(THD *thd, Item_sum_int *item)
Definition: item_sum.h:985
bool get_time(MYSQL_TIME *ltime) override
Definition: item_sum.h:1002
double val_real() override
Definition: item_sum.h:993
Item_sum_int(Item *item_par)
Definition: item_sum.h:989
enum Item_result result_type() const override
Definition: item_sum.h:1003
String * val_str(String *str) override
Definition: item_sum.cc:1396
Item_sum_int(const POS &pos, PT_item_list *list, PT_window *w)
Definition: item_sum.h:980
my_decimal * val_decimal(my_decimal *) override
Definition: item_sum.cc:1398
Implements aggregation of values into an array.
Definition: item_sum.h:1249
Item_sum_json_array(THD *thd, Item_sum *item, unique_ptr_destroy_only< Json_wrapper > wrapper, unique_ptr_destroy_only< Json_array > array)
Definition: item_sum.cc:5883
~Item_sum_json_array() override
bool add() override
Definition: item_sum.cc:5956
unique_ptr_destroy_only< Json_array > m_json_array
Accumulates the final value.
Definition: item_sum.h:1251
Item * copy_or_same(THD *thd) override
Definition: item_sum.cc:6005
const char * func_name() const override
Definition: item_sum.h:1261
void clear() override
Definition: item_sum.cc:5898
Implements aggregation of values into an object.
Definition: item_sum.h:1268
Item_sum_json_object(THD *thd, Item_sum *item, unique_ptr_destroy_only< Json_wrapper > wrapper, unique_ptr_destroy_only< Json_object > object)
Definition: item_sum.cc:5907
Item * copy_or_same(THD *thd) override
Definition: item_sum.cc:6113
bool add() override
Definition: item_sum.cc:6018
unique_ptr_destroy_only< Json_object > m_json_object
Accumulates the final value.
Definition: item_sum.h:1270
~Item_sum_json_object() override
const char * func_name() const override
Definition: item_sum.h:1297
bool check_wf_semantics1(THD *thd, Query_block *select, Window_evaluation_requirements *reqs) override
Only relevant for aggregates qua window functions.
Definition: item_sum.cc:5932
std::map< std::string, int > m_key_map
Map of keys in Json_object and the count for each key within a window frame.
Definition: item_sum.h:1279
void clear() override
Definition: item_sum.cc:5922
bool m_optimize
If window provides ordering on the key in Json_object, a key_map is not needed to handle rows leaving...
Definition: item_sum.h:1287
String m_tmp_key_value
Buffer used to get the value of the key.
Definition: item_sum.h:1272
Common abstraction for Item_sum_json_array and Item_sum_json_object.
Definition: item_sum.h:1205
void reset_field() override
Definition: item_sum.cc:5843
void update_field() override
Definition: item_sum.cc:5863
bool val_json(Json_wrapper *wr) override
Get a JSON value from an Item.
Definition: item_sum.cc:5761
unique_ptr_destroy_only< Json_wrapper > m_wrapper
Wrapper around the container (object/array) which accumulates the value.
Definition: item_sum.h:1214
enum Sumfunctype sum_func() const override
Definition: item_sum.h:1230
longlong val_int() override
Definition: item_sum.cc:5799
String m_value
String used when reading JSON binary values or JSON text values.
Definition: item_sum.h:1210
String m_conversion_buffer
String used for converting JSON text values to utf8mb4 charset.
Definition: item_sum.h:1212
Item_sum super
Definition: item_sum.h:1206
bool get_time(MYSQL_TIME *ltime) override
Definition: item_sum.cc:5837
~Item_sum_json() override
String * val_str(String *str) override
Definition: item_sum.cc:5741
my_decimal * val_decimal(my_decimal *decimal_buffer) override
Definition: item_sum.cc:5814
Item_result result_type() const override
Definition: item_sum.h:1231
bool fix_fields(THD *thd, Item **pItem) override
Definition: item_sum.cc:5715
bool check_wf_semantics1(THD *, Query_block *, Window_evaluation_requirements *) override
Only relevant for aggregates qua window functions.
Definition: item_sum.cc:5710
bool get_date(MYSQL_TIME *ltime, my_time_flags_t fuzzydate) override
Definition: item_sum.cc:5831
Item_sum_json(unique_ptr_destroy_only< Json_wrapper > wrapper, Args &&... parent_args)
Construct an Item_sum_json instance.
Definition: item_sum.cc:5701
double val_real() override
Definition: item_sum.cc:5784
Definition: item_sum.h:1714
Item_sum_max(Item *item_par)
Definition: item_sum.h:1716
Item_sum_max(THD *thd, const Item_sum_max *item)
Definition: item_sum.h:1719
const char * func_name() const override
Definition: item_sum.h:1722
Item_sum_max * clone_hybrid(THD *thd) const override
Create a clone of this object.
Definition: item_sum.cc:3090
enum Sumfunctype sum_func() const override
Definition: item_sum.h:1721
Item_sum_max(const POS &pos, Item *item_par, PT_window *w)
Definition: item_sum.h:1717
Definition: item_sum.h:1700
Item_sum_min(THD *thd, const Item_sum_min *item)
Definition: item_sum.h:1705
Item_sum_min(Item *item_par)
Definition: item_sum.h:1702
enum Sumfunctype sum_func() const override
Definition: item_sum.h:1707
const char * func_name() const override
Definition: item_sum.h:1708
Item_sum_min(const POS &pos, Item *item_par, PT_window *w)
Definition: item_sum.h:1703
Item_sum_min * clone_hybrid(THD *thd) const override
Create a clone of this object.
Definition: item_sum.cc:3086
Common abstract class for: Item_avg_field Item_variance_field.
Definition: item_sum.h:1151
bool get_date(MYSQL_TIME *ltime, my_time_flags_t fuzzydate) override
Definition: item_sum.h:1157
bool is_null() override
The method allows to determine nullness of a complex expression without fully evaluating it,...
Definition: item_sum.h:1163
bool get_time(MYSQL_TIME *ltime) override
Definition: item_sum.h:1160
longlong val_int() override
Definition: item_sum.h:1153
Definition: item_sum.h:930
my_decimal * val_decimal(my_decimal *) override
Definition: item_sum.cc:1392
Item_sum_num(THD *thd, Item_sum_num *item)
Definition: item_sum.h:949
bool fix_fields(THD *, Item **) override
Definition: item_sum.cc:1402
longlong val_int() override
Definition: item_sum.h:958
enum_field_types default_data_type() const override
Get the default data (output) type for the specific item.
Definition: item_sum.h:951
String * val_str(String *str) override
Definition: item_sum.cc:1390
bool get_date(MYSQL_TIME *ltime, my_time_flags_t fuzzydate) override
Definition: item_sum.h:964
bool get_time(MYSQL_TIME *ltime) override
Definition: item_sum.h:967
Item_sum super
Definition: item_sum.h:931
Item_sum_num(Item *item_par)
Definition: item_sum.h:955
bool is_evaluated
Definition: item_sum.h:940
Item_sum_num(const POS &pos, Item *item_par, PT_window *window)
Definition: item_sum.h:943
void reset_field() override
Definition: item_sum.cc:3279
Item_sum_num(const POS &pos, PT_item_list *list, PT_window *w)
Definition: item_sum.h:946
Definition: item_sum.h:1892
Item_sum_or(THD *thd, Item_sum_or *item)
Definition: item_sum.h:1897
Item * copy_or_same(THD *thd) override
Definition: item_sum.cc:3254
const char * func_name() const override
Definition: item_sum.h:1898
Item_sum_or(const POS &pos, Item *item_par, PT_window *w)
Definition: item_sum.h:1894
Definition: item_sum.h:1507
double val_real() override
Definition: item_sum.cc:2399
Item_sum_std(const POS &pos, Item *item_par, uint sample_arg, PT_window *w)
Definition: item_sum.h:1509
Item * copy_or_same(THD *thd) override
Definition: item_sum.cc:2408
Item_sum_std(THD *thd, Item_sum_std *item)
Definition: item_sum.h:1512
const char * func_name() const override
Definition: item_sum.h:1516
enum Item_result result_type() const override
Definition: item_sum.h:1520
enum Sumfunctype sum_func() const override
Definition: item_sum.h:1513
Item * result_item(Field *) override
Definition: item_sum.h:1515
Definition: item_sum.h:1006
ulonglong m_count
Execution state: this is for counting rows entering and leaving the window frame, see m_frame_null_co...
Definition: item_sum.h:1017
bool check_wf_semantics1(THD *thd, Query_block *select, Window_evaluation_requirements *reqs) override
Only relevant for aggregates qua window functions.
Definition: item_sum.cc:1913
Item * copy_or_same(THD *thd) override
Definition: item_sum.cc:1845
enum Item_result result_type() const override
Definition: item_sum.h:1045
double sum
Definition: item_sum.h:1009
bool add() override
Definition: item_sum.cc:1935
Item_result hybrid_type
Definition: item_sum.h:1008
void no_rows_in_result() override
Mark an aggregate as having no rows.
Definition: item_sum.cc:1864
void reset_field() override
Definition: item_sum.cc:3371
String * val_str(String *str) override
Definition: item_sum.cc:2024
longlong val_int() override
Definition: item_sum.cc:1956
my_decimal dec_buffs[2]
Definition: item_sum.h:1010
void clear() override
Definition: item_sum.cc:1852
const char * func_name() const override
Definition: item_sum.h:1051
Item_sum_sum(const POS &pos, Item *item_par, bool distinct, PT_window *window)
Definition: item_sum.h:1027
void update_field() override
calc next value and merge it with field_value.
Definition: item_sum.cc:3459
uint curr_dec_buff
Definition: item_sum.h:1011
ulonglong m_frame_null_count
Execution state: this is for counting NULLs of rows entering and leaving the window frame,...
Definition: item_sum.h:1024
my_decimal * val_decimal(my_decimal *) override
Definition: item_sum.cc:2030
bool resolve_type(THD *thd) override
Resolve type-related information for this item, such as result field type, maximum size,...
Definition: item_sum.cc:1866
enum Sumfunctype sum_func() const override
Definition: item_sum.h:1036
double val_real() override
Definition: item_sum.cc:1980
Definition: item_sum.h:2060
bool get_date(MYSQL_TIME *ltime, my_time_flags_t fuzzydate) override
Definition: item_sum.h:2071
longlong val_int() override
Definition: item_sum.cc:3928
bool get_time(MYSQL_TIME *ltime) override
Definition: item_sum.h:2074
my_decimal * val_decimal(my_decimal *) override
Definition: item_sum.cc:3930
Item_sum_udf_decimal(const POS &pos, udf_func *udf_arg, PT_item_list *opt_list)
Definition: item_sum.h:2062
Item * copy_or_same(THD *thd) override
Definition: item_sum.cc:3939
double val_real() override
Definition: item_sum.cc:3926
enum Item_result result_type() const override
Definition: item_sum.h:2077
String * val_str(String *) override
Definition: item_sum.cc:3922
Item_sum_udf_decimal(THD *thd, Item_sum_udf_decimal *item)
Definition: item_sum.h:2065
bool resolve_type(THD *) override
Resolve type-related information for this item, such as result field type, maximum size,...
Definition: item_sum.h:2078
Definition: item_sum.h:1970
bool resolve_type(THD *) override
Resolve type-related information for this item, such as result field type, maximum size,...
Definition: item_sum.h:1989
longlong val_int() override
Definition: item_sum.h:1976
my_decimal * val_decimal(my_decimal *) override
Definition: item_sum.cc:3918
String * val_str(String *str) override
Definition: item_sum.cc:3914
Item * copy_or_same(THD *thd) override
Definition: item_sum.cc:3901
bool get_date(MYSQL_TIME *ltime, my_time_flags_t fuzzydate) override
Definition: item_sum.h:1983
double val_real() override
Definition: item_sum.cc:3906
Item_sum_udf_float(THD *thd, Item_sum_udf_float *item)
Definition: item_sum.h:1974
Item_sum_udf_float(const POS &pos, udf_func *udf_arg, PT_item_list *opt_list)
Definition: item_sum.h:1972
bool get_time(MYSQL_TIME *ltime) override
Definition: item_sum.h:1986
Definition: item_sum.h:1997
bool get_date(MYSQL_TIME *ltime, my_time_flags_t fuzzydate) override
Definition: item_sum.h:2010
Item_sum_udf_int(THD *thd, Item_sum_udf_int *item)
Definition: item_sum.h:2001
bool resolve_type(THD *) override
Resolve type-related information for this item, such as result field type, maximum size,...
Definition: item_sum.h:2015
bool get_time(MYSQL_TIME *ltime) override
Definition: item_sum.h:2013
enum Item_result result_type() const override
Definition: item_sum.h:2014
Item * copy_or_same(THD *thd) override
Definition: item_sum.cc:3943
String * val_str(String *str) override
Definition: item_sum.cc:3955
Item_sum_udf_int(const POS &pos, udf_func *udf_arg, PT_item_list *opt_list)
Definition: item_sum.h:1999
longlong val_int() override
Definition: item_sum.cc:3947
my_decimal * val_decimal(my_decimal *) override
Definition: item_sum.cc:3959
double val_real() override
Definition: item_sum.h:2004
Definition: item_sum.h:2022
bool resolve_type(THD *) override
Default max_length is max argument length.
Definition: item_sum.cc:3965
double val_real() override
Definition: item_sum.h:2029
String * val_str(String *) override
Definition: item_sum.cc:3981
enum Item_result result_type() const override
Definition: item_sum.h:2055
bool get_date(MYSQL_TIME *ltime, my_time_flags_t fuzzydate) override
Definition: item_sum.h:2049
bool get_time(MYSQL_TIME *ltime) override
Definition: item_sum.h:2052
Item * copy_or_same(THD *thd) override
Definition: item_sum.cc:3973
my_decimal * val_decimal(my_decimal *dec) override
Definition: item_sum.cc:3977
Item_sum_udf_str(THD *thd, Item_sum_udf_str *item)
Definition: item_sum.h:2026
longlong val_int() override
Definition: item_sum.h:2038
Item_sum_udf_str(const POS &pos, udf_func *udf_arg, PT_item_list *opt_list)
Definition: item_sum.h:2024
Definition: item_sum.h:1429
ulonglong count
Definition: item_sum.h:1440
void update_field() override
Definition: item_sum.cc:2739
bool resolve_type(THD *) override
Resolve type-related information for this item, such as result field type, maximum size,...
Definition: item_sum.cc:2607
double val_real() override
Definition: item_sum.cc:2684
void cleanup() override
Called for every Item after use (preparation and execution).
Definition: item_sum.h:1474
void clear() override
Definition: item_sum.cc:2661
Item * copy_or_same(THD *thd) override
Definition: item_sum.cc:2627
Item * result_item(Field *) override
Definition: item_sum.h:1466
Item_sum_variance(const POS &pos, Item *item_par, uint sample_arg, PT_window *w)
Definition: item_sum.h:1450
enum Sumfunctype sum_func() const override
Definition: item_sum.h:1459
double recurrence_s
Definition: item_sum.h:1438
bool optimize
If set, uses a algorithm II mentioned in the class description to calculate the variance which helps ...
Definition: item_sum.h:1448
const char * func_name() const override
Definition: item_sum.h:1468
bool add() override
Definition: item_sum.cc:2663
void no_rows_in_result() override
Mark an aggregate as having no rows.
Definition: item_sum.h:1467
double recurrence_s2
Definition: item_sum.h:1439
Item_result hybrid_type
Definition: item_sum.h:1433
bool check_wf_semantics1(THD *thd, Query_block *select, Window_evaluation_requirements *reqs) override
Only relevant for aggregates qua window functions.
Definition: item_sum.cc:2591
double recurrence_m
Used in recurrence relation.
Definition: item_sum.h:1437
my_decimal * val_decimal(my_decimal *) override
Definition: item_sum.cc:2714
uint prec_increment
Definition: item_sum.h:1442
enum Item_result result_type() const override
Definition: item_sum.h:1473
void reset_field() override
Definition: item_sum.cc:2719
uint sample
Definition: item_sum.h:1441
Field * create_tmp_field(bool group, TABLE *table) override
Create a new field to match the type of value we're expected to yield.
Definition: item_sum.cc:2640
Definition: item_sum.h:1912
const char * func_name() const override
Definition: item_sum.h:1920
Item * copy_or_same(THD *thd) override
Definition: item_sum.cc:3261
Item_sum_xor(const POS &pos, Item *item_par, PT_window *w)
Definition: item_sum.h:1914
Item_sum_xor(THD *thd, Item_sum_xor *item)
Definition: item_sum.h:1919
Class Item_sum is the base class used for special expressions that SQL calls 'set functions'.
Definition: item_sum.h:398
virtual void update_after_wf_arguments_changed(THD *)
Signal to the function that its arguments may have changed, and that any internal caches etc.
Definition: item_sum.h:658
bool collect_grouped_aggregates(uchar *) override
Definition: item_sum.cc:701
table_map not_null_tables() const override
Return table map of tables that can't be NULL tables (tables that are used in a context where if they...
Definition: item_sum.h:580
virtual bool check_wf_semantics1(THD *thd, Query_block *select, Window_evaluation_requirements *reqs)
Only relevant for aggregates qua window functions.
Definition: item_sum.cc:410
void split_sum_func(THD *thd, Ref_item_array ref_item_array, mem_root_deque< Item * > *fields) override
See comments in Item_cmp_func::split_sum_func()
Definition: item_sum.cc:884
virtual bool check_wf_semantics2(Window_evaluation_requirements *reqs)
Like check_wf_semantics1.
Definition: item_sum.h:716
void aggregator_clear()
Called to cleanup the aggregator.
Definition: item_sum.h:670
virtual const Item_sum * unwrap_sum() const
In case we are an Item_rollup_sum_switcher, return the underlying Item_sum, otherwise,...
Definition: item_sum.h:776
bool resolve_type(THD *) override
Resolve type-related information for this item, such as result field type, maximum size,...
Definition: item_sum.cc:480
bool aggregate_check_distinct(uchar *arg) override
Definition: item_sum.cc:617
bool init_sum_func_check(THD *thd)
Prepare an aggregate function for checking of context.
Definition: item_sum.cc:154
virtual bool aggregator_setup(THD *thd)
Called to initialize the aggregator.
Definition: item_sum.h:664
bool wf_common_init()
Common initial actions for window functions.
Definition: item_sum.cc:905
Item_sum(const POS &pos, PT_window *w)
Definition: item_sum.h:514
bool force_copy_fields
Used in making ROLLUP.
Definition: item_sum.h:426
void no_rows_in_result() override
Mark an aggregate as having no rows.
Definition: item_sum.h:604
bool allow_group_via_temp_table
If incremental update of fields is supported.
Definition: item_sum.h:493
int8 max_aggr_level
max level of unbound column references
Definition: item_sum.h:490
void print(const THD *thd, String *str, enum_query_type query_type) const override
This method is used for to:
Definition: item_sum.cc:462
void make_const()
Definition: item_sum.h:587
Item * replace_aggregate(uchar *) override
Definition: item_sum.cc:732
Window * window()
Definition: item_sum.h:726
virtual void make_unique()
Definition: item_sum.h:609
bool fix_fields(THD *thd, Item **ref) override
Definition: item_sum.cc:872
bool reset_and_add()
Resets the aggregate value to its default and aggregates the current value of its attribute(s).
Definition: item_sum.h:544
bool is_null() override
The method allows to determine nullness of a complex expression without fully evaluating it,...
Definition: item_sum.h:585
virtual Item * result_item(Field *field)
Definition: item_sum.h:567
bool forced_const
True means that this field has been evaluated during optimization.
Definition: item_sum.h:507
virtual void update_field()=0
bool check_sum_func(THD *thd, Item **ref)
Validate the semantic requirements of a set function.
Definition: item_sum.cc:247
bool clean_up_after_removal(uchar *arg) override
Remove the item from the list of inner aggregation functions in the Query_block it was moved to by It...
Definition: item_sum.cc:518
void unsupported_as_wf()
Definition: item_sum.h:785
Aggregator * aggr
Aggregator class instance.
Definition: item_sum.h:407
const Window * window() const
Definition: item_sum.h:727
virtual bool needs_partition_cardinality() const
Return true if we need to make two passes over the rows in the partition - either because we need the...
Definition: item_sum.h:756
virtual bool is_rollup_sum_wrapper() const
Overridden by Item_rollup_sum_switcher.
Definition: item_sum.h:770
bool aggregate_check_group(uchar *arg) override
Definition: item_sum.cc:641
bool with_distinct
Indicates how the aggregate function was specified by the parser : true if it was written as AGGREGAT...
Definition: item_sum.h:433
virtual enum Sumfunctype real_sum_func() const
Definition: item_sum.h:538
nesting_map save_deny_window_func
WFs are forbidden when resolving Item_sum; this member is used to restore WF allowance status afterwa...
Definition: item_sum.h:499
bool collect_scalar_subqueries(uchar *) override
Definition: item_sum.cc:740
virtual void reset_field()=0
virtual bool framing() const
All aggregates are framing, i.e.
Definition: item_sum.h:740
bool has_with_distinct() const
Definition: item_sum.h:437
void update_used_tables() override
Updates used tables, not null tables information and accumulates properties up the item tree,...
Definition: item_sum.cc:760
Item * set_arg(THD *thd, uint i, Item *new_val) override
Definition: item_sum.cc:830
bool m_window_resolved
True if we have already resolved this window functions window reference.
Definition: item_sum.h:417
virtual Field * create_tmp_field(bool group, TABLE *table)
Definition: item_sum.cc:674
friend class Aggregator_simple
Definition: item_sum.h:400
void add_used_tables_for_aggr_func()
Add used_tables information for aggregate function, based on its aggregated query block.
Definition: item_sum.cc:818
Item ** referenced_by[2]
For a group aggregate which is aggregated into an outer query block; none, or just the first or both ...
Definition: item_sum.h:479
Sumfunctype
Definition: item_sum.h:439
@ COUNT_FUNC
Definition: item_sum.h:440
@ STD_FUNC
Definition: item_sum.h:448
@ AVG_DISTINCT_FUNC
Definition: item_sum.h:445
@ DENSE_RANK_FUNC
Definition: item_sum.h:456
@ FIRST_LAST_VALUE_FUNC
Definition: item_sum.h:461
@ SUM_BIT_FUNC
Definition: item_sum.h:450
@ COUNT_DISTINCT_FUNC
Definition: item_sum.h:441
@ SUM_FUNC
Definition: item_sum.h:442
@ CUME_DIST_FUNC
Definition: item_sum.h:457
@ SUM_DISTINCT_FUNC
Definition: item_sum.h:443
@ UDF_SUM_FUNC
Definition: item_sum.h:451
@ ROLLUP_SUM_SWITCHER_FUNC
Definition: item_sum.h:463
@ JSON_AGG_FUNC
Definition: item_sum.h:453
@ ROW_NUMBER_FUNC
Definition: item_sum.h:454
@ MAX_FUNC
Definition: item_sum.h:447
@ GEOMETRY_AGGREGATE_FUNC
Definition: item_sum.h:464
@ AVG_FUNC
Definition: item_sum.h:444
@ MIN_FUNC
Definition: item_sum.h:446
@ NTILE_FUNC
Definition: item_sum.h:459
@ NTH_VALUE_FUNC
Definition: item_sum.h:462
@ GROUP_CONCAT_FUNC
Definition: item_sum.h:452
@ RANK_FUNC
Definition: item_sum.h:455
@ LEAD_LAG_FUNC
Definition: item_sum.h:460
@ PERCENT_RANK_FUNC
Definition: item_sum.h:458
@ VARIANCE_FUNC
Definition: item_sum.h:449
virtual int set_aggregator(Aggregator::Aggregator_type aggregator)
Definition: item_sum.cc:835
bool aggregator_add()
Called to add value to the aggregator.
Definition: item_sum.h:676
Item_sum(Item *a)
Definition: item_sum.h:517
void set_distinct(bool distinct)
Definition: item_sum.h:679
Item_sum * next_sum
next in the circular chain of registered objects
Definition: item_sum.h:481
Item_sum * in_sum_func
the containing set function if any
Definition: item_sum.h:482
virtual bool keep_field_type() const
Definition: item_sum.h:565
bool collect_item_field_or_view_ref_processor(uchar *) override
Collects fields and view references that have the qualifying table in the specified query block.
Definition: item_sum.cc:750
bool has_force_copy_fields() const
Definition: item_sum.h:436
Type type() const override
Definition: item_sum.h:534
void mark_as_sum_func()
Definition: item_sum.cc:452
Query_block * aggr_query_block
For a group aggregate, query block where function is aggregated.
Definition: item_sum.h:489
PT_window * m_window
If sum is a window function, this field contains the window.
Definition: item_sum.h:412
Item_sum(const POS &pos, Item *a, PT_window *w)
Definition: item_sum.h:522
static ulonglong ram_limitation(THD *thd)
Calculate the affordable RAM limit for structures like TREE or Unique used in Item_sum_*.
Definition: item_sum.cc:126
bool reset_wf_state(uchar *arg) override
Reset execution state for such window function types as determined by arg.
Definition: item_sum.cc:892
table_map used_tables() const override
Definition: item_sum.h:577
virtual Item_sum * unwrap_sum()
Non-const version.
Definition: item_sum.h:778
void fix_after_pullout(Query_block *parent_query_block, Query_block *removed_query_block) override
Fix after tables have been moved from one query_block level to the parent level, e....
Definition: item_sum.cc:781
virtual bool setup(THD *)
Definition: item_sum.h:694
void cleanup() override
Called for every Item after use (preparation and execution).
Definition: item_sum.cc:862
int8 max_sum_func_level
max level of aggregation for contained functions
Definition: item_sum.h:492
virtual bool uses_only_one_row() const
Only for framing window functions.
Definition: item_sum.h:746
Item ** get_arg_ptr(uint i)
Definition: item_sum.h:644
bool itemize(Parse_context *pc, Item **res) override
The same as contextualize() but with additional parameter.
Definition: item_sum.cc:94
virtual enum Sumfunctype sum_func() const =0
Item_sum(const POS &pos, Item *a, Item *b, PT_window *w)
Definition: item_sum.h:525
bool eq(const Item *item, bool binary_cmp) const override
Definition: item_sum.cc:590
bool has_aggregate_ref_in_group_by(uchar *arg) override
Check if an aggregate is referenced from within the GROUP BY clause of the query block in which it is...
Definition: item_sum.cc:666
Query_block * base_query_block
query block where function is placed
Definition: item_sum.h:483
Definition: item_sum.h:1928
udf_handler udf
Definition: item_sum.h:1932
void update_field() override
Definition: item_sum.h:1964
void cleanup() override
Called for every Item after use (preparation and execution).
Definition: item_sum.cc:3881
bool itemize(Parse_context *pc, Item **res) override
The same as contextualize() but with additional parameter.
Definition: item_sum.cc:3859
void reset_field() override
Definition: item_sum.h:1963
bool add() override
Definition: item_sum.cc:3874
bool fix_fields(THD *thd, Item **ref) override
Definition: item_sum.h:1949
Item_udf_sum(const POS &pos, udf_func *udf_arg, PT_item_list *opt_list)
Definition: item_sum.h:1935
void clear() override
Definition: item_sum.cc:3868
~Item_udf_sum() override
Definition: item_sum.h:1943
void print(const THD *thd, String *str, enum_query_type query_type) const override
This method is used for to:
Definition: item_sum.cc:3890
Item_udf_sum(THD *thd, Item_udf_sum *item)
Definition: item_sum.h:1939
Item_sum super
Definition: item_sum.h:1929
const char * func_name() const override
Definition: item_sum.h:1948
enum Sumfunctype sum_func() const override
Definition: item_sum.h:1959
Definition: item_sum.h:1347
my_decimal * val_decimal(my_decimal *dec_buf) override
Definition: item_sum.h:1356
const char * func_name() const override
Definition: item_sum.h:1360
bool resolve_type(THD *) override
Resolve type-related information for this item, such as result field type, maximum size,...<