调用流程函数时是否有来自 static 关键字的任何 Flink 特定优化？

Question

说明：

流程函数的美妙之处在于它们使我们能够访问键控状态和计时器，这使开发人员能够完全控制输入流中接收到的每个事件。它们工作得很好，几乎可以解决我所有的用例。那我为什么在这里打扰你？公平的问题。 我很好奇是否有任何底层 Flink 性能优化来自使用处理器的静态实现与使用新关键字？

例子：

将静态处理函数应用于键控流

private static final CountWithTimeoutFunction TIMEOUT_COUNT_PROCESSOR = new CountWithTimeoutFunction();

// apply the process function onto a keyed stream
DataStream<Tuple2<String, Long>> result = stream
    .keyBy(0)
    .process(TIMEOUT_COUNT_PROCESSOR);

将非静态处理函数应用于键控流

// apply the process function onto a keyed stream
DataStream<Tuple2<String, Long>> result = stream
    .keyBy(0)
    .process(new CountWithTimeoutFunction());

Answer 1

不，没有优化。在这两种情况下，首先构建您的工作流图，然后将其序列化/分发到任务管理器，然后再进行反序列化并开始执行。因此，对函数使用单例并没有什么好处，因为在构建工作流图时，在任何一种情况下都只会创建其中一个。