我在flink中找不到任何关于如何对时态表函数执行左联接的文档。所有的例子都描述了内部连接。换句话说,当我将一个事件表连接到一个时态表函数时,我希望结果包含左表中的每个条目,而不管时态表上是否有匹配项。
ogsagwnx1#
事实上,到目前为止还没有得到支持。见李劲松在这张jira票上的评论:将影响左外联接(udtf仅支持左联接),当条件为false时,应发出右空值的数据,而不是过滤掉数据你说的对,我们应该支持不要犹豫,用你的用例来评论这个问题。也许现在blink planner的合并更稳定了,添加特性的时间/注意力也更多了。编辑:使用时态表(与时态表函数相反)可能会更幸运
1条答案
按热度按时间ogsagwnx1#
事实上,到目前为止还没有得到支持。见李劲松在这张jira票上的评论:
将影响左外联接(udtf仅支持左联接),当条件为false时,应发出右空值的数据,而不是过滤掉数据
你说的对,我们应该支持
不要犹豫,用你的用例来评论这个问题。也许现在blink planner的合并更稳定了,添加特性的时间/注意力也更多了。
编辑:使用时态表(与时态表函数相反)可能会更幸运