Flink：如何在一对多流的连接中立即发出输出

Question

我有一个查询流和一个项目流。我想在query_id上加入这两个流，关系是一对多。如何在项目到达后立即将项目发送到输出流并从查询中获取一些信息。

Answer 1

您可以使用表 API 和简单的联接来执行此操作，也可以使用 CoFlatMap 在由query_id键控的流上自己实现它，并在状态中缓冲传入事件。不过，您应该考虑一些保留策略，以确保状态不会无限增长。