NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
Public Member Functions | |
DataGenerator (std::string logicalSourceName, std::string physicalSourceName, uint64_t numberOfBuffers) | |
PhysicalSourceTypePtr | getSource () |
DataGenerator (std::string logicalSourceName, std::string physicalSourceName, uint64_t numberOfBuffers) | |
PhysicalSourceTypePtr | getSource () |
DataGenerator (std::string logicalSourceName, std::string physicalSourceName, uint64_t numberOfBuffers) | |
PhysicalSourceTypePtr | getSource () |
DataGenerator (std::string logicalSourceName, std::string physicalSourceName, uint64_t numberOfBuffers) | |
PhysicalSourceTypePtr | getSource () |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
References NES::Runtime::TupleBuffer::getBuffer(), NES::TestUtils::logicalSourceName(), NES_DEBUG, NES::TestUtils::physicalSourceName(), and NES::Runtime::TupleBuffer::setNumberOfTuples().
|
inline |
References NES::Runtime::TupleBuffer::getBuffer(), NES::TestUtils::logicalSourceName(), NES_DEBUG, NES::TestUtils::physicalSourceName(), and NES::Runtime::TupleBuffer::setNumberOfTuples().
|
inline |
References NES::Runtime::TupleBuffer::getBuffer(), NES::TestUtils::logicalSourceName(), NES_DEBUG, NES::TestUtils::physicalSourceName(), and NES::Runtime::TupleBuffer::setNumberOfTuples().
|
inline |
References NES::Runtime::TupleBuffer::getBuffer(), NES::TestUtils::logicalSourceName(), NES_DEBUG, NES::TestUtils::physicalSourceName(), and NES::Runtime::TupleBuffer::setNumberOfTuples().