Realtime Compute for Apache Flink：Fungsi yang Didukung

Kategori

Fungsi

Deskripsi

Fungsi Perbandingan

value1 = value2

Mengembalikan true jika value1 sama dengan value2.

value1 <> value2

Mengembalikan true jika value1 tidak sama dengan value2.

value1 > value2

Mengembalikan true jika value1 lebih besar dari value2.

value1 >= value2

Mengembalikan true jika value1 lebih besar dari atau sama dengan value2.

value1 < value2

Mengembalikan true jika value1 kurang dari value2.

value1 <= value2

Mengembalikan true jika value1 kurang dari atau sama dengan value2.

value IS NULL

Mengembalikan true jika nilai tersebut adalah NULL.

value IS NOT NULL

Mengembalikan true jika nilai tersebut bukan NULL.

value1 IS DISTINCT FROM value2

Mengembalikan true jika tipe data atau nilai value1 dan value2 berbeda. Semua nilai NULL dianggap sama.

value1 IS NOT DISTINCT FROM value2

Mengembalikan true jika tipe data dan nilai value1 dan value2 sama. Semua nilai NULL dianggap sama.

value1 BETWEEN [ ASYMMETRIC | SYMMETRIC ] value2 AND value3

Mengembalikan true secara default atau ketika kata kunci ASYMMETRIC digunakan jika kondisi berikut terpenuhi: value1 lebih besar dari atau sama dengan value2 dan kurang dari atau sama dengan value3.

value1 NOT BETWEEN [ ASYMMETRIC | SYMMETRIC ] value2 AND value3

Mengembalikan true secara default atau ketika kata kunci ASYMMETRIC digunakan jika kondisi berikut terpenuhi: value1 kurang dari value2 atau lebih besar dari value3.

string1 LIKE string2 [ ESCAPE char ]

Mengembalikan true jika string1 cocok dengan string2.

string1 NOT LIKE string2 [ ESCAPE char ]

Mengembalikan true jika string1 tidak cocok dengan string2.

string1 SIMILAR TO string2 [ ESCAPE char ]

Mengembalikan true jika string1 cocok dengan ekspresi reguler SQL string2.

string1 NOT SIMILAR TO string2 [ ESCAPE char ]

Mengembalikan true jika string1 tidak cocok dengan ekspresi reguler SQL string2.

value1 IN (value2 [, value3]* )

Mengembalikan true jika value1 ada dalam daftar nilai (value2, value3, …).

value1 NOT IN (value2 [, value3]* )

Mengembalikan true jika value1 tidak ada dalam daftar nilai (value2, value3, …).

EXISTS (sub-query)

Mengembalikan true jika setidaknya satu baris data dikembalikan untuk subquery.

value IN (sub-query)

Mengembalikan true jika nilai tersebut sama dengan satu baris data dalam hasil set subquery.

value NOT IN (sub-query)

Mengembalikan true jika nilai tersebut tidak termasuk dalam baris data yang dikembalikan oleh subquery.

Fungsi logika

BITAND

Menjalankan operasi bitwise AND.

BITNOT

Menjalankan operasi bitwise NOT.

BITOR

Menjalankan operasi bitwise OR.

BITXOR

Menjalankan operasi bitwise XOR.

boolean1 OR boolean2

Mengembalikan true jika boolean1 atau boolean2 bernilai true.

boolean1 AND boolean2

Mengembalikan true jika boolean1 dan boolean2 bernilai true.

NOT boolean

Mengembalikan true jika boolean bernilai false. Mengembalikan false jika boolean bernilai true. Mengembalikan unknown jika boolean bernilai unknown.

boolean IS FALSE

Mengembalikan true jika boolean bernilai false. Mengembalikan false jika boolean bernilai true atau unknown.

boolean IS NOT FALSE

Mengembalikan true jika boolean bernilai true atau unknown. Mengembalikan false jika boolean bernilai false.

boolean IS TRUE

Mengembalikan true jika boolean bernilai true. Mengembalikan false jika boolean bernilai false atau unknown.

boolean IS NOT TRUE

Mengembalikan true jika boolean bernilai false atau unknown. Mengembalikan false jika boolean bernilai true.

boolean IS UNKNOWN

