|
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().