通过

内置函数

  • 项目

适用于：勾选“是” Databricks SQL 勾选“是” Databricks Runtime

本文提供适用于字符串和二进制类型、数字标量、聚合、窗口、数组、映射、日期和时间戳、强制转换、CSV 数据、JSON 数据、XPath 操作的内置运算符和函数及其他杂项函数的链接与说明。

对于现有内置函数不支持的用例，请考虑定义自定义函数。 请参阅什么是用户定义函数 (UDF)？。

另请参阅：

运算符和谓词

若要了解如何在考虑到运算符相互之间关系的情况下分析运算符，请参阅运算符优先顺序。

操作员 语法 说明
& expr1 & expr2 返回 expr1 和 expr2 的按位 AND 结果。
and expr1 and expr2 返回 expr1 和 expr2 的逻辑 AND。
* multiplier * multiplicand 返回 multiplier 乘以 multiplicand 的结果。
!= expr1 != expr2 如果 expr1 不等于 expr2，则返回 true，否则返回 false。
! !expr 返回布尔表达式的逻辑 NOT 结果。
between expr1 [not] between expr2 and expr2 测试 expr1 是否大于等于 expr2 且小于等于 expr3。
[ ] arrayExpr [ indexExpr ] 返回 ARRAY arrayExpr 的第 indexExpr 个元素。
[ ] mapExpr [ keyExpr ] 返回 keyExpr 中 MAP mapExpr 的值。
^ expr1 ^ expr2 返回 expr1 和 expr2 的按位异或 OR (XOR) 结果。
: jsonStr : jsonPath 返回从 jsonStr 中提取的字段。
:: expr :: type 将值 expr 强制转换为目标数据类型 type。
?:: expr ?:: type 如果可能，将值 expr 转换为目标数据类型 type；否则返回 NULL。
div dividend div divisor 返回 dividend 除以 divisor 所得结果的整数部分。
. mapExpr . keyIdentifier 按照 keyIdentifier 返回 MAP 值。
. structExpr . fieldIdentifier 按照 fieldIdentifier 返回 STRUCT 字段。
== expr1 == expr2 如果 expr1 等于 expr2，则返回 true；否则返回 false。
= expr1 = expr2 如果 expr1 等于 expr2，则返回 true；否则返回 false。
>= expr1 >= expr2 如果 expr1 大于或等于 expr2，则返回 true，否则返回 false。
> expr1 > expr2 如果 expr1 大于 expr2，则返回 true，否则返回 false。
exists exists(query) 如果 query 返回至少一行，则返回 true，否则返回 false。
ilike str [not] ilike (pattern[ESCAPE escape]) 如果 str（不）匹配具有 escape 的 pattern（不区分大小写），则返回 true。
ilike str [not] ilike {ANY\|SOME\|ALL}([pattern[, ...]]) 如果 str（不）匹配任意/所有模式（不区分大小写），则返回 true。
in elem [not] in (expr1[, ...]) 如果 elem（不）等于任何 exprN，则返回 true。
in elem [not] in (query) 如果 elem（不）等于 query 中的任何行，则返回 true。
is distinct expr1 is [not] distinct from expr2 测试参数是否具有不同的值，其中 NULL 被视为可比较值。
is false expr is [not] false 测试 expr 是否为 false。
is null expr is [not] null 如果 expr 不为 NULL，则返回 true。
is true expr is [not] true 测试 expr 是否为 true。
like str [not] like (pattern[ESCAPE escape]) 如果 str（不）匹配具有 escape 的 pattern，则返回 true。
like str [not] like {ANY\|SOME\|ALL}([pattern[, ...]]) 如果 str（不）匹配任意/所有模式，则返回 true。
<=> expr1 <=> expr2 对于非空操作数，返回与 EQUAL(=) 相同的结果，但如果两个操作数均为 NULL，则返回 true；如果其中一个操作数为 NULL，则返回 false。
<= expr1 <= expr2 如果 expr1 小于或等于 expr2，则返回 true，否则返回 false。
<> expr1 <> expr2 如果 expr1 不等于 expr2，则返回 true，否则返回 false。
< expr1 < expr2 如果 expr1 小于 expr2，则返回 true，否则返回 false。
- expr1 - expr2 返回从 expr1 减去 expr2 得到的结果。
not not expr 返回布尔表达式的逻辑 NOT 结果。
or expr1 or expr2 返回 expr1 和 expr2 的逻辑 OR。
% dividend % divisor 返回在进行 dividend / divisor 运算后的余数。
|| expr1 \|\| expr2 返回将 expr1 和 expr2 串联后的结果。
| expr1 \| expr2 返回 expr1 和 expr2 的按位 OR 结果。
+ expr1 + expr2 返回 expr1 和 expr2 的总和。
regexp str [not] regexp regex 如果 str（不）匹配 regex，则返回 true。
regexp_like str [not] regexp_like regex 如果 str（不）匹配 regex，则返回 true。
rlike str [not] rlike regex 如果 str（不）匹配 regex，则返回 true。
/ dividend / divisor 返回 dividend 除以 divisor 的结果。
~ ~ expr 返回 expr 的按位 NOT 结果。

运算符优先顺序

优先顺序 操作员
1 :、、::?::、、[ ]
2 -(unary), +(unary), ~
3 *、、/%、、div
4 +、 -、、 \|\|
5 &
6 ^
7 \|
8 =、、==、<><=>、!=、<、<=、、 >>=
9 not, exists
10 between、、inrlike、regexp、ilike、like、、 is [not] [NULL, true, false]is [not] distinct from
11 and
12 or

字符串和二进制函数

