1.水位線：
2.clickhouse的分布式表:
3.關於時間戳和水位線理解：
介面：timestampassigner,此介面是哦提取時間戳的。利用assigntimesandwatermarks()傳入。
為什麼是- 就是水位線我往前 這樣的話 可以容忍 遲到的資料。
flink的處理函式：
processfunction
keyedprocessfunction
coprocessfunction
processjoinfunction
broadcastprocessfunction
keyed
broadcas
tproce
ssfun
ction
processwindow
function
processallwindowfunction、
nc的使用：
我自己對學習的理解
很多同學在納悶，為什麼覺得自己付出了很多，但是成績依然不理想？其實不同的人對於數學這門課的天份是不一樣的，有的同學付出的不多，但學到的相對比較多，有的則不然。不論怎樣，學習的路很長，不能以一時成敗就裹足不前，要放長線，向遠看，樹立自己的目標，日積月累，相信時間的積累，最後的成果是豐碩的。天下不可能有...
Flink學習筆記（六） flink的運算元與富函式
一 flink中的的transformation運算元 flink常用運算元就不自己詳細記錄了，看這裡就夠了。二 富函式 在呼叫datastream的運算元例如map filter時，可以傳入乙個函式，也可以傳入乙個function類，就像這樣 val filterstream stream.fil...
我自己的BLOG
我的blog終於開始了,希望能與大家一起學習,一起進步 我最早接觸電腦是在上大學一年級的時候,那個時候不知道電腦是什麼東東,只是聽同學說過那個東西什麼都能做.真的有那麼神奇嗎 我第一次用電腦還是在計算機課上,上機實驗,每個人一台機器,心理感覺真的很爽,就是不會用 當把機器開啟的時候,進的是個dos系...