anonymous_namespace{IRCodegen.cpp} Namespace Reference

Functions
void	add_qualifier_to_execution_unit (RelAlgExecutionUnit &ra_exe_unit, const std::shared_ptr< Analyzer::Expr > &qual)
void	check_if_loop_join_is_allowed (RelAlgExecutionUnit &ra_exe_unit, const ExecutionOptions &eo, const std::vector< InputTableInfo > &query_infos, const size_t level_idx, const std::string &fail_reason)

Function Documentation

add_qualifier_to_execution_unit()

void anonymous_namespace{IRCodegen.cpp}::add_qualifier_to_execution_unit	(	RelAlgExecutionUnit &	ra_exe_unit,
		const std::shared_ptr< Analyzer::Expr > &	qual
	)

Definition at line 186 of file IRCodegen.cpp.

References qual_to_conjunctive_form(), RelAlgExecutionUnit::quals, and RelAlgExecutionUnit::simple_quals.

Referenced by Executor::buildCurrentLevelHashTable().

                                                                              {
  const auto qual_cf = qual_to_conjunctive_form(qual);
  ra_exe_unit.simple_quals.insert(ra_exe_unit.simple_quals.end(),
                                  qual_cf.simple_quals.begin(),
                                  qual_cf.simple_quals.end());
  ra_exe_unit.quals.insert(
      ra_exe_unit.quals.end(), qual_cf.quals.begin(), qual_cf.quals.end());
}

Here is the call graph for this function:

Here is the caller graph for this function:

check_if_loop_join_is_allowed()

void anonymous_namespace{IRCodegen.cpp}::check_if_loop_join_is_allowed	(	RelAlgExecutionUnit &	ra_exe_unit,
		const ExecutionOptions &	eo,
		const std::vector< InputTableInfo > &	query_infos,
		const size_t	level_idx,
		const std::string &	fail_reason
	)

Definition at line 196 of file IRCodegen.cpp.

References ExecutionOptions::allow_loop_joins, is_trivial_loop_join(), and RelAlgExecutionUnit::join_quals.

Referenced by Executor::buildJoinLoops().

                                                                 {
  if (eo.allow_loop_joins) {
    return;
  }
  if (level_idx + 1 != ra_exe_unit.join_quals.size()) {
    throw std::runtime_error(
        "Hash join failed, reason(s): " + fail_reason +
        " | Cannot fall back to loop join for intermediate join quals");
  }
  if (!is_trivial_loop_join(query_infos, ra_exe_unit)) {
    throw std::runtime_error(
        "Hash join failed, reason(s): " + fail_reason +
        " | Cannot fall back to loop join for non-trivial inner table size");
  }
}

Here is the call graph for this function:

Here is the caller graph for this function: