#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 MultiThreadedTest.cpp:

Classes
class	NES::MultiThreadedTest

struct	NES::NonKeyedResultRecord

struct	NES::KeyedResultRecord

Namespaces
	NES
	This exception represents a network error.

Functions
	NES::TEST_P (MultiThreadedTest, DISABLED_testFilterQuery)

	NES::TEST_P (MultiThreadedTest, testProjectQuery)

std::ostream &	NES::operator<< (std::ostream &os, const NonKeyedResultRecord &record)

std::ostream &	NES::operator<< (std::ostream &os, const KeyedResultRecord &record)

	NES::TEST_P (MultiThreadedTest, DISABLED_testNonKeyedEventTimeTumblingWindowAggregation)

	NES::TEST_P (MultiThreadedTest, testNonKeyedEventTimeSlidingWindowAggregation)

	NES::TEST_P (MultiThreadedTest, testKeyedEventTimeTumblingWindowAggregation)

	NES::TEST_P (MultiThreadedTest, DISABLED_testMultipleNonKeyedEventTimeTumblingWindows)

	NES::TEST_P (MultiThreadedTest, testMultipleKeyedEventTimeTumblingWindows)

	NES::INSTANTIATE_TEST_CASE_P (testQueriesMultiThreaded, MultiThreadedTest, ::testing::Values(1, 2, 3, 4, 8), [](const testing::TestParamInfo< MultiThreadedTest::ParamType > &info) { return std::to_string(info.param)+"Workerthreads";})

Classes

Namespaces

Functions