OmniSciDB
a5dc49c757
|
#include <DBHandler.h>
Classes | |
struct | DeferredCopyFromSessions |
struct | DeferredCopyFromState |
Public Member Functions | |
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) | |
void | initialize (const bool is_new_db) |
~DBHandler () override | |
void | krb5_connect (TKrb5Session &session, const std::string &token, const std::string &dbname) override |
void | connect (TSessionId &session, const std::string &username, const std::string &passwd, const std::string &dbname) override |
void | disconnect (const TSessionId &session) override |
void | switch_database (const TSessionId &session, const std::string &dbname) override |
void | clone_session (TSessionId &session2, const TSessionId &session1) override |
void | get_server_status (TServerStatus &_return, const TSessionId &session) override |
void | get_status (std::vector< TServerStatus > &_return, const TSessionId &session) override |
void | get_hardware_info (TClusterHardwareInfo &_return, const TSessionId &session) override |
bool | hasTableAccessPrivileges (const TableDescriptor *td, const Catalog_Namespace::SessionInfo &session_info) |
void | get_tables (std::vector< std::string > &_return, const TSessionId &session) override |
void | get_tables_for_database (std::vector< std::string > &_return, const TSessionId &session, const std::string &database_name) override |
void | get_physical_tables (std::vector< std::string > &_return, const TSessionId &session) override |
void | get_views (std::vector< std::string > &_return, const TSessionId &session) override |
void | get_tables_meta (std::vector< TTableMeta > &_return, const TSessionId &session) override |
void | get_table_details (TTableDetails &_return, const TSessionId &session, const std::string &table_name) override |
void | get_table_details_for_database (TTableDetails &_return, const TSessionId &session, const std::string &table_name, const std::string &database_name) override |
void | get_internal_table_details (TTableDetails &_return, const TSessionId &session, const std::string &table_name, const bool include_system_columns) override |
void | get_internal_table_details_for_database (TTableDetails &_return, const TSessionId &session, const std::string &table_name, const std::string &database_name) override |
void | get_users (std::vector< std::string > &_return, const TSessionId &session) override |
void | get_databases (std::vector< TDBInfo > &_return, const TSessionId &session) override |
void | get_version (std::string &_return) override |
void | start_heap_profile (const TSessionId &session) override |
void | stop_heap_profile (const TSessionId &session) override |
void | get_heap_profile (std::string &_return, const TSessionId &session) override |
void | get_memory (std::vector< TNodeMemoryInfo > &_return, const TSessionId &session, const std::string &memory_level) override |
void | clear_cpu_memory (const TSessionId &session) override |
void | clear_gpu_memory (const TSessionId &session) override |
void | clearRenderMemory (const TSessionId &session) |
void | pause_executor_queue (const TSessionId &session) |
void | resume_executor_queue (const TSessionId &session) |
void | 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 |
void | 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 |
void | set_table_epoch (const TSessionId &session, const int db_id, const int table_id, const int new_epoch) override |
void | set_table_epoch_by_name (const TSessionId &session, const std::string &table_name, const int new_epoch) override |
int32_t | get_table_epoch (const TSessionId &session, const int32_t db_id, const int32_t table_id) override |
int32_t | get_table_epoch_by_name (const TSessionId &session, const std::string &table_name) override |
void | get_table_epochs (std::vector< TTableEpochInfo > &_return, const TSessionId &session, const int32_t db_id, const int32_t table_id) override |
void | set_table_epochs (const TSessionId &session, const int32_t db_id, const std::vector< TTableEpochInfo > &table_epochs) override |
void | get_session_info (TSessionInfo &_return, const TSessionId &session) override |
void | set_leaf_info (const TSessionId &session, const TLeafInfo &info) override |
void | 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) |
void | 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 |
void | get_completion_hints (std::vector< TCompletionHint > &hints, const TSessionId &session, const std::string &sql, const int cursor) override |
void | 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 |
void | sql_execute_gdf (TDataFrame &_return, const TSessionId &session, const std::string &query, const int32_t device_id, const int32_t first_n) override |
void | deallocate_df (const TSessionId &session, const TDataFrame &df, const TDeviceType::type device_type, const int32_t device_id) override |
void | interrupt (const TSessionId &query_session, const TSessionId &interrupt_session) override |
void | sql_validate (TRowDescriptor &_return, const TSessionId &session, const std::string &query) override |
TExecuteMode::type | getExecutionMode (const TSessionId &session) |
void | set_execution_mode (const TSessionId &session, const TExecuteMode::type mode) override |
void | 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 |
void | 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 |
int32_t | create_custom_expression (const TSessionId &session, const TCustomExpression &custom_expression) override |
void | get_custom_expressions (std::vector< TCustomExpression > &_return, const TSessionId &session) override |
void | update_custom_expression (const TSessionId &session, const int32_t id, const std::string &expression_json) override |
void | delete_custom_expressions (const TSessionId &session, const std::vector< int32_t > &custom_expression_ids, const bool do_soft_delete) override |
void | get_dashboard (TDashboard &_return, const TSessionId &session, const int32_t dashboard_id) override |
void | get_dashboards (std::vector< TDashboard > &_return, const TSessionId &session) override |
int32_t | 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 |
void | 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 |
void | delete_dashboard (const TSessionId &session, const int32_t dashboard_id) override |
void | share_dashboards (const TSessionId &session, const std::vector< int32_t > &dashboard_ids, const std::vector< std::string > &groups, const TDashboardPermissions &permissions) override |
void | delete_dashboards (const TSessionId &session, const std::vector< int32_t > &dashboard_ids) override |
void | 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 |
void | unshare_dashboards (const TSessionId &session, const std::vector< int32_t > &dashboard_ids, const std::vector< std::string > &groups, const TDashboardPermissions &permissions) override |
void | 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 |
void | get_dashboard_grantees (std::vector< TDashboardGrantees > &_return, const TSessionId &session, const int32_t dashboard_id) override |
void | get_link_view (TFrontendView &_return, const TSessionId &session, const std::string &link) override |
void | create_link (std::string &_return, const TSessionId &session, const std::string &view_state, const std::string &view_metadata) override |
void | load_table_binary (const TSessionId &session, const std::string &table_name, const std::vector< TRow > &rows, const std::vector< std::string > &column_names) override |
void | 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 |
void | load_table_binary_arrow (const TSessionId &session, const std::string &table_name, const std::string &arrow_stream, const bool use_column_names) override |
void | load_table (const TSessionId &session, const std::string &table_name, const std::vector< TStringRow > &rows, const std::vector< std::string > &column_names) override |
void | detect_column_types (TDetectResult &_return, const TSessionId &session, const std::string &file_name, const TCopyParams ©_params) override |
void | create_table (const TSessionId &session, const std::string &table_name, const TRowDescriptor &row_desc, const TCreateParams &create_params) override |
void | import_table (const TSessionId &session, const std::string &table_name, const std::string &file_name, const TCopyParams ©_params) override |
void | 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 |
void | import_table_status (TImportStatus &_return, const TSessionId &session, const std::string &import_id) override |
void | get_first_geo_file_in_archive (std::string &_return, const TSessionId &session, const std::string &archive_path, const TCopyParams ©_params) override |
void | get_all_files_in_archive (std::vector< std::string > &_return, const TSessionId &session, const std::string &archive_path, const TCopyParams ©_params) override |
void | get_layers_in_geo_file (std::vector< TGeoFileLayerInfo > &_return, const TSessionId &session, const std::string &file_name, const TCopyParams ©_params) override |
int64_t | query_get_outer_fragment_count (const TSessionId &session, const std::string &select_query) override |
void | check_table_consistency (TTableMeta &_return, const TSessionId &session, const int32_t table_id) override |
void | 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 |
void | execute_query_step (TStepResult &_return, const TPendingQuery &pending_query, const TSubqueryId subquery_id, const std::string &start_time_str) override |
void | 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 |
void | start_render_query (TPendingRenderQuery &_return, const TSessionId &session, const int64_t widget_id, const int16_t node_idx, const std::string &vega_json) override |
void | execute_next_render_step (TRenderStepResult &_return, const TPendingRenderQuery &pending_render, const TRenderAggDataMap &merged_data) override |
void | insert_data (const TSessionId &session, const TInsertData &insert_data) override |
void | insert_chunks (const TSessionId &session, const TInsertChunks &insert_chunks) override |
void | checkpoint (const TSessionId &session, const int32_t table_id) override |
void | get_roles (std::vector< std::string > &_return, const TSessionId &session) override |
bool | has_role (const TSessionId &sessionId, const std::string &granteeName, const std::string &roleName) override |
bool | has_object_privilege (const TSessionId &sessionId, const std::string &granteeName, const std::string &objectName, const TDBObjectType::type object_type, const TDBObjectPermissions &permissions) override |
void | get_db_objects_for_grantee (std::vector< TDBObject > &_return, const TSessionId &session, const std::string &roleName) override |
void | get_db_object_privs (std::vector< TDBObject > &_return, const TSessionId &session, const std::string &objectName, const TDBObjectType::type type) override |
void | get_all_roles_for_user (std::vector< std::string > &_return, const TSessionId &session, const std::string &granteeName) override |
void | get_all_effective_roles_for_user (std::vector< std::string > &_return, const TSessionId &session, const std::string &granteeName) override |
std::vector< std::string > | get_valid_groups (const TSessionId &session, int32_t dashboard_id, std::vector< std::string > groups) |
void | set_license_key (TLicenseInfo &_return, const TSessionId &session, const std::string &key, const std::string &nonce) override |
void | get_license_claims (TLicenseInfo &_return, const TSessionId &session, const std::string &nonce) override |
void | get_device_parameters (std::map< std::string, std::string > &_return, const TSessionId &session) override |
void | 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 |
void | get_function_names (std::vector< std::string > &_return, const TSessionId &session) override |
void | get_runtime_function_names (std::vector< std::string > &_return, const TSessionId &session) override |
void | get_function_details (std::vector< TUserDefinedFunction > &_return, const TSessionId &session, const std::vector< std::string > &udf_names) override |
void | get_table_function_names (std::vector< std::string > &_return, const TSessionId &session) override |
void | get_runtime_table_function_names (std::vector< std::string > &_return, const TSessionId &session) override |
void | get_table_function_details (std::vector< TUserDefinedTableFunction > &_return, const TSessionId &session, const std::vector< std::string > &udtf_names) override |
void | shutdown () |
void | emergency_shutdown () |
TSessionId | getInvalidSessionId () const |
void | internal_connect (TSessionId &session, const std::string &username, const std::string &dbname) |
bool | isAggregator () const |
bool | checkInMemorySystemTableQuery (const std::unordered_set< shared::TableKey > &tables_selected_from) const |
template<typename... ARGS> | |
std::shared_ptr < query_state::QueryState > | create_query_state (ARGS &&...args) |
Catalog_Namespace::SessionInfo | get_session_copy (const TSessionId &session_id) |
void | get_tables_meta_impl (std::vector< TTableMeta > &_return, QueryStateProxy query_state_proxy, const Catalog_Namespace::SessionInfo &session_info, const bool with_table_locks=true) |
void | resizeDispatchQueue (size_t queue_size) |
Static Public Member Functions | |
static size_t | max_bytes_for_thrift () |
Protected Member Functions | |
std::shared_ptr < Catalog_Namespace::SessionInfo > | get_session_ptr (const TSessionId &session_id) |
ConnectionInfo | getConnectionInfo () const |
Private Member Functions | |
void | init_executor_resource_mgr () |
void | validate_configurations () |
std::shared_ptr < Catalog_Namespace::SessionInfo > | create_new_session (TSessionId &session, const std::string &dbname, const Catalog_Namespace::UserMetadata &user_meta, std::shared_ptr< Catalog_Namespace::Catalog > cat) |
void | 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) |
void | disconnect_impl (Catalog_Namespace::SessionInfoPtr &session_ptr) |
void | check_table_load_privileges (const Catalog_Namespace::SessionInfo &session_info, const std::string &table_name) |
void | get_tables_impl (std::vector< std::string > &table_names, const Catalog_Namespace::SessionInfo &, const GetTablesType get_tables_type, const std::string &database_name={}) |
void | 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={}) |
void | getAllRolesForUserImpl (std::shared_ptr< Catalog_Namespace::SessionInfo const > session_ptr, std::vector< std::string > &roles, const std::string &granteeName, bool effective) |
void | check_read_only (const std::string &str) |
void | validateGroups (const std::vector< std::string > &groups) |
void | validateDashboardIdsForSharing (const Catalog_Namespace::SessionInfo &session_info, const std::vector< int32_t > &dashboard_ids) |
void | shareOrUnshareDashboards (const TSessionId &session, const std::vector< int32_t > &dashboard_ids, const std::vector< std::string > &groups, const TDashboardPermissions &permissions, const bool do_share) |
std::pair< TPlanResult, lockmgr::LockedTableDescriptors > | 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) |
void | 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) |
int64_t | process_deferred_copy_from (const TSessionId &session_id) |
void | 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) |
bool | user_can_access_table (const Catalog_Namespace::SessionInfo &, const TableDescriptor *td, const AccessPrivileges acess_priv) |
void | execute_distributed_copy_statement (Parser::CopyTableStmt *, const Catalog_Namespace::SessionInfo &session_info) |
TPlanResult | 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) |
TRowDescriptor | validateRelAlg (const std::string &query_ra, QueryStateProxy query_state_proxy) |
void | dispatch_query_task (std::shared_ptr< QueryDispatchQueue::Task > query_task, const bool is_update_delete) |
std::vector< PushedDownFilterInfo > | 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 |
void | 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) |
void | executeDdl (TQueryResult &_return, const std::string &query_ra, std::shared_ptr< Catalog_Namespace::SessionInfo const > session_ptr) |
void | executeDdl (ExecutionResult &_return, const std::string &query_ra, std::shared_ptr< Catalog_Namespace::SessionInfo const > session_ptr) |
TColumnType | populateThriftColumnType (const Catalog_Namespace::Catalog *cat, const ColumnDescriptor *cd) |
void | set_execution_mode_nolock (Catalog_Namespace::SessionInfo *session_ptr, const TExecuteMode::type mode) |
char | unescape_char (std::string str) |
import_export::CopyParams | thrift_to_copyparams (const TCopyParams &cp) |
TCopyParams | copyparams_to_thrift (const import_export::CopyParams &cp) |
void | check_geospatial_files (const boost::filesystem::path file_path, const import_export::CopyParams ©_params) |
void | 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) |
TColumnType | create_geo_column (const TDatumType::type type, const std::string &name, const bool is_array) |
void | convertResultSet (ExecutionResult &result, const Catalog_Namespace::SessionInfo &session_info, const std::string &query_state_str, TQueryResult &_return) |
std::vector< TargetMetaInfo > | getTargetMetaInfo (const std::vector< std::shared_ptr< Analyzer::TargetEntry >> &targets) const |
std::vector< std::string > | getTargetNames (const std::vector< TargetMetaInfo > &targets) const |
std::vector< std::string > | getTargetNames (const std::vector< std::shared_ptr< Analyzer::TargetEntry >> &targets) const |
void | 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) |
void | 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) |
std::unordered_map < std::string, std::unordered_set < std::string > > | fill_column_names_by_table (std::vector< std::string > &table_names, query_state::StdLog &stdlog) |
TDashboard | 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) |
std::unordered_set< std::string > | 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) |
std::unique_ptr < lockmgr::AbstractLockContainer < const TableDescriptor * > > | 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) |
void | 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) |
void | 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) |
Catalog_Namespace::SessionInfoPtr | findCalciteSession (TSessionId const &) const |
void | check_and_invalidate_sessions (Parser::DDLStmt *ddl) |
std::string const | createInMemoryCalciteSession (const std::shared_ptr< Catalog_Namespace::Catalog > &catalog_ptr) |
void | removeInMemoryCalciteSession (const std::string &session_id) |
ExecutionResult | getUserSessions (std::shared_ptr< Catalog_Namespace::SessionInfo const > session_ptr) |
ExecutionResult | getQueries (std::shared_ptr< Catalog_Namespace::SessionInfo const > session_ptr) |
void | get_queries_info (std::vector< TQueryInfo > &_return, const TSessionId &session) override |
void | interruptQuery (const Catalog_Namespace::SessionInfo &session_info, const std::string &target_session) |
void | alterSystemClear (const std::string &sesson_id, ExecutionResult &result, const std::string &cache_type, int64_t &execution_time_ms) |
void | alterSession (const std::string &sesson_id, ExecutionResult &result, const std::pair< std::string, std::string > &session_parameter, int64_t &execution_time_ms) |
TRole::type | getServerRole () const |
void | 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) |
void | 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) |
void | resetSessionsStore () |
Static Private Member Functions | |
static void | value_to_thrift_column (const TargetValue &tv, const SQLTypeInfo &ti, TColumn &column) |
static TDatum | value_to_thrift (const TargetValue &tv, const SQLTypeInfo &ti) |
static void | 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) |
static void | convertExplain (TQueryResult &_return, const ResultSet &results, const bool column_format) |
static void | convertResult (TQueryResult &_return, const ResultSet &results, const bool column_format) |
static void | 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) |
static void | createSimpleResult (TQueryResult &_return, const ResultSet &results, const bool column_format, const std::string label) |
static bool | has_database_permission (const AccessPrivileges &privs, const TDBObjectPermissions &permissions) |
static bool | has_table_permission (const AccessPrivileges &privs, const TDBObjectPermissions &permission) |
static bool | has_dashboard_permission (const AccessPrivileges &privs, const TDBObjectPermissions &permissions) |
static bool | has_view_permission (const AccessPrivileges &privs, const TDBObjectPermissions &permissions) |
static bool | has_server_permission (const AccessPrivileges &privs, const TDBObjectPermissions &permissions) |
Friends | |
class | RenderHandler::Impl |
class | HeavyDBAggHandler |
class | HeavyDBLeafHandler |
void | run_warmup_queries (std::shared_ptr< DBHandler > handler, std::string base_path, std::string query_file_path) |
Definition at line 165 of file DBHandler.h.
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 | ||
) |
Definition at line 169 of file DBHandler.cpp.
|
override |
Definition at line 576 of file DBHandler.cpp.
References shutdown().
|
private |
Definition at line 8045 of file DBHandler.cpp.
References measure< TimeT >::execution(), set_execution_mode(), switch_database(), to_upper(), and run_benchmark_import::type.
Referenced by executeDdl().
|
private |
Definition at line 8029 of file DBHandler.cpp.
References clear_cpu_memory(), clear_gpu_memory(), clearRenderMemory(), measure< TimeT >::execution(), and to_upper().
Referenced by executeDdl().
|
override |
Definition at line 7106 of file DBHandler.cpp.
References measure< TimeT >::execution(), logger::INFO, leaf_handler_, LOG, and THROW_DB_EXCEPTION.
|
private |
Definition at line 6433 of file DBHandler.cpp.
References sessions_store_.
|
private |
Definition at line 5170 of file DBHandler.cpp.
References import_export::Importer::gdalFileExists().
Referenced by detect_column_types(), and importGeoTableSingle().
|
private |
Definition at line 580 of file DBHandler.cpp.
References read_only_, and THROW_DB_EXCEPTION.
Referenced by create_custom_expression(), create_dashboard(), create_table(), delete_custom_expressions(), delete_dashboards(), detect_column_types(), import_table(), importGeoTableSingle(), prepare_loader_generic(), replace_dashboard(), set_license_key(), shareOrUnshareDashboards(), sql_execute_impl(), and update_custom_expression().
|
override |
Definition at line 7037 of file DBHandler.cpp.
References get_session_ptr(), leaf_handler_, heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, and THROW_DB_EXCEPTION.
|
private |
Definition at line 6169 of file DBHandler.cpp.
References cat(), Catalog_Namespace::SessionInfo::get_currentUser(), Catalog_Namespace::SessionInfo::getCatalog(), AccessPrivileges::INSERT_INTO_TABLE, lockmgr::instance(), DBObject::loadKey(), DBObject::setPrivileges(), TableDBObjectType, and THROW_DB_EXCEPTION.
Referenced by import_table(), importGeoTableSingle(), and prepare_loader_generic().
bool DBHandler::checkInMemorySystemTableQuery | ( | const std::unordered_set< shared::TableKey > & | tables_selected_from | ) | const |
Definition at line 8184 of file DBHandler.cpp.
References CHECK, anonymous_namespace{DBHandler.cpp}::check_and_reset_in_memory_system_table(), Catalog_Namespace::SysCatalog::getCatalog(), Catalog_Namespace::SysCatalog::instance(), and shared::kInfoSchemaDbName.
|
override |
Definition at line 7352 of file DBHandler.cpp.
References cat(), get_session_ptr(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, and STDLOG.
|
override |
Definition at line 2911 of file DBHandler.cpp.
References Executor::clearMemory(), Data_Namespace::CPU_LEVEL, get_session_ptr(), anonymous_namespace{DBHandler.cpp}::pause_and_resume_executor_queue(), render_handler_, heavyai::RequestInfo::requestId(), resume_executor_queue(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, and THROW_DB_EXCEPTION.
Referenced by alterSystemClear().
|
override |
Definition at line 2887 of file DBHandler.cpp.
References Executor::clearMemory(), get_session_ptr(), getConnectionInfo(), Data_Namespace::GPU_LEVEL, anonymous_namespace{DBHandler.cpp}::pause_and_resume_executor_queue(), render_handler_, heavyai::RequestInfo::requestId(), resume_executor_queue(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, THROW_DB_EXCEPTION, and toString().
Referenced by alterSystemClear().
void DBHandler::clearRenderMemory | ( | const TSessionId & | session | ) |
Definition at line 2934 of file DBHandler.cpp.
References get_session_ptr(), getConnectionInfo(), anonymous_namespace{DBHandler.cpp}::pause_and_resume_executor_queue(), render_handler_, heavyai::RequestInfo::requestId(), resume_executor_queue(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, THROW_DB_EXCEPTION, and toString().
Referenced by alterSystemClear().
|
override |
Definition at line 768 of file DBHandler.cpp.
References cat(), LeafAggregator::clone_session(), executor_device_type_, get_session_ptr(), getConnectionInfo(), logger::INFO, leaf_aggregator_, LeafAggregator::leafCount(), LOG, heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), sessions_store_, SET_REQUEST_ID, STDLOG, THROW_DB_EXCEPTION, toString(), and Catalog_Namespace::UserMetadata::userLoggable().
|
override |
Definition at line 658 of file DBHandler.cpp.
References AccessPrivileges::ACCESS, cat(), connect_impl(), DatabaseDBObjectType, getConnectionInfo(), lockmgr::instance(), DBObject::loadKey(), logger::set_new_request_id(), DBObject::setPrivileges(), STDLOG, super_user_rights_, THROW_DB_EXCEPTION, toString(), and Catalog_Namespace::UserMetadata::userLoggable().
|
private |
Definition at line 694 of file DBHandler.cpp.
References query_state::StdLog::appendNameValuePairs(), executor_device_type_, getConnectionInfo(), query_state::StdLog::getConstSessionInfo(), logger::INFO, lockmgr::instance(), join(), LOG, sessions_store_, query_state::StdLog::setSessionInfo(), super_user_rights_, toString(), and Catalog_Namespace::UserMetadata::userLoggable().
Referenced by connect(), and internal_connect().
|
staticprivate |
Definition at line 1250 of file DBHandler.cpp.
References ExecutionResult::CalciteDdl, convertExplain(), convertResult(), convertRows(), ExecutionResult::empty(), ExecutionResult::Explanation, ExecutionResult::getExecutionTime(), ExecutionResult::getResultType(), ExecutionResult::getRows(), ExecutionResult::getTargetsMeta(), ExecutionResult::QueryResult, and ExecutionResult::SimpleResult.
Referenced by convertResultSet(), get_tables_meta_impl(), sql_execute_local(), and validateRelAlg().
|
staticprivate |
Definition at line 6405 of file DBHandler.cpp.
References createSimpleResult().
Referenced by convertData().
|
staticprivate |
Definition at line 6411 of file DBHandler.cpp.
References createSimpleResult().
Referenced by convertData().
|
private |
Definition at line 7746 of file DBHandler.cpp.
References CHECK, convertData(), create_query_state(), query_state::QueryState::createQueryStateProxy(), Catalog_Namespace::SessionInfo::get_session_id(), get_session_ptr(), and ExecutionResult::getDataPtr().
Referenced by executeDdl().
|
staticprivate |
Definition at line 6313 of file DBHandler.cpp.
References query_state::QueryStateProxy::createTimer(), ThriftSerializers::target_meta_infos_to_thrift(), THROW_DB_EXCEPTION, to_string(), value_to_thrift(), and value_to_thrift_column().
Referenced by convertData().
|
private |
Definition at line 4049 of file DBHandler.cpp.
References import_export::CopyParams::add_metadata_columns, import_export::CopyParams::array_begin, import_export::CopyParams::array_delim, import_export::CopyParams::array_end, CHECK, import_export::CopyParams::connection_string, import_export::CopyParams::credential_string, import_export::CopyParams::delimiter, import_export::CopyParams::dsn, import_export::CopyParams::escape, import_export::CopyParams::geo_coords_comp_param, import_export::CopyParams::geo_coords_encoding, import_export::CopyParams::geo_coords_srid, import_export::CopyParams::geo_coords_type, import_export::CopyParams::geo_explode_collections, import_export::CopyParams::geo_layer_name, import_export::CopyParams::geo_validate_geometry, import_export::CopyParams::has_header, import_export::kAuto, import_export::kAutoDetect, import_export::kDelimitedFile, import_export::kDouble, kENCODING_GEOINT, import_export::kFile, import_export::kFloat, import_export::kGeoFile, kGEOGRAPHY, kGEOMETRY, import_export::kHasHeader, import_export::kInt, import_export::kNoHeader, import_export::kNone, import_export::kOdbc, import_export::kParquetFile, import_export::kPoint, import_export::kRasterFile, import_export::kSmallInt, import_export::kWorld, import_export::CopyParams::line_delim, import_export::CopyParams::null_str, import_export::CopyParams::password, import_export::CopyParams::quote, import_export::CopyParams::quoted, import_export::CopyParams::raster_drop_if_all_null, import_export::CopyParams::raster_import_bands, import_export::CopyParams::raster_import_dimensions, import_export::CopyParams::raster_point_compute_angle, import_export::CopyParams::raster_point_transform, import_export::CopyParams::raster_point_type, import_export::CopyParams::raster_scanlines_per_thread, import_export::CopyParams::s3_access_key, import_export::CopyParams::s3_endpoint, import_export::CopyParams::s3_region, import_export::CopyParams::s3_secret_key, import_export::CopyParams::s3_session_token, import_export::CopyParams::sanitize_column_names, import_export::CopyParams::source_srid, import_export::CopyParams::source_type, import_export::CopyParams::sql_order_by, import_export::CopyParams::sql_select, import_export::CopyParams::threads, import_export::CopyParams::trim_spaces, and import_export::CopyParams::username.
Referenced by detect_column_types(), and importGeoTableSingle().
|
override |
Definition at line 4625 of file DBHandler.cpp.
References check_read_only(), anonymous_namespace{DBHandler.cpp}::create_custom_expr_from_thrift_obj(), custom_expressions_mutex_, get_session_ptr(), getConnectionInfo(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, THROW_DB_EXCEPTION, and toString().
|
override |
Definition at line 4824 of file DBHandler.cpp.
References cat(), CHECK, dbhandler::check_not_info_schema_db(), check_read_only(), AccessPrivileges::CREATE_DASHBOARD, anonymous_namespace{DBHandler.cpp}::dashboard_exists(), DashboardDBObjectType, DashboardDescriptor::dashboardMetadata, DashboardDescriptor::dashboardName, DashboardDescriptor::dashboardState, g_allow_system_dashboard_update, get_session_ptr(), getConnectionInfo(), DashboardDescriptor::imageHash, lockmgr::instance(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, THROW_DB_EXCEPTION, toString(), DashboardDescriptor::user, and DashboardDescriptor::userId.
|
private |
Definition at line 5160 of file DBHandler.cpp.
References setup::name, and run_benchmark_import::type.
|
override |
Definition at line 5136 of file DBHandler.cpp.
References cat(), get_session_ptr(), getConnectionInfo(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, THROW_DB_EXCEPTION, toString(), LinkDescriptor::userId, LinkDescriptor::viewMetadata, and LinkDescriptor::viewState.
|
private |
|
inline |
Definition at line 663 of file DBHandler.h.
References run_benchmark_import::args.
Referenced by convertResultSet(), get_table_details_impl(), get_tables_meta(), sql_execute(), sql_execute_df(), and sql_validate().
|
override |
Definition at line 5191 of file DBHandler.cpp.
References check_read_only(), getConnectionInfo(), ImportHelpers::is_reserved_name(), join(), heavyai::RequestInfo::json(), kENCODING_DATE_IN_DAYS, kENCODING_DICT, kENCODING_FIXED, kENCODING_GEOINT, kENCODING_NONE, logger::request_id(), heavyai::RequestInfo::requestId(), ImportHelpers::sanitize_name(), SET_REQUEST_ID, heavyai::RequestInfo::setRequestId(), sql_execute(), STDLOG, thrift_to_encoding(), thrift_to_encoding_name(), thrift_to_name(), THROW_DB_EXCEPTION, to_string(), and toString().
Referenced by importGeoTableSingle().
|
private |
Definition at line 586 of file DBHandler.cpp.
References calcite_, Catalog_Namespace::CALCITE_SESSION_ID_LENGTH, calcite_sessions_, calcite_sessions_mtx_, CHECK, executor_device_type_, and generate_random_string().
Referenced by processCalciteRequest().
|
staticprivate |
Definition at line 6368 of file DBHandler.cpp.
References CHECK, CHECK_EQ, and run_benchmark_import::label.
Referenced by convertExplain(), and convertResult().
|
override |
Definition at line 1562 of file DBHandler.cpp.
References CPU, data_mgr_, ArrowResultSet::deallocateArrowResultBuffer(), logger::ERROR, get_session_ptr(), GPU, handle_to_dev_ptr_mutex_, ipc_handle_to_dev_ptr_, LOG, heavyai::RequestInfo::requestId(), run_benchmark_import::result, heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, and STDLOG.
|
override |
Definition at line 4678 of file DBHandler.cpp.
References check_read_only(), custom_expressions_mutex_, get_session_ptr(), getConnectionInfo(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, THROW_DB_EXCEPTION, and toString().
|
override |
Definition at line 4921 of file DBHandler.cpp.
References delete_dashboards().
|
override |
Definition at line 4926 of file DBHandler.cpp.
References cat(), dbhandler::check_not_info_schema_db(), check_read_only(), g_allow_system_dashboard_update, get_session_ptr(), getConnectionInfo(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, THROW_DB_EXCEPTION, and toString().
Referenced by delete_dashboard().
|
override |
Definition at line 4340 of file DBHandler.cpp.
References anonymous_namespace{DBHandler.cpp}::add_vsi_archive_prefix(), anonymous_namespace{DBHandler.cpp}::add_vsi_geo_prefix(), anonymous_namespace{DBHandler.cpp}::add_vsi_network_prefix(), CHECK, check_geospatial_files(), check_read_only(), copyparams_to_thrift(), encoding_to_thrift(), shared::file_or_glob_path_exists(), import_export::CopyParams::file_sort_order_by, import_export::CopyParams::file_sort_regex, anonymous_namespace{DBHandler.cpp}::find_first_geo_file_in_archive(), import_export::Importer::gdalFileExists(), import_export::Importer::gdalFileOrDirectoryExists(), import_export::Importer::gdalToColumnDescriptors(), import_export::CopyParams::geo_coords_comp_param, import_export::CopyParams::geo_coords_encoding, import_export::CopyParams::geo_coords_srid, import_export::CopyParams::geo_coords_type, import_export::DataStreamSink::get_copy_params(), import_export::Detector::get_headers(), import_export::Detector::get_sample_rows(), get_session_ptr(), import_export::Detector::getBestColumnTypes(), getConnectionInfo(), import_path_, anonymous_namespace{DBHandler.cpp}::is_a_supported_archive_file(), anonymous_namespace{DBHandler.cpp}::is_local_file(), ImportHelpers::is_reserved_name(), shared::kDefaultSampleRowsCount, import_export::kDelimitedFile, Geospatial::kGeoColumnName, import_export::kGeoFile, import_export::kOdbc, import_export::kParquetFile, import_export::kRasterFile, shared::local_glob_filter_sort_files(), anonymous_namespace{DBHandler.cpp}::path_is_relative(), populateThriftColumnType(), import_export::Importer::readMetadataSampleGDAL(), import_export::CopyParams::regex_path_filter, heavyai::RequestInfo::requestId(), import_export::CopyParams::sanitize_column_names, ImportHelpers::sanitize_name(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, import_export::CopyParams::source_type, STDLOG, thrift_to_copyparams(), THROW_DB_EXCEPTION, toString(), type_to_thrift(), and anonymous_namespace{DBHandler.cpp}::validate_import_file_path_if_local().
Referenced by importGeoTableSingle().
|
override |
Definition at line 719 of file DBHandler.cpp.
References get_session_ptr(), getConnectionInfo(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), sessions_store_, SET_REQUEST_ID, STDLOG, and toString().
|
private |
Definition at line 727 of file DBHandler.cpp.
References LeafAggregator::disconnect(), leaf_aggregator_, LeafAggregator::leafCount(), and render_handler_.
Referenced by resetSessionsStore().
|
private |
Definition at line 1820 of file DBHandler.cpp.
References CHECK, and dispatch_queue_.
Referenced by validateRelAlg().
void DBHandler::emergency_shutdown | ( | ) |
Definition at line 7565 of file DBHandler.cpp.
References calcite_.
Referenced by shutdown().
|
private |
Definition at line 6838 of file DBHandler.cpp.
Referenced by sql_execute_impl().
|
override |
Definition at line 7330 of file DBHandler.cpp.
References measure< TimeT >::execution(), logger::INFO, LOG, render_handler_, SET_REQUEST_ID, and THROW_DB_EXCEPTION.
|
override |
Definition at line 7086 of file DBHandler.cpp.
References measure< TimeT >::execution(), logger::INFO, leaf_handler_, LOG, SET_REQUEST_ID, and THROW_DB_EXCEPTION.
|
private |
Definition at line 6206 of file DBHandler.cpp.
References allow_loop_joins_, allow_multifrag_, query_state::QueryStateProxy::createTimer(), Default, measure< TimeT >::execution(), ExecutionResult::Explanation, g_dynamic_watchdog_time_limit, g_enable_columnar_output, g_enable_dynamic_watchdog, g_enable_runtime_query_interrupt, g_enable_watchdog, g_optimize_cuda_block_and_grid_sizes, g_pending_query_interrupt_freq, g_running_query_interrupt_freq, query_state::QueryState::getConstSessionInfo(), ExecutionResult::getExecutionTime(), Executor::getExecutor(), ExecutionResult::getPushedDownFilterInfo(), ExecutionResult::getRows(), SystemParameters::gpu_input_mem_limit, lockmgr::TableSchemaLockMgr::instance(), lockmgr::TableDataLockMgr::instance(), intel_jit_profile_, ExplainInfo::isCalciteExplain(), ExplainInfo::isJustExplain(), ExplainInfo::isOptimizedExplain(), ExplainInfo::isPlanExplain(), ExplainInfo::isVerbose(), jit_debug_, Optimized, ExecutionResult::QueryResult, ExecutionResult::setExecutionTime(), ExecutionResult::setResultType(), system_parameters_, Executor::UNITARY_EXECUTOR_ID, and VLOG.
Referenced by execute_rel_alg_with_filter_push_down(), get_tables_meta_impl(), sql_execute_impl(), and validateRelAlg().
|
private |
Definition at line 6794 of file DBHandler.cpp.
References ExecutionResult::addExecutionTime(), execute_rel_alg(), query_state::QueryState::getQueryStr(), ExplainInfo::None, parse_to_ra(), and system_parameters_.
Referenced by sql_execute_impl().
|
private |
Definition at line 8070 of file DBHandler.cpp.
References alterSession(), alterSystemClear(), DdlCommandExecutor::commandStr(), convertResultSet(), ExecutionResult::empty(), DdlCommandExecutor::execute(), measure< TimeT >::execution(), getQueries(), ExecutionResult::getRows(), DdlCommandExecutor::getSessionParameter(), DdlCommandExecutor::getTargetQuerySessionToKill(), getUserSessions(), interruptQuery(), DdlCommandExecutor::isAlterSessionSet(), DdlCommandExecutor::isAlterSystemClear(), DdlCommandExecutor::isAlterSystemControlExecutorQueue(), DdlCommandExecutor::isKillQuery(), DdlCommandExecutor::isShowQueries(), DdlCommandExecutor::isShowUserSessions(), pause_executor_queue(), read_only_, run_benchmark_import::result, resume_executor_queue(), DdlCommandExecutor::returnCacheType(), and DdlCommandExecutor::returnQueueAction().
Referenced by sql_execute_impl().
|
private |
Definition at line 8127 of file DBHandler.cpp.
References alterSession(), alterSystemClear(), ExecutionResult::CalciteDdl, DdlCommandExecutor::commandStr(), DdlCommandExecutor::execute(), measure< TimeT >::execution(), getQueries(), ExecutionResult::getResultType(), DdlCommandExecutor::getSessionParameter(), DdlCommandExecutor::getTargetQuerySessionToKill(), getUserSessions(), interruptQuery(), DdlCommandExecutor::isAlterSessionSet(), DdlCommandExecutor::isAlterSystemClear(), DdlCommandExecutor::isAlterSystemControlExecutorQueue(), DdlCommandExecutor::isKillQuery(), DdlCommandExecutor::isShowQueries(), DdlCommandExecutor::isShowUserSessions(), pause_executor_queue(), ExecutionResult::QueryResult, read_only_, resume_executor_queue(), DdlCommandExecutor::returnCacheType(), DdlCommandExecutor::returnQueueAction(), ExecutionResult::setExecutionTime(), and ExecutionResult::setResultType().
|
private |
Definition at line 1770 of file DBHandler.cpp.
References get_table_details_impl().
Referenced by get_token_based_completions().
|
private |
Definition at line 3237 of file DBHandler.cpp.
References ColumnDescriptor::columnName, ColumnDescriptor::columnType, Geospatial::GeoTypesFactory::getGeoColumns(), import_export::Importer::set_geo_physical_import_buffer_columnar(), and THROW_DB_EXCEPTION.
Referenced by fillMissingBuffers(), load_table(), load_table_binary_arrow(), and load_table_binary_columnar().
|
private |
Definition at line 3275 of file DBHandler.cpp.
References CHECK, and fillGeoColumns().
Referenced by load_table(), load_table_binary(), load_table_binary_arrow(), and load_table_binary_columnar().
|
private |
Definition at line 6112 of file DBHandler.cpp.
References calcite_sessions_, and calcite_sessions_mtx_.
Referenced by get_session_ptr().
|
override |
Definition at line 2293 of file DBHandler.cpp.
References get_session_ptr(), getAllRolesForUserImpl(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, and STDLOG.
|
override |
Definition at line 5968 of file DBHandler.cpp.
References anonymous_namespace{DBHandler.cpp}::add_vsi_archive_prefix(), anonymous_namespace{DBHandler.cpp}::add_vsi_network_prefix(), import_export::Importer::gdalFileExists(), import_export::Importer::gdalGetAllFilesInArchive(), get_session_ptr(), getConnectionInfo(), import_path_, anonymous_namespace{DBHandler.cpp}::is_a_supported_archive_file(), anonymous_namespace{DBHandler.cpp}::path_is_relative(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, thrift_to_copyparams(), THROW_DB_EXCEPTION, toString(), and anonymous_namespace{DBHandler.cpp}::validate_import_file_path_if_local().
|
override |
Definition at line 2281 of file DBHandler.cpp.
References get_session_ptr(), getAllRolesForUserImpl(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, and STDLOG.
|
override |
Definition at line 1661 of file DBHandler.cpp.
References anonymous_namespace{DBHandler.cpp}::extract_projection_tokens_for_completion(), get_completion_hints_unsorted(), get_session_ptr(), get_uc_compatible_table_names_by_column(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, gpu_enabled::sort(), STDLOG, and to_upper().
|
private |
Definition at line 1696 of file DBHandler.cpp.
References calcite_, logger::ERROR, GET_PHYSICAL_TABLES_AND_VIEWS, get_tables_impl(), get_token_based_completions(), query_state::StdLog::getConstSessionInfo(), just_whitelisted_keyword_hints(), and LOG.
Referenced by get_completion_hints().
|
override |
Definition at line 4643 of file DBHandler.cpp.
References anonymous_namespace{DBHandler.cpp}::create_thrift_obj_from_custom_expr(), custom_expressions_mutex_, get_session_ptr(), getConnectionInfo(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, and toString().
|
override |
Definition at line 4698 of file DBHandler.cpp.
References cat(), get_dashboard_impl(), get_session_ptr(), getConnectionInfo(), lockmgr::instance(), is_allowed_on_dashboard(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, THROW_DB_EXCEPTION, to_string(), toString(), Catalog_Namespace::UserMetadata::userName, and AccessPrivileges::VIEW_DASHBOARD.
|
override |
Definition at line 5090 of file DBHandler.cpp.
References cat(), DashboardPrivileges::CREATE_DASHBOARD, DashboardDBObjectType, DashboardPrivileges::DELETE_DASHBOARD, DashboardPrivileges::EDIT_DASHBOARD, get_session_ptr(), getConnectionInfo(), lockmgr::instance(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, THROW_DB_EXCEPTION, to_string(), toString(), Catalog_Namespace::UserMetadata::userId, Catalog_Namespace::UserMetadata::userName, and DashboardPrivileges::VIEW_DASHBOARD.
|
private |
Definition at line 4745 of file DBHandler.cpp.
References cat(), DashboardPrivileges::CREATE_DASHBOARD, DashboardDBObjectType, DashboardDescriptor::dashboardId, DashboardDescriptor::dashboardMetadata, DashboardDescriptor::dashboardName, DashboardDescriptor::dashboardState, DashboardPrivileges::DELETE_DASHBOARD, DashboardPrivileges::EDIT_DASHBOARD, DBObject::getPrivileges(), AccessPrivileges::hasPermission(), DashboardDescriptor::imageHash, lockmgr::instance(), DashboardDescriptor::updateTime, DashboardDescriptor::user, DashboardDescriptor::userId, Catalog_Namespace::UserMetadata::userName, and DashboardPrivileges::VIEW_DASHBOARD.
Referenced by get_dashboard(), and get_dashboards().
|
override |
Definition at line 4723 of file DBHandler.cpp.
References cat(), get_dashboard_impl(), get_session_ptr(), getConnectionInfo(), is_allowed_on_dashboard(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, toString(), Catalog_Namespace::UserMetadata::userName, and AccessPrivileges::VIEW_DASHBOARD.
|
override |
Definition at line 3056 of file DBHandler.cpp.
References get_session_ptr(), getConnectionInfo(), lockmgr::instance(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, and toString().
|
override |
Definition at line 2162 of file DBHandler.cpp.
References AccessPrivileges::ALL_TABLE, cat(), DashboardDBObjectType, DatabaseDBObjectType, get_session_ptr(), DBObject::getObjectKey(), lockmgr::instance(), DBObject::loadKey(), heavyai::RequestInfo::requestId(), serialize_db_object(), ServerDBObjectType, heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, TableDBObjectType, THROW_DB_EXCEPTION, to_string(), and ViewDBObjectType.
|
override |
Definition at line 2133 of file DBHandler.cpp.
References get_session_ptr(), lockmgr::instance(), heavyai::RequestInfo::requestId(), serialize_db_object(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, and THROW_DB_EXCEPTION.
|
override |
Definition at line 7584 of file DBHandler.cpp.
References cpu_mode_only_, EXPOSE_THRIFT_MAP, get_session_ptr(), getConnectionInfo(), report::params, heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, and toString().
|
override |
Definition at line 5921 of file DBHandler.cpp.
References anonymous_namespace{DBHandler.cpp}::add_vsi_archive_prefix(), anonymous_namespace{DBHandler.cpp}::add_vsi_network_prefix(), anonymous_namespace{DBHandler.cpp}::find_first_geo_file_in_archive(), import_export::Importer::gdalFileExists(), get_session_ptr(), getConnectionInfo(), import_path_, anonymous_namespace{DBHandler.cpp}::is_a_supported_archive_file(), anonymous_namespace{DBHandler.cpp}::path_is_relative(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, thrift_to_copyparams(), THROW_DB_EXCEPTION, toString(), and anonymous_namespace{DBHandler.cpp}::validate_import_file_path_if_local().
|
override |
Definition at line 7704 of file DBHandler.cpp.
References ExtensionFunctionsWhitelist::get_ext_funcs(), and ThriftSerializers::to_thrift().
|
override |
Definition at line 7684 of file DBHandler.cpp.
References ExtensionFunctionsWhitelist::get_udfs_name().
|
override |
Definition at line 923 of file DBHandler.cpp.
References data_mgr_, get_session_ptr(), getConnectionInfo(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, and toString().
|
override |
Definition at line 6119 of file DBHandler.cpp.
References get_session_ptr(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, and THROW_DB_EXCEPTION.
|
override |
Definition at line 2410 of file DBHandler.cpp.
References get_session_ptr(), get_table_details_impl(), getConnectionInfo(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, and toString().
|
override |
Definition at line 2422 of file DBHandler.cpp.
References get_session_ptr(), get_table_details_impl(), getConnectionInfo(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, and toString().
|
override |
Definition at line 6007 of file DBHandler.cpp.
References anonymous_namespace{DBHandler.cpp}::add_vsi_archive_prefix(), anonymous_namespace{DBHandler.cpp}::add_vsi_geo_prefix(), anonymous_namespace{DBHandler.cpp}::add_vsi_network_prefix(), CHECK, import_export::Importer::EMPTY, anonymous_namespace{DBHandler.cpp}::find_first_geo_file_in_archive(), import_export::Importer::gdalFileExists(), import_export::Importer::gdalFileOrDirectoryExists(), import_export::Importer::gdalGetLayersInGeoFile(), import_export::Importer::GEO, get_session_ptr(), getConnectionInfo(), import_path_, anonymous_namespace{DBHandler.cpp}::is_a_supported_archive_file(), import_export::Importer::NON_GEO, anonymous_namespace{DBHandler.cpp}::path_is_relative(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, thrift_to_copyparams(), THROW_DB_EXCEPTION, toString(), import_export::Importer::UNSUPPORTED_GEO, and anonymous_namespace{DBHandler.cpp}::validate_import_file_path_if_local().
|
override |
Definition at line 7542 of file DBHandler.cpp.
References get_session_ptr(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, and STDLOG.
|
override |
Definition at line 2639 of file DBHandler.cpp.
References cat(), get_session_ptr(), getConnectionInfo(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, THROW_DB_EXCEPTION, to_string(), and toString().
|
override |
Definition at line 3020 of file DBHandler.cpp.
References Data_Namespace::CPU_LEVEL, Buffer_Namespace::FREE, get_session_ptr(), getConnectionInfo(), Data_Namespace::GPU_LEVEL, lockmgr::instance(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, and toString().
|
override |
Definition at line 2716 of file DBHandler.cpp.
References GET_PHYSICAL_TABLES, get_session_ptr(), get_tables_impl(), getConnectionInfo(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, and toString().
|
overrideprivate |
Definition at line 7892 of file DBHandler.cpp.
References CHECK, get_session_ptr(), Executor::getExecutor(), GPU, jit_debug_, heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), sessions_store_, SET_REQUEST_ID, STDLOG, system_parameters_, and Executor::UNITARY_EXECUTOR_ID.
|
override |
Definition at line 2317 of file DBHandler.cpp.
References anonymous_namespace{DBHandler.cpp}::dump_table_col_names(), get_session_ptr(), getConnectionInfo(), render_handler_, heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, THROW_DB_EXCEPTION, and toString().
|
override |
Definition at line 1879 of file DBHandler.cpp.
References get_session_ptr(), lockmgr::instance(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, and STDLOG.
|
override |
Definition at line 7694 of file DBHandler.cpp.
References ExtensionFunctionsWhitelist::get_udfs_name().
|
override |
Definition at line 7724 of file DBHandler.cpp.
References table_functions::TableFunctionsFactory::get_table_funcs(), and setup::name.
|
override |
Definition at line 859 of file DBHandler.cpp.
References heavyai::get_hostname(), get_session_ptr(), getConnectionInfo(), getServerRole(), MAPD_EDITION, MAPD_RELEASE, read_only_, render_handler_, heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, start_time_, STDLOG, and toString().
Catalog_Namespace::SessionInfo DBHandler::get_session_copy | ( | const TSessionId & | session_id | ) |
Definition at line 6136 of file DBHandler.cpp.
References Catalog_Namespace::CALCITE_SESSION_ID_LENGTH, calcite_sessions_, calcite_sessions_mtx_, and sessions_store_.
Referenced by get_valid_groups().
|
override |
Definition at line 958 of file DBHandler.cpp.
References CHECK, get_session_ptr(), getConnectionInfo(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, and toString().
|
protected |
Definition at line 6147 of file DBHandler.cpp.
References Catalog_Namespace::CALCITE_SESSION_ID_LENGTH, findCalciteSession(), sessions_store_, and THROW_DB_EXCEPTION.
Referenced by check_table_consistency(), checkpoint(), clear_cpu_memory(), clear_gpu_memory(), clearRenderMemory(), clone_session(), convertResultSet(), create_custom_expression(), create_dashboard(), create_link(), deallocate_df(), delete_custom_expressions(), delete_dashboards(), detect_column_types(), disconnect(), get_all_effective_roles_for_user(), get_all_files_in_archive(), get_all_roles_for_user(), get_completion_hints(), get_custom_expressions(), get_dashboard(), get_dashboard_grantees(), get_dashboards(), get_databases(), get_db_object_privs(), get_db_objects_for_grantee(), get_device_parameters(), get_first_geo_file_in_archive(), get_hardware_info(), get_heap_profile(), get_internal_table_details(), get_internal_table_details_for_database(), get_layers_in_geo_file(), get_license_claims(), get_link_view(), get_memory(), get_physical_tables(), get_queries_info(), get_result_row_for_pixel(), get_roles(), get_server_status(), get_session_info(), get_status(), get_table_details(), get_table_details_for_database(), get_table_epoch(), get_table_epoch_by_name(), get_table_epochs(), get_tables(), get_tables_for_database(), get_tables_meta(), get_users(), get_views(), getExecutionMode(), has_object_privilege(), has_role(), import_table(), import_table_status(), importGeoTableSingle(), insert_chunks(), insert_data(), interrupt(), invalidate_cur_session(), load_table(), load_table_binary(), load_table_binary_arrow(), load_table_binary_columnar(), pause_executor_queue(), query_get_outer_fragment_count(), register_runtime_extension_functions(), render_vega(), replace_dashboard(), resume_executor_queue(), set_cur_session(), set_execution_mode(), set_table_epoch(), set_table_epoch_by_name(), set_table_epochs(), shareOrUnshareDashboards(), sql_execute(), sql_execute_df(), sql_execute_gdf(), sql_validate(), start_heap_profile(), start_query(), start_render_query(), stop_heap_profile(), switch_database(), and update_custom_expression().
|
override |
Definition at line 878 of file DBHandler.cpp.
References g_cluster, heavyai::get_hostname(), get_session_ptr(), getConnectionInfo(), getInvalidSessionId(), LeafAggregator::getLeafStatus(), getServerRole(), logger::INFO, isAggregator(), leaf_aggregator_, LeafAggregator::leafCount(), LOG, MAPD_EDITION, MAPD_RELEASE, read_only_, render_handler_, heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, start_time_, STDLOG, super_user_rights_, and toString().
|
override |
Definition at line 2435 of file DBHandler.cpp.
References get_session_ptr(), get_table_details_impl(), getConnectionInfo(), legacylockmgr::getExecuteReadLock(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, and toString().
|
override |
Definition at line 2448 of file DBHandler.cpp.
References get_session_ptr(), get_table_details_impl(), getConnectionInfo(), legacylockmgr::getExecuteReadLock(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, and toString().
|
private |
Definition at line 2529 of file DBHandler.cpp.
References calcite_, cat(), CHECK, Data_Namespace::CPU_LEVEL, create_query_state(), g_leaf_count, anonymous_namespace{DBHandler.cpp}::get_refresh_info(), query_state::StdLog::getSessionInfo(), hasTableAccessPrivileges(), lockmgr::instance(), parse_to_ra(), populateThriftColumnType(), query_state::StdLog::setQueryState(), system_parameters_, table_is_replicated(), THROW_DB_EXCEPTION, and validateRelAlg().
Referenced by fill_column_names_by_table(), get_internal_table_details(), get_internal_table_details_for_database(), get_table_details(), get_table_details_for_database(), and get_uc_compatible_table_names_by_column().
|
override |
Definition at line 7417 of file DBHandler.cpp.
References cat(), get_session_ptr(), getConnectionInfo(), legacylockmgr::getExecuteReadLock(), lockmgr::TableLockMgrImpl< TableSchemaLockMgr >::getReadLockForTable(), lockmgr::TableLockMgrImpl< TableDataLockMgr >::getReadLockForTable(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, THROW_DB_EXCEPTION, and toString().
|
override |
Definition at line 7438 of file DBHandler.cpp.
References cat(), get_session_ptr(), getConnectionInfo(), legacylockmgr::getExecuteReadLock(), lockmgr::TableLockMgrImpl< TableSchemaLockMgr >::getReadLockForTable(), lockmgr::TableLockMgrImpl< TableDataLockMgr >::getReadLockForTable(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, THROW_DB_EXCEPTION, and toString().
|
override |
Definition at line 7464 of file DBHandler.cpp.
References cat(), CHECK, get_session_ptr(), getConnectionInfo(), legacylockmgr::getExecuteReadLock(), lockmgr::TableLockMgrImpl< TableSchemaLockMgr >::getReadLockForTable(), lockmgr::TableLockMgrImpl< TableDataLockMgr >::getReadLockForTable(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, and toString().
|
override |
Definition at line 7735 of file DBHandler.cpp.
References table_functions::TableFunctionsFactory::get_table_funcs(), and ThriftSerializers::to_thrift().
|
override |
Definition at line 7714 of file DBHandler.cpp.
References table_functions::TableFunctionsFactory::get_table_funcs(), and setup::name.
|
override |
Definition at line 2692 of file DBHandler.cpp.
References GET_PHYSICAL_TABLES_AND_VIEWS, get_session_ptr(), get_tables_impl(), getConnectionInfo(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, and toString().
|
override |
Definition at line 2702 of file DBHandler.cpp.
References GET_PHYSICAL_TABLES_AND_VIEWS, get_session_ptr(), get_tables_impl(), getConnectionInfo(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, and toString().
|
private |
Definition at line 2675 of file DBHandler.cpp.
References Catalog_Namespace::SessionInfo::get_currentUser(), Catalog_Namespace::SessionInfo::getCatalog(), Catalog_Namespace::Catalog::getTableNamesForUser(), lockmgr::instance(), and THROW_DB_EXCEPTION.
Referenced by get_completion_hints_unsorted(), get_physical_tables(), get_tables(), get_tables_for_database(), and get_views().
|
override |
Definition at line 2828 of file DBHandler.cpp.
References create_query_state(), get_session_ptr(), get_tables_meta_impl(), getConnectionInfo(), legacylockmgr::getExecuteReadLock(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, THROW_DB_EXCEPTION, and toString().
void 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 |
||
) |
Definition at line 2734 of file DBHandler.cpp.
References cat(), convertData(), gpu_enabled::copy(), CPU, execute_rel_alg(), Catalog_Namespace::SessionInfo::getCatalog(), hasTableAccessPrivileges(), LOG, parse_to_ra(), run_benchmark_import::result, system_parameters_, table_is_replicated(), run_benchmark_import::tables, THROW_DB_EXCEPTION, ThriftSerializers::type_info_to_thrift(), and logger::WARNING.
Referenced by get_tables_meta().
|
private |
Definition at line 1725 of file DBHandler.cpp.
References fill_column_names_by_table(), find_last_word_from_cursor(), get_column_hints(), get_qualified_column_hints(), and should_suggest_column_hints().
Referenced by get_completion_hints_unsorted().
|
private |
Definition at line 1795 of file DBHandler.cpp.
References get_table_details_impl(), and to_upper().
Referenced by get_completion_hints().
|
override |
Definition at line 2847 of file DBHandler.cpp.
References get_session_ptr(), getConnectionInfo(), lockmgr::instance(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, and toString().
std::vector< std::string > DBHandler::get_valid_groups | ( | const TSessionId & | session, |
int32_t | dashboard_id, | ||
std::vector< std::string > | groups | ||
) |
Definition at line 4946 of file DBHandler.cpp.
References cat(), get_session_copy(), lockmgr::instance(), Catalog_Namespace::UserMetadata::isSuper, heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, THROW_DB_EXCEPTION, and to_string().
|
override |
|
override |
Definition at line 2725 of file DBHandler.cpp.
References get_session_ptr(), get_tables_impl(), GET_VIEWS, getConnectionInfo(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, and toString().
|
private |
Definition at line 2248 of file DBHandler.cpp.
References CHECK, lockmgr::instance(), and THROW_DB_EXCEPTION.
Referenced by get_all_effective_roles_for_user(), and get_all_roles_for_user().
|
protected |
Definition at line 1790 of file DBHandler.cpp.
References TrackingProcessor::client_address, TrackingProcessor::client_protocol, and heavydb.connection::ConnectionInfo.
Referenced by clear_gpu_memory(), clearRenderMemory(), clone_session(), connect(), connect_impl(), create_custom_expression(), create_dashboard(), create_link(), create_table(), delete_custom_expressions(), delete_dashboards(), detect_column_types(), disconnect(), get_all_files_in_archive(), get_custom_expressions(), get_dashboard(), get_dashboard_grantees(), get_dashboards(), get_databases(), get_device_parameters(), get_first_geo_file_in_archive(), get_hardware_info(), get_internal_table_details(), get_internal_table_details_for_database(), get_layers_in_geo_file(), get_link_view(), get_memory(), get_physical_tables(), get_result_row_for_pixel(), get_server_status(), get_session_info(), get_status(), get_table_details(), get_table_details_for_database(), get_table_epoch(), get_table_epoch_by_name(), get_table_epochs(), get_tables(), get_tables_for_database(), get_tables_meta(), get_users(), get_views(), import_table(), import_table_status(), importGeoTableSingle(), interrupt(), invalidate_cur_session(), load_table(), load_table_binary(), load_table_binary_columnar(), pause_executor_queue(), register_runtime_extension_functions(), render_vega(), replace_dashboard(), resume_executor_queue(), set_cur_session(), set_execution_mode(), set_table_epoch(), set_table_epoch_by_name(), set_table_epochs(), shareOrUnshareDashboards(), sql_execute(), sql_validate(), switch_database(), and update_custom_expression().
TExecuteMode::type DBHandler::getExecutionMode | ( | const TSessionId & | session | ) |
Definition at line 3074 of file DBHandler.cpp.
References CPU, get_session_ptr(), GPU, and UNREACHABLE.
TSessionId DBHandler::getInvalidSessionId | ( | ) | const |
Definition at line 3016 of file DBHandler.cpp.
References INVALID_SESSION_ID.
Referenced by get_status().
|
private |
Definition at line 7813 of file DBHandler.cpp.
References CHECK, ResultSetLogicalValuesBuilder::create(), genLiteralStr(), Executor::getExecutor(), GPU, jit_debug_, kTEXT, run_benchmark_import::label, sessions_store_, system_parameters_, toString(), and Executor::UNITARY_EXECUTOR_ID.
Referenced by executeDdl().
|
private |
Definition at line 850 of file DBHandler.cpp.
References g_cluster, leaf_aggregator_, and LeafAggregator::leafCount().
Referenced by get_server_status(), and get_status().
|
private |
|
private |
Definition at line 6304 of file DBHandler.cpp.
Referenced by sql_execute_df().
|
private |
|
private |
Definition at line 7775 of file DBHandler.cpp.
References ResultSetLogicalValuesBuilder::create(), genLiteralStr(), kTEXT, run_benchmark_import::label, and sessions_store_.
Referenced by executeDdl().
|
staticprivate |
Definition at line 2019 of file DBHandler.cpp.
References DashboardPrivileges::CREATE_DASHBOARD, DashboardPrivileges::DELETE_DASHBOARD, DashboardPrivileges::EDIT_DASHBOARD, AccessPrivileges::hasPermission(), THROW_DB_EXCEPTION, and DashboardPrivileges::VIEW_DASHBOARD.
|
staticprivate |
Definition at line 1982 of file DBHandler.cpp.
References DatabasePrivileges::ACCESS, DatabasePrivileges::CREATE_DATABASE, DatabasePrivileges::DROP_DATABASE, AccessPrivileges::hasPermission(), THROW_DB_EXCEPTION, and DatabasePrivileges::VIEW_SQL_EDITOR.
|
override |
Definition at line 2067 of file DBHandler.cpp.
References cat(), DashboardDBObjectType, DatabaseDBObjectType, Grantee::findDbObject(), get_session_ptr(), DBObject::getObjectKey(), lockmgr::instance(), Catalog_Namespace::UserMetadata::isSuper, DBObject::loadKey(), permissionFuncMap_, heavyai::RequestInfo::requestId(), ServerDBObjectType, heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, TableDBObjectType, THROW_DB_EXCEPTION, to_string(), run_benchmark_import::type, and ViewDBObjectType.
|
override |
Definition at line 1897 of file DBHandler.cpp.
References get_session_ptr(), lockmgr::instance(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, and THROW_DB_EXCEPTION.
|
staticprivate |
Definition at line 2053 of file DBHandler.cpp.
References ServerPrivileges::ALTER_SERVER, CHECK, ServerPrivileges::CREATE_SERVER, ServerPrivileges::DROP_SERVER, AccessPrivileges::hasPermission(), and ServerPrivileges::SERVER_USAGE.
|
staticprivate |
Definition at line 1999 of file DBHandler.cpp.
References TablePrivileges::ALTER_TABLE, TablePrivileges::CREATE_TABLE, TablePrivileges::DELETE_FROM_TABLE, TablePrivileges::DROP_TABLE, AccessPrivileges::hasPermission(), TablePrivileges::INSERT_INTO_TABLE, TablePrivileges::SELECT_FROM_TABLE, THROW_DB_EXCEPTION, TablePrivileges::TRUNCATE_TABLE, and TablePrivileges::UPDATE_IN_TABLE.
|
staticprivate |
Definition at line 2035 of file DBHandler.cpp.
References ViewPrivileges::CREATE_VIEW, ViewPrivileges::DELETE_FROM_VIEW, ViewPrivileges::DROP_VIEW, AccessPrivileges::hasPermission(), ViewPrivileges::INSERT_INTO_VIEW, ViewPrivileges::SELECT_FROM_VIEW, THROW_DB_EXCEPTION, and ViewPrivileges::UPDATE_IN_VIEW.
bool DBHandler::hasTableAccessPrivileges | ( | const TableDescriptor * | td, |
const Catalog_Namespace::SessionInfo & | session_info | ||
) |
Definition at line 2658 of file DBHandler.cpp.
References cat(), Catalog_Namespace::SessionInfo::get_currentUser(), Catalog_Namespace::SessionInfo::getCatalog(), lockmgr::instance(), TableDescriptor::isView, DBObject::loadKey(), TableDBObjectType, TableDescriptor::tableName, and ViewDBObjectType.
Referenced by get_table_details_impl(), and get_tables_meta_impl().
|
override |
Definition at line 5404 of file DBHandler.cpp.
References importGeoTableGlobFilterSort(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, and thrift_to_copyparams().
|
override |
Definition at line 5280 of file DBHandler.cpp.
References cat(), CHECK, check_read_only(), check_table_load_privileges(), import_export::create_importer(), import_export::CopyParams::delimiter, measure< TimeT >::execution(), shared::file_or_glob_path_exists(), g_enable_non_kernel_time_query_interrupt, anonymous_namespace{DBHandler.cpp}::get_import_tag(), get_session_ptr(), getConnectionInfo(), legacylockmgr::getExecuteReadLock(), Executor::getExecutor(), lockmgr::TableLockMgrImpl< T >::getWriteLockForTable(), import_path_, logger::INFO, import_export::kOdbc, LOG, anonymous_namespace{DBHandler.cpp}::log_system_cpu_memory_status(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, import_export::CopyParams::source_type, import_export::CopyParams::sql_select, run_benchmark_import::start_time, STDLOG, thrift_to_copyparams(), THROW_DB_EXCEPTION, toString(), Executor::UNITARY_EXECUTOR_ID, and anonymous_namespace{DBHandler.cpp}::validate_import_file_path_if_local().
|
override |
Definition at line 5906 of file DBHandler.cpp.
References import_export::Importer::get_import_status(), get_session_ptr(), getConnectionInfo(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, and toString().
|
private |
Definition at line 5423 of file DBHandler.cpp.
References import_export::CopyParams::file_sort_order_by, import_export::CopyParams::file_sort_regex, importGeoTableSingle(), shared::local_glob_filter_sort_files(), import_export::CopyParams::regex_path_filter, and shared::validate_sort_options().
Referenced by import_geo_table(), and process_deferred_copy_from().
|
private |
Definition at line 5450 of file DBHandler.cpp.
References anonymous_namespace{DBHandler.cpp}::add_vsi_archive_prefix(), anonymous_namespace{DBHandler.cpp}::add_vsi_geo_prefix(), anonymous_namespace{DBHandler.cpp}::add_vsi_network_prefix(), cat(), CHECK, CHECK_EQ, check_geospatial_files(), check_read_only(), check_table_load_privileges(), copyparams_to_thrift(), create_table(), detect_column_types(), import_export::Importer::EMPTY, measure< TimeT >::execution(), anonymous_namespace{DBHandler.cpp}::find_first_geo_file_in_archive(), g_enable_non_kernel_time_query_interrupt, import_export::Importer::gdalFileExists(), import_export::Importer::gdalFileOrDirectoryExists(), import_export::Importer::gdalGetLayersInGeoFile(), import_export::Importer::GEO, import_export::CopyParams::geo_layer_name, anonymous_namespace{DBHandler.cpp}::get_import_tag(), anonymous_namespace{DBHandler.cpp}::get_mismatch_attr_warning_text(), get_session_ptr(), getConnectionInfo(), legacylockmgr::getExecuteReadLock(), Executor::getExecutor(), lockmgr::TableLockMgrImpl< T >::getWriteLockForTable(), import_path_, logger::INFO, anonymous_namespace{DBHandler.cpp}::is_a_supported_archive_file(), import_export::kGeoFile, import_export::kRasterFile, LOG, LOG_IF, anonymous_namespace{DBHandler.cpp}::log_system_cpu_memory_status(), import_export::Importer::NON_GEO, anonymous_namespace{DBHandler.cpp}::path_is_relative(), populateThriftColumnType(), ImportHelpers::sanitize_name(), import_export::CopyParams::source_type, run_benchmark_import::start_time, STDLOG, THROW_COLUMN_ATTR_MISMATCH_EXCEPTION, THROW_DB_EXCEPTION, to_string(), toString(), anonymous_namespace{DBHandler.cpp}::TTypeInfo_IsGeo(), anonymous_namespace{DBHandler.cpp}::TTypeInfo_TypeToString(), Executor::UNITARY_EXECUTOR_ID, import_export::Importer::UNSUPPORTED_GEO, anonymous_namespace{DBHandler.cpp}::validate_import_file_path_if_local(), VLOG, and logger::WARNING.
Referenced by importGeoTableGlobFilterSort().
|
private |
Definition at line 252 of file DBHandler.cpp.
References Executor::auto_cpu_mem_bytes, CHECK_GT, cpu_threads(), data_mgr_, format_num_bytes(), g_cpu_threads_override, g_executor_resource_mgr_allow_cpu_gpu_kernel_concurrency, g_executor_resource_mgr_allow_cpu_kernel_concurrency, g_executor_resource_mgr_allow_cpu_result_mem_oversubscription_concurrency, g_executor_resource_mgr_allow_cpu_slot_oversubscription_concurrency, g_executor_resource_mgr_cpu_result_mem_bytes, g_executor_resource_mgr_cpu_result_mem_ratio, g_executor_resource_mgr_max_available_resource_use_ratio, g_executor_resource_mgr_per_query_max_cpu_result_mem_ratio, g_executor_resource_mgr_per_query_max_cpu_slots_ratio, logger::INFO, Executor::init_resource_mgr(), LOG, SystemParameters::num_gpus, and system_parameters_.
Referenced by initialize().
void DBHandler::initialize | ( | const bool | is_new_db | ) |
Definition at line 382 of file DBHandler.cpp.
References ExtensionFunctionsWhitelist::add(), Executor::addUdfIrToModule(), ExtensionFunctionsWhitelist::addUdfs(), authMetadata_, base_data_path_, calcite_, clang_options_, clang_path_, UdfCompiler::compileUdf(), CPU, cpu_mode_only_, SystemParameters::cpu_only, QueryEngine::createInstance(), data_mgr_, test_exceptions::data_path, db_leaves_, disk_cache_config_, enable_rendering_, logger::ERROR, executor_device_type_, logger::FATAL, g_base_path, g_enable_executor_resource_mgr, table_functions::TableFunctionsFactory::get_table_funcs(), UdfCompiler::getAstFileName(), GPU, import_path_, logger::INFO, init_executor_resource_mgr(), table_functions::init_table_functions(), initialized_, lockmgr::instance(), shared::kDataDirectoryName, shared::kDefaultImportDirName, CudaMgr_Namespace::Kepler, RuntimeLibManager::loadRuntimeLibs(), LOG, max_concurrent_render_sessions_, SystemParameters::num_gpus, num_reader_threads_, query_engine_, render_compositor_use_last_gpu_, render_handler_, render_mem_bytes_, renderer_enable_slab_allocation_, renderer_prefer_igpu_, renderer_use_parallel_executors_, renderer_vulkan_timeout_, reserved_gpu_mem_, SystemParameters::start_gpu, start_time_, string_leaves_, system_parameters_, THROW_DB_EXCEPTION, ThriftSerializers::to_thrift(), udf_filename_, validate_configurations(), and logger::WARNING.
|
override |
Definition at line 7126 of file DBHandler.cpp.
References cat(), CHECK, CHECK_EQ, gpu_enabled::copy(), get_session_ptr(), Chunk_NS::Chunk::getChunk(), Data_Namespace::AbstractBuffer::getEncoder(), lockmgr::TableLockMgrImpl< TableSchemaLockMgr >::getReadLockForTable(), lockmgr::TableLockMgrImpl< T >::getWriteLockForTable(), Data_Namespace::AbstractBuffer::initEncoder(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, Encoder::setNumElems(), STDLOG, and THROW_DB_EXCEPTION.
|
override |
Definition at line 7185 of file DBHandler.cpp.
References DataBlockPtr::arraysPtr, cat(), CHECK, CHECK_EQ, Fragmenter_Namespace::InsertData::columnIds, import_export::ImporterUtils::composeNullArray(), import_export::ImporterUtils::composeNullPointCoords(), Fragmenter_Namespace::InsertData::data, Fragmenter_Namespace::InsertData::databaseId, import_export::fill_missing_columns(), get_session_ptr(), lockmgr::TableLockMgrImpl< TableSchemaLockMgr >::getReadLockForTable(), lockmgr::TableLockMgrImpl< T >::getWriteLockForTable(), Fragmenter_Namespace::InsertData::is_default, kENCODING_DICT, kENCODING_NONE, kNULLT, kPOINT, DataBlockPtr::numbersPtr, Fragmenter_Namespace::InsertData::numRows, heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, DataBlockPtr::stringsPtr, Fragmenter_Namespace::InsertData::tableId, and THROW_DB_EXCEPTION.
void DBHandler::internal_connect | ( | TSessionId & | session, |
const std::string & | username, | ||
const std::string & | dbname | ||
) |
Definition at line 620 of file DBHandler.cpp.
References AccessPrivileges::ACCESS, cat(), connect_impl(), DatabaseDBObjectType, lockmgr::instance(), DBObject::loadKey(), logger::set_new_request_id(), DBObject::setPrivileges(), STDLOG, THROW_DB_EXCEPTION, and Catalog_Namespace::UserMetadata::userLoggable().
|
override |
Definition at line 792 of file DBHandler.cpp.
References cat(), CHECK, g_enable_dynamic_watchdog, g_enable_non_kernel_time_query_interrupt, g_enable_runtime_query_interrupt, get_session_ptr(), getConnectionInfo(), Executor::getExecutor(), logger::INFO, LeafAggregator::interrupt(), jit_debug_, leaf_aggregator_, LeafAggregator::leafCount(), LOG, heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, system_parameters_, toString(), Executor::UNITARY_EXECUTOR_ID, and VLOG.
|
private |
Definition at line 7940 of file DBHandler.cpp.
References CHECK, CHECK_EQ, Catalog_Namespace::DBMetadata::dbName, g_enable_non_kernel_time_query_interrupt, g_enable_runtime_query_interrupt, Catalog_Namespace::SessionInfo::get_currentUser(), Catalog_Namespace::SessionInfo::get_session_id(), Catalog_Namespace::SessionInfo::getCatalog(), Catalog_Namespace::Catalog::getCurrentDB(), Executor::getExecutor(), Catalog_Namespace::UserMetadata::isSuper, jit_debug_, leaf_aggregator_, LeafAggregator::leafCount(), sessions_store_, system_parameters_, Executor::UNITARY_EXECUTOR_ID, Catalog_Namespace::UserMetadata::userLoggable(), Catalog_Namespace::UserMetadata::userName, and VLOG.
Referenced by executeDdl().
|
override |
Definition at line 3001 of file DBHandler.cpp.
References get_session_ptr(), getConnectionInfo(), Executor::getExecutor(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, toString(), and Executor::UNITARY_EXECUTOR_ID.
bool DBHandler::isAggregator | ( | ) | const |
Definition at line 648 of file DBHandler.cpp.
References leaf_aggregator_, and LeafAggregator::leafCount().
Referenced by get_status().
|
override |
|
override |
Definition at line 3710 of file DBHandler.cpp.
References CHECK, anonymous_namespace{DBHandler.cpp}::column_ids_by_names(), logger::ERROR, fillGeoColumns(), fillMissingBuffers(), anonymous_namespace{DBHandler.cpp}::get_load_tag(), get_session_ptr(), getConnectionInfo(), legacylockmgr::getExecuteReadLock(), lockmgr::TableLockMgrImpl< T >::getWriteLockForTable(), LOG, anonymous_namespace{DBHandler.cpp}::log_system_cpu_memory_status(), prepare_loader_generic(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, THROW_DB_EXCEPTION, and toString().
|
override |
Definition at line 3324 of file DBHandler.cpp.
References anonymous_namespace{DBHandler.cpp}::column_ids_by_names(), logger::ERROR, fillMissingBuffers(), anonymous_namespace{DBHandler.cpp}::get_load_tag(), get_session_ptr(), getConnectionInfo(), legacylockmgr::getExecuteReadLock(), lockmgr::TableLockMgrImpl< T >::getWriteLockForTable(), LOG, anonymous_namespace{DBHandler.cpp}::log_system_cpu_memory_status(), prepare_loader_generic(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, THROW_DB_EXCEPTION, and toString().
|
override |
Definition at line 3606 of file DBHandler.cpp.
References anonymous_namespace{DBHandler.cpp}::column_ids_by_names(), logger::ERROR, fillGeoColumns(), fillMissingBuffers(), anonymous_namespace{DBHandler.cpp}::get_load_tag(), get_session_ptr(), legacylockmgr::getExecuteReadLock(), lockmgr::TableLockMgrImpl< T >::getWriteLockForTable(), anonymous_namespace{DBHandler.cpp}::loadArrowStream(), LOG, anonymous_namespace{DBHandler.cpp}::log_system_cpu_memory_status(), prepare_loader_generic(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, and THROW_DB_EXCEPTION.
|
override |
Definition at line 3468 of file DBHandler.cpp.
References CHECK, anonymous_namespace{DBHandler.cpp}::column_ids_by_names(), fillGeoColumns(), fillMissingBuffers(), anonymous_namespace{DBHandler.cpp}::get_column_size(), anonymous_namespace{DBHandler.cpp}::get_load_tag(), get_session_ptr(), getConnectionInfo(), legacylockmgr::getExecuteReadLock(), lockmgr::TableLockMgrImpl< T >::getWriteLockForTable(), anonymous_namespace{DBHandler.cpp}::log_system_cpu_memory_status(), prepare_loader_generic(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, THROW_DB_EXCEPTION, and toString().
|
inlinestatic |
Definition at line 206 of file DBHandler.h.
|
private |
Definition at line 6913 of file DBHandler.cpp.
References anonymous_namespace{Utm.h}::a, cat(), CHECK, anonymous_namespace{DBHandler.cpp}::check_in_memory_system_table_query(), query_state::Timer::createQueryStateProxy(), query_state::QueryStateProxy::createTimer(), g_multi_instance, query_state::QueryState::getConstSessionInfo(), lockmgr::instance(), processCalciteRequest(), run_benchmark_import::result, gpu_enabled::sort(), and run_benchmark_import::tables.
Referenced by execute_rel_alg_with_filter_push_down(), get_table_details_impl(), get_tables_meta_impl(), sql_execute_impl(), and sql_validate().
void DBHandler::pause_executor_queue | ( | const TSessionId & | session | ) |
Definition at line 2950 of file DBHandler.cpp.
References get_session_ptr(), getConnectionInfo(), Executor::pause_executor_queue(), STDLOG, THROW_DB_EXCEPTION, and toString().
Referenced by executeDdl().
|
private |
Definition at line 2363 of file DBHandler.cpp.
References ColumnDescriptor::columnId, ColumnDescriptor::columnName, ColumnDescriptor::columnType, ColumnDescriptor::default_value, encoding_to_thrift(), ThriftSerializers::fixup_geo_column_descriptor(), SQLTypeInfo::get_comp_param(), SQLTypeInfo::get_compression(), SQLTypeInfo::get_notnull(), SQLTypeInfo::get_output_srid(), SQLTypeInfo::get_precision(), SQLTypeInfo::get_scale(), SQLTypeInfo::get_size(), SQLTypeInfo::get_subtype(), SQLTypeInfo::get_type(), ColumnDescriptor::getDefaultValueLiteral(), Catalog_Namespace::Catalog::getMetadataForDict(), SQLTypeInfo::is_date_in_days(), IS_GEO, ImportHelpers::is_reserved_name(), ColumnDescriptor::isSystemCol, kARRAY, kDATE, kENCODING_DICT, ColumnDescriptor::sourceName, THROW_DB_EXCEPTION, and type_to_thrift().
Referenced by detect_column_types(), get_table_details_impl(), and importGeoTableSingle().
|
private |
Definition at line 3399 of file DBHandler.cpp.
References cat(), CHECK, check_read_only(), check_table_load_privileges(), anonymous_namespace{DBHandler.cpp}::check_table_not_sharded(), anonymous_namespace{DBHandler.cpp}::check_valid_column_names(), g_cluster, Catalog_Namespace::SessionInfo::getCatalog(), leaf_aggregator_, LeafAggregator::leafCount(), import_export::setup_column_loaders(), THROW_DB_EXCEPTION, and to_string().
Referenced by load_table(), load_table_binary(), load_table_binary_arrow(), and load_table_binary_columnar().
|
private |
Definition at line 1430 of file DBHandler.cpp.
References deferred_copy_from_sessions, measure< TimeT >::execution(), importGeoTableGlobFilterSort(), and DBHandler::DeferredCopyFromSessions::remove().
Referenced by sql_execute().
|
private |
Definition at line 6880 of file DBHandler.cpp.
References ExplainInfo::ActualQuery(), calcite_, createInMemoryCalciteSession(), query_state::Timer::createQueryStateProxy(), query_state::QueryStateProxy::createTimer(), SystemParameters::enable_calcite_view_optimize, g_enable_watchdog, Catalog_Namespace::SysCatalog::instance(), Catalog_Namespace::SysCatalog::isAggregator(), ExplainInfo::isCalciteExplain(), ExplainInfo::isCalciteExplainDetail(), ExplainInfo::isSelectExplain(), heavyai::RequestInfo::json(), legacy_syntax_, pg_shim(), removeInMemoryCalciteSession(), logger::request_id(), and heavyai::RequestInfo::sessionId().
Referenced by parse_to_ra().
|
override |
Definition at line 7021 of file DBHandler.cpp.
References get_session_ptr(), leaf_handler_, heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, and THROW_DB_EXCEPTION.
|
override |
Definition at line 7601 of file DBHandler.cpp.
References table_functions::TableFunctionsFactory::add(), ExtensionFunctionsWhitelist::addRTUdfs(), SystemParameters::ALLOWED_SUPERUSERS_ONLY, calcite_, CHECK, ExtensionFunctionsWhitelist::clearRTUdfs(), SystemParameters::DISALLOWED, Executor::extension_module_sources, ThriftSerializers::from_thrift(), get_session_ptr(), table_functions::TableFunctionsFactory::get_table_funcs(), getConnectionInfo(), Executor::registerExtensionFunctions(), heavyai::RequestInfo::requestId(), table_functions::TableFunctionsFactory::reset(), Executor::rt_udf_cpu_module, Executor::rt_udf_gpu_module, SystemParameters::runtime_udf_registration_policy, heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, system_parameters_, THROW_DB_EXCEPTION, ThriftSerializers::to_thrift(), toString(), and VLOG.
|
private |
Definition at line 613 of file DBHandler.cpp.
References calcite_sessions_, calcite_sessions_mtx_, and CHECK.
Referenced by processCalciteRequest().
|
private |
|
override |
Definition at line 4523 of file DBHandler.cpp.
References measure< TimeT >::execution(), get_session_ptr(), getConnectionInfo(), render_handler_, heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, THROW_DB_EXCEPTION, and toString().
|
override |
Definition at line 4869 of file DBHandler.cpp.
References cat(), CHECK, dbhandler::check_not_info_schema_db(), check_read_only(), DashboardDescriptor::dashboardId, DashboardDescriptor::dashboardMetadata, DashboardDescriptor::dashboardName, DashboardDescriptor::dashboardState, AccessPrivileges::EDIT_DASHBOARD, g_allow_system_dashboard_update, get_session_ptr(), getConnectionInfo(), DashboardDescriptor::imageHash, lockmgr::instance(), is_allowed_on_dashboard(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, THROW_DB_EXCEPTION, to_string(), toString(), DashboardDescriptor::user, DashboardDescriptor::userId, and Catalog_Namespace::UserMetadata::userId.
|
private |
Definition at line 365 of file DBHandler.cpp.
References base_data_path_, Catalog_Namespace::SessionsStore::create(), disconnect_impl(), idle_session_duration_, max_num_sessions_, max_session_duration_, and sessions_store_.
void DBHandler::resizeDispatchQueue | ( | size_t | queue_size | ) |
Definition at line 8180 of file DBHandler.cpp.
References dispatch_queue_.
void DBHandler::resume_executor_queue | ( | const TSessionId & | session | ) |
Definition at line 2964 of file DBHandler.cpp.
References get_session_ptr(), getConnectionInfo(), Executor::resume_executor_queue(), STDLOG, THROW_DB_EXCEPTION, and toString().
Referenced by clear_cpu_memory(), clear_gpu_memory(), clearRenderMemory(), and executeDdl().
|
override |
Definition at line 2978 of file DBHandler.cpp.
References get_session_ptr(), getConnectionInfo(), Executor::getExecutor(), run_benchmark_import::label, heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, toString(), and Executor::UNITARY_EXECUTOR_ID.
|
override |
Definition at line 3087 of file DBHandler.cpp.
References get_session_ptr(), getConnectionInfo(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), set_execution_mode_nolock(), SET_REQUEST_ID, STDLOG, and toString().
Referenced by alterSession().
|
private |
Definition at line 6186 of file DBHandler.cpp.
References CPU, cpu_mode_only_, Catalog_Namespace::SessionInfo::get_currentUser(), GPU, logger::INFO, LOG, Catalog_Namespace::SessionInfo::set_executor_device_type(), and Catalog_Namespace::UserMetadata::userLoggable().
Referenced by set_execution_mode().
|
override |
Definition at line 973 of file DBHandler.cpp.
References g_distributed_leaf_idx, and g_distributed_num_leaves.
|
override |
Definition at line 7532 of file DBHandler.cpp.
References check_read_only(), heavyai::RequestInfo::requestId(), SET_REQUEST_ID, and THROW_DB_EXCEPTION.
|
override |
Definition at line 7362 of file DBHandler.cpp.
References cat(), get_session_ptr(), getConnectionInfo(), legacylockmgr::getExecuteReadLock(), lockmgr::TableLockMgrImpl< TableSchemaLockMgr >::getWriteLockForTable(), lockmgr::TableLockMgrImpl< TableDataLockMgr >::getWriteLockForTable(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, THROW_DB_EXCEPTION, and toString().
|
override |
Definition at line 7387 of file DBHandler.cpp.
References cat(), get_session_ptr(), getConnectionInfo(), legacylockmgr::getExecuteReadLock(), lockmgr::TableLockMgrImpl< TableSchemaLockMgr >::getWriteLockForTable(), lockmgr::TableLockMgrImpl< TableDataLockMgr >::getWriteLockForTable(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, THROW_DB_EXCEPTION, and toString().
|
override |
Definition at line 7493 of file DBHandler.cpp.
References cat(), Executor::clearExternalCaches(), g_cluster, get_session_ptr(), getConnectionInfo(), legacylockmgr::getExecuteReadLock(), lockmgr::TableLockMgrImpl< TableDataLockMgr >::getWriteLockForTable(), lockmgr::TableLockMgrImpl< TableSchemaLockMgr >::getWriteLockForTable(), leaf_aggregator_, LeafAggregator::leafCount(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, THROW_DB_EXCEPTION, and toString().
|
override |
Definition at line 5063 of file DBHandler.cpp.
References share_dashboards().
|
override |
Definition at line 5052 of file DBHandler.cpp.
References heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, and shareOrUnshareDashboards().
Referenced by share_dashboard().
|
private |
Definition at line 5008 of file DBHandler.cpp.
References AccessPrivileges::add(), check_read_only(), AccessPrivileges::CREATE_DASHBOARD, DashboardDBObjectType, AccessPrivileges::DELETE_DASHBOARD, AccessPrivileges::EDIT_DASHBOARD, get_session_ptr(), getConnectionInfo(), lockmgr::instance(), STDLOG, THROW_DB_EXCEPTION, toString(), validateDashboardIdsForSharing(), validateGroups(), and AccessPrivileges::VIEW_DASHBOARD.
Referenced by share_dashboards(), and unshare_dashboards().
void DBHandler::shutdown | ( | ) |
Definition at line 7551 of file DBHandler.cpp.
References Executor::clearExternalCaches(), Catalog_Namespace::SysCatalog::destroy(), emergency_shutdown(), query_engine_, and render_handler_.
Referenced by ~DBHandler().
void 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 | ||
) |
Definition at line 1368 of file DBHandler.cpp.
References CHECK, create_query_state(), DEBUG_TIMER, deferred_copy_from_sessions, measure< TimeT >::execution(), get_session_ptr(), ExecutionResult::getExecutionTime(), lockmgr::TableSchemaLockMgr::instance(), lockmgr::TableDataLockMgr::instance(), process_deferred_copy_from(), DBHandler::DeferredCopyFromSessions::remove(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, ExecutionResult::setExecutionTime(), sql_execute_impl(), STDLOG, THROW_DB_EXCEPTION, and VLOG.
Referenced by create_table().
|
override |
Definition at line 1289 of file DBHandler.cpp.
References agg_handler_, create_query_state(), DEBUG_TIMER, deferred_copy_from_sessions, measure< TimeT >::execution(), get_session_ptr(), getConnectionInfo(), lockmgr::TableSchemaLockMgr::instance(), lockmgr::TableDataLockMgr::instance(), leaf_aggregator_, LeafAggregator::leafCount(), process_deferred_copy_from(), DBHandler::DeferredCopyFromSessions::remove(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, sql_execute_local(), STDLOG, system_parameters_, THROW_DB_EXCEPTION, toString(), and VLOG.
|
override |
Definition at line 1461 of file DBHandler.cpp.
References CHECK, CPU, create_query_state(), data_mgr_, measure< TimeT >::execution(), get_session_ptr(), ExecutionResult::getExecutionTime(), ExecutionResult::getRows(), getTargetNames(), ExecutionResult::getTargetsMeta(), GPU, handle_to_dev_ptr_mutex_, ipc_handle_to_dev_ptr_, ParserWrapper::Read, heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, sql_execute_impl(), STDLOG, and THROW_DB_EXCEPTION.
Referenced by sql_execute_gdf().
|
override |
Definition at line 1543 of file DBHandler.cpp.
References get_session_ptr(), heavyai::RequestInfo::json(), logger::request_id(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, heavyai::RequestInfo::setRequestId(), sql_execute_df(), and STDLOG.
|
private |
Definition at line 6445 of file DBHandler.cpp.
References ExplainInfo::ActualQuery(), DBHandler::DeferredCopyFromSessions::add(), ExecutionResult::addExecutionTime(), cat(), CHECK, dbhandler::check_not_info_schema_db(), check_read_only(), DBHandler::DeferredCopyFromState::copy_params, Parser::create_stmt_for_query(), deferred_copy_from_sessions, ParserWrapper::Delete, dispatch_queue_, execute_distributed_copy_statement(), execute_rel_alg(), execute_rel_alg_with_filter_push_down(), executeDdl(), ExecutionResult::Explanation, DBHandler::DeferredCopyFromState::file_name, g_cluster, g_enable_filter_push_down, g_enable_runtime_query_interrupt, g_max_log_length, query_state::QueryState::getConstSessionInfo(), legacylockmgr::getExecuteReadLock(), legacylockmgr::getExecuteWriteLock(), Executor::getExecutor(), query_state::QueryState::getQueryStr(), query_state::QueryState::getQuerySubmittedTime(), QueryExecutionError::hasErrorCode(), ParserWrapper::Insert, ExplainInfo::isCalciteExplain(), leaf_aggregator_, leaf_handler_, LeafAggregator::leafCount(), anonymous_namespace{DBHandler.cpp}::log_system_cpu_memory_status(), ParserWrapper::NotDML, parse_to_ra(), DBHandler::DeferredCopyFromState::partitions, ParserWrapper::Read, read_only_, run_benchmark_import::result, ParserWrapper::SchemaRead, ExecutionResult::SimpleResult, strip(), substring(), system_parameters_, DBHandler::DeferredCopyFromState::table, logger::thread_local_ids(), THROW_DB_EXCEPTION, Executor::UNITARY_EXECUTOR_ID, ParserWrapper::Unknown, ParserWrapper::Update, ExecutionResult::updateResultSet(), and system_validator::SingleNodeValidator::validate().
Referenced by sql_execute(), sql_execute_df(), and sql_execute_local().
|
private |
Definition at line 1193 of file DBHandler.cpp.
References convertData(), measure< TimeT >::execution(), LOG, ParserWrapper::Read, run_benchmark_import::result, ParserWrapper::SchemaRead, ParserWrapper::SchemaWrite, sql_execute_impl(), VLOG, logger::WARNING, and ParserWrapper::Write.
Referenced by sql_execute().
|
override |
Definition at line 1594 of file DBHandler.cpp.
References create_query_state(), get_session_ptr(), getConnectionInfo(), legacylockmgr::getExecuteReadLock(), parse_to_ra(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, system_parameters_, THROW_DB_EXCEPTION, toString(), and validateRelAlg().
|
override |
Definition at line 6084 of file DBHandler.cpp.
References get_session_ptr(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, and THROW_DB_EXCEPTION.
|
override |
Definition at line 7053 of file DBHandler.cpp.
References measure< TimeT >::execution(), get_session_ptr(), logger::INFO, leaf_handler_, LOG, heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, and THROW_DB_EXCEPTION.
|
override |
Definition at line 7295 of file DBHandler.cpp.
References measure< TimeT >::execution(), get_session_ptr(), logger::INFO, LOG, render_handler_, heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, and THROW_DB_EXCEPTION.
|
override |
Definition at line 6098 of file DBHandler.cpp.
References get_session_ptr(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, and THROW_DB_EXCEPTION.
|
override |
Definition at line 747 of file DBHandler.cpp.
References cat(), get_session_ptr(), getConnectionInfo(), lockmgr::instance(), leaf_aggregator_, LeafAggregator::leafCount(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, LeafAggregator::switch_database(), THROW_DB_EXCEPTION, and toString().
Referenced by alterSession().
|
private |
Definition at line 3854 of file DBHandler.cpp.
References import_export::CopyParams::add_metadata_columns, import_export::CopyParams::array_begin, import_export::CopyParams::array_delim, import_export::CopyParams::array_end, CHECK, import_export::CopyParams::connection_string, import_export::CopyParams::credential_string, import_export::CopyParams::delimiter, import_export::CopyParams::dsn, import_export::CopyParams::escape, g_allow_s3_server_privileges, import_export::CopyParams::geo_coords_comp_param, import_export::CopyParams::geo_coords_encoding, import_export::CopyParams::geo_coords_srid, import_export::CopyParams::geo_coords_type, import_export::CopyParams::geo_explode_collections, import_export::CopyParams::geo_layer_name, import_export::CopyParams::geo_validate_geometry, import_export::CopyParams::has_header, import_export::kAuto, import_export::kAutoDetect, import_export::kDelimitedFile, import_export::kDouble, kENCODING_GEOINT, kENCODING_NONE, import_export::kFile, import_export::kFloat, import_export::kGeoFile, kGEOGRAPHY, kGEOMETRY, import_export::kHasHeader, import_export::kInt, import_export::kNoHeader, import_export::kNone, import_export::kParquetFile, import_export::kPoint, import_export::kRasterFile, import_export::kSmallInt, import_export::kWorld, import_export::CopyParams::line_delim, import_export::CopyParams::null_str, import_export::CopyParams::password, import_export::CopyParams::quote, import_export::CopyParams::quoted, import_export::CopyParams::raster_drop_if_all_null, import_export::CopyParams::raster_import_bands, import_export::CopyParams::raster_import_dimensions, import_export::CopyParams::raster_point_compute_angle, import_export::CopyParams::raster_point_transform, import_export::CopyParams::raster_point_type, import_export::CopyParams::raster_scanlines_per_thread, import_export::CopyParams::s3_access_key, import_export::CopyParams::s3_endpoint, import_export::CopyParams::s3_region, import_export::CopyParams::s3_secret_key, import_export::CopyParams::s3_session_token, import_export::CopyParams::sanitize_column_names, import_export::CopyParams::source_srid, import_export::CopyParams::source_type, import_export::CopyParams::sql_order_by, import_export::CopyParams::sql_select, import_export::CopyParams::threads, THROW_DB_EXCEPTION, to_string(), import_export::CopyParams::trim_spaces, unescape_char(), and import_export::CopyParams::username.
Referenced by detect_column_types(), get_all_files_in_archive(), get_first_geo_file_in_archive(), get_layers_in_geo_file(), import_geo_table(), and import_table().
|
private |
Definition at line 3836 of file DBHandler.cpp.
Referenced by thrift_to_copyparams().
|
override |
Definition at line 5082 of file DBHandler.cpp.
References unshare_dashboards().
|
override |
Definition at line 5072 of file DBHandler.cpp.
References heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, and shareOrUnshareDashboards().
Referenced by unshare_dashboard().
|
override |
Definition at line 4660 of file DBHandler.cpp.
References check_read_only(), custom_expressions_mutex_, get_session_ptr(), getConnectionInfo(), heavyai::RequestInfo::requestId(), heavyai::RequestInfo::sessionId(), SET_REQUEST_ID, STDLOG, THROW_DB_EXCEPTION, and toString().
|
private |
Definition at line 6418 of file DBHandler.cpp.
References cat(), CHECK, Catalog_Namespace::SessionInfo::get_currentUser(), Catalog_Namespace::SessionInfo::getCatalog(), lockmgr::instance(), DBObject::loadKey(), DBObject::setPrivileges(), TableDBObjectType, and TableDescriptor::tableName.
|
private |
Definition at line 354 of file DBHandler.cpp.
References CHECK, g_num_tuple_threshold_switch_to_baseline, and g_ratio_num_hash_entry_to_num_tuple_switch_to_baseline.
Referenced by initialize().
|
private |
Definition at line 4983 of file DBHandler.cpp.
References cat(), Catalog_Namespace::SessionInfo::get_currentUser(), Catalog_Namespace::SessionInfo::getCatalog(), Catalog_Namespace::UserMetadata::isSuper, join(), THROW_DB_EXCEPTION, and Catalog_Namespace::UserMetadata::userId.
Referenced by shareOrUnshareDashboards().
|
private |
Definition at line 4975 of file DBHandler.cpp.
References lockmgr::instance(), and THROW_DB_EXCEPTION.
Referenced by shareOrUnshareDashboards().
|
private |
Definition at line 1826 of file DBHandler.cpp.
References cat(), CHECK, CHECK_EQ, convertData(), CPU, dispatch_query_task(), execute_rel_alg(), Catalog_Namespace::SysCatalog::getCatalog(), Catalog_Namespace::SysCatalog::instance(), kENCODING_DICT, and logger::thread_local_ids().
Referenced by get_table_details_impl(), and sql_validate().
|
staticprivate |
Definition at line 1103 of file DBHandler.cpp.
References CHECK, CHECK_EQ, SQLTypeInfo::get_elem_type(), SQLTypeInfo::get_notnull(), SQLTypeInfo::get_scale(), SQLTypeInfo::get_type(), SQLTypeInfo::is_array(), SQLTypeInfo::is_decimal(), kBIGINT, kBOOLEAN, kDATE, kDECIMAL, kFLOAT, kINT, kINTERVAL_DAY_TIME, kINTERVAL_YEAR_MONTH, kNUMERIC, kSMALLINT, kTIME, kTIMESTAMP, kTINYINT, NULL_BIGINT, NULL_BOOLEAN, NULL_DOUBLE, NULL_FLOAT, NULL_INT, NULL_SMALLINT, and NULL_TINYINT.
Referenced by convertRows().
|
staticprivate |
Definition at line 978 of file DBHandler.cpp.
References CHECK, CHECK_EQ, SQLTypeInfo::get_elem_type(), SQLTypeInfo::get_notnull(), SQLTypeInfo::get_scale(), SQLTypeInfo::get_type(), SQLTypeInfo::is_array(), SQLTypeInfo::is_column(), SQLTypeInfo::is_decimal(), SQLTypeInfo::is_geometry(), is_null(), kBIGINT, kBOOLEAN, kDATE, kDECIMAL, kDOUBLE, kFLOAT, kINT, kINTERVAL_DAY_TIME, kINTERVAL_YEAR_MONTH, kNUMERIC, kSMALLINT, kTIME, kTIMESTAMP, kTINYINT, NULL_BIGINT, NULL_BOOLEAN, NULL_DOUBLE, NULL_FLOAT, NULL_INT, NULL_SMALLINT, and NULL_TINYINT.
Referenced by convertRows().
|
friend |
Definition at line 1029 of file DBHandler.h.
|
friend |
Definition at line 1030 of file DBHandler.h.
|
friend |
Definition at line 1028 of file DBHandler.h.
|
friend |
Definition at line 215 of file HeavyDB.cpp.
std::unique_ptr<HeavyDBAggHandler> DBHandler::agg_handler_ |
Definition at line 655 of file DBHandler.h.
Referenced by sql_execute().
const bool DBHandler::allow_loop_joins_ |
Definition at line 646 of file DBHandler.h.
Referenced by execute_rel_alg().
bool DBHandler::allow_multifrag_ |
Definition at line 644 of file DBHandler.h.
Referenced by execute_rel_alg().
const AuthMetadata& DBHandler::authMetadata_ |
Definition at line 651 of file DBHandler.h.
Referenced by initialize().
const std::string DBHandler::base_data_path_ |
Definition at line 637 of file DBHandler.h.
Referenced by initialize(), and resetSessionsStore().
std::shared_ptr<Calcite> DBHandler::calcite_ |
Definition at line 657 of file DBHandler.h.
Referenced by createInMemoryCalciteSession(), emergency_shutdown(), get_completion_hints_unsorted(), get_table_details_impl(), initialize(), processCalciteRequest(), and register_runtime_extension_functions().
|
private |
Definition at line 951 of file DBHandler.h.
Referenced by createInMemoryCalciteSession(), findCalciteSession(), get_session_copy(), and removeInMemoryCalciteSession().
|
mutableprivate |
Definition at line 952 of file DBHandler.h.
Referenced by createInMemoryCalciteSession(), findCalciteSession(), get_session_copy(), and removeInMemoryCalciteSession().
|
private |
Definition at line 983 of file DBHandler.h.
Referenced by initialize().
|
private |
Definition at line 982 of file DBHandler.h.
Referenced by initialize().
bool DBHandler::cpu_mode_only_ |
Definition at line 647 of file DBHandler.h.
Referenced by get_device_parameters(), initialize(), and set_execution_mode_nolock().
|
private |
Definition at line 1073 of file DBHandler.h.
Referenced by create_custom_expression(), delete_custom_expressions(), get_custom_expressions(), and update_custom_expression().
std::shared_ptr<Data_Namespace::DataMgr> DBHandler::data_mgr_ |
Definition at line 632 of file DBHandler.h.
Referenced by deallocate_df(), get_hardware_info(), init_executor_resource_mgr(), initialize(), and sql_execute_df().
std::vector<LeafHostInfo> DBHandler::db_leaves_ |
Definition at line 635 of file DBHandler.h.
Referenced by initialize().
|
private |
Definition at line 1018 of file DBHandler.h.
Referenced by process_deferred_copy_from(), sql_execute(), and sql_execute_impl().
|
private |
Definition at line 980 of file DBHandler.h.
Referenced by initialize().
std::unique_ptr<QueryDispatchQueue> DBHandler::dispatch_queue_ |
Definition at line 660 of file DBHandler.h.
Referenced by dispatch_query_task(), resizeDispatchQueue(), and sql_execute_impl().
|
private |
Definition at line 966 of file DBHandler.h.
|
private |
Definition at line 962 of file DBHandler.h.
Referenced by initialize().
ExecutorDeviceType DBHandler::executor_device_type_ |
Definition at line 639 of file DBHandler.h.
Referenced by clone_session(), connect_impl(), createInMemoryCalciteSession(), and initialize().
|
mutableprivate |
Definition at line 1021 of file DBHandler.h.
Referenced by deallocate_df(), and sql_execute_df().
|
private |
Definition at line 959 of file DBHandler.h.
Referenced by resetSessionsStore().
boost::filesystem::path DBHandler::import_path_ |
Definition at line 638 of file DBHandler.h.
Referenced by detect_column_types(), get_all_files_in_archive(), get_first_geo_file_in_archive(), get_layers_in_geo_file(), import_table(), importGeoTableSingle(), and initialize().
|
private |
Definition at line 686 of file DBHandler.h.
Referenced by initialize().
const bool DBHandler::intel_jit_profile_ |
Definition at line 643 of file DBHandler.h.
Referenced by execute_rel_alg().
|
mutableprivate |
Definition at line 1022 of file DBHandler.h.
Referenced by deallocate_df(), and sql_execute_df().
const bool DBHandler::jit_debug_ |
Definition at line 642 of file DBHandler.h.
Referenced by execute_rel_alg(), get_queries_info(), getQueries(), interrupt(), and interruptQuery().
LeafAggregator DBHandler::leaf_aggregator_ |
Definition at line 634 of file DBHandler.h.
Referenced by clone_session(), disconnect_impl(), get_status(), getServerRole(), interrupt(), interruptQuery(), isAggregator(), prepare_loader_generic(), set_table_epochs(), sql_execute(), sql_execute_impl(), and switch_database().
std::unique_ptr<HeavyDBLeafHandler> DBHandler::leaf_handler_ |
Definition at line 656 of file DBHandler.h.
Referenced by broadcast_serialized_rows(), check_table_consistency(), execute_query_step(), query_get_outer_fragment_count(), sql_execute_impl(), and start_query().
const bool DBHandler::legacy_syntax_ |
Definition at line 658 of file DBHandler.h.
Referenced by processCalciteRequest().
|
private |
Definition at line 969 of file DBHandler.h.
Referenced by initialize().
|
private |
Definition at line 984 of file DBHandler.h.
Referenced by resetSessionsStore().
|
private |
Definition at line 960 of file DBHandler.h.
Referenced by resetSessionsStore().
|
private |
Definition at line 973 of file DBHandler.h.
Referenced by initialize().
|
private |
Definition at line 1032 of file DBHandler.h.
Referenced by has_object_privilege().
std::shared_ptr<QueryEngine> DBHandler::query_engine_ |
Definition at line 653 of file DBHandler.h.
Referenced by initialize(), and shutdown().
|
private |
Definition at line 950 of file DBHandler.h.
std::default_random_engine DBHandler::random_gen_ |
Definition at line 640 of file DBHandler.h.
const bool DBHandler::read_only_ |
Definition at line 645 of file DBHandler.h.
Referenced by check_read_only(), executeDdl(), get_server_status(), get_status(), and sql_execute_impl().
|
private |
Definition at line 971 of file DBHandler.h.
Referenced by initialize().
std::unique_ptr<RenderHandler> DBHandler::render_handler_ |
Definition at line 654 of file DBHandler.h.
Referenced by clear_cpu_memory(), clear_gpu_memory(), clearRenderMemory(), disconnect_impl(), execute_next_render_step(), get_result_row_for_pixel(), get_server_status(), get_status(), initialize(), render_vega(), shutdown(), and start_render_query().
|
private |
Definition at line 968 of file DBHandler.h.
Referenced by initialize().
std::mutex DBHandler::render_mutex_ |
Definition at line 649 of file DBHandler.h.
|
private |
Definition at line 967 of file DBHandler.h.
|
private |
Definition at line 972 of file DBHandler.h.
Referenced by initialize().
|
private |
Definition at line 963 of file DBHandler.h.
Referenced by initialize().
|
private |
Definition at line 965 of file DBHandler.h.
Referenced by initialize().
|
private |
Definition at line 964 of file DBHandler.h.
Referenced by initialize().
|
private |
Definition at line 970 of file DBHandler.h.
Referenced by initialize().
std::uniform_int_distribution<int64_t> DBHandler::session_id_dist_ |
Definition at line 641 of file DBHandler.h.
heavyai::shared_mutex DBHandler::sessions_mutex_ |
Definition at line 648 of file DBHandler.h.
|
private |
Definition at line 985 of file DBHandler.h.
Referenced by check_and_invalidate_sessions(), clone_session(), connect_impl(), disconnect(), get_queries_info(), get_session_copy(), get_session_ptr(), getQueries(), getUserSessions(), interruptQuery(), and resetSessionsStore().
int64_t DBHandler::start_time_ |
Definition at line 650 of file DBHandler.h.
Referenced by get_server_status(), get_status(), and initialize().
std::vector<LeafHostInfo> DBHandler::string_leaves_ |
Definition at line 636 of file DBHandler.h.
Referenced by initialize().
|
private |
Definition at line 956 of file DBHandler.h.
Referenced by connect(), connect_impl(), and get_status().
SystemParameters& DBHandler::system_parameters_ |
Definition at line 652 of file DBHandler.h.
Referenced by execute_rel_alg(), execute_rel_alg_with_filter_push_down(), get_queries_info(), get_table_details_impl(), get_tables_meta_impl(), getQueries(), init_executor_resource_mgr(), initialize(), interrupt(), interruptQuery(), register_runtime_extension_functions(), sql_execute(), sql_execute_impl(), and sql_validate().
|
private |
Definition at line 981 of file DBHandler.h.
Referenced by initialize().