對于Timelyre表，使用除sum/avg/max/min/count之外的所有聚合函數時必須滿足以下兩個要求的其中之一：

全量tag字段where條件過濾
全量tag字段group by聚合

例如，表timelyre_test有tag1與tag2兩個tag字段，則使用AVG聚合函數方法如下：

SELECT avg(v) FROM timelyre_test WHERE tag1=‘xx’ AND tag2=‘xx’;

或者

SELECT avg(v) FROM timelyre_test GROUP BY tag1,tag2;

COUNT

函數名

返回類型

描述

count(<col>)

Int

統計字段數量

說明

返回記錄條數。

舉例

SELECT count(<field_name>) FROM <table_name> WHERE tag='xx';

對于count函數，Timelyre有一些特殊用法：

1.推薦使用count(<field_name>)的方式，其中，<field_name>為非時間戳與tag的普通字段。此種用法不會統計NULL值

2.count( * )的方式會返回全表行數，返回結果較慢，不推薦使用。

SUM

函數名

返回類型

描述

sum(<col>)

Int

求和

說明

計算某一列所有值的和。

舉例

SELECT sum(<field_name>) FROM <table_name> WHERE tag='xx';

AVG

函數名

返回類型

描述

avg(<col>)

Double

平均值

說明

返回某常數或者某一列的平均值。

舉例

SELECT avg(<field_name>) FROM <table_name> WHERE tag='xx';

MIN

函數名

返回類型

描述

min(<col>)

字段的公共類型

最小值

說明

返回某列的最小值。

舉例

SELECT min(<field_name>) FROM <table_name> WHERE tag='xx';

MAX

函數名

返回類型

描述

max(<col>)

字段的公共類型

最大值

說明

返回某列的最大值。

舉例

SELECT max(<field_name>) FROM <table_name> WHERE tag='xx';

STDDEV

函數名

返回類型

描述

stddev(x)

Double

標準差

說明

返回指定列的標準差。

舉例

SELECT stddev(<field_name>) FROM <table_name> WHERE tag='xx';

PERCENTILE2

函數名

返回類型

描述

percentile2(<col>, N)

Double

數值區域的百分比數值點

說明

返回數值區域的百分比數值點，即返回排序值排位為N%的值。

N的值必須取0到100之間。

舉例

SELECT percentile2(<field_name>,N) FROM <table_name> WHERE tag='xx';

TOP

函數名

返回類型

描述

top(<col>, N)

Array

字段中最大的N個值

舉例

SELECT top(<field_name>,N) FROM <table_name> WHERE tag='xx';

BOTTOM

函數名

返回類型

描述

bottom(<col>, N)

Array

字段中最小的N個值

舉例

SELECT bottom(<field_name>,N) FROM <table_name> WHERE tag='xx';

FIRST

函數名

返回類型

描述

first(<col>)

Double

最早時間戳的字段值

舉例

SELECT first(<field_name>) FROM <table_name> WHERE tag='xx';

LAST

函數名

返回類型

描述

last(<col>)

Double

最晚時間戳的字段值

舉例

SELECT last(<field_name>) FROM <table_name> WHERE tag='xx';

TIMELYRE_SAMPLE

函數名

返回類型

描述

timelyre_sample(<col>,N)

Array

字段值的隨機N個樣本

舉例

SELECT timelyre_sample(<field_name>,N) FROM <table_name> WHERE tag='xx';

MODE

函數名

返回類型

描述

mode(<col>)

Double

字段值列表中最常用的值

舉例

SELECT mode(<field_name>) FROM <table_name> WHERE tag='xx';

MEDIAN

函數名

返回類型

描述

median(<col>)

Double

單個字段中的排序值的中位數

舉例

SELECT median(<field_name>) FROM <table_name> WHERE tag='xx';

SPREAD

函數名

返回類型

描述

spread(<col>)

Double

字段的最小值和最大值之間的差值

舉例

SELECT spread(<field_name>) FROM <table_name> WHERE tag='xx';

INTEGRAL

