NES::Optimizer Namespace Reference

Classes
class	SampleCodeGenerationPhase
	: This phase allows generating C++ code for each logical operator and add it to the operator as property More...
class	SemanticQueryValidation
	This class is responsible for Semantic Query Validation. More...
class	SyntacticQueryValidation
	This class is responsible for Syntactic Query Validation. More...
class	PlacementAmendmentHandler
	The placement amendment handler class is responsible for processing placement amendments of updated shared query plans. To this end, we can initialize the handles with a pre-configured number of handler threads. More...
class	PlacementAmendmentInstance
	class representing the placement amendment instance More...
class	MockedPlacementAmendmentHandler

Typedefs
using	GlobalExecutionPlanPtr = std::shared_ptr< GlobalExecutionPlan >
using	PlacementAmendmentHandlerPtr = std::shared_ptr< PlacementAmendmentHandler >
using	DeploymentContextPtr = std::shared_ptr< DeploymentContext >
using	SampleCodeGenerationPhasePtr = std::shared_ptr< SampleCodeGenerationPhase >
using	SemanticQueryValidationPtr = std::shared_ptr< SemanticQueryValidation >
using	SyntacticQueryValidationPtr = std::shared_ptr< SyntacticQueryValidation >
using	TypeInferencePhasePtr = std::shared_ptr< TypeInferencePhase >
using	QueryRewritePhasePtr = std::shared_ptr< QueryRewritePhase >
using	OriginIdInferencePhasePtr = std::shared_ptr< OriginIdInferencePhase >
using	TopologySpecificQueryRewritePhasePtr = std::shared_ptr< TopologySpecificQueryRewritePhase >
using	SignatureInferencePhasePtr = std::shared_ptr< SignatureInferencePhase >
using	QueryMergerPhasePtr = std::shared_ptr< QueryMergerPhase >
using	MemoryLayoutSelectionPhasePtr = std::shared_ptr< MemoryLayoutSelectionPhase >
using	QueryPlacementAmendmentPhasePtr = std::shared_ptr< QueryPlacementAmendmentPhase >
using	GlobalQueryPlanUpdatePhasePtr = std::shared_ptr< GlobalQueryPlanUpdatePhase >
using	GlobalQueryPlanPtr = std::shared_ptr< GlobalQueryPlan >
using	PlacementAmendmentInstancePtr = std::shared_ptr< PlacementAmendmentInstance >
using	UMPMCAmendmentQueuePtr = std::shared_ptr< folly::UMPMCQueue< NES::Optimizer::PlacementAmendmentInstancePtr, true > >
using	ExecutionNodePtr = std::shared_ptr< ExecutionNode >
using	ExecutionNodeWLock = std::shared_ptr< folly::Synchronized< ExecutionNodePtr >::WLockedPtr >

Enumerations
enum class	PlacementStrategy : uint8_t {   TopDown = 0 , BottomUp = 1 , IFCOP = 2 , ILP = 3 ,   MlHeuristic = 4 , ELEGANT_PERFORMANCE = 5 , ELEGANT_ENERGY = 6 , ELEGANT_BALANCED = 7 }

Variables
const std::string	PINNED_WORKER_ID = "PINNED_WORKER_ID"
const std::string	PLACED_DECOMPOSED_PLAN_ID
const std::string	PROCESSED = "PROCESSED"
const std::string	CO_LOCATED_UPSTREAM_OPERATORS
const std::string	CONNECTED_SYS_DECOMPOSED_PLAN_DETAILS
const std::string	UPSTREAM_LOGICAL_OPERATOR_ID
const std::string	DOWNSTREAM_LOGICAL_OPERATOR_ID

Typedef Documentation

DeploymentContextPtr

using NES::Optimizer::DeploymentContextPtr = typedef std::shared_ptr<DeploymentContext>

ExecutionNodePtr

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

ExecutionNodeWLock

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

GlobalExecutionPlanPtr

typedef std::shared_ptr< GlobalExecutionPlan > NES::Optimizer::GlobalExecutionPlanPtr

GlobalQueryPlanPtr

using NES::Optimizer::GlobalQueryPlanPtr = typedef std::shared_ptr<GlobalQueryPlan>

GlobalQueryPlanUpdatePhasePtr

typedef std::shared_ptr< GlobalQueryPlanUpdatePhase > NES::Optimizer::GlobalQueryPlanUpdatePhasePtr

MemoryLayoutSelectionPhasePtr

