OmniSciDB  0bd2ec9cf4
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
RelAlgDagBuilder.cpp File Reference
#include "RelAlgDagBuilder.h"
#include "../Shared/sqldefs.h"
#include "CalciteDeserializerUtils.h"
#include "Catalog/Catalog.h"
#include "Descriptors/RelAlgExecutionDescriptor.h"
#include "JsonAccessors.h"
#include "RelAlgOptimizer.h"
#include "RelLeftDeepInnerJoin.h"
#include "Rendering/RenderRelAlgUtils.h"
#include "RexVisitor.h"
#include <rapidjson/error/en.h>
#include <rapidjson/error/error.h>
#include <rapidjson/stringbuffer.h>
#include <rapidjson/writer.h>
#include <string>
#include <unordered_set>
+ Include dependency graph for RelAlgDagBuilder.cpp:

Go to the source code of this file.

Classes

class  anonymous_namespace{RelAlgDagBuilder.cpp}::RexRebindInputsVisitor
 
struct  std::hash< std::pair< const RelAlgNode *, int > >
 
class  anonymous_namespace{RelAlgDagBuilder.cpp}::anonymous_namespace{RelAlgDagBuilder.cpp}::RexInputReplacementVisitor
 
class  anonymous_namespace{RelAlgDagBuilder.cpp}::RANodeIterator
 
class  anonymous_namespace{RelAlgDagBuilder.cpp}::anonymous_namespace{RelAlgDagBuilder.cpp}::CoalesceSecondaryProjectVisitor
 
class  anonymous_namespace{RelAlgDagBuilder.cpp}::WindowFunctionDetectionVisitor
 
class  anonymous_namespace{RelAlgDagBuilder.cpp}::RexWindowFuncReplacementVisitor
 
class  anonymous_namespace{RelAlgDagBuilder.cpp}::RexInputBackpropagationVisitor
 
class  details::RelAlgDispatcher
 

Namespaces

 anonymous_namespace{RelAlgDagBuilder.cpp}
 
 std
 
 anonymous_namespace{RelAlgDagBuilder.cpp}::anonymous_namespace{RelAlgDagBuilder.cpp}
 
 details
 

Functions

std::vector< RexInputanonymous_namespace{RelAlgDagBuilder.cpp}::n_outputs (const RelAlgNode *node, const size_t n)
 
RANodeOutput get_node_output (const RelAlgNode *ra_node)
 
bool anonymous_namespace{RelAlgDagBuilder.cpp}::isRenamedInput (const RelAlgNode *node, const size_t index, const std::string &new_name)
 
std::set< std::pair< const
RelAlgNode *, int > > 
anonymous_namespace{RelAlgDagBuilder.cpp}::get_equiv_cols (const RelAlgNode *node, const size_t which_col)
 
unsigned anonymous_namespace{RelAlgDagBuilder.cpp}::node_id (const rapidjson::Value &ra_node) noexcept
 
std::unique_ptr< RexAbstractInputanonymous_namespace{RelAlgDagBuilder.cpp}::parse_abstract_input (const rapidjson::Value &expr) noexcept
 
std::unique_ptr< RexLiteralanonymous_namespace{RelAlgDagBuilder.cpp}::parse_literal (const rapidjson::Value &expr)
 
std::unique_ptr< const RexScalaranonymous_namespace{RelAlgDagBuilder.cpp}::parse_scalar_expr (const rapidjson::Value &expr, const Catalog_Namespace::Catalog &cat, RelAlgDagBuilder &root_dag_builder)
 
SQLTypeInfo anonymous_namespace{RelAlgDagBuilder.cpp}::parse_type (const rapidjson::Value &type_obj)
 
std::vector< std::unique_ptr
< const RexScalar > > 
anonymous_namespace{RelAlgDagBuilder.cpp}::parse_expr_array (const rapidjson::Value &arr, const Catalog_Namespace::Catalog &cat, RelAlgDagBuilder &root_dag_builder)
 
