NES::Testing::TestExecutionEngine Class Reference

A simple stand alone query execution engine for testing. More...

#include <TestExecutionEngine.hpp>

Public Member Functions
	TestExecutionEngine (const QueryCompilation::DumpMode &dumpMode=QueryCompilation::DumpMode::NONE, const uint64_t numWorkerThreads=1, const QueryCompilation::StreamJoinStrategy &joinStrategy=QueryCompilation::StreamJoinStrategy::NESTED_LOOP_JOIN, const QueryCompilation::WindowingStrategy &windowingStrategy=QueryCompilation::WindowingStrategy::SLICING)
std::shared_ptr< TestSink >	createDataSink (const SchemaPtr &outputSchema, uint32_t expectedTuples=1)
template<class Type >
auto	createCollectSink (SchemaPtr outputSchema)
std::shared_ptr< SourceDescriptor >	createDataSource (SchemaPtr inputSchema)
std::shared_ptr< Runtime::Execution::ExecutableQueryPlan >	submitQuery (DecomposedQueryPlanPtr decomposedQueryPlan)
std::shared_ptr< NonRunnableDataSource >	getDataSource (std::shared_ptr< Runtime::Execution::ExecutableQueryPlan > plan, uint32_t source)
void	emitBuffer (std::shared_ptr< Runtime::Execution::ExecutableQueryPlan > plan, Runtime::TupleBuffer buffer)
bool	stopQuery (std::shared_ptr< Runtime::Execution::ExecutableQueryPlan > plan, Runtime::QueryTerminationType type=Runtime::QueryTerminationType::HardStop)
Runtime::MemoryLayouts::TestTupleBuffer	getBuffer (const SchemaPtr &schema)
bool	stop ()
Runtime::BufferManagerPtr	getBufferManager () const
Runtime::NodeEnginePtr	getNodeEngine () const

Detailed Description

A simple stand alone query execution engine for testing.

Constructor & Destructor Documentation

TestExecutionEngine()

NES::Testing::TestExecutionEngine::TestExecutionEngine ( const QueryCompilation::DumpMode &  dumpMode = QueryCompilation::DumpMode::NONE, const uint64_t  numWorkerThreads = 1, const QueryCompilation::StreamJoinStrategy &  joinStrategy = QueryCompilation::StreamJoinStrategy::NESTED_LOOP_JOIN, const QueryCompilation::WindowingStrategy &  windowingStrategy = QueryCompilation::WindowingStrategy::SLICING  )

explicit

References NES::Testing::DEFAULT_BUFFERSIZE, NES::Testing::DEFAULT_NO_BUFFERS_IN_GLOBAL_BM_PER_THREAD, NES::Testing::DEFAULT_NO_BUFFERS_IN_SOURCE_BM_PER_THREAD, and dumpMode.

Member Function Documentation

createCollectSink()

template<class Type >

auto NES::Testing::TestExecutionEngine::createCollectSink ( SchemaPtr  outputSchema )

inline

References NES::CollectTestSink< Type >::create().

Here is the call graph for this function:

createDataSink()

std::shared_ptr< TestSink > NES::Testing::TestExecutionEngine::createDataSink	(	const SchemaPtr &	outputSchema,
		uint32_t	expectedTuples = 1
	)

createDataSource()

std::shared_ptr< SourceDescriptor > NES::Testing::TestExecutionEngine::createDataSource

(

SchemaPtr

inputSchema

)

References NES::Testing::createNonRunnableSource(), and NES::Runtime::Graceful.

Here is the call graph for this function:

emitBuffer()

void NES::Testing::TestExecutionEngine::emitBuffer	(	std::shared_ptr< Runtime::Execution::ExecutableQueryPlan >	plan,
		Runtime::TupleBuffer	buffer
	)

getBuffer()

Runtime::MemoryLayouts::TestTupleBuffer NES::Testing::TestExecutionEngine::getBuffer

(

const SchemaPtr &

schema

)

References NES::Runtime::MemoryLayouts::RowLayout::create().

Here is the call graph for this function:

getBufferManager()

Runtime::BufferManagerPtr NES::Testing::TestExecutionEngine::getBufferManager

(

)

const

getDataSource()

std::shared_ptr< NonRunnableDataSource > NES::Testing::TestExecutionEngine::getDataSource	(	std::shared_ptr< Runtime::Execution::ExecutableQueryPlan >	plan,
		uint32_t	source
	)

References NES_ASSERT.

getNodeEngine()

Runtime::NodeEnginePtr NES::Testing::TestExecutionEngine::getNodeEngine

(

)

const

stop()

bool NES::Testing::TestExecutionEngine::stop

(

)

stopQuery()

bool NES::Testing::TestExecutionEngine::stopQuery	(	std::shared_ptr< Runtime::Execution::ExecutableQueryPlan >	plan,
		Runtime::QueryTerminationType	type = Runtime::QueryTerminationType::HardStop
	)

References type.

submitQuery()

std::shared_ptr< Runtime::Execution::ExecutableQueryPlan > NES::Testing::TestExecutionEngine::submitQuery

(

DecomposedQueryPlanPtr

decomposedQueryPlan

)

References NES_ASSERT.

---

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

• /nebulastream/nes-coordinator/tests/include/Util/TestExecutionEngine.hpp
• /nebulastream/nes-coordinator/tests/src/Util/TestExecutionEngine.cpp