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().