Collaboration diagram for NES::JoinMultiThreadedTest:

[legend]

Public Member Functions
void	SetUp () override

void	TearDown () override

void	recyclePooledBuffer (Runtime::detail::MemorySegment *) override
	Interface method for pooled buffer recycling. More...

void	recycleUnpooledBuffer (Runtime::detail::MemorySegment *) override
	Interface method for unpooled buffer recycling. More...

template<typename ResultRecord >
std::vector< ResultRecord > &	runQueryAndPrintMissingRecords (const std::vector< std::pair< SchemaPtr, std::string >> &inputs, const std::vector< ResultRecord > &expectedTuples, const std::shared_ptr< CollectTestSink< ResultRecord >> &testSink, const Query &query)

Public Member Functions inherited from NES::Testing::BaseIntegrationTest
	BaseIntegrationTest ()
	the base test class ctor that creates the internal test resources More...

	~BaseIntegrationTest () override

void	SetUp () override
	Fetches the port. More...

void	TearDown () override
	Release internal ports. More...

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

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::Testing::BaseUnitTest
void	SetUp () override

void	TearDown () override

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 ()

Public Attributes
const uint64_t	numTuplesPerBuffer = 2

std::shared_ptr< Testing::TestExecutionEngine >	executionEngine

QueryCompilation::StreamJoinStrategy	joinStrategy

QueryCompilation::WindowingStrategy	windowingStrategy

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

Static Public Attributes
static constexpr auto	dumpNone = QueryCompilation::DumpMode::NONE

static constexpr auto	waitTillStoppingQuery = std::chrono::milliseconds(100)

static constexpr DecomposedQueryId	defaultDecomposedQueryPlanId = INVALID_DECOMPOSED_QUERY_PLAN_ID

static constexpr SharedQueryId	defaultSharedQueryId = INVALID_SHARED_QUERY_ID

Additional Inherited Members
Protected Member Functions inherited from NES::Testing::BaseIntegrationTest
BorrowedPortPtr	getAvailablePort ()
	Retrieve another free port. More...

std::filesystem::path	getTestResourceFolder () const
	returns the test resource folder to write files More...

Protected Attributes inherited from NES::Testing::BaseIntegrationTest
BorrowedPortPtr	rpcCoordinatorPort {nullptr}

BorrowedPortPtr	restPort {nullptr}

Member Function Documentation

◆ recyclePooledBuffer()

void NES::JoinMultiThreadedTest::recyclePooledBuffer ( Runtime::detail::MemorySegment * buffer )

inlineoverridevirtual

Interface method for pooled buffer recycling.

Parameters

buffer the buffer to recycle

Implements NES::Runtime::BufferRecycler.

◆ recycleUnpooledBuffer()

void NES::JoinMultiThreadedTest::recycleUnpooledBuffer ( Runtime::detail::MemorySegment * buffer )

inlineoverridevirtual

Interface method for unpooled buffer recycling.

Parameters

buffer the buffer to recycle

Implements NES::Runtime::BufferRecycler.

◆ runQueryAndPrintMissingRecords()

template<typename ResultRecord >

std::vector<ResultRecord>& NES::JoinMultiThreadedTest::runQueryAndPrintMissingRecords	(	const std::vector< std::pair< SchemaPtr, std::string >> &	inputs,
		const std::vector< ResultRecord > &	expectedTuples,
		const std::shared_ptr< CollectTestSink< ResultRecord >> &	testSink,
		const Query &	query
	)

inline

References NES::TestUtils::createExpectedBuffersFromCsv(), defaultDecomposedQueryPlanId, defaultSharedQueryId, executionEngine, NES::Query::getQueryPlan(), NES::Runtime::Graceful, NES_INFO, numTuplesPerBuffer, and waitTillStoppingQuery.

Here is the call graph for this function:

◆ SetUp()

void NES::JoinMultiThreadedTest::SetUp ( )

inlineoverride

References dumpNone, executionEngine, joinStrategy, and windowingStrategy.

◆ SetUpTestCase()

static void NES::JoinMultiThreadedTest::SetUpTestCase ( )

inlinestatic

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

Here is the call graph for this function:

◆ TearDown()

void NES::JoinMultiThreadedTest::TearDown ( )

inlineoverride

References executionEngine, NES_INFO, and NES::Testing::BaseIntegrationTest::TearDown().

Here is the call graph for this function:

Member Data Documentation

◆ defaultDecomposedQueryPlanId

constexpr DecomposedQueryId NES::JoinMultiThreadedTest::defaultDecomposedQueryPlanId = INVALID_DECOMPOSED_QUERY_PLAN_ID

staticconstexpr

Referenced by runQueryAndPrintMissingRecords().

◆ defaultSharedQueryId

constexpr SharedQueryId NES::JoinMultiThreadedTest::defaultSharedQueryId = INVALID_SHARED_QUERY_ID

staticconstexpr

Referenced by runQueryAndPrintMissingRecords().

◆ dumpNone

constexpr auto NES::JoinMultiThreadedTest::dumpNone = QueryCompilation::DumpMode::NONE

staticconstexpr

Referenced by SetUp().

◆ executionEngine

std::shared_ptr<Testing::TestExecutionEngine> NES::JoinMultiThreadedTest::executionEngine

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

◆ joinStrategy

QueryCompilation::StreamJoinStrategy NES::JoinMultiThreadedTest::joinStrategy

Referenced by SetUp().

◆ numTuplesPerBuffer

const uint64_t NES::JoinMultiThreadedTest::numTuplesPerBuffer = 2

Referenced by runQueryAndPrintMissingRecords().

◆ waitTillStoppingQuery

constexpr auto NES::JoinMultiThreadedTest::waitTillStoppingQuery = std::chrono::milliseconds(100)

staticconstexpr

Referenced by runQueryAndPrintMissingRecords().

◆ windowingStrategy

QueryCompilation::WindowingStrategy NES::JoinMultiThreadedTest::windowingStrategy

Referenced by SetUp().

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

/nebulastream/nes-coordinator/tests/Integration/JoinMultiThreadedTest.cpp

Public Member Functions

Static Public Member Functions

Public Attributes

Static Public Attributes

Additional Inherited Members

Member Function Documentation

◆ recyclePooledBuffer()

◆ recycleUnpooledBuffer()

◆ runQueryAndPrintMissingRecords()

◆ SetUp()

◆ SetUpTestCase()

◆ TearDown()

Member Data Documentation

◆ defaultDecomposedQueryPlanId

◆ defaultSharedQueryId

◆ dumpNone

◆ executionEngine

◆ joinStrategy

◆ numTuplesPerBuffer

◆ waitTillStoppingQuery

◆ windowingStrategy