NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
NES::TestUtils::TestSourceProvider Class Reference

#include <TestSourceProvider.hpp>

Collaboration diagram for NES::TestUtils::TestSourceProvider:
[legend]

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

Constructor & Destructor Documentation

◆ TestSourceProvider()

NES::TestUtils::TestSourceProvider::TestSourceProvider ( QueryCompilation::QueryCompilerOptionsPtr  options)
explicit

Constructor of a TestSourceProvider.

Parameters
options

Member Function Documentation

◆ lower()

DataSourcePtr NES::TestUtils::TestSourceProvider::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.

Parameters
operatorIdid of the data source
originId
sourceDescriptor
nodeEngine
successors
Returns
DataSourcePtr

References NES::TestUtils::TestSourceDescriptor::create().

Here is the call graph for this function:

The documentation for this class was generated from the following files: