我有一个查询流和一个项目流。我想在查询id上加入这两个流，关系是一对多。如何在项目到达后立即将其发送到输出流，并从查询中获取一些信息。
puruo6ea1#
您可以使用表api和简单的连接来实现这一点，也可以使用查询id键控的流上的coflatmap并缓冲状态中的传入事件来实现它。不过，您应该考虑一些保留策略，以确保该州不会无限增长。
1条答案
按热度按时间puruo6ea1#
您可以使用表api和简单的连接来实现这一点，也可以使用查询id键控的流上的coflatmap并缓冲状态中的传入事件来实现它。不过，您应该考虑一些保留策略，以确保该州不会无限增长。