OmniSciDB  a7179b2938
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
omnisci.thrift.OmniSci.Processor Class Reference
+ Inheritance diagram for omnisci.thrift.OmniSci.Processor:
+ Collaboration diagram for omnisci.thrift.OmniSci.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_physical_tables
 
def process_get_views
 
def process_get_tables_meta
 
def process_get_table_details
 
def process_get_internal_table_details
 
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_table_epoch
 
def process_set_table_epoch_by_name
 
def process_get_table_epoch
 
def process_get_table_epoch_by_name
 
def process_get_session_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_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_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_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
 
- Public Member Functions inherited from omnisci.thrift.OmniSci.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_physical_tables
 
def get_views
 
def get_tables_meta
 
def get_table_details
 
def get_internal_table_details
 
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_table_epoch
 
def set_table_epoch_by_name
 
def get_table_epoch
 
def get_table_epoch_by_name
 
def get_session_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 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 checkpoint
 
def get_roles
 
def get_db_objects_for_grantee
 
def get_db_object_privs
 
def get_all_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
 

Private Attributes

 _handler
 
 _processMap
 
 _on_message_begin
 

Detailed Description

Definition at line 3816 of file OmniSci.py.

Constructor & Destructor Documentation

def omnisci.thrift.OmniSci.Processor.__init__ (   self,
  handler 
)

Definition at line 3817 of file OmniSci.py.

3818  def __init__(self, handler):
3819  self._handler = handler
3820  self._processMap = {}
3821  self._processMap["connect"] = Processor.process_connect
3822  self._processMap["krb5_connect"] = Processor.process_krb5_connect
3823  self._processMap["disconnect"] = Processor.process_disconnect
3824  self._processMap["switch_database"] = Processor.process_switch_database
3825  self._processMap["clone_session"] = Processor.process_clone_session
3826  self._processMap["get_server_status"] = Processor.process_get_server_status
3827  self._processMap["get_status"] = Processor.process_get_status
3828  self._processMap["get_hardware_info"] = Processor.process_get_hardware_info
3829  self._processMap["get_tables"] = Processor.process_get_tables
3830  self._processMap["get_physical_tables"] = Processor.process_get_physical_tables
3831  self._processMap["get_views"] = Processor.process_get_views
3832  self._processMap["get_tables_meta"] = Processor.process_get_tables_meta
3833  self._processMap["get_table_details"] = Processor.process_get_table_details
3834  self._processMap["get_internal_table_details"] = Processor.process_get_internal_table_details
3835  self._processMap["get_users"] = Processor.process_get_users
3836  self._processMap["get_databases"] = Processor.process_get_databases
3837  self._processMap["get_version"] = Processor.process_get_version
3838  self._processMap["start_heap_profile"] = Processor.process_start_heap_profile
3839  self._processMap["stop_heap_profile"] = Processor.process_stop_heap_profile
3840  self._processMap["get_heap_profile"] = Processor.process_get_heap_profile
3841  self._processMap["get_memory"] = Processor.process_get_memory
3842  self._processMap["clear_cpu_memory"] = Processor.process_clear_cpu_memory
3843  self._processMap["clear_gpu_memory"] = Processor.process_clear_gpu_memory
3844  self._processMap["set_table_epoch"] = Processor.process_set_table_epoch
3845  self._processMap["set_table_epoch_by_name"] = Processor.process_set_table_epoch_by_name
3846  self._processMap["get_table_epoch"] = Processor.process_get_table_epoch
3847  self._processMap["get_table_epoch_by_name"] = Processor.process_get_table_epoch_by_name
3848  self._processMap["get_session_info"] = Processor.process_get_session_info
3849  self._processMap["sql_execute"] = Processor.process_sql_execute
3850  self._processMap["sql_execute_df"] = Processor.process_sql_execute_df
3851  self._processMap["sql_execute_gdf"] = Processor.process_sql_execute_gdf
3852  self._processMap["deallocate_df"] = Processor.process_deallocate_df
3853  self._processMap["interrupt"] = Processor.process_interrupt
3854  self._processMap["sql_validate"] = Processor.process_sql_validate
3855  self._processMap["get_completion_hints"] = Processor.process_get_completion_hints
3856  self._processMap["set_execution_mode"] = Processor.process_set_execution_mode
3857  self._processMap["render_vega"] = Processor.process_render_vega
3858  self._processMap["get_result_row_for_pixel"] = Processor.process_get_result_row_for_pixel
3859  self._processMap["get_dashboard"] = Processor.process_get_dashboard
3860  self._processMap["get_dashboards"] = Processor.process_get_dashboards
3861  self._processMap["create_dashboard"] = Processor.process_create_dashboard
3862  self._processMap["replace_dashboard"] = Processor.process_replace_dashboard
3863  self._processMap["delete_dashboard"] = Processor.process_delete_dashboard
3864  self._processMap["share_dashboards"] = Processor.process_share_dashboards
3865  self._processMap["delete_dashboards"] = Processor.process_delete_dashboards
3866  self._processMap["share_dashboard"] = Processor.process_share_dashboard
3867  self._processMap["unshare_dashboard"] = Processor.process_unshare_dashboard
3868  self._processMap["unshare_dashboards"] = Processor.process_unshare_dashboards
3869  self._processMap["get_dashboard_grantees"] = Processor.process_get_dashboard_grantees
3870  self._processMap["get_link_view"] = Processor.process_get_link_view
3871  self._processMap["create_link"] = Processor.process_create_link
3872  self._processMap["load_table_binary"] = Processor.process_load_table_binary
3873  self._processMap["load_table_binary_columnar"] = Processor.process_load_table_binary_columnar
3874  self._processMap["load_table_binary_arrow"] = Processor.process_load_table_binary_arrow
3875  self._processMap["load_table"] = Processor.process_load_table
3876  self._processMap["detect_column_types"] = Processor.process_detect_column_types
3877  self._processMap["create_table"] = Processor.process_create_table
3878  self._processMap["import_table"] = Processor.process_import_table
3879  self._processMap["import_geo_table"] = Processor.process_import_geo_table
3880  self._processMap["import_table_status"] = Processor.process_import_table_status
3881  self._processMap["get_first_geo_file_in_archive"] = Processor.process_get_first_geo_file_in_archive
3882  self._processMap["get_all_files_in_archive"] = Processor.process_get_all_files_in_archive
3883  self._processMap["get_layers_in_geo_file"] = Processor.process_get_layers_in_geo_file
3884  self._processMap["query_get_outer_fragment_count"] = Processor.process_query_get_outer_fragment_count
3885  self._processMap["check_table_consistency"] = Processor.process_check_table_consistency
3886  self._processMap["start_query"] = Processor.process_start_query
3887  self._processMap["execute_query_step"] = Processor.process_execute_query_step
3888  self._processMap["broadcast_serialized_rows"] = Processor.process_broadcast_serialized_rows
3889  self._processMap["start_render_query"] = Processor.process_start_render_query
3890  self._processMap["execute_next_render_step"] = Processor.process_execute_next_render_step
3891  self._processMap["insert_data"] = Processor.process_insert_data
3892  self._processMap["checkpoint"] = Processor.process_checkpoint
3893  self._processMap["get_roles"] = Processor.process_get_roles
3894  self._processMap["get_db_objects_for_grantee"] = Processor.process_get_db_objects_for_grantee
3895  self._processMap["get_db_object_privs"] = Processor.process_get_db_object_privs
3896  self._processMap["get_all_roles_for_user"] = Processor.process_get_all_roles_for_user
3897  self._processMap["has_role"] = Processor.process_has_role
3898  self._processMap["has_object_privilege"] = Processor.process_has_object_privilege
3899  self._processMap["set_license_key"] = Processor.process_set_license_key
3900  self._processMap["get_license_claims"] = Processor.process_get_license_claims
3901  self._processMap["get_device_parameters"] = Processor.process_get_device_parameters
3902  self._processMap["register_runtime_extension_functions"] = Processor.process_register_runtime_extension_functions
3903  self._on_message_begin = None

Member Function Documentation

def omnisci.thrift.OmniSci.Processor.on_message_begin (   self,
  func 
)

Definition at line 3904 of file OmniSci.py.

References omnisci.thrift.OmniSci.Processor._on_message_begin.

3905  def on_message_begin(self, func):
3906  self._on_message_begin = func
def omnisci.thrift.OmniSci.Processor.process (   self,
  iprot,
  oprot 
)

Definition at line 3907 of file OmniSci.py.

References omnisci.thrift.OmniSci.Processor._on_message_begin, and omnisci.thrift.OmniSci.Processor._processMap.

