CODEWITHSUNDEEP
apache-flinkflink-streaming
Shen Jenson
Shen Jenson

Reputation: 47

Temporal Left Joins in Flink

I cannot find any documentation on how to perform left joins on temporal table functions in Flink. All examples describe what seems to be the inner join.

In other words, when I join a table of events onto a temporal table function, I want the result to contain every entry from the left table, regardless of whether there was a match on the temporal table or not.

Upvotes: 1

Views: 673

Answers (1)

BenoitParis
BenoitParis

Reputation: 3184

Indeed it is not supported as of yet. See Jingsong Lee's comment in this JIRA ticket:

will affect left outer join(UDTF only support left join), when condition is false, should emit data with right null values instead of filtering out data

Zhenghua Gao You are right, we should support it

Do not hesitate to comment on that ticket with your use case. Maybe now that the merge of the Blink planner is more stable there is more time/attention to adding features.

EDIT: You might have more luck with Temporal Tables (as opposed to Temporal Table Functions)

Upvotes: 2

Related Questions