#include <NesCoordinator.hpp>

Collaboration diagram for NES::NesCoordinator:

Public Member Functions
	NesCoordinator (CoordinatorConfigurationPtr coordinatorConfig)

	~NesCoordinator () override
	dtor More...

uint64_t	startCoordinator (bool blocking)
	start rpc server: rest server, and one worker < More...

bool	stopCoordinator (bool force)
	method to stop coordinator More...

std::vector< Runtime::QueryStatisticsPtr >	getQueryStatistics (SharedQueryId sharedQueryId)
	method to return the query statistics More...

Catalogs::Source::SourceCatalogPtr	getSourceCatalog () const
	catalog method for debug use only More...

TopologyPtr	getTopology () const
	get topology of coordinator More...

RequestHandlerServicePtr	getRequestHandlerService ()
	Get the instance of query service. More...

Catalogs::Query::QueryCatalogPtr	getQueryCatalog ()
	Get instance of query catalog. More...

Catalogs::UDF::UDFCatalogPtr	getUDFCatalog ()
	Return the UDF catalog. More...

MonitoringServicePtr	getMonitoringService ()
	Get instance of monitoring service. More...

GlobalQueryPlanPtr	getGlobalQueryPlan ()
	Get the instance of Global Query Plan. More...

Runtime::NodeEnginePtr	getNodeEngine ()

void	onFatalError (int signalNumber, std::string string) override
	onFatalError shall be called when a signal is caught More...

void	onFatalException (std::shared_ptr< std::exception > ptr, std::string string) override
	onFatalException shall be called when an exception is caught More...

bool	isCoordinatorRunning ()
	Method to check if a coordinator is still running. More...

LocationServicePtr	getLocationService () const

Optimizer::GlobalExecutionPlanPtr	getGlobalExecutionPlan () const

NesWorkerPtr	getNesWorker ()

Statistic::StatisticProbeHandlerPtr	getStatisticProbeHandler () const

Public Member Functions inherited from NES::detail::virtual_enable_shared_from_this< NesCoordinator >
	~virtual_enable_shared_from_this () NES_NOEXCEPT(true) override=default

std::shared_ptr< T1 >	shared_from_this ()

std::weak_ptr< T1 >	weak_from_this ()

Public Member Functions inherited from NES::detail::virtual_enable_shared_from_this_base< true >
virtual	~virtual_enable_shared_from_this_base () NES_NOEXCEPT(isNoexceptDestructible)=default

Public Member Functions inherited from NES::detail::virtual_enable_shared_from_this< ErrorListener >
	~virtual_enable_shared_from_this () NES_NOEXCEPT(true) override=default

std::shared_ptr< T1 >	shared_from_this ()

std::weak_ptr< T1 >	weak_from_this ()

Static Public Attributes
constexpr static uint64_t	NES_COORDINATOR_ID = 1

Constructor & Destructor Documentation

◆ NesCoordinator()

NES::NesCoordinator::NesCoordinator ( CoordinatorConfigurationPtr coordinatorConfig )

explicit

References NES::Compiler::JITCompilerBuilder::build(), NES::Compiler::CPPCompiler::create(), NES::Statistic::DefaultStatisticQueryGenerator::create(), NES::QueryParsingService::create(), NES_DEBUG, NES::Compiler::JITCompilerBuilder::registerLanguageCompiler(), and NES::setThreadName().

Here is the call graph for this function:

◆ ~NesCoordinator()

NES::NesCoordinator::~NesCoordinator ( )

override

dtor

Returns

References NES_DEBUG, and stopCoordinator().

Here is the call graph for this function:

Member Function Documentation

◆ getGlobalExecutionPlan()

Optimizer::GlobalExecutionPlanPtr NES::NesCoordinator::getGlobalExecutionPlan ( ) const

getter for the global execution plan

Returns

◆ getGlobalQueryPlan()

GlobalQueryPlanPtr NES::NesCoordinator::getGlobalQueryPlan ( )

Get the instance of Global Query Plan.

Returns: Global query plan

◆ getLocationService()

LocationServicePtr NES::NesCoordinator::getLocationService ( ) const

getter for the locationService

Returns

◆ getMonitoringService()

MonitoringServicePtr NES::NesCoordinator::getMonitoringService ( )

Get instance of monitoring service.

Returns: monitoring service pointer

◆ getNesWorker()

NesWorkerPtr NES::NesCoordinator::getNesWorker ( )

◆ getNodeEngine()

