anonymous_namespace{QueryPhysicalInputsCollector.cpp}::RexPhysicalInputsVisitor Class Reference

Inheritance diagram for anonymous_namespace{QueryPhysicalInputsCollector.cpp}::RexPhysicalInputsVisitor:

Collaboration diagram for anonymous_namespace{QueryPhysicalInputsCollector.cpp}::RexPhysicalInputsVisitor:

Public Member Functions
PhysicalInputSet	visitInput (const RexInput *input) const override
PhysicalInputSet	visitSubQuery (const RexSubQuery *subquery) const override
PhysicalInputSet	visitOperator (const RexOperator *oper) const override

Protected Member Functions
PhysicalInputSet	aggregateResult (const PhysicalInputSet &aggregate, const PhysicalInputSet &next_result) const override

Detailed Description

Definition at line 43 of file QueryPhysicalInputsCollector.cpp.

Member Function Documentation

PhysicalInputSet anonymous_namespace{QueryPhysicalInputsCollector.cpp}::RexPhysicalInputsVisitor::aggregateResult ( const PhysicalInputSet &  aggregate, const PhysicalInputSet &  next_result  ) const

inlineoverrideprotected

Definition at line 101 of file QueryPhysicalInputsCollector.cpp.

References run_benchmark_import::result.

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

PhysicalInputSet anonymous_namespace{QueryPhysicalInputsCollector.cpp}::RexPhysicalInputsVisitor::visitInput ( const RexInput *  input ) const

inlineoverride

Definition at line 45 of file QueryPhysicalInputsCollector.cpp.

References CHECK, CHECK_GT, CHECK_LT, get_node_output(), RexAbstractInput::getIndex(), and RexInput::getSourceNode().

                                                                    {
    const auto source_ra = input->getSourceNode();
    const auto scan_ra = dynamic_cast<const RelScan*>(source_ra);
    if (!scan_ra) {
      const auto join_ra = dynamic_cast<const RelJoin*>(source_ra);
      if (join_ra) {
        const auto node_inputs = get_node_output(join_ra);
        CHECK_LT(input->getIndex(), node_inputs.size());
        return visitInput(&node_inputs[input->getIndex()]);
      }
      return PhysicalInputSet{};
    }
    const auto scan_td = scan_ra->getTableDescriptor();
    CHECK(scan_td);
    const int col_id = input->getIndex() + 1;
    const int table_id = scan_td->tableId;
    CHECK_GT(table_id, 0);
    auto db_id = scan_ra->getCatalog().getDatabaseId();
    return {{col_id, table_id, db_id}};
  }

Here is the call graph for this function:

PhysicalInputSet anonymous_namespace{QueryPhysicalInputsCollector.cpp}::RexPhysicalInputsVisitor::visitOperator ( const RexOperator *  oper ) const

inlineoverride

Definition at line 73 of file QueryPhysicalInputsCollector.cpp.

References CHECK_EQ, CHECK_LT, get_node_output(), RexOperator::getOperand(), run_benchmark_import::result, and RexOperator::size().

                                                                         {
    PhysicalInputSet result;
    if (auto window_oper = dynamic_cast<const RexWindowFunctionOperator*>(oper)) {
      for (const auto& partition_key : window_oper->getPartitionKeys()) {
        if (auto input = dynamic_cast<const RexInput*>(partition_key.get())) {
          const auto source_node = input->getSourceNode();
          if (auto filter_node = dynamic_cast<const RelFilter*>(source_node)) {
            // Partitions utilize string dictionary translation in the hash join framework
            // if the partition key is a dictionary encoded string. Ensure we reach the
            // source for all partition keys, so we can access string dictionaries for the
            // partition keys while we build the partition (hash) table
            CHECK_EQ(filter_node->inputCount(), size_t(1));
            const auto parent_node = filter_node->getInput(0);
            const auto node_inputs = get_node_output(parent_node);
            CHECK_LT(input->getIndex(), node_inputs.size());
            result = aggregateResult(result, visitInput(&node_inputs[input->getIndex()]));
          }
          result = aggregateResult(result, visit(input));
        }
      }
    }
    for (size_t i = 0; i < oper->size(); i++) {
      result = aggregateResult(result, visit(oper->getOperand(i)));
    }
    return result;
  }

Here is the call graph for this function:

PhysicalInputSet anonymous_namespace{QueryPhysicalInputsCollector.cpp}::RexPhysicalInputsVisitor::visitSubQuery ( const RexSubQuery *  subquery ) const

inlineoverride

Definition at line 66 of file QueryPhysicalInputsCollector.cpp.

References CHECK, and RelAlgVisitor< T >::visit().

                                                                             {
    const auto ra = subquery->getRelAlg();
    CHECK(ra);
    RelAlgPhysicalInputsVisitor visitor;
    return visitor.visit(ra);
  }

Here is the call graph for this function:

---

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

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