版本：latest

两步聚合

首先，通过使用聚合函数创建一个中间聚合，而不是在一步中计算最终结果。然后，使用分析函数计算最终结果。

社区版
企业版

stats_agg

对二维数据执行线性回归分析，例如计算相关系数和协方差。并且还可以分别计算每个维度的常见统计数据，将数据聚合成中间统计聚合形式，以便进行进一步计算。

提示

只有 x 和 y 都不为空时才会纳入聚合。

stats_agg(y, x)

选项	描述
`y`	要进行统计聚合的数据集中的`y`值。
`x`	要进行统计聚合的数据集中的`x`值。

查看 stats_agg 示例

示例数据集。

SELECT * FROM test_stats;
+-------------------------------+---+---+
| time                          | x | y |
+-------------------------------+---+---+
| 1970-01-01T00:00:00.000000001 | 1 | 1 |
| 1970-01-01T00:00:00.000000002 | 1 | 2 |
| 1970-01-01T00:00:00.000000003 | 1 | 3 |
| 1970-01-01T00:00:00.000000004 | 1 | 4 |
| 1970-01-01T00:00:00.000000005 | 1 | 5 |
| 1970-01-01T00:00:00.000000006 | 2 | 1 |
| 1970-01-01T00:00:00.000000007 | 2 | 2 |
| 1970-01-01T00:00:00.000000008 | 2 | 3 |
| 1970-01-01T00:00:00.000000009 | 2 | 4 |
| 1970-01-01T00:00:00.000000010 | 2 | 5 |
+-------------------------------+---+---+

使用 stats_agg 聚合结果。

SELECT stats_agg(y, x) FROM test_stats;
+------------------------------------------------------------------------------------------------------------------------------------------------------------+
| stats_agg(test_stats.y,test_stats.x)                                                                                                                       |
+------------------------------------------------------------------------------------------------------------------------------------------------------------+
| {n: 10, sx: 15.0, sx2: 2.5, sx3: -2.7755575615628914e-16, sx4: 0.6249999999999999, sy: 30.0, sy2: 20.0, sy3: -1.7763568394002505e-15, sy4: 68.0, sxy: 0.0} |
+------------------------------------------------------------------------------------------------------------------------------------------------------------+

以上结果返回了一个结果集，每个返回值的解释分别为：

{ 
  n:   bigint, -- count 
  sx:  double, -- sum(x)- sum(x)
  sx2: double, -- sum((x-sx/n)^2) (sum of squares)
  sx3: double, -- sum((x-sx/n)^3)
  sx4: double, -- sum((x-sx/n)^4)
  sy:  double, -- sum(y)
  sy2: double, -- sum((y-sy/n)^2) (sum of squares)
  sy3: double, -- sum((y-sy/n)^3)
  sy4: double, -- sum((y-sy/n)^4)
  sxy: double, -- sum((x-sx/n)*(y-sy/n)) (sum of products) 
}

stats_agg 支持以下二次聚合的函数

函数	描述
`num_vals`	计算二维统计总量中的数值个数。
`average_y`, `average_x`	计算二维统计聚合后指定维度的平均值。
`sum_y`, `sum_x`	计算二维统计聚合后指定维度的和，方式为 population。
`stddev_samp_y`, `stddev_samp_x`	计算二维统计聚合后指定维度的标准差，方式为 sample。
`stddev_pop_y`, `stddev_pop_x`	计算二维统计聚合后指定维度的标准差，方式为 population。
`var_samp_y`, `var_samp_x`	计算二维统计聚合后指定维度的方差，方式为 sample。
`var_pop_y`, `var_pop_x`	计算二维统计聚合后指定维度的方差，方式为 population。
`skewness_samp_y`, `skewness_samp_x`	计算二维统计聚合后指定维度的偏度值，方式为 sample。
`skewness_pop_y`, `skewness_pop_x`	计算二维统计聚合后指定维度的偏度值，方式为 population。
`kurtosis_samp_y`, `kurtosis_samp_x`	计算二维统计聚合后指定维度的峰度值，方式为 sample。
`kurtosis_pop_y`, `kurtosis_pop_x`	计算二维统计聚合后指定维度的峰度值，方式为 population。
`correlation`	计算二维统计聚合后的相关。
`covariance_samp`, `covariance_pop`	计算二维统计聚合后的协方差。
`determination_coeff`	计算二维统计聚合后的决定系数。
`slope`	根据二维统计聚合，计算线性拟合线的斜率。
`intercept`	计算二维统计聚合后y的截距。
`x_intercept`	计算二维统计聚合后x的截距。

