The placement amendment handler class is responsible for processing placement amendments of updated shared query plans. To this end, we can initialize the handles with a pre-configured number of handler threads. More...

#include <PlacementAmendmentHandler.hpp>

Public Member Functions
	PlacementAmendmentHandler (uint16_t numOfHandler)
	Ctor. More...

virtual	~PlacementAmendmentHandler ()
	Dtor. More...

void	start ()
	Start processing amendment instances. More...

void	shutDown ()
	Shutdown the handler. More...

virtual void	enqueueRequest (const NES::Optimizer::PlacementAmendmentInstancePtr &placementAmendmentInstance)
	Method allows to enqueue the amendment instance for execution in the queue. More...

Detailed Description

The placement amendment handler class is responsible for processing placement amendments of updated shared query plans. To this end, we can initialize the handles with a pre-configured number of handler threads.

Constructor & Destructor Documentation

◆ PlacementAmendmentHandler()

NES::Optimizer::PlacementAmendmentHandler::PlacementAmendmentHandler ( uint16_t numOfHandler )

Ctor.

Parameters

numOfHandler number of handler threads to spawn

◆ ~PlacementAmendmentHandler()

NES::Optimizer::PlacementAmendmentHandler::~PlacementAmendmentHandler ( )

virtual

Dtor.

References NES_INFO, and shutDown().

Here is the call graph for this function:

Member Function Documentation

◆ enqueueRequest()

void NES::Optimizer::PlacementAmendmentHandler::enqueueRequest ( const NES::Optimizer::PlacementAmendmentInstancePtr & placementAmendmentInstance )

virtual

Method allows to enqueue the amendment instance for execution in the queue.

Parameters

placementAmendmentInstance : the object containing required payload and execution logic for amending invalid or missing placements of a shared query plan

◆ shutDown()

void NES::Optimizer::PlacementAmendmentHandler::shutDown ( )

Shutdown the handler.

References NES_INFO, and NES_WARNING.

Referenced by ~PlacementAmendmentHandler().

Here is the caller graph for this function:

◆ start()

void NES::Optimizer::PlacementAmendmentHandler::start ( )

Start processing amendment instances.