函数 说明
expr1 || expr2 返回将 expr1 和 expr2 串联后的结果。
aes_decrypt(expr, key[, mode[, padding[, aad]]]) 使用 AES 加密对二进制 expr 进行解密。
aes_encrypt(expr, key[, mode[, padding[, iv[, aad]]]]) 使用 AES 加密对二进制 expr 进行加密。
ascii(str) 返回 str 的第一个字符的 ASCII 码位。
base64(expr) 将 expr 转换为 base 64 字符串。
bin(expr) 返回 expr 的二进制表示形式。
binary(expr) 将 expr 值强制转换为 BINARY。
bit_length(expr) 返回字符串数据的位长度或二进制数据的位数。
bitmap_count(expr) 返回在表示位图的 BINARY 字符串中设置的位数。
btrim(str [, trimStr]) 返回删除了前导字符和尾随字符的 str。
char(expr) 返回位于提供的 UTF-16 码位的字符。
char_length(expr) 返回字符串数据的字符长度或二进制数据的字节数。
character_length(expr) 返回字符串数据的字符长度或二进制数据的字节数。
charindex(substr, str[, pos]) 返回 substr 第一次出现在 str 中位置 pos 之后的位置。
chr(expr) 返回位于提供的 UTF-16 码位的字符。
concat(expr1, expr2[, …]) 返回参数的串联。
concat_ws(sep[, expr1[, …]]) 返回由 sep 分隔的串联字符串。
contains(expr, subExpr) 如果 expr STRING 或 BINARY 包含 subExpr，则返回 true。
crc32(expr) 返回 expr 的循环冗余校验值。
decode(expr, charSet) 使用字符集编码 charSet 将二进制 expr 转换为字符串。
encode(expr, charSet) 使用 charSet 字符编码返回字符串的二进制表示形式。
endswith(expr, endExpr) 如果 expr STRING 或 BINARY 以 endExpr 结尾，则返回 true。
find_in_set(searchExpr, sourceExpr) 返回某个字符串在逗号分隔的字符串列表中的位置。
format_number(expr, scale) 设置 expr 的格式（如 #,###,###.##），四舍五入到小数位数 scale。
format_number(expr, fmt) 设置 expr 的格式（如 fmt）。
format_string(strfmt[, obj1 [, …]]) 从 printf 样式的格式字符串返回一个带格式的字符串。
hex(expr) 将 expr 转换为十六进制。
str ilike (pattern[ESCAPE escape]) 如果 str 匹配具有 escape 的 pattern（不区分大小写），则返回 true。
initcap(expr) 返回 expr，其中的每个单词的首字母大写。
instr(str, substr) 返回 str 中 substr 的第一个匹配项的索引（从 1 开始）。
lcase(expr) 返回将 expr 的所有字符均更改为小写后的结果。
left(str, len) 返回 str 中最左边的 len 个字符。
len(expr) 返回字符串数据的字符长度或二进制数据的字节数。
length(expr) 返回字符串数据的字符长度或二进制数据的字节数。
levenshtein(str1, str2) 返回字符串 str1 和 str2 之间的 Levenshtein 距离。
str like (pattern[ESCAPE escape]) 如果 str 与具有 escape 的 pattern 匹配，则返回 true。
locate(substr, str[, pos]) 返回 substr 第一次出现在 str 中位置 pos 之后的位置。
lower(expr) 返回将 expr 的所有字符均更改为小写后的结果。
lpad(expr, len[, pad]) 返回 expr，左侧填充了 pad，填充后长度为 len。
ltrim([trimstr,] str) 返回 str，其中删除了 trimStr 内的前导字符。
mask(str[, upperChar[, lowerChar[, digitChar[, otherChar]]]]) 返回输入 str 的掩码版本。
md5(expr) 以十六进制字符串形式返回 expr 的 MD5 128 位校验和。
octet_length(expr) 返回字符串数据的字节长度或二进制数据的字节数。
overlay(input PLACING replace FROM pos [FOR len]) 将 input 替换为从 pos 开始且长度为 len 的 replace。
parse_url(url, partToExtract[, key]) 从 url 中提取一个部分。
position(substr, str[, pos]) 返回 substr 第一次出现在 str 中位置 pos 之后的位置。
position(subtr IN str) 返回 substr 第一次出现在 str 中位置 pos 之后的位置。
printf(strfmt[, obj1 [, …]]) 从 printf 样式的格式字符串返回一个带格式的字符串。
str regexp regex 如果 str 与 regex 匹配，则返回 true。
str regexp_like regex 如果 str 与 regex 匹配，则返回 true。
regexp_count(str, regexp) 返回 str 与 regexp 模式匹配的次数。
regexp_extract(str, regexp[, idx]) 从 str 中提取与 regexp 表达式匹配且对应于 regex 组索引的第一个字符串。
regexp_extract_all(str, regexp[, idx]) 从 str 中提取与 regexp 表达式匹配且对应于 regex 组索引的所有字符串。
regexp_instr(str, regexp) 返回 str 中与 regexp 匹配的第一个 substring 的位置。
regexp_replace(str, regexp, rep[, position]) 将 str 中与 regexp 匹配的所有子字符串替换为 rep。
regexp_substr(str, regexp) 返回 str 中与 regexp 匹配的第一个 substring。
repeat(expr, n) 返回重复 expr n 次的字符串。
replace(str, search [, replace]) 将所有 search 项都替换为 replace。
reverse(expr) 返回一个反向字符串或一个包含逆序的元素的数组。
right(str, len) 返回字符串 str 中最右边的 len 个字符。
str rlike regex 如果 str 与 regex 匹配，则返回 true。
rpad(expr, len[, pad]) 返回右侧填充了 pad 的 expr，填充后整个字符的长度为 len。
rtrim([trimStr,] str) 返回删除了尾随字符的 str。
sentences(str[, lang, country]) 将 str 拆分为一个数组，其中包含单词数组。
sha(expr) 以 expr 的十六进制字符串形式返回 sha1 哈希值。
sha1(expr) 以 expr 的十六进制字符串形式返回 sha1 哈希值。
sha2(expr, bitLength) 以 expr 的十六进制字符串形式返回 SHA-2 系列的校验和。
soundex(expr) 返回字符串的 soundex 代码。
space(n) 返回由 n 个空格组成的字符串。
split(str, regex[, limit]) 根据匹配 regex 的匹配项拆分 str，并以最大的长度 limit 返回数组。
split_part(str, delim, partNum) 将 str 围绕 delim 的次数拆分，并返回 partNum 部分。
startswith(expr, startExpr) 如果 expr STRING 或 BINARY 以 startExpr 开头，则返回 true。
string(expr) 将 expr 值强制转换为 STRING。
substr(expr, pos[, len]) 返回 expr 的子字符串（从 pos 开始，并且长度为 len）。
substr(expr FROM pos[ FOR len]) 返回 expr 的子字符串（从 pos 开始，并且长度为 len）。
substring(expr, pos[, len]) 返回 expr 的子字符串（从 pos 开始，并且长度为 len）。
substring(expr FROM pos[ FOR len]) 返回 expr 的子字符串（从 pos 开始，并且长度为 len）。
substring_index(expr, delim, count) 返回分隔符 delim 出现 count 次之前 expr 的子字符串。
to_binary(expr[, fmt]) 返回基于 fmt 强制转换为 BINARY 的 expr。
to_char(numExpr, fmt) 使用 fmt 格式将 numExpr 强制转换为 STRING。
to_varchar(numExpr, fmt) 使用 fmt 格式将 numExpr 强制转换为 STRING。
translate(expr, from, to) 返回一个 expr，其中 from 内的所有字符都被替换为 to 中的字符。
trim([[BOTH | LEADING | TRAILING] [trimStr] FROM] str) 剪裁字符串中的字符。
try_aes_decrypt(expr, key[, mode[, padding[, aad]]]) 解密使用 AES 加密生成的二进制文件 expr，并在出错时返回 NULL。
try_to_binary(expr [, fmt]) 返回基于 fmt 强制转换为 BINARY 的 expr；或者，如果输入无效，则返回 NULL。
try_url_decode(str) 从 application/x-www-form-urlencoded 格式转换回字符串，并在出现错误时返回 NULL。
try_zstd_decompress(value) 返回使用 Zstandard 压缩技术解压缩的值；如果输入无效，则返回 NULL。
ucase(expr) 返回将 expr 的所有字符均更改为大写后的结果。
unbase64(expr) 以二进制形式返回已解码的 base64 字符串。
unhex(expr) 将十六进制的 expr 转换为 BINARY。
upper(expr) 返回将 expr 的所有字符均更改为大写后的结果。
url_decode(str) 将字符串从 application/x-www-form-urlencoded 格式转换回来。
url_encode(str) 将字符串转换为 application/x-www-form-urlencoded 格式。
zstd_compress (value[,level[,streaming_mode]]) 返回使用 Zstandard 压缩技术压缩的值。
zstd_decompress(value) 返回使用 Zstandard 压缩技术解压缩的值。