SqlWindowFunctionKind anonymous_namespace{RelAlgDagBuilder.cpp}::parse_window_function_kind (const std::string &name)
 
std::vector< std::unique_ptr
< const RexScalar > > 
anonymous_namespace{RelAlgDagBuilder.cpp}::parse_window_order_exprs (const rapidjson::Value &arr, const Catalog_Namespace::Catalog &cat, RelAlgDagBuilder &root_dag_builder)
 
SortDirection anonymous_namespace{RelAlgDagBuilder.cpp}::parse_sort_direction (const rapidjson::Value &collation)
 
NullSortedPosition anonymous_namespace{RelAlgDagBuilder.cpp}::parse_nulls_position (const rapidjson::Value &collation)
 
std::vector< SortFieldanonymous_namespace{RelAlgDagBuilder.cpp}::parse_window_order_collation (const rapidjson::Value &arr, const Catalog_Namespace::Catalog &cat, RelAlgDagBuilder &root_dag_builder)
 
RexWindowFunctionOperator::RexWindowBound anonymous_namespace{RelAlgDagBuilder.cpp}::parse_window_bound (const rapidjson::Value &window_bound_obj, const Catalog_Namespace::Catalog &cat, RelAlgDagBuilder &root_dag_builder)
 
std::unique_ptr< const
RexSubQuery
anonymous_namespace{RelAlgDagBuilder.cpp}::parse_subquery (const rapidjson::Value &expr, const Catalog_Namespace::Catalog &cat, RelAlgDagBuilder &root_dag_builder)
 
std::unique_ptr< RexOperatoranonymous_namespace{RelAlgDagBuilder.cpp}::parse_operator (const rapidjson::Value &expr, const Catalog_Namespace::Catalog &cat, RelAlgDagBuilder &root_dag_builder)
 
std::unique_ptr< RexCaseanonymous_namespace{RelAlgDagBuilder.cpp}::parse_case (const rapidjson::Value &expr, const Catalog_Namespace::Catalog &cat, RelAlgDagBuilder &root_dag_builder)
 
std::vector< std::string > anonymous_namespace{RelAlgDagBuilder.cpp}::strings_from_json_array (const rapidjson::Value &json_str_arr) noexcept
 
std::vector< size_t > anonymous_namespace{RelAlgDagBuilder.cpp}::indices_from_json_array (const rapidjson::Value &json_idx_arr) noexcept
 
std::string anonymous_namespace{RelAlgDagBuilder.cpp}::json_node_to_string (const rapidjson::Value &node) noexcept
 
std::unique_ptr< const RexAgganonymous_namespace{RelAlgDagBuilder.cpp}::parse_aggregate_expr (const rapidjson::Value &expr)
 
JoinType anonymous_namespace{RelAlgDagBuilder.cpp}::to_join_type (const std::string &join_type_name)
 
std::unique_ptr< const RexScalaranonymous_namespace{RelAlgDagBuilder.cpp}::disambiguate_rex (const RexScalar *, const RANodeOutput &)
 
std::unique_ptr< const
RexOperator
anonymous_namespace{RelAlgDagBuilder.cpp}::disambiguate_operator (const RexOperator *rex_operator, const RANodeOutput &ra_output) noexcept
 
std::unique_ptr< const RexCaseanonymous_namespace{RelAlgDagBuilder.cpp}::disambiguate_case (const RexCase *rex_case, const RANodeOutput &ra_output)
 
void anonymous_namespace{RelAlgDagBuilder.cpp}::bind_project_to_input (RelProject *project_node, const RANodeOutput &input) noexcept
 
void anonymous_namespace{RelAlgDagBuilder.cpp}::bind_table_func_to_input (RelTableFunction *table_func_node, const RANodeOutput &input) noexcept
 
void anonymous_namespace{RelAlgDagBuilder.cpp}::bind_inputs (const std::vector< std::shared_ptr< RelAlgNode >> &nodes) noexcept
 
void anonymous_namespace{RelAlgDagBuilder.cpp}::mark_nops (const std::vector< std::shared_ptr< RelAlgNode >> &nodes) noexcept
 
