常用函数介绍

1

1

3

4

1

1

3

4

1

1

3

4

1

1

3

4

1

1

3

4

avg

avg(x)

返回表达式中所有值的平均值。只能用于数值字段

avg( profit ) 返回利润平均值

max

max(x)

返回表达式中所有值的最大值。只能用于数值字段

max( profit ) 返回利润最大值

min

min(x)

返回表达式中所有值的最小值。只能用于数值字段

min( profit ) 返回利润最小值

count

count(x)

计数，求行数

count( p_date ) 返回总天数

sum

sum(x)

返回表达式中所有值的总和。只能用于数值字段

sum( profit ) 返回利润总和

uniqCombined

uniqCombined(HLL_precision)(x[, ...])

计算不同参数值的近似数目。对于大集合(2 亿或更多元素)，由于散列函数的选择不好，估计误差将大于理论值。

quantile

quantile(level)(x)

返回表达式中所有值的分位数。只能用于数值字段。level 范围 0-1

quantile(0.5)(x) 返回 x 的 0.5 分位数

uniq

uniq(x)

计数不同。与 count(distinct) 作用相同，精确度上存在 0.5% 的误差。如需精确值，请使用count(distinct)，但其查询耗时较长，可能因为超时而查不出数，不建议使用。

argMax

argMax(arg,val)

根据字段 val 计算其最大值. 然后取其最大值所在记录行字段Arg 的值

groupArray

groupArray(n)(fieldname)

取前 n 条记录 . 结果为一个数组

any

any(x)

选择第一个遇到的值

quantileExact

quantileExact(level)(x)

返回表达式中所有值的分位数。只能用于数值字段。level 范围 0-1。 与 quantile 作用相同，是精确查询。使用 quantileExact 时查询耗时较长，可能因为超时而查不出数，不建议使用。

quantileExact(0.5)(x) 返回 x 的 0.5 分位数

2020/12/21

2020/12/21

2020/12/21 0:00

20201221

2020/12/21

2020/12/21 0:00

2020/12/21 18:00

2020/12/21

2020/12/21 18:00

2020/12/21 18:00

1608544800

2020/12/22 2:00

2020/12/22

2020/12/21

toDateTime

toDateTime(x)

将字符型时间日期转化为时间日期型

toDateTime('2018-12-24 10:10:00')

toStartOfFiveMinute

toStartOfFiveMinute（x）

截取时间日期到最近的 5 的倍数分钟（之后归零），返回日期

toStartOfFiveMinute(toDateTime('2018-12-11 11:12:13')) 返回 2018-12-11 11:10:00

now

now（)

生成当前时间日期

now( ) 返回 2018-12-13 10:10:12

toStartOfFifteenMinutes

toStartOfFifteenMinutes（x)

截取时间日期到最近的 15 的倍数分钟（之后归零），返回日期

toStartOfFifteenMinute(toDateTime('2018-12-11 11:12:13')) 返回 2018-12-11 11:00:00

toStartOfInterval

toStartOfInterval(time_or_data, INTERVAL x unit [, time_zone])

这是名为 toStartOf*的所有函数的通用函数。例如，toStartOfInterval（t，INTERVAL 1 year）返回与 toStartOfYear（t）相同的结果，toStartOfInterval（t，INTERVAL 1 month）返回与 toStartOfMonth（t）相同的结果， toStartOfInterval（t，INTERVAL 1 day）返回与 toStartOfDay（t）相同的结果， toStartOfInterval（t，INTERVAL 15 minute）返回与 toStartOfFifteenMinutes（t）相同的结果。

toStartOfInterval(toDateTime('2019-10-10 09:09:20'),INTERVAL 1 year) 返回 2019-01-01

toIntervalDay

toIntervalDay(x)

日期转化为时间戳，天级别

toIntervalDay(toDateTime('2019-08-12 11:12:13')) 返回 1565579533

toIntervalMinute

toIntervalMinute(x)

日期转化为时间戳，分钟级别

toIntervalMinute(toDateTime('2019-08-14 11:12:13')) 返回 1565579533

toIntervalHour

toIntervalHour(x)

日期转化为时间戳，小时级别

