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::TestQuery, 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 | |
crossJoinWith(const Query &subQueryRhs) | NES::Query | |
filter(ExpressionNodePtr const &filterExpression) | NES::Query | |
flatMapUDF(Catalogs::UDF::UDFDescriptorPtr const &descriptor) | NES::Query | |
from(const SourceDescriptorPtr &descriptor) | NES::TestQuery | inlinestatic |
from(const SchemaPtr &inputSchema) | NES::TestQuery | inlinestatic |
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 | |
intervalJoinWith(const Query &subQueryRhs) | NES::Query | |
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 | |
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 | |
~Query()=default | NES::Query | virtual |