這篇文章主要介紹了Flink中如何使用TimeWindowAll,具有一定借鑒價值,感興趣的朋友可以參考下,希望大家閱讀完這篇文章之后大有收獲,下面讓小編帶著大家一起了解一下。
timeWindowAll時間滾動窗口(不分區時間滾動窗口【滑動窗口與滾動窗口的區別,在于滑動窗口會有數據元素重疊可能,而滾動窗口不存在元素重疊】)
示例環境
java.version: 1.8.xflink.version: 1.11.1
Flink 系例 之 搭建開發環境與數據
TimeWindowAll.java
import com.flink.examples.DataSource; import org.apache.flink.api.java.tuple.Tuple3; import org.apache.flink.streaming.api.datastream.DataStream; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; import org.apache.flink.streaming.api.functions.source.RichSourceFunction; import org.apache.flink.streaming.api.windowing.time.Time; import java.util.List; /** * @Description 不分區時間滾動窗口 */ public class TimeWindowAll { /* 窗口在處理流數據時,通常會對流進行分區; 數據流劃分為: keyed(根據key劃分不同數據流區) non-keyed(指沒有按key劃分的數據流區,指所有原始數據流) */ /** * 遍歷集合,返回指定時間滾動窗口下最大年齡數據記錄 * @param args * @throws Exception */ public static void main(String[] args) throws Exception { final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); //env.setParallelism(1); DataStream<Tuple3<String, String, Integer>> inStream = env.addSource(new MyRichSourceFunction()); DataStream<Tuple3<String, String, Integer>> dataStream = inStream //按時間窗口滾動,對前6秒內的輸入數據流,計算一次 .timeWindowAll(Time.seconds(6)) //注意:計算變量為f2 .maxBy(2); dataStream.print(); env.execute("flink TimeWindow job"); } /** * 模擬數據持續輸出 */ public static class MyRichSourceFunction extends RichSourceFunction<Tuple3<String, String, Integer>> { @Override public void run(SourceContext<Tuple3<String, String, Integer>> ctx) throws Exception { List<Tuple3<String, String, Integer>> tuple3List = DataSource.getTuple3ToList(); for (Tuple3 tuple3 : tuple3List){ ctx.collect(tuple3); //1秒鐘輸出一個 Thread.sleep(1 * 1000); } } @Override public void cancel() { try{ super.close(); }catch (Exception e){ e.printStackTrace(); } } } }
打印結果
2> (王五,man,29)
感謝你能夠認真閱讀完這篇文章,希望小編分享的“Flink中如何使用TimeWindowAll”這篇文章對大家有幫助,同時也希望大家多多支持億速云,關注億速云行業資訊頻道,更多相關知識等著你來學習!
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。