NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
#include <Runtime/MemoryLayout/ColumnLayout.hpp>
#include <Runtime/MemoryLayout/RowLayout.hpp>
#include <Runtime/MemoryLayout/RowLayoutField.hpp>
#include <Runtime/NodeEngine.hpp>
#include <Runtime/NodeEngineBuilder.hpp>
#include <Runtime/TupleBuffer.hpp>
#include <Runtime/WorkerContext.hpp>
#include <Sinks/Formats/NesFormat.hpp>
#include <Sinks/Mediums/SinkMedium.hpp>
#include <Sources/DefaultSource.hpp>
#include <Sources/SourceCreator.hpp>
#include <Util/TestTupleBuffer.hpp>
#include <gtest/gtest.h>
Classes | |
class | NES::TestSink |
A sink for testing that can be part of a query plan and enables executing queries and producing results. More... | |
class | NES::CollectTestSink< Type > |
A sink for testing that is instantiated using 'Type'. The CollectSink uses 'Type' as a template parameter for the TupleBuffer that it writes results into. More... | |
Namespaces | |
NES | |
This exception represents a network error. | |