NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
#include <Common/PhysicalTypes/PhysicalType.hpp>
#include <Runtime/TupleBuffer.hpp>
#include <Runtime/detail/TupleBufferImpl.hpp>
#include <Util/Logger/Logger.hpp>
#include <Util/magicenum/magic_enum.hpp>
#include <bitset>
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::detail | |
Functions | |
void | NES::Runtime::detail::zmqBufferRecyclingCallback (void *ptr, void *hint) |
This is the callback that is called when ZMQ is done with the sending of the buffer with payload in ptr. The hint parameter is the size of the whole buffer (casted as void*) More... | |