?????? [????????] Stream SQL window join ????

Thu, 27 Aug 2020 01:16:30 -0700 

hi ??????????window??????trigger??evitor??????????????




------------------ ???????? ------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<[email protected]&gt;;
????????:&nbsp;2020??8??27??(??????) ????3:51
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;Re: [????????] Stream SQL window join ????



??????????????,????????????????????????????????count????,??????????????????????????????

Danny Chan <[email protected]&gt; ??2020??8??27?????? ????2:48??????

&gt; ?????? ~
&gt;
&gt; ?????????? window-join[1] ??????????, window-join ?? Flink DataStream 
?????????? feature.
&gt; ?????????????????? SQL ????????????, ????, tumbling window join 
??????????????:
&gt;
&gt; ```sql
&gt; select ... window_start, window_end
&gt; from TABLE(
&gt;&nbsp;&nbsp; TUMBLE(
&gt;&nbsp;&nbsp;&nbsp;&nbsp; DATA =&gt; TABLE table_a,
&gt;&nbsp;&nbsp;&nbsp;&nbsp; TIMECOL =&gt; DESCRIPTOR(rowtime),
&gt;&nbsp;&nbsp;&nbsp;&nbsp; SIZE =&gt; INTERVAL '1' MINUTE)) tumble_a
&gt;&nbsp;&nbsp; [LEFT | RIGHT | FULL OUTER] JOIN TABLE(
&gt;&nbsp;&nbsp; TUMBLE(
&gt;&nbsp;&nbsp;&nbsp;&nbsp; DATA =&gt; TABLE table_b,
&gt;&nbsp;&nbsp;&nbsp;&nbsp; TIMECOL =&gt; DESCRIPTOR(rowtime),
&gt;&nbsp;&nbsp;&nbsp;&nbsp; SIZE =&gt; INTERVAL '1' MINUTE)) tumble_b
&gt; on tumble_a.col1 = tumble_b.col1 and ...
&gt; ```
&gt;
&gt; ?????????????????????????? interval join ????????????window join ?? case 
????????????, ??????????????????????????
&gt;
&gt; ?????????????? window join ?????????????????????????????? window-join 
???????? interval join)??
&gt;
&gt; ???? ~
&gt;
&gt; [1]
&gt; 
https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/stream/operators/joining.html
&gt;
&gt; Best,
&gt; Danny Chan
&gt;

回复