在 Flink 中加入两个流并管理状态
Joining two streams and managing state in Flink
我在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 solution.
谢谢，
里尔万
这在很大程度上取决于您想对连接的数据应用什么计算。如果您可以使用 StreamSQL（或 table api）表达您的计算。我建议使用它，因为它抽象了实现的低级细节的所有负担，例如状态保持。
如果 Table API 不够，则切换到 DataStream API。
我在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 solution.
谢谢， 里尔万
这在很大程度上取决于您想对连接的数据应用什么计算。如果您可以使用 StreamSQL（或 table api）表达您的计算。我建议使用它，因为它抽象了实现的低级细节的所有负担，例如状态保持。
如果 Table API 不够，则切换到 DataStream API。