flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From liu_mingzhang <liu_mingzh...@163.com>
Subject 回复: flink 自定义UDTF函数
Date Mon, 17 Jun 2019 02:09:47 GMT
自定义的函数如下:




源码中注释里的示例也是这样写的,但是编译报错...


在2019年6月15日 15:52,Hequn Cheng<chenghequn@gmail.com> 写道:
自定义的函数忘贴了么 :)

On Fri, Jun 14, 2019 at 6:58 PM liu_mingzhang <liu_mingzhang@163.com> wrote:


我希望自定义一个这样功能的UDTF,

将表中原始数据:
id        filed1        field2
1         A,B,C         D,E,F

转换成:
id    num    filed1        field2
1       1        A                D
1       2        B                E
1       3        C                F


下面是我自己写的函数,但是报错


然而ROW是有这样的构造函数的


我不明白我为什么会报错, 希望大佬们帮忙解答,不胜感激

Mime
  • Unnamed multipart/related (inline, None, 0 bytes)
View raw message