NES::UpdateAndDrainQueryMetadata Class Reference

Metadata defining the information about the new decomposed plan that needs to be started and immediately terminated. This metadata can be used for state migration using adhoc queries that are merged into the currently running decomposed query. Therefore, first the current plan needs to be updated to perform state migration before terminating it. More...

#include <UpdateAndDrainQueryMetadata.hpp>

Collaboration diagram for NES::UpdateAndDrainQueryMetadata:

Public Member Functions
	UpdateAndDrainQueryMetadata (WorkerId workerId, SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, DecomposedQueryPlanVersion decomposedQueryPlanVersion, uint16_t numberOfSources)
Public Member Functions inherited from NES::ReconfigurationMetadata
	ReconfigurationMetadata (ReconfigurationMetadataType reconfigurationMetaDataType)
virtual	~ReconfigurationMetadata ()=default
template<class T >
bool	instanceOf () const
template<class T >
std::shared_ptr< const T >	as () const

Public Attributes
const WorkerId	workerId
const SharedQueryId	sharedQueryId
const DecomposedQueryId	decomposedQueryId
const DecomposedQueryPlanVersion	decomposedQueryPlanVersion
const uint16_t	numberOfSources
Public Attributes inherited from NES::ReconfigurationMetadata
const ReconfigurationMetadataType	reconfigurationMetadataType

Detailed Description

Metadata defining the information about the new decomposed plan that needs to be started and immediately terminated. This metadata can be used for state migration using adhoc queries that are merged into the currently running decomposed query. Therefore, first the current plan needs to be updated to perform state migration before terminating it.

Constructor & Destructor Documentation

UpdateAndDrainQueryMetadata()

NES::UpdateAndDrainQueryMetadata::UpdateAndDrainQueryMetadata ( WorkerId  workerId, SharedQueryId  sharedQueryId, DecomposedQueryId  decomposedQueryId, DecomposedQueryPlanVersion  decomposedQueryPlanVersion, uint16_t  numberOfSources  )

inline

References NES::UpdateAndDrainQuery.

Member Data Documentation

decomposedQueryId

const DecomposedQueryId NES::UpdateAndDrainQueryMetadata::decomposedQueryId

Referenced by TEST_F().

decomposedQueryPlanVersion

const DecomposedQueryPlanVersion NES::UpdateAndDrainQueryMetadata::decomposedQueryPlanVersion

Referenced by TEST_F().

numberOfSources

const uint16_t NES::UpdateAndDrainQueryMetadata::numberOfSources

Referenced by TEST_F().

sharedQueryId

const SharedQueryId NES::UpdateAndDrainQueryMetadata::sharedQueryId

Referenced by TEST_F().

workerId

const WorkerId NES::UpdateAndDrainQueryMetadata::workerId

Referenced by TEST_F().

---

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

• /nebulastream/nes-common/include/Reconfiguration/Metadata/UpdateAndDrainQueryMetadata.hpp