NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
Metadata defining the information about how many sources will send the reconfiguration marker before draining and terminating the decomposed query. More...
#include <DrainQueryMetadata.hpp>
Public Member Functions | |
DrainQueryMetadata (uint64_t numberOfSources) | |
![]() | |
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 uint64_t | numberOfSources |
![]() | |
const ReconfigurationMetadataType | reconfigurationMetadataType |
Metadata defining the information about how many sources will send the reconfiguration marker before draining and terminating the decomposed query.
|
inline |
References NES::DrainQuery.
const uint64_t NES::DrainQueryMetadata::numberOfSources |
Referenced by TEST_F().