OmniSciDB
a5dc49c757
|
This is the complete list of members for DBHandler, including all inherited members.
agg_handler_ | DBHandler | |
allow_loop_joins_ | DBHandler | |
allow_multifrag_ | DBHandler | |
alterSession(const std::string &sesson_id, ExecutionResult &result, const std::pair< std::string, std::string > &session_parameter, int64_t &execution_time_ms) | DBHandler | private |
alterSystemClear(const std::string &sesson_id, ExecutionResult &result, const std::string &cache_type, int64_t &execution_time_ms) | DBHandler | private |
authMetadata_ | DBHandler | |
base_data_path_ | DBHandler | |
broadcast_serialized_rows(const TSerializedRows &serialized_rows, const TRowDescriptor &row_desc, const TQueryId query_id, const TSubqueryId subquery_id, const bool is_final_subquery_result) override | DBHandler | |
calcite_ | DBHandler | |
calcite_sessions_ | DBHandler | private |
calcite_sessions_mtx_ | DBHandler | mutableprivate |
check_and_invalidate_sessions(Parser::DDLStmt *ddl) | DBHandler | private |
check_geospatial_files(const boost::filesystem::path file_path, const import_export::CopyParams ©_params) | DBHandler | private |
check_read_only(const std::string &str) | DBHandler | private |
check_table_consistency(TTableMeta &_return, const TSessionId &session, const int32_t table_id) override | DBHandler | |
check_table_load_privileges(const Catalog_Namespace::SessionInfo &session_info, const std::string &table_name) | DBHandler | private |
checkInMemorySystemTableQuery(const std::unordered_set< shared::TableKey > &tables_selected_from) const | DBHandler | |
checkpoint(const TSessionId &session, const int32_t table_id) override | DBHandler | |
clang_options_ | DBHandler | private |
clang_path_ | DBHandler | private |
clear_cpu_memory(const TSessionId &session) override | DBHandler | |
clear_gpu_memory(const TSessionId &session) override | DBHandler | |
clearRenderMemory(const TSessionId &session) | DBHandler | |
clone_session(TSessionId &session2, const TSessionId &session1) override | DBHandler | |
connect(TSessionId &session, const std::string &username, const std::string &passwd, const std::string &dbname) override | DBHandler | |
connect_impl(TSessionId &session, const std::string &passwd, const std::string &dbname, const Catalog_Namespace::UserMetadata &user_meta, std::shared_ptr< Catalog_Namespace::Catalog > cat, query_state::StdLog &stdlog) | DBHandler | private |
convertData(TQueryResult &_return, ExecutionResult &result, const QueryStateProxy &query_state_proxy, const bool column_format, const int32_t first_n, const int32_t at_most_n) | DBHandler | privatestatic |
convertExplain(TQueryResult &_return, const ResultSet &results, const bool column_format) | DBHandler | privatestatic |
convertResult(TQueryResult &_return, const ResultSet &results, const bool column_format) | DBHandler | privatestatic |
convertResultSet(ExecutionResult &result, const Catalog_Namespace::SessionInfo &session_info, const std::string &query_state_str, TQueryResult &_return) | DBHandler | private |
convertRows(TQueryResult &_return, QueryStateProxy query_state_proxy, const std::vector< TargetMetaInfo > &targets, const ResultSet &results, const bool column_format, const int32_t first_n, const int32_t at_most_n) | DBHandler | privatestatic |
copyparams_to_thrift(const import_export::CopyParams &cp) | DBHandler | private |
cpu_mode_only_ | DBHandler | |
create_custom_expression(const TSessionId &session, const TCustomExpression &custom_expression) override | DBHandler | |
create_dashboard(const TSessionId &session, const std::string &dashboard_name, const std::string &dashboard_state, const std::string &image_hash, const std::string &dashboard_metadata) override | DBHandler | |
create_geo_column(const TDatumType::type type, const std::string &name, const bool is_array) | DBHandler | private |
create_link(std::string &_return, const TSessionId &session, const std::string &view_state, const std::string &view_metadata) override | DBHandler | |
create_new_session(TSessionId &session, const std::string &dbname, const Catalog_Namespace::UserMetadata &user_meta, std::shared_ptr< Catalog_Namespace::Catalog > cat) | DBHandler | private |
create_query_state(ARGS &&...args) | DBHandler | inline |
create_table(const TSessionId &session, const std::string &table_name, const TRowDescriptor &row_desc, const TCreateParams &create_params) override | DBHandler | |
createInMemoryCalciteSession(const std::shared_ptr< Catalog_Namespace::Catalog > &catalog_ptr) | DBHandler | private |
createSimpleResult(TQueryResult &_return, const ResultSet &results, const bool column_format, const std::string label) | DBHandler | privatestatic |
custom_expressions_mutex_ | DBHandler | private |
data_mgr_ | DBHandler | |
db_leaves_ | DBHandler | |
DBHandler(const std::vector< LeafHostInfo > &db_leaves, const std::vector< LeafHostInfo > &string_leaves, const std::string &base_data_path, const bool allow_multifrag, const bool jit_debug, const bool intel_jit_profile, const bool read_only, const bool allow_loop_joins, const bool enable_rendering, const bool renderer_prefer_igpu, const unsigned renderer_vulkan_timeout_ms, const bool renderer_use_parallel_executors, const bool enable_auto_clear_render_mem, const int render_oom_retry_threshold, const size_t render_mem_bytes, const size_t max_concurrent_render_sessions, const size_t reserved_gpu_mem, const bool render_compositor_use_last_gpu, const bool renderer_enable_slab_allocation, const size_t num_reader_threads, const AuthMetadata &authMetadata, SystemParameters &system_parameters, const bool legacy_syntax, const int idle_session_duration, const int max_session_duration, const std::string &udf_filename, const std::string &clang_path, const std::vector< std::string > &clang_options, const File_Namespace::DiskCacheConfig &disk_cache_config, const bool is_new_db) | DBHandler | |
deallocate_df(const TSessionId &session, const TDataFrame &df, const TDeviceType::type device_type, const int32_t device_id) override | DBHandler | |
deferred_copy_from_sessions | DBHandler | private |
delete_custom_expressions(const TSessionId &session, const std::vector< int32_t > &custom_expression_ids, const bool do_soft_delete) override | DBHandler | |
delete_dashboard(const TSessionId &session, const int32_t dashboard_id) override | DBHandler | |
delete_dashboards(const TSessionId &session, const std::vector< int32_t > &dashboard_ids) override | DBHandler | |
detect_column_types(TDetectResult &_return, const TSessionId &session, const std::string &file_name, const TCopyParams ©_params) override | DBHandler | |
disconnect(const TSessionId &session) override | DBHandler | |
disconnect_impl(Catalog_Namespace::SessionInfoPtr &session_ptr) | DBHandler | private |
disk_cache_config_ | DBHandler | private |
dispatch_query_task(std::shared_ptr< QueryDispatchQueue::Task > query_task, const bool is_update_delete) | DBHandler | private |
dispatch_queue_ | DBHandler | |
emergency_shutdown() | DBHandler | |
enable_auto_clear_render_mem_ | DBHandler | private |
enable_rendering_ | DBHandler | private |
execute_distributed_copy_statement(Parser::CopyTableStmt *, const Catalog_Namespace::SessionInfo &session_info) | DBHandler | private |
execute_next_render_step(TRenderStepResult &_return, const TPendingRenderQuery &pending_render, const TRenderAggDataMap &merged_data) override | DBHandler | |
execute_query_step(TStepResult &_return, const TPendingQuery &pending_query, const TSubqueryId subquery_id, const std::string &start_time_str) override | DBHandler | |
execute_rel_alg(ExecutionResult &_return, QueryStateProxy, const std::string &query_ra, const bool column_format, const ExecutorDeviceType executor_device_type, const int32_t first_n, const int32_t at_most_n, const bool just_validate, const bool find_push_down_candidates, const ExplainInfo &explain_info, const std::optional< size_t > executor_index=std::nullopt) const | DBHandler | private |
execute_rel_alg_with_filter_push_down(ExecutionResult &_return, QueryStateProxy, std::string &query_ra, const bool column_format, const ExecutorDeviceType executor_device_type, const int32_t first_n, const int32_t at_most_n, const bool just_explain, const bool just_calcite_explain, const std::vector< PushedDownFilterInfo > &filter_push_down_requests) | DBHandler | private |
executeDdl(TQueryResult &_return, const std::string &query_ra, std::shared_ptr< Catalog_Namespace::SessionInfo const > session_ptr) | DBHandler | private |
executeDdl(ExecutionResult &_return, const std::string &query_ra, std::shared_ptr< Catalog_Namespace::SessionInfo const > session_ptr) | DBHandler | private |
executor_device_type_ | DBHandler | |
fill_column_names_by_table(std::vector< std::string > &table_names, query_state::StdLog &stdlog) | DBHandler | private |
fillGeoColumns(const TSessionId &session, const Catalog_Namespace::Catalog &catalog, std::vector< std::unique_ptr< import_export::TypedImportBuffer >> &import_buffers, const ColumnDescriptor *cd, size_t &col_idx, size_t num_rows, const std::string &table_name) | DBHandler | private |
fillMissingBuffers(const TSessionId &session, const Catalog_Namespace::Catalog &catalog, std::vector< std::unique_ptr< import_export::TypedImportBuffer >> &import_buffers, const std::list< const ColumnDescriptor * > &cds, const std::vector< int > &desc_id_to_column_id, size_t num_rows, const std::string &table_name) | DBHandler | private |
findCalciteSession(TSessionId const &) const | DBHandler | private |
get_all_effective_roles_for_user(std::vector< std::string > &_return, const TSessionId &session, const std::string &granteeName) override | DBHandler | |
get_all_files_in_archive(std::vector< std::string > &_return, const TSessionId &session, const std::string &archive_path, const TCopyParams ©_params) override | DBHandler | |
get_all_roles_for_user(std::vector< std::string > &_return, const TSessionId &session, const std::string &granteeName) override | DBHandler | |
get_completion_hints(std::vector< TCompletionHint > &hints, const TSessionId &session, const std::string &sql, const int cursor) override | DBHandler | |
get_completion_hints_unsorted(std::vector< TCompletionHint > &hints, std::vector< std::string > &visible_tables, query_state::StdLog &stdlog, const std::string &sql, const int cursor) | DBHandler | private |
get_custom_expressions(std::vector< TCustomExpression > &_return, const TSessionId &session) override | DBHandler | |
get_dashboard(TDashboard &_return, const TSessionId &session, const int32_t dashboard_id) override | DBHandler | |
get_dashboard_grantees(std::vector< TDashboardGrantees > &_return, const TSessionId &session, const int32_t dashboard_id) override | DBHandler | |
get_dashboard_impl(const std::shared_ptr< Catalog_Namespace::SessionInfo const > &session_ptr, Catalog_Namespace::UserMetadata &user_meta, const DashboardDescriptor *dash, const bool populate_state=true) | DBHandler | private |
get_dashboards(std::vector< TDashboard > &_return, const TSessionId &session) override | DBHandler | |
get_databases(std::vector< TDBInfo > &_return, const TSessionId &session) override | DBHandler | |
get_db_object_privs(std::vector< TDBObject > &_return, const TSessionId &session, const std::string &objectName, const TDBObjectType::type type) override | DBHandler | |
get_db_objects_for_grantee(std::vector< TDBObject > &_return, const TSessionId &session, const std::string &roleName) override | DBHandler | |
get_device_parameters(std::map< std::string, std::string > &_return, const TSessionId &session) override | DBHandler | |
get_first_geo_file_in_archive(std::string &_return, const TSessionId &session, const std::string &archive_path, const TCopyParams ©_params) override | DBHandler | |
get_function_details(std::vector< TUserDefinedFunction > &_return, const TSessionId &session, const std::vector< std::string > &udf_names) override | DBHandler | |
get_function_names(std::vector< std::string > &_return, const TSessionId &session) override | DBHandler | |
get_hardware_info(TClusterHardwareInfo &_return, const TSessionId &session) override | DBHandler | |
get_heap_profile(std::string &_return, const TSessionId &session) override | DBHandler | |
get_internal_table_details(TTableDetails &_return, const TSessionId &session, const std::string &table_name, const bool include_system_columns) override | DBHandler | |
get_internal_table_details_for_database(TTableDetails &_return, const TSessionId &session, const std::string &table_name, const std::string &database_name) override | DBHandler | |
get_layers_in_geo_file(std::vector< TGeoFileLayerInfo > &_return, const TSessionId &session, const std::string &file_name, const TCopyParams ©_params) override | DBHandler | |
get_license_claims(TLicenseInfo &_return, const TSessionId &session, const std::string &nonce) override | DBHandler | |
get_link_view(TFrontendView &_return, const TSessionId &session, const std::string &link) override | DBHandler | |
get_memory(std::vector< TNodeMemoryInfo > &_return, const TSessionId &session, const std::string &memory_level) override | DBHandler | |
get_physical_tables(std::vector< std::string > &_return, const TSessionId &session) override | DBHandler | |
get_queries_info(std::vector< TQueryInfo > &_return, const TSessionId &session) override | DBHandler | private |
get_result_row_for_pixel(TPixelTableRowResult &_return, const TSessionId &session, const int64_t widget_id, const TPixel &pixel, const std::map< std::string, std::vector< std::string >> &table_col_names, const bool column_format, const int32_t pixel_radius, const std::string &nonce) override | DBHandler | |
get_roles(std::vector< std::string > &_return, const TSessionId &session) override | DBHandler | |
get_runtime_function_names(std::vector< std::string > &_return, const TSessionId &session) override | DBHandler | |
get_runtime_table_function_names(std::vector< std::string > &_return, const TSessionId &session) override | DBHandler | |
get_server_status(TServerStatus &_return, const TSessionId &session) override | DBHandler | |
get_session_copy(const TSessionId &session_id) | DBHandler | |
get_session_info(TSessionInfo &_return, const TSessionId &session) override | DBHandler | |
get_session_ptr(const TSessionId &session_id) | DBHandler | protected |
get_status(std::vector< TServerStatus > &_return, const TSessionId &session) override | DBHandler | |
get_table_details(TTableDetails &_return, const TSessionId &session, const std::string &table_name) override | DBHandler | |
get_table_details_for_database(TTableDetails &_return, const TSessionId &session, const std::string &table_name, const std::string &database_name) override | DBHandler | |
get_table_details_impl(TTableDetails &_return, query_state::StdLog &stdlog, const std::string &table_name, const bool get_system, const bool get_physical, const std::string &database_name={}) | DBHandler | private |
get_table_epoch(const TSessionId &session, const int32_t db_id, const int32_t table_id) override | DBHandler | |
get_table_epoch_by_name(const TSessionId &session, const std::string &table_name) override | DBHandler | |
get_table_epochs(std::vector< TTableEpochInfo > &_return, const TSessionId &session, const int32_t db_id, const int32_t table_id) override | DBHandler | |
get_table_function_details(std::vector< TUserDefinedTableFunction > &_return, const TSessionId &session, const std::vector< std::string > &udtf_names) override | DBHandler | |
get_table_function_names(std::vector< std::string > &_return, const TSessionId &session) override | DBHandler | |
get_tables(std::vector< std::string > &_return, const TSessionId &session) override | DBHandler | |
get_tables_for_database(std::vector< std::string > &_return, const TSessionId &session, const std::string &database_name) override | DBHandler | |
get_tables_impl(std::vector< std::string > &table_names, const Catalog_Namespace::SessionInfo &, const GetTablesType get_tables_type, const std::string &database_name={}) | DBHandler | private |
get_tables_meta(std::vector< TTableMeta > &_return, const TSessionId &session) override | DBHandler | |
get_tables_meta_impl(std::vector< TTableMeta > &_return, QueryStateProxy query_state_proxy, const Catalog_Namespace::SessionInfo &session_info, const bool with_table_locks=true) | DBHandler | |
get_token_based_completions(std::vector< TCompletionHint > &hints, query_state::StdLog &stdlog, std::vector< std::string > &visible_tables, const std::string &sql, const int cursor) | DBHandler | private |
get_uc_compatible_table_names_by_column(const std::unordered_set< std::string > &uc_column_names, std::vector< std::string > &table_names, query_state::StdLog &stdlog) | DBHandler | private |
get_users(std::vector< std::string > &_return, const TSessionId &session) override | DBHandler | |
get_valid_groups(const TSessionId &session, int32_t dashboard_id, std::vector< std::string > groups) | DBHandler | |
get_version(std::string &_return) override | DBHandler | |
get_views(std::vector< std::string > &_return, const TSessionId &session) override | DBHandler | |
getAllRolesForUserImpl(std::shared_ptr< Catalog_Namespace::SessionInfo const > session_ptr, std::vector< std::string > &roles, const std::string &granteeName, bool effective) | DBHandler | private |
getConnectionInfo() const | DBHandler | protected |
getExecutionMode(const TSessionId &session) | DBHandler | |
getInvalidSessionId() const | DBHandler | |
getQueries(std::shared_ptr< Catalog_Namespace::SessionInfo const > session_ptr) | DBHandler | private |
getServerRole() const | DBHandler | private |
getTargetMetaInfo(const std::vector< std::shared_ptr< Analyzer::TargetEntry >> &targets) const | DBHandler | private |
getTargetNames(const std::vector< TargetMetaInfo > &targets) const | DBHandler | private |
getTargetNames(const std::vector< std::shared_ptr< Analyzer::TargetEntry >> &targets) const | DBHandler | private |
getUserSessions(std::shared_ptr< Catalog_Namespace::SessionInfo const > session_ptr) | DBHandler | private |
handle_to_dev_ptr_mutex_ | DBHandler | mutableprivate |
has_dashboard_permission(const AccessPrivileges &privs, const TDBObjectPermissions &permissions) | DBHandler | privatestatic |
has_database_permission(const AccessPrivileges &privs, const TDBObjectPermissions &permissions) | DBHandler | privatestatic |
has_object_privilege(const TSessionId &sessionId, const std::string &granteeName, const std::string &objectName, const TDBObjectType::type object_type, const TDBObjectPermissions &permissions) override | DBHandler | |
has_role(const TSessionId &sessionId, const std::string &granteeName, const std::string &roleName) override | DBHandler | |
has_server_permission(const AccessPrivileges &privs, const TDBObjectPermissions &permissions) | DBHandler | privatestatic |
has_table_permission(const AccessPrivileges &privs, const TDBObjectPermissions &permission) | DBHandler | privatestatic |
has_view_permission(const AccessPrivileges &privs, const TDBObjectPermissions &permissions) | DBHandler | privatestatic |
hasTableAccessPrivileges(const TableDescriptor *td, const Catalog_Namespace::SessionInfo &session_info) | DBHandler | |
HeavyDBAggHandler class | DBHandler | friend |
HeavyDBLeafHandler class | DBHandler | friend |
idle_session_duration_ | DBHandler | private |
import_geo_table(const TSessionId &session, const std::string &table_name, const std::string &file_name, const TCopyParams ©_params, const TRowDescriptor &row_desc, const TCreateParams &create_params) override | DBHandler | |
import_path_ | DBHandler | |
import_table(const TSessionId &session, const std::string &table_name, const std::string &file_name, const TCopyParams ©_params) override | DBHandler | |
import_table_status(TImportStatus &_return, const TSessionId &session, const std::string &import_id) override | DBHandler | |
importGeoTableGlobFilterSort(const TSessionId &session, const std::string &table_name, const std::string &file_name, const import_export::CopyParams ©_params, const TRowDescriptor &row_desc, const TCreateParams &create_params) | DBHandler | private |
importGeoTableSingle(const TSessionId &session, const std::string &table_name, const std::string &file_name, const import_export::CopyParams ©_params, const TRowDescriptor &row_desc, const TCreateParams &create_params) | DBHandler | private |
init_executor_resource_mgr() | DBHandler | private |
initialize(const bool is_new_db) | DBHandler | |
initialized_ | DBHandler | private |
insert_chunks(const TSessionId &session, const TInsertChunks &insert_chunks) override | DBHandler | |
insert_data(const TSessionId &session, const TInsertData &insert_data) override | DBHandler | |
intel_jit_profile_ | DBHandler | |
internal_connect(TSessionId &session, const std::string &username, const std::string &dbname) | DBHandler | |
interrupt(const TSessionId &query_session, const TSessionId &interrupt_session) override | DBHandler | |
interruptQuery(const Catalog_Namespace::SessionInfo &session_info, const std::string &target_session) | DBHandler | private |
invalidate_cur_session(const TSessionId &parent_session, const TSessionId &leaf_session, const std::string &start_time_str, const std::string &label, bool for_running_query_kernel) override | DBHandler | |
ipc_handle_to_dev_ptr_ | DBHandler | mutableprivate |
isAggregator() const | DBHandler | |
jit_debug_ | DBHandler | |
krb5_connect(TKrb5Session &session, const std::string &token, const std::string &dbname) override | DBHandler | |
leaf_aggregator_ | DBHandler | |
leaf_handler_ | DBHandler | |
legacy_syntax_ | DBHandler | |
load_table(const TSessionId &session, const std::string &table_name, const std::vector< TStringRow > &rows, const std::vector< std::string > &column_names) override | DBHandler | |
load_table_binary(const TSessionId &session, const std::string &table_name, const std::vector< TRow > &rows, const std::vector< std::string > &column_names) override | DBHandler | |
load_table_binary_arrow(const TSessionId &session, const std::string &table_name, const std::string &arrow_stream, const bool use_column_names) override | DBHandler | |
load_table_binary_columnar(const TSessionId &session, const std::string &table_name, const std::vector< TColumn > &cols, const std::vector< std::string > &column_names) override | DBHandler | |
max_bytes_for_thrift() | DBHandler | inlinestatic |
max_concurrent_render_sessions_ | DBHandler | private |
max_num_sessions_ | DBHandler | private |
max_session_duration_ | DBHandler | private |
num_reader_threads_ | DBHandler | private |
parse_to_ra(QueryStateProxy, const std::string &query_str, const std::vector< TFilterPushDownInfo > &filter_push_down_info, const bool acquire_locks, const SystemParameters &system_parameters, bool check_privileges=true) | DBHandler | private |
pause_executor_queue(const TSessionId &session) | DBHandler | |
permissionFuncMap_ | DBHandler | private |
populateThriftColumnType(const Catalog_Namespace::Catalog *cat, const ColumnDescriptor *cd) | DBHandler | private |
prepare_loader_generic(const Catalog_Namespace::SessionInfo &session_info, const std::string &table_name, size_t num_cols, std::unique_ptr< import_export::Loader > *loader, std::vector< std::unique_ptr< import_export::TypedImportBuffer >> *import_buffers, const std::vector< std::string > &column_names, std::string load_type) | DBHandler | private |
process_deferred_copy_from(const TSessionId &session_id) | DBHandler | private |
processCalciteRequest(QueryStateProxy, const std::shared_ptr< Catalog_Namespace::Catalog > &cat, const std::string &query_str, const std::vector< TFilterPushDownInfo > &filter_push_down_info, const SystemParameters &system_parameters, const bool check_privileges) | DBHandler | private |
query_engine_ | DBHandler | |
query_get_outer_fragment_count(const TSessionId &session, const std::string &select_query) override | DBHandler | |
query_states_ | DBHandler | private |
random_gen_ | DBHandler | |
read_only_ | DBHandler | |
register_runtime_extension_functions(const TSessionId &session, const std::vector< TUserDefinedFunction > &udfs, const std::vector< TUserDefinedTableFunction > &udtfs, const std::map< std::string, std::string > &device_ir_map) override | DBHandler | |
removeInMemoryCalciteSession(const std::string &session_id) | DBHandler | private |
render_compositor_use_last_gpu_ | DBHandler | private |
render_handler_ | DBHandler | |
render_mem_bytes_ | DBHandler | private |
render_mutex_ | DBHandler | |
render_oom_retry_threshold_ | DBHandler | private |
render_rel_alg(TRenderResult &_return, const std::string &query_ra, const std::string &query_str, const Catalog_Namespace::SessionInfo &session_info, const std::string &render_type, const bool is_projection_query) | DBHandler | private |
render_vega(TRenderResult &_return, const TSessionId &session, const int64_t widget_id, const std::string &vega_json, const int32_t compression_level, const std::string &nonce) override | DBHandler | |
renderer_enable_slab_allocation_ | DBHandler | private |
renderer_prefer_igpu_ | DBHandler | private |
renderer_use_parallel_executors_ | DBHandler | private |
renderer_vulkan_timeout_ | DBHandler | private |
RenderHandler::Impl class | DBHandler | friend |
replace_dashboard(const TSessionId &session, const int32_t dashboard_id, const std::string &dashboard_name, const std::string &dashboard_owner, const std::string &dashboard_state, const std::string &image_hash, const std::string &dashboard_metadata) override | DBHandler | |
reserved_gpu_mem_ | DBHandler | private |
resetSessionsStore() | DBHandler | private |
resizeDispatchQueue(size_t queue_size) | DBHandler | |
resume_executor_queue(const TSessionId &session) | DBHandler | |
run_warmup_queries(std::shared_ptr< DBHandler > handler, std::string base_path, std::string query_file_path) | DBHandler | friend |
session_id_dist_ | DBHandler | |
sessions_mutex_ | DBHandler | |
sessions_store_ | DBHandler | private |
set_cur_session(const TSessionId &parent_session, const TSessionId &leaf_session, const std::string &start_time_str, const std::string &label, bool for_running_query_kernel) override | DBHandler | |
set_execution_mode(const TSessionId &session, const TExecuteMode::type mode) override | DBHandler | |
set_execution_mode_nolock(Catalog_Namespace::SessionInfo *session_ptr, const TExecuteMode::type mode) | DBHandler | private |
set_leaf_info(const TSessionId &session, const TLeafInfo &info) override | DBHandler | |
set_license_key(TLicenseInfo &_return, const TSessionId &session, const std::string &key, const std::string &nonce) override | DBHandler | |
set_table_epoch(const TSessionId &session, const int db_id, const int table_id, const int new_epoch) override | DBHandler | |
set_table_epoch_by_name(const TSessionId &session, const std::string &table_name, const int new_epoch) override | DBHandler | |
set_table_epochs(const TSessionId &session, const int32_t db_id, const std::vector< TTableEpochInfo > &table_epochs) override | DBHandler | |
share_dashboard(const TSessionId &session, const int32_t dashboard_id, const std::vector< std::string > &groups, const std::vector< std::string > &objects, const TDashboardPermissions &permissions, const bool grant_role) override | DBHandler | |
share_dashboards(const TSessionId &session, const std::vector< int32_t > &dashboard_ids, const std::vector< std::string > &groups, const TDashboardPermissions &permissions) override | DBHandler | |
shareOrUnshareDashboards(const TSessionId &session, const std::vector< int32_t > &dashboard_ids, const std::vector< std::string > &groups, const TDashboardPermissions &permissions, const bool do_share) | DBHandler | private |
shutdown() | DBHandler | |
sql_execute(ExecutionResult &_return, const TSessionId &session, const std::string &query, const bool column_format, const int32_t first_n, const int32_t at_most_n, lockmgr::LockedTableDescriptors &locks) | DBHandler | |
sql_execute(TQueryResult &_return, const TSessionId &session, const std::string &query, const bool column_format, const std::string &nonce, const int32_t first_n, const int32_t at_most_n) override | DBHandler | |
sql_execute_df(TDataFrame &_return, const TSessionId &session, const std::string &query, const TDeviceType::type device_type, const int32_t device_id, const int32_t first_n, const TArrowTransport::type transport_method) override | DBHandler | |
sql_execute_gdf(TDataFrame &_return, const TSessionId &session, const std::string &query, const int32_t device_id, const int32_t first_n) override | DBHandler | |
sql_execute_impl(ExecutionResult &_return, QueryStateProxy, const bool column_format, const ExecutorDeviceType executor_device_type, const int32_t first_n, const int32_t at_most_n, const bool use_calcite, lockmgr::LockedTableDescriptors &locks) | DBHandler | private |
sql_execute_local(TQueryResult &_return, const QueryStateProxy &query_state_proxy, const std::shared_ptr< Catalog_Namespace::SessionInfo > session_ptr, const std::string &query_str, const bool column_format, const std::string &nonce, const int32_t first_n, const int32_t at_most_n, const bool use_calcite) | DBHandler | private |
sql_validate(TRowDescriptor &_return, const TSessionId &session, const std::string &query) override | DBHandler | |
start_heap_profile(const TSessionId &session) override | DBHandler | |
start_query(TPendingQuery &_return, const TSessionId &leaf_session, const TSessionId &parent_session, const std::string &serialized_rel_alg_dag, const std::string &start_time_str, const bool just_explain, const std::vector< int64_t > &outer_fragment_indices) override | DBHandler | |
start_render_query(TPendingRenderQuery &_return, const TSessionId &session, const int64_t widget_id, const int16_t node_idx, const std::string &vega_json) override | DBHandler | |
start_time_ | DBHandler | |
stop_heap_profile(const TSessionId &session) override | DBHandler | |
string_leaves_ | DBHandler | |
super_user_rights_ | DBHandler | private |
switch_database(const TSessionId &session, const std::string &dbname) override | DBHandler | |
system_parameters_ | DBHandler | |
thrift_to_copyparams(const TCopyParams &cp) | DBHandler | private |
udf_filename_ | DBHandler | private |
unescape_char(std::string str) | DBHandler | private |
unshare_dashboard(const TSessionId &session, const int32_t dashboard_id, const std::vector< std::string > &groups, const std::vector< std::string > &objects, const TDashboardPermissions &permissions) override | DBHandler | |
unshare_dashboards(const TSessionId &session, const std::vector< int32_t > &dashboard_ids, const std::vector< std::string > &groups, const TDashboardPermissions &permissions) override | DBHandler | |
update_custom_expression(const TSessionId &session, const int32_t id, const std::string &expression_json) override | DBHandler | |
user_can_access_table(const Catalog_Namespace::SessionInfo &, const TableDescriptor *td, const AccessPrivileges acess_priv) | DBHandler | private |
validate_configurations() | DBHandler | private |
validateDashboardIdsForSharing(const Catalog_Namespace::SessionInfo &session_info, const std::vector< int32_t > &dashboard_ids) | DBHandler | private |
validateGroups(const std::vector< std::string > &groups) | DBHandler | private |
validateRelAlg(const std::string &query_ra, QueryStateProxy query_state_proxy) | DBHandler | private |
value_to_thrift(const TargetValue &tv, const SQLTypeInfo &ti) | DBHandler | privatestatic |
value_to_thrift_column(const TargetValue &tv, const SQLTypeInfo &ti, TColumn &column) | DBHandler | privatestatic |
~DBHandler() override | DBHandler |