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

Public Member Functions inherited from RexVisitor< PhysicalInputSet >
PhysicalInputSet	visitInput (const RexInput *) const override

PhysicalInputSet	visitLiteral (const RexLiteral *) const override

PhysicalInputSet	visitSubQuery (const RexSubQuery *) const override

PhysicalInputSet	visitRef (const RexRef *) const override

PhysicalInputSet	visitOperator (const RexOperator *rex_operator) const override

PhysicalInputSet	visitCase (const RexCase *rex_case) const override

Public Member Functions inherited from RexVisitorBase< PhysicalInputSet >
virtual PhysicalInputSet	visit (const RexScalar *rex_scalar) const

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

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

PhysicalInputSet	defaultResult () const override

Detailed Description

Definition at line 41 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 99 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

inlineoverridevirtual

Implements RexVisitorBase< PhysicalInputSet >.

Definition at line 43 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);
     return {{col_id, table_id}};
   }

Here is the call graph for this function:

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

inlineoverridevirtual

Implements RexVisitorBase< PhysicalInputSet >.

Definition at line 70 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));
         }
       }
       return result;
     }
     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

inlineoverridevirtual

Implements RexVisitorBase< PhysicalInputSet >.

Definition at line 63 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

Public Member Functions

Protected Member Functions

Detailed Description

Member Function Documentation