JoinMultiThreadedTest.cpp File Reference

#include <API/TestSchemas.hpp>
#include <BaseIntegrationTest.hpp>
#include <Catalogs/Source/PhysicalSource.hpp>
#include <Components/NesCoordinator.hpp>
#include <Plans/DecomposedQueryPlan/DecomposedQueryPlan.hpp>
#include <Plans/Global/Query/GlobalQueryPlan.hpp>
#include <Services/RequestHandlerService.hpp>
#include <Util/Logger/Logger.hpp>
#include <Util/TestExecutionEngine.hpp>
#include <Util/TestSinkDescriptor.hpp>
#include <chrono>
#include <gmock/gmock-matchers.h>
#include <gtest/gtest.h>
#include <iostream>

Include dependency graph for JoinMultiThreadedTest.cpp:

Classes
class	NES::JoinMultiThreadedTest

Namespaces
	NES
	This exception represents a network error.

Functions
	NES::TEST_P (JoinMultiThreadedTest, testOneJoin)
	NES::TEST_P (JoinMultiThreadedTest, testTwoJoins)
	NES::TEST_P (JoinMultiThreadedTest, testThreeJoins)
	NES::TEST_P (JoinMultiThreadedTest, oneJoinSlidingWindow)
	NES::TEST_P (JoinMultiThreadedTest, threeJoinsSlidingWindow)
	NES::INSTANTIATE_TEST_CASE_P (testJoinQueriesMultiThreaded, JoinMultiThreadedTest, ::testing::Combine(ALL_JOIN_STRATEGIES, ALL_WINDOW_STRATEGIES, ::testing::Values(1, 2, 3, 4, 8)), [](const testing::TestParamInfo< JoinMultiThreadedTest::ParamType > &info) { return std::string(magic_enum::enum_name(std::get< 0 >(info.param)))+"_"+std::string(magic_enum::enum_name(std::get< 1 >(info.param)))+"_"+std::to_string(std::get< 2 >(info.param))+"Workerthreads";})