数字标量函数

函数 说明
~ expr 返回 expr 的按位 NOT 结果。
dividend / divisor 返回 dividend 除以 divisor 的结果。
expr1 | expr2 返回 expr1 和 expr2 的按位 OR 结果。
- expr 返回 expr 的求反值。
expr1 - expr2 返回从 expr1 减去 expr2 得到的结果。
+ expr 返回 expr 的值。
expr1 + expr2 返回 expr1 和 expr2 的总和。
dividend % divisor 返回在进行 dividend / divisor 运算后的余数。
expr1 ^ expr2 返回 expr1 和 expr2 的按位异或 OR (XOR) 结果。
expr1 & expr2 返回 expr1 和 expr2 的按位 AND。
multiplier * multiplicand 返回 multiplier 乘以 multiplicand 的结果。
abs(expr) 返回 expr 中数值的绝对值。
acos(expr) 返回 expr 的反余弦值 (arccosine)。
acosh(expr) 返回 expr 的反双曲余弦值。
asin(expr) 返回 expr 的反正弦值 (arcsine)。
asinh(expr) 返回 expr 的反双曲正弦值。
atan(expr) 返回 expr 的反正切 (arctangent)。
atan2(exprY, exprX) 返回平面的正 x 轴与坐标 (exprX, exprY) 指定的点之间的角度（以弧度为单位）。
atanh(expr) 返回 expr 的反双曲正切值。
bigint(expr) 将 expr 值强制转换为 BIGINT。
bit_count(expr) 返回参数中设置的位数。
bit_get(expr, pos) 返回某个整数的二进制表示形式中某一位的值。
bit_reverse(expr) 返回通过反转参数中的位顺序获得的值。
bitmap_bit_position(expr) 返回桶中给定 BIGINT 编号的以 0 为基准的位位置。
bitmap_bucket_number(expr) 返回给定 BIGINT 编号的位图桶编号。
bround(expr[,targetScale]) 使用 HALF_EVEN 舍入模式返回舍入运算后的 expr。
cbrt(expr) 返回 expr 的立方根。
ceil(expr[,targetScale]) 返回不小于 expr 的最小数，向上舍入到相对于小数点的 targetScale 位数。
ceiling(expr[,targetScale]) 返回不小于 expr 的最小数，向上舍入到相对于小数点的 targetScale 位数。
conv(num, fromBase, toBase) 将 num 从 fromBase 转换为 toBase。
convert_timezone([sourceTz, ]targetTz, sourceTs) 将 TIMESTAMP_NTZ sourceTs 从 sourceTz 时区转换为 targetTz。
cos(expr) 返回 expr 的余弦值。
cosh(expr) 返回 expr 的双曲余弦。
cot(expr) 返回 expr 的余切值。
csc(expr) 返回 expr 的余割。
decimal(expr) 将 expr 值强制转换为 DECIMAL。
degrees(expr) 将弧度转换为度。
divisor div dividend 返回 divisor 除以 dividend 所得结果的整数部分。
double(expr) 将 expr 值强制转换为 DOUBLE。
e() 返回常数 e。
exp(expr) 返回 e 的 expr 次方。
expm1(expr) 返回 exp(expr) - 1。
factorial(expr) 返回 expr 的阶乘。
float(expr) 将 expr 值强制转换为 FLOAT。
floor(expr[,targetScale]) 返回不小于 expr 的最大数，向下舍入到相对于小数点的 targetScale 位数。
getbit(expr, pos) 返回某个整数的二进制表示形式中某一位的值。
hypot(expr1, expr2) 返回 sqrt(expr1 * expr1 + expr2 * expr2)。
int(expr) 将 expr 值强制转换为 INTEGER。
isnan(expr) 如果 true 为 expr，则返回 NaN。
ln(expr) 返回 expr 的自然对数（以 e 为底）。
log([base,] expr) 返回 expr 的对数（以 base 为底）。
log1p(expr) 返回 log(1 + expr)。
log2(expr) 返回 expr 的对数（以 2 为底）。
log10(expr) 返回 expr 的对数（以 10 为底）。
mod(dividend, divisor) 返回在进行 dividend / divisor 运算后的余数。
nanvl(expr1, expr2) 如果不是 NaN，则返回 expr1，否则返回 expr2。
negative(expr) 返回 expr 的求反值。
'nullifzero（expr）' 如果不为零，则返回 expr；否则返回 NULL。
pi() 返回 pi。
pmod(dividend, divisor) 返回在进行 dividend / divisor 运算后的正余数。
positive(expr) 返回 expr 的值。
pow(expr1, expr2) 将 expr1 提升为 expr2 的幂。
power(expr1, expr2) 将 expr1 提升为 expr2 的幂。
radians(expr) 将 expr（以度为单位）转换为弧度。
rand([seed]) 返回介于 0 和 1 之间的随机值。
randn([seed]) 从标准正态分布返回一个随机值。
random([seed]) 返回介于 0 和 1 之间的随机值。
rint(expr) 以 DOUBLE 值返回舍入为整数的 expr。
round(expr[,targetScale]) 使用 HALF_UP 舍入模式返回舍入运算后的 expr。
sec(expr) 返回 expr 的正切。
shiftleft(expr, n) 返回按位左移 n 位后的结果。
shiftright(expr, n) 返回按位右移 n 位的带符号整数。
shiftrightunsigned(expr, n) 返回按位右移 n 位的无符号整数。
sign(expr) 当 expr 为负数、0 或正数时返回 -1.0、0.0 或 1.0。
signum(expr) 当 expr 为负数、0 或正数时返回 -1.0、0.0 或 1.0。
sin(expr) 返回 expr 的正弦值。
sinh(expr) 返回 expr 的双曲正弦。
smallint(expr) 将 expr 值强制转换为 SMALLINT。
sqrt(expr) 返回 expr 的平方根。
tan(expr) 返回 expr 的正切。
tanh(expr) 返回 expr 的双曲正切值。
tinyint(expr) 将 expr 强制转换为 TINYINT。
to_number(expr, fmt) 使用格式设置 fmt 返回强制转换为 DECIMAL 的 expr。
try_add(expr1, expr2) 返回 expr1 加 expr2 的和，或者，如果发生错误，则返回 NULL。
try_divide(dividend, divisor) 返回 dividend 除以 divisor，或者，如果 divisor 为 0，则返回 NULL。
try_mod(dividend, divisor) 返回在进行 dividend / divisor 运算后的余数，或者，如果 divisor 为 0，则返回 NULL。
try_multiply(multiplier, multiplicand) 在溢出时返回 multiplier 乘以 multiplicand 或 NULL 的结果。
try_subtract(expr1, expr2) 返回在溢出时从 expr1 或 NULL 减去 expr2 得到的结果。
try_to_number(expr, fmt ) 返回使用格式设置 fmt 强制转换为 DECIMAL 的 expr，或者，如果 expr 与格式不匹配，则返回 NULL。
width_bucket(expr, minExpr, maxExpr, numBuckets) 返回等宽直方图中某个值的 Bucket 编号。
“zeroifnull（expr）” 如果不为 NULL，则返回 expr；否则返回 0。

