NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
WindowAggregationFunctionTest.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 WindowAggregationFunctionTest.cpp:

Classes

class  WindowAggregationFunctionTest
 

Functions

 TEST_F (WindowAggregationFunctionTest, testSumAggregation)
 
 TEST_F (WindowAggregationFunctionTest, testAvgAggregation)
 
 TEST_F (WindowAggregationFunctionTest, testMinAggregation)
 
 TEST_F (WindowAggregationFunctionTest, testMaxAggregation)
 
 TEST_F (WindowAggregationFunctionTest, testMultiAggregationFunctions)
 

Variables

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

Function Documentation

◆ TEST_F() [1/5]

TEST_F ( WindowAggregationFunctionTest  ,
testAvgAggregation   
)

References NES::Attribute(), NES::Schema::create(), NES::API::EventTime(), NES::TestQuery::from(), NES::INT64, NES::API::Milliseconds(), magic_enum::detail::value(), and NES::Query::window().

Here is the call graph for this function:

◆ TEST_F() [2/5]

TEST_F ( WindowAggregationFunctionTest  ,
testMaxAggregation   
)

References NES::Attribute(), NES::Schema::create(), NES::API::EventTime(), NES::TestQuery::from(), NES::INT64, NES::API::Milliseconds(), magic_enum::detail::value(), and NES::Query::window().

Here is the call graph for this function:

◆ TEST_F() [3/5]

TEST_F ( WindowAggregationFunctionTest  ,
testMinAggregation   
)

References NES::Attribute(), NES::Schema::create(), NES::API::EventTime(), NES::TestQuery::from(), NES::INT64, NES::API::Milliseconds(), magic_enum::detail::value(), and NES::Query::window().

Here is the call graph for this function:

◆ TEST_F() [4/5]

TEST_F ( WindowAggregationFunctionTest  ,
testMultiAggregationFunctions   
)

References NES::Attribute(), NES::Schema::create(), NES::API::EventTime(), NES::TestQuery::from(), NES::INT64, NES::API::Milliseconds(), NES::UINT64, and NES::Query::window().

Here is the call graph for this function:

◆ TEST_F() [5/5]

TEST_F ( WindowAggregationFunctionTest  ,
testSumAggregation   
)

References NES::Attribute(), NES::Schema::create(), NES::API::EventTime(), NES::TestQuery::from(), NES::INT64, NES::API::Milliseconds(), magic_enum::detail::value(), and NES::Query::window().

Here is the call graph for this function:

Variable Documentation

◆ dumpMode

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