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

Wed, 11 Sep 2019 23:35:52 -0700 

????????????????????????????????????


    tableEnv.registerDataStream("testCountTable", waterMarkStream, 
'curuserid,'timelong,'rowtime.rowtime)
    
    val result = tableEnv.sqlQuery(s"SELECT COUNT(0) as 
pv,COUNT(distinct curuserid)" +
      s" as uv,TUMBLE_END(rowtime, INTERVAL '10' MINUTE) FROM 
testCountTable GROUP BY TUMBLE(rowtime, INTERVAL '10' MINUTE)")


    val dsRow: DataStream[Row] = tableEnv.toAppendStream[Row](result)


    val data=dsRow.map(w => {
      val StrArrary = w.toString.split(",")
      val 
str="{\"pv\":"+"\""+StrArrary(0)+"\""+",\"uv\":"+"\""+StrArrary(1)+"\""+",\"rowtime\":"+"\""+StrArrary(2)+"\""+"}"
      str
    })
    data.print()





------------------ ???????? ------------------
??????:&nbsp;"Jark Wu"<[email protected]&gt;;
????????:&nbsp;2019??9??12??(??????) ????12:51
??????:&nbsp;"user-zh"<[email protected]&gt;;

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



Hi??
???????? SQL ????

blink sql ?? window ?????????????????????? 

&gt; ?? 2019??9??11????18:56?????? <[email protected]&gt; ??????
&gt; 
&gt; ??????????????
&gt; ??????????????flink1.9??????blink 
SQL????????????????????state????????????FSStateBackend??????????State????????????????????????????????????state????blink????????????????????????state??????????????????????????????1.9??flinkSQL????????????????????

回复