Mengembalikan true jika boolean bernilai unknown. Mengembalikan false jika boolean bernilai true atau false.

boolean IS NOT UNKNOWN

Mengembalikan true jika boolean bernilai true atau false. Mengembalikan false jika boolean bernilai unknown.

Fungsi aritmetika

+ numeric

Mengembalikan nilai numerik.

- numeric

Mengembalikan nilai yang berlawanan dengan nilai numerik.

numeric1 + numeric2

Mengembalikan jumlah dari numeric1 dan numeric2.

numeric1 - numeric2

Mengembalikan selisih dari numeric1 dan numeric2.

numeric1 * numberic2

Mengembalikan produk dari numeric1 dikalikan dengan numeric2.

numeric1 / numeric2

Mengembalikan hasil bagi dari numeric1 dibagi dengan numeric2.

numeric1 % numeric2

Mengembalikan sisa dari numeric1 dibagi dengan numeric2.

POWER(numeric1, numeric2)

Mengembalikan nilai numeric1 dipangkatkan numeric2.

ABS(numeric)

Mengembalikan nilai absolut dari nilai numerik.

SQRT(numeric)

Mengembalikan akar kuadrat dari nilai numerik.

LN(numeric)

Mengembalikan logaritma natural dari nilai numerik dengan basis e.

LOG10(numeric)

Mengembalikan logaritma natural dari nilai numerik dengan basis 10.

LOG2(numeric)

Mengembalikan logaritma natural dari nilai numerik dengan basis 2.

LOG(numeric2) LOG(numeric1, numeric2)

Mengembalikan logaritma natural dari numeric2 jika satu parameter input dipanggil. Mengembalikan logaritma natural dari numeric2 dengan basis numeric1 jika dua parameter input dipanggil. Nilai numeric2 harus lebih besar dari 0 dan nilai numeric1 harus lebih besar dari 1.

EXP(numeric)

Mengembalikan hasil dari e dipangkatkan numeric.

CEIL(numeric) CEILING(numeric)

Membulatkan angka ke atas dan mengembalikan bilangan bulat terkecil yang lebih besar dari atau sama dengan numeric.

FLOOR(numeric)

Membulatkan angka ke bawah dan mengembalikan bilangan bulat terbesar yang lebih kecil dari atau sama dengan numeric.

SIN(numeric)

Mengembalikan sinus dari nilai numerik.

SINH(numeric)

Mengembalikan sinus hiperbolik dari nilai numerik. Nilai yang dikembalikan adalah tipe data DOUBLE.

COS(numeric)

Mengembalikan kosinus dari nilai numerik.

TAN(numeric)

Mengembalikan nilai tangen dari nilai numerik.

TANH(numeric)

Mengembalikan nilai tangen hiperbolik dari nilai numerik. Nilai yang dikembalikan adalah tipe data DOUBLE.

COT(numeric)

Mengembalikan kotangen dari nilai numerik.

ASIN(numeric)

Mengembalikan arcsinus dari nilai numerik.

ACOS(numeric)

Mengembalikan arccosinus dari nilai numerik.

ATAN(numeric)

Mengembalikan arctangen dari nilai numerik.

ATAN2(numeric1, numeric2)

Mengembalikan arctangen dari koordinat (numeric1, numeric2).

COSH(numeric)

Mengembalikan kosinus hiperbolik dari nilai numerik. Nilai yang dikembalikan adalah tipe data DOUBLE.

DEGREES(numeric)

Mengembalikan derajat dari radian numeric.

RADIANS(numeric)

Mengembalikan radian dari derajat numeric.

SIGN(numeric)

Mengembalikan tanda dari nilai numerik.

ROUND(numeric, INT)

Mengembalikan nilai yang dibulatkan ke jumlah tempat desimal yang ditentukan oleh INT untuk nilai numerik.

PI()

Mengembalikan nilai yang sangat mendekati pi.

E()

Mengembalikan nilai yang sangat mendekati e.

RAND()

Mengembalikan nilai pseudorandom presisi ganda dalam rentang [0.0, 1.0).

RAND(INT)

Mengembalikan nilai pseudorandom presisi ganda dalam rentang [0.0, 1.0) dengan seed awal INT.

RAND_INTEGER(INT)

