#include <Configurations/Coordinator/CoordinatorConfiguration.hpp>
#include <Exceptions/ErrorListener.hpp>
#include <Identifiers/Identifiers.hpp>
#include <Util/VirtualEnableSharedFromThis.hpp>
#include <folly/concurrency/UnboundedQueue.h>
#include <future>
#include <string>
#include <thread>
#include <vector>

Include dependency graph for NesCoordinator.hpp:

This graph shows which files directly or indirectly include this file:

Classes
class	NES::NesCoordinator

Namespaces
	grpc

	NES
	This exception represents a network error.

	NES::Statistic

	NES::Runtime
	Turn this on to have Thread::current_num_threads_ keep a count of currently-active threads.

	NES::Catalogs

	NES::Catalogs::Source

	NES::Catalogs::Query

	NES::Catalogs::UDF

	NES::Optimizer

Typedefs
using	NES::Statistic::StatisticProbeHandlerPtr = std::shared_ptr< StatisticProbeHandler >

using	NES::Runtime::QueryStatisticsPtr = std::shared_ptr< QueryStatistics >

using	NES::Runtime::NodeEnginePtr = std::shared_ptr< NodeEngine >

using	NES::RequestQueuePtr = std::shared_ptr< RequestQueue >

using	NES::TopologyPtr = std::shared_ptr< Topology >

using	NES::RestServerPtr = std::shared_ptr< RestServer >

using	NES::NesWorkerPtr = std::shared_ptr< NesWorker >

using	NES::RequestHandlerServicePtr = std::shared_ptr< RequestHandlerService >

using	NES::QueryParsingServicePtr = std::shared_ptr< QueryParsingService >

using	NES::MonitoringServicePtr = std::shared_ptr< MonitoringService >

using	NES::GlobalQueryPlanPtr = std::shared_ptr< GlobalQueryPlan >

using	NES::WorkerRPCClientPtr = std::shared_ptr< WorkerRPCClient >

using	NES::CoordinatorHealthCheckServicePtr = std::shared_ptr< CoordinatorHealthCheckService >

using	NES::LocationServicePtr = std::shared_ptr< LocationService >

using	NES::Catalogs::Source::SourceCatalogPtr = std::shared_ptr< SourceCatalog >

using	NES::Catalogs::Query::QueryCatalogPtr = std::shared_ptr< QueryCatalog >

using	NES::Catalogs::UDF::UDFCatalogPtr = std::shared_ptr< UDFCatalog >

using	NES::Optimizer::GlobalExecutionPlanPtr = std::shared_ptr< GlobalExecutionPlan >

using	NES::Optimizer::PlacementAmendmentHandlerPtr = std::shared_ptr< PlacementAmendmentHandler >

using	NES::NesCoordinatorPtr = std::shared_ptr< NesCoordinator >

Classes

Namespaces

Typedefs