KeyedTumblingWindowQueryExecutionTest.cpp File Reference

#include <API/QueryAPI.hpp>
#include <API/Schema.hpp>
#include <BaseIntegrationTest.hpp>
#include <Plans/DecomposedQueryPlan/DecomposedQueryPlan.hpp>
#include <Types/ThresholdWindow.hpp>
#include <Util/Logger/Logger.hpp>
#include <Util/TestExecutionEngine.hpp>
#include <Util/TestSinkDescriptor.hpp>
#include <Util/TestSourceDescriptor.hpp>
#include <Util/magicenum/magic_enum.hpp>
#include <iostream>
#include <utility>

Include dependency graph for KeyedTumblingWindowQueryExecutionTest.cpp:

Classes
class	KeyedTumblingWindowQueryExecutionTest

Functions
void	fillBuffer (Runtime::MemoryLayouts::TestTupleBuffer &buf)
	TEST_F (KeyedTumblingWindowQueryExecutionTest, singleKeyTumblingWindow)
	TEST_F (KeyedTumblingWindowQueryExecutionTest, singleKeyTumblingWindowNoProjection)
	TEST_F (KeyedTumblingWindowQueryExecutionTest, multiKeyTumblingWindow)

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/3]

TEST_F	(	KeyedTumblingWindowQueryExecutionTest	,
		multiKeyTumblingWindow
	)

References NES::WindowOperatorBuilder::KeyedWindowedQuery::apply(), NES::Attribute(), NES::WindowOperatorBuilder::WindowedQuery::byKey(), 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/3]

TEST_F	(	KeyedTumblingWindowQueryExecutionTest	,
		singleKeyTumblingWindow
	)

References NES::WindowOperatorBuilder::KeyedWindowedQuery::apply(), NES::Attribute(), NES::WindowOperatorBuilder::WindowedQuery::byKey(), 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:

TEST_F() [3/3]

TEST_F	(	KeyedTumblingWindowQueryExecutionTest	,
		singleKeyTumblingWindowNoProjection
	)

References NES::WindowOperatorBuilder::KeyedWindowedQuery::apply(), NES::Attribute(), NES::WindowOperatorBuilder::WindowedQuery::byKey(), 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:

Variable Documentation

dumpMode

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

constexpr

Referenced by KeyedTumblingWindowQueryExecutionTest::SetUp().