std::vector< const Rex * > anonymous_namespace{RelAlgDagBuilder.cpp}::anonymous_namespace{RelAlgDagBuilder.cpp}::reproject_targets (const RelProject *simple_project, const std::vector< const Rex * > &target_exprs) noexcept
 
void anonymous_namespace{RelAlgDagBuilder.cpp}::create_compound (std::vector< std::shared_ptr< RelAlgNode >> &nodes, const std::vector< size_t > &pattern) noexcept
 
bool anonymous_namespace{RelAlgDagBuilder.cpp}::anonymous_namespace{RelAlgDagBuilder.cpp}::input_can_be_coalesced (const RelAlgNode *parent_node, const size_t index, const bool first_rex_is_input)
 
bool anonymous_namespace{RelAlgDagBuilder.cpp}::anonymous_namespace{RelAlgDagBuilder.cpp}::is_window_function_sum (const RexScalar *rex)
 
bool anonymous_namespace{RelAlgDagBuilder.cpp}::anonymous_namespace{RelAlgDagBuilder.cpp}::is_window_function_operator (const RexScalar *rex)
 
bool anonymous_namespace{RelAlgDagBuilder.cpp}::anonymous_namespace{RelAlgDagBuilder.cpp}::project_has_window_function_input (const RelProject *ra_project)
 
void anonymous_namespace{RelAlgDagBuilder.cpp}::coalesce_nodes (std::vector< std::shared_ptr< RelAlgNode >> &nodes, const std::vector< const RelAlgNode * > &left_deep_joins)
 
void anonymous_namespace{RelAlgDagBuilder.cpp}::separate_window_function_expressions (std::vector< std::shared_ptr< RelAlgNode >> &nodes)
 
int64_t anonymous_namespace{RelAlgDagBuilder.cpp}::get_int_literal_field (const rapidjson::Value &obj, const char field[], const int64_t default_val) noexcept
 
void anonymous_namespace{RelAlgDagBuilder.cpp}::check_empty_inputs_field (const rapidjson::Value &node) noexcept
 
const TableDescriptoranonymous_namespace{RelAlgDagBuilder.cpp}::getTableFromScanNode (const Catalog_Namespace::Catalog &cat, const rapidjson::Value &scan_ra)
 
std::vector< std::string > anonymous_namespace{RelAlgDagBuilder.cpp}::getFieldNamesFromScanNode (const rapidjson::Value &scan_ra)
 
std::string tree_string (const RelAlgNode *ra, const size_t indent)
 

Variables

const unsigned anonymous_namespace{RelAlgDagBuilder.cpp}::FIRST_RA_NODE_ID = 1
 

Function Documentation

RANodeOutput get_node_output ( const RelAlgNode ra_node)

Definition at line 112 of file RelAlgDagBuilder.cpp.

References CHECK(), CHECK_EQ, get_node_output(), and anonymous_namespace{RelAlgDagBuilder.cpp}::n_outputs().

Referenced by anonymous_namespace{RelAlgDagBuilder.cpp}::bind_inputs(), anonymous_namespace{RelAlgDagBuilder.cpp}::create_compound(), anonymous_namespace{RelAlgExecutor.cpp}::get_left_deep_join_input_sizes(), get_node_output(), RelProject::isIdentity(), anonymous_namespace{QueryPhysicalInputsCollector.cpp}::RexPhysicalInputsVisitor::visitInput(), and anonymous_namespace{QueryPhysicalInputsCollector.cpp}::RexPhysicalInputsVisitor::visitOperator().

