QueryRunner::anonymous_namespace{QueryRunner.cpp} Namespace Reference

Functions
std::shared_ptr< ExecutionResult >	run_select_query_with_filter_push_down (QueryStateProxy query_state_proxy, const ExecutorDeviceType device_type, const bool hoist_literals, const bool allow_loop_joins, const bool just_explain, const ExecutorExplainType explain_type, const bool with_filter_push_down)

Function Documentation

std::shared_ptr<ExecutionResult> QueryRunner::anonymous_namespace{QueryRunner.cpp}::run_select_query_with_filter_push_down	(	QueryStateProxy	query_state_proxy,
		const ExecutorDeviceType	device_type,
		const bool	hoist_literals,
		const bool	allow_loop_joins,
		const bool	just_explain,
		const ExecutorExplainType	explain_type,
		const bool	with_filter_push_down
	)

Definition at line 789 of file QueryRunner.cpp.

References ExecutionOptions::allow_loop_joins, cat(), CompilationOptions::defaults(), ExecutionOptions::defaults(), CompilationOptions::explain_type, ExecutionOptions::find_push_down_candidates, g_enable_columnar_output, g_enable_watchdog, g_gpu_mem_limit_percent, query_state::QueryState::getConstSessionInfo(), Executor::getExecutor(), query_state::QueryState::getQueryStr(), ExecutionOptions::gpu_input_mem_limit_percent, ExecutionOptions::just_explain, ExecutionOptions::output_columnar_hint, pg_shim(), run_benchmark_import::result, and Executor::UNITARY_EXECUTOR_ID.

Referenced by QueryRunner::QueryRunner::runSelectQuery().

                                      {
  auto& cat = query_state_proxy->getConstSessionInfo()->getCatalog();
  auto executor = Executor::getExecutor(Executor::UNITARY_EXECUTOR_ID);
  CompilationOptions co = CompilationOptions::defaults(device_type);
  co.explain_type = explain_type;

  ExecutionOptions eo = ExecutionOptions::defaults();
  eo.output_columnar_hint = g_enable_columnar_output;
  eo.just_explain = just_explain;
  eo.allow_loop_joins = allow_loop_joins;
  eo.find_push_down_candidates = with_filter_push_down;
  eo.gpu_input_mem_limit_percent = g_gpu_mem_limit_percent;

  auto calcite_mgr = cat.getCalciteMgr();
  const auto calciteQueryParsingOption =
      calcite_mgr->getCalciteQueryParsingOption(true, false, true);
  auto calciteOptimizationOption =
      calcite_mgr->getCalciteOptimizationOption(false, g_enable_watchdog, {}, false);
  const auto query_ra = calcite_mgr
                            ->process(query_state_proxy,
                                      pg_shim(query_state_proxy->getQueryStr()),
                                      calciteQueryParsingOption,
                                      calciteOptimizationOption)
                            .plan_result;
  auto ra_executor = RelAlgExecutor(executor.get(), query_ra);
  auto result = std::make_shared<ExecutionResult>(
      ra_executor.executeRelAlgQuery(co, eo, false, nullptr));
  const auto& filter_push_down_requests = result->getPushedDownFilterInfo();
  if (!filter_push_down_requests.empty()) {
    std::vector<TFilterPushDownInfo> filter_push_down_info;
    for (const auto& req : filter_push_down_requests) {
      TFilterPushDownInfo filter_push_down_info_for_request;
      filter_push_down_info_for_request.input_prev = req.input_prev;
      filter_push_down_info_for_request.input_start = req.input_start;
      filter_push_down_info_for_request.input_next = req.input_next;
      filter_push_down_info.push_back(filter_push_down_info_for_request);
    }
    calciteOptimizationOption.filter_push_down_info = filter_push_down_info;
    const auto new_query_ra = calcite_mgr
                                  ->process(query_state_proxy,
                                            pg_shim(query_state_proxy->getQueryStr()),
                                            calciteQueryParsingOption,
                                            calciteOptimizationOption)
                                  .plan_result;
    auto eo_modified = eo;
    eo_modified.find_push_down_candidates = false;
    eo_modified.just_calcite_explain = false;
    auto new_ra_executor = RelAlgExecutor(executor.get(), new_query_ra);
    return std::make_shared<ExecutionResult>(
        new_ra_executor.executeRelAlgQuery(co, eo_modified, false, nullptr));
  } else {
    return result;
  }
}

Here is the call graph for this function:

Here is the caller graph for this function: