SerializationUtilTest.cpp File Reference

#include <API/AttributeField.hpp>
#include <API/Expressions/ArithmeticalExpressions.hpp>
#include <API/Expressions/Expressions.hpp>
#include <API/Expressions/LogicalExpressions.hpp>
#include <API/Query.hpp>
#include <API/QueryAPI.hpp>
#include <API/Schema.hpp>
#include <API/Windowing.hpp>
#include <BaseIntegrationTest.hpp>
#include <Common/DataTypes/DataTypeFactory.hpp>
#include <Expressions/ArithmeticalExpressions/AbsExpressionNode.hpp>
#include <Expressions/ArithmeticalExpressions/AddExpressionNode.hpp>
#include <Expressions/ArithmeticalExpressions/DivExpressionNode.hpp>
#include <Expressions/ArithmeticalExpressions/MulExpressionNode.hpp>
#include <Expressions/ArithmeticalExpressions/SqrtExpressionNode.hpp>
#include <Expressions/ArithmeticalExpressions/SubExpressionNode.hpp>
#include <Expressions/CaseExpressionNode.hpp>
#include <Expressions/ExpressionSerializationUtil.hpp>
#include <Expressions/FieldAccessExpressionNode.hpp>
#include <Expressions/FieldAssignmentExpressionNode.hpp>
#include <Expressions/Functions/FunctionExpressionNode.hpp>
#include <Expressions/LogicalExpressions/AndExpressionNode.hpp>
#include <Expressions/LogicalExpressions/EqualsExpressionNode.hpp>
#include <Expressions/LogicalExpressions/GreaterExpressionNode.hpp>
#include <Expressions/LogicalExpressions/LessEqualsExpressionNode.hpp>
#include <Expressions/LogicalExpressions/LessExpressionNode.hpp>
#include <Expressions/LogicalExpressions/OrExpressionNode.hpp>
#include <Expressions/WhenExpressionNode.hpp>
#include <Measures/TimeCharacteristic.hpp>
#include <Operators/LogicalOperators/LogicalBinaryOperator.hpp>
#include <Operators/LogicalOperators/LogicalIntervalJoinDescriptor.hpp>
#include <Operators/LogicalOperators/LogicalIntervalJoinOperator.hpp>
#include <Operators/LogicalOperators/Network/NetworkSinkDescriptor.hpp>
#include <Operators/LogicalOperators/Network/NetworkSourceDescriptor.hpp>
#include <Operators/LogicalOperators/Sinks/FileSinkDescriptor.hpp>
#include <Operators/LogicalOperators/Sinks/OPCSinkDescriptor.hpp>
#include <Operators/LogicalOperators/Sinks/PrintSinkDescriptor.hpp>
#include <Operators/LogicalOperators/Sinks/SinkLogicalOperator.hpp>
#include <Operators/LogicalOperators/Sinks/StatisticSinkDescriptor.hpp>
#include <Operators/LogicalOperators/Sinks/ZmqSinkDescriptor.hpp>
#include <Operators/LogicalOperators/Sources/BinarySourceDescriptor.hpp>
#include <Operators/LogicalOperators/Sources/CsvSourceDescriptor.hpp>
#include <Operators/LogicalOperators/Sources/DefaultSourceDescriptor.hpp>
#include <Operators/LogicalOperators/Sources/LogicalSourceDescriptor.hpp>
#include <Operators/LogicalOperators/Sources/SenseSourceDescriptor.hpp>
#include <Operators/LogicalOperators/Sources/SourceLogicalOperator.hpp>
#include <Operators/LogicalOperators/Sources/TCPSourceDescriptor.hpp>
#include <Operators/LogicalOperators/Sources/ZmqSourceDescriptor.hpp>
#include <Operators/LogicalOperators/StatisticCollection/Descriptor/CountMinDescriptor.hpp>
#include <Operators/LogicalOperators/StatisticCollection/Metrics/IngestionRate.hpp>
#include <Operators/LogicalOperators/StatisticCollection/SendingPolicy/SendingPolicyASAP.hpp>
#include <Operators/LogicalOperators/StatisticCollection/SendingPolicy/SendingPolicyAdaptive.hpp>
#include <Operators/LogicalOperators/StatisticCollection/SendingPolicy/SendingPolicyLazy.hpp>
#include <Operators/LogicalOperators/StatisticCollection/TriggerCondition/NeverTrigger.hpp>
#include <Operators/LogicalOperators/Windows/Aggregations/WindowAggregationDescriptor.hpp>
#include <Operators/LogicalOperators/Windows/Joins/LogicalJoinOperator.hpp>
#include <Operators/LogicalOperators/Windows/LogicalWindowDescriptor.hpp>
#include <Operators/Serialization/OperatorSerializationUtil.hpp>
#include <Operators/Serialization/QueryPlanSerializationUtil.hpp>
#include <Operators/Serialization/SchemaSerializationUtil.hpp>
#include <Plans/Query/QueryPlan.hpp>
#include <SerializableOperator.pb.h>
#include <SerializableQueryPlan.pb.h>
#include <Serialization/DataTypeSerializationUtil.hpp>
#include <Types/ThresholdWindow.hpp>
#include <Util/JavaUDFDescriptorBuilder.hpp>
#include <Util/Logger/Logger.hpp>
#include <google/protobuf/util/json_util.h>
#include <gtest/gtest.h>
#include <iostream>

Classes
class	SerializationUtilTest