112  {
113  RANodeOutput outputs;
114  const auto scan_node = dynamic_cast<const RelScan*>(ra_node);
115  if (scan_node) {
116  // Scan node has no inputs, output contains all columns in the table.
117  CHECK_EQ(size_t(0), scan_node->inputCount());
118  return n_outputs(scan_node, scan_node->size());
119  }
120  const auto project_node = dynamic_cast<const RelProject*>(ra_node);
121  if (project_node) {
122  // Project output count doesn't depend on the input
123  CHECK_EQ(size_t(1), project_node->inputCount());
124  return n_outputs(project_node, project_node->size());
125  }
126  const auto filter_node = dynamic_cast<const RelFilter*>(ra_node);
127  if (filter_node) {
128  // Filter preserves shape
129  CHECK_EQ(size_t(1), filter_node->inputCount());
130  const auto prev_out = get_node_output(filter_node->getInput(0));
131  return n_outputs(filter_node, prev_out.size());
132  }
133  const auto aggregate_node = dynamic_cast<const RelAggregate*>(ra_node);
134  if (aggregate_node) {
135  // Aggregate output count doesn't depend on the input
136  CHECK_EQ(size_t(1), aggregate_node->inputCount());
137  return n_outputs(aggregate_node, aggregate_node->size());
138  }
139  const auto compound_node = dynamic_cast<const RelCompound*>(ra_node);
140  if (compound_node) {
141  // Compound output count doesn't depend on the input
142  CHECK_EQ(size_t(1), compound_node->inputCount());
143  return n_outputs(compound_node, compound_node->size());
144  }
145  const auto join_node = dynamic_cast<const RelJoin*>(ra_node);
146  if (join_node) {
147  // Join concatenates the outputs from the inputs and the output
148  // directly references the nodes in the input.
149  CHECK_EQ(size_t(2), join_node->inputCount());
150  auto lhs_out =
151  n_outputs(join_node->getInput(0), get_node_output(join_node->getInput(0)).size());
152  const auto rhs_out =
153  n_outputs(join_node->getInput(1), get_node_output(join_node->getInput(1)).size());
154  lhs_out.insert(lhs_out.end(), rhs_out.begin(), rhs_out.end());
155  return lhs_out;
156  }
157  const auto table_func_node = dynamic_cast<const RelTableFunction*>(ra_node);
158  if (table_func_node) {
159  // Table Function output count doesn't depend on the input
160  CHECK_EQ(size_t(1), table_func_node->inputCount());
161  return n_outputs(table_func_node, table_func_node->size());
162  }
163  const auto sort_node = dynamic_cast<const RelSort*>(ra_node);
164  if (sort_node) {
165  // Sort preserves shape
166  CHECK_EQ(size_t(1), sort_node->inputCount());
167  const auto prev_out = get_node_output(sort_node->getInput(0));
168  return n_outputs(sort_node, prev_out.size());
169  }
170  const auto logical_values_node = dynamic_cast<const RelLogicalValues*>(ra_node);
171  if (logical_values_node) {
172  CHECK_EQ(size_t(0), logical_values_node->inputCount());
173  return n_outputs(logical_values_node, logical_values_node->size());
174  }
175  CHECK(false);
176  return outputs;
177 }
#define CHECK_EQ(x, y)
Definition: Logger.h:201
CHECK(cgen_state)
RANodeOutput get_node_output(const RelAlgNode *ra_node)
std::vector< RexInput > RANodeOutput
std::vector< RexInput > n_outputs(const RelAlgNode *node, const size_t n)

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

std::string tree_string ( const RelAlgNode ra,
const size_t  indent 
)

Definition at line 2200 of file RelAlgDagBuilder.cpp.

References RelAlgNode::getInput(), RelAlgNode::inputCount(), run_benchmark_import::result, RelAlgNode::toString(), and tree_string().

Referenced by tree_string().

2200  {
2201  std::string result = std::string(indent, ' ') + ra->toString() + "\n";
2202  for (size_t i = 0; i < ra->inputCount(); ++i) {
2203  result += tree_string(ra->getInput(i), indent + 2);
2204  }
2205  return result;
2206 }
const RelAlgNode * getInput(const size_t idx) const
std::string tree_string(const RelAlgNode *ra, const size_t indent)
virtual std::string toString() const =0
const size_t inputCount() const

+ Here is the call graph for this function:

+ Here is the caller graph for this function: