Flink join和connect有什么区别？
我对这些定义感到困惑。在文档中，它似乎join后面是一个已key定义的，但connect不需要指定key，其结果是a connectedStream。我们可以做些什么conenctedStream，是否有任何具体的例子，我们使用一个而不是另一个？
还有，connected stream看起来怎么样？
展开
收起
1
条回答
写回答
写回答
-
flink小助手会定期更新直播回顾等资料和文章干货，还整合了大家在钉群提出的有关flink的问题及回答。一个connect操作是更普遍的则连接操作。Connect确保两个流（键控或非键控）在同一位置（在a内的相同并行实例处）相遇CoXXXFunction。
一个流可以是控制流，其操纵应用于另一个流的行为。例如，您可以流入新的机器学习模型或其他业务规则。
或者，您可以使用两个已键入的流的属性，并在同一位置进行会合以进行连接。Flink提供一些预定义的连接运算符。
但是，数据流的加入通常取决于不同的特定于用例的行为，例如“您希望等待另一个密钥到达多长时间？”，“您只查找一个或多个匹配对吗？”或“如果没有匹配的记录到达或者其他匹配记录不再存储在状态中，是否有需要特殊处理的后期元素？“ connect()如果需要，A 允许您实现自己的连接逻辑。该数据工匠培训在这里解释连接用于连接的一个例子。
2019-07-17 23:18:37赞同 展开评论 打赏
问答分类：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
