Collaboration diagram for DemoCityQueryExecutionTest:

[legend]

Public Member Functions
void	SetUp () override

void	TearDown () override

void	generateAndEmitInputBuffers (const std::shared_ptr< Runtime::Execution::ExecutableQueryPlan > &queryPlan, const std::vector< SchemaPtr > &sourceSchemas, std::vector< std::function< void(Runtime::MemoryLayouts::TestTupleBuffer &)>> inputDataGenerators)

Public Member Functions inherited from NES::Testing::BaseUnitTest
void	SetUp () override

void	TearDown () override

virtual void	onFatalError (int signalNumber, std::string callstack) override
	onFatalError shall be called when a signal is caught More...

virtual void	onFatalException (std::shared_ptr< std::exception > exception, std::string callstack) override
	onFatalException shall be called when an exception is caught More...

Public Member Functions inherited from NES::detail::virtual_enable_shared_from_this< ErrorListener >
	~virtual_enable_shared_from_this () NES_NOEXCEPT(true) override=default

std::shared_ptr< T1 >	shared_from_this ()

std::weak_ptr< T1 >	weak_from_this ()

Public Member Functions inherited from NES::detail::virtual_enable_shared_from_this_base< true >
virtual	~virtual_enable_shared_from_this_base () NES_NOEXCEPT(isNoexceptDestructible)=default

Public Member Functions inherited from NES::Testing::detail::TestWaitingHelper
	TestWaitingHelper ()

void	startWaitingThread (std::string testName)

void	completeTest ()

void	failTest ()

Static Public Member Functions
static void	SetUpTestCase ()

static void	TearDownTestCase ()

Public Attributes
std::shared_ptr< Testing::TestExecutionEngine >	executionEngine

std::shared_ptr< TestUtils::TestSinkDescriptor >	testSinkDescriptor

Public Attributes inherited from NES::Testing::BaseUnitTest
detail::TestSourceNameHelper	srcName

Static Public Attributes
static constexpr DecomposedQueryId	defaultDecomposedQueryPlanId = INVALID_DECOMPOSED_QUERY_PLAN_ID

static constexpr SharedQueryId	defaultSharedQueryId = INVALID_SHARED_QUERY_ID

Member Function Documentation

◆ generateAndEmitInputBuffers()

void DemoCityQueryExecutionTest::generateAndEmitInputBuffers	(	const std::shared_ptr< Runtime::Execution::ExecutableQueryPlan > &	queryPlan,
		const std::vector< SchemaPtr > &	sourceSchemas,
		std::vector< std::function< void(Runtime::MemoryLayouts::TestTupleBuffer &)>>	inputDataGenerators
	)

inline

References executionEngine.

◆ SetUp()

void DemoCityQueryExecutionTest::SetUp ( )

inlineoverride

References dumpMode, and executionEngine.

◆ SetUpTestCase()

static void DemoCityQueryExecutionTest::SetUpTestCase ( )

inlinestatic

References NES::LOG_DEBUG, NES_DEBUG, and NES::Logger::setupLogging().

Here is the call graph for this function:

◆ TearDown()

void DemoCityQueryExecutionTest::TearDown ( )

inlineoverride

References executionEngine, and NES_DEBUG.

◆ TearDownTestCase()

static void DemoCityQueryExecutionTest::TearDownTestCase ( )

inlinestatic

References NES_DEBUG.

Member Data Documentation

◆ defaultDecomposedQueryPlanId

constexpr DecomposedQueryId DemoCityQueryExecutionTest::defaultDecomposedQueryPlanId = INVALID_DECOMPOSED_QUERY_PLAN_ID

staticconstexpr

◆ defaultSharedQueryId

constexpr SharedQueryId DemoCityQueryExecutionTest::defaultSharedQueryId = INVALID_SHARED_QUERY_ID

staticconstexpr

◆ executionEngine

std::shared_ptr<Testing::TestExecutionEngine> DemoCityQueryExecutionTest::executionEngine

Referenced by generateAndEmitInputBuffers(), SetUp(), and TearDown().

◆ testSinkDescriptor

std::shared_ptr<TestUtils::TestSinkDescriptor> DemoCityQueryExecutionTest::testSinkDescriptor

The documentation for this class was generated from the following file:

/nebulastream/nes-coordinator/tests/UnitTests/QueryExecution/DemoCityQueryExecutionTest.cpp

Public Member Functions

Static Public Member Functions

Public Attributes

Static Public Attributes