NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
LogicalOperatorTest.cpp File Reference
#include <BaseIntegrationTest.hpp>
#include <Expressions/ConstantValueExpressionNode.hpp>
#include <Operators/LogicalOperators/LogicalFilterOperator.hpp>
#include <Operators/LogicalOperators/LogicalOperator.hpp>
#include <Operators/LogicalOperators/Sources/DefaultSourceDescriptor.hpp>
#include <Operators/LogicalOperators/Sources/SourceLogicalOperator.hpp>
#include <Util/DumpHandler/ConsoleDumpHandler.hpp>
#include <Util/DumpHandler/DumpContext.hpp>
#include <Util/Logger/Logger.hpp>
#include <gtest/gtest.h>
#include <Catalogs/Source/LogicalSource.hpp>
#include <Catalogs/Source/SourceCatalog.hpp>
#include <Common/DataTypes/DataTypeFactory.hpp>
#include <Runtime/NodeEngine.hpp>
#include <Sources/DefaultSource.hpp>
#include <iostream>
#include <memory>
#include <Nodes/Iterators/BreadthFirstNodeIterator.hpp>
#include <Nodes/Iterators/DepthFirstNodeIterator.hpp>
#include <Optimizer/Phases/TypeInferencePhase.hpp>
#include <Util/Core.hpp>
Include dependency graph for LogicalOperatorTest.cpp:

Classes

class  NES::LogicalOperatorTest
 

Namespaces

 NES
 This exception represents a network error.
 

