Executor Member List

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

acquireExecuteMutex()	Executor	inlineprivate
active_window_function_	Executor	private
addDeletedColumn(const RelAlgExecutionUnit &ra_exe_unit, const CompilationOptions &co)	Executor	private
addJoinLoopIterator(const std::vector< llvm::Value * > &prev_iters, const size_t level_idx)	Executor	private
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)	Executor	static
agg_col_range_cache_	Executor	private
aggregateWindowStatePtr(CodeGenerator *code_generator, const CompilationOptions &co)	Executor	private
align(const size_t off_in, const size_t alignment)	Executor	inlineprivatestatic
attachExecutorToQuerySession(const QuerySessionId &query_session_id, const std::string &query_str, const std::string &query_submitted_time)	Executor
auto_cpu_mem_bytes	Executor	static
auto_num_threads	Executor	privatestatic
AutoTrackBuffersInRuntimeIR()	Executor	private
baseline_threshold	Executor	privatestatic
BaselineJoinHashTable class	Executor	friend
block_size_x_	Executor	private
blockSize() const	Executor
BoundingBoxIntersectJoinHashTable class	Executor	friend
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)	Executor	private
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)	Executor	private
buildHoistLeftHandSideFiltersCb(const RelAlgExecutionUnit &ra_exe_unit, const size_t level_idx, const shared::TableKey &inner_table_key, const CompilationOptions &co)	Executor	private
buildIsDeletedCb(const RelAlgExecutionUnit &ra_exe_unit, const size_t level_idx, const CompilationOptions &co)	Executor	private
buildJoinLoops(RelAlgExecutionUnit &ra_exe_unit, const CompilationOptions &co, const ExecutionOptions &eo, const std::vector< InputTableInfo > &query_infos, ColumnCacheMap &column_cache)	Executor	private
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)	Executor	private
buildSelectedFragsMappingForUnion(std::vector< std::vector< size_t >> &selected_fragments_crossjoin, const FragmentsList &selected_fragments, const RelAlgExecutionUnit &ra_exe_unit)	Executor	private
CachedCardinality typedef	Executor
canSkipFragmentForFpQual(const Analyzer::BinOper *comp_expr, const Analyzer::ColumnVar *lhs_col, const Fragmenter_Namespace::FragmentInfo &fragment, const Analyzer::Constant *rhs_const) const	Executor	private
cardinality_cache_	Executor	privatestatic
castToFP(llvm::Value *, SQLTypeInfo const &from_ti, SQLTypeInfo const &to_ti)	Executor	private
castToIntPtrTyIn(llvm::Value *val, const size_t bit_width)	Executor	private
cgen_state_	Executor	private
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()	Executor	static
clearExternalCaches(bool for_update, const TableDescriptor *td, const int current_db_id)	Executor	inlinestatic
clearMemory(const Data_Namespace::MemoryLevel memory_level)	Executor	static
clearMetaInfoCache()	Executor	private
clearQuerySessionStatus(const QuerySessionId &query_session, const std::string &submitted_time_str)	Executor
codegenAggregateWindowState(CodeGenerator *code_generator, const CompilationOptions &co, llvm::Value *aggregate_state)	Executor	private
codegenConditionalAggregateCondValSelector(llvm::Value *cond_lv, SQLAgg const aggKind, CompilationOptions const &co) const	Executor	private
codegenCurrentPartitionIndex(const WindowFunctionContext *window_func_context, CodeGenerator *code_generator, const CompilationOptions &co, llvm::Value *current_row_pos_lv)	Executor	private
CodeGenerator class	Executor	friend
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)	Executor	private
codegenFrameBoundExpr(const Analyzer::WindowFunction *window_func, const Analyzer::WindowFrame *frame_bound, CodeGenerator &code_generator, const CompilationOptions &co)	Executor	private
codegenFrameBoundRange(const Analyzer::WindowFunction *window_func, CodeGenerator &code_generator, const CompilationOptions &co)	Executor	private
codegenFrameNullRange(WindowFunctionContext *window_func_context, CodeGenerator *code_generator, const CompilationOptions &co, llvm::Value *partition_index_lv) const	Executor	private
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)	Executor	private
codegenLoadCurrentValueFromColBuf(WindowFunctionContext *window_func_context, CodeGenerator &code_generator, WindowFrameBoundFuncArgs &args) const	Executor	private
codegenLoadOrderKeyBufPtr(WindowFunctionContext *window_func_context, CodeGenerator *code_generator, const CompilationOptions &co) const	Executor	private
codegenLoadPartitionBuffers(WindowFunctionContext *window_func_context, CodeGenerator *code_generator, const CompilationOptions &co, llvm::Value *partition_index_lv) const	Executor	private
codegenSkipDeletedOuterTableRow(const RelAlgExecutionUnit &ra_exe_unit, const CompilationOptions &co)	Executor	private
codegenWindowAvgEpilogue(CodeGenerator *code_generator, const CompilationOptions &co, llvm::Value *crt_val, llvm::Value *window_func_null_val)	Executor	private
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)	Executor	private
codegenWindowFunction(const size_t target_index, const CompilationOptions &co)	Executor	private
codegenWindowFunctionAggregate(CodeGenerator *code_generator, const CompilationOptions &co)	Executor	private
codegenWindowFunctionAggregateCalls(llvm::Value *aggregate_state, const CompilationOptions &co)	Executor	private
codegenWindowFunctionStateInit(CodeGenerator *code_generator, const CompilationOptions &co, llvm::Value *aggregate_state)	Executor	private
codegenWindowNavigationFunctionOnFrame(const CompilationOptions &co)	Executor	private
codegenWindowResetStateControlFlow(CodeGenerator *code_generator, const CompilationOptions &co)	Executor	private
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)	Executor	private
collectAllDeviceShardedTopResults(SharedKernelContext &shared_context, const RelAlgExecutionUnit &ra_exe_unit, const ExecutorDeviceType device_type) const	Executor	private
ColumnFetcher class	Executor	friend
compilation_mutex_	Executor
compilation_queue_time_ms_	Executor	private
compileBody(const RelAlgExecutionUnit &ra_exe_unit, GroupByAndAggregate &group_by_and_aggregate, QueryMemoryDescriptor &query_mem_desc, const CompilationOptions &co, const GpuSharedMemoryContext &gpu_smem_context={})	Executor	private
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)	Executor	private
computeColRangesCache(const std::unordered_set< PhysicalInput > &phys_inputs)	Executor	private
computeStringDictionaryGenerations(const std::unordered_set< PhysicalInput > &phys_inputs)	Executor	private
computeTableGenerations(const std::unordered_set< shared::TableKey > &phys_table_keys)	Executor	private
containsLeftDeepOuterJoin() const	Executor	inline
context_	Executor	private
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)	Executor	private
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)	Executor	private
cudaMgr() const	Executor	inlineprivate
current_query_session_	Executor	private
data_mgr_	Executor	private
debug_dir_	Executor	private
debug_file_	Executor	private
deviceCount(const ExecutorDeviceType) const	Executor
deviceCountForMemoryLevel(const Data_Namespace::MemoryLevel memory_level) const	Executor	private
deviceCycles(int milliseconds) const	Executor	private
DiamondCodegen	Executor	friend
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
execute_mutex_	Executor	privatestatic
executeExplain(const QueryCompilationDescriptor &)	Executor	private
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)	Executor	private
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)	Executor	private
executeTableFunction(const TableFunctionExecutionUnit exe_unit, const std::vector< InputTableInfo > &table_infos, const CompilationOptions &co, const ExecutionOptions &eo)	Executor	private
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)	Executor	private
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)	Executor	private
ExecutionKernel class	Executor	friend
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_	Executor	private
executor_resource_mgr_	Executor	static
executor_session_mutex_	Executor	privatestatic
ExecutorId typedef	Executor
executors_	Executor	privatestatic
executors_cache_mutex_	Executor	privatestatic
extension_module_sources	Executor	static
extension_modules_	Executor	private
ExtModuleKinds enum name	Executor
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)	Executor	private
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)	Executor	private
generatePTX(const std::string &) const	Executor	private
get_concurrent_resource_grant_policy(const ExecutorResourceMgr_Namespace::ResourceType resource_type)	Executor	static
get_executor_resource_pool_info()	Executor	static
get_executor_resource_pool_total_resource_quantity(const ExecutorResourceMgr_Namespace::ResourceType resource_type)	Executor	static
get_extension_module(ExtModuleKinds kind) const	Executor	inlineprivate
get_geos_module() const	Executor	inline
get_libdevice_module() const	Executor	inline
get_rt_module() const	Executor	inline
get_rt_udf_module(bool is_gpu=false) const	Executor	inline
get_udf_module(bool is_gpu=false) const	Executor	inline
getArenaBlockSize()	Executor	static
getBaselineThreshold(bool for_count_distinct, ExecutorDeviceType device_type)	Executor	inlinestatic
getCachedCardinality(const CardinalityCacheKey &cache_key)	Executor
getCgenStatePtr() const	Executor	inline
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()	Executor	inline
getCurrentQuerySession(heavyai::shared_lock< heavyai::shared_mutex > &read_lock)	Executor
getDataMgr() const	Executor	inline
getDataRecyclerLock()	Executor
getDeviceTypeForTargets(const RelAlgExecutionUnit &ra_exe_unit, const ExecutorDeviceType requested_device_type)	Executor	private
getExecutor(const ExecutorId id, const std::string &debug_dir="", const std::string &debug_file="", const SystemParameters &system_parameters=SystemParameters())	Executor	static
getExecutorId() const	Executor	inline
getExecutorIdsRunningQuery(const QuerySessionId &interrupt_session) const	Executor
getFirstOrderColTypeInfo(WindowFunctionContext *window_func_context) const	Executor	private
getFragmentCount(const FragmentsList &selected_fragments, const size_t scan_idx, const RelAlgExecutionUnit &ra_exe_unit)	Executor	private
getFramingFuncName(const std::string &bound_type, const std::string &order_col_type, const std::string &op_type, bool for_timestamp_type) const	Executor	private
getInnerTabIdToJoinCond() const	Executor	private
getJoinHashTablePtrs(const ExecutorDeviceType device_type, const int device_id)	Executor	private
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	Executor	private
getOrderKeyTypeName(WindowFunctionContext *window_func_context) const	Executor	private
getPhysicalColumnDescriptor(const Analyzer::ColumnVar *, int) const	Executor
getPlanStatePtr() const	Executor	inline
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)	Executor	private
getRowSetMemoryOwner() const	Executor
getSessionLock()	Executor
getStringDictionaryProxy(const shared::StringDictKey &dict_key, const bool with_generation) const	Executor	inline
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)	Executor	private
getTableGeneration(const shared::TableKey &table_key) const	Executor
getTableInfo(const shared::TableKey &table_key) const	Executor
getTemporaryTables()	Executor	inline
getTemporaryTables() const	Executor
getUniqueThreadSharedResultSets(const std::vector< std::pair< ResultSetPtr, std::vector< size_t >>> &results_per_device) const	Executor	private
gpu_active_modules_	Executor	privatestatic
gpu_active_modules_device_mask_	Executor	privatestatic
gpu_active_modules_mutex_	Executor	privatestatic
gpu_exec_mutex_	Executor	private
grid_size_x_	Executor	private
gridSize() const	Executor
GroupByAndAggregate class	Executor	friend
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)	Executor	private
has_extension_module(ExtModuleKinds kind) const	Executor	inlineprivate
has_geos_module() const	Executor	inline
has_libdevice_module() const	Executor	inline
has_rt_module() const	Executor	inline
has_rt_udf_module(bool is_gpu=false) const	Executor	inline
has_udf_module(bool is_gpu=false) const	Executor	inline
HashJoin class	Executor	friend
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)	Executor	static
initialize_extension_module_sources()	Executor	static
initializeNVPTXBackend() const	Executor	private
inlineHoistedLiterals()	Executor	private
input_table_info_cache_	Executor	mutableprivate
insertErrorCodeChecker(llvm::Function *query_func, unsigned const error_code_idx, bool hoist_literals, bool allow_runtime_query_interrupt)	Executor	private
interrupt(const QuerySessionId &query_session="", const QuerySessionId &interrupt_session="")	Executor
interrupted_	Executor	private
INVALID_EXECUTOR_ID	Executor	static
invalidateCardinalityCacheForTable(const shared::TableKey &table_key)	Executor	static
invalidateRunningQuerySession(heavyai::unique_lock< heavyai::shared_mutex > &write_lock)	Executor
InValuesBitmap class	Executor	friend
isArchMaxwell(const ExecutorDeviceType dt) const	Executor
isArchPascalOrLater(const ExecutorDeviceType dt) const	Executor	inlineprivate
isCPUOnly() const	Executor
isFragmentFullyDeleted(const InputDescriptor &table_desc, const Fragmenter_Namespace::FragmentInfo &fragment)	Executor	private
kernel_mutex_	Executor	static
kernel_queue_time_ms_	Executor	private
KernelSubtask class	Executor	friend
latest_query_plan_extracted_	Executor	privatestatic
launchKernelsImpl(SharedKernelContext &shared_context, std::vector< std::unique_ptr< ExecutionKernel >> &&kernels, const ExecutorDeviceType device_type, const size_t requested_num_threads)	Executor	private
launchKernelsLocked(SharedKernelContext &shared_context, std::vector< std::unique_ptr< ExecutionKernel >> &&kernels, const ExecutorDeviceType device_type)	Executor	private
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)	Executor	private
LeafAggregator class	Executor	friend
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_count	Executor	privatestatic
max_gpu_slab_size_	Executor	private
maxGpuSlabSize() const	Executor
needFetchAllFragments(const InputColDescriptor &col_desc, const RelAlgExecutionUnit &ra_exe_unit, const FragmentsList &selected_fragments) const	Executor	private
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	Executor	private
nukeCacheOfExecutors()	Executor	inlinestatic
nukeOldState(const bool allow_lazy_fetch, const std::vector< InputTableInfo > &query_infos, const PlanState::DeletedColumnsMap &deleted_cols_map, const RelAlgExecutionUnit *ra_exe_unit)	Executor	private
numBlocksPerMP() const	Executor
nvptx_target_machine_	Executor	mutableprivate
optimizeAndCodegenCPU(llvm::Function *, llvm::Function *, const std::unordered_set< llvm::Function * > &, const CompilationOptions &)	Executor	private
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 &)	Executor	private
pause_executor_queue()	Executor	static
PendingExecutionClosure class	Executor	friend
PerfectJoinHashTable class	Executor	friend
PerFragmentCallBack typedef	Executor	private
plan_state_	Executor	private
preloadFragOffsets(const std::vector< InputDescriptor > &input_descs, const std::vector< InputTableInfo > &query_infos)	Executor	private
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	Executor	private
prepareRowModeFuncArgs(bool for_start_bound, SqlWindowFrameBoundType bound_type, const WindowFrameBoundFuncArgs &args) const	Executor	private
queries_interrupt_flag_	Executor	privatestatic
queries_session_map_	Executor	privatestatic
query_plan_dag_cache_	Executor	privatestatic
QueryCompilationDescriptor class	Executor	friend
QueryExecutionContext class	Executor	friend
QueryFragmentDescriptor class	Executor	friend
QueryMemoryDescriptor class	Executor	friend
QueryMemoryInitializer class	Executor	friend
QueryRewriter class	Executor	friend
RangeJoinHashTable class	Executor	friend
recycler_mutex_	Executor	privatestatic
redeclareFilterFunction()	Executor	private
reduceMultiDeviceResults(const RelAlgExecutionUnit &, std::vector< std::pair< ResultSetPtr, std::vector< size_t >>> &all_fragment_results, std::shared_ptr< RowSetMemoryOwner >, const QueryMemoryDescriptor &) const	Executor	private
reduceMultiDeviceResultSets(std::vector< std::pair< ResultSetPtr, std::vector< size_t >>> &all_fragment_results, std::shared_ptr< RowSetMemoryOwner >, const QueryMemoryDescriptor &) const	Executor	private
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)	Executor	static
reduceSpeculativeTopN(const RelAlgExecutionUnit &, std::vector< std::pair< ResultSetPtr, std::vector< size_t >>> &all_fragment_results, std::shared_ptr< RowSetMemoryOwner >, const QueryMemoryDescriptor &) const	Executor	private
register_runtime_extension_functions_mutex_	Executor	static
registerActiveModule(void *module, const int device_id)	Executor	static
registerExtensionFunctions(F register_extension_functions)	Executor	inlinestatic
registerExtractedQueryPlanDag(const QueryPlanDAG &query_plan_dag)	Executor
RelAlgExecutor class	Executor	friend
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 class	Executor	friend
resultset_recycler_holder_	Executor	privatestatic
resultsUnion(SharedKernelContext &shared_context, const RelAlgExecutionUnit &ra_exe_unit)	Executor	private
resume_executor_queue()	Executor	static
row_set_mem_owner_	Executor	private
serializeLiterals(const std::unordered_map< int, CgenState::LiteralValues > &literals, const int device_id)	Executor	private
set_concurrent_resource_grant_policy(const ExecutorResourceMgr_Namespace::ConcurrentResourceGrantPolicy &concurrent_resource_grant_policy)	Executor	static
set_executor_resource_pool_resource(const ExecutorResourceMgr_Namespace::ResourceType resource_type, const size_t resource_quantity)	Executor	static
setBlockSize(unsigned block_size)	Executor
setColRangeCache(const AggregatedColRange &aggregated_col_range)	Executor	inline
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)	Executor	private
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)	Executor	private
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)	Executor	private
spillDoubleElement(llvm::Value *elem_val, llvm::Type *elem_ty)	Executor	private
str_dict_mutex_	Executor	mutableprivate
StringDictionaryTranslationMgr class	Executor	friend
table_generations_	Executor	private
table_id_to_node_map_	Executor	private
TableFunctionCompilationContext class	Executor	friend
TableFunctionExecutionContext class	Executor	friend
TableOptimizer class	Executor	friend
TargetExprCodegen	Executor	friend
TargetExprCodegenBuilder	Executor	friend
temporary_tables_	Executor	private
UNITARY_EXECUTOR_ID	Executor	static
unregisterActiveModule(const int device_id)	Executor	static
update_after_registration(bool update_runtime_modules_only=false)	Executor	inlinestatic
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_	Executor	private
WindowProjectNodeContext class	Executor	friend