SourceGrouping takes Source, groups them together according to its GroupingCriteria and stores them. When a ProcessSourcesEvent is received the sources that need to be processed are output together with the sources they are grouped with as a SourceGroup. More...

#include <SourceGrouping.h>

Inheritance diagram for SourceXtractor::SourceGrouping:

[legend]

Collaboration diagram for SourceXtractor::SourceGrouping:

[legend]

Public Member Functions
virtual	~SourceGrouping ()=default
	Destructor.
	SourceGrouping (std::shared_ptr< GroupingCriteria > grouping_criteria, std::shared_ptr< SourceGroupFactory > group_factory, unsigned int hard_limit)
std::set< PropertyId >	requiredProperties () const override
	Returns the set of required properties to compute the grouping.
void	receiveSource (std::unique_ptr< SourceInterface > source) override
	Handles a new Source.
void	receiveProcessSignal (const ProcessSourcesEvent &event) override
	Handles a ProcessSourcesEvent to trigger the processing of some of the Sources stored in SourceGrouping.
Public Member Functions inherited from SourceXtractor::PipelineEmitter< SourceGroupInterface >
	~PipelineEmitter () override=default
void	setNextStage (std::shared_ptr< PipelineReceiver< SourceGroupInterface > > next)
Public Member Functions inherited from SourceXtractor::Observable< SourceGroupInterface >
virtual	~Observable ()=default
	Destructor.
virtual void	addObserver (std::shared_ptr< Observer< SourceGroupInterface > > observer)
	Adds an Observer that will be notified when notify Observers is called.
virtual void	removeObserver (std::shared_ptr< Observer< SourceGroupInterface > > observer)
	Removes a previously added Observer from the list of Observers to notify.
Public Member Functions inherited from SourceXtractor::PipelineReceiver< SourceInterface >
virtual	~PipelineReceiver ()=default

Private Attributes
std::shared_ptr< GroupingCriteria >	m_grouping_criteria
std::shared_ptr< SourceGroupFactory >	m_group_factory
std::list< std::unique_ptr< SourceGroupInterface > >	m_source_groups
unsigned int	m_hard_limit

Additional Inherited Members
Protected Member Functions inherited from SourceXtractor::PipelineEmitter< SourceGroupInterface >
void	sendSource (std::unique_ptr< SourceGroupInterface > source) const
void	sendProcessSignal (const ProcessSourcesEvent &event) const
Protected Member Functions inherited from SourceXtractor::Observable< SourceGroupInterface >
void	notifyObservers (const SourceGroupInterface &message) const

Detailed Description

SourceGrouping takes Source, groups them together according to its GroupingCriteria and stores them. When a ProcessSourcesEvent is received the sources that need to be processed are output together with the sources they are grouped with as a SourceGroup.

Definition at line 98 of file SourceGrouping.h.

Constructor & Destructor Documentation

◆ ~SourceGrouping()

virtual SourceXtractor::SourceGrouping::~SourceGrouping ( )

virtualdefault

Destructor.

◆ SourceGrouping()

SourceXtractor::SourceGrouping::SourceGrouping	(	std::shared_ptr< GroupingCriteria >	grouping_criteria,
		std::shared_ptr< SourceGroupFactory >	group_factory,
		unsigned int	hard_limit )