|
NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
#include <API/QueryAPI.hpp>#include <API/TestSchemas.hpp>#include <BaseIntegrationTest.hpp>#include <Catalogs/Topology/Topology.hpp>#include <Common/DataTypes/DataTypeFactory.hpp>#include <Configurations/Coordinator/LogicalSourceType.hpp>#include <Configurations/Coordinator/SchemaType.hpp>#include <Configurations/Worker/PhysicalSourceTypes/LambdaSourceType.hpp>#include <Exceptions/RPCQueryUndeploymentException.hpp>#include <Network/NetworkSink.hpp>#include <Network/NetworkSource.hpp>#include <Operators/LogicalOperators/Sources/SourceLogicalOperator.hpp>#include <Optimizer/Phases/QueryPlacementAmendmentPhase.hpp>#include <Optimizer/Phases/TypeInferencePhase.hpp>#include <Phases/DeploymentPhase.hpp>#include <Plans/DecomposedQueryPlan/DecomposedQueryPlan.hpp>#include <Plans/Global/Execution/GlobalExecutionPlan.hpp>#include <Plans/Utils/PlanIdGenerator.hpp>#include <Reconfiguration/Metadata/DrainQueryMetadata.hpp>#include <Reconfiguration/Metadata/UpdateAndDrainQueryMetadata.hpp>#include <Reconfiguration/ReconfigurationMarker.hpp>#include <RequestProcessor/RequestTypes/AddQueryRequest.hpp>#include <RequestProcessor/RequestTypes/ISQP/ISQPEvents/ISQPAddLinkEvent.hpp>#include <RequestProcessor/RequestTypes/ISQP/ISQPRequest.hpp>#include <RequestProcessor/StorageHandles/TwoPhaseLockingStorageHandler.hpp>#include <Runtime/Execution/ExecutableQueryPlan.hpp>#include <Runtime/NodeEngine.hpp>#include <Services/PlacementAmendment/PlacementAmendmentHandler.hpp>#include <Services/PlacementAmendment/PlacementAmendmentInstance.hpp>#include <Sources/DataSource.hpp>#include <Util/CompilerConstants.hpp>#include <Util/DeploymentContext.hpp>#include <Util/TestHarness/TestHarness.hpp>#include <gtest/gtest.h>#include <z3++.h>Classes | |
| class | NES::QueryReconfigurationTest |
Namespaces | |
| NES | |
| This exception represents a network error. | |
Functions | |
| NES::TEST_F (QueryReconfigurationTest, testMarkerPropagation) | |
| NES::TEST_F (QueryReconfigurationTest, testPlanIdMatching) | |