PlacementAmendmentHandlerTest.cpp File Reference

#include <API/QueryAPI.hpp>
#include <API/TestSchemas.hpp>
#include <BaseUnitTest.hpp>
#include <Catalogs/Query/QueryCatalog.hpp>
#include <Catalogs/Query/QueryCatalogEntry.hpp>
#include <Catalogs/Source/LogicalSource.hpp>
#include <Catalogs/Source/PhysicalSource.hpp>
#include <Catalogs/Source/SourceCatalog.hpp>
#include <Catalogs/Topology/Topology.hpp>
#include <Catalogs/Topology/TopologyNode.hpp>
#include <Catalogs/UDF/UDFCatalog.hpp>
#include <Configurations/Coordinator/CoordinatorConfiguration.hpp>
#include <Configurations/Worker/PhysicalSourceTypes/DefaultSourceType.hpp>
#include <Configurations/WorkerConfigurationKeys.hpp>
#include <Configurations/WorkerPropertyKeys.hpp>
#include <Exceptions/RPCQueryUndeploymentException.hpp>
#include <Operators/LogicalOperators/Sinks/SinkLogicalOperator.hpp>
#include <Operators/LogicalOperators/Sources/SourceLogicalOperator.hpp>
#include <Operators/LogicalOperators/Watermarks/WatermarkAssignerLogicalOperator.hpp>
#include <Operators/LogicalOperators/Windows/Joins/LogicalJoinOperator.hpp>
#include <Optimizer/Phases/QueryMergerPhase.hpp>
#include <Optimizer/Phases/QueryPlacementAmendmentPhase.hpp>
#include <Optimizer/Phases/SignatureInferencePhase.hpp>
#include <Optimizer/Phases/TypeInferencePhase.hpp>
#include <Phases/DeploymentPhase.hpp>
#include <Plans/Global/Execution/ExecutionNode.hpp>
#include <Plans/Global/Execution/GlobalExecutionPlan.hpp>
#include <Plans/Global/Query/GlobalQueryPlan.hpp>
#include <Plans/Global/Query/SharedQueryPlan.hpp>
#include <Plans/Query/QueryPlan.hpp>
#include <RequestProcessor/RequestTypes/AddQueryRequest.hpp>
#include <RequestProcessor/RequestTypes/ISQP/ISQPEvents/ISQPAddLinkEvent.hpp>
#include <RequestProcessor/RequestTypes/ISQP/ISQPEvents/ISQPAddLinkPropertyEvent.hpp>
#include <RequestProcessor/RequestTypes/ISQP/ISQPEvents/ISQPAddNodeEvent.hpp>
#include <RequestProcessor/RequestTypes/ISQP/ISQPEvents/ISQPAddQueryEvent.hpp>
#include <RequestProcessor/RequestTypes/ISQP/ISQPEvents/ISQPRemoveLinkEvent.hpp>
#include <RequestProcessor/RequestTypes/ISQP/ISQPEvents/ISQPRemoveNodeEvent.hpp>
#include <RequestProcessor/RequestTypes/ISQP/ISQPEvents/ISQPRemoveQueryEvent.hpp>
#include <RequestProcessor/RequestTypes/ISQP/ISQPRequest.hpp>
#include <RequestProcessor/StorageHandles/StorageDataStructures.hpp>
#include <RequestProcessor/StorageHandles/TwoPhaseLockingStorageHandler.hpp>
#include <Services/PlacementAmendment/PlacementAmendmentHandler.hpp>
#include <Services/PlacementAmendment/PlacementAmendmentInstance.hpp>
#include <StatisticCollection/StatisticCache/DefaultStatisticCache.hpp>
#include <StatisticCollection/StatisticProbeHandling/DefaultStatisticProbeGenerator.hpp>
#include <StatisticCollection/StatisticProbeHandling/StatisticProbeHandler.hpp>
#include <StatisticCollection/StatisticRegistry/StatisticRegistry.hpp>
#include <Util/DeploymentContext.hpp>
#include <Util/IncrementalPlacementUtils.hpp>
#include <Util/Logger/Logger.hpp>
#include <gmock/gmock.h>
#include <gtest/gtest.h>
#include <z3++.h>

Classes
class	NES::Optimizer::MockedPlacementAmendmentHandler
class	NES::RequestProcessor::MockedDeploymentPhase
class	NES::RequestProcessor::PlacementAmendmentHandlerTest

Namespaces
	z3
	NES
	This exception represents a network error.
	NES::Optimizer
	NES::RequestProcessor

Typedefs
using	z3::ExprPtr = std::shared_ptr< expr >

Functions
void	NES::RequestProcessor::handleMockedPlacementAmendmentCall (const NES::Optimizer::PlacementAmendmentInstancePtr &placementAmendmentInstance)
	NES::RequestProcessor::TEST_F (PlacementAmendmentHandlerTest, testAddQueryEvents)
	NES::RequestProcessor::TEST_F (PlacementAmendmentHandlerTest, testMultipleAddQueryEventsInaSingleBatchWithMergingWithIncrementalPlacement2PL)
	NES::RequestProcessor::TEST_F (PlacementAmendmentHandlerTest, testMultipleAddQueryEventsInaSingleBatchWithMergingWithoutIncrementalPlacement2PL)
	NES::RequestProcessor::TEST_F (PlacementAmendmentHandlerTest, testMultipleAddQueryEventsInaSingleBatchWithoutMergingWithoutIncrementalPlacementWith2PL)
	NES::RequestProcessor::TEST_F (PlacementAmendmentHandlerTest, testMultipleAddQueryEventsInaSingleBatchWithoutMergingWithoutIncrementalPlacementWithOCC)
	NES::RequestProcessor::TEST_F (PlacementAmendmentHandlerTest, testMultipleAddQueryEventsInaSingleBatchWithMergingWithoutIncrementalPlacementWithOCC)
	NES::RequestProcessor::TEST_F (PlacementAmendmentHandlerTest, testMultipleAddQueryEventsInDifferentBatchWithMergingWithIncrementalPlacementOCC)
	NES::RequestProcessor::TEST_F (PlacementAmendmentHandlerTest, testMultipleAddQueryEventsInDifferentBatchWithMergingWithoutIncrementalPlacement)
	NES::RequestProcessor::TEST_F (PlacementAmendmentHandlerTest, testMultipleAddQueryEventsInDifferentBatchWithoutMergingWithoutIncrementalPlacement)
	NES::RequestProcessor::TEST_F (PlacementAmendmentHandlerTest, testFailureDuringPlacementOfMultipleQueriesUsingOptimisticStrategy)
	NES::RequestProcessor::TEST_F (PlacementAmendmentHandlerTest, testTopologyChangeEventsInaSingleBatchWithMergingWithoutIncrementalPlacement2PL)
	NES::RequestProcessor::TEST_F (PlacementAmendmentHandlerTest, testTopologyChangeEventsFourUnionQueryInaSingleBatchWithMergingWithoutIncrementalPlacement2PL)
	NES::RequestProcessor::TEST_F (PlacementAmendmentHandlerTest, testTopologyChangeEventsFourUnionQueryInaSingleBatchWithMergingWithIncrementalPlacement2PL)
	NES::RequestProcessor::TEST_F (PlacementAmendmentHandlerTest, testJoinMigrationAmendmentPhase)