OmniSciDB
a5dc49c757
|
This is the complete list of members for RelAlgExecutor, including all inherited members.
addLeafResult(const unsigned id, const AggregatedResult &result) | RelAlgExecutor | inline |
addTemporaryTable(const int table_id, const ResultSetPtr &result) | RelAlgExecutor | inlineprivate |
canUseResultsetCache(const ExecutionOptions &eo, RenderInfo *render_info) const | RelAlgExecutor | private |
cleanupPostExecution() | RelAlgExecutor | |
ColumnValidationFunction typedef | StorageIOFacility | private |
computeColRangesCache() | RelAlgExecutor | |
computeStringDictionaryGenerations() | RelAlgExecutor | |
computeTableGenerations() | RelAlgExecutor | |
computeWindow(const WorkUnit &work_unit, const CompilationOptions &co, const ExecutionOptions &eo, ColumnCacheMap &column_cache_map, const int64_t queue_time_ms) | RelAlgExecutor | private |
createAggregateWorkUnit(const RelAggregate *, const SortInfo &, const bool just_explain) | RelAlgExecutor | private |
createCompoundWorkUnit(const RelCompound *, const SortInfo &, const ExecutionOptions &eo) | RelAlgExecutor | private |
createFilterWorkUnit(const RelFilter *, const SortInfo &, const bool just_explain) | RelAlgExecutor | private |
createJoinWorkUnit(const RelJoin *, const SortInfo &, const bool just_explain) | RelAlgExecutor | private |
createProjectWorkUnit(const RelProject *, const SortInfo &, const ExecutionOptions &eo) | RelAlgExecutor | private |
createSortInputWorkUnit(const RelSort *, std::list< Analyzer::OrderEntry > &order_entries, const ExecutionOptions &eo) | RelAlgExecutor | private |
createTableFunctionWorkUnit(const RelTableFunction *table_func, const bool just_explain, const bool is_gpu) | RelAlgExecutor | private |
createUnionWorkUnit(const RelLogicalUnion *, const SortInfo &, const ExecutionOptions &eo) | RelAlgExecutor | private |
createWindowFunctionContext(const Analyzer::WindowFunction *window_func, const std::shared_ptr< Analyzer::BinOper > &partition_key_cond, std::unordered_map< QueryPlanHash, std::shared_ptr< HashJoin >> &partition_cache, std::unordered_map< QueryPlanHash, size_t > &sorted_partition_key_ref_count_map, const WorkUnit &work_unit, const std::vector< InputTableInfo > &query_infos, const CompilationOptions &co, ColumnCacheMap &column_cache_map, std::shared_ptr< RowSetMemoryOwner > row_set_mem_owner) | RelAlgExecutor | private |
createWorkUnit(const RelAlgNode *, const SortInfo &, const ExecutionOptions &eo) | RelAlgExecutor | private |
DeleteVictimOffsetList typedef | StorageIOFacility | private |
dml_transaction_parameters_ | RelAlgExecutor | private |
eraseFromTemporaryTables(const int table_id) | RelAlgExecutor | inlineprivate |
executeAggregate(const RelAggregate *aggregate, const CompilationOptions &co, const ExecutionOptions &eo, RenderInfo *render_info, const int64_t queue_time_ms) | RelAlgExecutor | private |
executeCompound(const RelCompound *, const CompilationOptions &, const ExecutionOptions &, RenderInfo *, const int64_t queue_time_ms) | RelAlgExecutor | private |
executeDelete(const RelAlgNode *node, const CompilationOptions &co, const ExecutionOptions &eo_in, const int64_t queue_time_ms) | RelAlgExecutor | private |
executeFilter(const RelFilter *, const CompilationOptions &, const ExecutionOptions &, RenderInfo *, const int64_t queue_time_ms) | RelAlgExecutor | private |
executeLogicalValues(const RelLogicalValues *, const ExecutionOptions &) | RelAlgExecutor | private |
executeModify(const RelModify *modify, const ExecutionOptions &eo) | RelAlgExecutor | private |
executePostExecutionCallback() | RelAlgExecutor | |
executeProject(const RelProject *, const CompilationOptions &, const ExecutionOptions &, RenderInfo *, const int64_t queue_time_ms, const std::optional< size_t > previous_count) | RelAlgExecutor | private |
executeRelAlgQuery(const CompilationOptions &co, const ExecutionOptions &eo, const bool just_explain_plan, const bool explain_verbose, RenderInfo *render_info) | RelAlgExecutor | |
executeRelAlgQueryNoRetry(const CompilationOptions &co, const ExecutionOptions &eo, const bool just_explain_plan, const bool explain_verbose, RenderInfo *render_info) | RelAlgExecutor | private |
executeRelAlgQuerySingleStep(const RaExecutionSequence &seq, const size_t step_idx, const CompilationOptions &co, const ExecutionOptions &eo, RenderInfo *render_info) | RelAlgExecutor | |
executeRelAlgQueryWithFilterPushDown(const RaExecutionSequence &seq, const CompilationOptions &co, const ExecutionOptions &eo, RenderInfo *render_info, const int64_t queue_time_ms) | RelAlgExecutor | |
executeRelAlgSeq(const RaExecutionSequence &seq, const CompilationOptions &co, const ExecutionOptions &eo, RenderInfo *render_info, const int64_t queue_time_ms, const bool with_existing_temp_tables=false) | RelAlgExecutor | |
executeRelAlgStep(const RaExecutionSequence &seq, const size_t step_idx, const CompilationOptions &, const ExecutionOptions &, RenderInfo *, const int64_t queue_time_ms) | RelAlgExecutor | private |
executeRelAlgSubSeq(const RaExecutionSequence &seq, const std::pair< size_t, size_t > interval, const CompilationOptions &co, const ExecutionOptions &eo, RenderInfo *render_info, const int64_t queue_time_ms) | RelAlgExecutor | |
executeSimpleInsert(const Analyzer::Query &insert_query, Fragmenter_Namespace::InsertDataLoader &inserter, const Catalog_Namespace::SessionInfo &session) | RelAlgExecutor | |
executeSort(const RelSort *, const CompilationOptions &, const ExecutionOptions &, RenderInfo *, const int64_t queue_time_ms) | RelAlgExecutor | private |
executeTableFunction(const RelTableFunction *, const CompilationOptions &, const ExecutionOptions &, const int64_t queue_time_ms) | RelAlgExecutor | private |
executeUnion(const RelLogicalUnion *, const RaExecutionSequence &, const CompilationOptions &, const ExecutionOptions &, RenderInfo *, const int64_t queue_time_ms) | RelAlgExecutor | private |
executeUpdate(const RelAlgNode *node, const CompilationOptions &co, const ExecutionOptions &eo, const int64_t queue_time_ms) | RelAlgExecutor | private |
executeWorkUnit(const WorkUnit &work_unit, const std::vector< TargetMetaInfo > &targets_meta, const bool is_agg, const CompilationOptions &co_in, const ExecutionOptions &eo_in, RenderInfo *, const int64_t queue_time_ms, const std::optional< size_t > previous_count=std::nullopt) | RelAlgExecutor | private |
executor_ | RelAlgExecutor | private |
getErrorMessageFromCode(const int32_t error_code) | RelAlgExecutor | static |
getExecutor() const | RelAlgExecutor | |
getFilteredCountAll(const RelAlgExecutionUnit &ra_exe_unit, const bool is_agg, const CompilationOptions &co, const ExecutionOptions &eo) | RelAlgExecutor | private |
getFilterSelectivity(const std::vector< std::shared_ptr< Analyzer::Expr >> &filter_expressions, const CompilationOptions &co, const ExecutionOptions &eo) | RelAlgExecutor | private |
getGlobalQueryHint() | RelAlgExecutor | inline |
getJoinInfo(const RelAlgNode *root_node) | RelAlgExecutor | |
getLeftDeepJoinTreesInfo() | RelAlgExecutor | inlineprivate |
getNDVEstimation(const WorkUnit &work_unit, const int64_t range, const bool is_agg, const CompilationOptions &co, const ExecutionOptions &eo) | RelAlgExecutor | private |
getOuterFragmentCount(const CompilationOptions &co, const ExecutionOptions &eo) | RelAlgExecutor | |
getOwnedRelAlgDag() | RelAlgExecutor | inline |
getParsedQueryHint(const RelAlgNode *node) | RelAlgExecutor | inline |
getParsedQueryHints() | RelAlgExecutor | inline |
getPhysicalTableIds() const | RelAlgExecutor | |
getRaExecutionSequence(const RelAlgNode *root_node, Executor *executor) | RelAlgExecutor | inline |
getRelAlgDag() | RelAlgExecutor | inline |
getRelAlgTranslator(const RelAlgNode *root_node) | RelAlgExecutor | |
getRootRelAlgNode() const | RelAlgExecutor | inline |
getRootRelAlgNodeShPtr() const | RelAlgExecutor | inline |
getSubqueries() const noexcept | RelAlgExecutor | inline |
handleNop(RaExecutionDesc &ed) | RelAlgExecutor | private |
handleOutOfMemoryRetry(const RelAlgExecutor::WorkUnit &work_unit, ColumnCacheMap &column_cache, const std::vector< TargetMetaInfo > &targets_meta, const bool is_agg, const CompilationOptions &co, const ExecutionOptions &eo, RenderInfo *render_info, const QueryExecutionError &e, const int64_t queue_time_ms) | RelAlgExecutor | private |
handlePersistentError(const int32_t error_code) | RelAlgExecutor | privatestatic |
has_step_for_union_ | RelAlgExecutor | private |
hasDeletedRowInQuery(std::vector< InputTableInfo > const &) const | RelAlgExecutor | private |
hasStepForUnion() const | RelAlgExecutor | inlineprivate |
initializeParallelismHints() | RelAlgExecutor | private |
isRowidLookup(const WorkUnit &work_unit) | RelAlgExecutor | private |
leaf_results_ | RelAlgExecutor | private |
left_deep_join_info_ | RelAlgExecutor | private |
makeJoinQuals(const RexScalar *join_condition, const std::vector< JoinType > &join_types, const std::unordered_map< const RelAlgNode *, int > &input_to_nest_level, const bool just_explain) const | RelAlgExecutor | private |
now_ | RelAlgExecutor | private |
PendingExecutionClosure class | RelAlgExecutor | friend |
post_execution_callback_ | RelAlgExecutor | private |
prepareForeignTable() | RelAlgExecutor | |
prepareForeignTables() | RelAlgExecutor | |
prepareForSystemTableExecution(const CompilationOptions &co) const | RelAlgExecutor | |
prepareLeafExecution(const AggregatedColRange &agg_col_range, const StringDictionaryGenerations &string_dictionary_generations, const TableGenerations &table_generations) | RelAlgExecutor | |
query_dag_ | RelAlgExecutor | private |
query_state_ | RelAlgExecutor | private |
queue_time_ms_ | RelAlgExecutor | private |
RelAlgExecutor(Executor *executor, std::shared_ptr< const query_state::QueryState > query_state=nullptr) | RelAlgExecutor | inline |
RelAlgExecutor(Executor *executor, const std::string &query_ra, std::shared_ptr< const query_state::QueryState > query_state=nullptr) | RelAlgExecutor | inline |
RelAlgExecutor(Executor *executor, std::unique_ptr< RelAlgDag > query_dag, std::shared_ptr< const query_state::QueryState > query_state=nullptr) | RelAlgExecutor | inline |
selectFiltersToBePushedDown(const RelAlgExecutor::WorkUnit &work_unit, const CompilationOptions &co, const ExecutionOptions &eo) | RelAlgExecutor | private |
setHasStepForUnion(bool flag) | RelAlgExecutor | inlineprivate |
setupCaching(const RelAlgNode *ra) | RelAlgExecutor | private |
speculative_topn_blacklist_ | RelAlgExecutor | privatestatic |
StorageIOFacility(Executor *executor) | StorageIOFacility | inlineprivate |
TableDescriptorType typedef | StorageIOFacility | private |
target_exprs_owned_ | RelAlgExecutor | private |
TargetInfoList typedef | RelAlgExecutor | |
temporary_tables_ | RelAlgExecutor | private |
TransactionLog typedef | StorageIOFacility | private |
TransactionLogPtr typedef | StorageIOFacility | private |
translateLeftDeepJoinFilter(const RelLeftDeepInnerJoin *join, const std::vector< InputDescriptor > &input_descs, const std::unordered_map< const RelAlgNode *, int > &input_to_nest_level, const bool just_explain) | RelAlgExecutor | private |
UpdateCallback typedef | StorageIOFacility | private |
UpdateTargetColumnNamesList typedef | StorageIOFacility | private |
UpdateTargetOffsetList typedef | StorageIOFacility | private |
UpdateTargetTypeList typedef | StorageIOFacility | private |
yieldDeleteCallback(DeleteTransactionParameters &delete_parameters) | StorageIOFacility | inlineprivate |
yieldUpdateCallback(UpdateTransactionParameters &update_parameters) | StorageIOFacility | inlineprivate |