查看二次聚合的示例

SELECT stddev_samp_x(stats_agg(y, x)) FROM test_stats;
+-----------------------------------------------------+
| stddev_samp_x(stats_agg(test_stats.y,test_stats.x)) |
+-----------------------------------------------------+
| 0.5270462766947299                                  |
+-----------------------------------------------------+

gauge_agg

分析 Gauge数据。与 Counter 不同，Gauge可以减少也可以增加。

gauge_agg(time, numeric_expression)

选项	描述
`numeric_expression`	要操作的数字表达式。可以是常量、列或函数，以及算术运算符的任意组合。

查看 gauge_agg 示例

SELECT gauge_agg(time, pressure) FROM air GROUP BY date_trunc('month', time);
+-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| gauge_agg(air.time,air.pressure)                                                                                                                                                                                |
+-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| {first: {ts: 2023-03-01T00:00:00, val: 54.0}, second: {ts: 2023-03-01T00:00:00, val: 59.0}, penultimate: {ts: 2023-03-14T16:00:00, val: 55.0}, last: {ts: 2023-03-14T16:00:00, val: 80.0}, num_elements: 13122} |
| {first: {ts: 2023-02-01T00:00:00, val: 60.0}, second: {ts: 2023-02-01T00:00:00, val: 54.0}, penultimate: {ts: 2023-02-28T23:57:00, val: 74.0}, last: {ts: 2023-02-28T23:57:00, val: 59.0}, num_elements: 26880} |
| {first: {ts: 2023-01-14T16:00:00, val: 63.0}, second: {ts: 2023-01-14T16:00:00, val: 68.0}, penultimate: {ts: 2023-01-31T23:57:00, val: 54.0}, last: {ts: 2023-01-31T23:57:00, val: 77.0}, num_elements: 16640} |
+-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+

gauge_agg 支持以下二次聚合的函数

函数	描述
`delta`	获取一段时间内Gauge的变化。这是简单的增量，通过从第一个值减去最后一个看到的值来计算。
`time_delta`	获取持续时间，最后一个 Gauge 的时间减去第一个 Gauge 的时间。
`rate`	计算 Gauge 变化和时间变化的比率。
`first_time`	取得 Gauge 中最小的时间戳。
`last_time`	取得 Gauge 中最大的时间戳。
`first_val`	取得 Gauge 中最小时间戳对应的值。
`last_val`	取得 Gauge 中最大时间戳对应的值。
`idelta_left`	计算 Gauge 最早的瞬时变化。这等于第二个值减去第一个值。
`idelta_right`	计算 Gauge 最晚的瞬时变化。这等于最后一个值值减去倒数第二个值。

compact_state_agg

给定一个在离散状态之间切换的系统或值，汇总每个状态所花费的时间。例如，您可以使用compact_state_agg函数来跟踪系统在error、running或starting状态下花费的时间。

compact_state_agg(time_expression, state)

选项	描述
`time_expression`	要操作的时间表达式。可以是常量、列或函数，以及算术运算符的任意组合。

查看 compact_state_agg 示例

示例数据集如下：

CREATE TABLE states(state STRING);
INSERT INTO states VALUES ('2020-01-01 10:00:00', 'starting'),('2020-01-01 10:30:00', 'running'),('2020-01-03 16:00:00', 'error'),('2020-01-03 18:30:00', 'starting'),('2020-01-03 19:30:00', 'running'),('2020-01-05 12:00:00', 'stopping');
SELECT * FROM states;
+---------------------+----------+
| time                | state    |
+---------------------+----------+
| 2020-01-01T10:00:00 | starting |
| 2020-01-01T10:30:00 | running  |
| 2020-01-03T16:00:00 | error    |
| 2020-01-03T18:30:00 | starting |
| 2020-01-03T19:30:00 | running  |
| 2020-01-05T12:00:00 | stopping |
+---------------------+----------+

使用 compact_state_agg 函数聚合：

SELECT compact_state_agg(time, state) FROM states;
+--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| compact_state_agg(states.time,states.state)                                                                                                                                                                                                                                                                                                                                          |
+--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| {state_duration: [{state: error, duration: 0 years 0 mons 0 days 2 hours 30 mins 0.000000000 secs}, {state: starting, duration: 0 years 0 mons 0 days 1 hours 30 mins 0.000000000 secs}, {state: stopping, duration: 0 years 0 mons 0 days 0 hours 0 mins 0.000000000 secs}, {state: running, duration: 0 years 0 mons 3 days 22 hours 0 mins 0.000000000 secs}], state_periods: []} |
+--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+