聚合函数

功能 说明
any(expr) 如果组中至少一个 expr 值为 true，则返回 true。
any_value(expr[,ignoreNull]) 返回一组行的某个 expr 值。
approx_count_distinct(expr[,relativeSD]) 返回组内 expr 中的预估非重复值数。
approx_percentile(expr,percentage[,accuracy]) 返回组内 expr 的百分位近似值。
approx_top_k(expr[,k[,maxItemsTracked]]) 返回 expr 中最常出现的前 k 个项目值及其近似计数。
array_agg(expr) 返回一个数组，该数组由组内 expr 中的所有值组成。
avg(expr) 返回从组的值计算出的平均值。
bit_and(expr) 返回组中所有输入值的按位 AND 结果。
bit_or(expr) 返回组中所有输入值的按位 OR 结果。
bit_xor(expr) 返回组中所有输入值的按位 XOR 结果。
bitmap_construct_agg(expr) 返回组中所有位位置值的按位 OR。 在组中介于 0 和 32767 之间，作为 BINARY。
bitmap_or_agg(expr) 返回组中所有 BINARY 输入值的按位 OR。
bool_and(expr) 如果 expr 中的所有值在组内都为 true，则返回 true。
bool_or(expr) 如果 expr 中的至少一个值在组内为 true，则返回 true。
collect_list(expr) 返回一个数组，该数组由组内 expr 中的所有值组成。
collect_set(expr) 返回一个数组，该数组由组内 expr 中的所有唯一值组成。
corr(expr1,expr2) 返回表示一组数字对之间的关联情况的皮尔逊系数。
count(*) 返回在组中检索到的行的总数，包括那些包含 null 的行。
count(expr[, …]) 返回组中为其提供的表达式均为非 null 值的行的数目。
count_if(expr) 返回 expr 中组的 true 值数。
count_min_sketch(column,epsilon,confidence,seed) 返回具有 epsilon、confidence 和 seed 的 column 中的组中所有值的 count-min sketch。
covar_pop(expr1,expr2) 返回组中数字对的总体协方差。
covar_samp(expr1,expr2) 返回组中数字对的样本协方差。
every(expr) 如果组中 expr 的所有值均为 true，则返回 true。
first(expr[,ignoreNull]) 返回一组行的第一个 expr 值。
first_value(expr[,ignoreNull]) 返回一组行的第一个 expr 值。
histogram_numeric(expr,numBins) 基于 expr 计算具有 numBins 个箱的直方图，返回表示箱中心的对数组。
hll_sketch_agg(expr[,lgConfigK]) 返回用于计算近似非重复值计数的 HyperLogLog 草图。
hll_union_agg(expr[,allowDifferentLgConfigK]) 聚合一组行的 HyperLogLog 草图。
kurtosis(expr) 返回从组的值计算出的峰度值。
last(expr[,ignoreNull]) 返回一组行的最后一个 expr 值。
last_value(expr[,ignoreNull]) 返回一组行的最后一个 expr 值。
max(expr) 返回组中 expr 的最大值。
max_by(expr1,expr2) 返回与组中 expr2 的最大值关联的 expr1 的值。
mean(expr) 返回从组的值计算出的平均值。
median(expr) 返回根据组的值计算出的中值。
min(expr) 返回组中 expr 的最小值。
min_by(expr1, expr2) 返回与组中 expr2 的最小值关联的 expr1 的值。
mode(expr [,deterministic]) 返回组中 expr 的最常见值，而不是 NULL。
percentile(expr, percentage [,frequency]) 返回位于指定 percentage 处的 expr 的确切百分位值。
percentile_approx(expr,percentage[,accuracy]) 返回组内 expr 的百分位近似值。
percentile_cont(pct) WITHIN GROUP (ORDER BY key) 返回组内 key 的插值百分位。
percentile_disc(pct) WITHIN GROUP (ORDER BY key) 返回组内 key 的离散百分比。
regr_avgx(yExpr, xExpr) 返回从 xExpr 和 yExpr 为 NOT NULL 的组的值计算出的 xExpr 的平均值。
regr_avgy(yExpr, xExpr) 返回从 xExpr 和 yExpr 为 NOT NULL 的组的值计算出的 yExpr 的平均值。
regr_count(yExpr, xExpr) 返回组中非空值对 yExpr, xExpr 的个数。
regr_intercept(yExpr, xExpr) 返回组中单变量线性回归线的截距，其中 xExpr 和 yExpr 不为 NULL。
regr_r2(yExpr, xExpr) 返回 xExpr 和 yExpr 不是 NULL 的组值的决定系数。
regr_slope(yExpr, xExpr) 返回组中非 null 值对 yExpr、xExpr 的线性回归线的斜率。
regr_sxx(yExpr, xExpr) 返回 xExpr 和 yExpr 不为 NULL 的组中 xExpr 值的平方和。
regr_sxy(yExpr, xExpr) 返回从 xExpr 和 yExpr 为 NOT NULL 的组中的值计算的 yExpr 和 xExpr 乘积的总和。
regr_syy(yExpr, xExpr) 返回 xExpr 和 yExpr 不为 NULL 的组中 yExpr 值的平方和。
schema_of_json_agg(json[, options]) 以 DDL 格式返回组中 JSON 字符串的组合架构。
schema_of_variant_agg(variantExpr) 以 DDL 格式返回组中所有 VARIANT 值的组合架构。
skewness(expr) 返回从组的值计算出的偏度值。
some(expr) 如果组中至少有一个 expr 值是 true，则返回 true。
std(expr) 返回通过组中的值计算出的样本标准偏差。
stddev(expr) 返回通过组中的值计算出的样本标准偏差。
stddev_pop(expr) 返回从组的值计算出的总体标准偏差。
stddev_samp(expr) 返回从组的值计算出的样本标准偏差。
sum(expr) 返回从组的值计算出的总和值。
try_avg(expr) 返回根据组的值计算出的平均值，如果溢出则返回 NULL。
try_sum(expr) 返回根据组的值计算出的和，如果溢出则返回 NULL。
var_pop(expr) 返回从组的值计算出的总体方差。
var_samp(expr) 返回从组的值计算出的样本方差。
variance(expr) 返回从组的值计算出的样本方差。

