|
NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
#include <API/Query.hpp>#include <BaseIntegrationTest.hpp>#include <Catalogs/Query/QueryCatalog.hpp>#include <Compiler/CPPCompiler/CPPCompiler.hpp>#include <Compiler/JITCompilerBuilder.hpp>#include <Exceptions/InvalidArgumentException.hpp>#include <Plans/Query/QueryPlan.hpp>#include <Plans/Utils/PlanIdGenerator.hpp>#include <Services/QueryParsingService.hpp>#include <Util/Core.hpp>#include <Util/Logger/Logger.hpp>#include <Util/TestUtils.hpp>#include <iostream>Classes | |
| class | QueryCatalogTest |
Functions | |
| TEST_F (QueryCatalogTest, testAddNewQuery) | |
| TEST_F (QueryCatalogTest, testAddNewPattern) | |
| TEST_F (QueryCatalogTest, testAddNewQueryAndStop) | |
| TEST_F (QueryCatalogTest, testPrintQuery) | |
| TEST_F (QueryCatalogTest, testAddNewQueryWithMultipleSinks) | |
| TEST_F (QueryCatalogTest, getAllQueriesWithoutAnyQueryRegistration) | |
| TEST_F (QueryCatalogTest, getAllQueriesAfterQueryRegistration) | |
| TEST_F (QueryCatalogTest, getAllRunningQueries) | |
| TEST_F (QueryCatalogTest, throInvalidArgumentExceptionWhenQueryStatusIsUnknown) | |
Variables | |
| std::string | ip = "127.0.0.1" |
| std::string | host = "localhost" |
| TEST_F | ( | QueryCatalogTest | , |
| getAllQueriesAfterQueryRegistration | |||
| ) |
References NES::Optimizer::BottomUp, and NES::REGISTERED.
| TEST_F | ( | QueryCatalogTest | , |
| getAllQueriesWithoutAnyQueryRegistration | |||
| ) |
| TEST_F | ( | QueryCatalogTest | , |
| getAllRunningQueries | |||
| ) |
References NES::Optimizer::BottomUp, NES::REGISTERED, and NES::RUNNING.
| TEST_F | ( | QueryCatalogTest | , |
| testAddNewPattern | |||
| ) |
References NES::Optimizer::BottomUp, and NES::REGISTERED.
| TEST_F | ( | QueryCatalogTest | , |
| testAddNewQuery | |||
| ) |
References NES::Optimizer::BottomUp, and NES::REGISTERED.
| TEST_F | ( | QueryCatalogTest | , |
| testAddNewQueryAndStop | |||
| ) |
References NES::Optimizer::BottomUp, NES::MARKED_FOR_HARD_STOP, and NES::REGISTERED.
| TEST_F | ( | QueryCatalogTest | , |
| testAddNewQueryWithMultipleSinks | |||
| ) |
References NES::Optimizer::BottomUp, and NES::REGISTERED.
| TEST_F | ( | QueryCatalogTest | , |
| testPrintQuery | |||
| ) |
References NES::Optimizer::BottomUp, and NES::REGISTERED.
| TEST_F | ( | QueryCatalogTest | , |
| throInvalidArgumentExceptionWhenQueryStatusIsUnknown | |||
| ) |
| std::string host = "localhost" |
| std::string ip = "127.0.0.1" |
Referenced by NES::__attribute__(), TEST_F(), and NES::TEST_F().