Mengembalikan integer pseudorandom dalam rentang [0, INT).

RAND_INTEGER(INT1,INT2)

Mengembalikan integer pseudorandom dalam rentang [0, INT2) dengan seed awal INT1.

UUID()

Mengembalikan string Universally Unique Identifier (UUID) berdasarkan RFC 4122 Tipe 4. String UUID dihasilkan secara pseudorandom.

BIN(INT)

Mengembalikan nilai INTEGER dalam format biner.

HEX(numeric) HEX(string)

Mengembalikan nilai numerik integer atau string dalam format heksadesimal.

TRUNCATE(numeric1, integer2)

Mengembalikan angka yang dipotong ke jumlah tempat desimal yang ditentukan oleh integer2.

UNHEX(expr)

Mengonversi ekspresi string heksadesimal menjadi BINARY.

PERCENTILE(expr, percentage[, frequency])

Mengembalikan nilai persentil tepat dari expr pada persentase yang ditentukan.

Fungsi String

string1 || string2

Mengembalikan hasil penggabungan dari string1 dan string2.

CHAR_LENGTH(string) CHARACTER_LENGTH(string)

Mengembalikan jumlah karakter dalam string.

UPPER(string)

Mengembalikan string dalam huruf kapital.

LOWER(string)

Mengembalikan string dalam huruf kecil.

POSITION(string1 IN string2)

Mengembalikan posisi kemunculan pertama dari string1 di dalam string2, dengan posisi dimulai dari 1. Jika string1 tidak ditemukan di dalam string2, nilai yang dikembalikan adalah 0.

TRIM([ BOTH | LEADING | TRAILING ] string1 FROM string2)

Menghapus string yang dimulai, diakhiri, atau dimulai dan diakhiri dengan string1 dari string2, lalu mengembalikan hasilnya.

Fungsi ini menghapus semua karakter di akhir string hingga ditemukan karakter yang tidak termasuk dalam parameter TRAILING. Sebagai contoh, TRIM(TRAILING 'fe' from 'abcdef') mengembalikan abcd.

LTRIM(string)

Menghapus spasi di bagian kiri string.

RTRIM(string)

Menghapus spasi di bagian kanan string.

REPEAT(string, int)

Mengembalikan string yang mengulang string tertentu sebanyak jumlah yang ditentukan oleh integer.

REGEXP_REPLACE

Mengganti string yang ditentukan dengan string yang diinginkan dan mengembalikan string baru.

OVERLAY(string1 PLACING string2 FROM integer1 [ FOR integer2 ])

Mengganti sejumlah total integer2 karakter di string1 dengan string2, dimulai dari posisi yang ditentukan oleh integer1, dan mengembalikan string baru. Secara default, integer2 menunjukkan panjang dari string2.

SUBSTRING(string FROM integer1 [FOR integer2 ])

Mengembalikan substring yang dimulai dari posisi integer1 dalam sebuah string dengan panjang yang ditentukan oleh integer2. Secara default, integer2 menentukan panjang dari posisi integer1 hingga akhir string.

REPLACE(string1, string2, string3)

Mengganti semua kemunculan string2 dengan string3 di dalam string1 dan mengembalikan string baru. Pastikan string2 dan string3 tidak tumpang tindih.

REGEXP_EXTRACT(string1, string2[, integer])

Memisahkan string1 berdasarkan ekspresi reguler dari string2 dan mengembalikan string pada posisi yang ditentukan oleh integer.

INITCAP(string)

Mengonversi string menjadi format di mana huruf pertama setiap kata menggunakan huruf besar, sementara huruf lainnya menggunakan huruf kecil. Setiap kata dalam string merupakan urutan karakter alfanumerik.

CONCAT(string1, string2, ...)

Menggabungkan beberapa string dan mengembalikan string baru. Jika parameter input bernilai NULL, maka hasilnya juga akan mengembalikan NULL.

CONCAT_WS(string1, string2, string3, ...)

Mengembalikan string hasil penggabungan string2, string3, … menggunakan pemisah yang ditentukan oleh string1.

LPAD(string1, integer, string2)

Menambahkan string1 di sebelah kiri dengan string2 hingga mencapai panjang yang ditentukan oleh integer.

