NES::TestUtils::TestSinkProvider Class Reference

#include <TestSinkProvider.hpp>

Collaboration diagram for NES::TestUtils::TestSinkProvider:

Public Member Functions
DataSinkPtr	lower (OperatorId sinkId, SinkDescriptorPtr sinkDescriptor, SchemaPtr schema, Runtime::NodeEnginePtr nodeEngine, const QueryCompilation::PipelineQueryPlanPtr &querySubPlan, size_t numOfProducers) override
	Lowers a sink descriptor to a executable data sink. More...

Member Function Documentation

lower()

DataSinkPtr NES::TestUtils::TestSinkProvider::lower ( OperatorId  sinkId, SinkDescriptorPtr  sinkDescriptor, SchemaPtr  schema, Runtime::NodeEnginePtr  nodeEngine, const QueryCompilation::PipelineQueryPlanPtr &  querySubPlan, size_t  numOfProducers  )

override

Lowers a sink descriptor to a executable data sink.

Parameters

operatorId	id of this sink
sinkDescriptor	the sink descriptor
schema	the schema of the sink
nodeEngine	the node engine
querySubPlanId
numOfProducers

Returns

DataSinkPtr

References NES::TestUtils::TestSinkDescriptor::getSink().

Here is the call graph for this function:

---

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

• /nebulastream/nes-coordinator/tests/include/Util/TestSinkProvider.hpp
• /nebulastream/nes-coordinator/tests/src/Util/TestSinkProvider.cpp