NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
NES::ReconfigurationMarkerSerializationUtil Class Reference

#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...
 

Member Function Documentation

◆ deserialize()

void NES::ReconfigurationMarkerSerializationUtil::deserialize ( const SerializableReconfigurationMarker &  serializableReconfigurationMarker,
ReconfigurationMarkerPtr  reconfigurationMarker 
)
static

Deserialize reconfiguration marker.

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

Here is the call graph for this function:
Here is the caller graph for this function:

◆ serialize()

void NES::ReconfigurationMarkerSerializationUtil::serialize ( const ReconfigurationMarkerPtr reconfigurationMarker,
SerializableReconfigurationMarker &  serializableReconfigurationMarker 
)
static

Serialize reconfiguration marker.

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

Here is the call graph for this function:
Here is the caller graph for this function:

The documentation for this class was generated from the following files: