NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
NodeEngine.hpp File Reference
#include "OperatorHandlerStore.hpp"
#include <Exceptions/ErrorListener.hpp>
#include <Network/ExchangeProtocolListener.hpp>
#include <Network/NetworkForwardRefs.hpp>
#include <Runtime/Execution/ExecutableQueryPlanStatus.hpp>
#include <Runtime/RuntimeForwardRefs.hpp>
#include <StatisticCollection/StatisticManager.hpp>
#include <Util/VirtualEnableSharedFromThis.hpp>
#include <iostream>
#include <map>
#include <mutex>
#include <pthread.h>
#include <string>
#include <unistd.h>
#include <unordered_set>
#include <vector>
Include dependency graph for NodeEngine.hpp:
This graph shows which files directly or indirectly include this file:

Classes

class  NES::Runtime::NodeEngine
 this class represents the interface and entrance point into the query processing part of NES. It provides basic functionality such as deploying, undeploying, starting, and stopping. More...
 

Namespaces

 NES
 This exception represents a network error.
 
 NES::Monitoring
 
 NES::Runtime
 Turn this on to have Thread::current_num_threads_ keep a count of currently-active threads.
 

Typedefs

using NES::PhysicalSourceTypePtr = std::shared_ptr< PhysicalSourceType >