NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
NES::Query Member List

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 classNES::Queryfriend
CEPOperatorBuilder::Seq classNES::Queryfriend
CrossJoinOperatorBuilder::CrossJoin classNES::Queryfriend
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::Querystatic
getQueryPlan() constNES::Query
inferModel(std::string model, std::initializer_list< ExpressionItem > inputFields, std::initializer_list< ExpressionItem > outputFields)NES::Query
IntervalJoinOperatorBuilder::JoinLowerBound classNES::Queryfriend
IntervalJoinOperatorBuilder::JoinWhere classNES::Queryfriend
intervalJoinWith(const Query &subQueryRhs)NES::Query
JoinOperatorBuilder::JoinWhere classNES::Queryfriend
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 classNES::Queryfriend
orWith(const Query &subQuery)NES::Query
project(Args &&... args) -> std::enable_if_t< std::conjunction_v< std::is_constructible< ExpressionItem, Args >... >, Query & >NES::Queryinline
project(std::vector< ExpressionNodePtr > expressions)NES::Query
Query(const Query &)NES::Query
Query(QueryPlanPtr queryPlan)NES::Query
queryPlanNES::Queryprotected
seqWith(const Query &subQueryRhs)NES::Query
sink(SinkDescriptorPtr sinkDescriptor, WorkerId workerId=INVALID_WORKER_NODE_ID)NES::Queryvirtual
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 classNES::Queryfriend
WindowOperatorBuilder::WindowedQuery classNES::Queryfriend
~Query()=defaultNES::Queryvirtual