#include <RelAlgDagBuilder.h>

Inheritance diagram for RelProject:

Collaboration diagram for RelProject:

Public Types
using	ConstRexScalarPtr = std::unique_ptr< const RexScalar >

using	ConstRexScalarPtrVector = std::vector< ConstRexScalarPtr >

Public Member Functions
	RelProject (std::vector< std::unique_ptr< const RexScalar >> &scalar_exprs, const std::vector< std::string > &fields, std::shared_ptr< const RelAlgNode > input)

	RelProject (RelProject const &)

void	setExpressions (std::vector< std::unique_ptr< const RexScalar >> &exprs) const

bool	isSimple () const

bool	isIdentity () const

bool	isRenaming () const

size_t	size () const override

const RexScalar *	getProjectAt (const size_t idx) const

const RexScalar *	getProjectAtAndRelease (const size_t idx) const

std::vector< std::unique_ptr < const RexScalar > >	getExpressionsAndRelease ()

const std::vector< std::string > &	getFields () const

void	setFields (std::vector< std::string > &&fields)

const std::string	getFieldName (const size_t i) const

void	replaceInput (std::shared_ptr< const RelAlgNode > old_input, std::shared_ptr< const RelAlgNode > input) override

void	replaceInput (std::shared_ptr< const RelAlgNode > old_input, std::shared_ptr< const RelAlgNode > input, std::optional< std::unordered_map< unsigned, unsigned >> old_to_new_index_map)

void	appendInput (std::string new_field_name, std::unique_ptr< const RexScalar > new_input)

std::string	toString (RelRexToStringConfig config=RelRexToStringConfig::defaults()) const override

size_t	toHash () const override

std::shared_ptr< RelAlgNode >	deepCopy () const override

bool	hasWindowFunctionExpr () const

void	addHint (const ExplainedQueryHint &hint_explained)

const bool	hasHintEnabled (QueryHint candidate_hint) const

const ExplainedQueryHint &	getHintInfo (QueryHint hint) const

bool	hasDeliveredHint ()

Hints *	getDeliveredHints ()

Public Member Functions inherited from RelAlgNode
	RelAlgNode (RelAlgInputs inputs={})

virtual	~RelAlgNode ()

void	resetQueryExecutionState ()

void	setContextData (const RaExecutionDesc *context_data) const

void	setOutputMetainfo (const std::vector< TargetMetaInfo > &targets_metainfo) const

void	setQueryPlanDag (const std::string &extracted_query_plan_dag) const

std::string	getQueryPlanDag () const

size_t	getQueryPlanDagHash () const

const std::vector < TargetMetaInfo > &	getOutputMetainfo () const

unsigned	getId () const

void	setIdInPlanTree (size_t id) const

std::optional< size_t >	getIdInPlanTree () const

bool	hasContextData () const

const RaExecutionDesc *	getContextData () const

const size_t	inputCount () const

const RelAlgNode *	getInput (const size_t idx) const

std::shared_ptr< const RelAlgNode >	getAndOwnInput (const size_t idx) const

void	addManagedInput (std::shared_ptr< const RelAlgNode > input)

bool	hasInput (const RelAlgNode *needle) const

void	setRelNodeDagId (const size_t id) const

size_t	getRelNodeDagId () const

bool	isNop () const

void	markAsNop ()

void	clearContextData () const

Public Member Functions inherited from ModifyManipulationTarget
	ModifyManipulationTarget (bool const update_via_select=false, bool const delete_via_select=false, bool const varlen_update_required=false, TableDescriptor const *table_descriptor=nullptr, ColumnNameList target_columns=ColumnNameList())

void	setUpdateViaSelectFlag () const

void	setDeleteViaSelectFlag () const

void	setVarlenUpdateRequired (bool required) const

void	forceRowwiseOutput () const

TableDescriptor const *	getModifiedTableDescriptor () const

void	setModifiedTableDescriptor (TableDescriptor const *td) const

auto const	isUpdateViaSelect () const

auto const	isDeleteViaSelect () const

auto const	isVarlenUpdateRequired () const

auto const	isRowwiseOutputForced () const

void	setTargetColumns (ColumnNameList const &target_columns) const

ColumnNameList const &	getTargetColumns () const

template<typename VALIDATION_FUNCTOR >
bool	validateTargetColumns (VALIDATION_FUNCTOR validator) const

Private Member Functions
template<typename EXPR_VISITOR_FUNCTOR >
void	visitScalarExprs (EXPR_VISITOR_FUNCTOR visitor_functor) const

