#include <RelAlgDag.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 (const TableDescriptor td, const Catalog_Namespace::Catalog catalog)

	scalar_exprs_ (std::move(scalar_exprs))

	fields_ (fields)

	hint_applied_ (false)

	hints_ (std::make_unique< Hints >())

	has_pushed_down_window_expr_ (false)

	RelProject (RelProject const &)

virtual void	acceptChildren (Visitor &v) const override

virtual void	accept (Visitor &v, std::string name) const override

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

void	propagateModifyManipulationTarget (std::shared_ptr< RelProject > new_project_node) const

void	resetModifyManipulationTarget () const

bool	hasPushedDownWindowExpr () const

void	setPushedDownWindowExpr ()

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 idx) 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

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

virtual size_t	toHash () const override

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

virtual	~RelAlgNode ()

void	resetQueryExecutionState ()

void	setContextData (const RaExecutionDesc *context_data) const

void	setOutputMetainfo (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

bool	hasContextData () const

const RaExecutionDesc *	getContextData () const

const size_t	inputCount () const

const RelAlgNode *	getInput (const size_t idx) const

const std::vector< RelAlgNode const * >	getInputs () 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 RelAlgDagNode
	RelAlgDagNode ()

virtual size_t	getStepNumber () const

virtual void	setStepNumber (size_t step) const

std::optional< size_t >	getIdInPlanTree () const

void	setIdInPlanTree (size_t id) 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(), const Catalog_Namespace::Catalog catalog=nullptr)

void	setUpdateViaSelectFlag (bool required) const

void	setDeleteViaSelectFlag (bool required) const

void	setVarlenUpdateRequired (bool required) const

void	forceRowwiseOutput () const

TableDescriptor const *	getModifiedTableDescriptor () const

TableDescriptor const *	getTableDescriptor () const

void	setModifiedTableDescriptor (TableDescriptor const *td) const

const Catalog_Namespace::Catalog *	getModifiedTableCatalog () const

void	setModifiedTableCatalog (const Catalog_Namespace::Catalog *catalog) const

auto const	isUpdateViaSelect () const

auto const	isDeleteViaSelect () const

auto const	isVarlenUpdateRequired () const

auto const	isProjectForUpdate () const

auto const	isRowwiseOutputForced () const

void	setTargetColumns (ColumnNameList const &target_columns) const

ColumnNameList const &	getTargetColumns () const

void	invalidateTargetColumns () const

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

Public Attributes
	catalog

	hint_applied_ {false}

	has_pushed_down_window_expr_

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_

bool	has_pushed_down_window_expr_

Friends
class	RelModify

struct	RelAlgDagSerializer

std::size_t	hash_value (RelProject const &)

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

Protected Attributes inherited from RelAlgNode
RelAlgInputs	inputs_

unsigned	id_

std::optional< size_t >	hash_

Protected Attributes inherited from RelAlgDagNode
size_t	step_ {0}

std::optional< size_t >	id_in_plan_tree_

Detailed Description

Definition at line 1254 of file RelAlgDag.h.

Member Typedef Documentation

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

Definition at line 1257 of file RelAlgDag.h.

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

Definition at line 1258 of file RelAlgDag.h.

Constructor & Destructor Documentation

RelProject::RelProject	(	const TableDescriptor *	td,
		const Catalog_Namespace::Catalog *	catalog
	)

inline

Definition at line 1261 of file RelAlgDag.h.

1262 : ModifyManipulationTarget(false, false, false, td, {}, catalog)

ModifyManipulationTarget::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(), const Catalog_Namespace::Catalog *catalog=nullptr)

Definition: RelAlgDag.h:1185

RelProject::catalog

catalog

Definition: RelAlgDag.h:1262

RelProject::RelProject ( RelProject const & rhs )

