【发布时间】:2020-08-28 17:19:07
【问题描述】:
我找不到任何关于如何在 Flink 中对时态表函数执行左连接的文档。所有示例都描述了似乎是内部连接的内容。
换句话说,当我将事件表加入时态表函数时,我希望结果包含左表中的每个条目,无论时态表上是否存在匹配项。
【问题讨论】:
标签: apache-flink flink-streaming
我找不到任何关于如何在 Flink 中对时态表函数执行左连接的文档。所有示例都描述了似乎是内部连接的内容。
换句话说,当我将事件表加入时态表函数时,我希望结果包含左表中的每个条目,无论时态表上是否存在匹配项。
【问题讨论】:
标签: apache-flink flink-streaming
确实,目前还不支持。见Jingsong Lee's comment in this JIRA ticket:
会影响左外连接(UDTF 只支持左连接),当 条件为假,应该发出具有正确空值的数据,而不是 过滤数据
正华高友是对的,我们应该支持它
不要犹豫,用你的用例评论那张票。也许现在 Blink 规划器的合并更加稳定,有更多的时间/注意力来添加功能。
编辑:Temporal Tables(相对于时态表函数)可能会让您更幸运
【讨论】: