NES::Runtime::NodeEngine Member List

This is the complete list of members for NES::Runtime::NodeEngine, including all inherited members.

addReconfigureMarker(SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, ReconfigurationMarkerPtr &reconfigurationMarker)	NES::Runtime::NodeEngine
bufferData(DecomposedQueryId decomposedQueryId, DecomposedQueryPlanVersion decomposedQueryVersion, OperatorId uniqueNetworkSinkDescriptorId)	NES::Runtime::NodeEngine
checkDecomposableQueryPlanToStart(DecomposedQueryId id, DecomposedQueryPlanVersion version)	NES::Runtime::NodeEngine
deployExecutableQueryPlan(const Execution::ExecutableQueryPlanPtr &executableQueryPlan)	NES::Runtime::NodeEngine
getBufferManager(uint32_t bufferManagerIndex=0) const	NES::Runtime::NodeEngine
getDecomposedQueryIds(SharedQueryId sharedQueryId)	NES::Runtime::NodeEngine
getExecutableQueryPlan(DecomposedQueryId decomposedQueryId, DecomposedQueryPlanVersion decomposedQueryVersion) const	NES::Runtime::NodeEngine
getHardwareManager() const	NES::Runtime::NodeEngine
getMetricStore()	NES::Runtime::NodeEngine
getNetworkManager()	NES::Runtime::NodeEngine
getNodeId() const	NES::Runtime::NodeEngine
getOpenCLManager() const	NES::Runtime::NodeEngine
getPartitionManager()	NES::Runtime::NodeEngine
getPhysicalSourceTypes() const	NES::Runtime::NodeEngine
getQueryManager()	NES::Runtime::NodeEngine
getQueryStatistics(SharedQueryId sharedQueryId)	NES::Runtime::NodeEngine
getQueryStatistics(bool withReset=false)	NES::Runtime::NodeEngine
getQueryStatus(SharedQueryId sharedQueryId)	NES::Runtime::NodeEngine
getQueryStatusListener()	NES::Runtime::NodeEngine
getStatisticManager() const	NES::Runtime::NodeEngine
getWorkerId()	NES::Runtime::NodeEngine
NodeEngine()=delete	NES::Runtime::NodeEngine
NodeEngine(const NodeEngine &)=delete	NES::Runtime::NodeEngine
NodeEngine(std::vector< PhysicalSourceTypePtr > physicalSources, HardwareManagerPtr &&, std::vector< BufferManagerPtr > &&, QueryManagerPtr &&, std::function< Network::NetworkManagerPtr(std::shared_ptr< NodeEngine >)> &&, Network::PartitionManagerPtr &&, OperatorHandlerStorePtr, QueryCompilation::QueryCompilerPtr &&, std::weak_ptr< AbstractQueryStatusListener > &&, OpenCLManagerPtr &&, WorkerId nodeEngineId, uint64_t numberOfBuffersInGlobalBufferManager, uint64_t numberOfBuffersInSourceLocalBufferPool, uint64_t numberOfBuffersPerWorker, bool sourceSharing)	NES::Runtime::NodeEngine	explicit
NodeEngineBuilder class	NES::Runtime::NodeEngine	friend
NodeEngineQueryStatus enum name	NES::Runtime::NodeEngine
onChannelError(Network::Messages::ErrorMessage) override	NES::Runtime::NodeEngine	virtual
onDataBuffer(Network::NesPartition, TupleBuffer &) override	NES::Runtime::NodeEngine
NES::Network::ExchangeProtocolListener::onDataBuffer(NesPartition, Runtime::TupleBuffer &)=0	NES::Network::ExchangeProtocolListener	pure virtual
onEndOfStream(Network::Messages::EndOfStreamMessage) override	NES::Runtime::NodeEngine	virtual
onEvent(Network::NesPartition, Runtime::BaseEvent &) override	NES::Runtime::NodeEngine
NES::Network::ExchangeProtocolListener::onEvent(NesPartition, Runtime::BaseEvent &)=0	NES::Network::ExchangeProtocolListener	pure virtual
onFatalError(int signalNumber, std::string callstack) override	NES::Runtime::NodeEngine	virtual
onFatalException(std::shared_ptr< std::exception > exception, std::string callstack) override	NES::Runtime::NodeEngine	virtual
onServerError(Network::Messages::ErrorMessage) override	NES::Runtime::NodeEngine	virtual
operator=(const NodeEngine &)=delete	NES::Runtime::NodeEngine
reconfigureSubPlan(DecomposedQueryPlanPtr &reconfiguredDecomposedQueryPlan)	NES::Runtime::NodeEngine
registerDecomposableQueryPlan(const DecomposedQueryPlanPtr &decomposedQueryPlan)	NES::Runtime::NodeEngine
registerExecutableQueryPlan(const Execution::ExecutableQueryPlanPtr &executableQueryPlan)	NES::Runtime::NodeEngine
setMetricStore(Monitoring::MetricStorePtr metricStore)	NES::Runtime::NodeEngine
setNodeId(const WorkerId NodeId)	NES::Runtime::NodeEngine
virtual_enable_shared_from_this< NodeEngine >::shared_from_this()	NES::detail::virtual_enable_shared_from_this< NodeEngine >	inline
NES::Exceptions::ErrorListener::shared_from_this()	NES::detail::virtual_enable_shared_from_this< ErrorListener >	inline
startDecomposedQueryPlan(SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId)	NES::Runtime::NodeEngine
stop(bool markQueriesAsFailed=false)	NES::Runtime::NodeEngine
stopDecomposedQueryPlan(SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, Runtime::QueryTerminationType terminationType=Runtime::QueryTerminationType::HardStop)	NES::Runtime::NodeEngine
undeployDecomposedQueryPlan(SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId)	NES::Runtime::NodeEngine
unregisterDecomposedQueryPlan(SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId)	NES::Runtime::NodeEngine
updateNetworkSink(WorkerId newNodeId, const std::string &newHostname, uint32_t newPort, DecomposedQueryId decomposedQueryId, DecomposedQueryPlanVersion decomposedQueryVersion, OperatorId uniqueNetworkSinkDescriptorId)	NES::Runtime::NodeEngine
updatePhysicalSources(const std::vector< PhysicalSourceTypePtr > &physicalSources)	NES::Runtime::NodeEngine
virtual_enable_shared_from_this< NodeEngine >::weak_from_this()	NES::detail::virtual_enable_shared_from_this< NodeEngine >	inline
NES::Exceptions::ErrorListener::weak_from_this()	NES::detail::virtual_enable_shared_from_this< ErrorListener >	inline
~ExchangeProtocolListener()=default	NES::Network::ExchangeProtocolListener	virtual
~NodeEngine() override	NES::Runtime::NodeEngine	virtual
virtual_enable_shared_from_this< NodeEngine >::~virtual_enable_shared_from_this() NES_NOEXCEPT(true) override=default	NES::detail::virtual_enable_shared_from_this< NodeEngine >
NES::Exceptions::ErrorListener::~virtual_enable_shared_from_this() NES_NOEXCEPT(true) override=default	NES::detail::virtual_enable_shared_from_this< ErrorListener >
~virtual_enable_shared_from_this_base() NES_NOEXCEPT(isNoexceptDestructible)=default	NES::detail::virtual_enable_shared_from_this_base< true >	virtual