|
NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
#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>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... | |