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
On Thu, 30 Apr 2020 at 22:35, lec
Thanks, but is the bottom layer of the table API really implemented like
this?
Konstantin Knauf 于 2020年4月30日周四 22:02写道：
> Hi Lec Ssmi,
>
> yes, Dastream#connect on two streams both keyed on the productId with a
> KeyedCoProcessFunction is the way to go.
>
> Cheers,
>
> Konstantin
>
> On Thu, Apr
Hi Lec Ssmi,
yes, Dastream#connect on two streams both keyed on the productId with a
KeyedCoProcessFunction is the way to go.
Cheers,
Konstantin
On Thu, Apr 30, 2020 at 11:10 AM lec ssmi wrote:
> Maybe, the connect method?
>
> lec ssmi 于2020年4月30日周四 下午3:59写道：
>
>> Hi:
>> As the following
Maybe, the connect method?
lec ssmi 于2020年4月30日周四 下午3:59写道：
> 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 W