toIntervalHour(toDateTime('2019-08-14 11:12:13')) 返回 1565579533

toMonday

toMonday(x)

将 Date 或 DateTime 向前取整到本周的星期一。 返回 Date 类型。

toMonday(toDateTime('2019-08-14 11:12:13')) 返回 2019-08-12

toStartOfHour

toStartOfHour(x)

将DateTime向前取整到当前小时的开始。

toStartOfHour(toDateTime('2018-12-11 11:12:13')) 返回 11

today

today( )

生成今天的日期

today( ) 返回 2018-12-13

toHour

toHour(x)

取时间日期的小时

toHour(toDateTime('2018-12-11 11:12:13')) 返回 11

toStartOfTenMinutes

toStartOfTenMinutes(x)

将 DateTime 以十分钟为单位向前取整到最接近的时间点

toStartOfTenMinute(toDateTime('2018-12-11 11:12:13')) 返回 2018-12-11 11:00:00

toStartOfDay

toStartOfMinute(string date time)

将 DateTime 向前取整到当日的开始。

toYear

toYear(string date)

返回日期中的年

toRelativeWeekNum

toRelativeWeekNum(date)

将 Date 或 DateTime 转换为星期数，从过去的某个固定时间点开始。

toMonth

toMonth(string date)

返回日期中的月

toStartOfMinute

toStartOfMinute( )

截取时间日期到分钟（之后归零），返回日期

toStartOfMinute(toDateTime('2018-12-11 11:12:13')) 返回 2018-12-11 11:12:00

toUnixTimestamp

toUnixTimestamp( )

将 DateTime 转换为 unix 时间戳

addDays

addDays(date_time,int)

函数将一段时间间隔添加到 Date/DateTime，然后返回 Date/DateTim

toRelativeYearNum

toRelativeYearNum(date_time)

将 Date 或 DateTime 转换为年份的编号，从过去的某个固定时间点开始

year

year(Date/DateTime/String date)

返回日期中的年

year(toDateTime('2018-12-11 11:12:13'))返回 2018

month

month(Date/DateTime/String date)

返回日期中的月

month(toDateTime('2018-12-11 11:12:13'))返回 12

quarter

quarter(Date/DateTime/String date)

返回日期中的季度数

quarter(toDateTime('2018-12-11 11:12:13'))返回 12

day

day(Date/DateTime/String)

返回 dayOfMonth

day('2019-09-12') 返回 12

last_day

last_day(Date/DateTime/String date)

返回日期所在的月份的最后一天

last_day(toDateTime('2018-12-11 11:12:13'))返回 2018-12-31

next_day

next_day(Date/DateTime/String date, string day_of_week)

返回日期中的下一个星期day_of_week

next_day(toDate('2015-01-14'), 'TU') 返回 2015-01-20

dateDiff

dateDiff(Date/DateTime date1, Date/DateTime date2 [, String timezone])； dateDiff(String unit, Date/DateTime date1, Date/DateTime date2 [, String timezone])

返回两个日期的差值

dateDiff(now(), yesterday())返回 -1

date_sub

date_sub (string/Date/DateTime startdate, int days)

返回start_time 前 days 天的日期/时间

date_sub('2019-09-08', 1) 返回'2019-09-07'

date_add

date_add (string/Date/DateTime startdate, int days)

返回start_time 后 days 天的日期/时间

date_add('2019-09-08', 1) 返回'2019-09-09'

from_unixtime

from_unixtime(Date/DateTime/UInt32 date, String parttern[, String timezone])

将日期或时间戳转换为 pattern 形式的字符串

from_unixtime(toDateTime('2019-09-09 09:00:00'), 'time: %F %T', 'Asia/Shanghai') 返回'time: 2019-09-09 09:00:00'

to_date,toDate

to_date(String/UInt16 date)

将字符串/自 1970-01-01 起的第 date 天转换为日期类型

toDate('20190909') 返回'2019-09-09'

date_format

date_format(Date/DateTime/String, String pattern)

将日期按指定格式输出

date_format('2019-09-09', 'yyyy') 返回 '2019'

unix_timestamp

unix_timestamp(Date/DateTime/String)