Functions

 NES::TEST_F (LogicalOperatorTest, getSuccessors)
 
 NES::TEST_F (LogicalOperatorTest, getPredecessors)
 
 NES::TEST_F (LogicalOperatorTest, addSelfAsSuccessor)
 
 NES::TEST_F (LogicalOperatorTest, addAndRemoveSingleSuccessor)
 
 NES::TEST_F (LogicalOperatorTest, addAndRemoveMultipleSuccessors)
 
 NES::TEST_F (LogicalOperatorTest, addAndRemoveDuplicatedSuccessors)
 
 NES::TEST_F (LogicalOperatorTest, addAndRemoveLogicalDuplicateButDifferentOperatorAsSuccessors)
 
 NES::TEST_F (LogicalOperatorTest, addAndRemoveNullSuccessor)
 
 NES::TEST_F (LogicalOperatorTest, addSelfAsPredecessor)
 
 NES::TEST_F (LogicalOperatorTest, addAndRemoveSinglePredecessor)
 
 NES::TEST_F (LogicalOperatorTest, addAndRemoveMultiplePredecessors)
 
 NES::TEST_F (LogicalOperatorTest, addAndRemoveDuplicatedPredecessors)
 
 NES::TEST_F (LogicalOperatorTest, addAndRemoveLogicallyDuplicatedButDifferentOperatorAsPredecessors)
 
 NES::TEST_F (LogicalOperatorTest, consistencyBetweenSuccessorPredecesorRelation1)
 
 NES::TEST_F (LogicalOperatorTest, consistencyBetweenSuccessorPredecesorRelation2)
 
 NES::TEST_F (LogicalOperatorTest, addAndRemoveNullPredecessor)
 
 NES::TEST_F (LogicalOperatorTest, replaceSuccessor)
 replace filterOp1 with filterOp3 original: sourceOp -> filterOp1 -> filterOp2 filterOp3 -> filterOp4 replaced: sourceOp -> filterOp3 -> filterOp2 |-> filterOp4 More...
 
 NES::TEST_F (LogicalOperatorTest, replaceWithEqualSuccessor)
 replace filterOp1 with filterOp1Copy original: sourceOp -> filterOp1 -> filterOp2 replaced: sourceOp -> filterOp1Copy -> filterOp2 More...
 
 NES::TEST_F (LogicalOperatorTest, replaceWithExistedSuccessor)
 replace filterOp1 with filterOp3 original: sourceOp -> filterOp1 -> filterOp2 |-> filterOp3 -> filterOp4 replaced: sourceOp -> filterOp1 -> filterOp2 |-> filterOp3 -> filterOp4 More...
 
 NES::TEST_F (LogicalOperatorTest, replaceWithIdenticalSuccessor)
 replace filterOp1 with filterOp1 original: sourceOp -> filterOp1 -> filterOp2 replaced: sourceOp -> filterOp1 -> filterOp2 More...
 
 NES::TEST_F (LogicalOperatorTest, replaceWithSubSuccessor)
 replace filterOp1 with filterOp2 original: sourceOp -> filterOp1 -> filterOp2 replaced: sourceOp -> filterOp2 More...
 
 NES::TEST_F (LogicalOperatorTest, replaceWithNoneSuccessor)
 replace filterOp3 (not existed) with filterOp3 original: sourceOp -> filterOp1 -> filterOp2 replaced: sourceOp -> filterOp1 -> filterOp2 More...
 
 NES::TEST_F (LogicalOperatorTest, replaceSuccessorInvalidOldOperator)
 
 NES::TEST_F (LogicalOperatorTest, replaceWithWithInvalidNewOperator)
 
 NES::TEST_F (LogicalOperatorTest, replacePredecessor)
 replace filterOp1 with filterOp3 original: sourceOp <- filterOp1 <- filterOp2 replaced: sourceOp <- filterOp3 <- filterOp2 More...
 
 NES::TEST_F (LogicalOperatorTest, replaceWithEqualPredecessor)
 replace filterOp1 with filterOp1Copy original: sourceOp -> filterOp1 -> filterOp2 replaced: sourceOp -> filterOp1Copy -> filterOp2 More...
 
 NES::TEST_F (LogicalOperatorTest, replaceWithIdenticalPredecessor)
 replace filterOp1 with filterOp1 original: sourceOp -> filterOp1 -> filterOp2 replaced: sourceOp -> filterOp1 -> filterOp2 More...
 
 NES::TEST_F (LogicalOperatorTest, removeExistedAndLevelUpSuccessors)
 remove filterOp1 from topology original: sourceOp -> filterOp1 -> filterOp2 |-> filterOp3 desired: sourceOp -> filterOp2 |-> filterOp3 More...
 
 NES::TEST_F (LogicalOperatorTest, removeNotExistedAndLevelUpSuccessors)
 remove filterOp4 from topology original: sourceOp -> filterOp1 -> filterOp2 |-> filterOp3 More...
 
 NES::TEST_F (LogicalOperatorTest, removeExistedSblingAndLevelUpSuccessors)
 remove filterOp1 from topology More...
 
 NES::TEST_F (LogicalOperatorTest, remove)
 
 NES::TEST_F (LogicalOperatorTest, clear)
 
 NES::TEST_F (LogicalOperatorTest, equalWithAllSuccessors1)
 
 NES::TEST_F (LogicalOperatorTest, equalWithAllSuccessors2)
 
 NES::TEST_F (LogicalOperatorTest, equalWithAllSuccessors3)
 
 NES::TEST_F (LogicalOperatorTest, equalWithAllPredecessors1)
 
 NES::TEST_F (LogicalOperatorTest, equalWithAllPredecessors2)
 
 NES::TEST_F (LogicalOperatorTest, equalWithAllPredecessors3)
 
 NES::TEST_F (LogicalOperatorTest, as)
 
 NES::TEST_F (LogicalOperatorTest, asBadCast)
 
 NES::TEST_F (LogicalOperatorTest, findRecurisivelyOperatorNotExists)
 
 NES::TEST_F (LogicalOperatorTest, isCyclic)
 
 NES::TEST_F (LogicalOperatorTest, isNotCyclic)
 
 NES::TEST_F (LogicalOperatorTest, getAndFlattenAllSuccessorsNoCycle)
 
 NES::TEST_F (LogicalOperatorTest, getAndFlattenAllSuccessorsForCycle)
 
 NES::TEST_F (LogicalOperatorTest, prettyPrint)
 
 NES::TEST_F (LogicalOperatorTest, instanceOf)
 
 NES::TEST_F (LogicalOperatorTest, getOperatorByType)
 
 NES::TEST_F (LogicalOperatorTest, swap1)
 
 NES::TEST_F (LogicalOperatorTest, swap2)
 
 NES::TEST_F (LogicalOperatorTest, swap3)
 
 NES::TEST_F (LogicalOperatorTest, swap4)
 
 NES::TEST_F (LogicalOperatorTest, swap5)
 
 NES::TEST_F (LogicalOperatorTest, swap6)
 
 NES::TEST_F (LogicalOperatorTest, splitWithSinglePredecessor)
 
 NES::TEST_F (LogicalOperatorTest, splitWithAtLastSuccessor)
 
 NES::TEST_F (LogicalOperatorTest, splitWithAtRoot)
 
 NES::TEST_F (LogicalOperatorTest, splitWithMultiplePredecessors)
 
 NES::TEST_F (LogicalOperatorTest, bfIterator)
 
 NES::TEST_F (LogicalOperatorTest, dfIterator)