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

[star]

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




------------------ ???????? ------------------
??????:&nbsp;"Benchao Li"<libenc...@gmail.com&gt;;
????????:&nbsp;2020??6??8??(??????) ????10:57
??????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

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



UDAF??accumulator??????????Flink??????????????state????????????????????checkpoint????????
????????????????????????????UDAF??????????????????????UDAF??????????????????????????
????????????????accumulator????

star <3149768...@qq.com&gt; ??2020??6??8?????? ????10:50??????

&gt; ????udaf?????????????????????????????????? 
??????????arrayList????????????arraylist????????????????????arraylist
&gt; ????checkpoint
&gt;
&gt;
&gt;
&gt;
&gt; ------------------&amp;nbsp;????????&amp;nbsp;------------------
&gt; ??????:&amp;nbsp;"Benchao Li"<libenc...@gmail.com&amp;gt;;
&gt; ????????:&amp;nbsp;2020??6??8??(??????) ????10:46
&gt; ??????:&amp;nbsp;"user-zh"<user-zh@flink.apache.org&amp;gt;;
&gt;
&gt; ????:&amp;nbsp;Re: flink 1.9 ??????UDAF ????state??????????????
&gt;
&gt;
&gt;
&gt; ??????????????????????
&gt; ????????UDAF????????state????????Flink??????????
&gt; ??????UDAF????????????state????????????????????????
&gt;
&gt; star <3149768...@qq.com&amp;gt; ??2020??6??8?????? ????10:44??????
&gt;
&gt; &amp;gt; ??????????
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; flink 1.9 ??????UDAF ????state??????????????
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; ??????sql???? ????????stage??
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; class MyFunc extends AggregateFunction{
&gt; &amp;gt; createAccumulator
&gt; &amp;gt; accumulate
&gt; &amp;gt; getValue
&gt; &amp;gt; merge
&gt; &amp;gt; &amp;amp;nbsp; }
&gt;
&gt;
&gt;
&gt; --
&gt;
&gt; Best,
&gt; Benchao Li



-- 

Best,
Benchao Li