flinkTrigger基礎認識

2021-10-25 09:27:46 字數 786 閱讀 6553

trigger是flink視窗的觸發器,也就是說它決定著什麼時候視窗關閉,它有四個內建方法,

*onelement() 方法會在視窗中每進入一條資料的時候呼叫一次

*onprocessingtime() 方法會在乙個processingtime定時器觸發的時候呼叫

*oneventtime()方法會在乙個eventtime定時器觸發的時候呼叫

*clear()方法會在視窗清除的時候呼叫

比如說在乙個對學生分數進行keyby–window(time)–sum的計算中,觸發視窗的是乙個定時器,但是假如我需要視窗在一些特殊情況結束運算,那該怎麼辦,在trigger的四個方法裡,除了clear()外的其他三個方法都用於關閉視窗,大多數情況我們的自定義視窗關閉會在onelement()中完成,因為資料會進入該方法,我們的操作空間更廣。

我們怎麼做到自定義關閉視窗?

在可以控制視窗關閉的三個方法返回值都是列舉類triggerresult,現在我們來認識一下triggerresult列舉類的四個列舉值

clear()方法會在視窗結束的時候呼叫,並不受fire_and_purge中清除視窗的影響,也就是說,就算在onelement中返回fire_and_purge,也不過進入到clear()方法。我們想做到自定義清楚視窗需要靈活使用continue與其他列舉類進行判斷使用。還有我們在trigger視窗內設定的valuestate值會在下乙個視窗來之前置空。

fire_and_purge進行視窗清楚的時候不會進入clear()

待研究。。。。

以上為本人經過查詢資料和測試的來,歡迎同學指正,一起進步

springsecurity Run As認證服務

zhangxin.security.service.roleservice.loadmenu role user,run as temp zhangxin.security.runasdemo.runasdate.showdate role admin,role run as temp object...

c WebApi之身份驗證 Basic基礎認證

為什麼需要身份認證 身份認證是為了提高介面訪問的安全性,如果沒有身份驗證,那麼任何只要知道伺服器的url,就可以隨意訪問伺服器,從而訪問或者運算元據庫,這會是很恐怖的事。什麼是basic基礎認證 basic基礎認證是一種簡單的使用者名稱 密碼驗證過程,它的主要原理是加密使用者資訊,生成票據,每次需要...

Token Cookie Session的認識了解

token token的意思是 令牌 是使用者身份的驗證方式,最簡單的token組成 uid 使用者唯一的身份標識 time 當前時間的時間戳 sign 簽名,由token的前幾位 雜湊演算法壓縮成一定長的十六進製制字串,可以防止惡意第三方拼接token請求伺服器 還可以把不變的引數也放進token...