flink Iterate迭代基本概念

2022-06-06 01:48:08 字數 628 閱讀 7054

基本概念:在流中建立「反饋(feedback)」迴圈,通過將乙個運算元的輸出重定向到某個先前的運算元。這對於定義不斷更新模型的演算法特別有用。

迭代的資料流向:datastream → iterativestream → datastream

以下**以流開始並連續應用迭代體。大於0的元素將被傳送回反饋(feedback)通道,繼續迭代,其餘元素將向下游**,離開迭代。

iterativestreamiteration =initialstream.iterate();

datastream

iterationbody = iteration.map (/*

do something

*/);

datastream

feedback = iterationbody.filter(new filterfunction()

});//這裡設定feedback這個資料流是被反饋的通道,只要是value>0的資料都會被重新迭代計算。

iteration.closewith(feedback);

datastream

output = iterationbody.filter(new filterfunction()

});

Optimized Purchasing基礎知識

pr的三要素 物料 數量 採購日期 日期是會影響價錢的 blanket po fo框架訂單。a 成本中心,i 限制 專案的限制標籤 miro支票不管數量,從帳戶分配輸入金額。產生pr三種 me51n,me25,mrp 產生po四種 me21n,me25,me57,me59n evo 物料管理 採購 ...

Phabricator Arcanist基本用法

git clone git git clone git 獲取到arcanist的原始碼後,進行相關配置 開啟.bash profile open e bash profile在環境變數中新增 export path path somewhere arcanist bin 命令列中輸入arc命令檢視是...

HttpServletResponse基本功能

request是請求物件,而response是響應物件。response物件的功能分為以下四種 設定響應頭資訊 addheader refresh 5 url x 傳送狀態碼 senderror 404 設定響應正文 getwriter print fdsfdsa 重定向 sendredirect ...