從[email protected]轉發Apache Apex中的操作符生命週期是什麼?
何時調用操作符的構造函數?文檔在運營商的一生中說過一次,但我想知道「生命週期」的定義是否涵蓋了apex應用的開始/停止/崩潰(由於編碼錯誤)?
從[email protected]轉發Apache Apex中的操作符生命週期是什麼?
何時調用操作符的構造函數?文檔在運營商的一生中說過一次,但我想知道「生命週期」的定義是否涵蓋了apex應用的開始/停止/崩潰(由於編碼錯誤)?
給定的操作符的生命週期如下。生命週期跨越操作員實例的執行週期。如果操作員失敗,生命週期從下面開始。運營商狀態的檢查點每隔幾個窗口週期性地發生一次,並且在發生故障時它成爲最後已知的檢查點。
→ Constructor is called
→ State is applied from last known checkpoint
→ setup()
→ loop over {
→ beginWindow()
→ loop over {
→ process()
}
→ endWindow()
}
→ teardown()
操作員有生命週期。構造函數 - >檢查點狀態應用 - > setup() - > loop {beginWindow() - > loop {process()爲每個輸入端口} - > endWindow()} - > tearDown()。當操作員恢復時,週期是一樣的。檢查點狀態是操作員崩潰之前最後一個已知檢查點的狀態。