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::AbstractLineageManager Class Referenceabstract

The Abstract Lineage Manager class is used to map of all tuples that got their sequence number changed by stateful operators. More...

#include <AbstractLineageManager.hpp>

Public Member Functions

virtual ~AbstractLineageManager () noexcept=default
 
virtual void insert (BufferSequenceNumber newBufferSequenceNumber, BufferSequenceNumber oldBufferSequenceNumber)=0
 Inserts a pair newId, oldId into bufferAncestorMapping, where newId is a key. More...
 
virtual bool trim (BufferSequenceNumber bufferSequenceNumber)=0
 Deletes a pair<newId,oldId> from bufferAncestorMapping manager. More...
 
virtual size_t getLineageSize () const =0
 Return current bufferAncestorMapping size. More...
 

Detailed Description

The Abstract Lineage Manager class is used to map of all tuples that got their sequence number changed by stateful operators.

Constructor & Destructor Documentation

◆ ~AbstractLineageManager()

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

Member Function Documentation

◆ getLineageSize()

virtual size_t NES::Runtime::AbstractLineageManager::getLineageSize ( ) const
pure virtual

Return current bufferAncestorMapping size.

Returns
Current bufferAncestorMapping size

Implemented in NES::Runtime::InMemoryLineageManager.

◆ insert()

virtual void NES::Runtime::AbstractLineageManager::insert ( BufferSequenceNumber  newBufferSequenceNumber,
BufferSequenceNumber  oldBufferSequenceNumber 
)
pure virtual

Inserts a pair newId, oldId into bufferAncestorMapping, where newId is a key.

Parameters
newIdnew sequence number that was created by a stateful operator
oldIdold sequence number that the tuple had

Implemented in NES::Runtime::InMemoryLineageManager.

◆ trim()

virtual bool NES::Runtime::AbstractLineageManager::trim ( BufferSequenceNumber  bufferSequenceNumber)
pure virtual

Deletes a pair<newId,oldId> from bufferAncestorMapping manager.

Parameters
bufferSequenceNumbernewId of the tuple
Returns
true in case of a success trimming

Implemented in NES::Runtime::InMemoryLineageManager.

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