typedef std::shared_ptr< MemoryLayoutSelectionPhase > NES::Optimizer::MemoryLayoutSelectionPhasePtr

OriginIdInferencePhasePtr

typedef std::shared_ptr< OriginIdInferencePhase > NES::Optimizer::OriginIdInferencePhasePtr

PlacementAmendmentHandlerPtr

typedef std::shared_ptr< PlacementAmendmentHandler > NES::Optimizer::PlacementAmendmentHandlerPtr

PlacementAmendmentInstancePtr

typedef std::shared_ptr< PlacementAmendmentInstance > NES::Optimizer::PlacementAmendmentInstancePtr

QueryMergerPhasePtr

typedef std::shared_ptr< QueryMergerPhase > NES::Optimizer::QueryMergerPhasePtr

QueryPlacementAmendmentPhasePtr

typedef std::shared_ptr< QueryPlacementAmendmentPhase > NES::Optimizer::QueryPlacementAmendmentPhasePtr

QueryRewritePhasePtr

typedef std::shared_ptr< QueryRewritePhase > NES::Optimizer::QueryRewritePhasePtr

SampleCodeGenerationPhasePtr

typedef std::shared_ptr< SampleCodeGenerationPhase > NES::Optimizer::SampleCodeGenerationPhasePtr

SemanticQueryValidationPtr

typedef std::shared_ptr< SemanticQueryValidation > NES::Optimizer::SemanticQueryValidationPtr

SignatureInferencePhasePtr

typedef std::shared_ptr< SignatureInferencePhase > NES::Optimizer::SignatureInferencePhasePtr

SyntacticQueryValidationPtr

typedef std::shared_ptr< SyntacticQueryValidation > NES::Optimizer::SyntacticQueryValidationPtr

TopologySpecificQueryRewritePhasePtr

typedef std::shared_ptr< TopologySpecificQueryRewritePhase > NES::Optimizer::TopologySpecificQueryRewritePhasePtr

TypeInferencePhasePtr

typedef std::shared_ptr< TypeInferencePhase > NES::Optimizer::TypeInferencePhasePtr

UMPMCAmendmentQueuePtr

typedef std::shared_ptr< folly::UMPMCQueue< NES::Optimizer::PlacementAmendmentInstancePtr, true > > NES::Optimizer::UMPMCAmendmentQueuePtr

Enumeration Type Documentation

PlacementStrategy

enum NES::Optimizer::PlacementStrategy : uint8_t

strong

Enumerator
TopDown
BottomUp
IFCOP
ILP
MlHeuristic
ELEGANT_PERFORMANCE
ELEGANT_ENERGY
ELEGANT_BALANCED

Variable Documentation

CO_LOCATED_UPSTREAM_OPERATORS

const std::string NES::Optimizer::CO_LOCATED_UPSTREAM_OPERATORS

Initial value:

=
    "CO_LOCATED_UPSTREAM_OPERATORS"

CONNECTED_SYS_DECOMPOSED_PLAN_DETAILS

const std::string NES::Optimizer::CONNECTED_SYS_DECOMPOSED_PLAN_DETAILS

Initial value:

=
    "CONNECTED_SYS_SUB_PLAN_DETAILS"

DOWNSTREAM_LOGICAL_OPERATOR_ID

const std::string NES::Optimizer::DOWNSTREAM_LOGICAL_OPERATOR_ID

Initial value:

=
    "DOWNSTREAM_LOGICAL_OPERATOR_ID"

Referenced by NES::Experimental::findUpstreamAndDownstreamPinnedOperators(), and NES::RequestProcessor::TEST_F().

PINNED_WORKER_ID

const std::string NES::Optimizer::PINNED_WORKER_ID = "PINNED_WORKER_ID"

Referenced by NES::Experimental::findUpstreamAndDownstreamPinnedOperators(), and NES::RequestProcessor::TEST_F().

PLACED_DECOMPOSED_PLAN_ID

const std::string NES::Optimizer::PLACED_DECOMPOSED_PLAN_ID

Initial value:

=
    "PLACED_DECOMPOSED_PLAN_ID"

PROCESSED

const std::string NES::Optimizer::PROCESSED = "PROCESSED"

UPSTREAM_LOGICAL_OPERATOR_ID

const std::string NES::Optimizer::UPSTREAM_LOGICAL_OPERATOR_ID

Initial value:

=
    "UPSTREAM_LOGICAL_OPERATOR_ID"

Referenced by NES::Experimental::findUpstreamAndDownstreamPinnedOperators(), and NES::RequestProcessor::TEST_F().