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().