QueryManager.hpp File Reference

#include <Identifiers/Identifiers.hpp>
#include <Listeners/QueryStatusListener.hpp>
#include <Runtime/BufferManager.hpp>
#include <Runtime/Execution/ExecutablePipeline.hpp>
#include <Runtime/Execution/ExecutableQueryPlan.hpp>
#include <Runtime/Execution/ExecutableQueryPlanStatus.hpp>
#include <Runtime/QueryStatistics.hpp>
#include <Runtime/Reconfigurable.hpp>
#include <Runtime/ReconfigurationMessage.hpp>
#include <Runtime/RuntimeForwardRefs.hpp>
#include <Runtime/Task.hpp>
#include <Sources/DataSource.hpp>
#include <Util/AtomicCounter.hpp>
#include <Util/MMapCircularBuffer.hpp>
#include <Util/ThreadBarrier.hpp>
#include <Util/VirtualEnableSharedFromThis.hpp>
#include <Util/libcuckoo/cuckoohash_map.hh>
#include <chrono>
#include <condition_variable>
#include <deque>
#include <map>
#include <memory>
#include <mutex>
#include <shared_mutex>
#include <thread>
#include <unordered_map>
#include <unordered_set>
#include <Reconfiguration/ReconfigurationMarker.hpp>
#include <folly/MPMCQueue.h>
#include <folly/concurrency/UnboundedQueue.h>

Include dependency graph for QueryManager.hpp:

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

Classes
class	NES::Runtime::AbstractQueryManager
class	NES::Runtime::DynamicQueryManager
class	NES::Runtime::MultiQueueQueryManager

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

Typedefs
using	NES::Network::NetworkSourcePtr = std::shared_ptr< NetworkSource >
using	NES::Runtime::ThreadPoolPtr = std::shared_ptr< ThreadPool >
using	NES::Runtime::QueryManagerPtr = std::shared_ptr< AbstractQueryManager >
using	NES::Runtime::DynamicQueryManagerPtr = std::shared_ptr< DynamicQueryManager >
using	NES::Runtime::MultiQueueQueryManagerPtr = std::shared_ptr< MultiQueueQueryManager >