#include <RelAlgDagBuilder.h>

Inheritance diagram for RelCompound:

Collaboration diagram for RelCompound:

Public Member Functions
	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

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

std::string	toString () const override

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

void	addHint (const HintExplained &hint_explained)

const bool	hasHintEnabled (const std::string &candidate_hint_name) const

const HintExplained &	getHintInfo (const std::string &hint_name) const

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

virtual	~RelAlgNode ()

void	resetQueryExecutionState ()

void	setContextData (const void *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 void *	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

bool	isNop () const

void	markAsNop ()

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 Attributes
std::unique_ptr< const RexScalar >	filter_expr_

const size_t	groupby_count_

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

const std::vector< std::string >	fields_

const bool	is_agg_

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

const std::vector< const Rex * >	target_exprs_

bool	hint_applied_

std::unique_ptr< Hints >	hints_

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

Protected Attributes inherited from RelAlgNode
RelAlgInputs	inputs_

const unsigned	id_

Detailed Description

Definition at line 1263 of file RelAlgDagBuilder.h.

Constructor & Destructor Documentation

◆ RelCompound() [1/2]

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 1268 of file RelAlgDagBuilder.h.

References 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() [2/2]

RelCompound::RelCompound ( RelCompound const & rhs )

Definition at line 442 of file RelAlgDagBuilder.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

◆ addHint()

void RelCompound::addHint ( const HintExplained & hint_explained )

inline

Definition at line 1355 of file RelAlgDagBuilder.h.

References HintExplained::getHintName().

Referenced by RelCompound().

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

Here is the call graph for this function:

Here is the caller graph for this function:

◆ deepCopy()

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

inlineoverridevirtual

Implements RelAlgNode.

Definition at line 1351 of file RelAlgDagBuilder.h.

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

◆ getFieldName()

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

inline

Definition at line 1316 of file RelAlgDagBuilder.h.

1316 { return fields_[i]; }

RelCompound::fields_

const std::vector< std::string > fields_

Definition: RelAlgDagBuilder.h:1380

◆ getFields()

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

inline

Definition at line 1314 of file RelAlgDagBuilder.h.

1314 { return fields_; }

RelCompound::fields_

const std::vector< std::string > fields_

Definition: RelAlgDagBuilder.h:1380

◆ getFilterExpr()

const RexScalar* RelCompound::getFilterExpr ( ) const

inline

Definition at line 1306 of file RelAlgDagBuilder.h.

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

1306 { return filter_expr_.get(); }

RelCompound::filter_expr_

std::unique_ptr< const RexScalar > filter_expr_

Definition: RelAlgDagBuilder.h:1377

Here is the caller graph for this function:

◆ getGroupByCount()

const size_t RelCompound::getGroupByCount ( ) const

inline

Definition at line 1329 of file RelAlgDagBuilder.h.

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

1329 { return groupby_count_; }

RelCompound::groupby_count_

const size_t groupby_count_

Definition: RelAlgDagBuilder.h:1378

Here is the caller graph for this function:

◆ getHintInfo()

const HintExplained& RelCompound::getHintInfo ( const std::string & hint_name ) const

inline

Definition at line 1369 of file RelAlgDagBuilder.h.

References CHECK.

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

◆ getScalarSource()

const RexScalar* RelCompound::getScalarSource ( const size_t i ) const

inline

Definition at line 1320 of file RelAlgDagBuilder.h.

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

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

Here is the caller graph for this function:

◆ getScalarSourcesSize()

const size_t RelCompound::getScalarSourcesSize ( ) const

inline

Definition at line 1318 of file RelAlgDagBuilder.h.

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

1318 { return scalar_sources_.size(); }

RelCompound::scalar_sources_

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

Definition: RelAlgDagBuilder.h:1383

Here is the caller graph for this function:

◆ getTargetExpr()

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

inline

Definition at line 1312 of file RelAlgDagBuilder.h.

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

1312 { return target_exprs_[i]; }

RelCompound::target_exprs_

const std::vector< const Rex * > target_exprs_

Definition: RelAlgDagBuilder.h:1385

Here is the caller graph for this function:

◆ hasHintEnabled()

const bool RelCompound::hasHintEnabled ( const std::string & candidate_hint_name ) const

inline

Definition at line 1362 of file RelAlgDagBuilder.h.

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

◆ isAggregate()

bool RelCompound::isAggregate ( ) const

inline

Definition at line 1331 of file RelAlgDagBuilder.h.

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

1331 { return is_agg_; }

RelCompound::is_agg_

const bool is_agg_

Definition: RelAlgDagBuilder.h:1381

Here is the caller graph for this function:

◆ replaceInput()

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

overridevirtual

Reimplemented from RelAlgNode.

Definition at line 325 of file RelAlgDagBuilder.cpp.

References RelAlgNode::replaceInput().

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

◆ setFilterExpr()

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

inline

Definition at line 1308 of file RelAlgDagBuilder.h.

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

◆ setScalarSources()

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

inline

Definition at line 1324 of file RelAlgDagBuilder.h.

References CHECK_EQ.

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

◆ size()

size_t RelCompound::size ( ) const

inlineoverridevirtual

Implements RelAlgNode.

Definition at line 1304 of file RelAlgDagBuilder.h.

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

1304 { return target_exprs_.size(); }

RelCompound::target_exprs_

const std::vector< const Rex * > target_exprs_

Definition: RelAlgDagBuilder.h:1385

Here is the caller graph for this function:

◆ toString()

std::string RelCompound::toString ( ) const

inlineoverridevirtual

Implements RelAlgNode.

Definition at line 1333 of file RelAlgDagBuilder.h.

References run_benchmark_import::result, and to_string().

                                       {
     std::string result =
         "(RelCompound<" + std::to_string(reinterpret_cast<uint64_t>(this)) + ">(";
     result += (filter_expr_ ? filter_expr_->toString() : "null") + " ";
     for (const auto target_expr : target_exprs_) {
       result += target_expr->toString() + " ";
     }
     result += "groups: [";
     for (size_t group_index = 0; group_index < groupby_count_; ++group_index) {
       result += " " + std::to_string(group_index);
     }
     result += " ] sources: [";
     for (const auto& scalar_source : scalar_sources_) {
       result += " " + scalar_source->toString();
     }
     return result + " ]))";
   }

Here is the call graph for this function:

Member Data Documentation

◆ agg_exprs_

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

private

Definition at line 1379 of file RelAlgDagBuilder.h.

◆ fields_

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

private

Definition at line 1380 of file RelAlgDagBuilder.h.

◆ filter_expr_

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

private

Definition at line 1377 of file RelAlgDagBuilder.h.

Referenced by RelCompound().

◆ groupby_count_

const size_t RelCompound::groupby_count_

private

Definition at line 1378 of file RelAlgDagBuilder.h.

◆ hint_applied_

bool RelCompound::hint_applied_

private

Definition at line 1386 of file RelAlgDagBuilder.h.

Referenced by RelCompound().

◆ hints_

std::unique_ptr<Hints> RelCompound::hints_

private

Definition at line 1387 of file RelAlgDagBuilder.h.

Referenced by RelCompound().

◆ is_agg_

const bool RelCompound::is_agg_

private

Definition at line 1381 of file RelAlgDagBuilder.h.

◆ scalar_sources_

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

private

Definition at line 1383 of file RelAlgDagBuilder.h.

◆ target_exprs_

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

private

Definition at line 1385 of file RelAlgDagBuilder.h.

Referenced by RelTableFunction::replaceInput().

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 Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ RelCompound() [1/2]

◆ RelCompound() [2/2]

Member Function Documentation

◆ addHint()

◆ deepCopy()

◆ getFieldName()

◆ getFields()

◆ getFilterExpr()

◆ getGroupByCount()

◆ getHintInfo()

◆ getScalarSource()

◆ getScalarSourcesSize()

◆ getTargetExpr()

◆ hasHintEnabled()

◆ isAggregate()

◆ replaceInput()

◆ setFilterExpr()

◆ setScalarSources()

◆ size()

◆ toString()

Member Data Documentation

◆ agg_exprs_

◆ fields_

◆ filter_expr_

◆ groupby_count_

◆ hint_applied_

◆ hints_

◆ is_agg_

◆ scalar_sources_

◆ target_exprs_