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