LowerLogicalToPhysicalOperatorsTest.cpp File Reference

#include <API/QueryAPI.hpp>
#include <BaseIntegrationTest.hpp>
#include <Common/DataTypes/DataTypeFactory.hpp>
#include <Expressions/ConstantValueExpressionNode.hpp>
#include <Expressions/FieldAssignmentExpressionNode.hpp>
#include <Expressions/LogicalExpressions/EqualsExpressionNode.hpp>
#include <Measures/TimeCharacteristic.hpp>
#include <Measures/TimeMeasure.hpp>
#include <Operators/LogicalOperators/LogicalBatchJoinDescriptor.hpp>
#include <Operators/LogicalOperators/LogicalBatchJoinOperator.hpp>
#include <Operators/LogicalOperators/LogicalBinaryOperator.hpp>
#include <Operators/LogicalOperators/Sinks/PrintSinkDescriptor.hpp>
#include <Operators/LogicalOperators/Sources/LogicalSourceDescriptor.hpp>
#include <Operators/LogicalOperators/UDFs/PythonUDFDescriptor.hpp>
#include <Operators/LogicalOperators/Watermarks/IngestionTimeWatermarkStrategyDescriptor.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/WindowOperator.hpp>
#include <Plans/DecomposedQueryPlan/DecomposedQueryPlan.hpp>
#include <Plans/Query/QueryPlan.hpp>
#include <Plans/Utils/PlanIterator.hpp>
#include <QueryCompiler/Operators/PhysicalOperators/Joining/PhysicalJoinBuildOperator.hpp>
#include <QueryCompiler/Operators/PhysicalOperators/Joining/PhysicalJoinSinkOperator.hpp>
#include <QueryCompiler/Operators/PhysicalOperators/Joining/Streaming/PhysicalStreamJoinProbeOperator.hpp>
#include <QueryCompiler/Operators/PhysicalOperators/PhysicalDemultiplexOperator.hpp>
#include <QueryCompiler/Operators/PhysicalOperators/PhysicalFilterOperator.hpp>
#include <QueryCompiler/Operators/PhysicalOperators/PhysicalMapOperator.hpp>
#include <QueryCompiler/Operators/PhysicalOperators/PhysicalMapUDFOperator.hpp>
#include <QueryCompiler/Operators/PhysicalOperators/PhysicalProjectOperator.hpp>
#include <QueryCompiler/Operators/PhysicalOperators/PhysicalSinkOperator.hpp>
#include <QueryCompiler/Operators/PhysicalOperators/PhysicalSourceOperator.hpp>
#include <QueryCompiler/Operators/PhysicalOperators/PhysicalUnionOperator.hpp>
#include <QueryCompiler/Operators/PhysicalOperators/PhysicalWatermarkAssignmentOperator.hpp>
#include <QueryCompiler/Operators/PhysicalOperators/Windowing/PhysicalSlicePreAggregationOperator.hpp>
#include <QueryCompiler/Operators/PhysicalOperators/Windowing/PhysicalWindowSinkOperator.hpp>
#include <QueryCompiler/Phases/Translations/DefaultPhysicalOperatorProvider.hpp>
#include <QueryCompiler/Phases/Translations/LowerLogicalToPhysicalOperators.hpp>
#include <QueryCompiler/QueryCompilerOptions.hpp>
#include <Util/CompilerConstants.hpp>
#include <Util/DumpHandler/ConsoleDumpHandler.hpp>
#include <Util/JavaUDFDescriptorBuilder.hpp>
#include <Util/Logger/Logger.hpp>
#include <gtest/gtest.h>

Include dependency graph for LowerLogicalToPhysicalOperatorsTest.cpp:

Classes
class	NES::LowerLogicalToPhysicalOperatorsTest

Namespaces
	NES
	This exception represents a network error.

Functions
	NES::TEST_F (LowerLogicalToPhysicalOperatorsTest, translateFilterQuery)
	Input Query Plan: More...
	NES::TEST_F (LowerLogicalToPhysicalOperatorsTest, translateDemultiplexFilterQuery)
	Input Query Plan: More...
	NES::TEST_F (LowerLogicalToPhysicalOperatorsTest, translateFilterMultiplexQuery)
	Input Query Plan: More...
	NES::TEST_F (LowerLogicalToPhysicalOperatorsTest, translateFilterImplicitMultiplexQuery)
	Input Query Plan: More...
	NES::TEST_F (LowerLogicalToPhysicalOperatorsTest, DISABLED_translateSimpleJoinQuery)
	Input Query Plan: More...
	NES::TEST_F (LowerLogicalToPhysicalOperatorsTest, DISABLED_translateSimpleBatchJoinQuery)
	NES::TEST_F (LowerLogicalToPhysicalOperatorsTest, DISABLED_translateJoinQueryWithMultiplex)
	Input Query Plan: More...
	NES::TEST_F (LowerLogicalToPhysicalOperatorsTest, DISABLED_translateJoinQueryWithMultiplex4Edges)
	Input Query Plan: More...
	NES::TEST_F (LowerLogicalToPhysicalOperatorsTest, DISABLED_translateWindowQuery)
	Input Query Plan: More...
	NES::TEST_F (LowerLogicalToPhysicalOperatorsTest, translateMapQuery)
	Input Query Plan: More...
	NES::TEST_F (LowerLogicalToPhysicalOperatorsTest, translateMapJavaUDFQuery)
	Input Query Plan: More...
	NES::TEST_F (LowerLogicalToPhysicalOperatorsTest, translateProjectQuery)
	Input Query Plan: More...
	NES::TEST_F (LowerLogicalToPhysicalOperatorsTest, translateTwoSourceQuery)
	Input Query Plan: More...
	NES::TEST_F (LowerLogicalToPhysicalOperatorsTest, translateSinkSourceQuery)
	Input Query Plan: More...
	NES::TEST_F (LowerLogicalToPhysicalOperatorsTest, checkUsedSameOperator)
	Check that same decomposed query is lowered with the same operator handler Input Query Plan: More...
	NES::TEST_F (LowerLogicalToPhysicalOperatorsTest, checkRecreationFileSet)
	Check migration file path is propagated Input Query Plan: More...
	NES::TEST_F (LowerLogicalToPhysicalOperatorsTest, checkMigrationFileIsPropogatedToSink)
	check recreation file Input Query Plan: More...