全部产品
Search
文档中心

Realtime Compute for Apache Flink:REGEXP_REPLACE

更新时间:Jun 19, 2025

Topik ini menjelaskan penggunaan fungsi REGEXP_REPLACE, yang mengganti string tertentu dengan string yang diinginkan dan mengembalikan string baru.

Batasan

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

Sintaksis

VARCHAR REGEXP_REPLACE(VARCHAR str, VARCHAR pattern, VARCHAR replacement)

Parameter input

Parameter

Tipe data

Deskripsi

str

VARCHAR

String yang ditentukan.

pattern

VARCHAR

String asli yang ingin Anda ganti.

replacement

VARCHAR

String yang digunakan untuk menggantikan string asli.

null
  • Jika parameter input bernilai NULL atau ekspresi reguler tidak valid, maka fungsi akan mengembalikan NULL.

  • Sistem mem-parsing parameter pattern dan replacement menjadi ekspresi reguler. Ekspresi tersebut diproses menggunakan Java Pattern. Oleh karena itu, parameter pattern dan replacement harus mengikuti sintaksis Java Regex.

Contoh

  • Data Uji

    Tabel 1. T1

    str1(VARCHAR)

    pattern1(VARCHAR)

    replace1(VARCHAR)

    2014-03-13

    -

    String kosong

    String kosong

    -

    String kosong

    2014-03-13

    String kosong

    s

    2014-03-13

    (

    s

    100-200

    (\d+)

    num

  • Pernyataan Uji

    SELECT REGEXP_REPLACE(str1, pattern1, replace1) as `result`
    FROM T1;
  • Hasil Uji

    result(VARCHAR)

    20140313

    String kosong

    s2s0s1s4s-s0s3s-s1s3s

    NULL

    num-num