#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 () 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

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

unsigned	getId () 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

TableDescriptor const *	getModifiedTableDescriptor () const

void	setModifiedTableDescriptor (TableDescriptor const *td) const

auto const	isUpdateViaSelect () const

auto const	isDeleteViaSelect () const

auto const	isVarlenUpdateRequired () 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 >	hash_

Detailed Description

Definition at line 954 of file RelAlgDagBuilder.h.

Member Typedef Documentation

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

Definition at line 957 of file RelAlgDagBuilder.h.

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

Definition at line 958 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 961 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 337 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 1050 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 146 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 1044 of file RelAlgDagBuilder.h.

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

Hints* RelProject::getDeliveredHints ( )

inline

Definition at line 1073 of file RelAlgDagBuilder.h.

References hints_.

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

1073 { return hints_.get(); }

RelProject::hints_

std::unique_ptr< Hints > hints_

Definition: RelAlgDagBuilder.h:1095

Here is the caller graph for this function:

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

inline

Definition at line 1006 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 1013 of file RelAlgDagBuilder.h.

References fields_, and i.

1013 { return fields_[i]; }

RelProject::fields_

std::vector< std::string > fields_

Definition: RelAlgDagBuilder.h:1093

i

int i

Definition: Parser_wnd_pregen.cpp:2002

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

inline

Definition at line 1010 of file RelAlgDagBuilder.h.

References fields_.

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

1010 { return fields_; }

RelProject::fields_

std::vector< std::string > fields_

Definition: RelAlgDagBuilder.h:1093

Here is the caller graph for this function:

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

inline

Definition at line 1064 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 996 of file RelAlgDagBuilder.h.

References CHECK, and scalar_exprs_.

Referenced by anonymous_namespace{RelAlgExecutor.cpp}::get_used_inputs(), anonymous_namespace{RelAlgOptimizer.cpp}::is_identical_copy(), anonymous_namespace{RelAlgExecutor.cpp}::scalar_at(), anonymous_namespace{RelAlgDagBuilder.cpp}::separate_window_function_expressions(), 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 1001 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 1071 of file RelAlgDagBuilder.h.

References hints_.

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

RelProject::hints_

std::unique_ptr< Hints > hints_

Definition: RelAlgDagBuilder.h:1095

const bool RelProject::hasHintEnabled ( QueryHint candidate_hint ) const

inline

Definition at line 1057 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 2250 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 1083 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 221 of file RelAlgDagBuilder.cpp.

References CHECK, CHECK_EQ, get_node_output(), RelAlgNode::getInput(), i, 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 294 of file RelAlgDagBuilder.cpp.

References CHECK, CHECK_EQ, fields_, i, 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 981 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 1015 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 127 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 974 of file RelAlgDagBuilder.h.

References scalar_exprs_.

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

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

inline

Definition at line 1011 of file RelAlgDagBuilder.h.

References fields_.

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

RelProject::fields_

std::vector< std::string > fields_

Definition: RelAlgDagBuilder.h:1093

size_t RelProject::size ( ) const

inlineoverridevirtual

Implements RelAlgNode.

Definition at line 994 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().

994 { return scalar_exprs_.size(); }

RelProject::scalar_exprs_

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

Definition: RelAlgDagBuilder.h:1092

Here is the caller graph for this function:

size_t RelProject::toHash ( ) const

inlineoverridevirtual

Implements RelAlgNode.

Definition at line 1033 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 ( ) const

inlineoverridevirtual

Implements RelAlgNode.

Definition at line 1028 of file RelAlgDagBuilder.h.

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

Referenced by toHash().

                                       {
     return cat(
         ::typeName(this), "(", ::toString(scalar_exprs_), ", ", ::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 1077 of file RelAlgDagBuilder.h.

References i, and 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 956 of file RelAlgDagBuilder.h.

Member Data Documentation

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

mutableprivate

Definition at line 1093 of file RelAlgDagBuilder.h.

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

bool RelProject::hint_applied_

private

Definition at line 1094 of file RelAlgDagBuilder.h.

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

std::unique_ptr<Hints> RelProject::hints_

private

Definition at line 1095 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 1092 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