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