FunctionAnnotation 能帮忙解释一下这个作用吗?

看了一下不是特别理解  

小象老师

赞同来自:

我看了下  主要里面是提供了一些注解   在你写自定义函数的时候可以用来指定有哪些你已知的函数参数到结果的值的变化   这是为了flink做代码优化   比如里面的ForwardedFields就是指定你函数参数到return值有哪些是没变的

时间不再回头 - 一句话介绍

赞同来自:

github拉flink源码看就知道了 /** * This class defines Java annotations for semantic assertions that can be added to Flink functions. * Semantic annotations can help the Flink optimizer to generate more efficient execution plans for Flink programs. * ....... */ @Public public class FunctionAnnotation {

要回复问题请先登录注册