ThresholdWindowQueryExecutionTest.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/magicenum/magic_enum.hpp>

Include dependency graph for ThresholdWindowQueryExecutionTest.cpp:

Classes
class	ThresholdWindowQueryExecutionTest

Functions
template<typename T >
void	fillBuffer (Runtime::MemoryLayouts::TestTupleBuffer &buf)
	TEST_F (ThresholdWindowQueryExecutionTest, simpleThresholdWindowTestSum)
	TEST_F (ThresholdWindowQueryExecutionTest, simpleThresholdWindowTestWithMax)
	TEST_F (ThresholdWindowQueryExecutionTest, simpleThresholdWindowTestWithMin)
	TEST_F (ThresholdWindowQueryExecutionTest, simpleThresholdWindowTestWithAvg)
	TEST_F (ThresholdWindowQueryExecutionTest, simpleThresholdWindowTestWithCount)
	TEST_F (ThresholdWindowQueryExecutionTest, simpleThresholdWindowTestSumFloat)
	TEST_F (ThresholdWindowQueryExecutionTest, simpleThresholdWindowTestSumInt32)
	TEST_F (ThresholdWindowQueryExecutionTest, simpleThresholdWindowTestSumDouble)
	TEST_F (ThresholdWindowQueryExecutionTest, simpleThresholdWindowTestWithCountAndSum)

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

Function Documentation

fillBuffer()

template<typename T >

void fillBuffer

(

Runtime::MemoryLayouts::TestTupleBuffer &

buf

)

References NES_DEBUG, and NES::Runtime::MemoryLayouts::TestTupleBuffer::setNumberOfTuples().

Here is the call graph for this function:

TEST_F() [1/9]

TEST_F	(	ThresholdWindowQueryExecutionTest	,
		simpleThresholdWindowTestSum
	)

Test the execution of a query with threshold window operator and apply a Sum aggregation.

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

Here is the call graph for this function:

TEST_F() [2/9]

TEST_F	(	ThresholdWindowQueryExecutionTest	,
		simpleThresholdWindowTestSumDouble
	)

Test the execution of a query with threshold window operator and apply a Sum aggregation of float64/Double data.

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

Here is the call graph for this function:

TEST_F() [3/9]

TEST_F	(	ThresholdWindowQueryExecutionTest	,
		simpleThresholdWindowTestSumFloat
	)

Test the execution of a query with threshold window operator and apply a Sum aggregation of float32 data.

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

Here is the call graph for this function:

TEST_F() [4/9]

TEST_F	(	ThresholdWindowQueryExecutionTest	,
		simpleThresholdWindowTestSumInt32
	)

Test the execution of a query with threshold window operator and apply a Sum aggregation of Int32 data.

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

Here is the call graph for this function:

TEST_F() [5/9]

TEST_F	(	ThresholdWindowQueryExecutionTest	,
		simpleThresholdWindowTestWithAvg
	)

Test the execution of a query with threshold window operator and apply a Average aggregation.

References NES::WindowOperatorBuilder::WindowedQuery::apply(), NES::Attribute(), NES::API::Avg(), NES::Schema::create(), NES::TestQuery::from(), NES::INT64, NES::Query::sink(), and NES::Query::window().

Here is the call graph for this function:

TEST_F() [6/9]

TEST_F	(	ThresholdWindowQueryExecutionTest	,
		simpleThresholdWindowTestWithCount
	)

Test the execution of a query with threshold window operator and apply a Count aggregation.

References NES::WindowOperatorBuilder::WindowedQuery::apply(), NES::Attribute(), NES::API::Count(), NES::Schema::create(), NES::TestQuery::from(), NES::INT64, NES::Query::sink(), and NES::Query::window().

Here is the call graph for this function:

TEST_F() [7/9]

TEST_F	(	ThresholdWindowQueryExecutionTest	,
		simpleThresholdWindowTestWithCountAndSum
	)

Test the execution of a query with threshold window operator and apply a Count aggregation in combination with a sum aggregation. This test checks the behaviour of multi aggs incl. count aggregations as count agg do not have an access field

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

Here is the call graph for this function:

TEST_F() [8/9]

TEST_F	(	ThresholdWindowQueryExecutionTest	,
		simpleThresholdWindowTestWithMax
	)

Test the execution of a query with threshold window operator and apply a Max aggregation.

References NES::WindowOperatorBuilder::WindowedQuery::apply(), NES::Attribute(), NES::Schema::create(), NES::TestQuery::from(), NES::INT64, NES::API::Max(), NES::Query::sink(), and NES::Query::window().

Here is the call graph for this function:

TEST_F() [9/9]

TEST_F	(	ThresholdWindowQueryExecutionTest	,
		simpleThresholdWindowTestWithMin
	)

Test the execution of a query with threshold window operator and apply a Min aggregation.

References NES::WindowOperatorBuilder::WindowedQuery::apply(), NES::Attribute(), NES::Schema::create(), NES::TestQuery::from(), NES::INT64, NES::API::Min(), NES::Query::sink(), 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 ThresholdWindowQueryExecutionTest::SetUp().