NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
WindowAggregationFunctionTest Class Reference
Collaboration diagram for WindowAggregationFunctionTest:
[legend]

Public Member Functions

void SetUp () override
 
void TearDown () override
 
void fillBuffer (Runtime::MemoryLayouts::TestTupleBuffer &buf, uint64_t ts)
 
Runtime::Execution::ExecutableQueryPlanPtr executeQuery (Query query)
 
- 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 sourceSchema
 
std::shared_ptr< Testing::TestExecutionEngineexecutionEngine
 
- 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

◆ executeQuery()

Runtime::Execution::ExecutableQueryPlanPtr WindowAggregationFunctionTest::executeQuery ( Query  query)
inline

References NES::Query::getQueryPlan().

Here is the call graph for this function:

◆ fillBuffer()

void WindowAggregationFunctionTest::fillBuffer ( Runtime::MemoryLayouts::TestTupleBuffer buf,
uint64_t  ts 
)
inline

◆ SetUp()

void WindowAggregationFunctionTest::SetUp ( )
inlineoverride

References NES::Schema::create(), dumpMode, NES::INT64, NES::Testing::BaseUnitTest::SetUp(), and NES::UINT64.

Here is the call graph for this function:

◆ SetUpTestCase()

static void WindowAggregationFunctionTest::SetUpTestCase ( )
inlinestatic

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

Here is the call graph for this function:

◆ TearDown()

void WindowAggregationFunctionTest::TearDown ( )
inlineoverride

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

Here is the call graph for this function:

◆ TearDownTestCase()

static void WindowAggregationFunctionTest::TearDownTestCase ( )
inlinestatic

References NES_DEBUG.

Member Data Documentation

◆ defaultDecomposedQueryPlanId

constexpr DecomposedQueryId WindowAggregationFunctionTest::defaultDecomposedQueryPlanId = INVALID_DECOMPOSED_QUERY_PLAN_ID
staticconstexpr

◆ defaultSharedQueryId

constexpr SharedQueryId WindowAggregationFunctionTest::defaultSharedQueryId = INVALID_SHARED_QUERY_ID
staticconstexpr

◆ executionEngine

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

◆ sourceSchema

SchemaPtr WindowAggregationFunctionTest::sourceSchema

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