OmniSciDB  72c90bc290
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
Executor Member List

This is the complete list of members for Executor, including all inherited members.

acquireExecuteMutex()Executorinlineprivate
active_window_function_Executorprivate
addDeletedColumn(const RelAlgExecutionUnit &ra_exe_unit, const CompilationOptions &co)Executorprivate
addJoinLoopIterator(const std::vector< llvm::Value * > &prev_iters, const size_t level_idx)Executorprivate
addToCardinalityCache(const CardinalityCacheKey &cache_key, const size_t cache_value)Executor
addToQuerySessionList(const QuerySessionId &query_session, const std::string &query_str, const std::string &submitted, const size_t executor_id, const QuerySessionStatus::QueryStatus query_status, heavyai::unique_lock< heavyai::shared_mutex > &write_lock)Executor
addTransientStringLiterals(const RelAlgExecutionUnit &ra_exe_unit, const std::shared_ptr< RowSetMemoryOwner > &row_set_mem_owner)Executor
addUdfIrToModule(const std::string &udf_ir_filename, const bool is_cuda_ir)Executorstatic
agg_col_range_cache_Executorprivate
aggregateWindowStatePtr(CodeGenerator *code_generator, const CompilationOptions &co)Executorprivate
align(const size_t off_in, const size_t alignment)Executorinlineprivatestatic
attachExecutorToQuerySession(const QuerySessionId &query_session_id, const std::string &query_str, const std::string &query_submitted_time)Executor
auto_cpu_mem_bytesExecutorstatic
auto_num_threadsExecutorprivatestatic
AutoTrackBuffersInRuntimeIR()Executorprivate
baseline_thresholdExecutorprivatestatic
BaselineJoinHashTable classExecutorfriend
block_size_x_Executorprivate
blockSize() const Executor
BoundingBoxIntersectJoinHashTable classExecutorfriend
buildCurrentLevelHashTable(const JoinCondition &current_level_join_conditions, size_t level_idx, RelAlgExecutionUnit &ra_exe_unit, const CompilationOptions &co, const std::vector< InputTableInfo > &query_infos, ColumnCacheMap &column_cache, std::vector< std::string > &fail_reasons)Executorprivate
buildHashTableForQualifier(const std::shared_ptr< Analyzer::BinOper > &qual_bin_oper, const std::vector< InputTableInfo > &query_infos, const MemoryLevel memory_level, const JoinType join_type, const HashType preferred_hash_type, ColumnCacheMap &column_cache, const HashTableBuildDagMap &hashtable_build_dag_map, const RegisteredQueryHint &query_hint, const TableIdToNodeMap &table_id_to_node_map)Executorprivate
buildHoistLeftHandSideFiltersCb(const RelAlgExecutionUnit &ra_exe_unit, const size_t level_idx, const shared::TableKey &inner_table_key, const CompilationOptions &co)Executorprivate
buildIsDeletedCb(const RelAlgExecutionUnit &ra_exe_unit, const size_t level_idx, const CompilationOptions &co)Executorprivate
buildJoinLoops(RelAlgExecutionUnit &ra_exe_unit, const CompilationOptions &co, const ExecutionOptions &eo, const std::vector< InputTableInfo > &query_infos, ColumnCacheMap &column_cache)Executorprivate
buildSelectedFragsMapping(std::vector< std::vector< size_t >> &selected_fragments_crossjoin, std::vector< size_t > &local_col_to_frag_pos, const std::list< std::shared_ptr< const InputColDescriptor >> &col_global_ids, const FragmentsList &selected_fragments, const RelAlgExecutionUnit &ra_exe_unit)Executorprivate
buildSelectedFragsMappingForUnion(std::vector< std::vector< size_t >> &selected_fragments_crossjoin, const FragmentsList &selected_fragments, const RelAlgExecutionUnit &ra_exe_unit)Executorprivate
CachedCardinality typedefExecutor
canSkipFragmentForFpQual(const Analyzer::BinOper *comp_expr, const Analyzer::ColumnVar *lhs_col, const Fragmenter_Namespace::FragmentInfo &fragment, const Analyzer::Constant *rhs_const) const Executorprivate
cardinality_cache_Executorprivatestatic
castToFP(llvm::Value *, SQLTypeInfo const &from_ti, SQLTypeInfo const &to_ti)Executorprivate
castToIntPtrTyIn(llvm::Value *val, const size_t bit_width)Executorprivate
cgen_state_Executorprivate
checkCurrentQuerySession(const std::string &candidate_query_session, heavyai::shared_lock< heavyai::shared_mutex > &read_lock)Executor
checkIsQuerySessionEnrolled(const QuerySessionId &query_session, heavyai::shared_lock< heavyai::shared_mutex > &read_lock)Executor
checkIsQuerySessionInterrupted(const std::string &query_session, heavyai::shared_lock< heavyai::shared_mutex > &read_lock)Executor
checkNonKernelTimeInterrupted() const Executor
checkPendingQueryStatus(const QuerySessionId &query_session)Executor
clearCaches(bool runtime_only=false)Executor
clearCardinalityCache()Executorstatic
clearExternalCaches(bool for_update, const TableDescriptor *td, const int current_db_id)Executorinlinestatic
clearMemory(const Data_Namespace::MemoryLevel memory_level)Executorstatic
clearMetaInfoCache()Executorprivate
clearQuerySessionStatus(const QuerySessionId &query_session, const std::string &submitted_time_str)Executor
codegenAggregateWindowState(CodeGenerator *code_generator, const CompilationOptions &co, llvm::Value *aggregate_state)Executorprivate
codegenConditionalAggregateCondValSelector(llvm::Value *cond_lv, SQLAgg const aggKind, CompilationOptions const &co) const Executorprivate
codegenCurrentPartitionIndex(const WindowFunctionContext *window_func_context, CodeGenerator *code_generator, const CompilationOptions &co, llvm::Value *current_row_pos_lv)Executorprivate
CodeGenerator classExecutorfriend
codegenFrameBound(bool for_start_bound, bool for_range_mode, bool for_window_frame_naviation, const Analyzer::WindowFrame *frame_bound, bool is_timestamp_type_frame, llvm::Value *order_key_null_val, const WindowFrameBoundFuncArgs &args)Executorprivate
codegenFrameBoundExpr(const Analyzer::WindowFunction *window_func, const Analyzer::WindowFrame *frame_bound, CodeGenerator &code_generator, const CompilationOptions &co)Executorprivate
codegenFrameBoundRange(const Analyzer::WindowFunction *window_func, CodeGenerator &code_generator, const CompilationOptions &co)Executorprivate
codegenFrameNullRange(WindowFunctionContext *window_func_context, CodeGenerator *code_generator, const CompilationOptions &co, llvm::Value *partition_index_lv) const Executorprivate
codegenJoinLoops(const std::vector< JoinLoop > &join_loops, const RelAlgExecutionUnit &ra_exe_unit, GroupByAndAggregate &group_by_and_aggregate, llvm::Function *query_func, llvm::BasicBlock *entry_bb, QueryMemoryDescriptor &query_mem_desc, const CompilationOptions &co, const ExecutionOptions &eo)Executorprivate
codegenLoadCurrentValueFromColBuf(WindowFunctionContext *window_func_context, CodeGenerator &code_generator, WindowFrameBoundFuncArgs &args) const Executorprivate
codegenLoadOrderKeyBufPtr(WindowFunctionContext *window_func_context, CodeGenerator *code_generator, const CompilationOptions &co) const Executorprivate
codegenLoadPartitionBuffers(WindowFunctionContext *window_func_context, CodeGenerator *code_generator, const CompilationOptions &co, llvm::Value *partition_index_lv) const Executorprivate
codegenSkipDeletedOuterTableRow(const RelAlgExecutionUnit &ra_exe_unit, const CompilationOptions &co)Executorprivate
codegenWindowAvgEpilogue(CodeGenerator *code_generator, const CompilationOptions &co, llvm::Value *crt_val, llvm::Value *window_func_null_val)Executorprivate
codegenWindowFrameBounds(WindowFunctionContext *window_func_context, const Analyzer::WindowFrame *frame_start_bound, const Analyzer::WindowFrame *frame_end_bound, llvm::Value *order_key_col_null_val_lv, WindowFrameBoundFuncArgs &args, CodeGenerator &code_generator)Executorprivate
codegenWindowFunction(const size_t target_index, const CompilationOptions &co)Executorprivate
codegenWindowFunctionAggregate(CodeGenerator *code_generator, const CompilationOptions &co)Executorprivate
codegenWindowFunctionAggregateCalls(llvm::Value *aggregate_state, const CompilationOptions &co)Executorprivate
codegenWindowFunctionStateInit(CodeGenerator *code_generator, const CompilationOptions &co, llvm::Value *aggregate_state)Executorprivate
codegenWindowNavigationFunctionOnFrame(const CompilationOptions &co)Executorprivate
codegenWindowResetStateControlFlow(CodeGenerator *code_generator, const CompilationOptions &co)Executorprivate
collectAllDeviceResults(SharedKernelContext &shared_context, const RelAlgExecutionUnit &ra_exe_unit, const QueryMemoryDescriptor &query_mem_desc, const ExecutorDeviceType device_type, std::shared_ptr< RowSetMemoryOwner > row_set_mem_owner)Executorprivate
collectAllDeviceShardedTopResults(SharedKernelContext &shared_context, const RelAlgExecutionUnit &ra_exe_unit, const ExecutorDeviceType device_type) const Executorprivate
ColumnFetcher classExecutorfriend
compilation_mutex_Executor
compilation_queue_time_ms_Executorprivate
compileBody(const RelAlgExecutionUnit &ra_exe_unit, GroupByAndAggregate &group_by_and_aggregate, QueryMemoryDescriptor &query_mem_desc, const CompilationOptions &co, const GpuSharedMemoryContext &gpu_smem_context={})Executorprivate
compileWorkUnit(const std::vector< InputTableInfo > &query_infos, const PlanState::DeletedColumnsMap &deleted_cols_map, const RelAlgExecutionUnit &ra_exe_unit, const CompilationOptions &co, const ExecutionOptions &eo, const CudaMgr_Namespace::CudaMgr *cuda_mgr, const bool allow_lazy_fetch, std::shared_ptr< RowSetMemoryOwner >, const size_t max_groups_buffer_entry_count, const int8_t crt_min_byte_width, const bool has_cardinality_estimation, ColumnCacheMap &column_cache, RenderInfo *render_info=nullptr)Executorprivate
computeColRangesCache(const std::unordered_set< PhysicalInput > &phys_inputs)Executorprivate
computeStringDictionaryGenerations(const std::unordered_set< PhysicalInput > &phys_inputs)Executorprivate
computeTableGenerations(const std::unordered_set< shared::TableKey > &phys_table_keys)Executorprivate
containsLeftDeepOuterJoin() const Executorinline
context_Executorprivate
createErrorCheckControlFlow(llvm::Function *query_func, bool run_with_dynamic_watchdog, bool run_with_allowing_runtime_interrupt, const std::vector< JoinLoop > &join_loops, ExecutorDeviceType device_type, const std::vector< InputTableInfo > &input_table_infos)Executorprivate
createKernels(SharedKernelContext &shared_context, const RelAlgExecutionUnit &ra_exe_unit, ColumnFetcher &column_fetcher, const std::vector< InputTableInfo > &table_infos, const ExecutionOptions &eo, const bool is_agg, const bool allow_single_frag_table_opt, const size_t context_count, const QueryCompilationDescriptor &query_comp_desc, const QueryMemoryDescriptor &query_mem_desc, RenderInfo *render_info, std::unordered_set< int > &available_gpus, int &available_cpus)Executorprivate
cudaMgr() const Executorinlineprivate
current_query_session_Executorprivate
data_mgr_Executorprivate
debug_dir_Executorprivate
debug_file_Executorprivate
deviceCount(const ExecutorDeviceType) const Executor
deviceCountForMemoryLevel(const Data_Namespace::MemoryLevel memory_level) const Executorprivate
deviceCycles(int milliseconds) const Executorprivate
DiamondCodegenExecutorfriend
dumpCache() const Executor
enableRuntimeQueryInterrupt(const double runtime_query_check_freq, const unsigned pending_query_check_freq) const Executor
enrollQuerySession(const QuerySessionId &query_session, const std::string &query_str, const std::string &submitted_time_str, const size_t executor_id, const QuerySessionStatus::QueryStatus query_session_status)Executor
ERR_COLUMNAR_CONVERSION_NOT_SUPPORTEDExecutorstatic
ERR_DIV_BY_ZEROExecutorstatic
ERR_GEOSExecutorstatic
ERR_INTERRUPTEDExecutorstatic
ERR_OUT_OF_CPU_MEMExecutorstatic
ERR_OUT_OF_GPU_MEMExecutorstatic
ERR_OUT_OF_RENDER_MEMExecutorstatic
ERR_OUT_OF_SLOTSExecutorstatic
ERR_OUT_OF_TIMEExecutorstatic
ERR_OVERFLOW_OR_UNDERFLOWExecutorstatic
ERR_SINGLE_VALUE_FOUND_MULTIPLE_VALUESExecutorstatic
ERR_STREAMING_TOP_N_NOT_SUPPORTED_IN_RENDER_QUERYExecutorstatic
ERR_STRING_CONST_IN_RESULTSETExecutorstatic
ERR_TOO_MANY_LITERALSExecutorstatic
ERR_UNSUPPORTED_SELF_JOINExecutorstatic
ERR_WIDTH_BUCKET_INVALID_ARGUMENTExecutorstatic
execute_mutex_Executorprivatestatic
executeExplain(const QueryCompilationDescriptor &)Executorprivate
executePlanWithGroupBy(const RelAlgExecutionUnit &ra_exe_unit, const CompilationResult &, const bool hoist_literals, ResultSetPtr *results, const ExecutorDeviceType device_type, std::vector< std::vector< const int8_t * >> &col_buffers, const std::vector< size_t > outer_tab_frag_ids, QueryExecutionContext *, const std::vector< std::vector< int64_t >> &num_rows, const std::vector< std::vector< uint64_t >> &frag_offsets, Data_Namespace::DataMgr *, const int device_id, const shared::TableKey &outer_table_key, const int64_t limit, const uint32_t start_rowid, const uint32_t num_tables, const bool allow_runtime_interrupt, RenderInfo *render_info, const bool optimize_cuda_block_and_grid_sizes, const int64_t rows_to_process=-1)Executorprivate
executePlanWithoutGroupBy(const RelAlgExecutionUnit &ra_exe_unit, const CompilationResult &, const bool hoist_literals, ResultSetPtr *results, const std::vector< Analyzer::Expr * > &target_exprs, const ExecutorDeviceType device_type, std::vector< std::vector< const int8_t * >> &col_buffers, QueryExecutionContext *query_exe_context, const std::vector< std::vector< int64_t >> &num_rows, const std::vector< std::vector< uint64_t >> &frag_offsets, Data_Namespace::DataMgr *data_mgr, const int device_id, const uint32_t start_rowid, const uint32_t num_tables, const bool allow_runtime_interrupt, RenderInfo *render_info, const bool optimize_cuda_block_and_grid_sizes, const int64_t rows_to_process=-1)Executorprivate
executeTableFunction(const TableFunctionExecutionUnit exe_unit, const std::vector< InputTableInfo > &table_infos, const CompilationOptions &co, const ExecutionOptions &eo)Executorprivate
executeUpdate(const RelAlgExecutionUnit &ra_exe_unit, const std::vector< InputTableInfo > &table_infos, const TableDescriptor *updated_table_desc, const CompilationOptions &co, const ExecutionOptions &eo, const Catalog_Namespace::Catalog &cat, std::shared_ptr< RowSetMemoryOwner > row_set_mem_owner, const UpdateLogForFragment::Callback &cb, const bool is_agg)Executor
executeWorkUnit(size_t &max_groups_buffer_entry_guess, const bool is_agg, const std::vector< InputTableInfo > &, const RelAlgExecutionUnit &, const CompilationOptions &, const ExecutionOptions &options, RenderInfo *render_info, const bool has_cardinality_estimation, ColumnCacheMap &column_cache)Executor
executeWorkUnitImpl(size_t &max_groups_buffer_entry_guess, const bool is_agg, const bool allow_single_frag_table_opt, const std::vector< InputTableInfo > &, const RelAlgExecutionUnit &, const CompilationOptions &, const ExecutionOptions &options, std::shared_ptr< RowSetMemoryOwner >, RenderInfo *render_info, const bool has_cardinality_estimation, ColumnCacheMap &column_cache)Executorprivate
executeWorkUnitPerFragment(const RelAlgExecutionUnit &ra_exe_unit, const InputTableInfo &table_info, const CompilationOptions &co, const ExecutionOptions &eo, const Catalog_Namespace::Catalog &cat, PerFragmentCallBack &cb, const std::set< size_t > &fragment_indexes_param)Executorprivate
ExecutionKernel classExecutorfriend
Executor(const ExecutorId id, Data_Namespace::DataMgr *data_mgr, const size_t block_size_x, const size_t grid_size_x, const size_t max_gpu_slab_size, const std::string &debug_dir, const std::string &debug_file)Executor
executor_id_Executorprivate
executor_resource_mgr_Executorstatic
executor_session_mutex_Executorprivatestatic
ExecutorId typedefExecutor
executors_Executorprivatestatic
executors_cache_mutex_Executorprivatestatic
extension_module_sourcesExecutorstatic
extension_modules_Executorprivate
ExtModuleKinds enum nameExecutor
fetchChunks(const ColumnFetcher &, const RelAlgExecutionUnit &ra_exe_unit, const int device_id, const Data_Namespace::MemoryLevel, const std::map< shared::TableKey, const TableFragments * > &, const FragmentsList &selected_fragments, std::list< ChunkIter > &, std::list< std::shared_ptr< Chunk_NS::Chunk >> &, DeviceAllocator *device_allocator, const size_t thread_idx, const bool allow_runtime_interrupt)Executorprivate
fetchUnionChunks(const ColumnFetcher &, const RelAlgExecutionUnit &ra_exe_unit, const int device_id, const Data_Namespace::MemoryLevel, const std::map< shared::TableKey, const TableFragments * > &, const FragmentsList &selected_fragments, std::list< ChunkIter > &, std::list< std::shared_ptr< Chunk_NS::Chunk >> &, DeviceAllocator *device_allocator, const size_t thread_idx, const bool allow_runtime_interrupt)Executorprivate
generatePTX(const std::string &) const Executorprivate
get_concurrent_resource_grant_policy(const ExecutorResourceMgr_Namespace::ResourceType resource_type)Executorstatic
get_executor_resource_pool_info()Executorstatic
get_executor_resource_pool_total_resource_quantity(const ExecutorResourceMgr_Namespace::ResourceType resource_type)Executorstatic
get_extension_module(ExtModuleKinds kind) const Executorinlineprivate
get_geos_module() const Executorinline
get_libdevice_module() const Executorinline
get_rt_module() const Executorinline
get_rt_udf_module(bool is_gpu=false) const Executorinline
get_udf_module(bool is_gpu=false) const Executorinline
getArenaBlockSize()Executorstatic
getBaselineThreshold(bool for_count_distinct, ExecutorDeviceType device_type)Executorinlinestatic
getCachedCardinality(const CardinalityCacheKey &cache_key)Executor
getCgenStatePtr() const Executorinline
getChunkRequestInfo(const ExecutorDeviceType device_type, const std::vector< InputDescriptor > &input_descs, const std::vector< InputTableInfo > &query_infos, const std::vector< std::pair< int32_t, FragmentsList >> &device_fragment_lists) const Executor
getColLazyFetchInfo(const std::vector< Analyzer::Expr * > &target_exprs) const Executor
getColRange(const PhysicalInput &) const Executor
getColumnByteWidthMap(const std::set< shared::TableKey > &table_ids_to_fetch, const bool include_lazy_fetched_cols) const Executor
getColumnDescriptor(const Analyzer::ColumnVar *) const Executor
getContext()Executorinline
getCurrentQuerySession(heavyai::shared_lock< heavyai::shared_mutex > &read_lock)Executor
getDataMgr() const Executorinline
getDataRecyclerLock()Executor
getDeviceTypeForTargets(const RelAlgExecutionUnit &ra_exe_unit, const ExecutorDeviceType requested_device_type)Executorprivate
getExecutor(const ExecutorId id, const std::string &debug_dir="", const std::string &debug_file="", const SystemParameters &system_parameters=SystemParameters())Executorstatic
getExecutorId() const Executorinline
getExecutorIdsRunningQuery(const QuerySessionId &interrupt_session) const Executor
getFirstOrderColTypeInfo(WindowFunctionContext *window_func_context) const Executorprivate
getFragmentCount(const FragmentsList &selected_fragments, const size_t scan_idx, const RelAlgExecutionUnit &ra_exe_unit)Executorprivate
getFramingFuncName(const std::string &bound_type, const std::string &order_col_type, const std::string &op_type, bool for_timestamp_type) const Executorprivate
getInnerTabIdToJoinCond() const Executorprivate
getJoinHashTablePtrs(const ExecutorDeviceType device_type, const int device_id)Executorprivate
getJoinIntersectionStringProxyTranslationMap(const StringDictionaryProxy *source_proxy, StringDictionaryProxy *dest_proxy, const std::vector< StringOps_Namespace::StringOpInfo > &source_string_op_infos, const std::vector< StringOps_Namespace::StringOpInfo > &dest_source_string_op_infos, std::shared_ptr< RowSetMemoryOwner > row_set_mem_owner) const Executor
getLatestQueryPlanDagExtracted() const Executor
getNumBytesForFetchedRow(const std::set< shared::TableKey > &table_keys_to_fetch) const Executor
getNumBytesForFetchedRow(const std::set< int > &table_ids_to_fetch) const Executor
getNumCurentSessionsEnrolled() const Executor
getOrderKeySize(WindowFunctionContext *window_func_context) const Executorprivate
getOrderKeyTypeName(WindowFunctionContext *window_func_context) const Executorprivate
getPhysicalColumnDescriptor(const Analyzer::ColumnVar *, int) const Executor
getPlanStatePtr() const Executorinline
getQueryPlanDagCache()Executor
getQuerySessionInfo(const QuerySessionId &query_session, heavyai::shared_lock< heavyai::shared_mutex > &read_lock)Executor
getQuerySessionStatus(const QuerySessionId &candidate_query_session, heavyai::shared_lock< heavyai::shared_mutex > &read_lock)Executor
getResultSetRecyclerHolder()Executor
getRowCountAndOffsetForAllFrags(const RelAlgExecutionUnit &ra_exe_unit, const CartesianProduct< std::vector< std::vector< size_t >>> &frag_ids_crossjoin, const std::vector< InputDescriptor > &input_descs, const std::map< shared::TableKey, const TableFragments * > &all_tables_fragments)Executorprivate
getRowSetMemoryOwner() const Executor
getSessionLock()Executor
getStringDictionaryProxy(const shared::StringDictKey &dict_key, const bool with_generation) const Executorinline
getStringDictionaryProxy(const shared::StringDictKey &dict_key, const std::shared_ptr< RowSetMemoryOwner > row_set_mem_owner, const bool with_generation) const Executor
getStringProxyNumericTranslationMap(const shared::StringDictKey &source_dict_key, const std::vector< StringOps_Namespace::StringOpInfo > &string_op_infos, std::shared_ptr< RowSetMemoryOwner > row_set_mem_owner, const bool with_generation) const Executor
getStringProxyTranslationMap(const shared::StringDictKey &source_dict_key, const shared::StringDictKey &dest_dict_key, const RowSetMemoryOwner::StringTranslationType translation_type, const std::vector< StringOps_Namespace::StringOpInfo > &string_op_infos, std::shared_ptr< RowSetMemoryOwner > row_set_mem_owner, const bool with_generation) const Executor
getTableFragmentIndices(const RelAlgExecutionUnit &ra_exe_unit, const ExecutorDeviceType device_type, const size_t table_idx, const size_t outer_frag_idx, std::map< shared::TableKey, const TableFragments * > &selected_tables_fragments, const std::unordered_map< shared::TableKey, const Analyzer::BinOper * > &inner_table_id_to_join_condition)Executorprivate
getTableGeneration(const shared::TableKey &table_key) const Executor
getTableInfo(const shared::TableKey &table_key) const Executor
getTemporaryTables()Executorinline
getTemporaryTables() const Executor
getUniqueThreadSharedResultSets(const std::vector< std::pair< ResultSetPtr, std::vector< size_t >>> &results_per_device) const Executorprivate
gpu_active_modules_Executorprivatestatic
gpu_active_modules_device_mask_Executorprivatestatic
gpu_active_modules_mutex_Executorprivatestatic
gpu_exec_mutex_Executorprivate
grid_size_x_Executorprivate
gridSize() const Executor
GroupByAndAggregate classExecutorfriend
groupByColumnCodegen(Analyzer::Expr *group_by_col, const size_t col_width, const CompilationOptions &, const bool translate_null_val, const int64_t translated_null_val, DiamondCodegen &, std::stack< llvm::BasicBlock * > &, const bool thread_mem_shared)Executorprivate
has_extension_module(ExtModuleKinds kind) const Executorinlineprivate
has_geos_module() const Executorinline
has_libdevice_module() const Executorinline
has_rt_module() const Executorinline
has_rt_udf_module(bool is_gpu=false) const Executorinline
has_udf_module(bool is_gpu=false) const Executorinline
HashJoin classExecutorfriend
hasLazyFetchColumns(const std::vector< Analyzer::Expr * > &target_exprs) const Executor
init_resource_mgr(const size_t num_cpu_slots, const size_t num_gpu_slots, const size_t cpu_result_mem, const size_t cpu_buffer_pool_mem, const size_t gpu_buffer_pool_mem, const double per_query_max_cpu_slots_ratio, const double per_query_max_cpu_result_mem_ratio, const bool allow_cpu_kernel_concurrency, const bool allow_cpu_gpu_kernel_concurrency, const bool allow_cpu_slot_oversubscription_concurrency, const bool allow_cpu_result_mem_oversubscription, const double max_available_resource_use_ratio)Executorstatic
initialize_extension_module_sources()Executorstatic
initializeNVPTXBackend() const Executorprivate
inlineHoistedLiterals()Executorprivate
input_table_info_cache_Executormutableprivate
insertErrorCodeChecker(llvm::Function *query_func, unsigned const error_code_idx, bool hoist_literals, bool allow_runtime_query_interrupt)Executorprivate
interrupt(const QuerySessionId &query_session="", const QuerySessionId &interrupt_session="")Executor
interrupted_Executorprivate
INVALID_EXECUTOR_IDExecutorstatic
invalidateCardinalityCacheForTable(const shared::TableKey &table_key)Executorstatic
invalidateRunningQuerySession(heavyai::unique_lock< heavyai::shared_mutex > &write_lock)Executor
InValuesBitmap classExecutorfriend
isArchMaxwell(const ExecutorDeviceType dt) const Executor
isArchPascalOrLater(const ExecutorDeviceType dt) const Executorinlineprivate
isCPUOnly() const Executor
isFragmentFullyDeleted(const InputDescriptor &table_desc, const Fragmenter_Namespace::FragmentInfo &fragment)Executorprivate
kernel_mutex_Executorstatic
kernel_queue_time_ms_Executorprivate
KernelSubtask classExecutorfriend
latest_query_plan_extracted_Executorprivatestatic
launchKernelsImpl(SharedKernelContext &shared_context, std::vector< std::unique_ptr< ExecutionKernel >> &&kernels, const ExecutorDeviceType device_type, const size_t requested_num_threads)Executorprivate
launchKernelsLocked(SharedKernelContext &shared_context, std::vector< std::unique_ptr< ExecutionKernel >> &&kernels, const ExecutorDeviceType device_type)Executorprivate
launchKernelsViaResourceMgr(SharedKernelContext &shared_context, std::vector< std::unique_ptr< ExecutionKernel >> &&kernels, const ExecutorDeviceType device_type, const std::vector< InputDescriptor > &input_descs, const QueryMemoryDescriptor &query_mem_desc)Executorprivate
LeafAggregator classExecutorfriend
logSystemCPUMemoryStatus(std::string const &tag, size_t const thread_idx) const Executor
logSystemGPUMemoryStatus(std::string const &tag, size_t const thread_idx) const Executor
max_gpu_countExecutorprivatestatic
max_gpu_slab_size_Executorprivate
maxGpuSlabSize() const Executor
needFetchAllFragments(const InputColDescriptor &col_desc, const RelAlgExecutionUnit &ra_exe_unit, const FragmentsList &selected_fragments) const Executorprivate
needLinearizeAllFragments(const ColumnDescriptor *cd, const InputColDescriptor &inner_col_desc, const RelAlgExecutionUnit &ra_exe_unit, const FragmentsList &selected_fragments, const Data_Namespace::MemoryLevel memory_level) const Executorprivate
nukeCacheOfExecutors()Executorinlinestatic
nukeOldState(const bool allow_lazy_fetch, const std::vector< InputTableInfo > &query_infos, const PlanState::DeletedColumnsMap &deleted_cols_map, const RelAlgExecutionUnit *ra_exe_unit)Executorprivate
numBlocksPerMP() const Executor
nvptx_target_machine_Executormutableprivate
optimizeAndCodegenCPU(llvm::Function *, llvm::Function *, const std::unordered_set< llvm::Function * > &, const CompilationOptions &)Executorprivate
optimizeAndCodegenGPU(llvm::Function *, llvm::Function *, std::unordered_set< llvm::Function * > &, const bool no_inline, const CudaMgr_Namespace::CudaMgr *cuda_mgr, const bool is_gpu_smem_used, const CompilationOptions &)Executorprivate
pause_executor_queue()Executorstatic
PendingExecutionClosure classExecutorfriend
PerfectJoinHashTable classExecutorfriend
PerFragmentCallBack typedefExecutorprivate
plan_state_Executorprivate
preloadFragOffsets(const std::vector< InputDescriptor > &input_descs, const std::vector< InputTableInfo > &query_infos)Executorprivate
prepareRangeModeFuncArgs(bool for_start_bound, const Analyzer::WindowFrame *frame_bound, bool is_timestamp_type_frame, llvm::Value *order_key_null_val, const WindowFrameBoundFuncArgs &frame_args) const Executorprivate
prepareRowModeFuncArgs(bool for_start_bound, SqlWindowFrameBoundType bound_type, const WindowFrameBoundFuncArgs &args) const Executorprivate
queries_interrupt_flag_Executorprivatestatic
queries_session_map_Executorprivatestatic
query_plan_dag_cache_Executorprivatestatic
QueryCompilationDescriptor classExecutorfriend
QueryExecutionContext classExecutorfriend
QueryFragmentDescriptor classExecutorfriend
QueryMemoryDescriptor classExecutorfriend
QueryMemoryInitializer classExecutorfriend
QueryRewriter classExecutorfriend
RangeJoinHashTable classExecutorfriend
recycler_mutex_Executorprivatestatic
redeclareFilterFunction()Executorprivate
reduceMultiDeviceResults(const RelAlgExecutionUnit &, std::vector< std::pair< ResultSetPtr, std::vector< size_t >>> &all_fragment_results, std::shared_ptr< RowSetMemoryOwner >, const QueryMemoryDescriptor &) const Executorprivate
reduceMultiDeviceResultSets(std::vector< std::pair< ResultSetPtr, std::vector< size_t >>> &all_fragment_results, std::shared_ptr< RowSetMemoryOwner >, const QueryMemoryDescriptor &) const Executorprivate
reduceResults(const SQLAgg agg, const SQLTypeInfo &ti, const int64_t agg_init_val, const int8_t out_byte_width, const int64_t *out_vec, const size_t out_vec_sz, const bool is_group_by, const bool float_argument_input)Executorstatic
reduceSpeculativeTopN(const RelAlgExecutionUnit &, std::vector< std::pair< ResultSetPtr, std::vector< size_t >>> &all_fragment_results, std::shared_ptr< RowSetMemoryOwner >, const QueryMemoryDescriptor &) const Executorprivate
register_runtime_extension_functions_mutex_Executorstatic
registerActiveModule(void *module, const int device_id)Executorstatic
registerExtensionFunctions(F register_extension_functions)Executorinlinestatic
registerExtractedQueryPlanDag(const QueryPlanDAG &query_plan_dag)Executor
RelAlgExecutor classExecutorfriend
removeFromQuerySessionList(const QuerySessionId &query_session, const std::string &submitted_time_str, heavyai::unique_lock< heavyai::shared_mutex > &write_lock)Executor
reset(bool discard_runtime_modules_only=false)Executor
resetBlockSize()Executor
resetGridSize()Executor
resetInterrupt()Executor
ResultSet classExecutorfriend
resultset_recycler_holder_Executorprivatestatic
resultsUnion(SharedKernelContext &shared_context, const RelAlgExecutionUnit &ra_exe_unit)Executorprivate
resume_executor_queue()Executorstatic
row_set_mem_owner_Executorprivate
serializeLiterals(const std::unordered_map< int, CgenState::LiteralValues > &literals, const int device_id)Executorprivate
set_concurrent_resource_grant_policy(const ExecutorResourceMgr_Namespace::ConcurrentResourceGrantPolicy &concurrent_resource_grant_policy)Executorstatic
set_executor_resource_pool_resource(const ExecutorResourceMgr_Namespace::ResourceType resource_type, const size_t resource_quantity)Executorstatic
setBlockSize(unsigned block_size)Executor
setColRangeCache(const AggregatedColRange &aggregated_col_range)Executorinline
setGridSize(unsigned grid_size)Executor
setQuerySessionAsInterrupted(const QuerySessionId &query_session, heavyai::unique_lock< heavyai::shared_mutex > &write_lock)Executor
setupCaching(const std::unordered_set< PhysicalInput > &phys_inputs, const std::unordered_set< shared::TableKey > &phys_table_keys)Executor
skipFragment(const InputDescriptor &table_desc, const Fragmenter_Namespace::FragmentInfo &frag_info, const std::list< std::shared_ptr< Analyzer::Expr >> &simple_quals, const std::vector< uint64_t > &frag_offsets, const size_t frag_idx)Executorprivate
skipFragmentInnerJoins(const InputDescriptor &table_desc, const RelAlgExecutionUnit &ra_exe_unit, const Fragmenter_Namespace::FragmentInfo &fragment, const std::vector< uint64_t > &frag_offsets, const size_t frag_idx)Executorprivate
skipFragmentPair(const Fragmenter_Namespace::FragmentInfo &outer_fragment_info, const Fragmenter_Namespace::FragmentInfo &inner_fragment_info, const int inner_table_id, const std::unordered_map< shared::TableKey, const Analyzer::BinOper * > &inner_table_id_to_join_condition, const RelAlgExecutionUnit &ra_exe_unit, const ExecutorDeviceType device_type)Executorprivate
spillDoubleElement(llvm::Value *elem_val, llvm::Type *elem_ty)Executorprivate
str_dict_mutex_Executormutableprivate
StringDictionaryTranslationMgr classExecutorfriend
table_generations_Executorprivate
table_id_to_node_map_Executorprivate
TableFunctionCompilationContext classExecutorfriend
TableFunctionExecutionContext classExecutorfriend
TableOptimizer classExecutorfriend
TargetExprCodegenExecutorfriend
TargetExprCodegenBuilderExecutorfriend
temporary_tables_Executorprivate
UNITARY_EXECUTOR_IDExecutorstatic
unregisterActiveModule(const int device_id)Executorstatic
update_after_registration(bool update_runtime_modules_only=false)Executorinlinestatic
update_extension_modules(bool update_runtime_modules_only=false)Executor
updateQuerySessionExecutorAssignment(const QuerySessionId &query_session, const std::string &submitted_time_str, const size_t executor_id, heavyai::unique_lock< heavyai::shared_mutex > &write_lock)Executor
updateQuerySessionStatus(const QuerySessionId &query_session, const std::string &submitted_time_str, const QuerySessionStatus::QueryStatus new_query_status)Executor
updateQuerySessionStatusWithLock(const QuerySessionId &query_session, const std::string &submitted_time_str, const QuerySessionStatus::QueryStatus updated_query_status, heavyai::unique_lock< heavyai::shared_mutex > &write_lock)Executor
warpSize() const Executor
window_project_node_context_owned_Executorprivate
WindowProjectNodeContext classExecutorfriend