OmniSciDB  fe05a0c208
 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_table_epochs
 
def process_set_table_epochs
 
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_table_epochs
 
def set_table_epochs
 
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 3924 of file OmniSci.py.

Constructor & Destructor Documentation

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

Definition at line 3925 of file OmniSci.py.

3926  def __init__(self, handler):
3927  self._handler = handler
3928  self._processMap = {}
3929  self._processMap["connect"] = Processor.process_connect
3930  self._processMap["krb5_connect"] = Processor.process_krb5_connect
3931  self._processMap["disconnect"] = Processor.process_disconnect
3932  self._processMap["switch_database"] = Processor.process_switch_database
3933  self._processMap["clone_session"] = Processor.process_clone_session
3934  self._processMap["get_server_status"] = Processor.process_get_server_status
3935  self._processMap["get_status"] = Processor.process_get_status
3936  self._processMap["get_hardware_info"] = Processor.process_get_hardware_info
3937  self._processMap["get_tables"] = Processor.process_get_tables
3938  self._processMap["get_physical_tables"] = Processor.process_get_physical_tables
3939  self._processMap["get_views"] = Processor.process_get_views
3940  self._processMap["get_tables_meta"] = Processor.process_get_tables_meta
3941  self._processMap["get_table_details"] = Processor.process_get_table_details
3942  self._processMap["get_internal_table_details"] = Processor.process_get_internal_table_details
3943  self._processMap["get_users"] = Processor.process_get_users
3944  self._processMap["get_databases"] = Processor.process_get_databases
3945  self._processMap["get_version"] = Processor.process_get_version
3946  self._processMap["start_heap_profile"] = Processor.process_start_heap_profile
3947  self._processMap["stop_heap_profile"] = Processor.process_stop_heap_profile
3948  self._processMap["get_heap_profile"] = Processor.process_get_heap_profile
3949  self._processMap["get_memory"] = Processor.process_get_memory
3950  self._processMap["clear_cpu_memory"] = Processor.process_clear_cpu_memory
3951  self._processMap["clear_gpu_memory"] = Processor.process_clear_gpu_memory
3952  self._processMap["set_table_epoch"] = Processor.process_set_table_epoch
3953  self._processMap["set_table_epoch_by_name"] = Processor.process_set_table_epoch_by_name
3954  self._processMap["get_table_epoch"] = Processor.process_get_table_epoch
3955  self._processMap["get_table_epoch_by_name"] = Processor.process_get_table_epoch_by_name
3956  self._processMap["get_table_epochs"] = Processor.process_get_table_epochs
3957  self._processMap["set_table_epochs"] = Processor.process_set_table_epochs
3958  self._processMap["get_session_info"] = Processor.process_get_session_info
3959  self._processMap["sql_execute"] = Processor.process_sql_execute
3960  self._processMap["sql_execute_df"] = Processor.process_sql_execute_df
3961  self._processMap["sql_execute_gdf"] = Processor.process_sql_execute_gdf
3962  self._processMap["deallocate_df"] = Processor.process_deallocate_df
3963  self._processMap["interrupt"] = Processor.process_interrupt
3964  self._processMap["sql_validate"] = Processor.process_sql_validate
3965  self._processMap["get_completion_hints"] = Processor.process_get_completion_hints
3966  self._processMap["set_execution_mode"] = Processor.process_set_execution_mode
3967  self._processMap["render_vega"] = Processor.process_render_vega
3968  self._processMap["get_result_row_for_pixel"] = Processor.process_get_result_row_for_pixel
3969  self._processMap["get_dashboard"] = Processor.process_get_dashboard
3970  self._processMap["get_dashboards"] = Processor.process_get_dashboards
3971  self._processMap["create_dashboard"] = Processor.process_create_dashboard
3972  self._processMap["replace_dashboard"] = Processor.process_replace_dashboard
3973  self._processMap["delete_dashboard"] = Processor.process_delete_dashboard
3974  self._processMap["share_dashboards"] = Processor.process_share_dashboards
3975  self._processMap["delete_dashboards"] = Processor.process_delete_dashboards
3976  self._processMap["share_dashboard"] = Processor.process_share_dashboard
3977  self._processMap["unshare_dashboard"] = Processor.process_unshare_dashboard
3978  self._processMap["unshare_dashboards"] = Processor.process_unshare_dashboards
3979  self._processMap["get_dashboard_grantees"] = Processor.process_get_dashboard_grantees
3980  self._processMap["get_link_view"] = Processor.process_get_link_view
3981  self._processMap["create_link"] = Processor.process_create_link
3982  self._processMap["load_table_binary"] = Processor.process_load_table_binary
3983  self._processMap["load_table_binary_columnar"] = Processor.process_load_table_binary_columnar
3984  self._processMap["load_table_binary_arrow"] = Processor.process_load_table_binary_arrow
3985  self._processMap["load_table"] = Processor.process_load_table
3986  self._processMap["detect_column_types"] = Processor.process_detect_column_types
3987  self._processMap["create_table"] = Processor.process_create_table
3988  self._processMap["import_table"] = Processor.process_import_table
3989  self._processMap["import_geo_table"] = Processor.process_import_geo_table
3990  self._processMap["import_table_status"] = Processor.process_import_table_status
3991  self._processMap["get_first_geo_file_in_archive"] = Processor.process_get_first_geo_file_in_archive
3992  self._processMap["get_all_files_in_archive"] = Processor.process_get_all_files_in_archive
3993  self._processMap["get_layers_in_geo_file"] = Processor.process_get_layers_in_geo_file
3994  self._processMap["query_get_outer_fragment_count"] = Processor.process_query_get_outer_fragment_count
3995  self._processMap["check_table_consistency"] = Processor.process_check_table_consistency
3996  self._processMap["start_query"] = Processor.process_start_query
3997  self._processMap["execute_query_step"] = Processor.process_execute_query_step
3998  self._processMap["broadcast_serialized_rows"] = Processor.process_broadcast_serialized_rows
3999  self._processMap["start_render_query"] = Processor.process_start_render_query
4000  self._processMap["execute_next_render_step"] = Processor.process_execute_next_render_step
4001  self._processMap["insert_data"] = Processor.process_insert_data
4002  self._processMap["checkpoint"] = Processor.process_checkpoint
4003  self._processMap["get_roles"] = Processor.process_get_roles
4004  self._processMap["get_db_objects_for_grantee"] = Processor.process_get_db_objects_for_grantee
4005  self._processMap["get_db_object_privs"] = Processor.process_get_db_object_privs
4006  self._processMap["get_all_roles_for_user"] = Processor.process_get_all_roles_for_user
4007  self._processMap["has_role"] = Processor.process_has_role
4008  self._processMap["has_object_privilege"] = Processor.process_has_object_privilege
4009  self._processMap["set_license_key"] = Processor.process_set_license_key
4010  self._processMap["get_license_claims"] = Processor.process_get_license_claims
4011  self._processMap["get_device_parameters"] = Processor.process_get_device_parameters
4012  self._processMap["register_runtime_extension_functions"] = Processor.process_register_runtime_extension_functions
4013  self._on_message_begin = None

Member Function Documentation

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

Definition at line 4014 of file OmniSci.py.

References omnisci.thrift.OmniSci.Processor._on_message_begin.

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

Definition at line 4017 of file OmniSci.py.

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

