QueryRedeploymentIntegrationTest.cpp File Reference

#include <BaseIntegrationTest.hpp>
#include <Catalogs/Source/PhysicalSource.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 <GRPC/CoordinatorRPCClient.hpp>
#include <Mobility/WorkerMobilityHandler.hpp>
#include <Network/NetworkSink.hpp>
#include <Network/PartitionManager.hpp>
#include <Operators/LogicalOperators/Network/NetworkSourceDescriptor.hpp>
#include <Operators/LogicalOperators/Sinks/SinkLogicalOperator.hpp>
#include <Operators/LogicalOperators/Sources/SourceLogicalOperator.hpp>
#include <Plans/DecomposedQueryPlan/DecomposedQueryPlan.hpp>
#include <Plans/Global/Execution/ExecutionNode.hpp>
#include <Plans/Global/Execution/GlobalExecutionPlan.hpp>
#include <Plans/Global/Query/SharedQueryPlan.hpp>
#include <Plans/Query/QueryPlan.hpp>
#include <RequestProcessor/StorageHandles/SerialStorageHandler.hpp>
#include <RequestProcessor/StorageHandles/StorageDataStructures.hpp>
#include <Runtime/Execution/ExecutableQueryPlan.hpp>
#include <Runtime/NodeEngine.hpp>
#include <Runtime/QueryManager.hpp>
#include <Services/RequestHandlerService.hpp>
#include <Util/TestUtils.hpp>
#include <Util/TopologyLinkInformation.hpp>
#include <atomic>
#include <gtest/gtest.h>

Include dependency graph for QueryRedeploymentIntegrationTest.cpp:

Classes
class	NES::QueryRedeploymentIntegrationTest

Namespaces
	NES
	This exception represents a network error.

Functions
	NES::TEST_P (QueryRedeploymentIntegrationTest, DISABLED_testAsyncConnectingSink)
	This tests the asynchronous connection establishment, where the sink buffers incoming tuples while waiting for the network channel to become available. More...

Variables
constexpr std::chrono::duration< int64_t, std::milli >	NES::defaultTimeoutInSec = std::chrono::seconds(TestUtils::defaultTimeout)
constexpr uint32_t	NES::DATA_CHANNEL_RETRY_TIMES = 10
constexpr uint32_t	NES::EVENT_CHANNEL_RETRY_TIMES = 1
constexpr std::chrono::milliseconds	NES::WAIT_TIME = std::chrono::milliseconds(1000)