JSON_VALUE - Realtime Compute for Apache Flink

Mengekstrak ekspresi jalur yang ditentukan dari string JSON.

Batasan

Fungsi ini hanya didukung di Realtime Compute for Apache Flink yang menggunakan Ververica Runtime (VVR) 3.0.0 atau versi lebih baru.

Sintaks

VARCHAR JSON_VALUE(VARCHAR content, VARCHAR path)

Parameter input

Parameter

Tipe data

Deskripsi

konten

VARCHAR

Objek JSON yang ingin Anda parsing.

Catatan

Tipe parameter harus berupa VARCHAR. Jika bukan, gunakan CAST untuk mengonversinya. Mengirimkan data non-VARCHAR secara langsung dapat menyebabkan kesalahan penguraian dan hasil NULL yang tidak terduga.

jalur

VARCHAR

Ekspresi jalur yang ditentukan. Anda harus menggunakan tanda kutip tunggal (') dalam jalur kustom. Contoh:

JSON_VALUE(json,'$.passenger_name') AS ABC

Simbol berikut didukung dalam sebuah jalur:

$: menunjukkan objek root.
[]: menunjukkan indeks array.
*: menunjukkan karakter wildcard array.
.: menunjukkan elemen anak.

Catatan

Jika parameter input berisi JSON yang tidak valid atau nilai NULL, maka akan dikembalikan NULL.

Contoh

Data Uji

Tabel 1 T1

id(INT)	json(VARCHAR)	path1(VARCHAR)
1	[10, 20, [30, 40]]	$[2][*]
2	{"aaa":"bbb","ccc":{"ddd":"eee","fff":"ggg","hhh":["h0","h1","h2"]},"iii":"jjj"}	$.ccc.hhh[*]
3	{"aaa":"bbb","ccc":{"ddd":"eee","fff":"ggg","hhh":["h0","h1","h2"]},"iii":"jjj"}	$.ccc.hhh[1]
4	[10, 20, [30, 40]]	NULL
5	NULL	$[2][*]
6	"{xx]"	"$[2][*]"

Pernyataan Uji

SELECT 
    id,
    JSON_VALUE(json, path1) AS `value`
FROM 
    T1;

Hasil Uji
id (INT)
value (VARCHAR)
1
[30,40]
2
["h0","h1","h2"]
3
h1
4
NULL
5
NULL
6
NULL

Referensi

Untuk informasi lebih lanjut tentang fungsi bawaan yang didukung oleh Flink yang sepenuhnya dikelola, lihat Fungsi yang Didukung.
Untuk informasi lebih lanjut tentang fungsi yang ditentukan pengguna (UDFs), lihat UDFs dan Kelola UDFs.

id (INT)	value (VARCHAR)
1	[30,40]
2	["h0","h1","h2"]
3	h1
4	NULL
5	NULL
6	NULL