Cara menggunakan fungsi PARSE_JSON - Realtime Compute for Apache Flink

Mengonversi string JSON menjadi nilai VARIANT.

Batasan

Fungsi ini hanya didukung di Ververica Runtime (VVR) versi 11.1.0 atau yang lebih baru.

VARIANT PARSE_JSON(VARCHAR jsonStr [, BOOLEAN allowDuplicateKeys])

Argumen

Tipe data

Deskripsi

jsonStr

VARCHAR

String JSON yang akan diurai.

null

Jika input adalah NULL, fungsi mengembalikan NULL.

allowDuplicateKeys

BOOLEAN

Argumen opsional ini menentukan apakah kunci duplikat diperbolehkan. Nilai yang valid:

true: Menyimpan nilai dari kunci duplikat terakhir dalam string JSON.
false (default): Melaporkan kesalahan jika ada kunci duplikat dalam string JSON.

Fungsi	Mekanisme Penanganan Kesalahan	Nilai Pengembalian untuk Input JSON Tidak Valid	Skenario yang Sesuai
PARSE_JSON	Memunculkan kesalahan secara eksplisit.	Mengembalikan kesalahan.	Validasi input ketat diperlukan.
TRY_PARSE_JSON	Menoleransi kesalahan.	Mengembalikan `NULL`.	Toleransi terhadap input tidak valid diperlukan.

Pernyataan uji:

SELECT PARSE_JSON(jsonString) AS v
FROM T1;