3908  def process(self, iprot, oprot):
3909  (name, type, seqid) = iprot.readMessageBegin()
3910  if self._on_message_begin:
3911  self._on_message_begin(name, type, seqid)
3912  if name not in self._processMap:
3913  iprot.skip(TType.STRUCT)
3914  iprot.readMessageEnd()
3915  x = TApplicationException(TApplicationException.UNKNOWN_METHOD, 'Unknown function %s' % (name))
3916  oprot.writeMessageBegin(name, TMessageType.EXCEPTION, seqid)
3917  x.write(oprot)
3918  oprot.writeMessageEnd()
3919  oprot.trans.flush()
3920  return
3921  else:
3922  self._processMap[name](self, seqid, iprot, oprot)
3923  return True
def omnisci.thrift.OmniSci.Processor.process_broadcast_serialized_rows (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5660 of file OmniSci.py.

5661  def process_broadcast_serialized_rows(self, seqid, iprot, oprot):
5663  args.read(iprot)
5664  iprot.readMessageEnd()
5666  try:
5667  self._handler.broadcast_serialized_rows(args.serialized_rows, args.row_desc, args.query_id)
5668  msg_type = TMessageType.REPLY
5669  except TTransport.TTransportException:
5670  raise
5671  except TOmniSciException as e:
5672  msg_type = TMessageType.REPLY
5673  result.e = e
5674  except TApplicationException as ex:
5675  logging.exception('TApplication exception in handler')
5676  msg_type = TMessageType.EXCEPTION
5677  result = ex
5678  except Exception:
5679  logging.exception('Unexpected exception in handler')
5680  msg_type = TMessageType.EXCEPTION
5681  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5682  oprot.writeMessageBegin("broadcast_serialized_rows", msg_type, seqid)
5683  result.write(oprot)
5684  oprot.writeMessageEnd()
5685  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_check_table_consistency (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5582 of file OmniSci.py.

5583  def process_check_table_consistency(self, seqid, iprot, oprot):
5585  args.read(iprot)
5586  iprot.readMessageEnd()
5588  try:
5589  result.success = self._handler.check_table_consistency(args.session, args.table_id)
5590  msg_type = TMessageType.REPLY
5591  except TTransport.TTransportException:
5592  raise
5593  except TOmniSciException as e:
5594  msg_type = TMessageType.REPLY
5595  result.e = e
5596  except TApplicationException as ex:
5597  logging.exception('TApplication exception in handler')
5598  msg_type = TMessageType.EXCEPTION
5599  result = ex
5600  except Exception:
5601  logging.exception('Unexpected exception in handler')
5602  msg_type = TMessageType.EXCEPTION
5603  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5604  oprot.writeMessageBegin("check_table_consistency", msg_type, seqid)
5605  result.write(oprot)
5606  oprot.writeMessageEnd()
5607  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_checkpoint (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5764 of file OmniSci.py.

5765  def process_checkpoint(self, seqid, iprot, oprot):
5766  args = checkpoint_args()
5767  args.read(iprot)
5768  iprot.readMessageEnd()
5769  result = checkpoint_result()
5770  try:
5771  self._handler.checkpoint(args.session, args.db_id, args.table_id)
5772  msg_type = TMessageType.REPLY
5773  except TTransport.TTransportException:
5774  raise
5775  except TOmniSciException as e:
5776  msg_type = TMessageType.REPLY
5777  result.e = e
5778  except TApplicationException as ex:
5779  logging.exception('TApplication exception in handler')
5780  msg_type = TMessageType.EXCEPTION
5781  result = ex
5782  except Exception:
5783  logging.exception('Unexpected exception in handler')
5784  msg_type = TMessageType.EXCEPTION
5785  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5786  oprot.writeMessageBegin("checkpoint", msg_type, seqid)
5787  result.write(oprot)
5788  oprot.writeMessageEnd()
5789  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_clear_cpu_memory (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4470 of file OmniSci.py.

4471  def process_clear_cpu_memory(self, seqid, iprot, oprot):
4472  args = clear_cpu_memory_args()
4473  args.read(iprot)
4474  iprot.readMessageEnd()
4475  result = clear_cpu_memory_result()
4476  try:
4477  self._handler.clear_cpu_memory(args.session)
4478  msg_type = TMessageType.REPLY
4479  except TTransport.TTransportException:
4480  raise
4481  except TOmniSciException as e:
4482  msg_type = TMessageType.REPLY
4483  result.e = e
4484  except TApplicationException as ex:
4485  logging.exception('TApplication exception in handler')
4486  msg_type = TMessageType.EXCEPTION
4487  result = ex
4488  except Exception:
4489  logging.exception('Unexpected exception in handler')
4490  msg_type = TMessageType.EXCEPTION
4491  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4492  oprot.writeMessageBegin("clear_cpu_memory", msg_type, seqid)
4493  result.write(oprot)
4494  oprot.writeMessageEnd()
4495  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_clear_gpu_memory (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4496 of file OmniSci.py.

4497  def process_clear_gpu_memory(self, seqid, iprot, oprot):
4498  args = clear_gpu_memory_args()
4499  args.read(iprot)
4500  iprot.readMessageEnd()
4501  result = clear_gpu_memory_result()
4502  try:
4503  self._handler.clear_gpu_memory(args.session)
4504  msg_type = TMessageType.REPLY
4505  except TTransport.TTransportException:
4506  raise
4507  except TOmniSciException as e:
4508  msg_type = TMessageType.REPLY
4509  result.e = e
4510  except TApplicationException as ex:
4511  logging.exception('TApplication exception in handler')
4512  msg_type = TMessageType.EXCEPTION
4513  result = ex
4514  except Exception:
4515  logging.exception('Unexpected exception in handler')
4516  msg_type = TMessageType.EXCEPTION
4517  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4518  oprot.writeMessageBegin("clear_gpu_memory", msg_type, seqid)
4519  result.write(oprot)
4520  oprot.writeMessageEnd()
4521  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_clone_session (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4028 of file OmniSci.py.

4029  def process_clone_session(self, seqid, iprot, oprot):
4030  args = clone_session_args()
4031  args.read(iprot)
4032  iprot.readMessageEnd()
4033  result = clone_session_result()
4034  try:
4035  result.success = self._handler.clone_session(args.session)
4036  msg_type = TMessageType.REPLY
4037  except TTransport.TTransportException:
4038  raise
4039  except TOmniSciException as e:
4040  msg_type = TMessageType.REPLY
4041  result.e = e
4042  except TApplicationException as ex:
4043  logging.exception('TApplication exception in handler')
4044  msg_type = TMessageType.EXCEPTION
4045  result = ex
4046  except Exception:
4047  logging.exception('Unexpected exception in handler')
4048  msg_type = TMessageType.EXCEPTION
4049  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4050  oprot.writeMessageBegin("clone_session", msg_type, seqid)
4051  result.write(oprot)
4052  oprot.writeMessageEnd()
4053  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_connect (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 3924 of file OmniSci.py.

3925  def process_connect(self, seqid, iprot, oprot):
3926  args = connect_args()
3927  args.read(iprot)
3928  iprot.readMessageEnd()
3929  result = connect_result()
3930  try:
3931  result.success = self._handler.connect(args.user, args.passwd, args.dbname)
3932  msg_type = TMessageType.REPLY
3933  except TTransport.TTransportException:
3934  raise
3935  except TOmniSciException as e:
3936  msg_type = TMessageType.REPLY
3937  result.e = e
3938  except TApplicationException as ex:
3939  logging.exception('TApplication exception in handler')
3940  msg_type = TMessageType.EXCEPTION
3941  result = ex
3942  except Exception:
3943  logging.exception('Unexpected exception in handler')
3944  msg_type = TMessageType.EXCEPTION
3945  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
3946  oprot.writeMessageBegin("connect", msg_type, seqid)
3947  result.write(oprot)
3948  oprot.writeMessageEnd()
3949  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_create_dashboard (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4958 of file OmniSci.py.

4959  def process_create_dashboard(self, seqid, iprot, oprot):
4960  args = create_dashboard_args()
4961  args.read(iprot)
4962  iprot.readMessageEnd()
4963  result = create_dashboard_result()
4964  try:
4965  result.success = self._handler.create_dashboard(args.session, args.dashboard_name, args.dashboard_state, args.image_hash, args.dashboard_metadata)
4966  msg_type = TMessageType.REPLY
4967  except TTransport.TTransportException:
4968  raise
4969  except TOmniSciException as e:
4970  msg_type = TMessageType.REPLY
4971  result.e = e
4972  except TApplicationException as ex:
4973  logging.exception('TApplication exception in handler')
4974  msg_type = TMessageType.EXCEPTION
4975  result = ex
4976  except Exception:
4977  logging.exception('Unexpected exception in handler')
4978  msg_type = TMessageType.EXCEPTION
4979  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4980  oprot.writeMessageBegin("create_dashboard", msg_type, seqid)
4981  result.write(oprot)
4982  oprot.writeMessageEnd()
4983  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_create_link (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5218 of file OmniSci.py.

5219  def process_create_link(self, seqid, iprot, oprot):
5220  args = create_link_args()
5221  args.read(iprot)
5222  iprot.readMessageEnd()
5223  result = create_link_result()
5224  try:
5225  result.success = self._handler.create_link(args.session, args.view_state, args.view_metadata)
5226  msg_type = TMessageType.REPLY
5227  except TTransport.TTransportException:
5228  raise
5229  except TOmniSciException as e:
5230  msg_type = TMessageType.REPLY
5231  result.e = e
5232  except TApplicationException as ex:
5233  logging.exception('TApplication exception in handler')
5234  msg_type = TMessageType.EXCEPTION
5235  result = ex
5236  except Exception:
5237  logging.exception('Unexpected exception in handler')
5238  msg_type = TMessageType.EXCEPTION
5239  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5240  oprot.writeMessageBegin("create_link", msg_type, seqid)
5241  result.write(oprot)
5242  oprot.writeMessageEnd()
5243  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_create_table (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5374 of file OmniSci.py.

5375  def process_create_table(self, seqid, iprot, oprot):
5376  args = create_table_args()
5377  args.read(iprot)
5378  iprot.readMessageEnd()
5379  result = create_table_result()
5380  try:
5381  self._handler.create_table(args.session, args.table_name, args.row_desc, args.file_type, args.create_params)
5382  msg_type = TMessageType.REPLY
5383  except TTransport.TTransportException:
5384  raise
5385  except TOmniSciException as e:
5386  msg_type = TMessageType.REPLY
5387  result.e = e
5388  except TApplicationException as ex:
5389  logging.exception('TApplication exception in handler')
5390  msg_type = TMessageType.EXCEPTION
5391  result = ex
5392  except Exception:
5393  logging.exception('Unexpected exception in handler')
5394  msg_type = TMessageType.EXCEPTION
5395  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5396  oprot.writeMessageBegin("create_table", msg_type, seqid)
5397  result.write(oprot)
5398  oprot.writeMessageEnd()
5399  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_deallocate_df (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4724 of file OmniSci.py.

4725  def process_deallocate_df(self, seqid, iprot, oprot):
4726  args = deallocate_df_args()
4727  args.read(iprot)
4728  iprot.readMessageEnd()
4729  result = deallocate_df_result()
4730  try:
4731  self._handler.deallocate_df(args.session, args.df, args.device_type, args.device_id)
4732  msg_type = TMessageType.REPLY
4733  except TTransport.TTransportException:
4734  raise
4735  except TOmniSciException as e:
4736  msg_type = TMessageType.REPLY
4737  result.e = e
4738  except TApplicationException as ex:
4739  logging.exception('TApplication exception in handler')
4740  msg_type = TMessageType.EXCEPTION
4741  result = ex
4742  except Exception:
4743  logging.exception('Unexpected exception in handler')
4744  msg_type = TMessageType.EXCEPTION
4745  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4746  oprot.writeMessageBegin("deallocate_df", msg_type, seqid)
4747  result.write(oprot)
4748  oprot.writeMessageEnd()
4749  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_delete_dashboard (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5010 of file OmniSci.py.

5011  def process_delete_dashboard(self, seqid, iprot, oprot):
5012  args = delete_dashboard_args()
5013  args.read(iprot)
5014  iprot.readMessageEnd()
5015  result = delete_dashboard_result()
5016  try:
5017  self._handler.delete_dashboard(args.session, args.dashboard_id)
5018  msg_type = TMessageType.REPLY
5019  except TTransport.TTransportException:
5020  raise
5021  except TOmniSciException as e:
5022  msg_type = TMessageType.REPLY
5023  result.e = e
5024  except TApplicationException as ex:
5025  logging.exception('TApplication exception in handler')
5026  msg_type = TMessageType.EXCEPTION
5027  result = ex
5028  except Exception:
5029  logging.exception('Unexpected exception in handler')
5030  msg_type = TMessageType.EXCEPTION
5031  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5032  oprot.writeMessageBegin("delete_dashboard", msg_type, seqid)
5033  result.write(oprot)
5034  oprot.writeMessageEnd()
5035  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_delete_dashboards (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5062 of file OmniSci.py.

5063  def process_delete_dashboards(self, seqid, iprot, oprot):
5064  args = delete_dashboards_args()
5065  args.read(iprot)
5066  iprot.readMessageEnd()
5067  result = delete_dashboards_result()
5068  try:
5069  self._handler.delete_dashboards(args.session, args.dashboard_ids)
5070  msg_type = TMessageType.REPLY
5071  except TTransport.TTransportException:
5072  raise
5073  except TOmniSciException as e:
5074  msg_type = TMessageType.REPLY
5075  result.e = e
5076  except TApplicationException as ex:
5077  logging.exception('TApplication exception in handler')
5078  msg_type = TMessageType.EXCEPTION
5079  result = ex
5080  except Exception:
5081  logging.exception('Unexpected exception in handler')
5082  msg_type = TMessageType.EXCEPTION
5083  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5084  oprot.writeMessageBegin("delete_dashboards", msg_type, seqid)
5085  result.write(oprot)
5086  oprot.writeMessageEnd()
5087  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_detect_column_types (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5348 of file OmniSci.py.

5349  def process_detect_column_types(self, seqid, iprot, oprot):
5350  args = detect_column_types_args()
5351  args.read(iprot)
5352  iprot.readMessageEnd()
5353  result = detect_column_types_result()
5354  try:
5355  result.success = self._handler.detect_column_types(args.session, args.file_name, args.copy_params)
5356  msg_type = TMessageType.REPLY
5357  except TTransport.TTransportException:
5358  raise
5359  except TOmniSciException as e:
5360  msg_type = TMessageType.REPLY
5361  result.e = e
5362  except TApplicationException as ex:
5363  logging.exception('TApplication exception in handler')
5364  msg_type = TMessageType.EXCEPTION
5365  result = ex
5366  except Exception:
5367  logging.exception('Unexpected exception in handler')
5368  msg_type = TMessageType.EXCEPTION
5369  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5370  oprot.writeMessageBegin("detect_column_types", msg_type, seqid)
5371  result.write(oprot)
5372  oprot.writeMessageEnd()
5373  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_disconnect (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 3976 of file OmniSci.py.

3977  def process_disconnect(self, seqid, iprot, oprot):
3978  args = disconnect_args()
3979  args.read(iprot)
3980  iprot.readMessageEnd()
3981  result = disconnect_result()
3982  try:
3983  self._handler.disconnect(args.session)
3984  msg_type = TMessageType.REPLY
3985  except TTransport.TTransportException:
3986  raise
3987  except TOmniSciException as e:
3988  msg_type = TMessageType.REPLY
3989  result.e = e
3990  except TApplicationException as ex:
3991  logging.exception('TApplication exception in handler')
3992  msg_type = TMessageType.EXCEPTION
3993  result = ex
3994  except Exception:
3995  logging.exception('Unexpected exception in handler')
3996  msg_type = TMessageType.EXCEPTION
3997  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
3998  oprot.writeMessageBegin("disconnect", msg_type, seqid)
3999  result.write(oprot)
4000  oprot.writeMessageEnd()
4001  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_execute_next_render_step (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5712 of file OmniSci.py.

5713  def process_execute_next_render_step(self, seqid, iprot, oprot):
5715  args.read(iprot)
5716  iprot.readMessageEnd()
5718  try:
5719  result.success = self._handler.execute_next_render_step(args.pending_render, args.merged_data)
5720  msg_type = TMessageType.REPLY
5721  except TTransport.TTransportException:
5722  raise
5723  except TOmniSciException as e:
5724  msg_type = TMessageType.REPLY
5725  result.e = e
5726  except TApplicationException as ex:
5727  logging.exception('TApplication exception in handler')
5728  msg_type = TMessageType.EXCEPTION
5729  result = ex
5730  except Exception:
5731  logging.exception('Unexpected exception in handler')
5732  msg_type = TMessageType.EXCEPTION
5733  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5734  oprot.writeMessageBegin("execute_next_render_step", msg_type, seqid)
5735  result.write(oprot)
5736  oprot.writeMessageEnd()
5737  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_execute_query_step (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5634 of file OmniSci.py.

5635  def process_execute_query_step(self, seqid, iprot, oprot):
5636  args = execute_query_step_args()
5637  args.read(iprot)
5638  iprot.readMessageEnd()
5639  result = execute_query_step_result()
5640  try:
5641  result.success = self._handler.execute_query_step(args.pending_query)
5642  msg_type = TMessageType.REPLY
5643  except TTransport.TTransportException:
5644  raise
5645  except TOmniSciException as e:
5646  msg_type = TMessageType.REPLY
5647  result.e = e
5648  except TApplicationException as ex:
5649  logging.exception('TApplication exception in handler')
5650  msg_type = TMessageType.EXCEPTION
5651  result = ex
5652  except Exception:
5653  logging.exception('Unexpected exception in handler')
5654  msg_type = TMessageType.EXCEPTION
5655  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5656  oprot.writeMessageBegin("execute_query_step", msg_type, seqid)
5657  result.write(oprot)
5658  oprot.writeMessageEnd()
5659  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_all_files_in_archive (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5504 of file OmniSci.py.

5505  def process_get_all_files_in_archive(self, seqid, iprot, oprot):
5507  args.read(iprot)
5508  iprot.readMessageEnd()
5510  try:
5511  result.success = self._handler.get_all_files_in_archive(args.session, args.archive_path, args.copy_params)
5512  msg_type = TMessageType.REPLY
5513  except TTransport.TTransportException:
5514  raise
5515  except TOmniSciException as e:
5516  msg_type = TMessageType.REPLY
5517  result.e = e
5518  except TApplicationException as ex:
5519  logging.exception('TApplication exception in handler')
5520  msg_type = TMessageType.EXCEPTION
5521  result = ex
5522  except Exception:
5523  logging.exception('Unexpected exception in handler')
5524  msg_type = TMessageType.EXCEPTION
5525  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5526  oprot.writeMessageBegin("get_all_files_in_archive", msg_type, seqid)
5527  result.write(oprot)
5528  oprot.writeMessageEnd()
5529  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_all_roles_for_user (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5868 of file OmniSci.py.

5869  def process_get_all_roles_for_user(self, seqid, iprot, oprot):
5871  args.read(iprot)
5872  iprot.readMessageEnd()
5874  try:
5875  result.success = self._handler.get_all_roles_for_user(args.session, args.userName)
5876  msg_type = TMessageType.REPLY
5877  except TTransport.TTransportException:
5878  raise
5879  except TOmniSciException as e:
5880  msg_type = TMessageType.REPLY
5881  result.e = e
5882  except TApplicationException as ex:
5883  logging.exception('TApplication exception in handler')
5884  msg_type = TMessageType.EXCEPTION
5885  result = ex
5886  except Exception:
5887  logging.exception('Unexpected exception in handler')
5888  msg_type = TMessageType.EXCEPTION
5889  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5890  oprot.writeMessageBegin("get_all_roles_for_user", msg_type, seqid)
5891  result.write(oprot)
5892  oprot.writeMessageEnd()
5893  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_completion_hints (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4802 of file OmniSci.py.

4803  def process_get_completion_hints(self, seqid, iprot, oprot):
4804  args = get_completion_hints_args()
4805  args.read(iprot)
4806  iprot.readMessageEnd()
4807  result = get_completion_hints_result()
4808  try:
4809  result.success = self._handler.get_completion_hints(args.session, args.sql, args.cursor)
4810  msg_type = TMessageType.REPLY
4811  except TTransport.TTransportException:
4812  raise
4813  except TOmniSciException as e:
4814  msg_type = TMessageType.REPLY
4815  result.e = e
4816  except TApplicationException as ex:
4817  logging.exception('TApplication exception in handler')
4818  msg_type = TMessageType.EXCEPTION
4819  result = ex
4820  except Exception:
4821  logging.exception('Unexpected exception in handler')
4822  msg_type = TMessageType.EXCEPTION
4823  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4824  oprot.writeMessageBegin("get_completion_hints", msg_type, seqid)
4825  result.write(oprot)
4826  oprot.writeMessageEnd()
4827  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_dashboard (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4906 of file OmniSci.py.

4907  def process_get_dashboard(self, seqid, iprot, oprot):
4908  args = get_dashboard_args()
4909  args.read(iprot)
4910  iprot.readMessageEnd()
4911  result = get_dashboard_result()
4912  try:
4913  result.success = self._handler.get_dashboard(args.session, args.dashboard_id)
4914  msg_type = TMessageType.REPLY
4915  except TTransport.TTransportException:
4916  raise
4917  except TOmniSciException as e:
4918  msg_type = TMessageType.REPLY
4919  result.e = e
4920  except TApplicationException as ex:
4921  logging.exception('TApplication exception in handler')
4922  msg_type = TMessageType.EXCEPTION
4923  result = ex
4924  except Exception:
4925  logging.exception('Unexpected exception in handler')
4926  msg_type = TMessageType.EXCEPTION
4927  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4928  oprot.writeMessageBegin("get_dashboard", msg_type, seqid)
4929  result.write(oprot)
4930  oprot.writeMessageEnd()
4931  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_dashboard_grantees (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5166 of file OmniSci.py.

5167  def process_get_dashboard_grantees(self, seqid, iprot, oprot):
5169  args.read(iprot)
5170  iprot.readMessageEnd()
5172  try:
5173  result.success = self._handler.get_dashboard_grantees(args.session, args.dashboard_id)
5174  msg_type = TMessageType.REPLY
5175  except TTransport.TTransportException:
5176  raise
5177  except TOmniSciException as e:
5178  msg_type = TMessageType.REPLY
5179  result.e = e
5180  except TApplicationException as ex:
5181  logging.exception('TApplication exception in handler')
5182  msg_type = TMessageType.EXCEPTION
5183  result = ex
5184  except Exception:
5185  logging.exception('Unexpected exception in handler')
5186  msg_type = TMessageType.EXCEPTION
5187  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5188  oprot.writeMessageBegin("get_dashboard_grantees", msg_type, seqid)
5189  result.write(oprot)
5190  oprot.writeMessageEnd()
5191  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_dashboards (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4932 of file OmniSci.py.

4933  def process_get_dashboards(self, seqid, iprot, oprot):
4934  args = get_dashboards_args()
4935  args.read(iprot)
4936  iprot.readMessageEnd()
4937  result = get_dashboards_result()
4938  try:
4939  result.success = self._handler.get_dashboards(args.session)
4940  msg_type = TMessageType.REPLY
4941  except TTransport.TTransportException:
4942  raise
4943  except TOmniSciException as e:
4944  msg_type = TMessageType.REPLY
4945  result.e = e
4946  except TApplicationException as ex:
4947  logging.exception('TApplication exception in handler')
4948  msg_type = TMessageType.EXCEPTION
4949  result = ex
4950  except Exception:
4951  logging.exception('Unexpected exception in handler')
4952  msg_type = TMessageType.EXCEPTION
4953  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4954  oprot.writeMessageBegin("get_dashboards", msg_type, seqid)
4955  result.write(oprot)
4956  oprot.writeMessageEnd()
4957  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_databases (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4314 of file OmniSci.py.

4315  def process_get_databases(self, seqid, iprot, oprot):
4316  args = get_databases_args()
4317  args.read(iprot)
4318  iprot.readMessageEnd()
4319  result = get_databases_result()
4320  try:
4321  result.success = self._handler.get_databases(args.session)
4322  msg_type = TMessageType.REPLY
4323  except TTransport.TTransportException:
4324  raise
4325  except TOmniSciException as e:
4326  msg_type = TMessageType.REPLY
4327  result.e = e
4328  except TApplicationException as ex:
4329  logging.exception('TApplication exception in handler')
4330  msg_type = TMessageType.EXCEPTION
4331  result = ex
4332  except Exception:
4333  logging.exception('Unexpected exception in handler')
4334  msg_type = TMessageType.EXCEPTION
4335  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4336  oprot.writeMessageBegin("get_databases", msg_type, seqid)
4337  result.write(oprot)
4338  oprot.writeMessageEnd()
4339  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_db_object_privs (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5842 of file OmniSci.py.

5843  def process_get_db_object_privs(self, seqid, iprot, oprot):
5844  args = get_db_object_privs_args()
5845  args.read(iprot)
5846  iprot.readMessageEnd()
5847  result = get_db_object_privs_result()
5848  try:
5849  result.success = self._handler.get_db_object_privs(args.session, args.objectName, args.type)
5850  msg_type = TMessageType.REPLY
5851  except TTransport.TTransportException:
5852  raise
5853  except TOmniSciException as e:
5854  msg_type = TMessageType.REPLY
5855  result.e = e
5856  except TApplicationException as ex:
5857  logging.exception('TApplication exception in handler')
5858  msg_type = TMessageType.EXCEPTION
5859  result = ex
5860  except Exception:
5861  logging.exception('Unexpected exception in handler')
5862  msg_type = TMessageType.EXCEPTION
5863  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5864  oprot.writeMessageBegin("get_db_object_privs", msg_type, seqid)
5865  result.write(oprot)
5866  oprot.writeMessageEnd()
5867  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_db_objects_for_grantee (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5816 of file OmniSci.py.

5817  def process_get_db_objects_for_grantee(self, seqid, iprot, oprot):
5819  args.read(iprot)
5820  iprot.readMessageEnd()
5822  try:
5823  result.success = self._handler.get_db_objects_for_grantee(args.session, args.roleName)
5824  msg_type = TMessageType.REPLY
5825  except TTransport.TTransportException:
5826  raise
5827  except TOmniSciException as e:
5828  msg_type = TMessageType.REPLY
5829  result.e = e
5830  except TApplicationException as ex:
5831  logging.exception('TApplication exception in handler')
5832  msg_type = TMessageType.EXCEPTION
5833  result = ex
5834  except Exception:
5835  logging.exception('Unexpected exception in handler')
5836  msg_type = TMessageType.EXCEPTION
5837  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5838  oprot.writeMessageBegin("get_db_objects_for_grantee", msg_type, seqid)
5839  result.write(oprot)
5840  oprot.writeMessageEnd()
5841  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_device_parameters (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5998 of file OmniSci.py.

5999  def process_get_device_parameters(self, seqid, iprot, oprot):
6001  args.read(iprot)
6002  iprot.readMessageEnd()
6003  result = get_device_parameters_result()
6004  try:
6005  result.success = self._handler.get_device_parameters(args.session)
6006  msg_type = TMessageType.REPLY
6007  except TTransport.TTransportException:
6008  raise
6009  except TOmniSciException as e:
6010  msg_type = TMessageType.REPLY
6011  result.e = e
6012  except TApplicationException as ex:
6013  logging.exception('TApplication exception in handler')
6014  msg_type = TMessageType.EXCEPTION
6015  result = ex
6016  except Exception:
6017  logging.exception('Unexpected exception in handler')
6018  msg_type = TMessageType.EXCEPTION
6019  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6020  oprot.writeMessageBegin("get_device_parameters", msg_type, seqid)
6021  result.write(oprot)
6022  oprot.writeMessageEnd()
6023  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_first_geo_file_in_archive (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5478 of file OmniSci.py.

5479  def process_get_first_geo_file_in_archive(self, seqid, iprot, oprot):
5481  args.read(iprot)
5482  iprot.readMessageEnd()
5484  try:
5485  result.success = self._handler.get_first_geo_file_in_archive(args.session, args.archive_path, args.copy_params)
5486  msg_type = TMessageType.REPLY
5487  except TTransport.TTransportException:
5488  raise
5489  except TOmniSciException as e:
5490  msg_type = TMessageType.REPLY
5491  result.e = e
5492  except TApplicationException as ex:
5493  logging.exception('TApplication exception in handler')
5494  msg_type = TMessageType.EXCEPTION
5495  result = ex
5496  except Exception:
5497  logging.exception('Unexpected exception in handler')
5498  msg_type = TMessageType.EXCEPTION
5499  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5500  oprot.writeMessageBegin("get_first_geo_file_in_archive", msg_type, seqid)
5501  result.write(oprot)
5502  oprot.writeMessageEnd()
5503  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_hardware_info (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4106 of file OmniSci.py.

4107  def process_get_hardware_info(self, seqid, iprot, oprot):
4108  args = get_hardware_info_args()
4109  args.read(iprot)
4110  iprot.readMessageEnd()
4111  result = get_hardware_info_result()
4112  try:
4113  result.success = self._handler.get_hardware_info(args.session)
4114  msg_type = TMessageType.REPLY
4115  except TTransport.TTransportException:
4116  raise
4117  except TOmniSciException as e:
4118  msg_type = TMessageType.REPLY
4119  result.e = e
4120  except TApplicationException as ex:
4121  logging.exception('TApplication exception in handler')
4122  msg_type = TMessageType.EXCEPTION
4123  result = ex
4124  except Exception:
4125  logging.exception('Unexpected exception in handler')
4126  msg_type = TMessageType.EXCEPTION
4127  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4128  oprot.writeMessageBegin("get_hardware_info", msg_type, seqid)
4129  result.write(oprot)
4130  oprot.writeMessageEnd()
4131  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_heap_profile (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4418 of file OmniSci.py.

4419  def process_get_heap_profile(self, seqid, iprot, oprot):
4420  args = get_heap_profile_args()
4421  args.read(iprot)
4422  iprot.readMessageEnd()
4423  result = get_heap_profile_result()
4424  try:
4425  result.success = self._handler.get_heap_profile(args.session)
4426  msg_type = TMessageType.REPLY
4427  except TTransport.TTransportException:
4428  raise
4429  except TOmniSciException as e:
4430  msg_type = TMessageType.REPLY
4431  result.e = e
4432  except TApplicationException as ex:
4433  logging.exception('TApplication exception in handler')
4434  msg_type = TMessageType.EXCEPTION
4435  result = ex
4436  except Exception:
4437  logging.exception('Unexpected exception in handler')
4438  msg_type = TMessageType.EXCEPTION
4439  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4440  oprot.writeMessageBegin("get_heap_profile", msg_type, seqid)
4441  result.write(oprot)
4442  oprot.writeMessageEnd()
4443  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_internal_table_details (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4262 of file OmniSci.py.

4263  def process_get_internal_table_details(self, seqid, iprot, oprot):
4265  args.read(iprot)
4266  iprot.readMessageEnd()
4268  try:
4269  result.success = self._handler.get_internal_table_details(args.session, args.table_name)
4270  msg_type = TMessageType.REPLY
4271  except TTransport.TTransportException:
4272  raise
4273  except TOmniSciException as e:
4274  msg_type = TMessageType.REPLY
4275  result.e = e
4276  except TApplicationException as ex:
4277  logging.exception('TApplication exception in handler')
4278  msg_type = TMessageType.EXCEPTION
4279  result = ex
4280  except Exception:
4281  logging.exception('Unexpected exception in handler')
4282  msg_type = TMessageType.EXCEPTION
4283  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4284  oprot.writeMessageBegin("get_internal_table_details", msg_type, seqid)
4285  result.write(oprot)
4286  oprot.writeMessageEnd()
4287  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_layers_in_geo_file (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5530 of file OmniSci.py.

5531  def process_get_layers_in_geo_file(self, seqid, iprot, oprot):
5533  args.read(iprot)
5534  iprot.readMessageEnd()
5536  try:
5537  result.success = self._handler.get_layers_in_geo_file(args.session, args.file_name, args.copy_params)
5538  msg_type = TMessageType.REPLY
5539  except TTransport.TTransportException:
5540  raise
5541  except TOmniSciException as e:
5542  msg_type = TMessageType.REPLY
5543  result.e = e
5544  except TApplicationException as ex:
5545  logging.exception('TApplication exception in handler')
5546  msg_type = TMessageType.EXCEPTION
5547  result = ex
5548  except Exception:
5549  logging.exception('Unexpected exception in handler')
5550  msg_type = TMessageType.EXCEPTION
5551  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5552  oprot.writeMessageBegin("get_layers_in_geo_file", msg_type, seqid)
5553  result.write(oprot)
5554  oprot.writeMessageEnd()
5555  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_license_claims (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5972 of file OmniSci.py.

5973  def process_get_license_claims(self, seqid, iprot, oprot):
5974  args = get_license_claims_args()
5975  args.read(iprot)
5976  iprot.readMessageEnd()
5977  result = get_license_claims_result()
5978  try:
5979  result.success = self._handler.get_license_claims(args.session, args.nonce)
5980  msg_type = TMessageType.REPLY
5981  except TTransport.TTransportException:
5982  raise
5983  except TOmniSciException as e:
5984  msg_type = TMessageType.REPLY
5985  result.e = e
5986  except TApplicationException as ex:
5987  logging.exception('TApplication exception in handler')
5988  msg_type = TMessageType.EXCEPTION
5989  result = ex
5990  except Exception:
5991  logging.exception('Unexpected exception in handler')
5992  msg_type = TMessageType.EXCEPTION
5993  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5994  oprot.writeMessageBegin("get_license_claims", msg_type, seqid)
5995  result.write(oprot)
5996  oprot.writeMessageEnd()
5997  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_link_view (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5192 of file OmniSci.py.

5193  def process_get_link_view(self, seqid, iprot, oprot):
5194  args = get_link_view_args()
5195  args.read(iprot)
5196  iprot.readMessageEnd()
5197  result = get_link_view_result()
5198  try:
5199  result.success = self._handler.get_link_view(args.session, args.link)
5200  msg_type = TMessageType.REPLY
5201  except TTransport.TTransportException:
5202  raise
5203  except TOmniSciException as e:
5204  msg_type = TMessageType.REPLY
5205  result.e = e
5206  except TApplicationException as ex:
5207  logging.exception('TApplication exception in handler')
5208  msg_type = TMessageType.EXCEPTION
5209  result = ex
5210  except Exception:
5211  logging.exception('Unexpected exception in handler')
5212  msg_type = TMessageType.EXCEPTION
5213  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5214  oprot.writeMessageBegin("get_link_view", msg_type, seqid)
5215  result.write(oprot)
5216  oprot.writeMessageEnd()
5217  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_memory (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4444 of file OmniSci.py.

4445  def process_get_memory(self, seqid, iprot, oprot):
4446  args = get_memory_args()
4447  args.read(iprot)
4448  iprot.readMessageEnd()
4449  result = get_memory_result()
4450  try:
4451  result.success = self._handler.get_memory(args.session, args.memory_level)
4452  msg_type = TMessageType.REPLY
4453  except TTransport.TTransportException:
4454  raise
4455  except TOmniSciException as e:
4456  msg_type = TMessageType.REPLY
4457  result.e = e
4458  except TApplicationException as ex:
4459  logging.exception('TApplication exception in handler')
4460  msg_type = TMessageType.EXCEPTION
4461  result = ex
4462  except Exception:
4463  logging.exception('Unexpected exception in handler')
4464  msg_type = TMessageType.EXCEPTION
4465  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4466  oprot.writeMessageBegin("get_memory", msg_type, seqid)
4467  result.write(oprot)
4468  oprot.writeMessageEnd()
4469  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_physical_tables (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4158 of file OmniSci.py.

4159  def process_get_physical_tables(self, seqid, iprot, oprot):
4160  args = get_physical_tables_args()
4161  args.read(iprot)
4162  iprot.readMessageEnd()
4163  result = get_physical_tables_result()
4164  try:
4165  result.success = self._handler.get_physical_tables(args.session)
4166  msg_type = TMessageType.REPLY
4167  except TTransport.TTransportException:
4168  raise
4169  except TOmniSciException as e:
4170  msg_type = TMessageType.REPLY
4171  result.e = e
4172  except TApplicationException as ex:
4173  logging.exception('TApplication exception in handler')
4174  msg_type = TMessageType.EXCEPTION
4175  result = ex
4176  except Exception:
4177  logging.exception('Unexpected exception in handler')
4178  msg_type = TMessageType.EXCEPTION
4179  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4180  oprot.writeMessageBegin("get_physical_tables", msg_type, seqid)
4181  result.write(oprot)
4182  oprot.writeMessageEnd()
4183  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_result_row_for_pixel (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4880 of file OmniSci.py.

4881  def process_get_result_row_for_pixel(self, seqid, iprot, oprot):
4883  args.read(iprot)
4884  iprot.readMessageEnd()
4886  try:
4887  result.success = self._handler.get_result_row_for_pixel(args.session, args.widget_id, args.pixel, args.table_col_names, args.column_format, args.pixelRadius, args.nonce)
4888  msg_type = TMessageType.REPLY
4889  except TTransport.TTransportException:
4890  raise
4891  except TOmniSciException as e:
4892  msg_type = TMessageType.REPLY
4893  result.e = e
4894  except TApplicationException as ex:
4895  logging.exception('TApplication exception in handler')
4896  msg_type = TMessageType.EXCEPTION
4897  result = ex
4898  except Exception:
4899  logging.exception('Unexpected exception in handler')
4900  msg_type = TMessageType.EXCEPTION
4901  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4902  oprot.writeMessageBegin("get_result_row_for_pixel", msg_type, seqid)
4903  result.write(oprot)
4904  oprot.writeMessageEnd()
4905  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_roles (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5790 of file OmniSci.py.

5791  def process_get_roles(self, seqid, iprot, oprot):
5792  args = get_roles_args()
5793  args.read(iprot)
5794  iprot.readMessageEnd()
5795  result = get_roles_result()
5796  try:
5797  result.success = self._handler.get_roles(args.session)
5798  msg_type = TMessageType.REPLY
5799  except TTransport.TTransportException:
5800  raise
5801  except TOmniSciException as e:
5802  msg_type = TMessageType.REPLY
5803  result.e = e
5804  except TApplicationException as ex:
5805  logging.exception('TApplication exception in handler')
5806  msg_type = TMessageType.EXCEPTION
5807  result = ex
5808  except Exception:
5809  logging.exception('Unexpected exception in handler')
5810  msg_type = TMessageType.EXCEPTION
5811  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5812  oprot.writeMessageBegin("get_roles", msg_type, seqid)
5813  result.write(oprot)
5814  oprot.writeMessageEnd()
5815  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_server_status (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4054 of file OmniSci.py.

4055  def process_get_server_status(self, seqid, iprot, oprot):
4056  args = get_server_status_args()
4057  args.read(iprot)
4058  iprot.readMessageEnd()
4059  result = get_server_status_result()
4060  try:
4061  result.success = self._handler.get_server_status(args.session)
4062  msg_type = TMessageType.REPLY
4063  except TTransport.TTransportException:
4064  raise
4065  except TOmniSciException as e:
4066  msg_type = TMessageType.REPLY
4067  result.e = e
4068  except TApplicationException as ex:
4069  logging.exception('TApplication exception in handler')
4070  msg_type = TMessageType.EXCEPTION
4071  result = ex
4072  except Exception:
4073  logging.exception('Unexpected exception in handler')
4074  msg_type = TMessageType.EXCEPTION
4075  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4076  oprot.writeMessageBegin("get_server_status", msg_type, seqid)
4077  result.write(oprot)
4078  oprot.writeMessageEnd()
4079  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_session_info (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4620 of file OmniSci.py.

4621  def process_get_session_info(self, seqid, iprot, oprot):
4622  args = get_session_info_args()
4623  args.read(iprot)
4624  iprot.readMessageEnd()
4625  result = get_session_info_result()
4626  try:
4627  result.success = self._handler.get_session_info(args.session)
4628  msg_type = TMessageType.REPLY
4629  except TTransport.TTransportException:
4630  raise
4631  except TOmniSciException as e:
4632  msg_type = TMessageType.REPLY
4633  result.e = e
4634  except TApplicationException as ex:
4635  logging.exception('TApplication exception in handler')
4636  msg_type = TMessageType.EXCEPTION
4637  result = ex
4638  except Exception:
4639  logging.exception('Unexpected exception in handler')
4640  msg_type = TMessageType.EXCEPTION
4641  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4642  oprot.writeMessageBegin("get_session_info", msg_type, seqid)
4643  result.write(oprot)
4644  oprot.writeMessageEnd()
4645  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_status (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4080 of file OmniSci.py.

4081  def process_get_status(self, seqid, iprot, oprot):
4082  args = get_status_args()
4083  args.read(iprot)
4084  iprot.readMessageEnd()
4085  result = get_status_result()
4086  try:
4087  result.success = self._handler.get_status(args.session)
4088  msg_type = TMessageType.REPLY
4089  except TTransport.TTransportException:
4090  raise
4091  except TOmniSciException as e:
4092  msg_type = TMessageType.REPLY
4093  result.e = e
4094  except TApplicationException as ex:
4095  logging.exception('TApplication exception in handler')
4096  msg_type = TMessageType.EXCEPTION
4097  result = ex
4098  except Exception:
4099  logging.exception('Unexpected exception in handler')
4100  msg_type = TMessageType.EXCEPTION
4101  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4102  oprot.writeMessageBegin("get_status", msg_type, seqid)
4103  result.write(oprot)
4104  oprot.writeMessageEnd()
4105  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_table_details (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4236 of file OmniSci.py.

4237  def process_get_table_details(self, seqid, iprot, oprot):
4238  args = get_table_details_args()
4239  args.read(iprot)
4240  iprot.readMessageEnd()
4241  result = get_table_details_result()
4242  try:
4243  result.success = self._handler.get_table_details(args.session, args.table_name)
4244  msg_type = TMessageType.REPLY
4245  except TTransport.TTransportException:
4246  raise
4247  except TOmniSciException as e:
4248  msg_type = TMessageType.REPLY
4249  result.e = e
4250  except TApplicationException as ex:
4251  logging.exception('TApplication exception in handler')
4252  msg_type = TMessageType.EXCEPTION
4253  result = ex
4254  except Exception:
4255  logging.exception('Unexpected exception in handler')
4256  msg_type = TMessageType.EXCEPTION
4257  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4258  oprot.writeMessageBegin("get_table_details", msg_type, seqid)
4259  result.write(oprot)
4260  oprot.writeMessageEnd()
4261  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_table_epoch (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4574 of file OmniSci.py.

4575  def process_get_table_epoch(self, seqid, iprot, oprot):
4576  args = get_table_epoch_args()
4577  args.read(iprot)
4578  iprot.readMessageEnd()
4579  result = get_table_epoch_result()
4580  try:
4581  result.success = self._handler.get_table_epoch(args.session, args.db_id, args.table_id)
4582  msg_type = TMessageType.REPLY
4583  except TTransport.TTransportException:
4584  raise
4585  except TApplicationException as ex:
4586  logging.exception('TApplication exception in handler')
4587  msg_type = TMessageType.EXCEPTION
4588  result = ex
4589  except Exception:
4590  logging.exception('Unexpected exception in handler')
4591  msg_type = TMessageType.EXCEPTION
4592  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4593  oprot.writeMessageBegin("get_table_epoch", msg_type, seqid)
4594  result.write(oprot)
4595  oprot.writeMessageEnd()
4596  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_table_epoch_by_name (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4597 of file OmniSci.py.

4598  def process_get_table_epoch_by_name(self, seqid, iprot, oprot):
4600  args.read(iprot)
4601  iprot.readMessageEnd()
4603  try:
4604  result.success = self._handler.get_table_epoch_by_name(args.session, args.table_name)
4605  msg_type = TMessageType.REPLY
4606  except TTransport.TTransportException:
4607  raise
4608  except TApplicationException as ex:
4609  logging.exception('TApplication exception in handler')
4610  msg_type = TMessageType.EXCEPTION
4611  result = ex
4612  except Exception:
4613  logging.exception('Unexpected exception in handler')
4614  msg_type = TMessageType.EXCEPTION
4615  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4616  oprot.writeMessageBegin("get_table_epoch_by_name", msg_type, seqid)
4617  result.write(oprot)
4618  oprot.writeMessageEnd()
4619  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_tables (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4132 of file OmniSci.py.

4133  def process_get_tables(self, seqid, iprot, oprot):
4134  args = get_tables_args()
4135  args.read(iprot)
4136  iprot.readMessageEnd()
4137  result = get_tables_result()
4138  try:
4139  result.success = self._handler.get_tables(args.session)
4140  msg_type = TMessageType.REPLY
4141  except TTransport.TTransportException:
4142  raise
4143  except TOmniSciException as e:
4144  msg_type = TMessageType.REPLY
4145  result.e = e
4146  except TApplicationException as ex:
4147  logging.exception('TApplication exception in handler')
4148  msg_type = TMessageType.EXCEPTION
4149  result = ex
4150  except Exception:
4151  logging.exception('Unexpected exception in handler')
4152  msg_type = TMessageType.EXCEPTION
4153  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4154  oprot.writeMessageBegin("get_tables", msg_type, seqid)
4155  result.write(oprot)
4156  oprot.writeMessageEnd()
4157  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_tables_meta (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4210 of file OmniSci.py.

4211  def process_get_tables_meta(self, seqid, iprot, oprot):
4212  args = get_tables_meta_args()
4213  args.read(iprot)
4214  iprot.readMessageEnd()
4215  result = get_tables_meta_result()
4216  try:
4217  result.success = self._handler.get_tables_meta(args.session)
4218  msg_type = TMessageType.REPLY
4219  except TTransport.TTransportException:
4220  raise
4221  except TOmniSciException as e:
4222  msg_type = TMessageType.REPLY
4223  result.e = e
4224  except TApplicationException as ex:
4225  logging.exception('TApplication exception in handler')
4226  msg_type = TMessageType.EXCEPTION
4227  result = ex
4228  except Exception:
4229  logging.exception('Unexpected exception in handler')
4230  msg_type = TMessageType.EXCEPTION
4231  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4232  oprot.writeMessageBegin("get_tables_meta", msg_type, seqid)
4233  result.write(oprot)
4234  oprot.writeMessageEnd()
4235  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_users (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4288 of file OmniSci.py.

4289  def process_get_users(self, seqid, iprot, oprot):
4290  args = get_users_args()
4291  args.read(iprot)
4292  iprot.readMessageEnd()
4293  result = get_users_result()
4294  try:
4295  result.success = self._handler.get_users(args.session)
4296  msg_type = TMessageType.REPLY
4297  except TTransport.TTransportException:
4298  raise
4299  except TOmniSciException as e:
4300  msg_type = TMessageType.REPLY
4301  result.e = e
4302  except TApplicationException as ex:
4303  logging.exception('TApplication exception in handler')
4304  msg_type = TMessageType.EXCEPTION
4305  result = ex
4306  except Exception:
4307  logging.exception('Unexpected exception in handler')
4308  msg_type = TMessageType.EXCEPTION
4309  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4310  oprot.writeMessageBegin("get_users", msg_type, seqid)
4311  result.write(oprot)
4312  oprot.writeMessageEnd()
4313  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_version (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4340 of file OmniSci.py.

4341  def process_get_version(self, seqid, iprot, oprot):
4342  args = get_version_args()
4343  args.read(iprot)
4344  iprot.readMessageEnd()
4345  result = get_version_result()
4346  try:
4347  result.success = self._handler.get_version()
4348  msg_type = TMessageType.REPLY
4349  except TTransport.TTransportException:
4350  raise
4351  except TOmniSciException as e:
4352  msg_type = TMessageType.REPLY
4353  result.e = e
4354  except TApplicationException as ex:
4355  logging.exception('TApplication exception in handler')
4356  msg_type = TMessageType.EXCEPTION
4357  result = ex
4358  except Exception:
4359  logging.exception('Unexpected exception in handler')
4360  msg_type = TMessageType.EXCEPTION
4361  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4362  oprot.writeMessageBegin("get_version", msg_type, seqid)
4363  result.write(oprot)
4364  oprot.writeMessageEnd()
4365  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_views (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4184 of file OmniSci.py.

4185  def process_get_views(self, seqid, iprot, oprot):
4186  args = get_views_args()
4187  args.read(iprot)
4188  iprot.readMessageEnd()
4189  result = get_views_result()
4190  try:
4191  result.success = self._handler.get_views(args.session)
4192  msg_type = TMessageType.REPLY
4193  except TTransport.TTransportException:
4194  raise
4195  except TOmniSciException as e:
4196  msg_type = TMessageType.REPLY
4197  result.e = e
4198  except TApplicationException as ex:
4199  logging.exception('TApplication exception in handler')
4200  msg_type = TMessageType.EXCEPTION
4201  result = ex
4202  except Exception:
4203  logging.exception('Unexpected exception in handler')
4204  msg_type = TMessageType.EXCEPTION
4205  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4206  oprot.writeMessageBegin("get_views", msg_type, seqid)
4207  result.write(oprot)
4208  oprot.writeMessageEnd()
4209  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_has_object_privilege (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5920 of file OmniSci.py.

5921  def process_has_object_privilege(self, seqid, iprot, oprot):
5922  args = has_object_privilege_args()
5923  args.read(iprot)
5924  iprot.readMessageEnd()
5925  result = has_object_privilege_result()
5926  try:
5927  result.success = self._handler.has_object_privilege(args.session, args.granteeName, args.ObjectName, args.objectType, args.permissions)
5928  msg_type = TMessageType.REPLY
5929  except TTransport.TTransportException:
5930  raise
5931  except TOmniSciException as e:
5932  msg_type = TMessageType.REPLY
5933  result.e = e
5934  except TApplicationException as ex:
5935  logging.exception('TApplication exception in handler')
5936  msg_type = TMessageType.EXCEPTION
5937  result = ex
5938  except Exception:
5939  logging.exception('Unexpected exception in handler')
5940  msg_type = TMessageType.EXCEPTION
5941  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5942  oprot.writeMessageBegin("has_object_privilege", msg_type, seqid)
5943  result.write(oprot)
5944  oprot.writeMessageEnd()
5945  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_has_role (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5894 of file OmniSci.py.

5895  def process_has_role(self, seqid, iprot, oprot):
5896  args = has_role_args()
5897  args.read(iprot)
5898  iprot.readMessageEnd()
5899  result = has_role_result()
5900  try:
5901  result.success = self._handler.has_role(args.session, args.granteeName, args.roleName)
5902  msg_type = TMessageType.REPLY
5903  except TTransport.TTransportException:
5904  raise
5905  except TOmniSciException as e:
5906  msg_type = TMessageType.REPLY
5907  result.e = e
5908  except TApplicationException as ex:
5909  logging.exception('TApplication exception in handler')
5910  msg_type = TMessageType.EXCEPTION
5911  result = ex
5912  except Exception:
5913  logging.exception('Unexpected exception in handler')
5914  msg_type = TMessageType.EXCEPTION
5915  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5916  oprot.writeMessageBegin("has_role", msg_type, seqid)
5917  result.write(oprot)
5918  oprot.writeMessageEnd()
5919  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_import_geo_table (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5426 of file OmniSci.py.

5427  def process_import_geo_table(self, seqid, iprot, oprot):
5428  args = import_geo_table_args()
5429  args.read(iprot)
5430  iprot.readMessageEnd()
5431  result = import_geo_table_result()
5432  try:
5433  self._handler.import_geo_table(args.session, args.table_name, args.file_name, args.copy_params, args.row_desc, args.create_params)
5434  msg_type = TMessageType.REPLY
5435  except TTransport.TTransportException:
5436  raise
5437  except TOmniSciException as e:
5438  msg_type = TMessageType.REPLY
5439  result.e = e
5440  except TApplicationException as ex:
5441  logging.exception('TApplication exception in handler')
5442  msg_type = TMessageType.EXCEPTION
5443  result = ex
5444  except Exception:
5445  logging.exception('Unexpected exception in handler')
5446  msg_type = TMessageType.EXCEPTION
5447  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5448  oprot.writeMessageBegin("import_geo_table", msg_type, seqid)
5449  result.write(oprot)
5450  oprot.writeMessageEnd()
5451  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_import_table (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5400 of file OmniSci.py.

5401  def process_import_table(self, seqid, iprot, oprot):
5402  args = import_table_args()
5403  args.read(iprot)
5404  iprot.readMessageEnd()
5405  result = import_table_result()
5406  try:
5407  self._handler.import_table(args.session, args.table_name, args.file_name, args.copy_params)
5408  msg_type = TMessageType.REPLY
5409  except TTransport.TTransportException:
5410  raise
5411  except TOmniSciException as e:
5412  msg_type = TMessageType.REPLY
5413  result.e = e
5414  except TApplicationException as ex:
5415  logging.exception('TApplication exception in handler')
5416  msg_type = TMessageType.EXCEPTION
5417  result = ex
5418  except Exception:
5419  logging.exception('Unexpected exception in handler')
5420  msg_type = TMessageType.EXCEPTION
5421  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5422  oprot.writeMessageBegin("import_table", msg_type, seqid)
5423  result.write(oprot)
5424  oprot.writeMessageEnd()
5425  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_import_table_status (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5452 of file OmniSci.py.

5453  def process_import_table_status(self, seqid, iprot, oprot):
5454  args = import_table_status_args()
5455  args.read(iprot)
5456  iprot.readMessageEnd()
5457  result = import_table_status_result()
5458  try:
5459  result.success = self._handler.import_table_status(args.session, args.import_id)
5460  msg_type = TMessageType.REPLY
5461  except TTransport.TTransportException:
5462  raise
5463  except TOmniSciException as e:
5464  msg_type = TMessageType.REPLY
5465  result.e = e
5466  except TApplicationException as ex:
5467  logging.exception('TApplication exception in handler')
5468  msg_type = TMessageType.EXCEPTION
5469  result = ex
5470  except Exception:
5471  logging.exception('Unexpected exception in handler')
5472  msg_type = TMessageType.EXCEPTION
5473  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5474  oprot.writeMessageBegin("import_table_status", msg_type, seqid)
5475  result.write(oprot)
5476  oprot.writeMessageEnd()
5477  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_insert_data (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5738 of file OmniSci.py.

5739  def process_insert_data(self, seqid, iprot, oprot):
5740  args = insert_data_args()
5741  args.read(iprot)
5742  iprot.readMessageEnd()
5743  result = insert_data_result()
5744  try:
5745  self._handler.insert_data(args.session, args.insert_data)
5746  msg_type = TMessageType.REPLY
5747  except TTransport.TTransportException:
5748  raise
5749  except TOmniSciException as e:
5750  msg_type = TMessageType.REPLY
5751  result.e = e
5752  except TApplicationException as ex:
5753  logging.exception('TApplication exception in handler')
5754  msg_type = TMessageType.EXCEPTION
5755  result = ex
5756  except Exception:
5757  logging.exception('Unexpected exception in handler')
5758  msg_type = TMessageType.EXCEPTION
5759  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5760  oprot.writeMessageBegin("insert_data", msg_type, seqid)
5761  result.write(oprot)
5762  oprot.writeMessageEnd()
5763  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_interrupt (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4750 of file OmniSci.py.

4751  def process_interrupt(self, seqid, iprot, oprot):
4752  args = interrupt_args()
4753  args.read(iprot)
4754  iprot.readMessageEnd()
4755  result = interrupt_result()
4756  try:
4757  self._handler.interrupt(args.query_session, args.interrupt_session)
4758  msg_type = TMessageType.REPLY
4759  except TTransport.TTransportException:
4760  raise
4761  except TOmniSciException as e:
4762  msg_type = TMessageType.REPLY
4763  result.e = e
4764  except TApplicationException as ex:
4765  logging.exception('TApplication exception in handler')
4766  msg_type = TMessageType.EXCEPTION
4767  result = ex
4768  except Exception:
4769  logging.exception('Unexpected exception in handler')
4770  msg_type = TMessageType.EXCEPTION
4771  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4772  oprot.writeMessageBegin("interrupt", msg_type, seqid)
4773  result.write(oprot)
4774  oprot.writeMessageEnd()
4775  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_krb5_connect (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 3950 of file OmniSci.py.

3951  def process_krb5_connect(self, seqid, iprot, oprot):
3952  args = krb5_connect_args()
3953  args.read(iprot)
3954  iprot.readMessageEnd()
3955  result = krb5_connect_result()
3956  try:
3957  result.success = self._handler.krb5_connect(args.inputToken, args.dbname)
3958  msg_type = TMessageType.REPLY
3959  except TTransport.TTransportException:
3960  raise
3961  except TOmniSciException as e:
3962  msg_type = TMessageType.REPLY
3963  result.e = e
3964  except TApplicationException as ex:
3965  logging.exception('TApplication exception in handler')
3966  msg_type = TMessageType.EXCEPTION
3967  result = ex
3968  except Exception:
3969  logging.exception('Unexpected exception in handler')
3970  msg_type = TMessageType.EXCEPTION
3971  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
3972  oprot.writeMessageBegin("krb5_connect", msg_type, seqid)
3973  result.write(oprot)
3974  oprot.writeMessageEnd()
3975  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_load_table (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5322 of file OmniSci.py.

5323  def process_load_table(self, seqid, iprot, oprot):
5324  args = load_table_args()
5325  args.read(iprot)
5326  iprot.readMessageEnd()
5327  result = load_table_result()
5328  try:
5329  self._handler.load_table(args.session, args.table_name, args.rows)
5330  msg_type = TMessageType.REPLY
5331  except TTransport.TTransportException:
5332  raise
5333  except TOmniSciException as e:
5334  msg_type = TMessageType.REPLY
5335  result.e = e
5336  except TApplicationException as ex:
5337  logging.exception('TApplication exception in handler')
5338  msg_type = TMessageType.EXCEPTION
5339  result = ex
5340  except Exception:
5341  logging.exception('Unexpected exception in handler')
5342  msg_type = TMessageType.EXCEPTION
5343  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5344  oprot.writeMessageBegin("load_table", msg_type, seqid)
5345  result.write(oprot)
5346  oprot.writeMessageEnd()
5347  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_load_table_binary (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5244 of file OmniSci.py.

5245  def process_load_table_binary(self, seqid, iprot, oprot):
5246  args = load_table_binary_args()
5247  args.read(iprot)
5248  iprot.readMessageEnd()
5249  result = load_table_binary_result()
5250  try:
5251  self._handler.load_table_binary(args.session, args.table_name, args.rows)
5252  msg_type = TMessageType.REPLY
5253  except TTransport.TTransportException:
5254  raise
5255  except TOmniSciException as e:
5256  msg_type = TMessageType.REPLY
5257  result.e = e
5258  except TApplicationException as ex:
5259  logging.exception('TApplication exception in handler')
5260  msg_type = TMessageType.EXCEPTION
5261  result = ex
5262  except Exception:
5263  logging.exception('Unexpected exception in handler')
5264  msg_type = TMessageType.EXCEPTION
5265  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5266  oprot.writeMessageBegin("load_table_binary", msg_type, seqid)
5267  result.write(oprot)
5268  oprot.writeMessageEnd()
5269  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_load_table_binary_arrow (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5296 of file OmniSci.py.

5297  def process_load_table_binary_arrow(self, seqid, iprot, oprot):
5299  args.read(iprot)
5300  iprot.readMessageEnd()
5302  try:
5303  self._handler.load_table_binary_arrow(args.session, args.table_name, args.arrow_stream)
5304  msg_type = TMessageType.REPLY
5305  except TTransport.TTransportException:
5306  raise
5307  except TOmniSciException as e:
5308  msg_type = TMessageType.REPLY
5309  result.e = e
5310  except TApplicationException as ex:
5311  logging.exception('TApplication exception in handler')
5312  msg_type = TMessageType.EXCEPTION
5313  result = ex
5314  except Exception:
5315  logging.exception('Unexpected exception in handler')
5316  msg_type = TMessageType.EXCEPTION
5317  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5318  oprot.writeMessageBegin("load_table_binary_arrow", msg_type, seqid)
5319  result.write(oprot)
5320  oprot.writeMessageEnd()
5321  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_load_table_binary_columnar (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5270 of file OmniSci.py.

5271  def process_load_table_binary_columnar(self, seqid, iprot, oprot):
5273  args.read(iprot)
5274  iprot.readMessageEnd()
5276  try:
5277  self._handler.load_table_binary_columnar(args.session, args.table_name, args.cols)
5278  msg_type = TMessageType.REPLY
5279  except TTransport.TTransportException:
5280  raise
5281  except TOmniSciException as e:
5282  msg_type = TMessageType.REPLY
5283  result.e = e
5284  except TApplicationException as ex:
5285  logging.exception('TApplication exception in handler')
5286  msg_type = TMessageType.EXCEPTION
5287  result = ex
5288  except Exception:
5289  logging.exception('Unexpected exception in handler')
5290  msg_type = TMessageType.EXCEPTION
5291  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5292  oprot.writeMessageBegin("load_table_binary_columnar", msg_type, seqid)
5293  result.write(oprot)
5294  oprot.writeMessageEnd()
5295  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_query_get_outer_fragment_count (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5556 of file OmniSci.py.

5557  def process_query_get_outer_fragment_count(self, seqid, iprot, oprot):
5559  args.read(iprot)
5560  iprot.readMessageEnd()
5562  try:
5563  result.success = self._handler.query_get_outer_fragment_count(args.session, args.query)
5564  msg_type = TMessageType.REPLY
5565  except TTransport.TTransportException:
5566  raise
5567  except TOmniSciException as e:
5568  msg_type = TMessageType.REPLY
5569  result.e = e
5570  except TApplicationException as ex:
5571  logging.exception('TApplication exception in handler')
5572  msg_type = TMessageType.EXCEPTION
5573  result = ex
5574  except Exception:
5575  logging.exception('Unexpected exception in handler')
5576  msg_type = TMessageType.EXCEPTION
5577  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5578  oprot.writeMessageBegin("query_get_outer_fragment_count", msg_type, seqid)
5579  result.write(oprot)
5580  oprot.writeMessageEnd()
5581  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_register_runtime_extension_functions (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6024 of file OmniSci.py.

6025  def process_register_runtime_extension_functions(self, seqid, iprot, oprot):
6027  args.read(iprot)
6028  iprot.readMessageEnd()
6030  try:
6031  self._handler.register_runtime_extension_functions(args.session, args.udfs, args.udtfs, args.device_ir_map)
6032  msg_type = TMessageType.REPLY
6033  except TTransport.TTransportException:
6034  raise
6035  except TOmniSciException as e:
6036  msg_type = TMessageType.REPLY
6037  result.e = e
6038  except TApplicationException as ex:
6039  logging.exception('TApplication exception in handler')
6040  msg_type = TMessageType.EXCEPTION
6041  result = ex
6042  except Exception:
6043  logging.exception('Unexpected exception in handler')
6044  msg_type = TMessageType.EXCEPTION
6045  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6046  oprot.writeMessageBegin("register_runtime_extension_functions", msg_type, seqid)
6047  result.write(oprot)
6048  oprot.writeMessageEnd()
6049  oprot.trans.flush()
6050 
6051 # HELPER FUNCTIONS AND STRUCTURES
6052 
def omnisci.thrift.OmniSci.Processor.process_render_vega (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4854 of file OmniSci.py.

4855  def process_render_vega(self, seqid, iprot, oprot):
4856  args = render_vega_args()
4857  args.read(iprot)
4858  iprot.readMessageEnd()
4859  result = render_vega_result()
4860  try:
4861  result.success = self._handler.render_vega(args.session, args.widget_id, args.vega_json, args.compression_level, args.nonce)
4862  msg_type = TMessageType.REPLY
4863  except TTransport.TTransportException:
4864  raise
4865  except TOmniSciException as e:
4866  msg_type = TMessageType.REPLY
4867  result.e = e
4868  except TApplicationException as ex:
4869  logging.exception('TApplication exception in handler')
4870  msg_type = TMessageType.EXCEPTION
4871  result = ex
4872  except Exception:
4873  logging.exception('Unexpected exception in handler')
4874  msg_type = TMessageType.EXCEPTION
4875  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4876  oprot.writeMessageBegin("render_vega", msg_type, seqid)
4877  result.write(oprot)
4878  oprot.writeMessageEnd()
4879  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_replace_dashboard (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4984 of file OmniSci.py.

4985  def process_replace_dashboard(self, seqid, iprot, oprot):
4986  args = replace_dashboard_args()
4987  args.read(iprot)
4988  iprot.readMessageEnd()
4989  result = replace_dashboard_result()
4990  try:
4991  self._handler.replace_dashboard(args.session, args.dashboard_id, args.dashboard_name, args.dashboard_owner, args.dashboard_state, args.image_hash, args.dashboard_metadata)
4992  msg_type = TMessageType.REPLY
4993  except TTransport.TTransportException:
4994  raise
4995  except TOmniSciException as e:
4996  msg_type = TMessageType.REPLY
4997  result.e = e
4998  except TApplicationException as ex:
4999  logging.exception('TApplication exception in handler')
5000  msg_type = TMessageType.EXCEPTION
5001  result = ex
5002  except Exception:
5003  logging.exception('Unexpected exception in handler')
5004  msg_type = TMessageType.EXCEPTION
5005  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5006  oprot.writeMessageBegin("replace_dashboard", msg_type, seqid)
5007  result.write(oprot)
5008  oprot.writeMessageEnd()
5009  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_set_execution_mode (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4828 of file OmniSci.py.

4829  def process_set_execution_mode(self, seqid, iprot, oprot):
4830  args = set_execution_mode_args()
4831  args.read(iprot)
4832  iprot.readMessageEnd()
4833  result = set_execution_mode_result()
4834  try:
4835  self._handler.set_execution_mode(args.session, args.mode)
4836  msg_type = TMessageType.REPLY
4837  except TTransport.TTransportException:
4838  raise
4839  except TOmniSciException as e:
4840  msg_type = TMessageType.REPLY
4841  result.e = e
4842  except TApplicationException as ex:
4843  logging.exception('TApplication exception in handler')
4844  msg_type = TMessageType.EXCEPTION
4845  result = ex
4846  except Exception:
4847  logging.exception('Unexpected exception in handler')
4848  msg_type = TMessageType.EXCEPTION
4849  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4850  oprot.writeMessageBegin("set_execution_mode", msg_type, seqid)
4851  result.write(oprot)
4852  oprot.writeMessageEnd()
4853  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_set_license_key (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5946 of file OmniSci.py.

5947  def process_set_license_key(self, seqid, iprot, oprot):
5948  args = set_license_key_args()
5949  args.read(iprot)
5950  iprot.readMessageEnd()
5951  result = set_license_key_result()
5952  try:
5953  result.success = self._handler.set_license_key(args.session, args.key, args.nonce)
5954  msg_type = TMessageType.REPLY
5955  except TTransport.TTransportException:
5956  raise
5957  except TOmniSciException as e:
5958  msg_type = TMessageType.REPLY
5959  result.e = e
5960  except TApplicationException as ex:
5961  logging.exception('TApplication exception in handler')
5962  msg_type = TMessageType.EXCEPTION
5963  result = ex
5964  except Exception:
5965  logging.exception('Unexpected exception in handler')
5966  msg_type = TMessageType.EXCEPTION
5967  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5968  oprot.writeMessageBegin("set_license_key", msg_type, seqid)
5969  result.write(oprot)
5970  oprot.writeMessageEnd()
5971  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_set_table_epoch (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4522 of file OmniSci.py.

4523  def process_set_table_epoch(self, seqid, iprot, oprot):
4524  args = set_table_epoch_args()
4525  args.read(iprot)
4526  iprot.readMessageEnd()
4527  result = set_table_epoch_result()
4528  try:
4529  self._handler.set_table_epoch(args.session, args.db_id, args.table_id, args.new_epoch)
4530  msg_type = TMessageType.REPLY
4531  except TTransport.TTransportException:
4532  raise
4533  except TOmniSciException as e:
4534  msg_type = TMessageType.REPLY
4535  result.e = e
4536  except TApplicationException as ex:
4537  logging.exception('TApplication exception in handler')
4538  msg_type = TMessageType.EXCEPTION
4539  result = ex
4540  except Exception:
4541  logging.exception('Unexpected exception in handler')
4542  msg_type = TMessageType.EXCEPTION
4543  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4544  oprot.writeMessageBegin("set_table_epoch", msg_type, seqid)
4545  result.write(oprot)
4546  oprot.writeMessageEnd()
4547  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_set_table_epoch_by_name (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4548 of file OmniSci.py.

4549  def process_set_table_epoch_by_name(self, seqid, iprot, oprot):
4551  args.read(iprot)
4552  iprot.readMessageEnd()
4554  try:
4555  self._handler.set_table_epoch_by_name(args.session, args.table_name, args.new_epoch)
4556  msg_type = TMessageType.REPLY
4557  except TTransport.TTransportException:
4558  raise
4559  except TOmniSciException as e:
4560  msg_type = TMessageType.REPLY
4561  result.e = e
4562  except TApplicationException as ex:
4563  logging.exception('TApplication exception in handler')
4564  msg_type = TMessageType.EXCEPTION
4565  result = ex
4566  except Exception:
4567  logging.exception('Unexpected exception in handler')
4568  msg_type = TMessageType.EXCEPTION
4569  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4570  oprot.writeMessageBegin("set_table_epoch_by_name", msg_type, seqid)
4571  result.write(oprot)
4572  oprot.writeMessageEnd()
4573  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_share_dashboard (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5088 of file OmniSci.py.

5089  def process_share_dashboard(self, seqid, iprot, oprot):
5090  args = share_dashboard_args()
5091  args.read(iprot)
5092  iprot.readMessageEnd()
5093  result = share_dashboard_result()
5094  try:
5095  self._handler.share_dashboard(args.session, args.dashboard_id, args.groups, args.objects, args.permissions, args.grant_role)
5096  msg_type = TMessageType.REPLY
5097  except TTransport.TTransportException:
5098  raise
5099  except TOmniSciException as e:
5100  msg_type = TMessageType.REPLY
5101  result.e = e
5102  except TApplicationException as ex:
5103  logging.exception('TApplication exception in handler')
5104  msg_type = TMessageType.EXCEPTION
5105  result = ex
5106  except Exception:
5107  logging.exception('Unexpected exception in handler')
5108  msg_type = TMessageType.EXCEPTION
5109  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5110  oprot.writeMessageBegin("share_dashboard", msg_type, seqid)
5111  result.write(oprot)
5112  oprot.writeMessageEnd()
5113  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_share_dashboards (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5036 of file OmniSci.py.

5037  def process_share_dashboards(self, seqid, iprot, oprot):
5038  args = share_dashboards_args()
5039  args.read(iprot)
5040  iprot.readMessageEnd()
5041  result = share_dashboards_result()
5042  try:
5043  self._handler.share_dashboards(args.session, args.dashboard_ids, args.groups, args.permissions)
5044  msg_type = TMessageType.REPLY
5045  except TTransport.TTransportException:
5046  raise
5047  except TOmniSciException as e:
5048  msg_type = TMessageType.REPLY
5049  result.e = e
5050  except TApplicationException as ex:
5051  logging.exception('TApplication exception in handler')
5052  msg_type = TMessageType.EXCEPTION
5053  result = ex
5054  except Exception:
5055  logging.exception('Unexpected exception in handler')
5056  msg_type = TMessageType.EXCEPTION
5057  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5058  oprot.writeMessageBegin("share_dashboards", msg_type, seqid)
5059  result.write(oprot)
5060  oprot.writeMessageEnd()
5061  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_sql_execute (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4646 of file OmniSci.py.

4647  def process_sql_execute(self, seqid, iprot, oprot):
4648  args = sql_execute_args()
4649  args.read(iprot)
4650  iprot.readMessageEnd()
4651  result = sql_execute_result()
4652  try:
4653  result.success = self._handler.sql_execute(args.session, args.query, args.column_format, args.nonce, args.first_n, args.at_most_n)
4654  msg_type = TMessageType.REPLY
4655  except TTransport.TTransportException:
4656  raise
4657  except TOmniSciException as e:
4658  msg_type = TMessageType.REPLY
4659  result.e = e
4660  except TApplicationException as ex:
4661  logging.exception('TApplication exception in handler')
4662  msg_type = TMessageType.EXCEPTION
4663  result = ex
4664  except Exception:
4665  logging.exception('Unexpected exception in handler')
4666  msg_type = TMessageType.EXCEPTION
4667  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4668  oprot.writeMessageBegin("sql_execute", msg_type, seqid)
4669  result.write(oprot)
4670  oprot.writeMessageEnd()
4671  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_sql_execute_df (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4672 of file OmniSci.py.

4673  def process_sql_execute_df(self, seqid, iprot, oprot):
4674  args = sql_execute_df_args()
4675  args.read(iprot)
4676  iprot.readMessageEnd()
4677  result = sql_execute_df_result()
4678  try:
4679  result.success = self._handler.sql_execute_df(args.session, args.query, args.device_type, args.device_id, args.first_n, args.transport_method)
4680  msg_type = TMessageType.REPLY
4681  except TTransport.TTransportException:
4682  raise
4683  except TOmniSciException as e:
4684  msg_type = TMessageType.REPLY
4685  result.e = e
4686  except TApplicationException as ex:
4687  logging.exception('TApplication exception in handler')
4688  msg_type = TMessageType.EXCEPTION
4689  result = ex
4690  except Exception:
4691  logging.exception('Unexpected exception in handler')
4692  msg_type = TMessageType.EXCEPTION
4693  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4694  oprot.writeMessageBegin("sql_execute_df", msg_type, seqid)
4695  result.write(oprot)
4696  oprot.writeMessageEnd()
4697  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_sql_execute_gdf (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4698 of file OmniSci.py.

4699  def process_sql_execute_gdf(self, seqid, iprot, oprot):
4700  args = sql_execute_gdf_args()
4701  args.read(iprot)
4702  iprot.readMessageEnd()
4703  result = sql_execute_gdf_result()
4704  try:
4705  result.success = self._handler.sql_execute_gdf(args.session, args.query, args.device_id, args.first_n)
4706  msg_type = TMessageType.REPLY
4707  except TTransport.TTransportException:
4708  raise
4709  except TOmniSciException as e:
4710  msg_type = TMessageType.REPLY
4711  result.e = e
4712  except TApplicationException as ex:
4713  logging.exception('TApplication exception in handler')
4714  msg_type = TMessageType.EXCEPTION
4715  result = ex
4716  except Exception:
4717  logging.exception('Unexpected exception in handler')
4718  msg_type = TMessageType.EXCEPTION
4719  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4720  oprot.writeMessageBegin("sql_execute_gdf", msg_type, seqid)
4721  result.write(oprot)
4722  oprot.writeMessageEnd()
4723  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_sql_validate (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4776 of file OmniSci.py.

4777  def process_sql_validate(self, seqid, iprot, oprot):
4778  args = sql_validate_args()
4779  args.read(iprot)
4780  iprot.readMessageEnd()
4781  result = sql_validate_result()
4782  try:
4783  result.success = self._handler.sql_validate(args.session, args.query)
4784  msg_type = TMessageType.REPLY
4785  except TTransport.TTransportException:
4786  raise
4787  except TOmniSciException as e:
4788  msg_type = TMessageType.REPLY
4789  result.e = e
4790  except TApplicationException as ex:
4791  logging.exception('TApplication exception in handler')
4792  msg_type = TMessageType.EXCEPTION
4793  result = ex
4794  except Exception:
4795  logging.exception('Unexpected exception in handler')
4796  msg_type = TMessageType.EXCEPTION
4797  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4798  oprot.writeMessageBegin("sql_validate", msg_type, seqid)
4799  result.write(oprot)
4800  oprot.writeMessageEnd()
4801  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_start_heap_profile (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4366 of file OmniSci.py.

4367  def process_start_heap_profile(self, seqid, iprot, oprot):
4368  args = start_heap_profile_args()
4369  args.read(iprot)
4370  iprot.readMessageEnd()
4371  result = start_heap_profile_result()
4372  try:
4373  self._handler.start_heap_profile(args.session)
4374  msg_type = TMessageType.REPLY
4375  except TTransport.TTransportException:
4376  raise
4377  except TOmniSciException as e:
4378  msg_type = TMessageType.REPLY
4379  result.e = e
4380  except TApplicationException as ex:
4381  logging.exception('TApplication exception in handler')
4382  msg_type = TMessageType.EXCEPTION
4383  result = ex
4384  except Exception:
4385  logging.exception('Unexpected exception in handler')
4386  msg_type = TMessageType.EXCEPTION
4387  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4388  oprot.writeMessageBegin("start_heap_profile", msg_type, seqid)
4389  result.write(oprot)
4390  oprot.writeMessageEnd()
4391  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_start_query (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5608 of file OmniSci.py.

5609  def process_start_query(self, seqid, iprot, oprot):
5610  args = start_query_args()
5611  args.read(iprot)
5612  iprot.readMessageEnd()
5613  result = start_query_result()
5614  try:
5615  result.success = self._handler.start_query(args.leaf_session, args.parent_session, args.query_ra, args.just_explain, args.outer_fragment_indices)
5616  msg_type = TMessageType.REPLY
5617  except TTransport.TTransportException:
5618  raise
5619  except TOmniSciException as e:
5620  msg_type = TMessageType.REPLY
5621  result.e = e
5622  except TApplicationException as ex:
5623  logging.exception('TApplication exception in handler')
5624  msg_type = TMessageType.EXCEPTION
5625  result = ex
5626  except Exception:
5627  logging.exception('Unexpected exception in handler')
5628  msg_type = TMessageType.EXCEPTION
5629  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5630  oprot.writeMessageBegin("start_query", msg_type, seqid)
5631  result.write(oprot)
5632  oprot.writeMessageEnd()
5633  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_start_render_query (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5686 of file OmniSci.py.

5687  def process_start_render_query(self, seqid, iprot, oprot):
5688  args = start_render_query_args()
5689  args.read(iprot)
5690  iprot.readMessageEnd()
5691  result = start_render_query_result()
5692  try:
5693  result.success = self._handler.start_render_query(args.session, args.widget_id, args.node_idx, args.vega_json)
5694  msg_type = TMessageType.REPLY
5695  except TTransport.TTransportException:
5696  raise
5697  except TOmniSciException as e:
5698  msg_type = TMessageType.REPLY
5699  result.e = e
5700  except TApplicationException as ex:
5701  logging.exception('TApplication exception in handler')
5702  msg_type = TMessageType.EXCEPTION
5703  result = ex
5704  except Exception:
5705  logging.exception('Unexpected exception in handler')
5706  msg_type = TMessageType.EXCEPTION
5707  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5708  oprot.writeMessageBegin("start_render_query", msg_type, seqid)
5709  result.write(oprot)
5710  oprot.writeMessageEnd()
5711  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_stop_heap_profile (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4392 of file OmniSci.py.

4393  def process_stop_heap_profile(self, seqid, iprot, oprot):
4394  args = stop_heap_profile_args()
4395  args.read(iprot)
4396  iprot.readMessageEnd()
4397  result = stop_heap_profile_result()
4398  try:
4399  self._handler.stop_heap_profile(args.session)
4400  msg_type = TMessageType.REPLY
4401  except TTransport.TTransportException:
4402  raise
4403  except TOmniSciException as e:
4404  msg_type = TMessageType.REPLY
4405  result.e = e
4406  except TApplicationException as ex:
4407  logging.exception('TApplication exception in handler')
4408  msg_type = TMessageType.EXCEPTION
4409  result = ex
4410  except Exception:
4411  logging.exception('Unexpected exception in handler')
4412  msg_type = TMessageType.EXCEPTION
4413  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4414  oprot.writeMessageBegin("stop_heap_profile", msg_type, seqid)
4415  result.write(oprot)
4416  oprot.writeMessageEnd()
4417  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_switch_database (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4002 of file OmniSci.py.

4003  def process_switch_database(self, seqid, iprot, oprot):
4004  args = switch_database_args()
4005  args.read(iprot)
4006  iprot.readMessageEnd()
4007  result = switch_database_result()
4008  try:
4009  self._handler.switch_database(args.session, args.dbname)
4010  msg_type = TMessageType.REPLY
4011  except TTransport.TTransportException:
4012  raise
4013  except TOmniSciException as e:
4014  msg_type = TMessageType.REPLY
4015  result.e = e
4016  except TApplicationException as ex:
4017  logging.exception('TApplication exception in handler')
4018  msg_type = TMessageType.EXCEPTION
4019  result = ex
4020  except Exception:
4021  logging.exception('Unexpected exception in handler')
4022  msg_type = TMessageType.EXCEPTION
4023  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4024  oprot.writeMessageBegin("switch_database", msg_type, seqid)
4025  result.write(oprot)
4026  oprot.writeMessageEnd()
4027  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_unshare_dashboard (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5114 of file OmniSci.py.

5115  def process_unshare_dashboard(self, seqid, iprot, oprot):
5116  args = unshare_dashboard_args()
5117  args.read(iprot)
5118  iprot.readMessageEnd()
5119  result = unshare_dashboard_result()
5120  try:
5121  self._handler.unshare_dashboard(args.session, args.dashboard_id, args.groups, args.objects, args.permissions)
5122  msg_type = TMessageType.REPLY
5123  except TTransport.TTransportException:
5124  raise
5125  except TOmniSciException as e:
5126  msg_type = TMessageType.REPLY
5127  result.e = e
5128  except TApplicationException as ex:
5129  logging.exception('TApplication exception in handler')
5130  msg_type = TMessageType.EXCEPTION
5131  result = ex
5132  except Exception:
5133  logging.exception('Unexpected exception in handler')
5134  msg_type = TMessageType.EXCEPTION
5135  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5136  oprot.writeMessageBegin("unshare_dashboard", msg_type, seqid)
5137  result.write(oprot)
5138  oprot.writeMessageEnd()
5139  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_unshare_dashboards (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5140 of file OmniSci.py.

5141  def process_unshare_dashboards(self, seqid, iprot, oprot):
5142  args = unshare_dashboards_args()
5143  args.read(iprot)
5144  iprot.readMessageEnd()
5145  result = unshare_dashboards_result()
5146  try:
5147  self._handler.unshare_dashboards(args.session, args.dashboard_ids, args.groups, args.permissions)
5148  msg_type = TMessageType.REPLY
5149  except TTransport.TTransportException:
5150  raise
5151  except TOmniSciException as e:
5152  msg_type = TMessageType.REPLY
5153  result.e = e
5154  except TApplicationException as ex:
5155  logging.exception('TApplication exception in handler')
5156  msg_type = TMessageType.EXCEPTION
5157  result = ex
5158  except Exception:
5159  logging.exception('Unexpected exception in handler')
5160  msg_type = TMessageType.EXCEPTION
5161  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5162  oprot.writeMessageBegin("unshare_dashboards", msg_type, seqid)
5163  result.write(oprot)
5164  oprot.writeMessageEnd()
5165  oprot.trans.flush()

Member Data Documentation

omnisci.thrift.OmniSci.Processor._handler
private

Definition at line 3818 of file OmniSci.py.

omnisci.thrift.OmniSci.Processor._on_message_begin
private

Definition at line 3902 of file OmniSci.py.

Referenced by omnisci.thrift.OmniSci.Processor.on_message_begin(), and omnisci.thrift.OmniSci.Processor.process().

omnisci.thrift.OmniSci.Processor._processMap
private

Definition at line 3819 of file OmniSci.py.

Referenced by omnisci.thrift.OmniSci.Processor.process().


The documentation for this class was generated from the following file: