我找不到任何关于如何在Flink中对时态表函数执行左联接的文档。所有的例子都描述了内部连接。
换句话说,当我将事件表连接到时态表函数时,我希望结果包含左表中的每个条目,而不管时态表上是否匹配。
事实上,目前还不支持它。请参阅李在这张JIRA门票中的评论:
将影响左外部联接(UDTF仅支持左联接(,当条件为false,应发出具有正确null值的数据,而不是过滤掉数据
高正华是对的,我们应该支持
请毫不犹豫地用您的用例对该票证进行评论。也许现在Blink计划器的合并更加稳定了,所以有更多的时间/注意力添加功能。
编辑:你可能会在时态表(与时态表函数相反(上运气更好