anonymous_namespace{QueryPhysicalInputsCollector.cpp}::RelAlgPhysicalInputsVisitor Class Reference

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

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

Public Member Functions
PhysicalInputSet	visitCompound (const RelCompound *compound) const override
PhysicalInputSet	visitFilter (const RelFilter *filter) const override
PhysicalInputSet	visitJoin (const RelJoin *join) const override
PhysicalInputSet	visitLeftDeepInnerJoin (const RelLeftDeepInnerJoin *) const override
PhysicalInputSet	visitProject (const RelProject *project) const override
PhysicalInputSet	visitSort (const RelSort *sort) const override
Public Member Functions inherited from RelAlgVisitor< PhysicalInputSet >
PhysicalInputSet	visit (const RelAlgNode *rel_alg) const
virtual PhysicalInputSet	visitAggregate (const RelAggregate *) const
virtual PhysicalInputSet	visitScan (const RelScan *) const
virtual PhysicalInputSet	visitLogicalValues (const RelLogicalValues *) const
virtual PhysicalInputSet	visitModify (const RelModify *) const
virtual PhysicalInputSet	visitTableFunction (const RelTableFunction *) const
virtual PhysicalInputSet	visitLogicalUnion (const RelLogicalUnion *) const

Protected Member Functions
PhysicalInputSet	aggregateResult (const PhysicalInputSet &aggregate, const PhysicalInputSet &next_result) const override
Protected Member Functions inherited from RelAlgVisitor< PhysicalInputSet >
virtual PhysicalInputSet	aggregateResult (const PhysicalInputSet &aggregate, const PhysicalInputSet &next_result) const
virtual PhysicalInputSet	defaultResult () const

Detailed Description

Definition at line 28 of file QueryPhysicalInputsCollector.cpp.

Member Function Documentation

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

overrideprotected

Definition at line 180 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}::RelAlgPhysicalInputsVisitor::visitCompound ( const RelCompound *  compound ) const

overridevirtual

Reimplemented from RelAlgVisitor< PhysicalInputSet >.

Definition at line 107 of file QueryPhysicalInputsCollector.cpp.

References CHECK, RelCompound::getFilterExpr(), RelCompound::getScalarSource(), RelCompound::getScalarSourcesSize(), run_benchmark_import::result, and RexVisitorBase< T >::visit().

                                       {
  PhysicalInputSet result;
  for (size_t i = 0; i < compound->getScalarSourcesSize(); ++i) {
    const auto rex = compound->getScalarSource(i);
    CHECK(rex);
    RexPhysicalInputsVisitor visitor;
    const auto rex_phys_inputs = visitor.visit(rex);
    result.insert(rex_phys_inputs.begin(), rex_phys_inputs.end());
  }
  const auto filter = compound->getFilterExpr();
  if (filter) {
    RexPhysicalInputsVisitor visitor;
    const auto filter_phys_inputs = visitor.visit(filter);
    result.insert(filter_phys_inputs.begin(), filter_phys_inputs.end());
  }
  return result;
}

Here is the call graph for this function:

PhysicalInputSet anonymous_namespace{QueryPhysicalInputsCollector.cpp}::RelAlgPhysicalInputsVisitor::visitFilter ( const RelFilter *  filter ) const

overridevirtual

Reimplemented from RelAlgVisitor< PhysicalInputSet >.

Definition at line 126 of file QueryPhysicalInputsCollector.cpp.

References CHECK, RelFilter::getCondition(), and RexVisitorBase< T >::visit().

                                                                                       {
  const auto condition = filter->getCondition();
  CHECK(condition);
  RexPhysicalInputsVisitor visitor;
  return visitor.visit(condition);
}

Here is the call graph for this function:

PhysicalInputSet anonymous_namespace{QueryPhysicalInputsCollector.cpp}::RelAlgPhysicalInputsVisitor::visitJoin ( const RelJoin *  join ) const

overridevirtual

Reimplemented from RelAlgVisitor< PhysicalInputSet >.

Definition at line 133 of file QueryPhysicalInputsCollector.cpp.

References RelJoin::getCondition(), and RexVisitorBase< T >::visit().

                                                                                 {
  const auto condition = join->getCondition();
  if (!condition) {
    return PhysicalInputSet{};
  }
  RexPhysicalInputsVisitor visitor;
  return visitor.visit(condition);
}

Here is the call graph for this function:

PhysicalInputSet anonymous_namespace{QueryPhysicalInputsCollector.cpp}::RelAlgPhysicalInputsVisitor::visitLeftDeepInnerJoin ( const RelLeftDeepInnerJoin *  left_deep_inner_join ) const

overridevirtual

Reimplemented from RelAlgVisitor< PhysicalInputSet >.

Definition at line 142 of file QueryPhysicalInputsCollector.cpp.

References CHECK_GE, RelLeftDeepInnerJoin::getInnerCondition(), RelLeftDeepInnerJoin::getOuterCondition(), RelAlgNode::inputCount(), run_benchmark_import::result, and RexVisitorBase< T >::visit().

                                                            {
  PhysicalInputSet result;
  const auto condition = left_deep_inner_join->getInnerCondition();
  RexPhysicalInputsVisitor visitor;
  if (condition) {
    result = visitor.visit(condition);
  }
  CHECK_GE(left_deep_inner_join->inputCount(), size_t(2));
  for (size_t nesting_level = 1; nesting_level <= left_deep_inner_join->inputCount() - 1;
       ++nesting_level) {
    const auto outer_condition = left_deep_inner_join->getOuterCondition(nesting_level);
    if (outer_condition) {
      const auto outer_result = visitor.visit(outer_condition);
      result.insert(outer_result.begin(), outer_result.end());
    }
  }
  return result;
}

Here is the call graph for this function:

PhysicalInputSet anonymous_namespace{QueryPhysicalInputsCollector.cpp}::RelAlgPhysicalInputsVisitor::visitProject ( const RelProject *  project ) const

overridevirtual

Reimplemented from RelAlgVisitor< PhysicalInputSet >.

Definition at line 162 of file QueryPhysicalInputsCollector.cpp.

References CHECK, RelProject::getProjectAt(), run_benchmark_import::result, RelProject::size(), and RexVisitorBase< T >::visit().

                                     {
  PhysicalInputSet result;
  for (size_t i = 0; i < project->size(); ++i) {
    const auto rex = project->getProjectAt(i);
    CHECK(rex);
    RexPhysicalInputsVisitor visitor;
    const auto rex_phys_inputs = visitor.visit(rex);
    result.insert(rex_phys_inputs.begin(), rex_phys_inputs.end());
  }
  return result;
}

Here is the call graph for this function:

PhysicalInputSet anonymous_namespace{QueryPhysicalInputsCollector.cpp}::RelAlgPhysicalInputsVisitor::visitSort ( const RelSort *  sort ) const

overridevirtual

Reimplemented from RelAlgVisitor< PhysicalInputSet >.

Definition at line 175 of file QueryPhysicalInputsCollector.cpp.

References CHECK_EQ, RelAlgNode::getInput(), and RelAlgNode::inputCount().

                                                                                 {
  CHECK_EQ(sort->inputCount(), size_t(1));
  return visit(sort->getInput(0));
}

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