文档首页> 数据湖探索 DLI> Flink SQL语法参考> Flink Opensource SQL1.10语法参考> 函数> 内置函数> 表值函数> string_split
更新时间：2023-02-24 GMT+08:00
查看PDF

string_split

string_split函数，根据指定的分隔符将目标字符串拆分为子字符串，并返回子字符串列表。

语法说明

string_split(target, separator)
表1 string_split参数说明

参数

数据类型

说明

target

STRING

待处理的目标字符串。

说明：
  • 如果target为NULL，则返回一个空行。
  • 如果target包含两个或多个连续出现的分隔符时，则返回长度为零的空子字符串。
  • 如果target未包含指定分隔符，则返回目标字符串。

separator

VARCHAR

指定的分隔符，当前仅支持单字符分割。

示例

  1. 准备测试输入数据
    表2 测试源表disSource数据和分隔符

    target（STRING）

    separator （VARCHAR）

    test-flink

    -

    flink

    -

    one-two-ww-three

    -
  2. 输入测试SQL语句
    create table disSource(
  target STRING,
  separator  VARCHAR
) with (
  "connector.type" = "dis",
  "connector.region" = "xxx",
  "connector.channel" = "ygj-dis-in",
  "format.type" = 'csv'
);

create table disSink(
  target STRING,
  item STRING
) with (
  'connector.type' = 'dis',
  'connector.region' = 'xxx',
  'connector.channel' = 'ygj-dis-out',
  'format.type' = 'csv'
);

insert into
  disSink
select
  target,
  item
from
  disSource,
lateral table(string_split(target, separator)) as T(item);
  3. 查看测试结果
    表3 disSink结果表数据

    target（STRING）

    item（STRING）

    test-flink

    test

    test-flink

    flink

    flink

    flink

    one-two-ww-three

    one

    one-two-ww-three

    two

    one-two-ww-three

    ww

    one-two-ww-three

    three
父主题： 表值函数