NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
NonKeyedTumblingWindowQueryExecutionTest.cpp File Reference
#include <API/QueryAPI.hpp>
#include <API/Schema.hpp>
#include <BaseIntegrationTest.hpp>
#include <Plans/DecomposedQueryPlan/DecomposedQueryPlan.hpp>
#include <Util/Logger/Logger.hpp>
#include <Util/TestExecutionEngine.hpp>
#include <Util/TestSinkDescriptor.hpp>
#include <Util/magicenum/magic_enum.hpp>
Include dependency graph for NonKeyedTumblingWindowQueryExecutionTest.cpp:

Classes

class  NonKeyedTumblingWindowQueryExecutionTest
 

Functions

void fillBuffer (Runtime::MemoryLayouts::TestTupleBuffer &buf)
 
 TEST_F (NonKeyedTumblingWindowQueryExecutionTest, testTumblingWindow)
 
 TEST_F (NonKeyedTumblingWindowQueryExecutionTest, testSimpleTumblingWindowNoProjection)
 

Variables

constexpr auto dumpMode = NES::QueryCompilation::DumpMode::NONE
 

Function Documentation

◆ fillBuffer()

void fillBuffer ( Runtime::MemoryLayouts::TestTupleBuffer buf)

References NES::Runtime::MemoryLayouts::TestTupleBuffer::getBuffer(), NES::Runtime::MemoryLayouts::TestTupleBuffer::setNumberOfTuples(), and NES::Runtime::TupleBuffer::setSequenceData().

Referenced by TEST_F().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ TEST_F() [1/2]

TEST_F ( NonKeyedTumblingWindowQueryExecutionTest  ,
testSimpleTumblingWindowNoProjection   
)

References NES::WindowOperatorBuilder::WindowedQuery::apply(), NES::Attribute(), NES::Schema::create(), NES::API::EventTime(), fillBuffer(), NES::TestQuery::from(), NES::INT64, NES::API::Milliseconds(), NES::Query::sink(), NES::API::Sum(), NES::UINT64, and NES::Query::window().

Here is the call graph for this function:

◆ TEST_F() [2/2]

TEST_F ( NonKeyedTumblingWindowQueryExecutionTest  ,
testTumblingWindow   
)

References NES::WindowOperatorBuilder::WindowedQuery::apply(), NES::Attribute(), NES::Schema::create(), NES::API::EventTime(), fillBuffer(), NES::TestQuery::from(), NES::INT64, NES::API::Milliseconds(), NES::Query::project(), NES::API::Sum(), NES::UINT64, and NES::Query::window().

Here is the call graph for this function:

Variable Documentation

◆ dumpMode

constexpr auto dumpMode = NES::QueryCompilation::DumpMode::NONE
constexpr