OmniSciDB  340b00dbf6
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
Executor Member List

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

active_window_function_Executorprivate
addCodeToCache(const CodeCacheKey &, std::shared_ptr< CompilationContext >, llvm::Module *, CodeCache &)Executorstatic
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 std::string &cache_key, const size_t cache_value)Executor
addToQuerySessionList(const std::string &query_session, const std::string &query_str, SESSION_MAP_LOCK &write_lock)Executor
addToQuerySessionList(const std::string &query_session, const std::string &query_str, mapd_unique_lock< mapd_shared_mutex > &write_lock)Executor
agg_col_range_cache_Executorprivate
aggregateWindowStatePtr()Executorprivate
align(const size_t off_in, const size_t alignment)Executorinlineprivatestatic
baseline_thresholdExecutorprivatestatic
BaselineJoinHashTable classExecutorfriend
block_size_x_Executorprivate
blockSize() const Executor
buildCurrentLevelHashTable(const JoinCondition &current_level_join_conditions, 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 JoinHashTableInterface::HashType preferred_hash_type, ColumnCacheMap &column_cache)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, 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
CachedCardinality typedefExecutor
cardinality_cache_Executorprivatestatic
castToFP(llvm::Value *val)Executorprivate
castToIntPtrTyIn(llvm::Value *val, const size_t bit_width)Executorprivate
catalog_Executorprivate
cgen_state_Executorprivate
checkCurrentQuerySession(const std::string &candidate_query_session, SESSION_MAP_LOCK &read_lock)Executor
checkCurrentQuerySession(const std::string &candidate_query_session, mapd_shared_lock< mapd_shared_mutex > &read_lock)Executor
checkIsQuerySessionInterrupted(const std::string &query_session, SESSION_MAP_LOCK &read_lock)Executor
checkIsQuerySessionInterrupted(const std::string &query_session, mapd_shared_lock< mapd_shared_mutex > &read_lock)Executor
clearMemory(const Data_Namespace::MemoryLevel memory_level)Executorstatic
clearMetaInfoCache()Executorprivate
code_cache_sizeExecutorprivatestatic
codegenAggregateWindowState()Executorprivate
CodeGenerator classExecutorfriend
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, const QueryMemoryDescriptor &query_mem_desc, const CompilationOptions &co, const ExecutionOptions &eo)Executorprivate
codegenSkipDeletedOuterTableRow(const RelAlgExecutionUnit &ra_exe_unit, const CompilationOptions &co)Executorprivate
codegenWindowAvgEpilogue(llvm::Value *crt_val, llvm::Value *window_func_null_val, llvm::Value *multiplicity_lv)Executorprivate
codegenWindowFunction(const size_t target_index, const CompilationOptions &co)Executorprivate
codegenWindowFunctionAggregate(const CompilationOptions &co)Executorprivate
codegenWindowFunctionAggregateCalls(llvm::Value *aggregate_state, const CompilationOptions &co)Executorprivate
codegenWindowFunctionStateInit(llvm::Value *aggregate_state)Executorprivate
codegenWindowResetStateControlFlow()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 Executorprivate
ColumnFetcher classExecutorfriend
compilation_mutex_Executorstatic
compilation_queue_time_ms_Executorprivate
compileBody(const RelAlgExecutionUnit &ra_exe_unit, GroupByAndAggregate &group_by_and_aggregate, const 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(std::unordered_set< int > phys_table_ids)Executorprivate
containsLeftDeepOuterJoin() const Executorinline
cpu_code_cache_Executorprivate
createErrorCheckControlFlow(llvm::Function *query_func, bool run_with_dynamic_watchdog, bool run_with_allowing_runtime_interrupt, 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
current_query_session_Executorprivatestatic
debug_dir_Executorprivate
debug_file_Executorprivate
deviceCount(const ExecutorDeviceType) const Executorprivate
deviceCountForMemoryLevel(const Data_Namespace::MemoryLevel memory_level) const Executorprivate
deviceCycles(int milliseconds) const Executorprivate
enableRuntimeQueryInterrupt(const double runtime_query_check_freq, const unsigned pending_query_check_freq) const 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
execute_mutex_Executorprivatestatic
execute_spin_lock_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 int outer_table_id, const int64_t limit, const uint32_t start_rowid, const uint32_t num_tables, RenderInfo *render_info)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, RenderInfo *render_info)Executorprivate
executeTableFunction(const TableFunctionExecutionUnit exe_unit, const std::vector< InputTableInfo > &table_infos, const CompilationOptions &co, const ExecutionOptions &eo, const Catalog_Namespace::Catalog &cat)Executorprivate
executeUpdate(const RelAlgExecutionUnit &ra_exe_unit, const std::vector< InputTableInfo > &table_infos, 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, const Catalog_Namespace::Catalog &, 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, const Catalog_Namespace::Catalog &, 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)Executorprivate
ExecutionKernel classExecutorfriend
Executor(const ExecutorId id, 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_session_mutex_Executorprivatestatic
ExecutorId typedefExecutor
executors_Executorprivatestatic
executors_cache_mutex_Executorprivatestatic
fetchChunks(const ColumnFetcher &, const RelAlgExecutionUnit &ra_exe_unit, const int device_id, const Data_Namespace::MemoryLevel, const std::map< int, const TableFragments * > &, const FragmentsList &selected_fragments, const Catalog_Namespace::Catalog &, std::list< ChunkIter > &, std::list< std::shared_ptr< Chunk_NS::Chunk >> &, DeviceAllocator *device_allocator)Executorprivate
fetchUnionChunks(const ColumnFetcher &, const RelAlgExecutionUnit &ra_exe_unit, const int device_id, const Data_Namespace::MemoryLevel, const std::map< int, const TableFragments * > &, const FragmentsList &selected_fragments, const Catalog_Namespace::Catalog &, std::list< ChunkIter > &, std::list< std::shared_ptr< Chunk_NS::Chunk >> &, DeviceAllocator *device_allocator)Executorprivate
generatePTX(const std::string &) const Executorprivate
getArenaBlockSize()Executorstatic
getCachedCardinality(const std::string &cache_key)Executor
getCatalog() const Executor
getCodeFromCache(const CodeCacheKey &, const CodeCache &)Executorprivate
getColLazyFetchInfo(const std::vector< Analyzer::Expr * > &target_exprs) const Executor
getColRange(const PhysicalInput &) const Executor
getColumnDescriptor(const Analyzer::ColumnVar *) const Executor
getCurrentQuerySession(SESSION_MAP_LOCK &read_lock)Executor
getCurrentQuerySession(mapd_shared_lock< mapd_shared_mutex > &read_lock)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
getFragmentCount(const FragmentsList &selected_fragments, const size_t scan_idx, const RelAlgExecutionUnit &ra_exe_unit)Executorprivate
getInnerTabIdToJoinCond() const Executorprivate
getJoinHashTablePtrs(const ExecutorDeviceType device_type, const int device_id)Executorprivate
getNumBytesForFetchedRow(const std::set< int > &table_ids_to_fetch) const Executor
getPhysicalColumnDescriptor(const Analyzer::ColumnVar *, int) const Executor
getQuerySessionInfo(const std::string &query_session, mapd_shared_lock< mapd_shared_mutex > &read_lock)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< int, const TableFragments * > &all_tables_fragments)Executorprivate
getRowSetMemoryOwner() const Executor
getSessionLock()Executor
getStringDictionaryProxy(const int dictId, const 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< int, const TableFragments * > &selected_tables_fragments, const std::unordered_map< int, const Analyzer::BinOper * > &inner_table_id_to_join_condition)Executorprivate
getTableGeneration(const int table_id) const Executor
getTableInfo(const int table_id) const Executor
getTemporaryTables() const Executor
gpu_active_modules_Executorprivatestatic
gpu_active_modules_device_mask_Executorprivatestatic
gpu_active_modules_mutex_Executorprivatestatic
gpu_code_cache_Executorprivate
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, GroupByAndAggregate::DiamondCodegen &, std::stack< llvm::BasicBlock * > &, const bool thread_mem_shared)Executorprivate
high_scan_limitExecutorstatic
initializeNVPTXBackend() const Executorprivate
inlineHoistedLiterals()Executorprivate
input_table_info_cache_Executormutableprivate
insertErrorCodeChecker(llvm::Function *query_func, bool hoist_literals)Executorprivate
interrupt(const std::string &query_session="", const std::string &interrupt_session="")Executor
interrupted_Executorprivatestatic
invalidateRunningQuerySession(SESSION_MAP_LOCK &write_lock)Executor
invalidateRunningQuerySession(mapd_unique_lock< mapd_shared_mutex > &write_lock)Executor
InValuesBitmap classExecutorfriend
isArchMaxwell(const ExecutorDeviceType dt) const Executor
isArchPascalOrLater(const ExecutorDeviceType dt) const Executorinlineprivate
isCPUOnly() const Executor
JoinHashTable classExecutorfriend
kernel_mutex_Executorstatic
kernel_queue_time_ms_Executorprivate
launchKernels(SharedKernelContext &shared_context, std::vector< std::unique_ptr< ExecutionKernel >> &&kernels)Executorprivate
launchKernels(SharedKernelContext &shared_context, std::vector< std::unique_ptr< ExecutionKernel >> &&kernels)Executor
LeafAggregator classExecutorfriend
lit_str_dict_proxy_Executormutableprivate
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
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 CompilationOptions &)Executorprivate
OverlapsJoinHashTable classExecutorfriend
PendingExecutionClosure classExecutorfriend
PerFragmentCallBack typedefExecutorprivate
plan_state_Executorprivate
preloadFragOffsets(const std::vector< InputDescriptor > &input_descs, const std::vector< InputTableInfo > &query_infos)Executorprivate
queries_interrupt_flag_Executorprivatestatic
queries_session_map_Executorprivatestatic
QueryCompilationDescriptor classExecutorfriend
QueryExecutionContext classExecutorfriend
QueryFragmentDescriptor classExecutorfriend
QueryMemoryDescriptor classExecutorfriend
QueryMemoryInitializer classExecutorfriend
QueryRewriter 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
registerActiveModule(void *module, const int device_id) const Executor
RelAlgExecutor classExecutorfriend
removeFromQuerySessionList(const std::string &query_session, SESSION_MAP_LOCK &write_lock)Executor
removeFromQuerySessionList(const std::string &query_session, mapd_unique_lock< mapd_shared_mutex > &write_lock)Executor
resetInterrupt()Executor
ResultSet classExecutorfriend
resultsUnion(SharedKernelContext &shared_context, const RelAlgExecutionUnit &ra_exe_unit)Executorprivate
row_set_mem_owner_Executorprivate
serializeLiterals(const std::unordered_map< int, CgenState::LiteralValues > &literals, const int device_id)Executorprivate
setCatalog(const Catalog_Namespace::Catalog *catalog)Executor
setColRangeCache(const AggregatedColRange &aggregated_col_range)Executorinline
setCurrentQuerySession(const std::string &query_session, SESSION_MAP_LOCK &write_lock)Executor
setCurrentQuerySession(const std::string &query_session, mapd_unique_lock< mapd_shared_mutex > &write_lock)Executor
setQuerySessionAsInterrupted(const std::string &query_session, SESSION_MAP_LOCK &write_lock)Executor
setQuerySessionAsInterrupted(const std::string &query_session, mapd_unique_lock< mapd_shared_mutex > &write_lock)Executor
setupCaching(const std::unordered_set< PhysicalInput > &phys_inputs, const std::unordered_set< int > &phys_table_ids)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< int, 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
string_dictionary_generations_Executorprivate
table_generations_Executorprivate
TableFunctionCompilationContext classExecutorfriend
TableFunctionExecutionContext classExecutorfriend
TableOptimizer classExecutorfriend
TargetExprCodegenExecutorfriend
TargetExprCodegenBuilderExecutorfriend
temporary_tables_Executorprivate
UNITARY_EXECUTOR_IDExecutorstatic
unregisterActiveModule(void *module, const int device_id) const Executor
warpSize() const Executor
window_project_node_context_owned_Executorprivate
WindowProjectNodeContext classExecutorfriend