heavydb.thrift.Heavy.Processor Class Reference

Inheritance diagram for heavydb.thrift.Heavy.Processor:

Collaboration diagram for heavydb.thrift.Heavy.Processor:

Public Member Functions
def	__init__
def	on_message_begin
def	process
def	process_connect
def	process_krb5_connect
def	process_disconnect
def	process_switch_database
def	process_clone_session
def	process_get_server_status
def	process_get_status
def	process_get_hardware_info
def	process_get_tables
def	process_get_tables_for_database
def	process_get_physical_tables
def	process_get_views
def	process_get_tables_meta
def	process_get_table_details
def	process_get_table_details_for_database
def	process_get_internal_table_details
def	process_get_internal_table_details_for_database
def	process_get_users
def	process_get_databases
def	process_get_version
def	process_start_heap_profile
def	process_stop_heap_profile
def	process_get_heap_profile
def	process_get_memory
def	process_clear_cpu_memory
def	process_clear_gpu_memory
def	process_set_cur_session
def	process_invalidate_cur_session
def	process_set_table_epoch
def	process_set_table_epoch_by_name
def	process_get_table_epoch
def	process_get_table_epoch_by_name
def	process_get_table_epochs
def	process_set_table_epochs
def	process_get_session_info
def	process_get_queries_info
def	process_set_leaf_info
def	process_sql_execute
def	process_sql_execute_df
def	process_sql_execute_gdf
def	process_deallocate_df
def	process_interrupt
def	process_sql_validate
def	process_get_completion_hints
def	process_set_execution_mode
def	process_render_vega
def	process_get_result_row_for_pixel
def	process_create_custom_expression
def	process_get_custom_expressions
def	process_update_custom_expression
def	process_delete_custom_expressions
def	process_get_dashboard
def	process_get_dashboards
def	process_create_dashboard
def	process_replace_dashboard
def	process_delete_dashboard
def	process_share_dashboards
def	process_delete_dashboards
def	process_share_dashboard
def	process_unshare_dashboard
def	process_unshare_dashboards
def	process_get_dashboard_grantees
def	process_get_link_view
def	process_create_link
def	process_load_table_binary
def	process_load_table_binary_columnar
def	process_load_table_binary_arrow
def	process_load_table
def	process_detect_column_types
def	process_create_table
def	process_import_table
def	process_import_geo_table
def	process_import_table_status
def	process_get_first_geo_file_in_archive
def	process_get_all_files_in_archive
def	process_get_layers_in_geo_file
def	process_query_get_outer_fragment_count
def	process_check_table_consistency
def	process_start_query
def	process_execute_query_step
def	process_broadcast_serialized_rows
def	process_start_render_query
def	process_execute_next_render_step
def	process_insert_data
def	process_insert_chunks
def	process_checkpoint
def	process_get_roles
def	process_get_db_objects_for_grantee
def	process_get_db_object_privs
def	process_get_all_roles_for_user
def	process_get_all_effective_roles_for_user
def	process_has_role
def	process_has_object_privilege
def	process_set_license_key
def	process_get_license_claims
def	process_get_device_parameters
def	process_register_runtime_extension_functions
def	process_get_table_function_names
def	process_get_runtime_table_function_names
def	process_get_table_function_details
def	process_get_function_names
def	process_get_runtime_function_names
def	process_get_function_details
Public Member Functions inherited from heavydb.thrift.Heavy.Iface
def	connect
def	krb5_connect
def	disconnect
def	switch_database
def	clone_session
def	get_server_status
def	get_status
def	get_hardware_info
def	get_tables
def	get_tables_for_database
def	get_physical_tables
def	get_views
def	get_tables_meta
def	get_table_details
def	get_table_details_for_database
def	get_internal_table_details
def	get_internal_table_details_for_database
def	get_users
def	get_databases
def	get_version
def	start_heap_profile
def	stop_heap_profile
def	get_heap_profile
def	get_memory
def	clear_cpu_memory
def	clear_gpu_memory
def	set_cur_session
def	invalidate_cur_session
def	set_table_epoch
def	set_table_epoch_by_name
def	get_table_epoch
def	get_table_epoch_by_name
def	get_table_epochs
def	set_table_epochs
def	get_session_info
def	get_queries_info
def	set_leaf_info
def	sql_execute
def	sql_execute_df
def	sql_execute_gdf
def	deallocate_df
def	interrupt
def	sql_validate
def	get_completion_hints
def	set_execution_mode
def	render_vega
def	get_result_row_for_pixel
def	create_custom_expression
def	get_custom_expressions
def	update_custom_expression
def	delete_custom_expressions
def	get_dashboard
def	get_dashboards
def	create_dashboard
def	replace_dashboard
def	delete_dashboard
def	share_dashboards
def	delete_dashboards
def	share_dashboard
def	unshare_dashboard
def	unshare_dashboards
def	get_dashboard_grantees
def	get_link_view
def	create_link
def	load_table_binary
def	load_table_binary_columnar
def	load_table_binary_arrow
def	load_table
def	detect_column_types
def	create_table
def	import_table
def	import_geo_table
def	import_table_status
def	get_first_geo_file_in_archive
def	get_all_files_in_archive
def	get_layers_in_geo_file
def	query_get_outer_fragment_count
def	check_table_consistency
def	start_query
def	execute_query_step
def	broadcast_serialized_rows
def	start_render_query
def	execute_next_render_step
def	insert_data
def	insert_chunks
def	checkpoint
def	get_roles
def	get_db_objects_for_grantee
def	get_db_object_privs
def	get_all_roles_for_user
def	get_all_effective_roles_for_user
def	has_role
def	has_object_privilege
def	set_license_key
def	get_license_claims
def	get_device_parameters
def	register_runtime_extension_functions
def	get_table_function_names
def	get_runtime_table_function_names
def	get_table_function_details
def	get_function_names
def	get_runtime_function_names
def	get_function_details

