This class contains logic to transmit a collection of query sub plans to the desired worker nodes. More...

#include <DeploymentPhase.hpp>

Public Member Functions
	DeploymentPhase (const Catalogs::Query::QueryCatalogPtr &queryCatalog)

virtual void	execute (const std::set< Optimizer::DeploymentContextPtr > &deploymentContexts, RequestType requestType)
	method for deploying decomposed query plans in different states More...

virtual void	execute (const std::set< Optimizer::ReconfigurationMarkerUnit > &reconfigurationMarkerUnits, const ReconfigurationMarkerPtr &reconfigurationMarker)
	method for deploying reconfiguration markers More...

virtual	~DeploymentPhase ()=default

Static Public Member Functions
static DeploymentPhasePtr	create (const Catalogs::Query::QueryCatalogPtr &queryCatalog)
	Returns a smart pointer to the QueryDeploymentPhase. More...

Detailed Description

This class contains logic to transmit a collection of query sub plans to the desired worker nodes.

Constructor & Destructor Documentation

◆ DeploymentPhase()

NES::DeploymentPhase::DeploymentPhase ( const Catalogs::Query::QueryCatalogPtr & queryCatalog )

explicit

References NES_INFO.

◆ ~DeploymentPhase()

virtual NES::DeploymentPhase::~DeploymentPhase ( )

virtualdefault

Member Function Documentation

◆ create()

DeploymentPhasePtr NES::DeploymentPhase::create ( const Catalogs::Query::QueryCatalogPtr & queryCatalog )

static

Returns a smart pointer to the QueryDeploymentPhase.

Returns: shared pointer to the instance of QueryDeploymentPhase

Referenced by NES::RequestProcessor::ISQPRequest::executeRequestLogic(), NES::RequestProcessor::StopQueryRequest::executeRequestLogic(), NES::RequestProcessor::AddQueryRequest::executeRequestLogic(), and NES::RequestProcessor::FailQueryRequest::executeRequestLogic().

Here is the caller graph for this function:

◆ execute() [1/2]

void NES::DeploymentPhase::execute	(	const std::set< Optimizer::DeploymentContextPtr > &	deploymentContexts,
		RequestType	requestType
	)

virtual

method for deploying decomposed query plans in different states

Parameters

deploymentContexts	the vector of deployment contexts containing the worker rpc address and decomposed query plan
requestType	request type

Exceptions

ExecutionNodeNotFoundException Unable to find ExecutionNodes where the query {sharedQueryId} is deployed

Reimplemented in NES::RequestProcessor::MockedDeploymentPhase.

References NES_INFO.

◆ execute() [2/2]

void NES::DeploymentPhase::execute	(	const std::set< Optimizer::ReconfigurationMarkerUnit > &	reconfigurationMarkerUnits,
		const ReconfigurationMarkerPtr &	reconfigurationMarker
	)

virtual

method for deploying reconfiguration markers

Parameters

reconfigurationMarkerUnits	set of reconfiguration marker unit
reconfigurationMarker

References NES::Reconfiguration.

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

/nebulastream/nes-coordinator/include/Phases/DeploymentPhase.hpp
/nebulastream/nes-coordinator/src/Phases/DeploymentPhase.cpp

Public Member Functions

Static Public Member Functions