o2::mergers::IntegratingMerger Class Reference

IntegratingMerger data processor class. More...

#include <IntegratingMerger.h>

Inherits o2::framework::Task.

Public Member Functions
	IntegratingMerger (const MergerConfig &, const header::DataHeader::SubSpecificationType &)
	Default constructor. It expects Merger configuration and subSpec of output channel.
	~IntegratingMerger () override=default
	Default destructor.
void	init (framework::InitContext &ctx) override
	IntegratingMerger init callback.
void	run (framework::ProcessingContext &ctx) override
	IntegratingMerger process callback.
void	endOfStream (framework::EndOfStreamContext &eosContext) override
	Callback for CallbackService::Id::EndOfStream.
Public Member Functions inherited from o2::framework::Task
virtual	~Task ()
virtual void	finaliseCCDB (ConcreteDataMatcher &matcher, void *obj)
virtual void	stop ()
	This is invoked on stop.

Detailed Description

IntegratingMerger data processor class.

Mergers are DPL devices able to merge ROOT objects produced in parallel.

Definition at line 41 of file IntegratingMerger.h.

Constructor & Destructor Documentation

IntegratingMerger()

o2::mergers::IntegratingMerger::IntegratingMerger	(	const MergerConfig &	config,
		const header::DataHeader::SubSpecificationType &	subSpec
	)

Default constructor. It expects Merger configuration and subSpec of output channel.

Definition at line 34 of file IntegratingMerger.cxx.

~IntegratingMerger()

o2::mergers::IntegratingMerger::~IntegratingMerger ( )

overridedefault

Default destructor.

Member Function Documentation

endOfStream()

void o2::mergers::IntegratingMerger::endOfStream ( framework::EndOfStreamContext &  eosContext )

overridevirtual

Callback for CallbackService::Id::EndOfStream.

Reimplemented from o2::framework::Task.

Definition at line 139 of file IntegratingMerger.cxx.

init()

void o2::mergers::IntegratingMerger::init ( framework::InitContext &  ctx )

overridevirtual

IntegratingMerger init callback.

Reimplemented from o2::framework::Task.

Definition at line 40 of file IntegratingMerger.cxx.

run()

void o2::mergers::IntegratingMerger::run ( framework::ProcessingContext &  ctx )

overridevirtual

IntegratingMerger process callback.

Implements o2::framework::Task.

Definition at line 58 of file IntegratingMerger.cxx.

---

The documentation for this class was generated from the following files:

• /home/runner/work/AliceO2/AliceO2/Utilities/Mergers/include/Mergers/IntegratingMerger.h
• /home/runner/work/AliceO2/AliceO2/Utilities/Mergers/src/IntegratingMerger.cxx