OmniSciDB  a5dc49c757
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
DBHandler Member List

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)DBHandlerprivate
alterSystemClear(const std::string &sesson_id, ExecutionResult &result, const std::string &cache_type, int64_t &execution_time_ms)DBHandlerprivate
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) overrideDBHandler
calcite_DBHandler
calcite_sessions_DBHandlerprivate
calcite_sessions_mtx_DBHandlermutableprivate
check_and_invalidate_sessions(Parser::DDLStmt *ddl)DBHandlerprivate
check_geospatial_files(const boost::filesystem::path file_path, const import_export::CopyParams &copy_params)DBHandlerprivate
check_read_only(const std::string &str)DBHandlerprivate
check_table_consistency(TTableMeta &_return, const TSessionId &session, const int32_t table_id) overrideDBHandler
check_table_load_privileges(const Catalog_Namespace::SessionInfo &session_info, const std::string &table_name)DBHandlerprivate
checkInMemorySystemTableQuery(const std::unordered_set< shared::TableKey > &tables_selected_from) const DBHandler
checkpoint(const TSessionId &session, const int32_t table_id) overrideDBHandler
clang_options_DBHandlerprivate
clang_path_DBHandlerprivate
clear_cpu_memory(const TSessionId &session) overrideDBHandler
clear_gpu_memory(const TSessionId &session) overrideDBHandler
clearRenderMemory(const TSessionId &session)DBHandler
clone_session(TSessionId &session2, const TSessionId &session1) overrideDBHandler
connect(TSessionId &session, const std::string &username, const std::string &passwd, const std::string &dbname) overrideDBHandler
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)DBHandlerprivate
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)DBHandlerprivatestatic
convertExplain(TQueryResult &_return, const ResultSet &results, const bool column_format)DBHandlerprivatestatic
convertResult(TQueryResult &_return, const ResultSet &results, const bool column_format)DBHandlerprivatestatic
convertResultSet(ExecutionResult &result, const Catalog_Namespace::SessionInfo &session_info, const std::string &query_state_str, TQueryResult &_return)DBHandlerprivate
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)DBHandlerprivatestatic
copyparams_to_thrift(const import_export::CopyParams &cp)DBHandlerprivate
cpu_mode_only_DBHandler
create_custom_expression(const TSessionId &session, const TCustomExpression &custom_expression) overrideDBHandler
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) overrideDBHandler
create_geo_column(const TDatumType::type type, const std::string &name, const bool is_array)DBHandlerprivate
create_link(std::string &_return, const TSessionId &session, const std::string &view_state, const std::string &view_metadata) overrideDBHandler
create_new_session(TSessionId &session, const std::string &dbname, const Catalog_Namespace::UserMetadata &user_meta, std::shared_ptr< Catalog_Namespace::Catalog > cat)DBHandlerprivate
create_query_state(ARGS &&...args)DBHandlerinline
create_table(const TSessionId &session, const std::string &table_name, const TRowDescriptor &row_desc, const TCreateParams &create_params) overrideDBHandler
createInMemoryCalciteSession(const std::shared_ptr< Catalog_Namespace::Catalog > &catalog_ptr)DBHandlerprivate
createSimpleResult(TQueryResult &_return, const ResultSet &results, const bool column_format, const std::string label)DBHandlerprivatestatic
custom_expressions_mutex_DBHandlerprivate
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) overrideDBHandler
deferred_copy_from_sessionsDBHandlerprivate
delete_custom_expressions(const TSessionId &session, const std::vector< int32_t > &custom_expression_ids, const bool do_soft_delete) overrideDBHandler
delete_dashboard(const TSessionId &session, const int32_t dashboard_id) overrideDBHandler
delete_dashboards(const TSessionId &session, const std::vector< int32_t > &dashboard_ids) overrideDBHandler
detect_column_types(TDetectResult &_return, const TSessionId &session, const std::string &file_name, const TCopyParams &copy_params) overrideDBHandler
disconnect(const TSessionId &session) overrideDBHandler
disconnect_impl(Catalog_Namespace::SessionInfoPtr &session_ptr)DBHandlerprivate
disk_cache_config_DBHandlerprivate
dispatch_query_task(std::shared_ptr< QueryDispatchQueue::Task > query_task, const bool is_update_delete)DBHandlerprivate
dispatch_queue_DBHandler
emergency_shutdown()DBHandler
enable_auto_clear_render_mem_DBHandlerprivate
enable_rendering_DBHandlerprivate
execute_distributed_copy_statement(Parser::CopyTableStmt *, const Catalog_Namespace::SessionInfo &session_info)DBHandlerprivate
execute_next_render_step(TRenderStepResult &_return, const TPendingRenderQuery &pending_render, const TRenderAggDataMap &merged_data) overrideDBHandler
execute_query_step(TStepResult &_return, const TPendingQuery &pending_query, const TSubqueryId subquery_id, const std::string &start_time_str) overrideDBHandler
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 DBHandlerprivate
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)DBHandlerprivate
executeDdl(TQueryResult &_return, const std::string &query_ra, std::shared_ptr< Catalog_Namespace::SessionInfo const > session_ptr)DBHandlerprivate
executeDdl(ExecutionResult &_return, const std::string &query_ra, std::shared_ptr< Catalog_Namespace::SessionInfo const > session_ptr)DBHandlerprivate
executor_device_type_DBHandler
fill_column_names_by_table(std::vector< std::string > &table_names, query_state::StdLog &stdlog)DBHandlerprivate
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)DBHandlerprivate
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)DBHandlerprivate
findCalciteSession(TSessionId const &) const DBHandlerprivate
get_all_effective_roles_for_user(std::vector< std::string > &_return, const TSessionId &session, const std::string &granteeName) overrideDBHandler
get_all_files_in_archive(std::vector< std::string > &_return, const TSessionId &session, const std::string &archive_path, const TCopyParams &copy_params) overrideDBHandler
get_all_roles_for_user(std::vector< std::string > &_return, const TSessionId &session, const std::string &granteeName) overrideDBHandler
get_completion_hints(std::vector< TCompletionHint > &hints, const TSessionId &session, const std::string &sql, const int cursor) overrideDBHandler
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)DBHandlerprivate
get_custom_expressions(std::vector< TCustomExpression > &_return, const TSessionId &session) overrideDBHandler
get_dashboard(TDashboard &_return, const TSessionId &session, const int32_t dashboard_id) overrideDBHandler
get_dashboard_grantees(std::vector< TDashboardGrantees > &_return, const TSessionId &session, const int32_t dashboard_id) overrideDBHandler
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)DBHandlerprivate
get_dashboards(std::vector< TDashboard > &_return, const TSessionId &session) overrideDBHandler
get_databases(std::vector< TDBInfo > &_return, const TSessionId &session) overrideDBHandler
get_db_object_privs(std::vector< TDBObject > &_return, const TSessionId &session, const std::string &objectName, const TDBObjectType::type type) overrideDBHandler
get_db_objects_for_grantee(std::vector< TDBObject > &_return, const TSessionId &session, const std::string &roleName) overrideDBHandler
get_device_parameters(std::map< std::string, std::string > &_return, const TSessionId &session) overrideDBHandler
get_first_geo_file_in_archive(std::string &_return, const TSessionId &session, const std::string &archive_path, const TCopyParams &copy_params) overrideDBHandler
get_function_details(std::vector< TUserDefinedFunction > &_return, const TSessionId &session, const std::vector< std::string > &udf_names) overrideDBHandler
get_function_names(std::vector< std::string > &_return, const TSessionId &session) overrideDBHandler
get_hardware_info(TClusterHardwareInfo &_return, const TSessionId &session) overrideDBHandler
get_heap_profile(std::string &_return, const TSessionId &session) overrideDBHandler
get_internal_table_details(TTableDetails &_return, const TSessionId &session, const std::string &table_name, const bool include_system_columns) overrideDBHandler
get_internal_table_details_for_database(TTableDetails &_return, const TSessionId &session, const std::string &table_name, const std::string &database_name) overrideDBHandler
get_layers_in_geo_file(std::vector< TGeoFileLayerInfo > &_return, const TSessionId &session, const std::string &file_name, const TCopyParams &copy_params) overrideDBHandler
get_license_claims(TLicenseInfo &_return, const TSessionId &session, const std::string &nonce) overrideDBHandler
get_link_view(TFrontendView &_return, const TSessionId &session, const std::string &link) overrideDBHandler
get_memory(std::vector< TNodeMemoryInfo > &_return, const TSessionId &session, const std::string &memory_level) overrideDBHandler
get_physical_tables(std::vector< std::string > &_return, const TSessionId &session) overrideDBHandler
get_queries_info(std::vector< TQueryInfo > &_return, const TSessionId &session) overrideDBHandlerprivate
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) overrideDBHandler
get_roles(std::vector< std::string > &_return, const TSessionId &session) overrideDBHandler
get_runtime_function_names(std::vector< std::string > &_return, const TSessionId &session) overrideDBHandler
get_runtime_table_function_names(std::vector< std::string > &_return, const TSessionId &session) overrideDBHandler
get_server_status(TServerStatus &_return, const TSessionId &session) overrideDBHandler
get_session_copy(const TSessionId &session_id)DBHandler
get_session_info(TSessionInfo &_return, const TSessionId &session) overrideDBHandler
get_session_ptr(const TSessionId &session_id)DBHandlerprotected
get_status(std::vector< TServerStatus > &_return, const TSessionId &session) overrideDBHandler
get_table_details(TTableDetails &_return, const TSessionId &session, const std::string &table_name) overrideDBHandler
get_table_details_for_database(TTableDetails &_return, const TSessionId &session, const std::string &table_name, const std::string &database_name) overrideDBHandler
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={})DBHandlerprivate
get_table_epoch(const TSessionId &session, const int32_t db_id, const int32_t table_id) overrideDBHandler
get_table_epoch_by_name(const TSessionId &session, const std::string &table_name) overrideDBHandler
get_table_epochs(std::vector< TTableEpochInfo > &_return, const TSessionId &session, const int32_t db_id, const int32_t table_id) overrideDBHandler
get_table_function_details(std::vector< TUserDefinedTableFunction > &_return, const TSessionId &session, const std::vector< std::string > &udtf_names) overrideDBHandler
get_table_function_names(std::vector< std::string > &_return, const TSessionId &session) overrideDBHandler
get_tables(std::vector< std::string > &_return, const TSessionId &session) overrideDBHandler
get_tables_for_database(std::vector< std::string > &_return, const TSessionId &session, const std::string &database_name) overrideDBHandler
get_tables_impl(std::vector< std::string > &table_names, const Catalog_Namespace::SessionInfo &, const GetTablesType get_tables_type, const std::string &database_name={})DBHandlerprivate
get_tables_meta(std::vector< TTableMeta > &_return, const TSessionId &session) overrideDBHandler
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)DBHandlerprivate
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)DBHandlerprivate
get_users(std::vector< std::string > &_return, const TSessionId &session) overrideDBHandler
get_valid_groups(const TSessionId &session, int32_t dashboard_id, std::vector< std::string > groups)DBHandler
get_version(std::string &_return) overrideDBHandler
get_views(std::vector< std::string > &_return, const TSessionId &session) overrideDBHandler
getAllRolesForUserImpl(std::shared_ptr< Catalog_Namespace::SessionInfo const > session_ptr, std::vector< std::string > &roles, const std::string &granteeName, bool effective)DBHandlerprivate
getConnectionInfo() const DBHandlerprotected
getExecutionMode(const TSessionId &session)DBHandler
getInvalidSessionId() const DBHandler
getQueries(std::shared_ptr< Catalog_Namespace::SessionInfo const > session_ptr)DBHandlerprivate
getServerRole() const DBHandlerprivate
getTargetMetaInfo(const std::vector< std::shared_ptr< Analyzer::TargetEntry >> &targets) const DBHandlerprivate
getTargetNames(const std::vector< TargetMetaInfo > &targets) const DBHandlerprivate
getTargetNames(const std::vector< std::shared_ptr< Analyzer::TargetEntry >> &targets) const DBHandlerprivate
getUserSessions(std::shared_ptr< Catalog_Namespace::SessionInfo const > session_ptr)DBHandlerprivate
handle_to_dev_ptr_mutex_DBHandlermutableprivate
has_dashboard_permission(const AccessPrivileges &privs, const TDBObjectPermissions &permissions)DBHandlerprivatestatic
has_database_permission(const AccessPrivileges &privs, const TDBObjectPermissions &permissions)DBHandlerprivatestatic
has_object_privilege(const TSessionId &sessionId, const std::string &granteeName, const std::string &objectName, const TDBObjectType::type object_type, const TDBObjectPermissions &permissions) overrideDBHandler
has_role(const TSessionId &sessionId, const std::string &granteeName, const std::string &roleName) overrideDBHandler
has_server_permission(const AccessPrivileges &privs, const TDBObjectPermissions &permissions)DBHandlerprivatestatic
has_table_permission(const AccessPrivileges &privs, const TDBObjectPermissions &permission)DBHandlerprivatestatic
has_view_permission(const AccessPrivileges &privs, const TDBObjectPermissions &permissions)DBHandlerprivatestatic
hasTableAccessPrivileges(const TableDescriptor *td, const Catalog_Namespace::SessionInfo &session_info)DBHandler
HeavyDBAggHandler classDBHandlerfriend
HeavyDBLeafHandler classDBHandlerfriend
idle_session_duration_DBHandlerprivate
import_geo_table(const TSessionId &session, const std::string &table_name, const std::string &file_name, const TCopyParams &copy_params, const TRowDescriptor &row_desc, const TCreateParams &create_params) overrideDBHandler
import_path_DBHandler
import_table(const TSessionId &session, const std::string &table_name, const std::string &file_name, const TCopyParams &copy_params) overrideDBHandler
import_table_status(TImportStatus &_return, const TSessionId &session, const std::string &import_id) overrideDBHandler
importGeoTableGlobFilterSort(const TSessionId &session, const std::string &table_name, const std::string &file_name, const import_export::CopyParams &copy_params, const TRowDescriptor &row_desc, const TCreateParams &create_params)DBHandlerprivate
importGeoTableSingle(const TSessionId &session, const std::string &table_name, const std::string &file_name, const import_export::CopyParams &copy_params, const TRowDescriptor &row_desc, const TCreateParams &create_params)DBHandlerprivate
init_executor_resource_mgr()DBHandlerprivate
initialize(const bool is_new_db)DBHandler
initialized_DBHandlerprivate
insert_chunks(const TSessionId &session, const TInsertChunks &insert_chunks) overrideDBHandler
insert_data(const TSessionId &session, const TInsertData &insert_data) overrideDBHandler
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) overrideDBHandler
interruptQuery(const Catalog_Namespace::SessionInfo &session_info, const std::string &target_session)DBHandlerprivate
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) overrideDBHandler
ipc_handle_to_dev_ptr_DBHandlermutableprivate
isAggregator() const DBHandler
jit_debug_DBHandler
krb5_connect(TKrb5Session &session, const std::string &token, const std::string &dbname) overrideDBHandler
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) overrideDBHandler
load_table_binary(const TSessionId &session, const std::string &table_name, const std::vector< TRow > &rows, const std::vector< std::string > &column_names) overrideDBHandler
load_table_binary_arrow(const TSessionId &session, const std::string &table_name, const std::string &arrow_stream, const bool use_column_names) overrideDBHandler
load_table_binary_columnar(const TSessionId &session, const std::string &table_name, const std::vector< TColumn > &cols, const std::vector< std::string > &column_names) overrideDBHandler
max_bytes_for_thrift()DBHandlerinlinestatic
max_concurrent_render_sessions_DBHandlerprivate
max_num_sessions_DBHandlerprivate
max_session_duration_DBHandlerprivate
num_reader_threads_DBHandlerprivate
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)DBHandlerprivate
pause_executor_queue(const TSessionId &session)DBHandler
permissionFuncMap_DBHandlerprivate
populateThriftColumnType(const Catalog_Namespace::Catalog *cat, const ColumnDescriptor *cd)DBHandlerprivate
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)DBHandlerprivate
process_deferred_copy_from(const TSessionId &session_id)DBHandlerprivate
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)DBHandlerprivate
query_engine_DBHandler
query_get_outer_fragment_count(const TSessionId &session, const std::string &select_query) overrideDBHandler
query_states_DBHandlerprivate
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) overrideDBHandler
removeInMemoryCalciteSession(const std::string &session_id)DBHandlerprivate
render_compositor_use_last_gpu_DBHandlerprivate
render_handler_DBHandler
render_mem_bytes_DBHandlerprivate
render_mutex_DBHandler
render_oom_retry_threshold_DBHandlerprivate
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)DBHandlerprivate
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) overrideDBHandler
renderer_enable_slab_allocation_DBHandlerprivate
renderer_prefer_igpu_DBHandlerprivate
renderer_use_parallel_executors_DBHandlerprivate
renderer_vulkan_timeout_DBHandlerprivate
RenderHandler::Impl classDBHandlerfriend
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) overrideDBHandler
reserved_gpu_mem_DBHandlerprivate
resetSessionsStore()DBHandlerprivate
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)DBHandlerfriend
session_id_dist_DBHandler
sessions_mutex_DBHandler
sessions_store_DBHandlerprivate
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) overrideDBHandler
set_execution_mode(const TSessionId &session, const TExecuteMode::type mode) overrideDBHandler
set_execution_mode_nolock(Catalog_Namespace::SessionInfo *session_ptr, const TExecuteMode::type mode)DBHandlerprivate
set_leaf_info(const TSessionId &session, const TLeafInfo &info) overrideDBHandler
set_license_key(TLicenseInfo &_return, const TSessionId &session, const std::string &key, const std::string &nonce) overrideDBHandler
set_table_epoch(const TSessionId &session, const int db_id, const int table_id, const int new_epoch) overrideDBHandler
set_table_epoch_by_name(const TSessionId &session, const std::string &table_name, const int new_epoch) overrideDBHandler
set_table_epochs(const TSessionId &session, const int32_t db_id, const std::vector< TTableEpochInfo > &table_epochs) overrideDBHandler
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) overrideDBHandler
share_dashboards(const TSessionId &session, const std::vector< int32_t > &dashboard_ids, const std::vector< std::string > &groups, const TDashboardPermissions &permissions) overrideDBHandler
shareOrUnshareDashboards(const TSessionId &session, const std::vector< int32_t > &dashboard_ids, const std::vector< std::string > &groups, const TDashboardPermissions &permissions, const bool do_share)DBHandlerprivate
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) overrideDBHandler
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) overrideDBHandler
sql_execute_gdf(TDataFrame &_return, const TSessionId &session, const std::string &query, const int32_t device_id, const int32_t first_n) overrideDBHandler
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)DBHandlerprivate
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)DBHandlerprivate
sql_validate(TRowDescriptor &_return, const TSessionId &session, const std::string &query) overrideDBHandler
start_heap_profile(const TSessionId &session) overrideDBHandler
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) overrideDBHandler
start_render_query(TPendingRenderQuery &_return, const TSessionId &session, const int64_t widget_id, const int16_t node_idx, const std::string &vega_json) overrideDBHandler
start_time_DBHandler
stop_heap_profile(const TSessionId &session) overrideDBHandler
string_leaves_DBHandler
super_user_rights_DBHandlerprivate
switch_database(const TSessionId &session, const std::string &dbname) overrideDBHandler
system_parameters_DBHandler
thrift_to_copyparams(const TCopyParams &cp)DBHandlerprivate
udf_filename_DBHandlerprivate
unescape_char(std::string str)DBHandlerprivate
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) overrideDBHandler
unshare_dashboards(const TSessionId &session, const std::vector< int32_t > &dashboard_ids, const std::vector< std::string > &groups, const TDashboardPermissions &permissions) overrideDBHandler
update_custom_expression(const TSessionId &session, const int32_t id, const std::string &expression_json) overrideDBHandler
user_can_access_table(const Catalog_Namespace::SessionInfo &, const TableDescriptor *td, const AccessPrivileges acess_priv)DBHandlerprivate
validate_configurations()DBHandlerprivate
validateDashboardIdsForSharing(const Catalog_Namespace::SessionInfo &session_info, const std::vector< int32_t > &dashboard_ids)DBHandlerprivate
validateGroups(const std::vector< std::string > &groups)DBHandlerprivate
validateRelAlg(const std::string &query_ra, QueryStateProxy query_state_proxy)DBHandlerprivate
value_to_thrift(const TargetValue &tv, const SQLTypeInfo &ti)DBHandlerprivatestatic
value_to_thrift_column(const TargetValue &tv, const SQLTypeInfo &ti, TColumn &column)DBHandlerprivatestatic
~DBHandler() overrideDBHandler