|
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().