从[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()。当操作员恢复时,周期是一样的。检查点状态是操作员崩溃之前最后一个已知检查点的状态。