#include <Identifiers/Identifiers.hpp>
#include <memory>
#include <set>
#include <vector>

Include dependency graph for IncrementalPlacementUtils.hpp:

This graph shows which files directly or indirectly include this file:

Namespaces
	NES
	This exception represents a network error.

	NES::Optimizer

	NES::Experimental
	create a table source

Typedefs
using	NES::Optimizer::ExecutionNodePtr = std::shared_ptr< ExecutionNode >

using	NES::Optimizer::ExecutionNodeWLock = std::shared_ptr< folly::Synchronized< ExecutionNodePtr >::WLockedPtr >

using	NES::LogicalOperatorPtr = std::shared_ptr< LogicalOperator >

Functions
std::pair< std::set< OperatorId >, std::set< OperatorId > >	NES::Experimental::findUpstreamAndDownstreamPinnedOperators (const SharedQueryPlanPtr &sharedQueryPlan, Optimizer::ExecutionNodeWLock lockedUpstreamNode, Optimizer::ExecutionNodeWLock lockedDownstreamNode, const TopologyPtr &topology)
	identifies the upstream and downstream operators that can remain deployed on the same nodes as they were before the topology change occurred. These sets can be used as input for an incremental placement. All operators placed upstream of the set of upstream operators or downstream of the downstream operators can remain as is and will not need to be re-placed More...

std::vector< std::pair< LogicalOperatorPtr, LogicalOperatorPtr > >	NES::Experimental::findNetworkOperatorsForLink (const SharedQueryId &sharedQueryPlanId, Optimizer::ExecutionNodeWLock lockedUpstreamNode, Optimizer::ExecutionNodeWLock lockedDownstreamNode)
	find all pairs of network sinks and sources that connect the specified up- and downstream node and belong to the specified shared query More...

Namespaces

Typedefs