NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
Nes components that require to be reconfigured at Runtime need to inherit from this class. It provides a reconfigure callback that will be called per thread and a postReconfigurationCallback that will be called on the last thread the executes the reconfiguration. More...
#include <Reconfigurable.hpp>
Public Member Functions | |
~Reconfigurable () NES_NOEXCEPT(false) override=default | |
virtual void | reconfigure (ReconfigurationMessage &, WorkerContext &) |
reconfigure callback that will be called per thread More... | |
virtual void | postReconfigurationCallback (ReconfigurationMessage &) |
callback that will be called on the last thread the executes the reconfiguration More... | |
![]() | |
~virtual_enable_shared_from_this () NES_NOEXCEPT(isNoexceptDestructible) override=default | |
std::shared_ptr< T1 > | shared_from_this () |
std::weak_ptr< T1 > | weak_from_this () |
![]() | |
virtual | ~virtual_enable_shared_from_this_base () NES_NOEXCEPT(isNoexceptDestructible)=default |
Nes components that require to be reconfigured at Runtime need to inherit from this class. It provides a reconfigure callback that will be called per thread and a postReconfigurationCallback that will be called on the last thread the executes the reconfiguration.
|
overridedefault |
|
inlinevirtual |
callback that will be called on the last thread the executes the reconfiguration
Reimplemented in NES::SinkMedium, NES::Network::NetworkSource, NES::Network::NetworkSink, NES::Runtime::AbstractQueryManager, NES::Runtime::Execution::ExecutableQueryPlan, and NES::Runtime::Execution::ExecutablePipeline.
Referenced by NES::Runtime::Execution::ExecutablePipeline::postReconfigurationCallback(), NES::Runtime::Execution::ExecutableQueryPlan::postReconfigurationCallback(), NES::Runtime::AbstractQueryManager::postReconfigurationCallback(), NES::Network::NetworkSource::postReconfigurationCallback(), and NES::SinkMedium::postReconfigurationCallback().
|
inlinevirtual |
reconfigure callback that will be called per thread
Reimplemented in NES::Network::NetworkSink, NES::SinkMedium, NES::Network::NetworkSource, NES::Runtime::Execution::ExecutablePipeline, and NES::Runtime::AbstractQueryManager.
Referenced by NES::Runtime::AbstractQueryManager::reconfigure(), NES::Runtime::Execution::ExecutablePipeline::reconfigure(), NES::Network::NetworkSource::reconfigure(), and NES::SinkMedium::reconfigure().