|
NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
#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>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()))) | |
| 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 | ( | WindowSerializationTest | , |
| testSerializeDeserializeWindowJoinOperators | |||
| ) |
References NES::Attribute(), NES::API::EventTime(), and NES::API::IngestionTime().
| TEST_P | ( | WindowSerializationTest | , |
| testSerializeDeserializeWindowOperators | |||
| ) |
References NES::Attribute(), NES::API::EventTime(), and NES::API::IngestionTime().