?????? blinkSQL????????????????????state??

Thu, 12 Sep 2019 02:24:58 -0700 

 ????????????
    
 blinkSQL??????????????????watermark????????????????????checkpoint????????????????????????????flinkSQL????????????????????????????????????????blinkSQL??????????????????????






------------------ ???????? ------------------
??????:&nbsp;"LakeShen"<[email protected]&gt;;
????????:&nbsp;2019??9??12??(??????) ????4:18
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;Re: blinkSQL????????????????????state??



Hi ????,
*&nbsp;&nbsp;&nbsp; ??*????????????watermark????????????????
&nbsp;&nbsp;&nbsp; 
??????????????????????????????????????????????????????checkpoint 
??????????????????????????



???? <[email protected]&gt; ??2019??9??12?????? ????2:35??????

&gt; ????????????????????????????????????
&gt;
&gt;
&gt; &amp;nbsp; &amp;nbsp; tableEnv.registerDataStream("testCountTable",
&gt; waterMarkStream, 'curuserid,'timelong,'rowtime.rowtime)
&gt; &amp;nbsp; &amp;nbsp;&amp;nbsp;
&gt; &amp;nbsp; &amp;nbsp; val result = tableEnv.sqlQuery(s"SELECT COUNT(0) as
&gt; pv,COUNT(distinct curuserid)" +
&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; s" as uv,TUMBLE_END(rowtime, INTERVAL 
'10' MINUTE)
&gt; FROM testCountTable GROUP BY TUMBLE(rowtime, INTERVAL '10' MINUTE)")
&gt;
&gt;
&gt; &amp;nbsp; &amp;nbsp; val dsRow: DataStream[Row] =
&gt; tableEnv.toAppendStream[Row](result)
&gt;
&gt;
&gt; &amp;nbsp; &amp;nbsp; val data=dsRow.map(w =&amp;gt; {
&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; val StrArrary = w.toString.split(",")
&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; val
&gt; 
str="{\"pv\":"+"\""+StrArrary(0)+"\""+",\"uv\":"+"\""+StrArrary(1)+"\""+",\"rowtime\":"+"\""+StrArrary(2)+"\""+"}"
&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; str
&gt; &amp;nbsp; &amp;nbsp; })
&gt; &amp;nbsp; &amp;nbsp; data.print()
&gt;
&gt;
&gt;
&gt;
&gt;
&gt; ------------------&amp;nbsp;????????&amp;nbsp;------------------
&gt; ??????:&amp;nbsp;"Jark Wu"<[email protected]&amp;gt;;
&gt; ????????:&amp;nbsp;2019??9??12??(??????) ????12:51
&gt; ??????:&amp;nbsp;"user-zh"<[email protected]&amp;gt;;
&gt;
&gt; ????:&amp;nbsp;Re: blinkSQL????????????????????state??
&gt;
&gt;
&gt;
&gt; Hi??
&gt; ???????? SQL ????
&gt;
&gt; blink sql ?? window ??????????????????????
&gt;
&gt; &amp;gt; ?? 2019??9??11????18:56?????? <[email protected]&amp;gt; ??????
&gt; &amp;gt;
&gt; &amp;gt; ??????????????
&gt; &amp;gt; ??????????????flink1.9??????blink
&gt; 
SQL????????????????????state????????????FSStateBackend??????????State????????????????????????????????????state????blink????????????????????????state??????????????????????????????1.9??flinkSQL????????????????????

回复