排名开窗函数

函数 说明
dense_rank() 返回某个值相对于分区中所有值的排名。
ntile(n) 将每个窗口分区的行分割为从 1 到至多 n 的 n 个 Bucket。
percent_rank() 计算分区中某个值的百分比排名。
rank() 返回某个值相对于分区中所有值的排名。
row_number() 根据窗口分区中的行顺序，为每一行分配唯一的顺序编号（从 1 开始）。

分析窗口函数

函数 说明
cume_dist() 返回某个值相对于分区中所有值的位置。
lag(expr[,offset[,default]]) 从分区中的前一行返回值 expr。
lead(expr[,offset[,default]]) 从分区中的后续行返回值 expr。
nth_value(expr, offset[, ignoreNulls]) 返回位于窗口中特定 offset 处的 expr 的值。

数组函数

功能 描述
arrayExpr[indexExpr] 返回数组 arrayExpr 的位置 indexExpr 处的元素。
aggregate(expr,start,merge[,finish]) 使用自定义聚合器聚合数组中的元素。
array([expr [, …]]) 返回一个数组，其中包含 expr 中的元素。
array_append(array, elem) 返回 elem 追加的 array。
array_compact(array) 从 array 中删除 NULL 值。
array_contains(array,value) 如果 array 包含 value，则返回 true。
array_distinct(array) 从 array 中删除重复值。
array_except(array1,array2) 返回 array1 中（而不是 array2 中）的元素的数组。
array_insert(array, index, elem) 返回一个展开的 array，其中的 elem 插入到 index 位置。
array_intersect(array1,array2) 返回 array1 和 array2 的交集中的元素的数组。
array_join(array,delimiter[,nullReplacement]) 串联 array 的元素。
array_max(array) 返回 array 中的最大值。
array_min(array) 返回 array 中的最小值。
array_position(array,element) 返回 array 中第一次出现 element 的位置。
array_prepend(array, elem) 返回以 elem 为前缀的 array。
array_remove(array,element) 从 array 中删除所有出现的 element。
array_repeat(element,count) 返回包含 element count 时间的数组。
array_size(array) 返回 array 中的元素数量。
array_sort(array,func) 返回根据 func 排序的 array。
array_union(array1,array2) 返回 array1 和 array2 的并集中的元素的数组，不包含重复项。
arrays_overlap(array1, array2) 如果 array1 和 array2 的交集不为空，则返回 true。
arrays_zip(array1 [, …]) 返回合并的结构数组，其中第 n 个结构包含输入数组的所有第 N 个值。
cardinality(expr) 返回 expr 的大小。
concat(expr1, expr2 [, …]) 返回参数的串联。
element_at(arrayExpr, index) 返回位于 index 处的 arrayExpr 的元素。
exists(expr, pred) 如果 pred 对于 expr 中的任一元素为 true，则返回 true。
explode(collection) 通过取消嵌套 collection 返回行。
explode_outer(collection) 使用 outer 语义通过取消嵌套 collection 返回行。
filter(expr,func) 使用函数 func 筛选 expr 中的数组。
flatten(arrayOfArrays) 将数组的数组转换为单个数组。
forall(expr, predFunc) 测试 predFunc 是否对数组中的所有元素都有效。
get(arrayExpr, index) 返回 index 处的 arrayExpr 元素，从 0 开始。
inline(expr) 将结构数组分解为一个表。
inline_outer(expr) 使用 outer 语义将结构数组分解为表。
posexplode(expr) 通过取消嵌套具有位置编号的数组来返回行。
posexplode_outer(expr) 使用 OUTER 语义，通过取消嵌套具有位置编号的数组来返回行。
reduce(expr,start,merge[,finish]) 使用自定义聚合器聚合数组中的元素。
reverse(array) 返回一个反向字符串或一个包含逆序的元素的数组。
sequence(start,stop,step) 生成一个数组，其中包含从 start 到 stop（含）的元素，这些元素按 step 递增。
shuffle(array) 返回 expr 中数组的随机排列。
size(expr) 返回 expr 的基数。
slice(expr,start,length) 返回数组的子集。
sort_array(expr[,ascendingOrder]) 按排序顺序返回 expr 中的数组。
transform(expr, func) 使用函数 expr 转换 func 中数组中的元素。
try_element_at(arrayExpr, index) 返回位于 index 处的 arrayExpr 的元素；如果 index 超出边界，则返回 NULL。
zip_with(expr1, expr2, func) 使用 func 按元素将 expr1 和 expr2 中的数组合并到一个数组中。

映射函数

功能 描述
mapExpr[keyExpr] 返回映射 mapExpr 的 keyExpr 处的值。
cardinality(expr) 返回 expr 的大小。
element_at(mapExpr, key) 返回 key 的 mapExpr 值。
explode(expr) 通过取消嵌套 expr 返回行。
explode_outer(expr) 使用 outer 语义通过取消嵌套 expr 返回行。
map([{key1, value1}[, …]]) 创建具有指定键值对的映射。
map_concat([expr1 [, …]]) 返回所有 expr 映射表达式的并集。
map_contains_key(map, key) 如果 map 包含 key，则返回 true；否则返回 false。
map_entries(map) 返回 map 中所有条目的无序数组。
map_filter(expr, func) 使用 func 函数在 expr 中筛选映射中的条目。
map_from_arrays(keys, values) 创建具有 keys 和 values 对数组的映射。
map_from_entries(expr) 创建从指定的条目数组创建的映射。
map_keys(map) 返回包含 map 键的无序数组。
map_values(map) 返回一个包含 map 值的无序数组。
map_zip_with(map1, map2, func) 将 map1 和 map2 合并到一个映射中。
size(expr) 返回 expr 的基数。
str_to_map(expr[,pairDelim[,keyValueDelim]]) 在使用分隔符将 expr 拆分为键值对之后返回映射。
transform_keys(expr, func) 使用 func 函数在 expr 中转换映射中的键。
transform_values(expr, func) 使用 func 函数在 expr 中转换映射中的值。
try_element_at(mapExpr, key) 返回 key 的 mapExpr 值；如果 key 不存在，则返回 NULL。

日期、时间戳和时间间隔函数

有关日期和时间戳格式的信息，请参阅日期/时间模式。

