參考：
使用process，自定義coprocessfunction
使用state記錄兩條流的資料，
在process1中，判斷資料2是否存在，存在則collect，不存在則開啟timer
文章中timer的時間寫法有問題
應該用context.timestamp()+time.seconds(5).tomilliseconds
但是前提是 env.setstreamtimecharacteristic(timecharacteristic.ingestiontime);
參考
Flink 專案案例實操01
專案詳情 基於實時計算，您可以輕鬆完成實時欺詐檢測系統。實時欺詐檢測系統能夠及時發現使用者高危行為並採取措施，降低損失。實時欺詐檢測 風控 系統流程如下 實時計算訂閱訊息佇列，過濾出感興趣的行為，比如 購買 領券 瀏覽等。實時計算計算把這個行為特徵化。實時計算通過udf呼叫外部乙個風險模型，判斷這次...
UDP SOCKET程式設計中的connect
udp是乙個無連線的協議，因此socket函式connect 似乎對udp是沒有意義的，然而事實不是這樣。使用connect 來建立與服務程式的連線。與tcp協議不同，udp的connect 並沒有與服務程式三次握手。上面說了udp是非連線的，實際上也可以是連線的。使用連線的udp，kernel可以...
qt中的 connect 函式
1 connect 函式實現的是訊號與槽的關聯。注意 只有qo bject類及其派生的類才能使用訊號和槽的機制 2 函式原型 static qmetaobject connection connect const qobject sender,const char signal,const qobj...