NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
#include <API/Expressions/Expressions.hpp>
#include <API/QueryAPI.hpp>
#include <BaseIntegrationTest.hpp>
#include <Common/DataTypes/DataTypeFactory.hpp>
#include <Expressions/ConstantValueExpressionNode.hpp>
#include <Operators/LogicalOperators/LogicalOperator.hpp>
#include <Operators/LogicalOperators/Sinks/PrintSinkDescriptor.hpp>
#include <Operators/LogicalOperators/Sources/LogicalSourceDescriptor.hpp>
#include <Plans/DecomposedQueryPlan/DecomposedQueryPlan.hpp>
#include <Plans/Query/QueryPlan.hpp>
#include <QueryCompiler/Operators/OperatorPipeline.hpp>
#include <QueryCompiler/Operators/PhysicalOperators/PhysicalEmitOperator.hpp>
#include <QueryCompiler/Operators/PhysicalOperators/PhysicalFilterOperator.hpp>
#include <QueryCompiler/Operators/PhysicalOperators/PhysicalScanOperator.hpp>
#include <QueryCompiler/Operators/PhysicalOperators/PhysicalSinkOperator.hpp>
#include <QueryCompiler/Operators/PhysicalOperators/PhysicalSourceOperator.hpp>
#include <QueryCompiler/Operators/PipelineQueryPlan.hpp>
#include <QueryCompiler/Phases/AddScanAndEmitPhase.hpp>
#include <Sources/DefaultSource.hpp>
#include <Util/Logger/Logger.hpp>
#include <gtest/gtest.h>
#include <iostream>
Classes | |
class | NES::AddScanAndEmitPhaseTest |
Namespaces | |
NES | |
This exception represents a network error. | |
Functions | |
NES::TEST_F (AddScanAndEmitPhaseTest, scanOperator) | |
Input Query Plan: Input: | Physical Source |. More... | |
NES::TEST_F (AddScanAndEmitPhaseTest, sinkOperator) | |
Input Query Plan: Input: | Physical Sink |. More... | |
NES::TEST_F (AddScanAndEmitPhaseTest, pipelineFilterQuery) | |
Input Query Plan: Input: | Physical Filter |. More... | |