功能 说明
intervalExpr / divisor 返回除以 divisor 的间隔。
- intervalExpr 返回 intervalExpr 的求反值。
intervalExpr1 - intervalExpr2 返回从 intervalExpr1 减去 intervalExpr2 得到的结果。
datetimeExpr1 - datetimeExpr2 返回从 datetimeExpr1 减去 datetimeExpr2 得到的结果。
+ intervalExpr 返回 intervalExpr 的值。
intervalExpr1 + intervalExpr2 返回 intervalExpr1 和 intervalExpr2 的总和。
intervalExpr * multiplicand 返回 intervalExpr 乘以 multiplicand 的结果。
abs(expr) 返回 expr 中间隔值的绝对值。
add_months(startDate,numMonths) 返回在 startDate 之后 numMonths 的日期。
curdate() 返回查询计算开始时的当前日期。
current_date() 返回查询计算开始时的当前日期。
current_timestamp() 返回查询计算开始时的当前时间戳。
current_timezone() 返回当前会话的本地时区。
date(expr) 将 expr 值强制转换为 DATE。
date_add(startDate,numDays) 返回在 startDate 之后的日期 numDays。
date_add(unit, value, expr) 将 value unit 添加到时间戳 expr。
date_diff(unit, start, stop) 返回两个以 unit 为单位的时间戳之间的差异。
date_format(expr,fmt) 将时间戳转换为 fmt 格式的字符串。
date_from_unix_date(days) 根据自 1970-01-01 以来的天数创建日期。
date_part(field,expr) 提取部分日期、时间戳或间隔。
date_sub(startDate,numDays) 返回在 startDate 之前的日期 numDays。
date_trunc(unit,expr) 返回已截断到 unit 中指定的单位的时间戳。
dateadd(startDate,numDays) 返回在 startDate 之后的日期 numDays。
dateadd(unit, value, expr) 将 value unit 添加到时间戳 expr。
datediff(endDate,startDate) 返回从 startDate 到 endDate 的天数。
datediff(unit, start, stop) 返回两个以 unit 为单位的时间戳之间的差异。
day(expr) 返回日期或时间戳的月份日期。
dayofmonth(expr) 返回日期或时间戳的月份日期。
dayofweek(expr) 返回日期或时间戳的星期几。
dayofyear(expr) 返回日期或时间戳的年份日期。
divisor div dividend 返回间隔 divisor 除以间隔 dividend 的整数部分。
extract(field FROM source) 返回 source 的 field。
from_unixtime(unixTime,fmt) 返回 fmt 中的 unixTime。
from_utc_timestamp(expr,timezone) 返回时间戳的UTC时间戳expr。timeZone
getdate() 返回查询计算开始时的当前时间戳。
hour(expr) 返回时间戳的小时部分。
last_day(expr) 返回日期所属月份的最后一天。
make_date(year,month,day) 从 year、month 和 day 字段创建日期。
make_dt_interval([days[, hours[, mins[, secs]]]]) 从 days、hours、mins 和 secs 创建日期时间间隔。
make_interval(years, months, weeks, days, hours, mins, secs) 已弃用：从 years、months、weeks、days、hours、mins 和 secs 创建时间间隔。
make_timestamp(year,month,day,hour,min,sec[,timezone]) 从 year、month、day、hour、min、sec 和 timezone 字段创建时间戳。
make_ym_interval([years[, months]]) 从 years 和 months 创建年月时间间隔。
minute(expr) 返回 expr 中时间戳的分钟部分。
month(expr) 返回 expr 中时间戳的月份部分。
months_between(expr1,expr2[,roundOff]) 返回 expr1 和 expr2 中的日期或时间戳之间已过去的月数。
next_day(expr,dayOfWeek) 返回晚于 expr 并已按 dayOfWeek 中命名的第一个日期。
now() 返回查询计算开始时的当前时间戳。
quarter(expr) 返回 expr 的年度的第几季（范围为 1 到 4）。
second(expr) 返回 expr 中时间戳的第二个分量。
session_window(expr, gpDuration) 通过时间戳表达式创建会话窗口。
sign(expr) 当间隔 expr 为负数、0 或正数时分别返回 -1.0、0.0 或 1.0。
signum(expr) 当间隔 expr 为负数、0 或正数时分别返回 -1.0、0.0 或 1.0。
timediff(unit, start, stop) 返回两个以 unit 为单位的时间戳之间的差异。
timestamp(expr) 将 expr 强制转换为 TIMESTAMP。
timestamp_micros(expr) 创建自 UTC 纪元以来的时间戳（expr 微秒）。
timestamp_millis(expr) 创建自 UTC 纪元以来的时间戳 expr 毫秒。
timestamp_seconds(expr) 创建自 UTC 纪元以来的时间戳（expr 秒）。
timestampadd(unit, value, expr) 将 value unit 添加到时间戳 expr。
timestampdiff(unit, start, stop) 返回两个以 unit 为单位的时间戳之间的差异。
to_date(expr[,fmt]) 返回使用可选格式设置将 expr 转换为日期后的值。
to_timestamp(expr[,fmt]) 使用可选格式将 expr 强制转换返回到某个时间戳。
to_unix_timestamp(expr[,fmt]) 将 expr 中的时间戳返回为 UNIX 时间戳。
to_utc_timestamp(expr,timezone) 返回时间戳的UTC时间戳expr。timezone
trunc(expr, fmt) 返回一个日期，其时间部分已截断到格式模型 fmt 所指定的单位。
try_add(expr1, expr2) 返回 expr1 加 expr2 的和，或者，如果发生错误，则返回 NULL。
try_divide(dividend, divisor) 返回 dividend 除以 divisor，或者，如果 divisor 为 0，则返回 NULL。
try_multiply(multiplier, multiplicand) 在溢出时返回 multiplier 乘以 multiplicand 或 NULL 的结果。
try_subtract(expr1, expr2) 返回在溢出时从 expr1 或 NULL 减去 expr2 得到的结果。
try_to_timestamp(expr[,fmt]) 返回使用可选格式设置强制转换为某个时间戳的 expr，如果强制转换失败，则返回 NULL。
unix_date(expr) 返回自 1970-01-01 以来经过的天数。
unix_micros(expr) 返回自 1970-01-01 00:00:00 UTC 以来的微秒数。
unix_millis(expr) 返回自 1970-01-01 00:00:00 UTC 以来经过的毫秒数。
unix_seconds(expr) 返回自 1970-01-01 00:00:00 UTC 以来经过的秒数。
unix_timestamp([expr[, fmt]]) 返回当前时间或指定时间的 UNIX 时间戳。
weekday(expr) 返回 expr 的星期日期。
weekofyear(expr) 返回 expr 的年度中的第几周。
year(expr) 返回 expr 的年份部分。
window(expr, width[, step[, start]]) 通过时间戳表达式创建基于跳跃的滑动窗口。
window_time(window) 返回由 window 或 session_window 函数生成的滑动窗口的非独占结束时间。

H3 地理空间函数

有关 H3 地理空间函数的信息，请参阅 H3 地理空间函数。

Cast 函数和构造函数

有关在类型之间强制转换的信息，请参阅 cast 函数和 try_cast 函数。

