NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
#include <TestSourceProvider.hpp>
Public Member Functions | |
TestSourceProvider (QueryCompilation::QueryCompilerOptionsPtr options) | |
Constructor of a TestSourceProvider. More... | |
DataSourcePtr | lower (OperatorId operatorId, OriginId originId, StatisticId statisticId, SourceDescriptorPtr sourceDescriptor, Runtime::NodeEnginePtr nodeEngine, std::vector< Runtime::Execution::SuccessorExecutablePipeline > successors) override |
Lowers a source descriptor to a executable data source. More... | |
|
explicit |
Constructor of a TestSourceProvider.
options |
|
override |
Lowers a source descriptor to a executable data source.
operatorId | id of the data source |
originId | |
sourceDescriptor | |
nodeEngine | |
successors |
References NES::TestUtils::TestSourceDescriptor::create().