RPAD(string1, integer, string2)

Isi string1 dengan string2 di sebelah kanan hingga mencapai panjang yang ditentukan oleh integer.

FROM_BASE64(string)

Mendekode string1 menggunakan algoritma Base64.

TO_BASE64(string)

Mengkodekan string1 menggunakan algoritma Base64.

ASCII(string)

Mengembalikan kode ASCII karakter pertama dalam sebuah string.

CHR(integer)

Mengembalikan karakter ASCII dengan nilai biner yang sesuai dengan nilai integer yang ditentukan.

DECODE(binary, string)

Mendekode string dalam format pengkodean tertentu, seperti US-ASCII, ISO-8859-1, UTF-8, UTF-16BE, UTF-16LE, atau UTF-16.

ENCODE(string1, string2)

Mengkodekan string ke dalam format pengkodean tertentu, seperti US-ASCII, ISO-8859-1, UTF-8, UTF-16BE, UTF-16LE, atau UTF-16.

INSTR(string1, string2)

Mengembalikan posisi kemunculan pertama dari string2 di dalam string1.

LEFT(string, integer)

Mengembalikan karakter paling kiri dengan panjang integer dari suatu string.

RIGHT(string, integer)

Mengembalikan karakter paling kanan dengan panjang integer dari suatu string.

LOCATE(string1, string2[, integer])

Mengembalikan posisi kemunculan pertama dari string1 di string2 setelah posisi yang ditentukan oleh integer.

PARSE_URL

Menguraikan bagian tertentu dari URL dan mengembalikan nilai yang dihasilkan.

REGEXP

Mencari string tertentu menggunakan ekspresi reguler dan mengembalikan nilai Boolean berdasarkan hasil pencarian.

REGEXP_SUBSTR(str, regex)

Mengembalikan substring pertama dalam str yang cocok dengan regex.

REGEXP_INSTR(str, regex)

Mengembalikan posisi substring pertama dalam str yang cocok dengan regex.

REGEXP_COUNT(str, regex)

Mengembalikan jumlah kali str cocok dengan pola regex.

REGEXP_EXTRACT_ALL(str, regex[, extractIndex])

Mengekstrak semua substring dalam str yang cocok dengan ekspresi regex dan sesuai dengan grup regex extractIndex.

REVERSE(string)

Mengembalikan string dalam urutan terbalik.

SPLIT_INDEX

Memisahkan string menjadi beberapa segmen berdasarkan pemisah tertentu dan mengembalikan bidang pada posisi yang ditentukan.

STR_TO_MAP(string1[, string2, string3])

Memisahkan string1 menjadi pasangan kunci-nilai menggunakan pembatas dan mengembalikan peta.

SUBSTR(string[, integer1[, integer2]])

Mengembalikan substring yang dimulai dari posisi integer1 dalam sebuah string, dengan panjang yang ditentukan oleh integer2.

PRINTF(format[, obj]*)

Mengembalikan string terformat dari string format bergaya printf.

TRANSLATE(expr, fromStr, toStr)

Menerjemahkan ekspresi di mana semua karakter dalam fromStr diganti dengan yang ada di toStr.

ELT(index, expr[, exprs]*)

Mengembalikan ekspresi ke-index. index harus berupa bilangan bulat antara 1 dan jumlah ekspresi.

BTRIM(str[, trimStr])

Menghapus karakter awal dan akhir apa pun dalam trimStr dari str. trimStr diatur ke spasi putih secara default.

STARTSWITH(expr, startExpr)

Mengembalikan apakah expr diawali dengan startExpr. Jika startExpr kosong, hasilnya adalah true.

ENDSWITH(expr, endExpr)

Mengembalikan apakah expr diakhiri dengan endExpr. Jika endExpr kosong, hasilnya adalah true.

Fungsi Waktu

DATE string

Mengembalikan nilai tanggal dalam SQL yang diuraikan dari string dengan format yyyy-MM-dd.

DATEDIFF

Menghitung selisih antara dua nilai tanggal.

DATE_ADD

Mengembalikan nilai tanggal yang merupakan jumlah hari tertentu setelah tanggal tertentu.

DATE_SUB

Mengembalikan tanggal yang merupakan jumlah hari tertentu sebelum tanggal yang ditentukan.

