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