OmniSciDB  72c90bc290
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
QueryRunner::anonymous_namespace{QueryRunner.cpp} Namespace Reference

Functions

std::shared_ptr< ExecutionResultrun_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 820 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().

827  {
828  auto& cat = query_state_proxy->getConstSessionInfo()->getCatalog();
831  co.explain_type = explain_type;
832 
835  eo.just_explain = just_explain;
836  eo.allow_loop_joins = allow_loop_joins;
837  eo.find_push_down_candidates = with_filter_push_down;
839 
840  auto calcite_mgr = cat.getCalciteMgr();
841  const auto calciteQueryParsingOption =
842  calcite_mgr->getCalciteQueryParsingOption(true, false, true, false);
843  auto calciteOptimizationOption =
844  calcite_mgr->getCalciteOptimizationOption(false, g_enable_watchdog, {}, false);
845  const auto query_ra = calcite_mgr
846  ->process(query_state_proxy,
847  pg_shim(query_state_proxy->getQueryStr()),
848  calciteQueryParsingOption,
849  calciteOptimizationOption)
850  .plan_result;
851  auto ra_executor = RelAlgExecutor(executor.get(), query_ra);
852  auto result = std::make_shared<ExecutionResult>(
853  ra_executor.executeRelAlgQuery(co, eo, false, false, nullptr));
854  const auto& filter_push_down_requests = result->getPushedDownFilterInfo();
855  if (!filter_push_down_requests.empty()) {
856  std::vector<TFilterPushDownInfo> filter_push_down_info;
857  for (const auto& req : filter_push_down_requests) {
858  TFilterPushDownInfo filter_push_down_info_for_request;
859  filter_push_down_info_for_request.input_prev = req.input_prev;
860  filter_push_down_info_for_request.input_start = req.input_start;
861  filter_push_down_info_for_request.input_next = req.input_next;
862  filter_push_down_info.push_back(filter_push_down_info_for_request);
863  }
864  calciteOptimizationOption.filter_push_down_info = filter_push_down_info;
865  const auto new_query_ra = calcite_mgr
866  ->process(query_state_proxy,
867  pg_shim(query_state_proxy->getQueryStr()),
868  calciteQueryParsingOption,
869  calciteOptimizationOption)
870  .plan_result;
871  auto eo_modified = eo;
872  eo_modified.find_push_down_candidates = false;
873  eo_modified.just_calcite_explain = false;
874  auto new_ra_executor = RelAlgExecutor(executor.get(), new_query_ra);
875  return std::make_shared<ExecutionResult>(
876  new_ra_executor.executeRelAlgQuery(co, eo_modified, false, false, nullptr));
877  } else {
878  return result;
879  }
880 }
std::string cat(Ts &&...args)
std::string const & getQueryStr() const
Definition: QueryState.h:159
static std::shared_ptr< Executor > getExecutor(const ExecutorId id, const std::string &debug_dir="", const std::string &debug_file="", const SystemParameters &system_parameters=SystemParameters())
Definition: Execute.cpp:509
bool g_enable_columnar_output
Definition: Execute.cpp:102
ExecutorExplainType explain_type
bool g_enable_watchdog
double g_gpu_mem_limit_percent
Definition: QueryRunner.cpp:56
static CompilationOptions defaults(const ExecutorDeviceType device_type=ExecutorDeviceType::GPU)
double gpu_input_mem_limit_percent
static constexpr ExecutorId UNITARY_EXECUTOR_ID
Definition: Execute.h:423
static ExecutionOptions defaults()
std::shared_ptr< Catalog_Namespace::SessionInfo const > getConstSessionInfo() const
Definition: QueryState.cpp:84
std::string pg_shim(const std::string &query)

+ Here is the call graph for this function:

+ Here is the caller graph for this function: