|
NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
#include <API/Expressions/Expressions.hpp>#include <API/QueryAPI.hpp>#include <API/TestSchemas.hpp>#include <BaseIntegrationTest.hpp>#include <Catalogs/Query/QueryCatalogEntry.hpp>#include <Catalogs/Source/PhysicalSource.hpp>#include <Catalogs/Source/SourceCatalogEntry.hpp>#include <Catalogs/Topology/Topology.hpp>#include <Catalogs/Topology/TopologyNode.hpp>#include <Components/NesCoordinator.hpp>#include <Components/NesWorker.hpp>#include <Configurations/Coordinator/CoordinatorConfiguration.hpp>#include <Configurations/Worker/PhysicalSourceTypes/LambdaSourceType.hpp>#include <Configurations/Worker/WorkerConfiguration.hpp>#include <Expressions/FieldAssignmentExpressionNode.hpp>#include <Expressions/LogicalExpressions/EqualsExpressionNode.hpp>#include <Operators/LogicalOperators/StatisticCollection/Metrics/Cardinality.hpp>#include <Operators/LogicalOperators/StatisticCollection/Metrics/Selectivity.hpp>#include <Services/RequestHandlerService.hpp>#include <StatisticCollection/Characteristic/DataCharacteristic.hpp>#include <StatisticCollection/StatisticProbeHandling/StatisticProbeHandler.hpp>#include <Util/Logger/Logger.hpp>#include <Util/TestTupleBuffer.hpp>#include <Util/TestUtils.hpp>#include <gtest/gtest.h>#include <unordered_map>Classes | |
| class | NES::StatisticsIntegrationTest |
Namespaces | |
| NES | |
| This exception represents a network error. | |
Functions | |
| NES::TEST_P (StatisticsIntegrationTest, singleTrackAndProbeDataCharacteristic) | |
| Test case for creating a statistic, probing it and deleting it for a cardinality. More... | |
| NES::INSTANTIATE_TEST_CASE_P (testDefaultStatisticStore, StatisticsIntegrationTest, ::testing::Combine(::testing::Values(1, 2, 3), ::testing::Values(1, 5, 10), ::testing::Values(1, 10, 1000), ::testing::Values(Statistic::Cardinality::create(Statistic::Over(StatisticsIntegrationTest::fieldNameToTrack)), Statistic::Selectivity::create(Statistic::Over(StatisticsIntegrationTest::fieldNameToTrack)))), [](const testing::TestParamInfo< StatisticsIntegrationTest::ParamType > &info) { return std::string(std::to_string(std::get< 0 >(info.param))+"Workers_"+std::to_string(std::get< 1 >(info.param))+"NumberOfBuffers_"+std::to_string(std::get< 2 >(info.param))+"WindowSize_"+std::to_string(info.index)+"Metric");}) | |