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

【问题标题】：Joining two streams and managing state in Flink在 Flink 中加入两个流并管理状态
【发布时间】：2018-05-29 15:24:02
【问题描述】：

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

另外如何维护流和连接的状态？ flink 有没有 in build 解决方案。

谢谢，里尔万

【问题讨论】：

【解决方案1】：

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

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

【讨论】：

在提出问题之前，请先阅读文档。关于 flink 中状态的部分描述得很好：ci.apache.org/projects/flink/flink-docs-release-1.5/dev/stream/…