TIME string

Mengembalikan nilai waktu SQL yang diurai dari string dalam format HH:mm:ss.

TIMESTAMP string

Mengembalikan timestamp SQL yang diurai dari string dalam format yyyy-MM-dd HH:mm:ss[.SSS].

INTERVAL string range

Menguraikan interval dalam milidetik di SQL dari string berformat dd hh:mm:ss.fff atau menguraikan interval dalam bulan di SQL dari string berformat yyyy-mm.

LOCALTIME

Mengembalikan waktu saat ini dalam SQL berdasarkan zona waktu lokal. Nilai yang dikembalikan bertipe TIME(0).

LOCALTIMESTAMP

Mengembalikan waktu saat ini dalam SQL sesuai zona waktu lokal. Nilai yang dikembalikan bertipe TIMESTAMP(3).

CURRENT_TIME

Mengembalikan waktu saat ini dalam SQL pada zona waktu lokal. Fungsi ini setara dengan LOCAL_TIME.

CURRENT_DATE

Mengembalikan waktu saat ini dalam SQL di zona waktu lokal. Nilai yang dikembalikan adalah tipe TIME(0).

CURRENT_TIMESTAMP

Mengembalikan waktu saat ini dalam SQL di zona waktu lokal. Nilai yang dikembalikan adalah tipe TIMESTAMP(3).

NOW()

Mengembalikan waktu saat ini dalam SQL di zona waktu lokal. Fungsi ini setara dengan fungsi LOCAL_TIME.

CURRENT_ROW_TIMESTAMP()

Mengembalikan tanggal saat ini dalam SQL di zona waktu lokal.

EXTRACT(timeintervalunit FROM temporal)

Mengembalikan nilai tipe data LONG yang diekstraksi dari unit interval waktu temporal.

YEAR(date)

Mengembalikan tahun dari nilai tanggal dalam SQL.

QUARTER(date)

Mengembalikan kuartal tempat nilai tanggal dalam SQL berada.

MONTH(date)

Mengembalikan bulan dari nilai tanggal dalam SQL.

WEEK(date)

Mengembalikan nomor urut minggu dalam tahun berdasarkan nilai tanggal dalam SQL.

DAYOFYEAR(date)

Mengembalikan nomor urut hari dalam tahun berdasarkan nilai tanggal dalam SQL.

DAYOFMONTH

Mengembalikan nomor urut hari dalam bulan untuk nilai tanggal di SQL.

HOUR(timestamp)

Mengembalikan komponen jam dari cap waktu dalam SQL.

MINUTE(timestamp)

Mengembalikan komponen menit dari cap waktu dalam SQL.

SECOND(timestamp)

Mengembalikan komponen detik dari cap waktu dalam SQL.

FLOOR(timepoint TO timeintervalunit)

Mengembalikan nilai yang membulatkan ke bawah suatu titik waktu ke satuan waktu yang ditentukan oleh timeintervalunit.

CEIL(timespoint TO timeintervalunit)

Mengembalikan nilai yang membulatkan waktu ke atas hingga satuan waktu yang ditentukan oleh timeintervalunit.

(timepoint1, temporal1) OVERLAPS (timepoint2, temporal2)

Mengembalikan true jika dua interval waktu yang didefinisikan oleh (timepoint1, temporal1) dan (timepoint2, temporal2) saling tumpang tindih.

DATE_FORMAT

Mengonversi nilai tanggal dari tipe data STRING ke format yang ditentukan.

DATE_FORMAT_TZ

Mengonversi data tipe TIMESTAMP menjadi string dengan format tertentu berdasarkan zona waktu yang ditentukan.

TIMESTAMPADD(timeintervalunit, interval, timepoint)

Mengembalikan titik waktu baru dengan menambahkan periode waktu ke titik waktu tertentu. Periode waktu dihitung berdasarkan timeintervalunit dikalikan dengan interval.

TIMESTAMPDIFF(timepointunit, timepoint1, timepoint2)

Mengembalikan durasi waktu antara timepoint1 dan timepoint2.

CONVERT_TZ(string1, string2, string3)

