DataSource interface to register a new physical data source plugin. Implementations of this plugin must implement createDatasource that translates a source descriptor to a DataSourcePtr. More...

#include <DataSourcePlugin.hpp>

Public Member Functions
	DataSourcePlugin ()=default

virtual std::optional< DataSourcePtr >	createDataSource (OperatorId sourceId, OriginId originId, StatisticId statisticId, const SourceDescriptorPtr &sourceDescriptor, const Runtime::NodeEnginePtr &nodeEngine, size_t numSourceLocalBuffers, const std::vector< Runtime::Execution::SuccessorExecutablePipeline > &successors)=0
	Translates a source descriptor to a data source. More...

virtual	~DataSourcePlugin ()=default

Detailed Description

DataSource interface to register a new physical data source plugin. Implementations of this plugin must implement createDatasource that translates a source descriptor to a DataSourcePtr.

Constructor & Destructor Documentation

◆ DataSourcePlugin()

NES::DataSourcePlugin::DataSourcePlugin ( )

default

◆ ~DataSourcePlugin()

virtual NES::DataSourcePlugin::~DataSourcePlugin ( )

virtualdefault

Member Function Documentation

◆ createDataSource()

virtual std::optional<DataSourcePtr> NES::DataSourcePlugin::createDataSource	(	OperatorId	sourceId,
		OriginId	originId,
		StatisticId	statisticId,
		const SourceDescriptorPtr &	sourceDescriptor,
		const Runtime::NodeEnginePtr &	nodeEngine,
		size_t	numSourceLocalBuffers,
		const std::vector< Runtime::Execution::SuccessorExecutablePipeline > &	successors
	)

pure virtual

Translates a source descriptor to a data source.

Parameters

sourceId	id of the source
originId	id of the origin for which data is produced.
sourceDescriptor	the source descriptor.
nodeEngine	reference to the node engine
numSourceLocalBuffers	number of source buffers that can be allocated.
successors	the successor pipeline, which is used to emit data.

Returns: std::optional<DataSourcePtr>

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