?????? ????flink??????????????????????

Tue, 24 Dec 2019 17:57:27 -0800 

????????
??????????????metric????????recordsIn>recordsOut
??????????????????window??????processfunction??????????????filter??????
??????????
.window(TumblingEventTimeWindows.of(org.apache.flink.streaming.api.windowing.time.Time.minutes(1)))
.process(new ProcessWindowFunction<Row, Row, Integer, TimeWindow&gt;() {
    @Override
    public void process(Integer integer, Context context, Iterable<Row&gt; 
elements, Collector<Row&gt; out) {
        for (Row element : elements) {
                out.collect(element);
        }
    }
})




------------------&nbsp;????????&nbsp;------------------
??????:&nbsp;"jingjing bai"<baijingjing7...@gmail.com&gt;;
????????:&nbsp;2019??12??24??(??????) ????9:18
??????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

????:&nbsp;Re: ????flink??????????????????????



??????????????????????????metircs????????????????


1530130567 <1530130...@qq.com&gt; ??2019??12??24?????? ????8:46??????

&gt; ????????????
&gt; &amp;nbsp; ??????????flink stream api??????????????????????????ETL????
&gt; &amp;nbsp; 
????????????????1??????tumble??????watermark??10s??????????????????????????????????????????????????????
&gt; &amp;nbsp; ????????????????topic 5000/s,??????????????topic????4000/s
&gt; &amp;nbsp;
&gt; 
????????????????????????????????????????????????????????????????????????????????????????????????????processfunction????????????
&gt; &amp;nbsp; ps????????????????????????

回复