将日期转换为 timestamp

unix_timestamp(toDateTime('2019-09-09 09:00:00'), 'time: %F %T', 'Asia/Shanghai') 返回'time: 2019-09-09 09:00:00'

toWeek

toWeek(date[,mode])

返回日期所在的周, 范围[0, 53]

toWeek(toDate('2019-12-06'), 3) 返回 49

toDayOfWeek

todayofweek(date)

返回日期所在的星期，范围[1,7]

todayofweek('2020-01-01') 返回 3

143876768892010

143876768892010

143876768892010

143876768892010

123a

转换失败

cast

cast(X, 'Y')

通用强转函数，将名称为X的任意类型数据，转化成 Y 格式

将 int 类型的 uid 转换为 String 类型 CAST (uid, 'String')

toString

toString(x)

将数值型、字符型、日期等转化为字符型

toString('2018-12-24') 返回 2018-12-24

toInt64

toInt64(x)

将数据类型转化为 int 格式(64 个字节)

toInt64(123.883) 返回 123

toUInt8OrZero

toUInt8OrZero(x)

将无符号整数字符型转化为整数型，否则返回 0

toUInt8OrZero('123.12') 返回 0

toDateOrZero

toDateOrZero(x)

将数据类型转化为 DATE 格式，否则返回 0

toDateOrZero(toDateTime('2018-12-11 11:12:13')) 返回 2018-12-11

toUInt16OrZero

toUInt16OrZero(x)

将无符号整数字符型转化为整数型，否则返回 0

toUInt8OrZero('123') 返回 123

toUInt64OrZero

toUInt64OrZero(x)

将数据类型转化为 int 格式(64 个字节)，失败则为 0

toUInt64OrZero('123') 返回 123

toDateOrNull

toDateOrNull(a)

将 a 的数据类型转成 date or null

toUInt32OrZero

toUInt32OrZero(x)

将数据类型转化为 int 格式(32 个字节)，失败则为 0

toFloat32OrZero

toFloat32OrZero( )

将数值字符串型转化为数值型

toFloat32OrZero(‘-123’) 返回-123

toIntervalMonth

toIntervalMonth( )

将数字类型参数转换为 Interval 类型（时间区间）

toInt32

toInt32(a)

将 a 的数据类型转成 int32

toDateTimeOrNull

toDateTimeOrNull(a)

将 a 的数据类型转成 datetime or null

toFloat64

toFloat64(a)

将 a 的数据类型转成 float64

toUInt8

toUInt8(a)

将 a 的数据类型转成 Uint8

toFloat64OrZero

toFloat64OrZero(a)

将 a 的数据类型转成 float or zero

toUInt32

toUInt32(a)

将 a 的数据类型转成 Uint32

parseDateTimeBestEffort

parseDateTimeBestEffort()

将数字类型参数解析为 Date 或 DateTime 类型。 与 toDate 和 toDateTime 不同，parseDateTimeBestEffort 可以进行更复杂的日期格式。

parseDateTimeBestEffortOrNull

parseDateTimeBestEffortOrNull()

将数字类型参数解析为 Date 或 DateTime 类型,遇到无法处理的日期格式时返回 null

parseDateTimeBestEffortOrZero

parseDateTimeBestEffortOrZero()

将数字类型参数解析为 Date 或 DateTime 类型,遇到无法处理的日期格式时返回零 Date 或零 DateTime

门前大桥下

，

123

2020/12/22 18:00

2020/12/21

小明

8,9,8

2020/12/22 18:00

19

substring

substring(s, offset, length)

字符串截取

substring('123abcABC', 2, 3) 返回 23a

empty

empty(x)

判断字符串是空为 1，否则为 0

empty('123a') 返回 0

length

length(x)

返回字符串的长度

length('123a') 返回 4

extractAll

extractAll(haystack,pattern)

返回匹配到的所有子串，输出列表

extractAll('iioomAj12123124OOBJ123B', '\d+') 返回 [12123124,123]

splitByChar

splitByChar(separator, s)

以单个字符分割字符串

concat

concat(s1, s2, ...)

将参数中的多个字符串拼接，不带分隔符

concat('123', 'abc', 'ABC') 返回 123abcABC

