QueryDeploymentTest.cpp File Reference

#include <API/QueryAPI.hpp>
#include <API/TestSchemas.hpp>
#include <BaseIntegrationTest.hpp>
#include <Catalogs/Exceptions/InvalidQueryException.hpp>
#include <Common/DataTypes/DataTypeFactory.hpp>
#include <Configurations/Coordinator/LogicalSourceType.hpp>
#include <Configurations/Coordinator/SchemaType.hpp>
#include <Configurations/Worker/PhysicalSourceTypes/DefaultSourceType.hpp>
#include <Configurations/Worker/PhysicalSourceTypes/LambdaSourceType.hpp>
#include <Util/TestHarness/TestHarness.hpp>

Include dependency graph for QueryDeploymentTest.cpp:

Classes
class	NES::QueryDeploymentTest

Namespaces
	NES
	This exception represents a network error.

Functions
	NES::TEST_F (QueryDeploymentTest, testDeployTwoWorkerMergeUsingBottomUp)
	NES::TEST_F (QueryDeploymentTest, testDeployTwoWorkerMergeUsingTopDown)
	NES::TEST_F (QueryDeploymentTest, testDeployOneWorkerFileOutput)
	NES::TEST_F (QueryDeploymentTest, testDeployOneWorkerFileOutputUsingTopDownStrategy)
	Test deploy query with print sink with one worker using top down strategy. More...
	NES::TEST_F (QueryDeploymentTest, testDeployTwoWorkerFileOutput)
	NES::TEST_F (QueryDeploymentTest, testSourceSharing)
	NES::TEST_F (QueryDeploymentTest, testSourceSharingWithFilter)
	NES::TEST_F (QueryDeploymentTest, testDeployTwoWorkerFileOutputUsingTopDownStrategy)
	NES::TEST_F (QueryDeploymentTest, testDeployOneWorkerFileOutputWithFilter)
	NES::TEST_F (QueryDeploymentTest, testDeployOneWorkerFileOutputWithFilterWithInProcessTerminationWhenTwoSourcesRunning)
	NES::TEST_F (QueryDeploymentTest, testDeployOneWorkerFileOutputWithFilterWithInProcessTerminationWhenOneSourceRunning)
	NES::TEST_F (QueryDeploymentTest, testDeployOneWorkerFileOutputWithFilterWithInProcessTerminationWhenNoSourceRunning)
	NES::TEST_F (QueryDeploymentTest, testDeployOneWorkerFileOutputWithProjection)
	NES::TEST_F (QueryDeploymentTest, testDeployOneWorkerFileOutputWithWrongProjection)
	NES::TEST_F (QueryDeploymentTest, testDeployUndeployMultipleQueriesTwoWorkerFileOutput)
	NES::TEST_F (QueryDeploymentTest, testOneQueuePerQueryWithOutput)
	NES::TEST_F (QueryDeploymentTest, testOneQueuePerQueryWithHardShutdownAndStatic)
	NES::TEST_F (QueryDeploymentTest, testDeployUndeployMultipleQueriesOnTwoWorkerFileOutputWithQueryMerging)
	NES::TEST_F (QueryDeploymentTest, testDeployTwoWorkerJoinUsingTopDownOnSameSchema)
	NES::TEST_F (QueryDeploymentTest, testOneQueuePerQueryWithHardShutdown)
	NES::TEST_F (QueryDeploymentTest, DISABLED_testSelfJoinTumblingWindow)
	NES::TEST_F (QueryDeploymentTest, testJoinWithDifferentSourceDifferentSpeedTumblingWindow)
	NES::TEST_F (QueryDeploymentTest, testJoinWithSlidingWindow)
	NES::TEST_F (QueryDeploymentTest, testJoinWithThreeSources)
	NES::TEST_F (QueryDeploymentTest, testJoinWithFourSources)
	NES::TEST_F (QueryDeploymentTest, DISABLED_testJoin2WithDifferentSourceTumblingWindowDistributed)
	This tests just outputs the default source for a hierarchy with one relay which also produces data by itself Topology: PhysicalNode[id=1, ip=127.0.0.1, resourceCapacity=12, usedResource=0] => Join 2 |–PhysicalNode[id=2, ip=127.0.0.1, resourceCapacity=1, usedResource=0] => Join 1 | |–PhysicalNode[id=6, ip=127.0.0.1, resourceCapacity=12, usedResource=0] | |–PhysicalNode[id=5, ip=127.0.0.1, resourceCapacity=12, usedResource=0] | |–PhysicalNode[id=4, ip=127.0.0.1, resourceCapacity=12, usedResource=0]. More...
	NES::TEST_F (QueryDeploymentTest, DISABLED_testJoin2WithDifferentSourceSlidingWindowDistributed)
	This tests just outputs the default source for a hierarchy with one relay which also produces data by itself Topology: PhysicalNode[id=1, ip=127.0.0.1, resourceCapacity=12, usedResource=0] => Join 2 |–PhysicalNode[id=2, ip=127.0.0.1, resourceCapacity=1, usedResource=0] => Join 1 | |–PhysicalNode[id=6, ip=127.0.0.1, resourceCapacity=12, usedResource=0] | |–PhysicalNode[id=5, ip=127.0.0.1, resourceCapacity=12, usedResource=0] | |–PhysicalNode[id=4, ip=127.0.0.1, resourceCapacity=12, usedResource=0]. More...
	NES::TEST_F (QueryDeploymentTest, testIntervalJoinTwoSources)