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

Public Member Functions

 DataGeneratorMultiKey (std::string logicalSourceName, std::string physicalSourceName, uint64_t numberOfBuffers, uint64_t numberOfKeys=1)
 
PhysicalSourceTypePtr getSource ()
 
 DataGeneratorMultiKey (std::string logicalSourceName, std::string physicalSourceName, uint64_t numberOfBuffers, uint64_t numberOfKeys=1)
 
PhysicalSourceTypePtr getSource ()
 
 DataGeneratorMultiKey (std::string logicalSourceName, std::string physicalSourceName, uint64_t numberOfBuffers, uint64_t numberOfKeys=1)
 
PhysicalSourceTypePtr getSource ()
 

Constructor & Destructor Documentation

◆ DataGeneratorMultiKey() [1/3]

NES::DataGeneratorMultiKey::DataGeneratorMultiKey ( std::string  logicalSourceName,
std::string  physicalSourceName,
uint64_t  numberOfBuffers,
uint64_t  numberOfKeys = 1 
)
inline

◆ DataGeneratorMultiKey() [2/3]

NES::DataGeneratorMultiKey::DataGeneratorMultiKey ( std::string  logicalSourceName,
std::string  physicalSourceName,
uint64_t  numberOfBuffers,
uint64_t  numberOfKeys = 1 
)
inline

◆ DataGeneratorMultiKey() [3/3]

NES::DataGeneratorMultiKey::DataGeneratorMultiKey ( std::string  logicalSourceName,
std::string  physicalSourceName,
uint64_t  numberOfBuffers,
uint64_t  numberOfKeys = 1 
)
inline

Member Function Documentation

◆ getSource() [1/3]

PhysicalSourceTypePtr NES::DataGeneratorMultiKey::getSource ( )
inline

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

Here is the call graph for this function:

◆ getSource() [2/3]

PhysicalSourceTypePtr NES::DataGeneratorMultiKey::getSource ( )
inline

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

Here is the call graph for this function:

◆ getSource() [3/3]

PhysicalSourceTypePtr NES::DataGeneratorMultiKey::getSource ( )
inline

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

Here is the call graph for this function:

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