一：flink中的的transformation運算元
flink常用運算元就不自己詳細記錄了，看這裡就夠了。
二：富函式
在呼叫datastream的運算元例如map、filter時，可以傳入乙個函式，也可以傳入乙個function類，就像這樣：
val filterstream = stream.
filter
(new
filterfunction
[string]
})
class
mymapfunction
extends
richmapfunction
[string,string]
override def map
(in: string)
: string =
///open方法會在運算元呼叫後執行，一般做一些清理工作，例如關閉連線
override def close()
: unit =
}
val mapstream = stream.
map(
newmymapfunction
)
flink學習 flink架構
flink結構 graph 2個併發度 source為1個併發度 的sockettextstreamwordcount四層執行圖的演變過程 jobgraph streamgraph經過優化後生成了 jobgraph，提交給 jobmanager 的資料結構。executiongraph jobman...
Flink學習筆記（五） flink資料合流
上一章記錄了flink的分流操作，那麼有分流是不是應該有合流呢？當然是有這樣的操作啦 stream1和stream2流需要合併為stream流 1.union合流 2.connect合流 前置配置 streamexecutionenvironment env streamexecutionenvir...
Flink學習筆記1 Flink框架api介紹
1.獲得 execution 環境 getexecutionenvironment createlocalenvironment createremoteenvironment string host,int port,string.jarfiles 批處理示例 executionenvironme...