You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 戴嘉诚 <a7...@gmail.com> on 2020/11/24 06:43:32 UTC

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

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