flink table api 或者 sql 使用 自定义含有的state方法

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

flink table api 或者 sql 使用 自定义含有的state方法

戴嘉诚
大家好:
    请问,因为当前flink sql或者flink table
中,不支持自定义的udf中使用有state的逻辑,所以,当我们自己任务中,如果统计需要聚集型指标的情况下,就不能用上flink
sql了,只能自己使用flink datastream去硬编码,请问,flink
sql中,能否有其他方式,可以调用我们自己定义的有state的udf,并且可以不让再解析执行的时候,多次出现呢?还是说,只能一个指标一个flink
job?