lower

lower(string)

将字符串转为小写

char_length

char_length(string)

假定字符串以 UTF-8 编码组成的文本，返回此字符串的 Unicode 字符长度。如果传入的字符串不是 UTF-8 编码，则函数可能返回一个预期外的值（不会抛出异常）

startsWith

startsWith(s, prefix)

返回是否以指定的前缀开头。如果字符串以指定的前缀开头，则返回 1，否则返回 0

replaceRegexpAll

replaceRegexpAll(haystack,pattern,replacement)

正则匹配替换所有匹配到的pattern

replaceOne('asd123cbbj464sd', 'sd', '-') 返回 a-123cbbj464-

replaceRegexpOne

replaceRegexpOne(haystack, pattern, replacement)

使用‘pattern’正则表达式替换。

replaceAll

replaceAll(haystack, pattern, replacement)

用‘replacement’子串替换‘haystack’中出现的所有‘pattern’子串

split

split(string str, string pat)

按照 pat 字符串分割 str，会返回分割后的字符串数组

split('abc', 'b') 返回['a', 'c']

concat_ws

concat_ws(String delimiter, String str1, String str2, ...)

返回以'delimiter'连接的字符串

concat_ws('_', 'abc', 'def') 返回 'abc_def'

substring

substring(String str, int start, int len)，substr(String str, int start, int len)

返回第 start 起长度为 len 的字符串

substring('abc', 2); 返回'bc'

lpad,rpad

lpad(String, len, pad_str)

将 str 进行用 pad 进行左补足到 len 位

lpad('abcd', 10, '.') 返回 '......abcd'

regexp_replace

regexp_replace(String str, String str1, String str2)

返回将 str 中的 str1 转换为 str2 后的结果, 支持 re2 正则表达式

regexp_replace('world.', '^', 'hello ') 返回'hello world.'

200

正数

250

(200,300]

105

350

300

multiIf

multiIf(cond_1, then_1, cond_2, then_2...else)

允许您在查询中更紧凑地编写CASE运算符 参数: *cond_N — 函数返回then_N的条件。 *then_N — 执行时函数的结果。 *else — 如果没有满足任何条件，则为函数的结果。

multiIf(1 > 2, '正确', 2 < 0, '正确', '错误') 返回 错误

if

if(cond, then, else), cond ? operator then : else

如果cond ！= 0则返回then，如果cond = 0则返回else。 cond必须是UInt8类型，then和else必须存在最低的共同类型。

if(1 > 2, '正确', '错误') 返回 错误

case

CASE WHEN a THEN b [WHEN c THEN d]* [ELSE e] END

如果a为TRUE,则返回b；如果c为TRUE，则返回d；否则返回e

visitParamExtractInt

visitParamExtractUInt(params, name)

将名为“name”的字段的值解析成 UInt64。如果这是一个字符串字段，函数将尝试从字符串的开头解析一个数字。如果该字段不存在，或无法从它中解析到数字，则返回0。

visitParamExtractFloat

visitParamExtractFloat(params, name)

将名为“name”的字段的值解析成 float64

visitParamExtractBool

visitParamExtractBool(params, name)

解析一个 true/false 值. 结果是 UInt8

visitParamHas

visitParamHas(params, name)

检查是否存在“name”名称的字段

visitParamExtractRaw

visitParamExtractRaw(params, name)

返回字段的值，包含空格符。

visitParamExtractRaw('{"abc":{"def":[1,2,3]}}', 'abc') = '{"def":[1,2,3]}'

get_json_object

get_json_object(string json_string, string path)

返回 JSON 中 path 指定的元素

get_json_object('{"n_s" : [{"ac":"abc","xz":"xz"}, {"def":"def"}], "n_i" : [1, 23]}', '$.n_s[0].ac'); 返回'abc'

power

power(x, y)

接受 x 和 y 两个参数。返回 x 的 y 次方

pow

pow(x, y)

接受 x 和 y 两个参数。返回 x 的 y 次方。

pow(2, 3) 返回 8

sqrt

sqrt(x)

接受一个数值类型的参数并返回它的平方根。

sqrt(4) 返回 2