Mengonversi string datetime1 dari zona waktu string2 ke zona waktu string3. String datetime1 menggunakan format timestamp ISO default yyyy-MM-dd HH:mm:ss.

FROM_UNIXTIME

Mengembalikan nilai tanggal dari tipe data VARCHAR.

UNIX_TIMESTAMP

Mengonversi nilai tanggal menjadi stempel waktu UNIX.

TO_DATE

Mengonversi nilai tanggal dari tipe data INT atau VARCHAR ke tipe data DATE.

TO_TIMESTAMP_LTZ(numeric, presisi)

Mengonversi waktu menjadi nilai tipe data TIMESTAMP_LTZ. Waktu tersebut merupakan timestamp UNIX dengan satuan: milidetik atau detik.

TO_TIMESTAMP(string1[, string2])

Mengonversi string1 dalam format string2 di zona waktu UTC+0 menjadi timestamp. Secara default, format yang ditentukan oleh string2 adalah yyyy-MM-dd HH:mm:ss.

TO_TIMESTAMP_TZ

Mengonversi nilai tanggal dari tipe data VARCHAR ke tipe data TIMESTAMP berdasarkan zona waktu yang ditentukan.

CURRENT_WATERMARK(rowtime)

Mengembalikan watermark saat ini untuk kolom waktu yang ditentukan oleh rowtime.

Fungsi bersyarat

CASE value WHEN value1_1 [, value1_2]* THEN RESULT1 (WHEN value2_1 [, value2_2 ]* THEN result_2)* (ELSE result_z) END

Mengembalikan resultX jika nilai pertama cocok dengan daftar nilai (valueX_1, valueX_2, …).

CASE WHEN condition1 THEN result1 (WHEN condition2 THEN result2)* (ELSE result_z) END

Mengembalikan resultX ketika kondisi pertama X terpenuhi.

NULLIF(value1,value2)

Mengembalikan NULL jika value1 sama dengan value2. Mengembalikan value1 jika value1 tidak sama dengan value2.

COALESCE(value1,value2 [, value3]*)

Mengembalikan nilai non-NULL pertama dari value1, value2, ….

IF(kondisi,nilai_benar, nilai_salah)

Mengembalikan true_value jika kondisi terpenuhi. Mengembalikan false_value jika kondisi tidak terpenuhi.

IFNULL(input,null_replacement)

Mengembalikan null_replacement jika parameter input adalah NULL. Mengembalikan parameter input jika parameter input tidak NULL.

IS_ALPHA(string)

Mengembalikan true jika semua karakter dalam string adalah huruf. Mengembalikan false jika ada karakter dalam string yang bukan huruf.

IS_DECIMAL(string)

Mengembalikan true jika string dapat diurai menjadi angka yang valid. Mengembalikan false jika string tidak dapat diurai menjadi angka yang valid.

IS_DIGIT(string)

Mengembalikan true jika semua karakter dalam string adalah digit. Mengembalikan false jika ada karakter dalam string yang bukan digit.

GREATEST(value1[,value2]*)

Mengembalikan nilai maksimum dari parameter input. Mengembalikan NULL jika parameter input diatur ke NULL.

LEAST(value1[,value2]*)

Mengembalikan nilai minimum dari parameter input. Mengembalikan NULL jika parameter input diatur ke NULL.

Fungsi konversi tipe data

CONV

Menjalankan konversi basis pada nilai numerik atau karakter.

CAST(value AS type)

Mengembalikan nilai baru yang dikonversi ke tipe.

TYPEOF(input) | TYPEOF(input, force_serializable)

Mengembalikan representasi string dari tipe data ekspresi input.

Fungsi koleksi

CARDINALITY(array)

Mengembalikan jumlah elemen dalam array.

array '[' INT ']'

Mengembalikan elemen pada posisi yang ditentukan oleh INT dalam array.

ELEMENT(array)

Mengembalikan satu-satunya elemen dari array yang kardinalitasnya 1.

CARDINALITY(map)

Mengembalikan jumlah entri dalam map.

map'[' value ']'

Mengembalikan nilai yang sesuai dengan kunci yang ditentukan dalam map.

Fungsi JSON

IS JSON [ { VALUE | SCALAR | ARRAY | OBJECT } ]

Menentukan apakah string yang diberikan adalah string JSON yang valid.

