特牛生活网

Flink自定义函数(自定义分词函数UDTF)_flink 自定义udtf 函数-CSDN博客

网友收藏
文章浏览阅读1.2k次。Flink自定义函数概述自定义函数(UDF)是一种扩展开发机制,可以用来在查询语句里调用难以用其他方式表达的频繁使用或自定义的逻辑。函数分类:Scalar functions类似于spark的udfTable functions类似于 spark的udtfAggregate functions类似于spark的udafTable aggregate functionsAsync table functins自定义Table Function实现分词功能一个词条包括多个词语所以分词_flink 自定义udtf 函数