內建函式
適用於: Databricks SQL Databricks Runtime
本文提供字串和二進位類型、數值純量、匯總、windows、陣列、地圖、日期和時間戳、轉型、CSV 數據、JSON 數據、XPath 操作和其他函式之內建運算符和函式的連結和描述。
另請參閱:
運算符和述詞
如需如何相互剖析運算符的相關信息,請參閱 運算符優先順序。
運算子 | 語法 | 描述 |
---|---|---|
和 | expr1 & expr2 |
傳回和expr2 的expr1 位 AND。 |
and | expr1 and expr2 |
傳回和expr2 的expr1 邏輯AND。 |
* | multiplier * multiplicand |
multiplier 傳回乘以 multiplicand 。 |
!= | expr1 != expr2 |
如果 expr1 不等於 expr2 ,則 false 傳回 true,否則傳回 。 |
! | !expr |
傳回布爾表達式的邏輯 NOT 。 |
between | expr1 [not] between expr2 and expr2 |
測試是否 expr1 大於或等於 expr2 ,且小於或等於 expr3 。 |
[ ] | arrayExpr [ indexExpr ] |
indexExpr 傳回 ARRAY 的 nd 元素arrayExpr |
[ ] | mapExpr [ keyExpr ] |
傳回 MAP 的值keyExpr mapExpr |
^ | expr1 ^ expr2 |
傳回和expr2 的expr1 位排除OR (XOR) 。 |
: | jsonStr : jsonPath |
傳回從擷取的 jsonStr 欄位。 |
:: | expr :: type |
將值 expr 轉換成目標資料類型 type 。 |
div | divisor div dividend |
傳回 除法dividend 的divisor 整數部分。 |
. | mapExpr . keyIdentifier |
依keyIdentifier 傳MAP 回值。 |
. | structExpr . fieldIdentifier |
依fieldIdentifier 傳STRUCT 回欄位。 |
== | expr1 == expr2 |
如果 expr1 等於 expr2 ,則false 傳true 回 ,否則傳回 。 |
= | expr1 = expr2 |
如果 expr1 等於 expr2 ,則false 傳true 回 ,否則傳回 。 |
>= | expr1 >= expr2 |
如果 expr1 大於或等於 expr2 ,則false 傳true 回 ,否則傳回 。 |
> | expr1 > expr2 |
如果 expr1 大於 expr2 ,則false 傳true 回 ,否則傳回 。 |
exists | exists(query) |
如果 query 傳回至少一個數據列,則傳回 true,否則傳回 false。 |
ilike | str [not] ilike (pattern[ESCAPE escape]) |
如果 str 與pattern escape 不區分大小寫相符,則傳回 true。 |
ilike | str [not] ilike {ANY|SOME|ALL}([pattern[, ...]]) |
如果 str 不符合任何/所有模式不區分大小寫,則傳回 true。 |
在 | elem [not] in (expr1[, ...]) |
如果 elem 不等於任何 exprN ,則傳true 回 。 |
在 | elem [not] in (query) |
如果 elem 中不等於 任何資料列query ,則傳true 回 。 |
相異 | expr1 is [not] distinct from expr2 |
測試自變數是否有不同的值,其中 NULL 會被視為可比較的值。 |
為 false | expr is [not] false |
測試是否 expr 為 (不是) false 。 |
為 null | expr is [not] null |
如果 expr 為 ,則傳true 回 。NULL 。 |
為 true | expr is [not] true |
測試是否 expr 為 (不是) true 。 |
喜歡 | str [not] like (pattern[ESCAPE escape]) |
如果 str 與不相符pattern escape ,則傳回 true。 |
喜歡 | str [not] like {ANY|SOME|ALL}([pattern[, ...]]) |
如果 str 不符合任何/所有模式,則傳回 true。 |
<=> | expr1 <=> expr2 |
傳回與EQUAL(=) 非 Null 操作數的 相同結果,但如果兩者都是 NULL ,false 則傳回 true 。如果其中一個為 NULL 。 |
<= | expr1 <= expr2 |
如果 expr1 小於或等於 expr2 ,則false 傳true 回 ,否則傳回 。 |
<> | expr1 <> expr2 |
如果 expr1 不等於 expr2 ,則false 傳true 回 ,否則傳回 。 |
< | expr1 < expr2 |
如果 expr1 小於 expr2 ,則false 傳true 回 ,否則傳回 。 |
- | expr1 - expr2 |
傳回的expr2 expr1 減法。 |
not | not expr |
傳回布爾表達式的邏輯 NOT 。 |
or | expr1 or expr2 |
傳回和expr2 的expr1 邏輯OR 。 |
% | dividend % divisor |
傳回 之後 dividend / divisor 的餘數。 |
|| | expr1 || expr2 |
傳回和expr2 的expr1 串連。 |
| | expr1 | expr2 |
傳回和expr2 的expr1 位OR 。 |
+ | expr1 + expr2 |
傳回 expr1 和 expr2 的總和。 |
Regexp | str [not] regexp regex |
如果 不符合 regex ,則str 傳回 true。 |
regexp_like | str [not] regexp_like regex |
如果 不符合 regex ,則str 傳回 true。 |
rlike | str [not] rlike regex |
如果 不符合 regex ,則str 傳回 true。 |
/ | dividend / divisor |
dividend 傳回除以 divisor 。 |
~ | ~ expr |
傳回的expr 位NOT 。 |
運算子優先順序
優先順序 | 運算子 |
---|---|
1 | : 、 、 :: [ ] |
2 | - (一元), + (一元), ~ |
3 | * 、 、 / 、 % div |
4 | + 、 、 - || |
5 | & |
6 | ^ |
7 | | |
8 | = 、== 、<=> 、<> 、!= 、< 、<= 、 > >= |
9 | not , exists |
10 | between 、in 、rlike 、regexp 、ilike 、like 、、、 is [not] [NULL, true, false] is [not] distinct from |
11 | and |
12 | or |
字串和二進位函式
函式 | 描述 |
---|---|
expr1 ||expr2 | 傳回和expr2 的expr1 串連。 |
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 轉換成基底 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 樣式的格式字串傳回格式化字串。 |
十六進位(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) | 從傳回最 len 左邊的字元 str 。 |
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 replace 以 取代 ,其開頭pos 為 ,且 長度len 為 。 |
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 | 如果 符合 regex ,則str 傳回 true。 |
str regexp_like regex | 如果 符合 regex ,則str 傳回 true。 |
regexp_count(str, regexp) | 傳回符合模式的regexp 次數str 。 |
regexp_extract(str, regexp[, idx]) | 擷取 中 str 符合 regexp 表達式的第一個字串,並對應至 regex 群組索引。 |
regexp_extract_all(str, regexp[, idx]) | 擷取 中 str 符合 regexp 表達式的所有字串,並對應至 regex 群組索引。 |
regexp_instr(str, regexp) | 傳回中 str 符合 regexp 之第一個子字串的位置。 |
regexp_replace(str, regexp, rep[, position]) | 將符合regexp 的所有子字串str 取代為 rep 。 |
regexp_substr(str, regexp) | 傳回 中 str 符合 regexp 的第一個子字串。 |
repeat(expr, n) | 傳回重複時間的 expr n 字串。 |
replace(str, search [, replace]) | 將的所有專案 search 取代為 replace 。 |
reverse(expr) | 傳回反轉字串或具有專案反向順序的陣列。 |
right(str, len) | 從字串 str 傳回最len 右邊的字元。 |
str rlike regex | 如果 符合 regex ,則str 傳回 true。 |
rpad(expr, len[, pad]) | 傳 expr 回 ,並以 右填補為 pad 的 len 長度。 |
rtrim([trimStr,] str) | str 傳回結尾字元已移除。 |
sentences(str[, lang, country]) | 分割 str 成單字陣列。 |
沙(expr) | 傳回 sha1 哈希值做為 的 expr 十六進位字串。 |
sha1(expr) | 傳回 sha1 哈希值做為 的 expr 十六進位字串。 |
sha2(expr, bitLength) | 傳回 SHA-2 系列總和檢查碼做為 的 expr 十六進位字串。 |
soundex(expr) | 傳回字串的 soundex 程式代碼。 |
space(n) | 傳回包含空格的 n 字串。 |
split(str, regex[, limit]) | 在 str 符合 regex 的項目周圍分割,並傳回長度最多 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]) | 傳回 從 開始pos 且 長度len 為 的子字串expr 。 |
substr(expr FROM pos[ FOR len]) | 傳回 從 開始pos 且 長度len 為 的子字串expr 。 |
substring(expr, pos[, len]) | 傳回 從 開始pos 且 長度len 為 的子字串expr 。 |
substring(expr FROM pos[ FOR len]) | 傳回 從 開始pos 且 長度len 為 的子字串expr 。 |
substring_index(expr, delim, count) | 傳回 在發生分隔符 delim 之前count 的 子字串expr 。 |
to_binary(expr[, fmt]) | expr 傳回以 為基礎的fmt 二進位轉換。 |
to_char(numExpr, fmt) | numExpr 傳回使用格式設定fmt 的STRING 轉換。 |
to_varchar(numExpr, fmt) | numExpr 傳回使用格式設定fmt 的STRING 轉換。 |
translate(expr, from, to) | 傳expr 回 ,其中的所有字元都已取代為 中的to 字元from 。 |
trim([BOTH |LEADING |尾端] [trimStr] FROM] str) | 修剪字串中的字元。 |
try_aes_decrypt(expr, key[, mode[, padding[, aad]]]]) | 使用 AES 加密解密二進位檔 expr ,並在發生錯誤時傳回 NULL 。 |
try_to_binary(expr [, fmt]) | 根據 傳 expr 回轉換成 BINARY fmt ,如果輸入無效,則傳回 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 格式。 |
數值純量函式
函式 | 描述 |
---|---|
~ expr | 傳回的expr 位NOT 。 |
dividend / divisor | dividend 傳回除以 divisor 。 |
expr1 |expr2 | 傳回和expr2 的expr1 位OR 。 |
- expr | 傳回的 expr 負值。 |
expr1 - expr2 | 傳回的expr2 expr1 減法。 |
+ expr | 傳回的值 expr 。 |
expr1 + expr2 | 傳回 expr1 和 expr2 的總和。 |
dividend % divisor | 傳回 之後 dividend / divisor 的餘數。 |
expr1 ^ expr2 | 傳回和expr2 的expr1 位排除OR (XOR) 。 |
expr1 和 expr2 | 傳回和expr2 的expr1 位 AND。 |
乘數 * 乘數 | multiplier 傳回乘以 multiplicand 。 |
abs(expr) | 傳回 中 expr 數值的絕對值。 |
acos(expr) | 傳回的 expr 反餘弦值(反餘弦值)。 |
acosh(expr) | 傳回的反雙曲餘弦 expr 。 |
asin(expr) | 傳回 的 expr 反正弦值(反正弦值)。 |
asinh(expr) | 傳回的 expr 反雙曲正弦值。 |
atan(expr) | 傳回 的 expr 反正切值(反正切值)。 |
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 Cube 根目錄。 |
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 的雙曲餘弦。 |
科特(expr) | 傳回的 expr 餘切值。 |
csc(expr) | 傳回的 expr 共存項。 |
decimal(expr) | 將值 expr 轉換成 DECIMAL。 |
degrees(expr) | 將弧度轉換為度。 |
divisor div dividend | 傳回 除法dividend 的divisor 整數部分。 |
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) | 傳回 的自然對數(基底e )。expr |
log(base,] expr) | 使用base 傳回的expr 對數。 |
log1p(expr) | 傳回 log(1 + expr) 。 |
log2(expr) | 使用基底 2 傳回 的expr 對數。 |
log10(expr) | 使用基底 10 傳回 的expr 對數。 |
mod(除數,除數) | 傳回 之後 dividend / divisor 的餘數。 |
nanvl(expr1, expr2) | 如果 不是 NaN ,則expr2 傳expr1 回 ,否則傳回 。 |
negative(expr) | 傳回的 expr 負值。 |
pi() | 傳回pi。 |
pmod(除數,除數) | 傳回 後面的 dividend / divisor 正餘數。 |
positive(expr) | 傳回的值 expr 。 |
pow(expr1, expr2) | expr1 引發至的expr2 乘冪。 |
power(expr1, expr2) | expr1 引發至的expr2 乘冪。 |
radians(expr) | 以 expr 度為單位轉換成弧度。 |
rand(種子]) | 傳回介於 0 到 1 之間的隨機值。 |
蘭丁([種子]) | 從標準常態分佈傳回隨機值。 |
random([seed]) | 傳回介於 0 到 1 之間的隨機值。 |
rint(expr) | 傳 expr 回四捨五入為整數做為 DOUBLE。 |
round(expr[,targetScale]) | 使用HALF_UP 四捨五入模式傳回四捨五入expr 。 |
sec(expr) | 傳回的 expr secant。 |
sin(expr) | 傳回 expr 的正弦。 |
shiftleft(expr, n) | 傳回位左移位 n 。 |
shiftright(expr, n) | 傳回位帶正負號的帶正負號整數,由位移位 n 。 |
shiftrightunsigned(expr, n) | 傳回位不帶正負號的整數數位,由位向 n 右移位。 |
sign(expr) | 傳回 -1.0、0.0 或 1.0,如同 expr 負數、0 或正數。 |
signum(expr) | 傳回 -1.0、0.0 或 1.0,如同 expr 負數、0 或正數。 |
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 ,傳expr 回轉換成 DECIMAL。 |
try_add(expr1, expr2) | 傳回 和 的總 expr1 和 expr2 ,如果發生錯誤,則傳回 NULL。 |
try_divide(除數,除數) | dividend 傳回除以 divisor ,如果 divisor 為 0,則傳回 NULL。 |
try_multiply(乘數、乘數) | 傳 multiplier 回乘以 multiplicand 、或 NULL 溢位時。 |
try_subtract(expr1, expr2) | 傳回的減法expr2 ,或NULL 溢expr1 位時。 |
try_to_number(expr, fmt ) | expr 如果 expr 格式不符合格式fmt ,則傳回轉換成 DECIMAL。 |
width_bucket(expr, minExpr, maxExpr, numBuckets) | 傳回等寬直方圖中值的貯體編號。 |
彙總函數
函式 | 描述 |
---|---|
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]]) | 傳 k 回 中 expr 最常發生的專案值及其近似計數。 |
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) | 傳回一組數位組之間的相互關聯 Pearson 係數。 |
count\ | 傳回群組中擷取的數據列總數,包括包含 null 的數據列。 |
count(expr[, ...]) | 傳回群組中提供的表示式都是非 Null 的數據列數目。 |
count_if(expr) | 傳回 中 expr 群組的 true 值數目。 |
count_min_sketch(欄,epsilon,信心,種子) | 使用、 confidence 和 seed 傳回 群組中column epsilon 所有值的 count-min 草圖。 |
covar_pop(expr1,expr2) | 傳回群組中數位組的母體共變數。 |
covar_samp(expr1,expr2) | 傳回群組中數位組的樣本共變數。 |
every(expr) | 如果群組中的所有值 expr 都為 true,則傳回 true。 |
first(expr[,ignoreNull]) | 傳回數據列群組的第一個 值 expr 。 |
first_value(expr[,ignoreNull]) | 傳回數據列群組的第一個 值 expr 。 |
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) | 傳 expr1 回與群組中 最大值相關聯的 值 expr2 。 |
mean(expr) | 傳回從群組值計算的平均值。 |
median(expr) | 傳回從群組值計算的中位數。 |
min(expr) | 傳回群組中的 最小值 expr 。 |
min_by(expr1, expr2) | 傳回與群組中 最小值相關聯的 值expr1 expr2 。 |
mode(expr [,deterministic]) | 傳回群組中最常不是 NULL 的值 expr 。 |
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 平均值,其中 xExpr 和 yExpr 為 NOT NULL。 |
regr_avgy(yExpr, xExpr) | 傳回從群組值計算的 yExpr 平均值,其中 xExpr 和 yExpr 為 NOT NULL。 |
regr_count(yExpr, xExpr) | 傳回群組中非 Null 值組yExpr xExpr 的數目。 |
regr_intercept(yExpr, xExpr) | 傳回群組中單變數線性回歸線的截距,其中 xExpr 和 yExpr 為 NOT NULL。 |
regr_r2(yExpr, xExpr) | 從群組的值傳回判斷係數,其中 xExpr 和 yExpr 為 NOT NULL。 |
regr_slope(yExpr, xExpr) | 傳回群組中非 Null 值組yExpr xExpr 線性回歸線的斜率。 |
regr_sxx(yExpr, xExpr) | 傳回群組值的平方 xExpr 總和,其中 xExpr 和 yExpr 為 NOT NULL。 |
regr_sxy(yExpr, xExpr) | 傳回和計算自群組值,yExpr 且 為 NOT NULL 的產品總和xExpr yExpr 。xExpr |
regr_syy(yExpr, xExpr) | 傳回群組值的平方 yExpr 總和,其中 xExpr 和 yExpr 為 NOT NULL。 |
schema_of_json_agg(json[, options]) | 以 DDL 格式傳回群組中字串的 JSON 合併架構。 |
扭曲(expr) | 傳回從群組值計算的扭曲值。 |
some(expr) | 如果群組true 中至少有一個 值為 expr ,則傳回 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) | 傳回從群組值計算的樣本變異數。 |
變異數(expr) | 傳回從群組值計算的樣本變異數。 |
排名視窗函式
函式 | 描述 |
---|---|
dense_rank() | 傳回與分割區中所有值相較之下的值排名。 |
ntile(n) | 將每個視窗分割區的數據列分割成最多 1 到 n n 個值區。 |
percent_rank() | 計算數據分割內值的百分比排名。 |
rank() | 傳回與分割區中所有值相較之下的值排名。 |
row_number() | 根據視窗分割內數據列的順序,為每個數據列指派唯一的序號,從一個開始。 |
分析視窗函式
函式 | 描述 |
---|---|
cume_dist() | 傳回相對於數據分割中所有值的值位置。 |
lag(expr[,offset[,default]]] ) | 從數據分割內的前一個數據列傳回的值 expr 。 |
lead(expr[,offset[,default]]) | 從數據分割內的後續數據列傳回的值 expr 。 |
nth_value(expr, offset[, ignoreNulls]) | 傳回視窗中特定 offset 處的值expr 。 |
陣列函數
函式 | 描述 |
---|---|
arrayExpr[indexExpr] | 傳回位於ARRAYarrayExpr 位置indexExpr 的專案。 |
aggregate(expr,start,merge[,finish]) | 使用自訂匯總工具匯總數組中的專案。 |
array([expr [, ...]]]) | 傳回數位,其中包含中的 expr 專案。 |
array_append(array, elem) | array 傳回 所附加的 elem 。 |
array_compact(陣列) | 從 array 移除 NULL 值。 |
array_contains(array,value) | 如果 array 包含 value ,則傳回 true。 |
array_distinct(陣列) | 從 array 移除重複的值。 |
array_except(array1,array2) | 傳回 中的 array1 項目陣列,但不在中 array2 。 |
array_insert(array, index, elem) | 傳回展開array 的位置插入index 的位置elem 。 |
array_intersect(array1,array2) | 傳回和 array2 交集array1 中項目的陣列。 |
array_join(array,delimiter[,nullReplacement]) | 串連的專案 array 。 |
array_max(陣列) | 傳回 中的 array 最大值。 |
array_min(陣列) | 傳回 中的 array 最小值。 |
array_position(array,element) | 傳回 中array 第一次出現element 的位置。 |
array_prepend(array, elem) | array 傳回 前面加上 elem 。 |
array_remove(array,element) | 從array 移除 的所有專案element 。 |
array_repeat(元素,count) | 傳回包含 element count 時間的陣列。 |
array_size(陣列) | 傳回 中的 array 項目數目。 |
array_sort(陣列,func) | array 傳回根據 func 排序。 |
array_union(array1,array2) | 傳回 和 等array2 位array1 中項目陣列,不含重複專案。 |
arrays_overlap(array1, array2) | 如果 和 array2 的交集不是空的array1 ,則傳回 true。 |
arrays_zip(array1 [, ...]) | 傳回結構合併的陣列,其中第 n 個結構包含輸入數位的所有 N 個值。 |
基數(expr) | 傳回的大小 expr 。 |
concat(expr1, expr2 [, ...]) | 傳回自變數的串連。 |
element_at(arrayExpr, index) | 傳回 位於index 的 arrayExpr 專案。 |
exists(expr, pred) | 如果 pred 中任何專案 expr 為 true,則傳回 true。 |
爆炸(集合) | 透過非巢狀 collection 傳回數據列。 |
explode_outer(集合) | 使用外部語意取消巢狀 collection 傳回數據列。 |
filter(expr,func) | 使用函式 func 篩選 中的expr 陣列。 |
flatten(arrayOfArrays) | 將陣列陣陣轉換成單一陣列。 |
forall(expr, predFunc) | 測試是否 predFunc 保留陣列中的所有專案。 |
get(arrayExpr, index) | 傳回 位於 index 的 arrayExpr 專案,從 0 開始。 |
內嵌(expr) | 將結構陣列分解成數據表。 |
inline_outer(expr) | 將結構數位分解成具有外部語意的數據表。 |
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) | 使用func 函式 轉換 中expr 陣列中的專案。 |
try_element_at(arrayExpr, index) | 傳arrayExpr 回 位於 index 的專案,如果 index 超出界限,則NULL 傳回 。 |
zip_with(expr1, expr2, func) | 使用 將和expr2 中的expr1 數組合並成單一陣列func 。 |
對應函式
函式 | 描述 |
---|---|
mapExpr[keyExpr] | 傳回 MAP mapExpr 的 keyExpr 值。 |
基數(expr) | 傳回的大小 expr 。 |
element_at(mapExpr,金鑰) | 傳回的 key 值mapExpr 。 |
爆炸(expr) | 透過非巢狀 expr 傳回數據列。 |
explode_outer(expr) | 使用外部語意取消巢狀 expr 傳回數據列。 |
map([{key1, value1}[, ...]]] ) | 建立具有指定索引鍵/值組的對應。 |
map_concat([expr1 [, ...]]]) | 傳回所有 expr 對應表達式的聯集。 |
map_contains_key(地圖,索引鍵) | 如果 map 包含 key ,則傳true 回 ,false 否則傳回 。 |
map_entries(地圖) | 傳回 中 map 所有專案的未排序數位。 |
map_filter(expr, func) | 使用func 函式 篩選 對應expr 中的專案。 |
map_from_arrays(索引鍵、值) | 建立具有 一對 keys 和 values 陣列的對應。 |
map_from_entries(expr) | 建立從指定項目陣列建立的對應。 |
map_keys(地圖) | 傳回未排序的陣列,其中包含的 map 索引鍵。 |
map_values(地圖) | 傳回未排序的陣列,其中包含的值 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,索引鍵) | 如果 不存在,NULL key 則傳回的值mapExpr key 。 |
日期、時間戳和間隔函式
如需日期和時間格式的資訊,請參閱 日期時間模式。
函式 | 描述 |
---|---|
intervalExpr / divisor | 傳回除以的 divisor 間隔。 |
- intervalExpr | 傳回的 intervalExpr 負值。 |
intervalExpr1 - intervalExpr2 | 傳回的intervalExpr2 intervalExpr1 減法。 |
datetimeExpr1 - datetimeExpr2 | 傳回的datetimeExpr2 datetimeExpr1 減法。 |
+ 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(單位、值、expr) | 將 s 加入value unit 至時間戳 。 expr |
date_diff(單位,啟動,停止) | 傳回以 s 測量 unit 的兩個時間戳之間的差異。 |
date_format(expr,fmt) | 以 格式 fmt 將時間戳轉換為字串。 |
date_from_unix_date(天) | 從之後 1970-01-01 的天數建立日期。 |
date_part(field,expr) | 擷取日期、時間戳或間隔的一部分。 |
date_sub(startDate,numDays) | 傳回 之前的startDate 日期numDays 。 |
date_trunc(單位,expr) | 傳回截斷至 中所指定單位的 unit 時間戳。 |
dateadd(startDate,numDays) | 傳回 之後startDate 的日期numDays 。 |
dateadd(unit, value, expr) | 將 s 加入value unit 至時間戳 。 expr |
datediff(endDate,startDate) | 傳回 從 startDate 到 endDate 的天數。 |
datediff(unit, start, stop) | 傳回以 s 測量 unit 的兩個時間戳之間的差異。 |
day(expr) | 傳回日期或時間戳的月份日期。 |
dayofmonth(expr) | 傳回日期或時間戳的月份日期。 |
dayofweek(expr) | 傳回日期或時間戳的星期數。 |
dayofyear(expr) | 傳回日期或時間戳的年份日期。 |
divisor div dividend | 傳回間隔dividend 除法的divisor 整數部分。 |
extract(field FROM source) | 傳field source 回 。 |
from_unixtime(unixTime,fmt) | 在 中fmt 傳unixTime 回 。 |
from_utc_timestamp(expr,timezone) | 傳回時區 timeZone 中以UTC指定的時間戳expr 。 |
getdate() | 傳回查詢評估開始時的目前時間戳。 |
hour(expr) | 傳回時間戳的小時元件。 |
last_day(expr) | 傳回日期所屬月份的最後一天。 |
make_date(年,月,日) | 從 year 、 month 和 day 欄位建立日期。 |
make_dt_interval([days[, hours[,min[, secs]]]]) | 從days 、 hours mins 和 secs 建立日時間間隔。 |
make_interval(年、月、周、天、小時、分鐘、秒) | 已淘汰:從 years 、、months 、weeks 、days 、 hours mins 和 secs 建立間隔。 |
make_timestamp(year,month,day,hour,min,sec[,timezone]) | 從year 、month 、、、hour day 、min 、 sec 和 timezone 欄位建立時間戳。 |
make_ym_interval(年[, 月]]) | 從 years 和 months 建立年月間隔。 |
minute(expr) | 傳回 中 expr 時間戳的分鐘元件。 |
month(expr) | 傳回 中 expr 時間戳的月份元件。 |
months_between(expr1,expr2[,roundOff]) | 傳回 和 expr2 中expr1 日期或時間戳之間經過的月數。 |
next_day(expr,dayOfWeek) | 傳回晚於 expr 的第一個日期,並在 中 dayOfWeek 命名為 。 |
now() | 傳回查詢評估開始時的目前時間戳。 |
quarter(expr) | 傳回範圍 1 到 4 的年份 expr 四分之一。 |
second(expr) | 傳回 中 expr 時間戳的第二個元件。 |
session_window(expr, gpDuration) | 在時間戳表示式上建立會話視窗。 |
sign(expr) | 傳回 -1.0、0.0 或 1.0,因為間隔 expr 為負數、0 或正數。 |
signum(expr) | 傳回 -1.0、0.0 或 1.0,因為間隔 expr 為負數、0 或正數。 |
timediff(unit, start, stop) | 傳回以 s 測量 unit 的兩個時間戳之間的差異。 |
timestamp(expr) | expr 轉換成 TIMESTAMP。 |
timestamp_micros(expr) | 建立自UTC epoch以來的時間戳 expr 微秒數。 |
timestamp_millis(expr) | 建立UTC epoch之後的時間戳 expr 毫秒。 |
timestamp_seconds(expr) | 建立UTC epoch之後的時間戳 expr 秒數。 |
timestampadd(unit, value, expr) | 將 s 加入value unit 至時間戳 。 expr |
timestampdiff(unit, start, stop) | 傳回以 s 測量 unit 的兩個時間戳之間的差異。 |
to_date(expr[,fmt]) | 使用選擇性格式傳 expr 回轉換成日期。 |
to_timestamp(expr[,fmt]) | 使用選擇性格式,傳 expr 回轉換成時間戳。 |
to_unix_timestamp(expr[,fmt]) | 以 UNIX 時間戳的形式傳回 中的 expr 時間戳。 |
to_utc_timestamp(expr,timezone) | 以UTC傳回不同時區中的 expr 時間戳。 |
trunc(expr, fmt) | 傳回日期,其日期部分截斷至格式模型 fmt 所指定的單位。 |
try_add(expr1, expr2) | 傳回 和 的總 expr1 和 expr2 ,如果發生錯誤,則傳回 NULL。 |
try_divide(除數,除數) | dividend 傳回除以 divisor ,如果 divisor 為 0,則傳回 NULL。 |
try_multiply(乘數、乘數) | 傳 multiplier 回乘以 multiplicand 、或 NULL 溢位時。 |
try_subtract(expr1, expr2) | 傳回的減法expr2 ,或NULL 溢expr1 位時。 |
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(視窗) | 傳回視窗或session_window函式所產生的滑動視窗內含結束時間。 |
H3 地理空間函式
如需 H3 地理空間函式的相關信息,請參閱 H3 地理空間函式。
轉換函式和建構函式
如需類型之間轉換的資訊,請參閱 cast 函 式和 try_cast函式。
函式 | 描述 |
---|---|
array([expr [, ...]]]) | 傳回數位,其中包含中的 expr 專案。 |
bigint(expr) | 將值expr BIGINT 轉換成 。 |
binary(expr) | 將的值expr BINARY 轉換為 。 |
布林值(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 欄位建立日期。 |
make_dt_interval([days[, hours[,min[, secs]]]]) | 從days 、 hours mins 和 secs 建立日時間間隔。 |
make_interval(年、月、周、天、小時、分鐘、秒) | 從years 、、months 、weeks days 、 hours mins 和 secs 建立間隔。 |
make_timestamp(year,month,day,hour,min,sec[,timezone]) | 從year 、month 、、、hour day 、min 、 sec 和 timezone 欄位建立時間戳。 |
make_ym_interval(年[, 月]]) | 從 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) | expr 傳回使用格式設定fmt 的STRING 轉換。 |
to_date(expr[,fmt]) | 使用選擇性格式傳 expr 回轉換成日期。 |
to_number(expr, fmt) | 使用格式fmt ,傳expr 回轉換成 DECIMA L。 |
to_timestamp(expr[,fmt]) | 使用選擇性格式,傳 expr 回轉換成時間戳。 |
to_varchar(expr, fmt) | expr 傳回使用格式設定fmt 的STRING 轉換。 |
try_cast(expr AS 類型) | 安全地將值 expr 轉換成目標數據類型 type 。 |
try_to_number(expr, fmt) | expr 傳回使用格式fmt 設定 的轉換,NULL DECIMAL 如果 expr 不是有效的 ,則傳回 。 |
CSV 函式
函式 | 描述 |
---|---|
from_csv(csvStr, schema[, options]) | 傳回具有 csvStr 和 schema 的結構值。 |
schema_of_csv(csv[, options]) | 以 DDL 格式傳回 CSV 字串的架構。 |
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 [, ...]) | 以 Tuple 的形式傳回多個 JSON 物件。 |
schema_of_json(jsonStr[, options]) | 傳回 DDL 格式字串的 JSON 架構。 |
schema_of_json_agg(jsonStr[, options]) | 以 DDL 格式傳回群組中字串的 JSON 合併架構。 |
to_json(expr[, options]) | 傳 JSON 回字串,其中包含 中指定的 expr 結構。 |
XPath 和 XML 函式
函式 | 描述 |
---|---|
from_xml(xmlStr, schema[, options]) | 傳回使用 schema 剖析的結構xmlStr 值。 |
schema_of_xml(xmlStr[, options]) | 傳回 DDL 格式字串的 XML 架構。 |
xpath(xml, xpath) | 傳回符合 xpath 之節點xml 內的值。 |
xpath_boolean(xml, xpath) | true 如果xpath 表示式評估為 true ,則傳回 ;如果找到 中的xml 相符節點,則傳回 。 |
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(內容) | 傳回文字的情感。 |
ai_classify(內容、標籤) | 將提供的內容分類為其中一個提供的標籤。 |
ai_extract(內容、標籤) | 從指定的文字擷取由標籤指定的實體。 |
ai_fix_grammar(內容) | 更正指定文字中的文法錯誤。 |
ai_gen(內容) | 從 Databricks Foundation 模型 API 叫用最先進的產生 AI 模型,以回應使用者提供的提示。 |
ai_generate_text(prompt, modelName[, param1, value1] [...]) | 已被取代:傳回指定提示時,由選取的大型語言模型 (LLM) 產生的文字。 |
ai_mask(內容、標籤) | 遮罩指定文字中的指定實體。 |
ai_query(endpointName, request, returnType) | 叫用現有的 Databricks 模型服務端點,並剖析並傳回其回應。 |
ai_similarity(strExpr1,strExpr2) | 比較兩個字串,並計算語意相似度分數。 |
ai_summarize(content[, max_words]) | 產生指定文字的摘要。 |
ai_translate(內容,to_lang) | 將文字翻譯成指定的目標語言。 |
讀取函式
函式 | 描述 |
---|---|
read_files(path, [optionKey => optionValue] [, ...]) | 讀取雲端記憶體上的數據檔,並以表格式格式傳回。 |
read_kafka([optionKey => optionValue] [, ...]) | 從 Apache Kafka 叢集讀取記錄,並以表格式傳回記錄。 |
read_kinesis({parameter => value} [, ...]) | 傳回從一或多個數據流讀取記錄的數據表。 |
read_pubsub([parameter => value] [, ...]) | 從主題讀取 Pub/Sub 記錄的數據表值函式。 |
read_pulsar({optionKey => optionValue} [, ...]) | 傳回數據表,其中包含從 Pulsar 讀取的記錄。 |
read_state_metadata(路徑) | 傳回數據表,其中包含代表串流查詢狀態元數據的數據列。 |
read_statestore(path [, option_key => option_value] [...]) | 從串流查詢的狀態存放區傳回記錄。 |