?????? flink 1.9 ??????UDAF ????state??????????????

Sun, 07 Jun 2020 19:51:19 -0700 

????udaf?????????????????????????????????? 
??????????arrayList????????????arraylist????????????????????arraylist 
????checkpoint




------------------ ???????? ------------------
??????:&nbsp;"Benchao Li"<[email protected]&gt;;
????????:&nbsp;2020??6??8??(??????) ????10:46
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;Re: flink 1.9 ??????UDAF ????state??????????????



??????????????????????
????????UDAF????????state????????Flink??????????
??????UDAF????????????state????????????????????????

star <[email protected]&gt; ??2020??6??8?????? ????10:44??????

&gt; ??????????
&gt;
&gt;
&gt; flink 1.9 ??????UDAF ????state??????????????
&gt;
&gt;
&gt; ??????sql???? ????????stage??
&gt;
&gt;
&gt; class MyFunc extends AggregateFunction{
&gt; createAccumulator
&gt; accumulate
&gt; getValue
&gt; merge
&gt; &amp;nbsp; }



-- 

Best,
Benchao Li

回复