OmniSciDB  6686921089
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups 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_tables_for_database
 
def process_get_physical_tables
 
def process_get_views
 
def process_get_tables_meta
 
def process_get_table_details
 
def process_get_table_details_for_database
 
def process_get_internal_table_details
 
def process_get_internal_table_details_for_database
 
def process_get_users
 
def process_get_databases
 
def process_get_version
 
def process_start_heap_profile
 
def process_stop_heap_profile
 
def process_get_heap_profile
 
def process_get_memory
 
def process_clear_cpu_memory
 
def process_clear_gpu_memory
 
def process_set_cur_session
 
def process_invalidate_cur_session
 
def process_set_table_epoch
 
def process_set_table_epoch_by_name
 
def process_get_table_epoch
 
def process_get_table_epoch_by_name
 
def process_get_table_epochs
 
def process_set_table_epochs
 
def process_get_session_info
 
def process_sql_execute
 
def process_sql_execute_df
 
def process_sql_execute_gdf
 
def process_deallocate_df
 
def process_interrupt
 
def process_sql_validate
 
def process_get_completion_hints
 
def process_set_execution_mode
 
def process_render_vega
 
def process_get_result_row_for_pixel
 
def process_create_custom_expression
 
def process_get_custom_expressions
 
def process_update_custom_expression
 
def process_delete_custom_expressions
 
def process_get_dashboard
 
def process_get_dashboards
 
def process_create_dashboard
 
def process_replace_dashboard
 
def process_delete_dashboard
 
def process_share_dashboards
 
def process_delete_dashboards
 
def process_share_dashboard
 
def process_unshare_dashboard
 
def process_unshare_dashboards
 
def process_get_dashboard_grantees
 
def process_get_link_view
 
def process_create_link
 
def process_load_table_binary
 
def process_load_table_binary_columnar
 
def process_load_table_binary_columnar_polys
 
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_tables_for_database
 
def get_physical_tables
 
def get_views
 
def get_tables_meta
 
def get_table_details
 
def get_table_details_for_database
 
def get_internal_table_details
 
def get_internal_table_details_for_database
 
def get_users
 
def get_databases
 
def get_version
 
def start_heap_profile
 
def stop_heap_profile
 
def get_heap_profile
 
def get_memory
 
def clear_cpu_memory
 
def clear_gpu_memory
 
def set_cur_session
 
def invalidate_cur_session
 
def set_table_epoch
 
def set_table_epoch_by_name
 
def get_table_epoch
 
def get_table_epoch_by_name
 
def get_table_epochs
 
def set_table_epochs
 
def get_session_info
 
def sql_execute
 
def sql_execute_df
 
def sql_execute_gdf
 
def deallocate_df
 
def interrupt
 
def sql_validate
 
def get_completion_hints
 
def set_execution_mode
 
def render_vega
 
def get_result_row_for_pixel
 
def create_custom_expression
 
def get_custom_expressions
 
def update_custom_expression
 
def delete_custom_expressions
 
def get_dashboard
 
def get_dashboards
 
def create_dashboard
 
def replace_dashboard
 
def delete_dashboard
 
def share_dashboards
 
def delete_dashboards
 
def share_dashboard
 
def unshare_dashboard
 
def unshare_dashboards
 
def get_dashboard_grantees
 
def get_link_view
 
def create_link
 
def load_table_binary
 
def load_table_binary_columnar
 
def load_table_binary_columnar_polys
 
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 4406 of file OmniSci.py.

Constructor & Destructor Documentation

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

Definition at line 4407 of file OmniSci.py.

4408  def __init__(self, handler):
4409  self._handler = handler
4410  self._processMap = {}
4411  self._processMap["connect"] = Processor.process_connect
4412  self._processMap["krb5_connect"] = Processor.process_krb5_connect
4413  self._processMap["disconnect"] = Processor.process_disconnect
4414  self._processMap["switch_database"] = Processor.process_switch_database
4415  self._processMap["clone_session"] = Processor.process_clone_session
4416  self._processMap["get_server_status"] = Processor.process_get_server_status
4417  self._processMap["get_status"] = Processor.process_get_status
4418  self._processMap["get_hardware_info"] = Processor.process_get_hardware_info
4419  self._processMap["get_tables"] = Processor.process_get_tables
4420  self._processMap["get_tables_for_database"] = Processor.process_get_tables_for_database
4421  self._processMap["get_physical_tables"] = Processor.process_get_physical_tables
4422  self._processMap["get_views"] = Processor.process_get_views
4423  self._processMap["get_tables_meta"] = Processor.process_get_tables_meta
4424  self._processMap["get_table_details"] = Processor.process_get_table_details
4425  self._processMap["get_table_details_for_database"] = Processor.process_get_table_details_for_database
4426  self._processMap["get_internal_table_details"] = Processor.process_get_internal_table_details
4427  self._processMap["get_internal_table_details_for_database"] = Processor.process_get_internal_table_details_for_database
4428  self._processMap["get_users"] = Processor.process_get_users
4429  self._processMap["get_databases"] = Processor.process_get_databases
4430  self._processMap["get_version"] = Processor.process_get_version
4431  self._processMap["start_heap_profile"] = Processor.process_start_heap_profile
4432  self._processMap["stop_heap_profile"] = Processor.process_stop_heap_profile
4433  self._processMap["get_heap_profile"] = Processor.process_get_heap_profile
4434  self._processMap["get_memory"] = Processor.process_get_memory
4435  self._processMap["clear_cpu_memory"] = Processor.process_clear_cpu_memory
4436  self._processMap["clear_gpu_memory"] = Processor.process_clear_gpu_memory
4437  self._processMap["set_cur_session"] = Processor.process_set_cur_session
4438  self._processMap["invalidate_cur_session"] = Processor.process_invalidate_cur_session
4439  self._processMap["set_table_epoch"] = Processor.process_set_table_epoch
4440  self._processMap["set_table_epoch_by_name"] = Processor.process_set_table_epoch_by_name
4441  self._processMap["get_table_epoch"] = Processor.process_get_table_epoch
4442  self._processMap["get_table_epoch_by_name"] = Processor.process_get_table_epoch_by_name
4443  self._processMap["get_table_epochs"] = Processor.process_get_table_epochs
4444  self._processMap["set_table_epochs"] = Processor.process_set_table_epochs
4445  self._processMap["get_session_info"] = Processor.process_get_session_info
4446  self._processMap["sql_execute"] = Processor.process_sql_execute
4447  self._processMap["sql_execute_df"] = Processor.process_sql_execute_df
4448  self._processMap["sql_execute_gdf"] = Processor.process_sql_execute_gdf
4449  self._processMap["deallocate_df"] = Processor.process_deallocate_df
4450  self._processMap["interrupt"] = Processor.process_interrupt
4451  self._processMap["sql_validate"] = Processor.process_sql_validate
4452  self._processMap["get_completion_hints"] = Processor.process_get_completion_hints
4453  self._processMap["set_execution_mode"] = Processor.process_set_execution_mode
4454  self._processMap["render_vega"] = Processor.process_render_vega
4455  self._processMap["get_result_row_for_pixel"] = Processor.process_get_result_row_for_pixel
4456  self._processMap["create_custom_expression"] = Processor.process_create_custom_expression
4457  self._processMap["get_custom_expressions"] = Processor.process_get_custom_expressions
4458  self._processMap["update_custom_expression"] = Processor.process_update_custom_expression
4459  self._processMap["delete_custom_expressions"] = Processor.process_delete_custom_expressions
4460  self._processMap["get_dashboard"] = Processor.process_get_dashboard
4461  self._processMap["get_dashboards"] = Processor.process_get_dashboards
4462  self._processMap["create_dashboard"] = Processor.process_create_dashboard
4463  self._processMap["replace_dashboard"] = Processor.process_replace_dashboard
4464  self._processMap["delete_dashboard"] = Processor.process_delete_dashboard
4465  self._processMap["share_dashboards"] = Processor.process_share_dashboards
4466  self._processMap["delete_dashboards"] = Processor.process_delete_dashboards
4467  self._processMap["share_dashboard"] = Processor.process_share_dashboard
4468  self._processMap["unshare_dashboard"] = Processor.process_unshare_dashboard
4469  self._processMap["unshare_dashboards"] = Processor.process_unshare_dashboards
4470  self._processMap["get_dashboard_grantees"] = Processor.process_get_dashboard_grantees
4471  self._processMap["get_link_view"] = Processor.process_get_link_view
4472  self._processMap["create_link"] = Processor.process_create_link
4473  self._processMap["load_table_binary"] = Processor.process_load_table_binary
4474  self._processMap["load_table_binary_columnar"] = Processor.process_load_table_binary_columnar
4475  self._processMap["load_table_binary_columnar_polys"] = Processor.process_load_table_binary_columnar_polys
4476  self._processMap["load_table_binary_arrow"] = Processor.process_load_table_binary_arrow
4477  self._processMap["load_table"] = Processor.process_load_table
4478  self._processMap["detect_column_types"] = Processor.process_detect_column_types
4479  self._processMap["create_table"] = Processor.process_create_table
4480  self._processMap["import_table"] = Processor.process_import_table
4481  self._processMap["import_geo_table"] = Processor.process_import_geo_table
4482  self._processMap["import_table_status"] = Processor.process_import_table_status
4483  self._processMap["get_first_geo_file_in_archive"] = Processor.process_get_first_geo_file_in_archive
4484  self._processMap["get_all_files_in_archive"] = Processor.process_get_all_files_in_archive
4485  self._processMap["get_layers_in_geo_file"] = Processor.process_get_layers_in_geo_file
4486  self._processMap["query_get_outer_fragment_count"] = Processor.process_query_get_outer_fragment_count
4487  self._processMap["check_table_consistency"] = Processor.process_check_table_consistency
4488  self._processMap["start_query"] = Processor.process_start_query
4489  self._processMap["execute_query_step"] = Processor.process_execute_query_step
4490  self._processMap["broadcast_serialized_rows"] = Processor.process_broadcast_serialized_rows
4491  self._processMap["start_render_query"] = Processor.process_start_render_query
4492  self._processMap["execute_next_render_step"] = Processor.process_execute_next_render_step
4493  self._processMap["insert_data"] = Processor.process_insert_data
4494  self._processMap["checkpoint"] = Processor.process_checkpoint
4495  self._processMap["get_roles"] = Processor.process_get_roles
4496  self._processMap["get_db_objects_for_grantee"] = Processor.process_get_db_objects_for_grantee
4497  self._processMap["get_db_object_privs"] = Processor.process_get_db_object_privs
4498  self._processMap["get_all_roles_for_user"] = Processor.process_get_all_roles_for_user
4499  self._processMap["has_role"] = Processor.process_has_role
4500  self._processMap["has_object_privilege"] = Processor.process_has_object_privilege
4501  self._processMap["set_license_key"] = Processor.process_set_license_key
4502  self._processMap["get_license_claims"] = Processor.process_get_license_claims
4503  self._processMap["get_device_parameters"] = Processor.process_get_device_parameters
4504  self._processMap["register_runtime_extension_functions"] = Processor.process_register_runtime_extension_functions
4505  self._on_message_begin = None

