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

Репост с адреса [email protected]

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


person Community    schedule 22.04.2016    source источник


Ответы (2)


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

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

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

person Community    schedule 22.04.2016