JSON_EXISTS(jsonValue, path [ { TRUE | FALSE | UNKNOWN | ERROR } ON ERROR ])

Menentukan apakah string JSON memenuhi kriteria pencarian jalur yang diberikan.

JSON_STRING(value)

Menserialisasi nilai menjadi string JSON yang berisi nilai yang diserialisasi.

JSON_VALUE

Mengekstrak ekspresi jalur yang ditentukan dari string JSON.

JSON_QUERY(jsonValue, path [ { WITHOUT | WITH CONDITIONAL | WITH UNCONDITIONAL } [ ARRAY ] WRAPPER ] [ { NULL | EMPTY ARRAY | EMPTY OBJECT | ERROR } ON EMPTY ] [ { NULL | EMPTY ARRAY | EMPTY OBJECT | ERROR } ON ERROR ])

Mengekstrak nilai JSON dari string JSON.

JSON_OBJECT([[KEY] key VALUE value]* [ { NULL | ABSENT } ON NULL ])

Membuat objek JSON dari daftar pasangan key-value.

JSON_OBJECTAGG([KEY] key VALUE value [ { NULL | ABSENT } ON NULL ])

Menggabungkan ekspresi key-value menjadi objek JSON.

JSON_ARRAY([value]* [ { NULL | ABSENT } ON NULL ])

Membuat array JSON dari daftar nilai.

JSON_ARRAYAGG(items [ { NULL | ABSENT } ON NULL ])

Membuat objek JSON dengan menggabungkan items menjadi array.

JSON_QUOTE

Mengutip string sebagai nilai JSON dengan membungkusnya dengan karakter tanda kutip ganda.

JSON_UNQUOTE

Membatalkan kutipan nilai JSON.

Fungsi konstruksi nilai

-- implicit constructor with parenthesis (value1 [, value2]*)

Mengembalikan baris data yang dibuat dari daftar nilai (value1, value2, …).

ARRAY '['value1 [, value2 ]* ']'

Mengembalikan array yang dibuat dari daftar nilai (value1, value2, …).

MAP '['value1, value2 [, value3, value4 ]* ']'

Mengembalikan map yang dibuat dari daftar pasangan key-value ((value1, value2), (value3, value4), …).

Fungsi pengambilan nilai

tableName.compositeType.field

Ekstrak nilai bidang tipe data komposit Flink, seperti Tuple atau POJO, berdasarkan nama.

tableName.compositeType.*

Mengonversi subtipe tipe data komposit Flink, seperti Tuple atau POJO, menjadi bidang terpisah.

Fungsi pengelompokan

GROUP_ID()

Mengembalikan integer yang secara unik mengidentifikasi kombinasi kunci pengelompokan.

GROUPING(expression1 [, expression2]* ) | GROUPING_ID(expression1 [, expression2]* )

Mengembalikan vektor bit dari ekspresi pengelompokan yang diberikan.

Fungsi hash

MD5(string)

Mengembalikan nilai hash MD5 dari string dalam format string 32 digit heksadesimal.

SHA1(string)

Mengembalikan nilai hash SHA-1 dari string dalam format string 40 digit heksadesimal.

SHA224(string)

Mengembalikan nilai hash SHA-224 dari string dalam format string 56 digit heksadesimal.

SHA256(string)

Mengembalikan nilai hash SHA-256 dari string dalam format string 64 digit heksadesimal.

SHA384(string)

Mengembalikan nilai hash SHA-384 dari string dalam format string 96 digit heksadesimal.

SHA512(string)

Mengembalikan nilai hash SHA-512 dari string dalam format string 128 digit heksadesimal.

SHA2(string,hashLength)

Mengembalikan nilai hash menggunakan fungsi hash, seperti SHA-224, SHA-256, SHA-384, atau SHA-512.

MURMUR_HASH

Menentukan nilai hash 32-bit untuk parameter menggunakan metode hash32x86.

MURMUR_HASH_64

Menentukan nilai hash 64-bit untuk parameter menggunakan metode hash128x64.

Fungsi Lainnya

ISNAN

Memeriksa apakah angka floating-point yang ditentukan adalah NAN (Bukan angka). Fungsi ini mirip dengan fungsi Double.isNan() atau Float.isNan() dalam Java.

