NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
#include <ReconfigurationMarkerSerializationUtil.hpp>
Static Public Member Functions | |
static void | serialize (const ReconfigurationMarkerPtr &reconfigurationMarker, SerializableReconfigurationMarker &serializableReconfigurationMarker) |
Serialize reconfiguration marker. More... | |
static void | deserialize (const SerializableReconfigurationMarker &serializableReconfigurationMarker, ReconfigurationMarkerPtr reconfigurationMarker) |
Deserialize reconfiguration marker. More... | |
|
static |
Deserialize reconfiguration marker.
serializableReconfigurationMarker | : serialized marker that needs to be deserialized |
reconfigurationMarker | : deserialized marker |
References NES::ReconfigurationMarkerEvent::create(), NES::QueryStateSerializationUtil::deserializeQueryState(), and NES_DEBUG.
Referenced by TEST_F().
|
static |
Serialize reconfiguration marker.
reconfigurationMarker | : marker to be serialized |
serializableReconfigurationMarker | : serialized marker |
References NES::DrainQuery, NES_DEBUG, NES::QueryStateSerializationUtil::serializeQueryState(), NES::UpdateAndDrainQuery, NES::UpdateQuery, and magic_enum::detail::value().
Referenced by NES::WorkerRPCClient::addReconfigurationMarker(), and TEST_F().