Funzioni predefinite
Si applica a: Databricks SQL Databricks Runtime
Questo articolo presenta collegamenti a e descrizioni di operatori e funzioni predefiniti per stringhe e tipi binari, scalari numerici, aggregazioni, finestre, matrici, mappe, date e timestamp, cast, dati CSV, dati JSON, manipolazione XPath e altre funzioni varie.
Per i casi d'uso non supportati dalle funzioni predefinite esistenti, è consigliabile definire una funzione personalizzata. Vedere Che cosa sono le funzioni definite dall'utente?.
Vedere anche:
Operatori e predicati
Per informazioni sul modo in cui gli operatori vengono analizzati l'uno rispetto all'altro, vedere Precedenza dell'operatore.
Operatore | Sintassi | ||
---|---|---|---|
& | expr1 & expr2 |
||
e | expr1 and expr2 |
||
* | multiplier * multiplicand |
||
!= | expr1 != expr2 |
||
! | !expr |
||
tra | expr1 [not] between expr2 and expr2 |
||
[ ] | arrayExpr [ indexExpr ] |
||
[ ] | mapExpr [ keyExpr ] |
||
^ | expr1 ^ expr2 |
||
: | jsonStr : jsonPath |
||
:: | expr :: type |
||
?:: | expr ?:: type |
||
div | dividend div divisor |
||
. | mapExpr . keyIdentifier |
||
. | structExpr . fieldIdentifier |
||
== | expr1 == expr2 |
||
= | expr1 = expr2 |
||
>= | expr1 >= expr2 |
||
> | expr1 > expr2 |
||
exists | exists(query) |
||
mi piace | str [not] ilike (pattern[ESCAPE escape]) |
||
mi piace | str [not] ilike {ANY|SOME|ALL}([pattern[, ...]]) |
||
in | elem [not] in (expr1[, ...]) |
||
in | elem [not] in (query) |
||
è distinto | expr1 is [not] distinct from expr2 |
||
è false | expr is [not] false |
||
è null | expr is [not] null |
||
è true | expr is [not] true |
||
come | str [not] like (pattern[ESCAPE escape]) |
||
come | str [not] like {ANY|SOME|ALL}([pattern[, ...]]) |
||
<=> | expr1 <=> expr2 |
||
<= | expr1 <= expr2 |
||
<> | expr1 <> expr2 |
||
< | expr1 < expr2 |
||
- | expr1 - expr2 |
||
not | not expr |
||
or | expr1 or expr2 |
||
% | dividend % divisor |
||
|| | expr1 || expr2 |
Restituisce la concatenazione di expr1 e expr2 . |
|
| | expr1 | expr2 |
Restituisce l'oggetto bit per OR bit di expr1 e expr2 . |
|
+ | expr1 + expr2 |
||
regexp | str [not] regexp regex |
||
regexp_like | str [not] regexp_like regex |
||
rlike | str [not] rlike regex |
||
/ | dividend / divisor |
||
~ | ~ expr |
Precedenza tra gli operatori
Precedenza | Operatore |
---|---|
1 | : , :: , ?:: [ ] |
2 | - (unario), + (unario), ~ |
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 |
Funzioni stringa e binaria
Funzione | Descrizione |
---|---|
expr1 || expr2 | Restituisce la concatenazione di expr1 e expr2 . |
aes_decrypt(expr, key[, mode[, padding[, aad]]]) | Decrittografa un file binario expr usando la crittografia AES. |
aes_encrypt(expr, key[, mode[, padding[, iv[, aad]]]) | Crittografa un file binario expr usando la crittografia AES. |
ascii(str) | Restituisce il punto di codice ASCII del primo carattere di str . |
base64(expr) | Converte expr in una stringa di base 64. |
bin(expr) | Restituisce la rappresentazione binaria di expr . |
binary(expr) | Esegue il cast del valore di expr in BINARY . |
bit_length(expr) | Restituisce la lunghezza di bit dei dati stringa o il numero di bit di dati binari. |
bitmap_count(expr) | Restituisce il numero di bit impostati in una BINARY stringa che rappresenta una bitmap. |
btrim(str [, trimStr]) | Restituisce str con caratteri iniziali e finali rimossi. |
char(expr) | Restituisce il carattere in corrispondenza del punto di codice UTF-16 fornito. |
char_length(expr) | Restituisce la lunghezza del carattere dei dati stringa o il numero di byte di dati binari. |
character_length(expr) | Restituisce la lunghezza del carattere dei dati stringa o il numero di byte di dati binari. |
charindex(substr, str[, pos]) | Restituisce la posizione della prima occorrenza di substr in str dopo la posizione pos . |
chr(expr) | Restituisce il carattere in corrispondenza del punto di codice UTF-16 fornito. |
concat(expr1, expr2[, ...]) | Restituisce la concatenazione degli argomenti. |
concat_ws(sep[, expr1[, ...]]) | Restituisce le stringhe di concatenazione separate da sep . |
contains(expr, subExpr) | Restituisce true se expr STRING o BINARY contiene subExpr . |
crc32(expr) | Restituisce un valore di controllo della ridondanza ciclico pari a expr . |
decode(expr, charSet) | Converte il file binario expr in una stringa usando la codifica charSet del set di caratteri . |
encode(expr, charSet) | Restituisce la rappresentazione binaria di una stringa utilizzando la codifica dei charSet caratteri. |
endswith(expr, endExpr) | Restituisce true se expr STRING o BINARY termina con endExpr . |
find_in_set(searchExpr, sourceExpr) | Restituisce la posizione di una stringa all'interno di un elenco delimitato da virgole di stringhe. |
format_number(expr, scale) | Formati expr come #,###,###.## , arrotondati a scale posizioni decimali. |
format_number(expr, fmt) | Formati expr come fmt . |
format_string(strfmt[, obj1 [, ...]]) | Restituisce una stringa formattata dalle stringhe di formato di tipo printf. |
hex(expr) | Converte in expr esadecimale. |
str ilike (pattern[ESCAPE escape]) | Restituisce true se str corrisponde pattern senza escape distinzione tra maiuscole e minuscole. |
initcap(expr) | Restituisce expr con la prima lettera di ogni parola in maiuscolo. |
instr(str, substr) | Restituisce l'indice (in base 1) della prima occorrenza di substr in str . |
lcase(expr) | Restituisce expr con tutti i caratteri modificati in minuscolo. |
left(str, len) | Restituisce i caratteri più a len sinistra da str . |
len(expr) | Restituisce la lunghezza del carattere dei dati stringa o il numero di byte di dati binari. |
length(expr) | Restituisce la lunghezza del carattere dei dati stringa o il numero di byte di dati binari. |
levenshtein(str1, str2) | Restituisce la distanza Levenshtein tra le stringhe str1 e str2 . |
str like (pattern[ESCAPE escape]) | Restituisce true se str corrisponde pattern a .escape |
locate(substr, str[, pos]) | Restituisce la posizione della prima occorrenza di substr in str dopo la posizione pos . |
lower(expr) | Restituisce expr con tutti i caratteri modificati in minuscolo. |
lpad(expr, len[, pad]) | Restituisce expr , riempito a sinistra con pad fino a una lunghezza di len . |
ltrim([trimstr,] str) | Restituisce str con caratteri iniziali all'interno trimStr di rimosso. |
mask(str[, upperChar[, lowerChar[, digitChar[, otherChar]]]]) | Restituisce una versione mascherata dell'input str . |
md5(expr) | Restituisce un checksum MD5 a 128 bit di expr come stringa esadecimale. |
octet_length(expr) | Restituisce la lunghezza in byte dei dati stringa o il numero di byte di dati binari. |
overlay(input PLACING replace FROM pos [FOR len]) | input Sostituisce con che replace inizia da pos e è di lunghezza len . |
parse_url(url, partToExtract[, key]) | Estrae una parte da url . |
position(substr, str[, pos]) | Restituisce la posizione della prima occorrenza di substr in str dopo la posizione pos . |
position(subtr IN str) | Restituisce la posizione della prima occorrenza di substr in str dopo la posizione pos . |
printf(strfmt[, obj1 [, ...]]) | Restituisce una stringa formattata dalle stringhe di formato di tipo printf. |
str regexp regex | Restituisce true se str corrisponde a regex . |
str regexp_like regex | Restituisce true se str corrisponde a regex . |
regexp_count(str, regexp) | Restituisce il numero di volte in cui str corrisponde al regexp modello. |
regexp_extract(str, regexp[, idx]) | Estrae la prima stringa in str che corrisponde all'espressione regexp e corrisponde all'indice del regex gruppo. |
regexp_extract_all(str, regexp[, idx]) | Estrae tutte le stringhe in str che corrispondono all'espressione regexp e corrisponde all'indice del regex gruppo. |
regexp_instr(str, regexp) | Restituisce la posizione della prima sottostringa in str che corrisponde a regexp . |
regexp_replace(str, regexp, rep[, position]) | Sostituisce tutte le sottostringhe di str che corrispondono regexp a rep . |
regexp_substr(str, regexp) | Restituisce la prima sottostringa in str che corrisponde a regexp . |
repeat(expr, n) | Restituisce la stringa che ripete i expr n tempi. |
replace(str, search [, replace]) | Sostituisce tutte le occorrenze di search con replace . |
reverse(expr) | Restituisce una stringa invertita o una matrice con ordine inverso di elementi. |
right(str, len) | Restituisce i caratteri più a len destra della stringa str . |
str rlike regex | Restituisce true se str corrisponde a regex . |
rpad(expr, len[, pad]) | Restituisce expr , con riempimento a destra con pad fino a una lunghezza di len . |
rtrim([trimStr,] str) | Restituisce str con caratteri finali rimossi. |
sentences(str[, lang, country]) | str Suddivide in una matrice di parole. |
sha(expr) | Restituisce un valore hash sha1 come stringa esadecimale di expr . |
sha1(expr) | Restituisce un valore hash sha1 come stringa esadecimale di expr . |
sha2(expr, bitLength) | Restituisce un checksum della famiglia SHA-2 come stringa esadecimale di expr . |
soundex(expr) | Restituisce il codice soundex della stringa. |
space(n) | Restituisce una stringa costituita da n spazi. |
split(str, regex[, limit]) | Suddivide le str occorrenze che corrispondono regex e restituisce una matrice con una lunghezza massima limit di . |
split_part(str, delim, partNum) | Divide le occorrenze str di delim e restituisce la partNum parte. |
startswith(expr, startExpr) | Restituisce true se expr STRING o BINARY inizia con startExpr . |
string(expr) | Esegue il cast del valore expr su STRING . |
substr(expr, pos[, len]) | Restituisce la sottostringa di expr che inizia da pos e è di lunghezza len . |
substr(expr FROM pos[ FOR len]) | Restituisce la sottostringa di expr che inizia da pos e è di lunghezza len . |
substring(expr, pos[, len]) | Restituisce la sottostringa di expr che inizia da pos e è di lunghezza len . |
substring(expr FROM pos[ FOR len]) | Restituisce la sottostringa di expr che inizia da pos e è di lunghezza len . |
substring_index(expr, delim, count) | Restituisce la sottostringa di prima count delle expr occorrenze del delimitatore delim . |
to_binary(expr[, fmt]) | Restituisce expr il cast a un oggetto Binary basato su fmt . |
to_char(numExpr, fmt) | Restituisce numExpr il cast a STRING usando la formattazione fmt ". |
to_varchar(numExpr, fmt) | Restituisce numExpr il cast a STRING usando la formattazione fmt ". |
translate(expr, from, to) | Restituisce un oggetto expr in cui tutti i caratteri in from sono stati sostituiti con quelli in to . |
trim([[BOTH | LEADING | TRAILING] [trimStr] FROM] str) | Tagliare i caratteri da una stringa. |
try_aes_decrypt(expr, key[, mode[, padding[, aad]]]) | Decrittografa un file binario expr usando la crittografia AES e restituisce NULL in caso di errore. |
try_to_binary(expr [, fmt]) | Restituisce expr il cast a in fmt base a BINARY o NULL se l'input non è valido. |
try_url_decode(str) | Converte una stringa dal formato application/x-www-form-urlencoded e restituisce NULL in caso di errore. |
try_zstd_decompress(valore) | Restituisce un valore decompresso con compressione Zstandard o NULL se l'input non è valido. |
ucase(expr) | Restituisce expr con tutti i caratteri modificati in maiuscolo. |
unbase64(expr) | Restituisce una stringa base64 decodificata come binaria. |
unhex(expr) | Converte l'esadecimale expr in BINARY . |
upper(expr) | Restituisce expr con tutti i caratteri modificati in maiuscolo. |
url_decode(str) | Converte di nuovo una stringa dal formato application/x-www-form-urlencoded . |
url_encode(str) | Converte una stringa in formato application/x-www-form-urlencoded . |
zstd_compress (valore[,level[,streaming_mode]]) | Restituisce il valore compresso con la compressione Zstandard. |
zstd_decompress(valore) | Restituisce un valore decompresso con compressione Zstandard. |
Funzioni scalari numeriche
Funzione | Descrizione |
---|---|
~ expr | Restituisce il bit per NOT bit di expr . |
dividendo/divisore | Restituisce dividend diviso per divisor . |
expr1 | expr2 | Restituisce l'oggetto bit per OR bit di expr1 e expr2 . |
- expr | Restituisce il valore negato di expr . |
expr1 - expr2 | Restituisce la sottrazione di expr2 da expr1 . |
+ espr | Restituisce il valore di expr . |
expr1 + expr2 | Restituisce la somma di expr1 e expr2 . |
divisore dividend % | Restituisce il resto dopo dividend / divisor . |
expr1 ^ expr2 | Restituisce l'esclusivo OR (XOR) bit per bit di expr1 e expr2 . |
expr1 & expr2 | Restituisce l'oggetto bit per AND bit di expr1 e expr2 . |
moltiplicatore * moltiplicatore | Restituisce multiplier moltiplicato per multiplicand . |
abs(expr) | Restituisce il valore assoluto del valore numerico in expr . |
acos(expr) | Restituisce il coseno inverso (arcocosine) di expr . |
acosh(expr) | Restituisce il coseno iperbolico inverso di expr . |
asin(expr) | Restituisce il seno inverso (arcone) di expr . |
asinh(expr) | Restituisce il seno iperbolico inverso di expr . |
atan(expr) | Restituisce la tangente inversa (arcotangente) di expr . |
atan2(exprY, exprX) | Restituisce l'angolo in radianti tra l'asse x positivo di un piano e il punto specificato dalle coordinate (exprX , exprY ). |
atanh(expr) | Restituisce la tangente iperbolica inversa di expr . |
bigint(expr) | Esegue il cast del valore expr su BIGINT . |
bit_count(expr) | Restituisce il numero di bit impostati nell'argomento . |
bit_get(expr, pos) | Restituisce il valore di un bit in una rappresentazione binaria di un valore numerico integrale. |
bit_reverse(expr) | Restituisce il valore ottenuto invertendo l'ordine dei bit nell'argomento . |
bitmap_bit_position(expr) | Restituisce la posizione in bit a 0 di un determinato BIGINT numero all'interno di un bucket. |
bitmap_bucket_number(expr) | Restituisce il numero di bucket bitmap per un determinato BIGINT numero. |
bround(expr[,targetScale]) | Restituisce l'oggetto arrotondato utilizzando HALF_EVEN la modalità di arrotondamentoexpr . |
cbrt(expr) | Restituisce la radice del cubo di expr . |
ceil(expr[,targetScale]) | Restituisce il numero più piccolo non inferiore expr a arrotondato a targetScale cifre rispetto al separatore decimale. |
ceiling(expr[,targetScale]) | Restituisce il numero più piccolo non inferiore expr a arrotondato a targetScale cifre rispetto al separatore decimale. |
conv(num, fromBase, toBase) | Converte num da fromBase a toBase . |
convert_timezone([sourceTz, ]targetTz, sourceTs) | Converte l'oggetto TIMESTAMP_NTZ sourceTs sourceTz dal fuso orario a targetTz . |
cos(expr) | Restituisce il coseno di expr . |
cosh(expr) | Restituisce il coseno iperbolico di expr . |
cot(expr) | Restituisce la cotangente di expr . |
csc(expr) | Restituisce il cosecante di expr . |
decimal(expr) | Esegue il cast del valore expr su DECIMAL . |
gradi(expr) | Converte i radianti in gradi. |
dividendo divisore div | Restituisce la parte integrante della divisione di per divisor dividend . |
double(expr) | Esegue il cast del valore expr su DOUBLE . |
e() | Restituisce la costante e . |
exp(expr) | Restituisce e la potenza di expr . |
expm1(expr) | Restituisce exp(expr) - 1 . |
factorial(expr) | Restituisce il fattoriale di expr . |
float(expr) | Esegue il cast del valore expr su FLOAT . |
floor(expr[,targetScale]) | Restituisce il numero più grande non inferiore expr a arrotondato a targetScale cifre rispetto al separatore decimale. |
getbit(expr, pos) | Restituisce il valore di un bit in una rappresentazione binaria di un valore numerico integrale. |
hypot(expr1, expr2) | Restituisce sqrt(expr1 * expr1 + expr2 * expr2) . |
int(expr) | Esegue il cast del valore expr su INTEGER . |
isnan(expr) | Restituisce true se expr è NaN . |
ln(expr) | Restituisce il logaritmo naturale (base e ) di expr . |
log([base,] expr) | Restituisce il logaritmo di expr con base . |
log1p(expr) | Restituisce log(1 + expr) . |
log2(expr) | Restituisce il logaritmo di expr con base 2 . |
log10(expr) | Restituisce il logaritmo di expr con base 10 . |
mod(dividend, divisor) | Restituisce il resto dopo dividend / divisor . |
nanvl(expr1, expr2) | Restituisce expr1 se non NaN è o expr2 in caso contrario. |
negative(expr) | Restituisce il valore negato di expr . |
pi() | Restituisce pi. |
pmod(dividend, divisor) | Restituisce il resto positivo dopo dividend / divisor . |
positive(expr) | Restituisce il valore di expr . |
pow(expr1, expr2) | Genera expr1 la potenza di expr2 . |
power(expr1, expr2) | Genera expr1 la potenza di expr2 . |
radianti(expr) | Converte expr in gradi in radianti. |
rand([seed]) | Restituisce un valore casuale compreso tra 0 e 1. |
randn([seed]) | Restituisce un valore casuale da una distribuzione normale standard. |
random([seed]) | Restituisce un valore casuale compreso tra 0 e 1. |
rint(expr) | Restituisce expr arrotondato a un numero intero come .DOUBLE |
round(expr[,targetScale]) | Restituisce l'oggetto arrotondato utilizzando HALF_UP la modalità di arrotondamentoexpr . |
sec(expr) | Restituisce la secante di expr . |
shiftleft(expr, n) | Restituisce un valore a sinistra bit per bit spostato in n base ai bit. |
shiftright(expr, n) | Restituisce un numero integrale con segno bit per bit spostato a destra per n bit. |
shiftrightunsigned(expr, n) | Restituisce un numero integrale senza segno bit per bit spostato a destra per n bit. |
sign(expr) | Restituisce -1.0, 0.0 o 1.0 come expr negativo, 0 o positivo. |
signum(expr) | Restituisce -1.0, 0.0 o 1.0 come expr negativo, 0 o positivo. |
sin(expr) | Restituisce il seno di expr . |
sinh(expr) | Restituisce il seno iperbolico di expr . |
smallint(expr) | Esegue il cast del valore expr su SMALLINT . |
sqrt(expr) | Restituisce la radice quadrata di expr . |
tan(expr) | Restituisce la tangente di expr . |
tanh(expr) | Restituisce la tangente iperbolica di expr . |
tinyint(expr) | Esegue il expr cast a TINYINT . |
to_number(expr, fmt ) | Restituisce expr il cast a DECIMAL utilizzando la formattazione fmt . |
try_add(expr1, expr2) | Restituisce la somma di expr1 e expr2 o NULL in caso di errore. |
try_divide(dividend, divisore) | Restituisce dividend diviso per divisor o NULL se divisor è 0. |
try_mod(dividend, divisore) | Restituisce il resto dopo dividend / divisor o NULL se divisor è 0.. |
try_multiply(moltiplicatore, moltiplicatore) | Restituisce multiplier moltiplicato per multiplicand o NULL in caso di overflow. |
try_subtract(expr1, expr2) | Restituisce la sottrazione di expr2 da expr1 o NULL in caso di overflow. |
try_to_number(expr, fmt ) | Restituisce expr il cast a DECIMAL utilizzando la formattazione fmt o NULL se expr non corrisponde al formato. |
width_bucket(expr, minExpr, maxExpr, numBuckets) | Restituisce il numero di bucket per un valore in un istogramma di larghezza equi. |
Funzioni di aggregazione
Funzione | Descrizione |
---|---|
any(expr) | Restituisce true se almeno un valore di expr nel gruppo è true. |
any_value(expr[,ignoreNull]) | Restituisce un valore di expr per un gruppo di righe. |
approx_count_distinct(expr[,relativeSD]) | Restituisce il numero stimato di valori distinti all'interno expr del gruppo. |
approx_percentile(expr,percentage[,accuracy]) | Restituisce il percentile approssimativo dell'oggetto expr all'interno del gruppo. |
approx_top_k(expr[,k[,maxItemsTracked]]) | Restituisce i valori degli k elementi più frequenti in un expr insieme ai relativi conteggi approssimativi. |
array_agg(expr) | Restituisce una matrice costituita da tutti i valori all'interno expr del gruppo. |
avg(expr) | Restituisce la media calcolata dai valori di un gruppo. |
bit_and(expr) | Restituisce il bit per AND bit di tutti i valori di input nel gruppo. |
bit_or(expr) | Restituisce il bit per OR bit di tutti i valori di input nel gruppo. |
bit_xor(expr) | Restituisce il bit per XOR bit di tutti i valori di input nel gruppo. |
bitmap_construct_agg(expr) | Restituisce il bit per OR bit di tutti i valori di posizione del bit nel gruppo. compreso tra 0 e 32767 in un gruppo come BINARY . |
bitmap_or_agg(expr) | Restituisce il bit per OR bit di tutti i BINARY valori di input nel gruppo. |
bool_and(expr) | Restituisce true se tutti i valori in expr sono true all'interno del gruppo. |
bool_or(expr) | Restituisce true se almeno un valore in expr è true all'interno del gruppo. |
collect_list(expr) | Restituisce una matrice costituita da tutti i valori all'interno expr del gruppo. |
collect_set(expr) | Restituisce una matrice costituita da tutti i valori univoci all'interno expr del gruppo. |
corr(expr1,expr2) | Restituisce il coefficiente di Pearson della correlazione tra un gruppo di coppie numeri. |
count(*) | Restituisce il numero totale di righe recuperate in un gruppo, incluse le righe contenenti null. |
count(expr[, ...]) | Restituisce il numero di righe di un gruppo per cui le espressioni fornite sono tutte non Null. |
count_if(expr) | Restituisce il numero di valori true per il gruppo in expr . |
count_min_sketch(column,epsilon,confidence,seed) | Restituisce uno schizzo count-min di tutti i valori nel gruppo in column con epsilon , confidence e seed . |
covar_pop(expr1,expr2) | Restituisce la covarianza della popolazione di coppie di numeri in un gruppo. |
covar_samp(expr1,expr2) | Restituisce la covarianza di esempio di coppie numeriche in un gruppo. |
every(expr) | Restituisce true se tutti i valori di expr nel gruppo sono true. |
first(expr[,ignoreNull]) | Restituisce il primo valore di expr per un gruppo di righe. |
first_value(expr[,ignoreNull]) | Restituisce il primo valore di expr per un gruppo di righe. |
histogram_numeric(expr,numBins) | Calcola un istogramma su expr con numBins contenitori, restituendo una matrice di coppie che rappresenta i centri bin. |
hll_sketch_agg(expr[,lgConfigK]) | Restituisce uno schizzo HyperLogLog utilizzato per approssimare un conteggio dei valori distinti. |
hll_union_agg(expr[,allowDifferentLgConfigK]) | Aggrega gli schizzi di HyperLogLog per un gruppo di righe. |
kurtosi(expr) | Restituisce il valore della kurtosi calcolato dai valori di un gruppo. |
last(expr[,ignoreNull]) | Restituisce l'ultimo valore di expr per il gruppo di righe. |
last_value(expr[,ignoreNull]) | Restituisce l'ultimo valore di expr per il gruppo di righe. |
max(expr) | Restituisce il valore massimo di expr in un gruppo. |
max_by(expr1,expr2) | Restituisce il valore di un expr1 oggetto associato al valore massimo di expr2 in un gruppo. |
mean(expr) | Restituisce la media calcolata dai valori di un gruppo. |
median(expr) | Restituisce la mediano calcolata dai valori di un gruppo. |
min(expr) | Restituisce il valore minimo di expr in un gruppo. |
min_by(expr1, expr2) | Restituisce il valore di un expr1 oggetto associato al valore minimo di expr2 in un gruppo. |
mode(expr [,deterministic]) | Restituisce il valore più frequente, non NULL , di expr in un gruppo. |
percentile(expr, percentage [,frequency]) | Restituisce il valore percentile esatto di expr in corrispondenza dell'oggetto specificato percentage . |
percentile_approx(expr,percentage[,accuracy]) | Restituisce il percentile approssimativo dell'oggetto expr all'interno del gruppo. |
percentile_cont(pct) WITHIN GROUP (ORDER BY key) | Restituisce il percentile interpolato dell'oggetto key all'interno del gruppo. |
percentile_disc(pct) WITHIN GROUP (ORDER BY key) | Restituisce il percentile discreto dell'oggetto key all'interno del gruppo. |
regr_avgx(yExpr, xExpr) | Restituisce la media calcolata xExpr dai valori di un gruppo in cui xExpr e yExpr sono NOT NULL . |
regr_avgy(yExpr, xExpr) | Restituisce la media calcolata yExpr dai valori di un gruppo in cui xExpr e yExpr sono NOT NULL . |
regr_count(yExpr, xExpr) | Restituisce il numero di coppie yExpr di valori non Null , xExpr nel gruppo. |
regr_intercept(yExpr, xExpr) | Restituisce l'intercetta della linea di regressione lineare uni-variate in un gruppo in cui xExpr e yExpr non sono NULL. |
regr_r2(yExpr, xExpr) | Restituisce il coefficiente di determinazione dai valori di un gruppo in cui xExpr e yExpr sono NOT NULL. |
regr_slope(yExpr, xExpr) | Restituisce la pendenza della linea di regressione lineare di coppie yExpr di valori non Null , xExpr nel gruppo. |
regr_sxx(yExpr, xExpr) | Restituisce la somma dei quadrati dei xExpr valori di un gruppo in cui xExpr e yExpr sono NOT NULL. |
regr_sxy(yExpr, xExpr) | Restituisce la somma dei prodotti di yExpr e xExpr calcolati dai valori di un gruppo in cui xExpr e yExpr sono NOT NULL . |
regr_syy(yExpr, xExpr) | Restituisce la somma dei quadrati dei yExpr valori di un gruppo in cui xExpr e yExpr sono NOT NULL. |
schema_of_json_agg(json[, options]) | Restituisce lo schema combinato delle JSON stringhe in un gruppo in formato DDL. |
schema_of_variant_agg(variantExpr) | Restituisce lo schema combinato di tutti i VARIANT valori in un gruppo in formato DDL. |
asimmetria(expr) | Restituisce il valore di asimmetria calcolato dai valori di un gruppo. |
some(expr) | Restituisce true se almeno un valore di expr in un gruppo è true . |
std(expr) | Restituisce la deviazione standard del campione calcolata dai valori all'interno del gruppo. |
stddev(expr) | Restituisce la deviazione standard del campione calcolata dai valori all'interno del gruppo. |
stddev_pop(expr) | Restituisce la deviazione standard della popolazione calcolata dai valori di un gruppo. |
stddev_samp(expr) | Restituisce la deviazione standard del campione calcolata dai valori di un gruppo. |
sum(expr) | Restituisce la somma calcolata dai valori di un gruppo. |
try_avg(expr) | Restituisce la media calcolata dai valori di un gruppo, NULL se è presente un overflow. |
try_sum(expr) | Restituisce la somma calcolata dai valori di un gruppo, NULL se è presente un overflow. |
var_pop(expr) | Restituisce la varianza della popolazione calcolata dai valori di un gruppo. |
var_samp(expr) | Restituisce la varianza del campione calcolata dai valori di un gruppo. |
varianza(expr) | Restituisce la varianza del campione calcolata dai valori di un gruppo. |
Funzioni della finestra di classificazione
Funzione | Descrizione |
---|---|
dense_rank() | Restituisce il rango di un valore rispetto a tutti i valori nella partizione. |
ntile(n) | Divide le righe per ogni partizione di finestra in n bucket compresi tra 1 e al massimo n . |
percent_rank() | Calcola la classificazione percentuale di un valore all'interno della partizione. |
rank() | Restituisce il rango di un valore rispetto a tutti i valori nella partizione. |
row_number() | Assegna un numero univoco e sequenziale a ogni riga, a partire da uno, in base all'ordinamento delle righe all'interno della partizione della finestra. |
Funzioni della finestra analitica
Funzione | Descrizione |
---|---|
cume_dist() | Restituisce la posizione di un valore relativo a tutti i valori nella partizione. |
lag(expr[,offset[,default]]) | Restituisce il valore di expr da una riga precedente all'interno della partizione. |
lead(expr[,offset[,default]]) | Restituisce il valore di expr da una riga successiva all'interno della partizione. |
nth_value(expr, offset[, ignoreNulls]) | Restituisce il valore di in corrispondenza di expr un oggetto specifico offset nella finestra. |
Funzioni matrice
Funzione | Descrizione |
---|---|
arrayExpr[indexExpr] | Restituisce l'elemento nella posizione indexExpr di ARRAY arrayExpr . |
aggregate(expr,start,merge[,finish]) | Aggrega gli elementi in una matrice usando un aggregatore personalizzato. |
array([expr [, ...]]) | Restituisce una matrice con gli elementi in expr . |
array_append(array, elem) | Restituisce array accodato da elem . |
array_compact(matrice) | Rimuove i valori NULL da array . |
array_contains(matrice, valore) | Restituisce true se array contiene value . |
array_distinct(matrice) | Rimuove i valori duplicati da array . |
array_except(array1,array2) | Restituisce una matrice degli elementi in array1 ma non in array2 . |
array_insert(array, index, elem) | Restituisce un oggetto espanso in array cui elem viene inserito in corrispondenza della index posizione. |
array_intersect(array1,array2) | Restituisce una matrice degli elementi nell'intersezione di array1 e array2 . |
array_join(matrice, delimitatore[,nullReplacement]) | Concatena gli elementi di array . |
array_max(matrice) | Restituisce il valore massimo in array . |
array_min(matrice) | Restituisce il valore minimo in array . |
array_position(matrice, elemento) | Restituisce la posizione della prima occorrenza di element in array . |
array_prepend(array, elem) | Restituisce array anteporre elem a . |
array_remove(matrice, elemento) | Rimuove tutte le occorrenze di element da array . |
array_repeat(element,count) | Restituisce una matrice contenente element count gli orari. |
array_size(matrice) | Restituisce il numero di elementi in array . |
array_sort(array,func) | Restituisce array l'ordinamento in base a func . |
array_union(array1,array2) | Restituisce una matrice degli elementi nell'unione di array1 e array2 senza duplicati. |
arrays_overlap(array1, array2) | Restituisce true se l'intersezione di array1 e array2 non è vuota. |
arrays_zip(array1 [, ...]) | Restituisce una matrice unita di struct in cui l'n° struct contiene tutti i valori Nth delle matrici di input. |
cardinalità(expr) | Restituisce le dimensioni di expr . |
concat(expr1, expr2 [, ...]) | Restituisce la concatenazione degli argomenti. |
element_at(arrayExpr, index) | Restituisce l'elemento di un oggetto arrayExpr in corrispondenza index di . |
exists(expr, pred) | Restituisce true se pred è true per qualsiasi elemento in expr . |
explode(collection) | Restituisce le righe annullando l'annidamento collection di . |
explode_outer(raccolta) | Restituisce le righe annullando l'annidamento collection utilizzando la semantica esterna. |
filter(expr,func) | Filtra la matrice in expr usando la funzione func . |
flatten(arrayOfArrays) | Trasforma una matrice di matrici in una singola matrice. |
forall(expr, predFunc) | Verifica se predFunc contiene tutti gli elementi nella matrice. |
get(arrayExpr, index) | Restituisce l'elemento di un oggetto arrayExpr in , index a partire da 0 . |
inline(expr) | Esplode una matrice di struct in una tabella. |
inline_outer(expr) | Esplode una matrice di struct in una tabella con semantica esterna. |
posexplode(expr) | Restituisce le righe annullando l'annidamento della matrice con numerazione delle posizioni. |
posexplode_outer(expr) | Restituisce le righe annullando l'annidamento della matrice con numerazione delle posizioni usando OUTER la semantica. |
reduce(expr,start,merge[,finish]) | Aggrega gli elementi in una matrice usando un aggregatore personalizzato. |
reverse(array) | Restituisce una stringa invertita o una matrice con ordine inverso di elementi. |
sequence(start,stop,step) | Genera una matrice di elementi da start a stop (inclusivo), incrementando di step . |
shuffle(array) | Restituisce una permutazione casuale della matrice in expr . |
size(expr) | Restituisce la cardinalità di expr . |
slice(expr,start,length) | Restituisce un subset di una matrice. |
sort_array(expr[,ascendingOrder]) | Restituisce la matrice in expr in ordine ordinato. |
transform(expr, func) | Trasforma gli elementi in una matrice in expr usando la funzione func . |
try_element_at(arrayExpr, index) | Restituisce l'elemento di un oggetto arrayExpr in o index NULL se index non è associato. |
zip_with(expr1, expr2, func) | Unisce le matrici in expr1 e expr2 , a livello di elemento, in una singola matrice usando func . |
Funzioni di mapping
Funzione | Descrizione |
---|---|
mapExpr[keyExpr] | Restituisce il valore in corrispondenza keyExpr di MAP mapExpr . |
cardinalità(expr) | Restituisce le dimensioni di expr . |
element_at(mapExpr, key) | Restituisce il valore di mapExpr per key . |
explode(expr) | Restituisce le righe annullando l'annidamento expr di . |
explode_outer(expr) | Restituisce le righe annullando l'annidamento expr utilizzando la semantica esterna. |
map([{key1, value1}[, ...]]) | Crea una mappa con le coppie chiave-valore specificate. |
map_concat([expr1 [, ...]]) | Restituisce l'unione di tutte le expr espressioni della mappa. |
map_contains_key(mappa, chiave) | Restituisce true se map contiene key , false in caso contrario. |
map_entries(mappa) | Restituisce una matrice non ordinata di tutte le voci in map . |
map_filter(expr, func) | Filtra le voci della mappa in expr usando la funzione func . |
map_from_arrays(chiavi, valori) | Crea una mappa con una coppia di keys matrici e values . |
map_from_entries(expr) | Crea una mappa creata dalla matrice di voci specificata. |
map_keys(mappa) | Restituisce una matrice non ordinata contenente le chiavi di map . |
map_values(mappa) | Restituisce una matrice non ordinata contenente i valori di map . |
map_zip_with(map1, map2, func) | map1 Unisce e map2 in una singola mappa. |
size(expr) | Restituisce la cardinalità di expr . |
str_to_map(expr[,pairDelim[,keyValueDelim]]) | Restituisce una mappa dopo la suddivisione expr in coppie chiave-valore usando delimitatori. |
transform_keys(expr, func) | Trasforma le chiavi in una mappa in expr usando la funzione func . |
transform_values(expr, func) | Trasforma i valori in una mappa in expr usando la funzione func . |
try_element_at(mapExpr, key) | Restituisce il valore di mapExpr per key o NULL se key non esiste. |
Funzioni di data, timestamp e intervallo
Per informazioni sui formati di data e ora, vedere Modelli Datetime.
Funzione | Descrizione |
---|---|
intervalExpr/divisore | Restituisce l'intervallo diviso per divisor . |
- intervalExpr | Restituisce il valore negato di intervalExpr . |
intervalExpr1 - intervalExpr2 | Restituisce la sottrazione di intervalExpr2 da intervalExpr1 . |
datetimeExpr1 - datetimeExpr2 | Restituisce la sottrazione di datetimeExpr2 da datetimeExpr1 . |
+ intervalExpr | Restituisce il valore di intervalExpr . |
intervalExpr1 + intervalExpr2 | Restituisce la somma di intervalExpr1 e intervalExpr2 . |
intervalExpr * multiplicand | Restituisce intervalExpr moltiplicato per multiplicand . |
abs(expr) | Restituisce il valore assoluto del valore di intervallo in expr . |
add_months(startDate,numMonths) | Restituisce la data successiva numMonths startDate a . |
curdate() | Restituisce la data corrente all'inizio della valutazione della query. |
current_date() | Restituisce la data corrente all'inizio della valutazione della query. |
current_timestamp() | Restituisce il timestamp corrente all'inizio della valutazione della query. |
current_timezone() | Restituisce il fuso orario locale della sessione corrente. |
date(expr) | Esegue il cast del valore expr su DATE. |
date_add(startDate,numDays) | Restituisce la data numDays dopo startDate . |
date_add(unit, value, expr) | Aggiunge value unit s a un timestamp expr . |
date_diff(unit, start, stop) | Restituisce la differenza tra due timestamp misurati in unit s. |
date_format(expr,fmt) | Converte un timestamp in una stringa nel formato fmt . |
date_from_unix_date(giorni) | Crea una data dal numero di giorni trascorsi da 1970-01-01 . |
date_part(field,expr) | Estrae una parte della data, del timestamp o dell'intervallo. |
date_sub(startDate,numDays) | Restituisce la data numDays precedente startDate a . |
date_trunc(unit,expr) | Restituisce il timestamp troncato all'unità specificata in unit . |
dateadd(startDate,numDays) | Restituisce la data numDays dopo startDate . |
dateadd(unit, value, expr) | Aggiunge value unit s a un timestamp expr . |
datediff(endDate,startDate) | Restituisce il numero di giorni da startDate a endDate . |
datediff(unit, start, stop) | Restituisce la differenza tra due timestamp misurati in unit s. |
day(expr) | Restituisce il giorno del mese della data o del timestamp. |
dayofmonth(expr) | Restituisce il giorno del mese della data o del timestamp. |
dayofweek(expr) | Restituisce il giorno della settimana della data o del timestamp. |
dayofyear(expr) | Restituisce il giorno dell'anno della data o del timestamp. |
dividendo divisore div | Restituisce la parte integrante della divisione dell'intervallo in base all'intervallo divisor dividend . |
extract(field FROM source) | Restituisce field di source . |
from_unixtime(unixTime,fmt) | Restituisce unixTime in fmt . |
from_utc_timestamp(expr,fuso orario) | Restituisce un timestamp specificato in expr UTC nel fuso timeZone orario . |
getdate() | Restituisce il timestamp corrente all'inizio della valutazione della query. |
hour(expr) | Restituisce il componente hour di un timestamp. |
last_day(expr) | Restituisce l'ultimo giorno del mese a cui appartiene la data. |
make_date(anno,mese,giorno) | Crea una data dai year campi , month e day . |
make_dt_interval([days[, hours[, mins[, secs]]]]) | Crea un intervallo di tempo di giorno da days , hours mins e secs . |
make_interval(anni, mesi, settimane, giorni, ore, min, secs) | Deprecato: crea un intervallo da years , months , weeks , hours days , mins e secs . |
make_timestamp(year,month,day,hour,min,sec[,timezone]) | Crea un timestamp dai year campi , day month , hour , min , sec , e timezone . |
make_ym_interval([years[, months]]) | Crea un intervallo di anno-mese da years e months . |
minute(expr) | Restituisce il componente minuto del timestamp in expr . |
month(expr) | Restituisce il componente month del timestamp in expr . |
months_between(expr1,expr2[,roundOff]) | Restituisce il numero di mesi trascorsi tra date o timestamp in expr1 e expr2 . |
next_day(expr,dayOfWeek) | Restituisce la prima data successiva a expr e denominata come in dayOfWeek . |
now() | Restituisce il timestamp corrente all'inizio della valutazione della query. |
quarter(expr) | Restituisce il trimestre dell'anno per expr nell'intervallo compreso tra 1 e 4. |
second(expr) | Restituisce il secondo componente del timestamp in expr . |
session_window(expr, gpDuration) | Crea una finestra di sessione in un'espressione timestamp. |
sign(expr) | Restituisce -1,0, 0,0 o 1,0 come intervallo expr è negativo, 0 o positivo. |
signum(expr) | Restituisce -1,0, 0,0 o 1,0 come intervallo expr è negativo, 0 o positivo. |
timediff(unit, start, stop) | Restituisce la differenza tra due timestamp misurati in unit s. |
timestamp(expr) | Esegue il expr cast a TIMESTAMP . |
timestamp_micros(expr) | Crea un microsecondo timestamp expr dall'epoca UTC. |
timestamp_millis(expr) | Crea un timestamp expr millisecondi dall'epoca UTC. |
timestamp_seconds(expr) | Crea il timestamp expr secondi dall'epoca UTC. |
timestampadd(unit, value, expr) | Aggiunge value unit s a un timestamp expr . |
timestampdiff(unit, start, stop) | Restituisce la differenza tra due timestamp misurati in unit s. |
to_date(expr[,fmt]) | Restituisce expr il cast a una data utilizzando una formattazione facoltativa. |
to_timestamp(expr[,fmt]) | Restituisce expr il cast a un timestamp usando una formattazione facoltativa. |
to_unix_timestamp(expr[,fmt]) | Restituisce il timestamp in expr come timestamp UNIX. |
to_utc_timestamp(expr,timezone) | Restituisce il timestamp in expr un fuso orario diverso come UTC. |
trunc(expr, fmt) | Restituisce una data con la parte della data troncata all'unità specificata dal modello fmt di formato . |
try_add(expr1, expr2) | Restituisce la somma di expr1 e expr2 o NULL in caso di errore. |
try_divide(dividend, divisore) | Restituisce dividend diviso per divisor o NULL se divisor è 0. |
try_multiply(moltiplicatore, moltiplicatore) | Restituisce multiplier moltiplicato per multiplicand o NULL in caso di overflow. |
try_subtract(expr1, expr2) | Restituisce la sottrazione di expr2 da expr1 o NULL in caso di overflow. |
try_to_timestamp(expr[,fmt]) | Restituisce expr il cast a un timestamp usando una formattazione facoltativa o NULL se il cast ha esito negativo. |
unix_date(expr) | Restituisce il numero di giorni trascorsi da 1970-01-01 . |
unix_micros(expr) | Restituisce il numero di microsecondi da 1970-01-01 00:00:00 UTC . |
unix_millis(expr) | Restituisce il numero di millisecondi da 1970-01-01 00:00:00 UTC . |
unix_seconds(expr) | Restituisce il numero di secondi trascorsi da 1970-01-01 00:00:00 UTC . |
unix_timestamp([expr[, fmt]]) | eturn il timestamp UNIX dell'ora corrente o specificata. |
weekday(expr) | Restituisce il giorno della settimana di expr . |
weekofyear(expr) | Restituisce la settimana dell'anno di expr . |
year(expr) | Restituisce il componente year di expr . |
window(expr, width[, step[, start]]) | Crea una finestra temporale scorrevole basata su salto su un'espressione timestamp. |
window_time(finestra) | Restituisce l'ora di fine inclusiva di una finestra scorrevole prodotta dalla finestra o dalle funzioni session_window. |
Funzioni geospaziali H3
Per informazioni sulle funzioni geospaziali H3, vedere Funzioni geospaziali H3.
Cast di funzioni e costruttori
Per informazioni sul cast tra tipi, vedere Funzione cast e funzione try_cast.
Funzione | Descrizione |
---|---|
array([expr [, ...]]) | Restituisce una matrice con gli elementi in expr . |
bigint(expr) | Esegue il cast del valore expr su BIGINT . |
binary(expr) | Esegue il cast del valore di expr in BINARY . |
boolean(expr) | Esegue il expr cast a BOOLEAN . |
cast(tipo AS expr) | Esegue il cast del valore expr al tipo di dati di type destinazione . |
expr :: type | Esegue il cast del valore expr al tipo di dati di type destinazione . |
date(expr) | Esegue il cast del valore expr su DATE . |
decimal(expr) | Esegue il cast del valore expr su DECIMAL . |
double(expr) | Esegue il cast del valore expr su DOUBLE . |
float(expr) | Esegue il cast del valore expr su FLOAT . |
int(expr) | Esegue il cast del valore expr su INTEGER . |
make_date(anno,mese,giorno) | Crea una data dai year campi , month e day . |
make_dt_interval([days[, hours[, mins[, secs]]]]) | Crea un intervallo di tempo di giorno da days , hours mins e secs . |
make_interval(anni, mesi, settimane, giorni, ore, min, secs) | Crea un intervallo da years , months , days weeks , , mins hours e secs . |
make_timestamp(year,month,day,hour,min,sec[,timezone]) | Crea un timestamp dai year campi , day month , hour , min , sec , e timezone . |
make_ym_interval([years[, months]]) | Crea un intervallo di anno-mese da years e months . |
map([{key1, value1} [, ...]]) | Crea una mappa con le coppie chiave-valore specificate. |
named_struct({name1, val1} [, ...]) | Crea uno struct con i nomi e i valori di campo specificati. |
smallint(expr) | Esegue il cast del valore expr su SMALLINT . |
string(expr) | Esegue il cast del valore expr su STRING . |
struct(expr1 [, ...]) | Crea un oggetto STRUCT con i valori di campo specificati. |
tinyint(expr) | Esegue il expr cast a TINYINT . |
timestamp(expr) | Esegue il expr cast a TIMESTAMP . |
to_char(expr, fmt) | Restituisce expr il cast a STRING usando la formattazione fmt ". |
to_date(expr[,fmt]) | Restituisce expr il cast a una data utilizzando una formattazione facoltativa. |
to_number(expr, fmt) | Restituisce expr il cast a DECIMA L usando la formattazione fmt . |
to_timestamp(expr[,fmt]) | Restituisce expr il cast a un timestamp usando una formattazione facoltativa. |
to_varchar(expr, fmt) | Restituisce expr il cast a STRING usando la formattazione fmt ". |
try_cast(tipo AS expr) | Esegue il cast del valore expr nel tipo di dati di type destinazione in modo sicuro. |
try_to_number(expr, fmt) | Restituisce expr il cast a DECIMAL utilizzando la formattazione fmt o NULL se expr non è valido. |
Funzioni CSV
Funzione | Descrizione |
---|---|
from_csv(csvStr, schema[, opzioni]) | Restituisce un valore di struct con csvStr e schema . |
schema_of_csv(csv[, opzioni]) | Restituisce lo schema di una stringa CSV in formato DDL. |
to_csv(expr[, options]) | Restituisce una stringa CSV con il valore dello struct specificato. |
Funzioni JSON
Funzione | Descrizione |
---|---|
jsonStr: jsonPath | Restituisce i campi estratti da jsonStr . |
from_json(jsonStr, schema[, options]) | Restituisce un valore di struct con jsonStr e schema . |
get_json_object(expr, path) | Estrae un JSON oggetto da path . |
json_array_length(jsonArray) | Restituisce il numero di elementi nella matrice più esterna JSON . |
json_object_keys(jsonObject) | Restituisce tutte le chiavi dell'oggetto più esterno JSON come matrice. |
json_tuple(jsonStr, path1 [, ...]) | Restituisce più JSON oggetti come tupla. |
parse_json(jsonStr) | Restituisce un VARIANT valore da jsonStr . |
schema_of_json(jsonStr[, options]) | Restituisce lo schema di una JSON stringa in formato DDL. |
schema_of_json_agg(jsonStr[, options]) | Restituisce lo schema combinato delle JSON stringhe in un gruppo in formato DDL. |
to_json(expr[, options]) | Restituisce una stringa JSON con o STRUCT VARIANT specificata in expr . |
Funzioni VARIANT
Funzione | Descrizione |
---|---|
variantExpr : jsonPath | Restituisce i campi estratti dal variantExpr percorso JSON. |
is_variant_null(variantExpr) | Verifica se variantExpr è un oggetto VARIANT con codifica NULL . |
parse_json(jsonStr) | Restituisce un VARIANT valore da jsonStr . |
schema_of_variant(variantExpr) | Restituisce lo schema di un'espressione VARIANT in formato DDL. |
schema_of_variant_agg(variantExpr) | Restituisce lo schema combinato di tutti i VARIANT valori in un gruppo in formato DDL. |
to_json(expr[, options]) | Restituisce una stringa JSON con o STRUCT VARIANT specificata in expr . |
try_parse_json(jsonStr) | Restituisce un VARIANT valore dall'oggetto jsonStr , se possibile. Se non è possibile, NULL viene restituito . |
try_variant_get(variantExpr,path,type) | Estrae un valore di type tipo da variantExpr , specificato da path o NULL se non è possibile eseguire il cast al tipo di destinazione. |
variant_explode(variantExpr) | Restituisce un set di righe annullando l'annidamento variantExpr di . |
variant_explode_outer(variantExpr) | Restituisce un set di righe annullando l'annidamento variantExpr utilizzando la semantica esterna. |
variant_get(variantExpr,path,type) | Estrae un valore di type tipo da variantExpr , specificato da path . |
Funzioni XPath e XML
Funzione | Descrizione |
---|---|
from_xml(xmlStr, schema[, opzioni]) | Restituisce un valore dello struct analizzato dall'oggetto xmlStr utilizzando schema . |
schema_of_xml(xmlStr[, options]) | Restituisce lo schema di una XML stringa in formato DDL. |
xpath(xml, xpath) | Restituisce valori all'interno dei nodi di xml che corrispondono a xpath . |
xpath_boolean(xml, xpath) | Restituisce true se l'espressione xpath restituisce true o se viene trovato un nodo corrispondente in xml . |
xpath_double(xml, xpath) | Restituisce un DOUBLE valore da un documento XML. |
xpath_float(xml, xpath) | Restituisce un FLOAT valore da un documento XML. |
xpath_int(xml, xpath) | Restituisce un INTEGER valore da un documento XML. |
xpath_long(xml, xpath) | Restituisce un BIGINT valore da un documento XML. |
xpath_number(xml, xpath) | Restituisce un DOUBLE valore da un documento XML. |
xpath_short(xml, xpath) | Restituisce un SHORT valore da un documento XML. |
xpath_string(xml, xpath) | Restituisce il contenuto del primo nodo XML corrispondente all'espressione XPath. |
Funzioni di intelligenza artificiale
Funzione | Descrizione |
---|---|
ai_analyze_sentiment(content) | Restituisce il sentiment di un testo. |
ai_classify(contenuto, etichette) | Classifica il contenuto fornito in una delle etichette fornite. |
ai_extract(content, labels) | Estrae le entità specificate dalle etichette da un determinato testo. |
ai_fix_grammar(content) | Corregge gli errori grammaticali in un determinato testo. |
ai_forecast(osservato, time_col) | Estropola i dati delle serie temporali in futuro. |
ai_gen(contenuto) | Richiama un modello di intelligenza artificiale generativa all'avanguardia dalle API del modello di Databricks Foundation per rispondere alla richiesta fornita dall'utente. |
ai_generate_text(prompt, modelName[, param1, value1] [...]) | Deprecato: restituisce il testo generato da un modello LLM (Large Language Model) selezionato in base al prompt. |
ai_mask(content, labels) | Maschera le entità specificate all'interno di un determinato testo. |
ai_query(endpointName, request, returnType) | Richiama un endpoint di gestione del modello di intelligenza artificiale mosaico esistente e analizza e restituisce la risposta. |
ai_similarity(strExpr1, strExpr2) | Confronta due stringhe e calcola il punteggio di somiglianza semantica. |
ai_summarize(content[, max_words]) | Genera un riepilogo di un determinato testo. |
ai_translate(content, to_lang) | Converte il testo in una lingua di destinazione specificata. |
vector_search(index, query, num_results) | Eseguire una query su un indice di Ricerca vettoriale di Mosaic AI usando SQL. |
Leggere le funzioni
Funzione | Descrizione |
---|---|
read_files(path, [optionKey => optionValue] [, ...]) | Legge i file di dati nell'archiviazione cloud e lo restituisce in formato tabulare. |
read_kafka([optionKey => optionValue] [, ...]) | Legge i record da un cluster Apache Kafka e lo restituisce in formato tabulare. |
read_kinesis({parameter => value} [, ...]) | Restituisce una tabella con i record lettidai da da da uno o più flussi. |
read_pubsub([parameter => value] [, ...]) | Funzione con valori di tabella per la lettura di record da Pub/Sub da un argomento. |
read_pulsar({optionKey => optionValue} [, ...]) | Restituisce una tabella con record letti da Pulsar. |
read_state_metadata(path) | Restituisce una tabella con righe che rappresentano i metadati di uno stato di query di streaming. |
read_statestore(path [, option_key => option_value] [...]) | Restituisce i record dall'archivio di stato delle query di streaming. |
Funzioni varie
Funzione | Descrizione |
---|---|
assert_true(expr) | Restituisce un errore se expr non è true. |
CASE expr { WHEN opt1 THEN res1 } [...] [ELSE def] FINE | Restituisce resN per il primo optN oggetto uguale expr o def se nessuna corrisponde. |
CASE { WHEN cond1 THEN res1 } [...] [ELSE def] FINE | Restituisce resN per il primo condN oggetto che restituisce true o def se non viene trovato alcun valore. |
cloud_files_state( { TABLE(table) | checkpoint } ) | |
coalesce(expr1, expr2 [, ...]) | Restituisce il primo argomento non Null. |
cubo (expr1 [, ...]) | Crea un cubo multidimensionale utilizzando le colonne di espressione specificate. |
current_catalog() | Restituisce il catalogo corrente. |
current_database() | Restituisce lo schema corrente. |
current_metastore() | Restituisce l'ID metastore del catalogo Unity corrente. |
current_recipient(key) | Restituisce una proprietà per il destinatario corrente in una visualizzazione condivisa con condivisione Delta. |
current_schema() | Restituisce lo schema corrente. |
current_user() | Restituisce l'utente che esegue l'istruzione . |
current_version() | Restituisce la versione corrente di Azure Databricks. |
decode(expr, { key, value } [, ...] [,defValue]) | Restituisce il valore corrispondente alla chiave. |
elt(index, expr1 [, ...] ) | Restituisce l'na espressione. |
equal_null(expr1, expr2) | Restituisce true se expr1 è uguale o entrambe expr2 le espressioni sono NULL o false in caso contrario. |
event_log( { TABLE(table) | pipeline_id } ) | |
greatest(expr1, expr2 [, ...]) | Restituisce il valore più grande di tutti gli argomenti, ignorando i valori Null. |
grouping(col) | Indica se una colonna specificata in un GROUPING SET oggetto , ROLLUP o CUBE rappresenta un subtotale. |
grouping_id([col1 [, ...]]) | Restituisce il livello di raggruppamento per un set di colonne. |
hash(expr1 [, ...]) | Restituisce un valore con hash degli argomenti. |
hll_sketch_estimate(expr) | Stima il numero di valori distinti raccolti in uno schizzo HyperLogLog. |
hll_union(expr1, expr2 [,allowDifferentLgConfigK]) | Combina due schizzi HyperLogLog. |
java_method(classe, metodo[, arg1 [, ...]]) | Chiama un metodo con reflection. |
if(cond, expr1, expr2) | Restituisce expr1 se cond è true o expr2 in caso contrario. |
iff(cond, expr1, expr2) | Restituisce expr1 se cond è true o expr2 in caso contrario. |
ifnull(expr1, expr2) | Restituisce expr2 se expr1 è NULL o expr1 in caso contrario. |
input_file_block_length() | Restituisce la lunghezza in byte del blocco letto. |
input_file_block_start() | Restituisce l'offset iniziale in byte del blocco letto. |
input_file_name() | Restituisce il nome del file letto o una stringa vuota, se non disponibile. |
is_account_group_member(gruppo) | Restituisce true se l'utente corrente è un membro del gruppo a livello di account. |
is_member(gruppo) | Restituisce true se l'utente corrente è un membro del gruppo a livello di area di lavoro. |
isnull(expr) | Restituisce true se expr è NULL . |
isnotnull(expr) | Restituisce true se expr non NULL è . |
least(expr1, expr2 [, ...]) | Restituisce il valore più piccolo di tutti gli argomenti, ignorando i valori Null. |
list_secrets([scopeStr]) | Restituisce le chiavi in tutti o in un ambito che l'utente è autorizzato a visualizzare dal servizio segreto databricks. |
luhn_check(numStr) | Restituisce true se numStr supera il controllo dell'algoritmo Luhn. |
monotonically_increasing_id() | Restituisce numeri interi a 64 bit che aumentano in modo monotonico. |
nullif(expr1, expr2) | Restituisce NULL se expr1 è expr2 uguale a o expr1 in caso contrario. |
nvl(expr1, expr2) | Restituisce expr2 se expr1 è NULL o expr1 in caso contrario. |
nvl2(expr1, expr2, expr3) | Restituisce expr2 se expr1 non NULL è o expr3 in caso contrario. |
raise_error(expr) | Genera un'eccezione con expr come messaggio. |
range(end) | Restituisce una tabella di valori all'interno di un intervallo specificato. |
range(start, end [, step [, numParts]]) | Restituisce una tabella di valori all'interno di un intervallo specificato. |
reflect(class, method[, arg1 [, ...]]) | Chiama un metodo con reflection. |
secret(scope, key) | Estrae un valore segreto con il scope servizio segreto specificato e key dal servizio segreto Databricks. |
session_user() | Restituisce l'utente connesso ad Azure Databricks. |
spark_partition_id() | Restituisce l'ID partizione corrente. |
sql_keywords() | Restituisce il set di parole chiave SQL in Azure Databricks. |
stack(numRows, expr1 [, ...]) | expr1 Separa , ..., exprN in numRows righe. |
table_changes(table_str, start [, end]) | Restituisce un log delle modifiche apportate a una tabella Delta Lake con feed di dati delle modifiche abilitato. |
try_reflect(classe, metodo[, arg1 [, ...]]) | Chiama un metodo con reflection, restituendo NULL se il metodo ha esito negativo. |
try_secret(ambito, chiave) | Estrae un valore segreto con il servizio segreto specificato scope e key dal servizio segreto Databricks o NULL se la chiave non può essere recuperata. |
typeof(expr) | Restituisce una stringa di tipo DDL formattata per il tipo di dati di expr . |
user() | Restituisce l'utente che esegue l'istruzione . |
uuid() | Restituisce una stringa UUID (Universally Unique Identifier). |
window(expr, width[, step [, start]]) | Crea una finestra temporale scorrevole basata su salto su un'espressione timestamp. |
xxhash64(expr1 [, ...]) | Restituisce un valore con hash a 64 bit degli argomenti. |
version() | Restituisce la versione di Apache Spark. |