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) | |