NES::OperatorHandlerStore Class Reference

#include <OperatorHandlerStore.hpp>

Public Member Functions
bool	contains (const SharedQueryId queryId, const DecomposedQueryId planId, const OperatorId operatorId)
	Check that storage contains operator handler by key. More...
Runtime::Execution::OperatorHandlerPtr	getOperatorHandler (const SharedQueryId queryId, const DecomposedQueryId planId, const OperatorId operatorId)
	Return operator handler that storage contains by key. More...
void	storeOperatorHandler (const SharedQueryId queryId, const DecomposedQueryId planId, const OperatorId operatorId, Runtime::Execution::OperatorHandlerPtr handler)
	Store operator handler to storage by key. More...
void	removeOperatorHandlers (const SharedQueryId queryId)
	Remove all operator handlers for query. More...
void	removeOperatorHandlers (const SharedQueryId queryId, const DecomposedQueryId planId)
	Remove all operator handlers for query and decomposed query plan. More...

Static Public Member Functions
static OperatorHandlerStorePtr	create ()

Member Function Documentation

contains()

bool NES::OperatorHandlerStore::contains	(	const SharedQueryId	queryId,
		const DecomposedQueryId	planId,
		const OperatorId	operatorId
	)

Check that storage contains operator handler by key.

Parameters

queryId	query id
planId	decomposed query plan id
operatorId	operator id

Returns

true if operator handler stored

create()

OperatorHandlerStorePtr NES::OperatorHandlerStore::create ( )

static

Referenced by NES::TestUtils::createTestQueryCompiler().

Here is the caller graph for this function:

getOperatorHandler()

Runtime::Execution::OperatorHandlerPtr NES::OperatorHandlerStore::getOperatorHandler	(	const SharedQueryId	queryId,
		const DecomposedQueryId	planId,
		const OperatorId	operatorId
	)

Return operator handler that storage contains by key.

Parameters

queryId	query id
planId	decomposed query plan id
operatorId	operator id

Returns

operator handler

removeOperatorHandlers() [1/2]

void NES::OperatorHandlerStore::removeOperatorHandlers

(

const SharedQueryId

queryId

)

Remove all operator handlers for query.

Parameters

queryId

query id

removeOperatorHandlers() [2/2]

void NES::OperatorHandlerStore::removeOperatorHandlers	(	const SharedQueryId	queryId,
		const DecomposedQueryId	planId
	)

Remove all operator handlers for query and decomposed query plan.

Parameters

queryId	query id
planId	decomposed query plan id

storeOperatorHandler()

void NES::OperatorHandlerStore::storeOperatorHandler	(	const SharedQueryId	queryId,
		const DecomposedQueryId	planId,
		const OperatorId	operatorId,
		Runtime::Execution::OperatorHandlerPtr	handler
	)

Store operator handler to storage by key.

Parameters

queryId	query id
planId	decomposed query plan id
operatorId	operator id
handler	operator handler that needs to be stored

Returns

operator handler

---

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

• /nebulastream/nes-runtime/include/Runtime/OperatorHandlerStore.hpp
• /nebulastream/nes-runtime/src/Runtime/OperatorHandlerStore.cpp