ark::pipeline::CollectRuntimesStage

Defined in header “ark/pipeline/stages/collect_runtimes_stage.hh”.

---

This stage will retrieve all pipeline metrics during execution to tally the expected runtimes for all subscribers in this pipeline. Upon pipeline completion, the final tally for the expected runtimes will be emitted.

Methods

• CollectRuntimesStage(std::string name)
  Constructor.

• ~CollectRuntimesStage()
  Destructor.

• void initialize(pipeline::StageInterface & interface)
  Called from the executor when we are initialized.

• void finalize()
  Write out the calculated runtime values collected by this stage.