本文为您介绍如何使用实时计算聚合函数CONCAT_AGG。Flink SQL中使用CONCAT_AGG函数将对应字段的所有字符串连接成新的字符串。

语法

CONCAT_AGG([linedelimiter,] value ) 

入参

参数 数据类型
linedelimiter 目前只支持字符串常量。可选。

功能描述

连接对应字段的字符串,默认连接符\n,连接完成后新生成的字符串。返回值VARCHAR类型。

示例

  • 测试数据
    b(VARCHAR) c(VARCHAR)
    Hi milk
    Hi milk
    Hi milk
    Hi milk
    Hi milk
    Hi milk
    Hello cola
    Hello cola
    Happy suda
    Happy suda
  • 测试语句
    SELECT 
          b,
          concat_agg(c) as var1, 
          concat_agg('-', c) as var2
    FROM MyTable
    GROUP BY b;         
  • 测试结果
    b (VARCHAR) var1(VARCHAR) var2(VARCHAR)
    Hi

    milk

    milk

    milk

    milk

    milk

    milk

    milk-milk-milk-milk-milk-milk
    Hello

    cola

    cola

    cola-cola
    Happy

    suda

    suda

    suda-suda