NES::DistributedNemoJoinIntegrationTest Class Reference

Test of distributed NEMO join. More...

Collaboration diagram for NES::DistributedNemoJoinIntegrationTest:

Public Member Functions
void	SetUp () override
TestHarness	createTestHarness (const Query &query, std::function< void(CoordinatorConfigurationPtr)> crdFunctor, uint64_t layers, uint64_t nodesPerNode, uint64_t leafNodesPerNode)
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 ()
static CSVSourceTypePtr	createCSVSourceType (const std::string &logicalSourceNAme, const std::string &physicalSourceName, const std::string &inputPath)

Public Attributes
BufferManagerPtr	bufferManager
QueryCompilation::StreamJoinStrategy	joinStrategy = QueryCompilation::StreamJoinStrategy::NESTED_LOOP_JOIN
QueryCompilation::WindowingStrategy	windowingStrategy = QueryCompilation::WindowingStrategy::SLICING
Public Attributes inherited from NES::Testing::BaseUnitTest
detail::TestSourceNameHelper	srcName

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}

Detailed Description

Test of distributed NEMO join.

Member Function Documentation

createCSVSourceType()

static CSVSourceTypePtr NES::DistributedNemoJoinIntegrationTest::createCSVSourceType ( const std::string &  logicalSourceNAme, const std::string &  physicalSourceName, const std::string &  inputPath  )

inlinestatic

References NES::TestUtils::physicalSourceName().

Here is the call graph for this function:

createTestHarness()

TestHarness NES::DistributedNemoJoinIntegrationTest::createTestHarness ( const Query &  query, std::function< void(CoordinatorConfigurationPtr)>  crdFunctor, uint64_t  layers, uint64_t  nodesPerNode, uint64_t  leafNodesPerNode  )

inline

Creates a TestHarness with a given query and topology parameters. The leafs of the topology are sources.

Parameters

query	the query
crdFunctor	functor to pass coordinator params
layers	number of layers of the topology tree
nodesPerNode	number of children per node
leafNodesPerNode	number of leaf nodes for the parents of last layer

Returns

the TestHarness

References NES::TestHarness::addLogicalSource(), NES::TestHarness::attachWorkerToWorkerWithId(), NES::TestHarness::attachWorkerWithCSVSourceToWorkerWithId(), NES::Schema::create(), NES::DataTypeFactory::createUInt32(), NES::DataTypeFactory::createUInt64(), NES_DEBUG, nodeId, NES::TestUtils::restPort(), NES::TestHarness::setJoinStrategy(), NES::TestHarness::setupTopology(), NES::TestHarness::setWindowingStrategy(), NES::TestHarness::validate(), and magic_enum::detail::value().

Here is the call graph for this function:

SetUp()

void NES::DistributedNemoJoinIntegrationTest::SetUp ( )

inlineoverride

References NES::Testing::BaseIntegrationTest::SetUp().

Here is the call graph for this function:

SetUpTestCase()

static void NES::DistributedNemoJoinIntegrationTest::SetUpTestCase ( )

inlinestatic

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

Here is the call graph for this function:

Member Data Documentation

bufferManager

BufferManagerPtr NES::DistributedNemoJoinIntegrationTest::bufferManager

joinStrategy

QueryCompilation::StreamJoinStrategy NES::DistributedNemoJoinIntegrationTest::joinStrategy = QueryCompilation::StreamJoinStrategy::NESTED_LOOP_JOIN

windowingStrategy

QueryCompilation::WindowingStrategy NES::DistributedNemoJoinIntegrationTest::windowingStrategy = QueryCompilation::WindowingStrategy::SLICING

---

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

• /nebulastream/nes-coordinator/tests/Integration/DistributedNemoJoinIntegrationTest.cpp