anonymous_namespace{RelAlgExecutor.cpp}::RexUsedInputsVisitor Class Reference

Inheritance diagram for anonymous_namespace{RelAlgExecutor.cpp}::RexUsedInputsVisitor:

Collaboration diagram for anonymous_namespace{RelAlgExecutor.cpp}::RexUsedInputsVisitor:

Public Member Functions
	RexUsedInputsVisitor (const Catalog_Namespace::Catalog &cat)
const std::vector < std::shared_ptr< RexInput > > &	get_inputs_owned () const
std::unordered_set< const RexInput * >	visitInput (const RexInput *rex_input) const override
Public Member Functions inherited from RexVisitor< std::unordered_set< const RexInput * > >
std::unordered_set< const RexInput * >	visitInput (const RexInput *) const override
std::unordered_set< const RexInput * >	visitLiteral (const RexLiteral *) const override
std::unordered_set< const RexInput * >	visitSubQuery (const RexSubQuery *) const override
std::unordered_set< const RexInput * >	visitRef (const RexRef *) const override
std::unordered_set< const RexInput * >	visitOperator (const RexOperator *rex_operator) const override
std::unordered_set< const RexInput * >	visitCase (const RexCase *rex_case) const override
Public Member Functions inherited from RexVisitorBase< std::unordered_set< const RexInput * > >
virtual std::unordered_set < const RexInput * >	visit (const RexScalar *rex_scalar) const

Protected Member Functions
std::unordered_set< const RexInput * >	aggregateResult (const std::unordered_set< const RexInput * > &aggregate, const std::unordered_set< const RexInput * > &next_result) const override
Protected Member Functions inherited from RexVisitor< std::unordered_set< const RexInput * > >
std::unordered_set< const RexInput * >	defaultResult () const override

Private Attributes
std::vector< std::shared_ptr < RexInput > >	synthesized_physical_inputs_owned
const Catalog_Namespace::Catalog &	cat_

Detailed Description

Definition at line 809 of file RelAlgExecutor.cpp.

Constructor & Destructor Documentation

anonymous_namespace{RelAlgExecutor.cpp}::RexUsedInputsVisitor::RexUsedInputsVisitor ( const Catalog_Namespace::Catalog &  cat )

inline

Definition at line 811 of file RelAlgExecutor.cpp.

: RexVisitor(), cat_(cat) {}

Member Function Documentation

std::unordered_set<const RexInput*> anonymous_namespace{RelAlgExecutor.cpp}::RexUsedInputsVisitor::aggregateResult ( const std::unordered_set< const RexInput * > &  aggregate, const std::unordered_set< const RexInput * > &  next_result  ) const

inlineoverrideprotectedvirtual

Reimplemented from RexVisitor< std::unordered_set< const RexInput * > >.

Definition at line 844 of file RelAlgExecutor.cpp.

References run_benchmark_import::result.

                                                                           {
    auto result = aggregate;
    result.insert(next_result.begin(), next_result.end());
    return result;
  }

const std::vector<std::shared_ptr<RexInput> >& anonymous_namespace{RelAlgExecutor.cpp}::RexUsedInputsVisitor::get_inputs_owned ( ) const

inline

Definition at line 813 of file RelAlgExecutor.cpp.

Referenced by anonymous_namespace{RelAlgExecutor.cpp}::get_join_source_used_inputs(), and anonymous_namespace{RelAlgExecutor.cpp}::get_used_inputs().

                                                                     {
    return synthesized_physical_inputs_owned;
  }

Here is the caller graph for this function:

std::unordered_set<const RexInput*> anonymous_namespace{RelAlgExecutor.cpp}::RexUsedInputsVisitor::visitInput ( const RexInput *  rex_input ) const

inlineoverridevirtual

Implements RexVisitorBase< std::unordered_set< const RexInput * > >.

Definition at line 817 of file RelAlgExecutor.cpp.

References RelAlgExecutor::cat_, CHECK, RexAbstractInput::getIndex(), Catalog_Namespace::Catalog::getMetadataForColumnBySpi(), RexInput::getSourceNode(), RelScan::getTableDescriptor(), IS_GEO, and SPIMAP_GEO_PHYSICAL_INPUT.

                                                {
    const auto input_ra = rex_input->getSourceNode();
    CHECK(input_ra);
    const auto scan_ra = dynamic_cast<const RelScan*>(input_ra);
    if (scan_ra) {
      const auto td = scan_ra->getTableDescriptor();
      if (td) {
        const auto col_id = rex_input->getIndex();
        const auto cd = cat_.getMetadataForColumnBySpi(td->tableId, col_id + 1);
        if (cd && cd->columnType.get_physical_cols() > 0) {
          CHECK(IS_GEO(cd->columnType.get_type()));
          std::unordered_set<const RexInput*> synthesized_physical_inputs;
          for (auto i = 0; i < cd->columnType.get_physical_cols(); i++) {
            auto physical_input =
                new RexInput(scan_ra, SPIMAP_GEO_PHYSICAL_INPUT(col_id, i));
            synthesized_physical_inputs_owned.emplace_back(physical_input);
            synthesized_physical_inputs.insert(physical_input);
          }
          return synthesized_physical_inputs;
        }
      }
    }
    return {rex_input};
  }

Here is the call graph for this function:

Member Data Documentation

const Catalog_Namespace::Catalog& anonymous_namespace{RelAlgExecutor.cpp}::RexUsedInputsVisitor::cat_

private

Definition at line 854 of file RelAlgExecutor.cpp.

std::vector<std::shared_ptr<RexInput> > anonymous_namespace{RelAlgExecutor.cpp}::RexUsedInputsVisitor::synthesized_physical_inputs_owned

mutableprivate

Definition at line 853 of file RelAlgExecutor.cpp.

---

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

• /home/jenkins-slave/workspace/core-os-doxygen/QueryEngine/RelAlgExecutor.cpp