|
NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
#include <API/Schema.hpp>#include <BaseIntegrationTest.hpp>#include <Catalogs/Source/PhysicalSource.hpp>#include <Configurations/Worker/PhysicalSourceTypes/CSVSourceType.hpp>#include <Configurations/Worker/QueryCompilerConfiguration.hpp>#include <Operators/LogicalOperators/Network/NetworkSourceDescriptor.hpp>#include <Operators/LogicalOperators/Sources/BinarySourceDescriptor.hpp>#include <Operators/LogicalOperators/Sources/CsvSourceDescriptor.hpp>#include <Operators/LogicalOperators/Sources/DefaultSourceDescriptor.hpp>#include <Operators/LogicalOperators/Sources/KafkaSourceDescriptor.hpp>#include <Operators/LogicalOperators/Sources/SenseSourceDescriptor.hpp>#include <Operators/LogicalOperators/Sources/TCPSourceDescriptor.hpp>#include <Operators/LogicalOperators/Sources/ZmqSourceDescriptor.hpp>#include <QueryCompiler/Phases/Translations/ConvertLogicalToPhysicalSource.hpp>#include <Runtime/NodeEngine.hpp>#include <Runtime/NodeEngineBuilder.hpp>#include <Util/Logger/Logger.hpp>#include <Util/TestUtils.hpp>Classes | |
| class | NES::ConvertLogicalToPhysicalSourceTest |
Namespaces | |
| NES | |
| This exception represents a network error. | |
Functions | |
| NES::TEST_F (ConvertLogicalToPhysicalSourceTest, testConvertingCsvFileLogicalToPhysicalSource) | |
| NES::TEST_F (ConvertLogicalToPhysicalSourceTest, testConvertingTCPLogicalToPhysicalSource) | |
| NES::TEST_F (ConvertLogicalToPhysicalSourceTest, testConvertingBinaryFileLogicalToPhysicalSource) | |
| NES::TEST_F (ConvertLogicalToPhysicalSourceTest, testConvertingZMQLogicalToPhysicalSource) | |
| NES::TEST_F (ConvertLogicalToPhysicalSourceTest, testConvertingSenseLogicalToPhysicalSource) | |
| NES::TEST_F (ConvertLogicalToPhysicalSourceTest, testConvertingDefaultLogicalToPhysicalSource) | |
| NES::TEST_F (ConvertLogicalToPhysicalSourceTest, testConvertingNetworkLogicalToPhysicalSource) | |