NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
TimeWindowSerializationTest.cpp File Reference
#include <API/Expressions/Expressions.hpp>
#include <API/Expressions/LogicalExpressions.hpp>
#include <API/QueryAPI.hpp>
#include <API/Windowing.hpp>
#include <BaseIntegrationTest.hpp>
#include <Common/DataTypes/DataTypeFactory.hpp>
#include <Expressions/FieldAccessExpressionNode.hpp>
#include <Expressions/LogicalExpressions/EqualsExpressionNode.hpp>
#include <Operators/LogicalOperators/Network/NetworkSourceDescriptor.hpp>
#include <Operators/LogicalOperators/Sources/BinarySourceDescriptor.hpp>
#include <Operators/LogicalOperators/Sources/TCPSourceDescriptor.hpp>
#include <Operators/LogicalOperators/Windows/Joins/LogicalJoinDescriptor.hpp>
#include <Operators/LogicalOperators/Windows/Joins/LogicalJoinOperator.hpp>
#include <Operators/LogicalOperators/Windows/LogicalWindowDescriptor.hpp>
#include <Operators/LogicalOperators/Windows/LogicalWindowOperator.hpp>
#include <Operators/Serialization/OperatorSerializationUtil.hpp>
#include <Operators/Serialization/QueryPlanSerializationUtil.hpp>
#include <Plans/Query/QueryPlan.hpp>
#include <SerializableOperator.pb.h>
#include <Types/SlidingWindow.hpp>
#include <Util/Logger/Logger.hpp>
#include <gtest/gtest.h>
#include <tuple>
Include dependency graph for TimeWindowSerializationTest.cpp:

Classes

class  WindowSerializationTest
 

Functions

 TEST_P (WindowSerializationTest, testSerializeDeserializeWindowOperators)
 
 TEST_P (WindowSerializationTest, testSerializeDeserializeWindowJoinOperators)
 
 INSTANTIATE_TEST_SUITE_P (MyInstantiation, WindowSerializationTest, ::testing::Combine(::testing::Values(Milliseconds(1), Milliseconds(200), Milliseconds(1000), Hours(1), Hours(6), Hours(24), Days(1), Days(10), Minutes(1), Minutes(5), Minutes(60), Seconds(1), Seconds(5), Seconds(60)), ::testing::Values(Milliseconds(), Hours(), Days(), Minutes(), Seconds())))
 

Function Documentation

◆ INSTANTIATE_TEST_SUITE_P()

INSTANTIATE_TEST_SUITE_P ( MyInstantiation  ,
WindowSerializationTest  ,
::testing::Combine(::testing::Values(Milliseconds(1), Milliseconds(200), Milliseconds(1000), Hours(1), Hours(6), Hours(24), Days(1), Days(10), Minutes(1), Minutes(5), Minutes(60), Seconds(1), Seconds(5), Seconds(60)), ::testing::Values(Milliseconds(), Hours(), Days(), Minutes(), Seconds()))   
)

◆ TEST_P() [1/2]

TEST_P ( WindowSerializationTest  ,
testSerializeDeserializeWindowJoinOperators   
)

References NES::Attribute(), NES::API::EventTime(), and NES::API::IngestionTime().

Here is the call graph for this function:

◆ TEST_P() [2/2]

TEST_P ( WindowSerializationTest  ,
testSerializeDeserializeWindowOperators   
)

References NES::Attribute(), NES::API::EventTime(), and NES::API::IngestionTime().

Here is the call graph for this function: