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