Flink Table Api 之表函数使用_flink table 函数使用

作者：爱喝兽奶帝天荒 | 2024-06-27 08:03:41

踩

flink table 函数使用

表函数（Table Functions）

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

比如，通过自定义表函数，对读取数据中的某些字段可以根据业务需求做一些特殊的处理

下面看一个具体的代码案例


package com.congge.table.api.udf;
 
 
import com.congge.source.SensorReading;
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.datastream.DataStreamSource;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flin

本文内容由网友自发贡献，转载请注明出处：https://www.wpsshop.cn/w/爱喝兽奶帝天荒/article/detail/761787?site