Definition at line 556 of file RelAlgDag.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>())
     , has_pushed_down_window_expr_(rhs.has_pushed_down_window_expr_) {
   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

virtual void RelProject::accept	(	Visitor &	v,
		std::string	name
	)		const

inlineoverridevirtual

Implements RelAlgDagNode.

Definition at line 1294 of file RelAlgDag.h.

References acceptChildren(), and RelAlgDagNode::Visitor::visit().

Referenced by TableFunctionsFactory_node.PrintNode::__str__().

                                                                  {
     if (v.visit(this, std::move(name))) {
       acceptChildren(v);
     }
   }

Here is the call graph for this function:

Here is the caller graph for this function:

virtual void RelProject::acceptChildren ( Visitor & v ) const

inlineoverridevirtual

Implements RelAlgDagNode.

Definition at line 1282 of file RelAlgDag.h.

References RelAlgDagNode::accept(), getFieldName(), RelAlgNode::getInputs(), getProjectAt(), anonymous_namespace{Utm.h}::n, and size().

Referenced by accept().

                                                          {
     for (size_t i = 0; i < size(); ++i) {
       if (getProjectAt(i)) {
         getProjectAt(i)->accept(v, "\"" + getFieldName(i) + "\"");
       }
     }
     for (auto& n : getInputs()) {
       if (n) {
         n->accept(v, "input");
       }
     }
   }

Here is the call graph for this function:

Here is the caller graph for this function:

void RelProject::addHint ( const ExplainedQueryHint & hint_explained )

inline

Definition at line 1413 of file RelAlgDag.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 RelAlgDag.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 1400 of file RelAlgDag.h.

References has_pushed_down_window_expr_, ModifyManipulationTarget::isProjectForUpdate(), and propagateModifyManipulationTarget().

                                                       {
     auto copied_project_node = std::make_shared<RelProject>(*this);
     if (isProjectForUpdate()) {
       propagateModifyManipulationTarget(copied_project_node);
     }
     if (has_pushed_down_window_expr_) {
       copied_project_node->setPushedDownWindowExpr();
     }
     return copied_project_node;
   }

Here is the call graph for this function:

RelProject::fields_ ( fields )

Hints* RelProject::getDeliveredHints ( )

inline

Definition at line 1436 of file RelAlgDag.h.

References hints_.

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

1436 { return hints_.get(); }

RelProject::hints_

std::unique_ptr< Hints > hints_

Definition: RelAlgDag.h:1462

Here is the caller graph for this function:

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

inline

Definition at line 1362 of file RelAlgDag.h.

References scalar_exprs_.

                                                                        {
     return std::move(scalar_exprs_);
   }

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

inline

Definition at line 1369 of file RelAlgDag.h.

References CHECK, and fields_.

Referenced by acceptChildren().

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

Here is the caller graph for this function:

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

inline

Definition at line 1366 of file RelAlgDag.h.

References fields_.

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

1366 { return fields_; }

RelProject::fields_

std::vector< std::string > fields_

Definition: RelAlgDag.h:1460

Here is the caller graph for this function:

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

inline

Definition at line 1427 of file RelAlgDag.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 1352 of file RelAlgDag.h.

References CHECK, and scalar_exprs_.

Referenced by acceptChildren(), anonymous_namespace{RelAlgExecutor.cpp}::get_used_inputs(), anonymous_namespace{RelAlgOptimizer.cpp}::is_identical_copy(), anonymous_namespace{RelAlgDag.cpp}::anonymous_namespace{RelAlgDag.cpp}::need_pushdown_generic_expr(), 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 1357 of file RelAlgDag.h.

References CHECK, and scalar_exprs_.

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

RelProject::has_pushed_down_window_expr_ ( false )

inline

Definition at line 1275 of file RelAlgDag.h.

References CHECK_EQ, fields_, RelAlgNode::inputs_, and scalar_exprs_.

                                             {
     CHECK_EQ(scalar_exprs_.size(), fields_.size());
     inputs_.push_back(input);
   }

bool RelProject::hasDeliveredHint ( )

inline

Definition at line 1434 of file RelAlgDag.h.

References hints_.

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

RelProject::hints_

std::unique_ptr< Hints > hints_

Definition: RelAlgDag.h:1462

const bool RelProject::hasHintEnabled ( QueryHint candidate_hint ) const

inline

Definition at line 1420 of file RelAlgDag.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::hasPushedDownWindowExpr ( ) const

inline

Definition at line 1348 of file RelAlgDag.h.

References has_pushed_down_window_expr_.

1348 { return has_pushed_down_window_expr_; }

RelProject::has_pushed_down_window_expr_

has_pushed_down_window_expr_

Definition: RelAlgDag.h:1264

bool RelProject::hasWindowFunctionExpr ( ) const

Definition at line 2857 of file RelAlgDag.cpp.

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

                                              {
   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:

RelProject::hint_applied_ ( false )

RelProject::hints_ ( std::make_unique< Hints > () )

void RelProject::injectOffsetInFragmentExpr ( ) const

inlineprivate

Definition at line 1450 of file RelAlgDag.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 RelAlgDag.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 RelAlgDag.cpp.

References CHECK, CHECK_EQ, fields_, anonymous_namespace{RelAlgDag.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 1307 of file RelAlgDag.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::propagateModifyManipulationTarget ( std::shared_ptr< RelProject > new_project_node ) const

inline

Definition at line 1322 of file RelAlgDag.h.

References ModifyManipulationTarget::getModifiedTableCatalog(), ModifyManipulationTarget::getModifiedTableDescriptor(), ModifyManipulationTarget::getTargetColumns(), ModifyManipulationTarget::isDeleteViaSelect(), ModifyManipulationTarget::isUpdateViaSelect(), ModifyManipulationTarget::isVarlenUpdateRequired(), and resetModifyManipulationTarget().

Referenced by deepCopy().

                                                         {
     if (isUpdateViaSelect()) {
       new_project_node->setUpdateViaSelectFlag(true);
     }
     if (isDeleteViaSelect()) {
       new_project_node->setDeleteViaSelectFlag(true);
     }
     if (isVarlenUpdateRequired()) {
       new_project_node->setVarlenUpdateRequired(true);
     }
     new_project_node->setModifiedTableDescriptor(getModifiedTableDescriptor());
     new_project_node->setTargetColumns(getTargetColumns());
     new_project_node->setModifiedTableCatalog(getModifiedTableCatalog());
     resetModifyManipulationTarget();
   }

Here is the call graph for this function:

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 1374 of file RelAlgDag.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 RelAlgDag.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::resetModifyManipulationTarget ( ) const

inline

Definition at line 1339 of file RelAlgDag.h.

References ModifyManipulationTarget::invalidateTargetColumns(), ModifyManipulationTarget::setDeleteViaSelectFlag(), ModifyManipulationTarget::setModifiedTableCatalog(), ModifyManipulationTarget::setModifiedTableDescriptor(), ModifyManipulationTarget::setUpdateViaSelectFlag(), and ModifyManipulationTarget::setVarlenUpdateRequired().

Referenced by propagateModifyManipulationTarget().

                                              {
     setModifiedTableDescriptor(nullptr);
     setModifiedTableCatalog(nullptr);
     setUpdateViaSelectFlag(false);
     setDeleteViaSelectFlag(false);
     setVarlenUpdateRequired(false);
     invalidateTargetColumns();
   }

Here is the call graph for this function:

Here is the caller graph for this function:

RelProject::scalar_exprs_ ( std:: movescalar_exprs )

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

inline

Definition at line 1300 of file RelAlgDag.h.

References scalar_exprs_.

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

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

inline

Definition at line 1367 of file RelAlgDag.h.

References fields_.

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

RelProject::fields_

std::vector< std::string > fields_

Definition: RelAlgDag.h:1460

void RelProject::setPushedDownWindowExpr ( )

inline

Definition at line 1350 of file RelAlgDag.h.

References has_pushed_down_window_expr_.

1350 { has_pushed_down_window_expr_ = true; }

RelProject::has_pushed_down_window_expr_

has_pushed_down_window_expr_

Definition: RelAlgDag.h:1264

size_t RelProject::size ( ) const

inlineoverridevirtual

Implements RelAlgNode.

Definition at line 1320 of file RelAlgDag.h.

References scalar_exprs_.

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

1320 { return scalar_exprs_.size(); }

RelProject::scalar_exprs_

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

Definition: RelAlgDag.h:1459

Here is the caller graph for this function:

virtual size_t RelProject::toHash ( ) const

inlineoverridevirtual

Implements RelAlgNode.

Definition at line 1438 of file RelAlgDag.h.

References hash_value.

1438 { return hash_value(*this); }

RelProject::hash_value

friend std::size_t hash_value(RelProject const &)

Definition: RelAlgDag.cpp:3679

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

inlineoverridevirtual

Implements RelAlgNode.

Definition at line 1387 of file RelAlgDag.h.

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

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

Here is the call graph for this function:

template<typename EXPR_VISITOR_FUNCTOR >

void RelProject::visitScalarExprs ( EXPR_VISITOR_FUNCTOR visitor_functor ) const

inlineprivate

Definition at line 1444 of file RelAlgDag.h.

References scalar_exprs_.

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

Friends And Related Function Documentation

std::size_t hash_value ( RelProject const & rel_project )

friend

Definition at line 3679 of file RelAlgDag.cpp.

Referenced by toHash().

                                                     {
   if (rel_project.hash_) {
     return *rel_project.hash_;
   }
   rel_project.hash_ = typeid(RelProject).hash_code();
   boost::hash_combine(*rel_project.hash_, rel_project.scalar_exprs_);
   boost::hash_combine(*rel_project.hash_, rel_project.fields_);
   boost::hash_combine(*rel_project.hash_, rel_project.inputs_);
   return *rel_project.hash_;
 }

friend struct RelAlgDagSerializer

friend

Definition at line 1465 of file RelAlgDag.h.

friend class RelModify

friend

Definition at line 1256 of file RelAlgDag.h.

Member Data Documentation

RelProject::catalog

Definition at line 1262 of file RelAlgDag.h.

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

mutableprivate

Definition at line 1460 of file RelAlgDag.h.

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

RelProject::has_pushed_down_window_expr_

Initial value:

{false} {}
  
  RelProject(std::vector<std::unique_ptr<const RexScalar>>& scalar_exprs,
             const std::vector<std::string>& fields,
             std::shared_ptr<const RelAlgNode> input)
      : ModifyManipulationTarget(false, false, false, nullptr)

Definition at line 1264 of file RelAlgDag.h.

Referenced by deepCopy(), hasPushedDownWindowExpr(), and setPushedDownWindowExpr().

bool RelProject::has_pushed_down_window_expr_

private

Definition at line 1463 of file RelAlgDag.h.

RelProject::hint_applied_ {false}

Definition at line 1263 of file RelAlgDag.h.

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

bool RelProject::hint_applied_

private

Definition at line 1461 of file RelAlgDag.h.

std::unique_ptr<Hints> RelProject::hints_

private

Definition at line 1462 of file RelAlgDag.h.

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

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

mutableprivate

Definition at line 1459 of file RelAlgDag.h.

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

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

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

Public Types

Public Member Functions

Public Attributes

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