UnionQueryExecutionTest Class Reference

Collaboration diagram for UnionQueryExecutionTest:

Public Member Functions
struct	__attribute__ ((packed)) DefaultRecord
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 &, uint64_t)>> inputDataGenerators, uint64_t numInputTuples=10)
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
SchemaPtr	defaultSchema
std::shared_ptr< SourceDescriptor >	defaultSource
std::function< void(Runtime::MemoryLayouts::TestTupleBuffer &, uint64_t numInputRecords)>	defaultDataGenerator
std::shared_ptr< CollectTestSink< DefaultRecord > >	defaultSink
std::shared_ptr< NES::TestUtils::TestSinkDescriptor >	defaultTestSinkDescriptor
std::shared_ptr< Testing::TestExecutionEngine >	executionEngine
Public Attributes inherited from NES::Testing::BaseUnitTest
detail::TestSourceNameHelper	srcName

Static Public Attributes
static constexpr uint64_t	millisecondsToHours = 3600000
static constexpr uint64_t	defaultTimeoutInMilliseconds = 5000
static constexpr DecomposedQueryId	defaultDecomposedQueryPlanId = INVALID_DECOMPOSED_QUERY_PLAN_ID
static constexpr SharedQueryId	defaultSharedQueryId = INVALID_SHARED_QUERY_ID

Member Function Documentation

__attribute__()

struct UnionQueryExecutionTest::__attribute__ ( (packed)  )

inline

References NES::Attribute(), NES::Query::filter(), NES::TestQuery::from(), NES::Query::getQueryPlan(), NES::Query::sink(), and NES::Query::unionWith().

Here is the call graph for this function:

generateAndEmitInputBuffers()

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

inline

SetUp()

void UnionQueryExecutionTest::SetUp ( )

inlineoverride

References NES::Schema::create(), dumpMode, NES::INT64, NES::Runtime::MemoryLayouts::TestTupleBuffer::setNumberOfTuples(), and NES::Testing::BaseUnitTest::SetUp().

Here is the call graph for this function:

SetUpTestCase()

static void UnionQueryExecutionTest::SetUpTestCase ( )

inlinestatic

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

Here is the call graph for this function:

TearDown()

void UnionQueryExecutionTest::TearDown ( )

inlineoverride

References NES_DEBUG, and NES::Testing::BaseUnitTest::TearDown().

Here is the call graph for this function:

TearDownTestCase()

static void UnionQueryExecutionTest::TearDownTestCase ( )

inlinestatic

References NES_DEBUG.

Member Data Documentation

defaultDataGenerator

std::function<void(Runtime::MemoryLayouts::TestTupleBuffer&, uint64_t numInputRecords)> UnionQueryExecutionTest::defaultDataGenerator

defaultDecomposedQueryPlanId

constexpr DecomposedQueryId UnionQueryExecutionTest::defaultDecomposedQueryPlanId = INVALID_DECOMPOSED_QUERY_PLAN_ID

staticconstexpr

defaultSchema

SchemaPtr UnionQueryExecutionTest::defaultSchema

defaultSharedQueryId

constexpr SharedQueryId UnionQueryExecutionTest::defaultSharedQueryId = INVALID_SHARED_QUERY_ID

staticconstexpr

defaultSink

std::shared_ptr<CollectTestSink<DefaultRecord> > UnionQueryExecutionTest::defaultSink

defaultSource

std::shared_ptr<SourceDescriptor> UnionQueryExecutionTest::defaultSource

defaultTestSinkDescriptor

std::shared_ptr<NES::TestUtils::TestSinkDescriptor> UnionQueryExecutionTest::defaultTestSinkDescriptor

defaultTimeoutInMilliseconds

constexpr uint64_t UnionQueryExecutionTest::defaultTimeoutInMilliseconds = 5000

staticconstexpr

executionEngine

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

millisecondsToHours

constexpr uint64_t UnionQueryExecutionTest::millisecondsToHours = 3600000

staticconstexpr

---

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

• /nebulastream/nes-coordinator/tests/UnitTests/QueryExecution/UnionQueryExecutionTest.cpp