OmniSciDB  340b00dbf6
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
OmniSci.py
Go to the documentation of this file.
1 #
2 # Autogenerated by Thrift Compiler (0.13.0)
3 #
4 # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
5 #
6 # options string: py
7 #
8 
9 from thrift.Thrift import TType, TMessageType, TFrozenDict, TException, TApplicationException
10 from thrift.protocol.TProtocol import TProtocolException
11 from thrift.TRecursive import fix_spec
12 
13 import sys
14 import logging
15 from .ttypes import *
16 from thrift.Thrift import TProcessor
17 from thrift.transport import TTransport
18 all_structs = []
19 
20 
21 class Iface(object):
22  def connect(self, user, passwd, dbname):
23  """
24  Parameters:
25  - user
26  - passwd
27  - dbname
28 
29  """
30  pass
31 
32  def krb5_connect(self, inputToken, dbname):
33  """
34  Parameters:
35  - inputToken
36  - dbname
37 
38  """
39  pass
40 
41  def disconnect(self, session):
42  """
43  Parameters:
44  - session
45 
46  """
47  pass
48 
49  def switch_database(self, session, dbname):
50  """
51  Parameters:
52  - session
53  - dbname
54 
55  """
56  pass
57 
58  def clone_session(self, session):
59  """
60  Parameters:
61  - session
62 
63  """
64  pass
65 
66  def get_server_status(self, session):
67  """
68  Parameters:
69  - session
70 
71  """
72  pass
73 
74  def get_status(self, session):
75  """
76  Parameters:
77  - session
78 
79  """
80  pass
81 
82  def get_hardware_info(self, session):
83  """
84  Parameters:
85  - session
86 
87  """
88  pass
89 
90  def get_tables(self, session):
91  """
92  Parameters:
93  - session
94 
95  """
96  pass
97 
98  def get_physical_tables(self, session):
99  """
100  Parameters:
101  - session
102 
103  """
104  pass
105 
106  def get_views(self, session):
107  """
108  Parameters:
109  - session
110 
111  """
112  pass
113 
114  def get_tables_meta(self, session):
115  """
116  Parameters:
117  - session
118 
119  """
120  pass
121 
122  def get_table_details(self, session, table_name):
123  """
124  Parameters:
125  - session
126  - table_name
127 
128  """
129  pass
130 
131  def get_internal_table_details(self, session, table_name):
132  """
133  Parameters:
134  - session
135  - table_name
136 
137  """
138  pass
139 
140  def get_users(self, session):
141  """
142  Parameters:
143  - session
144 
145  """
146  pass
147 
148  def get_databases(self, session):
149  """
150  Parameters:
151  - session
152 
153  """
154  pass
155 
156  def get_version(self):
157  pass
158 
159  def start_heap_profile(self, session):
160  """
161  Parameters:
162  - session
163 
164  """
165  pass
166 
167  def stop_heap_profile(self, session):
168  """
169  Parameters:
170  - session
171 
172  """
173  pass
174 
175  def get_heap_profile(self, session):
176  """
177  Parameters:
178  - session
179 
180  """
181  pass
182 
183  def get_memory(self, session, memory_level):
184  """
185  Parameters:
186  - session
187  - memory_level
188 
189  """
190  pass
191 
192  def clear_cpu_memory(self, session):
193  """
194  Parameters:
195  - session
196 
197  """
198  pass
199 
200  def clear_gpu_memory(self, session):
201  """
202  Parameters:
203  - session
204 
205  """
206  pass
207 
208  def set_table_epoch(self, session, db_id, table_id, new_epoch):
209  """
210  Parameters:
211  - session
212  - db_id
213  - table_id
214  - new_epoch
215 
216  """
217  pass
218 
219  def set_table_epoch_by_name(self, session, table_name, new_epoch):
220  """
221  Parameters:
222  - session
223  - table_name
224  - new_epoch
225 
226  """
227  pass
228 
229  def get_table_epoch(self, session, db_id, table_id):
230  """
231  Parameters:
232  - session
233  - db_id
234  - table_id
235 
236  """
237  pass
238 
239  def get_table_epoch_by_name(self, session, table_name):
240  """
241  Parameters:
242  - session
243  - table_name
244 
245  """
246  pass
247 
248  def get_session_info(self, session):
249  """
250  Parameters:
251  - session
252 
253  """
254  pass
255 
256  def sql_execute(self, session, query, column_format, nonce, first_n, at_most_n):
257  """
258  Parameters:
259  - session
260  - query
261  - column_format
262  - nonce
263  - first_n
264  - at_most_n
265 
266  """
267  pass
268 
269  def sql_execute_df(self, session, query, device_type, device_id, first_n, transport_method):
270  """
271  Parameters:
272  - session
273  - query
274  - device_type
275  - device_id
276  - first_n
277  - transport_method
278 
279  """
280  pass
281 
282  def sql_execute_gdf(self, session, query, device_id, first_n):
283  """
284  Parameters:
285  - session
286  - query
287  - device_id
288  - first_n
289 
290  """
291  pass
292 
293  def deallocate_df(self, session, df, device_type, device_id):
294  """
295  Parameters:
296  - session
297  - df
298  - device_type
299  - device_id
300 
301  """
302  pass
303 
304  def interrupt(self, query_session, interrupt_session):
305  """
306  Parameters:
307  - query_session
308  - interrupt_session
309 
310  """
311  pass
312 
313  def sql_validate(self, session, query):
314  """
315  Parameters:
316  - session
317  - query
318 
319  """
320  pass
321 
322  def get_completion_hints(self, session, sql, cursor):
323  """
324  Parameters:
325  - session
326  - sql
327  - cursor
328 
329  """
330  pass
331 
332  def set_execution_mode(self, session, mode):
333  """
334  Parameters:
335  - session
336  - mode
337 
338  """
339  pass
340 
341  def render_vega(self, session, widget_id, vega_json, compression_level, nonce):
342  """
343  Parameters:
344  - session
345  - widget_id
346  - vega_json
347  - compression_level
348  - nonce
349 
350  """
351  pass
352 
353  def get_result_row_for_pixel(self, session, widget_id, pixel, table_col_names, column_format, pixelRadius, nonce):
354  """
355  Parameters:
356  - session
357  - widget_id
358  - pixel
359  - table_col_names
360  - column_format
361  - pixelRadius
362  - nonce
363 
364  """
365  pass
366 
367  def get_dashboard(self, session, dashboard_id):
368  """
369  Parameters:
370  - session
371  - dashboard_id
372 
373  """
374  pass
375 
376  def get_dashboards(self, session):
377  """
378  Parameters:
379  - session
380 
381  """
382  pass
383 
384  def create_dashboard(self, session, dashboard_name, dashboard_state, image_hash, dashboard_metadata):
385  """
386  Parameters:
387  - session
388  - dashboard_name
389  - dashboard_state
390  - image_hash
391  - dashboard_metadata
392 
393  """
394  pass
395 
396  def replace_dashboard(self, session, dashboard_id, dashboard_name, dashboard_owner, dashboard_state, image_hash, dashboard_metadata):
397  """
398  Parameters:
399  - session
400  - dashboard_id
401  - dashboard_name
402  - dashboard_owner
403  - dashboard_state
404  - image_hash
405  - dashboard_metadata
406 
407  """
408  pass
409 
410  def delete_dashboard(self, session, dashboard_id):
411  """
412  Parameters:
413  - session
414  - dashboard_id
415 
416  """
417  pass
418 
419  def share_dashboards(self, session, dashboard_ids, groups, permissions):
420  """
421  Parameters:
422  - session
423  - dashboard_ids
424  - groups
425  - permissions
426 
427  """
428  pass
429 
430  def delete_dashboards(self, session, dashboard_ids):
431  """
432  Parameters:
433  - session
434  - dashboard_ids
435 
436  """
437  pass
438 
439  def share_dashboard(self, session, dashboard_id, groups, objects, permissions, grant_role):
440  """
441  Parameters:
442  - session
443  - dashboard_id
444  - groups
445  - objects
446  - permissions
447  - grant_role
448 
449  """
450  pass
451 
452  def unshare_dashboard(self, session, dashboard_id, groups, objects, permissions):
453  """
454  Parameters:
455  - session
456  - dashboard_id
457  - groups
458  - objects
459  - permissions
460 
461  """
462  pass
463 
464  def unshare_dashboards(self, session, dashboard_ids, groups, permissions):
465  """
466  Parameters:
467  - session
468  - dashboard_ids
469  - groups
470  - permissions
471 
472  """
473  pass
474 
475  def get_dashboard_grantees(self, session, dashboard_id):
476  """
477  Parameters:
478  - session
479  - dashboard_id
480 
481  """
482  pass
483 
484  def get_link_view(self, session, link):
485  """
486  Parameters:
487  - session
488  - link
489 
490  """
491  pass
492 
493  def create_link(self, session, view_state, view_metadata):
494  """
495  Parameters:
496  - session
497  - view_state
498  - view_metadata
499 
500  """
501  pass
502 
503  def load_table_binary(self, session, table_name, rows):
504  """
505  Parameters:
506  - session
507  - table_name
508  - rows
509 
510  """
511  pass
512 
513  def load_table_binary_columnar(self, session, table_name, cols):
514  """
515  Parameters:
516  - session
517  - table_name
518  - cols
519 
520  """
521  pass
522 
523  def load_table_binary_arrow(self, session, table_name, arrow_stream):
524  """
525  Parameters:
526  - session
527  - table_name
528  - arrow_stream
529 
530  """
531  pass
532 
533  def load_table(self, session, table_name, rows):
534  """
535  Parameters:
536  - session
537  - table_name
538  - rows
539 
540  """
541  pass
542 
543  def detect_column_types(self, session, file_name, copy_params):
544  """
545  Parameters:
546  - session
547  - file_name
548  - copy_params
549 
550  """
551  pass
552 
553  def create_table(self, session, table_name, row_desc, file_type, create_params):
554  """
555  Parameters:
556  - session
557  - table_name
558  - row_desc
559  - file_type
560  - create_params
561 
562  """
563  pass
564 
565  def import_table(self, session, table_name, file_name, copy_params):
566  """
567  Parameters:
568  - session
569  - table_name
570  - file_name
571  - copy_params
572 
573  """
574  pass
575 
576  def import_geo_table(self, session, table_name, file_name, copy_params, row_desc, create_params):
577  """
578  Parameters:
579  - session
580  - table_name
581  - file_name
582  - copy_params
583  - row_desc
584  - create_params
585 
586  """
587  pass
588 
589  def import_table_status(self, session, import_id):
590  """
591  Parameters:
592  - session
593  - import_id
594 
595  """
596  pass
597 
598  def get_first_geo_file_in_archive(self, session, archive_path, copy_params):
599  """
600  Parameters:
601  - session
602  - archive_path
603  - copy_params
604 
605  """
606  pass
607 
608  def get_all_files_in_archive(self, session, archive_path, copy_params):
609  """
610  Parameters:
611  - session
612  - archive_path
613  - copy_params
614 
615  """
616  pass
617 
618  def get_layers_in_geo_file(self, session, file_name, copy_params):
619  """
620  Parameters:
621  - session
622  - file_name
623  - copy_params
624 
625  """
626  pass
627 
628  def query_get_outer_fragment_count(self, session, query):
629  """
630  Parameters:
631  - session
632  - query
633 
634  """
635  pass
636 
637  def check_table_consistency(self, session, table_id):
638  """
639  Parameters:
640  - session
641  - table_id
642 
643  """
644  pass
645 
646  def start_query(self, leaf_session, parent_session, query_ra, just_explain, outer_fragment_indices):
647  """
648  Parameters:
649  - leaf_session
650  - parent_session
651  - query_ra
652  - just_explain
653  - outer_fragment_indices
654 
655  """
656  pass
657 
658  def execute_query_step(self, pending_query):
659  """
660  Parameters:
661  - pending_query
662 
663  """
664  pass
665 
666  def broadcast_serialized_rows(self, serialized_rows, row_desc, query_id):
667  """
668  Parameters:
669  - serialized_rows
670  - row_desc
671  - query_id
672 
673  """
674  pass
675 
676  def start_render_query(self, session, widget_id, node_idx, vega_json):
677  """
678  Parameters:
679  - session
680  - widget_id
681  - node_idx
682  - vega_json
683 
684  """
685  pass
686 
687  def execute_next_render_step(self, pending_render, merged_data):
688  """
689  Parameters:
690  - pending_render
691  - merged_data
692 
693  """
694  pass
695 
696  def insert_data(self, session, insert_data):
697  """
698  Parameters:
699  - session
700  - insert_data
701 
702  """
703  pass
704 
705  def checkpoint(self, session, db_id, table_id):
706  """
707  Parameters:
708  - session
709  - db_id
710  - table_id
711 
712  """
713  pass
714 
715  def get_roles(self, session):
716  """
717  Parameters:
718  - session
719 
720  """
721  pass
722 
723  def get_db_objects_for_grantee(self, session, roleName):
724  """
725  Parameters:
726  - session
727  - roleName
728 
729  """
730  pass
731 
732  def get_db_object_privs(self, session, objectName, type):
733  """
734  Parameters:
735  - session
736  - objectName
737  - type
738 
739  """
740  pass
741 
742  def get_all_roles_for_user(self, session, userName):
743  """
744  Parameters:
745  - session
746  - userName
747 
748  """
749  pass
750 
751  def has_role(self, session, granteeName, roleName):
752  """
753  Parameters:
754  - session
755  - granteeName
756  - roleName
757 
758  """
759  pass
760 
761  def has_object_privilege(self, session, granteeName, ObjectName, objectType, permissions):
762  """
763  Parameters:
764  - session
765  - granteeName
766  - ObjectName
767  - objectType
768  - permissions
769 
770  """
771  pass
772 
773  def set_license_key(self, session, key, nonce):
774  """
775  Parameters:
776  - session
777  - key
778  - nonce
779 
780  """
781  pass
782 
783  def get_license_claims(self, session, nonce):
784  """
785  Parameters:
786  - session
787  - nonce
788 
789  """
790  pass
791 
792  def get_device_parameters(self, session):
793  """
794  Parameters:
795  - session
796 
797  """
798  pass
799 
800  def register_runtime_extension_functions(self, session, udfs, udtfs, device_ir_map):
801  """
802  Parameters:
803  - session
804  - udfs
805  - udtfs
806  - device_ir_map
807 
808  """
809  pass
810 
811 
812 class Client(Iface):
813  def __init__(self, iprot, oprot=None):
814  self._iprot = self._oprot = iprot
815  if oprot is not None:
816  self._oprot = oprot
817  self._seqid = 0
818 
819  def connect(self, user, passwd, dbname):
820  """
821  Parameters:
822  - user
823  - passwd
824  - dbname
825 
826  """
827  self.send_connect(user, passwd, dbname)
828  return self.recv_connect()
829 
830  def send_connect(self, user, passwd, dbname):
831  self._oprot.writeMessageBegin('connect', TMessageType.CALL, self._seqid)
832  args = connect_args()
833  args.user = user
834  args.passwd = passwd
835  args.dbname = dbname
836  args.write(self._oprot)
837  self._oprot.writeMessageEnd()
838  self._oprot.trans.flush()
839 
840  def recv_connect(self):
841  iprot = self._iprot
842  (fname, mtype, rseqid) = iprot.readMessageBegin()
843  if mtype == TMessageType.EXCEPTION:
844  x = TApplicationException()
845  x.read(iprot)
846  iprot.readMessageEnd()
847  raise x
848  result = connect_result()
849  result.read(iprot)
850  iprot.readMessageEnd()
851  if result.success is not None:
852  return result.success
853  if result.e is not None:
854  raise result.e
855  raise TApplicationException(TApplicationException.MISSING_RESULT, "connect failed: unknown result")
856 
857  def krb5_connect(self, inputToken, dbname):
858  """
859  Parameters:
860  - inputToken
861  - dbname
862 
863  """
864  self.send_krb5_connect(inputToken, dbname)
865  return self.recv_krb5_connect()
866 
867  def send_krb5_connect(self, inputToken, dbname):
868  self._oprot.writeMessageBegin('krb5_connect', TMessageType.CALL, self._seqid)
869  args = krb5_connect_args()
870  args.inputToken = inputToken
871  args.dbname = dbname
872  args.write(self._oprot)
873  self._oprot.writeMessageEnd()
874  self._oprot.trans.flush()
875 
876  def recv_krb5_connect(self):
877  iprot = self._iprot
878  (fname, mtype, rseqid) = iprot.readMessageBegin()
879  if mtype == TMessageType.EXCEPTION:
880  x = TApplicationException()
881  x.read(iprot)
882  iprot.readMessageEnd()
883  raise x
884  result = krb5_connect_result()
885  result.read(iprot)
886  iprot.readMessageEnd()
887  if result.success is not None:
888  return result.success
889  if result.e is not None:
890  raise result.e
891  raise TApplicationException(TApplicationException.MISSING_RESULT, "krb5_connect failed: unknown result")
892 
893  def disconnect(self, session):
894  """
895  Parameters:
896  - session
897 
898  """
899  self.send_disconnect(session)
900  self.recv_disconnect()
901 
902  def send_disconnect(self, session):
903  self._oprot.writeMessageBegin('disconnect', TMessageType.CALL, self._seqid)
904  args = disconnect_args()
905  args.session = session
906  args.write(self._oprot)
907  self._oprot.writeMessageEnd()
908  self._oprot.trans.flush()
909 
910  def recv_disconnect(self):
911  iprot = self._iprot
912  (fname, mtype, rseqid) = iprot.readMessageBegin()
913  if mtype == TMessageType.EXCEPTION:
914  x = TApplicationException()
915  x.read(iprot)
916  iprot.readMessageEnd()
917  raise x
918  result = disconnect_result()
919  result.read(iprot)
920  iprot.readMessageEnd()
921  if result.e is not None:
922  raise result.e
923  return
924 
925  def switch_database(self, session, dbname):
926  """
927  Parameters:
928  - session
929  - dbname
930 
931  """
932  self.send_switch_database(session, dbname)
933  self.recv_switch_database()
934 
935  def send_switch_database(self, session, dbname):
936  self._oprot.writeMessageBegin('switch_database', TMessageType.CALL, self._seqid)
937  args = switch_database_args()
938  args.session = session
939  args.dbname = dbname
940  args.write(self._oprot)
941  self._oprot.writeMessageEnd()
942  self._oprot.trans.flush()
943 
945  iprot = self._iprot
946  (fname, mtype, rseqid) = iprot.readMessageBegin()
947  if mtype == TMessageType.EXCEPTION:
948  x = TApplicationException()
949  x.read(iprot)
950  iprot.readMessageEnd()
951  raise x
952  result = switch_database_result()
953  result.read(iprot)
954  iprot.readMessageEnd()
955  if result.e is not None:
956  raise result.e
957  return
958 
959  def clone_session(self, session):
960  """
961  Parameters:
962  - session
963 
964  """
965  self.send_clone_session(session)
966  return self.recv_clone_session()
967 
968  def send_clone_session(self, session):
969  self._oprot.writeMessageBegin('clone_session', TMessageType.CALL, self._seqid)
970  args = clone_session_args()
971  args.session = session
972  args.write(self._oprot)
973  self._oprot.writeMessageEnd()
974  self._oprot.trans.flush()
975 
977  iprot = self._iprot
978  (fname, mtype, rseqid) = iprot.readMessageBegin()
979  if mtype == TMessageType.EXCEPTION:
980  x = TApplicationException()
981  x.read(iprot)
982  iprot.readMessageEnd()
983  raise x
984  result = clone_session_result()
985  result.read(iprot)
986  iprot.readMessageEnd()
987  if result.success is not None:
988  return result.success
989  if result.e is not None:
990  raise result.e
991  raise TApplicationException(TApplicationException.MISSING_RESULT, "clone_session failed: unknown result")
992 
993  def get_server_status(self, session):
994  """
995  Parameters:
996  - session
997 
998  """
999  self.send_get_server_status(session)
1000  return self.recv_get_server_status()
1001 
1002  def send_get_server_status(self, session):
1003  self._oprot.writeMessageBegin('get_server_status', TMessageType.CALL, self._seqid)
1004  args = get_server_status_args()
1005  args.session = session
1006  args.write(self._oprot)
1007  self._oprot.writeMessageEnd()
1008  self._oprot.trans.flush()
1009 
1011  iprot = self._iprot
1012  (fname, mtype, rseqid) = iprot.readMessageBegin()
1013  if mtype == TMessageType.EXCEPTION:
1014  x = TApplicationException()
1015  x.read(iprot)
1016  iprot.readMessageEnd()
1017  raise x
1018  result = get_server_status_result()
1019  result.read(iprot)
1020  iprot.readMessageEnd()
1021  if result.success is not None:
1022  return result.success
1023  if result.e is not None:
1024  raise result.e
1025  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_server_status failed: unknown result")
1026 
1027  def get_status(self, session):
1028  """
1029  Parameters:
1030  - session
1031 
1032  """
1033  self.send_get_status(session)
1034  return self.recv_get_status()
1035 
1036  def send_get_status(self, session):
1037  self._oprot.writeMessageBegin('get_status', TMessageType.CALL, self._seqid)
1038  args = get_status_args()
1039  args.session = session
1040  args.write(self._oprot)
1041  self._oprot.writeMessageEnd()
1042  self._oprot.trans.flush()
1043 
1044  def recv_get_status(self):
1045  iprot = self._iprot
1046  (fname, mtype, rseqid) = iprot.readMessageBegin()
1047  if mtype == TMessageType.EXCEPTION:
1048  x = TApplicationException()
1049  x.read(iprot)
1050  iprot.readMessageEnd()
1051  raise x
1052  result = get_status_result()
1053  result.read(iprot)
1054  iprot.readMessageEnd()
1055  if result.success is not None:
1056  return result.success
1057  if result.e is not None:
1058  raise result.e
1059  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_status failed: unknown result")
1060 
1061  def get_hardware_info(self, session):
1062  """
1063  Parameters:
1064  - session
1065 
1066  """
1067  self.send_get_hardware_info(session)
1068  return self.recv_get_hardware_info()
1069 
1070  def send_get_hardware_info(self, session):
1071  self._oprot.writeMessageBegin('get_hardware_info', TMessageType.CALL, self._seqid)
1072  args = get_hardware_info_args()
1073  args.session = session
1074  args.write(self._oprot)
1075  self._oprot.writeMessageEnd()
1076  self._oprot.trans.flush()
1077 
1079  iprot = self._iprot
1080  (fname, mtype, rseqid) = iprot.readMessageBegin()
1081  if mtype == TMessageType.EXCEPTION:
1082  x = TApplicationException()
1083  x.read(iprot)
1084  iprot.readMessageEnd()
1085  raise x
1086  result = get_hardware_info_result()
1087  result.read(iprot)
1088  iprot.readMessageEnd()
1089  if result.success is not None:
1090  return result.success
1091  if result.e is not None:
1092  raise result.e
1093  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_hardware_info failed: unknown result")
1094 
1095  def get_tables(self, session):
1096  """
1097  Parameters:
1098  - session
1099 
1100  """
1101  self.send_get_tables(session)
1102  return self.recv_get_tables()
1103 
1104  def send_get_tables(self, session):
1105  self._oprot.writeMessageBegin('get_tables', TMessageType.CALL, self._seqid)
1106  args = get_tables_args()
1107  args.session = session
1108  args.write(self._oprot)
1109  self._oprot.writeMessageEnd()
1110  self._oprot.trans.flush()
1111 
1112  def recv_get_tables(self):
1113  iprot = self._iprot
1114  (fname, mtype, rseqid) = iprot.readMessageBegin()
1115  if mtype == TMessageType.EXCEPTION:
1116  x = TApplicationException()
1117  x.read(iprot)
1118  iprot.readMessageEnd()
1119  raise x
1120  result = get_tables_result()
1121  result.read(iprot)
1122  iprot.readMessageEnd()
1123  if result.success is not None:
1124  return result.success
1125  if result.e is not None:
1126  raise result.e
1127  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_tables failed: unknown result")
1128 
1129  def get_physical_tables(self, session):
1130  """
1131  Parameters:
1132  - session
1133 
1134  """
1135  self.send_get_physical_tables(session)
1136  return self.recv_get_physical_tables()
1137 
1138  def send_get_physical_tables(self, session):
1139  self._oprot.writeMessageBegin('get_physical_tables', TMessageType.CALL, self._seqid)
1140  args = get_physical_tables_args()
1141  args.session = session
1142  args.write(self._oprot)
1143  self._oprot.writeMessageEnd()
1144  self._oprot.trans.flush()
1145 
1147  iprot = self._iprot
1148  (fname, mtype, rseqid) = iprot.readMessageBegin()
1149  if mtype == TMessageType.EXCEPTION:
1150  x = TApplicationException()
1151  x.read(iprot)
1152  iprot.readMessageEnd()
1153  raise x
1154  result = get_physical_tables_result()
1155  result.read(iprot)
1156  iprot.readMessageEnd()
1157  if result.success is not None:
1158  return result.success
1159  if result.e is not None:
1160  raise result.e
1161  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_physical_tables failed: unknown result")
1162 
1163  def get_views(self, session):
1164  """
1165  Parameters:
1166  - session
1167 
1168  """
1169  self.send_get_views(session)
1170  return self.recv_get_views()
1171 
1172  def send_get_views(self, session):
1173  self._oprot.writeMessageBegin('get_views', TMessageType.CALL, self._seqid)
1174  args = get_views_args()
1175  args.session = session
1176  args.write(self._oprot)
1177  self._oprot.writeMessageEnd()
1178  self._oprot.trans.flush()
1179 
1180  def recv_get_views(self):
1181  iprot = self._iprot
1182  (fname, mtype, rseqid) = iprot.readMessageBegin()
1183  if mtype == TMessageType.EXCEPTION:
1184  x = TApplicationException()
1185  x.read(iprot)
1186  iprot.readMessageEnd()
1187  raise x
1188  result = get_views_result()
1189  result.read(iprot)
1190  iprot.readMessageEnd()
1191  if result.success is not None:
1192  return result.success
1193  if result.e is not None:
1194  raise result.e
1195  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_views failed: unknown result")
1196 
1197  def get_tables_meta(self, session):
1198  """
1199  Parameters:
1200  - session
1201 
1202  """
1203  self.send_get_tables_meta(session)
1204  return self.recv_get_tables_meta()
1205 
1206  def send_get_tables_meta(self, session):
1207  self._oprot.writeMessageBegin('get_tables_meta', TMessageType.CALL, self._seqid)
1208  args = get_tables_meta_args()
1209  args.session = session
1210  args.write(self._oprot)
1211  self._oprot.writeMessageEnd()
1212  self._oprot.trans.flush()
1213 
1215  iprot = self._iprot
1216  (fname, mtype, rseqid) = iprot.readMessageBegin()
1217  if mtype == TMessageType.EXCEPTION:
1218  x = TApplicationException()
1219  x.read(iprot)
1220  iprot.readMessageEnd()
1221  raise x
1222  result = get_tables_meta_result()
1223  result.read(iprot)
1224  iprot.readMessageEnd()
1225  if result.success is not None:
1226  return result.success
1227  if result.e is not None:
1228  raise result.e
1229  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_tables_meta failed: unknown result")
1230 
1231  def get_table_details(self, session, table_name):
1232  """
1233  Parameters:
1234  - session
1235  - table_name
1236 
1237  """
1238  self.send_get_table_details(session, table_name)
1239  return self.recv_get_table_details()
1240 
1241  def send_get_table_details(self, session, table_name):
1242  self._oprot.writeMessageBegin('get_table_details', TMessageType.CALL, self._seqid)
1243  args = get_table_details_args()
1244  args.session = session
1245  args.table_name = table_name
1246  args.write(self._oprot)
1247  self._oprot.writeMessageEnd()
1248  self._oprot.trans.flush()
1249 
1251  iprot = self._iprot
1252  (fname, mtype, rseqid) = iprot.readMessageBegin()
1253  if mtype == TMessageType.EXCEPTION:
1254  x = TApplicationException()
1255  x.read(iprot)
1256  iprot.readMessageEnd()
1257  raise x
1258  result = get_table_details_result()
1259  result.read(iprot)
1260  iprot.readMessageEnd()
1261  if result.success is not None:
1262  return result.success
1263  if result.e is not None:
1264  raise result.e
1265  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table_details failed: unknown result")
1266 
1267  def get_internal_table_details(self, session, table_name):
1268  """
1269  Parameters:
1270  - session
1271  - table_name
1272 
1273  """
1274  self.send_get_internal_table_details(session, table_name)
1275  return self.recv_get_internal_table_details()
1276 
1277  def send_get_internal_table_details(self, session, table_name):
1278  self._oprot.writeMessageBegin('get_internal_table_details', TMessageType.CALL, self._seqid)
1280  args.session = session
1281  args.table_name = table_name
1282  args.write(self._oprot)
1283  self._oprot.writeMessageEnd()
1284  self._oprot.trans.flush()
1285 
1287  iprot = self._iprot
1288  (fname, mtype, rseqid) = iprot.readMessageBegin()
1289  if mtype == TMessageType.EXCEPTION:
1290  x = TApplicationException()
1291  x.read(iprot)
1292  iprot.readMessageEnd()
1293  raise x
1295  result.read(iprot)
1296  iprot.readMessageEnd()
1297  if result.success is not None:
1298  return result.success
1299  if result.e is not None:
1300  raise result.e
1301  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_internal_table_details failed: unknown result")
1302 
1303  def get_users(self, session):
1304  """
1305  Parameters:
1306  - session
1307 
1308  """
1309  self.send_get_users(session)
1310  return self.recv_get_users()
1311 
1312  def send_get_users(self, session):
1313  self._oprot.writeMessageBegin('get_users', TMessageType.CALL, self._seqid)
1314  args = get_users_args()
1315  args.session = session
1316  args.write(self._oprot)
1317  self._oprot.writeMessageEnd()
1318  self._oprot.trans.flush()
1319 
1320  def recv_get_users(self):
1321  iprot = self._iprot
1322  (fname, mtype, rseqid) = iprot.readMessageBegin()
1323  if mtype == TMessageType.EXCEPTION:
1324  x = TApplicationException()
1325  x.read(iprot)
1326  iprot.readMessageEnd()
1327  raise x
1328  result = get_users_result()
1329  result.read(iprot)
1330  iprot.readMessageEnd()
1331  if result.success is not None:
1332  return result.success
1333  if result.e is not None:
1334  raise result.e
1335  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_users failed: unknown result")
1336 
1337  def get_databases(self, session):
1338  """
1339  Parameters:
1340  - session
1341 
1342  """
1343  self.send_get_databases(session)
1344  return self.recv_get_databases()
1345 
1346  def send_get_databases(self, session):
1347  self._oprot.writeMessageBegin('get_databases', TMessageType.CALL, self._seqid)
1348  args = get_databases_args()
1349  args.session = session
1350  args.write(self._oprot)
1351  self._oprot.writeMessageEnd()
1352  self._oprot.trans.flush()
1353 
1355  iprot = self._iprot
1356  (fname, mtype, rseqid) = iprot.readMessageBegin()
1357  if mtype == TMessageType.EXCEPTION:
1358  x = TApplicationException()
1359  x.read(iprot)
1360  iprot.readMessageEnd()
1361  raise x
1362  result = get_databases_result()
1363  result.read(iprot)
1364  iprot.readMessageEnd()
1365  if result.success is not None:
1366  return result.success
1367  if result.e is not None:
1368  raise result.e
1369  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_databases failed: unknown result")
1370 
1371  def get_version(self):
1372  self.send_get_version()
1373  return self.recv_get_version()
1374 
1375  def send_get_version(self):
1376  self._oprot.writeMessageBegin('get_version', TMessageType.CALL, self._seqid)
1377  args = get_version_args()
1378  args.write(self._oprot)
1379  self._oprot.writeMessageEnd()
1380  self._oprot.trans.flush()
1381 
1382  def recv_get_version(self):
1383  iprot = self._iprot
1384  (fname, mtype, rseqid) = iprot.readMessageBegin()
1385  if mtype == TMessageType.EXCEPTION:
1386  x = TApplicationException()
1387  x.read(iprot)
1388  iprot.readMessageEnd()
1389  raise x
1390  result = get_version_result()
1391  result.read(iprot)
1392  iprot.readMessageEnd()
1393  if result.success is not None:
1394  return result.success
1395  if result.e is not None:
1396  raise result.e
1397  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_version failed: unknown result")
1398 
1399  def start_heap_profile(self, session):
1400  """
1401  Parameters:
1402  - session
1403 
1404  """
1405  self.send_start_heap_profile(session)
1407 
1408  def send_start_heap_profile(self, session):
1409  self._oprot.writeMessageBegin('start_heap_profile', TMessageType.CALL, self._seqid)
1410  args = start_heap_profile_args()
1411  args.session = session
1412  args.write(self._oprot)
1413  self._oprot.writeMessageEnd()
1414  self._oprot.trans.flush()
1415 
1417  iprot = self._iprot
1418  (fname, mtype, rseqid) = iprot.readMessageBegin()
1419  if mtype == TMessageType.EXCEPTION:
1420  x = TApplicationException()
1421  x.read(iprot)
1422  iprot.readMessageEnd()
1423  raise x
1424  result = start_heap_profile_result()
1425  result.read(iprot)
1426  iprot.readMessageEnd()
1427  if result.e is not None:
1428  raise result.e
1429  return
1430 
1431  def stop_heap_profile(self, session):
1432  """
1433  Parameters:
1434  - session
1435 
1436  """
1437  self.send_stop_heap_profile(session)
1438  self.recv_stop_heap_profile()
1439 
1440  def send_stop_heap_profile(self, session):
1441  self._oprot.writeMessageBegin('stop_heap_profile', TMessageType.CALL, self._seqid)
1442  args = stop_heap_profile_args()
1443  args.session = session
1444  args.write(self._oprot)
1445  self._oprot.writeMessageEnd()
1446  self._oprot.trans.flush()
1447 
1449  iprot = self._iprot
1450  (fname, mtype, rseqid) = iprot.readMessageBegin()
1451  if mtype == TMessageType.EXCEPTION:
1452  x = TApplicationException()
1453  x.read(iprot)
1454  iprot.readMessageEnd()
1455  raise x
1456  result = stop_heap_profile_result()
1457  result.read(iprot)
1458  iprot.readMessageEnd()
1459  if result.e is not None:
1460  raise result.e
1461  return
1462 
1463  def get_heap_profile(self, session):
1464  """
1465  Parameters:
1466  - session
1467 
1468  """
1469  self.send_get_heap_profile(session)
1470  return self.recv_get_heap_profile()
1471 
1472  def send_get_heap_profile(self, session):
1473  self._oprot.writeMessageBegin('get_heap_profile', TMessageType.CALL, self._seqid)
1474  args = get_heap_profile_args()
1475  args.session = session
1476  args.write(self._oprot)
1477  self._oprot.writeMessageEnd()
1478  self._oprot.trans.flush()
1479 
1481  iprot = self._iprot
1482  (fname, mtype, rseqid) = iprot.readMessageBegin()
1483  if mtype == TMessageType.EXCEPTION:
1484  x = TApplicationException()
1485  x.read(iprot)
1486  iprot.readMessageEnd()
1487  raise x
1488  result = get_heap_profile_result()
1489  result.read(iprot)
1490  iprot.readMessageEnd()
1491  if result.success is not None:
1492  return result.success
1493  if result.e is not None:
1494  raise result.e
1495  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_heap_profile failed: unknown result")
1496 
1497  def get_memory(self, session, memory_level):
1498  """
1499  Parameters:
1500  - session
1501  - memory_level
1502 
1503  """
1504  self.send_get_memory(session, memory_level)
1505  return self.recv_get_memory()
1506 
1507  def send_get_memory(self, session, memory_level):
1508  self._oprot.writeMessageBegin('get_memory', TMessageType.CALL, self._seqid)
1509  args = get_memory_args()
1510  args.session = session
1511  args.memory_level = memory_level
1512  args.write(self._oprot)
1513  self._oprot.writeMessageEnd()
1514  self._oprot.trans.flush()
1515 
1516  def recv_get_memory(self):
1517  iprot = self._iprot
1518  (fname, mtype, rseqid) = iprot.readMessageBegin()
1519  if mtype == TMessageType.EXCEPTION:
1520  x = TApplicationException()
1521  x.read(iprot)
1522  iprot.readMessageEnd()
1523  raise x
1524  result = get_memory_result()
1525  result.read(iprot)
1526  iprot.readMessageEnd()
1527  if result.success is not None:
1528  return result.success
1529  if result.e is not None:
1530  raise result.e
1531  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_memory failed: unknown result")
1532 
1533  def clear_cpu_memory(self, session):
1534  """
1535  Parameters:
1536  - session
1537 
1538  """
1539  self.send_clear_cpu_memory(session)
1540  self.recv_clear_cpu_memory()
1541 
1542  def send_clear_cpu_memory(self, session):
1543  self._oprot.writeMessageBegin('clear_cpu_memory', TMessageType.CALL, self._seqid)
1544  args = clear_cpu_memory_args()
1545  args.session = session
1546  args.write(self._oprot)
1547  self._oprot.writeMessageEnd()
1548  self._oprot.trans.flush()
1549 
1551  iprot = self._iprot
1552  (fname, mtype, rseqid) = iprot.readMessageBegin()
1553  if mtype == TMessageType.EXCEPTION:
1554  x = TApplicationException()
1555  x.read(iprot)
1556  iprot.readMessageEnd()
1557  raise x
1558  result = clear_cpu_memory_result()
1559  result.read(iprot)
1560  iprot.readMessageEnd()
1561  if result.e is not None:
1562  raise result.e
1563  return
1564 
1565  def clear_gpu_memory(self, session):
1566  """
1567  Parameters:
1568  - session
1569 
1570  """
1571  self.send_clear_gpu_memory(session)
1572  self.recv_clear_gpu_memory()
1573 
1574  def send_clear_gpu_memory(self, session):
1575  self._oprot.writeMessageBegin('clear_gpu_memory', TMessageType.CALL, self._seqid)
1576  args = clear_gpu_memory_args()
1577  args.session = session
1578  args.write(self._oprot)
1579  self._oprot.writeMessageEnd()
1580  self._oprot.trans.flush()
1581 
1583  iprot = self._iprot
1584  (fname, mtype, rseqid) = iprot.readMessageBegin()
1585  if mtype == TMessageType.EXCEPTION:
1586  x = TApplicationException()
1587  x.read(iprot)
1588  iprot.readMessageEnd()
1589  raise x
1590  result = clear_gpu_memory_result()
1591  result.read(iprot)
1592  iprot.readMessageEnd()
1593  if result.e is not None:
1594  raise result.e
1595  return
1596 
1597  def set_table_epoch(self, session, db_id, table_id, new_epoch):
1598  """
1599  Parameters:
1600  - session
1601  - db_id
1602  - table_id
1603  - new_epoch
1604 
1605  """
1606  self.send_set_table_epoch(session, db_id, table_id, new_epoch)
1607  self.recv_set_table_epoch()
1608 
1609  def send_set_table_epoch(self, session, db_id, table_id, new_epoch):
1610  self._oprot.writeMessageBegin('set_table_epoch', TMessageType.CALL, self._seqid)
1611  args = set_table_epoch_args()
1612  args.session = session
1613  args.db_id = db_id
1614  args.table_id = table_id
1615  args.new_epoch = new_epoch
1616  args.write(self._oprot)
1617  self._oprot.writeMessageEnd()
1618  self._oprot.trans.flush()
1619 
1621  iprot = self._iprot
1622  (fname, mtype, rseqid) = iprot.readMessageBegin()
1623  if mtype == TMessageType.EXCEPTION:
1624  x = TApplicationException()
1625  x.read(iprot)
1626  iprot.readMessageEnd()
1627  raise x
1628  result = set_table_epoch_result()
1629  result.read(iprot)
1630  iprot.readMessageEnd()
1631  if result.e is not None:
1632  raise result.e
1633  return
1634 
1635  def set_table_epoch_by_name(self, session, table_name, new_epoch):
1636  """
1637  Parameters:
1638  - session
1639  - table_name
1640  - new_epoch
1641 
1642  """
1643  self.send_set_table_epoch_by_name(session, table_name, new_epoch)
1645 
1646  def send_set_table_epoch_by_name(self, session, table_name, new_epoch):
1647  self._oprot.writeMessageBegin('set_table_epoch_by_name', TMessageType.CALL, self._seqid)
1649  args.session = session
1650  args.table_name = table_name
1651  args.new_epoch = new_epoch
1652  args.write(self._oprot)
1653  self._oprot.writeMessageEnd()
1654  self._oprot.trans.flush()
1655 
1657  iprot = self._iprot
1658  (fname, mtype, rseqid) = iprot.readMessageBegin()
1659  if mtype == TMessageType.EXCEPTION:
1660  x = TApplicationException()
1661  x.read(iprot)
1662  iprot.readMessageEnd()
1663  raise x
1665  result.read(iprot)
1666  iprot.readMessageEnd()
1667  if result.e is not None:
1668  raise result.e
1669  return
1670 
1671  def get_table_epoch(self, session, db_id, table_id):
1672  """
1673  Parameters:
1674  - session
1675  - db_id
1676  - table_id
1677 
1678  """
1679  self.send_get_table_epoch(session, db_id, table_id)
1680  return self.recv_get_table_epoch()
1681 
1682  def send_get_table_epoch(self, session, db_id, table_id):
1683  self._oprot.writeMessageBegin('get_table_epoch', TMessageType.CALL, self._seqid)
1684  args = get_table_epoch_args()
1685  args.session = session
1686  args.db_id = db_id
1687  args.table_id = table_id
1688  args.write(self._oprot)
1689  self._oprot.writeMessageEnd()
1690  self._oprot.trans.flush()
1691 
1693  iprot = self._iprot
1694  (fname, mtype, rseqid) = iprot.readMessageBegin()
1695  if mtype == TMessageType.EXCEPTION:
1696  x = TApplicationException()
1697  x.read(iprot)
1698  iprot.readMessageEnd()
1699  raise x
1700  result = get_table_epoch_result()
1701  result.read(iprot)
1702  iprot.readMessageEnd()
1703  if result.success is not None:
1704  return result.success
1705  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table_epoch failed: unknown result")
1706 
1707  def get_table_epoch_by_name(self, session, table_name):
1708  """
1709  Parameters:
1710  - session
1711  - table_name
1712 
1713  """
1714  self.send_get_table_epoch_by_name(session, table_name)
1715  return self.recv_get_table_epoch_by_name()
1716 
1717  def send_get_table_epoch_by_name(self, session, table_name):
1718  self._oprot.writeMessageBegin('get_table_epoch_by_name', TMessageType.CALL, self._seqid)
1720  args.session = session
1721  args.table_name = table_name
1722  args.write(self._oprot)
1723  self._oprot.writeMessageEnd()
1724  self._oprot.trans.flush()
1725 
1727  iprot = self._iprot
1728  (fname, mtype, rseqid) = iprot.readMessageBegin()
1729  if mtype == TMessageType.EXCEPTION:
1730  x = TApplicationException()
1731  x.read(iprot)
1732  iprot.readMessageEnd()
1733  raise x
1735  result.read(iprot)
1736  iprot.readMessageEnd()
1737  if result.success is not None:
1738  return result.success
1739  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table_epoch_by_name failed: unknown result")
1740 
1741  def get_session_info(self, session):
1742  """
1743  Parameters:
1744  - session
1745 
1746  """
1747  self.send_get_session_info(session)
1748  return self.recv_get_session_info()
1749 
1750  def send_get_session_info(self, session):
1751  self._oprot.writeMessageBegin('get_session_info', TMessageType.CALL, self._seqid)
1752  args = get_session_info_args()
1753  args.session = session
1754  args.write(self._oprot)
1755  self._oprot.writeMessageEnd()
1756  self._oprot.trans.flush()
1757 
1759  iprot = self._iprot
1760  (fname, mtype, rseqid) = iprot.readMessageBegin()
1761  if mtype == TMessageType.EXCEPTION:
1762  x = TApplicationException()
1763  x.read(iprot)
1764  iprot.readMessageEnd()
1765  raise x
1766  result = get_session_info_result()
1767  result.read(iprot)
1768  iprot.readMessageEnd()
1769  if result.success is not None:
1770  return result.success
1771  if result.e is not None:
1772  raise result.e
1773  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_session_info failed: unknown result")
1774 
1775  def sql_execute(self, session, query, column_format, nonce, first_n, at_most_n):
1776  """
1777  Parameters:
1778  - session
1779  - query
1780  - column_format
1781  - nonce
1782  - first_n
1783  - at_most_n
1784 
1785  """
1786  self.send_sql_execute(session, query, column_format, nonce, first_n, at_most_n)
1787  return self.recv_sql_execute()
1788 
1789  def send_sql_execute(self, session, query, column_format, nonce, first_n, at_most_n):
1790  self._oprot.writeMessageBegin('sql_execute', TMessageType.CALL, self._seqid)
1791  args = sql_execute_args()
1792  args.session = session
1793  args.query = query
1794  args.column_format = column_format
1795  args.nonce = nonce
1796  args.first_n = first_n
1797  args.at_most_n = at_most_n
1798  args.write(self._oprot)
1799  self._oprot.writeMessageEnd()
1800  self._oprot.trans.flush()
1801 
1802  def recv_sql_execute(self):
1803  iprot = self._iprot
1804  (fname, mtype, rseqid) = iprot.readMessageBegin()
1805  if mtype == TMessageType.EXCEPTION:
1806  x = TApplicationException()
1807  x.read(iprot)
1808  iprot.readMessageEnd()
1809  raise x
1810  result = sql_execute_result()
1811  result.read(iprot)
1812  iprot.readMessageEnd()
1813  if result.success is not None:
1814  return result.success
1815  if result.e is not None:
1816  raise result.e
1817  raise TApplicationException(TApplicationException.MISSING_RESULT, "sql_execute failed: unknown result")
1818 
1819  def sql_execute_df(self, session, query, device_type, device_id, first_n, transport_method):
1820  """
1821  Parameters:
1822  - session
1823  - query
1824  - device_type
1825  - device_id
1826  - first_n
1827  - transport_method
1828 
1829  """
1830  self.send_sql_execute_df(session, query, device_type, device_id, first_n, transport_method)
1831  return self.recv_sql_execute_df()
1832 
1833  def send_sql_execute_df(self, session, query, device_type, device_id, first_n, transport_method):
1834  self._oprot.writeMessageBegin('sql_execute_df', TMessageType.CALL, self._seqid)
1835  args = sql_execute_df_args()
1836  args.session = session
1837  args.query = query
1838  args.device_type = device_type
1839  args.device_id = device_id
1840  args.first_n = first_n
1841  args.transport_method = transport_method
1842  args.write(self._oprot)
1843  self._oprot.writeMessageEnd()
1844  self._oprot.trans.flush()
1845 
1847  iprot = self._iprot
1848  (fname, mtype, rseqid) = iprot.readMessageBegin()
1849  if mtype == TMessageType.EXCEPTION:
1850  x = TApplicationException()
1851  x.read(iprot)
1852  iprot.readMessageEnd()
1853  raise x
1854  result = sql_execute_df_result()
1855  result.read(iprot)
1856  iprot.readMessageEnd()
1857  if result.success is not None:
1858  return result.success
1859  if result.e is not None:
1860  raise result.e
1861  raise TApplicationException(TApplicationException.MISSING_RESULT, "sql_execute_df failed: unknown result")
1862 
1863  def sql_execute_gdf(self, session, query, device_id, first_n):
1864  """
1865  Parameters:
1866  - session
1867  - query
1868  - device_id
1869  - first_n
1870 
1871  """
1872  self.send_sql_execute_gdf(session, query, device_id, first_n)
1873  return self.recv_sql_execute_gdf()
1874 
1875  def send_sql_execute_gdf(self, session, query, device_id, first_n):
1876  self._oprot.writeMessageBegin('sql_execute_gdf', TMessageType.CALL, self._seqid)
1877  args = sql_execute_gdf_args()
1878  args.session = session
1879  args.query = query
1880  args.device_id = device_id
1881  args.first_n = first_n
1882  args.write(self._oprot)
1883  self._oprot.writeMessageEnd()
1884  self._oprot.trans.flush()
1885 
1887  iprot = self._iprot
1888  (fname, mtype, rseqid) = iprot.readMessageBegin()
1889  if mtype == TMessageType.EXCEPTION:
1890  x = TApplicationException()
1891  x.read(iprot)
1892  iprot.readMessageEnd()
1893  raise x
1894  result = sql_execute_gdf_result()
1895  result.read(iprot)
1896  iprot.readMessageEnd()
1897  if result.success is not None:
1898  return result.success
1899  if result.e is not None:
1900  raise result.e
1901  raise TApplicationException(TApplicationException.MISSING_RESULT, "sql_execute_gdf failed: unknown result")
1902 
1903  def deallocate_df(self, session, df, device_type, device_id):
1904  """
1905  Parameters:
1906  - session
1907  - df
1908  - device_type
1909  - device_id
1910 
1911  """
1912  self.send_deallocate_df(session, df, device_type, device_id)
1913  self.recv_deallocate_df()
1914 
1915  def send_deallocate_df(self, session, df, device_type, device_id):
1916  self._oprot.writeMessageBegin('deallocate_df', TMessageType.CALL, self._seqid)
1917  args = deallocate_df_args()
1918  args.session = session
1919  args.df = df
1920  args.device_type = device_type
1921  args.device_id = device_id
1922  args.write(self._oprot)
1923  self._oprot.writeMessageEnd()
1924  self._oprot.trans.flush()
1925 
1927  iprot = self._iprot
1928  (fname, mtype, rseqid) = iprot.readMessageBegin()
1929  if mtype == TMessageType.EXCEPTION:
1930  x = TApplicationException()
1931  x.read(iprot)
1932  iprot.readMessageEnd()
1933  raise x
1934  result = deallocate_df_result()
1935  result.read(iprot)
1936  iprot.readMessageEnd()
1937  if result.e is not None:
1938  raise result.e
1939  return
1940 
1941  def interrupt(self, query_session, interrupt_session):
1942  """
1943  Parameters:
1944  - query_session
1945  - interrupt_session
1946 
1947  """
1948  self.send_interrupt(query_session, interrupt_session)
1949  self.recv_interrupt()
1950 
1951  def send_interrupt(self, query_session, interrupt_session):
1952  self._oprot.writeMessageBegin('interrupt', TMessageType.CALL, self._seqid)
1953  args = interrupt_args()
1954  args.query_session = query_session
1955  args.interrupt_session = interrupt_session
1956  args.write(self._oprot)
1957  self._oprot.writeMessageEnd()
1958  self._oprot.trans.flush()
1959 
1960  def recv_interrupt(self):
1961  iprot = self._iprot
1962  (fname, mtype, rseqid) = iprot.readMessageBegin()
1963  if mtype == TMessageType.EXCEPTION:
1964  x = TApplicationException()
1965  x.read(iprot)
1966  iprot.readMessageEnd()
1967  raise x
1968  result = interrupt_result()
1969  result.read(iprot)
1970  iprot.readMessageEnd()
1971  if result.e is not None:
1972  raise result.e
1973  return
1974 
1975  def sql_validate(self, session, query):
1976  """
1977  Parameters:
1978  - session
1979  - query
1980 
1981  """
1982  self.send_sql_validate(session, query)
1983  return self.recv_sql_validate()
1984 
1985  def send_sql_validate(self, session, query):
1986  self._oprot.writeMessageBegin('sql_validate', TMessageType.CALL, self._seqid)
1987  args = sql_validate_args()
1988  args.session = session
1989  args.query = query
1990  args.write(self._oprot)
1991  self._oprot.writeMessageEnd()
1992  self._oprot.trans.flush()
1993 
1995  iprot = self._iprot
1996  (fname, mtype, rseqid) = iprot.readMessageBegin()
1997  if mtype == TMessageType.EXCEPTION:
1998  x = TApplicationException()
1999  x.read(iprot)
2000  iprot.readMessageEnd()
2001  raise x
2002  result = sql_validate_result()
2003  result.read(iprot)
2004  iprot.readMessageEnd()
2005  if result.success is not None:
2006  return result.success
2007  if result.e is not None:
2008  raise result.e
2009  raise TApplicationException(TApplicationException.MISSING_RESULT, "sql_validate failed: unknown result")
2010 
2011  def get_completion_hints(self, session, sql, cursor):
2012  """
2013  Parameters:
2014  - session
2015  - sql
2016  - cursor
2017 
2018  """
2019  self.send_get_completion_hints(session, sql, cursor)
2020  return self.recv_get_completion_hints()
2021 
2022  def send_get_completion_hints(self, session, sql, cursor):
2023  self._oprot.writeMessageBegin('get_completion_hints', TMessageType.CALL, self._seqid)
2024  args = get_completion_hints_args()
2025  args.session = session
2026  args.sql = sql
2027  args.cursor = cursor
2028  args.write(self._oprot)
2029  self._oprot.writeMessageEnd()
2030  self._oprot.trans.flush()
2031 
2033  iprot = self._iprot
2034  (fname, mtype, rseqid) = iprot.readMessageBegin()
2035  if mtype == TMessageType.EXCEPTION:
2036  x = TApplicationException()
2037  x.read(iprot)
2038  iprot.readMessageEnd()
2039  raise x
2040  result = get_completion_hints_result()
2041  result.read(iprot)
2042  iprot.readMessageEnd()
2043  if result.success is not None:
2044  return result.success
2045  if result.e is not None:
2046  raise result.e
2047  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_completion_hints failed: unknown result")
2048 
2049  def set_execution_mode(self, session, mode):
2050  """
2051  Parameters:
2052  - session
2053  - mode
2054 
2055  """
2056  self.send_set_execution_mode(session, mode)
2058 
2059  def send_set_execution_mode(self, session, mode):
2060  self._oprot.writeMessageBegin('set_execution_mode', TMessageType.CALL, self._seqid)
2061  args = set_execution_mode_args()
2062  args.session = session
2063  args.mode = mode
2064  args.write(self._oprot)
2065  self._oprot.writeMessageEnd()
2066  self._oprot.trans.flush()
2067 
2069  iprot = self._iprot
2070  (fname, mtype, rseqid) = iprot.readMessageBegin()
2071  if mtype == TMessageType.EXCEPTION:
2072  x = TApplicationException()
2073  x.read(iprot)
2074  iprot.readMessageEnd()
2075  raise x
2076  result = set_execution_mode_result()
2077  result.read(iprot)
2078  iprot.readMessageEnd()
2079  if result.e is not None:
2080  raise result.e
2081  return
2082 
2083  def render_vega(self, session, widget_id, vega_json, compression_level, nonce):
2084  """
2085  Parameters:
2086  - session
2087  - widget_id
2088  - vega_json
2089  - compression_level
2090  - nonce
2091 
2092  """
2093  self.send_render_vega(session, widget_id, vega_json, compression_level, nonce)
2094  return self.recv_render_vega()
2095 
2096  def send_render_vega(self, session, widget_id, vega_json, compression_level, nonce):
2097  self._oprot.writeMessageBegin('render_vega', TMessageType.CALL, self._seqid)
2098  args = render_vega_args()
2099  args.session = session
2100  args.widget_id = widget_id
2101  args.vega_json = vega_json
2102  args.compression_level = compression_level
2103  args.nonce = nonce
2104  args.write(self._oprot)
2105  self._oprot.writeMessageEnd()
2106  self._oprot.trans.flush()
2107 
2108  def recv_render_vega(self):
2109  iprot = self._iprot
2110  (fname, mtype, rseqid) = iprot.readMessageBegin()
2111  if mtype == TMessageType.EXCEPTION:
2112  x = TApplicationException()
2113  x.read(iprot)
2114  iprot.readMessageEnd()
2115  raise x
2116  result = render_vega_result()
2117  result.read(iprot)
2118  iprot.readMessageEnd()
2119  if result.success is not None:
2120  return result.success
2121  if result.e is not None:
2122  raise result.e
2123  raise TApplicationException(TApplicationException.MISSING_RESULT, "render_vega failed: unknown result")
2124 
2125  def get_result_row_for_pixel(self, session, widget_id, pixel, table_col_names, column_format, pixelRadius, nonce):
2126  """
2127  Parameters:
2128  - session
2129  - widget_id
2130  - pixel
2131  - table_col_names
2132  - column_format
2133  - pixelRadius
2134  - nonce
2135 
2136  """
2137  self.send_get_result_row_for_pixel(session, widget_id, pixel, table_col_names, column_format, pixelRadius, nonce)
2138  return self.recv_get_result_row_for_pixel()
2139 
2140  def send_get_result_row_for_pixel(self, session, widget_id, pixel, table_col_names, column_format, pixelRadius, nonce):
2141  self._oprot.writeMessageBegin('get_result_row_for_pixel', TMessageType.CALL, self._seqid)
2143  args.session = session
2144  args.widget_id = widget_id
2145  args.pixel = pixel
2146  args.table_col_names = table_col_names
2147  args.column_format = column_format
2148  args.pixelRadius = pixelRadius
2149  args.nonce = nonce
2150  args.write(self._oprot)
2151  self._oprot.writeMessageEnd()
2152  self._oprot.trans.flush()
2153 
2155  iprot = self._iprot
2156  (fname, mtype, rseqid) = iprot.readMessageBegin()
2157  if mtype == TMessageType.EXCEPTION:
2158  x = TApplicationException()
2159  x.read(iprot)
2160  iprot.readMessageEnd()
2161  raise x
2163  result.read(iprot)
2164  iprot.readMessageEnd()
2165  if result.success is not None:
2166  return result.success
2167  if result.e is not None:
2168  raise result.e
2169  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_result_row_for_pixel failed: unknown result")
2170 
2171  def get_dashboard(self, session, dashboard_id):
2172  """
2173  Parameters:
2174  - session
2175  - dashboard_id
2176 
2177  """
2178  self.send_get_dashboard(session, dashboard_id)
2179  return self.recv_get_dashboard()
2180 
2181  def send_get_dashboard(self, session, dashboard_id):
2182  self._oprot.writeMessageBegin('get_dashboard', TMessageType.CALL, self._seqid)
2183  args = get_dashboard_args()
2184  args.session = session
2185  args.dashboard_id = dashboard_id
2186  args.write(self._oprot)
2187  self._oprot.writeMessageEnd()
2188  self._oprot.trans.flush()
2189 
2191  iprot = self._iprot
2192  (fname, mtype, rseqid) = iprot.readMessageBegin()
2193  if mtype == TMessageType.EXCEPTION:
2194  x = TApplicationException()
2195  x.read(iprot)
2196  iprot.readMessageEnd()
2197  raise x
2198  result = get_dashboard_result()
2199  result.read(iprot)
2200  iprot.readMessageEnd()
2201  if result.success is not None:
2202  return result.success
2203  if result.e is not None:
2204  raise result.e
2205  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_dashboard failed: unknown result")
2206 
2207  def get_dashboards(self, session):
2208  """
2209  Parameters:
2210  - session
2211 
2212  """
2213  self.send_get_dashboards(session)
2214  return self.recv_get_dashboards()
2215 
2216  def send_get_dashboards(self, session):
2217  self._oprot.writeMessageBegin('get_dashboards', TMessageType.CALL, self._seqid)
2218  args = get_dashboards_args()
2219  args.session = session
2220  args.write(self._oprot)
2221  self._oprot.writeMessageEnd()
2222  self._oprot.trans.flush()
2223 
2225  iprot = self._iprot
2226  (fname, mtype, rseqid) = iprot.readMessageBegin()
2227  if mtype == TMessageType.EXCEPTION:
2228  x = TApplicationException()
2229  x.read(iprot)
2230  iprot.readMessageEnd()
2231  raise x
2232  result = get_dashboards_result()
2233  result.read(iprot)
2234  iprot.readMessageEnd()
2235  if result.success is not None:
2236  return result.success
2237  if result.e is not None:
2238  raise result.e
2239  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_dashboards failed: unknown result")
2240 
2241  def create_dashboard(self, session, dashboard_name, dashboard_state, image_hash, dashboard_metadata):
2242  """
2243  Parameters:
2244  - session
2245  - dashboard_name
2246  - dashboard_state
2247  - image_hash
2248  - dashboard_metadata
2249 
2250  """
2251  self.send_create_dashboard(session, dashboard_name, dashboard_state, image_hash, dashboard_metadata)
2252  return self.recv_create_dashboard()
2253 
2254  def send_create_dashboard(self, session, dashboard_name, dashboard_state, image_hash, dashboard_metadata):
2255  self._oprot.writeMessageBegin('create_dashboard', TMessageType.CALL, self._seqid)
2256  args = create_dashboard_args()
2257  args.session = session
2258  args.dashboard_name = dashboard_name
2259  args.dashboard_state = dashboard_state
2260  args.image_hash = image_hash
2261  args.dashboard_metadata = dashboard_metadata
2262  args.write(self._oprot)
2263  self._oprot.writeMessageEnd()
2264  self._oprot.trans.flush()
2265 
2267  iprot = self._iprot
2268  (fname, mtype, rseqid) = iprot.readMessageBegin()
2269  if mtype == TMessageType.EXCEPTION:
2270  x = TApplicationException()
2271  x.read(iprot)
2272  iprot.readMessageEnd()
2273  raise x
2274  result = create_dashboard_result()
2275  result.read(iprot)
2276  iprot.readMessageEnd()
2277  if result.success is not None:
2278  return result.success
2279  if result.e is not None:
2280  raise result.e
2281  raise TApplicationException(TApplicationException.MISSING_RESULT, "create_dashboard failed: unknown result")
2282 
2283  def replace_dashboard(self, session, dashboard_id, dashboard_name, dashboard_owner, dashboard_state, image_hash, dashboard_metadata):
2284  """
2285  Parameters:
2286  - session
2287  - dashboard_id
2288  - dashboard_name
2289  - dashboard_owner
2290  - dashboard_state
2291  - image_hash
2292  - dashboard_metadata
2293 
2294  """
2295  self.send_replace_dashboard(session, dashboard_id, dashboard_name, dashboard_owner, dashboard_state, image_hash, dashboard_metadata)
2296  self.recv_replace_dashboard()
2297 
2298  def send_replace_dashboard(self, session, dashboard_id, dashboard_name, dashboard_owner, dashboard_state, image_hash, dashboard_metadata):
2299  self._oprot.writeMessageBegin('replace_dashboard', TMessageType.CALL, self._seqid)
2300  args = replace_dashboard_args()
2301  args.session = session
2302  args.dashboard_id = dashboard_id
2303  args.dashboard_name = dashboard_name
2304  args.dashboard_owner = dashboard_owner
2305  args.dashboard_state = dashboard_state
2306  args.image_hash = image_hash
2307  args.dashboard_metadata = dashboard_metadata
2308  args.write(self._oprot)
2309  self._oprot.writeMessageEnd()
2310  self._oprot.trans.flush()
2311 
2313  iprot = self._iprot
2314  (fname, mtype, rseqid) = iprot.readMessageBegin()
2315  if mtype == TMessageType.EXCEPTION:
2316  x = TApplicationException()
2317  x.read(iprot)
2318  iprot.readMessageEnd()
2319  raise x
2320  result = replace_dashboard_result()
2321  result.read(iprot)
2322  iprot.readMessageEnd()
2323  if result.e is not None:
2324  raise result.e
2325  return
2326 
2327  def delete_dashboard(self, session, dashboard_id):
2328  """
2329  Parameters:
2330  - session
2331  - dashboard_id
2332 
2333  """
2334  self.send_delete_dashboard(session, dashboard_id)
2335  self.recv_delete_dashboard()
2336 
2337  def send_delete_dashboard(self, session, dashboard_id):
2338  self._oprot.writeMessageBegin('delete_dashboard', TMessageType.CALL, self._seqid)
2339  args = delete_dashboard_args()
2340  args.session = session
2341  args.dashboard_id = dashboard_id
2342  args.write(self._oprot)
2343  self._oprot.writeMessageEnd()
2344  self._oprot.trans.flush()
2345 
2347  iprot = self._iprot
2348  (fname, mtype, rseqid) = iprot.readMessageBegin()
2349  if mtype == TMessageType.EXCEPTION:
2350  x = TApplicationException()
2351  x.read(iprot)
2352  iprot.readMessageEnd()
2353  raise x
2354  result = delete_dashboard_result()
2355  result.read(iprot)
2356  iprot.readMessageEnd()
2357  if result.e is not None:
2358  raise result.e
2359  return
2360 
2361  def share_dashboards(self, session, dashboard_ids, groups, permissions):
2362  """
2363  Parameters:
2364  - session
2365  - dashboard_ids
2366  - groups
2367  - permissions
2368 
2369  """
2370  self.send_share_dashboards(session, dashboard_ids, groups, permissions)
2371  self.recv_share_dashboards()
2372 
2373  def send_share_dashboards(self, session, dashboard_ids, groups, permissions):
2374  self._oprot.writeMessageBegin('share_dashboards', TMessageType.CALL, self._seqid)
2375  args = share_dashboards_args()
2376  args.session = session
2377  args.dashboard_ids = dashboard_ids
2378  args.groups = groups
2379  args.permissions = permissions
2380  args.write(self._oprot)
2381  self._oprot.writeMessageEnd()
2382  self._oprot.trans.flush()
2383 
2385  iprot = self._iprot
2386  (fname, mtype, rseqid) = iprot.readMessageBegin()
2387  if mtype == TMessageType.EXCEPTION:
2388  x = TApplicationException()
2389  x.read(iprot)
2390  iprot.readMessageEnd()
2391  raise x
2392  result = share_dashboards_result()
2393  result.read(iprot)
2394  iprot.readMessageEnd()
2395  if result.e is not None:
2396  raise result.e
2397  return
2398 
2399  def delete_dashboards(self, session, dashboard_ids):
2400  """
2401  Parameters:
2402  - session
2403  - dashboard_ids
2404 
2405  """
2406  self.send_delete_dashboards(session, dashboard_ids)
2407  self.recv_delete_dashboards()
2408 
2409  def send_delete_dashboards(self, session, dashboard_ids):
2410  self._oprot.writeMessageBegin('delete_dashboards', TMessageType.CALL, self._seqid)
2411  args = delete_dashboards_args()
2412  args.session = session
2413  args.dashboard_ids = dashboard_ids
2414  args.write(self._oprot)
2415  self._oprot.writeMessageEnd()
2416  self._oprot.trans.flush()
2417 
2419  iprot = self._iprot
2420  (fname, mtype, rseqid) = iprot.readMessageBegin()
2421  if mtype == TMessageType.EXCEPTION:
2422  x = TApplicationException()
2423  x.read(iprot)
2424  iprot.readMessageEnd()
2425  raise x
2426  result = delete_dashboards_result()
2427  result.read(iprot)
2428  iprot.readMessageEnd()
2429  if result.e is not None:
2430  raise result.e
2431  return
2432 
2433  def share_dashboard(self, session, dashboard_id, groups, objects, permissions, grant_role):
2434  """
2435  Parameters:
2436  - session
2437  - dashboard_id
2438  - groups
2439  - objects
2440  - permissions
2441  - grant_role
2442 
2443  """
2444  self.send_share_dashboard(session, dashboard_id, groups, objects, permissions, grant_role)
2445  self.recv_share_dashboard()
2446 
2447  def send_share_dashboard(self, session, dashboard_id, groups, objects, permissions, grant_role):
2448  self._oprot.writeMessageBegin('share_dashboard', TMessageType.CALL, self._seqid)
2449  args = share_dashboard_args()
2450  args.session = session
2451  args.dashboard_id = dashboard_id
2452  args.groups = groups
2453  args.objects = objects
2454  args.permissions = permissions
2455  args.grant_role = grant_role
2456  args.write(self._oprot)
2457  self._oprot.writeMessageEnd()
2458  self._oprot.trans.flush()
2459 
2461  iprot = self._iprot
2462  (fname, mtype, rseqid) = iprot.readMessageBegin()
2463  if mtype == TMessageType.EXCEPTION:
2464  x = TApplicationException()
2465  x.read(iprot)
2466  iprot.readMessageEnd()
2467  raise x
2468  result = share_dashboard_result()
2469  result.read(iprot)
2470  iprot.readMessageEnd()
2471  if result.e is not None:
2472  raise result.e
2473  return
2474 
2475  def unshare_dashboard(self, session, dashboard_id, groups, objects, permissions):
2476  """
2477  Parameters:
2478  - session
2479  - dashboard_id
2480  - groups
2481  - objects
2482  - permissions
2483 
2484  """
2485  self.send_unshare_dashboard(session, dashboard_id, groups, objects, permissions)
2486  self.recv_unshare_dashboard()
2487 
2488  def send_unshare_dashboard(self, session, dashboard_id, groups, objects, permissions):
2489  self._oprot.writeMessageBegin('unshare_dashboard', TMessageType.CALL, self._seqid)
2490  args = unshare_dashboard_args()
2491  args.session = session
2492  args.dashboard_id = dashboard_id
2493  args.groups = groups
2494  args.objects = objects
2495  args.permissions = permissions
2496  args.write(self._oprot)
2497  self._oprot.writeMessageEnd()
2498  self._oprot.trans.flush()
2499 
2501  iprot = self._iprot
2502  (fname, mtype, rseqid) = iprot.readMessageBegin()
2503  if mtype == TMessageType.EXCEPTION:
2504  x = TApplicationException()
2505  x.read(iprot)
2506  iprot.readMessageEnd()
2507  raise x
2508  result = unshare_dashboard_result()
2509  result.read(iprot)
2510  iprot.readMessageEnd()
2511  if result.e is not None:
2512  raise result.e
2513  return
2514 
2515  def unshare_dashboards(self, session, dashboard_ids, groups, permissions):
2516  """
2517  Parameters:
2518  - session
2519  - dashboard_ids
2520  - groups
2521  - permissions
2522 
2523  """
2524  self.send_unshare_dashboards(session, dashboard_ids, groups, permissions)
2526 
2527  def send_unshare_dashboards(self, session, dashboard_ids, groups, permissions):
2528  self._oprot.writeMessageBegin('unshare_dashboards', TMessageType.CALL, self._seqid)
2529  args = unshare_dashboards_args()
2530  args.session = session
2531  args.dashboard_ids = dashboard_ids
2532  args.groups = groups
2533  args.permissions = permissions
2534  args.write(self._oprot)
2535  self._oprot.writeMessageEnd()
2536  self._oprot.trans.flush()
2537 
2539  iprot = self._iprot
2540  (fname, mtype, rseqid) = iprot.readMessageBegin()
2541  if mtype == TMessageType.EXCEPTION:
2542  x = TApplicationException()
2543  x.read(iprot)
2544  iprot.readMessageEnd()
2545  raise x
2546  result = unshare_dashboards_result()
2547  result.read(iprot)
2548  iprot.readMessageEnd()
2549  if result.e is not None:
2550  raise result.e
2551  return
2552 
2553  def get_dashboard_grantees(self, session, dashboard_id):
2554  """
2555  Parameters:
2556  - session
2557  - dashboard_id
2558 
2559  """
2560  self.send_get_dashboard_grantees(session, dashboard_id)
2561  return self.recv_get_dashboard_grantees()
2562 
2563  def send_get_dashboard_grantees(self, session, dashboard_id):
2564  self._oprot.writeMessageBegin('get_dashboard_grantees', TMessageType.CALL, self._seqid)
2566  args.session = session
2567  args.dashboard_id = dashboard_id
2568  args.write(self._oprot)
2569  self._oprot.writeMessageEnd()
2570  self._oprot.trans.flush()
2571 
2573  iprot = self._iprot
2574  (fname, mtype, rseqid) = iprot.readMessageBegin()
2575  if mtype == TMessageType.EXCEPTION:
2576  x = TApplicationException()
2577  x.read(iprot)
2578  iprot.readMessageEnd()
2579  raise x
2581  result.read(iprot)
2582  iprot.readMessageEnd()
2583  if result.success is not None:
2584  return result.success
2585  if result.e is not None:
2586  raise result.e
2587  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_dashboard_grantees failed: unknown result")
2588 
2589  def get_link_view(self, session, link):
2590  """
2591  Parameters:
2592  - session
2593  - link
2594 
2595  """
2596  self.send_get_link_view(session, link)
2597  return self.recv_get_link_view()
2598 
2599  def send_get_link_view(self, session, link):
2600  self._oprot.writeMessageBegin('get_link_view', TMessageType.CALL, self._seqid)
2601  args = get_link_view_args()
2602  args.session = session
2603  args.link = link
2604  args.write(self._oprot)
2605  self._oprot.writeMessageEnd()
2606  self._oprot.trans.flush()
2607 
2609  iprot = self._iprot
2610  (fname, mtype, rseqid) = iprot.readMessageBegin()
2611  if mtype == TMessageType.EXCEPTION:
2612  x = TApplicationException()
2613  x.read(iprot)
2614  iprot.readMessageEnd()
2615  raise x
2616  result = get_link_view_result()
2617  result.read(iprot)
2618  iprot.readMessageEnd()
2619  if result.success is not None:
2620  return result.success
2621  if result.e is not None:
2622  raise result.e
2623  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_link_view failed: unknown result")
2624 
2625  def create_link(self, session, view_state, view_metadata):
2626  """
2627  Parameters:
2628  - session
2629  - view_state
2630  - view_metadata
2631 
2632  """
2633  self.send_create_link(session, view_state, view_metadata)
2634  return self.recv_create_link()
2635 
2636  def send_create_link(self, session, view_state, view_metadata):
2637  self._oprot.writeMessageBegin('create_link', TMessageType.CALL, self._seqid)
2638  args = create_link_args()
2639  args.session = session
2640  args.view_state = view_state
2641  args.view_metadata = view_metadata
2642  args.write(self._oprot)
2643  self._oprot.writeMessageEnd()
2644  self._oprot.trans.flush()
2645 
2646  def recv_create_link(self):
2647  iprot = self._iprot
2648  (fname, mtype, rseqid) = iprot.readMessageBegin()
2649  if mtype == TMessageType.EXCEPTION:
2650  x = TApplicationException()
2651  x.read(iprot)
2652  iprot.readMessageEnd()
2653  raise x
2654  result = create_link_result()
2655  result.read(iprot)
2656  iprot.readMessageEnd()
2657  if result.success is not None:
2658  return result.success
2659  if result.e is not None:
2660  raise result.e
2661  raise TApplicationException(TApplicationException.MISSING_RESULT, "create_link failed: unknown result")
2662 
2663  def load_table_binary(self, session, table_name, rows):
2664  """
2665  Parameters:
2666  - session
2667  - table_name
2668  - rows
2669 
2670  """
2671  self.send_load_table_binary(session, table_name, rows)
2672  self.recv_load_table_binary()
2673 
2674  def send_load_table_binary(self, session, table_name, rows):
2675  self._oprot.writeMessageBegin('load_table_binary', TMessageType.CALL, self._seqid)
2676  args = load_table_binary_args()
2677  args.session = session
2678  args.table_name = table_name
2679  args.rows = rows
2680  args.write(self._oprot)
2681  self._oprot.writeMessageEnd()
2682  self._oprot.trans.flush()
2683 
2685  iprot = self._iprot
2686  (fname, mtype, rseqid) = iprot.readMessageBegin()
2687  if mtype == TMessageType.EXCEPTION:
2688  x = TApplicationException()
2689  x.read(iprot)
2690  iprot.readMessageEnd()
2691  raise x
2692  result = load_table_binary_result()
2693  result.read(iprot)
2694  iprot.readMessageEnd()
2695  if result.e is not None:
2696  raise result.e
2697  return
2698 
2699  def load_table_binary_columnar(self, session, table_name, cols):
2700  """
2701  Parameters:
2702  - session
2703  - table_name
2704  - cols
2705 
2706  """
2707  self.send_load_table_binary_columnar(session, table_name, cols)
2709 
2710  def send_load_table_binary_columnar(self, session, table_name, cols):
2711  self._oprot.writeMessageBegin('load_table_binary_columnar', TMessageType.CALL, self._seqid)
2713  args.session = session
2714  args.table_name = table_name
2715  args.cols = cols
2716  args.write(self._oprot)
2717  self._oprot.writeMessageEnd()
2718  self._oprot.trans.flush()
2719 
2721  iprot = self._iprot
2722  (fname, mtype, rseqid) = iprot.readMessageBegin()
2723  if mtype == TMessageType.EXCEPTION:
2724  x = TApplicationException()
2725  x.read(iprot)
2726  iprot.readMessageEnd()
2727  raise x
2729  result.read(iprot)
2730  iprot.readMessageEnd()
2731  if result.e is not None:
2732  raise result.e
2733  return
2734 
2735  def load_table_binary_arrow(self, session, table_name, arrow_stream):
2736  """
2737  Parameters:
2738  - session
2739  - table_name
2740  - arrow_stream
2741 
2742  """
2743  self.send_load_table_binary_arrow(session, table_name, arrow_stream)
2745 
2746  def send_load_table_binary_arrow(self, session, table_name, arrow_stream):
2747  self._oprot.writeMessageBegin('load_table_binary_arrow', TMessageType.CALL, self._seqid)
2749  args.session = session
2750  args.table_name = table_name
2751  args.arrow_stream = arrow_stream
2752  args.write(self._oprot)
2753  self._oprot.writeMessageEnd()
2754  self._oprot.trans.flush()
2755 
2757  iprot = self._iprot
2758  (fname, mtype, rseqid) = iprot.readMessageBegin()
2759  if mtype == TMessageType.EXCEPTION:
2760  x = TApplicationException()
2761  x.read(iprot)
2762  iprot.readMessageEnd()
2763  raise x
2765  result.read(iprot)
2766  iprot.readMessageEnd()
2767  if result.e is not None:
2768  raise result.e
2769  return
2770 
2771  def load_table(self, session, table_name, rows):
2772  """
2773  Parameters:
2774  - session
2775  - table_name
2776  - rows
2777 
2778  """
2779  self.send_load_table(session, table_name, rows)
2780  self.recv_load_table()
2781 
2782  def send_load_table(self, session, table_name, rows):
2783  self._oprot.writeMessageBegin('load_table', TMessageType.CALL, self._seqid)
2784  args = load_table_args()
2785  args.session = session
2786  args.table_name = table_name
2787  args.rows = rows
2788  args.write(self._oprot)
2789  self._oprot.writeMessageEnd()
2790  self._oprot.trans.flush()
2791 
2792  def recv_load_table(self):
2793  iprot = self._iprot
2794  (fname, mtype, rseqid) = iprot.readMessageBegin()
2795  if mtype == TMessageType.EXCEPTION:
2796  x = TApplicationException()
2797  x.read(iprot)
2798  iprot.readMessageEnd()
2799  raise x
2800  result = load_table_result()
2801  result.read(iprot)
2802  iprot.readMessageEnd()
2803  if result.e is not None:
2804  raise result.e
2805  return
2806 
2807  def detect_column_types(self, session, file_name, copy_params):
2808  """
2809  Parameters:
2810  - session
2811  - file_name
2812  - copy_params
2813 
2814  """
2815  self.send_detect_column_types(session, file_name, copy_params)
2816  return self.recv_detect_column_types()
2817 
2818  def send_detect_column_types(self, session, file_name, copy_params):
2819  self._oprot.writeMessageBegin('detect_column_types', TMessageType.CALL, self._seqid)
2820  args = detect_column_types_args()
2821  args.session = session
2822  args.file_name = file_name
2823  args.copy_params = copy_params
2824  args.write(self._oprot)
2825  self._oprot.writeMessageEnd()
2826  self._oprot.trans.flush()
2827 
2829  iprot = self._iprot
2830  (fname, mtype, rseqid) = iprot.readMessageBegin()
2831  if mtype == TMessageType.EXCEPTION:
2832  x = TApplicationException()
2833  x.read(iprot)
2834  iprot.readMessageEnd()
2835  raise x
2836  result = detect_column_types_result()
2837  result.read(iprot)
2838  iprot.readMessageEnd()
2839  if result.success is not None:
2840  return result.success
2841  if result.e is not None:
2842  raise result.e
2843  raise TApplicationException(TApplicationException.MISSING_RESULT, "detect_column_types failed: unknown result")
2844 
2845  def create_table(self, session, table_name, row_desc, file_type, create_params):
2846  """
2847  Parameters:
2848  - session
2849  - table_name
2850  - row_desc
2851  - file_type
2852  - create_params
2853 
2854  """
2855  self.send_create_table(session, table_name, row_desc, file_type, create_params)
2856  self.recv_create_table()
2857 
2858  def send_create_table(self, session, table_name, row_desc, file_type, create_params):
2859  self._oprot.writeMessageBegin('create_table', TMessageType.CALL, self._seqid)
2860  args = create_table_args()
2861  args.session = session
2862  args.table_name = table_name
2863  args.row_desc = row_desc
2864  args.file_type = file_type
2865  args.create_params = create_params
2866  args.write(self._oprot)
2867  self._oprot.writeMessageEnd()
2868  self._oprot.trans.flush()
2869 
2871  iprot = self._iprot
2872  (fname, mtype, rseqid) = iprot.readMessageBegin()
2873  if mtype == TMessageType.EXCEPTION:
2874  x = TApplicationException()
2875  x.read(iprot)
2876  iprot.readMessageEnd()
2877  raise x
2878  result = create_table_result()
2879  result.read(iprot)
2880  iprot.readMessageEnd()
2881  if result.e is not None:
2882  raise result.e
2883  return
2884 
2885  def import_table(self, session, table_name, file_name, copy_params):
2886  """
2887  Parameters:
2888  - session
2889  - table_name
2890  - file_name
2891  - copy_params
2892 
2893  """
2894  self.send_import_table(session, table_name, file_name, copy_params)
2895  self.recv_import_table()
2896 
2897  def send_import_table(self, session, table_name, file_name, copy_params):
2898  self._oprot.writeMessageBegin('import_table', TMessageType.CALL, self._seqid)
2899  args = import_table_args()
2900  args.session = session
2901  args.table_name = table_name
2902  args.file_name = file_name
2903  args.copy_params = copy_params
2904  args.write(self._oprot)
2905  self._oprot.writeMessageEnd()
2906  self._oprot.trans.flush()
2907 
2909  iprot = self._iprot
2910  (fname, mtype, rseqid) = iprot.readMessageBegin()
2911  if mtype == TMessageType.EXCEPTION:
2912  x = TApplicationException()
2913  x.read(iprot)
2914  iprot.readMessageEnd()
2915  raise x
2916  result = import_table_result()
2917  result.read(iprot)
2918  iprot.readMessageEnd()
2919  if result.e is not None:
2920  raise result.e
2921  return
2922 
2923  def import_geo_table(self, session, table_name, file_name, copy_params, row_desc, create_params):
2924  """
2925  Parameters:
2926  - session
2927  - table_name
2928  - file_name
2929  - copy_params
2930  - row_desc
2931  - create_params
2932 
2933  """
2934  self.send_import_geo_table(session, table_name, file_name, copy_params, row_desc, create_params)
2935  self.recv_import_geo_table()
2936 
2937  def send_import_geo_table(self, session, table_name, file_name, copy_params, row_desc, create_params):
2938  self._oprot.writeMessageBegin('import_geo_table', TMessageType.CALL, self._seqid)
2939  args = import_geo_table_args()
2940  args.session = session
2941  args.table_name = table_name
2942  args.file_name = file_name
2943  args.copy_params = copy_params
2944  args.row_desc = row_desc
2945  args.create_params = create_params
2946  args.write(self._oprot)
2947  self._oprot.writeMessageEnd()
2948  self._oprot.trans.flush()
2949 
2951  iprot = self._iprot
2952  (fname, mtype, rseqid) = iprot.readMessageBegin()
2953  if mtype == TMessageType.EXCEPTION:
2954  x = TApplicationException()
2955  x.read(iprot)
2956  iprot.readMessageEnd()
2957  raise x
2958  result = import_geo_table_result()
2959  result.read(iprot)
2960  iprot.readMessageEnd()
2961  if result.e is not None:
2962  raise result.e
2963  return
2964 
2965  def import_table_status(self, session, import_id):
2966  """
2967  Parameters:
2968  - session
2969  - import_id
2970 
2971  """
2972  self.send_import_table_status(session, import_id)
2973  return self.recv_import_table_status()
2974 
2975  def send_import_table_status(self, session, import_id):
2976  self._oprot.writeMessageBegin('import_table_status', TMessageType.CALL, self._seqid)
2977  args = import_table_status_args()
2978  args.session = session
2979  args.import_id = import_id
2980  args.write(self._oprot)
2981  self._oprot.writeMessageEnd()
2982  self._oprot.trans.flush()
2983 
2985  iprot = self._iprot
2986  (fname, mtype, rseqid) = iprot.readMessageBegin()
2987  if mtype == TMessageType.EXCEPTION:
2988  x = TApplicationException()
2989  x.read(iprot)
2990  iprot.readMessageEnd()
2991  raise x
2992  result = import_table_status_result()
2993  result.read(iprot)
2994  iprot.readMessageEnd()
2995  if result.success is not None:
2996  return result.success
2997  if result.e is not None:
2998  raise result.e
2999  raise TApplicationException(TApplicationException.MISSING_RESULT, "import_table_status failed: unknown result")
3000 
3001  def get_first_geo_file_in_archive(self, session, archive_path, copy_params):
3002  """
3003  Parameters:
3004  - session
3005  - archive_path
3006  - copy_params
3007 
3008  """
3009  self.send_get_first_geo_file_in_archive(session, archive_path, copy_params)
3011 
3012  def send_get_first_geo_file_in_archive(self, session, archive_path, copy_params):
3013  self._oprot.writeMessageBegin('get_first_geo_file_in_archive', TMessageType.CALL, self._seqid)
3015  args.session = session
3016  args.archive_path = archive_path
3017  args.copy_params = copy_params
3018  args.write(self._oprot)
3019  self._oprot.writeMessageEnd()
3020  self._oprot.trans.flush()
3021 
3023  iprot = self._iprot
3024  (fname, mtype, rseqid) = iprot.readMessageBegin()
3025  if mtype == TMessageType.EXCEPTION:
3026  x = TApplicationException()
3027  x.read(iprot)
3028  iprot.readMessageEnd()
3029  raise x
3031  result.read(iprot)
3032  iprot.readMessageEnd()
3033  if result.success is not None:
3034  return result.success
3035  if result.e is not None:
3036  raise result.e
3037  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_first_geo_file_in_archive failed: unknown result")
3038 
3039  def get_all_files_in_archive(self, session, archive_path, copy_params):
3040  """
3041  Parameters:
3042  - session
3043  - archive_path
3044  - copy_params
3045 
3046  """
3047  self.send_get_all_files_in_archive(session, archive_path, copy_params)
3048  return self.recv_get_all_files_in_archive()
3049 
3050  def send_get_all_files_in_archive(self, session, archive_path, copy_params):
3051  self._oprot.writeMessageBegin('get_all_files_in_archive', TMessageType.CALL, self._seqid)
3053  args.session = session
3054  args.archive_path = archive_path
3055  args.copy_params = copy_params
3056  args.write(self._oprot)
3057  self._oprot.writeMessageEnd()
3058  self._oprot.trans.flush()
3059 
3061  iprot = self._iprot
3062  (fname, mtype, rseqid) = iprot.readMessageBegin()
3063  if mtype == TMessageType.EXCEPTION:
3064  x = TApplicationException()
3065  x.read(iprot)
3066  iprot.readMessageEnd()
3067  raise x
3069  result.read(iprot)
3070  iprot.readMessageEnd()
3071  if result.success is not None:
3072  return result.success
3073  if result.e is not None:
3074  raise result.e
3075  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_all_files_in_archive failed: unknown result")
3076 
3077  def get_layers_in_geo_file(self, session, file_name, copy_params):
3078  """
3079  Parameters:
3080  - session
3081  - file_name
3082  - copy_params
3083 
3084  """
3085  self.send_get_layers_in_geo_file(session, file_name, copy_params)
3086  return self.recv_get_layers_in_geo_file()
3087 
3088  def send_get_layers_in_geo_file(self, session, file_name, copy_params):
3089  self._oprot.writeMessageBegin('get_layers_in_geo_file', TMessageType.CALL, self._seqid)
3091  args.session = session
3092  args.file_name = file_name
3093  args.copy_params = copy_params
3094  args.write(self._oprot)
3095  self._oprot.writeMessageEnd()
3096  self._oprot.trans.flush()
3097 
3099  iprot = self._iprot
3100  (fname, mtype, rseqid) = iprot.readMessageBegin()
3101  if mtype == TMessageType.EXCEPTION:
3102  x = TApplicationException()
3103  x.read(iprot)
3104  iprot.readMessageEnd()
3105  raise x
3107  result.read(iprot)
3108  iprot.readMessageEnd()
3109  if result.success is not None:
3110  return result.success
3111  if result.e is not None:
3112  raise result.e
3113  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_layers_in_geo_file failed: unknown result")
3114 
3115  def query_get_outer_fragment_count(self, session, query):
3116  """
3117  Parameters:
3118  - session
3119  - query
3120 
3121  """
3122  self.send_query_get_outer_fragment_count(session, query)
3124 
3125  def send_query_get_outer_fragment_count(self, session, query):
3126  self._oprot.writeMessageBegin('query_get_outer_fragment_count', TMessageType.CALL, self._seqid)
3128  args.session = session
3129  args.query = query
3130  args.write(self._oprot)
3131  self._oprot.writeMessageEnd()
3132  self._oprot.trans.flush()
3133 
3135  iprot = self._iprot
3136  (fname, mtype, rseqid) = iprot.readMessageBegin()
3137  if mtype == TMessageType.EXCEPTION:
3138  x = TApplicationException()
3139  x.read(iprot)
3140  iprot.readMessageEnd()
3141  raise x
3143  result.read(iprot)
3144  iprot.readMessageEnd()
3145  if result.success is not None:
3146  return result.success
3147  if result.e is not None:
3148  raise result.e
3149  raise TApplicationException(TApplicationException.MISSING_RESULT, "query_get_outer_fragment_count failed: unknown result")
3150 
3151  def check_table_consistency(self, session, table_id):
3152  """
3153  Parameters:
3154  - session
3155  - table_id
3156 
3157  """
3158  self.send_check_table_consistency(session, table_id)
3159  return self.recv_check_table_consistency()
3160 
3161  def send_check_table_consistency(self, session, table_id):
3162  self._oprot.writeMessageBegin('check_table_consistency', TMessageType.CALL, self._seqid)
3164  args.session = session
3165  args.table_id = table_id
3166  args.write(self._oprot)
3167  self._oprot.writeMessageEnd()
3168  self._oprot.trans.flush()
3169 
3171  iprot = self._iprot
3172  (fname, mtype, rseqid) = iprot.readMessageBegin()
3173  if mtype == TMessageType.EXCEPTION:
3174  x = TApplicationException()
3175  x.read(iprot)
3176  iprot.readMessageEnd()
3177  raise x
3179  result.read(iprot)
3180  iprot.readMessageEnd()
3181  if result.success is not None:
3182  return result.success
3183  if result.e is not None:
3184  raise result.e
3185  raise TApplicationException(TApplicationException.MISSING_RESULT, "check_table_consistency failed: unknown result")
3186 
3187  def start_query(self, leaf_session, parent_session, query_ra, just_explain, outer_fragment_indices):
3188  """
3189  Parameters:
3190  - leaf_session
3191  - parent_session
3192  - query_ra
3193  - just_explain
3194  - outer_fragment_indices
3195 
3196  """
3197  self.send_start_query(leaf_session, parent_session, query_ra, just_explain, outer_fragment_indices)
3198  return self.recv_start_query()
3199 
3200  def send_start_query(self, leaf_session, parent_session, query_ra, just_explain, outer_fragment_indices):
3201  self._oprot.writeMessageBegin('start_query', TMessageType.CALL, self._seqid)
3202  args = start_query_args()
3203  args.leaf_session = leaf_session
3204  args.parent_session = parent_session
3205  args.query_ra = query_ra
3206  args.just_explain = just_explain
3207  args.outer_fragment_indices = outer_fragment_indices
3208  args.write(self._oprot)
3209  self._oprot.writeMessageEnd()
3210  self._oprot.trans.flush()
3211 
3212  def recv_start_query(self):
3213  iprot = self._iprot
3214  (fname, mtype, rseqid) = iprot.readMessageBegin()
3215  if mtype == TMessageType.EXCEPTION:
3216  x = TApplicationException()
3217  x.read(iprot)
3218  iprot.readMessageEnd()
3219  raise x
3220  result = start_query_result()
3221  result.read(iprot)
3222  iprot.readMessageEnd()
3223  if result.success is not None:
3224  return result.success
3225  if result.e is not None:
3226  raise result.e
3227  raise TApplicationException(TApplicationException.MISSING_RESULT, "start_query failed: unknown result")
3228 
3229  def execute_query_step(self, pending_query):
3230  """
3231  Parameters:
3232  - pending_query
3233 
3234  """
3235  self.send_execute_query_step(pending_query)
3236  return self.recv_execute_query_step()
3237 
3238  def send_execute_query_step(self, pending_query):
3239  self._oprot.writeMessageBegin('execute_query_step', TMessageType.CALL, self._seqid)
3240  args = execute_query_step_args()
3241  args.pending_query = pending_query
3242  args.write(self._oprot)
3243  self._oprot.writeMessageEnd()
3244  self._oprot.trans.flush()
3245 
3247  iprot = self._iprot
3248  (fname, mtype, rseqid) = iprot.readMessageBegin()
3249  if mtype == TMessageType.EXCEPTION:
3250  x = TApplicationException()
3251  x.read(iprot)
3252  iprot.readMessageEnd()
3253  raise x
3254  result = execute_query_step_result()
3255  result.read(iprot)
3256  iprot.readMessageEnd()
3257  if result.success is not None:
3258  return result.success
3259  if result.e is not None:
3260  raise result.e
3261  raise TApplicationException(TApplicationException.MISSING_RESULT, "execute_query_step failed: unknown result")
3262 
3263  def broadcast_serialized_rows(self, serialized_rows, row_desc, query_id):
3264  """
3265  Parameters:
3266  - serialized_rows
3267  - row_desc
3268  - query_id
3269 
3270  """
3271  self.send_broadcast_serialized_rows(serialized_rows, row_desc, query_id)
3273 
3274  def send_broadcast_serialized_rows(self, serialized_rows, row_desc, query_id):
3275  self._oprot.writeMessageBegin('broadcast_serialized_rows', TMessageType.CALL, self._seqid)
3277  args.serialized_rows = serialized_rows
3278  args.row_desc = row_desc
3279  args.query_id = query_id
3280  args.write(self._oprot)
3281  self._oprot.writeMessageEnd()
3282  self._oprot.trans.flush()
3283 
3285  iprot = self._iprot
3286  (fname, mtype, rseqid) = iprot.readMessageBegin()
3287  if mtype == TMessageType.EXCEPTION:
3288  x = TApplicationException()
3289  x.read(iprot)
3290  iprot.readMessageEnd()
3291  raise x
3293  result.read(iprot)
3294  iprot.readMessageEnd()
3295  if result.e is not None:
3296  raise result.e
3297  return
3298 
3299  def start_render_query(self, session, widget_id, node_idx, vega_json):
3300  """
3301  Parameters:
3302  - session
3303  - widget_id
3304  - node_idx
3305  - vega_json
3306 
3307  """
3308  self.send_start_render_query(session, widget_id, node_idx, vega_json)
3309  return self.recv_start_render_query()
3310 
3311  def send_start_render_query(self, session, widget_id, node_idx, vega_json):
3312  self._oprot.writeMessageBegin('start_render_query', TMessageType.CALL, self._seqid)
3313  args = start_render_query_args()
3314  args.session = session
3315  args.widget_id = widget_id
3316  args.node_idx = node_idx
3317  args.vega_json = vega_json
3318  args.write(self._oprot)
3319  self._oprot.writeMessageEnd()
3320  self._oprot.trans.flush()
3321 
3323  iprot = self._iprot
3324  (fname, mtype, rseqid) = iprot.readMessageBegin()
3325  if mtype == TMessageType.EXCEPTION:
3326  x = TApplicationException()
3327  x.read(iprot)
3328  iprot.readMessageEnd()
3329  raise x
3330  result = start_render_query_result()
3331  result.read(iprot)
3332  iprot.readMessageEnd()
3333  if result.success is not None:
3334  return result.success
3335  if result.e is not None:
3336  raise result.e
3337  raise TApplicationException(TApplicationException.MISSING_RESULT, "start_render_query failed: unknown result")
3338 
3339  def execute_next_render_step(self, pending_render, merged_data):
3340  """
3341  Parameters:
3342  - pending_render
3343  - merged_data
3344 
3345  """
3346  self.send_execute_next_render_step(pending_render, merged_data)
3347  return self.recv_execute_next_render_step()
3348 
3349  def send_execute_next_render_step(self, pending_render, merged_data):
3350  self._oprot.writeMessageBegin('execute_next_render_step', TMessageType.CALL, self._seqid)
3352  args.pending_render = pending_render
3353  args.merged_data = merged_data
3354  args.write(self._oprot)
3355  self._oprot.writeMessageEnd()
3356  self._oprot.trans.flush()
3357 
3359  iprot = self._iprot
3360  (fname, mtype, rseqid) = iprot.readMessageBegin()
3361  if mtype == TMessageType.EXCEPTION:
3362  x = TApplicationException()
3363  x.read(iprot)
3364  iprot.readMessageEnd()
3365  raise x
3367  result.read(iprot)
3368  iprot.readMessageEnd()
3369  if result.success is not None:
3370  return result.success
3371  if result.e is not None:
3372  raise result.e
3373  raise TApplicationException(TApplicationException.MISSING_RESULT, "execute_next_render_step failed: unknown result")
3374 
3375  def insert_data(self, session, insert_data):
3376  """
3377  Parameters:
3378  - session
3379  - insert_data
3380 
3381  """
3382  self.send_insert_data(session, insert_data)
3383  self.recv_insert_data()
3384 
3385  def send_insert_data(self, session, insert_data):
3386  self._oprot.writeMessageBegin('insert_data', TMessageType.CALL, self._seqid)
3387  args = insert_data_args()
3388  args.session = session
3389  args.insert_data = insert_data
3390  args.write(self._oprot)
3391  self._oprot.writeMessageEnd()
3392  self._oprot.trans.flush()
3393 
3394  def recv_insert_data(self):
3395  iprot = self._iprot
3396  (fname, mtype, rseqid) = iprot.readMessageBegin()
3397  if mtype == TMessageType.EXCEPTION:
3398  x = TApplicationException()
3399  x.read(iprot)
3400  iprot.readMessageEnd()
3401  raise x
3402  result = insert_data_result()
3403  result.read(iprot)
3404  iprot.readMessageEnd()
3405  if result.e is not None:
3406  raise result.e
3407  return
3408 
3409  def checkpoint(self, session, db_id, table_id):
3410  """
3411  Parameters:
3412  - session
3413  - db_id
3414  - table_id
3415 
3416  """
3417  self.send_checkpoint(session, db_id, table_id)
3418  self.recv_checkpoint()
3419 
3420  def send_checkpoint(self, session, db_id, table_id):
3421  self._oprot.writeMessageBegin('checkpoint', TMessageType.CALL, self._seqid)
3422  args = checkpoint_args()
3423  args.session = session
3424  args.db_id = db_id
3425  args.table_id = table_id
3426  args.write(self._oprot)
3427  self._oprot.writeMessageEnd()
3428  self._oprot.trans.flush()
3429 
3430  def recv_checkpoint(self):
3431  iprot = self._iprot
3432  (fname, mtype, rseqid) = iprot.readMessageBegin()
3433  if mtype == TMessageType.EXCEPTION:
3434  x = TApplicationException()
3435  x.read(iprot)
3436  iprot.readMessageEnd()
3437  raise x
3438  result = checkpoint_result()
3439  result.read(iprot)
3440  iprot.readMessageEnd()
3441  if result.e is not None:
3442  raise result.e
3443  return
3444 
3445  def get_roles(self, session):
3446  """
3447  Parameters:
3448  - session
3449 
3450  """
3451  self.send_get_roles(session)
3452  return self.recv_get_roles()
3453 
3454  def send_get_roles(self, session):
3455  self._oprot.writeMessageBegin('get_roles', TMessageType.CALL, self._seqid)
3456  args = get_roles_args()
3457  args.session = session
3458  args.write(self._oprot)
3459  self._oprot.writeMessageEnd()
3460  self._oprot.trans.flush()
3461 
3462  def recv_get_roles(self):
3463  iprot = self._iprot
3464  (fname, mtype, rseqid) = iprot.readMessageBegin()
3465  if mtype == TMessageType.EXCEPTION:
3466  x = TApplicationException()
3467  x.read(iprot)
3468  iprot.readMessageEnd()
3469  raise x
3470  result = get_roles_result()
3471  result.read(iprot)
3472  iprot.readMessageEnd()
3473  if result.success is not None:
3474  return result.success
3475  if result.e is not None:
3476  raise result.e
3477  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_roles failed: unknown result")
3478 
3479  def get_db_objects_for_grantee(self, session, roleName):
3480  """
3481  Parameters:
3482  - session
3483  - roleName
3484 
3485  """
3486  self.send_get_db_objects_for_grantee(session, roleName)
3487  return self.recv_get_db_objects_for_grantee()
3488 
3489  def send_get_db_objects_for_grantee(self, session, roleName):
3490  self._oprot.writeMessageBegin('get_db_objects_for_grantee', TMessageType.CALL, self._seqid)
3492  args.session = session
3493  args.roleName = roleName
3494  args.write(self._oprot)
3495  self._oprot.writeMessageEnd()
3496  self._oprot.trans.flush()
3497 
3499  iprot = self._iprot
3500  (fname, mtype, rseqid) = iprot.readMessageBegin()
3501  if mtype == TMessageType.EXCEPTION:
3502  x = TApplicationException()
3503  x.read(iprot)
3504  iprot.readMessageEnd()
3505  raise x
3507  result.read(iprot)
3508  iprot.readMessageEnd()
3509  if result.success is not None:
3510  return result.success
3511  if result.e is not None:
3512  raise result.e
3513  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_db_objects_for_grantee failed: unknown result")
3514 
3515  def get_db_object_privs(self, session, objectName, type):
3516  """
3517  Parameters:
3518  - session
3519  - objectName
3520  - type
3521 
3522  """
3523  self.send_get_db_object_privs(session, objectName, type)
3524  return self.recv_get_db_object_privs()
3525 
3526  def send_get_db_object_privs(self, session, objectName, type):
3527  self._oprot.writeMessageBegin('get_db_object_privs', TMessageType.CALL, self._seqid)
3528  args = get_db_object_privs_args()
3529  args.session = session
3530  args.objectName = objectName
3531  args.type = type
3532  args.write(self._oprot)
3533  self._oprot.writeMessageEnd()
3534  self._oprot.trans.flush()
3535 
3537  iprot = self._iprot
3538  (fname, mtype, rseqid) = iprot.readMessageBegin()
3539  if mtype == TMessageType.EXCEPTION:
3540  x = TApplicationException()
3541  x.read(iprot)
3542  iprot.readMessageEnd()
3543  raise x
3544  result = get_db_object_privs_result()
3545  result.read(iprot)
3546  iprot.readMessageEnd()
3547  if result.success is not None:
3548  return result.success
3549  if result.e is not None:
3550  raise result.e
3551  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_db_object_privs failed: unknown result")
3552 
3553  def get_all_roles_for_user(self, session, userName):
3554  """
3555  Parameters:
3556  - session
3557  - userName
3558 
3559  """
3560  self.send_get_all_roles_for_user(session, userName)
3561  return self.recv_get_all_roles_for_user()
3562 
3563  def send_get_all_roles_for_user(self, session, userName):
3564  self._oprot.writeMessageBegin('get_all_roles_for_user', TMessageType.CALL, self._seqid)
3566  args.session = session
3567  args.userName = userName
3568  args.write(self._oprot)
3569  self._oprot.writeMessageEnd()
3570  self._oprot.trans.flush()
3571 
3573  iprot = self._iprot
3574  (fname, mtype, rseqid) = iprot.readMessageBegin()
3575  if mtype == TMessageType.EXCEPTION:
3576  x = TApplicationException()
3577  x.read(iprot)
3578  iprot.readMessageEnd()
3579  raise x
3581  result.read(iprot)
3582  iprot.readMessageEnd()
3583  if result.success is not None:
3584  return result.success
3585  if result.e is not None:
3586  raise result.e
3587  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_all_roles_for_user failed: unknown result")
3588 
3589  def has_role(self, session, granteeName, roleName):
3590  """
3591  Parameters:
3592  - session
3593  - granteeName
3594  - roleName
3595 
3596  """
3597  self.send_has_role(session, granteeName, roleName)
3598  return self.recv_has_role()
3599 
3600  def send_has_role(self, session, granteeName, roleName):
3601  self._oprot.writeMessageBegin('has_role', TMessageType.CALL, self._seqid)
3602  args = has_role_args()
3603  args.session = session
3604  args.granteeName = granteeName
3605  args.roleName = roleName
3606  args.write(self._oprot)
3607  self._oprot.writeMessageEnd()
3608  self._oprot.trans.flush()
3609 
3610  def recv_has_role(self):
3611  iprot = self._iprot
3612  (fname, mtype, rseqid) = iprot.readMessageBegin()
3613  if mtype == TMessageType.EXCEPTION:
3614  x = TApplicationException()
3615  x.read(iprot)
3616  iprot.readMessageEnd()
3617  raise x
3618  result = has_role_result()
3619  result.read(iprot)
3620  iprot.readMessageEnd()
3621  if result.success is not None:
3622  return result.success
3623  if result.e is not None:
3624  raise result.e
3625  raise TApplicationException(TApplicationException.MISSING_RESULT, "has_role failed: unknown result")
3626 
3627  def has_object_privilege(self, session, granteeName, ObjectName, objectType, permissions):
3628  """
3629  Parameters:
3630  - session
3631  - granteeName
3632  - ObjectName
3633  - objectType
3634  - permissions
3635 
3636  """
3637  self.send_has_object_privilege(session, granteeName, ObjectName, objectType, permissions)
3638  return self.recv_has_object_privilege()
3639 
3640  def send_has_object_privilege(self, session, granteeName, ObjectName, objectType, permissions):
3641  self._oprot.writeMessageBegin('has_object_privilege', TMessageType.CALL, self._seqid)
3642  args = has_object_privilege_args()
3643  args.session = session
3644  args.granteeName = granteeName
3645  args.ObjectName = ObjectName
3646  args.objectType = objectType
3647  args.permissions = permissions
3648  args.write(self._oprot)
3649  self._oprot.writeMessageEnd()
3650  self._oprot.trans.flush()
3651 
3653  iprot = self._iprot
3654  (fname, mtype, rseqid) = iprot.readMessageBegin()
3655  if mtype == TMessageType.EXCEPTION:
3656  x = TApplicationException()
3657  x.read(iprot)
3658  iprot.readMessageEnd()
3659  raise x
3660  result = has_object_privilege_result()
3661  result.read(iprot)
3662  iprot.readMessageEnd()
3663  if result.success is not None:
3664  return result.success
3665  if result.e is not None:
3666  raise result.e
3667  raise TApplicationException(TApplicationException.MISSING_RESULT, "has_object_privilege failed: unknown result")
3668 
3669  def set_license_key(self, session, key, nonce):
3670  """
3671  Parameters:
3672  - session
3673  - key
3674  - nonce
3675 
3676  """
3677  self.send_set_license_key(session, key, nonce)
3678  return self.recv_set_license_key()
3679 
3680  def send_set_license_key(self, session, key, nonce):
3681  self._oprot.writeMessageBegin('set_license_key', TMessageType.CALL, self._seqid)
3682  args = set_license_key_args()
3683  args.session = session
3684  args.key = key
3685  args.nonce = nonce
3686  args.write(self._oprot)
3687  self._oprot.writeMessageEnd()
3688  self._oprot.trans.flush()
3689 
3691  iprot = self._iprot
3692  (fname, mtype, rseqid) = iprot.readMessageBegin()
3693  if mtype == TMessageType.EXCEPTION:
3694  x = TApplicationException()
3695  x.read(iprot)
3696  iprot.readMessageEnd()
3697  raise x
3698  result = set_license_key_result()
3699  result.read(iprot)
3700  iprot.readMessageEnd()
3701  if result.success is not None:
3702  return result.success
3703  if result.e is not None:
3704  raise result.e
3705  raise TApplicationException(TApplicationException.MISSING_RESULT, "set_license_key failed: unknown result")
3706 
3707  def get_license_claims(self, session, nonce):
3708  """
3709  Parameters:
3710  - session
3711  - nonce
3712 
3713  """
3714  self.send_get_license_claims(session, nonce)
3715  return self.recv_get_license_claims()
3716 
3717  def send_get_license_claims(self, session, nonce):
3718  self._oprot.writeMessageBegin('get_license_claims', TMessageType.CALL, self._seqid)
3719  args = get_license_claims_args()
3720  args.session = session
3721  args.nonce = nonce
3722  args.write(self._oprot)
3723  self._oprot.writeMessageEnd()
3724  self._oprot.trans.flush()
3725 
3727  iprot = self._iprot
3728  (fname, mtype, rseqid) = iprot.readMessageBegin()
3729  if mtype == TMessageType.EXCEPTION:
3730  x = TApplicationException()
3731  x.read(iprot)
3732  iprot.readMessageEnd()
3733  raise x
3734  result = get_license_claims_result()
3735  result.read(iprot)
3736  iprot.readMessageEnd()
3737  if result.success is not None:
3738  return result.success
3739  if result.e is not None:
3740  raise result.e
3741  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_license_claims failed: unknown result")
3742 
3743  def get_device_parameters(self, session):
3744  """
3745  Parameters:
3746  - session
3747 
3748  """
3749  self.send_get_device_parameters(session)
3750  return self.recv_get_device_parameters()
3751 
3752  def send_get_device_parameters(self, session):
3753  self._oprot.writeMessageBegin('get_device_parameters', TMessageType.CALL, self._seqid)
3755  args.session = session
3756  args.write(self._oprot)
3757  self._oprot.writeMessageEnd()
3758  self._oprot.trans.flush()
3759 
3761  iprot = self._iprot
3762  (fname, mtype, rseqid) = iprot.readMessageBegin()
3763  if mtype == TMessageType.EXCEPTION:
3764  x = TApplicationException()
3765  x.read(iprot)
3766  iprot.readMessageEnd()
3767  raise x
3768  result = get_device_parameters_result()
3769  result.read(iprot)
3770  iprot.readMessageEnd()
3771  if result.success is not None:
3772  return result.success
3773  if result.e is not None:
3774  raise result.e
3775  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_device_parameters failed: unknown result")
3776 
3777  def register_runtime_extension_functions(self, session, udfs, udtfs, device_ir_map):
3778  """
3779  Parameters:
3780  - session
3781  - udfs
3782  - udtfs
3783  - device_ir_map
3784 
3785  """
3786  self.send_register_runtime_extension_functions(session, udfs, udtfs, device_ir_map)
3788 
3789  def send_register_runtime_extension_functions(self, session, udfs, udtfs, device_ir_map):
3790  self._oprot.writeMessageBegin('register_runtime_extension_functions', TMessageType.CALL, self._seqid)
3792  args.session = session
3793  args.udfs = udfs
3794  args.udtfs = udtfs
3795  args.device_ir_map = device_ir_map
3796  args.write(self._oprot)
3797  self._oprot.writeMessageEnd()
3798  self._oprot.trans.flush()
3799 
3801  iprot = self._iprot
3802  (fname, mtype, rseqid) = iprot.readMessageBegin()
3803  if mtype == TMessageType.EXCEPTION:
3804  x = TApplicationException()
3805  x.read(iprot)
3806  iprot.readMessageEnd()
3807  raise x
3809  result.read(iprot)
3810  iprot.readMessageEnd()
3811  if result.e is not None:
3812  raise result.e
3813  return
3814 
3815 
3816 class Processor(Iface, TProcessor):
3817  def __init__(self, handler):
3818  self._handler = handler
3819  self._processMap = {}
3820  self._processMap["connect"] = Processor.process_connect
3821  self._processMap["krb5_connect"] = Processor.process_krb5_connect
3822  self._processMap["disconnect"] = Processor.process_disconnect
3823  self._processMap["switch_database"] = Processor.process_switch_database
3824  self._processMap["clone_session"] = Processor.process_clone_session
3825  self._processMap["get_server_status"] = Processor.process_get_server_status
3826  self._processMap["get_status"] = Processor.process_get_status
3827  self._processMap["get_hardware_info"] = Processor.process_get_hardware_info
3828  self._processMap["get_tables"] = Processor.process_get_tables
3829  self._processMap["get_physical_tables"] = Processor.process_get_physical_tables
3830  self._processMap["get_views"] = Processor.process_get_views
3831  self._processMap["get_tables_meta"] = Processor.process_get_tables_meta
3832  self._processMap["get_table_details"] = Processor.process_get_table_details
3833  self._processMap["get_internal_table_details"] = Processor.process_get_internal_table_details
3834  self._processMap["get_users"] = Processor.process_get_users
3835  self._processMap["get_databases"] = Processor.process_get_databases
3836  self._processMap["get_version"] = Processor.process_get_version
3837  self._processMap["start_heap_profile"] = Processor.process_start_heap_profile
3838  self._processMap["stop_heap_profile"] = Processor.process_stop_heap_profile
3839  self._processMap["get_heap_profile"] = Processor.process_get_heap_profile
3840  self._processMap["get_memory"] = Processor.process_get_memory
3841  self._processMap["clear_cpu_memory"] = Processor.process_clear_cpu_memory
3842  self._processMap["clear_gpu_memory"] = Processor.process_clear_gpu_memory
3843  self._processMap["set_table_epoch"] = Processor.process_set_table_epoch
3844  self._processMap["set_table_epoch_by_name"] = Processor.process_set_table_epoch_by_name
3845  self._processMap["get_table_epoch"] = Processor.process_get_table_epoch
3846  self._processMap["get_table_epoch_by_name"] = Processor.process_get_table_epoch_by_name
3847  self._processMap["get_session_info"] = Processor.process_get_session_info
3848  self._processMap["sql_execute"] = Processor.process_sql_execute
3849  self._processMap["sql_execute_df"] = Processor.process_sql_execute_df
3850  self._processMap["sql_execute_gdf"] = Processor.process_sql_execute_gdf
3851  self._processMap["deallocate_df"] = Processor.process_deallocate_df
3852  self._processMap["interrupt"] = Processor.process_interrupt
3853  self._processMap["sql_validate"] = Processor.process_sql_validate
3854  self._processMap["get_completion_hints"] = Processor.process_get_completion_hints
3855  self._processMap["set_execution_mode"] = Processor.process_set_execution_mode
3856  self._processMap["render_vega"] = Processor.process_render_vega
3857  self._processMap["get_result_row_for_pixel"] = Processor.process_get_result_row_for_pixel
3858  self._processMap["get_dashboard"] = Processor.process_get_dashboard
3859  self._processMap["get_dashboards"] = Processor.process_get_dashboards
3860  self._processMap["create_dashboard"] = Processor.process_create_dashboard
3861  self._processMap["replace_dashboard"] = Processor.process_replace_dashboard
3862  self._processMap["delete_dashboard"] = Processor.process_delete_dashboard
3863  self._processMap["share_dashboards"] = Processor.process_share_dashboards
3864  self._processMap["delete_dashboards"] = Processor.process_delete_dashboards
3865  self._processMap["share_dashboard"] = Processor.process_share_dashboard
3866  self._processMap["unshare_dashboard"] = Processor.process_unshare_dashboard
3867  self._processMap["unshare_dashboards"] = Processor.process_unshare_dashboards
3868  self._processMap["get_dashboard_grantees"] = Processor.process_get_dashboard_grantees
3869  self._processMap["get_link_view"] = Processor.process_get_link_view
3870  self._processMap["create_link"] = Processor.process_create_link
3871  self._processMap["load_table_binary"] = Processor.process_load_table_binary
3872  self._processMap["load_table_binary_columnar"] = Processor.process_load_table_binary_columnar
3873  self._processMap["load_table_binary_arrow"] = Processor.process_load_table_binary_arrow
3874  self._processMap["load_table"] = Processor.process_load_table
3875  self._processMap["detect_column_types"] = Processor.process_detect_column_types
3876  self._processMap["create_table"] = Processor.process_create_table
3877  self._processMap["import_table"] = Processor.process_import_table
3878  self._processMap["import_geo_table"] = Processor.process_import_geo_table
3879  self._processMap["import_table_status"] = Processor.process_import_table_status
3880  self._processMap["get_first_geo_file_in_archive"] = Processor.process_get_first_geo_file_in_archive
3881  self._processMap["get_all_files_in_archive"] = Processor.process_get_all_files_in_archive
3882  self._processMap["get_layers_in_geo_file"] = Processor.process_get_layers_in_geo_file
3883  self._processMap["query_get_outer_fragment_count"] = Processor.process_query_get_outer_fragment_count
3884  self._processMap["check_table_consistency"] = Processor.process_check_table_consistency
3885  self._processMap["start_query"] = Processor.process_start_query
3886  self._processMap["execute_query_step"] = Processor.process_execute_query_step
3887  self._processMap["broadcast_serialized_rows"] = Processor.process_broadcast_serialized_rows
3888  self._processMap["start_render_query"] = Processor.process_start_render_query
3889  self._processMap["execute_next_render_step"] = Processor.process_execute_next_render_step
3890  self._processMap["insert_data"] = Processor.process_insert_data
3891  self._processMap["checkpoint"] = Processor.process_checkpoint
3892  self._processMap["get_roles"] = Processor.process_get_roles
3893  self._processMap["get_db_objects_for_grantee"] = Processor.process_get_db_objects_for_grantee
3894  self._processMap["get_db_object_privs"] = Processor.process_get_db_object_privs
3895  self._processMap["get_all_roles_for_user"] = Processor.process_get_all_roles_for_user
3896  self._processMap["has_role"] = Processor.process_has_role
3897  self._processMap["has_object_privilege"] = Processor.process_has_object_privilege
3898  self._processMap["set_license_key"] = Processor.process_set_license_key
3899  self._processMap["get_license_claims"] = Processor.process_get_license_claims
3900  self._processMap["get_device_parameters"] = Processor.process_get_device_parameters
3901  self._processMap["register_runtime_extension_functions"] = Processor.process_register_runtime_extension_functions
3902  self._on_message_begin = None
3903 
3904  def on_message_begin(self, func):
3905  self._on_message_begin = func
3906 
3907  def process(self, iprot, oprot):
3908  (name, type, seqid) = iprot.readMessageBegin()
3909  if self._on_message_begin:
3910  self._on_message_begin(name, type, seqid)
3911  if name not in self._processMap:
3912  iprot.skip(TType.STRUCT)
3913  iprot.readMessageEnd()
3914  x = TApplicationException(TApplicationException.UNKNOWN_METHOD, 'Unknown function %s' % (name))
3915  oprot.writeMessageBegin(name, TMessageType.EXCEPTION, seqid)
3916  x.write(oprot)
3917  oprot.writeMessageEnd()
3918  oprot.trans.flush()
3919  return
3920  else:
3921  self._processMap[name](self, seqid, iprot, oprot)
3922  return True
3923 
3924  def process_connect(self, seqid, iprot, oprot):
3925  args = connect_args()
3926  args.read(iprot)
3927  iprot.readMessageEnd()
3928  result = connect_result()
3929  try:
3930  result.success = self._handler.connect(args.user, args.passwd, args.dbname)
3931  msg_type = TMessageType.REPLY
3932  except TTransport.TTransportException:
3933  raise
3934  except TOmniSciException as e:
3935  msg_type = TMessageType.REPLY
3936  result.e = e
3937  except TApplicationException as ex:
3938  logging.exception('TApplication exception in handler')
3939  msg_type = TMessageType.EXCEPTION
3940  result = ex
3941  except Exception:
3942  logging.exception('Unexpected exception in handler')
3943  msg_type = TMessageType.EXCEPTION
3944  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
3945  oprot.writeMessageBegin("connect", msg_type, seqid)
3946  result.write(oprot)
3947  oprot.writeMessageEnd()
3948  oprot.trans.flush()
3949 
3950  def process_krb5_connect(self, seqid, iprot, oprot):
3951  args = krb5_connect_args()
3952  args.read(iprot)
3953  iprot.readMessageEnd()
3954  result = krb5_connect_result()
3955  try:
3956  result.success = self._handler.krb5_connect(args.inputToken, args.dbname)
3957  msg_type = TMessageType.REPLY
3958  except TTransport.TTransportException:
3959  raise
3960  except TOmniSciException as e:
3961  msg_type = TMessageType.REPLY
3962  result.e = e
3963  except TApplicationException as ex:
3964  logging.exception('TApplication exception in handler')
3965  msg_type = TMessageType.EXCEPTION
3966  result = ex
3967  except Exception:
3968  logging.exception('Unexpected exception in handler')
3969  msg_type = TMessageType.EXCEPTION
3970  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
3971  oprot.writeMessageBegin("krb5_connect", msg_type, seqid)
3972  result.write(oprot)
3973  oprot.writeMessageEnd()
3974  oprot.trans.flush()
3975 
3976  def process_disconnect(self, seqid, iprot, oprot):
3977  args = disconnect_args()
3978  args.read(iprot)
3979  iprot.readMessageEnd()
3980  result = disconnect_result()
3981  try:
3982  self._handler.disconnect(args.session)
3983  msg_type = TMessageType.REPLY
3984  except TTransport.TTransportException:
3985  raise
3986  except TOmniSciException as e:
3987  msg_type = TMessageType.REPLY
3988  result.e = e
3989  except TApplicationException as ex:
3990  logging.exception('TApplication exception in handler')
3991  msg_type = TMessageType.EXCEPTION
3992  result = ex
3993  except Exception:
3994  logging.exception('Unexpected exception in handler')
3995  msg_type = TMessageType.EXCEPTION
3996  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
3997  oprot.writeMessageBegin("disconnect", msg_type, seqid)
3998  result.write(oprot)
3999  oprot.writeMessageEnd()
4000  oprot.trans.flush()
4001 
4002  def process_switch_database(self, seqid, iprot, oprot):
4003  args = switch_database_args()
4004  args.read(iprot)
4005  iprot.readMessageEnd()
4006  result = switch_database_result()
4007  try:
4008  self._handler.switch_database(args.session, args.dbname)
4009  msg_type = TMessageType.REPLY
4010  except TTransport.TTransportException:
4011  raise
4012  except TOmniSciException as e:
4013  msg_type = TMessageType.REPLY
4014  result.e = e
4015  except TApplicationException as ex:
4016  logging.exception('TApplication exception in handler')
4017  msg_type = TMessageType.EXCEPTION
4018  result = ex
4019  except Exception:
4020  logging.exception('Unexpected exception in handler')
4021  msg_type = TMessageType.EXCEPTION
4022  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4023  oprot.writeMessageBegin("switch_database", msg_type, seqid)
4024  result.write(oprot)
4025  oprot.writeMessageEnd()
4026  oprot.trans.flush()
4027 
4028  def process_clone_session(self, seqid, iprot, oprot):
4029  args = clone_session_args()
4030  args.read(iprot)
4031  iprot.readMessageEnd()
4032  result = clone_session_result()
4033  try:
4034  result.success = self._handler.clone_session(args.session)
4035  msg_type = TMessageType.REPLY
4036  except TTransport.TTransportException:
4037  raise
4038  except TOmniSciException as e:
4039  msg_type = TMessageType.REPLY
4040  result.e = e
4041  except TApplicationException as ex:
4042  logging.exception('TApplication exception in handler')
4043  msg_type = TMessageType.EXCEPTION
4044  result = ex
4045  except Exception:
4046  logging.exception('Unexpected exception in handler')
4047  msg_type = TMessageType.EXCEPTION
4048  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4049  oprot.writeMessageBegin("clone_session", msg_type, seqid)
4050  result.write(oprot)
4051  oprot.writeMessageEnd()
4052  oprot.trans.flush()
4053 
4054  def process_get_server_status(self, seqid, iprot, oprot):
4055  args = get_server_status_args()
4056  args.read(iprot)
4057  iprot.readMessageEnd()
4058  result = get_server_status_result()
4059  try:
4060  result.success = self._handler.get_server_status(args.session)
4061  msg_type = TMessageType.REPLY
4062  except TTransport.TTransportException:
4063  raise
4064  except TOmniSciException as e:
4065  msg_type = TMessageType.REPLY
4066  result.e = e
4067  except TApplicationException as ex:
4068  logging.exception('TApplication exception in handler')
4069  msg_type = TMessageType.EXCEPTION
4070  result = ex
4071  except Exception:
4072  logging.exception('Unexpected exception in handler')
4073  msg_type = TMessageType.EXCEPTION
4074  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4075  oprot.writeMessageBegin("get_server_status", msg_type, seqid)
4076  result.write(oprot)
4077  oprot.writeMessageEnd()
4078  oprot.trans.flush()
4079 
4080  def process_get_status(self, seqid, iprot, oprot):
4081  args = get_status_args()
4082  args.read(iprot)
4083  iprot.readMessageEnd()
4084  result = get_status_result()
4085  try:
4086  result.success = self._handler.get_status(args.session)
4087  msg_type = TMessageType.REPLY
4088  except TTransport.TTransportException:
4089  raise
4090  except TOmniSciException as e:
4091  msg_type = TMessageType.REPLY
4092  result.e = e
4093  except TApplicationException as ex:
4094  logging.exception('TApplication exception in handler')
4095  msg_type = TMessageType.EXCEPTION
4096  result = ex
4097  except Exception:
4098  logging.exception('Unexpected exception in handler')
4099  msg_type = TMessageType.EXCEPTION
4100  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4101  oprot.writeMessageBegin("get_status", msg_type, seqid)
4102  result.write(oprot)
4103  oprot.writeMessageEnd()
4104  oprot.trans.flush()
4105 
4106  def process_get_hardware_info(self, seqid, iprot, oprot):
4107  args = get_hardware_info_args()
4108  args.read(iprot)
4109  iprot.readMessageEnd()
4110  result = get_hardware_info_result()
4111  try:
4112  result.success = self._handler.get_hardware_info(args.session)
4113  msg_type = TMessageType.REPLY
4114  except TTransport.TTransportException:
4115  raise
4116  except TOmniSciException as e:
4117  msg_type = TMessageType.REPLY
4118  result.e = e
4119  except TApplicationException as ex:
4120  logging.exception('TApplication exception in handler')
4121  msg_type = TMessageType.EXCEPTION
4122  result = ex
4123  except Exception:
4124  logging.exception('Unexpected exception in handler')
4125  msg_type = TMessageType.EXCEPTION
4126  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4127  oprot.writeMessageBegin("get_hardware_info", msg_type, seqid)
4128  result.write(oprot)
4129  oprot.writeMessageEnd()
4130  oprot.trans.flush()
4131 
4132  def process_get_tables(self, seqid, iprot, oprot):
4133  args = get_tables_args()
4134  args.read(iprot)
4135  iprot.readMessageEnd()
4136  result = get_tables_result()
4137  try:
4138  result.success = self._handler.get_tables(args.session)
4139  msg_type = TMessageType.REPLY
4140  except TTransport.TTransportException:
4141  raise
4142  except TOmniSciException as e:
4143  msg_type = TMessageType.REPLY
4144  result.e = e
4145  except TApplicationException as ex:
4146  logging.exception('TApplication exception in handler')
4147  msg_type = TMessageType.EXCEPTION
4148  result = ex
4149  except Exception:
4150  logging.exception('Unexpected exception in handler')
4151  msg_type = TMessageType.EXCEPTION
4152  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4153  oprot.writeMessageBegin("get_tables", msg_type, seqid)
4154  result.write(oprot)
4155  oprot.writeMessageEnd()
4156  oprot.trans.flush()
4157 
4158  def process_get_physical_tables(self, seqid, iprot, oprot):
4159  args = get_physical_tables_args()
4160  args.read(iprot)
4161  iprot.readMessageEnd()
4162  result = get_physical_tables_result()
4163  try:
4164  result.success = self._handler.get_physical_tables(args.session)
4165  msg_type = TMessageType.REPLY
4166  except TTransport.TTransportException:
4167  raise
4168  except TOmniSciException as e:
4169  msg_type = TMessageType.REPLY
4170  result.e = e
4171  except TApplicationException as ex:
4172  logging.exception('TApplication exception in handler')
4173  msg_type = TMessageType.EXCEPTION
4174  result = ex
4175  except Exception:
4176  logging.exception('Unexpected exception in handler')
4177  msg_type = TMessageType.EXCEPTION
4178  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4179  oprot.writeMessageBegin("get_physical_tables", msg_type, seqid)
4180  result.write(oprot)
4181  oprot.writeMessageEnd()
4182  oprot.trans.flush()
4183 
4184  def process_get_views(self, seqid, iprot, oprot):
4185  args = get_views_args()
4186  args.read(iprot)
4187  iprot.readMessageEnd()
4188  result = get_views_result()
4189  try:
4190  result.success = self._handler.get_views(args.session)
4191  msg_type = TMessageType.REPLY
4192  except TTransport.TTransportException:
4193  raise
4194  except TOmniSciException as e:
4195  msg_type = TMessageType.REPLY
4196  result.e = e
4197  except TApplicationException as ex:
4198  logging.exception('TApplication exception in handler')
4199  msg_type = TMessageType.EXCEPTION
4200  result = ex
4201  except Exception:
4202  logging.exception('Unexpected exception in handler')
4203  msg_type = TMessageType.EXCEPTION
4204  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4205  oprot.writeMessageBegin("get_views", msg_type, seqid)
4206  result.write(oprot)
4207  oprot.writeMessageEnd()
4208  oprot.trans.flush()
4209 
4210  def process_get_tables_meta(self, seqid, iprot, oprot):
4211  args = get_tables_meta_args()
4212  args.read(iprot)
4213  iprot.readMessageEnd()
4214  result = get_tables_meta_result()
4215  try:
4216  result.success = self._handler.get_tables_meta(args.session)
4217  msg_type = TMessageType.REPLY
4218  except TTransport.TTransportException:
4219  raise
4220  except TOmniSciException as e:
4221  msg_type = TMessageType.REPLY
4222  result.e = e
4223  except TApplicationException as ex:
4224  logging.exception('TApplication exception in handler')
4225  msg_type = TMessageType.EXCEPTION
4226  result = ex
4227  except Exception:
4228  logging.exception('Unexpected exception in handler')
4229  msg_type = TMessageType.EXCEPTION
4230  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4231  oprot.writeMessageBegin("get_tables_meta", msg_type, seqid)
4232  result.write(oprot)
4233  oprot.writeMessageEnd()
4234  oprot.trans.flush()
4235 
4236  def process_get_table_details(self, seqid, iprot, oprot):
4237  args = get_table_details_args()
4238  args.read(iprot)
4239  iprot.readMessageEnd()
4240  result = get_table_details_result()
4241  try:
4242  result.success = self._handler.get_table_details(args.session, args.table_name)
4243  msg_type = TMessageType.REPLY
4244  except TTransport.TTransportException:
4245  raise
4246  except TOmniSciException as e:
4247  msg_type = TMessageType.REPLY
4248  result.e = e
4249  except TApplicationException as ex:
4250  logging.exception('TApplication exception in handler')
4251  msg_type = TMessageType.EXCEPTION
4252  result = ex
4253  except Exception:
4254  logging.exception('Unexpected exception in handler')
4255  msg_type = TMessageType.EXCEPTION
4256  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4257  oprot.writeMessageBegin("get_table_details", msg_type, seqid)
4258  result.write(oprot)
4259  oprot.writeMessageEnd()
4260  oprot.trans.flush()
4261 
4262  def process_get_internal_table_details(self, seqid, iprot, oprot):
4264  args.read(iprot)
4265  iprot.readMessageEnd()
4267  try:
4268  result.success = self._handler.get_internal_table_details(args.session, args.table_name)
4269  msg_type = TMessageType.REPLY
4270  except TTransport.TTransportException:
4271  raise
4272  except TOmniSciException as e:
4273  msg_type = TMessageType.REPLY
4274  result.e = e
4275  except TApplicationException as ex:
4276  logging.exception('TApplication exception in handler')
4277  msg_type = TMessageType.EXCEPTION
4278  result = ex
4279  except Exception:
4280  logging.exception('Unexpected exception in handler')
4281  msg_type = TMessageType.EXCEPTION
4282  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4283  oprot.writeMessageBegin("get_internal_table_details", msg_type, seqid)
4284  result.write(oprot)
4285  oprot.writeMessageEnd()
4286  oprot.trans.flush()
4287 
4288  def process_get_users(self, seqid, iprot, oprot):
4289  args = get_users_args()
4290  args.read(iprot)
4291  iprot.readMessageEnd()
4292  result = get_users_result()
4293  try:
4294  result.success = self._handler.get_users(args.session)
4295  msg_type = TMessageType.REPLY
4296  except TTransport.TTransportException:
4297  raise
4298  except TOmniSciException as e:
4299  msg_type = TMessageType.REPLY
4300  result.e = e
4301  except TApplicationException as ex:
4302  logging.exception('TApplication exception in handler')
4303  msg_type = TMessageType.EXCEPTION
4304  result = ex
4305  except Exception:
4306  logging.exception('Unexpected exception in handler')
4307  msg_type = TMessageType.EXCEPTION
4308  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4309  oprot.writeMessageBegin("get_users", msg_type, seqid)
4310  result.write(oprot)
4311  oprot.writeMessageEnd()
4312  oprot.trans.flush()
4313 
4314  def process_get_databases(self, seqid, iprot, oprot):
4315  args = get_databases_args()
4316  args.read(iprot)
4317  iprot.readMessageEnd()
4318  result = get_databases_result()
4319  try:
4320  result.success = self._handler.get_databases(args.session)
4321  msg_type = TMessageType.REPLY
4322  except TTransport.TTransportException:
4323  raise
4324  except TOmniSciException as e:
4325  msg_type = TMessageType.REPLY
4326  result.e = e
4327  except TApplicationException as ex:
4328  logging.exception('TApplication exception in handler')
4329  msg_type = TMessageType.EXCEPTION
4330  result = ex
4331  except Exception:
4332  logging.exception('Unexpected exception in handler')
4333  msg_type = TMessageType.EXCEPTION
4334  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4335  oprot.writeMessageBegin("get_databases", msg_type, seqid)
4336  result.write(oprot)
4337  oprot.writeMessageEnd()
4338  oprot.trans.flush()
4339 
4340  def process_get_version(self, seqid, iprot, oprot):
4341  args = get_version_args()
4342  args.read(iprot)
4343  iprot.readMessageEnd()
4344  result = get_version_result()
4345  try:
4346  result.success = self._handler.get_version()
4347  msg_type = TMessageType.REPLY
4348  except TTransport.TTransportException:
4349  raise
4350  except TOmniSciException as e:
4351  msg_type = TMessageType.REPLY
4352  result.e = e
4353  except TApplicationException as ex:
4354  logging.exception('TApplication exception in handler')
4355  msg_type = TMessageType.EXCEPTION
4356  result = ex
4357  except Exception:
4358  logging.exception('Unexpected exception in handler')
4359  msg_type = TMessageType.EXCEPTION
4360  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4361  oprot.writeMessageBegin("get_version", msg_type, seqid)
4362  result.write(oprot)
4363  oprot.writeMessageEnd()
4364  oprot.trans.flush()
4365 
4366  def process_start_heap_profile(self, seqid, iprot, oprot):
4367  args = start_heap_profile_args()
4368  args.read(iprot)
4369  iprot.readMessageEnd()
4370  result = start_heap_profile_result()
4371  try:
4372  self._handler.start_heap_profile(args.session)
4373  msg_type = TMessageType.REPLY
4374  except TTransport.TTransportException:
4375  raise
4376  except TOmniSciException as e:
4377  msg_type = TMessageType.REPLY
4378  result.e = e
4379  except TApplicationException as ex:
4380  logging.exception('TApplication exception in handler')
4381  msg_type = TMessageType.EXCEPTION
4382  result = ex
4383  except Exception:
4384  logging.exception('Unexpected exception in handler')
4385  msg_type = TMessageType.EXCEPTION
4386  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4387  oprot.writeMessageBegin("start_heap_profile", msg_type, seqid)
4388  result.write(oprot)
4389  oprot.writeMessageEnd()
4390  oprot.trans.flush()
4391 
4392  def process_stop_heap_profile(self, seqid, iprot, oprot):
4393  args = stop_heap_profile_args()
4394  args.read(iprot)
4395  iprot.readMessageEnd()
4396  result = stop_heap_profile_result()
4397  try:
4398  self._handler.stop_heap_profile(args.session)
4399  msg_type = TMessageType.REPLY
4400  except TTransport.TTransportException:
4401  raise
4402  except TOmniSciException as e:
4403  msg_type = TMessageType.REPLY
4404  result.e = e
4405  except TApplicationException as ex:
4406  logging.exception('TApplication exception in handler')
4407  msg_type = TMessageType.EXCEPTION
4408  result = ex
4409  except Exception:
4410  logging.exception('Unexpected exception in handler')
4411  msg_type = TMessageType.EXCEPTION
4412  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4413  oprot.writeMessageBegin("stop_heap_profile", msg_type, seqid)
4414  result.write(oprot)
4415  oprot.writeMessageEnd()
4416  oprot.trans.flush()
4417 
4418  def process_get_heap_profile(self, seqid, iprot, oprot):
4419  args = get_heap_profile_args()
4420  args.read(iprot)
4421  iprot.readMessageEnd()
4422  result = get_heap_profile_result()
4423  try:
4424  result.success = self._handler.get_heap_profile(args.session)
4425  msg_type = TMessageType.REPLY
4426  except TTransport.TTransportException:
4427  raise
4428  except TOmniSciException as e:
4429  msg_type = TMessageType.REPLY
4430  result.e = e
4431  except TApplicationException as ex:
4432  logging.exception('TApplication exception in handler')
4433  msg_type = TMessageType.EXCEPTION
4434  result = ex
4435  except Exception:
4436  logging.exception('Unexpected exception in handler')
4437  msg_type = TMessageType.EXCEPTION
4438  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4439  oprot.writeMessageBegin("get_heap_profile", msg_type, seqid)
4440  result.write(oprot)
4441  oprot.writeMessageEnd()
4442  oprot.trans.flush()
4443 
4444  def process_get_memory(self, seqid, iprot, oprot):
4445  args = get_memory_args()
4446  args.read(iprot)
4447  iprot.readMessageEnd()
4448  result = get_memory_result()
4449  try:
4450  result.success = self._handler.get_memory(args.session, args.memory_level)
4451  msg_type = TMessageType.REPLY
4452  except TTransport.TTransportException:
4453  raise
4454  except TOmniSciException as e:
4455  msg_type = TMessageType.REPLY
4456  result.e = e
4457  except TApplicationException as ex:
4458  logging.exception('TApplication exception in handler')
4459  msg_type = TMessageType.EXCEPTION
4460  result = ex
4461  except Exception:
4462  logging.exception('Unexpected exception in handler')
4463  msg_type = TMessageType.EXCEPTION
4464  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4465  oprot.writeMessageBegin("get_memory", msg_type, seqid)
4466  result.write(oprot)
4467  oprot.writeMessageEnd()
4468  oprot.trans.flush()
4469 
4470  def process_clear_cpu_memory(self, seqid, iprot, oprot):
4471  args = clear_cpu_memory_args()
4472  args.read(iprot)
4473  iprot.readMessageEnd()
4474  result = clear_cpu_memory_result()
4475  try:
4476  self._handler.clear_cpu_memory(args.session)
4477  msg_type = TMessageType.REPLY
4478  except TTransport.TTransportException:
4479  raise
4480  except TOmniSciException as e:
4481  msg_type = TMessageType.REPLY
4482  result.e = e
4483  except TApplicationException as ex:
4484  logging.exception('TApplication exception in handler')
4485  msg_type = TMessageType.EXCEPTION
4486  result = ex
4487  except Exception:
4488  logging.exception('Unexpected exception in handler')
4489  msg_type = TMessageType.EXCEPTION
4490  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4491  oprot.writeMessageBegin("clear_cpu_memory", msg_type, seqid)
4492  result.write(oprot)
4493  oprot.writeMessageEnd()
4494  oprot.trans.flush()
4495 
4496  def process_clear_gpu_memory(self, seqid, iprot, oprot):
4497  args = clear_gpu_memory_args()
4498  args.read(iprot)
4499  iprot.readMessageEnd()
4500  result = clear_gpu_memory_result()
4501  try:
4502  self._handler.clear_gpu_memory(args.session)
4503  msg_type = TMessageType.REPLY
4504  except TTransport.TTransportException:
4505  raise
4506  except TOmniSciException as e:
4507  msg_type = TMessageType.REPLY
4508  result.e = e
4509  except TApplicationException as ex:
4510  logging.exception('TApplication exception in handler')
4511  msg_type = TMessageType.EXCEPTION
4512  result = ex
4513  except Exception:
4514  logging.exception('Unexpected exception in handler')
4515  msg_type = TMessageType.EXCEPTION
4516  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4517  oprot.writeMessageBegin("clear_gpu_memory", msg_type, seqid)
4518  result.write(oprot)
4519  oprot.writeMessageEnd()
4520  oprot.trans.flush()
4521 
4522  def process_set_table_epoch(self, seqid, iprot, oprot):
4523  args = set_table_epoch_args()
4524  args.read(iprot)
4525  iprot.readMessageEnd()
4526  result = set_table_epoch_result()
4527  try:
4528  self._handler.set_table_epoch(args.session, args.db_id, args.table_id, args.new_epoch)
4529  msg_type = TMessageType.REPLY
4530  except TTransport.TTransportException:
4531  raise
4532  except TOmniSciException as e:
4533  msg_type = TMessageType.REPLY
4534  result.e = e
4535  except TApplicationException as ex:
4536  logging.exception('TApplication exception in handler')
4537  msg_type = TMessageType.EXCEPTION
4538  result = ex
4539  except Exception:
4540  logging.exception('Unexpected exception in handler')
4541  msg_type = TMessageType.EXCEPTION
4542  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4543  oprot.writeMessageBegin("set_table_epoch", msg_type, seqid)
4544  result.write(oprot)
4545  oprot.writeMessageEnd()
4546  oprot.trans.flush()
4547 
4548  def process_set_table_epoch_by_name(self, seqid, iprot, oprot):
4550  args.read(iprot)
4551  iprot.readMessageEnd()
4553  try:
4554  self._handler.set_table_epoch_by_name(args.session, args.table_name, args.new_epoch)
4555  msg_type = TMessageType.REPLY
4556  except TTransport.TTransportException:
4557  raise
4558  except TOmniSciException as e:
4559  msg_type = TMessageType.REPLY
4560  result.e = e
4561  except TApplicationException as ex:
4562  logging.exception('TApplication exception in handler')
4563  msg_type = TMessageType.EXCEPTION
4564  result = ex
4565  except Exception:
4566  logging.exception('Unexpected exception in handler')
4567  msg_type = TMessageType.EXCEPTION
4568  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4569  oprot.writeMessageBegin("set_table_epoch_by_name", msg_type, seqid)
4570  result.write(oprot)
4571  oprot.writeMessageEnd()
4572  oprot.trans.flush()
4573 
4574  def process_get_table_epoch(self, seqid, iprot, oprot):
4575  args = get_table_epoch_args()
4576  args.read(iprot)
4577  iprot.readMessageEnd()
4578  result = get_table_epoch_result()
4579  try:
4580  result.success = self._handler.get_table_epoch(args.session, args.db_id, args.table_id)
4581  msg_type = TMessageType.REPLY
4582  except TTransport.TTransportException:
4583  raise
4584  except TApplicationException as ex:
4585  logging.exception('TApplication exception in handler')
4586  msg_type = TMessageType.EXCEPTION
4587  result = ex
4588  except Exception:
4589  logging.exception('Unexpected exception in handler')
4590  msg_type = TMessageType.EXCEPTION
4591  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4592  oprot.writeMessageBegin("get_table_epoch", msg_type, seqid)
4593  result.write(oprot)
4594  oprot.writeMessageEnd()
4595  oprot.trans.flush()
4596 
4597  def process_get_table_epoch_by_name(self, seqid, iprot, oprot):
4599  args.read(iprot)
4600  iprot.readMessageEnd()
4602  try:
4603  result.success = self._handler.get_table_epoch_by_name(args.session, args.table_name)
4604  msg_type = TMessageType.REPLY
4605  except TTransport.TTransportException:
4606  raise
4607  except TApplicationException as ex:
4608  logging.exception('TApplication exception in handler')
4609  msg_type = TMessageType.EXCEPTION
4610  result = ex
4611  except Exception:
4612  logging.exception('Unexpected exception in handler')
4613  msg_type = TMessageType.EXCEPTION
4614  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4615  oprot.writeMessageBegin("get_table_epoch_by_name", msg_type, seqid)
4616  result.write(oprot)
4617  oprot.writeMessageEnd()
4618  oprot.trans.flush()
4619 
4620  def process_get_session_info(self, seqid, iprot, oprot):
4621  args = get_session_info_args()
4622  args.read(iprot)
4623  iprot.readMessageEnd()
4624  result = get_session_info_result()
4625  try:
4626  result.success = self._handler.get_session_info(args.session)
4627  msg_type = TMessageType.REPLY
4628  except TTransport.TTransportException:
4629  raise
4630  except TOmniSciException as e:
4631  msg_type = TMessageType.REPLY
4632  result.e = e
4633  except TApplicationException as ex:
4634  logging.exception('TApplication exception in handler')
4635  msg_type = TMessageType.EXCEPTION
4636  result = ex
4637  except Exception:
4638  logging.exception('Unexpected exception in handler')
4639  msg_type = TMessageType.EXCEPTION
4640  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4641  oprot.writeMessageBegin("get_session_info", msg_type, seqid)
4642  result.write(oprot)
4643  oprot.writeMessageEnd()
4644  oprot.trans.flush()
4645 
4646  def process_sql_execute(self, seqid, iprot, oprot):
4647  args = sql_execute_args()
4648  args.read(iprot)
4649  iprot.readMessageEnd()
4650  result = sql_execute_result()
4651  try:
4652  result.success = self._handler.sql_execute(args.session, args.query, args.column_format, args.nonce, args.first_n, args.at_most_n)
4653  msg_type = TMessageType.REPLY
4654  except TTransport.TTransportException:
4655  raise
4656  except TOmniSciException as e:
4657  msg_type = TMessageType.REPLY
4658  result.e = e
4659  except TApplicationException as ex:
4660  logging.exception('TApplication exception in handler')
4661  msg_type = TMessageType.EXCEPTION
4662  result = ex
4663  except Exception:
4664  logging.exception('Unexpected exception in handler')
4665  msg_type = TMessageType.EXCEPTION
4666  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4667  oprot.writeMessageBegin("sql_execute", msg_type, seqid)
4668  result.write(oprot)
4669  oprot.writeMessageEnd()
4670  oprot.trans.flush()
4671 
4672  def process_sql_execute_df(self, seqid, iprot, oprot):
4673  args = sql_execute_df_args()
4674  args.read(iprot)
4675  iprot.readMessageEnd()
4676  result = sql_execute_df_result()
4677  try:
4678  result.success = self._handler.sql_execute_df(args.session, args.query, args.device_type, args.device_id, args.first_n, args.transport_method)
4679  msg_type = TMessageType.REPLY
4680  except TTransport.TTransportException:
4681  raise
4682  except TOmniSciException as e:
4683  msg_type = TMessageType.REPLY
4684  result.e = e
4685  except TApplicationException as ex:
4686  logging.exception('TApplication exception in handler')
4687  msg_type = TMessageType.EXCEPTION
4688  result = ex
4689  except Exception:
4690  logging.exception('Unexpected exception in handler')
4691  msg_type = TMessageType.EXCEPTION
4692  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4693  oprot.writeMessageBegin("sql_execute_df", msg_type, seqid)
4694  result.write(oprot)
4695  oprot.writeMessageEnd()
4696  oprot.trans.flush()
4697 
4698  def process_sql_execute_gdf(self, seqid, iprot, oprot):
4699  args = sql_execute_gdf_args()
4700  args.read(iprot)
4701  iprot.readMessageEnd()
4702  result = sql_execute_gdf_result()
4703  try:
4704  result.success = self._handler.sql_execute_gdf(args.session, args.query, args.device_id, args.first_n)
4705  msg_type = TMessageType.REPLY
4706  except TTransport.TTransportException:
4707  raise
4708  except TOmniSciException as e:
4709  msg_type = TMessageType.REPLY
4710  result.e = e
4711  except TApplicationException as ex:
4712  logging.exception('TApplication exception in handler')
4713  msg_type = TMessageType.EXCEPTION
4714  result = ex
4715  except Exception:
4716  logging.exception('Unexpected exception in handler')
4717  msg_type = TMessageType.EXCEPTION
4718  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4719  oprot.writeMessageBegin("sql_execute_gdf", msg_type, seqid)
4720  result.write(oprot)
4721  oprot.writeMessageEnd()
4722  oprot.trans.flush()
4723 
4724  def process_deallocate_df(self, seqid, iprot, oprot):
4725  args = deallocate_df_args()
4726  args.read(iprot)
4727  iprot.readMessageEnd()
4728  result = deallocate_df_result()
4729  try:
4730  self._handler.deallocate_df(args.session, args.df, args.device_type, args.device_id)
4731  msg_type = TMessageType.REPLY
4732  except TTransport.TTransportException:
4733  raise
4734  except TOmniSciException as e:
4735  msg_type = TMessageType.REPLY
4736  result.e = e
4737  except TApplicationException as ex:
4738  logging.exception('TApplication exception in handler')
4739  msg_type = TMessageType.EXCEPTION
4740  result = ex
4741  except Exception:
4742  logging.exception('Unexpected exception in handler')
4743  msg_type = TMessageType.EXCEPTION
4744  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4745  oprot.writeMessageBegin("deallocate_df", msg_type, seqid)
4746  result.write(oprot)
4747  oprot.writeMessageEnd()
4748  oprot.trans.flush()
4749 
4750  def process_interrupt(self, seqid, iprot, oprot):
4751  args = interrupt_args()
4752  args.read(iprot)
4753  iprot.readMessageEnd()
4754  result = interrupt_result()
4755  try:
4756  self._handler.interrupt(args.query_session, args.interrupt_session)
4757  msg_type = TMessageType.REPLY
4758  except TTransport.TTransportException:
4759  raise
4760  except TOmniSciException as e:
4761  msg_type = TMessageType.REPLY
4762  result.e = e
4763  except TApplicationException as ex:
4764  logging.exception('TApplication exception in handler')
4765  msg_type = TMessageType.EXCEPTION
4766  result = ex
4767  except Exception:
4768  logging.exception('Unexpected exception in handler')
4769  msg_type = TMessageType.EXCEPTION
4770  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4771  oprot.writeMessageBegin("interrupt", msg_type, seqid)
4772  result.write(oprot)
4773  oprot.writeMessageEnd()
4774  oprot.trans.flush()
4775 
4776  def process_sql_validate(self, seqid, iprot, oprot):
4777  args = sql_validate_args()
4778  args.read(iprot)
4779  iprot.readMessageEnd()
4780  result = sql_validate_result()
4781  try:
4782  result.success = self._handler.sql_validate(args.session, args.query)
4783  msg_type = TMessageType.REPLY
4784  except TTransport.TTransportException:
4785  raise
4786  except TOmniSciException as e:
4787  msg_type = TMessageType.REPLY
4788  result.e = e
4789  except TApplicationException as ex:
4790  logging.exception('TApplication exception in handler')
4791  msg_type = TMessageType.EXCEPTION
4792  result = ex
4793  except Exception:
4794  logging.exception('Unexpected exception in handler')
4795  msg_type = TMessageType.EXCEPTION
4796  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4797  oprot.writeMessageBegin("sql_validate", msg_type, seqid)
4798  result.write(oprot)
4799  oprot.writeMessageEnd()
4800  oprot.trans.flush()
4801 
4802  def process_get_completion_hints(self, seqid, iprot, oprot):
4803  args = get_completion_hints_args()
4804  args.read(iprot)
4805  iprot.readMessageEnd()
4806  result = get_completion_hints_result()
4807  try:
4808  result.success = self._handler.get_completion_hints(args.session, args.sql, args.cursor)
4809  msg_type = TMessageType.REPLY
4810  except TTransport.TTransportException:
4811  raise
4812  except TOmniSciException as e:
4813  msg_type = TMessageType.REPLY
4814  result.e = e
4815  except TApplicationException as ex:
4816  logging.exception('TApplication exception in handler')
4817  msg_type = TMessageType.EXCEPTION
4818  result = ex
4819  except Exception:
4820  logging.exception('Unexpected exception in handler')
4821  msg_type = TMessageType.EXCEPTION
4822  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4823  oprot.writeMessageBegin("get_completion_hints", msg_type, seqid)
4824  result.write(oprot)
4825  oprot.writeMessageEnd()
4826  oprot.trans.flush()
4827 
4828  def process_set_execution_mode(self, seqid, iprot, oprot):
4829  args = set_execution_mode_args()
4830  args.read(iprot)
4831  iprot.readMessageEnd()
4832  result = set_execution_mode_result()
4833  try:
4834  self._handler.set_execution_mode(args.session, args.mode)
4835  msg_type = TMessageType.REPLY
4836  except TTransport.TTransportException:
4837  raise
4838  except TOmniSciException as e:
4839  msg_type = TMessageType.REPLY
4840  result.e = e
4841  except TApplicationException as ex:
4842  logging.exception('TApplication exception in handler')
4843  msg_type = TMessageType.EXCEPTION
4844  result = ex
4845  except Exception:
4846  logging.exception('Unexpected exception in handler')
4847  msg_type = TMessageType.EXCEPTION
4848  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4849  oprot.writeMessageBegin("set_execution_mode", msg_type, seqid)
4850  result.write(oprot)
4851  oprot.writeMessageEnd()
4852  oprot.trans.flush()
4853 
4854  def process_render_vega(self, seqid, iprot, oprot):
4855  args = render_vega_args()
4856  args.read(iprot)
4857  iprot.readMessageEnd()
4858  result = render_vega_result()
4859  try:
4860  result.success = self._handler.render_vega(args.session, args.widget_id, args.vega_json, args.compression_level, args.nonce)
4861  msg_type = TMessageType.REPLY
4862  except TTransport.TTransportException:
4863  raise
4864  except TOmniSciException as e:
4865  msg_type = TMessageType.REPLY
4866  result.e = e
4867  except TApplicationException as ex:
4868  logging.exception('TApplication exception in handler')
4869  msg_type = TMessageType.EXCEPTION
4870  result = ex
4871  except Exception:
4872  logging.exception('Unexpected exception in handler')
4873  msg_type = TMessageType.EXCEPTION
4874  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4875  oprot.writeMessageBegin("render_vega", msg_type, seqid)
4876  result.write(oprot)
4877  oprot.writeMessageEnd()
4878  oprot.trans.flush()
4879 
4880  def process_get_result_row_for_pixel(self, seqid, iprot, oprot):
4882  args.read(iprot)
4883  iprot.readMessageEnd()
4885  try:
4886  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)
4887  msg_type = TMessageType.REPLY
4888  except TTransport.TTransportException:
4889  raise
4890  except TOmniSciException as e:
4891  msg_type = TMessageType.REPLY
4892  result.e = e
4893  except TApplicationException as ex:
4894  logging.exception('TApplication exception in handler')
4895  msg_type = TMessageType.EXCEPTION
4896  result = ex
4897  except Exception:
4898  logging.exception('Unexpected exception in handler')
4899  msg_type = TMessageType.EXCEPTION
4900  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4901  oprot.writeMessageBegin("get_result_row_for_pixel", msg_type, seqid)
4902  result.write(oprot)
4903  oprot.writeMessageEnd()
4904  oprot.trans.flush()
4905 
4906  def process_get_dashboard(self, seqid, iprot, oprot):
4907  args = get_dashboard_args()
4908  args.read(iprot)
4909  iprot.readMessageEnd()
4910  result = get_dashboard_result()
4911  try:
4912  result.success = self._handler.get_dashboard(args.session, args.dashboard_id)
4913  msg_type = TMessageType.REPLY
4914  except TTransport.TTransportException:
4915  raise
4916  except TOmniSciException as e:
4917  msg_type = TMessageType.REPLY
4918  result.e = e
4919  except TApplicationException as ex:
4920  logging.exception('TApplication exception in handler')
4921  msg_type = TMessageType.EXCEPTION
4922  result = ex
4923  except Exception:
4924  logging.exception('Unexpected exception in handler')
4925  msg_type = TMessageType.EXCEPTION
4926  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4927  oprot.writeMessageBegin("get_dashboard", msg_type, seqid)
4928  result.write(oprot)
4929  oprot.writeMessageEnd()
4930  oprot.trans.flush()
4931 
4932  def process_get_dashboards(self, seqid, iprot, oprot):
4933  args = get_dashboards_args()
4934  args.read(iprot)
4935  iprot.readMessageEnd()
4936  result = get_dashboards_result()
4937  try:
4938  result.success = self._handler.get_dashboards(args.session)
4939  msg_type = TMessageType.REPLY
4940  except TTransport.TTransportException:
4941  raise
4942  except TOmniSciException as e:
4943  msg_type = TMessageType.REPLY
4944  result.e = e
4945  except TApplicationException as ex:
4946  logging.exception('TApplication exception in handler')
4947  msg_type = TMessageType.EXCEPTION
4948  result = ex
4949  except Exception:
4950  logging.exception('Unexpected exception in handler')
4951  msg_type = TMessageType.EXCEPTION
4952  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4953  oprot.writeMessageBegin("get_dashboards", msg_type, seqid)
4954  result.write(oprot)
4955  oprot.writeMessageEnd()
4956  oprot.trans.flush()
4957 
4958  def process_create_dashboard(self, seqid, iprot, oprot):
4959  args = create_dashboard_args()
4960  args.read(iprot)
4961  iprot.readMessageEnd()
4962  result = create_dashboard_result()
4963  try:
4964  result.success = self._handler.create_dashboard(args.session, args.dashboard_name, args.dashboard_state, args.image_hash, args.dashboard_metadata)
4965  msg_type = TMessageType.REPLY
4966  except TTransport.TTransportException:
4967  raise
4968  except TOmniSciException as e:
4969  msg_type = TMessageType.REPLY
4970  result.e = e
4971  except TApplicationException as ex:
4972  logging.exception('TApplication exception in handler')
4973  msg_type = TMessageType.EXCEPTION
4974  result = ex
4975  except Exception:
4976  logging.exception('Unexpected exception in handler')
4977  msg_type = TMessageType.EXCEPTION
4978  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4979  oprot.writeMessageBegin("create_dashboard", msg_type, seqid)
4980  result.write(oprot)
4981  oprot.writeMessageEnd()
4982  oprot.trans.flush()
4983 
4984  def process_replace_dashboard(self, seqid, iprot, oprot):
4985  args = replace_dashboard_args()
4986  args.read(iprot)
4987  iprot.readMessageEnd()
4988  result = replace_dashboard_result()
4989  try:
4990  self._handler.replace_dashboard(args.session, args.dashboard_id, args.dashboard_name, args.dashboard_owner, args.dashboard_state, args.image_hash, args.dashboard_metadata)
4991  msg_type = TMessageType.REPLY
4992  except TTransport.TTransportException:
4993  raise
4994  except TOmniSciException as e:
4995  msg_type = TMessageType.REPLY
4996  result.e = e
4997  except TApplicationException as ex:
4998  logging.exception('TApplication exception in handler')
4999  msg_type = TMessageType.EXCEPTION
5000  result = ex
5001  except Exception:
5002  logging.exception('Unexpected exception in handler')
5003  msg_type = TMessageType.EXCEPTION
5004  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5005  oprot.writeMessageBegin("replace_dashboard", msg_type, seqid)
5006  result.write(oprot)
5007  oprot.writeMessageEnd()
5008  oprot.trans.flush()
5009 
5010  def process_delete_dashboard(self, seqid, iprot, oprot):
5011  args = delete_dashboard_args()
5012  args.read(iprot)
5013  iprot.readMessageEnd()
5014  result = delete_dashboard_result()
5015  try:
5016  self._handler.delete_dashboard(args.session, args.dashboard_id)
5017  msg_type = TMessageType.REPLY
5018  except TTransport.TTransportException:
5019  raise
5020  except TOmniSciException as e:
5021  msg_type = TMessageType.REPLY
5022  result.e = e
5023  except TApplicationException as ex:
5024  logging.exception('TApplication exception in handler')
5025  msg_type = TMessageType.EXCEPTION
5026  result = ex
5027  except Exception:
5028  logging.exception('Unexpected exception in handler')
5029  msg_type = TMessageType.EXCEPTION
5030  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5031  oprot.writeMessageBegin("delete_dashboard", msg_type, seqid)
5032  result.write(oprot)
5033  oprot.writeMessageEnd()
5034  oprot.trans.flush()
5035 
5036  def process_share_dashboards(self, seqid, iprot, oprot):
5037  args = share_dashboards_args()
5038  args.read(iprot)
5039  iprot.readMessageEnd()
5040  result = share_dashboards_result()
5041  try:
5042  self._handler.share_dashboards(args.session, args.dashboard_ids, args.groups, args.permissions)
5043  msg_type = TMessageType.REPLY
5044  except TTransport.TTransportException:
5045  raise
5046  except TOmniSciException as e:
5047  msg_type = TMessageType.REPLY
5048  result.e = e
5049  except TApplicationException as ex:
5050  logging.exception('TApplication exception in handler')
5051  msg_type = TMessageType.EXCEPTION
5052  result = ex
5053  except Exception:
5054  logging.exception('Unexpected exception in handler')
5055  msg_type = TMessageType.EXCEPTION
5056  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5057  oprot.writeMessageBegin("share_dashboards", msg_type, seqid)
5058  result.write(oprot)
5059  oprot.writeMessageEnd()
5060  oprot.trans.flush()
5061 
5062  def process_delete_dashboards(self, seqid, iprot, oprot):
5063  args = delete_dashboards_args()
5064  args.read(iprot)
5065  iprot.readMessageEnd()
5066  result = delete_dashboards_result()
5067  try:
5068  self._handler.delete_dashboards(args.session, args.dashboard_ids)
5069  msg_type = TMessageType.REPLY
5070  except TTransport.TTransportException:
5071  raise
5072  except TOmniSciException as e:
5073  msg_type = TMessageType.REPLY
5074  result.e = e
5075  except TApplicationException as ex:
5076  logging.exception('TApplication exception in handler')
5077  msg_type = TMessageType.EXCEPTION
5078  result = ex
5079  except Exception:
5080  logging.exception('Unexpected exception in handler')
5081  msg_type = TMessageType.EXCEPTION
5082  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5083  oprot.writeMessageBegin("delete_dashboards", msg_type, seqid)
5084  result.write(oprot)
5085  oprot.writeMessageEnd()
5086  oprot.trans.flush()
5087 
5088  def process_share_dashboard(self, seqid, iprot, oprot):
5089  args = share_dashboard_args()
5090  args.read(iprot)
5091  iprot.readMessageEnd()
5092  result = share_dashboard_result()
5093  try:
5094  self._handler.share_dashboard(args.session, args.dashboard_id, args.groups, args.objects, args.permissions, args.grant_role)
5095  msg_type = TMessageType.REPLY
5096  except TTransport.TTransportException:
5097  raise
5098  except TOmniSciException as e:
5099  msg_type = TMessageType.REPLY
5100  result.e = e
5101  except TApplicationException as ex:
5102  logging.exception('TApplication exception in handler')
5103  msg_type = TMessageType.EXCEPTION
5104  result = ex
5105  except Exception:
5106  logging.exception('Unexpected exception in handler')
5107  msg_type = TMessageType.EXCEPTION
5108  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5109  oprot.writeMessageBegin("share_dashboard", msg_type, seqid)
5110  result.write(oprot)
5111  oprot.writeMessageEnd()
5112  oprot.trans.flush()
5113 
5114  def process_unshare_dashboard(self, seqid, iprot, oprot):
5115  args = unshare_dashboard_args()
5116  args.read(iprot)
5117  iprot.readMessageEnd()
5118  result = unshare_dashboard_result()
5119  try:
5120  self._handler.unshare_dashboard(args.session, args.dashboard_id, args.groups, args.objects, args.permissions)
5121  msg_type = TMessageType.REPLY
5122  except TTransport.TTransportException:
5123  raise
5124  except TOmniSciException as e:
5125  msg_type = TMessageType.REPLY
5126  result.e = e
5127  except TApplicationException as ex:
5128  logging.exception('TApplication exception in handler')
5129  msg_type = TMessageType.EXCEPTION
5130  result = ex
5131  except Exception:
5132  logging.exception('Unexpected exception in handler')
5133  msg_type = TMessageType.EXCEPTION
5134  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5135  oprot.writeMessageBegin("unshare_dashboard", msg_type, seqid)
5136  result.write(oprot)
5137  oprot.writeMessageEnd()
5138  oprot.trans.flush()
5139 
5140  def process_unshare_dashboards(self, seqid, iprot, oprot):
5141  args = unshare_dashboards_args()
5142  args.read(iprot)
5143  iprot.readMessageEnd()
5144  result = unshare_dashboards_result()
5145  try:
5146  self._handler.unshare_dashboards(args.session, args.dashboard_ids, args.groups, args.permissions)
5147  msg_type = TMessageType.REPLY
5148  except TTransport.TTransportException:
5149  raise
5150  except TOmniSciException as e:
5151  msg_type = TMessageType.REPLY
5152  result.e = e
5153  except TApplicationException as ex:
5154  logging.exception('TApplication exception in handler')
5155  msg_type = TMessageType.EXCEPTION
5156  result = ex
5157  except Exception:
5158  logging.exception('Unexpected exception in handler')
5159  msg_type = TMessageType.EXCEPTION
5160  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5161  oprot.writeMessageBegin("unshare_dashboards", msg_type, seqid)
5162  result.write(oprot)
5163  oprot.writeMessageEnd()
5164  oprot.trans.flush()
5165 
5166  def process_get_dashboard_grantees(self, seqid, iprot, oprot):
5168  args.read(iprot)
5169  iprot.readMessageEnd()
5171  try:
5172  result.success = self._handler.get_dashboard_grantees(args.session, args.dashboard_id)
5173  msg_type = TMessageType.REPLY
5174  except TTransport.TTransportException:
5175  raise
5176  except TOmniSciException as e:
5177  msg_type = TMessageType.REPLY
5178  result.e = e
5179  except TApplicationException as ex:
5180  logging.exception('TApplication exception in handler')
5181  msg_type = TMessageType.EXCEPTION
5182  result = ex
5183  except Exception:
5184  logging.exception('Unexpected exception in handler')
5185  msg_type = TMessageType.EXCEPTION
5186  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5187  oprot.writeMessageBegin("get_dashboard_grantees", msg_type, seqid)
5188  result.write(oprot)
5189  oprot.writeMessageEnd()
5190  oprot.trans.flush()
5191 
5192  def process_get_link_view(self, seqid, iprot, oprot):
5193  args = get_link_view_args()
5194  args.read(iprot)
5195  iprot.readMessageEnd()
5196  result = get_link_view_result()
5197  try:
5198  result.success = self._handler.get_link_view(args.session, args.link)
5199  msg_type = TMessageType.REPLY
5200  except TTransport.TTransportException:
5201  raise
5202  except TOmniSciException as e:
5203  msg_type = TMessageType.REPLY
5204  result.e = e
5205  except TApplicationException as ex:
5206  logging.exception('TApplication exception in handler')
5207  msg_type = TMessageType.EXCEPTION
5208  result = ex
5209  except Exception:
5210  logging.exception('Unexpected exception in handler')
5211  msg_type = TMessageType.EXCEPTION
5212  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5213  oprot.writeMessageBegin("get_link_view", msg_type, seqid)
5214  result.write(oprot)
5215  oprot.writeMessageEnd()
5216  oprot.trans.flush()
5217 
5218  def process_create_link(self, seqid, iprot, oprot):
5219  args = create_link_args()
5220  args.read(iprot)
5221  iprot.readMessageEnd()
5222  result = create_link_result()
5223  try:
5224  result.success = self._handler.create_link(args.session, args.view_state, args.view_metadata)
5225  msg_type = TMessageType.REPLY
5226  except TTransport.TTransportException:
5227  raise
5228  except TOmniSciException as e:
5229  msg_type = TMessageType.REPLY
5230  result.e = e
5231  except TApplicationException as ex:
5232  logging.exception('TApplication exception in handler')
5233  msg_type = TMessageType.EXCEPTION
5234  result = ex
5235  except Exception:
5236  logging.exception('Unexpected exception in handler')
5237  msg_type = TMessageType.EXCEPTION
5238  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5239  oprot.writeMessageBegin("create_link", msg_type, seqid)
5240  result.write(oprot)
5241  oprot.writeMessageEnd()
5242  oprot.trans.flush()
5243 
5244  def process_load_table_binary(self, seqid, iprot, oprot):
5245  args = load_table_binary_args()
5246  args.read(iprot)
5247  iprot.readMessageEnd()
5248  result = load_table_binary_result()
5249  try:
5250  self._handler.load_table_binary(args.session, args.table_name, args.rows)
5251  msg_type = TMessageType.REPLY
5252  except TTransport.TTransportException:
5253  raise
5254  except TOmniSciException as e:
5255  msg_type = TMessageType.REPLY
5256  result.e = e
5257  except TApplicationException as ex:
5258  logging.exception('TApplication exception in handler')
5259  msg_type = TMessageType.EXCEPTION
5260  result = ex
5261  except Exception:
5262  logging.exception('Unexpected exception in handler')
5263  msg_type = TMessageType.EXCEPTION
5264  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5265  oprot.writeMessageBegin("load_table_binary", msg_type, seqid)
5266  result.write(oprot)
5267  oprot.writeMessageEnd()
5268  oprot.trans.flush()
5269 
5270  def process_load_table_binary_columnar(self, seqid, iprot, oprot):
5272  args.read(iprot)
5273  iprot.readMessageEnd()
5275  try:
5276  self._handler.load_table_binary_columnar(args.session, args.table_name, args.cols)
5277  msg_type = TMessageType.REPLY
5278  except TTransport.TTransportException:
5279  raise
5280  except TOmniSciException as e:
5281  msg_type = TMessageType.REPLY
5282  result.e = e
5283  except TApplicationException as ex:
5284  logging.exception('TApplication exception in handler')
5285  msg_type = TMessageType.EXCEPTION
5286  result = ex
5287  except Exception:
5288  logging.exception('Unexpected exception in handler')
5289  msg_type = TMessageType.EXCEPTION
5290  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5291  oprot.writeMessageBegin("load_table_binary_columnar", msg_type, seqid)
5292  result.write(oprot)
5293  oprot.writeMessageEnd()
5294  oprot.trans.flush()
5295 
5296  def process_load_table_binary_arrow(self, seqid, iprot, oprot):
5298  args.read(iprot)
5299  iprot.readMessageEnd()
5301  try:
5302  self._handler.load_table_binary_arrow(args.session, args.table_name, args.arrow_stream)
5303  msg_type = TMessageType.REPLY
5304  except TTransport.TTransportException:
5305  raise
5306  except TOmniSciException as e:
5307  msg_type = TMessageType.REPLY
5308  result.e = e
5309  except TApplicationException as ex:
5310  logging.exception('TApplication exception in handler')
5311  msg_type = TMessageType.EXCEPTION
5312  result = ex
5313  except Exception:
5314  logging.exception('Unexpected exception in handler')
5315  msg_type = TMessageType.EXCEPTION
5316  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5317  oprot.writeMessageBegin("load_table_binary_arrow", msg_type, seqid)
5318  result.write(oprot)
5319  oprot.writeMessageEnd()
5320  oprot.trans.flush()
5321 
5322  def process_load_table(self, seqid, iprot, oprot):
5323  args = load_table_args()
5324  args.read(iprot)
5325  iprot.readMessageEnd()
5326  result = load_table_result()
5327  try:
5328  self._handler.load_table(args.session, args.table_name, args.rows)
5329  msg_type = TMessageType.REPLY
5330  except TTransport.TTransportException:
5331  raise
5332  except TOmniSciException as e:
5333  msg_type = TMessageType.REPLY
5334  result.e = e
5335  except TApplicationException as ex:
5336  logging.exception('TApplication exception in handler')
5337  msg_type = TMessageType.EXCEPTION
5338  result = ex
5339  except Exception:
5340  logging.exception('Unexpected exception in handler')
5341  msg_type = TMessageType.EXCEPTION
5342  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5343  oprot.writeMessageBegin("load_table", msg_type, seqid)
5344  result.write(oprot)
5345  oprot.writeMessageEnd()
5346  oprot.trans.flush()
5347 
5348  def process_detect_column_types(self, seqid, iprot, oprot):
5349  args = detect_column_types_args()
5350  args.read(iprot)
5351  iprot.readMessageEnd()
5352  result = detect_column_types_result()
5353  try:
5354  result.success = self._handler.detect_column_types(args.session, args.file_name, args.copy_params)
5355  msg_type = TMessageType.REPLY
5356  except TTransport.TTransportException:
5357  raise
5358  except TOmniSciException as e:
5359  msg_type = TMessageType.REPLY
5360  result.e = e
5361  except TApplicationException as ex:
5362  logging.exception('TApplication exception in handler')
5363  msg_type = TMessageType.EXCEPTION
5364  result = ex
5365  except Exception:
5366  logging.exception('Unexpected exception in handler')
5367  msg_type = TMessageType.EXCEPTION
5368  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5369  oprot.writeMessageBegin("detect_column_types", msg_type, seqid)
5370  result.write(oprot)
5371  oprot.writeMessageEnd()
5372  oprot.trans.flush()
5373 
5374  def process_create_table(self, seqid, iprot, oprot):
5375  args = create_table_args()
5376  args.read(iprot)
5377  iprot.readMessageEnd()
5378  result = create_table_result()
5379  try:
5380  self._handler.create_table(args.session, args.table_name, args.row_desc, args.file_type, args.create_params)
5381  msg_type = TMessageType.REPLY
5382  except TTransport.TTransportException:
5383  raise
5384  except TOmniSciException as e:
5385  msg_type = TMessageType.REPLY
5386  result.e = e
5387  except TApplicationException as ex:
5388  logging.exception('TApplication exception in handler')
5389  msg_type = TMessageType.EXCEPTION
5390  result = ex
5391  except Exception:
5392  logging.exception('Unexpected exception in handler')
5393  msg_type = TMessageType.EXCEPTION
5394  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5395  oprot.writeMessageBegin("create_table", msg_type, seqid)
5396  result.write(oprot)
5397  oprot.writeMessageEnd()
5398  oprot.trans.flush()
5399 
5400  def process_import_table(self, seqid, iprot, oprot):
5401  args = import_table_args()
5402  args.read(iprot)
5403  iprot.readMessageEnd()
5404  result = import_table_result()
5405  try:
5406  self._handler.import_table(args.session, args.table_name, args.file_name, args.copy_params)
5407  msg_type = TMessageType.REPLY
5408  except TTransport.TTransportException:
5409  raise
5410  except TOmniSciException as e:
5411  msg_type = TMessageType.REPLY
5412  result.e = e
5413  except TApplicationException as ex:
5414  logging.exception('TApplication exception in handler')
5415  msg_type = TMessageType.EXCEPTION
5416  result = ex
5417  except Exception:
5418  logging.exception('Unexpected exception in handler')
5419  msg_type = TMessageType.EXCEPTION
5420  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5421  oprot.writeMessageBegin("import_table", msg_type, seqid)
5422  result.write(oprot)
5423  oprot.writeMessageEnd()
5424  oprot.trans.flush()
5425 
5426  def process_import_geo_table(self, seqid, iprot, oprot):
5427  args = import_geo_table_args()
5428  args.read(iprot)
5429  iprot.readMessageEnd()
5430  result = import_geo_table_result()
5431  try:
5432  self._handler.import_geo_table(args.session, args.table_name, args.file_name, args.copy_params, args.row_desc, args.create_params)
5433  msg_type = TMessageType.REPLY
5434  except TTransport.TTransportException:
5435  raise
5436  except TOmniSciException as e:
5437  msg_type = TMessageType.REPLY
5438  result.e = e
5439  except TApplicationException as ex:
5440  logging.exception('TApplication exception in handler')
5441  msg_type = TMessageType.EXCEPTION
5442  result = ex
5443  except Exception:
5444  logging.exception('Unexpected exception in handler')
5445  msg_type = TMessageType.EXCEPTION
5446  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5447  oprot.writeMessageBegin("import_geo_table", msg_type, seqid)
5448  result.write(oprot)
5449  oprot.writeMessageEnd()
5450  oprot.trans.flush()
5451 
5452  def process_import_table_status(self, seqid, iprot, oprot):
5453  args = import_table_status_args()
5454  args.read(iprot)
5455  iprot.readMessageEnd()
5456  result = import_table_status_result()
5457  try:
5458  result.success = self._handler.import_table_status(args.session, args.import_id)
5459  msg_type = TMessageType.REPLY
5460  except TTransport.TTransportException:
5461  raise
5462  except TOmniSciException as e:
5463  msg_type = TMessageType.REPLY
5464  result.e = e
5465  except TApplicationException as ex:
5466  logging.exception('TApplication exception in handler')
5467  msg_type = TMessageType.EXCEPTION
5468  result = ex
5469  except Exception:
5470  logging.exception('Unexpected exception in handler')
5471  msg_type = TMessageType.EXCEPTION
5472  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5473  oprot.writeMessageBegin("import_table_status", msg_type, seqid)
5474  result.write(oprot)
5475  oprot.writeMessageEnd()
5476  oprot.trans.flush()
5477 
5478  def process_get_first_geo_file_in_archive(self, seqid, iprot, oprot):
5480  args.read(iprot)
5481  iprot.readMessageEnd()
5483  try:
5484  result.success = self._handler.get_first_geo_file_in_archive(args.session, args.archive_path, args.copy_params)
5485  msg_type = TMessageType.REPLY
5486  except TTransport.TTransportException:
5487  raise
5488  except TOmniSciException as e:
5489  msg_type = TMessageType.REPLY
5490  result.e = e
5491  except TApplicationException as ex:
5492  logging.exception('TApplication exception in handler')
5493  msg_type = TMessageType.EXCEPTION
5494  result = ex
5495  except Exception:
5496  logging.exception('Unexpected exception in handler')
5497  msg_type = TMessageType.EXCEPTION
5498  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5499  oprot.writeMessageBegin("get_first_geo_file_in_archive", msg_type, seqid)
5500  result.write(oprot)
5501  oprot.writeMessageEnd()
5502  oprot.trans.flush()
5503 
5504  def process_get_all_files_in_archive(self, seqid, iprot, oprot):
5506  args.read(iprot)
5507  iprot.readMessageEnd()
5509  try:
5510  result.success = self._handler.get_all_files_in_archive(args.session, args.archive_path, args.copy_params)
5511  msg_type = TMessageType.REPLY
5512  except TTransport.TTransportException:
5513  raise
5514  except TOmniSciException as e:
5515  msg_type = TMessageType.REPLY
5516  result.e = e
5517  except TApplicationException as ex:
5518  logging.exception('TApplication exception in handler')
5519  msg_type = TMessageType.EXCEPTION
5520  result = ex
5521  except Exception:
5522  logging.exception('Unexpected exception in handler')
5523  msg_type = TMessageType.EXCEPTION
5524  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5525  oprot.writeMessageBegin("get_all_files_in_archive", msg_type, seqid)
5526  result.write(oprot)
5527  oprot.writeMessageEnd()
5528  oprot.trans.flush()
5529 
5530  def process_get_layers_in_geo_file(self, seqid, iprot, oprot):
5532  args.read(iprot)
5533  iprot.readMessageEnd()
5535  try:
5536  result.success = self._handler.get_layers_in_geo_file(args.session, args.file_name, args.copy_params)
5537  msg_type = TMessageType.REPLY
5538  except TTransport.TTransportException:
5539  raise
5540  except TOmniSciException as e:
5541  msg_type = TMessageType.REPLY
5542  result.e = e
5543  except TApplicationException as ex:
5544  logging.exception('TApplication exception in handler')
5545  msg_type = TMessageType.EXCEPTION
5546  result = ex
5547  except Exception:
5548  logging.exception('Unexpected exception in handler')
5549  msg_type = TMessageType.EXCEPTION
5550  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5551  oprot.writeMessageBegin("get_layers_in_geo_file", msg_type, seqid)
5552  result.write(oprot)
5553  oprot.writeMessageEnd()
5554  oprot.trans.flush()
5555 
5556  def process_query_get_outer_fragment_count(self, seqid, iprot, oprot):
5558  args.read(iprot)
5559  iprot.readMessageEnd()
5561  try:
5562  result.success = self._handler.query_get_outer_fragment_count(args.session, args.query)
5563  msg_type = TMessageType.REPLY
5564  except TTransport.TTransportException:
5565  raise
5566  except TOmniSciException as e:
5567  msg_type = TMessageType.REPLY
5568  result.e = e
5569  except TApplicationException as ex:
5570  logging.exception('TApplication exception in handler')
5571  msg_type = TMessageType.EXCEPTION
5572  result = ex
5573  except Exception:
5574  logging.exception('Unexpected exception in handler')
5575  msg_type = TMessageType.EXCEPTION
5576  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5577  oprot.writeMessageBegin("query_get_outer_fragment_count", msg_type, seqid)
5578  result.write(oprot)
5579  oprot.writeMessageEnd()
5580  oprot.trans.flush()
5581 
5582  def process_check_table_consistency(self, seqid, iprot, oprot):
5584  args.read(iprot)
5585  iprot.readMessageEnd()
5587  try:
5588  result.success = self._handler.check_table_consistency(args.session, args.table_id)
5589  msg_type = TMessageType.REPLY
5590  except TTransport.TTransportException:
5591  raise
5592  except TOmniSciException as e:
5593  msg_type = TMessageType.REPLY
5594  result.e = e
5595  except TApplicationException as ex:
5596  logging.exception('TApplication exception in handler')
5597  msg_type = TMessageType.EXCEPTION
5598  result = ex
5599  except Exception:
5600  logging.exception('Unexpected exception in handler')
5601  msg_type = TMessageType.EXCEPTION
5602  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5603  oprot.writeMessageBegin("check_table_consistency", msg_type, seqid)
5604  result.write(oprot)
5605  oprot.writeMessageEnd()
5606  oprot.trans.flush()
5607 
5608  def process_start_query(self, seqid, iprot, oprot):
5609  args = start_query_args()
5610  args.read(iprot)
5611  iprot.readMessageEnd()
5612  result = start_query_result()
5613  try:
5614  result.success = self._handler.start_query(args.leaf_session, args.parent_session, args.query_ra, args.just_explain, args.outer_fragment_indices)
5615  msg_type = TMessageType.REPLY
5616  except TTransport.TTransportException:
5617  raise
5618  except TOmniSciException as e:
5619  msg_type = TMessageType.REPLY
5620  result.e = e
5621  except TApplicationException as ex:
5622  logging.exception('TApplication exception in handler')
5623  msg_type = TMessageType.EXCEPTION
5624  result = ex
5625  except Exception:
5626  logging.exception('Unexpected exception in handler')
5627  msg_type = TMessageType.EXCEPTION
5628  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5629  oprot.writeMessageBegin("start_query", msg_type, seqid)
5630  result.write(oprot)
5631  oprot.writeMessageEnd()
5632  oprot.trans.flush()
5633 
5634  def process_execute_query_step(self, seqid, iprot, oprot):
5635  args = execute_query_step_args()
5636  args.read(iprot)
5637  iprot.readMessageEnd()
5638  result = execute_query_step_result()
5639  try:
5640  result.success = self._handler.execute_query_step(args.pending_query)
5641  msg_type = TMessageType.REPLY
5642  except TTransport.TTransportException:
5643  raise
5644  except TOmniSciException as e:
5645  msg_type = TMessageType.REPLY
5646  result.e = e
5647  except TApplicationException as ex:
5648  logging.exception('TApplication exception in handler')
5649  msg_type = TMessageType.EXCEPTION
5650  result = ex
5651  except Exception:
5652  logging.exception('Unexpected exception in handler')
5653  msg_type = TMessageType.EXCEPTION
5654  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5655  oprot.writeMessageBegin("execute_query_step", msg_type, seqid)
5656  result.write(oprot)
5657  oprot.writeMessageEnd()
5658  oprot.trans.flush()
5659 
5660  def process_broadcast_serialized_rows(self, seqid, iprot, oprot):
5662  args.read(iprot)
5663  iprot.readMessageEnd()
5665  try:
5666  self._handler.broadcast_serialized_rows(args.serialized_rows, args.row_desc, args.query_id)
5667  msg_type = TMessageType.REPLY
5668  except TTransport.TTransportException:
5669  raise
5670  except TOmniSciException as e:
5671  msg_type = TMessageType.REPLY
5672  result.e = e
5673  except TApplicationException as ex:
5674  logging.exception('TApplication exception in handler')
5675  msg_type = TMessageType.EXCEPTION
5676  result = ex
5677  except Exception:
5678  logging.exception('Unexpected exception in handler')
5679  msg_type = TMessageType.EXCEPTION
5680  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5681  oprot.writeMessageBegin("broadcast_serialized_rows", msg_type, seqid)
5682  result.write(oprot)
5683  oprot.writeMessageEnd()
5684  oprot.trans.flush()
5685 
5686  def process_start_render_query(self, seqid, iprot, oprot):
5687  args = start_render_query_args()
5688  args.read(iprot)
5689  iprot.readMessageEnd()
5690  result = start_render_query_result()
5691  try:
5692  result.success = self._handler.start_render_query(args.session, args.widget_id, args.node_idx, args.vega_json)
5693  msg_type = TMessageType.REPLY
5694  except TTransport.TTransportException:
5695  raise
5696  except TOmniSciException as e:
5697  msg_type = TMessageType.REPLY
5698  result.e = e
5699  except TApplicationException as ex:
5700  logging.exception('TApplication exception in handler')
5701  msg_type = TMessageType.EXCEPTION
5702  result = ex
5703  except Exception:
5704  logging.exception('Unexpected exception in handler')
5705  msg_type = TMessageType.EXCEPTION
5706  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5707  oprot.writeMessageBegin("start_render_query", msg_type, seqid)
5708  result.write(oprot)
5709  oprot.writeMessageEnd()
5710  oprot.trans.flush()
5711 
5712  def process_execute_next_render_step(self, seqid, iprot, oprot):
5714  args.read(iprot)
5715  iprot.readMessageEnd()
5717  try:
5718  result.success = self._handler.execute_next_render_step(args.pending_render, args.merged_data)
5719  msg_type = TMessageType.REPLY
5720  except TTransport.TTransportException:
5721  raise
5722  except TOmniSciException as e:
5723  msg_type = TMessageType.REPLY
5724  result.e = e
5725  except TApplicationException as ex:
5726  logging.exception('TApplication exception in handler')
5727  msg_type = TMessageType.EXCEPTION
5728  result = ex
5729  except Exception:
5730  logging.exception('Unexpected exception in handler')
5731  msg_type = TMessageType.EXCEPTION
5732  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5733  oprot.writeMessageBegin("execute_next_render_step", msg_type, seqid)
5734  result.write(oprot)
5735  oprot.writeMessageEnd()
5736  oprot.trans.flush()
5737 
5738  def process_insert_data(self, seqid, iprot, oprot):
5739  args = insert_data_args()
5740  args.read(iprot)
5741  iprot.readMessageEnd()
5742  result = insert_data_result()
5743  try:
5744  self._handler.insert_data(args.session, args.insert_data)
5745  msg_type = TMessageType.REPLY
5746  except TTransport.TTransportException:
5747  raise
5748  except TOmniSciException as e:
5749  msg_type = TMessageType.REPLY
5750  result.e = e
5751  except TApplicationException as ex:
5752  logging.exception('TApplication exception in handler')
5753  msg_type = TMessageType.EXCEPTION
5754  result = ex
5755  except Exception:
5756  logging.exception('Unexpected exception in handler')
5757  msg_type = TMessageType.EXCEPTION
5758  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5759  oprot.writeMessageBegin("insert_data", msg_type, seqid)
5760  result.write(oprot)
5761  oprot.writeMessageEnd()
5762  oprot.trans.flush()
5763 
5764  def process_checkpoint(self, seqid, iprot, oprot):
5765  args = checkpoint_args()
5766  args.read(iprot)
5767  iprot.readMessageEnd()
5768  result = checkpoint_result()
5769  try:
5770  self._handler.checkpoint(args.session, args.db_id, args.table_id)
5771  msg_type = TMessageType.REPLY
5772  except TTransport.TTransportException:
5773  raise
5774  except TOmniSciException as e:
5775  msg_type = TMessageType.REPLY
5776  result.e = e
5777  except TApplicationException as ex:
5778  logging.exception('TApplication exception in handler')
5779  msg_type = TMessageType.EXCEPTION
5780  result = ex
5781  except Exception:
5782  logging.exception('Unexpected exception in handler')
5783  msg_type = TMessageType.EXCEPTION
5784  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5785  oprot.writeMessageBegin("checkpoint", msg_type, seqid)
5786  result.write(oprot)
5787  oprot.writeMessageEnd()
5788  oprot.trans.flush()
5789 
5790  def process_get_roles(self, seqid, iprot, oprot):
5791  args = get_roles_args()
5792  args.read(iprot)
5793  iprot.readMessageEnd()
5794  result = get_roles_result()
5795  try:
5796  result.success = self._handler.get_roles(args.session)
5797  msg_type = TMessageType.REPLY
5798  except TTransport.TTransportException:
5799  raise
5800  except TOmniSciException as e:
5801  msg_type = TMessageType.REPLY
5802  result.e = e
5803  except TApplicationException as ex:
5804  logging.exception('TApplication exception in handler')
5805  msg_type = TMessageType.EXCEPTION
5806  result = ex
5807  except Exception:
5808  logging.exception('Unexpected exception in handler')
5809  msg_type = TMessageType.EXCEPTION
5810  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5811  oprot.writeMessageBegin("get_roles", msg_type, seqid)
5812  result.write(oprot)
5813  oprot.writeMessageEnd()
5814  oprot.trans.flush()
5815 
5816  def process_get_db_objects_for_grantee(self, seqid, iprot, oprot):
5818  args.read(iprot)
5819  iprot.readMessageEnd()
5821  try:
5822  result.success = self._handler.get_db_objects_for_grantee(args.session, args.roleName)
5823  msg_type = TMessageType.REPLY
5824  except TTransport.TTransportException:
5825  raise
5826  except TOmniSciException as e:
5827  msg_type = TMessageType.REPLY
5828  result.e = e
5829  except TApplicationException as ex:
5830  logging.exception('TApplication exception in handler')
5831  msg_type = TMessageType.EXCEPTION
5832  result = ex
5833  except Exception:
5834  logging.exception('Unexpected exception in handler')
5835  msg_type = TMessageType.EXCEPTION
5836  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5837  oprot.writeMessageBegin("get_db_objects_for_grantee", msg_type, seqid)
5838  result.write(oprot)
5839  oprot.writeMessageEnd()
5840  oprot.trans.flush()
5841 
5842  def process_get_db_object_privs(self, seqid, iprot, oprot):
5843  args = get_db_object_privs_args()
5844  args.read(iprot)
5845  iprot.readMessageEnd()
5846  result = get_db_object_privs_result()
5847  try:
5848  result.success = self._handler.get_db_object_privs(args.session, args.objectName, args.type)
5849  msg_type = TMessageType.REPLY
5850  except TTransport.TTransportException:
5851  raise
5852  except TOmniSciException as e:
5853  msg_type = TMessageType.REPLY
5854  result.e = e
5855  except TApplicationException as ex:
5856  logging.exception('TApplication exception in handler')
5857  msg_type = TMessageType.EXCEPTION
5858  result = ex
5859  except Exception:
5860  logging.exception('Unexpected exception in handler')
5861  msg_type = TMessageType.EXCEPTION
5862  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5863  oprot.writeMessageBegin("get_db_object_privs", msg_type, seqid)
5864  result.write(oprot)
5865  oprot.writeMessageEnd()
5866  oprot.trans.flush()
5867 
5868  def process_get_all_roles_for_user(self, seqid, iprot, oprot):
5870  args.read(iprot)
5871  iprot.readMessageEnd()
5873  try:
5874  result.success = self._handler.get_all_roles_for_user(args.session, args.userName)
5875  msg_type = TMessageType.REPLY
5876  except TTransport.TTransportException:
5877  raise
5878  except TOmniSciException as e:
5879  msg_type = TMessageType.REPLY
5880  result.e = e
5881  except TApplicationException as ex:
5882  logging.exception('TApplication exception in handler')
5883  msg_type = TMessageType.EXCEPTION
5884  result = ex
5885  except Exception:
5886  logging.exception('Unexpected exception in handler')
5887  msg_type = TMessageType.EXCEPTION
5888  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5889  oprot.writeMessageBegin("get_all_roles_for_user", msg_type, seqid)
5890  result.write(oprot)
5891  oprot.writeMessageEnd()
5892  oprot.trans.flush()
5893 
5894  def process_has_role(self, seqid, iprot, oprot):
5895  args = has_role_args()
5896  args.read(iprot)
5897  iprot.readMessageEnd()
5898  result = has_role_result()
5899  try:
5900  result.success = self._handler.has_role(args.session, args.granteeName, args.roleName)
5901  msg_type = TMessageType.REPLY
5902  except TTransport.TTransportException:
5903  raise
5904  except TOmniSciException as e:
5905  msg_type = TMessageType.REPLY
5906  result.e = e
5907  except TApplicationException as ex:
5908  logging.exception('TApplication exception in handler')
5909  msg_type = TMessageType.EXCEPTION
5910  result = ex
5911  except Exception:
5912  logging.exception('Unexpected exception in handler')
5913  msg_type = TMessageType.EXCEPTION
5914  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5915  oprot.writeMessageBegin("has_role", msg_type, seqid)
5916  result.write(oprot)
5917  oprot.writeMessageEnd()
5918  oprot.trans.flush()
5919 
5920  def process_has_object_privilege(self, seqid, iprot, oprot):
5921  args = has_object_privilege_args()
5922  args.read(iprot)
5923  iprot.readMessageEnd()
5924  result = has_object_privilege_result()
5925  try:
5926  result.success = self._handler.has_object_privilege(args.session, args.granteeName, args.ObjectName, args.objectType, args.permissions)
5927  msg_type = TMessageType.REPLY
5928  except TTransport.TTransportException:
5929  raise
5930  except TOmniSciException as e:
5931  msg_type = TMessageType.REPLY
5932  result.e = e
5933  except TApplicationException as ex:
5934  logging.exception('TApplication exception in handler')
5935  msg_type = TMessageType.EXCEPTION
5936  result = ex
5937  except Exception:
5938  logging.exception('Unexpected exception in handler')
5939  msg_type = TMessageType.EXCEPTION
5940  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5941  oprot.writeMessageBegin("has_object_privilege", msg_type, seqid)
5942  result.write(oprot)
5943  oprot.writeMessageEnd()
5944  oprot.trans.flush()
5945 
5946  def process_set_license_key(self, seqid, iprot, oprot):
5947  args = set_license_key_args()
5948  args.read(iprot)
5949  iprot.readMessageEnd()
5950  result = set_license_key_result()
5951  try:
5952  result.success = self._handler.set_license_key(args.session, args.key, args.nonce)
5953  msg_type = TMessageType.REPLY
5954  except TTransport.TTransportException:
5955  raise
5956  except TOmniSciException as e:
5957  msg_type = TMessageType.REPLY
5958  result.e = e
5959  except TApplicationException as ex:
5960  logging.exception('TApplication exception in handler')
5961  msg_type = TMessageType.EXCEPTION
5962  result = ex
5963  except Exception:
5964  logging.exception('Unexpected exception in handler')
5965  msg_type = TMessageType.EXCEPTION
5966  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5967  oprot.writeMessageBegin("set_license_key", msg_type, seqid)
5968  result.write(oprot)
5969  oprot.writeMessageEnd()
5970  oprot.trans.flush()
5971 
5972  def process_get_license_claims(self, seqid, iprot, oprot):
5973  args = get_license_claims_args()
5974  args.read(iprot)
5975  iprot.readMessageEnd()
5976  result = get_license_claims_result()
5977  try:
5978  result.success = self._handler.get_license_claims(args.session, args.nonce)
5979  msg_type = TMessageType.REPLY
5980  except TTransport.TTransportException:
5981  raise
5982  except TOmniSciException as e:
5983  msg_type = TMessageType.REPLY
5984  result.e = e
5985  except TApplicationException as ex:
5986  logging.exception('TApplication exception in handler')
5987  msg_type = TMessageType.EXCEPTION
5988  result = ex
5989  except Exception:
5990  logging.exception('Unexpected exception in handler')
5991  msg_type = TMessageType.EXCEPTION
5992  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5993  oprot.writeMessageBegin("get_license_claims", msg_type, seqid)
5994  result.write(oprot)
5995  oprot.writeMessageEnd()
5996  oprot.trans.flush()
5997 
5998  def process_get_device_parameters(self, seqid, iprot, oprot):
6000  args.read(iprot)
6001  iprot.readMessageEnd()
6002  result = get_device_parameters_result()
6003  try:
6004  result.success = self._handler.get_device_parameters(args.session)
6005  msg_type = TMessageType.REPLY
6006  except TTransport.TTransportException:
6007  raise
6008  except TOmniSciException as e:
6009  msg_type = TMessageType.REPLY
6010  result.e = e
6011  except TApplicationException as ex:
6012  logging.exception('TApplication exception in handler')
6013  msg_type = TMessageType.EXCEPTION
6014  result = ex
6015  except Exception:
6016  logging.exception('Unexpected exception in handler')
6017  msg_type = TMessageType.EXCEPTION
6018  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6019  oprot.writeMessageBegin("get_device_parameters", msg_type, seqid)
6020  result.write(oprot)
6021  oprot.writeMessageEnd()
6022  oprot.trans.flush()
6023 
6024  def process_register_runtime_extension_functions(self, seqid, iprot, oprot):
6026  args.read(iprot)
6027  iprot.readMessageEnd()
6029  try:
6030  self._handler.register_runtime_extension_functions(args.session, args.udfs, args.udtfs, args.device_ir_map)
6031  msg_type = TMessageType.REPLY
6032  except TTransport.TTransportException:
6033  raise
6034  except TOmniSciException as e:
6035  msg_type = TMessageType.REPLY
6036  result.e = e
6037  except TApplicationException as ex:
6038  logging.exception('TApplication exception in handler')
6039  msg_type = TMessageType.EXCEPTION
6040  result = ex
6041  except Exception:
6042  logging.exception('Unexpected exception in handler')
6043  msg_type = TMessageType.EXCEPTION
6044  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
6045  oprot.writeMessageBegin("register_runtime_extension_functions", msg_type, seqid)
6046  result.write(oprot)
6047  oprot.writeMessageEnd()
6048  oprot.trans.flush()
6049 
6050 # HELPER FUNCTIONS AND STRUCTURES
6051 
6052 
6053 class connect_args(object):