void	injectOffsetInFragmentExpr () const

Private Attributes
std::vector< std::unique_ptr < const RexScalar > >	scalar_exprs_

std::vector< std::string >	fields_

bool	hint_applied_

std::unique_ptr< Hints >	hints_

Friends
class	RelModify

Additional Inherited Members
Static Public Member Functions inherited from RelAlgNode
static void	resetRelAlgFirstId () noexcept

Protected Attributes inherited from RelAlgNode
RelAlgInputs	inputs_

const unsigned	id_

std::optional< size_t >	id_in_plan_tree_

std::optional< size_t >	hash_

Detailed Description

Definition at line 1014 of file RelAlgDagBuilder.h.

Member Typedef Documentation

using RelProject::ConstRexScalarPtr = std::unique_ptr<const RexScalar>

Definition at line 1017 of file RelAlgDagBuilder.h.

using RelProject::ConstRexScalarPtrVector = std::vector<ConstRexScalarPtr>

Definition at line 1018 of file RelAlgDagBuilder.h.

Constructor & Destructor Documentation

RelProject::RelProject	(	std::vector< std::unique_ptr< const RexScalar >> &	scalar_exprs,
		const std::vector< std::string > &	fields,
		std::shared_ptr< const RelAlgNode >	input
	)

inline

Definition at line 1021 of file RelAlgDagBuilder.h.

References RelAlgNode::inputs_.

Referenced by toHash().

       : ModifyManipulationTarget(false, false, false, nullptr)
       , scalar_exprs_(std::move(scalar_exprs))
       , fields_(fields)
       , hint_applied_(false)
       , hints_(std::make_unique<Hints>()) {
     inputs_.push_back(input);
   }

Here is the caller graph for this function:

RelProject::RelProject ( RelProject const & rhs )

Definition at line 556 of file RelAlgDagBuilder.cpp.

References addHint(), hint_applied_, hints_, scalar_exprs_, and RexVisitorBase< T >::visit().

     : RelAlgNode(rhs)
     , ModifyManipulationTarget(rhs)
     , fields_(rhs.fields_)
     , hint_applied_(false)
     , hints_(std::make_unique<Hints>()) {
   RexDeepCopyVisitor copier;
   for (auto const& expr : rhs.scalar_exprs_) {
     scalar_exprs_.push_back(copier.visit(expr.get()));
   }
   if (rhs.hint_applied_) {
     for (auto const& kv : *rhs.hints_) {
       addHint(kv.second);
     }
   }
 }

Here is the call graph for this function:

Member Function Documentation

void RelProject::addHint ( const ExplainedQueryHint & hint_explained )

inline

Definition at line 1114 of file RelAlgDagBuilder.h.

References ExplainedQueryHint::getHint(), hint_applied_, and hints_.

Referenced by RelProject().

                                                          {
     if (!hint_applied_) {
       hint_applied_ = true;
     }
     hints_->emplace(hint_explained.getHint(), hint_explained);
   }

Here is the call graph for this function:

Here is the caller graph for this function:

void RelProject::appendInput	(	std::string	new_field_name,
		std::unique_ptr< const RexScalar >	new_input
	)

Definition at line 365 of file RelAlgDagBuilder.cpp.

References fields_, and scalar_exprs_.

                                                                        {
   fields_.emplace_back(std::move(new_field_name));
   scalar_exprs_.emplace_back(std::move(new_input));
 }

std::shared_ptr<RelAlgNode> RelProject::deepCopy ( ) const

inlineoverridevirtual

Implements RelAlgNode.

Definition at line 1108 of file RelAlgDagBuilder.h.

                                                       {
     return std::make_shared<RelProject>(*this);
   }

Hints* RelProject::getDeliveredHints ( )

inline

Definition at line 1137 of file RelAlgDagBuilder.h.

References hints_.

Referenced by anonymous_namespace{RelAlgDagBuilder.cpp}::handle_query_hint().

1137 { return hints_.get(); }

RelProject::hints_

std::unique_ptr< Hints > hints_

Definition: RelAlgDagBuilder.h:1159

Here is the caller graph for this function:

std::vector<std::unique_ptr<const RexScalar> > RelProject::getExpressionsAndRelease ( )

inline

Definition at line 1066 of file RelAlgDagBuilder.h.

References scalar_exprs_.

                                                                        {
     return std::move(scalar_exprs_);
   }

