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 (UDF)?.
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 | Descrizione |
---|---|---|
& | expr1 & expr2 |
Restituisce l'oggetto bit AND di expr1 e expr2 . |
e | expr1 and expr2 |
Restituisce il AND logico di expr1 e expr2 . |
* | multiplier * multiplicand |
Restituisce multiplier moltiplicato per multiplicand . |
!= | expr1 != expr2 |
Restituisce true se expr1 non è uguale expr2 , o false in caso contrario. |
! | !expr |
Restituisce il NOT logico di un'espressione booleana. |
tra | expr1 [not] between expr2 and expr2 |
Verifica se expr1 è maggiore o uguale a expr2 e minore o uguale a expr3 . |
[ ] | arrayExpr [ indexExpr ] |
Restituisce l’elemento indexExpr di ARRAY arrayExpr . |
[ ] | mapExpr [ keyExpr ] |
Restituisce un valore keyExpr di MAP mapExpr . |
^ | expr1 ^ expr2 |
Restituisce l'oggetto bit esclusivo OR (XOR) di expr1 e expr2 . |
: | jsonStr : jsonPath |
Restituisce i campi estratti da jsonStr . |
:: | expr :: type |
Esegue il cast del valore expr al tipo di dati di destinazione type . |
?:: | expr ?:: type |
Esegue il cast del valore expr al tipo di dati di destinazione type , se possibile, restituisce NULL in caso contrario. |
div | dividend div divisor |
Restituisce la parte integrante della divisione di dividend per divisor . |
. | mapExpr . keyIdentifier |
Restituisce un valore MAP per keyIdentifier . |
. | structExpr . fieldIdentifier |
Restituisce un campo STRUCT per fieldIdentifier . |
== | expr1 == expr2 |
Restituisce true se expr1 è uguale a expr2 o false in caso contrario. |
= | expr1 = expr2 |
Restituisce true se expr1 è uguale a expr2 o false in caso contrario. |
>= | expr1 >= expr2 |
Restituisce true se expr1 è maggiore o uguale a expr2 , o false in caso contrario. |
> | expr1 > expr2 |
Restituisce true se expr1 è maggiore di expr2 , o false in caso contrario. |
exists | exists(query) |
Restituisce true se query restituisce almeno una riga o false in caso contrario. |
ilike | str [not] ilike (pattern[ESCAPE escape]) |
Restituisce true se str (non) corrisponde a pattern con distinzione tra maiuscole e minuscole escape . |
ilike | str [not] ilike {ANY\|SOME\|ALL}([pattern[, ...]]) |
Restituisce true se str (non) corrisponde a qualsiasi o a tutti gli schemi senza distinzione tra maiuscole o minuscole. |
in | elem [not] in (expr1[, ...]) |
Restituisce true se elem (non) è uguale a qualsiasi exprN . |
in | elem [not] in (query) |
Restituisce true se elem (non) è uguale a qualsiasi riga in query . |
is distinct | expr1 is [not] distinct from expr2 |
Verifica se gli argomenti non dispongono di valori diversi in cui NULL s vengono considerati come valori confrontabili. |
is false | expr is [not] false |
Verifica se expr (non) è false . |
is null | expr is [not] null |
Restituisce true se expr (non) è NULL . |
is true | expr is [not] true |
Verifica se expr (non) è true . |
like | str [not] like (pattern[ESCAPE escape]) |
Restituisce true se str (non) corrisponde a pattern con escape . |
like | str [not] like {ANY\|SOME\|ALL}([pattern[, ...]]) |
Restituisce true se str (non) corrisponde ad alcun criterio o a tutti i criteri. |
<=> | expr1 <=> expr2 |
Restituisce lo stesso risultato di EQUAL(=) per gli operandi non Null, ma restituisce true se entrambi sono NULL , false se uno di essi è NULL . |
<= | expr1 <= expr2 |
Restituisce true se expr1 è minore o uguale a expr2 ; in caso contrario, false . |
<> | expr1 <> expr2 |
Restituisce true se expr1 non è uguale a expr2 , in caso contrario, false . |
< | expr1 < expr2 |
Restituisce true se expr1 è minore di expr2 , in caso contrario false . |
- | expr1 - expr2 |
Restituisce la sottrazione di expr2 da expr1 . |
not | not expr |
Restituisce il NOT logico di un'espressione booleana. |
or | expr1 or expr2 |
Restituisce il OR logico di expr1 e expr2 . |
% | dividend % divisor |
Restituisce il resto dopo dividend / divisor . |
|| | expr1 \|\| expr2 |
Restituisce la concatenazione dei parametri expr1 e expr2 . |
| | expr1 \| expr2 |
Restituisce l'oggetto bit OR di expr1 e expr2 . |
+ | expr1 + expr2 |
Restituisce la somma di expr1 e expr2 . |
regexp | str [not] regexp regex |
Restituisce true se str (non) corrisponde a regex . |
regexp_like | str [not] regexp_like regex |
Restituisce true se str (non) corrisponde a regex . |
rlike | str [not] rlike regex |
Restituisce true se str (non) corrisponde a regex . |
/ | dividend / divisor |
Restituisce dividend diviso per divisor . |
~ | ~ expr |
Restituisce l’oggetto bit NOT di 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 dei parametri expr1 e expr2 . |
aes_decrypt(expr, key[, mode[, padding[, aad]]]) | Decrittografa un expr binario 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 un oggetto expr in una stringa base 64. |
bin(expr) | Restituisce la rappresentazione binaria di expr . |
binary(expr) | Impostare il valore di expr su 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 stringa BINARY 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 una 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 del set di caratteri charSet . |
encode(expr, charSet) | Restituisce la rappresentazione binaria di una stringa utilizzando la codifica dei caratteri charSet . |
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 expr in esadecimale. |
str ilike (pattern[ESCAPE escape]) | Restituisce true se str corrisponde a pattern con distinzione tra maiuscole e minuscole escape . |
initcap(expr) | Restituisce expr con la prima lettera di ogni parola in maiuscolo. |
instr(str, substr) | Restituisce l'indice (basato su 1) della prima occorrenza di substr all'interno di str . |
lcase(expr) | Restituisce expr con tutti i caratteri modificati in minuscolo. |
left(str, len) | Restituisce i caratteri len più a 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 a pattern con 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 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]) | Sostituisce input con replace che 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 modello regexp . |
regexp_extract(str, regexp[, idx]) | Estrae la prima stringa in str che corrisponde all'espressione regexp e corrisponde all'indice del gruppo regex . |
regexp_extract_all(str, regexp[, idx]) | Estrae tutte le stringhe in str che corrispondono all'espressione regexp e corrisponde all'indice del gruppo regex . |
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 a regexp con rep . |
regexp_substr(str, regexp) | Restituisce la prima sottostringa in str che corrisponde a regexp . |
repeat(expr, n) | Restituisce la stringa che ripete i tempi expr n . |
replace(str, search [, replace]) | Sostituire 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 destra len 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]) | Suddivide str 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 spazi n . |
split(str, regex[, limit]) | Suddivide str intorno alle occorrenze che corrispondono a regex e restituisce una matrice con una lunghezza massima di limit . |
split_part(str, delim, partNum) | Divide str intorno alle occorrenze di delim e restituisce la parte partNum . |
startswith(expr, startExpr) | Restituisce true se expr STRING o BINARY inizia con startExpr . |
string(expr) | Impostare il 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 expr prima delle occorrenze count del delimitatore delim . |
to_binary(expr[, fmt]) | Restituisce expr , trasformato in un binario in base a fmt . |
to_char(numExpr, fmt) | Restituisce numExpr impostato su STRING usando la formattazione fmt ". |
to_varchar(numExpr, fmt) | Restituisce numExpr impostato su STRING usando la formattazione fmt ". |
translate(expr, from, to) | Restituisce un expr in cui tutti i caratteri in from sono stati sostituiti con quelli in to . |
trim([[BOTH | LEADING | TRAILING] [trimStr] FROM] str) | Annulla gli spazi dei 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 trasformato in BINARY basato su fmt 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(value) | 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 (value[,level[,streaming_mode]]) | Restituisce il valore compresso con la compressione Zstandard. |
zstd_decompress(value) | Restituisce un valore decompresso con compressione Zstandard. |
Funzioni scalari numeriche
Funzione | Descrizione |
---|---|
~ expr | Restituisce l’oggetto bit NOT di expr . |
dividend / divisor | Restituisce dividend diviso per divisor . |
expr1 | expr2 | Restituisce l'oggetto bit OR di expr1 e expr2 . |
- expr | Restituisce il valore negato di expr . |
expr1 - expr2 | Restituisce la sottrazione di expr2 da expr1 . |
+ expr | Restituisce il valore di expr . |
expr1 + expr2 | Restituisce la somma di expr1 e expr2 . |
dividend % divisor | Restituisce il resto dopo dividend / divisor . |
expr1 ^ expr2 | Restituisce l'oggetto bit esclusivo OR (XOR) di expr1 e expr2 . |
expr1 & expr2 | Restituisce l'oggetto bit AND di expr1 e expr2 . |
multiplier * multiplicand | Restituisce multiplier moltiplicato per multiplicand . |
abs(expr) | Restituisce il valore assoluto del valore numero in expr . |
acos(expr) | Restituisce il coseno inverso (arcocoseno) di expr . |
acosh(expr) | Restituisce il coseno iperbolico inverso di expr . |
asin(expr) | Restituisce il seno inverno (arcsine) 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) | Impostare il valore expr su BIGINT . |
bit_count(expr) | Restituisce il numero di set di bit 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 numero BIGINT all'interno di un bucket. |
bitmap_bucket_number(expr) | Restituisce il numero di bucket bitmap per un determinato numero BIGINT . |
bround(expr[,targetScale]) | Restituisce l'oggetto arrotondato expr utilizzando la modalità di arrotondamento HALF_EVEN . |
cbrt(expr) | Restituisce la radice cubica di expr . |
ceil(expr[,targetScale]) | Restituisce il numero più piccolo non inferiore a expr arrotondato a targetScale cifre rispetto al separatore decimale. |
ceiling(expr[,targetScale]) | Restituisce il numero più piccolo non inferiore a expr 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) | Impostare il valore expr su DECIMAL . |
degrees(expr) | Converte i radianti in gradi. |
divisor div dividend | Restituisce la parte integrante della divisione di divisor per dividend . |
double(expr) | Impostare il valore expr su DOUBLE . |
e() | Restituisce la costante e . |
exp(expr) | Restituisce e alla potenza di expr . |
expm1(expr) | Restituisce exp(expr) - 1 . |
factorial(expr) | Restituisce il fattoriale di expr . |
float(expr) | Impostare il valore expr su FLOAT . |
floor(expr[,targetScale]) | Restituisce il numero più grande non inferiore a expr 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) | Impostare il 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 . |
'nullifzero(expr)' | Restituisce expr se non è zero o NULL in caso contrario. |
pi() | Restituisce pi. |
pmod(dividend, divisor) | Restituisce il resto positivo dopo dividend / divisor . |
positive(expr) | Restituisce il valore di expr . |
pow(expr1, expr2) | Aumenta expr1 alla potenza di expr2 . |
power(expr1, expr2) | Aumenta expr1 alla 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 expr utilizzando la modalità di arrotondamento HALF_UP . |
sec(expr) | Restituisce la secante di expr . |
shiftleft(expr, n) | Restituisce un bitwise spostato a sinistra di n 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 perché expr è negativo, 0 o positivo. |
signum(expr) | Restituisce -1.0, 0.0 o 1.0 perché expr è negativo, 0 o positivo. |
sin(expr) | Restituisce il seno di expr . |
sinh(expr) | Restituisce il seno iperbolico di expr . |
smallint(expr) | Impostare il 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) | Imposta expr a TINYINT . |
to_number(expr, fmt ) | Restituisce expr impostato su DECIMAL usando la formattazione fmt . |
try_add(expr1, expr2) | Restituisce la somma di expr1 e expr2 o NULL in caso di errore. |
try_divide(dividend, divisor) | Restituisce dividend diviso per divisor o NULL se divisor è 0. |
try_mod(dividend, divisor) | Restituisce il resto dopo dividend / divisor o NULL se divisor è 0.. |
try_multiply(multiplier, multiplicand) | 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 trasformando in 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. |
'zeroifnull(expr)' | Restituisce expr se non NULL è o 0 in caso contrario. |
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 una stima del numero di valori distinti di expr nel gruppo. |
approx_percentile(expr,percentage[,accuracy]) | Restituisce il percentile approssimativo di expr nel gruppo. |
approx_top_k(expr[,k[,maxItemsTracked]]) | Restituisce i valori degli elementi più frequenti k in un'area expr con i relativi conteggi approssimativi. |
array_agg(expr) | Restituisce una matrice costituita da tutti i valori in expr nel gruppo. |
avg(expr) | Restituisce la media calcolata dai valori di un gruppo. |
bit_and(expr) | Restituisce il bitwise AND di tutti i valori di input del gruppo. |
bit_or(expr) | Restituisce il bitwise OR di tutti i valori di input del gruppo. |
bit_xor(expr) | Restituisce il bitwise XOR di tutti i valori di input del gruppo. |
bitmap_construct_agg(expr) | Restituisce il bitwise OR di tutti i valori di posizione dei bit nel gruppo. compreso tra 0 e 32767 in un gruppo come BINARY . |
bitmap_or_agg(expr) | Restituisce il bitwise OR di tutti i valori di input BINARY del 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 in expr nel gruppo. |
collect_set(expr) | Restituisce una matrice costituita da tutti i valori unici in expr nel 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 i bin numBins , restituendo una matrice di coppie che rappresentano i centri dei 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. |
kurtosis(expr) | Restituisce il valore della curtosi 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 associato al valore massimo di expr2 in un gruppo. |
mean(expr) | Restituisce la media calcolata dai valori di un gruppo. |
median(expr) | Restituisce la mediana 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 associato al valore minimo di expr2 in un gruppo. |
mode(expr [,deterministic]) | Restituisce il valore di expr più frequente, non NULL , in un gruppo. |
percentile(expr, percentage [,frequency]) | Restituisce il valore del percentile expr nel percentage specificato. |
percentile_approx(expr,percentage[,accuracy]) | Restituisce il percentile approssimativo di expr nel gruppo. |
percentile_cont(pct) WITHIN GROUP (ORDER BY key) | Restituisce il percentile interpolato di key nel gruppo. |
percentile_disc(pct) WITHIN GROUP (ORDER BY key) | Restituisce il percentile discreto di key nel gruppo. |
regr_avgx(yExpr, xExpr) | Restituisce la xExpr calcolata dai valori di un gruppo in cui xExpr e yExpr sono NOT NULL . |
regr_avgy(yExpr, xExpr) | Restituisce la yExpr calcolata dai valori di un gruppo in cui xExpr e yExpr sono NOT NULL . |
regr_count(yExpr, xExpr) | Restituisce il numero di coppie di valori non nulli yExpr , xExpr nel gruppo. |
regr_intercept(yExpr, xExpr) | Restituisce l'intercetta della retta di regressione lineare univariata in un gruppo in cui xExpr e yExpr sono NOT 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 valori xExpr 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 valori yExpr di un gruppo in cui xExpr e yExpr sono NOT NULL. |
schema_of_json_agg(json[, options]) | Restituisce lo schema combinato delle stringhe JSON in un gruppo in formato DDL. |
schema_of_variant_agg(variantExpr) | Restituisce lo schema combinato di tutti i valori VARIANT in un gruppo in formato DDL. |
skewness(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 un valore 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 di 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 ad un offset specifico nella finestra. |
Funzioni di 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(array) | Rimuove i valori NULL da array . |
array_contains(array,value) | Restituisce true se array contiene value . |
array_distinct(array) | 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 array espanso dove elem viene inserito in corrispondenza della posizione index . |
array_intersect(array1,array2) | Restituisce una matrice degli elementi nell'intersezione di array1 e array2 . |
array_join(array,delimiter[,nullReplacement]) | Elementi concatenati di array . |
array_max(array) | Restituisce il valore massimo in array . |
array_min(array) | Restituisce il valore minimo in array . |
array_position(array,element) | Restituisce la posizione della prima occorrenza di element in array . |
array_prepend(array, elem) | Restituisce array preceduto da elem . |
array_remove(array,element) | Rimuove tutte le occorrenze di element da array . |
array_repeat(element,count) | Restituisce una matrice contenente element count . |
array_size(array) | Restituisce il numero di elementi di array . |
array_sort(array,func) | Restituisce array ordinato 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 struct nth contiene tutti i valori Nth delle matrici di input. |
cardinality(expr) | Restituisce la dimensione di expr . |
concat(expr1, expr2 [, …]) | Restituisce una concatenazione degli argomenti. |
element_at(arrayExpr, index) | Restituisce l’elemento di un arrayExpr a index . |
exists(expr, pred) | Restituisce true se pred è true per qualsiasi elemento in expr . |
explode(collection) | Restituisce le righe annullando l'annidamento di collection . |
explode_outer(collection) | Restituisce le righe annullando l'annidamento di 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 la semantica OUTER . |
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 modo 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 arrayExpr in index , o 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 . |
cardinality(expr) | Restituisce la dimensione di expr . |
element_at(mapExpr, key) | Restituisce il valore di mapExpr per key . |
explode(expr) | Restituisce le righe annullando l'annidamento di expr . |
explode_outer(expr) | Restituisce le righe annullando l'annidamento di 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 espressioni della mappa expr . |
map_contains_key(map, key) | Restituisce true se map contiene key , false in caso contrario. |
map_entries(map) | 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(keys, values) | Crea una mappa con una coppia di keys e matrici values . |
map_from_entries(expr) | Crea una mappa creata dalla matrice di voci specificata. |
map_keys(map) | Restituisce una matrice non ordinata contenente le chiavi di map . |
map_values(map) | Restituisce una matrice non ordinata contenente i valori di map . |
map_zip_with(map1, map2, func) | Unisce map1 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, data e ora e intervallo
Per informazioni sui formati di data e ora, vedere Modelli data e ora.
Funzione | Descrizione |
---|---|
intervalExpr / divisor | 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 che è numMonths successiva a startDate . |
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 successiva a 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(days) | Crea una data dal numero di giorni trascorsi da 1970-01-01 . |
date_part(field,expr) | Estrae una parte della data, da data e ora o dell'intervallo. |
date_sub(startDate,numDays) | Restituisce la data numDays precedente a startDate . |
date_trunc(unit,expr) | Restituisce il timestamp troncato all'unità specificata in unit . |
dateadd(startDate,numDays) | Restituisce la data numDays successiva a 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 della data e ora. |
dayofmonth(expr) | Restituisce il giorno del mese della data o della data e ora. |
dayofweek(expr) | Restituisce il giorno della settimana della data o della data e ora. |
dayofyear(expr) | Restituisce il giorno dell'anno della data o della data e ora. |
divisor div dividend | Restituisce la parte integrante della divisione dell'intervallo divisor in base all'intervallo dividend . |
extract(field FROM source) | Restituisce field di source . |
from_unixtime(unixTime,fmt) | Restituisce unixTime in fmt . |
from_utc_timestamp(expr,timezone) | Restituisce il timestamp in corrispondenza UTC di un timestamp expr in timeZone . |
getdate() | Restituisce il timestamp corrente all'inizio della valutazione della query. |
hour(expr) | Restituisce il componente ora di una data e ora. |
last_day(expr) | Restituisce l'ultimo giorno del mese a cui appartiene la data. |
make_date(year,month,day) | Crea una data dai campi year , 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(years, months, weeks, days, hours, mins, secs) | Deprecato: crea un intervallo da years , months , weeks , days , hours , mins e secs . |
make_timestamp(year,month,day,hour,min,sec[,timezone]) | Crea un timestamp dai campi year , month , day , 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 minuti della data e ora in expr . |
month(expr) | Restituisce il componente mese di data e ora in expr . |
months_between(expr1,expr2[,roundOff]) | Restituisce il numero di mesi trascorsi tra date o date e ora 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 della data e ora in expr . |
session_window(expr, gpDuration) | Crea una finestra di sessione in un'espressione data e ora. |
sign(expr) | Restituisce -1,0, 0,0 o 1,0 perché l’intervallo expr è negativo, 0 o positivo. |
signum(expr) | Restituisce -1,0, 0,0 o 1,0 perché l’intervallo expr è negativo, 0 o positivo. |
timediff(unit, start, stop) | Restituisce la differenza tra due timestamp misurati in unit s. |
timestamp(expr) | Imposta expr a TIMESTAMP . |
timestamp_micros(expr) | Crea un timestamp in expr microsecondi dall'epoca UTC. |
timestamp_millis(expr) | Crea un timestamp in 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 impostato si una data usando una formattazione opzionale. |
to_timestamp(expr[,fmt]) | Restituisce expr impostato su un timestamp usando una formattazione opzionale. |
to_unix_timestamp(expr[,fmt]) | Restituisce il timestamp in expr come timestamp UNIX. |
to_utc_timestamp(expr,timezone) | Restituisce il timestamp in corrispondenza UTC di un timestamp expr in timezone . |
trunc(expr, fmt) | Restituisce una data con la parte della data troncata all'unità specificata dal modello di formato fmt . |
try_add(expr1, expr2) | Restituisce la somma di expr1 e expr2 o NULL in caso di errore. |
try_divide(dividend, divisor) | Restituisce dividend diviso per divisor o NULL se divisor è 0. |
try_multiply(multiplier, multiplicand) | 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 impostato su un timestamp usando una formattazione opzionale o NULL se la trasmissione fallisce. |
unix_date(expr) | Restituisce il numero di giorni trascorsi da 1970-01-01 . |
unix_micros(expr) | Restituisce il numero di microsecondi trascorsi da 1970-01-01 00:00:00 UTC . |
unix_millis(expr) | Restituisce il numero di millisecondi trascorsi 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]]) | Restituisce 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 anno di expr . |
window(expr, width[, step[, start]]) | Crea una finestra scorrevole a salti basata su un'espressione timestamp. |
window_time(window) | 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) | Impostare il valore expr su BIGINT . |
binary(expr) | Impostare il valore di expr su BINARY . |
boolean(expr) | Imposta expr a BOOLEAN . |
cast(expr AS type) | Esegue il cast del valore expr al tipo di dati di destinazione type . |
expr :: type | Esegue il cast del valore expr al tipo di dati di destinazione type . |
date(expr) | Impostare il valore expr su DATE . |
decimal(expr) | Impostare il valore expr su DECIMAL . |
double(expr) | Impostare il valore expr su DOUBLE . |
float(expr) | Impostare il valore expr su FLOAT . |
int(expr) | Impostare il valore expr su INTEGER . |
make_date(year,month,day) | Crea una data dai campi year , 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(years, months, weeks, days, hours, mins, secs) | Crea un intervallo da years , months , weeks , days , hours , mins e secs . |
make_timestamp(year,month,day,hour,min,sec[,timezone]) | Crea un timestamp dai campi year , month , day , 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 una struttura con i nomi e i valori di campo specificati. |
smallint(expr) | Impostare il valore expr su SMALLINT . |
string(expr) | Impostare il valore expr su STRING . |
struct(expr1 [, …]) | Crea un STRUCT con i valori di campo specificati. |
tinyint(expr) | Imposta expr a TINYINT . |
timestamp(expr) | Imposta expr a TIMESTAMP . |
to_char(expr, fmt) | Restituisce expr impostato su STRING usando la formattazione fmt ". |
to_date(expr[,fmt]) | Restituisce expr impostato si una data usando una formattazione opzionale. |
to_number(expr, fmt) | Restituisce expr impostato su DECIMA L usando la formattazione fmt . |
to_timestamp(expr[,fmt]) | Restituisce expr impostato su un timestamp usando una formattazione opzionale. |
to_varchar(expr, fmt) | Restituisce expr impostato su STRING usando la formattazione fmt ". |
try_cast(expr AS type) | Imposta il valore expr nel tipo di dati di destinazione type in modo sicuro. |
try_to_number(expr, fmt) | Restituisce expr impostato su DECIMAL usando la formattazione fmt , o NULL se expr non è valido. |
Funzioni CSV e Avro
Funzione | Descrizione |
---|---|
from_avro(avroBin, jsonSchema[, options]) | Restituisce un valore di struct basato su avroBin e jsonSchema . |
from_csv(csvStr, schema[, options]) | Restituisce un valore struct con csvStr e schema . |
schema_of_csv(csv[, options]) | Restituisce lo schema di una stringa CSV in formato DDL. |
to_avro(expr[, options]) | Restituisce un valore binario Avro con il valore dello struct specificato. |
to_csv(expr[, options]) | Restituisce una stringa CSV con il valore struct specificato. |
Funzioni JSON
Funzione | Descrizione |
---|---|
jsonStr : jsonPath | Restituisce i campi estratti da jsonStr . |
from_json(jsonStr, schema[, options]) | Restituisce un valore struct con jsonStr e schema . |
get_json_object(expr, path) | Estrae un oggetto JSON da path . |
json_array_length(jsonArray) | Restituisce il numero di elementi nella matrice JSON più esterna. |
json_object_keys(jsonObject) | Restituisce tutte le chiavi dell'oggetto più esterno JSON come matrice. |
json_tuple(jsonStr, path1 [, …]) | Restituisce più oggetti JSON come tupla. |
parse_json(jsonStr) | Restituisce un valore VARIANT da jsonStr . |
schema_of_json(jsonStr[, options]) | Restituisce lo schema di una stringa JSON in formato DDL. |
schema_of_json_agg(jsonStr[, options]) | Restituisce lo schema combinato delle stringhe JSON in un gruppo in formato DDL. |
to_json(expr[, options]) | Restituisce una stringa JSON con STRUCT o VARIANT specificata in expr . |
Funzioni VARIANT
Funzione | Descrizione |
---|---|
variantExpr : jsonPath | Restituisce i campi estratti da variantExpr usando il percorso JSON. |
is_variant_null(variantExpr) | Verifica se variantExpr è un VARIANT con codifica NULL . |
parse_json(jsonStr) | Restituisce un valore VARIANT 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 valori VARIANT in un gruppo in formato DDL. |
to_json(expr[, options]) | Restituisce una stringa JSON con STRUCT o VARIANT specificata in expr . |
try_parse_json(jsonStr) | Restituisce un valore VARIANT da jsonStr , se possibile. Se non è possibile, NULL viene restituito . |
try_variant_get(variantExpr,path,type) | Estrae un valore di tipo type 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 di variantExpr . |
variant_explode_outer(variantExpr) | Restituisce un set di righe annullando l'annidamento di variantExpr utilizzando la semantica esterna. |
variant_get(variantExpr,path,type) | Estrae un valore di tipo type da variantExpr , specificato da path . |
Funzioni XPath e XML
Funzione | Descrizione |
---|---|
from_xml(xmlStr, schema[, options]) | Restituisce un valore struct analizzato da xmlStr utilizzando schema . |
schema_of_xml(xmlStr[, options]) | Restituisce lo schema di una stringa XML 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 valore DOUBLE da un documento XML. |
xpath_float(xml, xpath) | Restituisce un valore FLOAT da un documento XML. |
xpath_int(xml, xpath) | Restituisce un valore INTEGER da un documento XML. |
xpath_long(xml, xpath) | Restituisce un valore BIGINT da un documento XML. |
xpath_number(xml, xpath) | Restituisce un valore DOUBLE da un documento XML. |
xpath_short(xml, xpath) | Restituisce un valore SHORT 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(content, labels) | 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(observed, time_col) | Estrapola i dati delle serie temporali in futuro. |
ai_gen(content) | 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. |
Funzioni Read
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 letti da Kinesis 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. |
Azioni varie
Funzione | Descrizione |
---|---|
assert_true(expr) | Restituisce un errore se expr non è true. |
CASE expr { WHEN opt1 THEN res1 } […] [ELSE def] END | Restituisce resN per il primo optN uguale a expr o def se nessuna corrisponde. |
CASE { WHEN cond1 THEN res1 } […] [ELSE def] END | Restituisce resN per il primo condN che restituisce true o def se non viene trovato alcun valore. |
cloud_files_state( { TABLE(table) | checkpoint } ) | Restituisce lo stato a livello di file di un'origine del caricatore automatico cloud_files . |
coalesce(expr1, expr2 [, …]) | Restituisce il primo argomento non Null. |
cube (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 un’espressione nth. |
equal_null(expr1, expr2) | Restituisce true se expr1 è uguale a expr2 o entrambe le espressioni sono NULL , o false in caso contrario. |
event_log( { TABLE(table) | pipeline_id } ) | Restituisce una tabella della cronologia degli aggiornamenti per una vista materializzata, una tabella di streaming o una pipeline DLT. |
greatest(expr1, expr2 [, …]) | Restituisce il valore più grande di tutti gli argomenti, ignorando i valori Null. |
grouping(col) | Indica se una colonna specificata in GROUPING SET , 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 [, ...]]) | Richiama un metodo con riflessione. |
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(group) | 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 è uguale a expr2 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 [, …]]) | Richiama un metodo con riflessione. |
secret(scope, key) | Estrae un valore segreto con il scope 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 [, ...]) | Separa expr1 , ..., 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 riflessione, restituendo NULL se il metodo ha esito negativo. |
try_secret(scope, key) | 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 scorrevole a salti basata su un'espressione timestamp. |
xxhash64(expr1 [, …]) | Restituisce un valore con hash a 64 bit degli argomenti. |
version() | Restituisce la versione di Apache Spark. |