Runtime::NodeEnginePtr NES::NesCoordinator::getNodeEngine ( )

◆ getQueryCatalog()

Catalogs::Query::QueryCatalogPtr NES::NesCoordinator::getQueryCatalog ( )

Get instance of query catalog.

Returns: query catalog pointer

◆ getQueryStatistics()

std::vector< Runtime::QueryStatisticsPtr > NES::NesCoordinator::getQueryStatistics ( SharedQueryId sharedQueryId )

method to return the query statistics

Parameters

id	of the shared query

Returns: vector of queryStatistics

References NES_INFO.

◆ getRequestHandlerService()

RequestHandlerServicePtr NES::NesCoordinator::getRequestHandlerService ( )

Get the instance of query service.

Returns: Query service pointer

◆ getSourceCatalog()

Catalogs::Source::SourceCatalogPtr NES::NesCoordinator::getSourceCatalog ( ) const

catalog method for debug use only

Returns: sourceCatalog

◆ getStatisticProbeHandler()

Statistic::StatisticProbeHandlerPtr NES::NesCoordinator::getStatisticProbeHandler ( ) const

◆ getTopology()

TopologyPtr NES::NesCoordinator::getTopology ( ) const

get topology of coordinator

Returns: topology

◆ getUDFCatalog()

Catalogs::UDF::UDFCatalogPtr NES::NesCoordinator::getUDFCatalog ( )

Return the UDF catalog.

Returns: Pointer to the UDF catalog.

◆ isCoordinatorRunning()

bool NES::NesCoordinator::isCoordinatorRunning ( )

Method to check if a coordinator is still running.

Returns: running status of the coordinator

◆ onFatalError()

void NES::NesCoordinator::onFatalError	(	int	signalNumber,
		std::string
	)

overridevirtual

onFatalError shall be called when a signal is caught

Parameters

signalNumber	the caught signal
stacktrace	the stacktrace of the error

Implements NES::Exceptions::ErrorListener.

◆ onFatalException()

void NES::NesCoordinator::onFatalException	(	std::shared_ptr< std::exception >	,
		std::string
	)

overridevirtual

onFatalException shall be called when an exception is caught

Parameters

exception	the caught exception
stacktrace	the stacktrace of the error

Implements NES::Exceptions::ErrorListener.

◆ startCoordinator()

uint64_t NES::NesCoordinator::startCoordinator ( bool blocking )

start rpc server: rest server, and one worker <

Parameters

bool	if the method should block

blocking

withConnect

References NES::Schema::createFromSchemaType(), NES::Exceptions::installGlobalErrorListener(), backward::details::move(), NES_ASSERT, NES_ASSERT2_FMT, NES_DEBUG, NES_INFO, NES_THROW_RUNTIME_ERROR, NES::setThreadName(), and NES::detail::virtual_enable_shared_from_this< NesCoordinator >::weak_from_this().

Here is the call graph for this function:

◆ stopCoordinator()

bool NES::NesCoordinator::stopCoordinator ( bool force )

method to stop coordinator

Parameters

force the shutdown even when queryIdAndCatalogEntryMapping are running

Returns: bool indicating success

References NES_DEBUG, NES_ERROR, and NES_THROW_RUNTIME_ERROR.

Referenced by ~NesCoordinator().

Here is the caller graph for this function:

Member Data Documentation

◆ NES_COORDINATOR_ID

constexpr static uint64_t NES::NesCoordinator::NES_COORDINATOR_ID = 1

staticconstexpr

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

/nebulastream/nes-coordinator/include/Components/NesCoordinator.hpp
/nebulastream/nes-coordinator/src/Components/NesCoordinator.cpp

Public Member Functions

Static Public Attributes

Constructor & Destructor Documentation

◆ NesCoordinator()

◆ ~NesCoordinator()

Member Function Documentation

◆ getGlobalExecutionPlan()

◆ getGlobalQueryPlan()

◆ getLocationService()

◆ getMonitoringService()

◆ getNesWorker()

◆ getNodeEngine()

◆ getQueryCatalog()

◆ getQueryStatistics()

◆ getRequestHandlerService()

◆ getSourceCatalog()

◆ getStatisticProbeHandler()

◆ getTopology()

◆ getUDFCatalog()

◆ isCoordinatorRunning()

◆ onFatalError()

◆ onFatalException()

◆ startCoordinator()

◆ stopCoordinator()

Member Data Documentation

◆ NES_COORDINATOR_ID