const std::string RelProject::getFieldName ( const size_t i ) const

inline

Definition at line 1073 of file RelAlgDagBuilder.h.

References fields_.

1073 { return fields_[i]; }

RelProject::fields_

std::vector< std::string > fields_

Definition: RelAlgDagBuilder.h:1157

const std::vector<std::string>& RelProject::getFields ( ) const

inline

Definition at line 1070 of file RelAlgDagBuilder.h.

References fields_.

Referenced by anonymous_namespace{RelAlgDagBuilder.cpp}::create_compound().

1070 { return fields_; }

RelProject::fields_

std::vector< std::string > fields_

Definition: RelAlgDagBuilder.h:1157

Here is the caller graph for this function:

const ExplainedQueryHint& RelProject::getHintInfo ( QueryHint hint ) const

inline

Definition at line 1128 of file RelAlgDagBuilder.h.

References CHECK, hasHintEnabled(), hint_applied_, and hints_.

                                                               {
     CHECK(hint_applied_);
     CHECK(!hints_->empty());
     CHECK(hasHintEnabled(hint));
     return hints_->at(hint);
   }

Here is the call graph for this function:

const RexScalar* RelProject::getProjectAt ( const size_t idx ) const

inline

Definition at line 1056 of file RelAlgDagBuilder.h.

References CHECK, and scalar_exprs_.

Referenced by anonymous_namespace{RelAlgDagBuilder.cpp}::add_window_function_pre_project(), anonymous_namespace{RelAlgExecutor.cpp}::get_used_inputs(), anonymous_namespace{RelAlgOptimizer.cpp}::is_identical_copy(), anonymous_namespace{RelAlgExecutor.cpp}::scalar_at(), RelRexDagVisitor::visit(), and anonymous_namespace{QueryPhysicalInputsCollector.cpp}::RelAlgPhysicalInputsVisitor::visitProject().

                                                         {
     CHECK(idx < scalar_exprs_.size());
     return scalar_exprs_[idx].get();
   }

Here is the caller graph for this function:

const RexScalar* RelProject::getProjectAtAndRelease ( const size_t idx ) const

inline

Definition at line 1061 of file RelAlgDagBuilder.h.

References CHECK, and scalar_exprs_.

                                                                   {
     CHECK(idx < scalar_exprs_.size());
     return scalar_exprs_[idx].release();
   }

bool RelProject::hasDeliveredHint ( )

inline

Definition at line 1135 of file RelAlgDagBuilder.h.

References hints_.

1135 { return !hints_->empty(); }

RelProject::hints_

std::unique_ptr< Hints > hints_

Definition: RelAlgDagBuilder.h:1159

const bool RelProject::hasHintEnabled ( QueryHint candidate_hint ) const

inline

Definition at line 1121 of file RelAlgDagBuilder.h.

References hint_applied_, and hints_.

Referenced by getHintInfo().

                                                             {
     if (hint_applied_ && !hints_->empty()) {
       return hints_->find(candidate_hint) != hints_->end();
     }
     return false;
   }

Here is the caller graph for this function:

bool RelProject::hasWindowFunctionExpr ( ) const

Definition at line 2621 of file RelAlgDagBuilder.cpp.

References anonymous_namespace{RelAlgDagBuilder.cpp}::anonymous_namespace{RelAlgDagBuilder.cpp}::is_window_function_operator(), and scalar_exprs_.

