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 Types源码
Date Mon, 17 Jun 2019 02:21:46 GMT


我希望自定义一个这样功能的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




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


然而org.apache.flink.table.api.Types.ROW是有这样的构造函数的,注释中的示例也是这样写的


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


另: 不知道为什么之前发的图片没法成功, 如果这次还看不到的话, 麻烦请看附件,多谢各位大佬
Mime
View raw message