Private Attributes
	_handler
	_processMap
	_on_message_begin

Detailed Description

Definition at line 4785 of file Heavy.py.

Constructor & Destructor Documentation

def heavydb.thrift.Heavy.Processor.__init__	(		self,
			handler
	)

Definition at line 4786 of file Heavy.py.

    def __init__(self, handler):
        self._handler = handler
        self._processMap = {}
        self._processMap["connect"] = Processor.process_connect
        self._processMap["krb5_connect"] = Processor.process_krb5_connect
        self._processMap["disconnect"] = Processor.process_disconnect
        self._processMap["switch_database"] = Processor.process_switch_database
        self._processMap["clone_session"] = Processor.process_clone_session
        self._processMap["get_server_status"] = Processor.process_get_server_status
        self._processMap["get_status"] = Processor.process_get_status
        self._processMap["get_hardware_info"] = Processor.process_get_hardware_info
        self._processMap["get_tables"] = Processor.process_get_tables
        self._processMap["get_tables_for_database"] = Processor.process_get_tables_for_database
        self._processMap["get_physical_tables"] = Processor.process_get_physical_tables
        self._processMap["get_views"] = Processor.process_get_views
        self._processMap["get_tables_meta"] = Processor.process_get_tables_meta
        self._processMap["get_table_details"] = Processor.process_get_table_details
        self._processMap["get_table_details_for_database"] = Processor.process_get_table_details_for_database
        self._processMap["get_internal_table_details"] = Processor.process_get_internal_table_details
        self._processMap["get_internal_table_details_for_database"] = Processor.process_get_internal_table_details_for_database
        self._processMap["get_users"] = Processor.process_get_users
        self._processMap["get_databases"] = Processor.process_get_databases
        self._processMap["get_version"] = Processor.process_get_version
        self._processMap["start_heap_profile"] = Processor.process_start_heap_profile
        self._processMap["stop_heap_profile"] = Processor.process_stop_heap_profile
        self._processMap["get_heap_profile"] = Processor.process_get_heap_profile
        self._processMap["get_memory"] = Processor.process_get_memory
        self._processMap["clear_cpu_memory"] = Processor.process_clear_cpu_memory
        self._processMap["clear_gpu_memory"] = Processor.process_clear_gpu_memory
        self._processMap["set_cur_session"] = Processor.process_set_cur_session
        self._processMap["invalidate_cur_session"] = Processor.process_invalidate_cur_session
        self._processMap["set_table_epoch"] = Processor.process_set_table_epoch
        self._processMap["set_table_epoch_by_name"] = Processor.process_set_table_epoch_by_name
        self._processMap["get_table_epoch"] = Processor.process_get_table_epoch
        self._processMap["get_table_epoch_by_name"] = Processor.process_get_table_epoch_by_name
        self._processMap["get_table_epochs"] = Processor.process_get_table_epochs
        self._processMap["set_table_epochs"] = Processor.process_set_table_epochs
        self._processMap["get_session_info"] = Processor.process_get_session_info
        self._processMap["get_queries_info"] = Processor.process_get_queries_info
        self._processMap["set_leaf_info"] = Processor.process_set_leaf_info
        self._processMap["sql_execute"] = Processor.process_sql_execute
        self._processMap["sql_execute_df"] = Processor.process_sql_execute_df
        self._processMap["sql_execute_gdf"] = Processor.process_sql_execute_gdf
        self._processMap["deallocate_df"] = Processor.process_deallocate_df
        self._processMap["interrupt"] = Processor.process_interrupt
        self._processMap["sql_validate"] = Processor.process_sql_validate
        self._processMap["get_completion_hints"] = Processor.process_get_completion_hints
        self._processMap["set_execution_mode"] = Processor.process_set_execution_mode
        self._processMap["render_vega"] = Processor.process_render_vega
        self._processMap["get_result_row_for_pixel"] = Processor.process_get_result_row_for_pixel
        self._processMap["create_custom_expression"] = Processor.process_create_custom_expression
        self._processMap["get_custom_expressions"] = Processor.process_get_custom_expressions
        self._processMap["update_custom_expression"] = Processor.process_update_custom_expression
        self._processMap["delete_custom_expressions"] = Processor.process_delete_custom_expressions
        self._processMap["get_dashboard"] = Processor.process_get_dashboard
        self._processMap["get_dashboards"] = Processor.process_get_dashboards
        self._processMap["create_dashboard"] = Processor.process_create_dashboard
        self._processMap["replace_dashboard"] = Processor.process_replace_dashboard
        self._processMap["delete_dashboard"] = Processor.process_delete_dashboard
        self._processMap["share_dashboards"] = Processor.process_share_dashboards
        self._processMap["delete_dashboards"] = Processor.process_delete_dashboards
        self._processMap["share_dashboard"] = Processor.process_share_dashboard
        self._processMap["unshare_dashboard"] = Processor.process_unshare_dashboard
        self._processMap["unshare_dashboards"] = Processor.process_unshare_dashboards
        self._processMap["get_dashboard_grantees"] = Processor.process_get_dashboard_grantees
        self._processMap["get_link_view"] = Processor.process_get_link_view
        self._processMap["create_link"] = Processor.process_create_link
        self._processMap["load_table_binary"] = Processor.process_load_table_binary
        self._processMap["load_table_binary_columnar"] = Processor.process_load_table_binary_columnar
        self._processMap["load_table_binary_arrow"] = Processor.process_load_table_binary_arrow
        self._processMap["load_table"] = Processor.process_load_table
        self._processMap["detect_column_types"] = Processor.process_detect_column_types
        self._processMap["create_table"] = Processor.process_create_table
        self._processMap["import_table"] = Processor.process_import_table
        self._processMap["import_geo_table"] = Processor.process_import_geo_table
        self._processMap["import_table_status"] = Processor.process_import_table_status
        self._processMap["get_first_geo_file_in_archive"] = Processor.process_get_first_geo_file_in_archive
        self._processMap["get_all_files_in_archive"] = Processor.process_get_all_files_in_archive
        self._processMap["get_layers_in_geo_file"] = Processor.process_get_layers_in_geo_file
        self._processMap["query_get_outer_fragment_count"] = Processor.process_query_get_outer_fragment_count
        self._processMap["check_table_consistency"] = Processor.process_check_table_consistency
        self._processMap["start_query"] = Processor.process_start_query
        self._processMap["execute_query_step"] = Processor.process_execute_query_step
        self._processMap["broadcast_serialized_rows"] = Processor.process_broadcast_serialized_rows
        self._processMap["start_render_query"] = Processor.process_start_render_query
        self._processMap["execute_next_render_step"] = Processor.process_execute_next_render_step
        self._processMap["insert_data"] = Processor.process_insert_data
        self._processMap["insert_chunks"] = Processor.process_insert_chunks
        self._processMap["checkpoint"] = Processor.process_checkpoint
        self._processMap["get_roles"] = Processor.process_get_roles
        self._processMap["get_db_objects_for_grantee"] = Processor.process_get_db_objects_for_grantee
        self._processMap["get_db_object_privs"] = Processor.process_get_db_object_privs
        self._processMap["get_all_roles_for_user"] = Processor.process_get_all_roles_for_user
        self._processMap["get_all_effective_roles_for_user"] = Processor.process_get_all_effective_roles_for_user
        self._processMap["has_role"] = Processor.process_has_role
        self._processMap["has_object_privilege"] = Processor.process_has_object_privilege
        self._processMap["set_license_key"] = Processor.process_set_license_key
        self._processMap["get_license_claims"] = Processor.process_get_license_claims
        self._processMap["get_device_parameters"] = Processor.process_get_device_parameters
        self._processMap["register_runtime_extension_functions"] = Processor.process_register_runtime_extension_functions
        self._processMap["get_table_function_names"] = Processor.process_get_table_function_names
        self._processMap["get_runtime_table_function_names"] = Processor.process_get_runtime_table_function_names
        self._processMap["get_table_function_details"] = Processor.process_get_table_function_details
        self._processMap["get_function_names"] = Processor.process_get_function_names
        self._processMap["get_runtime_function_names"] = Processor.process_get_runtime_function_names
        self._processMap["get_function_details"] = Processor.process_get_function_details
        self._on_message_begin = None