全部产品
Search
文档中心

Realtime Compute for Apache Flink:KEYVALUE

更新时间:Jun 19, 2025

Tema ini menjelaskan penggunaan fungsi KEYVALUE. Fungsi ini membagi string menjadi pasangan kunci-nilai berdasarkan pemisah split1 dan membagi pasangan kunci-nilai menggunakan pemisah split2. Nilai yang sesuai dengan kunci akan dikembalikan.

Batasan

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

Sintaks

VARCHAR KEYVALUE(VARCHAR str, VARCHAR split1, VARCHAR split2, VARCHAR key_name)      

Parameter input

ParameterTipe dataDeskripsi
strVARCHARString yang ingin Anda bagi.
split1VARCHARPemisah split1 yang membagi string yang ditentukan menjadi pasangan kunci-nilai.
split2VARCHARPemisah split2 yang membagi pasangan kunci-nilai.
key_nameVARCHARNama dari kunci.
null
  • Jika parameter split1 atau split2 adalah NULL, maka nilai NULL akan dikembalikan.
  • Jika parameter str atau key_name adalah NULL, maka nilai NULL akan dikembalikan.
  • Jika tidak ada kunci yang ditemukan, maka nilai NULL akan dikembalikan.
  • Jika terdapat beberapa pasangan kunci-nilai, nilai pertama yang cocok dengan kunci akan dikembalikan.

Contoh

  • Data Uji

    Tabel 1. T1

    str(VARCHAR)split1(VARCHAR)split2(VARCHAR)key1(VARCHAR)
    k1=v1;k2=v2;=k2
    NULL;|:
    k1:v1|k2:v2NULL=:
    k1:v1|k2:v2|=NULL
    k1:v1|k2:v2|=:
  • Pernyataan Uji
    SELECT  KEYVALUE(str, split1, split2, key1) as `result`
    FROM T1;         
  • Hasil Uji
    result(VARCHAR)
    v2
    NULL
    NULL
    NULL
    NULL