NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
#include <Common/ExecutableType/NESType.hpp>
#include <Common/PhysicalTypes/PhysicalType.hpp>
#include <Common/PhysicalTypes/PhysicalTypeUtil.hpp>
#include <Runtime/MemoryLayout/BufferAccessException.hpp>
#include <Runtime/MemoryLayout/MemoryLayout.hpp>
#include <Runtime/RuntimeForwardRefs.hpp>
#include <Runtime/TupleBuffer.hpp>
#include <Util/Logger/Logger.hpp>
#include <cstdint>
#include <cstring>
#include <memory>
#include <ostream>
#include <string>
#include <variant>
Classes | |
class | NES::Runtime::MemoryLayouts::DynamicField |
The DynamicField allows to read and write a field at a specific address and a specific data type. For all field accesses we check that the template type is the same as the selected physical field type. If the type is not compatible accesses result in a BufferAccessException. More... | |
class | NES::Runtime::MemoryLayouts::DynamicTuple |
The DynamicRecords allows to read individual fields of a tuple. Field accesses are safe in the sense that if is checked the field exists. More... | |
class | NES::Runtime::MemoryLayouts::TestTupleBuffer |
The TestTupleBuffers allows to read records and individual fields from an tuple buffer. To this end, it assumes a specific data layout, i.e., RowLayout or ColumnLayout. This allows for dynamic accesses to a tuple buffer in the sense that at compile-time a user has not to specify a specific memory layout. Therefore, the memory layout can be a runtime option, whereby the code that operates on the tuple buffer stays the same. Furthermore, the TestTupleBuffers trades-off performance for safety. To this end, it checks field bounds and field types and throws BufferAccessException if the passed parameters would lead to invalid buffer accesses. The TestTupleBuffers supports different access methods: More... | |
class | NES::Runtime::MemoryLayouts::TestTupleBuffer::TupleIterator |
Iterator to process the tuples in a TestTupleBuffer. Take into account that it is invalid to add tuples to the tuple buffer while iterating over it. More... | |
Namespaces | |
NES | |
This exception represents a network error. | |
NES::Runtime | |
Turn this on to have Thread::current_num_threads_ keep a count of currently-active threads. | |
NES::Runtime::MemoryLayouts | |
Typedefs | |
using | NES::Runtime::MemoryLayouts::MemoryLayoutBufferPtr = std::shared_ptr< MemoryLayoutTupleBuffer > |