Re: join in sql without time interval
Posted by
Jark Wu-3 on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/join-in-sql-without-time-interval-tp34840p34860.html
Yes. Flink Table&SQL uses something like that but more lower API called `TwoInputStreamOperator`, you can see:
org.apache.flink.table.runtime.operators.join.stream.StreamingJoinOperator
And state ttl in TableConfig can take effect on such join query.
Best,
Jark
Thanks, but is the bottom layer of the table API really implemented like this?
Hi Lec Ssmi,
yes, Dastream#connect on two streams both keyed on the productId with a KeyedCoProcessFunction is the way to go.
Cheers,
Konstantin
Maybe, the connect method?
Hi:
As the following sql:
SELECT * FROM Orders INNER JOIN Product ON Orders.productId = Product.id
If we use datastream API instead of sql, how should it be achieved?
Because the APIs in DataStream only have Window Join and Interval Join，the official website says that to solve the above state capacity problem in sql is using TableConfig. But TableConfig itself can only solve the state ttl problem of non-time operators. So I think the above sql's implementation is neither tumble window join, nor sliding window join and interval join.
Best Regards
Lec Ssmi
--