Что такое жизненный цикл оператора в Apache Apex?

Question

Repost from users@apex.incubator.apache.org

Когда конструктор оператора называется? Документы говорят один раз в течение жизни оператора, но мне было интересно, охватывает ли определение «продолжительность жизни» старт/стоп/сбой (из-за ошибки кодирования) приложения-вершины?

Answer 1

Данный оператор имеет следующий жизненный цикл, как показано ниже. Жизненный цикл охватывает период выполнения экземпляра оператора. В случае сбоя оператора жизненный цикл начинается, как показано ниже. Контрольная точка состояния оператора периодически возникает один раз каждые несколько окон и становится последней известной контрольной точкой в ​​случае отказа.

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

Answer 2

Оператор имеет жизненный цикл. Constructor -> checkpointed state used -> setup() -> loop {beginWindow() -> loop {process() для каждого входного порта} -> endWindow()} -> tearDown(). Когда оператор восстанавливается, цикл тот же. Контролируемое состояние - это состояние от последней известной контрольной точки до того, как оператор разбился.