Referenced by RelModify::applyUpdateModificationsToInputNode().

                                              {
   for (const auto& expr : scalar_exprs_) {
     if (is_window_function_operator(expr.get())) {
       return true;
     }
   }
   return false;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void RelProject::injectOffsetInFragmentExpr ( ) const

inlineprivate

Definition at line 1147 of file RelAlgDagBuilder.h.

References fields_, kBIGINT, and scalar_exprs_.

                                           {
     RexFunctionOperator::ConstRexScalarPtrVector transient_vector;
     scalar_exprs_.emplace_back(
         std::make_unique<RexFunctionOperator const>(std::string("OFFSET_IN_FRAGMENT"),
                                                     transient_vector,
                                                     SQLTypeInfo(kBIGINT, false)));
     fields_.emplace_back("EXPR$DELETE_OFFSET_IN_FRAGMENT");
   }

bool RelProject::isIdentity ( ) const

Definition at line 440 of file RelAlgDagBuilder.cpp.

References CHECK, CHECK_EQ, get_node_output(), RelAlgNode::getInput(), RelAlgNode::inputCount(), isSimple(), and scalar_exprs_.

                                   {
   if (!isSimple()) {
     return false;
   }
   CHECK_EQ(size_t(1), inputCount());
   const auto source = getInput(0);
   if (dynamic_cast<const RelJoin*>(source)) {
     return false;
   }
   const auto source_shape = get_node_output(source);
   if (source_shape.size() != scalar_exprs_.size()) {
     return false;
   }
   for (size_t i = 0; i < scalar_exprs_.size(); ++i) {
     const auto& scalar_expr = scalar_exprs_[i];
     const auto input = dynamic_cast<const RexInput*>(scalar_expr.get());
     CHECK(input);
     CHECK_EQ(source, input->getSourceNode());
     // We should add the additional check that input->getIndex() !=
     // source_shape[i].getIndex(), but Calcite doesn't generate the right
     // Sort-Project-Sort sequence when joins are involved.
     if (input->getSourceNode() != source_shape[i].getSourceNode()) {
       return false;
     }
   }
   return true;
 }

Here is the call graph for this function:

bool RelProject::isRenaming ( ) const

Definition at line 513 of file RelAlgDagBuilder.cpp.

References CHECK, CHECK_EQ, fields_, anonymous_namespace{RelAlgDagBuilder.cpp}::isRenamedInput(), isSimple(), and scalar_exprs_.

                                   {
   if (!isSimple()) {
     return false;
   }
   CHECK_EQ(scalar_exprs_.size(), fields_.size());
   for (size_t i = 0; i < fields_.size(); ++i) {
     auto rex_in = dynamic_cast<const RexInput*>(scalar_exprs_[i].get());
     CHECK(rex_in);
     if (isRenamedInput(rex_in->getSourceNode(), rex_in->getIndex(), fields_[i])) {
       return true;
     }
   }
   return false;
 }

Here is the call graph for this function:

bool RelProject::isSimple ( ) const

inline

Definition at line 1041 of file RelAlgDagBuilder.h.

References scalar_exprs_.

Referenced by RelAlgExecutor::executeProject(), isIdentity(), isRenaming(), and anonymous_namespace{RelAlgOptimizer.cpp}::safe_to_redirect().

                         {
     for (const auto& expr : scalar_exprs_) {
       if (!dynamic_cast<const RexInput*>(expr.get())) {
         return false;
       }
     }
     return true;
   }

Here is the caller graph for this function:

void RelProject::replaceInput	(	std::shared_ptr< const RelAlgNode >	old_input,
		std::shared_ptr< const RelAlgNode >	input
	)

inlineoverridevirtual

Reimplemented from RelAlgNode.

Definition at line 1075 of file RelAlgDagBuilder.h.

                                                                     {
     replaceInput(old_input, input, std::nullopt);
   }

void RelProject::replaceInput	(	std::shared_ptr< const RelAlgNode >	old_input,
		std::shared_ptr< const RelAlgNode >	input,
		std::optional< std::unordered_map< unsigned, unsigned >>	old_to_new_index_map
	)

Definition at line 346 of file RelAlgDagBuilder.cpp.

References CHECK, RelAlgNode::replaceInput(), and scalar_exprs_.

                                                                             {
   RelAlgNode::replaceInput(old_input, input);
   std::unique_ptr<RexRebindInputsVisitor> rebind_inputs;
   if (old_to_new_index_map) {
     rebind_inputs = std::make_unique<RexRebindReindexInputsVisitor>(
         old_input.get(), input.get(), *old_to_new_index_map);
   } else {
     rebind_inputs =
         std::make_unique<RexRebindInputsVisitor>(old_input.get(), input.get());
   }
   CHECK(rebind_inputs);
   for (const auto& scalar_expr : scalar_exprs_) {
     rebind_inputs->visit(scalar_expr.get());
   }
 }

Here is the call graph for this function:

void RelProject::setExpressions ( std::vector< std::unique_ptr< const RexScalar >> & exprs ) const

inline

Definition at line 1034 of file RelAlgDagBuilder.h.

References scalar_exprs_.

                                                                               {
     scalar_exprs_ = std::move(exprs);
   }

void RelProject::setFields ( std::vector< std::string > && fields )

inline

Definition at line 1071 of file RelAlgDagBuilder.h.

References fields_.

1071 { fields_ = std::move(fields); }

RelProject::fields_

std::vector< std::string > fields_

Definition: RelAlgDagBuilder.h:1157

size_t RelProject::size ( ) const

inlineoverridevirtual

Implements RelAlgNode.

Definition at line 1054 of file RelAlgDagBuilder.h.

References scalar_exprs_.

Referenced by anonymous_namespace{RelAlgExecutor.cpp}::get_scalar_sources_size(), anonymous_namespace{RelAlgExecutor.cpp}::get_used_inputs(), anonymous_namespace{RelAlgOptimizer.cpp}::is_identical_copy(), RelRexDagVisitor::visit(), and anonymous_namespace{QueryPhysicalInputsCollector.cpp}::RelAlgPhysicalInputsVisitor::visitProject().

1054 { return scalar_exprs_.size(); }

RelProject::scalar_exprs_

std::vector< std::unique_ptr< const RexScalar > > scalar_exprs_

Definition: RelAlgDagBuilder.h:1156

Here is the caller graph for this function:

size_t RelProject::toHash ( ) const

inlineoverridevirtual

Implements RelAlgNode.

Definition at line 1097 of file RelAlgDagBuilder.h.

References fields_, RelAlgNode::hash_, RelProject(), scalar_exprs_, and toString().

                                  {
     if (!hash_) {
       hash_ = typeid(RelProject).hash_code();
       for (auto& target_expr : scalar_exprs_) {
         boost::hash_combine(*hash_, target_expr->toHash());
       }
       boost::hash_combine(*hash_, ::toString(fields_));
     }
     return *hash_;
   }

Here is the call graph for this function:

std::string RelProject::toString ( RelRexToStringConfig config = RelRexToStringConfig::defaults() ) const

inlineoverridevirtual

Implements RelAlgNode.

Definition at line 1088 of file RelAlgDagBuilder.h.

References cat(), fields_, scalar_exprs_, and typeName().

Referenced by toHash().

                                                                                    {
     auto ret = cat(::typeName(this), "(");
     for (auto& expr : scalar_exprs_) {
       ret += expr->toString(config) + " ";
     }
     return cat(ret, ", ", ::toString(fields_), ")");
   }

Here is the call graph for this function:

Here is the caller graph for this function:

template<typename EXPR_VISITOR_FUNCTOR >

void RelProject::visitScalarExprs ( EXPR_VISITOR_FUNCTOR visitor_functor ) const

inlineprivate

Definition at line 1141 of file RelAlgDagBuilder.h.

References scalar_exprs_.

Referenced by RelModify::applyUpdateModificationsToInputNode().

                                                                     {
     for (int i = 0; i < static_cast<int>(scalar_exprs_.size()); i++) {
       visitor_functor(i);
     }
   }

Here is the caller graph for this function:

Friends And Related Function Documentation

friend class RelModify

friend

Definition at line 1016 of file RelAlgDagBuilder.h.

Member Data Documentation

std::vector<std::string> RelProject::fields_

mutableprivate

Definition at line 1157 of file RelAlgDagBuilder.h.

Referenced by appendInput(), getFieldName(), getFields(), injectOffsetInFragmentExpr(), isRenaming(), setFields(), toHash(), and toString().

bool RelProject::hint_applied_

private

Definition at line 1158 of file RelAlgDagBuilder.h.

Referenced by addHint(), getHintInfo(), hasHintEnabled(), and RelProject().

std::unique_ptr<Hints> RelProject::hints_

private

Definition at line 1159 of file RelAlgDagBuilder.h.

Referenced by addHint(), getDeliveredHints(), getHintInfo(), hasDeliveredHint(), hasHintEnabled(), and RelProject().

std::vector<std::unique_ptr<const RexScalar> > RelProject::scalar_exprs_

mutableprivate

Definition at line 1156 of file RelAlgDagBuilder.h.

Referenced by appendInput(), getExpressionsAndRelease(), getProjectAt(), getProjectAtAndRelease(), hasWindowFunctionExpr(), injectOffsetInFragmentExpr(), isIdentity(), isRenaming(), isSimple(), RelProject(), replaceInput(), setExpressions(), size(), toHash(), toString(), and visitScalarExprs().

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

/home/jenkins-slave/workspace/core-os-doxygen/QueryEngine/RelAlgDagBuilder.h
/home/jenkins-slave/workspace/core-os-doxygen/QueryEngine/RelAlgDagBuilder.cpp

Public Types

Public Member Functions

Private Member Functions

Private Attributes

Friends

Additional Inherited Members

Detailed Description

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Friends And Related Function Documentation

Member Data Documentation