|
NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
#include <API/QueryAPI.hpp>#include <API/Schema.hpp>#include <BaseIntegrationTest.hpp>#include <Catalogs/Source/PhysicalSource.hpp>#include <Catalogs/Source/SourceCatalog.hpp>#include <Catalogs/UDF/UDFCatalog.hpp>#include <Common/DataTypes/DataTypeFactory.hpp>#include <Compiler/CPPCompiler/CPPCompiler.hpp>#include <Compiler/JITCompilerBuilder.hpp>#include <Configurations/Worker/PhysicalSourceTypes/DefaultSourceType.hpp>#include <Expressions/FieldAccessExpressionNode.hpp>#include <Network/NetworkChannel.hpp>#include <Operators/LogicalOperators/Sources/SourceLogicalOperator.hpp>#include <Operators/LogicalOperators/Windows/Joins/LogicalJoinOperator.hpp>#include <Optimizer/Phases/OriginIdInferencePhase.hpp>#include <Optimizer/Phases/StatisticIdInferencePhase.hpp>#include <Optimizer/Phases/TypeInferencePhase.hpp>#include <QueryCompiler/QueryCompilationRequest.hpp>#include <QueryCompiler/QueryCompiler.hpp>#include <QueryCompiler/QueryCompilerOptions.hpp>#include <Runtime/Execution/ExecutablePipelineStage.hpp>#include <Runtime/Execution/ExecutableQueryPlan.hpp>#include <Runtime/Execution/PipelineExecutionContext.hpp>#include <Runtime/FixedSizeBufferPool.hpp>#include <Runtime/LocalBufferPool.hpp>#include <Runtime/MemoryLayout/RowLayout.hpp>#include <Runtime/MemoryLayout/RowLayoutField.hpp>#include <Runtime/NodeEngineBuilder.hpp>#include <Runtime/QueryManager.hpp>#include <Runtime/WorkerContext.hpp>#include <Services/QueryParsingService.hpp>#include <Sinks/Formats/NesFormat.hpp>#include <Sources/DefaultSource.hpp>#include <Sources/SourceCreator.hpp>#include <Util/DummySink.hpp>#include <Util/Logger/Logger.hpp>#include <Util/NonRunnableDataSource.hpp>#include <Util/TestQuery.hpp>#include <Util/TestQueryCompiler.hpp>#include <Util/TestSink.hpp>#include <Util/TestUtils.hpp>Classes | |
| class | NES::Testing::TestExecutionEngine |
| A simple stand alone query execution engine for testing. More... | |
Namespaces | |
| NES | |
| This exception represents a network error. | |
| NES::Testing | |
Variables | |
| constexpr auto | NES::Testing::DEFAULT_BUFFERSIZE = 8196 |
| Default values for the test execution engine, otherwise tests will not terminate, as not enough buffers are available. More... | |
| constexpr auto | NES::Testing::DEFAULT_NO_BUFFERS_IN_GLOBAL_BM_PER_THREAD = 10240 |
| constexpr auto | NES::Testing::DEFAULT_NO_BUFFERS_IN_SOURCE_BM_PER_THREAD = 512 |