|
NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
This is the complete list of members for NES::Query, including all inherited members.
| andWith(const Query &subQueryRhs) | NES::Query | |
| as(std::string const &newSourceName) | NES::Query | |
| assignWatermark(Windowing::WatermarkStrategyDescriptorPtr const &watermarkStrategyDescriptor) | NES::Query | |
| batchJoinWith(const Query &subQueryRhs) | NES::Query | |
| buildStatistic(Windowing::WindowTypePtr window, Statistic::WindowStatisticDescriptorPtr statisticDescriptor, Statistic::StatisticMetricHash metricHash, Statistic::SendingPolicyPtr sendingPolicy, Statistic::TriggerConditionPtr triggerCondition) | NES::Query | |
| CEPOperatorBuilder::And class | NES::Query | friend |
| CEPOperatorBuilder::Seq class | NES::Query | friend |
| CrossJoinOperatorBuilder::CrossJoin class | NES::Query | friend |
| crossJoinWith(const Query &subQueryRhs) | NES::Query | |
| filter(ExpressionNodePtr const &filterExpression) | NES::Query | |
| flatMapUDF(Catalogs::UDF::UDFDescriptorPtr const &descriptor) | NES::Query | |
| from(std::string const &sourceName) | NES::Query | static |
| getQueryPlan() const | NES::Query | |
| inferModel(std::string model, std::initializer_list< ExpressionItem > inputFields, std::initializer_list< ExpressionItem > outputFields) | NES::Query | |
| IntervalJoinOperatorBuilder::JoinLowerBound class | NES::Query | friend |
| IntervalJoinOperatorBuilder::JoinWhere class | NES::Query | friend |
| intervalJoinWith(const Query &subQueryRhs) | NES::Query | |
| JoinOperatorBuilder::JoinWhere class | NES::Query | friend |
| joinWith(const Query &subQueryRhs) | NES::Query | |
| limit(const uint64_t limit) | NES::Query | |
| map(FieldAssignmentExpressionNodePtr const &mapExpression) | NES::Query | |
| mapUDF(Catalogs::UDF::UDFDescriptorPtr const &descriptor) | NES::Query | |
| NES::Experimental::BatchJoinOperatorBuilder::Join class | NES::Query | friend |
| orWith(const Query &subQuery) | NES::Query | |
| project(Args &&... args) -> std::enable_if_t< std::conjunction_v< std::is_constructible< ExpressionItem, Args >... >, Query & > | NES::Query | inline |
| project(std::vector< ExpressionNodePtr > expressions) | NES::Query | |
| Query(const Query &) | NES::Query | |
| Query(QueryPlanPtr queryPlan) | NES::Query | |
| queryPlan | NES::Query | protected |
| seqWith(const Query &subQueryRhs) | NES::Query | |
| sink(SinkDescriptorPtr sinkDescriptor, WorkerId workerId=INVALID_WORKER_NODE_ID) | NES::Query | virtual |
| times(const uint64_t minOccurrences, const uint64_t maxOccurrences) | NES::Query | |
| times(const uint64_t occurrences) | NES::Query | |
| times() | NES::Query | |
| unionWith(const Query &subQuery) | NES::Query | |
| window(Windowing::WindowTypePtr const &windowType) | NES::Query | |
| WindowOperatorBuilder::KeyedWindowedQuery class | NES::Query | friend |
| WindowOperatorBuilder::WindowedQuery class | NES::Query | friend |
| ~Query()=default | NES::Query | virtual |