函数 描述
array([expr [, …]]) 返回一个数组，其中包含 expr 中的元素。
bigint(expr) 将 expr 值强制转换为 BIGINT。
binary(expr) 将 expr 值强制转换为 BINARY。
boolean(expr) 将 expr 强制转换为 BOOLEAN。
cast(expr AS type) 将值 expr 强制转换为目标数据类型 type。
expr :: type 将值 expr 强制转换为目标数据类型 type。
date(expr) 将 expr 值强制转换为 DATE。
decimal(expr) 将 expr 值强制转换为 DECIMAL。
double(expr) 将 expr 值强制转换为 DOUBLE。
float(expr) 将 expr 值强制转换为 FLOAT。
int(expr) 将 expr 值强制转换为 INTEGER。
make_date(year,month,day) 从 year、month 和 day 字段创建日期。
make_dt_interval([days[, hours[, mins[, secs]]]]) 从 days、hours、mins 和 secs 创建日期时间间隔。
make_interval(years, months, weeks, days, hours, mins, secs) 从 years、months、weeks、days、hours、mins 和 secs 创建间隔。
make_timestamp(year,month,day,hour,min,sec[,timezone]) 从 year、month、day、hour、min、sec 和 timezone 字段创建时间戳。
make_ym_interval([years[, months]]) 从 years 和 months 创建年月时间间隔。
map([{key1, value1} [, …]]) 创建具有指定键值对的映射。
named_struct({name1, val1} [, …]) 创建具有指定的字段名称和值的结构。
smallint(expr) 将 expr 值强制转换为 SMALLINT。
string(expr) 将 expr 值强制转换为 STRING。
struct(expr1 [, …]) 创建具有指定字段值的 STRUCT。
tinyint(expr) 将 expr 强制转换为 TINYINT。
timestamp(expr) 将 expr 强制转换为 TIMESTAMP。
to_char(expr, fmt) 使用 fmt 格式将 expr 强制转换为 STRING。
to_date(expr[,fmt]) 返回使用可选格式设置将 expr 转换为日期后的值。
to_number(expr, fmt) 使用 fmt 格式返回 expr 强制转换为 DECIMAL。
to_timestamp(expr[,fmt]) 使用可选格式将 expr 强制转换返回到某个时间戳。
to_varchar(expr, fmt) 使用 fmt 格式将 expr 强制转换为 STRING。
try_cast(expr AS type) 将值 expr 安全强制转换为目标数据类型 type。
try_to_number(expr, fmt) 使用 fmt 格式返回 expr 强制转换为 DECIMAL，或者如果 expr 无效则返回 NULL。

CSV 和 Avro 函数

函数 说明
from_avro(avroBin, jsonSchema[, options]) 根据 avroBin 和 jsonSchema 返回结构值。
from_csv(csvStr, schema[, options]) 返回具有 csvStr 和 schema 的结构值。
schema_of_csv(csv[, options]) 返回 DDL 格式的 CSV 字符串的架构。
to_avro(expr[, options]) 返回具有指定结构值的 Avro 二进制值。
to_csv(expr[, options]) 返回具有指定结构值的 CSV 字符串。

JSON 函数

功能 描述
jsonStr : jsonPath 返回从 jsonStr 中提取的字段。
from_json(jsonStr, schema[, options]) 返回具有 jsonStr 和 schema 的结构值。
get_json_object(expr, path) 从 path 中提取 JSON 对象。
json_array_length(jsonArray) 返回最外层 JSON 数组中的元素数。
json_object_keys(jsonObject) 以数组形式返回最外层 JSON 对象的所有键。
json_tuple(jsonStr, path1 [, …]) 以元组形式返回多个 JSON 对象。
parse_json(jsonStr) 从 jsonStr 返回一个 VARIANT 值。
schema_of_json(jsonStr[, options]) 以 DDL 格式返回 JSON 字符串的架构。
schema_of_json_agg(jsonStr[, options]) 以 DDL 格式返回组中 JSON 字符串的组合架构。
to_json(expr[, options]) 返回一个 JSON 字符串，带有 expr 中指定的 STRUCT 或 VARIANT。

VARIANT 函数

函数 说明
variantExpr : jsonPath 使用 JSON 路径返回从 variantExpr 中提取的字段。
is_variant_null(variantExpr) 测试 variantExpr 是否为 VARIANT 编码的 NULL。
parse_json(jsonStr) 从 jsonStr 返回一个 VARIANT 值。
schema_of_variant(variantExpr) 返回 DDL 格式的 VARIANT 表达式的架构。
schema_of_variant_agg(variantExpr) 以 DDL 格式返回组中所有 VARIANT 值的组合架构。
to_json(expr[, options]) 返回一个 JSON 字符串，带有 expr 中指定的 STRUCT 或 VARIANT。
try_parse_json(jsonStr) 如果可能，从 jsonStr 返回 VARIANT 值。 如果不可能，则返回 NULL。
try_variant_get(variantExpr,path,type) 从 path 指定的 variantExpr 中提取类型为 type 的值，如果无法将值强制转换为目标类型，则提取 NULL。
variant_explode(variantExpr) 通过取消嵌套 variantExpr 返回行集。
variant_explode_outer(variantExpr) 使用 outer 语义通过取消嵌套 variantExpr 返回行集。
variant_get(variantExpr,path,type) 从 variantExpr 中提取由 path 指定的 type 类型的值。

XPath 和 XML 函数

Function 说明
from_xml(xmlStr, schema[, options]) 返回使用 schema 从 xmlStr 分析的结构值。
schema_of_xml(xmlStr[, options]) 以 DDL 格式返回 XML 字符串的架构。
xpath(xml, xpath) 返回与 xpath 匹配的 xml 节点内的值。
xpath_boolean(xml, xpath) 如果 xpath 表达式的计算结果为 true，或者在 xml 中找到匹配节点，则返回 true。
xpath_double(xml, xpath) 从 XML 文档返回一个 DOUBLE 值。
xpath_float(xml, xpath) 从 XML 文档返回一个 FLOAT 值。
xpath_int(xml, xpath) 从 XML 文档返回一个 INTEGER 值。
xpath_long(xml, xpath) 从 XML 文档返回一个 BIGINT 值。
xpath_number(xml, xpath) 从 XML 文档返回一个 DOUBLE 值。
xpath_short(xml, xpath) 从 XML 文档返回一个 SHORT 值。
xpath_string(xml, xpath) 返回与 XPath 表达式匹配的第一个 XML 节点的内容。

AI 函数