{alternativeSolution}

函數名

返回類型

描述

integral(<col>,[<time_unit>])

Double

指定時間范圍內字段值曲線下的積分面積

說明

<time_unit>為時間窗口，默認值為1s，可選的值有:ns/u/ms/s/m/h/d/w

舉例

SELECT integral(v) FROM <table_name> WHERE tag='xx';

SELECT integral(v,'100ms') FROM <table_name> WHERE tag='xx';

DERIVATIVE

{alternativeSolution}

函數名

返回類型

描述

derivative(<col>,[<time_unit>])

Double

指定時間窗口內相鄰兩個字段值之間的變化率

說明

<time_unit>為時間窗口，默認值為1s，可選的值有:ns/u/ms/s/m/h/d/w
derivative的計算公式為: (value - previous_value) / ( (timestamp - previous_timestamp) / time_unit)

舉例

SELECT derivative(v) FROM <table_name> WHERE tag='xx';

SELECT derivative(v,'100ms') FROM <table_name> WHERE tag='xx';

NON_NEGATIVE_DERIVATIVE

{alternativeSolution}

函數名

返回類型

描述

non_negative_derivative(<col>,[<time_unit>])

Double

指定時間窗口內相鄰兩個字段值之間大于等于0的變化率

說明

<time_unit>為時間窗口，默認值為1s，可選的值有:ns/u/ms/s/m/h/d/w
non_negative_derivative的計算公式為: (value - previous_value) / ( (timestamp - previous_timestamp) / time_unit)，取其中大于等于0的值

舉例

SELECT non_negative_derivative(v) FROM <table_name> WHERE tag='xx';

SELECT non_negative_derivative(v,'100ms') FROM <table_name> WHERE tag='xx';

DIFFERENCE

{alternativeSolution}

函數名

返回類型

描述

difference(<col>)

Double

相鄰兩個字段值之間的差值，會按照時間戳排序

舉例

SELECT difference(v) FROM <table_name> WHERE tag='xx';

NON_NEGATIVE_DIFFERENCE

{alternativeSolution}

函數名

返回類型

描述

non_negative_difference(<col>)

Double

相鄰兩個字段值之間大于等于0的差值，會按照時間戳排序

舉例

SELECT non_negative_difference(v) FROM <table_name> WHERE tag='xx';

ELAPSED

{alternativeSolution}

函數名

返回類型

描述

elapsed(<col>,[<time_unit>])

Double

一個字段在連續的時間間隔間的差異

說明

<time_unit>為時間窗口，默認值為1ns，可選的值有:ns/u/ms/s/m/h/d/w

舉例

SELECT elapsed(v) FROM <table_name> WHERE tag='xx';

SELECT elapsed(v,'100ms') FROM <table_name> WHERE tag='xx';

CUMULATIVE_SUM

{alternativeSolution}

函數名

返回類型

描述

cumulative_sum(<col>)

Double

后續字段值的總計,按照時間戳排序

說明

計算公式: 按照時間戳排序后，每一行的和等于之前所有數據的和加上當前行的數據，sum = pre_sum + value

舉例

SELECT cumulative_sum(v) FROM <table_name> WHERE tag='xx';

MOVING_AVERAGE

{alternativeSolution}

函數名

返回類型

描述

moving_average(<col>,N)

Double

包含N個連續字段值的滾動平均值

說明

計算公式: 假設有5個值(v1-v5)，我們指定窗口大小為3，那么按照時間排序后會生成3個窗口，v1-v3, v2-v4, v3-v5，分別計算這3個窗口的平均值，輸出結果

舉例

SELECT moving_average(v,3) FROM <table_name> WHERE tag='xx';

股份杠杆-10倍杠杠 跌多少会爆仓-【东方资本】,股票能不能加杠杆,开配资公司需要什么条件才能开,金太阳证券是正规的吗

股份杠杆-10倍杠杠跌多少会爆仓-【东方资本】,股票能不能加杠杆,开配资公司需要什么条件才能开,金太阳证券是正规的吗