NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
DefaultStatisticQueryGeneratorTest.cpp File Reference
#include <API/QueryAPI.hpp>
#include <API/Schema.hpp>
#include <BaseUnitTest.hpp>
#include <Catalogs/Source/SourceCatalog.hpp>
#include <Catalogs/UDF/UDFCatalog.hpp>
#include <Common/DataTypes/DataTypeFactory.hpp>
#include <Measures/TimeMeasure.hpp>
#include <Operators/LogicalOperators/LogicalFilterOperator.hpp>
#include <Operators/LogicalOperators/LogicalMapOperator.hpp>
#include <Operators/LogicalOperators/Sources/SourceLogicalOperator.hpp>
#include <Operators/LogicalOperators/StatisticCollection/Descriptor/CountMinDescriptor.hpp>
#include <Operators/LogicalOperators/StatisticCollection/Descriptor/HyperLogLogDescriptor.hpp>
#include <Operators/LogicalOperators/StatisticCollection/LogicalStatisticWindowOperator.hpp>
#include <Operators/LogicalOperators/StatisticCollection/Metrics/BufferRate.hpp>
#include <Operators/LogicalOperators/StatisticCollection/Metrics/Cardinality.hpp>
#include <Operators/LogicalOperators/StatisticCollection/Metrics/IngestionRate.hpp>
#include <Operators/LogicalOperators/StatisticCollection/Metrics/MinVal.hpp>
#include <Operators/LogicalOperators/StatisticCollection/Metrics/Selectivity.hpp>
#include <Operators/LogicalOperators/StatisticCollection/SendingPolicy/SendingPolicyASAP.hpp>
#include <Operators/LogicalOperators/StatisticCollection/SendingPolicy/SendingPolicyAdaptive.hpp>
#include <Operators/LogicalOperators/StatisticCollection/SendingPolicy/SendingPolicyLazy.hpp>
#include <Operators/LogicalOperators/StatisticCollection/TriggerCondition/NeverTrigger.hpp>
#include <Operators/LogicalOperators/Windows/Joins/LogicalJoinOperator.hpp>
#include <Optimizer/Phases/TypeInferencePhase.hpp>
#include <Plans/Query/QueryPlan.hpp>
#include <StatisticCollection/Characteristic/DataCharacteristic.hpp>
#include <StatisticCollection/Characteristic/WorkloadCharacteristic.hpp>
#include <StatisticCollection/QueryGeneration/DefaultStatisticQueryGenerator.hpp>
#include <Types/TumblingWindow.hpp>
#include <Util/Logger/Logger.hpp>
Include dependency graph for DefaultStatisticQueryGeneratorTest.cpp:

Classes

class  NES::DefaultStatisticQueryGeneratorTest
 

Namespaces

 NES
 This exception represents a network error.
 

Functions

 NES::TEST_F (DefaultStatisticQueryGeneratorTest, cardinality)
 Tests if a query is generated correctly for a cardinality, the outcome should be a HyperLogLog. More...
 
 NES::TEST_F (DefaultStatisticQueryGeneratorTest, selectivity)
 Tests if a query is generated correctly for a selectivity, the outcome should be a CountMin. More...
 
 NES::TEST_F (DefaultStatisticQueryGeneratorTest, ingestionRate)
 Tests if a query is generated correctly for an ingestionRate, the outcome should be a CountMin. More...
 
 NES::TEST_F (DefaultStatisticQueryGeneratorTest, bufferRate)
 Tests if a query is generated correctly for a bufferRate, the outcome should be a CountMin. More...
 
 NES::TEST_F (DefaultStatisticQueryGeneratorTest, minVal)
 Tests if a query is generated correctly for a minVal, the outcome should be a CountMin. More...
 
 NES::TEST_F (DefaultStatisticQueryGeneratorTest, workloadCharacteristicMapOperatorCardinality)
 Tests if we create a statistic query for collecting cardinality of a map operator. More...
 
 NES::TEST_F (DefaultStatisticQueryGeneratorTest, workloadCharacteristicFilterBeforeJoinQueryCardinality)
 Tests if we create a statistic query for collecting cardinality of a map operator that sits behind a join operator. More...