Apache Apex 中的运算符生命周期是什么？

Question

用户转发@apex.incubator.apache.org

什么时候调用运算符的构造函数？文档说在操作员的一生中只有一次，但我想知道 "lifetime" 的定义是否跨越 apex 应用程序的 start/stop/crash（由于编码错误）？

Answer 1

运算符有一个生命周期。构造函数 --> 已应用检查点状态 --> setup() --> loop {beginWindow() --> loop {process() for each input port} --> endWindow()} --> tearDown()。当操作员恢复时，循环是相同的。检查点状态是运算符崩溃前最后一个已知检查点的状态。

Answer 2

给定的运算符具有以下生命周期，如下所示。生命周期跨越算子实例的执行周期。如果操作员失败，生命周期将重新开始，如下所示。运算符状态的检查点每隔几个 windows 定期出现一次，并且在发生故障时成为最后一个已知的检查点。

→ Constructor is called
→ State is applied from last known checkpoint
→ setup()
→ loop over { 
        → beginWindow()  
        → loop over {
                → process()  
          }
        → endWindow()
  }    
→ teardown()

Apache Apex 中的运算符生命周期是什么？

What is the operator lifecycle in Apache Apex?

apache-apex