flink學習筆記-dataStream經常使用算子、自定義分區、自定義sink

flink當中對於實時處理,有不少的算子,咱們能夠來看看經常使用的算子主要有哪些,dataStream當中的算子主要分爲三大類,html Transformations:轉換的算子,都是懶執行的,只有真正碰到sink的算子纔會真正加載執行 partition:對數據進行從新分區等操做 Sink:數據下沉目的地 官網算子介紹:https://ci.apache.org/projects/flink/
相關文章
相關標籤/搜索