NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
Public Member Functions | List of all members
NES::Runtime::AbstractBufferStorage Class Referenceabstract

The Abstract buffer storage class to backup tuple buffers that are passing through node engine. More...

#include <AbstractBufferStorage.hpp>

Public Member Functions

virtual ~AbstractBufferStorage () noexcept=default
 
virtual void insertBuffer (NES::Runtime::TupleBuffer bufferPtr)=0
 Inserts a pair id, buffer link to the buffer storage. More...
 
virtual void trimBuffer (uint64_t timestamp)=0
 Deletes q pair<id,buffer> from buffer storage. More...
 
virtual size_t getStorageSize () const =0
 Return current storage size. More...
 

Detailed Description

The Abstract buffer storage class to backup tuple buffers that are passing through node engine.

Constructor & Destructor Documentation

◆ ~AbstractBufferStorage()

virtual NES::Runtime::AbstractBufferStorage::~AbstractBufferStorage ( )
virtualdefaultnoexcept

Member Function Documentation

◆ getStorageSize()

virtual size_t NES::Runtime::AbstractBufferStorage::getStorageSize ( ) const
pure virtual

Return current storage size.

Returns
Current storage size

Implemented in NES::Runtime::BufferStorage.

◆ insertBuffer()

virtual void NES::Runtime::AbstractBufferStorage::insertBuffer ( NES::Runtime::TupleBuffer  bufferPtr)
pure virtual

Inserts a pair id, buffer link to the buffer storage.

Parameters
queryIdid of current query
bufferPtrpointer to the buffer that will be stored

Implemented in NES::Runtime::BufferStorage.

◆ trimBuffer()

virtual void NES::Runtime::AbstractBufferStorage::trimBuffer ( uint64_t  timestamp)
pure virtual

Deletes q pair<id,buffer> from buffer storage.

Parameters
timestampmax timestamp of current epoch

Implemented in NES::Runtime::BufferStorage.

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