|
NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
#include <API/Query.hpp>#include <API/QueryAPI.hpp>#include <BaseIntegrationTest.hpp>#include <Expressions/LogicalExpressions/EqualsExpressionNode.hpp>#include <Expressions/LogicalExpressions/GreaterEqualsExpressionNode.hpp>#include <Expressions/LogicalExpressions/GreaterExpressionNode.hpp>#include <Expressions/LogicalExpressions/LessExpressionNode.hpp>#include <Operators/LogicalOperators/LogicalBinaryOperator.hpp>#include <Operators/LogicalOperators/LogicalFilterOperator.hpp>#include <Operators/LogicalOperators/LogicalIntervalJoinOperator.hpp>#include <Operators/LogicalOperators/Sources/LogicalSourceDescriptor.hpp>#include <Operators/LogicalOperators/Windows/Joins/LogicalJoinOperator.hpp>#include <Plans/Query/QueryPlan.hpp>#include <Services/QueryParsingService.hpp>#include <Util/Logger/Logger.hpp>#include <gtest/gtest.h>#include <iostream>#include <regex>Classes | |
| class | PatternParsingServiceTest |
Functions | |
| std::string | queryPlanToString (const QueryPlanPtr queryPlan) |
| uint64_t | getNumberOfJoinExpression (std::vector< std::shared_ptr< LogicalJoinOperator >> joins) |
| uint64_t | getNumberOfJoinExpression (std::vector< std::shared_ptr< LogicalIntervalJoinOperator >> joins) |
| TEST_F (PatternParsingServiceTest, simplePattern) | |
| TEST_F (PatternParsingServiceTest, DisjunctionPattern) | |
| TEST_F (PatternParsingServiceTest, NestedDisjunctionPattern) | |
| TEST_F (PatternParsingServiceTest, ConjunctionPatternWithFilterTumblingWindow) | |
| TEST_F (PatternParsingServiceTest, ConjunctionPatternWithFilterIntervalJoin) | |
| TEST_F (PatternParsingServiceTest, NestedConjunctionPattern) | |
| TEST_F (PatternParsingServiceTest, NestedConjunctionPatternWithFilter) | |
| TEST_F (PatternParsingServiceTest, SequencePattern) | |
| TEST_F (PatternParsingServiceTest, NestedSequencePattern) | |
| TEST_F (PatternParsingServiceTest, NestedSequencePatternWithIntervalJoin) | |
| TEST_F (PatternParsingServiceTest, MixedOperatorPattern) | |
| TEST_F (PatternParsingServiceTest, MixedOperatorPatternIntervalJoin) | |
| TEST_F (PatternParsingServiceTest, DISABLED_SequenceAndTimesPattern) | |
| TEST_F (PatternParsingServiceTest, simplePatternWithSelect) | |
| TEST_F (PatternParsingServiceTest, simplePatternWithMultipleSelectStatements) | |
| TEST_F (PatternParsingServiceTest, TimesOperator) | |
| TEST_F (PatternParsingServiceTest, TimesOperatorExact) | |
| TEST_F (PatternParsingServiceTest, TimesOperatorUnbounded) | |
| TEST_F (PatternParsingServiceTest, failingPatternWrongSyntaxExpected) | |
| TEST_F (PatternParsingServiceTest, SequencePatternChariteTest) | |
| TEST_F (PatternParsingServiceTest, SequencePatternDemoTest) | |
| TEST_F (PatternParsingServiceTest, SequencePatternDemoTest2) | |
| TEST_F (PatternParsingServiceTest, OrderIntervalTest) | |
| TEST_F (PatternParsingServiceTest, OrderSlidingTest) | |
| uint64_t getNumberOfJoinExpression | ( | std::vector< std::shared_ptr< LogicalIntervalJoinOperator >> | joins | ) |
References NES::BreadthFirstNodeIterator::end(), and NES_DEBUG.
| uint64_t getNumberOfJoinExpression | ( | std::vector< std::shared_ptr< LogicalJoinOperator >> | joins | ) |
References NES::BreadthFirstNodeIterator::end(), and NES_DEBUG.
Referenced by TEST_F().
| std::string queryPlanToString | ( | const QueryPlanPtr | queryPlan | ) |
| TEST_F | ( | PatternParsingServiceTest | , |
| ConjunctionPatternWithFilterIntervalJoin | |||
| ) |
References NES::Attribute(), NES::API::EventTime(), getNumberOfJoinExpression(), NES::Query::getQueryPlan(), NES::Query::intervalJoinWith(), NES::IntervalJoinOperatorBuilder::JoinWhere::lowerBound(), NES::Query::map(), NES::API::Minutes(), queryPlanToString(), NES::IntervalJoinOperatorBuilder::JoinLowerBound::upperBound(), and NES::IntervalJoinOperatorBuilder::IntervalJoin::where().
| TEST_F | ( | PatternParsingServiceTest | , |
| ConjunctionPatternWithFilterTumblingWindow | |||
| ) |
References NES::Query::andWith(), NES::Attribute(), NES::API::EventTime(), getNumberOfJoinExpression(), NES::Query::getQueryPlan(), NES::API::Minutes(), queryPlanToString(), and NES::CEPOperatorBuilder::And::window().
| TEST_F | ( | PatternParsingServiceTest | , |
| DISABLED_SequenceAndTimesPattern | |||
| ) |
References NES::Query::andWith(), NES::Attribute(), NES::API::EventTime(), NES::Query::getQueryPlan(), NES::API::Minutes(), queryPlanToString(), NES::Query::seqWith(), NES::Query::times(), NES::CEPOperatorBuilder::And::window(), NES::CEPOperatorBuilder::Seq::window(), and NES::CEPOperatorBuilder::Times::window().
| TEST_F | ( | PatternParsingServiceTest | , |
| DisjunctionPattern | |||
| ) |
| TEST_F | ( | PatternParsingServiceTest | , |
| failingPatternWrongSyntaxExpected | |||
| ) |
| TEST_F | ( | PatternParsingServiceTest | , |
| MixedOperatorPattern | |||
| ) |
References NES::Query::andWith(), NES::Attribute(), NES::API::EventTime(), NES::Query::from(), getNumberOfJoinExpression(), NES::Query::getQueryPlan(), NES::API::Minutes(), queryPlanToString(), NES::Query::seqWith(), NES::CEPOperatorBuilder::And::window(), and NES::CEPOperatorBuilder::Seq::window().
| TEST_F | ( | PatternParsingServiceTest | , |
| MixedOperatorPatternIntervalJoin | |||
| ) |
References NES::Attribute(), NES::API::EventTime(), NES::Query::from(), getNumberOfJoinExpression(), NES::Query::getQueryPlan(), NES::Query::intervalJoinWith(), NES::IntervalJoinOperatorBuilder::JoinWhere::lowerBound(), NES::Query::map(), NES::API::Minutes(), queryPlanToString(), NES::IntervalJoinOperatorBuilder::JoinLowerBound::upperBound(), and NES::IntervalJoinOperatorBuilder::IntervalJoin::where().
| TEST_F | ( | PatternParsingServiceTest | , |
| NestedConjunctionPattern | |||
| ) |
References NES::Query::andWith(), NES::Attribute(), NES::API::EventTime(), NES::Query::getQueryPlan(), NES::API::Minutes(), queryPlanToString(), and NES::CEPOperatorBuilder::And::window().
| TEST_F | ( | PatternParsingServiceTest | , |
| NestedConjunctionPatternWithFilter | |||
| ) |
References NES::Query::andWith(), NES::Attribute(), NES::API::EventTime(), getNumberOfJoinExpression(), NES::Query::getQueryPlan(), NES::API::Minutes(), queryPlanToString(), and NES::CEPOperatorBuilder::And::window().
| TEST_F | ( | PatternParsingServiceTest | , |
| NestedDisjunctionPattern | |||
| ) |
References NES::Query::getQueryPlan(), queryPlanToString(), and NES::Query::unionWith().
| TEST_F | ( | PatternParsingServiceTest | , |
| NestedSequencePattern | |||
| ) |
References NES::Attribute(), NES::API::EventTime(), NES::Query::from(), NES::Query::getQueryPlan(), NES::API::Minutes(), queryPlanToString(), NES::Query::seqWith(), and NES::CEPOperatorBuilder::Seq::window().
| TEST_F | ( | PatternParsingServiceTest | , |
| NestedSequencePatternWithIntervalJoin | |||
| ) |
References NES::Attribute(), NES::API::EventTime(), NES::Query::from(), NES::Query::getQueryPlan(), NES::Query::intervalJoinWith(), NES::IntervalJoinOperatorBuilder::JoinWhere::lowerBound(), NES::Query::map(), NES::API::Minutes(), queryPlanToString(), NES::IntervalJoinOperatorBuilder::JoinLowerBound::upperBound(), and NES::IntervalJoinOperatorBuilder::IntervalJoin::where().
| TEST_F | ( | PatternParsingServiceTest | , |
| OrderIntervalTest | |||
| ) |
References NES::Attribute(), NES::API::EventTime(), NES::Query::from(), getNumberOfJoinExpression(), NES::Query::getQueryPlan(), NES::Query::intervalJoinWith(), NES::IntervalJoinOperatorBuilder::JoinWhere::lowerBound(), NES::Query::map(), NES::API::Minutes(), queryPlanToString(), NES::IntervalJoinOperatorBuilder::JoinLowerBound::upperBound(), and NES::IntervalJoinOperatorBuilder::IntervalJoin::where().
| TEST_F | ( | PatternParsingServiceTest | , |
| OrderSlidingTest | |||
| ) |
References NES::Query::andWith(), NES::Attribute(), NES::API::EventTime(), getNumberOfJoinExpression(), NES::Query::getQueryPlan(), NES::API::Minutes(), queryPlanToString(), and NES::CEPOperatorBuilder::And::window().
| TEST_F | ( | PatternParsingServiceTest | , |
| SequencePattern | |||
| ) |
References NES::Attribute(), NES::API::EventTime(), NES::Query::from(), getNumberOfJoinExpression(), NES::Query::getQueryPlan(), NES::API::Minutes(), queryPlanToString(), NES::Query::seqWith(), and NES::CEPOperatorBuilder::Seq::window().
| TEST_F | ( | PatternParsingServiceTest | , |
| SequencePatternChariteTest | |||
| ) |
References NES::Attribute(), NES::API::EventTime(), NES::Query::from(), getNumberOfJoinExpression(), NES::Query::getQueryPlan(), NES::API::Minutes(), queryPlanToString(), NES::Query::seqWith(), and NES::CEPOperatorBuilder::Seq::window().
| TEST_F | ( | PatternParsingServiceTest | , |
| SequencePatternDemoTest | |||
| ) |
References NES::Query::andWith(), NES::Attribute(), NES::API::EventTime(), NES::Query::from(), NES::ExpressionItem::getExpressionNode(), getNumberOfJoinExpression(), NES::Query::getQueryPlan(), NES::API::Minutes(), queryPlanToString(), NES::Query::seqWith(), NES::CEPOperatorBuilder::And::window(), and NES::CEPOperatorBuilder::Seq::window().
| TEST_F | ( | PatternParsingServiceTest | , |
| SequencePatternDemoTest2 | |||
| ) |
References NES::Query::andWith(), NES::Attribute(), NES::API::EventTime(), NES::Query::from(), NES::ExpressionItem::getExpressionNode(), getNumberOfJoinExpression(), NES::Query::getQueryPlan(), NES::API::Minutes(), queryPlanToString(), NES::Query::seqWith(), NES::CEPOperatorBuilder::And::window(), and NES::CEPOperatorBuilder::Seq::window().
| TEST_F | ( | PatternParsingServiceTest | , |
| simplePattern | |||
| ) |
| TEST_F | ( | PatternParsingServiceTest | , |
| simplePatternWithMultipleSelectStatements | |||
| ) |
| TEST_F | ( | PatternParsingServiceTest | , |
| simplePatternWithSelect | |||
| ) |
| TEST_F | ( | PatternParsingServiceTest | , |
| TimesOperator | |||
| ) |
References NES::Attribute(), NES::API::EventTime(), NES::Query::getQueryPlan(), NES::API::Minutes(), queryPlanToString(), NES::Query::times(), and NES::CEPOperatorBuilder::Times::window().
| TEST_F | ( | PatternParsingServiceTest | , |
| TimesOperatorExact | |||
| ) |
References NES::Attribute(), NES::API::EventTime(), NES::Query::getQueryPlan(), NES::API::Minutes(), queryPlanToString(), NES::Query::times(), and NES::CEPOperatorBuilder::Times::window().
| TEST_F | ( | PatternParsingServiceTest | , |
| TimesOperatorUnbounded | |||
| ) |
References NES::Attribute(), NES::API::EventTime(), NES::Query::getQueryPlan(), NES::API::Minutes(), queryPlanToString(), NES::Query::times(), and NES::CEPOperatorBuilder::Times::window().