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

Public Member Functions

 DataGeneratorMultiValue (std::string logicalSourceName, std::string physicalSourceName, uint64_t numberOfBuffers)
 
PhysicalSourceTypePtr getSource ()
 

Constructor & Destructor Documentation

◆ DataGeneratorMultiValue()

NES::DataGeneratorMultiValue::DataGeneratorMultiValue ( std::string  logicalSourceName,
std::string  physicalSourceName,
uint64_t  numberOfBuffers 
)
inline

Member Function Documentation

◆ getSource()

PhysicalSourceTypePtr NES::DataGeneratorMultiValue::getSource ( )
inline

References NES::Runtime::TupleBuffer::getBuffer(), NES::TestUtils::logicalSourceName(), NES_DEBUG, NES::TestUtils::physicalSourceName(), and NES::Runtime::TupleBuffer::setNumberOfTuples().

Here is the call graph for this function:

The documentation for this class was generated from the following file: