NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
NES::Runtime::AbstractPoolProvider Class Referenceabstract

#include <AbstractBufferProvider.hpp>

Public Member Functions

virtual LocalBufferPoolPtr createLocalBufferPool (size_t numberOfReservedBuffers)=0
 Create a local buffer manager that is assigned to one pipeline or thread. More...
 
virtual FixedSizeBufferPoolPtr createFixedSizeBufferPool (size_t numberOfReservedBuffers)=0
 Create a local buffer manager that is assigned to one pipeline or thread. More...
 

Member Function Documentation

◆ createFixedSizeBufferPool()

virtual FixedSizeBufferPoolPtr NES::Runtime::AbstractPoolProvider::createFixedSizeBufferPool ( size_t  numberOfReservedBuffers)
pure virtual

Create a local buffer manager that is assigned to one pipeline or thread.

Parameters
numberOfReservedBuffersnumber of exclusive buffers to give to the pool
Returns
a local buffer manager with numberOfReservedBuffers exclusive buffer

Implemented in NES::Runtime::BufferManager.

◆ createLocalBufferPool()

virtual LocalBufferPoolPtr NES::Runtime::AbstractPoolProvider::createLocalBufferPool ( size_t  numberOfReservedBuffers)
pure virtual

Create a local buffer manager that is assigned to one pipeline or thread.

Parameters
numberOfReservedBuffersnumber of exclusive buffers to give to the pool
Returns
a local buffer manager with numberOfReservedBuffers exclusive buffer

Implemented in NES::Runtime::BufferManager.


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