TopologyNodeRelocationRequestTest.cpp File Reference

#include <API/QueryAPI.hpp>
#include <BaseIntegrationTest.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 <Common/DataTypes/DataTypeFactory.hpp>
#include <Configurations/Coordinator/CoordinatorConfiguration.hpp>
#include <Configurations/Coordinator/OptimizerConfiguration.hpp>
#include <Operators/LogicalOperators/LogicalUnionOperator.hpp>
#include <Operators/LogicalOperators/Network/NetworkSinkDescriptor.hpp>
#include <Operators/LogicalOperators/Network/NetworkSourceDescriptor.hpp>
#include <Operators/LogicalOperators/Network/NodeLocation.hpp>
#include <Operators/LogicalOperators/Sinks/SinkLogicalOperator.hpp>
#include <Operators/LogicalOperators/Sources/CsvSourceDescriptor.hpp>
#include <Operators/LogicalOperators/Sources/SourceLogicalOperator.hpp>
#include <Optimizer/Phases/TypeInferencePhase.hpp>
#include <Plans/ChangeLog/ChangeLog.hpp>
#include <Plans/DecomposedQueryPlan/DecomposedQueryPlan.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/StorageHandles/SerialStorageHandler.hpp>
#include <RequestProcessor/StorageHandles/StorageDataStructures.hpp>
#include <StatisticCollection/StatisticCache/DefaultStatisticCache.hpp>
#include <StatisticCollection/StatisticProbeHandling/DefaultStatisticProbeGenerator.hpp>
#include <StatisticCollection/StatisticProbeHandling/StatisticProbeHandler.hpp>
#include <StatisticCollection/StatisticRegistry/StatisticRegistry.hpp>
#include <Util/IncrementalPlacementUtils.hpp>
#include <Util/Logger/Logger.hpp>
#include <Util/Placement/PlacementConstants.hpp>
#include <gtest/gtest.h>
#include <z3++.h>

Include dependency graph for TopologyNodeRelocationRequestTest.cpp:

Classes
class	NES::RequestProcessor::TopologyNodeRelocationRequestTest

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

Functions
	NES::RequestProcessor::TEST_F (TopologyNodeRelocationRequestTest, testFindingIncrementalUpstreamAndDownstream)
	Test the algorithm to identify the upstream and downstream operators used as an input for an incremental placement to be performed due to a topology link removal. Construct a topology, place query subplans and calculate the sets of upstream and downstream operators of an incremental placement. More...

Variables
uint32_t	EVENT_CHANNEL_RETRY_TIMES = 1
auto	WAIT_TIME = std::chrono::milliseconds(1)
uint32_t	DATA_CHANNEL_RETRY_TIMES = 1
uint64_t	DEFAULT_NUMBER_OF_ORIGINS = 1

Variable Documentation

DATA_CHANNEL_RETRY_TIMES

uint32_t DATA_CHANNEL_RETRY_TIMES = 1

DEFAULT_NUMBER_OF_ORIGINS

uint64_t DEFAULT_NUMBER_OF_ORIGINS = 1

Referenced by NES::RequestProcessor::TEST_F().

EVENT_CHANNEL_RETRY_TIMES

uint32_t EVENT_CHANNEL_RETRY_TIMES = 1

WAIT_TIME

auto WAIT_TIME = std::chrono::milliseconds(1)