NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
Static Public Member Functions | Static Public Attributes | List of all members
NES::Statistic::StatisticIdsExtractor Class Reference

#include <StatisticIdsExtractor.hpp>

Static Public Member Functions

static std::vector< StatisticId > extractStatisticIdsFromQueryId (Catalogs::Query::QueryCatalogPtr queryCatalog, const QueryId &queryId, const std::chrono::milliseconds &timeout=DEFAULT_TIMEOUT_QUERY_STARTED)
 Extracts the statistic ids of the operator over which some statistic is being built. More...
 
static std::vector< StatisticId > extractStatisticIdsFromQueryPlan (const QueryPlan &queryPlan)
 Extracts the statistic ids of the operator over which some statistic is being built. More...
 

Static Public Attributes

static constexpr auto DEFAULT_TIMEOUT_QUERY_STARTED = std::chrono::milliseconds(10000)
 

Member Function Documentation

◆ extractStatisticIdsFromQueryId()

std::vector< StatisticId > NES::Statistic::StatisticIdsExtractor::extractStatisticIdsFromQueryId ( Catalogs::Query::QueryCatalogPtr  queryCatalog,
const QueryId &  queryId,
const std::chrono::milliseconds &  timeout = DEFAULT_TIMEOUT_QUERY_STARTED 
)
static

Extracts the statistic ids of the operator over which some statistic is being built.

Parameters
queryCatalogIn this catalog, we search for the queryPlan with the queryId and then extract statistic ids in this queryPlan
queryIdQueryId to extract the statistic ids from its queryPlan
timeoutTimeout for the query to be in the RUNNING state. Default is 10000ms

References magic_enum::enum_name(), extractStatisticIdsFromQueryPlan(), NES::FAILED, NES::MARKED_FOR_HARD_STOP, NES::MARKED_FOR_SOFT_STOP, NES_ERROR, NES_TRACE, NES_WARNING, NES::RUNNING, NES::SOFT_STOP_COMPLETED, NES::SOFT_STOP_TRIGGERED, NES::STOPPED, and NES::timeout.

Here is the call graph for this function:

◆ extractStatisticIdsFromQueryPlan()

std::vector< StatisticId > NES::Statistic::StatisticIdsExtractor::extractStatisticIdsFromQueryPlan ( const QueryPlan &  queryPlan)
static

Extracts the statistic ids of the operator over which some statistic is being built.

Parameters
queryPlanQueryPlan to extract the statistic ids from

Referenced by extractStatisticIdsFromQueryId(), and NES::TEST_P().

Here is the caller graph for this function:

Member Data Documentation

◆ DEFAULT_TIMEOUT_QUERY_STARTED

constexpr auto NES::Statistic::StatisticIdsExtractor::DEFAULT_TIMEOUT_QUERY_STARTED = std::chrono::milliseconds(10000)
staticconstexpr
The documentation for this class was generated from the following files: