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