|
NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
Namespaces | |
| detail | |
Classes | |
| class | NonRunnableDataSource |
| class | TestExecutionEngine |
| A simple stand alone query execution engine for testing. More... | |
| class | BaseIntegrationTest |
| class | BaseUnitTest |
| class | BorrowedPort |
| A borrowed port from the port pool of nes test base class. It manages garbage collection internally when dtor is called. More... | |
Typedefs | |
| using | BorrowedPortPtr = std::shared_ptr< BorrowedPort > |
Functions | |
| DataSourcePtr | createNonRunnableSource (const SchemaPtr &schema, const Runtime::BufferManagerPtr &bufferManager, const Runtime::QueryManagerPtr &queryManager, OperatorId operatorId, OriginId originId, StatisticId statisticId, size_t numSourceLocalBuffers, const std::vector< Runtime::Execution::SuccessorExecutablePipeline > &successors, NES::Runtime::QueryTerminationType terminationType=Runtime::QueryTerminationType::HardStop) |
Variables | |
| constexpr auto | DEFAULT_BUFFERSIZE = 8196 |
| Default values for the test execution engine, otherwise tests will not terminate, as not enough buffers are available. More... | |
| constexpr auto | DEFAULT_NO_BUFFERS_IN_GLOBAL_BM_PER_THREAD = 10240 |
| constexpr auto | DEFAULT_NO_BUFFERS_IN_SOURCE_BM_PER_THREAD = 512 |
| typedef std::shared_ptr< BorrowedPort > NES::Testing::BorrowedPortPtr |
| DataSourcePtr NES::Testing::createNonRunnableSource | ( | const SchemaPtr & | schema, |
| const Runtime::BufferManagerPtr & | bufferManager, | ||
| const Runtime::QueryManagerPtr & | queryManager, | ||
| OperatorId | operatorId, | ||
| OriginId | originId, | ||
| StatisticId | statisticId, | ||
| size_t | numSourceLocalBuffers, | ||
| const std::vector< Runtime::Execution::SuccessorExecutablePipeline > & | successors, | ||
| NES::Runtime::QueryTerminationType | terminationType = Runtime::QueryTerminationType::HardStop |
||
| ) |
Referenced by NES::Testing::TestExecutionEngine::createDataSource().
|
constexpr |
Default values for the test execution engine, otherwise tests will not terminate, as not enough buffers are available.
Referenced by NES::Testing::TestExecutionEngine::TestExecutionEngine().
|
constexpr |
Referenced by NES::Testing::TestExecutionEngine::TestExecutionEngine().
|
constexpr |
Referenced by NES::Testing::TestExecutionEngine::TestExecutionEngine().