函数 说明
ai_analyze_sentiment(content) 返回文本的情绪。
ai_classify(content, labels) 将提供的内容分类为提供的标签之一。
ai_extract(content, labels) 从给定文本中提取由标签指定的实体。
ai_fix_grammar(content) 更正给定文本中的语法错误。
ai_forecast(observed, time_col) 将时序数据外推到未来。
ai_gen(content) 从 Databricks Foundation 模型 API 调用最先进的生成式 AI 模型，以回答用户提供的提示。
ai_generate_text(prompt, modelName[, param1, value1] […]) 不推荐使用：在提供提示的情况下，返回选定的大型语言模型 (LLM) 生成的文本。
ai_mask(content, labels) 过滤给定文本中的指定实体。
ai_query(endpointName, request, returnType) 调用现有的 Mosaic AI 模型服务终结点，然后分析并返回其响应。
ai_similarity(strExpr1, strExpr2) 比较两个字符串并计算语义相似性分数。
ai_summarize(content[, max_words]) 生成给定文本的摘要。
ai_translate(content, to_lang) 将文本翻译为指定的目标语言。
vector_search(index, query, num_results) 使用 SQL 查询 Mosaic AI 矢量搜索索引。

读取函数

函数 说明
read_files(path, [optionKey => optionValue] [, …]) 读取云存储中的数据文件，并返回表格格式。
read_kafka([optionKey => optionValue] [, …]) 从 Apache Kafka 群集读取记录，并返回表格格式。
read_kinesis({parameter => value} [, …]) 返回一个表，其中包含从一个或多个流的 Kinesis 中读取的记录。
read_pubsub([parameter => value] [, …]) 一个用于从主题中的 Pub/Sub 读取记录的表值函数。
read_pulsar({optionKey => optionValue} [, …]) 返回一个表，其中包含从 Pulsar 读取的记录。
read_state_metadata(path) 返回一个表，其中包含表示流式处理查询状态元数据的行。
read_statestore(path [, option_key => option_value] […]) 从流式处理查询的状态存储中返回记录。

其他函数

函数 说明
assert_true(expr) 如果 expr 不为 true，则返回错误。
CASE expr { WHEN opt1 THEN res1 } […] [ELSE def] END 返回等于 expr 的第一个 optN 的 resN；如果没有任何匹配项，则返回 def。
CASE { WHEN cond1 THEN res1 } […] [ELSE def] END 返回计算结果为 true 的第一个 condN 的 resN；如果找不到任何匹配项，则返回 def。
cloud_files_state( { TABLE(table) | checkpoint } ) 返回自动加载程序 cloud_files 源的文件级状态。
coalesce(expr1, expr2 [, …]) 返回第一个非 null 参数。
cube (expr1 [, …]) 使用指定的表达式列创建多维多维数据集。
current_catalog() 返回当前目录。
current_database() 返回当前架构。
current_metastore() 返回当前的 Unity Catalog 元存储 ID。
current_recipient(key) 返回通过 Delta Sharing 共享的视图中当前接收者的属性。
current_schema() 返回当前架构。
current_user() 返回执行语句的用户。
current_version() 返回当前版本的 Azure Databricks。
decode(expr, { key, value } [, …] [,defValue]) 返回与键匹配的值。
elt(index, expr1 [, …] ) 返回第 n 个表达式。
equal_null(expr1, expr2) 如果 expr1 等于 expr2 或两个表达式都为 NULL，则返回 true，否则返回 false。
event_log( { TABLE(table) | pipeline_id } ) 返回具体化视图、流式处理表或 DLT 管道的刷新历史记录表。
greatest(expr1, expr2 [, …]) 返回所有参数的最大值（跳过 null 值）。
grouping(col) 指示 GROUPING SET、ROLLUP 或 CUBE 中指定的列是否表示小计。
grouping_id([col1 [, …]]) 返回一组列的分组级别。
hash(expr1 [, …]) 返回参数的哈希值。
hll_sketch_estimate(expr) 估计在 HyperLogLog 草图中收集的非重复值的数量。
hll_union(expr1, expr2 [,allowDifferentLgConfigK]) 合并两个 HyperLogLog 草图。
java_method(class, method[, arg1 [, …]]) 使用反射调用某个方法。
if(cond, expr1, expr2) 如果 cond 为 true，则返回 expr1；否则返回 expr2。
iff(cond, expr1, expr2) 如果 cond 为 true，则返回 expr1；否则返回 expr2。
ifnull(expr1, expr2) 如果 expr1 为 NULL，则返回 expr2；否则返回 expr1。
input_file_block_length() 返回所读取块的长度（以字节为单位）。
input_file_block_start() 返回正在读取的块的起始偏移量（以字节为单位）。
input_file_name() 返回正在读取的文件的名称。如果无法获得该名称，则返回空字符串。
is_account_group_member(group) 如果当前用户是帐户级别的组的成员，则返回 true。
is_member(group) 如果当前用户是工作区级别的组的成员，则返回 true。
isnull(expr) 如果 true 为 expr，则返回 NULL。
isnotnull(expr) 如果 expr 不为 NULL，则返回 true。
least(expr1, expr2 [, …]) 返回所有参数的最小值（跳过 null 值）。
list_secrets([scopeStr]) 返回用户有权从 Databricks 机密服务查看的所有或一个范围内的密钥。
luhn_check(numStr) 如果 numStr 通过 Luhn 算法检查，则返回 true。
monotonically_increasing_id() 返回单调递增的 64 位整数。
nullif(expr1, expr2) 如果 expr1 等于 expr2，则返回 NULL；否则返回 expr1。
nvl(expr1, expr2) 如果 expr1 为 NULL，则返回 expr2；否则返回 expr1。
nvl2(expr1, expr2, expr3) 如果 expr1 不是 NULL，则返回 expr2，否则返回 expr3。
raise_error(expr) 使用 expr 作为消息引发异常。
range(end) 返回指定范围内值的表。
range(start, end [, step [, numParts]]) 返回指定范围内值的表。
reflect(class, method[, arg1 [, …]]) 使用反射调用某个方法。
secret(scope, key) 从 Databricks 机密服务中提取具有给定 scope 和 key 的机密值。
session_user() 返回连接到 Azure Databricks 的用户。
spark_partition_id() 返回当前分区 ID。
sql_keywords() 返回 Azure Databricks 中的 SQL 关键字集。
stack(numRows, expr1 [, …]) 将 expr1 … exprN 分隔成 numRows 行。
table_changes(table_str, start [, end]) 返回已启用更改数据馈送的 Delta Lake 表的更改日志。
try_reflect(class, method[, arg1 [, …]]) 使用反射调用一个方法，如果方法失败，则返回 NULL。
try_secret(scope, key) 从 Databricks 机密服务中提取具有给定 scope 和 key 的机密值，如果无法检索密钥，则为 NULL。
typeof(expr) 为 expr 的数据类型返回 DDL 格式的类型字符串。
user() 返回执行语句的用户。
uuid() 返回全局唯一标识符 (UUID) 字符串。
window(expr, width[, step [, start]]) 通过时间戳表达式创建基于跳跃的滑动窗口。
xxhash64(expr1 [, …]) 返回参数的 64 位哈希值。
version() 返回 Apache Spark 版本。