NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
QueryAPITest.cpp File Reference
#include <API/QueryAPI.hpp>
#include <API/TestSchemas.hpp>
#include <BaseIntegrationTest.hpp>
#include <Catalogs/Source/LogicalSource.hpp>
#include <Catalogs/Source/PhysicalSource.hpp>
#include <Catalogs/Source/SourceCatalog.hpp>
#include <Catalogs/Topology/TopologyNode.hpp>
#include <Catalogs/UDF/UDFCatalog.hpp>
#include <Configurations/Worker/PhysicalSourceTypes/DefaultSourceType.hpp>
#include <Configurations/WorkerConfigurationKeys.hpp>
#include <Configurations/WorkerPropertyKeys.hpp>
#include <Expressions/FieldAssignmentExpressionNode.hpp>
#include <Expressions/LogicalExpressions/AndExpressionNode.hpp>
#include <Expressions/LogicalExpressions/EqualsExpressionNode.hpp>
#include <Expressions/LogicalExpressions/GreaterEqualsExpressionNode.hpp>
#include <Expressions/LogicalExpressions/GreaterExpressionNode.hpp>
#include <Expressions/LogicalExpressions/LessEqualsExpressionNode.hpp>
#include <Expressions/LogicalExpressions/LessExpressionNode.hpp>
#include <Expressions/LogicalExpressions/NegateExpressionNode.hpp>
#include <Expressions/LogicalExpressions/OrExpressionNode.hpp>
#include <Measures/TimeCharacteristic.hpp>
#include <Operators/LogicalOperators/LogicalIntervalJoinOperator.hpp>
#include <Operators/LogicalOperators/LogicalOperator.hpp>
#include <Operators/LogicalOperators/Sinks/PrintSinkDescriptor.hpp>
#include <Operators/LogicalOperators/Sinks/SinkLogicalOperator.hpp>
#include <Operators/LogicalOperators/Sources/LogicalSourceDescriptor.hpp>
#include <Operators/LogicalOperators/Sources/SourceLogicalOperator.hpp>
#include <Optimizer/Phases/TypeInferencePhase.hpp>
#include <Plans/Query/QueryPlan.hpp>
#include <Types/SlidingWindow.hpp>
#include <Types/ThresholdWindow.hpp>
#include <Types/TumblingWindow.hpp>
#include <Types/WindowType.hpp>
#include <Util/DumpHandler/ConsoleDumpHandler.hpp>
#include <Util/Logger/Logger.hpp>
#include <gmock/gmock-matchers.h>
#include <gtest/gtest.h>
#include <iostream>
#include <limits>
Include dependency graph for QueryAPITest.cpp:

Classes

class  NES::QueryAPITest
 

Namespaces

 NES
 This exception represents a network error.
 

Functions

 NES::TEST_F (QueryAPITest, testIntervalJoin)
 
 NES::TEST_F (QueryAPITest, testQueryFilter)
 
 NES::TEST_F (QueryAPITest, testQueryProjection)
 
 NES::TEST_F (QueryAPITest, testQueryTumblingWindow)
 
 NES::TEST_F (QueryAPITest, testQuerySlidingWindow)
 
 NES::TEST_F (QueryAPITest, testQueryMerge)
 
 NES::TEST_F (QueryAPITest, testQueryJoin)
 
 NES::TEST_F (QueryAPITest, testQueryCrossJoin)
 
 NES::TEST_F (QueryAPITest, testQueryExpression)
 
 NES::TEST_F (QueryAPITest, windowAggregationWithAs)
 Test if the custom field set for aggregation using "as()" is set in the sink output schema. More...
 
 NES::TEST_F (QueryAPITest, ThresholdWindowQueryTest)
 Test if the system can create a logical query plan with a Threshold Window Operator. More...
 
 NES::TEST_F (QueryAPITest, ThresholdWindowQueryTestWithMinSupport)
 Test if the system can create a logical query plan with a Threshold Window Operator with minuium count. More...
 
 NES::TEST_F (QueryAPITest, ThresholdWindowQueryTestwithKeyAndMinCount)
 Test if the system can create a logical query plan with a Threshold Window Operator and minium count. More...
 
 NES::TEST_F (QueryAPITest, testQuerySeqWithTwoSources)
 Test for Sequence-Operator (seqWith) with two sources. This test compares the structure of the seqWith operator with the structure of the joinWith operator. Query: SEQ(A,B) WITHIN 2 minutes. More...
 
 NES::TEST_F (QueryAPITest, testQuerySeqWithThreeSources)
 Test for Sequence-Operator (seqWith) with three sources. This test compares the structure of the seqWith operator with the structure of the joinWith operator. Query: SEQ(A,B,C) WITHIN 2 minutes. More...
 
 NES::TEST_F (QueryAPITest, testQueryAndWithTwoSources)
 Test for AND-Operator (andWith) with two sources. Compares the actual query plan of andWith with the expected query plan. Query: AND(A,B) WITHIN 2 minutes. More...
 
 NES::TEST_F (QueryAPITest, testQueryAndWithThreeSources)
 Test for AND-Operator (andWith) with three sources. Compares the actual query plan of andWith with the expected query plan. Query: AND(A,B,C) WITHIN 2 minutes. More...
 
 NES::TEST_F (QueryAPITest, testQueryTimesNoSpecifiedOccurrences)
 Test for Times-Operator. In this test, there are no occurrences specified (Times() without parameter), leading to a query that expects the default behavior of the Times-operator without filtering for min/max occurrences. More...
 
 NES::TEST_F (QueryAPITest, testQueryTimesExactOccurrences)
 Test for Times-Operator. In this test, there is an exact number (larger than 0) occurrences specified (Times(occurrences)), leading to a query that filters the tuples by the exact number of occurrences. More...
 
 NES::TEST_F (QueryAPITest, testQueryTimesZeroOccurrences)
 Test for Times-Operator. If the exact number of occurrences is 0 (Times(0)), this test should fail because min- and max-occurrences are set to 0 which is not allowed. More...
 
 NES::TEST_F (QueryAPITest, testQueryTimesMinMaxOccurrences)
 Test for Times-Operator. If there are two parameters specified (Times(min_occurrences, max_occurrences)), the query-plan is expected to filtered according to the minimum and maximum number of occurrences. More...