KEYVALUE

Memisahkan string menjadi pasangan key-value berdasarkan pemisah yang ditentukan oleh split1, memisahkan pasangan key-value berdasarkan pemisah yang ditentukan oleh split2, dan mengembalikan nilai yang sesuai dengan key.

Fungsi

Deskripsi

GENERATE_SERIES

Menghasilkan serangkaian data padding berdasarkan aturan from, from+1, from+2 ... to-1.

JSON_TUPLE

Mengambil nilai yang diwakili oleh setiap string jalur dari string JSON.

MULTI_KEYVALUE

Memisahkan string menjadi pasangan key-value berdasarkan pemisah pasangan key-value yang ditentukan oleh split1, memisahkan pasangan key-value berdasarkan pemisah yang ditentukan oleh split2, dan mengembalikan nilai key_name1 dan key_name2.

STRING_SPLIT

Memisahkan string menjadi substring berdasarkan pemisah yang ditentukan dan mengembalikan daftar substring.

Fungsi

Deskripsi

COUNT([ ALL ] expression | DISTINCT expression1 [, expression2]*)

Mengembalikan jumlah baris input untuk ekspresi yang tidak NULL secara default atau jika kata kunci ALL digunakan.

COUNT(*) | COUNT(1)

Mengembalikan jumlah baris input.

AVG([ ALL | DISTINCT ] expression)

Menghitung nilai rata-rata dari ekspresi di semua baris input secara default atau jika kata kunci ALL digunakan.

SUM([ ALL | DISTINCT ] expression)

Mengembalikan jumlah dari ekspresi di semua baris input secara default atau jika kata kunci ALL digunakan.

MAX([ ALL | DISTINCT ] expression)

Mengembalikan nilai maksimum dari ekspresi di semua baris input secara default atau jika kata kunci ALL digunakan.

MIN([ ALL | DISTINCT ] expression )

Mengembalikan nilai minimum dari ekspresi di semua baris input secara default atau jika kata kunci ALL digunakan.

STDDEV_POP([ ALL | DISTINCT ] expression)

Mengembalikan standar deviasi populasi dari ekspresi di semua baris input secara default atau jika kata kunci ALL digunakan.

STDDEV_SAMP([ ALL | DISTINCT ] expression)

Mengembalikan standar deviasi sampel dari ekspresi di semua baris input secara default atau jika kata kunci ALL digunakan.

VAR_POP([ ALL | DISTINCT ] expression)

Mengembalikan standar deviasi sampel dari ekspresi di semua baris input secara default atau jika kata kunci ALL digunakan.

VAR_SAMP([ ALL | DISTINCT ] expression)

Mengembalikan varians sampel dari ekspresi di semua baris input secara default atau jika kata kunci ALL digunakan.

COLLECT([ ALL | DISTINCT ] expression)

Mengembalikan beberapa ekspresi di semua baris input secara default atau jika kata kunci ALL digunakan.

VARIANCE([ ALL | DISTINCT ] expression)

Fungsi ini setara dengan fungsi VAR_SAMP().

RANK()

Mengembalikan peringkat suatu nilai dalam sekelompok nilai.

DENSE_RANK()

Mengembalikan peringkat nilai dalam grup nilai. Hasilnya adalah jumlah 1 dan nilai peringkat yang sebelumnya ditetapkan.

ROW_NUMBER()

Menghitung nomor urut baris berdasarkan urutan baris dalam partisi jendela. Nomor baris dimulai dari 1.

LEAD(expression [, offset] [, default])

Mengembalikan nilai ekspresi pada baris data offset setelah baris saat ini dalam jendela.

LAG(expression [, offset] [, default])

Mengembalikan nilai ekspresi pada baris data offset sebelum baris saat ini dalam jendela.

LISTAGG(expression [, separator])

Menggabungkan nilai ekspresi string dan memisahkan nilai-nilai tersebut dengan pemisah.

APPROX_COUNT_DISTINCT

Meningkatkan performa penyebaran Anda.

FIRST_VALUE

Mengembalikan catatan non-NULL pertama dari aliran data.

LAST_VALUE

Mengembalikan catatan non-NULL terakhir dari aliran data.