4018  def process(self, iprot, oprot):
4019  (name, type, seqid) = iprot.readMessageBegin()
4020  if self._on_message_begin:
4021  self._on_message_begin(name, type, seqid)
4022  if name not in self._processMap:
4023  iprot.skip(TType.STRUCT)
4024  iprot.readMessageEnd()
4025  x = TApplicationException(TApplicationException.UNKNOWN_METHOD, 'Unknown function %s' % (name))
4026  oprot.writeMessageBegin(name, TMessageType.EXCEPTION, seqid)
4027  x.write(oprot)
4028  oprot.writeMessageEnd()
4029  oprot.trans.flush()
4030  return
4031  else:
4032  self._processMap[name](self, seqid, iprot, oprot)
4033  return True
def omnisci.thrift.OmniSci.Processor.process_broadcast_serialized_rows (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5816 of file OmniSci.py.

5817  def process_broadcast_serialized_rows(self, seqid, iprot, oprot):
5819  args.read(iprot)
5820  iprot.readMessageEnd()
5822  try:
5823  self._handler.broadcast_serialized_rows(args.serialized_rows, args.row_desc, args.query_id, args.subquery_id, args.is_final_subquery_result)
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("broadcast_serialized_rows", msg_type, seqid)
5839  result.write(oprot)
5840  oprot.writeMessageEnd()
5841  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_check_table_consistency (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5738 of file OmniSci.py.

5739  def process_check_table_consistency(self, seqid, iprot, oprot):
5741  args.read(iprot)
5742  iprot.readMessageEnd()
5744  try:
5745  result.success = self._handler.check_table_consistency(args.session, args.table_id)
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("check_table_consistency", msg_type, seqid)
5761  result.write(oprot)
5762  oprot.writeMessageEnd()
5763  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_checkpoint (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5920 of file OmniSci.py.

5921  def process_checkpoint(self, seqid, iprot, oprot):
5922  args = checkpoint_args()
5923  args.read(iprot)
5924  iprot.readMessageEnd()
5925  result = checkpoint_result()
5926  try:
5927  self._handler.checkpoint(args.session, args.table_id)
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("checkpoint", msg_type, seqid)
5943  result.write(oprot)
5944  oprot.writeMessageEnd()
5945  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_clear_cpu_memory (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4580 of file OmniSci.py.

4581  def process_clear_cpu_memory(self, seqid, iprot, oprot):
4582  args = clear_cpu_memory_args()
4583  args.read(iprot)
4584  iprot.readMessageEnd()
4585  result = clear_cpu_memory_result()
4586  try:
4587  self._handler.clear_cpu_memory(args.session)
4588  msg_type = TMessageType.REPLY
4589  except TTransport.TTransportException:
4590  raise
4591  except TOmniSciException as e:
4592  msg_type = TMessageType.REPLY
4593  result.e = e
4594  except TApplicationException as ex:
4595  logging.exception('TApplication exception in handler')
4596  msg_type = TMessageType.EXCEPTION
4597  result = ex
4598  except Exception:
4599  logging.exception('Unexpected exception in handler')
4600  msg_type = TMessageType.EXCEPTION
4601  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4602  oprot.writeMessageBegin("clear_cpu_memory", msg_type, seqid)
4603  result.write(oprot)
4604  oprot.writeMessageEnd()
4605  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_clear_gpu_memory (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4606 of file OmniSci.py.

4607  def process_clear_gpu_memory(self, seqid, iprot, oprot):
4608  args = clear_gpu_memory_args()
4609  args.read(iprot)
4610  iprot.readMessageEnd()
4611  result = clear_gpu_memory_result()
4612  try:
4613  self._handler.clear_gpu_memory(args.session)
4614  msg_type = TMessageType.REPLY
4615  except TTransport.TTransportException:
4616  raise
4617  except TOmniSciException as e:
4618  msg_type = TMessageType.REPLY
4619  result.e = e
4620  except TApplicationException as ex:
4621  logging.exception('TApplication exception in handler')
4622  msg_type = TMessageType.EXCEPTION
4623  result = ex
4624  except Exception:
4625  logging.exception('Unexpected exception in handler')
4626  msg_type = TMessageType.EXCEPTION
4627  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4628  oprot.writeMessageBegin("clear_gpu_memory", msg_type, seqid)
4629  result.write(oprot)
4630  oprot.writeMessageEnd()
4631  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_clone_session (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4138 of file OmniSci.py.

4139  def process_clone_session(self, seqid, iprot, oprot):
4140  args = clone_session_args()
4141  args.read(iprot)
4142  iprot.readMessageEnd()
4143  result = clone_session_result()
4144  try:
4145  result.success = self._handler.clone_session(args.session)
4146  msg_type = TMessageType.REPLY
4147  except TTransport.TTransportException:
4148  raise
4149  except TOmniSciException as e:
4150  msg_type = TMessageType.REPLY
4151  result.e = e
4152  except TApplicationException as ex:
4153  logging.exception('TApplication exception in handler')
4154  msg_type = TMessageType.EXCEPTION
4155  result = ex
4156  except Exception:
4157  logging.exception('Unexpected exception in handler')
4158  msg_type = TMessageType.EXCEPTION
4159  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4160  oprot.writeMessageBegin("clone_session", msg_type, seqid)
4161  result.write(oprot)
4162  oprot.writeMessageEnd()
4163  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_connect (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4034 of file OmniSci.py.

4035  def process_connect(self, seqid, iprot, oprot):
4036  args = connect_args()
4037  args.read(iprot)
4038  iprot.readMessageEnd()
4039  result = connect_result()
4040  try:
4041  result.success = self._handler.connect(args.user, args.passwd, args.dbname)
4042  msg_type = TMessageType.REPLY
4043  except TTransport.TTransportException:
4044  raise
4045  except TOmniSciException as e:
4046  msg_type = TMessageType.REPLY
4047  result.e = e
4048  except TApplicationException as ex:
4049  logging.exception('TApplication exception in handler')
4050  msg_type = TMessageType.EXCEPTION
4051  result = ex
4052  except Exception:
4053  logging.exception('Unexpected exception in handler')
4054  msg_type = TMessageType.EXCEPTION
4055  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4056  oprot.writeMessageBegin("connect", msg_type, seqid)
4057  result.write(oprot)
4058  oprot.writeMessageEnd()
4059  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_create_dashboard (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5114 of file OmniSci.py.

5115  def process_create_dashboard(self, seqid, iprot, oprot):
5116  args = create_dashboard_args()
5117  args.read(iprot)
5118  iprot.readMessageEnd()
5119  result = create_dashboard_result()
5120  try:
5121  result.success = self._handler.create_dashboard(args.session, args.dashboard_name, args.dashboard_state, args.image_hash, args.dashboard_metadata)
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("create_dashboard", msg_type, seqid)
5137  result.write(oprot)
5138  oprot.writeMessageEnd()
5139  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_create_link (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5374 of file OmniSci.py.

5375  def process_create_link(self, seqid, iprot, oprot):
5376  args = create_link_args()
5377  args.read(iprot)
5378  iprot.readMessageEnd()
5379  result = create_link_result()
5380  try:
5381  result.success = self._handler.create_link(args.session, args.view_state, args.view_metadata)
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_link", msg_type, seqid)
5397  result.write(oprot)
5398  oprot.writeMessageEnd()
5399  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_create_table (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5530 of file OmniSci.py.

5531  def process_create_table(self, seqid, iprot, oprot):
5532  args = create_table_args()
5533  args.read(iprot)
5534  iprot.readMessageEnd()
5535  result = create_table_result()
5536  try:
5537  self._handler.create_table(args.session, args.table_name, args.row_desc, args.file_type, args.create_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("create_table", msg_type, seqid)
5553  result.write(oprot)
5554  oprot.writeMessageEnd()
5555  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_deallocate_df (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4880 of file OmniSci.py.

4881  def process_deallocate_df(self, seqid, iprot, oprot):
4882  args = deallocate_df_args()
4883  args.read(iprot)
4884  iprot.readMessageEnd()
4885  result = deallocate_df_result()
4886  try:
4887  self._handler.deallocate_df(args.session, args.df, args.device_type, args.device_id)
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("deallocate_df", msg_type, seqid)
4903  result.write(oprot)
4904  oprot.writeMessageEnd()
4905  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_delete_dashboard (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5166 of file OmniSci.py.

5167  def process_delete_dashboard(self, seqid, iprot, oprot):
5168  args = delete_dashboard_args()
5169  args.read(iprot)
5170  iprot.readMessageEnd()
5171  result = delete_dashboard_result()
5172  try:
5173  self._handler.delete_dashboard(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("delete_dashboard", msg_type, seqid)
5189  result.write(oprot)
5190  oprot.writeMessageEnd()
5191  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_delete_dashboards (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5218 of file OmniSci.py.

5219  def process_delete_dashboards(self, seqid, iprot, oprot):
5220  args = delete_dashboards_args()
5221  args.read(iprot)
5222  iprot.readMessageEnd()
5223  result = delete_dashboards_result()
5224  try:
5225  self._handler.delete_dashboards(args.session, args.dashboard_ids)
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("delete_dashboards", msg_type, seqid)
5241  result.write(oprot)
5242  oprot.writeMessageEnd()
5243  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_detect_column_types (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5504 of file OmniSci.py.

5505  def process_detect_column_types(self, seqid, iprot, oprot):
5506  args = detect_column_types_args()
5507  args.read(iprot)
5508  iprot.readMessageEnd()
5509  result = detect_column_types_result()
5510  try:
5511  result.success = self._handler.detect_column_types(args.session, args.file_name, 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("detect_column_types", msg_type, seqid)
5527  result.write(oprot)
5528  oprot.writeMessageEnd()
5529  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_disconnect (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4086 of file OmniSci.py.

4087  def process_disconnect(self, seqid, iprot, oprot):
4088  args = disconnect_args()
4089  args.read(iprot)
4090  iprot.readMessageEnd()
4091  result = disconnect_result()
4092  try:
4093  self._handler.disconnect(args.session)
4094  msg_type = TMessageType.REPLY
4095  except TTransport.TTransportException:
4096  raise
4097  except TOmniSciException as e:
4098  msg_type = TMessageType.REPLY
4099  result.e = e
4100  except TApplicationException as ex:
4101  logging.exception('TApplication exception in handler')
4102  msg_type = TMessageType.EXCEPTION
4103  result = ex
4104  except Exception:
4105  logging.exception('Unexpected exception in handler')
4106  msg_type = TMessageType.EXCEPTION
4107  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4108  oprot.writeMessageBegin("disconnect", msg_type, seqid)
4109  result.write(oprot)
4110  oprot.writeMessageEnd()
4111  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_execute_next_render_step (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5868 of file OmniSci.py.

5869  def process_execute_next_render_step(self, seqid, iprot, oprot):
5871  args.read(iprot)
5872  iprot.readMessageEnd()
5874  try:
5875  result.success = self._handler.execute_next_render_step(args.pending_render, args.merged_data)
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("execute_next_render_step", msg_type, seqid)
5891  result.write(oprot)
5892  oprot.writeMessageEnd()
5893  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_execute_query_step (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5790 of file OmniSci.py.

5791  def process_execute_query_step(self, seqid, iprot, oprot):
5792  args = execute_query_step_args()
5793  args.read(iprot)
5794  iprot.readMessageEnd()
5795  result = execute_query_step_result()
5796  try:
5797  result.success = self._handler.execute_query_step(args.pending_query, args.subquery_id)
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("execute_query_step", msg_type, seqid)
5813  result.write(oprot)
5814  oprot.writeMessageEnd()
5815  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_all_files_in_archive (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5660 of file OmniSci.py.

5661  def process_get_all_files_in_archive(self, seqid, iprot, oprot):
5663  args.read(iprot)
5664  iprot.readMessageEnd()
5666  try:
5667  result.success = self._handler.get_all_files_in_archive(args.session, args.archive_path, args.copy_params)
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("get_all_files_in_archive", msg_type, seqid)
5683  result.write(oprot)
5684  oprot.writeMessageEnd()
5685  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_all_roles_for_user (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6024 of file OmniSci.py.

6025  def process_get_all_roles_for_user(self, seqid, iprot, oprot):
6027  args.read(iprot)
6028  iprot.readMessageEnd()
6030  try:
6031  result.success = self._handler.get_all_roles_for_user(args.session, args.userName)
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("get_all_roles_for_user", msg_type, seqid)
6047  result.write(oprot)
6048  oprot.writeMessageEnd()
6049  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_completion_hints (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4958 of file OmniSci.py.

4959  def process_get_completion_hints(self, seqid, iprot, oprot):
4960  args = get_completion_hints_args()
4961  args.read(iprot)
4962  iprot.readMessageEnd()
4963  result = get_completion_hints_result()
4964  try:
4965  result.success = self._handler.get_completion_hints(args.session, args.sql, args.cursor)
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("get_completion_hints", msg_type, seqid)
4981  result.write(oprot)
4982  oprot.writeMessageEnd()
4983  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_dashboard (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5062 of file OmniSci.py.

5063  def process_get_dashboard(self, seqid, iprot, oprot):
5064  args = get_dashboard_args()
5065  args.read(iprot)
5066  iprot.readMessageEnd()
5067  result = get_dashboard_result()
5068  try:
5069  result.success = self._handler.get_dashboard(args.session, args.dashboard_id)
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("get_dashboard", msg_type, seqid)
5085  result.write(oprot)
5086  oprot.writeMessageEnd()
5087  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_dashboard_grantees (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5322 of file OmniSci.py.

5323  def process_get_dashboard_grantees(self, seqid, iprot, oprot):
5325  args.read(iprot)
5326  iprot.readMessageEnd()
5328  try:
5329  result.success = self._handler.get_dashboard_grantees(args.session, args.dashboard_id)
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("get_dashboard_grantees", msg_type, seqid)
5345  result.write(oprot)
5346  oprot.writeMessageEnd()
5347  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_dashboards (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5088 of file OmniSci.py.

5089  def process_get_dashboards(self, seqid, iprot, oprot):
5090  args = get_dashboards_args()
5091  args.read(iprot)
5092  iprot.readMessageEnd()
5093  result = get_dashboards_result()
5094  try:
5095  result.success = self._handler.get_dashboards(args.session)
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("get_dashboards", msg_type, seqid)
5111  result.write(oprot)
5112  oprot.writeMessageEnd()
5113  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_databases (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4424 of file OmniSci.py.

4425  def process_get_databases(self, seqid, iprot, oprot):
4426  args = get_databases_args()
4427  args.read(iprot)
4428  iprot.readMessageEnd()
4429  result = get_databases_result()
4430  try:
4431  result.success = self._handler.get_databases(args.session)
4432  msg_type = TMessageType.REPLY
4433  except TTransport.TTransportException:
4434  raise
4435  except TOmniSciException as e:
4436  msg_type = TMessageType.REPLY
4437  result.e = e
4438  except TApplicationException as ex:
4439  logging.exception('TApplication exception in handler')
4440  msg_type = TMessageType.EXCEPTION
4441  result = ex
4442  except Exception:
4443  logging.exception('Unexpected exception in handler')
4444  msg_type = TMessageType.EXCEPTION
4445  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4446  oprot.writeMessageBegin("get_databases", msg_type, seqid)
4447  result.write(oprot)
4448  oprot.writeMessageEnd()
4449  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_db_object_privs (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5998 of file OmniSci.py.

5999  def process_get_db_object_privs(self, seqid, iprot, oprot):
6000  args = get_db_object_privs_args()
6001  args.read(iprot)
6002  iprot.readMessageEnd()
6003  result = get_db_object_privs_result()
6004  try:
6005  result.success = self._handler.get_db_object_privs(args.session, args.objectName, args.type)
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_db_object_privs", msg_type, seqid)
6021  result.write(oprot)
6022  oprot.writeMessageEnd()
6023  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_db_objects_for_grantee (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5972 of file OmniSci.py.

5973  def process_get_db_objects_for_grantee(self, seqid, iprot, oprot):
5975  args.read(iprot)
5976  iprot.readMessageEnd()
5978  try:
5979  result.success = self._handler.get_db_objects_for_grantee(args.session, args.roleName)
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_db_objects_for_grantee", msg_type, seqid)
5995  result.write(oprot)
5996  oprot.writeMessageEnd()
5997  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_device_parameters (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6154 of file OmniSci.py.

6155  def process_get_device_parameters(self, seqid, iprot, oprot):
6157  args.read(iprot)
6158  iprot.readMessageEnd()
6159  result = get_device_parameters_result()
6160  try:
6161  result.success = self._handler.get_device_parameters(args.session)
6162  msg_type = TMessageType.REPLY
6163  except TTransport.TTransportException:
6164  raise
6165  except TOmniSciException as e:
6166  msg_type = TMessageType.REPLY
6167  result.e = e
6168  except TApplicationException as ex:
6169  logging.exception('TApplication exception in handler')
6170  msg_type = TMessageType.EXCEPTION
6171  result = ex
6172  except Exception:
6173  logging.exception('Unexpected exception in handler')
6174  msg_type = TMessageType.EXCEPTION
6175  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6176  oprot.writeMessageBegin("get_device_parameters", msg_type, seqid)
6177  result.write(oprot)
6178  oprot.writeMessageEnd()
6179  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_first_geo_file_in_archive (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5634 of file OmniSci.py.

5635  def process_get_first_geo_file_in_archive(self, seqid, iprot, oprot):
5637  args.read(iprot)
5638  iprot.readMessageEnd()
5640  try:
5641  result.success = self._handler.get_first_geo_file_in_archive(args.session, args.archive_path, args.copy_params)
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("get_first_geo_file_in_archive", msg_type, seqid)
5657  result.write(oprot)
5658  oprot.writeMessageEnd()
5659  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_hardware_info (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4216 of file OmniSci.py.

4217  def process_get_hardware_info(self, seqid, iprot, oprot):
4218  args = get_hardware_info_args()
4219  args.read(iprot)
4220  iprot.readMessageEnd()
4221  result = get_hardware_info_result()
4222  try:
4223  result.success = self._handler.get_hardware_info(args.session)
4224  msg_type = TMessageType.REPLY
4225  except TTransport.TTransportException:
4226  raise
4227  except TOmniSciException as e:
4228  msg_type = TMessageType.REPLY
4229  result.e = e
4230  except TApplicationException as ex:
4231  logging.exception('TApplication exception in handler')
4232  msg_type = TMessageType.EXCEPTION
4233  result = ex
4234  except Exception:
4235  logging.exception('Unexpected exception in handler')
4236  msg_type = TMessageType.EXCEPTION
4237  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4238  oprot.writeMessageBegin("get_hardware_info", msg_type, seqid)
4239  result.write(oprot)
4240  oprot.writeMessageEnd()
4241  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_heap_profile (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4528 of file OmniSci.py.

4529  def process_get_heap_profile(self, seqid, iprot, oprot):
4530  args = get_heap_profile_args()
4531  args.read(iprot)
4532  iprot.readMessageEnd()
4533  result = get_heap_profile_result()
4534  try:
4535  result.success = self._handler.get_heap_profile(args.session)
4536  msg_type = TMessageType.REPLY
4537  except TTransport.TTransportException:
4538  raise
4539  except TOmniSciException as e:
4540  msg_type = TMessageType.REPLY
4541  result.e = e
4542  except TApplicationException as ex:
4543  logging.exception('TApplication exception in handler')
4544  msg_type = TMessageType.EXCEPTION
4545  result = ex
4546  except Exception:
4547  logging.exception('Unexpected exception in handler')
4548  msg_type = TMessageType.EXCEPTION
4549  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4550  oprot.writeMessageBegin("get_heap_profile", msg_type, seqid)
4551  result.write(oprot)
4552  oprot.writeMessageEnd()
4553  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_internal_table_details (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4372 of file OmniSci.py.

4373  def process_get_internal_table_details(self, seqid, iprot, oprot):
4375  args.read(iprot)
4376  iprot.readMessageEnd()
4378  try:
4379  result.success = self._handler.get_internal_table_details(args.session, args.table_name)
4380  msg_type = TMessageType.REPLY
4381  except TTransport.TTransportException:
4382  raise
4383  except TOmniSciException as e:
4384  msg_type = TMessageType.REPLY
4385  result.e = e
4386  except TApplicationException as ex:
4387  logging.exception('TApplication exception in handler')
4388  msg_type = TMessageType.EXCEPTION
4389  result = ex
4390  except Exception:
4391  logging.exception('Unexpected exception in handler')
4392  msg_type = TMessageType.EXCEPTION
4393  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4394  oprot.writeMessageBegin("get_internal_table_details", msg_type, seqid)
4395  result.write(oprot)
4396  oprot.writeMessageEnd()
4397  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_layers_in_geo_file (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5686 of file OmniSci.py.

5687  def process_get_layers_in_geo_file(self, seqid, iprot, oprot):
5689  args.read(iprot)
5690  iprot.readMessageEnd()
5692  try:
5693  result.success = self._handler.get_layers_in_geo_file(args.session, args.file_name, args.copy_params)
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("get_layers_in_geo_file", msg_type, seqid)
5709  result.write(oprot)
5710  oprot.writeMessageEnd()
5711  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_license_claims (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6128 of file OmniSci.py.

6129  def process_get_license_claims(self, seqid, iprot, oprot):
6130  args = get_license_claims_args()
6131  args.read(iprot)
6132  iprot.readMessageEnd()
6133  result = get_license_claims_result()
6134  try:
6135  result.success = self._handler.get_license_claims(args.session, args.nonce)
6136  msg_type = TMessageType.REPLY
6137  except TTransport.TTransportException:
6138  raise
6139  except TOmniSciException as e:
6140  msg_type = TMessageType.REPLY
6141  result.e = e
6142  except TApplicationException as ex:
6143  logging.exception('TApplication exception in handler')
6144  msg_type = TMessageType.EXCEPTION
6145  result = ex
6146  except Exception:
6147  logging.exception('Unexpected exception in handler')
6148  msg_type = TMessageType.EXCEPTION
6149  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6150  oprot.writeMessageBegin("get_license_claims", msg_type, seqid)
6151  result.write(oprot)
6152  oprot.writeMessageEnd()
6153  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_link_view (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5348 of file OmniSci.py.

5349  def process_get_link_view(self, seqid, iprot, oprot):
5350  args = get_link_view_args()
5351  args.read(iprot)
5352  iprot.readMessageEnd()
5353  result = get_link_view_result()
5354  try:
5355  result.success = self._handler.get_link_view(args.session, args.link)
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("get_link_view", msg_type, seqid)
5371  result.write(oprot)
5372  oprot.writeMessageEnd()
5373  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_memory (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4554 of file OmniSci.py.

4555  def process_get_memory(self, seqid, iprot, oprot):
4556  args = get_memory_args()
4557  args.read(iprot)
4558  iprot.readMessageEnd()
4559  result = get_memory_result()
4560  try:
4561  result.success = self._handler.get_memory(args.session, args.memory_level)
4562  msg_type = TMessageType.REPLY
4563  except TTransport.TTransportException:
4564  raise
4565  except TOmniSciException as e:
4566  msg_type = TMessageType.REPLY
4567  result.e = e
4568  except TApplicationException as ex:
4569  logging.exception('TApplication exception in handler')
4570  msg_type = TMessageType.EXCEPTION
4571  result = ex
4572  except Exception:
4573  logging.exception('Unexpected exception in handler')
4574  msg_type = TMessageType.EXCEPTION
4575  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4576  oprot.writeMessageBegin("get_memory", msg_type, seqid)
4577  result.write(oprot)
4578  oprot.writeMessageEnd()
4579  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_physical_tables (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4268 of file OmniSci.py.

4269  def process_get_physical_tables(self, seqid, iprot, oprot):
4270  args = get_physical_tables_args()
4271  args.read(iprot)
4272  iprot.readMessageEnd()
4273  result = get_physical_tables_result()
4274  try:
4275  result.success = self._handler.get_physical_tables(args.session)
4276  msg_type = TMessageType.REPLY
4277  except TTransport.TTransportException:
4278  raise
4279  except TOmniSciException as e:
4280  msg_type = TMessageType.REPLY
4281  result.e = e
4282  except TApplicationException as ex:
4283  logging.exception('TApplication exception in handler')
4284  msg_type = TMessageType.EXCEPTION
4285  result = ex
4286  except Exception:
4287  logging.exception('Unexpected exception in handler')
4288  msg_type = TMessageType.EXCEPTION
4289  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4290  oprot.writeMessageBegin("get_physical_tables", msg_type, seqid)
4291  result.write(oprot)
4292  oprot.writeMessageEnd()
4293  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_result_row_for_pixel (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5036 of file OmniSci.py.

5037  def process_get_result_row_for_pixel(self, seqid, iprot, oprot):
5039  args.read(iprot)
5040  iprot.readMessageEnd()
5042  try:
5043  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)
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("get_result_row_for_pixel", msg_type, seqid)
5059  result.write(oprot)
5060  oprot.writeMessageEnd()
5061  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_roles (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5946 of file OmniSci.py.

5947  def process_get_roles(self, seqid, iprot, oprot):
5948  args = get_roles_args()
5949  args.read(iprot)
5950  iprot.readMessageEnd()
5951  result = get_roles_result()
5952  try:
5953  result.success = self._handler.get_roles(args.session)
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("get_roles", msg_type, seqid)
5969  result.write(oprot)
5970  oprot.writeMessageEnd()
5971  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_server_status (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4164 of file OmniSci.py.

4165  def process_get_server_status(self, seqid, iprot, oprot):
4166  args = get_server_status_args()
4167  args.read(iprot)
4168  iprot.readMessageEnd()
4169  result = get_server_status_result()
4170  try:
4171  result.success = self._handler.get_server_status(args.session)
4172  msg_type = TMessageType.REPLY
4173  except TTransport.TTransportException:
4174  raise
4175  except TOmniSciException as e:
4176  msg_type = TMessageType.REPLY
4177  result.e = e
4178  except TApplicationException as ex:
4179  logging.exception('TApplication exception in handler')
4180  msg_type = TMessageType.EXCEPTION
4181  result = ex
4182  except Exception:
4183  logging.exception('Unexpected exception in handler')
4184  msg_type = TMessageType.EXCEPTION
4185  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4186  oprot.writeMessageBegin("get_server_status", msg_type, seqid)
4187  result.write(oprot)
4188  oprot.writeMessageEnd()
4189  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_session_info (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4776 of file OmniSci.py.

4777  def process_get_session_info(self, seqid, iprot, oprot):
4778  args = get_session_info_args()
4779  args.read(iprot)
4780  iprot.readMessageEnd()
4781  result = get_session_info_result()
4782  try:
4783  result.success = self._handler.get_session_info(args.session)
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("get_session_info", msg_type, seqid)
4799  result.write(oprot)
4800  oprot.writeMessageEnd()
4801  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_status (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4190 of file OmniSci.py.

4191  def process_get_status(self, seqid, iprot, oprot):
4192  args = get_status_args()
4193  args.read(iprot)
4194  iprot.readMessageEnd()
4195  result = get_status_result()
4196  try:
4197  result.success = self._handler.get_status(args.session)
4198  msg_type = TMessageType.REPLY
4199  except TTransport.TTransportException:
4200  raise
4201  except TOmniSciException as e:
4202  msg_type = TMessageType.REPLY
4203  result.e = e
4204  except TApplicationException as ex:
4205  logging.exception('TApplication exception in handler')
4206  msg_type = TMessageType.EXCEPTION
4207  result = ex
4208  except Exception:
4209  logging.exception('Unexpected exception in handler')
4210  msg_type = TMessageType.EXCEPTION
4211  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4212  oprot.writeMessageBegin("get_status", msg_type, seqid)
4213  result.write(oprot)
4214  oprot.writeMessageEnd()
4215  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_table_details (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4346 of file OmniSci.py.

4347  def process_get_table_details(self, seqid, iprot, oprot):
4348  args = get_table_details_args()
4349  args.read(iprot)
4350  iprot.readMessageEnd()
4351  result = get_table_details_result()
4352  try:
4353  result.success = self._handler.get_table_details(args.session, args.table_name)
4354  msg_type = TMessageType.REPLY
4355  except TTransport.TTransportException:
4356  raise
4357  except TOmniSciException as e:
4358  msg_type = TMessageType.REPLY
4359  result.e = e
4360  except TApplicationException as ex:
4361  logging.exception('TApplication exception in handler')
4362  msg_type = TMessageType.EXCEPTION
4363  result = ex
4364  except Exception:
4365  logging.exception('Unexpected exception in handler')
4366  msg_type = TMessageType.EXCEPTION
4367  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4368  oprot.writeMessageBegin("get_table_details", msg_type, seqid)
4369  result.write(oprot)
4370  oprot.writeMessageEnd()
4371  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_table_epoch (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4684 of file OmniSci.py.

4685  def process_get_table_epoch(self, seqid, iprot, oprot):
4686  args = get_table_epoch_args()
4687  args.read(iprot)
4688  iprot.readMessageEnd()
4689  result = get_table_epoch_result()
4690  try:
4691  result.success = self._handler.get_table_epoch(args.session, args.db_id, args.table_id)
4692  msg_type = TMessageType.REPLY
4693  except TTransport.TTransportException:
4694  raise
4695  except TApplicationException as ex:
4696  logging.exception('TApplication exception in handler')
4697  msg_type = TMessageType.EXCEPTION
4698  result = ex
4699  except Exception:
4700  logging.exception('Unexpected exception in handler')
4701  msg_type = TMessageType.EXCEPTION
4702  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4703  oprot.writeMessageBegin("get_table_epoch", msg_type, seqid)
4704  result.write(oprot)
4705  oprot.writeMessageEnd()
4706  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_table_epoch_by_name (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4707 of file OmniSci.py.

4708  def process_get_table_epoch_by_name(self, seqid, iprot, oprot):
4710  args.read(iprot)
4711  iprot.readMessageEnd()
4713  try:
4714  result.success = self._handler.get_table_epoch_by_name(args.session, args.table_name)
4715  msg_type = TMessageType.REPLY
4716  except TTransport.TTransportException:
4717  raise
4718  except TApplicationException as ex:
4719  logging.exception('TApplication exception in handler')
4720  msg_type = TMessageType.EXCEPTION
4721  result = ex
4722  except Exception:
4723  logging.exception('Unexpected exception in handler')
4724  msg_type = TMessageType.EXCEPTION
4725  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4726  oprot.writeMessageBegin("get_table_epoch_by_name", msg_type, seqid)
4727  result.write(oprot)
4728  oprot.writeMessageEnd()
4729  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_table_epochs (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4730 of file OmniSci.py.

4731  def process_get_table_epochs(self, seqid, iprot, oprot):
4732  args = get_table_epochs_args()
4733  args.read(iprot)
4734  iprot.readMessageEnd()
4735  result = get_table_epochs_result()
4736  try:
4737  result.success = self._handler.get_table_epochs(args.session, args.db_id, args.table_id)
4738  msg_type = TMessageType.REPLY
4739  except TTransport.TTransportException:
4740  raise
4741  except TApplicationException as ex:
4742  logging.exception('TApplication exception in handler')
4743  msg_type = TMessageType.EXCEPTION
4744  result = ex
4745  except Exception:
4746  logging.exception('Unexpected exception in handler')
4747  msg_type = TMessageType.EXCEPTION
4748  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4749  oprot.writeMessageBegin("get_table_epochs", msg_type, seqid)
4750  result.write(oprot)
4751  oprot.writeMessageEnd()
4752  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_tables (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4242 of file OmniSci.py.

4243  def process_get_tables(self, seqid, iprot, oprot):
4244  args = get_tables_args()
4245  args.read(iprot)
4246  iprot.readMessageEnd()
4247  result = get_tables_result()
4248  try:
4249  result.success = self._handler.get_tables(args.session)
4250  msg_type = TMessageType.REPLY
4251  except TTransport.TTransportException:
4252  raise
4253  except TOmniSciException as e:
4254  msg_type = TMessageType.REPLY
4255  result.e = e
4256  except TApplicationException as ex:
4257  logging.exception('TApplication exception in handler')
4258  msg_type = TMessageType.EXCEPTION
4259  result = ex
4260  except Exception:
4261  logging.exception('Unexpected exception in handler')
4262  msg_type = TMessageType.EXCEPTION
4263  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4264  oprot.writeMessageBegin("get_tables", msg_type, seqid)
4265  result.write(oprot)
4266  oprot.writeMessageEnd()
4267  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_tables_meta (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4320 of file OmniSci.py.

4321  def process_get_tables_meta(self, seqid, iprot, oprot):
4322  args = get_tables_meta_args()
4323  args.read(iprot)
4324  iprot.readMessageEnd()
4325  result = get_tables_meta_result()
4326  try:
4327  result.success = self._handler.get_tables_meta(args.session)
4328  msg_type = TMessageType.REPLY
4329  except TTransport.TTransportException:
4330  raise
4331  except TOmniSciException as e:
4332  msg_type = TMessageType.REPLY
4333  result.e = e
4334  except TApplicationException as ex:
4335  logging.exception('TApplication exception in handler')
4336  msg_type = TMessageType.EXCEPTION
4337  result = ex
4338  except Exception:
4339  logging.exception('Unexpected exception in handler')
4340  msg_type = TMessageType.EXCEPTION
4341  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4342  oprot.writeMessageBegin("get_tables_meta", msg_type, seqid)
4343  result.write(oprot)
4344  oprot.writeMessageEnd()
4345  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_users (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4398 of file OmniSci.py.

4399  def process_get_users(self, seqid, iprot, oprot):
4400  args = get_users_args()
4401  args.read(iprot)
4402  iprot.readMessageEnd()
4403  result = get_users_result()
4404  try:
4405  result.success = self._handler.get_users(args.session)
4406  msg_type = TMessageType.REPLY
4407  except TTransport.TTransportException:
4408  raise
4409  except TOmniSciException as e:
4410  msg_type = TMessageType.REPLY
4411  result.e = e
4412  except TApplicationException as ex:
4413  logging.exception('TApplication exception in handler')
4414  msg_type = TMessageType.EXCEPTION
4415  result = ex
4416  except Exception:
4417  logging.exception('Unexpected exception in handler')
4418  msg_type = TMessageType.EXCEPTION
4419  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4420  oprot.writeMessageBegin("get_users", msg_type, seqid)
4421  result.write(oprot)
4422  oprot.writeMessageEnd()
4423  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_version (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4450 of file OmniSci.py.

4451  def process_get_version(self, seqid, iprot, oprot):
4452  args = get_version_args()
4453  args.read(iprot)
4454  iprot.readMessageEnd()
4455  result = get_version_result()
4456  try:
4457  result.success = self._handler.get_version()
4458  msg_type = TMessageType.REPLY
4459  except TTransport.TTransportException:
4460  raise
4461  except TOmniSciException as e:
4462  msg_type = TMessageType.REPLY
4463  result.e = e
4464  except TApplicationException as ex:
4465  logging.exception('TApplication exception in handler')
4466  msg_type = TMessageType.EXCEPTION
4467  result = ex
4468  except Exception:
4469  logging.exception('Unexpected exception in handler')
4470  msg_type = TMessageType.EXCEPTION
4471  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4472  oprot.writeMessageBegin("get_version", msg_type, seqid)
4473  result.write(oprot)
4474  oprot.writeMessageEnd()
4475  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_views (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4294 of file OmniSci.py.

4295  def process_get_views(self, seqid, iprot, oprot):
4296  args = get_views_args()
4297  args.read(iprot)
4298  iprot.readMessageEnd()
4299  result = get_views_result()
4300  try:
4301  result.success = self._handler.get_views(args.session)
4302  msg_type = TMessageType.REPLY
4303  except TTransport.TTransportException:
4304  raise
4305  except TOmniSciException as e:
4306  msg_type = TMessageType.REPLY
4307  result.e = e
4308  except TApplicationException as ex:
4309  logging.exception('TApplication exception in handler')
4310  msg_type = TMessageType.EXCEPTION
4311  result = ex
4312  except Exception:
4313  logging.exception('Unexpected exception in handler')
4314  msg_type = TMessageType.EXCEPTION
4315  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4316  oprot.writeMessageBegin("get_views", msg_type, seqid)
4317  result.write(oprot)
4318  oprot.writeMessageEnd()
4319  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_has_object_privilege (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6076 of file OmniSci.py.

6077  def process_has_object_privilege(self, seqid, iprot, oprot):
6078  args = has_object_privilege_args()
6079  args.read(iprot)
6080  iprot.readMessageEnd()
6081  result = has_object_privilege_result()
6082  try:
6083  result.success = self._handler.has_object_privilege(args.session, args.granteeName, args.ObjectName, args.objectType, args.permissions)
6084  msg_type = TMessageType.REPLY
6085  except TTransport.TTransportException:
6086  raise
6087  except TOmniSciException as e:
6088  msg_type = TMessageType.REPLY
6089  result.e = e
6090  except TApplicationException as ex:
6091  logging.exception('TApplication exception in handler')
6092  msg_type = TMessageType.EXCEPTION
6093  result = ex
6094  except Exception:
6095  logging.exception('Unexpected exception in handler')
6096  msg_type = TMessageType.EXCEPTION
6097  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6098  oprot.writeMessageBegin("has_object_privilege", msg_type, seqid)
6099  result.write(oprot)
6100  oprot.writeMessageEnd()
6101  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_has_role (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6050 of file OmniSci.py.

6051  def process_has_role(self, seqid, iprot, oprot):
6052  args = has_role_args()
6053  args.read(iprot)
6054  iprot.readMessageEnd()
6055  result = has_role_result()
6056  try:
6057  result.success = self._handler.has_role(args.session, args.granteeName, args.roleName)
6058  msg_type = TMessageType.REPLY
6059  except TTransport.TTransportException:
6060  raise
6061  except TOmniSciException as e:
6062  msg_type = TMessageType.REPLY
6063  result.e = e
6064  except TApplicationException as ex:
6065  logging.exception('TApplication exception in handler')
6066  msg_type = TMessageType.EXCEPTION
6067  result = ex
6068  except Exception:
6069  logging.exception('Unexpected exception in handler')
6070  msg_type = TMessageType.EXCEPTION
6071  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6072  oprot.writeMessageBegin("has_role", msg_type, seqid)
6073  result.write(oprot)
6074  oprot.writeMessageEnd()
6075  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_import_geo_table (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5582 of file OmniSci.py.

5583  def process_import_geo_table(self, seqid, iprot, oprot):
5584  args = import_geo_table_args()
5585  args.read(iprot)
5586  iprot.readMessageEnd()
5587  result = import_geo_table_result()
5588  try:
5589  self._handler.import_geo_table(args.session, args.table_name, args.file_name, args.copy_params, args.row_desc, args.create_params)
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("import_geo_table", msg_type, seqid)
5605  result.write(oprot)
5606  oprot.writeMessageEnd()
5607  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_import_table (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5556 of file OmniSci.py.

5557  def process_import_table(self, seqid, iprot, oprot):
5558  args = import_table_args()
5559  args.read(iprot)
5560  iprot.readMessageEnd()
5561  result = import_table_result()
5562  try:
5563  self._handler.import_table(args.session, args.table_name, args.file_name, args.copy_params)
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("import_table", msg_type, seqid)
5579  result.write(oprot)
5580  oprot.writeMessageEnd()
5581  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_import_table_status (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5608 of file OmniSci.py.

5609  def process_import_table_status(self, seqid, iprot, oprot):
5610  args = import_table_status_args()
5611  args.read(iprot)
5612  iprot.readMessageEnd()
5613  result = import_table_status_result()
5614  try:
5615  result.success = self._handler.import_table_status(args.session, args.import_id)
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("import_table_status", msg_type, seqid)
5631  result.write(oprot)
5632  oprot.writeMessageEnd()
5633  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_insert_data (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5894 of file OmniSci.py.

5895  def process_insert_data(self, seqid, iprot, oprot):
5896  args = insert_data_args()
5897  args.read(iprot)
5898  iprot.readMessageEnd()
5899  result = insert_data_result()
5900  try:
5901  self._handler.insert_data(args.session, args.insert_data)
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("insert_data", msg_type, seqid)
5917  result.write(oprot)
5918  oprot.writeMessageEnd()
5919  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_interrupt (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4906 of file OmniSci.py.

4907  def process_interrupt(self, seqid, iprot, oprot):
4908  args = interrupt_args()
4909  args.read(iprot)
4910  iprot.readMessageEnd()
4911  result = interrupt_result()
4912  try:
4913  self._handler.interrupt(args.query_session, args.interrupt_session)
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("interrupt", msg_type, seqid)
4929  result.write(oprot)
4930  oprot.writeMessageEnd()
4931  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_krb5_connect (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4060 of file OmniSci.py.

4061  def process_krb5_connect(self, seqid, iprot, oprot):
4062  args = krb5_connect_args()
4063  args.read(iprot)
4064  iprot.readMessageEnd()
4065  result = krb5_connect_result()
4066  try:
4067  result.success = self._handler.krb5_connect(args.inputToken, args.dbname)
4068  msg_type = TMessageType.REPLY
4069  except TTransport.TTransportException:
4070  raise
4071  except TOmniSciException as e:
4072  msg_type = TMessageType.REPLY
4073  result.e = e
4074  except TApplicationException as ex:
4075  logging.exception('TApplication exception in handler')
4076  msg_type = TMessageType.EXCEPTION
4077  result = ex
4078  except Exception:
4079  logging.exception('Unexpected exception in handler')
4080  msg_type = TMessageType.EXCEPTION
4081  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4082  oprot.writeMessageBegin("krb5_connect", msg_type, seqid)
4083  result.write(oprot)
4084  oprot.writeMessageEnd()
4085  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_load_table (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5478 of file OmniSci.py.

5479  def process_load_table(self, seqid, iprot, oprot):
5480  args = load_table_args()
5481  args.read(iprot)
5482  iprot.readMessageEnd()
5483  result = load_table_result()
5484  try:
5485  self._handler.load_table(args.session, args.table_name, args.rows, args.column_names)
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("load_table", msg_type, seqid)
5501  result.write(oprot)
5502  oprot.writeMessageEnd()
5503  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_load_table_binary (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5400 of file OmniSci.py.

5401  def process_load_table_binary(self, seqid, iprot, oprot):
5402  args = load_table_binary_args()
5403  args.read(iprot)
5404  iprot.readMessageEnd()
5405  result = load_table_binary_result()
5406  try:
5407  self._handler.load_table_binary(args.session, args.table_name, args.rows, args.column_names)
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("load_table_binary", msg_type, seqid)
5423  result.write(oprot)
5424  oprot.writeMessageEnd()
5425  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_load_table_binary_arrow (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5452 of file OmniSci.py.

5453  def process_load_table_binary_arrow(self, seqid, iprot, oprot):
5455  args.read(iprot)
5456  iprot.readMessageEnd()
5458  try:
5459  self._handler.load_table_binary_arrow(args.session, args.table_name, args.arrow_stream, args.use_column_names)
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("load_table_binary_arrow", msg_type, seqid)
5475  result.write(oprot)
5476  oprot.writeMessageEnd()
5477  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_load_table_binary_columnar (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5426 of file OmniSci.py.

5427  def process_load_table_binary_columnar(self, seqid, iprot, oprot):
5429  args.read(iprot)
5430  iprot.readMessageEnd()
5432  try:
5433  self._handler.load_table_binary_columnar(args.session, args.table_name, args.cols, args.column_names)
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("load_table_binary_columnar", msg_type, seqid)
5449  result.write(oprot)
5450  oprot.writeMessageEnd()
5451  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_query_get_outer_fragment_count (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5712 of file OmniSci.py.

5713  def process_query_get_outer_fragment_count(self, seqid, iprot, oprot):
5715  args.read(iprot)
5716  iprot.readMessageEnd()
5718  try:
5719  result.success = self._handler.query_get_outer_fragment_count(args.session, args.query)
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("query_get_outer_fragment_count", msg_type, seqid)
5735  result.write(oprot)
5736  oprot.writeMessageEnd()
5737  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_register_runtime_extension_functions (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6180 of file OmniSci.py.

6181  def process_register_runtime_extension_functions(self, seqid, iprot, oprot):
6183  args.read(iprot)
6184  iprot.readMessageEnd()
6186  try:
6187  self._handler.register_runtime_extension_functions(args.session, args.udfs, args.udtfs, args.device_ir_map)
6188  msg_type = TMessageType.REPLY
6189  except TTransport.TTransportException:
6190  raise
6191  except TOmniSciException as e:
6192  msg_type = TMessageType.REPLY
6193  result.e = e
6194  except TApplicationException as ex:
6195  logging.exception('TApplication exception in handler')
6196  msg_type = TMessageType.EXCEPTION
6197  result = ex
6198  except Exception:
6199  logging.exception('Unexpected exception in handler')
6200  msg_type = TMessageType.EXCEPTION
6201  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6202  oprot.writeMessageBegin("register_runtime_extension_functions", msg_type, seqid)
6203  result.write(oprot)
6204  oprot.writeMessageEnd()
6205  oprot.trans.flush()
6206 
6207 # HELPER FUNCTIONS AND STRUCTURES
6208 
def omnisci.thrift.OmniSci.Processor.process_render_vega (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5010 of file OmniSci.py.

5011  def process_render_vega(self, seqid, iprot, oprot):
5012  args = render_vega_args()
5013  args.read(iprot)
5014  iprot.readMessageEnd()
5015  result = render_vega_result()
5016  try:
5017  result.success = self._handler.render_vega(args.session, args.widget_id, args.vega_json, args.compression_level, args.nonce)
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("render_vega", msg_type, seqid)
5033  result.write(oprot)
5034  oprot.writeMessageEnd()
5035  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_replace_dashboard (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5140 of file OmniSci.py.

5141  def process_replace_dashboard(self, seqid, iprot, oprot):
5142  args = replace_dashboard_args()
5143  args.read(iprot)
5144  iprot.readMessageEnd()
5145  result = replace_dashboard_result()
5146  try:
5147  self._handler.replace_dashboard(args.session, args.dashboard_id, args.dashboard_name, args.dashboard_owner, args.dashboard_state, args.image_hash, args.dashboard_metadata)
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("replace_dashboard", msg_type, seqid)
5163  result.write(oprot)
5164  oprot.writeMessageEnd()
5165  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_set_execution_mode (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4984 of file OmniSci.py.

4985  def process_set_execution_mode(self, seqid, iprot, oprot):
4986  args = set_execution_mode_args()
4987  args.read(iprot)
4988  iprot.readMessageEnd()
4989  result = set_execution_mode_result()
4990  try:
4991  self._handler.set_execution_mode(args.session, args.mode)
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("set_execution_mode", msg_type, seqid)
5007  result.write(oprot)
5008  oprot.writeMessageEnd()
5009  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_set_license_key (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6102 of file OmniSci.py.

6103  def process_set_license_key(self, seqid, iprot, oprot):
6104  args = set_license_key_args()
6105  args.read(iprot)
6106  iprot.readMessageEnd()
6107  result = set_license_key_result()
6108  try:
6109  result.success = self._handler.set_license_key(args.session, args.key, args.nonce)
6110  msg_type = TMessageType.REPLY
6111  except TTransport.TTransportException:
6112  raise
6113  except TOmniSciException as e:
6114  msg_type = TMessageType.REPLY
6115  result.e = e
6116  except TApplicationException as ex:
6117  logging.exception('TApplication exception in handler')
6118  msg_type = TMessageType.EXCEPTION
6119  result = ex
6120  except Exception:
6121  logging.exception('Unexpected exception in handler')
6122  msg_type = TMessageType.EXCEPTION
6123  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6124  oprot.writeMessageBegin("set_license_key", msg_type, seqid)
6125  result.write(oprot)
6126  oprot.writeMessageEnd()
6127  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_set_table_epoch (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4632 of file OmniSci.py.

4633  def process_set_table_epoch(self, seqid, iprot, oprot):
4634  args = set_table_epoch_args()
4635  args.read(iprot)
4636  iprot.readMessageEnd()
4637  result = set_table_epoch_result()
4638  try:
4639  self._handler.set_table_epoch(args.session, args.db_id, args.table_id, args.new_epoch)
4640  msg_type = TMessageType.REPLY
4641  except TTransport.TTransportException:
4642  raise
4643  except TOmniSciException as e:
4644  msg_type = TMessageType.REPLY
4645  result.e = e
4646  except TApplicationException as ex:
4647  logging.exception('TApplication exception in handler')
4648  msg_type = TMessageType.EXCEPTION
4649  result = ex
4650  except Exception:
4651  logging.exception('Unexpected exception in handler')
4652  msg_type = TMessageType.EXCEPTION
4653  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4654  oprot.writeMessageBegin("set_table_epoch", msg_type, seqid)
4655  result.write(oprot)
4656  oprot.writeMessageEnd()
4657  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_set_table_epoch_by_name (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4658 of file OmniSci.py.

4659  def process_set_table_epoch_by_name(self, seqid, iprot, oprot):
4661  args.read(iprot)
4662  iprot.readMessageEnd()
4664  try:
4665  self._handler.set_table_epoch_by_name(args.session, args.table_name, args.new_epoch)
4666  msg_type = TMessageType.REPLY
4667  except TTransport.TTransportException:
4668  raise
4669  except TOmniSciException as e:
4670  msg_type = TMessageType.REPLY
4671  result.e = e
4672  except TApplicationException as ex:
4673  logging.exception('TApplication exception in handler')
4674  msg_type = TMessageType.EXCEPTION
4675  result = ex
4676  except Exception:
4677  logging.exception('Unexpected exception in handler')
4678  msg_type = TMessageType.EXCEPTION
4679  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4680  oprot.writeMessageBegin("set_table_epoch_by_name", msg_type, seqid)
4681  result.write(oprot)
4682  oprot.writeMessageEnd()
4683  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_set_table_epochs (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4753 of file OmniSci.py.

4754  def process_set_table_epochs(self, seqid, iprot, oprot):
4755  args = set_table_epochs_args()
4756  args.read(iprot)
4757  iprot.readMessageEnd()
4758  result = set_table_epochs_result()
4759  try:
4760  self._handler.set_table_epochs(args.session, args.db_id, args.table_epochs)
4761  msg_type = TMessageType.REPLY
4762  except TTransport.TTransportException:
4763  raise
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("set_table_epochs", msg_type, seqid)
4773  result.write(oprot)
4774  oprot.writeMessageEnd()
4775  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_share_dashboard (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5244 of file OmniSci.py.

5245  def process_share_dashboard(self, seqid, iprot, oprot):
5246  args = share_dashboard_args()
5247  args.read(iprot)
5248  iprot.readMessageEnd()
5249  result = share_dashboard_result()
5250  try:
5251  self._handler.share_dashboard(args.session, args.dashboard_id, args.groups, args.objects, args.permissions, args.grant_role)
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("share_dashboard", msg_type, seqid)
5267  result.write(oprot)
5268  oprot.writeMessageEnd()
5269  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_share_dashboards (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5192 of file OmniSci.py.

5193  def process_share_dashboards(self, seqid, iprot, oprot):
5194  args = share_dashboards_args()
5195  args.read(iprot)
5196  iprot.readMessageEnd()
5197  result = share_dashboards_result()
5198  try:
5199  self._handler.share_dashboards(args.session, args.dashboard_ids, args.groups, args.permissions)
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("share_dashboards", msg_type, seqid)
5215  result.write(oprot)
5216  oprot.writeMessageEnd()
5217  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_sql_execute (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4802 of file OmniSci.py.

4803  def process_sql_execute(self, seqid, iprot, oprot):
4804  args = sql_execute_args()
4805  args.read(iprot)
4806  iprot.readMessageEnd()
4807  result = sql_execute_result()
4808  try:
4809  result.success = self._handler.sql_execute(args.session, args.query, args.column_format, args.nonce, args.first_n, args.at_most_n)
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("sql_execute", msg_type, seqid)
4825  result.write(oprot)
4826  oprot.writeMessageEnd()
4827  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_sql_execute_df (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4828 of file OmniSci.py.

4829  def process_sql_execute_df(self, seqid, iprot, oprot):
4830  args = sql_execute_df_args()
4831  args.read(iprot)
4832  iprot.readMessageEnd()
4833  result = sql_execute_df_result()
4834  try:
4835  result.success = self._handler.sql_execute_df(args.session, args.query, args.device_type, args.device_id, args.first_n, args.transport_method)
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("sql_execute_df", msg_type, seqid)
4851  result.write(oprot)
4852  oprot.writeMessageEnd()
4853  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_sql_execute_gdf (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4854 of file OmniSci.py.

4855  def process_sql_execute_gdf(self, seqid, iprot, oprot):
4856  args = sql_execute_gdf_args()
4857  args.read(iprot)
4858  iprot.readMessageEnd()
4859  result = sql_execute_gdf_result()
4860  try:
4861  result.success = self._handler.sql_execute_gdf(args.session, args.query, args.device_id, args.first_n)
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("sql_execute_gdf", msg_type, seqid)
4877  result.write(oprot)
4878  oprot.writeMessageEnd()
4879  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_sql_validate (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4932 of file OmniSci.py.

4933  def process_sql_validate(self, seqid, iprot, oprot):
4934  args = sql_validate_args()
4935  args.read(iprot)
4936  iprot.readMessageEnd()
4937  result = sql_validate_result()
4938  try:
4939  result.success = self._handler.sql_validate(args.session, args.query)
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("sql_validate", msg_type, seqid)
4955  result.write(oprot)
4956  oprot.writeMessageEnd()
4957  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_start_heap_profile (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4476 of file OmniSci.py.

4477  def process_start_heap_profile(self, seqid, iprot, oprot):
4478  args = start_heap_profile_args()
4479  args.read(iprot)
4480  iprot.readMessageEnd()
4481  result = start_heap_profile_result()
4482  try:
4483  self._handler.start_heap_profile(args.session)
4484  msg_type = TMessageType.REPLY
4485  except TTransport.TTransportException:
4486  raise
4487  except TOmniSciException as e:
4488  msg_type = TMessageType.REPLY
4489  result.e = e
4490  except TApplicationException as ex:
4491  logging.exception('TApplication exception in handler')
4492  msg_type = TMessageType.EXCEPTION
4493  result = ex
4494  except Exception:
4495  logging.exception('Unexpected exception in handler')
4496  msg_type = TMessageType.EXCEPTION
4497  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4498  oprot.writeMessageBegin("start_heap_profile", msg_type, seqid)
4499  result.write(oprot)
4500  oprot.writeMessageEnd()
4501  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_start_query (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5764 of file OmniSci.py.

5765  def process_start_query(self, seqid, iprot, oprot):
5766  args = start_query_args()
5767  args.read(iprot)
5768  iprot.readMessageEnd()
5769  result = start_query_result()
5770  try:
5771  result.success = self._handler.start_query(args.leaf_session, args.parent_session, args.query_ra, args.just_explain, args.outer_fragment_indices)
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("start_query", msg_type, seqid)
5787  result.write(oprot)
5788  oprot.writeMessageEnd()
5789  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_start_render_query (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5842 of file OmniSci.py.

5843  def process_start_render_query(self, seqid, iprot, oprot):
5844  args = start_render_query_args()
5845  args.read(iprot)
5846  iprot.readMessageEnd()
5847  result = start_render_query_result()
5848  try:
5849  result.success = self._handler.start_render_query(args.session, args.widget_id, args.node_idx, args.vega_json)
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("start_render_query", msg_type, seqid)
5865  result.write(oprot)
5866  oprot.writeMessageEnd()
5867  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_stop_heap_profile (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4502 of file OmniSci.py.

4503  def process_stop_heap_profile(self, seqid, iprot, oprot):
4504  args = stop_heap_profile_args()
4505  args.read(iprot)
4506  iprot.readMessageEnd()
4507  result = stop_heap_profile_result()
4508  try:
4509  self._handler.stop_heap_profile(args.session)
4510  msg_type = TMessageType.REPLY
4511  except TTransport.TTransportException:
4512  raise
4513  except TOmniSciException as e:
4514  msg_type = TMessageType.REPLY
4515  result.e = e
4516  except TApplicationException as ex:
4517  logging.exception('TApplication exception in handler')
4518  msg_type = TMessageType.EXCEPTION
4519  result = ex
4520  except Exception:
4521  logging.exception('Unexpected exception in handler')
4522  msg_type = TMessageType.EXCEPTION
4523  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4524  oprot.writeMessageBegin("stop_heap_profile", msg_type, seqid)
4525  result.write(oprot)
4526  oprot.writeMessageEnd()
4527  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_switch_database (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4112 of file OmniSci.py.

4113  def process_switch_database(self, seqid, iprot, oprot):
4114  args = switch_database_args()
4115  args.read(iprot)
4116  iprot.readMessageEnd()
4117  result = switch_database_result()
4118  try:
4119  self._handler.switch_database(args.session, args.dbname)
4120  msg_type = TMessageType.REPLY
4121  except TTransport.TTransportException:
4122  raise
4123  except TOmniSciException as e:
4124  msg_type = TMessageType.REPLY
4125  result.e = e
4126  except TApplicationException as ex:
4127  logging.exception('TApplication exception in handler')
4128  msg_type = TMessageType.EXCEPTION
4129  result = ex
4130  except Exception:
4131  logging.exception('Unexpected exception in handler')
4132  msg_type = TMessageType.EXCEPTION
4133  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4134  oprot.writeMessageBegin("switch_database", msg_type, seqid)
4135  result.write(oprot)
4136  oprot.writeMessageEnd()
4137  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_unshare_dashboard (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5270 of file OmniSci.py.

5271  def process_unshare_dashboard(self, seqid, iprot, oprot):
5272  args = unshare_dashboard_args()
5273  args.read(iprot)
5274  iprot.readMessageEnd()
5275  result = unshare_dashboard_result()
5276  try:
5277  self._handler.unshare_dashboard(args.session, args.dashboard_id, args.groups, args.objects, args.permissions)
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("unshare_dashboard", msg_type, seqid)
5293  result.write(oprot)
5294  oprot.writeMessageEnd()
5295  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_unshare_dashboards (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5296 of file OmniSci.py.

5297  def process_unshare_dashboards(self, seqid, iprot, oprot):
5298  args = unshare_dashboards_args()
5299  args.read(iprot)
5300  iprot.readMessageEnd()
5301  result = unshare_dashboards_result()
5302  try:
5303  self._handler.unshare_dashboards(args.session, args.dashboard_ids, args.groups, args.permissions)
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("unshare_dashboards", msg_type, seqid)
5319  result.write(oprot)
5320  oprot.writeMessageEnd()
5321  oprot.trans.flush()

Member Data Documentation

omnisci.thrift.OmniSci.Processor._handler
private

Definition at line 3926 of file OmniSci.py.

omnisci.thrift.OmniSci.Processor._on_message_begin
private

Definition at line 4012 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 3927 of file OmniSci.py.

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


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