Member Function Documentation

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

Definition at line 4506 of file OmniSci.py.

References omnisci.thrift.OmniSci.Processor._on_message_begin.

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

Definition at line 4509 of file OmniSci.py.

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

4510  def process(self, iprot, oprot):
4511  (name, type, seqid) = iprot.readMessageBegin()
4512  if self._on_message_begin:
4513  self._on_message_begin(name, type, seqid)
4514  if name not in self._processMap:
4515  iprot.skip(TType.STRUCT)
4516  iprot.readMessageEnd()
4517  x = TApplicationException(TApplicationException.UNKNOWN_METHOD, 'Unknown function %s' % (name))
4518  oprot.writeMessageBegin(name, TMessageType.EXCEPTION, seqid)
4519  x.write(oprot)
4520  oprot.writeMessageEnd()
4521  oprot.trans.flush()
4522  return
4523  else:
4524  self._processMap[name](self, seqid, iprot, oprot)
4525  return True
def omnisci.thrift.OmniSci.Processor.process_broadcast_serialized_rows (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6568 of file OmniSci.py.

6569  def process_broadcast_serialized_rows(self, seqid, iprot, oprot):
6571  args.read(iprot)
6572  iprot.readMessageEnd()
6574  try:
6575  self._handler.broadcast_serialized_rows(args.serialized_rows, args.row_desc, args.query_id, args.subquery_id, args.is_final_subquery_result)
6576  msg_type = TMessageType.REPLY
6577  except TTransport.TTransportException:
6578  raise
6579  except TOmniSciException as e:
6580  msg_type = TMessageType.REPLY
6581  result.e = e
6582  except TApplicationException as ex:
6583  logging.exception('TApplication exception in handler')
6584  msg_type = TMessageType.EXCEPTION
6585  result = ex
6586  except Exception:
6587  logging.exception('Unexpected exception in handler')
6588  msg_type = TMessageType.EXCEPTION
6589  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6590  oprot.writeMessageBegin("broadcast_serialized_rows", msg_type, seqid)
6591  result.write(oprot)
6592  oprot.writeMessageEnd()
6593  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_check_table_consistency (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6490 of file OmniSci.py.

6491  def process_check_table_consistency(self, seqid, iprot, oprot):
6493  args.read(iprot)
6494  iprot.readMessageEnd()
6496  try:
6497  result.success = self._handler.check_table_consistency(args.session, args.table_id)
6498  msg_type = TMessageType.REPLY
6499  except TTransport.TTransportException:
6500  raise
6501  except TOmniSciException as e:
6502  msg_type = TMessageType.REPLY
6503  result.e = e
6504  except TApplicationException as ex:
6505  logging.exception('TApplication exception in handler')
6506  msg_type = TMessageType.EXCEPTION
6507  result = ex
6508  except Exception:
6509  logging.exception('Unexpected exception in handler')
6510  msg_type = TMessageType.EXCEPTION
6511  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6512  oprot.writeMessageBegin("check_table_consistency", msg_type, seqid)
6513  result.write(oprot)
6514  oprot.writeMessageEnd()
6515  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_checkpoint (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6672 of file OmniSci.py.

6673  def process_checkpoint(self, seqid, iprot, oprot):
6674  args = checkpoint_args()
6675  args.read(iprot)
6676  iprot.readMessageEnd()
6677  result = checkpoint_result()
6678  try:
6679  self._handler.checkpoint(args.session, args.table_id)
6680  msg_type = TMessageType.REPLY
6681  except TTransport.TTransportException:
6682  raise
6683  except TOmniSciException as e:
6684  msg_type = TMessageType.REPLY
6685  result.e = e
6686  except TApplicationException as ex:
6687  logging.exception('TApplication exception in handler')
6688  msg_type = TMessageType.EXCEPTION
6689  result = ex
6690  except Exception:
6691  logging.exception('Unexpected exception in handler')
6692  msg_type = TMessageType.EXCEPTION
6693  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6694  oprot.writeMessageBegin("checkpoint", msg_type, seqid)
6695  result.write(oprot)
6696  oprot.writeMessageEnd()
6697  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_clear_cpu_memory (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5150 of file OmniSci.py.

5151  def process_clear_cpu_memory(self, seqid, iprot, oprot):
5152  args = clear_cpu_memory_args()
5153  args.read(iprot)
5154  iprot.readMessageEnd()
5155  result = clear_cpu_memory_result()
5156  try:
5157  self._handler.clear_cpu_memory(args.session)
5158  msg_type = TMessageType.REPLY
5159  except TTransport.TTransportException:
5160  raise
5161  except TOmniSciException as e:
5162  msg_type = TMessageType.REPLY
5163  result.e = e
5164  except TApplicationException as ex:
5165  logging.exception('TApplication exception in handler')
5166  msg_type = TMessageType.EXCEPTION
5167  result = ex
5168  except Exception:
5169  logging.exception('Unexpected exception in handler')
5170  msg_type = TMessageType.EXCEPTION
5171  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5172  oprot.writeMessageBegin("clear_cpu_memory", msg_type, seqid)
5173  result.write(oprot)
5174  oprot.writeMessageEnd()
5175  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_clear_gpu_memory (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5176 of file OmniSci.py.

5177  def process_clear_gpu_memory(self, seqid, iprot, oprot):
5178  args = clear_gpu_memory_args()
5179  args.read(iprot)
5180  iprot.readMessageEnd()
5181  result = clear_gpu_memory_result()
5182  try:
5183  self._handler.clear_gpu_memory(args.session)
5184  msg_type = TMessageType.REPLY
5185  except TTransport.TTransportException:
5186  raise
5187  except TOmniSciException as e:
5188  msg_type = TMessageType.REPLY
5189  result.e = e
5190  except TApplicationException as ex:
5191  logging.exception('TApplication exception in handler')
5192  msg_type = TMessageType.EXCEPTION
5193  result = ex
5194  except Exception:
5195  logging.exception('Unexpected exception in handler')
5196  msg_type = TMessageType.EXCEPTION
5197  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5198  oprot.writeMessageBegin("clear_gpu_memory", msg_type, seqid)
5199  result.write(oprot)
5200  oprot.writeMessageEnd()
5201  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_clone_session (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4630 of file OmniSci.py.

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

Definition at line 4526 of file OmniSci.py.

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

Definition at line 5684 of file OmniSci.py.

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

Definition at line 5840 of file OmniSci.py.

5841  def process_create_dashboard(self, seqid, iprot, oprot):
5842  args = create_dashboard_args()
5843  args.read(iprot)
5844  iprot.readMessageEnd()
5845  result = create_dashboard_result()
5846  try:
5847  result.success = self._handler.create_dashboard(args.session, args.dashboard_name, args.dashboard_state, args.image_hash, args.dashboard_metadata)
5848  msg_type = TMessageType.REPLY
5849  except TTransport.TTransportException:
5850  raise
5851  except TOmniSciException as e:
5852  msg_type = TMessageType.REPLY
5853  result.e = e
5854  except TApplicationException as ex:
5855  logging.exception('TApplication exception in handler')
5856  msg_type = TMessageType.EXCEPTION
5857  result = ex
5858  except Exception:
5859  logging.exception('Unexpected exception in handler')
5860  msg_type = TMessageType.EXCEPTION
5861  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5862  oprot.writeMessageBegin("create_dashboard", msg_type, seqid)
5863  result.write(oprot)
5864  oprot.writeMessageEnd()
5865  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_create_link (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6100 of file OmniSci.py.

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

Definition at line 6282 of file OmniSci.py.

6283  def process_create_table(self, seqid, iprot, oprot):
6284  args = create_table_args()
6285  args.read(iprot)
6286  iprot.readMessageEnd()
6287  result = create_table_result()
6288  try:
6289  self._handler.create_table(args.session, args.table_name, args.row_desc, args.file_type, args.create_params)
6290  msg_type = TMessageType.REPLY
6291  except TTransport.TTransportException:
6292  raise
6293  except TOmniSciException as e:
6294  msg_type = TMessageType.REPLY
6295  result.e = e
6296  except TApplicationException as ex:
6297  logging.exception('TApplication exception in handler')
6298  msg_type = TMessageType.EXCEPTION
6299  result = ex
6300  except Exception:
6301  logging.exception('Unexpected exception in handler')
6302  msg_type = TMessageType.EXCEPTION
6303  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6304  oprot.writeMessageBegin("create_table", msg_type, seqid)
6305  result.write(oprot)
6306  oprot.writeMessageEnd()
6307  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_deallocate_df (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5502 of file OmniSci.py.

5503  def process_deallocate_df(self, seqid, iprot, oprot):
5504  args = deallocate_df_args()
5505  args.read(iprot)
5506  iprot.readMessageEnd()
5507  result = deallocate_df_result()
5508  try:
5509  self._handler.deallocate_df(args.session, args.df, args.device_type, args.device_id)
5510  msg_type = TMessageType.REPLY
5511  except TTransport.TTransportException:
5512  raise
5513  except TOmniSciException as e:
5514  msg_type = TMessageType.REPLY
5515  result.e = e
5516  except TApplicationException as ex:
5517  logging.exception('TApplication exception in handler')
5518  msg_type = TMessageType.EXCEPTION
5519  result = ex
5520  except Exception:
5521  logging.exception('Unexpected exception in handler')
5522  msg_type = TMessageType.EXCEPTION
5523  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5524  oprot.writeMessageBegin("deallocate_df", msg_type, seqid)
5525  result.write(oprot)
5526  oprot.writeMessageEnd()
5527  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_delete_custom_expressions (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5762 of file OmniSci.py.

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

Definition at line 5892 of file OmniSci.py.

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

Definition at line 5944 of file OmniSci.py.

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

Definition at line 6256 of file OmniSci.py.

6257  def process_detect_column_types(self, seqid, iprot, oprot):
6258  args = detect_column_types_args()
6259  args.read(iprot)
6260  iprot.readMessageEnd()
6261  result = detect_column_types_result()
6262  try:
6263  result.success = self._handler.detect_column_types(args.session, args.file_name, args.copy_params)
6264  msg_type = TMessageType.REPLY
6265  except TTransport.TTransportException:
6266  raise
6267  except TOmniSciException as e:
6268  msg_type = TMessageType.REPLY
6269  result.e = e
6270  except TApplicationException as ex:
6271  logging.exception('TApplication exception in handler')
6272  msg_type = TMessageType.EXCEPTION
6273  result = ex
6274  except Exception:
6275  logging.exception('Unexpected exception in handler')
6276  msg_type = TMessageType.EXCEPTION
6277  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6278  oprot.writeMessageBegin("detect_column_types", msg_type, seqid)
6279  result.write(oprot)
6280  oprot.writeMessageEnd()
6281  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_disconnect (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4578 of file OmniSci.py.

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

Definition at line 6620 of file OmniSci.py.

6621  def process_execute_next_render_step(self, seqid, iprot, oprot):
6623  args.read(iprot)
6624  iprot.readMessageEnd()
6626  try:
6627  result.success = self._handler.execute_next_render_step(args.pending_render, args.merged_data)
6628  msg_type = TMessageType.REPLY
6629  except TTransport.TTransportException:
6630  raise
6631  except TOmniSciException as e:
6632  msg_type = TMessageType.REPLY
6633  result.e = e
6634  except TApplicationException as ex:
6635  logging.exception('TApplication exception in handler')
6636  msg_type = TMessageType.EXCEPTION
6637  result = ex
6638  except Exception:
6639  logging.exception('Unexpected exception in handler')
6640  msg_type = TMessageType.EXCEPTION
6641  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6642  oprot.writeMessageBegin("execute_next_render_step", msg_type, seqid)
6643  result.write(oprot)
6644  oprot.writeMessageEnd()
6645  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_execute_query_step (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6542 of file OmniSci.py.

6543  def process_execute_query_step(self, seqid, iprot, oprot):
6544  args = execute_query_step_args()
6545  args.read(iprot)
6546  iprot.readMessageEnd()
6547  result = execute_query_step_result()
6548  try:
6549  result.success = self._handler.execute_query_step(args.pending_query, args.subquery_id, args.start_time_str)
6550  msg_type = TMessageType.REPLY
6551  except TTransport.TTransportException:
6552  raise
6553  except TOmniSciException as e:
6554  msg_type = TMessageType.REPLY
6555  result.e = e
6556  except TApplicationException as ex:
6557  logging.exception('TApplication exception in handler')
6558  msg_type = TMessageType.EXCEPTION
6559  result = ex
6560  except Exception:
6561  logging.exception('Unexpected exception in handler')
6562  msg_type = TMessageType.EXCEPTION
6563  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6564  oprot.writeMessageBegin("execute_query_step", msg_type, seqid)
6565  result.write(oprot)
6566  oprot.writeMessageEnd()
6567  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_all_files_in_archive (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6412 of file OmniSci.py.

6413  def process_get_all_files_in_archive(self, seqid, iprot, oprot):
6415  args.read(iprot)
6416  iprot.readMessageEnd()
6418  try:
6419  result.success = self._handler.get_all_files_in_archive(args.session, args.archive_path, args.copy_params)
6420  msg_type = TMessageType.REPLY
6421  except TTransport.TTransportException:
6422  raise
6423  except TOmniSciException as e:
6424  msg_type = TMessageType.REPLY
6425  result.e = e
6426  except TApplicationException as ex:
6427  logging.exception('TApplication exception in handler')
6428  msg_type = TMessageType.EXCEPTION
6429  result = ex
6430  except Exception:
6431  logging.exception('Unexpected exception in handler')
6432  msg_type = TMessageType.EXCEPTION
6433  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6434  oprot.writeMessageBegin("get_all_files_in_archive", msg_type, seqid)
6435  result.write(oprot)
6436  oprot.writeMessageEnd()
6437  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_all_roles_for_user (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6776 of file OmniSci.py.

6777  def process_get_all_roles_for_user(self, seqid, iprot, oprot):
6779  args.read(iprot)
6780  iprot.readMessageEnd()
6782  try:
6783  result.success = self._handler.get_all_roles_for_user(args.session, args.userName)
6784  msg_type = TMessageType.REPLY
6785  except TTransport.TTransportException:
6786  raise
6787  except TOmniSciException as e:
6788  msg_type = TMessageType.REPLY
6789  result.e = e
6790  except TApplicationException as ex:
6791  logging.exception('TApplication exception in handler')
6792  msg_type = TMessageType.EXCEPTION
6793  result = ex
6794  except Exception:
6795  logging.exception('Unexpected exception in handler')
6796  msg_type = TMessageType.EXCEPTION
6797  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6798  oprot.writeMessageBegin("get_all_roles_for_user", msg_type, seqid)
6799  result.write(oprot)
6800  oprot.writeMessageEnd()
6801  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_completion_hints (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5580 of file OmniSci.py.

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

Definition at line 5710 of file OmniSci.py.

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

Definition at line 5788 of file OmniSci.py.

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

Definition at line 6048 of file OmniSci.py.

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

Definition at line 5814 of file OmniSci.py.

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

Definition at line 4994 of file OmniSci.py.

4995  def process_get_databases(self, seqid, iprot, oprot):
4996  args = get_databases_args()
4997  args.read(iprot)
4998  iprot.readMessageEnd()
4999  result = get_databases_result()
5000  try:
5001  result.success = self._handler.get_databases(args.session)
5002  msg_type = TMessageType.REPLY
5003  except TTransport.TTransportException:
5004  raise
5005  except TOmniSciException as e:
5006  msg_type = TMessageType.REPLY
5007  result.e = e
5008  except TApplicationException as ex:
5009  logging.exception('TApplication exception in handler')
5010  msg_type = TMessageType.EXCEPTION
5011  result = ex
5012  except Exception:
5013  logging.exception('Unexpected exception in handler')
5014  msg_type = TMessageType.EXCEPTION
5015  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5016  oprot.writeMessageBegin("get_databases", msg_type, seqid)
5017  result.write(oprot)
5018  oprot.writeMessageEnd()
5019  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_db_object_privs (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6750 of file OmniSci.py.

6751  def process_get_db_object_privs(self, seqid, iprot, oprot):
6752  args = get_db_object_privs_args()
6753  args.read(iprot)
6754  iprot.readMessageEnd()
6755  result = get_db_object_privs_result()
6756  try:
6757  result.success = self._handler.get_db_object_privs(args.session, args.objectName, args.type)
6758  msg_type = TMessageType.REPLY
6759  except TTransport.TTransportException:
6760  raise
6761  except TOmniSciException as e:
6762  msg_type = TMessageType.REPLY
6763  result.e = e
6764  except TApplicationException as ex:
6765  logging.exception('TApplication exception in handler')
6766  msg_type = TMessageType.EXCEPTION
6767  result = ex
6768  except Exception:
6769  logging.exception('Unexpected exception in handler')
6770  msg_type = TMessageType.EXCEPTION
6771  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6772  oprot.writeMessageBegin("get_db_object_privs", msg_type, seqid)
6773  result.write(oprot)
6774  oprot.writeMessageEnd()
6775  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_db_objects_for_grantee (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6724 of file OmniSci.py.

6725  def process_get_db_objects_for_grantee(self, seqid, iprot, oprot):
6727  args.read(iprot)
6728  iprot.readMessageEnd()
6730  try:
6731  result.success = self._handler.get_db_objects_for_grantee(args.session, args.roleName)
6732  msg_type = TMessageType.REPLY
6733  except TTransport.TTransportException:
6734  raise
6735  except TOmniSciException as e:
6736  msg_type = TMessageType.REPLY
6737  result.e = e
6738  except TApplicationException as ex:
6739  logging.exception('TApplication exception in handler')
6740  msg_type = TMessageType.EXCEPTION
6741  result = ex
6742  except Exception:
6743  logging.exception('Unexpected exception in handler')
6744  msg_type = TMessageType.EXCEPTION
6745  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6746  oprot.writeMessageBegin("get_db_objects_for_grantee", msg_type, seqid)
6747  result.write(oprot)
6748  oprot.writeMessageEnd()
6749  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_device_parameters (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6906 of file OmniSci.py.

6907  def process_get_device_parameters(self, seqid, iprot, oprot):
6909  args.read(iprot)
6910  iprot.readMessageEnd()
6911  result = get_device_parameters_result()
6912  try:
6913  result.success = self._handler.get_device_parameters(args.session)
6914  msg_type = TMessageType.REPLY
6915  except TTransport.TTransportException:
6916  raise
6917  except TOmniSciException as e:
6918  msg_type = TMessageType.REPLY
6919  result.e = e
6920  except TApplicationException as ex:
6921  logging.exception('TApplication exception in handler')
6922  msg_type = TMessageType.EXCEPTION
6923  result = ex
6924  except Exception:
6925  logging.exception('Unexpected exception in handler')
6926  msg_type = TMessageType.EXCEPTION
6927  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6928  oprot.writeMessageBegin("get_device_parameters", msg_type, seqid)
6929  result.write(oprot)
6930  oprot.writeMessageEnd()
6931  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_first_geo_file_in_archive (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6386 of file OmniSci.py.

6387  def process_get_first_geo_file_in_archive(self, seqid, iprot, oprot):
6389  args.read(iprot)
6390  iprot.readMessageEnd()
6392  try:
6393  result.success = self._handler.get_first_geo_file_in_archive(args.session, args.archive_path, args.copy_params)
6394  msg_type = TMessageType.REPLY
6395  except TTransport.TTransportException:
6396  raise
6397  except TOmniSciException as e:
6398  msg_type = TMessageType.REPLY
6399  result.e = e
6400  except TApplicationException as ex:
6401  logging.exception('TApplication exception in handler')
6402  msg_type = TMessageType.EXCEPTION
6403  result = ex
6404  except Exception:
6405  logging.exception('Unexpected exception in handler')
6406  msg_type = TMessageType.EXCEPTION
6407  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6408  oprot.writeMessageBegin("get_first_geo_file_in_archive", msg_type, seqid)
6409  result.write(oprot)
6410  oprot.writeMessageEnd()
6411  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_hardware_info (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4708 of file OmniSci.py.

4709  def process_get_hardware_info(self, seqid, iprot, oprot):
4710  args = get_hardware_info_args()
4711  args.read(iprot)
4712  iprot.readMessageEnd()
4713  result = get_hardware_info_result()
4714  try:
4715  result.success = self._handler.get_hardware_info(args.session)
4716  msg_type = TMessageType.REPLY
4717  except TTransport.TTransportException:
4718  raise
4719  except TOmniSciException as e:
4720  msg_type = TMessageType.REPLY
4721  result.e = e
4722  except TApplicationException as ex:
4723  logging.exception('TApplication exception in handler')
4724  msg_type = TMessageType.EXCEPTION
4725  result = ex
4726  except Exception:
4727  logging.exception('Unexpected exception in handler')
4728  msg_type = TMessageType.EXCEPTION
4729  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4730  oprot.writeMessageBegin("get_hardware_info", msg_type, seqid)
4731  result.write(oprot)
4732  oprot.writeMessageEnd()
4733  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_heap_profile (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5098 of file OmniSci.py.

5099  def process_get_heap_profile(self, seqid, iprot, oprot):
5100  args = get_heap_profile_args()
5101  args.read(iprot)
5102  iprot.readMessageEnd()
5103  result = get_heap_profile_result()
5104  try:
5105  result.success = self._handler.get_heap_profile(args.session)
5106  msg_type = TMessageType.REPLY
5107  except TTransport.TTransportException:
5108  raise
5109  except TOmniSciException as e:
5110  msg_type = TMessageType.REPLY
5111  result.e = e
5112  except TApplicationException as ex:
5113  logging.exception('TApplication exception in handler')
5114  msg_type = TMessageType.EXCEPTION
5115  result = ex
5116  except Exception:
5117  logging.exception('Unexpected exception in handler')
5118  msg_type = TMessageType.EXCEPTION
5119  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5120  oprot.writeMessageBegin("get_heap_profile", msg_type, seqid)
5121  result.write(oprot)
5122  oprot.writeMessageEnd()
5123  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_internal_table_details (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4916 of file OmniSci.py.

4917  def process_get_internal_table_details(self, seqid, iprot, oprot):
4919  args.read(iprot)
4920  iprot.readMessageEnd()
4922  try:
4923  result.success = self._handler.get_internal_table_details(args.session, args.table_name)
4924  msg_type = TMessageType.REPLY
4925  except TTransport.TTransportException:
4926  raise
4927  except TOmniSciException as e:
4928  msg_type = TMessageType.REPLY
4929  result.e = e
4930  except TApplicationException as ex:
4931  logging.exception('TApplication exception in handler')
4932  msg_type = TMessageType.EXCEPTION
4933  result = ex
4934  except Exception:
4935  logging.exception('Unexpected exception in handler')
4936  msg_type = TMessageType.EXCEPTION
4937  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4938  oprot.writeMessageBegin("get_internal_table_details", msg_type, seqid)
4939  result.write(oprot)
4940  oprot.writeMessageEnd()
4941  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_internal_table_details_for_database (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4942 of file OmniSci.py.

4943  def process_get_internal_table_details_for_database(self, seqid, iprot, oprot):
4945  args.read(iprot)
4946  iprot.readMessageEnd()
4948  try:
4949  result.success = self._handler.get_internal_table_details_for_database(args.session, args.table_name, args.database_name)
4950  msg_type = TMessageType.REPLY
4951  except TTransport.TTransportException:
4952  raise
4953  except TOmniSciException as e:
4954  msg_type = TMessageType.REPLY
4955  result.e = e
4956  except TApplicationException as ex:
4957  logging.exception('TApplication exception in handler')
4958  msg_type = TMessageType.EXCEPTION
4959  result = ex
4960  except Exception:
4961  logging.exception('Unexpected exception in handler')
4962  msg_type = TMessageType.EXCEPTION
4963  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4964  oprot.writeMessageBegin("get_internal_table_details_for_database", msg_type, seqid)
4965  result.write(oprot)
4966  oprot.writeMessageEnd()
4967  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_layers_in_geo_file (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6438 of file OmniSci.py.

6439  def process_get_layers_in_geo_file(self, seqid, iprot, oprot):
6441  args.read(iprot)
6442  iprot.readMessageEnd()
6444  try:
6445  result.success = self._handler.get_layers_in_geo_file(args.session, args.file_name, args.copy_params)
6446  msg_type = TMessageType.REPLY
6447  except TTransport.TTransportException:
6448  raise
6449  except TOmniSciException as e:
6450  msg_type = TMessageType.REPLY
6451  result.e = e
6452  except TApplicationException as ex:
6453  logging.exception('TApplication exception in handler')
6454  msg_type = TMessageType.EXCEPTION
6455  result = ex
6456  except Exception:
6457  logging.exception('Unexpected exception in handler')
6458  msg_type = TMessageType.EXCEPTION
6459  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6460  oprot.writeMessageBegin("get_layers_in_geo_file", msg_type, seqid)
6461  result.write(oprot)
6462  oprot.writeMessageEnd()
6463  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_license_claims (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6880 of file OmniSci.py.

6881  def process_get_license_claims(self, seqid, iprot, oprot):
6882  args = get_license_claims_args()
6883  args.read(iprot)
6884  iprot.readMessageEnd()
6885  result = get_license_claims_result()
6886  try:
6887  result.success = self._handler.get_license_claims(args.session, args.nonce)
6888  msg_type = TMessageType.REPLY
6889  except TTransport.TTransportException:
6890  raise
6891  except TOmniSciException as e:
6892  msg_type = TMessageType.REPLY
6893  result.e = e
6894  except TApplicationException as ex:
6895  logging.exception('TApplication exception in handler')
6896  msg_type = TMessageType.EXCEPTION
6897  result = ex
6898  except Exception:
6899  logging.exception('Unexpected exception in handler')
6900  msg_type = TMessageType.EXCEPTION
6901  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6902  oprot.writeMessageBegin("get_license_claims", msg_type, seqid)
6903  result.write(oprot)
6904  oprot.writeMessageEnd()
6905  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_link_view (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6074 of file OmniSci.py.

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

Definition at line 5124 of file OmniSci.py.

5125  def process_get_memory(self, seqid, iprot, oprot):
5126  args = get_memory_args()
5127  args.read(iprot)
5128  iprot.readMessageEnd()
5129  result = get_memory_result()
5130  try:
5131  result.success = self._handler.get_memory(args.session, args.memory_level)
5132  msg_type = TMessageType.REPLY
5133  except TTransport.TTransportException:
5134  raise
5135  except TOmniSciException as e:
5136  msg_type = TMessageType.REPLY
5137  result.e = e
5138  except TApplicationException as ex:
5139  logging.exception('TApplication exception in handler')
5140  msg_type = TMessageType.EXCEPTION
5141  result = ex
5142  except Exception:
5143  logging.exception('Unexpected exception in handler')
5144  msg_type = TMessageType.EXCEPTION
5145  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5146  oprot.writeMessageBegin("get_memory", msg_type, seqid)
5147  result.write(oprot)
5148  oprot.writeMessageEnd()
5149  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_physical_tables (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4786 of file OmniSci.py.

4787  def process_get_physical_tables(self, seqid, iprot, oprot):
4788  args = get_physical_tables_args()
4789  args.read(iprot)
4790  iprot.readMessageEnd()
4791  result = get_physical_tables_result()
4792  try:
4793  result.success = self._handler.get_physical_tables(args.session)
4794  msg_type = TMessageType.REPLY
4795  except TTransport.TTransportException:
4796  raise
4797  except TOmniSciException as e:
4798  msg_type = TMessageType.REPLY
4799  result.e = e
4800  except TApplicationException as ex:
4801  logging.exception('TApplication exception in handler')
4802  msg_type = TMessageType.EXCEPTION
4803  result = ex
4804  except Exception:
4805  logging.exception('Unexpected exception in handler')
4806  msg_type = TMessageType.EXCEPTION
4807  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4808  oprot.writeMessageBegin("get_physical_tables", msg_type, seqid)
4809  result.write(oprot)
4810  oprot.writeMessageEnd()
4811  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_result_row_for_pixel (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5658 of file OmniSci.py.

5659  def process_get_result_row_for_pixel(self, seqid, iprot, oprot):
5661  args.read(iprot)
5662  iprot.readMessageEnd()
5664  try:
5665  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)
5666  msg_type = TMessageType.REPLY
5667  except TTransport.TTransportException:
5668  raise
5669  except TOmniSciException as e:
5670  msg_type = TMessageType.REPLY
5671  result.e = e
5672  except TApplicationException as ex:
5673  logging.exception('TApplication exception in handler')
5674  msg_type = TMessageType.EXCEPTION
5675  result = ex
5676  except Exception:
5677  logging.exception('Unexpected exception in handler')
5678  msg_type = TMessageType.EXCEPTION
5679  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5680  oprot.writeMessageBegin("get_result_row_for_pixel", msg_type, seqid)
5681  result.write(oprot)
5682  oprot.writeMessageEnd()
5683  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_roles (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6698 of file OmniSci.py.

6699  def process_get_roles(self, seqid, iprot, oprot):
6700  args = get_roles_args()
6701  args.read(iprot)
6702  iprot.readMessageEnd()
6703  result = get_roles_result()
6704  try:
6705  result.success = self._handler.get_roles(args.session)
6706  msg_type = TMessageType.REPLY
6707  except TTransport.TTransportException:
6708  raise
6709  except TOmniSciException as e:
6710  msg_type = TMessageType.REPLY
6711  result.e = e
6712  except TApplicationException as ex:
6713  logging.exception('TApplication exception in handler')
6714  msg_type = TMessageType.EXCEPTION
6715  result = ex
6716  except Exception:
6717  logging.exception('Unexpected exception in handler')
6718  msg_type = TMessageType.EXCEPTION
6719  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6720  oprot.writeMessageBegin("get_roles", msg_type, seqid)
6721  result.write(oprot)
6722  oprot.writeMessageEnd()
6723  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_server_status (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4656 of file OmniSci.py.

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

Definition at line 5398 of file OmniSci.py.

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

Definition at line 4682 of file OmniSci.py.

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

Definition at line 4864 of file OmniSci.py.

4865  def process_get_table_details(self, seqid, iprot, oprot):
4866  args = get_table_details_args()
4867  args.read(iprot)
4868  iprot.readMessageEnd()
4869  result = get_table_details_result()
4870  try:
4871  result.success = self._handler.get_table_details(args.session, args.table_name)
4872  msg_type = TMessageType.REPLY
4873  except TTransport.TTransportException:
4874  raise
4875  except TOmniSciException as e:
4876  msg_type = TMessageType.REPLY
4877  result.e = e
4878  except TApplicationException as ex:
4879  logging.exception('TApplication exception in handler')
4880  msg_type = TMessageType.EXCEPTION
4881  result = ex
4882  except Exception:
4883  logging.exception('Unexpected exception in handler')
4884  msg_type = TMessageType.EXCEPTION
4885  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4886  oprot.writeMessageBegin("get_table_details", msg_type, seqid)
4887  result.write(oprot)
4888  oprot.writeMessageEnd()
4889  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_table_details_for_database (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4890 of file OmniSci.py.

4891  def process_get_table_details_for_database(self, seqid, iprot, oprot):
4893  args.read(iprot)
4894  iprot.readMessageEnd()
4896  try:
4897  result.success = self._handler.get_table_details_for_database(args.session, args.table_name, args.database_name)
4898  msg_type = TMessageType.REPLY
4899  except TTransport.TTransportException:
4900  raise
4901  except TOmniSciException as e:
4902  msg_type = TMessageType.REPLY
4903  result.e = e
4904  except TApplicationException as ex:
4905  logging.exception('TApplication exception in handler')
4906  msg_type = TMessageType.EXCEPTION
4907  result = ex
4908  except Exception:
4909  logging.exception('Unexpected exception in handler')
4910  msg_type = TMessageType.EXCEPTION
4911  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4912  oprot.writeMessageBegin("get_table_details_for_database", msg_type, seqid)
4913  result.write(oprot)
4914  oprot.writeMessageEnd()
4915  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_table_epoch (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5306 of file OmniSci.py.

5307  def process_get_table_epoch(self, seqid, iprot, oprot):
5308  args = get_table_epoch_args()
5309  args.read(iprot)
5310  iprot.readMessageEnd()
5311  result = get_table_epoch_result()
5312  try:
5313  result.success = self._handler.get_table_epoch(args.session, args.db_id, args.table_id)
5314  msg_type = TMessageType.REPLY
5315  except TTransport.TTransportException:
5316  raise
5317  except TApplicationException as ex:
5318  logging.exception('TApplication exception in handler')
5319  msg_type = TMessageType.EXCEPTION
5320  result = ex
5321  except Exception:
5322  logging.exception('Unexpected exception in handler')
5323  msg_type = TMessageType.EXCEPTION
5324  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5325  oprot.writeMessageBegin("get_table_epoch", msg_type, seqid)
5326  result.write(oprot)
5327  oprot.writeMessageEnd()
5328  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_table_epoch_by_name (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5329 of file OmniSci.py.

5330  def process_get_table_epoch_by_name(self, seqid, iprot, oprot):
5332  args.read(iprot)
5333  iprot.readMessageEnd()
5335  try:
5336  result.success = self._handler.get_table_epoch_by_name(args.session, args.table_name)
5337  msg_type = TMessageType.REPLY
5338  except TTransport.TTransportException:
5339  raise
5340  except TApplicationException as ex:
5341  logging.exception('TApplication exception in handler')
5342  msg_type = TMessageType.EXCEPTION
5343  result = ex
5344  except Exception:
5345  logging.exception('Unexpected exception in handler')
5346  msg_type = TMessageType.EXCEPTION
5347  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5348  oprot.writeMessageBegin("get_table_epoch_by_name", msg_type, seqid)
5349  result.write(oprot)
5350  oprot.writeMessageEnd()
5351  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_table_epochs (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5352 of file OmniSci.py.

5353  def process_get_table_epochs(self, seqid, iprot, oprot):
5354  args = get_table_epochs_args()
5355  args.read(iprot)
5356  iprot.readMessageEnd()
5357  result = get_table_epochs_result()
5358  try:
5359  result.success = self._handler.get_table_epochs(args.session, args.db_id, args.table_id)
5360  msg_type = TMessageType.REPLY
5361  except TTransport.TTransportException:
5362  raise
5363  except TApplicationException as ex:
5364  logging.exception('TApplication exception in handler')
5365  msg_type = TMessageType.EXCEPTION
5366  result = ex
5367  except Exception:
5368  logging.exception('Unexpected exception in handler')
5369  msg_type = TMessageType.EXCEPTION
5370  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5371  oprot.writeMessageBegin("get_table_epochs", msg_type, seqid)
5372  result.write(oprot)
5373  oprot.writeMessageEnd()
5374  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_tables (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4734 of file OmniSci.py.

4735  def process_get_tables(self, seqid, iprot, oprot):
4736  args = get_tables_args()
4737  args.read(iprot)
4738  iprot.readMessageEnd()
4739  result = get_tables_result()
4740  try:
4741  result.success = self._handler.get_tables(args.session)
4742  msg_type = TMessageType.REPLY
4743  except TTransport.TTransportException:
4744  raise
4745  except TOmniSciException as e:
4746  msg_type = TMessageType.REPLY
4747  result.e = e
4748  except TApplicationException as ex:
4749  logging.exception('TApplication exception in handler')
4750  msg_type = TMessageType.EXCEPTION
4751  result = ex
4752  except Exception:
4753  logging.exception('Unexpected exception in handler')
4754  msg_type = TMessageType.EXCEPTION
4755  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4756  oprot.writeMessageBegin("get_tables", msg_type, seqid)
4757  result.write(oprot)
4758  oprot.writeMessageEnd()
4759  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_tables_for_database (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4760 of file OmniSci.py.

4761  def process_get_tables_for_database(self, seqid, iprot, oprot):
4763  args.read(iprot)
4764  iprot.readMessageEnd()
4766  try:
4767  result.success = self._handler.get_tables_for_database(args.session, args.database_name)
4768  msg_type = TMessageType.REPLY
4769  except TTransport.TTransportException:
4770  raise
4771  except TOmniSciException as e:
4772  msg_type = TMessageType.REPLY
4773  result.e = e
4774  except TApplicationException as ex:
4775  logging.exception('TApplication exception in handler')
4776  msg_type = TMessageType.EXCEPTION
4777  result = ex
4778  except Exception:
4779  logging.exception('Unexpected exception in handler')
4780  msg_type = TMessageType.EXCEPTION
4781  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4782  oprot.writeMessageBegin("get_tables_for_database", msg_type, seqid)
4783  result.write(oprot)
4784  oprot.writeMessageEnd()
4785  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_tables_meta (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4838 of file OmniSci.py.

4839  def process_get_tables_meta(self, seqid, iprot, oprot):
4840  args = get_tables_meta_args()
4841  args.read(iprot)
4842  iprot.readMessageEnd()
4843  result = get_tables_meta_result()
4844  try:
4845  result.success = self._handler.get_tables_meta(args.session)
4846  msg_type = TMessageType.REPLY
4847  except TTransport.TTransportException:
4848  raise
4849  except TOmniSciException as e:
4850  msg_type = TMessageType.REPLY
4851  result.e = e
4852  except TApplicationException as ex:
4853  logging.exception('TApplication exception in handler')
4854  msg_type = TMessageType.EXCEPTION
4855  result = ex
4856  except Exception:
4857  logging.exception('Unexpected exception in handler')
4858  msg_type = TMessageType.EXCEPTION
4859  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4860  oprot.writeMessageBegin("get_tables_meta", msg_type, seqid)
4861  result.write(oprot)
4862  oprot.writeMessageEnd()
4863  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_users (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4968 of file OmniSci.py.

4969  def process_get_users(self, seqid, iprot, oprot):
4970  args = get_users_args()
4971  args.read(iprot)
4972  iprot.readMessageEnd()
4973  result = get_users_result()
4974  try:
4975  result.success = self._handler.get_users(args.session)
4976  msg_type = TMessageType.REPLY
4977  except TTransport.TTransportException:
4978  raise
4979  except TOmniSciException as e:
4980  msg_type = TMessageType.REPLY
4981  result.e = e
4982  except TApplicationException as ex:
4983  logging.exception('TApplication exception in handler')
4984  msg_type = TMessageType.EXCEPTION
4985  result = ex
4986  except Exception:
4987  logging.exception('Unexpected exception in handler')
4988  msg_type = TMessageType.EXCEPTION
4989  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4990  oprot.writeMessageBegin("get_users", msg_type, seqid)
4991  result.write(oprot)
4992  oprot.writeMessageEnd()
4993  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_version (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5020 of file OmniSci.py.

5021  def process_get_version(self, seqid, iprot, oprot):
5022  args = get_version_args()
5023  args.read(iprot)
5024  iprot.readMessageEnd()
5025  result = get_version_result()
5026  try:
5027  result.success = self._handler.get_version()
5028  msg_type = TMessageType.REPLY
5029  except TTransport.TTransportException:
5030  raise
5031  except TOmniSciException as e:
5032  msg_type = TMessageType.REPLY
5033  result.e = e
5034  except TApplicationException as ex:
5035  logging.exception('TApplication exception in handler')
5036  msg_type = TMessageType.EXCEPTION
5037  result = ex
5038  except Exception:
5039  logging.exception('Unexpected exception in handler')
5040  msg_type = TMessageType.EXCEPTION
5041  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5042  oprot.writeMessageBegin("get_version", msg_type, seqid)
5043  result.write(oprot)
5044  oprot.writeMessageEnd()
5045  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_get_views (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4812 of file OmniSci.py.

4813  def process_get_views(self, seqid, iprot, oprot):
4814  args = get_views_args()
4815  args.read(iprot)
4816  iprot.readMessageEnd()
4817  result = get_views_result()
4818  try:
4819  result.success = self._handler.get_views(args.session)
4820  msg_type = TMessageType.REPLY
4821  except TTransport.TTransportException:
4822  raise
4823  except TOmniSciException as e:
4824  msg_type = TMessageType.REPLY
4825  result.e = e
4826  except TApplicationException as ex:
4827  logging.exception('TApplication exception in handler')
4828  msg_type = TMessageType.EXCEPTION
4829  result = ex
4830  except Exception:
4831  logging.exception('Unexpected exception in handler')
4832  msg_type = TMessageType.EXCEPTION
4833  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4834  oprot.writeMessageBegin("get_views", msg_type, seqid)
4835  result.write(oprot)
4836  oprot.writeMessageEnd()
4837  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_has_object_privilege (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6828 of file OmniSci.py.

6829  def process_has_object_privilege(self, seqid, iprot, oprot):
6830  args = has_object_privilege_args()
6831  args.read(iprot)
6832  iprot.readMessageEnd()
6833  result = has_object_privilege_result()
6834  try:
6835  result.success = self._handler.has_object_privilege(args.session, args.granteeName, args.ObjectName, args.objectType, args.permissions)
6836  msg_type = TMessageType.REPLY
6837  except TTransport.TTransportException:
6838  raise
6839  except TOmniSciException as e:
6840  msg_type = TMessageType.REPLY
6841  result.e = e
6842  except TApplicationException as ex:
6843  logging.exception('TApplication exception in handler')
6844  msg_type = TMessageType.EXCEPTION
6845  result = ex
6846  except Exception:
6847  logging.exception('Unexpected exception in handler')
6848  msg_type = TMessageType.EXCEPTION
6849  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6850  oprot.writeMessageBegin("has_object_privilege", msg_type, seqid)
6851  result.write(oprot)
6852  oprot.writeMessageEnd()
6853  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_has_role (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6802 of file OmniSci.py.

6803  def process_has_role(self, seqid, iprot, oprot):
6804  args = has_role_args()
6805  args.read(iprot)
6806  iprot.readMessageEnd()
6807  result = has_role_result()
6808  try:
6809  result.success = self._handler.has_role(args.session, args.granteeName, args.roleName)
6810  msg_type = TMessageType.REPLY
6811  except TTransport.TTransportException:
6812  raise
6813  except TOmniSciException as e:
6814  msg_type = TMessageType.REPLY
6815  result.e = e
6816  except TApplicationException as ex:
6817  logging.exception('TApplication exception in handler')
6818  msg_type = TMessageType.EXCEPTION
6819  result = ex
6820  except Exception:
6821  logging.exception('Unexpected exception in handler')
6822  msg_type = TMessageType.EXCEPTION
6823  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6824  oprot.writeMessageBegin("has_role", msg_type, seqid)
6825  result.write(oprot)
6826  oprot.writeMessageEnd()
6827  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_import_geo_table (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6334 of file OmniSci.py.

6335  def process_import_geo_table(self, seqid, iprot, oprot):
6336  args = import_geo_table_args()
6337  args.read(iprot)
6338  iprot.readMessageEnd()
6339  result = import_geo_table_result()
6340  try:
6341  self._handler.import_geo_table(args.session, args.table_name, args.file_name, args.copy_params, args.row_desc, args.create_params)
6342  msg_type = TMessageType.REPLY
6343  except TTransport.TTransportException:
6344  raise
6345  except TOmniSciException as e:
6346  msg_type = TMessageType.REPLY
6347  result.e = e
6348  except TApplicationException as ex:
6349  logging.exception('TApplication exception in handler')
6350  msg_type = TMessageType.EXCEPTION
6351  result = ex
6352  except Exception:
6353  logging.exception('Unexpected exception in handler')
6354  msg_type = TMessageType.EXCEPTION
6355  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6356  oprot.writeMessageBegin("import_geo_table", msg_type, seqid)
6357  result.write(oprot)
6358  oprot.writeMessageEnd()
6359  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_import_table (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6308 of file OmniSci.py.

6309  def process_import_table(self, seqid, iprot, oprot):
6310  args = import_table_args()
6311  args.read(iprot)
6312  iprot.readMessageEnd()
6313  result = import_table_result()
6314  try:
6315  self._handler.import_table(args.session, args.table_name, args.file_name, args.copy_params)
6316  msg_type = TMessageType.REPLY
6317  except TTransport.TTransportException:
6318  raise
6319  except TOmniSciException as e:
6320  msg_type = TMessageType.REPLY
6321  result.e = e
6322  except TApplicationException as ex:
6323  logging.exception('TApplication exception in handler')
6324  msg_type = TMessageType.EXCEPTION
6325  result = ex
6326  except Exception:
6327  logging.exception('Unexpected exception in handler')
6328  msg_type = TMessageType.EXCEPTION
6329  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6330  oprot.writeMessageBegin("import_table", msg_type, seqid)
6331  result.write(oprot)
6332  oprot.writeMessageEnd()
6333  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_import_table_status (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6360 of file OmniSci.py.

6361  def process_import_table_status(self, seqid, iprot, oprot):
6362  args = import_table_status_args()
6363  args.read(iprot)
6364  iprot.readMessageEnd()
6365  result = import_table_status_result()
6366  try:
6367  result.success = self._handler.import_table_status(args.session, args.import_id)
6368  msg_type = TMessageType.REPLY
6369  except TTransport.TTransportException:
6370  raise
6371  except TOmniSciException as e:
6372  msg_type = TMessageType.REPLY
6373  result.e = e
6374  except TApplicationException as ex:
6375  logging.exception('TApplication exception in handler')
6376  msg_type = TMessageType.EXCEPTION
6377  result = ex
6378  except Exception:
6379  logging.exception('Unexpected exception in handler')
6380  msg_type = TMessageType.EXCEPTION
6381  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6382  oprot.writeMessageBegin("import_table_status", msg_type, seqid)
6383  result.write(oprot)
6384  oprot.writeMessageEnd()
6385  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_insert_data (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6646 of file OmniSci.py.

6647  def process_insert_data(self, seqid, iprot, oprot):
6648  args = insert_data_args()
6649  args.read(iprot)
6650  iprot.readMessageEnd()
6651  result = insert_data_result()
6652  try:
6653  self._handler.insert_data(args.session, args.insert_data)
6654  msg_type = TMessageType.REPLY
6655  except TTransport.TTransportException:
6656  raise
6657  except TOmniSciException as e:
6658  msg_type = TMessageType.REPLY
6659  result.e = e
6660  except TApplicationException as ex:
6661  logging.exception('TApplication exception in handler')
6662  msg_type = TMessageType.EXCEPTION
6663  result = ex
6664  except Exception:
6665  logging.exception('Unexpected exception in handler')
6666  msg_type = TMessageType.EXCEPTION
6667  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6668  oprot.writeMessageBegin("insert_data", msg_type, seqid)
6669  result.write(oprot)
6670  oprot.writeMessageEnd()
6671  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_interrupt (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5528 of file OmniSci.py.

5529  def process_interrupt(self, seqid, iprot, oprot):
5530  args = interrupt_args()
5531  args.read(iprot)
5532  iprot.readMessageEnd()
5533  result = interrupt_result()
5534  try:
5535  self._handler.interrupt(args.query_session, args.interrupt_session)
5536  msg_type = TMessageType.REPLY
5537  except TTransport.TTransportException:
5538  raise
5539  except TOmniSciException as e:
5540  msg_type = TMessageType.REPLY
5541  result.e = e
5542  except TApplicationException as ex:
5543  logging.exception('TApplication exception in handler')
5544  msg_type = TMessageType.EXCEPTION
5545  result = ex
5546  except Exception:
5547  logging.exception('Unexpected exception in handler')
5548  msg_type = TMessageType.EXCEPTION
5549  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5550  oprot.writeMessageBegin("interrupt", msg_type, seqid)
5551  result.write(oprot)
5552  oprot.writeMessageEnd()
5553  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_invalidate_cur_session (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5228 of file OmniSci.py.

5229  def process_invalidate_cur_session(self, seqid, iprot, oprot):
5231  args.read(iprot)
5232  iprot.readMessageEnd()
5234  try:
5235  self._handler.invalidate_cur_session(args.parent_session, args.leaf_session, args.start_time_str, args.label, args.for_running_query_kernel)
5236  msg_type = TMessageType.REPLY
5237  except TTransport.TTransportException:
5238  raise
5239  except TOmniSciException as e:
5240  msg_type = TMessageType.REPLY
5241  result.e = e
5242  except TApplicationException as ex:
5243  logging.exception('TApplication exception in handler')
5244  msg_type = TMessageType.EXCEPTION
5245  result = ex
5246  except Exception:
5247  logging.exception('Unexpected exception in handler')
5248  msg_type = TMessageType.EXCEPTION
5249  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5250  oprot.writeMessageBegin("invalidate_cur_session", msg_type, seqid)
5251  result.write(oprot)
5252  oprot.writeMessageEnd()
5253  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_krb5_connect (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4552 of file OmniSci.py.

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

Definition at line 6230 of file OmniSci.py.

6231  def process_load_table(self, seqid, iprot, oprot):
6232  args = load_table_args()
6233  args.read(iprot)
6234  iprot.readMessageEnd()
6235  result = load_table_result()
6236  try:
6237  self._handler.load_table(args.session, args.table_name, args.rows, args.column_names)
6238  msg_type = TMessageType.REPLY
6239  except TTransport.TTransportException:
6240  raise
6241  except TOmniSciException as e:
6242  msg_type = TMessageType.REPLY
6243  result.e = e
6244  except TApplicationException as ex:
6245  logging.exception('TApplication exception in handler')
6246  msg_type = TMessageType.EXCEPTION
6247  result = ex
6248  except Exception:
6249  logging.exception('Unexpected exception in handler')
6250  msg_type = TMessageType.EXCEPTION
6251  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6252  oprot.writeMessageBegin("load_table", msg_type, seqid)
6253  result.write(oprot)
6254  oprot.writeMessageEnd()
6255  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_load_table_binary (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6126 of file OmniSci.py.

6127  def process_load_table_binary(self, seqid, iprot, oprot):
6128  args = load_table_binary_args()
6129  args.read(iprot)
6130  iprot.readMessageEnd()
6131  result = load_table_binary_result()
6132  try:
6133  self._handler.load_table_binary(args.session, args.table_name, args.rows, args.column_names)
6134  msg_type = TMessageType.REPLY
6135  except TTransport.TTransportException:
6136  raise
6137  except TOmniSciException as e:
6138  msg_type = TMessageType.REPLY
6139  result.e = e
6140  except TApplicationException as ex:
6141  logging.exception('TApplication exception in handler')
6142  msg_type = TMessageType.EXCEPTION
6143  result = ex
6144  except Exception:
6145  logging.exception('Unexpected exception in handler')
6146  msg_type = TMessageType.EXCEPTION
6147  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6148  oprot.writeMessageBegin("load_table_binary", msg_type, seqid)
6149  result.write(oprot)
6150  oprot.writeMessageEnd()
6151  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_load_table_binary_arrow (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6204 of file OmniSci.py.

6205  def process_load_table_binary_arrow(self, seqid, iprot, oprot):
6207  args.read(iprot)
6208  iprot.readMessageEnd()
6210  try:
6211  self._handler.load_table_binary_arrow(args.session, args.table_name, args.arrow_stream, args.use_column_names)
6212  msg_type = TMessageType.REPLY
6213  except TTransport.TTransportException:
6214  raise
6215  except TOmniSciException as e:
6216  msg_type = TMessageType.REPLY
6217  result.e = e
6218  except TApplicationException as ex:
6219  logging.exception('TApplication exception in handler')
6220  msg_type = TMessageType.EXCEPTION
6221  result = ex
6222  except Exception:
6223  logging.exception('Unexpected exception in handler')
6224  msg_type = TMessageType.EXCEPTION
6225  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6226  oprot.writeMessageBegin("load_table_binary_arrow", msg_type, seqid)
6227  result.write(oprot)
6228  oprot.writeMessageEnd()
6229  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_load_table_binary_columnar (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6152 of file OmniSci.py.

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

Definition at line 6178 of file OmniSci.py.

6179  def process_load_table_binary_columnar_polys(self, seqid, iprot, oprot):
6181  args.read(iprot)
6182  iprot.readMessageEnd()
6184  try:
6185  self._handler.load_table_binary_columnar_polys(args.session, args.table_name, args.cols, args.column_names, args.assign_render_groups)
6186  msg_type = TMessageType.REPLY
6187  except TTransport.TTransportException:
6188  raise
6189  except TOmniSciException as e:
6190  msg_type = TMessageType.REPLY
6191  result.e = e
6192  except TApplicationException as ex:
6193  logging.exception('TApplication exception in handler')
6194  msg_type = TMessageType.EXCEPTION
6195  result = ex
6196  except Exception:
6197  logging.exception('Unexpected exception in handler')
6198  msg_type = TMessageType.EXCEPTION
6199  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6200  oprot.writeMessageBegin("load_table_binary_columnar_polys", msg_type, seqid)
6201  result.write(oprot)
6202  oprot.writeMessageEnd()
6203  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_query_get_outer_fragment_count (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6464 of file OmniSci.py.

6465  def process_query_get_outer_fragment_count(self, seqid, iprot, oprot):
6467  args.read(iprot)
6468  iprot.readMessageEnd()
6470  try:
6471  result.success = self._handler.query_get_outer_fragment_count(args.session, args.query)
6472  msg_type = TMessageType.REPLY
6473  except TTransport.TTransportException:
6474  raise
6475  except TOmniSciException as e:
6476  msg_type = TMessageType.REPLY
6477  result.e = e
6478  except TApplicationException as ex:
6479  logging.exception('TApplication exception in handler')
6480  msg_type = TMessageType.EXCEPTION
6481  result = ex
6482  except Exception:
6483  logging.exception('Unexpected exception in handler')
6484  msg_type = TMessageType.EXCEPTION
6485  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6486  oprot.writeMessageBegin("query_get_outer_fragment_count", msg_type, seqid)
6487  result.write(oprot)
6488  oprot.writeMessageEnd()
6489  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_register_runtime_extension_functions (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6932 of file OmniSci.py.

6933  def process_register_runtime_extension_functions(self, seqid, iprot, oprot):
6935  args.read(iprot)
6936  iprot.readMessageEnd()
6938  try:
6939  self._handler.register_runtime_extension_functions(args.session, args.udfs, args.udtfs, args.device_ir_map)
6940  msg_type = TMessageType.REPLY
6941  except TTransport.TTransportException:
6942  raise
6943  except TOmniSciException as e:
6944  msg_type = TMessageType.REPLY
6945  result.e = e
6946  except TApplicationException as ex:
6947  logging.exception('TApplication exception in handler')
6948  msg_type = TMessageType.EXCEPTION
6949  result = ex
6950  except Exception:
6951  logging.exception('Unexpected exception in handler')
6952  msg_type = TMessageType.EXCEPTION
6953  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6954  oprot.writeMessageBegin("register_runtime_extension_functions", msg_type, seqid)
6955  result.write(oprot)
6956  oprot.writeMessageEnd()
6957  oprot.trans.flush()
6958 
6959 # HELPER FUNCTIONS AND STRUCTURES
6960 
def omnisci.thrift.OmniSci.Processor.process_render_vega (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5632 of file OmniSci.py.

5633  def process_render_vega(self, seqid, iprot, oprot):
5634  args = render_vega_args()
5635  args.read(iprot)
5636  iprot.readMessageEnd()
5637  result = render_vega_result()
5638  try:
5639  result.success = self._handler.render_vega(args.session, args.widget_id, args.vega_json, args.compression_level, args.nonce)
5640  msg_type = TMessageType.REPLY
5641  except TTransport.TTransportException:
5642  raise
5643  except TOmniSciException as e:
5644  msg_type = TMessageType.REPLY
5645  result.e = e
5646  except TApplicationException as ex:
5647  logging.exception('TApplication exception in handler')
5648  msg_type = TMessageType.EXCEPTION
5649  result = ex
5650  except Exception:
5651  logging.exception('Unexpected exception in handler')
5652  msg_type = TMessageType.EXCEPTION
5653  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5654  oprot.writeMessageBegin("render_vega", msg_type, seqid)
5655  result.write(oprot)
5656  oprot.writeMessageEnd()
5657  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_replace_dashboard (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5866 of file OmniSci.py.

5867  def process_replace_dashboard(self, seqid, iprot, oprot):
5868  args = replace_dashboard_args()
5869  args.read(iprot)
5870  iprot.readMessageEnd()
5871  result = replace_dashboard_result()
5872  try:
5873  self._handler.replace_dashboard(args.session, args.dashboard_id, args.dashboard_name, args.dashboard_owner, args.dashboard_state, args.image_hash, args.dashboard_metadata)
5874  msg_type = TMessageType.REPLY
5875  except TTransport.TTransportException:
5876  raise
5877  except TOmniSciException as e:
5878  msg_type = TMessageType.REPLY
5879  result.e = e
5880  except TApplicationException as ex:
5881  logging.exception('TApplication exception in handler')
5882  msg_type = TMessageType.EXCEPTION
5883  result = ex
5884  except Exception:
5885  logging.exception('Unexpected exception in handler')
5886  msg_type = TMessageType.EXCEPTION
5887  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5888  oprot.writeMessageBegin("replace_dashboard", msg_type, seqid)
5889  result.write(oprot)
5890  oprot.writeMessageEnd()
5891  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_set_cur_session (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5202 of file OmniSci.py.

5203  def process_set_cur_session(self, seqid, iprot, oprot):
5204  args = set_cur_session_args()
5205  args.read(iprot)
5206  iprot.readMessageEnd()
5207  result = set_cur_session_result()
5208  try:
5209  self._handler.set_cur_session(args.parent_session, args.leaf_session, args.start_time_str, args.label, args.for_running_query_kernel)
5210  msg_type = TMessageType.REPLY
5211  except TTransport.TTransportException:
5212  raise
5213  except TOmniSciException as e:
5214  msg_type = TMessageType.REPLY
5215  result.e = e
5216  except TApplicationException as ex:
5217  logging.exception('TApplication exception in handler')
5218  msg_type = TMessageType.EXCEPTION
5219  result = ex
5220  except Exception:
5221  logging.exception('Unexpected exception in handler')
5222  msg_type = TMessageType.EXCEPTION
5223  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5224  oprot.writeMessageBegin("set_cur_session", msg_type, seqid)
5225  result.write(oprot)
5226  oprot.writeMessageEnd()
5227  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_set_execution_mode (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5606 of file OmniSci.py.

5607  def process_set_execution_mode(self, seqid, iprot, oprot):
5608  args = set_execution_mode_args()
5609  args.read(iprot)
5610  iprot.readMessageEnd()
5611  result = set_execution_mode_result()
5612  try:
5613  self._handler.set_execution_mode(args.session, args.mode)
5614  msg_type = TMessageType.REPLY
5615  except TTransport.TTransportException:
5616  raise
5617  except TOmniSciException as e:
5618  msg_type = TMessageType.REPLY
5619  result.e = e
5620  except TApplicationException as ex:
5621  logging.exception('TApplication exception in handler')
5622  msg_type = TMessageType.EXCEPTION
5623  result = ex
5624  except Exception:
5625  logging.exception('Unexpected exception in handler')
5626  msg_type = TMessageType.EXCEPTION
5627  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5628  oprot.writeMessageBegin("set_execution_mode", msg_type, seqid)
5629  result.write(oprot)
5630  oprot.writeMessageEnd()
5631  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_set_license_key (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6854 of file OmniSci.py.

6855  def process_set_license_key(self, seqid, iprot, oprot):
6856  args = set_license_key_args()
6857  args.read(iprot)
6858  iprot.readMessageEnd()
6859  result = set_license_key_result()
6860  try:
6861  result.success = self._handler.set_license_key(args.session, args.key, args.nonce)
6862  msg_type = TMessageType.REPLY
6863  except TTransport.TTransportException:
6864  raise
6865  except TOmniSciException as e:
6866  msg_type = TMessageType.REPLY
6867  result.e = e
6868  except TApplicationException as ex:
6869  logging.exception('TApplication exception in handler')
6870  msg_type = TMessageType.EXCEPTION
6871  result = ex
6872  except Exception:
6873  logging.exception('Unexpected exception in handler')
6874  msg_type = TMessageType.EXCEPTION
6875  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6876  oprot.writeMessageBegin("set_license_key", msg_type, seqid)
6877  result.write(oprot)
6878  oprot.writeMessageEnd()
6879  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_set_table_epoch (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5254 of file OmniSci.py.

5255  def process_set_table_epoch(self, seqid, iprot, oprot):
5256  args = set_table_epoch_args()
5257  args.read(iprot)
5258  iprot.readMessageEnd()
5259  result = set_table_epoch_result()
5260  try:
5261  self._handler.set_table_epoch(args.session, args.db_id, args.table_id, args.new_epoch)
5262  msg_type = TMessageType.REPLY
5263  except TTransport.TTransportException:
5264  raise
5265  except TOmniSciException as e:
5266  msg_type = TMessageType.REPLY
5267  result.e = e
5268  except TApplicationException as ex:
5269  logging.exception('TApplication exception in handler')
5270  msg_type = TMessageType.EXCEPTION
5271  result = ex
5272  except Exception:
5273  logging.exception('Unexpected exception in handler')
5274  msg_type = TMessageType.EXCEPTION
5275  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5276  oprot.writeMessageBegin("set_table_epoch", msg_type, seqid)
5277  result.write(oprot)
5278  oprot.writeMessageEnd()
5279  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_set_table_epoch_by_name (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5280 of file OmniSci.py.

5281  def process_set_table_epoch_by_name(self, seqid, iprot, oprot):
5283  args.read(iprot)
5284  iprot.readMessageEnd()
5286  try:
5287  self._handler.set_table_epoch_by_name(args.session, args.table_name, args.new_epoch)
5288  msg_type = TMessageType.REPLY
5289  except TTransport.TTransportException:
5290  raise
5291  except TOmniSciException as e:
5292  msg_type = TMessageType.REPLY
5293  result.e = e
5294  except TApplicationException as ex:
5295  logging.exception('TApplication exception in handler')
5296  msg_type = TMessageType.EXCEPTION
5297  result = ex
5298  except Exception:
5299  logging.exception('Unexpected exception in handler')
5300  msg_type = TMessageType.EXCEPTION
5301  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5302  oprot.writeMessageBegin("set_table_epoch_by_name", msg_type, seqid)
5303  result.write(oprot)
5304  oprot.writeMessageEnd()
5305  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_set_table_epochs (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5375 of file OmniSci.py.

5376  def process_set_table_epochs(self, seqid, iprot, oprot):
5377  args = set_table_epochs_args()
5378  args.read(iprot)
5379  iprot.readMessageEnd()
5380  result = set_table_epochs_result()
5381  try:
5382  self._handler.set_table_epochs(args.session, args.db_id, args.table_epochs)
5383  msg_type = TMessageType.REPLY
5384  except TTransport.TTransportException:
5385  raise
5386  except TApplicationException as ex:
5387  logging.exception('TApplication exception in handler')
5388  msg_type = TMessageType.EXCEPTION
5389  result = ex
5390  except Exception:
5391  logging.exception('Unexpected exception in handler')
5392  msg_type = TMessageType.EXCEPTION
5393  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5394  oprot.writeMessageBegin("set_table_epochs", msg_type, seqid)
5395  result.write(oprot)
5396  oprot.writeMessageEnd()
5397  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_share_dashboard (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5970 of file OmniSci.py.

5971  def process_share_dashboard(self, seqid, iprot, oprot):
5972  args = share_dashboard_args()
5973  args.read(iprot)
5974  iprot.readMessageEnd()
5975  result = share_dashboard_result()
5976  try:
5977  self._handler.share_dashboard(args.session, args.dashboard_id, args.groups, args.objects, args.permissions, args.grant_role)
5978  msg_type = TMessageType.REPLY
5979  except TTransport.TTransportException:
5980  raise
5981  except TOmniSciException as e:
5982  msg_type = TMessageType.REPLY
5983  result.e = e
5984  except TApplicationException as ex:
5985  logging.exception('TApplication exception in handler')
5986  msg_type = TMessageType.EXCEPTION
5987  result = ex
5988  except Exception:
5989  logging.exception('Unexpected exception in handler')
5990  msg_type = TMessageType.EXCEPTION
5991  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5992  oprot.writeMessageBegin("share_dashboard", msg_type, seqid)
5993  result.write(oprot)
5994  oprot.writeMessageEnd()
5995  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_share_dashboards (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5918 of file OmniSci.py.

5919  def process_share_dashboards(self, seqid, iprot, oprot):
5920  args = share_dashboards_args()
5921  args.read(iprot)
5922  iprot.readMessageEnd()
5923  result = share_dashboards_result()
5924  try:
5925  self._handler.share_dashboards(args.session, args.dashboard_ids, args.groups, args.permissions)
5926  msg_type = TMessageType.REPLY
5927  except TTransport.TTransportException:
5928  raise
5929  except TOmniSciException as e:
5930  msg_type = TMessageType.REPLY
5931  result.e = e
5932  except TApplicationException as ex:
5933  logging.exception('TApplication exception in handler')
5934  msg_type = TMessageType.EXCEPTION
5935  result = ex
5936  except Exception:
5937  logging.exception('Unexpected exception in handler')
5938  msg_type = TMessageType.EXCEPTION
5939  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5940  oprot.writeMessageBegin("share_dashboards", msg_type, seqid)
5941  result.write(oprot)
5942  oprot.writeMessageEnd()
5943  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_sql_execute (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5424 of file OmniSci.py.

5425  def process_sql_execute(self, seqid, iprot, oprot):
5426  args = sql_execute_args()
5427  args.read(iprot)
5428  iprot.readMessageEnd()
5429  result = sql_execute_result()
5430  try:
5431  result.success = self._handler.sql_execute(args.session, args.query, args.column_format, args.nonce, args.first_n, args.at_most_n)
5432  msg_type = TMessageType.REPLY
5433  except TTransport.TTransportException:
5434  raise
5435  except TOmniSciException as e:
5436  msg_type = TMessageType.REPLY
5437  result.e = e
5438  except TApplicationException as ex:
5439  logging.exception('TApplication exception in handler')
5440  msg_type = TMessageType.EXCEPTION
5441  result = ex
5442  except Exception:
5443  logging.exception('Unexpected exception in handler')
5444  msg_type = TMessageType.EXCEPTION
5445  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5446  oprot.writeMessageBegin("sql_execute", msg_type, seqid)
5447  result.write(oprot)
5448  oprot.writeMessageEnd()
5449  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_sql_execute_df (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5450 of file OmniSci.py.

5451  def process_sql_execute_df(self, seqid, iprot, oprot):
5452  args = sql_execute_df_args()
5453  args.read(iprot)
5454  iprot.readMessageEnd()
5455  result = sql_execute_df_result()
5456  try:
5457  result.success = self._handler.sql_execute_df(args.session, args.query, args.device_type, args.device_id, args.first_n, args.transport_method)
5458  msg_type = TMessageType.REPLY
5459  except TTransport.TTransportException:
5460  raise
5461  except TOmniSciException as e:
5462  msg_type = TMessageType.REPLY
5463  result.e = e
5464  except TApplicationException as ex:
5465  logging.exception('TApplication exception in handler')
5466  msg_type = TMessageType.EXCEPTION
5467  result = ex
5468  except Exception:
5469  logging.exception('Unexpected exception in handler')
5470  msg_type = TMessageType.EXCEPTION
5471  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5472  oprot.writeMessageBegin("sql_execute_df", msg_type, seqid)
5473  result.write(oprot)
5474  oprot.writeMessageEnd()
5475  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_sql_execute_gdf (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5476 of file OmniSci.py.

5477  def process_sql_execute_gdf(self, seqid, iprot, oprot):
5478  args = sql_execute_gdf_args()
5479  args.read(iprot)
5480  iprot.readMessageEnd()
5481  result = sql_execute_gdf_result()
5482  try:
5483  result.success = self._handler.sql_execute_gdf(args.session, args.query, args.device_id, args.first_n)
5484  msg_type = TMessageType.REPLY
5485  except TTransport.TTransportException:
5486  raise
5487  except TOmniSciException as e:
5488  msg_type = TMessageType.REPLY
5489  result.e = e
5490  except TApplicationException as ex:
5491  logging.exception('TApplication exception in handler')
5492  msg_type = TMessageType.EXCEPTION
5493  result = ex
5494  except Exception:
5495  logging.exception('Unexpected exception in handler')
5496  msg_type = TMessageType.EXCEPTION
5497  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5498  oprot.writeMessageBegin("sql_execute_gdf", msg_type, seqid)
5499  result.write(oprot)
5500  oprot.writeMessageEnd()
5501  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_sql_validate (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5554 of file OmniSci.py.

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

Definition at line 5046 of file OmniSci.py.

5047  def process_start_heap_profile(self, seqid, iprot, oprot):
5048  args = start_heap_profile_args()
5049  args.read(iprot)
5050  iprot.readMessageEnd()
5051  result = start_heap_profile_result()
5052  try:
5053  self._handler.start_heap_profile(args.session)
5054  msg_type = TMessageType.REPLY
5055  except TTransport.TTransportException:
5056  raise
5057  except TOmniSciException as e:
5058  msg_type = TMessageType.REPLY
5059  result.e = e
5060  except TApplicationException as ex:
5061  logging.exception('TApplication exception in handler')
5062  msg_type = TMessageType.EXCEPTION
5063  result = ex
5064  except Exception:
5065  logging.exception('Unexpected exception in handler')
5066  msg_type = TMessageType.EXCEPTION
5067  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5068  oprot.writeMessageBegin("start_heap_profile", msg_type, seqid)
5069  result.write(oprot)
5070  oprot.writeMessageEnd()
5071  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_start_query (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6516 of file OmniSci.py.

6517  def process_start_query(self, seqid, iprot, oprot):
6518  args = start_query_args()
6519  args.read(iprot)
6520  iprot.readMessageEnd()
6521  result = start_query_result()
6522  try:
6523  result.success = self._handler.start_query(args.leaf_session, args.parent_session, args.query_ra, args.start_time_str, args.just_explain, args.outer_fragment_indices)
6524  msg_type = TMessageType.REPLY
6525  except TTransport.TTransportException:
6526  raise
6527  except TOmniSciException as e:
6528  msg_type = TMessageType.REPLY
6529  result.e = e
6530  except TApplicationException as ex:
6531  logging.exception('TApplication exception in handler')
6532  msg_type = TMessageType.EXCEPTION
6533  result = ex
6534  except Exception:
6535  logging.exception('Unexpected exception in handler')
6536  msg_type = TMessageType.EXCEPTION
6537  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6538  oprot.writeMessageBegin("start_query", msg_type, seqid)
6539  result.write(oprot)
6540  oprot.writeMessageEnd()
6541  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_start_render_query (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6594 of file OmniSci.py.

6595  def process_start_render_query(self, seqid, iprot, oprot):
6596  args = start_render_query_args()
6597  args.read(iprot)
6598  iprot.readMessageEnd()
6599  result = start_render_query_result()
6600  try:
6601  result.success = self._handler.start_render_query(args.session, args.widget_id, args.node_idx, args.vega_json)
6602  msg_type = TMessageType.REPLY
6603  except TTransport.TTransportException:
6604  raise
6605  except TOmniSciException as e:
6606  msg_type = TMessageType.REPLY
6607  result.e = e
6608  except TApplicationException as ex:
6609  logging.exception('TApplication exception in handler')
6610  msg_type = TMessageType.EXCEPTION
6611  result = ex
6612  except Exception:
6613  logging.exception('Unexpected exception in handler')
6614  msg_type = TMessageType.EXCEPTION
6615  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6616  oprot.writeMessageBegin("start_render_query", msg_type, seqid)
6617  result.write(oprot)
6618  oprot.writeMessageEnd()
6619  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_stop_heap_profile (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5072 of file OmniSci.py.

5073  def process_stop_heap_profile(self, seqid, iprot, oprot):
5074  args = stop_heap_profile_args()
5075  args.read(iprot)
5076  iprot.readMessageEnd()
5077  result = stop_heap_profile_result()
5078  try:
5079  self._handler.stop_heap_profile(args.session)
5080  msg_type = TMessageType.REPLY
5081  except TTransport.TTransportException:
5082  raise
5083  except TOmniSciException as e:
5084  msg_type = TMessageType.REPLY
5085  result.e = e
5086  except TApplicationException as ex:
5087  logging.exception('TApplication exception in handler')
5088  msg_type = TMessageType.EXCEPTION
5089  result = ex
5090  except Exception:
5091  logging.exception('Unexpected exception in handler')
5092  msg_type = TMessageType.EXCEPTION
5093  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5094  oprot.writeMessageBegin("stop_heap_profile", msg_type, seqid)
5095  result.write(oprot)
5096  oprot.writeMessageEnd()
5097  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_switch_database (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 4604 of file OmniSci.py.

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

Definition at line 5996 of file OmniSci.py.

5997  def process_unshare_dashboard(self, seqid, iprot, oprot):
5998  args = unshare_dashboard_args()
5999  args.read(iprot)
6000  iprot.readMessageEnd()
6001  result = unshare_dashboard_result()
6002  try:
6003  self._handler.unshare_dashboard(args.session, args.dashboard_id, args.groups, args.objects, args.permissions)
6004  msg_type = TMessageType.REPLY
6005  except TTransport.TTransportException:
6006  raise
6007  except TOmniSciException as e:
6008  msg_type = TMessageType.REPLY
6009  result.e = e
6010  except TApplicationException as ex:
6011  logging.exception('TApplication exception in handler')
6012  msg_type = TMessageType.EXCEPTION
6013  result = ex
6014  except Exception:
6015  logging.exception('Unexpected exception in handler')
6016  msg_type = TMessageType.EXCEPTION
6017  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6018  oprot.writeMessageBegin("unshare_dashboard", msg_type, seqid)
6019  result.write(oprot)
6020  oprot.writeMessageEnd()
6021  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_unshare_dashboards (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 6022 of file OmniSci.py.

6023  def process_unshare_dashboards(self, seqid, iprot, oprot):
6024  args = unshare_dashboards_args()
6025  args.read(iprot)
6026  iprot.readMessageEnd()
6027  result = unshare_dashboards_result()
6028  try:
6029  self._handler.unshare_dashboards(args.session, args.dashboard_ids, args.groups, args.permissions)
6030  msg_type = TMessageType.REPLY
6031  except TTransport.TTransportException:
6032  raise
6033  except TOmniSciException as e:
6034  msg_type = TMessageType.REPLY
6035  result.e = e
6036  except TApplicationException as ex:
6037  logging.exception('TApplication exception in handler')
6038  msg_type = TMessageType.EXCEPTION
6039  result = ex
6040  except Exception:
6041  logging.exception('Unexpected exception in handler')
6042  msg_type = TMessageType.EXCEPTION
6043  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6044  oprot.writeMessageBegin("unshare_dashboards", msg_type, seqid)
6045  result.write(oprot)
6046  oprot.writeMessageEnd()
6047  oprot.trans.flush()
def omnisci.thrift.OmniSci.Processor.process_update_custom_expression (   self,
  seqid,
  iprot,
  oprot 
)

Definition at line 5736 of file OmniSci.py.

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

Member Data Documentation

omnisci.thrift.OmniSci.Processor._handler
private

Definition at line 4408 of file OmniSci.py.

omnisci.thrift.OmniSci.Processor._on_message_begin
private

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

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


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