以上示例将状态数据汇总在一起，以便进一步分析，compact_state_agg 支持如下二次聚合函数：

函数	描述
`duration_in`	统计某个状态的持续时间，或统计某个状态在某个时间段内的持续时间。

duration_in

duration_in(state_agg_data, state [,begin_time, interval_time]) 

选项	描述
`state_agg_data`	`state_agg_data` 函数返回的结果集。
`state`	any 与 compact_state_agg 的 state 类型相同。
`begin_time`	可选，指定时间段内的开始时间。
`interval_time`	可选，指定时间段的持续时间，不指定时，时间段为无穷大。

查看 duration_in 示例

SELECT duration_in(compact_state_agg(time, state), 'running') FROM states;
+--------------------------------------------------------------------------+
| duration_in(compact_state_agg(states.time,states.state),Utf8("running")) |
+--------------------------------------------------------------------------+
| 0 years 0 mons 3 days 22 hours 0 mins 0.000000000 secs                   |
+--------------------------------------------------------------------------+

state_agg

给定一个在离散状态之间切换的系统或值，跟踪状态之间的转换。

state_agg(time_expression, state)

统计每个状态所花费的时间。

查看 state_agg 示例

示例数据集如下：

CREATE TABLE states(state STRING);
INSERT INTO states VALUES('2020-01-01 10:00:00', 'starting'),('2020-01-01 10:30:00', 'running'),('2020-01-03 16:00:00', 'error'),('2020-01-03 18:30:00', 'starting'),('2020-01-03 19:30:00', 'running'),('2020-01-05 12:00:00', 'stopping');
SELECT * FROM states;
+---------------------+----------+
| time                | state    |
+---------------------+----------+
| 2020-01-01T10:00:00 | starting |
| 2020-01-01T10:30:00 | running  |
| 2020-01-03T16:00:00 | error    |
| 2020-01-03T18:30:00 | starting |
| 2020-01-03T19:30:00 | running  |
| 2020-01-05T12:00:00 | stopping |
+---------------------+----------+

使用 state_agg 函数聚合：

SELECT state_agg(time, state) FROM states;
+--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| state_agg(states.time,states.state)                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                |
+--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| {state_duration: [{state: running, duration: 0 years 0 mons 3 days 22 hours 0 mins 0.000000000 secs}, {state: error, duration: 0 years 0 mons 0 days 2 hours 30 mins 0.000000000 secs}, {state: stopping, duration: 0 years 0 mons 0 days 0 hours 0 mins 0.000000000 secs}, {state: starting, duration: 0 years 0 mons 0 days 1 hours 30 mins 0.000000000 secs}], state_periods: [{state: running, periods: [{start_time: 2020-01-01T10:30:00, end_time: 2020-01-03T16:00:00}, {start_time: 2020-01-03T19:30:00, end_time: 2020-01-05T12:00:00}]}, {state: starting, periods: [{start_time: 2020-01-01T10:00:00, end_time: 2020-01-01T10:30:00}, {start_time: 2020-01-03T18:30:00, end_time: 2020-01-03T19:30:00}]}, {state: error, periods: [{start_time: 2020-01-03T16:00:00, end_time: 2020-01-03T18:30:00}]}]} |
+--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+

以上示例将状态数据汇总在一起，以便进一步分析，state_agg 支持如下二次聚合函数：

函数	描述
`duration_in`	统计某个状态的持续时间，或统计某个状态在某个时间段内的持续时间。
state_at	统计一时刻所处的状态。

duration_in

duration_in(state_agg_data, state [,begin_time, interval_time]) 

选项	描述
`state_agg_data`	`state_agg` 函数返回的结果集。
`state`	`any` 与 `compact_state_agg` 的 `state` 类型相同。
`begin_time`	可选，指定时间段内的开始时间。
`interval_time`	可选，指定时间段的持续时间，不指定时，时间段为无穷大。

查看 duration_in 示例

**统计 'running' 状态的持续时间。

SELECT duration_in(state_agg(time, state), 'running') FROM states;
+------------------------------------------------------------------+
| duration_in(state_agg(states.time,states.state),Utf8("running")) |
+------------------------------------------------------------------+
| 0 years 0 mons 3 days 22 hours 0 mins 0.000000000 secs           |
+------------------------------------------------------------------+

统计从 '2020-01-01 11:00:00' 开始 'running' 状态的持续时间。

