Flink 应用与进程



WindowedStream.apply.process的两个函数具有相同的描述。我发现的唯一区别是:.apply接收Context,而.proccess接收Window

applyprocess之间做出决定时应该考虑什么?

较新的process方法传递一个Context,其中包含Window和其他有用的字段。这包含传递Windowapply方法。没有充分的理由使用apply,它只是为了向后兼容而保留。

相关内容

  • 没有找到相关文章

最新更新