Beépített függvények
A következőkre vonatkozik: Databricks SQL Databricks Runtime
Ez a cikk a sztringek és bináris típusok, numerikus skalárok, aggregációk, ablakok, tömbök, térképek, dátumok és időbélyegek, casting, CSV-adatok, JSON-adatok, XPath-manipuláció és egyéb egyéb függvények beépített operátoraira és leírásaira mutató hivatkozásokat és leírásokat tartalmaz.
Lásd még:
Operátorok és predikátumok
Az operátorok egymáshoz való elemzésének módjáról további információt az Operátorok elsőbbsége című témakörben talál.
Operátor | Szintaxis | Leírás |
---|---|---|
& | expr1 & expr2 |
A bitenkénti ÉS és a expr1 expr2 . |
és | expr1 and expr2 |
A logikai ÉS és a expr1 expr2 . |
* | multiplier * multiplicand |
A visszaadott érték multiplier szorozva multiplicand . |
!= | expr1 != expr2 |
Igaz értéket ad vissza, ha expr1 nem egyenlő expr2 vagy false más módon. |
! | !expr |
Logikai kifejezés logikai NOT értékét adja vissza. |
között | expr1 [not] between expr2 and expr2 |
Azt vizsgálja, hogy nagyobb vagy egyenlő-e expr1 , mint expr2 a kisebb vagy egyenlő expr3 . |
[ ] | arrayExpr [ indexExpr ] |
indexExpr A TÖMB nd elemét adja visszaarrayExpr |
[ ] | mapExpr [ keyExpr ] |
A MAP értékének keyExpr visszaadása mapExpr |
^ | expr1 ^ expr2 |
A bitenkénti és OR (XOR) expr1 expr2 a . |
: | jsonStr : jsonPath |
A mezőből jsonStr kinyert mezőket adja vissza. |
:: | expr :: type |
Az értéket expr a cél adattípusra type veti. |
Div | divisor div dividend |
A by osztás divisor dividend szerves részét adja vissza. |
. | mapExpr . keyIdentifier |
Értéket keyIdentifier ad MAP vissza . |
. | structExpr . fieldIdentifier |
Egy mezőt fieldIdentifier ad STRUCT vissza . |
== | expr1 == expr2 |
Visszaadja true , ha expr1 egyenlő expr2 , vagy false más módon. |
= | expr1 = expr2 |
Visszaadja true , ha expr1 egyenlő expr2 , vagy false más módon. |
>= | expr1 >= expr2 |
Akkor adja true vissza, ha expr1 nagyobb vagy egyenlő expr2 , vagy false más módon. |
> | expr1 > expr2 |
Akkor adja true vissza, ha expr1 nagyobb, mint expr2 vagy false más. |
Létezik | exists(query) |
Igaz értéket ad vissza, ha query legalább egy sort ad vissza, vagy hamis értéket ad vissza. |
ilike | str [not] ilike (pattern[ESCAPE escape]) |
Igaz értéket ad vissza, ha str nem (nem) egyezik pattern a kis- és escape nagybetűkkel. |
ilike | str [not] ilike {ANY|SOME|ALL}([pattern[, ...]]) |
Igaz értéket ad vissza, ha str (nem) egyezik a kis- és nagybetűket érzéketlenül ábrázoló mintázatokkal. |
ban | elem [not] in (expr1[, ...]) |
Visszaadja true , ha elem nem (nem) egyenlő bármelyik exprN . |
ban | elem [not] in (query) |
Visszaadjatrue , ha elem nem (nem) egyenlő a sor.query |
eltérő | expr1 is [not] distinct from expr2 |
Azt vizsgálja, hogy az argumentumok eltérő értékekkel rendelkeznek-e (nem), ha a NULL-ek összehasonlítható értékeknek minősülnek. |
hamis | expr is [not] false |
Azt vizsgálja, hogy (nem) false van-eexpr . |
null értékű | expr is [not] null |
Visszaadja true , ha expr az (nem) NULL . |
igaz | expr is [not] true |
Azt vizsgálja, hogy (nem) true van-eexpr . |
szeret | str [not] like (pattern[ESCAPE escape]) |
Igaz értéket ad vissza, ha str (nem) egyezik pattern a .escape |
szeret | str [not] like {ANY|SOME|ALL}([pattern[, ...]]) |
Igaz értéket ad vissza, ha str nem (nem) egyezik az összes mintával. |
<=> | expr1 <=> expr2 |
Ugyanazt az eredményt adja vissza, mint a EQUAL(=) nem null értékű operandusok esetében, de akkor adja vissza true , ha mindkettő NULL , false ha az egyik az NULL . |
<= | expr1 <= expr2 |
Akkor adja true vissza, ha expr1 kisebb vagy egyenlő expr2 , vagy false más módon. |
<> | expr1 <> expr2 |
Visszaadja true , ha expr1 nem egyenlő expr2 vagy false más. |
< | expr1 < expr2 |
Akkor adja true vissza, ha expr1 kisebb, mint expr2 , vagy false más módon. |
- | expr1 - expr2 |
A kivonást expr2 adja vissza a forrásból expr1 . |
nem | not expr |
Logikai kifejezés logikai NOT értékét adja vissza. |
vagy | expr1 or expr2 |
A logikai OR expr1 és expr2 a . |
% | dividend % divisor |
A maradékot a következő után dividend / divisor adja vissza. |
|| | expr1 || expr2 |
A következő összefűződését expr1 adja vissza: és expr2 . |
| | expr1 | expr2 |
A bitenkénti OR expr1 és expr2 a . |
+ | expr1 + expr2 |
Az és a . összegének expr1 expr2 értékét adja vissza. |
regexp | str [not] regexp regex |
Igaz értéket ad vissza, ha str nem (nem) egyezik regex . |
regexp_like | str [not] regexp_like regex |
Igaz értéket ad vissza, ha str nem (nem) egyezik regex . |
rlike | str [not] rlike regex |
Igaz értéket ad vissza, ha str nem (nem) egyezik regex . |
/ | dividend / divisor |
A visszaadott érték dividend osztva a következővel divisor : . |
~ | ~ expr |
A bitenkénti értéket NOT expr adja vissza. |
Operátorok műveleti sorrendje
Prioritás | Operátor |
---|---|
0 | : , , :: [ ] |
2 | - (unary), + (unary), ~ |
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 |
Sztring- és bináris függvények
Függvény | Leírás |
---|---|
expr1 || expr2 | A következő összefűződését expr1 adja vissza: és expr2 . |
aes_decrypt(expr, key[, mode[, padding[, aad]]]) | Egy bináris visszafejtése expr AES-titkosítással. |
aes_encrypt(expr, key[, mode[, padding[, iv[, aad]]]]) | Bináris titkosítás expr AES-titkosítással. |
ascii(str) | A első karakterének ASCII-kódpontját str adja vissza. |
base64(expr) | expr Alap 64-es sztringgé alakul át. |
bin(expr) | A bináris ábrázolását expr adja vissza. |
binary(expr) | Bináris értékre veti az értéket expr . |
bit_length(kifejezés) | A sztringadatok bithosszát vagy a bináris adatok bitjeinek számát adja vissza. |
bitmap_count(kifejezés) | A bitképet képviselő sztringben BINARY beállított bitek számát adja vissza. |
btrim(str [, trimStr]) | Visszavezeti a str bevezető és a záró karaktereket. |
char(expr) | A megadott UTF-16 kódpont karakterét adja vissza. |
char_length(kifejezés) | A sztringadatok karakterhosszát vagy bináris adatok bájtjainak számát adja vissza. |
character_length(kifejezés) | A sztringadatok karakterhosszát vagy bináris adatok bájtjainak számát adja vissza. |
charindex(substr, str[, pos]) | A következő pozíció első előfordulásának substr str pos pozícióját adja vissza. |
chr(expr) | A megadott UTF-16 kódpont karakterét adja vissza. |
concat(expr1; expr2[, ...]) | Az argumentumok összefűzésének értékét adja vissza. |
concat_ws(sep[, expr1[, ...]]) | Az összefűzési sztringeket sep adja vissza. |
contains(expr, subExpr) | Visszaadja, true ha expr a SZTRING vagy a BINÁRIS tartalmaz subExpr . |
crc32(expr) | Ciklikus redundanciaellenőrzési expr értéket ad vissza. |
decode(expr, charSet) | A karakterkészlet kódolásával charSet lefordítja a bináris expr fájlt egy sztringre. |
encode(expr, charSet) | Egy sztring bináris ábrázolását adja vissza a charSet karakterkódolás használatával. |
endswith(expr, endExpr) | Visszaadjatrue , ha expr a SZTRING vagy a BINÁRIS végződés.endExpr |
find_in_set(searchExpr, sourceExpr) | Egy sztring helyét adja vissza a sztringek vesszővel tagolt listájában. |
format_number(kif, skálázás) | Formátumok expr , például #,###,###.## tizedesjegyre scale kerekítve. |
format_number(kif, fmt) | Formátumok expr , például fmt . |
format_string(strfmt[, obj1 [, ...]]) | Egy formázott sztringet ad vissza a printf stílusú formázási sztringekből. |
hex(expr) | expr Hexadecimálissá konvertálja. |
str ilike (minta[ESCAPE escape]) | Igaz értéket ad vissza, ha str pattern a kis- és nagybetűk escape érzéketlenek. |
initcap(expr) | Az egyes szavak első betűjével nagybetűs értéket ad expr vissza. |
instr(str, substr) | Az első előfordulás (1-alapú) indexét substr adja eredményül str . |
lcase(expr) | A visszaadott expr karakterek kisbetűssé változnak. |
bal(str, len) | A bal szélső len karaktereket adja vissza.str |
len(expr) | A sztringadatok karakterhosszát vagy bináris adatok bájtjainak számát adja vissza. |
length(expr) | A sztringadatok karakterhosszát vagy bináris adatok bájtjainak számát adja vissza. |
levenshtein(str1, str2) | A sztringek és str2 a sztringek str1 közötti Levenshtein távolságot adja vissza. |
str like (minta[ESCAPE escape]) | Igaz értéket ad vissza, ha str megegyezik pattern a következővel escape : . |
locate(substr, str[, pos]) | A következő pozíció első előfordulásának substr str pos pozícióját adja vissza. |
lower(expr) | A visszaadott expr karakterek kisbetűssé változnak. |
lpad(expr, len[, pad]) | Visszaadja expr , balról kipárnázva pad a hossza len . |
ltrim([trimstr;] str) | str Az el nem távolított bevezető karaktereket tartalmazó visszatérési értéktrimStr . |
mask(str[, upperChar[, lowerChar[, digitChar[, otherChar]]]]) | A bemenet str maszkolt verzióját adja vissza. |
md5(expr) | Egy MD5 128 bites ellenőrzőösszeget ad vissza hexa expr sztringként. |
octet_length(kifejezés) | A sztringadatok bájthosszát vagy bináris adatok bájtjainak számát adja vissza. |
overlay(input PLACING replace FROM pos [FOR len]) | input replace A helyére a kezdő pos és a hossz len lép. |
parse_url(url, partToExtract[, key]) | Kiolvas egy részt a fájlból url . |
position(substr, str[, pos]) | A következő pozíció első előfordulásának substr str pos pozícióját adja vissza. |
position(subtr IN str) | A következő pozíció első előfordulásának substr str pos pozícióját adja vissza. |
printf(strfmt[, obj1 [, ...]]) | Egy formázott sztringet ad vissza a printf stílusú formázási sztringekből. |
str regexp regex | Igaz értéket ad vissza, ha str megegyezik regex . |
str regexp_like regex | Igaz értéket ad vissza, ha str megegyezik regex . |
regexp_count(str, regexp) | A mintának megfelelő regexp alkalmak str számát adja vissza. |
regexp_extract(str, regexp[, idx]) | Kinyeri az első sztringet str , amely megfelel a regexp kifejezésnek, és megfelel a regex csoportindexnek. |
regexp_extract_all(str, regexp[, idx]) | Kinyeri a kifejezésnek megfelelő és a regexp csoportindexnek megfelelő összes sztringet.str regex |
regexp_instr(str, regexp) | Az első részszúrás pozícióját adja vissza az adott egyezésben str regexp . |
regexp_replace(str, regexp, rep[, position]) | Az adott egyezés regexp összes alsztringjének lecserélése str a gombrarep . |
regexp_substr(str, regexp) | Az első részszűrést adja vissza az adott egyezésben str regexp . |
repeat(expr; n) | Az ismétlődéseket megismétlő sztringet expr n adja vissza. |
replace(str, search [, replace]) | A minden előfordulását lecseréli search a gombra replace . |
reverse(expr) | Fordított sztringet vagy elemek fordított sorrendjét tartalmazó tömböt ad vissza. |
right(str, len) | A sztring len str jobb szélső karaktereit adja vissza. |
str rlike regex | Igaz értéket ad vissza, ha str megegyezik regex . |
rpad(expr, len[, pad]) | Visszaadja expr , jobbról kipárnázva pad a hossza len . |
rtrim([trimStr;] str) | Visszaadja str a záró karaktereket eltávolítva. |
mondatok(str[, lang, country]) | str Szavak tömbjének felosztása. |
sha(expr) | Sha1 kivonatértéket ad vissza hexa expr sztringként. |
sha1(expr) | Sha1 kivonatértéket ad vissza hexa expr sztringként. |
sha2(expr, bitLength) | Az SHA-2 család ellenőrzőösszegét adja vissza hexa expr sztringként. |
soundex(expr) | A sztring soundex kódját adja vissza. |
szóköz(n) | Szóközökből álló n sztringet ad vissza. |
split(str, regex[, limit]) | str Olyan előfordulások köré oszt, amelyek egyeznekregex , és legfeljebb limit egy tömböt adnak vissza. |
split_part(str, delim, partNum) | str A rész előfordulásai delim körül oszlik el, és visszaadja aztpartNum . |
startswith(expr, startExpr) | Visszaadja true , ha expr a SZTRING vagy a BINÁRIS függvény a következővel startExpr kezdődik: . |
string(expr) | Az értéket expr STRING értékre öntötte. |
substr(expr, pos[, len]) | Annak a részszűrését expr adja vissza, amely a következő időpontban pos kezdődik és hosszú len . |
substr(expr FROM pos[ FOR len]) | Annak a részszűrését expr adja vissza, amely a következő időpontban pos kezdődik és hosszú len . |
substring(expr, pos[, len]) | Annak a részszűrését expr adja vissza, amely a következő időpontban pos kezdődik és hosszú len . |
substring(expr FROM pos[ FOR len]) | Annak a részszűrését expr adja vissza, amely a következő időpontban pos kezdődik és hosszú len . |
substring_index(kibontás, tagolás, darabszám) | Az elválasztó delim előtti count előfordulások részszúrását expr adja vissza. |
to_binary(expr[, fmt]) | Visszaadja expr a bináris értékre leadott értéket a .fmt |
to_char(numExpr, fmt) | Visszaadja a numExpr formázást STRING használó fmt öntött értéket." |
to_varchar(numExpr, fmt) | Visszaadja a numExpr formázást STRING használó fmt öntött értéket." |
translate(expr, from, to) | Egy olyan karaktert expr ad vissza, amelyben az from összes karaktert lecserélték a következőben szereplő to karakterekre: |
trim([[BOTH | VEZETŐ | ZÁRÓ] [trimStr] FROM] str) | Karakterek levágása sztringből. |
try_aes_decrypt(expr, key[, mode[, padding[, aad]]]) | Egy bináris visszafejtése expr AES-titkosítással, hiba esetén pedig visszaadva NULL . |
try_to_binary(expr [, fmt]) | expr Bináris értékre leadott értéket ad vissza a megadott érték alapjánfmt , vagy NULL ha a bemenet érvénytelen. |
try_zstd_decompress(érték) | A Zstandard-tömörítéssel NULL vagy érvénytelen bemenettel tömörített értéket ad vissza. |
ucase(expr) | Az összes karakter nagybetűsre expr módosult visszaadása. |
unbase64(expr) | Egy dekódolt base64-sztringet ad vissza binárisként. |
unhex(expr) | Binárissá alakítja a hexadecimálist expr . |
upper(expr) | Az összes karakter nagybetűsre expr módosult visszaadása. |
url_decode(str) | Sztringet fordít vissza az alkalmazás/x-www-form-urlencoded formátumból. |
url_encode(str) | Sztringet lefordít alkalmazás/x-www-form-urlencoded formátumba. |
zstd_compress (érték[;szint[,streaming_mode]]) | Zstandard tömörítéssel tömörített értéket ad vissza. |
zstd_decompress(érték) | Zstandard tömörítéssel tömörített értéket ad vissza. |
Numerikus skaláris függvények
Függvény | Leírás |
---|---|
~ expr | A bitenkénti értéket NOT expr adja vissza. |
osztalék/ osztó | A visszaadott érték dividend osztva a következővel divisor : . |
expr1 | expr2 | A bitenkénti OR expr1 és expr2 a . |
- kifésül | A negated értékének expr értékét adja vissza. |
expr1 - expr2 | A kivonást expr2 adja vissza a forrásból expr1 . |
+ kif | Az érték értékét expr adja vissza. |
expr1 + expr2 | Az és a . összegének expr1 expr2 értékét adja vissza. |
osztalék %-os osztója | A maradékot a következő után dividend / divisor adja vissza. |
expr1 ^ expr2 | A bitenkénti és OR (XOR) expr1 expr2 a . |
expr1 és expr2 | A bitenkénti ÉS és a expr1 expr2 . |
szorzó * szorzás | A visszaadott érték multiplier szorozva multiplicand . |
abs(expr) | A numerikus érték abszolút értékét adja vissza a következőben expr : . |
acos(expr) | A függvény inverz koszinuszát expr (arccosine) adja vissza. |
acosh(expr) | A függvény inverz hiperbolikus koszinuszát expr adja vissza. |
asin(expr) | A függvény inverz szinuszát expr (arcsine) adja vissza. |
asinh(expr) | A függvény inverz hiperbolikus szinuszát expr adja vissza. |
atan(expr) | A függvény inverz tangensét expr (arctangent) adja vissza. |
atan2(exprY, exprX) | A sík pozitív x tengelye és a koordináták (exprX , exprY ) által megadott pont közötti radiánban megadott szöget adja vissza. |
atanh(expr) | A függvény inverz hiperbolikus tangensét adja expr vissza. |
bigint(expr) | Az értéket expr bigint értékre öntötte. |
bit_count(kifejezés) | Az argumentumban beállított bitek számát adja vissza. |
bit_get(expr, pos) | Egy bit értékét adja vissza egy integrál numerikus bináris ábrázolásában. |
bit_reverse(kifejezés) | Az argumentum bitjeinek sorrendjének megfordításával kapott értéket adja vissza. |
bitmap_bit_position(kifejezés) | Egy adott szám 0-alapú bitpozícióját adja vissza egy BIGINT gyűjtőben. |
bitmap_bucket_number(kifejezés) | Egy adott BIGINT szám bitkép gyűjtőszámát adja vissza. |
bround(expr[;targetScale]) | Kerekítési módban adja vissza a kerekített expr HALF_EVEN értéket. |
cbrt(expr) | A kocka gyökerét expr adja vissza. |
ceil(expr[;targetScale]) | A legkisebb számot adja vissza, amely nem kisebb, mint expr a tizedesvesszőhöz viszonyított számjegyekre kerekítve targetScale . |
ceiling(expr[;targetScale]) | A legkisebb számot adja vissza, amely nem kisebb, mint expr a tizedesvesszőhöz viszonyított számjegyekre kerekítve targetScale . |
conv(szám, fromBase, toBase) | Átkonvertálás num innen: fromBase toBase . |
convert_timezone([sourceTz, ]targetTz, sourceTs) | Átalakítja a TIMESTAMP_NTZ sourceTs az időzónából targetTz .sourceTz |
cos(expr) | A koszinusz értékét expr adja vissza. |
cosh(expr) | A hiperbolikus koszinusz értékét expr adja vissza. |
cot(kif) | A következő kotangensét expr adja vissza: . |
csc(expr) | A koszekáns értékét expr adja vissza. |
decimális(kitevő) | Az értéket expr decimális értékre öntötte. |
fok(kif) | A radiánokat fokmá alakítja. |
osztó div osztalék | A by osztás divisor dividend szerves részét adja vissza. |
double(expr) | Az értéket DUPLA értékre expr öntötte. |
e() | Az állandót e adja vissza. |
exp(expr) | e Visszatér a hatalom.expr |
expm1(expr) | A visszaadott érték.exp(expr) - 1 |
factorial(expr) | A függvény faktoriálisát expr adja vissza. |
float(expr) | Az értéket a FLOAT értékre expr öntötte. |
floor(expr[;targetScale]) | A legnagyobb számot adja vissza, amely nem kisebb, mint expr a targetScale tizedesvesszőhöz viszonyított számjegyekre kerekítve. |
getbit(expr, pos) | Egy bit értékét adja vissza egy integrál numerikus bináris ábrázolásában. |
hypot(expr1; expr2) | A visszaadott érték.sqrt(expr1 * expr1 + expr2 * expr2) |
int(expr) | Az értéket expr egész számra vetíti. |
isnan(expr) | Ha igen, true expr akkor adja vissza.NaN |
ln(expr) | A természetes logaritmust (alap e ) adja eredményül expr . |
log([base;] expr) | A következő logaritmusát expr base adja vissza: . |
log1p(expr) | A visszaadott érték.log(1 + expr) |
log2(expr) | Az alap 2 logaritmusát expr adja vissza. |
log10(expr) | Az alap 10 logaritmusát expr adja vissza. |
mod(osztalék, osztó) | A maradékot a következő után dividend / divisor adja vissza. |
nanvl(expr1, expr2) | Akkor ad expr1 vissza, ha nem NaN , vagy expr2 más módon. |
negatív(expr) | A negated értékének expr értékét adja vissza. |
pi() | A pi értéket adja vissza. |
pmod(osztalék, osztó) | A pozitív maradékot adja vissza a következő után dividend / divisor . |
positive(expr) | Az érték értékét expr adja vissza. |
pow(expr1, expr2) | Felemeli expr1 a hatalmat.expr2 |
power(expr1; expr2) | Felemeli expr1 a hatalmat.expr2 |
radians(expr) | expr Fokban radiánokká konvertálja. |
rand([mag]) | 0 és 1 közötti véletlenszerű értéket ad vissza. |
randn([mag]) | Véletlenszerű értéket ad vissza egy normál eloszlásból. |
random([seed]) | 0 és 1 közötti véletlenszerű értéket ad vissza. |
rint(expr) | expr Egy egész számra kerekített értéket ad vissza DUPLA értékként. |
round(expr[;targetScale]) | Kerekítési módban adja vissza a kerekített expr HALF_UP értéket. |
sec(expr) | A szekáns expr értékét adja vissza. |
shiftleft(expr; n) | Bitenkénti balra, bitenkénti eltolást n ad vissza. |
shiftright(expr; n) | Bitenkénti aláírt, bitenkénti aláírt integrálszámot ad vissza, amelyet n bitek jobbra tolnak el. |
shiftrightunsigned(expr, n) | Bitenkénti, alá nem írt aláírt szerves számot ad vissza, bitek szerint jobbra eltolással n . |
sign(expr) | -1,0, 0,0 vagy 1,0 értéket ad vissza negatív, 0 vagy pozitív értékként expr . |
signum(expr) | -1,0, 0,0 vagy 1,0 értéket ad vissza negatív, 0 vagy pozitív értékként expr . |
sin(expr) | A következő szinuszát expr adja vissza: . |
sinh(expr) | A hiperbolikusz szinuszát expr adja vissza. |
smallint(expr) | Az értéket expr a SMALLINT értékre öntötte. |
sqrt(expr) | A négyzetgyökét expr adja vissza. |
tan(expr) | A következő tangensét expr adja vissza: . |
tanh(expr) | A függvény hiperbolikus tangensét expr adja vissza. |
tinyint(expr) | A TINYINT-nek veti expr . |
to_number(kif; fmt ) | Formázással fmt visszaadja expr a TIZEDES értékre öntött értéket. |
try_add(expr1; expr2) | Hiba esetén a null expr2 értéket expr1 adja eredményül. |
try_divide(osztalék, osztó) | A visszaadott értékek dividend osztva divisor az , vagy NULL értékkel, ha divisor 0. |
try_multiply(szorzó, szorzó) | A visszaadott érték multiplier szorozva multiplicand , vagy NULL túlcsordulás esetén. |
try_subtract(expr1; expr2) | A kivonást adja vissza a expr2 forrásból expr1 vagy NULL a túlcsordulásból. |
try_to_number(expr, fmt ) | A decimális expr értékre öntött értéket adja vissza formázással fmt , vagy NULL értékre, ha expr nem egyezik meg a formátummal. |
width_bucket(expr, minExpr, maxExpr, numBuckets) | Egy egyenlőségszélességű hisztogramban szereplő érték gyűjtőszámát adja vissza. |
Aggregátumfüggvények
Függvény | Leírás |
---|---|
any(expr) | Igaz értéket ad vissza, ha a csoport legalább egy értéke expr igaz. |
any_value(expr[;ignoreNull]) | Egy sorcsoport bizonyos értékét expr adja vissza. |
approx_count_distinct(expr[;relativeSD]) | A csoporton belüli különböző értékek expr becsült számát adja vissza. |
approx_percentile(kif;százalék[;pontosság]) | A csoporton belüli hozzávetőleges percentilis értékét expr adja vissza. |
approx_top_k(expr[;k[;maxItemsTracked]]) | A leggyakrabban k előforduló elemértékeket adja vissza a expr hozzávetőleges számokkal együtt. |
array_agg(kifejezés) | Egy tömböt ad vissza, amely a csoport összes értékéből expr áll. |
avg(expr) | Egy csoport értékeiből kiszámított középértéket számítja ki. |
bit_and(kifejezés) | A csoport összes bemeneti értékének bitenkénti értékét AND adja vissza. |
bit_or(kifejezés) | A csoport összes bemeneti értékének bitenkénti értékét OR adja vissza. |
bit_xor(kifejezés) | A csoport összes bemeneti értékének bitenkénti értékét XOR adja vissza. |
bitmap_construct_agg(kifejezés) | A csoport összes bitpozícióértékének bitenkénti értékét OR adja vissza. 0 és 32767 között egy csoportban.BINARY |
bitmap_or_agg(kifejezés) | A csoport összes BINARY bemeneti értékének bitenkénti értékét OR adja vissza. |
bool_and(kifejezés) | Igaz értéket ad vissza, ha az összes érték expr igaz a csoportban. |
bool_or(kifejezés) | Igaz értéket ad vissza, ha legalább egy érték expr igaz a csoportban. |
collect_list(kifejezés) | Egy tömböt ad vissza, amely a csoport összes értékéből expr áll. |
collect_set(kifejezés) | A csoporton belüli összes egyedi értékből expr álló tömböt ad vissza. |
corr(expr1;expr2) | A pearson korrelációs együtthatót adja vissza a számpárok egy csoportja között. |
darabszám(*) | Egy csoport beolvasott sorainak teljes számát adja vissza, beleértve a null értéket tartalmazó sorokat is. |
count(expr[, ...]) | Egy olyan csoport sorainak számát adja vissza, amelyekhez a megadott kifejezések mind nem null értékűek. |
count_if(kifejezés) | A csoport valódi értékeinek számát adja vissza a következőben expr : . |
count_min_sketch(oszlop,epszilon,megbízhatóság,mag) | A csoport column összes értékének darab-perc vázlatát adja vissza az és confidence seed a epsilon . |
covar_pop(expr1;expr2) | Egy csoport számpárjainak sokasági kovvarianciáját adja vissza. |
covar_samp(expr1;expr2) | Egy csoport számpárjainak minta kovarianciáját adja vissza. |
every(expr) | Igaz értéket ad vissza, ha a csoport összes értéke expr igaz. |
first(expr[;ignoreNull]) | Egy sorcsoport első értékét expr adja vissza. |
first_value(expr[;ignoreNull]) | Egy sorcsoport első értékét expr adja vissza. |
histogram_numeric(expr;numBins) | Hisztogramot expr számít ki a tárolókkal numBins , és visszaadja a dobozközpontokat képviselő párok tömbjét. |
hll_sketch_agg(expr[;lgConfigK]) | Egy HyperLog-vázlatot ad vissza, amely egy különböző értékek számának közelítésére szolgál. |
hll_union_agg(expr[,allowDifferentLgConfigK]) | Összesíti a HyperLog-vázlatokat egy sorcsoporthoz. |
kurtosis(expr) | Egy csoport értékeiből kiszámított kurtózisértéket adja vissza. |
last(expr[;ignoreNull]) | A sorok csoportjának utolsó értékét expr adja vissza. |
last_value(expr[;ignoreNull]) | A sorok csoportjának utolsó értékét expr adja vissza. |
max(expr) | Egy csoport maximális értékét expr adja vissza. |
max_by(expr1;expr2) | Egy csoport maximális értékével expr2 társított érték értékét expr1 adja vissza. |
középérték(kifejezés) | Egy csoport értékeiből kiszámított középértéket számítja ki. |
medián(kifejezés) | Egy csoport értékeiből kiszámított mediánt adja vissza. |
min(expr) | Egy csoport minimális értékét expr adja vissza. |
min_by(expr1; expr2) | Egy csoport minimális értékéhez expr2 társított érték értékét expr1 adja vissza. |
mode(expr [,determinisztikus]) | A csoport leggyakoribb, nem NULL pedig a leggyakoribb értékét expr adja eredményül. |
percentilis(expr; százalék [;gyakoriság]) | A megadott percentage percentilisérték pontos értékét expr adja vissza. |
percentile_approx(kif;százalék[;pontosság]) | A csoporton belüli hozzávetőleges percentilis értékét expr adja vissza. |
percentile_cont(pct) CSOPORTON BELÜL (ORDER BY key) | A csoporton belüli interpolált percentilis értékét key adja vissza. |
percentile_disc(pct) CSOPORTON BELÜL (ORDER BY key) | A csoporton belüli különálló percentilis értékét key adja vissza. |
regr_avgx(yExpr, xExpr) | Egy olyan csoport értékeiből számított középértéket xExpr számítja ki, ahol xExpr ÉS yExpr NEM NULL. |
regr_avgy(yExpr, xExpr) | Egy olyan csoport értékeiből számított középértéket yExpr számítja ki, ahol xExpr ÉS yExpr NEM NULL. |
regr_count(yExpr, xExpr) | A nem null értékű párok yExpr xExpr számát adja vissza a csoportban. |
regr_intercept(yExpr, xExpr) | Az egyváltoztatású lineáris regressziós vonal metszetét adja vissza egy olyan csoportban, ahol xExpr ÉS yExpr NEM NULL. |
regr_r2(yExpr, xExpr) | A meghatározási együtthatót egy olyan csoport értékeiből adja vissza, ahol xExpr ÉS yExpr NEM NULL. |
regr_slope(yExpr, xExpr) | A nem null értékű párok lineáris regressziós yExpr xExpr vonalának meredekségét adja vissza a csoportban. |
regr_sxx(yExpr, xExpr) | Egy olyan csoport értékeinek négyzetösszegét xExpr adja vissza, ahol xExpr ÉS yExpr NEM NULL. |
regr_sxy(yExpr, xExpr) | Egy olyan csoport értékeiből kiszámított és xExpr előállított termékek yExpr összegét adja vissza, amelyeknél yExpr xExpr a NEM NULL érték van megadva. |
regr_syy(yExpr, xExpr) | Egy olyan csoport értékeinek négyzetösszegét yExpr adja vissza, ahol xExpr ÉS yExpr NEM NULL. |
schema_of_json_agg(json[, beállítások]) | A sztringek egyesített sémáját JSON adja vissza egy csoportban DDL formátumban. |
ferdeség(kitérő) | Egy csoport értékeiből kiszámított ferdeségi értéket adja vissza. |
some(expr) | Igaz értéket ad vissza, ha egy csoportban legalább egy érték expr szerepel true . |
std(expr) | A csoport értékeitől számított szórásmintát adja eredményül. |
stddev(expr) | A csoport értékeitől számított szórásmintát adja eredményül. |
stddev_pop(kifejezés) | Egy csoport értékeitől számított statisztikai szórást számítja ki. |
stddev_samp(kifejezés) | Egy csoport értékeitől számított szórásmintát adja eredményül. |
sum(expr) | Egy csoport értékeiből kiszámított összeget számítja ki. |
try_avg(kifejezés) | Egy csoport értékeiből kiszámított középértéket számítja ki, null értéket, ha túlcsordulás van. |
try_sum(kifejezés) | Egy csoport értékeiből kiszámított összeget számítja ki null értékre, ha túlcsordulás van. |
var_pop(kifejezés) | Egy csoport értékeiből kiszámított sokaság-varianciát számítja ki. |
var_samp(kifejezés) | Egy csoport értékeiből kiszámított mintaeltérést adja eredményül. |
variancia(expr) | Egy csoport értékeiből kiszámított mintaeltérést adja eredményül. |
Rangsorolási ablakfüggvények
Függvény | Leírás |
---|---|
dense_rank() | Egy érték rangját adja vissza a partíció összes értékéhez képest. |
ntile(n) | Az egyes ablakpartíciók sorait 1 és legfeljebb n 1 közötti n gyűjtőkre osztja. |
percent_rank() | Kiszámítja egy érték százalékos rangsorolását a partíción belül. |
rang() | Egy érték rangját adja vissza a partíció összes értékéhez képest. |
row_number() | Minden egyes sorhoz egyedi, szekvenciális számot rendel hozzá, egytől kezdve az ablakpartíció sorainak sorrendjétől függően. |
Elemzési ablakfüggvények
Függvény | Leírás |
---|---|
cume_dist() | Egy érték pozícióját adja vissza a partíció összes értékéhez viszonyítva. |
lag(expr[;offset[;default]]) | A partíció előző sorának expr értékét adja vissza. |
lead(expr[,offset[;default]]) | A partíció egy későbbi sorának expr értékét adja vissza. |
nth_value(expr, offset[, ignoreNulls]) | Egy adott offset érték értékét expr adja vissza az ablakban. |
Tömb függvények
Függvény | Leírás |
---|---|
arrayExpr[indexExpr] | A TÖMB arrayExpr pozícióban indexExpr lévő elemet adja vissza. |
összesítés(expr;start;egyesítés[;befejezés]) | Egy tömb elemeit összesíti egy egyéni összesítő használatával. |
array([expr [, ...]]) | Egy tömböt ad vissza, amelyben az elemek a következőben találhatóak expr : . |
array_append(tömb, elem) | A hozzáfűzött elem visszaadásokarray . |
array_compact(tömb) | Eltávolítja a NULL értékeket a fájlból array . |
array_contains(tömb;érték) | Igaz értéket ad vissza, ha array tartalmazza value . |
array_distinct(tömb) | Eltávolítja a duplikált értékeket a programból array . |
array_except(tömb1;tömb2) | Az elemek array1 tömböt ad vissza, de nem a következőben array2 : . |
array_insert(tömb, index, elem) | Egy kibontott array helyet ad vissza, amely elem a index pozícióba van beszúrva. |
array_intersect(tömb1;tömb2) | A metszéspontban lévő elemek tömbjének visszaadása array1 array2 . |
array_join(tömb;elválasztó[;nullReplacement]) | Összefűzi a array . |
array_max(tömb) | A maximális értéket adja vissza a következőben array : . |
array_min(tömb) | A minimális értéket adja vissza a következőben array : . |
array_position(tömb;elem) | A következő első előfordulásának element array pozícióját adja vissza: . |
array_prepend(tömb, elem) | Előre felerősített array elem értéket ad vissza. |
array_remove(tömb;elem) | Eltávolítja az összes előfordulást a element fájlból array . |
array_repeat(elem;darabszám) | Időt tartalmazó element count tömböt ad vissza. |
array_size(tömb) | A függvény elemeinek array számát adja vissza. |
array_sort(tömb;func) | array A szerint rendezve adja vissza a függvénytfunc . |
array_union(tömb1;tömb2) | Az elemek egy tömbét adja vissza az elemek egyesítő array1 elemeiből, és array2 nem ismétlődik. |
arrays_overlap(tömb1; tömb2) | Igaz értéket ad vissza, ha a metszete array1 array2 nem üres. |
arrays_zip(tömb1 [, ...]) | Egy egyesített szerkezettömböt ad vissza, amelyben az nth struct a bemeneti tömbök összes N-edik értékét tartalmazza. |
számosság(kifejezés) | A méretét expr adja vissza. |
concat(expr1; expr2 [, ...]) | Az argumentumok összefűzésének értékét adja vissza. |
element_at(arrayExpr, index) | Egy at index elemét arrayExpr adja vissza. |
exists(expr, pred) | Igaz értéket ad vissza, ha pred a függvény bármely elemére expr igaz. |
robbantás(gyűjtemény) | Sorokat ad vissza a beágyazás megszüntetésével collection . |
explode_outer(gyűjtemény) | Sorokat ad vissza a külső szemantikával való beágyazás collection megszüntetésével. |
filter(expr;func) | Szűri a tömböt expr a függvény func használatával. |
lapított(arrayOfArrays) | Tömbök tömböt alakít át egyetlen tömbbe. |
forall(expr, predFunc) | Ellenőrzi, hogy a tömb összes eleméhez rendelkezik-e predFunc . |
get(arrayExpr, index) | Egy at elemét arrayExpr index adja vissza a következőtől 0 kezdve: . |
inline(expr) | Strukturált tömböt robbant fel egy táblába. |
inline_outer(kifejezés) | Külső szemantikával rendelkező táblázatba bontja a szerkezetek tömbét. |
posexplode(expr) | Sorokat ad vissza a tömb sorszámozásával történő beágyazás megszüntetésével. |
posexplode_outer(kifejezés) | Sorokat ad vissza úgy, hogy nem ágyaz be a tömbbe a pozíciók OUTER számozásával szemantikával. |
reduce(expr;start;merge[;finish]) | Egy tömb elemeit összesíti egy egyéni összesítő használatával. |
fordított(tömb) | Fordított sztringet vagy elemek fordított sorrendjét tartalmazó tömböt ad vissza. |
sequence(start;stop;step) | Elemtömböt hoz létre a következőtől a (befogadó) értékig start stop , amely a következő szerint step növekszik: . |
shuffle(tömb) | A tömb véletlenszerű permutációját adja vissza a következőben expr : . |
size(expr) | A számosságát expr adja vissza. |
szelet(kif;kezdő;hossz) | Egy tömb egy részhalmazát adja vissza. |
sort_array(expr[;ascendingOrder]) | Rendezési sorrendben adja vissza a expr tömböt. |
transform(expr, func) | Átalakítja a tömb expr elemeit a függvény func használatával. |
try_element_at(arrayExpr, index) | Egy at elemét arrayExpr adja vissza, vagy NULL ha index nincs megkötve.index |
zip_with(expr1, expr2, func) | Egyesíti a tömböket expr1 , és expr2 elemszintű módon egyetlen tömbbe egyesíti a következővel func : . |
Leképezési függvények
Függvény | Leírás |
---|---|
mapExpr[keyExpr] | A MAP mapExpr értékének értékét keyExpr adja vissza. |
számosság(kifejezés) | A méretét expr adja vissza. |
element_at(mapExpr, kulcs) | A következő értékét adja eredményül mapExpr key : . |
robbantás(kif) | Sorokat ad vissza a beágyazás megszüntetésével expr . |
explode_outer(kifejezés) | Sorokat ad vissza a külső szemantikával való beágyazás expr megszüntetésével. |
map([{key1, value1}[, ...]]) | Létrehoz egy térképet a megadott kulcs-érték párokkal. |
map_concat([expr1 [, ...]]) | Az összes expr térképkifejezés egyesítését adja vissza. |
map_contains_key(térkép, kulcs) | Visszaadja true , ha map tartalmazza key , false ellenkező esetben. |
map_entries(térkép) | Egy rendezetlen tömböt ad vissza a (z) összes bejegyzéséből map . |
map_filter(kif, func) | A függvény használatával func szűri a térkép expr bejegyzéseit. |
map_from_arrays(kulcsok, értékek) | Létrehoz egy térképet a tömbök és values a keys tömbök párjával. |
map_from_entries(kifejezés) | Létrehoz egy térképet, amely a megadott bejegyzéstömbből jön létre. |
map_keys(térkép) | Egy rendezetlen tömböt ad vissza, amely tartalmazza a kulcsokat map . |
map_values(térkép) | Egy rendezetlen tömböt ad vissza, amely a következő értékeit map tartalmazza: . |
map_zip_with(map1, map2, func) | Egyesít map1 és map2 egyetlen térképet alkot. |
size(expr) | A számosságát expr adja vissza. |
str_to_map(expr[;pairDelim[;keyValueDelim]]) | Egy térképet ad vissza, miután elválasztójelekkel felosztott expr kulcs-érték párokra. |
transform_keys(expr, func) | Átalakítja a térkép expr kulcsait a függvény func használatával. |
transform_values(expr, func) | A függvény használatával átalakítja a térkép expr értékeit func . |
try_element_at(mapExpr, kulcs) | A ( vagy NULL ha key nem létezik) értékének mapExpr key értékét adja vissza. |
Dátum-, időbélyeg- és intervallumfüggvények
A dátum- és időbélyeg-formátumokról további információt a Datetime-mintákban talál.
Függvény | Leírás |
---|---|
intervalExpr /osztó | Az intervallumot osztva divisor adja vissza. |
- intervalExpr | A negated értékének intervalExpr értékét adja vissza. |
intervalExpr1 – intervalExpr2 | A kivonást intervalExpr2 adja vissza a forrásból intervalExpr1 . |
datetimeExpr1 – datetimeExpr2 | A kivonást datetimeExpr2 adja vissza a forrásból datetimeExpr1 . |
+ intervalExpr | Az érték értékét intervalExpr adja vissza. |
intervalExpr1 + intervalExpr2 | Az és a . összegének intervalExpr1 intervalExpr2 értékét adja vissza. |
intervalExpr * szorzás | A visszaadott érték intervalExpr szorozva multiplicand . |
abs(expr) | Az intervallumérték abszolút értékét adja vissza a következőben expr : . |
add_months(startDate;numMonths) | A következő startDate dátumot numMonths adja eredményül. |
curdate() | A lekérdezés kiértékelésének kezdetének aktuális dátumát adja vissza. |
current_date() | A lekérdezés kiértékelésének kezdetének aktuális dátumát adja vissza. |
current_timestamp() | Az aktuális időbélyeget adja vissza a lekérdezés kiértékelésének kezdetekor. |
current_timezone() | Az aktuális munkamenet helyi időzónájának értékét adja vissza. |
date(expr) | Az értéket expr a DATE értékre öntötte. |
date_add(startDate;numDays) | A következő startDate dátumot numDays adja eredményül. |
date_add(egység, érték, kif) | S-t ad value unit hozzá egy időbélyeghez expr . |
date_diff(egység, indítás, leállítás) | Az s-ben unit mért két időbélyeg közötti különbséget adja vissza. |
date_format(kif;fmt) | Az időbélyeget sztringgé alakítja.fmt |
date_from_unix_date(nap) | Dátumot hoz létre az azóta 1970-01-01 eltelt napok számából. |
date_part(mező;kifejezés) | Kinyeri a dátum, az időbélyeg vagy az intervallum egy részét. |
date_sub(startDate;numDays) | A korábbi startDate dátumot numDays adja vissza. |
date_trunc(egység;kif) | A megadott egységhez csonkolt időbélyeget ad unit vissza. |
dateadd(startDate;numDays) | A következő startDate dátumot numDays adja eredményül. |
dateadd(egység, érték, kif) | S-t ad value unit hozzá egy időbélyeghez expr . |
datediff(endDate;startDate) | A napok startDate számát adja eredményül endDate . |
datediff(egység, indítás, leállítás) | Az s-ben unit mért két időbélyeg közötti különbséget adja vissza. |
day(expr) | A dátum vagy időbélyeg hónapjának napját adja vissza. |
dayofmonth(expr) | A dátum vagy időbélyeg hónapjának napját adja vissza. |
dayofweek(expr) | A dátum vagy időbélyeg hét napját adja vissza. |
dayofyear(expr) | A dátum vagy időbélyeg évének napját adja vissza. |
osztó div osztalék | Az intervallumok intervallum divisor dividend szerinti osztásának szerves részét adja vissza. |
extract(field FROM source) | Visszatérési érték field : source . |
from_unixtime(unixTime;fmt) | Visszaadja unixTime a következőt fmt : . |
from_utc_timestamp(expr;timezone) | Időbélyeget ad vissza az expr időzón utc-ben megadott időbélyegben timeZone . |
getdate() | Az aktuális időbélyeget adja vissza a lekérdezés kiértékelésének kezdetekor. |
hour(expr) | Egy időbélyeg óra összetevőjét adja vissza. |
last_day(kifejezés) | Annak a hónapnak az utolsó napját adja vissza, amelyhez a dátum tartozik. |
make_date(év,hónap,nap) | Dátumot hoz létre a , month és day a mezőkbőlyear . |
make_dt_interval([nap[, óra[, perc[, másodperc]]]]) | Napközbeni intervallumot hoz létre a ( és secs hours ) mins értékrőldays . |
make_interval(évek, hónapok, hetek, napok, órák, percek, másodpercek) | Elavult: Időközt hoz létre a következőből: years , months , weeks , days , mins hours és secs . |
make_timestamp(év,hónap,nap,óra,perc;mp[;időzónás]) | Időbélyeget hoz létre a , month , , hour day , min , sec és timezone mezőkbőlyear . |
make_ym_interval([év[, hónap]]) | Létrehoz egy év-hónap intervallumot az és months a years . |
minute(expr) | Az időbélyeg percösszetevőjét adja vissza a következőben expr : . |
month(expr) | Az időbélyeg hónap összetevőjét adja vissza a következőben expr : . |
months_between(expr1;expr2[;roundOff]) | A dátumok és időbélyegek között eltelt hónapok számát adja eredményül expr1 expr2 . |
next_day(expr;dayOfWeek) | Az első dátumot adja vissza, amely később expr lesz, és a neve megegyezik a következővel dayOfWeek : . |
now() | Az aktuális időbélyeget adja vissza a lekérdezés kiértékelésének kezdetekor. |
quarter(expr) | Az év expr negyedévét adja vissza az 1 és 4 közötti tartományban. |
second(expr) | Az időbélyeg második összetevőjét adja vissza a következőben expr : . |
session_window(expr, gpDuration) | Munkamenetablakot hoz létre egy időbélyeg-kifejezésen keresztül. |
sign(expr) | -1,0, 0,0 vagy 1,0 értéket ad vissza, mivel az intervallum expr negatív, 0 vagy pozitív. |
signum(expr) | -1,0, 0,0 vagy 1,0 értéket ad vissza, mivel az intervallum expr negatív, 0 vagy pozitív. |
timediff(egység, indítás, leállítás) | Az s-ben unit mért két időbélyeg közötti különbséget adja vissza. |
timestamp(expr) | Leadások expr a TIMESTAMP-be. |
timestamp_micros(kifejezés) | Időbélyeg mikroszekundumokat expr hoz létre az UTC-korszak óta. |
timestamp_millis(kifejezés) | Időbélyeg expr ezredmásodpercet hoz létre az UTC-korszak óta. |
timestamp_seconds(kifejezés) | Időbélyeg expr másodpercet hoz létre az UTC-időszámítás óta. |
timestampadd(egység, érték, kif) | S-t ad value unit hozzá egy időbélyeghez expr . |
timestampdiff(egység, indítás, leállítás) | Az s-ben unit mért két időbélyeg közötti különbséget adja vissza. |
to_date(expr[;fmt]) | expr A dátumra leadott értéket adja vissza opcionális formázással. |
to_timestamp(expr[;fmt]) | expr Egy időbélyegre leadott értéket ad vissza opcionális formázással. |
to_unix_timestamp(expr[;fmt]) | Az időbélyeget expr UNIX időbélyegként adja vissza. |
to_utc_timestamp(expr;timezone) | Az időbélyeget egy másik időzónában expr adja vissza UTC-ként. |
trunc(expr, fmt) | Egy dátumot ad vissza, amely a dátum egy részét csonkolja a formátummodell fmt által megadott egységre. |
try_add(expr1; expr2) | Hiba esetén a null expr2 értéket expr1 adja eredményül. |
try_divide(osztalék, osztó) | A visszaadott értékek dividend osztva divisor az , vagy NULL értékkel, ha divisor 0. |
try_multiply(szorzó, szorzó) | A visszaadott érték multiplier szorozva multiplicand , vagy NULL túlcsordulás esetén. |
try_subtract(expr1; expr2) | A kivonást adja vissza a expr2 forrásból expr1 vagy NULL a túlcsordulásból. |
try_to_timestamp(expr[;fmt]) | expr A leadott értéket egy tetszőleges formázással adja vissza egy időbélyegre, vagy NULL ha a leadás sikertelen. |
unix_date(kifejezés) | Az azóta 1970-01-01 eltelt napok számát adja eredményül. |
unix_micros(kifejezés) | Az azóta 1970-01-01 00:00:00 UTC eltelt mikroszekundumok számát adja vissza. |
unix_millis(kifejezés) | Az azóta eltelt ezredmásodpercek 1970-01-01 00:00:00 UTC számát adja vissza. |
unix_seconds(kifejezés) | Az azóta 1970-01-01 00:00:00 UTC eltelt másodpercek számát adja vissza. |
unix_timestamp([expr[, fmt]]) | Az aktuális vagy megadott idő UNIX időbélyegét adja meg. |
weekday(expr) | A hét expr napját adja vissza. |
weekofyear(expr) | Az év hetét adja eredményül expr . |
year(expr) | A év összetevőjét adja eredményül expr . |
window(expr, width[, step[, start]]) | Egy időbélyeg-kifejezés fölé húzható csúsztatási ablakot hoz létre. |
window_time(ablak) | Az ablak vagy session_window függvény által létrehozott tolóablak befogadó befejezési idejét adja vissza. |
H3 térinformatikai függvények
A H3 térinformatikai függvényekről további információt a H3 térinformatikai függvényekben talál.
Öntött függvények és konstruktorok
A típusok közötti öntésről további információt a öntött függvény és try_cast függvény című témakörben talál.
Függvény | Leírás |
---|---|
array([expr [, ...]]) | Egy tömböt ad vissza, amelyben az elemek a következőben találhatóak expr : . |
bigint(expr) | Az értéket expr a következőre öntötte: BIGINT . |
binary(expr) | A következő értékre veti expr az BINARY értéket: . |
boolean(expr) | Casts expr to BOOLEAN . |
cast(expr AS type) | Az értéket expr a cél adattípusra type veti. |
expr :: type | Az értéket expr a cél adattípusra type veti. |
date(expr) | Az értéket expr a következőre öntötte: DATE . |
decimális(kitevő) | Az értéket expr a következőre öntötte: DECIMAL . |
double(expr) | Az értéket expr a következőre öntötte: DOUBLE . |
float(expr) | Az értéket expr a következőre öntötte: FLOAT . |
int(expr) | Az értéket expr a következőre öntötte: INTEGER . |
make_date(év,hónap,nap) | Dátumot hoz létre a , month és day a mezőkbőlyear . |
make_dt_interval([nap[, óra[, perc[, másodperc]]]]) | Napközbeni intervallumot hoz létre a ( és secs hours ) mins értékrőldays . |
make_interval(évek, hónapok, hetek, napok, órák, percek, másodpercek) | Intervallumot hoz létre a , months , weeks , hours days mins és .years secs |
make_timestamp(év,hónap,nap,óra,perc;mp[;időzónás]) | Időbélyeget hoz létre a , month , , hour day , min , sec és timezone mezőkbőlyear . |
make_ym_interval([év[, hónap]]) | Létrehoz egy év-hónap intervallumot az és months a years . |
map([{key1, value1} [, ...]]) | Létrehoz egy térképet a megadott kulcs-érték párokkal. |
named_struct({name1; val1} [, ...]) | Létrehoz egy szerkezetet a megadott mezőnevekkel és értékekkel. |
smallint(expr) | Az értéket expr a következőre öntötte: SMALLINT . |
string(expr) | Az értéket expr a következőre öntötte: STRING . |
struct(expr1 [, ...]) | Létrehoz egy STRUCT értéket a megadott mezőértékekkel. |
tinyint(expr) | Casts expr to TINYINT . |
timestamp(expr) | Casts expr to TIMESTAMP . |
to_char(expr, fmt) | Visszaadja a expr formázást STRING használó fmt öntött értéket." |
to_date(expr[;fmt]) | expr A dátumra leadott értéket adja vissza opcionális formázással. |
to_number(expr, fmt) | Formázással fmt visszaadja expr az L-be DECIMA leadott elemet. |
to_timestamp(expr[;fmt]) | expr Egy időbélyegre leadott értéket ad vissza opcionális formázással. |
to_varchar(expr, fmt) | Visszaadja a expr formázást STRING használó fmt öntött értéket." |
try_cast(expr AS típus) | Az értéket expr biztonságosan a céladattípusra type veti. |
try_to_number(expr, fmt) | Visszaadja expr a DECIMAL formázási fmt elemet, vagy NULL ha expr nem érvényes. |
CSV-függvények
Függvény | Leírás |
---|---|
from_csv(csvStr, séma[, beállítások]) | Egy szerkezetértéket ad vissza a csvStr következővel: és schema . |
schema_of_csv(csv[, beállítások]) | Egy CSV-sztring sémáját adja vissza DDL formátumban. |
to_csv(kif[, beállítások]) | Egy CSV-sztringet ad vissza a megadott strukturált értékkel. |
JSON-függvények
Függvény | Leírás |
---|---|
jsonStr : jsonPath | A mezőből jsonStr kinyert mezőket adja vissza. |
from_json(jsonStr, séma[, beállítások]) | Egy szerkezetértéket ad vissza a jsonStr következővel: és schema . |
get_json_object(kifejezés, elérési út) | Kinyer egy objektumot JSON a fájlból path . |
json_array_length(jsonArray) | A legkülső JSON tömb elemeinek számát adja vissza. |
json_object_keys(jsonObject) | A legkülső JSON objektum összes kulcsát tömbként adja vissza. |
json_tuple(jsonStr, path1 [, ...]) | Több JSON objektumot ad vissza rekordként. |
schema_of_json(jsonStr[, beállítások]) | Egy sztring JSON sémáját adja vissza DDL formátumban. |
schema_of_json_agg(jsonStr[, beállítások]) | A sztringek egyesített sémáját JSON adja vissza egy csoportban DDL formátumban. |
to_json(kif[, beállítások]) | Egy sztringet JSON ad vissza a következőben expr megadott szerkezettel: . |
XPath- és XML-függvények
Függvény | Leírás |
---|---|
from_xml(xmlStr, séma[, beállítások]) | A használatból xmlStr elemezett szerkezetértéket ad schema vissza. |
schema_of_xml(xmlStr[, beállítások]) | Egy sztring XML sémáját adja vissza DDL formátumban. |
xpath(xml, xpath) | Az adott egyezés xpath csomópontjaiban xml lévő értékeket adja vissza. |
xpath_boolean(xml, xpath) | Visszaadja true , ha a kifejezés kiértékeli xpath a következőt true , vagy ha talál egy megfelelő csomópontot xml . |
xpath_double(xml, xpath) | EGY XML-dokumentum DUPLA értékét adja vissza. |
xpath_float(xml, xpath) | EGY FLOAT értéket ad vissza egy XML-dokumentumból. |
xpath_int(xml, xpath) | EGY XML-dokumentum egész számának értékét adja vissza. |
xpath_long(xml, xpath) | BIGINT-értéket ad vissza egy XML-dokumentumból. |
xpath_number(xml, xpath) | EGY XML-dokumentum DUPLA értékét adja vissza. |
xpath_short(xml, xpath) | EGY XML-dokumentum rövid értékét adja vissza. |
xpath_string(xml, xpath) | Az XPath-kifejezésnek megfelelő első XML-csomópont tartalmát adja vissza. |
AI-függvények
Függvény | Leírás |
---|---|
ai_analyze_sentiment(tartalom) | Egy szöveg hangulatát adja vissza. |
ai_classify(tartalom, címkék) | A megadott tartalmat a megadott címkék egyikébe sorolja be. |
ai_extract(tartalom, címkék) | Kinyeri a címkék által megadott entitásokat egy adott szövegből. |
ai_fix_grammar(tartalom) | Kijavítja egy adott szöveg nyelvtani hibáit. |
ai_gen(tartalom) | A Databricks Foundation model API-jaiból meghív egy korszerű generatív AI-modellt a felhasználó által megadott kérés megválaszolásához. |
ai_generate_text(prompt, modelName[, param1, value1] [...]) | Elavult: Egy kiválasztott nagy nyelvi modell (LLM) által létrehozott szöveget ad vissza a kérésnek. |
ai_mask(tartalom, címkék) | Maszkolja a megadott entitásokat egy adott szövegen belül. |
ai_query(endpointName, request, returnType) | Meghív egy meglévő Mozaik AI-modellt, amely a végpontot szolgálja ki, elemzi és visszaadja a választ. |
ai_similarity(strExpr1, strExpr2) | Két sztringet hasonlít össze, és kiszámítja a szemantikai hasonlósági pontszámot. |
ai_summarize(content[, max_words]) | Egy adott szöveg összegzését hozza létre. |
ai_translate(tartalom, to_lang) | Szöveg fordítása megadott célnyelvre. |
Olvasási függvények
Függvény | Leírás |
---|---|
read_files(elérési út; [optionKey => optionValue] [, ...]) | Beolvassa az adatfájlokat a felhőbeli tárolóban, és táblázatos formátumban adja vissza. |
read_kafka([optionKey => optionValue] [, ...]) | Beolvassa a rekordokat egy Apache Kafka-fürtből, és táblázatos formátumban adja vissza. |
read_kinesis({parameter => value} [, ...]) | Egy táblát ad vissza, amely egy vagy több streamből olvas be rekordokat a Kinesisből. |
read_pubsub([paraméter => érték] [, ...]) | Táblaértékelt függvény, amely egy témakörből származó rekordokat olvas be a Pub/Sub függvényből. |
read_pulsar({optionKey => optionValue} [, ...]) | A Pulsarból beolvasott rekordokat tartalmazó táblát ad vissza. |
read_state_metadata(elérési út) | Olyan táblázatot ad vissza, amely egy streamelési lekérdezési állapot metaadatait ábrázoló sorokat tartalmaz. |
read_statestore(elérési út [, option_key => option_value] [...]) | Rekordokat ad vissza a streamelési lekérdezések állapottárolójából. |
Egyéb függvények
Függvény | Leírás |
---|---|
assert_true(kifejezés) | Hibát ad vissza, ha expr nem igaz. |
CASE expr { WHEN opt1 THEN res1 } [...] [ELSE def] VÉG | resN Az első optN egyenlőségjelet adja vissza, expr vagy def ha egyik sem egyezik. |
CASE { WHEN cond1 THEN res1 } [...] [ELSE def] VÉG | resN Az elsőnek condN az igaz értéket adja vissza, vagy def ha egyik sem található. |
cloud_files_state( { TABLE(table) | checkpoint } ) | |
coalesce(expr1; expr2 [, ...]) | Az első nem null argumentumot adja eredményül. |
kocka (expr1 [, ...]) | Többdimenziós kockát hoz létre a megadott kifejezésoszlopokkal. |
current_catalog() | Az aktuális katalógust adja vissza. |
current_database() | Az aktuális sémát adja vissza. |
current_metastore() | Az aktuális Unity Catalog metaadattár-azonosítót adja vissza. |
current_recipient(kulcs) | Az aktuális címzett tulajdonságát adja vissza a Delta-megosztással megosztott nézetben. |
current_schema() | Az aktuális sémát adja vissza. |
current_user() | Az utasítást végrehajtó felhasználót adja vissza. |
current_version() | Az Azure Databricks aktuális verzióját adja vissza. |
decode(expr, { key, value } [, ...] [,defValue]) | A kulcsnak megfelelő értéket adja vissza. |
elt(index, expr1 [, ...] ) | Az n. kifejezést adja vissza. |
equal_null(expr1; expr2) | Akkor adja true vissza, ha expr1 egyenlő expr2 vagy mindkét kifejezés NULL vagy false más. |
event_log( { TABLE(table) | pipeline_id } ) | |
greatest(expr1, expr2 [, ...]) | Az összes argumentum legnagyobb értékét adja vissza, kihagyva a null értékeket. |
csoportosítás(col) | Azt jelzi, hogy egy adott oszlop egy GROUPING SET , ROLLUP vagy CUBE részösszeget jelöl-e. |
grouping_id([col1 [, ...]]) | Egy oszlopkészlet csoportosítási szintjét adja vissza. |
hash(expr1 [, ...]) | Az argumentumok kivonatolt értékét adja vissza. |
hll_sketch_estimate(kifejezés) | A HyperLogLog-vázlatban összegyűjtött különböző értékek számának etimálása. |
hll_union(expr1; expr2 [,allowDifferentLgConfigK]) | Két HyperLog-vázlatot egyesít. |
java_method(osztály, metódus[, arg1 [, ...]]) | Visszatükrözéssel meghív egy metódust. |
if(cond, expr1, expr2) | expr1 cond Ha igentrue , vagy expr2 más módon adja vissza. |
iff(cond, expr1, expr2) | expr1 cond Ha igentrue , vagy expr2 más módon adja vissza. |
ifnull(expr1; expr2) | expr2 expr1 Ha igenNULL , vagy expr1 más módon adja vissza. |
input_file_block_length() | Az olvasandó blokk bájtban megadott hosszát adja vissza. |
input_file_block_start() | Az olvasandó blokk bájtban megadott kezdő eltolását adja vissza. |
input_file_name() | Az olvasandó fájl nevét adja vissza, vagy üres sztringet, ha nem érhető el. |
is_account_group_member(csoport) | Igaz értéket ad vissza, ha az aktuális felhasználó a fiók szintjén tagja a csoportnak. |
is_member(csoport) | Igaz értéket ad vissza, ha az aktuális felhasználó tagja a csoportnak a munkaterület szintjén. |
isnull(expr) | Ha igen, true expr akkor adja vissza.NULL |
isnotnull(expr) | Visszaadja true , ha expr nem NULL . |
least(expr1, expr2 [, ...]) | Az összes argumentum legkisebb értékét adja vissza, kihagyva a null értékeket. |
list_secrets() | Visszaadja azokat a kulcsokat, amelyeket a felhasználó jogosult megtekinteni a Databricks titkosszolgálattól. |
luhn_check(numStr) | Visszaadja true , ha numStr megfelel a Luhn-algoritmus ellenőrzésének. |
monotonically_increasing_id() | Monoton módon növekvő 64 bites egész számokat ad vissza. |
nullif(expr1; expr2) | Visszaadja NULL , ha expr1 egyenlő expr2 , vagy expr1 más módon. |
nvl(expr1; expr2) | expr2 expr1 Ha igenNULL , vagy expr1 más módon adja vissza. |
nvl2(expr1, expr2, expr3) | Visszaadja expr2 , ha expr1 nem NULL , vagy expr3 másként. |
raise_error(kifejezés) | Kivételt expr jelez üzenetként. |
tartomány(vége) | Egy megadott tartományon belüli értéktáblát ad vissza. |
range(start, end [, step [, numParts]]) | Egy megadott tartományon belüli értéktáblát ad vissza. |
reflect(class, method[, arg1 [, ...]]) | Visszatükrözéssel meghív egy metódust. |
titkos kód(hatókör, kulcs) | Kinyer egy titkos értéket a megadott scope és a Databricks titkos szolgáltatásból.key |
session_user() | Az Azure Databrickshez csatlakoztatott felhasználót adja vissza. |
spark_partition_id() | Az aktuális partícióazonosítót adja vissza. |
sql_keywords() | Az Sql-kulcsszavak készletét adja vissza az Azure Databricksben. |
stack(numRows, expr1 [, ...]) | Sorokra numRows bontja expr1 a ...- exprN t. |
table_changes(table_str, start [, end]) | Egy Delta Lake-tábla módosításainak naplóját adja vissza, amelyen engedélyezve van az adatcsatorna módosítása. |
try_reflect(osztály, metódus[, arg1 [, ...]]) | Visszatükrözéssel meghív egy metódust, amely NULL akkor ad vissza, ha a metódus sikertelen. |
typeof(expr) | Visszaad egy DDL formátumú típussztringet a következő adattípushoz expr : . |
user() | Az utasítást végrehajtó felhasználót adja vissza. |
uuid() | Univerzálisan egyedi azonosító (UUID) sztringet ad vissza. |
window(expr, width[, step [, start]]) | Egy időbélyeg-kifejezés fölé húzható csúsztatási ablakot hoz létre. |
xxhash64(expr1 [, ...]) | Az argumentumok 64 bites kivonatolt értékét adja vissza. |
verzió() | Az Apache Spark-verziót adja vissza. |
Visszajelzés
https://aka.ms/ContentUserFeedback.
Hamarosan elérhető: 2024-ben fokozatosan kivezetjük a GitHub-problémákat a tartalom visszajelzési mechanizmusaként, és lecseréljük egy új visszajelzési rendszerre. További információ:Visszajelzés küldése és megtekintése a következőhöz: