DataSink interface to register a new physical data sink plugin. Implementations of this plugin must implement createDataSink that translates a sink descriptor to a DataSinkPtr. More...

#include <DataSinkPlugin.hpp>

Public Member Functions
	DataSinkPlugin ()=default

virtual std::optional< DataSinkPtr >	createDataSink (OperatorId sinkId, SinkDescriptorPtr sinkDescriptor, SchemaPtr schema, Runtime::NodeEnginePtr nodeEngine, const QueryCompilation::PipelineQueryPlanPtr &querySubPlan, size_t numOfProducers)=0
	Translates a sink descriptor to a data sink. More...

virtual	~DataSinkPlugin ()=default

Detailed Description

DataSink interface to register a new physical data sink plugin. Implementations of this plugin must implement createDataSink that translates a sink descriptor to a DataSinkPtr.

Constructor & Destructor Documentation

◆ DataSinkPlugin()

NES::DataSinkPlugin::DataSinkPlugin ( )

default

◆ ~DataSinkPlugin()

virtual NES::DataSinkPlugin::~DataSinkPlugin ( )

virtualdefault

Member Function Documentation

◆ createDataSink()

virtual std::optional<DataSinkPtr> NES::DataSinkPlugin::createDataSink	(	OperatorId	sinkId,
		SinkDescriptorPtr	sinkDescriptor,
		SchemaPtr	schema,
		Runtime::NodeEnginePtr	nodeEngine,
		const QueryCompilation::PipelineQueryPlanPtr &	querySubPlan,
		size_t	numOfProducers
	)

pure virtual

Translates a sink descriptor to a data sink.

Parameters

sinkId	id of the sink
sinkDescriptor	sink descriptor for which we want to create a physical data sink
schema	of the result data
nodeEngine	reference to the node engine
querySubPlan	reference to the pipelined query plan
numOfProducers	number of data producers.

Returns

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