函数名称

函数格式

用途

示例

isNotNull

isNotNull(x)

检查参数是否不为 NULL. 是返回 1，否返回 0

sNotNull('abc') 返回 1

isNull

isNull(x)

检查参数是否为 NULL,是 NULL 返回 1,不是返回 0

isNull(null) 返回 1

coalesce

coalesce(x,...)

检查从左到右是否传递了“NULL”参数并返回第一个非'NULL参数。

coalesce(null,null,a,b,null) 返回 a

assumeNotNull

assumeNotNull( )

将 Nullable 类型的值转换为非 Nullable 类型的值

conv

conv(String/Int num, Int from_base, Int to_base)

进制转换

conv('10',10,2) 返回'1010'

bin

bin(Int/DateTime/String)

转换为二进制数

bin(10) 返回'1010'

cityHash64

cityHash64O()

计算任意数量字符串的 CityHash64 或使用特定实现的 Hash 函数计算任意数量其他类型的 Hash

intHash64

intHash64( )

从任何类型的整数计算 64 位哈希码

domain

domain(x)

返回URL的域名

domain('http://www.baidu.com.cn') 返回 www.baidu.com.cn

cutToFirstSignificantSubdomain

cutToFirstSignificantSubdomain( )

返回包含顶级域名与第一个有效子域名之间的内容

cutToFirstSignificantSubdomain('https://news.yandex.com.tr/')) = 'yandex.com.tr'

parse_url

parse_url(String url, String name)

返回 url 中为 name 的部分, 无法解析返回空字符串

parse_url('https://bytedance.feishu.cn/space/xx#PN78WD', 'PROTOCOL') 返回 https

map key

[map型字段名]{'[待提取字段名]'}

从 map 类型的字段中提取某一字段数据

select deductions{'Federal Taxes'} from employees limit 1;

map

map(KeyType k1, ValueType v1, KeyType k2, ValueType v2 ...)

构造 map 类型数据

map('a', 'b', 'c', 'd') 返回 {'a': 'b', 'c', 'd'}

str_to_map

map(String value, String kv_delimiter, String item_delimiter)

String 转 map 类型

str_to_map('a:b,c:d', ',', ':') 返回 {'a': 'b', 'c': 'd'}

arrayConcat

arrayConcat(array)

合并参数中传递的所有数组。

SELECT arrayConcat([1, 2], [3, 4], [5, 6]) AS res ┌─res─────┐ │ [1,2,3,4,5,6] │ └───────┘

notEmpty

notEmpty()

对于空字符串返回 0，对于非空字符串返回 1

arrayJoin

arrayJoin(array)

此函数将数组作为参数，并将该行在结果集中复制数组元素个数。 除了应用此函数的列中的值之外，简单地复制列中的所有值; 它被替换为相应的数组值。

SELECT arrayJoin([1, 2, 3] AS src) AS dst, 'Hello', src ┌dst-┬'Hello'-┬─src──┐ │ 1 │ Hello │ [1,2,3] │ │ 2 │ Hello │ [1,2,3] │ │ 3 │ Hello │ [1,2,3] │ └ ─ ┴ ─ ─ ┴─ ───┘

pmod

pmod(Int a, Int b)

浮点数会转换为整数取模, 如有特殊需求, 可在后期支持

pmod(10, 3) 返回 1

round

round(x,[N])

将值取整到指定的小数位数。 该函数按顺序返回最近的数字。如果给定数字包含多个最近数字，则函数返回其中最接近偶数的数字（银行的取整方式）。

round(123.883, 1) 返回 123.9

abs

abs(a)

计算数字（a）的绝对值

bitAnd

bitAnd(a, b)

结果类型是一个整数，其位数等于其参数的最大位。如果至少有一个参数为有符数字，则结果为有符数字。如果参数是浮点数，则将其强制转换为 Int64

rand

rand( )

返回一个 UInt32 类型的随机数字，所有 UInt32 类型的数字被生成的概率均相等

hostName

hostName()

返回一个字符串，其中包含执行此函数的主机的名称。

size

size(Array/Map/String)

返回里面的元素个数

size(map('a', 'b', 'c', 'd')) 返回 2