15篇文章 · 10278字 · 1人關(guān)注
-
Flink 術(shù)語表
Checkpoint Storagecheckpoint期間State Backend存儲snapshot的地方照弥，JobManager的Java...
-
Flink Architecture1. Flink 集群組成 Flink 運行時主要由兩部分構(gòu)成（圖中橘色部分）： JobManager TaskManager JobManag...
-
Timely Stream Processing
Timely Stream Processing只是在Stateful Stream Processing上增加了時間的處理弥虐，可用于做特定時間段...
-
Stateful Streaming Processing
1. 什么是State 有時候除了一次處理一個event, 我們也想記錄處理多個event的信息消恍，這個時候的操作就是stateful有狀態(tài)的更胖。 ...
-
Fault Tolerance1. State Backend Flink管理的state存儲在state backend里技掏。一種是RocksDB, 一種是JVM heap....
-
Event-Driven Applications
1. ProcessFunctions ProcessFunction能夠同時處理timers和state预茄，這也是創(chuàng)建event-driven ...
-
Streaming Analytics1. Event Time and Watermarks Flink 支持三種time模式：event time: 事件發(fā)生的時間ingesti...
-
Data Pipelines & ETL
Flink一個最常見的use case就是做ETL兴溜。 1. Stateless Transformation 無狀態(tài)的轉(zhuǎn)換最基礎(chǔ)的操作就是map...
-
DataStream API介紹1. 什么樣的數(shù)據(jù)可以流化 對于Java和Scala來說，凡是可以被序列化的對象都可以流化耻陕。Flink自己的序列化器可以用于： 基本數(shù)據(jù)類型：S...