NES::TestQuery Class Reference
TestQuery api for testing. More...
#include <TestQuery.hpp>
Collaboration diagram for NES::TestQuery:
Static Public Member Functions | |
| static Query | from (const SourceDescriptorPtr &descriptor) |
| Creates a query from a SourceDescriptor. More... | |
| static Query | from (const SchemaPtr &inputSchema) |
| Creates a query from an input schema. More... | |
 Static Public Member Functions inherited from NES::Query | |
| static Query | from (std::string const &sourceName) |
| : Creates a query from a particular source. The source is identified by its name. During query processing the underlying source descriptor is retrieved from the source catalog. More... | |
Additional Inherited Members | |
| Public Member Functions inherited from NES::Query | |
| Query (const Query &) | |
| virtual | ~Query ()=default |
| WindowOperatorBuilder::WindowedQuery | window (Windowing::WindowTypePtr const &windowType) |
| JoinOperatorBuilder::Join | joinWith (const Query &subQueryRhs) |
| can be called on the original query with the query to be joined with and sets this query in the class Join. More... | |
| NES::Experimental::BatchJoinOperatorBuilder::Join | batchJoinWith (const Query &subQueryRhs) |
| can be called on the original query with the query to be joined with and sets this query in the class BatchJoinOperatorBuilder::Join. More... | |
| CrossJoinOperatorBuilder::CrossJoin | crossJoinWith (const Query &subQueryRhs) |
| can be called on the original query with the query to be cross joined with and sets this query in the class CrossJoinOperatorBuilder::Join. More... | |
| IntervalJoinOperatorBuilder::IntervalJoin | intervalJoinWith (const Query &subQueryRhs) |
| can be called on the original query with the query to be joined with and sets this query in the class IntervalJoinOperatorBuilder::Join. More... | |
| CEPOperatorBuilder::And | andWith (const Query &subQueryRhs) |
| can be called on the original query with the query to be composed with and sets this query in the class And. More... | |
| CEPOperatorBuilder::Seq | seqWith (const Query &subQueryRhs) |
| can be called on the original query with the query to be composed with and sets this query in the class Join. More... | |
| CEPOperatorBuilder::Times | times (const uint64_t minOccurrences, const uint64_t maxOccurrences) |
| can be called on the original query to detect an number event occurrences between minOccurrence and maxOccurrence in a stream More... | |
| CEPOperatorBuilder::Times | times (const uint64_t occurrences) |
| can be called on the original query to detect an exact number event occurrences in a stream More... | |
| CEPOperatorBuilder::Times | times () |
| can be called on the original query to detect multiple occurrences of specified events in a stream More... | |
| Query & | orWith (const Query &subQuery) |
| can be called on the original query with the query to be composed with and sets this query in the class Or. More... | |
| Query & | buildStatistic (Windowing::WindowTypePtr window, Statistic::WindowStatisticDescriptorPtr statisticDescriptor, Statistic::StatisticMetricHash metricHash, Statistic::SendingPolicyPtr sendingPolicy, Statistic::TriggerConditionPtr triggerCondition) |
| Add a synopsis build operator to the query. More... | |
| Query & | unionWith (const Query &subQuery) |
| template<typename... Args> | |
| auto | project (Args &&... args) -> std::enable_if_t< std::conjunction_v< std::is_constructible< ExpressionItem, Args >... >, Query & > |
| this call projects out the attributes in the parameter list More... | |
| Query & | project (std::vector< ExpressionNodePtr > expressions) |
| this call projects out the attributes in the parameter list More... | |
| Query & | as (std::string const &newSourceName) |
| Query & | filter (ExpressionNodePtr const &filterExpression) |
| : Filter records according to the predicate. An examplary usage would be: filter(Attribute("f1" < 10)) More... | |
| Query & | limit (const uint64_t limit) |
| : Limit the number of records according to the limit count. More... | |
| Query & | assignWatermark (Windowing::WatermarkStrategyDescriptorPtr const &watermarkStrategyDescriptor) |
| : Create watermark assigner operator. More... | |
| Query & | mapUDF (Catalogs::UDF::UDFDescriptorPtr const &descriptor) |
| : Create map java udf operator. More... | |
| Query & | flatMapUDF (Catalogs::UDF::UDFDescriptorPtr const &descriptor) |
| : Create flat map java udf operator. More... | |
| Query & | map (FieldAssignmentExpressionNodePtr const &mapExpression) |
| : Map records according to a map expression. An examplary usage would be: map(Attribute("f2") = Attribute("f1") * 42 ) More... | |
| Query & | inferModel (std::string model, std::initializer_list< ExpressionItem > inputFields, std::initializer_list< ExpressionItem > outputFields) |
| virtual Query & | sink (SinkDescriptorPtr sinkDescriptor, WorkerId workerId=INVALID_WORKER_NODE_ID) |
| Add sink operator for the query. The Sink operator is defined by the sink descriptor, which represents the semantic of this sink. More... | |
| QueryPlanPtr | getQueryPlan () const |
| Gets the query plan from the current query. More... | |
| Query (QueryPlanPtr queryPlan) | |
| Protected Attributes inherited from NES::Query | |
| QueryPlanPtr | queryPlan |
Detailed Description
TestQuery api for testing.
Member Function Documentation
◆ from() [1/2]
Creates a query from an input schema.
- Parameters
-
inputSchema
- Returns
- Query
References NES::SchemaSourceDescriptor::create(), backward::details::move(), and NES::Query::queryPlan.
Here is the call graph for this function:
◆ from() [2/2]
|
inlinestatic |
Creates a query from a SourceDescriptor.
- Parameters
-
descriptor
- Returns
- Query
References NES::Query::queryPlan.
Referenced by UnionQueryExecutionTest::__attribute__(), NES::Runtime::Execution::StreamJoinQuerySharedExecutionTest::prepareRunTwoEqualQueriesDeployedDifferentTime(), NES::Runtime::Execution::StreamIntervalJoinQueryExecutionTest::runSingleJoinQuery(), NES::Runtime::Execution::StreamJoinQueryExecutionTest::runSingleJoinQuery(), TEST_F(), NES::TEST_P(), TEST_P(), and NES::Runtime::Execution::TEST_P().
Here is the caller graph for this function:
The documentation for this class was generated from the following file:
- /nebulastream/nes-coordinator/tests/include/Util/TestQuery.hpp