Functions
	TEST_F (SerializationUtilTest, dataTypeSerialization)
	TEST_F (SerializationUtilTest, schemaSerializationTest)
	TEST_F (SerializationUtilTest, schemaSerializationTestColumnLayout)
	TEST_F (SerializationUtilTest, sourceDescriptorSerialization)
	TEST_F (SerializationUtilTest, sinkDescriptorSerialization)
	TEST_F (SerializationUtilTest, expressionSerialization)
	TEST_F (SerializationUtilTest, functionExpressionSerialization)
	TEST_F (SerializationUtilTest, operatorSerialization)
	TEST_F (SerializationUtilTest, queryPlanSerDeSerialization)
	TEST_F (SerializationUtilTest, queryPlanSerDeSerializationMultipleFilters)
	TEST_F (SerializationUtilTest, queryPlanSerDeSerializationColumnarLayout)
	TEST_F (SerializationUtilTest, queryPlanWithMultipleRootSerDeSerialization)
	TEST_F (SerializationUtilTest, queryPlanWithMultipleSourceSerDeSerialization)
	TEST_F (SerializationUtilTest, testSerializeDeserializeCilentOriginatedQueryPlan)

Function Documentation

TEST_F() [1/14]

TEST_F	(	SerializationUtilTest	,
		dataTypeSerialization
	)

References NES::DataTypeFactory::createArray(), NES::DataTypeFactory::createDouble(), NES::DataTypeFactory::createFloat(), NES::DataTypeFactory::createInt16(), NES::DataTypeFactory::createInt32(), NES::DataTypeFactory::createInt64(), NES::DataTypeFactory::createInt8(), NES::DataTypeFactory::createText(), NES::DataTypeFactory::createUInt16(), NES::DataTypeFactory::createUInt32(), NES::DataTypeFactory::createUInt64(), NES::DataTypeFactory::createUInt8(), NES::DataTypeSerializationUtil::deserializeDataType(), and NES::DataTypeSerializationUtil::serializeDataType().

Here is the call graph for this function:

TEST_F() [2/14]

TEST_F	(	SerializationUtilTest	,
		expressionSerialization
	)

References NES::DataTypeFactory::createInt32().

Here is the call graph for this function:

TEST_F() [3/14]

TEST_F	(	SerializationUtilTest	,
		functionExpressionSerialization
	)

References NES::DataTypeFactory::createBasicValue(), and NES::DataTypeFactory::createUInt64().

Here is the call graph for this function:

TEST_F() [4/14]

TEST_F	(	SerializationUtilTest	,
		operatorSerialization
	)

References NES::ABS(), NES::Attribute(), NES::DataTypeFactory::createInt64(), NES::Statistic::DEFAULT, NES::API::EventTime(), NES::FLOAT32, NES::ExpressionItem::getExpressionNode(), NES::API::Hours(), NES::API::Milliseconds(), NES::MOD(), NES_DEBUG, NES::POWER(), NES::API::Seconds(), and NES::API::Sum().

Here is the call graph for this function:

TEST_F() [5/14]

TEST_F	(	SerializationUtilTest	,
		queryPlanSerDeSerialization
	)

References NES::Attribute().

Here is the call graph for this function:

TEST_F() [6/14]

TEST_F	(	SerializationUtilTest	,
		queryPlanSerDeSerializationColumnarLayout
	)

References NES::Attribute().

Here is the call graph for this function:

TEST_F() [7/14]

TEST_F	(	SerializationUtilTest	,
		queryPlanSerDeSerializationMultipleFilters
	)

References NES::Attribute().

Here is the call graph for this function:

TEST_F() [8/14]

TEST_F	(	SerializationUtilTest	,
		queryPlanWithMultipleRootSerDeSerialization
	)

References NES::Attribute().

Here is the call graph for this function:

TEST_F() [9/14]

TEST_F	(	SerializationUtilTest	,
		queryPlanWithMultipleSourceSerDeSerialization
	)

References NES::Attribute().

Here is the call graph for this function:

TEST_F() [10/14]

TEST_F	(	SerializationUtilTest	,
		schemaSerializationTest
	)

References NES::Schema::create(), NES::DataTypeFactory::createArray(), NES::DataTypeFactory::createDouble(), NES::DataTypeFactory::createInt32(), NES::DataTypeFactory::createInt8(), and NES::DataTypeFactory::createText().

Here is the call graph for this function:

TEST_F() [11/14]

TEST_F	(	SerializationUtilTest	,
		schemaSerializationTestColumnLayout
	)

References NES::Schema::COLUMNAR_LAYOUT, NES::Schema::create(), NES::DataTypeFactory::createArray(), NES::DataTypeFactory::createDouble(), NES::DataTypeFactory::createInt32(), NES::DataTypeFactory::createInt8(), and NES::DataTypeFactory::createText().

Here is the call graph for this function:

TEST_F() [12/14]

TEST_F	(	SerializationUtilTest	,
		sinkDescriptorSerialization
	)

References nodeId.

TEST_F() [13/14]

TEST_F	(	SerializationUtilTest	,
		sourceDescriptorSerialization
	)

References NES::Schema::create(), NES::INT32, NES_DEBUG, and nodeId.

Here is the call graph for this function:

TEST_F() [14/14]

TEST_F	(	SerializationUtilTest	,
		testSerializeDeserializeCilentOriginatedQueryPlan
	)

References NES::Query::from(), NES::Query::getQueryPlan(), and NES::Query::sink().

Here is the call graph for this function: