NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
NES::Testing Namespace Reference

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 Documentation

◆ BorrowedPortPtr

typedef std::shared_ptr< BorrowedPort > NES::Testing::BorrowedPortPtr

Function Documentation

◆ createNonRunnableSource()

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

Here is the caller graph for this function:

Variable Documentation

◆ DEFAULT_BUFFERSIZE

constexpr auto NES::Testing::DEFAULT_BUFFERSIZE = 8196
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().

◆ DEFAULT_NO_BUFFERS_IN_GLOBAL_BM_PER_THREAD

constexpr auto NES::Testing::DEFAULT_NO_BUFFERS_IN_GLOBAL_BM_PER_THREAD = 10240
constexpr

◆ DEFAULT_NO_BUFFERS_IN_SOURCE_BM_PER_THREAD

constexpr auto NES::Testing::DEFAULT_NO_BUFFERS_IN_SOURCE_BM_PER_THREAD = 512
constexpr