全部产品
Search
文档中心

Realtime Compute for Apache Flink:JSON_TUPLE

更新时间:Jun 19, 2025

Topik ini menjelaskan penggunaan fungsi JSON_TUPLE, yang mengekstrak nilai-nilai berdasarkan string jalur dari sebuah string JSON.

Batasan

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

Sintaksis

JSON_TUPLE(str, path1, path2 ..., pathN)     

Parameter input

ParameterTipe dataDeskripsi
strVARCHARString JSON.
path1 hingga pathNVARCHARSebuah string jalur, yang tidak dimulai dengan tanda dolar ($).

Contoh

  • Data Uji

    Tabel 1. T1

    d(VARCHAR)s(VARCHAR)
    {"qwe":"asd","qwe2":"asd2","qwe3":"asd3"}qwe3
    {"qwe":"asd4","qwe2":"asd5","qwe3":"asd3"}qwe2
  • Pernyataan Uji
    SELECT d, v 
    FROM T1, lateral table(JSON_TUPLE(d, 'qwe', s))
    AS T(v);   
  • Hasil Uji
    d(VARCHAR)v(VARCHAR)
    {"qwe":"asd","qwe2":"asd2","qwe3":"asd3"}asd
    {"qwe":"asd","qwe2":"asd2","qwe3":"asd3"}asd3
    {"qwe":"asd4","qwe2":"asd5","qwe3":"asd3"}asd4
    {"qwe":"asd4","qwe2":"asd5","qwe3":"asd3"}asd5