apache-flink - 在 Flink 中加入两个流并管理状态

Question

我在 flink 中有两个 nifi 流源，我需要对这两个源执行连接。哪个是更好的解决方案？是加入DataStreams提供的api还是table api( https://ci.apache.org/projects/flink/flink-docs-release-1.5/dev/table/streaming.html#streaming-concepts) .?

另外如何维护流和连接的状态？flink 是否提供了任何构建解决方案。

谢谢，里尔万

Answer 1

这在很大程度上取决于您要对连接的数据应用哪些计算。如果您可以使用 StreamSQL（或 table api）表达您的计算。我建议使用它，因为它抽象了实现的低级细节的所有负担，例如状态维护。

如果 Table API 不够用，则切换到 DataStream API。