SELECT duration_in(state_agg(time, state), 'running', Timestamp '2020-01-01 11:00:00') FROM states;
+----------------------------------------------------------------------------------------------+
| duration_in(state_agg(states.time,states.state),Utf8("running"),Utf8("2020-01-01 11:00:00")) |
+----------------------------------------------------------------------------------------------+
| 0 years 0 mons 3 days 21 hours 30 mins 0.000000000 secs                                      |
+----------------------------------------------------------------------------------------------+

统计从2020-01-01 11:00:00 开始的四天内 'running' 状态的持续时间。

SELECT duration_in(state_agg(time, state), 'running', Timestamp '2020-01-01 11:00:00', interval '4 day') FROM states;
+-------------------------------------------------------------------------------------------------------------------------------------------+
| duration_in(state_agg(states.time,states.state),Utf8("running"),Utf8("2020-01-01 11:00:00"),IntervalMonthDayNano("73786976294838206464")) |
+-------------------------------------------------------------------------------------------------------------------------------------------+
| 0 years 0 mons 3 days 20 hours 30 mins 0.000000000 secs                                                                                   |
+-------------------------------------------------------------------------------------------------------------------------------------------+

state_at

state_at(state_agg_data, time_expression)

选项	描述
`state_agg_data`	`state_agg` 函数返回的结果集。
`time_expression`	要操作的时间表达式。可以是常量、列或函数，以及算术运算符的任意组合。

查看 state_at 示例

SELECT state_at(state_agg(time, state), Timestamp '2020-01-01 10:30:00') FROM states;
+---------------------------------------------------------------------------+
| state_at(state_agg(states.time,states.state),Utf8("2020-01-01 10:30:00")) |
+---------------------------------------------------------------------------+
| running                                                                   |
+---------------------------------------------------------------------------+

社区版
企业版

candlestick_agg

进行金融资产数据分析，能得到股票的开盘价和收盘价，以及最低和最高价。

candlestick_agg(time, price, volume)

查看 candlestick_agg 示例

示例数据集如下：

CREATE TABLE IF NOT EXISTS tick(price bigint ,volume bigint);
INSERT tick(time, price, volume) VALUES('1999-12-31 00:00:00.000', 111, 444),('1999-12-31 00:00:00.005', 222, 444),('1999-12-31 00:00:00.010', 333, 222),('1999-12-31 00:00:10.015', 444, 111),('1999-12-31 00:00:10.020', 222, 555),('1999-12-31 00:10:00.025', 333, 555),('1999-12-31 00:10:00.030', 444, 333),('1999-12-31 01:00:00.035', 555, 222);
SELECT * FROM tick;
+-------------------------+-------+--------+
| time                    | price | volume |
+-------------------------+-------+--------+
| 1999-12-31T00:00:00     | 111   | 444    |
| 1999-12-31T00:00:00.005 | 222   | 444    |
| 1999-12-31T00:00:00.010 | 333   | 222    |
| 1999-12-31T00:00:10.015 | 444   | 111    |
| 1999-12-31T00:00:10.020 | 222   | 555    |
| 1999-12-31T00:10:00.025 | 333   | 555    |
| 1999-12-31T00:10:00.030 | 444   | 333    |
| 1999-12-31T01:00:00.035 | 555   | 222    |
+-------------------------+-------+--------+

使用 candlestick_agg 进行聚合。

SELECT candlestick_agg(time, price, volume) FROM tick;
+-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| candlestick_agg(tick.time,tick.price,tick.volume)                                                                                                                                                                                   |
+-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| {open: {ts: 1999-12-31T00:00:00, val: 111.0}, close: {ts: 1999-12-31T01:00:00.035, val: 555.0}, low: {ts: 1999-12-31T00:00:00, val: 111.0}, high: {ts: 1999-12-31T01:00:00.035, val: 555.0}, volume: {vol: 2886.0, vwap: 850149.0}} |
+-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+

可以在上述示例中分别提取开盘价、收盘价等。支持的函数有：

函数	描述
`close`	收盘价。
`close_time`	收盘时间。
`high`	最高价。
`high_time`	最高价时间。
`low`	最低价。
`low_time`	最低价时间。
`open`	开盘价。
`open_time`	开盘时间。
`volume`	总成加量。
`vwap`	成交量加权平均价格。

查看示例

SELECT close(candlestick_agg(time,price,volume)) AS close_price FROM tick;
+-------------+
| close_price |
+-------------+
| 555.0       |
+-------------+

两步聚合

stats_agg​

gauge_agg​

compact_state_agg​

duration_in​

state_agg​

duration_in​

state_at​

candlestick_agg​

stats_agg

gauge_agg

compact_state_agg

duration_in

state_agg

duration_in

state_at

candlestick_agg