RelCompound Class Reference

#include <RelAlgDag.h>

Inheritance diagram for RelCompound:

Collaboration diagram for RelCompound:

Public Member Functions
	RelCompound (const TableDescriptor *td)
	RelCompound (std::unique_ptr< const RexScalar > &filter_expr, const std::vector< const Rex * > &target_exprs, const size_t groupby_count, const std::vector< const RexAgg * > &agg_exprs, const std::vector< std::string > &fields, std::vector< std::unique_ptr< const RexScalar >> &scalar_sources, const bool is_agg, bool update_disguised_as_select=false, bool delete_disguised_as_select=false, bool varlen_update_required=false, TableDescriptor const *manipulation_target_table=nullptr, ColumnNameList target_columns=ColumnNameList())
	RelCompound (RelCompound const &)
void	replaceInput (std::shared_ptr< const RelAlgNode > old_input, std::shared_ptr< const RelAlgNode > input) override
size_t	size () const override
const RexScalar *	getFilterExpr () const
void	setFilterExpr (std::unique_ptr< const RexScalar > &new_expr)
const Rex *	getTargetExpr (const size_t i) const
const std::vector< std::string > &	getFields () const
const std::string	getFieldName (const size_t i) const
void	setFields (std::vector< std::string > &&fields)
const size_t	getScalarSourcesSize () const
const RexScalar *	getScalarSource (const size_t i) const
void	setScalarSources (std::vector< std::unique_ptr< const RexScalar >> &new_sources)
const size_t	getGroupByCount () const
bool	isAggregate () const
size_t	getAggExprSize () const
const RexAgg *	getAggExpr (size_t i) const
std::string	toString (RelRexToStringConfig config=RelRexToStringConfig::defaults()) const override
size_t	toHash () const override
std::shared_ptr< RelAlgNode >	deepCopy () const override
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 (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 (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
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

Private Attributes
std::unique_ptr< const RexScalar >	filter_expr_
size_t	groupby_count_
std::vector< std::unique_ptr < const RexAgg > >	agg_exprs_
std::vector< std::string >	fields_
bool	is_agg_
std::vector< std::unique_ptr < const RexScalar > >	scalar_sources_
std::vector< const Rex * >	target_exprs_
bool	hint_applied_
std::unique_ptr< Hints >	hints_

Friends
struct	RelAlgDagSerializer

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 >	id_in_plan_tree_
std::optional< size_t >	hash_

Detailed Description

Definition at line 1776 of file RelAlgDag.h.

Constructor & Destructor Documentation

RelCompound::RelCompound ( const TableDescriptor *  td )

inline

Definition at line 1779 of file RelAlgDag.h.

Referenced by toHash().

      : ModifyManipulationTarget(false, false, false, td)
      , groupby_count_{0}
      , is_agg_{false}
      , hint_applied_{false} {}

Here is the caller graph for this function:

RelCompound::RelCompound ( std::unique_ptr< const RexScalar > &  filter_expr, const std::vector< const Rex * > &  target_exprs, const size_t  groupby_count, const std::vector< const RexAgg * > &  agg_exprs, const std::vector< std::string > &  fields, std::vector< std::unique_ptr< const RexScalar >> &  scalar_sources, const bool  is_agg, bool  update_disguised_as_select = false, bool  delete_disguised_as_select = false, bool  varlen_update_required = false, TableDescriptor const *  manipulation_target_table = nullptr, ColumnNameList  target_columns = ColumnNameList()  )

inline

Definition at line 1788 of file RelAlgDag.h.

References agg_exprs_, and CHECK_EQ.

      : ModifyManipulationTarget(update_disguised_as_select,
                                 delete_disguised_as_select,
                                 varlen_update_required,
                                 manipulation_target_table,
                                 target_columns)
      , filter_expr_(std::move(filter_expr))
      , groupby_count_(groupby_count)
      , fields_(fields)
      , is_agg_(is_agg)
      , scalar_sources_(std::move(scalar_sources))
      , target_exprs_(target_exprs)
      , hint_applied_(false)
      , hints_(std::make_unique<Hints>()) {
    CHECK_EQ(fields.size(), target_exprs.size());
    for (auto agg_expr : agg_exprs) {
      agg_exprs_.emplace_back(agg_expr);
    }
  }

RelCompound::RelCompound

(

RelCompound const &

rhs

)

Definition at line 661 of file RelAlgDag.cpp.

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

    : RelAlgNode(rhs)
    , ModifyManipulationTarget(rhs)
    , groupby_count_(rhs.groupby_count_)
    , agg_exprs_(copyAggExprs(rhs.agg_exprs_))
    , fields_(rhs.fields_)
    , is_agg_(rhs.is_agg_)
    , scalar_sources_(copyRexScalars(rhs.scalar_sources_))
    , target_exprs_(remapTargetPointers(agg_exprs_,
                                        scalar_sources_,
                                        rhs.agg_exprs_,
                                        rhs.scalar_sources_,
                                        rhs.target_exprs_))
    , hint_applied_(false)
    , hints_(std::make_unique<Hints>()) {
  RexDeepCopyVisitor copier;
  filter_expr_ = rhs.filter_expr_ ? copier.visit(rhs.filter_expr_.get()) : nullptr;
  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 RelCompound::addHint ( const ExplainedQueryHint &  hint_explained )

inline

Definition at line 1868 of file RelAlgDag.h.

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

Referenced by RelCompound().

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

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

inlineoverridevirtual

Implements RelAlgNode.

Definition at line 1864 of file RelAlgDag.h.

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

const RexAgg* RelCompound::getAggExpr ( size_t  i ) const

inline

Definition at line 1857 of file RelAlgDag.h.

References agg_exprs_.

{ return agg_exprs_[i].get(); }

size_t RelCompound::getAggExprSize ( ) const

inline

Definition at line 1855 of file RelAlgDag.h.

References agg_exprs_.

{ return agg_exprs_.size(); }

Hints* RelCompound::getDeliveredHints ( )

inline

Definition at line 1891 of file RelAlgDag.h.

References hints_.

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

{ return hints_.get(); }

Here is the caller graph for this function:

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

inline

Definition at line 1836 of file RelAlgDag.h.

References fields_.

{ return fields_[i]; }

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

inline

Definition at line 1834 of file RelAlgDag.h.

References fields_.

{ return fields_; }

const RexScalar* RelCompound::getFilterExpr ( ) const

inline

Definition at line 1826 of file RelAlgDag.h.

References filter_expr_.

Referenced by anonymous_namespace{RelAlgExecutor.cpp}::get_used_inputs(), anonymous_namespace{RelAlgExecutor.cpp}::translate_quals(), RelRexDagVisitor::visit(), and anonymous_namespace{QueryPhysicalInputsCollector.cpp}::RelAlgPhysicalInputsVisitor::visitCompound().

{ return filter_expr_.get(); }

Here is the caller graph for this function:

const size_t RelCompound::getGroupByCount ( ) const

inline

Definition at line 1851 of file RelAlgDag.h.

References groupby_count_.

Referenced by anonymous_namespace{RelAlgExecutor.cpp}::translate_groupby_exprs().

{ return groupby_count_; }

Here is the caller graph for this function:

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

inline

Definition at line 1882 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* RelCompound::getScalarSource ( const size_t  i ) const

inline

Definition at line 1842 of file RelAlgDag.h.

References scalar_sources_.

Referenced by anonymous_namespace{RelAlgExecutor.cpp}::get_used_inputs(), anonymous_namespace{RelAlgExecutor.cpp}::scalar_at(), RelRexDagVisitor::visit(), and anonymous_namespace{QueryPhysicalInputsCollector.cpp}::RelAlgPhysicalInputsVisitor::visitCompound().

                                                         {
    return scalar_sources_[i].get();
  }

Here is the caller graph for this function:

const size_t RelCompound::getScalarSourcesSize ( ) const

inline

Definition at line 1840 of file RelAlgDag.h.

References scalar_sources_.

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

{ return scalar_sources_.size(); }

Here is the caller graph for this function:

const Rex* RelCompound::getTargetExpr ( const size_t  i ) const

inline

Definition at line 1832 of file RelAlgDag.h.

References target_exprs_.

Referenced by anonymous_namespace{RelAlgExecutor.cpp}::translate_targets(), and QueryPlanDagChecker::visit().

{ return target_exprs_[i]; }

Here is the caller graph for this function:

bool RelCompound::hasDeliveredHint ( )

inline

Definition at line 1889 of file RelAlgDag.h.

References hints_.

{ return !hints_->empty(); }

const bool RelCompound::hasHintEnabled ( QueryHint  candidate_hint ) const

inline

Definition at line 1875 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 RelCompound::isAggregate ( ) const

inline

Definition at line 1853 of file RelAlgDag.h.

References is_agg_.

Referenced by RelAlgExecutor::executeCompound(), anonymous_namespace{RelAlgExecutor.cpp}::translate_groupby_exprs(), and QueryPlanDagChecker::visit().

{ return is_agg_; }

Here is the caller graph for this function:

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

overridevirtual

Reimplemented from RelAlgNode.

Definition at line 543 of file RelAlgDag.cpp.

References filter_expr_, RelAlgNode::replaceInput(), and scalar_sources_.

                                                                      {
  RelAlgNode::replaceInput(old_input, input);
  RexRebindInputsVisitor rebind_inputs(old_input.get(), input.get());
  for (const auto& scalar_source : scalar_sources_) {
    rebind_inputs.visit(scalar_source.get());
  }
  if (filter_expr_) {
    rebind_inputs.visit(filter_expr_.get());
  }
}

Here is the call graph for this function:

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

inline

Definition at line 1838 of file RelAlgDag.h.

References fields_.

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

void RelCompound::setFilterExpr ( std::unique_ptr< const RexScalar > &  new_expr )

inline

Definition at line 1828 of file RelAlgDag.h.

References filter_expr_.

                                                               {
    filter_expr_ = std::move(new_expr);
  }

void RelCompound::setScalarSources ( std::vector< std::unique_ptr< const RexScalar >> &  new_sources )

inline

Definition at line 1846 of file RelAlgDag.h.

References CHECK_EQ, and scalar_sources_.

                                                                                {
    CHECK_EQ(new_sources.size(), scalar_sources_.size());
    scalar_sources_ = std::move(new_sources);
  }

size_t RelCompound::size ( ) const

inlineoverridevirtual

Implements RelAlgNode.

Definition at line 1824 of file RelAlgDag.h.

References target_exprs_.

Referenced by RelAlgExecutor::createCompoundWorkUnit(), anonymous_namespace{RelAlgExecutor.cpp}::translate_targets(), and QueryPlanDagChecker::visit().

{ return target_exprs_.size(); }

Here is the caller graph for this function:

size_t RelCompound::toHash ( ) const

overridevirtual

Implements RelAlgNode.

Definition at line 3430 of file RelAlgDag.cpp.

References agg_exprs_, fields_, filter_expr_, groupby_count_, RelAlgNode::hash_, HASH_N, is_agg_, RelCompound(), scalar_sources_, target_exprs_, and toString().

                                 {
  if (!hash_) {
    hash_ = typeid(RelCompound).hash_code();
    boost::hash_combine(*hash_, filter_expr_ ? filter_expr_->toHash() : HASH_N);
    boost::hash_combine(*hash_, is_agg_);
    for (auto& target_expr : target_exprs_) {
      if (auto rex_scalar = dynamic_cast<const RexScalar*>(target_expr)) {
        boost::hash_combine(*hash_, rex_scalar->toHash());
      }
    }
    for (auto& agg_expr : agg_exprs_) {
      boost::hash_combine(*hash_, agg_expr->toHash());
    }
    for (auto& scalar_source : scalar_sources_) {
      boost::hash_combine(*hash_, scalar_source->toHash());
    }
    boost::hash_combine(*hash_, groupby_count_);
    boost::hash_combine(*hash_, ::toString(fields_));
  }
  return *hash_;
}

Here is the call graph for this function:

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

overridevirtual

Implements RelAlgNode.

Definition at line 3404 of file RelAlgDag.cpp.

References agg_exprs_, cat(), fields_, filter_expr_, groupby_count_, is_agg_, scalar_sources_, target_exprs_, to_string(), and typeName().

Referenced by toHash().

                                                                 {
  auto ret = cat(::typeName(this),
                 ", filter_expr=",
                 (filter_expr_ ? filter_expr_->toString(config) : "null"),
                 ", target_exprs=");
  for (auto& expr : target_exprs_) {
    ret += expr->toString(config) + " ";
  }
  ret += ", agg_exps=";
  for (auto& expr : agg_exprs_) {
    ret += expr->toString(config) + " ";
  }
  ret += ", scalar_sources=";
  for (auto& expr : scalar_sources_) {
    ret += expr->toString(config) + " ";
  }
  return cat(ret,
             ", ",
             std::to_string(groupby_count_),
             ", ",
             ", fields=",
             ::toString(fields_),
             ", is_agg=",
             std::to_string(is_agg_));
}

Here is the call graph for this function:

Here is the caller graph for this function:

Friends And Related Function Documentation

friend struct RelAlgDagSerializer

friend

Definition at line 1906 of file RelAlgDag.h.

Member Data Documentation

std::vector<std::unique_ptr<const RexAgg> > RelCompound::agg_exprs_

private

Definition at line 1896 of file RelAlgDag.h.

Referenced by getAggExpr(), getAggExprSize(), RelCompound(), toHash(), and toString().

std::vector<std::string> RelCompound::fields_

private

Definition at line 1897 of file RelAlgDag.h.

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

std::unique_ptr<const RexScalar> RelCompound::filter_expr_

private

Definition at line 1894 of file RelAlgDag.h.

Referenced by getFilterExpr(), RelCompound(), replaceInput(), setFilterExpr(), toHash(), and toString().

size_t RelCompound::groupby_count_

private

Definition at line 1895 of file RelAlgDag.h.

Referenced by getGroupByCount(), toHash(), and toString().

bool RelCompound::hint_applied_

private

Definition at line 1903 of file RelAlgDag.h.

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

std::unique_ptr<Hints> RelCompound::hints_

private

Definition at line 1904 of file RelAlgDag.h.

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

bool RelCompound::is_agg_

private

Definition at line 1898 of file RelAlgDag.h.

Referenced by isAggregate(), toHash(), and toString().

std::vector<std::unique_ptr<const RexScalar> > RelCompound::scalar_sources_

private

Definition at line 1900 of file RelAlgDag.h.

Referenced by getScalarSource(), getScalarSourcesSize(), replaceInput(), setScalarSources(), toHash(), and toString().

std::vector<const Rex*> RelCompound::target_exprs_

private

Definition at line 1902 of file RelAlgDag.h.

Referenced by getTargetExpr(), size(), toHash(), and toString().

---

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