FlinkSQL-自定义表函数TableFunction_flink tablefunction

作者：Guff_9hys | 2024-06-27 08:24:13

踩

flink tablefunction

FlinkSQL-自定义表函数TableFunction

什么是表函数
表函数的实现
代码实现
测试用例

什么是表函数

Table Function类似FlatMap，一对多，输入一行数据输出多行数据

用户定义的表函数，也可以将0、1或多个标量值作为输入参数；与标量函数不同的是，它可以返回任意数量的行作为输出，而不是单个值
为了定义一个表函数，必须扩展 org.apache.flink.table.functions 中的基类 TableFunction 并实现（一个或多个）求值方法
表函数的行为由其求值方法决定

表函数的实现

TableFunction 要求必须实现的方法

eval

代码实现

    //实现自定义的TableFunction<返回值类型>
    public static class Split extends TableFunction<Tuple2<String, Integer>> {
   
        // 定义属性，分隔符
        private String separator = ","1
2
3
4

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/Guff_9hys/article/detail/761851