OmniSciDB  94e8789169
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
ttypes.py
Go to the documentation of this file.
1 #
2 # Autogenerated by Thrift Compiler (0.13.0)
3 #
4 # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
5 #
6 # options string: py
7 #
8 
9 from thrift.Thrift import TType, TMessageType, TFrozenDict, TException, TApplicationException
10 from thrift.protocol.TProtocol import TProtocolException
11 from thrift.TRecursive import fix_spec
12 
13 import sys
18 
19 from thrift.transport import TTransport
20 all_structs = []
21 
22 
23 class TExecuteMode(object):
24  GPU = 1
25  CPU = 2
26 
27  _VALUES_TO_NAMES = {
28  1: "GPU",
29  2: "CPU",
30  }
31 
32  _NAMES_TO_VALUES = {
33  "GPU": 1,
34  "CPU": 2,
35  }
36 
37 
38 class TFileType(object):
39  DELIMITED = 0
40  POLYGON = 1
41  PARQUET = 2
42 
43  _VALUES_TO_NAMES = {
44  0: "DELIMITED",
45  1: "POLYGON",
46  2: "PARQUET",
47  }
48 
49  _NAMES_TO_VALUES = {
50  "DELIMITED": 0,
51  "POLYGON": 1,
52  "PARQUET": 2,
53  }
54 
55 
56 class TPartitionDetail(object):
57  DEFAULT = 0
58  REPLICATED = 1
59  SHARDED = 2
60  OTHER = 3
61 
62  _VALUES_TO_NAMES = {
63  0: "DEFAULT",
64  1: "REPLICATED",
65  2: "SHARDED",
66  3: "OTHER",
67  }
68 
69  _NAMES_TO_VALUES = {
70  "DEFAULT": 0,
71  "REPLICATED": 1,
72  "SHARDED": 2,
73  "OTHER": 3,
74  }
75 
76 
77 class TGeoFileLayerContents(object):
78  EMPTY = 0
79  GEO = 1
80  NON_GEO = 2
81  UNSUPPORTED_GEO = 3
82 
83  _VALUES_TO_NAMES = {
84  0: "EMPTY",
85  1: "GEO",
86  2: "NON_GEO",
87  3: "UNSUPPORTED_GEO",
88  }
89 
90  _NAMES_TO_VALUES = {
91  "EMPTY": 0,
92  "GEO": 1,
93  "NON_GEO": 2,
94  "UNSUPPORTED_GEO": 3,
95  }
96 
97 
98 class TImportHeaderRow(object):
99  AUTODETECT = 0
100  NO_HEADER = 1
101  HAS_HEADER = 2
102 
103  _VALUES_TO_NAMES = {
104  0: "AUTODETECT",
105  1: "NO_HEADER",
106  2: "HAS_HEADER",
107  }
108 
109  _NAMES_TO_VALUES = {
110  "AUTODETECT": 0,
111  "NO_HEADER": 1,
112  "HAS_HEADER": 2,
113  }
114 
115 
116 class TRole(object):
117  SERVER = 0
118  AGGREGATOR = 1
119  LEAF = 2
120  STRING_DICTIONARY = 3
121 
122  _VALUES_TO_NAMES = {
123  0: "SERVER",
124  1: "AGGREGATOR",
125  2: "LEAF",
126  3: "STRING_DICTIONARY",
127  }
128 
129  _NAMES_TO_VALUES = {
130  "SERVER": 0,
131  "AGGREGATOR": 1,
132  "LEAF": 2,
133  "STRING_DICTIONARY": 3,
134  }
135 
136 
137 class TMergeType(object):
138  UNION = 0
139  REDUCE = 1
140 
141  _VALUES_TO_NAMES = {
142  0: "UNION",
143  1: "REDUCE",
144  }
145 
146  _NAMES_TO_VALUES = {
147  "UNION": 0,
148  "REDUCE": 1,
149  }
150 
151 
152 class TQueryType(object):
153  UNKNOWN = 0
154  READ = 1
155  WRITE = 2
156  SCHEMA_READ = 3
157  SCHEMA_WRITE = 4
158 
159  _VALUES_TO_NAMES = {
160  0: "UNKNOWN",
161  1: "READ",
162  2: "WRITE",
163  3: "SCHEMA_READ",
164  4: "SCHEMA_WRITE",
165  }
166 
167  _NAMES_TO_VALUES = {
168  "UNKNOWN": 0,
169  "READ": 1,
170  "WRITE": 2,
171  "SCHEMA_READ": 3,
172  "SCHEMA_WRITE": 4,
173  }
174 
175 
176 class TArrowTransport(object):
177  SHARED_MEMORY = 0
178  WIRE = 1
179 
180  _VALUES_TO_NAMES = {
181  0: "SHARED_MEMORY",
182  1: "WIRE",
183  }
184 
185  _NAMES_TO_VALUES = {
186  "SHARED_MEMORY": 0,
187  "WIRE": 1,
188  }
189 
190 
191 class TExpressionRangeType(object):
192  INVALID = 0
193  INTEGER = 1
194  FLOAT = 2
195  DOUBLE = 3
196 
197  _VALUES_TO_NAMES = {
198  0: "INVALID",
199  1: "INTEGER",
200  2: "FLOAT",
201  3: "DOUBLE",
202  }
203 
204  _NAMES_TO_VALUES = {
205  "INVALID": 0,
206  "INTEGER": 1,
207  "FLOAT": 2,
208  "DOUBLE": 3,
209  }
210 
211 
212 class TDBObjectType(object):
213  AbstractDBObjectType = 0
214  DatabaseDBObjectType = 1
215  TableDBObjectType = 2
216  DashboardDBObjectType = 3
217  ViewDBObjectType = 4
218  ServerDBObjectType = 5
219 
220  _VALUES_TO_NAMES = {
221  0: "AbstractDBObjectType",
222  1: "DatabaseDBObjectType",
223  2: "TableDBObjectType",
224  3: "DashboardDBObjectType",
225  4: "ViewDBObjectType",
226  5: "ServerDBObjectType",
227  }
228 
229  _NAMES_TO_VALUES = {
230  "AbstractDBObjectType": 0,
231  "DatabaseDBObjectType": 1,
232  "TableDBObjectType": 2,
233  "DashboardDBObjectType": 3,
234  "ViewDBObjectType": 4,
235  "ServerDBObjectType": 5,
236  }
237 
238 
239 class TDatumVal(object):
240  """
241  Attributes:
242  - int_val
243  - real_val
244  - str_val
245  - arr_val
246 
247  """
248 
249 
250  def __init__(self, int_val=None, real_val=None, str_val=None, arr_val=None,):
251  self.int_val = int_val
252  self.real_val = real_val
253  self.str_val = str_val
254  self.arr_val = arr_val
255 
256  def read(self, iprot):
257  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
258  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
259  return
260  iprot.readStructBegin()
261  while True:
262  (fname, ftype, fid) = iprot.readFieldBegin()
263  if ftype == TType.STOP:
264  break
265  if fid == 1:
266  if ftype == TType.I64:
267  self.int_val = iprot.readI64()
268  else:
269  iprot.skip(ftype)
270  elif fid == 2:
271  if ftype == TType.DOUBLE:
272  self.real_val = iprot.readDouble()
273  else:
274  iprot.skip(ftype)
275  elif fid == 3:
276  if ftype == TType.STRING:
277  self.str_val = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
278  else:
279  iprot.skip(ftype)
280  elif fid == 4:
281  if ftype == TType.LIST:
282  self.arr_val = []
283  (_etype3, _size0) = iprot.readListBegin()
284  for _i4 in range(_size0):
285  _elem5 = TDatum()
286  _elem5.read(iprot)
287  self.arr_val.append(_elem5)
288  iprot.readListEnd()
289  else:
290  iprot.skip(ftype)
291  else:
292  iprot.skip(ftype)
293  iprot.readFieldEnd()
294  iprot.readStructEnd()
295 
296  def write(self, oprot):
297  if oprot._fast_encode is not None and self.thrift_spec is not None:
298  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
299  return
300  oprot.writeStructBegin('TDatumVal')
301  if self.int_val is not None:
302  oprot.writeFieldBegin('int_val', TType.I64, 1)
303  oprot.writeI64(self.int_val)
304  oprot.writeFieldEnd()
305  if self.real_val is not None:
306  oprot.writeFieldBegin('real_val', TType.DOUBLE, 2)
307  oprot.writeDouble(self.real_val)
308  oprot.writeFieldEnd()
309  if self.str_val is not None:
310  oprot.writeFieldBegin('str_val', TType.STRING, 3)
311  oprot.writeString(self.str_val.encode('utf-8') if sys.version_info[0] == 2 else self.str_val)
312  oprot.writeFieldEnd()
313  if self.arr_val is not None:
314  oprot.writeFieldBegin('arr_val', TType.LIST, 4)
315  oprot.writeListBegin(TType.STRUCT, len(self.arr_val))
316  for iter6 in self.arr_val:
317  iter6.write(oprot)
318  oprot.writeListEnd()
319  oprot.writeFieldEnd()
320  oprot.writeFieldStop()
321  oprot.writeStructEnd()
322 
323  def validate(self):
324  return
325 
326  def __repr__(self):
327  L = ['%s=%r' % (key, value)
328  for key, value in self.__dict__.items()]
329  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
330 
331  def __eq__(self, other):
332  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
333 
334  def __ne__(self, other):
335  return not (self == other)
336 
337 
338 class TDatum(object):
339  """
340  Attributes:
341  - val
342  - is_null
343 
344  """
345 
346 
347  def __init__(self, val=None, is_null=None,):
348  self.val = val
349  self.is_null = is_null
350 
351  def read(self, iprot):
352  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
353  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
354  return
355  iprot.readStructBegin()
356  while True:
357  (fname, ftype, fid) = iprot.readFieldBegin()
358  if ftype == TType.STOP:
359  break
360  if fid == 1:
361  if ftype == TType.STRUCT:
362  self.val = TDatumVal()
363  self.val.read(iprot)
364  else:
365  iprot.skip(ftype)
366  elif fid == 2:
367  if ftype == TType.BOOL:
368  self.is_null = iprot.readBool()
369  else:
370  iprot.skip(ftype)
371  else:
372  iprot.skip(ftype)
373  iprot.readFieldEnd()
374  iprot.readStructEnd()
375 
376  def write(self, oprot):
377  if oprot._fast_encode is not None and self.thrift_spec is not None:
378  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
379  return
380  oprot.writeStructBegin('TDatum')
381  if self.val is not None:
382  oprot.writeFieldBegin('val', TType.STRUCT, 1)
383  self.val.write(oprot)
384  oprot.writeFieldEnd()
385  if self.is_null is not None:
386  oprot.writeFieldBegin('is_null', TType.BOOL, 2)
387  oprot.writeBool(self.is_null)
388  oprot.writeFieldEnd()
389  oprot.writeFieldStop()
390  oprot.writeStructEnd()
391 
392  def validate(self):
393  return
394 
395  def __repr__(self):
396  L = ['%s=%r' % (key, value)
397  for key, value in self.__dict__.items()]
398  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
399 
400  def __eq__(self, other):
401  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
402 
403  def __ne__(self, other):
404  return not (self == other)
405 
406 
407 class TStringValue(object):
408  """
409  Attributes:
410  - str_val
411  - is_null
412 
413  """
414 
415 
416  def __init__(self, str_val=None, is_null=None,):
417  self.str_val = str_val
418  self.is_null = is_null
419 
420  def read(self, iprot):
421  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
422  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
423  return
424  iprot.readStructBegin()
425  while True:
426  (fname, ftype, fid) = iprot.readFieldBegin()
427  if ftype == TType.STOP:
428  break
429  if fid == 1:
430  if ftype == TType.STRING:
431  self.str_val = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
432  else:
433  iprot.skip(ftype)
434  elif fid == 2:
435  if ftype == TType.BOOL:
436  self.is_null = iprot.readBool()
437  else:
438  iprot.skip(ftype)
439  else:
440  iprot.skip(ftype)
441  iprot.readFieldEnd()
442  iprot.readStructEnd()
443 
444  def write(self, oprot):
445  if oprot._fast_encode is not None and self.thrift_spec is not None:
446  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
447  return
448  oprot.writeStructBegin('TStringValue')
449  if self.str_val is not None:
450  oprot.writeFieldBegin('str_val', TType.STRING, 1)
451  oprot.writeString(self.str_val.encode('utf-8') if sys.version_info[0] == 2 else self.str_val)
452  oprot.writeFieldEnd()
453  if self.is_null is not None:
454  oprot.writeFieldBegin('is_null', TType.BOOL, 2)
455  oprot.writeBool(self.is_null)
456  oprot.writeFieldEnd()
457  oprot.writeFieldStop()
458  oprot.writeStructEnd()
459 
460  def validate(self):
461  return
462 
463  def __repr__(self):
464  L = ['%s=%r' % (key, value)
465  for key, value in self.__dict__.items()]
466  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
467 
468  def __eq__(self, other):
469  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
470 
471  def __ne__(self, other):
472  return not (self == other)
473 
474 
475 class TColumnType(object):
476  """
477  Attributes:
478  - col_name
479  - col_type
480  - is_reserved_keyword
481  - src_name
482  - is_system
483  - is_physical
484  - col_id
485 
486  """
487 
488 
489  def __init__(self, col_name=None, col_type=None, is_reserved_keyword=None, src_name=None, is_system=None, is_physical=None, col_id=None,):
490  self.col_name = col_name
491  self.col_type = col_type
492  self.is_reserved_keyword = is_reserved_keyword
493  self.src_name = src_name
494  self.is_system = is_system
495  self.is_physical = is_physical
496  self.col_id = col_id
497 
498  def read(self, iprot):
499  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
500  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
501  return
502  iprot.readStructBegin()
503  while True:
504  (fname, ftype, fid) = iprot.readFieldBegin()
505  if ftype == TType.STOP:
506  break
507  if fid == 1:
508  if ftype == TType.STRING:
509  self.col_name = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
510  else:
511  iprot.skip(ftype)
512  elif fid == 2:
513  if ftype == TType.STRUCT:
515  self.col_type.read(iprot)
516  else:
517  iprot.skip(ftype)
518  elif fid == 3:
519  if ftype == TType.BOOL:
520  self.is_reserved_keyword = iprot.readBool()
521  else:
522  iprot.skip(ftype)
523  elif fid == 4:
524  if ftype == TType.STRING:
525  self.src_name = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
526  else:
527  iprot.skip(ftype)
528  elif fid == 5:
529  if ftype == TType.BOOL:
530  self.is_system = iprot.readBool()
531  else:
532  iprot.skip(ftype)
533  elif fid == 6:
534  if ftype == TType.BOOL:
535  self.is_physical = iprot.readBool()
536  else:
537  iprot.skip(ftype)
538  elif fid == 7:
539  if ftype == TType.I64:
540  self.col_id = iprot.readI64()
541  else:
542  iprot.skip(ftype)
543  else:
544  iprot.skip(ftype)
545  iprot.readFieldEnd()
546  iprot.readStructEnd()
547 
548  def write(self, oprot):
549  if oprot._fast_encode is not None and self.thrift_spec is not None:
550  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
551  return
552  oprot.writeStructBegin('TColumnType')
553  if self.col_name is not None:
554  oprot.writeFieldBegin('col_name', TType.STRING, 1)
555  oprot.writeString(self.col_name.encode('utf-8') if sys.version_info[0] == 2 else self.col_name)
556  oprot.writeFieldEnd()
557  if self.col_type is not None:
558  oprot.writeFieldBegin('col_type', TType.STRUCT, 2)
559  self.col_type.write(oprot)
560  oprot.writeFieldEnd()
561  if self.is_reserved_keyword is not None:
562  oprot.writeFieldBegin('is_reserved_keyword', TType.BOOL, 3)
563  oprot.writeBool(self.is_reserved_keyword)
564  oprot.writeFieldEnd()
565  if self.src_name is not None:
566  oprot.writeFieldBegin('src_name', TType.STRING, 4)
567  oprot.writeString(self.src_name.encode('utf-8') if sys.version_info[0] == 2 else self.src_name)
568  oprot.writeFieldEnd()
569  if self.is_system is not None:
570  oprot.writeFieldBegin('is_system', TType.BOOL, 5)
571  oprot.writeBool(self.is_system)
572  oprot.writeFieldEnd()
573  if self.is_physical is not None:
574  oprot.writeFieldBegin('is_physical', TType.BOOL, 6)
575  oprot.writeBool(self.is_physical)
576  oprot.writeFieldEnd()
577  if self.col_id is not None:
578  oprot.writeFieldBegin('col_id', TType.I64, 7)
579  oprot.writeI64(self.col_id)
580  oprot.writeFieldEnd()
581  oprot.writeFieldStop()
582  oprot.writeStructEnd()
583 
584  def validate(self):
585  return
586 
587  def __repr__(self):
588  L = ['%s=%r' % (key, value)
589  for key, value in self.__dict__.items()]
590  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
591 
592  def __eq__(self, other):
593  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
594 
595  def __ne__(self, other):
596  return not (self == other)
597 
598 
599 class TRow(object):
600  """
601  Attributes:
602  - cols
603 
604  """
605 
606 
607  def __init__(self, cols=None,):
608  self.cols = cols
609 
610  def read(self, iprot):
611  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
612  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
613  return
614  iprot.readStructBegin()
615  while True:
616  (fname, ftype, fid) = iprot.readFieldBegin()
617  if ftype == TType.STOP:
618  break
619  if fid == 1:
620  if ftype == TType.LIST:
621  self.cols = []
622  (_etype10, _size7) = iprot.readListBegin()
623  for _i11 in range(_size7):
624  _elem12 = TDatum()
625  _elem12.read(iprot)
626  self.cols.append(_elem12)
627  iprot.readListEnd()
628  else:
629  iprot.skip(ftype)
630  else:
631  iprot.skip(ftype)
632  iprot.readFieldEnd()
633  iprot.readStructEnd()
634 
635  def write(self, oprot):
636  if oprot._fast_encode is not None and self.thrift_spec is not None:
637  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
638  return
639  oprot.writeStructBegin('TRow')
640  if self.cols is not None:
641  oprot.writeFieldBegin('cols', TType.LIST, 1)
642  oprot.writeListBegin(TType.STRUCT, len(self.cols))
643  for iter13 in self.cols:
644  iter13.write(oprot)
645  oprot.writeListEnd()
646  oprot.writeFieldEnd()
647  oprot.writeFieldStop()
648  oprot.writeStructEnd()
649 
650  def validate(self):
651  return
652 
653  def __repr__(self):
654  L = ['%s=%r' % (key, value)
655  for key, value in self.__dict__.items()]
656  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
657 
658  def __eq__(self, other):
659  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
660 
661  def __ne__(self, other):
662  return not (self == other)
663 
664 
665 class TColumnData(object):
666  """
667  Attributes:
668  - int_col
669  - real_col
670  - str_col
671  - arr_col
672 
673  """
674 
675 
676  def __init__(self, int_col=None, real_col=None, str_col=None, arr_col=None,):
677  self.int_col = int_col
678  self.real_col = real_col
679  self.str_col = str_col
680  self.arr_col = arr_col
681 
682  def read(self, iprot):
683  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
684  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
685  return
686  iprot.readStructBegin()
687  while True:
688  (fname, ftype, fid) = iprot.readFieldBegin()
689  if ftype == TType.STOP:
690  break
691  if fid == 1:
692  if ftype == TType.LIST:
693  self.int_col = []
694  (_etype17, _size14) = iprot.readListBegin()
695  for _i18 in range(_size14):
696  _elem19 = iprot.readI64()
697  self.int_col.append(_elem19)
698  iprot.readListEnd()
699  else:
700  iprot.skip(ftype)
701  elif fid == 2:
702  if ftype == TType.LIST:
703  self.real_col = []
704  (_etype23, _size20) = iprot.readListBegin()
705  for _i24 in range(_size20):
706  _elem25 = iprot.readDouble()
707  self.real_col.append(_elem25)
708  iprot.readListEnd()
709  else:
710  iprot.skip(ftype)
711  elif fid == 3:
712  if ftype == TType.LIST:
713  self.str_col = []
714  (_etype29, _size26) = iprot.readListBegin()
715  for _i30 in range(_size26):
716  _elem31 = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
717  self.str_col.append(_elem31)
718  iprot.readListEnd()
719  else:
720  iprot.skip(ftype)
721  elif fid == 4:
722  if ftype == TType.LIST:
723  self.arr_col = []
724  (_etype35, _size32) = iprot.readListBegin()
725  for _i36 in range(_size32):
726  _elem37 = TColumn()
727  _elem37.read(iprot)
728  self.arr_col.append(_elem37)
729  iprot.readListEnd()
730  else:
731  iprot.skip(ftype)
732  else:
733  iprot.skip(ftype)
734  iprot.readFieldEnd()
735  iprot.readStructEnd()
736 
737  def write(self, oprot):
738  if oprot._fast_encode is not None and self.thrift_spec is not None:
739  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
740  return
741  oprot.writeStructBegin('TColumnData')
742  if self.int_col is not None:
743  oprot.writeFieldBegin('int_col', TType.LIST, 1)
744  oprot.writeListBegin(TType.I64, len(self.int_col))
745  for iter38 in self.int_col:
746  oprot.writeI64(iter38)
747  oprot.writeListEnd()
748  oprot.writeFieldEnd()
749  if self.real_col is not None:
750  oprot.writeFieldBegin('real_col', TType.LIST, 2)
751  oprot.writeListBegin(TType.DOUBLE, len(self.real_col))
752  for iter39 in self.real_col:
753  oprot.writeDouble(iter39)
754  oprot.writeListEnd()
755  oprot.writeFieldEnd()
756  if self.str_col is not None:
757  oprot.writeFieldBegin('str_col', TType.LIST, 3)
758  oprot.writeListBegin(TType.STRING, len(self.str_col))
759  for iter40 in self.str_col:
760  oprot.writeString(iter40.encode('utf-8') if sys.version_info[0] == 2 else iter40)
761  oprot.writeListEnd()
762  oprot.writeFieldEnd()
763  if self.arr_col is not None:
764  oprot.writeFieldBegin('arr_col', TType.LIST, 4)
765  oprot.writeListBegin(TType.STRUCT, len(self.arr_col))
766  for iter41 in self.arr_col:
767  iter41.write(oprot)
768  oprot.writeListEnd()
769  oprot.writeFieldEnd()
770  oprot.writeFieldStop()
771  oprot.writeStructEnd()
772 
773  def validate(self):
774  return
775 
776  def __repr__(self):
777  L = ['%s=%r' % (key, value)
778  for key, value in self.__dict__.items()]
779  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
780 
781  def __eq__(self, other):
782  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
783 
784  def __ne__(self, other):
785  return not (self == other)
786 
787 
788 class TColumn(object):
789  """
790  Attributes:
791  - data
792  - nulls
793 
794  """
795 
796 
797  def __init__(self, data=None, nulls=None,):
798  self.data = data
799  self.nulls = nulls
800 
801  def read(self, iprot):
802  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
803  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
804  return
805  iprot.readStructBegin()
806  while True:
807  (fname, ftype, fid) = iprot.readFieldBegin()
808  if ftype == TType.STOP:
809  break
810  if fid == 1:
811  if ftype == TType.STRUCT:
812  self.data = TColumnData()
813  self.data.read(iprot)
814  else:
815  iprot.skip(ftype)
816  elif fid == 2:
817  if ftype == TType.LIST:
818  self.nulls = []
819  (_etype45, _size42) = iprot.readListBegin()
820  for _i46 in range(_size42):
821  _elem47 = iprot.readBool()
822  self.nulls.append(_elem47)
823  iprot.readListEnd()
824  else:
825  iprot.skip(ftype)
826  else:
827  iprot.skip(ftype)
828  iprot.readFieldEnd()
829  iprot.readStructEnd()
830 
831  def write(self, oprot):
832  if oprot._fast_encode is not None and self.thrift_spec is not None:
833  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
834  return
835  oprot.writeStructBegin('TColumn')
836  if self.data is not None:
837  oprot.writeFieldBegin('data', TType.STRUCT, 1)
838  self.data.write(oprot)
839  oprot.writeFieldEnd()
840  if self.nulls is not None:
841  oprot.writeFieldBegin('nulls', TType.LIST, 2)
842  oprot.writeListBegin(TType.BOOL, len(self.nulls))
843  for iter48 in self.nulls:
844  oprot.writeBool(iter48)
845  oprot.writeListEnd()
846  oprot.writeFieldEnd()
847  oprot.writeFieldStop()
848  oprot.writeStructEnd()
849 
850  def validate(self):
851  return
852 
853  def __repr__(self):
854  L = ['%s=%r' % (key, value)
855  for key, value in self.__dict__.items()]
856  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
857 
858  def __eq__(self, other):
859  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
860 
861  def __ne__(self, other):
862  return not (self == other)
863 
864 
865 class TStringRow(object):
866  """
867  Attributes:
868  - cols
869 
870  """
871 
872 
873  def __init__(self, cols=None,):
874  self.cols = cols
875 
876  def read(self, iprot):
877  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
878  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
879  return
880  iprot.readStructBegin()
881  while True:
882  (fname, ftype, fid) = iprot.readFieldBegin()
883  if ftype == TType.STOP:
884  break
885  if fid == 1:
886  if ftype == TType.LIST:
887  self.cols = []
888  (_etype52, _size49) = iprot.readListBegin()
889  for _i53 in range(_size49):
890  _elem54 = TStringValue()
891  _elem54.read(iprot)
892  self.cols.append(_elem54)
893  iprot.readListEnd()
894  else:
895  iprot.skip(ftype)
896  else:
897  iprot.skip(ftype)
898  iprot.readFieldEnd()
899  iprot.readStructEnd()
900 
901  def write(self, oprot):
902  if oprot._fast_encode is not None and self.thrift_spec is not None:
903  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
904  return
905  oprot.writeStructBegin('TStringRow')
906  if self.cols is not None:
907  oprot.writeFieldBegin('cols', TType.LIST, 1)
908  oprot.writeListBegin(TType.STRUCT, len(self.cols))
909  for iter55 in self.cols:
910  iter55.write(oprot)
911  oprot.writeListEnd()
912  oprot.writeFieldEnd()
913  oprot.writeFieldStop()
914  oprot.writeStructEnd()
915 
916  def validate(self):
917  return
918 
919  def __repr__(self):
920  L = ['%s=%r' % (key, value)
921  for key, value in self.__dict__.items()]
922  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
923 
924  def __eq__(self, other):
925  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
926 
927  def __ne__(self, other):
928  return not (self == other)
929 
930 
931 class TKrb5Session(object):
932  """
933  Attributes:
934  - sessionId
935  - krbToken
936 
937  """
938 
939 
940  def __init__(self, sessionId=None, krbToken=None,):
941  self.sessionId = sessionId
942  self.krbToken = krbToken
943 
944  def read(self, iprot):
945  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
946  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
947  return
948  iprot.readStructBegin()
949  while True:
950  (fname, ftype, fid) = iprot.readFieldBegin()
951  if ftype == TType.STOP:
952  break
953  if fid == 1:
954  if ftype == TType.STRING:
955  self.sessionId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
956  else:
957  iprot.skip(ftype)
958  elif fid == 2:
959  if ftype == TType.STRING:
960  self.krbToken = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
961  else:
962  iprot.skip(ftype)
963  else:
964  iprot.skip(ftype)
965  iprot.readFieldEnd()
966  iprot.readStructEnd()
967 
968  def write(self, oprot):
969  if oprot._fast_encode is not None and self.thrift_spec is not None:
970  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
971  return
972  oprot.writeStructBegin('TKrb5Session')
973  if self.sessionId is not None:
974  oprot.writeFieldBegin('sessionId', TType.STRING, 1)
975  oprot.writeString(self.sessionId.encode('utf-8') if sys.version_info[0] == 2 else self.sessionId)
976  oprot.writeFieldEnd()
977  if self.krbToken is not None:
978  oprot.writeFieldBegin('krbToken', TType.STRING, 2)
979  oprot.writeString(self.krbToken.encode('utf-8') if sys.version_info[0] == 2 else self.krbToken)
980  oprot.writeFieldEnd()
981  oprot.writeFieldStop()
982  oprot.writeStructEnd()
983 
984  def validate(self):
985  return
986 
987  def __repr__(self):
988  L = ['%s=%r' % (key, value)
989  for key, value in self.__dict__.items()]
990  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
991 
992  def __eq__(self, other):
993  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
994 
995  def __ne__(self, other):
996  return not (self == other)
997 
998 
999 class TStepResult(object):
1000  """
1001  Attributes:
1002  - serialized_rows
1003  - execution_finished
1004  - merge_type
1005  - sharded
1006  - row_desc
1007  - node_id
1008 
1009  """
1010 
1011 
1012  def __init__(self, serialized_rows=None, execution_finished=None, merge_type=None, sharded=None, row_desc=None, node_id=None,):
1013  self.serialized_rows = serialized_rows
1014  self.execution_finished = execution_finished
1015  self.merge_type = merge_type
1016  self.sharded = sharded
1017  self.row_desc = row_desc
1018  self.node_id = node_id
1019 
1020  def read(self, iprot):
1021  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
1022  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
1023  return
1024  iprot.readStructBegin()
1025  while True:
1026  (fname, ftype, fid) = iprot.readFieldBegin()
1027  if ftype == TType.STOP:
1028  break
1029  if fid == 1:
1030  if ftype == TType.STRUCT:
1032  self.serialized_rows.read(iprot)
1033  else:
1034  iprot.skip(ftype)
1035  elif fid == 2:
1036  if ftype == TType.BOOL:
1037  self.execution_finished = iprot.readBool()
1038  else:
1039  iprot.skip(ftype)
1040  elif fid == 3:
1041  if ftype == TType.I32:
1042  self.merge_type = iprot.readI32()
1043  else:
1044  iprot.skip(ftype)
1045  elif fid == 4:
1046  if ftype == TType.BOOL:
1047  self.sharded = iprot.readBool()
1048  else:
1049  iprot.skip(ftype)
1050  elif fid == 5:
1051  if ftype == TType.LIST:
1052  self.row_desc = []
1053  (_etype59, _size56) = iprot.readListBegin()
1054  for _i60 in range(_size56):
1055  _elem61 = TColumnType()
1056  _elem61.read(iprot)
1057  self.row_desc.append(_elem61)
1058  iprot.readListEnd()
1059  else:
1060  iprot.skip(ftype)
1061  elif fid == 6:
1062  if ftype == TType.I32:
1063  self.node_id = iprot.readI32()
1064  else:
1065  iprot.skip(ftype)
1066  else:
1067  iprot.skip(ftype)
1068  iprot.readFieldEnd()
1069  iprot.readStructEnd()
1070 
1071  def write(self, oprot):
1072  if oprot._fast_encode is not None and self.thrift_spec is not None:
1073  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
1074  return
1075  oprot.writeStructBegin('TStepResult')
1076  if self.serialized_rows is not None:
1077  oprot.writeFieldBegin('serialized_rows', TType.STRUCT, 1)
1078  self.serialized_rows.write(oprot)
1079  oprot.writeFieldEnd()
1080  if self.execution_finished is not None:
1081  oprot.writeFieldBegin('execution_finished', TType.BOOL, 2)
1082  oprot.writeBool(self.execution_finished)
1083  oprot.writeFieldEnd()
1084  if self.merge_type is not None:
1085  oprot.writeFieldBegin('merge_type', TType.I32, 3)
1086  oprot.writeI32(self.merge_type)
1087  oprot.writeFieldEnd()
1088  if self.sharded is not None:
1089  oprot.writeFieldBegin('sharded', TType.BOOL, 4)
1090  oprot.writeBool(self.sharded)
1091  oprot.writeFieldEnd()
1092  if self.row_desc is not None:
1093  oprot.writeFieldBegin('row_desc', TType.LIST, 5)
1094  oprot.writeListBegin(TType.STRUCT, len(self.row_desc))
1095  for iter62 in self.row_desc:
1096  iter62.write(oprot)
1097  oprot.writeListEnd()
1098  oprot.writeFieldEnd()
1099  if self.node_id is not None:
1100  oprot.writeFieldBegin('node_id', TType.I32, 6)
1101  oprot.writeI32(self.node_id)
1102  oprot.writeFieldEnd()
1103  oprot.writeFieldStop()
1104  oprot.writeStructEnd()
1105 
1106  def validate(self):
1107  return
1108 
1109  def __repr__(self):
1110  L = ['%s=%r' % (key, value)
1111  for key, value in self.__dict__.items()]
1112  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1113 
1114  def __eq__(self, other):
1115  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1116 
1117  def __ne__(self, other):
1118  return not (self == other)
1119 
1120 
1121 class TRowSet(object):
1122  """
1123  Attributes:
1124  - row_desc
1125  - rows
1126  - columns
1127  - is_columnar
1128 
1129  """
1130 
1131 
1132  def __init__(self, row_desc=None, rows=None, columns=None, is_columnar=None,):
1133  self.row_desc = row_desc
1134  self.rows = rows
1135  self.columns = columns
1136  self.is_columnar = is_columnar
1137 
1138  def read(self, iprot):
1139  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
1140  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
1141  return
1142  iprot.readStructBegin()
1143  while True:
1144  (fname, ftype, fid) = iprot.readFieldBegin()
1145  if ftype == TType.STOP:
1146  break
1147  if fid == 1:
1148  if ftype == TType.LIST:
1149  self.row_desc = []
1150  (_etype66, _size63) = iprot.readListBegin()
1151  for _i67 in range(_size63):
1152  _elem68 = TColumnType()
1153  _elem68.read(iprot)
1154  self.row_desc.append(_elem68)
1155  iprot.readListEnd()
1156  else:
1157  iprot.skip(ftype)
1158  elif fid == 2:
1159  if ftype == TType.LIST:
1160  self.rows = []
1161  (_etype72, _size69) = iprot.readListBegin()
1162  for _i73 in range(_size69):
1163  _elem74 = TRow()
1164  _elem74.read(iprot)
1165  self.rows.append(_elem74)
1166  iprot.readListEnd()
1167  else:
1168  iprot.skip(ftype)
1169  elif fid == 3:
1170  if ftype == TType.LIST:
1171  self.columns = []
1172  (_etype78, _size75) = iprot.readListBegin()
1173  for _i79 in range(_size75):
1174  _elem80 = TColumn()
1175  _elem80.read(iprot)
1176  self.columns.append(_elem80)
1177  iprot.readListEnd()
1178  else:
1179  iprot.skip(ftype)
1180  elif fid == 4:
1181  if ftype == TType.BOOL:
1182  self.is_columnar = iprot.readBool()
1183  else:
1184  iprot.skip(ftype)
1185  else:
1186  iprot.skip(ftype)
1187  iprot.readFieldEnd()
1188  iprot.readStructEnd()
1189 
1190  def write(self, oprot):
1191  if oprot._fast_encode is not None and self.thrift_spec is not None:
1192  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
1193  return
1194  oprot.writeStructBegin('TRowSet')
1195  if self.row_desc is not None:
1196  oprot.writeFieldBegin('row_desc', TType.LIST, 1)
1197  oprot.writeListBegin(TType.STRUCT, len(self.row_desc))
1198  for iter81 in self.row_desc:
1199  iter81.write(oprot)
1200  oprot.writeListEnd()
1201  oprot.writeFieldEnd()
1202  if self.rows is not None:
1203  oprot.writeFieldBegin('rows', TType.LIST, 2)
1204  oprot.writeListBegin(TType.STRUCT, len(self.rows))
1205  for iter82 in self.rows:
1206  iter82.write(oprot)
1207  oprot.writeListEnd()
1208  oprot.writeFieldEnd()
1209  if self.columns is not None:
1210  oprot.writeFieldBegin('columns', TType.LIST, 3)
1211  oprot.writeListBegin(TType.STRUCT, len(self.columns))
1212  for iter83 in self.columns:
1213  iter83.write(oprot)
1214  oprot.writeListEnd()
1215  oprot.writeFieldEnd()
1216  if self.is_columnar is not None:
1217  oprot.writeFieldBegin('is_columnar', TType.BOOL, 4)
1218  oprot.writeBool(self.is_columnar)
1219  oprot.writeFieldEnd()
1220  oprot.writeFieldStop()
1221  oprot.writeStructEnd()
1222 
1223  def validate(self):
1224  return
1225 
1226  def __repr__(self):
1227  L = ['%s=%r' % (key, value)
1228  for key, value in self.__dict__.items()]
1229  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1230 
1231  def __eq__(self, other):
1232  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1233 
1234  def __ne__(self, other):
1235  return not (self == other)
1236 
1237 
1238 class TQueryResult(object):
1239  """
1240  Attributes:
1241  - row_set
1242  - execution_time_ms
1243  - total_time_ms
1244  - nonce
1245  - debug
1246  - success
1247  - query_type
1248 
1249  """
1250 
1251 
1252  def __init__(self, row_set=None, execution_time_ms=None, total_time_ms=None, nonce=None, debug=None, success=True, query_type=0,):
1253  self.row_set = row_set
1254  self.execution_time_ms = execution_time_ms
1255  self.total_time_ms = total_time_ms
1256  self.nonce = nonce
1257  self.debug = debug
1258  self.success = success
1259  self.query_type = query_type
1260 
1261  def read(self, iprot):
1262  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
1263  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
1264  return
1265  iprot.readStructBegin()
1266  while True:
1267  (fname, ftype, fid) = iprot.readFieldBegin()
1268  if ftype == TType.STOP:
1269  break
1270  if fid == 1:
1271  if ftype == TType.STRUCT:
1272  self.row_set = TRowSet()
1273  self.row_set.read(iprot)
1274  else:
1275  iprot.skip(ftype)
1276  elif fid == 2:
1277  if ftype == TType.I64:
1278  self.execution_time_ms = iprot.readI64()
1279  else:
1280  iprot.skip(ftype)
1281  elif fid == 3:
1282  if ftype == TType.I64:
1283  self.total_time_ms = iprot.readI64()
1284  else:
1285  iprot.skip(ftype)
1286  elif fid == 4:
1287  if ftype == TType.STRING:
1288  self.nonce = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
1289  else:
1290  iprot.skip(ftype)
1291  elif fid == 5:
1292  if ftype == TType.STRING:
1293  self.debug = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
1294  else:
1295  iprot.skip(ftype)
1296  elif fid == 6:
1297  if ftype == TType.BOOL:
1298  self.success = iprot.readBool()
1299  else:
1300  iprot.skip(ftype)
1301  elif fid == 7:
1302  if ftype == TType.I32:
1303  self.query_type = iprot.readI32()
1304  else:
1305  iprot.skip(ftype)
1306  else:
1307  iprot.skip(ftype)
1308  iprot.readFieldEnd()
1309  iprot.readStructEnd()
1310 
1311  def write(self, oprot):
1312  if oprot._fast_encode is not None and self.thrift_spec is not None:
1313  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
1314  return
1315  oprot.writeStructBegin('TQueryResult')
1316  if self.row_set is not None:
1317  oprot.writeFieldBegin('row_set', TType.STRUCT, 1)
1318  self.row_set.write(oprot)
1319  oprot.writeFieldEnd()
1320  if self.execution_time_ms is not None:
1321  oprot.writeFieldBegin('execution_time_ms', TType.I64, 2)
1322  oprot.writeI64(self.execution_time_ms)
1323  oprot.writeFieldEnd()
1324  if self.total_time_ms is not None:
1325  oprot.writeFieldBegin('total_time_ms', TType.I64, 3)
1326  oprot.writeI64(self.total_time_ms)
1327  oprot.writeFieldEnd()
1328  if self.nonce is not None:
1329  oprot.writeFieldBegin('nonce', TType.STRING, 4)
1330  oprot.writeString(self.nonce.encode('utf-8') if sys.version_info[0] == 2 else self.nonce)
1331  oprot.writeFieldEnd()
1332  if self.debug is not None:
1333  oprot.writeFieldBegin('debug', TType.STRING, 5)
1334  oprot.writeString(self.debug.encode('utf-8') if sys.version_info[0] == 2 else self.debug)
1335  oprot.writeFieldEnd()
1336  if self.success is not None:
1337  oprot.writeFieldBegin('success', TType.BOOL, 6)
1338  oprot.writeBool(self.success)
1339  oprot.writeFieldEnd()
1340  if self.query_type is not None:
1341  oprot.writeFieldBegin('query_type', TType.I32, 7)
1342  oprot.writeI32(self.query_type)
1343  oprot.writeFieldEnd()
1344  oprot.writeFieldStop()
1345  oprot.writeStructEnd()
1346 
1347  def validate(self):
1348  return
1349 
1350  def __repr__(self):
1351  L = ['%s=%r' % (key, value)
1352  for key, value in self.__dict__.items()]
1353  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1354 
1355  def __eq__(self, other):
1356  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1357 
1358  def __ne__(self, other):
1359  return not (self == other)
1360 
1361 
1362 class TDataFrame(object):
1363  """
1364  Attributes:
1365  - sm_handle
1366  - sm_size
1367  - df_handle
1368  - df_size
1369  - execution_time_ms
1370  - arrow_conversion_time_ms
1371  - df_buffer
1372 
1373  """
1374 
1375 
1376  def __init__(self, sm_handle=None, sm_size=None, df_handle=None, df_size=None, execution_time_ms=None, arrow_conversion_time_ms=None, df_buffer=None,):
1377  self.sm_handle = sm_handle
1378  self.sm_size = sm_size
1379  self.df_handle = df_handle
1380  self.df_size = df_size
1381  self.execution_time_ms = execution_time_ms
1382  self.arrow_conversion_time_ms = arrow_conversion_time_ms
1383  self.df_buffer = df_buffer
1384 
1385  def read(self, iprot):
1386  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
1387  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
1388  return
1389  iprot.readStructBegin()
1390  while True:
1391  (fname, ftype, fid) = iprot.readFieldBegin()
1392  if ftype == TType.STOP:
1393  break
1394  if fid == 1:
1395  if ftype == TType.STRING:
1396  self.sm_handle = iprot.readBinary()
1397  else:
1398  iprot.skip(ftype)
1399  elif fid == 2:
1400  if ftype == TType.I64:
1401  self.sm_size = iprot.readI64()
1402  else:
1403  iprot.skip(ftype)
1404  elif fid == 3:
1405  if ftype == TType.STRING:
1406  self.df_handle = iprot.readBinary()
1407  else:
1408  iprot.skip(ftype)
1409  elif fid == 4:
1410  if ftype == TType.I64:
1411  self.df_size = iprot.readI64()
1412  else:
1413  iprot.skip(ftype)
1414  elif fid == 5:
1415  if ftype == TType.I64:
1416  self.execution_time_ms = iprot.readI64()
1417  else:
1418  iprot.skip(ftype)
1419  elif fid == 6:
1420  if ftype == TType.I64:
1421  self.arrow_conversion_time_ms = iprot.readI64()
1422  else:
1423  iprot.skip(ftype)
1424  elif fid == 7:
1425  if ftype == TType.STRING:
1426  self.df_buffer = iprot.readBinary()
1427  else:
1428  iprot.skip(ftype)
1429  else:
1430  iprot.skip(ftype)
1431  iprot.readFieldEnd()
1432  iprot.readStructEnd()
1433 
1434  def write(self, oprot):
1435  if oprot._fast_encode is not None and self.thrift_spec is not None:
1436  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
1437  return
1438  oprot.writeStructBegin('TDataFrame')
1439  if self.sm_handle is not None:
1440  oprot.writeFieldBegin('sm_handle', TType.STRING, 1)
1441  oprot.writeBinary(self.sm_handle)
1442  oprot.writeFieldEnd()
1443  if self.sm_size is not None:
1444  oprot.writeFieldBegin('sm_size', TType.I64, 2)
1445  oprot.writeI64(self.sm_size)
1446  oprot.writeFieldEnd()
1447  if self.df_handle is not None:
1448  oprot.writeFieldBegin('df_handle', TType.STRING, 3)
1449  oprot.writeBinary(self.df_handle)
1450  oprot.writeFieldEnd()
1451  if self.df_size is not None:
1452  oprot.writeFieldBegin('df_size', TType.I64, 4)
1453  oprot.writeI64(self.df_size)
1454  oprot.writeFieldEnd()
1455  if self.execution_time_ms is not None:
1456  oprot.writeFieldBegin('execution_time_ms', TType.I64, 5)
1457  oprot.writeI64(self.execution_time_ms)
1458  oprot.writeFieldEnd()
1459  if self.arrow_conversion_time_ms is not None:
1460  oprot.writeFieldBegin('arrow_conversion_time_ms', TType.I64, 6)
1461  oprot.writeI64(self.arrow_conversion_time_ms)
1462  oprot.writeFieldEnd()
1463  if self.df_buffer is not None:
1464  oprot.writeFieldBegin('df_buffer', TType.STRING, 7)
1465  oprot.writeBinary(self.df_buffer)
1466  oprot.writeFieldEnd()
1467  oprot.writeFieldStop()
1468  oprot.writeStructEnd()
1469 
1470  def validate(self):
1471  return
1472 
1473  def __repr__(self):
1474  L = ['%s=%r' % (key, value)
1475  for key, value in self.__dict__.items()]
1476  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1477 
1478  def __eq__(self, other):
1479  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1480 
1481  def __ne__(self, other):
1482  return not (self == other)
1483 
1484 
1485 class TDBInfo(object):
1486  """
1487  Attributes:
1488  - db_name
1489  - db_owner
1490 
1491  """
1492 
1493 
1494  def __init__(self, db_name=None, db_owner=None,):
1495  self.db_name = db_name
1496  self.db_owner = db_owner
1497 
1498  def read(self, iprot):
1499  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
1500  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
1501  return
1502  iprot.readStructBegin()
1503  while True:
1504  (fname, ftype, fid) = iprot.readFieldBegin()
1505  if ftype == TType.STOP:
1506  break
1507  if fid == 1:
1508  if ftype == TType.STRING:
1509  self.db_name = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
1510  else:
1511  iprot.skip(ftype)
1512  elif fid == 2:
1513  if ftype == TType.STRING:
1514  self.db_owner = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
1515  else:
1516  iprot.skip(ftype)
1517  else:
1518  iprot.skip(ftype)
1519  iprot.readFieldEnd()
1520  iprot.readStructEnd()
1521 
1522  def write(self, oprot):
1523  if oprot._fast_encode is not None and self.thrift_spec is not None:
1524  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
1525  return
1526  oprot.writeStructBegin('TDBInfo')
1527  if self.db_name is not None:
1528  oprot.writeFieldBegin('db_name', TType.STRING, 1)
1529  oprot.writeString(self.db_name.encode('utf-8') if sys.version_info[0] == 2 else self.db_name)
1530  oprot.writeFieldEnd()
1531  if self.db_owner is not None:
1532  oprot.writeFieldBegin('db_owner', TType.STRING, 2)
1533  oprot.writeString(self.db_owner.encode('utf-8') if sys.version_info[0] == 2 else self.db_owner)
1534  oprot.writeFieldEnd()
1535  oprot.writeFieldStop()
1536  oprot.writeStructEnd()
1537 
1538  def validate(self):
1539  return
1540 
1541  def __repr__(self):
1542  L = ['%s=%r' % (key, value)
1543  for key, value in self.__dict__.items()]
1544  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1545 
1546  def __eq__(self, other):
1547  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1548 
1549  def __ne__(self, other):
1550  return not (self == other)
1551 
1552 
1553 class TOmniSciException(TException):
1554  """
1555  Attributes:
1556  - error_msg
1557 
1558  """
1559 
1560 
1561  def __init__(self, error_msg=None,):
1562  self.error_msg = error_msg
1563 
1564  def read(self, iprot):
1565  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
1566  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
1567  return
1568  iprot.readStructBegin()
1569  while True:
1570  (fname, ftype, fid) = iprot.readFieldBegin()
1571  if ftype == TType.STOP:
1572  break
1573  if fid == 1:
1574  if ftype == TType.STRING:
1575  self.error_msg = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
1576  else:
1577  iprot.skip(ftype)
1578  else:
1579  iprot.skip(ftype)
1580  iprot.readFieldEnd()
1581  iprot.readStructEnd()
1582 
1583  def write(self, oprot):
1584  if oprot._fast_encode is not None and self.thrift_spec is not None:
1585  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
1586  return
1587  oprot.writeStructBegin('TOmniSciException')
1588  if self.error_msg is not None:
1589  oprot.writeFieldBegin('error_msg', TType.STRING, 1)
1590  oprot.writeString(self.error_msg.encode('utf-8') if sys.version_info[0] == 2 else self.error_msg)
1591  oprot.writeFieldEnd()
1592  oprot.writeFieldStop()
1593  oprot.writeStructEnd()
1594 
1595  def validate(self):
1596  return
1597 
1598  def __str__(self):
1599  return repr(self)
1600 
1601  def __repr__(self):
1602  L = ['%s=%r' % (key, value)
1603  for key, value in self.__dict__.items()]
1604  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1605 
1606  def __eq__(self, other):
1607  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1608 
1609  def __ne__(self, other):
1610  return not (self == other)
1611 
1612 
1613 class TCopyParams(object):
1614  """
1615  Attributes:
1616  - delimiter
1617  - null_str
1618  - has_header
1619  - quoted
1620  - quote
1621  - escape
1622  - line_delim
1623  - array_delim
1624  - array_begin
1625  - array_end
1626  - threads
1627  - file_type
1628  - s3_access_key
1629  - s3_secret_key
1630  - s3_region
1631  - geo_coords_encoding
1632  - geo_coords_comp_param
1633  - geo_coords_type
1634  - geo_coords_srid
1635  - sanitize_column_names
1636  - geo_layer_name
1637  - s3_endpoint
1638  - geo_assign_render_groups
1639  - geo_explode_collections
1640  - source_srid
1641 
1642  """
1643 
1644 
1645  def __init__(self, delimiter=None, null_str=None, has_header=0, quoted=None, quote=None, escape=None, line_delim=None, array_delim=None, array_begin=None, array_end=None, threads=None, file_type=0, s3_access_key=None, s3_secret_key=None, s3_region=None, geo_coords_encoding=6, geo_coords_comp_param=32, geo_coords_type=18, geo_coords_srid=4326, sanitize_column_names=True, geo_layer_name=None, s3_endpoint=None, geo_assign_render_groups=True, geo_explode_collections=False, source_srid=0,):
1646  self.delimiter = delimiter
1647  self.null_str = null_str
1648  self.has_header = has_header
1649  self.quoted = quoted
1650  self.quote = quote
1651  self.escape = escape
1652  self.line_delim = line_delim
1653  self.array_delim = array_delim
1654  self.array_begin = array_begin
1655  self.array_end = array_end
1656  self.threads = threads
1657  self.file_type = file_type
1658  self.s3_access_key = s3_access_key
1659  self.s3_secret_key = s3_secret_key
1660  self.s3_region = s3_region
1661  self.geo_coords_encoding = geo_coords_encoding
1662  self.geo_coords_comp_param = geo_coords_comp_param
1663  self.geo_coords_type = geo_coords_type
1664  self.geo_coords_srid = geo_coords_srid
1665  self.sanitize_column_names = sanitize_column_names
1666  self.geo_layer_name = geo_layer_name
1667  self.s3_endpoint = s3_endpoint
1668  self.geo_assign_render_groups = geo_assign_render_groups
1669  self.geo_explode_collections = geo_explode_collections
1670  self.source_srid = source_srid
1671 
1672  def read(self, iprot):
1673  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
1674  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
1675  return
1676  iprot.readStructBegin()
1677  while True:
1678  (fname, ftype, fid) = iprot.readFieldBegin()
1679  if ftype == TType.STOP:
1680  break
1681  if fid == 1:
1682  if ftype == TType.STRING:
1683  self.delimiter = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
1684  else:
1685  iprot.skip(ftype)
1686  elif fid == 2:
1687  if ftype == TType.STRING:
1688  self.null_str = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
1689  else:
1690  iprot.skip(ftype)
1691  elif fid == 3:
1692  if ftype == TType.I32:
1693  self.has_header = iprot.readI32()
1694  else:
1695  iprot.skip(ftype)
1696  elif fid == 4:
1697  if ftype == TType.BOOL:
1698  self.quoted = iprot.readBool()
1699  else:
1700  iprot.skip(ftype)
1701  elif fid == 5:
1702  if ftype == TType.STRING:
1703  self.quote = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
1704  else:
1705  iprot.skip(ftype)
1706  elif fid == 6:
1707  if ftype == TType.STRING:
1708  self.escape = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
1709  else:
1710  iprot.skip(ftype)
1711  elif fid == 7:
1712  if ftype == TType.STRING:
1713  self.line_delim = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
1714  else:
1715  iprot.skip(ftype)
1716  elif fid == 8:
1717  if ftype == TType.STRING:
1718  self.array_delim = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
1719  else:
1720  iprot.skip(ftype)
1721  elif fid == 9:
1722  if ftype == TType.STRING:
1723  self.array_begin = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
1724  else:
1725  iprot.skip(ftype)
1726  elif fid == 10:
1727  if ftype == TType.STRING:
1728  self.array_end = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
1729  else:
1730  iprot.skip(ftype)
1731  elif fid == 11:
1732  if ftype == TType.I32:
1733  self.threads = iprot.readI32()
1734  else:
1735  iprot.skip(ftype)
1736  elif fid == 12:
1737  if ftype == TType.I32:
1738  self.file_type = iprot.readI32()
1739  else:
1740  iprot.skip(ftype)
1741  elif fid == 13:
1742  if ftype == TType.STRING:
1743  self.s3_access_key = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
1744  else:
1745  iprot.skip(ftype)
1746  elif fid == 14:
1747  if ftype == TType.STRING:
1748  self.s3_secret_key = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
1749  else:
1750  iprot.skip(ftype)
1751  elif fid == 15:
1752  if ftype == TType.STRING:
1753  self.s3_region = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
1754  else:
1755  iprot.skip(ftype)
1756  elif fid == 16:
1757  if ftype == TType.I32:
1758  self.geo_coords_encoding = iprot.readI32()
1759  else:
1760  iprot.skip(ftype)
1761  elif fid == 17:
1762  if ftype == TType.I32:
1763  self.geo_coords_comp_param = iprot.readI32()
1764  else:
1765  iprot.skip(ftype)
1766  elif fid == 18:
1767  if ftype == TType.I32:
1768  self.geo_coords_type = iprot.readI32()
1769  else:
1770  iprot.skip(ftype)
1771  elif fid == 19:
1772  if ftype == TType.I32:
1773  self.geo_coords_srid = iprot.readI32()
1774  else:
1775  iprot.skip(ftype)
1776  elif fid == 20:
1777  if ftype == TType.BOOL:
1778  self.sanitize_column_names = iprot.readBool()
1779  else:
1780  iprot.skip(ftype)
1781  elif fid == 21:
1782  if ftype == TType.STRING:
1783  self.geo_layer_name = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
1784  else:
1785  iprot.skip(ftype)
1786  elif fid == 22:
1787  if ftype == TType.STRING:
1788  self.s3_endpoint = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
1789  else:
1790  iprot.skip(ftype)
1791  elif fid == 23:
1792  if ftype == TType.BOOL:
1793  self.geo_assign_render_groups = iprot.readBool()
1794  else:
1795  iprot.skip(ftype)
1796  elif fid == 24:
1797  if ftype == TType.BOOL:
1798  self.geo_explode_collections = iprot.readBool()
1799  else:
1800  iprot.skip(ftype)
1801  elif fid == 25:
1802  if ftype == TType.I32:
1803  self.source_srid = iprot.readI32()
1804  else:
1805  iprot.skip(ftype)
1806  else:
1807  iprot.skip(ftype)
1808  iprot.readFieldEnd()
1809  iprot.readStructEnd()
1810 
1811  def write(self, oprot):
1812  if oprot._fast_encode is not None and self.thrift_spec is not None:
1813  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
1814  return
1815  oprot.writeStructBegin('TCopyParams')
1816  if self.delimiter is not None:
1817  oprot.writeFieldBegin('delimiter', TType.STRING, 1)
1818  oprot.writeString(self.delimiter.encode('utf-8') if sys.version_info[0] == 2 else self.delimiter)
1819  oprot.writeFieldEnd()
1820  if self.null_str is not None:
1821  oprot.writeFieldBegin('null_str', TType.STRING, 2)
1822  oprot.writeString(self.null_str.encode('utf-8') if sys.version_info[0] == 2 else self.null_str)
1823  oprot.writeFieldEnd()
1824  if self.has_header is not None:
1825  oprot.writeFieldBegin('has_header', TType.I32, 3)
1826  oprot.writeI32(self.has_header)
1827  oprot.writeFieldEnd()
1828  if self.quoted is not None:
1829  oprot.writeFieldBegin('quoted', TType.BOOL, 4)
1830  oprot.writeBool(self.quoted)
1831  oprot.writeFieldEnd()
1832  if self.quote is not None:
1833  oprot.writeFieldBegin('quote', TType.STRING, 5)
1834  oprot.writeString(self.quote.encode('utf-8') if sys.version_info[0] == 2 else self.quote)
1835  oprot.writeFieldEnd()
1836  if self.escape is not None:
1837  oprot.writeFieldBegin('escape', TType.STRING, 6)
1838  oprot.writeString(self.escape.encode('utf-8') if sys.version_info[0] == 2 else self.escape)
1839  oprot.writeFieldEnd()
1840  if self.line_delim is not None:
1841  oprot.writeFieldBegin('line_delim', TType.STRING, 7)
1842  oprot.writeString(self.line_delim.encode('utf-8') if sys.version_info[0] == 2 else self.line_delim)
1843  oprot.writeFieldEnd()
1844  if self.array_delim is not None:
1845  oprot.writeFieldBegin('array_delim', TType.STRING, 8)
1846  oprot.writeString(self.array_delim.encode('utf-8') if sys.version_info[0] == 2 else self.array_delim)
1847  oprot.writeFieldEnd()
1848  if self.array_begin is not None:
1849  oprot.writeFieldBegin('array_begin', TType.STRING, 9)
1850  oprot.writeString(self.array_begin.encode('utf-8') if sys.version_info[0] == 2 else self.array_begin)
1851  oprot.writeFieldEnd()
1852  if self.array_end is not None:
1853  oprot.writeFieldBegin('array_end', TType.STRING, 10)
1854  oprot.writeString(self.array_end.encode('utf-8') if sys.version_info[0] == 2 else self.array_end)
1855  oprot.writeFieldEnd()
1856  if self.threads is not None:
1857  oprot.writeFieldBegin('threads', TType.I32, 11)
1858  oprot.writeI32(self.threads)
1859  oprot.writeFieldEnd()
1860  if self.file_type is not None:
1861  oprot.writeFieldBegin('file_type', TType.I32, 12)
1862  oprot.writeI32(self.file_type)
1863  oprot.writeFieldEnd()
1864  if self.s3_access_key is not None:
1865  oprot.writeFieldBegin('s3_access_key', TType.STRING, 13)
1866  oprot.writeString(self.s3_access_key.encode('utf-8') if sys.version_info[0] == 2 else self.s3_access_key)
1867  oprot.writeFieldEnd()
1868  if self.s3_secret_key is not None:
1869  oprot.writeFieldBegin('s3_secret_key', TType.STRING, 14)
1870  oprot.writeString(self.s3_secret_key.encode('utf-8') if sys.version_info[0] == 2 else self.s3_secret_key)
1871  oprot.writeFieldEnd()
1872  if self.s3_region is not None:
1873  oprot.writeFieldBegin('s3_region', TType.STRING, 15)
1874  oprot.writeString(self.s3_region.encode('utf-8') if sys.version_info[0] == 2 else self.s3_region)
1875  oprot.writeFieldEnd()
1876  if self.geo_coords_encoding is not None:
1877  oprot.writeFieldBegin('geo_coords_encoding', TType.I32, 16)
1878  oprot.writeI32(self.geo_coords_encoding)
1879  oprot.writeFieldEnd()
1880  if self.geo_coords_comp_param is not None:
1881  oprot.writeFieldBegin('geo_coords_comp_param', TType.I32, 17)
1882  oprot.writeI32(self.geo_coords_comp_param)
1883  oprot.writeFieldEnd()
1884  if self.geo_coords_type is not None:
1885  oprot.writeFieldBegin('geo_coords_type', TType.I32, 18)
1886  oprot.writeI32(self.geo_coords_type)
1887  oprot.writeFieldEnd()
1888  if self.geo_coords_srid is not None:
1889  oprot.writeFieldBegin('geo_coords_srid', TType.I32, 19)
1890  oprot.writeI32(self.geo_coords_srid)
1891  oprot.writeFieldEnd()
1892  if self.sanitize_column_names is not None:
1893  oprot.writeFieldBegin('sanitize_column_names', TType.BOOL, 20)
1894  oprot.writeBool(self.sanitize_column_names)
1895  oprot.writeFieldEnd()
1896  if self.geo_layer_name is not None:
1897  oprot.writeFieldBegin('geo_layer_name', TType.STRING, 21)
1898  oprot.writeString(self.geo_layer_name.encode('utf-8') if sys.version_info[0] == 2 else self.geo_layer_name)
1899  oprot.writeFieldEnd()
1900  if self.s3_endpoint is not None:
1901  oprot.writeFieldBegin('s3_endpoint', TType.STRING, 22)
1902  oprot.writeString(self.s3_endpoint.encode('utf-8') if sys.version_info[0] == 2 else self.s3_endpoint)
1903  oprot.writeFieldEnd()
1904  if self.geo_assign_render_groups is not None:
1905  oprot.writeFieldBegin('geo_assign_render_groups', TType.BOOL, 23)
1906  oprot.writeBool(self.geo_assign_render_groups)
1907  oprot.writeFieldEnd()
1908  if self.geo_explode_collections is not None:
1909  oprot.writeFieldBegin('geo_explode_collections', TType.BOOL, 24)
1910  oprot.writeBool(self.geo_explode_collections)
1911  oprot.writeFieldEnd()
1912  if self.source_srid is not None:
1913  oprot.writeFieldBegin('source_srid', TType.I32, 25)
1914  oprot.writeI32(self.source_srid)
1915  oprot.writeFieldEnd()
1916  oprot.writeFieldStop()
1917  oprot.writeStructEnd()
1918 
1919  def validate(self):
1920  return
1921 
1922  def __repr__(self):
1923  L = ['%s=%r' % (key, value)
1924  for key, value in self.__dict__.items()]
1925  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1926 
1927  def __eq__(self, other):
1928  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1929 
1930  def __ne__(self, other):
1931  return not (self == other)
1932 
1933 
1934 class TCreateParams(object):
1935  """
1936  Attributes:
1937  - is_replicated
1938 
1939  """
1940 
1941 
1942  def __init__(self, is_replicated=None,):
1943  self.is_replicated = is_replicated
1944 
1945  def read(self, iprot):
1946  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
1947  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
1948  return
1949  iprot.readStructBegin()
1950  while True:
1951  (fname, ftype, fid) = iprot.readFieldBegin()
1952  if ftype == TType.STOP:
1953  break
1954  if fid == 1:
1955  if ftype == TType.BOOL:
1956  self.is_replicated = iprot.readBool()
1957  else:
1958  iprot.skip(ftype)
1959  else:
1960  iprot.skip(ftype)
1961  iprot.readFieldEnd()
1962  iprot.readStructEnd()
1963 
1964  def write(self, oprot):
1965  if oprot._fast_encode is not None and self.thrift_spec is not None:
1966  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
1967  return
1968  oprot.writeStructBegin('TCreateParams')
1969  if self.is_replicated is not None:
1970  oprot.writeFieldBegin('is_replicated', TType.BOOL, 1)
1971  oprot.writeBool(self.is_replicated)
1972  oprot.writeFieldEnd()
1973  oprot.writeFieldStop()
1974  oprot.writeStructEnd()
1975 
1976  def validate(self):
1977  return
1978 
1979  def __repr__(self):
1980  L = ['%s=%r' % (key, value)
1981  for key, value in self.__dict__.items()]
1982  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1983 
1984  def __eq__(self, other):
1985  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1986 
1987  def __ne__(self, other):
1988  return not (self == other)
1989 
1990 
1991 class TDetectResult(object):
1992  """
1993  Attributes:
1994  - row_set
1995  - copy_params
1996 
1997  """
1998 
1999 
2000  def __init__(self, row_set=None, copy_params=None,):
2001  self.row_set = row_set
2002  self.copy_params = copy_params
2003 
2004  def read(self, iprot):
2005  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
2006  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
2007  return
2008  iprot.readStructBegin()
2009  while True:
2010  (fname, ftype, fid) = iprot.readFieldBegin()
2011  if ftype == TType.STOP:
2012  break
2013  if fid == 1:
2014  if ftype == TType.STRUCT:
2015  self.row_set = TRowSet()
2016  self.row_set.read(iprot)
2017  else:
2018  iprot.skip(ftype)
2019  elif fid == 2:
2020  if ftype == TType.STRUCT:
2021  self.copy_params = TCopyParams()
2022  self.copy_params.read(iprot)
2023  else:
2024  iprot.skip(ftype)
2025  else:
2026  iprot.skip(ftype)
2027  iprot.readFieldEnd()
2028  iprot.readStructEnd()
2029 
2030  def write(self, oprot):
2031  if oprot._fast_encode is not None and self.thrift_spec is not None:
2032  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
2033  return
2034  oprot.writeStructBegin('TDetectResult')
2035  if self.row_set is not None:
2036  oprot.writeFieldBegin('row_set', TType.STRUCT, 1)
2037  self.row_set.write(oprot)
2038  oprot.writeFieldEnd()
2039  if self.copy_params is not None:
2040  oprot.writeFieldBegin('copy_params', TType.STRUCT, 2)
2041  self.copy_params.write(oprot)
2042  oprot.writeFieldEnd()
2043  oprot.writeFieldStop()
2044  oprot.writeStructEnd()
2045 
2046  def validate(self):
2047  return
2048 
2049  def __repr__(self):
2050  L = ['%s=%r' % (key, value)
2051  for key, value in self.__dict__.items()]
2052  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2053 
2054  def __eq__(self, other):
2055  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2056 
2057  def __ne__(self, other):
2058  return not (self == other)
2059 
2060 
2061 class TImportStatus(object):
2062  """
2063  Attributes:
2064  - elapsed
2065  - rows_completed
2066  - rows_estimated
2067  - rows_rejected
2068 
2069  """
2070 
2071 
2072  def __init__(self, elapsed=None, rows_completed=None, rows_estimated=None, rows_rejected=None,):
2073  self.elapsed = elapsed
2074  self.rows_completed = rows_completed
2075  self.rows_estimated = rows_estimated
2076  self.rows_rejected = rows_rejected
2077 
2078  def read(self, iprot):
2079  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
2080  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
2081  return
2082  iprot.readStructBegin()
2083  while True:
2084  (fname, ftype, fid) = iprot.readFieldBegin()
2085  if ftype == TType.STOP:
2086  break
2087  if fid == 1:
2088  if ftype == TType.I64:
2089  self.elapsed = iprot.readI64()
2090  else:
2091  iprot.skip(ftype)
2092  elif fid == 2:
2093  if ftype == TType.I64:
2094  self.rows_completed = iprot.readI64()
2095  else:
2096  iprot.skip(ftype)
2097  elif fid == 3:
2098  if ftype == TType.I64:
2099  self.rows_estimated = iprot.readI64()
2100  else:
2101  iprot.skip(ftype)
2102  elif fid == 4:
2103  if ftype == TType.I64:
2104  self.rows_rejected = iprot.readI64()
2105  else:
2106  iprot.skip(ftype)
2107  else:
2108  iprot.skip(ftype)
2109  iprot.readFieldEnd()
2110  iprot.readStructEnd()
2111 
2112  def write(self, oprot):
2113  if oprot._fast_encode is not None and self.thrift_spec is not None:
2114  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
2115  return
2116  oprot.writeStructBegin('TImportStatus')
2117  if self.elapsed is not None:
2118  oprot.writeFieldBegin('elapsed', TType.I64, 1)
2119  oprot.writeI64(self.elapsed)
2120  oprot.writeFieldEnd()
2121  if self.rows_completed is not None:
2122  oprot.writeFieldBegin('rows_completed', TType.I64, 2)
2123  oprot.writeI64(self.rows_completed)
2124  oprot.writeFieldEnd()
2125  if self.rows_estimated is not None:
2126  oprot.writeFieldBegin('rows_estimated', TType.I64, 3)
2127  oprot.writeI64(self.rows_estimated)
2128  oprot.writeFieldEnd()
2129  if self.rows_rejected is not None:
2130  oprot.writeFieldBegin('rows_rejected', TType.I64, 4)
2131  oprot.writeI64(self.rows_rejected)
2132  oprot.writeFieldEnd()
2133  oprot.writeFieldStop()
2134  oprot.writeStructEnd()
2135 
2136  def validate(self):
2137  return
2138 
2139  def __repr__(self):
2140  L = ['%s=%r' % (key, value)
2141  for key, value in self.__dict__.items()]
2142  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2143 
2144  def __eq__(self, other):
2145  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2146 
2147  def __ne__(self, other):
2148  return not (self == other)
2149 
2150 
2151 class TFrontendView(object):
2152  """
2153  Attributes:
2154  - view_name
2155  - view_state
2156  - image_hash
2157  - update_time
2158  - view_metadata
2159 
2160  """
2161 
2162 
2163  def __init__(self, view_name=None, view_state=None, image_hash=None, update_time=None, view_metadata=None,):
2164  self.view_name = view_name
2165  self.view_state = view_state
2166  self.image_hash = image_hash
2167  self.update_time = update_time
2168  self.view_metadata = view_metadata
2169 
2170  def read(self, iprot):
2171  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
2172  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
2173  return
2174  iprot.readStructBegin()
2175  while True:
2176  (fname, ftype, fid) = iprot.readFieldBegin()
2177  if ftype == TType.STOP:
2178  break
2179  if fid == 1:
2180  if ftype == TType.STRING:
2181  self.view_name = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
2182  else:
2183  iprot.skip(ftype)
2184  elif fid == 2:
2185  if ftype == TType.STRING:
2186  self.view_state = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
2187  else:
2188  iprot.skip(ftype)
2189  elif fid == 3:
2190  if ftype == TType.STRING:
2191  self.image_hash = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
2192  else:
2193  iprot.skip(ftype)
2194  elif fid == 4:
2195  if ftype == TType.STRING:
2196  self.update_time = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
2197  else:
2198  iprot.skip(ftype)
2199  elif fid == 5:
2200  if ftype == TType.STRING:
2201  self.view_metadata = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
2202  else:
2203  iprot.skip(ftype)
2204  else:
2205  iprot.skip(ftype)
2206  iprot.readFieldEnd()
2207  iprot.readStructEnd()
2208 
2209  def write(self, oprot):
2210  if oprot._fast_encode is not None and self.thrift_spec is not None:
2211  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
2212  return
2213  oprot.writeStructBegin('TFrontendView')
2214  if self.view_name is not None:
2215  oprot.writeFieldBegin('view_name', TType.STRING, 1)
2216  oprot.writeString(self.view_name.encode('utf-8') if sys.version_info[0] == 2 else self.view_name)
2217  oprot.writeFieldEnd()
2218  if self.view_state is not None:
2219  oprot.writeFieldBegin('view_state', TType.STRING, 2)
2220  oprot.writeString(self.view_state.encode('utf-8') if sys.version_info[0] == 2 else self.view_state)
2221  oprot.writeFieldEnd()
2222  if self.image_hash is not None:
2223  oprot.writeFieldBegin('image_hash', TType.STRING, 3)
2224  oprot.writeString(self.image_hash.encode('utf-8') if sys.version_info[0] == 2 else self.image_hash)
2225  oprot.writeFieldEnd()
2226  if self.update_time is not None:
2227  oprot.writeFieldBegin('update_time', TType.STRING, 4)
2228  oprot.writeString(self.update_time.encode('utf-8') if sys.version_info[0] == 2 else self.update_time)
2229  oprot.writeFieldEnd()
2230  if self.view_metadata is not None:
2231  oprot.writeFieldBegin('view_metadata', TType.STRING, 5)
2232  oprot.writeString(self.view_metadata.encode('utf-8') if sys.version_info[0] == 2 else self.view_metadata)
2233  oprot.writeFieldEnd()
2234  oprot.writeFieldStop()
2235  oprot.writeStructEnd()
2236 
2237  def validate(self):
2238  return
2239 
2240  def __repr__(self):
2241  L = ['%s=%r' % (key, value)
2242  for key, value in self.__dict__.items()]
2243  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2244 
2245  def __eq__(self, other):
2246  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2247 
2248  def __ne__(self, other):
2249  return not (self == other)
2250 
2251 
2252 class TServerStatus(object):
2253  """
2254  Attributes:
2255  - read_only
2256  - version
2257  - rendering_enabled
2258  - start_time
2259  - edition
2260  - host_name
2261  - poly_rendering_enabled
2262  - role
2263 
2264  """
2265 
2266 
2267  def __init__(self, read_only=None, version=None, rendering_enabled=None, start_time=None, edition=None, host_name=None, poly_rendering_enabled=None, role=None,):
2268  self.read_only = read_only
2269  self.version = version
2270  self.rendering_enabled = rendering_enabled
2271  self.start_time = start_time
2272  self.edition = edition
2273  self.host_name = host_name
2274  self.poly_rendering_enabled = poly_rendering_enabled
2275  self.role = role
2276 
2277  def read(self, iprot):
2278  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
2279  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
2280  return
2281  iprot.readStructBegin()
2282  while True:
2283  (fname, ftype, fid) = iprot.readFieldBegin()
2284  if ftype == TType.STOP:
2285  break
2286  if fid == 1:
2287  if ftype == TType.BOOL:
2288  self.read_only = iprot.readBool()
2289  else:
2290  iprot.skip(ftype)
2291  elif fid == 2:
2292  if ftype == TType.STRING:
2293  self.version = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
2294  else:
2295  iprot.skip(ftype)
2296  elif fid == 3:
2297  if ftype == TType.BOOL:
2298  self.rendering_enabled = iprot.readBool()
2299  else:
2300  iprot.skip(ftype)
2301  elif fid == 4:
2302  if ftype == TType.I64:
2303  self.start_time = iprot.readI64()
2304  else:
2305  iprot.skip(ftype)
2306  elif fid == 5:
2307  if ftype == TType.STRING:
2308  self.edition = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
2309  else:
2310  iprot.skip(ftype)
2311  elif fid == 6:
2312  if ftype == TType.STRING:
2313  self.host_name = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
2314  else:
2315  iprot.skip(ftype)
2316  elif fid == 7:
2317  if ftype == TType.BOOL:
2318  self.poly_rendering_enabled = iprot.readBool()
2319  else:
2320  iprot.skip(ftype)
2321  elif fid == 8:
2322  if ftype == TType.I32:
2323  self.role = iprot.readI32()
2324  else:
2325  iprot.skip(ftype)
2326  else:
2327  iprot.skip(ftype)
2328  iprot.readFieldEnd()
2329  iprot.readStructEnd()
2330 
2331  def write(self, oprot):
2332  if oprot._fast_encode is not None and self.thrift_spec is not None:
2333  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
2334  return
2335  oprot.writeStructBegin('TServerStatus')
2336  if self.read_only is not None:
2337  oprot.writeFieldBegin('read_only', TType.BOOL, 1)
2338  oprot.writeBool(self.read_only)
2339  oprot.writeFieldEnd()
2340  if self.version is not None:
2341  oprot.writeFieldBegin('version', TType.STRING, 2)
2342  oprot.writeString(self.version.encode('utf-8') if sys.version_info[0] == 2 else self.version)
2343  oprot.writeFieldEnd()
2344  if self.rendering_enabled is not None:
2345  oprot.writeFieldBegin('rendering_enabled', TType.BOOL, 3)
2346  oprot.writeBool(self.rendering_enabled)
2347  oprot.writeFieldEnd()
2348  if self.start_time is not None:
2349  oprot.writeFieldBegin('start_time', TType.I64, 4)
2350  oprot.writeI64(self.start_time)
2351  oprot.writeFieldEnd()
2352  if self.edition is not None:
2353  oprot.writeFieldBegin('edition', TType.STRING, 5)
2354  oprot.writeString(self.edition.encode('utf-8') if sys.version_info[0] == 2 else self.edition)
2355  oprot.writeFieldEnd()
2356  if self.host_name is not None:
2357  oprot.writeFieldBegin('host_name', TType.STRING, 6)
2358  oprot.writeString(self.host_name.encode('utf-8') if sys.version_info[0] == 2 else self.host_name)
2359  oprot.writeFieldEnd()
2360  if self.poly_rendering_enabled is not None:
2361  oprot.writeFieldBegin('poly_rendering_enabled', TType.BOOL, 7)
2362  oprot.writeBool(self.poly_rendering_enabled)
2363  oprot.writeFieldEnd()
2364  if self.role is not None:
2365  oprot.writeFieldBegin('role', TType.I32, 8)
2366  oprot.writeI32(self.role)
2367  oprot.writeFieldEnd()
2368  oprot.writeFieldStop()
2369  oprot.writeStructEnd()
2370 
2371  def validate(self):
2372  return
2373 
2374  def __repr__(self):
2375  L = ['%s=%r' % (key, value)
2376  for key, value in self.__dict__.items()]
2377  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2378 
2379  def __eq__(self, other):
2380  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2381 
2382  def __ne__(self, other):
2383  return not (self == other)
2384 
2385 
2386 class TPixel(object):
2387  """
2388  Attributes:
2389  - x
2390  - y
2391 
2392  """
2393 
2394 
2395  def __init__(self, x=None, y=None,):
2396  self.x = x
2397  self.y = y
2398 
2399  def read(self, iprot):
2400  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
2401  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
2402  return
2403  iprot.readStructBegin()
2404  while True:
2405  (fname, ftype, fid) = iprot.readFieldBegin()
2406  if ftype == TType.STOP:
2407  break
2408  if fid == 1:
2409  if ftype == TType.I64:
2410  self.x = iprot.readI64()
2411  else:
2412  iprot.skip(ftype)
2413  elif fid == 2:
2414  if ftype == TType.I64:
2415  self.y = iprot.readI64()
2416  else:
2417  iprot.skip(ftype)
2418  else:
2419  iprot.skip(ftype)
2420  iprot.readFieldEnd()
2421  iprot.readStructEnd()
2422 
2423  def write(self, oprot):
2424  if oprot._fast_encode is not None and self.thrift_spec is not None:
2425  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
2426  return
2427  oprot.writeStructBegin('TPixel')
2428  if self.x is not None:
2429  oprot.writeFieldBegin('x', TType.I64, 1)
2430  oprot.writeI64(self.x)
2431  oprot.writeFieldEnd()
2432  if self.y is not None:
2433  oprot.writeFieldBegin('y', TType.I64, 2)
2434  oprot.writeI64(self.y)
2435  oprot.writeFieldEnd()
2436  oprot.writeFieldStop()
2437  oprot.writeStructEnd()
2438 
2439  def validate(self):
2440  return
2441 
2442  def __repr__(self):
2443  L = ['%s=%r' % (key, value)
2444  for key, value in self.__dict__.items()]
2445  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2446 
2447  def __eq__(self, other):
2448  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2449 
2450  def __ne__(self, other):
2451  return not (self == other)
2452 
2453 
2454 class TPixelTableRowResult(object):
2455  """
2456  Attributes:
2457  - pixel
2458  - vega_table_name
2459  - table_id
2460  - row_id
2461  - row_set
2462  - nonce
2463 
2464  """
2465 
2466 
2467  def __init__(self, pixel=None, vega_table_name=None, table_id=None, row_id=None, row_set=None, nonce=None,):
2468  self.pixel = pixel
2469  self.vega_table_name = vega_table_name
2470  self.table_id = table_id
2471  self.row_id = row_id
2472  self.row_set = row_set
2473  self.nonce = nonce
2474 
2475  def read(self, iprot):
2476  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
2477  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
2478  return
2479  iprot.readStructBegin()
2480  while True:
2481  (fname, ftype, fid) = iprot.readFieldBegin()
2482  if ftype == TType.STOP:
2483  break
2484  if fid == 1:
2485  if ftype == TType.STRUCT:
2486  self.pixel = TPixel()
2487  self.pixel.read(iprot)
2488  else:
2489  iprot.skip(ftype)
2490  elif fid == 2:
2491  if ftype == TType.STRING:
2492  self.vega_table_name = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
2493  else:
2494  iprot.skip(ftype)
2495  elif fid == 3:
2496  if ftype == TType.LIST:
2497  self.table_id = []
2498  (_etype87, _size84) = iprot.readListBegin()
2499  for _i88 in range(_size84):
2500  _elem89 = iprot.readI64()
2501  self.table_id.append(_elem89)
2502  iprot.readListEnd()
2503  else:
2504  iprot.skip(ftype)
2505  elif fid == 4:
2506  if ftype == TType.LIST:
2507  self.row_id = []
2508  (_etype93, _size90) = iprot.readListBegin()
2509  for _i94 in range(_size90):
2510  _elem95 = iprot.readI64()
2511  self.row_id.append(_elem95)
2512  iprot.readListEnd()
2513  else:
2514  iprot.skip(ftype)
2515  elif fid == 5:
2516  if ftype == TType.STRUCT:
2517  self.row_set = TRowSet()
2518  self.row_set.read(iprot)
2519  else:
2520  iprot.skip(ftype)
2521  elif fid == 6:
2522  if ftype == TType.STRING:
2523  self.nonce = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
2524  else:
2525  iprot.skip(ftype)
2526  else:
2527  iprot.skip(ftype)
2528  iprot.readFieldEnd()
2529  iprot.readStructEnd()
2530 
2531  def write(self, oprot):
2532  if oprot._fast_encode is not None and self.thrift_spec is not None:
2533  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
2534  return
2535  oprot.writeStructBegin('TPixelTableRowResult')
2536  if self.pixel is not None:
2537  oprot.writeFieldBegin('pixel', TType.STRUCT, 1)
2538  self.pixel.write(oprot)
2539  oprot.writeFieldEnd()
2540  if self.vega_table_name is not None:
2541  oprot.writeFieldBegin('vega_table_name', TType.STRING, 2)
2542  oprot.writeString(self.vega_table_name.encode('utf-8') if sys.version_info[0] == 2 else self.vega_table_name)
2543  oprot.writeFieldEnd()
2544  if self.table_id is not None:
2545  oprot.writeFieldBegin('table_id', TType.LIST, 3)
2546  oprot.writeListBegin(TType.I64, len(self.table_id))
2547  for iter96 in self.table_id:
2548  oprot.writeI64(iter96)
2549  oprot.writeListEnd()
2550  oprot.writeFieldEnd()
2551  if self.row_id is not None:
2552  oprot.writeFieldBegin('row_id', TType.LIST, 4)
2553  oprot.writeListBegin(TType.I64, len(self.row_id))
2554  for iter97 in self.row_id:
2555  oprot.writeI64(iter97)
2556  oprot.writeListEnd()
2557  oprot.writeFieldEnd()
2558  if self.row_set is not None:
2559  oprot.writeFieldBegin('row_set', TType.STRUCT, 5)
2560  self.row_set.write(oprot)
2561  oprot.writeFieldEnd()
2562  if self.nonce is not None:
2563  oprot.writeFieldBegin('nonce', TType.STRING, 6)
2564  oprot.writeString(self.nonce.encode('utf-8') if sys.version_info[0] == 2 else self.nonce)
2565  oprot.writeFieldEnd()
2566  oprot.writeFieldStop()
2567  oprot.writeStructEnd()
2568 
2569  def validate(self):
2570  return
2571 
2572  def __repr__(self):
2573  L = ['%s=%r' % (key, value)
2574  for key, value in self.__dict__.items()]
2575  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2576 
2577  def __eq__(self, other):
2578  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2579 
2580  def __ne__(self, other):
2581  return not (self == other)
2582 
2583 
2584 class TRenderResult(object):
2585  """
2586  Attributes:
2587  - image
2588  - nonce
2589  - execution_time_ms
2590  - render_time_ms
2591  - total_time_ms
2592  - vega_metadata
2593 
2594  """
2595 
2596 
2597  def __init__(self, image=None, nonce=None, execution_time_ms=None, render_time_ms=None, total_time_ms=None, vega_metadata=None,):
2598  self.image = image
2599  self.nonce = nonce
2600  self.execution_time_ms = execution_time_ms
2601  self.render_time_ms = render_time_ms
2602  self.total_time_ms = total_time_ms
2603  self.vega_metadata = vega_metadata
2604 
2605  def read(self, iprot):
2606  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
2607  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
2608  return
2609  iprot.readStructBegin()
2610  while True:
2611  (fname, ftype, fid) = iprot.readFieldBegin()
2612  if ftype == TType.STOP:
2613  break
2614  if fid == 1:
2615  if ftype == TType.STRING:
2616  self.image = iprot.readBinary()
2617  else:
2618  iprot.skip(ftype)
2619  elif fid == 2:
2620  if ftype == TType.STRING:
2621  self.nonce = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
2622  else:
2623  iprot.skip(ftype)
2624  elif fid == 3:
2625  if ftype == TType.I64:
2626  self.execution_time_ms = iprot.readI64()
2627  else:
2628  iprot.skip(ftype)
2629  elif fid == 4:
2630  if ftype == TType.I64:
2631  self.render_time_ms = iprot.readI64()
2632  else:
2633  iprot.skip(ftype)
2634  elif fid == 5:
2635  if ftype == TType.I64:
2636  self.total_time_ms = iprot.readI64()
2637  else:
2638  iprot.skip(ftype)
2639  elif fid == 6:
2640  if ftype == TType.STRING:
2641  self.vega_metadata = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
2642  else:
2643  iprot.skip(ftype)
2644  else:
2645  iprot.skip(ftype)
2646  iprot.readFieldEnd()
2647  iprot.readStructEnd()
2648 
2649  def write(self, oprot):
2650  if oprot._fast_encode is not None and self.thrift_spec is not None:
2651  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
2652  return
2653  oprot.writeStructBegin('TRenderResult')
2654  if self.image is not None:
2655  oprot.writeFieldBegin('image', TType.STRING, 1)
2656  oprot.writeBinary(self.image)
2657  oprot.writeFieldEnd()
2658  if self.nonce is not None:
2659  oprot.writeFieldBegin('nonce', TType.STRING, 2)
2660  oprot.writeString(self.nonce.encode('utf-8') if sys.version_info[0] == 2 else self.nonce)
2661  oprot.writeFieldEnd()
2662  if self.execution_time_ms is not None:
2663  oprot.writeFieldBegin('execution_time_ms', TType.I64, 3)
2664  oprot.writeI64(self.execution_time_ms)
2665  oprot.writeFieldEnd()
2666  if self.render_time_ms is not None:
2667  oprot.writeFieldBegin('render_time_ms', TType.I64, 4)
2668  oprot.writeI64(self.render_time_ms)
2669  oprot.writeFieldEnd()
2670  if self.total_time_ms is not None:
2671  oprot.writeFieldBegin('total_time_ms', TType.I64, 5)
2672  oprot.writeI64(self.total_time_ms)
2673  oprot.writeFieldEnd()
2674  if self.vega_metadata is not None:
2675  oprot.writeFieldBegin('vega_metadata', TType.STRING, 6)
2676  oprot.writeString(self.vega_metadata.encode('utf-8') if sys.version_info[0] == 2 else self.vega_metadata)
2677  oprot.writeFieldEnd()
2678  oprot.writeFieldStop()
2679  oprot.writeStructEnd()
2680 
2681  def validate(self):
2682  return
2683 
2684  def __repr__(self):
2685  L = ['%s=%r' % (key, value)
2686  for key, value in self.__dict__.items()]
2687  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2688 
2689  def __eq__(self, other):
2690  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2691 
2692  def __ne__(self, other):
2693  return not (self == other)
2694 
2695 
2696 class TGpuSpecification(object):
2697  """
2698  Attributes:
2699  - num_sm
2700  - clock_frequency_kHz
2701  - memory
2702  - compute_capability_major
2703  - compute_capability_minor
2704 
2705  """
2706 
2707 
2708  def __init__(self, num_sm=None, clock_frequency_kHz=None, memory=None, compute_capability_major=None, compute_capability_minor=None,):
2709  self.num_sm = num_sm
2710  self.clock_frequency_kHz = clock_frequency_kHz
2711  self.memory = memory
2712  self.compute_capability_major = compute_capability_major
2713  self.compute_capability_minor = compute_capability_minor
2714 
2715  def read(self, iprot):
2716  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
2717  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
2718  return
2719  iprot.readStructBegin()
2720  while True:
2721  (fname, ftype, fid) = iprot.readFieldBegin()
2722  if ftype == TType.STOP:
2723  break
2724  if fid == 1:
2725  if ftype == TType.I32:
2726  self.num_sm = iprot.readI32()
2727  else:
2728  iprot.skip(ftype)
2729  elif fid == 2:
2730  if ftype == TType.I64:
2731  self.clock_frequency_kHz = iprot.readI64()
2732  else:
2733  iprot.skip(ftype)
2734  elif fid == 3:
2735  if ftype == TType.I64:
2736  self.memory = iprot.readI64()
2737  else:
2738  iprot.skip(ftype)
2739  elif fid == 4:
2740  if ftype == TType.I16:
2741  self.compute_capability_major = iprot.readI16()
2742  else:
2743  iprot.skip(ftype)
2744  elif fid == 5:
2745  if ftype == TType.I16:
2746  self.compute_capability_minor = iprot.readI16()
2747  else:
2748  iprot.skip(ftype)
2749  else:
2750  iprot.skip(ftype)
2751  iprot.readFieldEnd()
2752  iprot.readStructEnd()
2753 
2754  def write(self, oprot):
2755  if oprot._fast_encode is not None and self.thrift_spec is not None:
2756  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
2757  return
2758  oprot.writeStructBegin('TGpuSpecification')
2759  if self.num_sm is not None:
2760  oprot.writeFieldBegin('num_sm', TType.I32, 1)
2761  oprot.writeI32(self.num_sm)
2762  oprot.writeFieldEnd()
2763  if self.clock_frequency_kHz is not None:
2764  oprot.writeFieldBegin('clock_frequency_kHz', TType.I64, 2)
2765  oprot.writeI64(self.clock_frequency_kHz)
2766  oprot.writeFieldEnd()
2767  if self.memory is not None:
2768  oprot.writeFieldBegin('memory', TType.I64, 3)
2769  oprot.writeI64(self.memory)
2770  oprot.writeFieldEnd()
2771  if self.compute_capability_major is not None:
2772  oprot.writeFieldBegin('compute_capability_major', TType.I16, 4)
2773  oprot.writeI16(self.compute_capability_major)
2774  oprot.writeFieldEnd()
2775  if self.compute_capability_minor is not None:
2776  oprot.writeFieldBegin('compute_capability_minor', TType.I16, 5)
2777  oprot.writeI16(self.compute_capability_minor)
2778  oprot.writeFieldEnd()
2779  oprot.writeFieldStop()
2780  oprot.writeStructEnd()
2781 
2782  def validate(self):
2783  return
2784 
2785  def __repr__(self):
2786  L = ['%s=%r' % (key, value)
2787  for key, value in self.__dict__.items()]
2788  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2789 
2790  def __eq__(self, other):
2791  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2792 
2793  def __ne__(self, other):
2794  return not (self == other)
2795 
2796 
2797 class THardwareInfo(object):
2798  """
2799  Attributes:
2800  - num_gpu_hw
2801  - num_cpu_hw
2802  - num_gpu_allocated
2803  - start_gpu
2804  - host_name
2805  - gpu_info
2806 
2807  """
2808 
2809 
2810  def __init__(self, num_gpu_hw=None, num_cpu_hw=None, num_gpu_allocated=None, start_gpu=None, host_name=None, gpu_info=None,):
2811  self.num_gpu_hw = num_gpu_hw
2812  self.num_cpu_hw = num_cpu_hw
2813  self.num_gpu_allocated = num_gpu_allocated
2814  self.start_gpu = start_gpu
2815  self.host_name = host_name
2816  self.gpu_info = gpu_info
2817 
2818  def read(self, iprot):
2819  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
2820  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
2821  return
2822  iprot.readStructBegin()
2823  while True:
2824  (fname, ftype, fid) = iprot.readFieldBegin()
2825  if ftype == TType.STOP:
2826  break
2827  if fid == 1:
2828  if ftype == TType.I16:
2829  self.num_gpu_hw = iprot.readI16()
2830  else:
2831  iprot.skip(ftype)
2832  elif fid == 2:
2833  if ftype == TType.I16:
2834  self.num_cpu_hw = iprot.readI16()
2835  else:
2836  iprot.skip(ftype)
2837  elif fid == 3:
2838  if ftype == TType.I16:
2839  self.num_gpu_allocated = iprot.readI16()
2840  else:
2841  iprot.skip(ftype)
2842  elif fid == 4:
2843  if ftype == TType.I16:
2844  self.start_gpu = iprot.readI16()
2845  else:
2846  iprot.skip(ftype)
2847  elif fid == 5:
2848  if ftype == TType.STRING:
2849  self.host_name = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
2850  else:
2851  iprot.skip(ftype)
2852  elif fid == 6:
2853  if ftype == TType.LIST:
2854  self.gpu_info = []
2855  (_etype101, _size98) = iprot.readListBegin()
2856  for _i102 in range(_size98):
2857  _elem103 = TGpuSpecification()
2858  _elem103.read(iprot)
2859  self.gpu_info.append(_elem103)
2860  iprot.readListEnd()
2861  else:
2862  iprot.skip(ftype)
2863  else:
2864  iprot.skip(ftype)
2865  iprot.readFieldEnd()
2866  iprot.readStructEnd()
2867 
2868  def write(self, oprot):
2869  if oprot._fast_encode is not None and self.thrift_spec is not None:
2870  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
2871  return
2872  oprot.writeStructBegin('THardwareInfo')
2873  if self.num_gpu_hw is not None:
2874  oprot.writeFieldBegin('num_gpu_hw', TType.I16, 1)
2875  oprot.writeI16(self.num_gpu_hw)
2876  oprot.writeFieldEnd()
2877  if self.num_cpu_hw is not None:
2878  oprot.writeFieldBegin('num_cpu_hw', TType.I16, 2)
2879  oprot.writeI16(self.num_cpu_hw)
2880  oprot.writeFieldEnd()
2881  if self.num_gpu_allocated is not None:
2882  oprot.writeFieldBegin('num_gpu_allocated', TType.I16, 3)
2883  oprot.writeI16(self.num_gpu_allocated)
2884  oprot.writeFieldEnd()
2885  if self.start_gpu is not None:
2886  oprot.writeFieldBegin('start_gpu', TType.I16, 4)
2887  oprot.writeI16(self.start_gpu)
2888  oprot.writeFieldEnd()
2889  if self.host_name is not None:
2890  oprot.writeFieldBegin('host_name', TType.STRING, 5)
2891  oprot.writeString(self.host_name.encode('utf-8') if sys.version_info[0] == 2 else self.host_name)
2892  oprot.writeFieldEnd()
2893  if self.gpu_info is not None:
2894  oprot.writeFieldBegin('gpu_info', TType.LIST, 6)
2895  oprot.writeListBegin(TType.STRUCT, len(self.gpu_info))
2896  for iter104 in self.gpu_info:
2897  iter104.write(oprot)
2898  oprot.writeListEnd()
2899  oprot.writeFieldEnd()
2900  oprot.writeFieldStop()
2901  oprot.writeStructEnd()
2902 
2903  def validate(self):
2904  return
2905 
2906  def __repr__(self):
2907  L = ['%s=%r' % (key, value)
2908  for key, value in self.__dict__.items()]
2909  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2910 
2911  def __eq__(self, other):
2912  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2913 
2914  def __ne__(self, other):
2915  return not (self == other)
2916 
2917 
2918 class TClusterHardwareInfo(object):
2919  """
2920  Attributes:
2921  - hardware_info
2922 
2923  """
2924 
2925 
2926  def __init__(self, hardware_info=None,):
2927  self.hardware_info = hardware_info
2928 
2929  def read(self, iprot):
2930  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
2931  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
2932  return
2933  iprot.readStructBegin()
2934  while True:
2935  (fname, ftype, fid) = iprot.readFieldBegin()
2936  if ftype == TType.STOP:
2937  break
2938  if fid == 1:
2939  if ftype == TType.LIST:
2940  self.hardware_info = []
2941  (_etype108, _size105) = iprot.readListBegin()
2942  for _i109 in range(_size105):
2943  _elem110 = THardwareInfo()
2944  _elem110.read(iprot)
2945  self.hardware_info.append(_elem110)
2946  iprot.readListEnd()
2947  else:
2948  iprot.skip(ftype)
2949  else:
2950  iprot.skip(ftype)
2951  iprot.readFieldEnd()
2952  iprot.readStructEnd()
2953 
2954  def write(self, oprot):
2955  if oprot._fast_encode is not None and self.thrift_spec is not None:
2956  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
2957  return
2958  oprot.writeStructBegin('TClusterHardwareInfo')
2959  if self.hardware_info is not None:
2960  oprot.writeFieldBegin('hardware_info', TType.LIST, 1)
2961  oprot.writeListBegin(TType.STRUCT, len(self.hardware_info))
2962  for iter111 in self.hardware_info:
2963  iter111.write(oprot)
2964  oprot.writeListEnd()
2965  oprot.writeFieldEnd()
2966  oprot.writeFieldStop()
2967  oprot.writeStructEnd()
2968 
2969  def validate(self):
2970  return
2971 
2972  def __repr__(self):
2973  L = ['%s=%r' % (key, value)
2974  for key, value in self.__dict__.items()]
2975  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2976 
2977  def __eq__(self, other):
2978  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2979 
2980  def __ne__(self, other):
2981  return not (self == other)
2982 
2983 
2984 class TMemoryData(object):
2985  """
2986  Attributes:
2987  - slab
2988  - start_page
2989  - num_pages
2990  - touch
2991  - chunk_key
2992  - buffer_epoch
2993  - is_free
2994 
2995  """
2996 
2997 
2998  def __init__(self, slab=None, start_page=None, num_pages=None, touch=None, chunk_key=None, buffer_epoch=None, is_free=None,):
2999  self.slab = slab
3000  self.start_page = start_page
3001  self.num_pages = num_pages
3002  self.touch = touch
3003  self.chunk_key = chunk_key
3004  self.buffer_epoch = buffer_epoch
3005  self.is_free = is_free
3006 
3007  def read(self, iprot):
3008  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
3009  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
3010  return
3011  iprot.readStructBegin()
3012  while True:
3013  (fname, ftype, fid) = iprot.readFieldBegin()
3014  if ftype == TType.STOP:
3015  break
3016  if fid == 1:
3017  if ftype == TType.I64:
3018  self.slab = iprot.readI64()
3019  else:
3020  iprot.skip(ftype)
3021  elif fid == 2:
3022  if ftype == TType.I32:
3023  self.start_page = iprot.readI32()
3024  else:
3025  iprot.skip(ftype)
3026  elif fid == 3:
3027  if ftype == TType.I64:
3028  self.num_pages = iprot.readI64()
3029  else:
3030  iprot.skip(ftype)
3031  elif fid == 4:
3032  if ftype == TType.I32:
3033  self.touch = iprot.readI32()
3034  else:
3035  iprot.skip(ftype)
3036  elif fid == 5:
3037  if ftype == TType.LIST:
3038  self.chunk_key = []
3039  (_etype115, _size112) = iprot.readListBegin()
3040  for _i116 in range(_size112):
3041  _elem117 = iprot.readI64()
3042  self.chunk_key.append(_elem117)
3043  iprot.readListEnd()
3044  else:
3045  iprot.skip(ftype)
3046  elif fid == 6:
3047  if ftype == TType.I32:
3048  self.buffer_epoch = iprot.readI32()
3049  else:
3050  iprot.skip(ftype)
3051  elif fid == 7:
3052  if ftype == TType.BOOL:
3053  self.is_free = iprot.readBool()
3054  else:
3055  iprot.skip(ftype)
3056  else:
3057  iprot.skip(ftype)
3058  iprot.readFieldEnd()
3059  iprot.readStructEnd()
3060 
3061  def write(self, oprot):
3062  if oprot._fast_encode is not None and self.thrift_spec is not None:
3063  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
3064  return
3065  oprot.writeStructBegin('TMemoryData')
3066  if self.slab is not None:
3067  oprot.writeFieldBegin('slab', TType.I64, 1)
3068  oprot.writeI64(self.slab)
3069  oprot.writeFieldEnd()
3070  if self.start_page is not None:
3071  oprot.writeFieldBegin('start_page', TType.I32, 2)
3072  oprot.writeI32(self.start_page)
3073  oprot.writeFieldEnd()
3074  if self.num_pages is not None:
3075  oprot.writeFieldBegin('num_pages', TType.I64, 3)
3076  oprot.writeI64(self.num_pages)
3077  oprot.writeFieldEnd()
3078  if self.touch is not None:
3079  oprot.writeFieldBegin('touch', TType.I32, 4)
3080  oprot.writeI32(self.touch)
3081  oprot.writeFieldEnd()
3082  if self.chunk_key is not None:
3083  oprot.writeFieldBegin('chunk_key', TType.LIST, 5)
3084  oprot.writeListBegin(TType.I64, len(self.chunk_key))
3085  for iter118 in self.chunk_key:
3086  oprot.writeI64(iter118)
3087  oprot.writeListEnd()
3088  oprot.writeFieldEnd()
3089  if self.buffer_epoch is not None:
3090  oprot.writeFieldBegin('buffer_epoch', TType.I32, 6)
3091  oprot.writeI32(self.buffer_epoch)
3092  oprot.writeFieldEnd()
3093  if self.is_free is not None:
3094  oprot.writeFieldBegin('is_free', TType.BOOL, 7)
3095  oprot.writeBool(self.is_free)
3096  oprot.writeFieldEnd()
3097  oprot.writeFieldStop()
3098  oprot.writeStructEnd()
3099 
3100  def validate(self):
3101  return
3102 
3103  def __repr__(self):
3104  L = ['%s=%r' % (key, value)
3105  for key, value in self.__dict__.items()]
3106  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3107 
3108  def __eq__(self, other):
3109  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3110 
3111  def __ne__(self, other):
3112  return not (self == other)
3113 
3114 
3115 class TNodeMemoryInfo(object):
3116  """
3117  Attributes:
3118  - host_name
3119  - page_size
3120  - max_num_pages
3121  - num_pages_allocated
3122  - is_allocation_capped
3123  - node_memory_data
3124 
3125  """
3126 
3127 
3128  def __init__(self, host_name=None, page_size=None, max_num_pages=None, num_pages_allocated=None, is_allocation_capped=None, node_memory_data=None,):
3129  self.host_name = host_name
3130  self.page_size = page_size
3131  self.max_num_pages = max_num_pages
3132  self.num_pages_allocated = num_pages_allocated
3133  self.is_allocation_capped = is_allocation_capped
3134  self.node_memory_data = node_memory_data
3135 
3136  def read(self, iprot):
3137  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
3138  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
3139  return
3140  iprot.readStructBegin()
3141  while True:
3142  (fname, ftype, fid) = iprot.readFieldBegin()
3143  if ftype == TType.STOP:
3144  break
3145  if fid == 1:
3146  if ftype == TType.STRING:
3147  self.host_name = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
3148  else:
3149  iprot.skip(ftype)
3150  elif fid == 2:
3151  if ftype == TType.I64:
3152  self.page_size = iprot.readI64()
3153  else:
3154  iprot.skip(ftype)
3155  elif fid == 3:
3156  if ftype == TType.I64:
3157  self.max_num_pages = iprot.readI64()
3158  else:
3159  iprot.skip(ftype)
3160  elif fid == 4:
3161  if ftype == TType.I64:
3162  self.num_pages_allocated = iprot.readI64()
3163  else:
3164  iprot.skip(ftype)
3165  elif fid == 5:
3166  if ftype == TType.BOOL:
3167  self.is_allocation_capped = iprot.readBool()
3168  else:
3169  iprot.skip(ftype)
3170  elif fid == 6:
3171  if ftype == TType.LIST:
3172  self.node_memory_data = []
3173  (_etype122, _size119) = iprot.readListBegin()
3174  for _i123 in range(_size119):
3175  _elem124 = TMemoryData()
3176  _elem124.read(iprot)
3177  self.node_memory_data.append(_elem124)
3178  iprot.readListEnd()
3179  else:
3180  iprot.skip(ftype)
3181  else:
3182  iprot.skip(ftype)
3183  iprot.readFieldEnd()
3184  iprot.readStructEnd()
3185 
3186  def write(self, oprot):
3187  if oprot._fast_encode is not None and self.thrift_spec is not None:
3188  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
3189  return
3190  oprot.writeStructBegin('TNodeMemoryInfo')
3191  if self.host_name is not None:
3192  oprot.writeFieldBegin('host_name', TType.STRING, 1)
3193  oprot.writeString(self.host_name.encode('utf-8') if sys.version_info[0] == 2 else self.host_name)
3194  oprot.writeFieldEnd()
3195  if self.page_size is not None:
3196  oprot.writeFieldBegin('page_size', TType.I64, 2)
3197  oprot.writeI64(self.page_size)
3198  oprot.writeFieldEnd()
3199  if self.max_num_pages is not None:
3200  oprot.writeFieldBegin('max_num_pages', TType.I64, 3)
3201  oprot.writeI64(self.max_num_pages)
3202  oprot.writeFieldEnd()
3203  if self.num_pages_allocated is not None:
3204  oprot.writeFieldBegin('num_pages_allocated', TType.I64, 4)
3205  oprot.writeI64(self.num_pages_allocated)
3206  oprot.writeFieldEnd()
3207  if self.is_allocation_capped is not None:
3208  oprot.writeFieldBegin('is_allocation_capped', TType.BOOL, 5)
3209  oprot.writeBool(self.is_allocation_capped)
3210  oprot.writeFieldEnd()
3211  if self.node_memory_data is not None:
3212  oprot.writeFieldBegin('node_memory_data', TType.LIST, 6)
3213  oprot.writeListBegin(TType.STRUCT, len(self.node_memory_data))
3214  for iter125 in self.node_memory_data:
3215  iter125.write(oprot)
3216  oprot.writeListEnd()
3217  oprot.writeFieldEnd()
3218  oprot.writeFieldStop()
3219  oprot.writeStructEnd()
3220 
3221  def validate(self):
3222  return
3223 
3224  def __repr__(self):
3225  L = ['%s=%r' % (key, value)
3226  for key, value in self.__dict__.items()]
3227  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3228 
3229  def __eq__(self, other):
3230  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3231 
3232  def __ne__(self, other):
3233  return not (self == other)
3234 
3235 
3236 class TTableMeta(object):
3237  """
3238  Attributes:
3239  - table_name
3240  - num_cols
3241  - is_view
3242  - is_replicated
3243  - shard_count
3244  - max_rows
3245  - table_id
3246  - max_table_id
3247  - col_types
3248  - col_names
3249 
3250  """
3251 
3252 
3253  def __init__(self, table_name=None, num_cols=None, is_view=None, is_replicated=None, shard_count=None, max_rows=None, table_id=None, max_table_id=None, col_types=None, col_names=None,):
3254  self.table_name = table_name
3255  self.num_cols = num_cols
3256  self.is_view = is_view
3257  self.is_replicated = is_replicated
3258  self.shard_count = shard_count
3259  self.max_rows = max_rows
3260  self.table_id = table_id
3261  self.max_table_id = max_table_id
3262  self.col_types = col_types
3263  self.col_names = col_names
3264 
3265  def read(self, iprot):
3266  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
3267  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
3268  return
3269  iprot.readStructBegin()
3270  while True:
3271  (fname, ftype, fid) = iprot.readFieldBegin()
3272  if ftype == TType.STOP:
3273  break
3274  if fid == 1:
3275  if ftype == TType.STRING:
3276  self.table_name = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
3277  else:
3278  iprot.skip(ftype)
3279  elif fid == 2:
3280  if ftype == TType.I64:
3281  self.num_cols = iprot.readI64()
3282  else:
3283  iprot.skip(ftype)
3284  elif fid == 4:
3285  if ftype == TType.BOOL:
3286  self.is_view = iprot.readBool()
3287  else:
3288  iprot.skip(ftype)
3289  elif fid == 5:
3290  if ftype == TType.BOOL:
3291  self.is_replicated = iprot.readBool()
3292  else:
3293  iprot.skip(ftype)
3294  elif fid == 6:
3295  if ftype == TType.I64:
3296  self.shard_count = iprot.readI64()
3297  else:
3298  iprot.skip(ftype)
3299  elif fid == 7:
3300  if ftype == TType.I64:
3301  self.max_rows = iprot.readI64()
3302  else:
3303  iprot.skip(ftype)
3304  elif fid == 8:
3305  if ftype == TType.I64:
3306  self.table_id = iprot.readI64()
3307  else:
3308  iprot.skip(ftype)
3309  elif fid == 9:
3310  if ftype == TType.I64:
3311  self.max_table_id = iprot.readI64()
3312  else:
3313  iprot.skip(ftype)
3314  elif fid == 10:
3315  if ftype == TType.LIST:
3316  self.col_types = []
3317  (_etype129, _size126) = iprot.readListBegin()
3318  for _i130 in range(_size126):
3319  _elem131 = omnisci.common.ttypes.TTypeInfo()
3320  _elem131.read(iprot)
3321  self.col_types.append(_elem131)
3322  iprot.readListEnd()
3323  else:
3324  iprot.skip(ftype)
3325  elif fid == 11:
3326  if ftype == TType.LIST:
3327  self.col_names = []
3328  (_etype135, _size132) = iprot.readListBegin()
3329  for _i136 in range(_size132):
3330  _elem137 = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
3331  self.col_names.append(_elem137)
3332  iprot.readListEnd()
3333  else:
3334  iprot.skip(ftype)
3335  else:
3336  iprot.skip(ftype)
3337  iprot.readFieldEnd()
3338  iprot.readStructEnd()
3339 
3340  def write(self, oprot):
3341  if oprot._fast_encode is not None and self.thrift_spec is not None:
3342  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
3343  return
3344  oprot.writeStructBegin('TTableMeta')
3345  if self.table_name is not None:
3346  oprot.writeFieldBegin('table_name', TType.STRING, 1)
3347  oprot.writeString(self.table_name.encode('utf-8') if sys.version_info[0] == 2 else self.table_name)
3348  oprot.writeFieldEnd()
3349  if self.num_cols is not None:
3350  oprot.writeFieldBegin('num_cols', TType.I64, 2)
3351  oprot.writeI64(self.num_cols)
3352  oprot.writeFieldEnd()
3353  if self.is_view is not None:
3354  oprot.writeFieldBegin('is_view', TType.BOOL, 4)
3355  oprot.writeBool(self.is_view)
3356  oprot.writeFieldEnd()
3357  if self.is_replicated is not None:
3358  oprot.writeFieldBegin('is_replicated', TType.BOOL, 5)
3359  oprot.writeBool(self.is_replicated)
3360  oprot.writeFieldEnd()
3361  if self.shard_count is not None:
3362  oprot.writeFieldBegin('shard_count', TType.I64, 6)
3363  oprot.writeI64(self.shard_count)
3364  oprot.writeFieldEnd()
3365  if self.max_rows is not None:
3366  oprot.writeFieldBegin('max_rows', TType.I64, 7)
3367  oprot.writeI64(self.max_rows)
3368  oprot.writeFieldEnd()
3369  if self.table_id is not None:
3370  oprot.writeFieldBegin('table_id', TType.I64, 8)
3371  oprot.writeI64(self.table_id)
3372  oprot.writeFieldEnd()
3373  if self.max_table_id is not None:
3374  oprot.writeFieldBegin('max_table_id', TType.I64, 9)
3375  oprot.writeI64(self.max_table_id)
3376  oprot.writeFieldEnd()
3377  if self.col_types is not None:
3378  oprot.writeFieldBegin('col_types', TType.LIST, 10)
3379  oprot.writeListBegin(TType.STRUCT, len(self.col_types))
3380  for iter138 in self.col_types:
3381  iter138.write(oprot)
3382  oprot.writeListEnd()
3383  oprot.writeFieldEnd()
3384  if self.col_names is not None:
3385  oprot.writeFieldBegin('col_names', TType.LIST, 11)
3386  oprot.writeListBegin(TType.STRING, len(self.col_names))
3387  for iter139 in self.col_names:
3388  oprot.writeString(iter139.encode('utf-8') if sys.version_info[0] == 2 else iter139)
3389  oprot.writeListEnd()
3390  oprot.writeFieldEnd()
3391  oprot.writeFieldStop()
3392  oprot.writeStructEnd()
3393 
3394  def validate(self):
3395  return
3396 
3397  def __repr__(self):
3398  L = ['%s=%r' % (key, value)
3399  for key, value in self.__dict__.items()]
3400  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3401 
3402  def __eq__(self, other):
3403  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3404 
3405  def __ne__(self, other):
3406  return not (self == other)
3407 
3408 
3409 class TTableDetails(object):
3410  """
3411  Attributes:
3412  - row_desc
3413  - fragment_size
3414  - page_size
3415  - max_rows
3416  - view_sql
3417  - shard_count
3418  - key_metainfo
3419  - is_temporary
3420  - partition_detail
3421 
3422  """
3423 
3424 
3425  def __init__(self, row_desc=None, fragment_size=None, page_size=None, max_rows=None, view_sql=None, shard_count=None, key_metainfo=None, is_temporary=None, partition_detail=None,):
3426  self.row_desc = row_desc
3427  self.fragment_size = fragment_size
3428  self.page_size = page_size
3429  self.max_rows = max_rows
3430  self.view_sql = view_sql
3431  self.shard_count = shard_count
3432  self.key_metainfo = key_metainfo
3433  self.is_temporary = is_temporary
3434  self.partition_detail = partition_detail
3435 
3436  def read(self, iprot):
3437  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
3438  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
3439  return
3440  iprot.readStructBegin()
3441  while True:
3442  (fname, ftype, fid) = iprot.readFieldBegin()
3443  if ftype == TType.STOP:
3444  break
3445  if fid == 1:
3446  if ftype == TType.LIST:
3447  self.row_desc = []
3448  (_etype143, _size140) = iprot.readListBegin()
3449  for _i144 in range(_size140):
3450  _elem145 = TColumnType()
3451  _elem145.read(iprot)
3452  self.row_desc.append(_elem145)
3453  iprot.readListEnd()
3454  else:
3455  iprot.skip(ftype)
3456  elif fid == 2:
3457  if ftype == TType.I64:
3458  self.fragment_size = iprot.readI64()
3459  else:
3460  iprot.skip(ftype)
3461  elif fid == 3:
3462  if ftype == TType.I64:
3463  self.page_size = iprot.readI64()
3464  else:
3465  iprot.skip(ftype)
3466  elif fid == 4:
3467  if ftype == TType.I64:
3468  self.max_rows = iprot.readI64()
3469  else:
3470  iprot.skip(ftype)
3471  elif fid == 5:
3472  if ftype == TType.STRING:
3473  self.view_sql = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
3474  else:
3475  iprot.skip(ftype)
3476  elif fid == 6:
3477  if ftype == TType.I64:
3478  self.shard_count = iprot.readI64()
3479  else:
3480  iprot.skip(ftype)
3481  elif fid == 7:
3482  if ftype == TType.STRING:
3483  self.key_metainfo = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
3484  else:
3485  iprot.skip(ftype)
3486  elif fid == 8:
3487  if ftype == TType.BOOL:
3488  self.is_temporary = iprot.readBool()
3489  else:
3490  iprot.skip(ftype)
3491  elif fid == 9:
3492  if ftype == TType.I32:
3493  self.partition_detail = iprot.readI32()
3494  else:
3495  iprot.skip(ftype)
3496  else:
3497  iprot.skip(ftype)
3498  iprot.readFieldEnd()
3499  iprot.readStructEnd()
3500 
3501  def write(self, oprot):
3502  if oprot._fast_encode is not None and self.thrift_spec is not None:
3503  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
3504  return
3505  oprot.writeStructBegin('TTableDetails')
3506  if self.row_desc is not None:
3507  oprot.writeFieldBegin('row_desc', TType.LIST, 1)
3508  oprot.writeListBegin(TType.STRUCT, len(self.row_desc))
3509  for iter146 in self.row_desc:
3510  iter146.write(oprot)
3511  oprot.writeListEnd()
3512  oprot.writeFieldEnd()
3513  if self.fragment_size is not None:
3514  oprot.writeFieldBegin('fragment_size', TType.I64, 2)
3515  oprot.writeI64(self.fragment_size)
3516  oprot.writeFieldEnd()
3517  if self.page_size is not None:
3518  oprot.writeFieldBegin('page_size', TType.I64, 3)
3519  oprot.writeI64(self.page_size)
3520  oprot.writeFieldEnd()
3521  if self.max_rows is not None:
3522  oprot.writeFieldBegin('max_rows', TType.I64, 4)
3523  oprot.writeI64(self.max_rows)
3524  oprot.writeFieldEnd()
3525  if self.view_sql is not None:
3526  oprot.writeFieldBegin('view_sql', TType.STRING, 5)
3527  oprot.writeString(self.view_sql.encode('utf-8') if sys.version_info[0] == 2 else self.view_sql)
3528  oprot.writeFieldEnd()
3529  if self.shard_count is not None:
3530  oprot.writeFieldBegin('shard_count', TType.I64, 6)
3531  oprot.writeI64(self.shard_count)
3532  oprot.writeFieldEnd()
3533  if self.key_metainfo is not None:
3534  oprot.writeFieldBegin('key_metainfo', TType.STRING, 7)
3535  oprot.writeString(self.key_metainfo.encode('utf-8') if sys.version_info[0] == 2 else self.key_metainfo)
3536  oprot.writeFieldEnd()
3537  if self.is_temporary is not None:
3538  oprot.writeFieldBegin('is_temporary', TType.BOOL, 8)
3539  oprot.writeBool(self.is_temporary)
3540  oprot.writeFieldEnd()
3541  if self.partition_detail is not None:
3542  oprot.writeFieldBegin('partition_detail', TType.I32, 9)
3543  oprot.writeI32(self.partition_detail)
3544  oprot.writeFieldEnd()
3545  oprot.writeFieldStop()
3546  oprot.writeStructEnd()
3547 
3548  def validate(self):
3549  return
3550 
3551  def __repr__(self):
3552  L = ['%s=%r' % (key, value)
3553  for key, value in self.__dict__.items()]
3554  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3555 
3556  def __eq__(self, other):
3557  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3558 
3559  def __ne__(self, other):
3560  return not (self == other)
3561 
3562 
3563 class TColumnRange(object):
3564  """
3565  Attributes:
3566  - type
3567  - col_id
3568  - table_id
3569  - has_nulls
3570  - int_min
3571  - int_max
3572  - bucket
3573  - fp_min
3574  - fp_max
3575 
3576  """
3577 
3578 
3579  def __init__(self, type=None, col_id=None, table_id=None, has_nulls=None, int_min=None, int_max=None, bucket=None, fp_min=None, fp_max=None,):
3580  self.type = type
3581  self.col_id = col_id
3582  self.table_id = table_id
3583  self.has_nulls = has_nulls
3584  self.int_min = int_min
3585  self.int_max = int_max
3586  self.bucket = bucket
3587  self.fp_min = fp_min
3588  self.fp_max = fp_max
3589 
3590  def read(self, iprot):
3591  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
3592  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
3593  return
3594  iprot.readStructBegin()
3595  while True:
3596  (fname, ftype, fid) = iprot.readFieldBegin()
3597  if ftype == TType.STOP:
3598  break
3599  if fid == 1:
3600  if ftype == TType.I32:
3601  self.type = iprot.readI32()
3602  else:
3603  iprot.skip(ftype)
3604  elif fid == 2:
3605  if ftype == TType.I32:
3606  self.col_id = iprot.readI32()
3607  else:
3608  iprot.skip(ftype)
3609  elif fid == 3:
3610  if ftype == TType.I32:
3611  self.table_id = iprot.readI32()
3612  else:
3613  iprot.skip(ftype)
3614  elif fid == 4:
3615  if ftype == TType.BOOL:
3616  self.has_nulls = iprot.readBool()
3617  else:
3618  iprot.skip(ftype)
3619  elif fid == 5:
3620  if ftype == TType.I64:
3621  self.int_min = iprot.readI64()
3622  else:
3623  iprot.skip(ftype)
3624  elif fid == 6:
3625  if ftype == TType.I64:
3626  self.int_max = iprot.readI64()
3627  else:
3628  iprot.skip(ftype)
3629  elif fid == 7:
3630  if ftype == TType.I64:
3631  self.bucket = iprot.readI64()
3632  else:
3633  iprot.skip(ftype)
3634  elif fid == 8:
3635  if ftype == TType.DOUBLE:
3636  self.fp_min = iprot.readDouble()
3637  else:
3638  iprot.skip(ftype)
3639  elif fid == 9:
3640  if ftype == TType.DOUBLE:
3641  self.fp_max = iprot.readDouble()
3642  else:
3643  iprot.skip(ftype)
3644  else:
3645  iprot.skip(ftype)
3646  iprot.readFieldEnd()
3647  iprot.readStructEnd()
3648 
3649  def write(self, oprot):
3650  if oprot._fast_encode is not None and self.thrift_spec is not None:
3651  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
3652  return
3653  oprot.writeStructBegin('TColumnRange')
3654  if self.type is not None:
3655  oprot.writeFieldBegin('type', TType.I32, 1)
3656  oprot.writeI32(self.type)
3657  oprot.writeFieldEnd()
3658  if self.col_id is not None:
3659  oprot.writeFieldBegin('col_id', TType.I32, 2)
3660  oprot.writeI32(self.col_id)
3661  oprot.writeFieldEnd()
3662  if self.table_id is not None:
3663  oprot.writeFieldBegin('table_id', TType.I32, 3)
3664  oprot.writeI32(self.table_id)
3665  oprot.writeFieldEnd()
3666  if self.has_nulls is not None:
3667  oprot.writeFieldBegin('has_nulls', TType.BOOL, 4)
3668  oprot.writeBool(self.has_nulls)
3669  oprot.writeFieldEnd()
3670  if self.int_min is not None:
3671  oprot.writeFieldBegin('int_min', TType.I64, 5)
3672  oprot.writeI64(self.int_min)
3673  oprot.writeFieldEnd()
3674  if self.int_max is not None:
3675  oprot.writeFieldBegin('int_max', TType.I64, 6)
3676  oprot.writeI64(self.int_max)
3677  oprot.writeFieldEnd()
3678  if self.bucket is not None:
3679  oprot.writeFieldBegin('bucket', TType.I64, 7)
3680  oprot.writeI64(self.bucket)
3681  oprot.writeFieldEnd()
3682  if self.fp_min is not None:
3683  oprot.writeFieldBegin('fp_min', TType.DOUBLE, 8)
3684  oprot.writeDouble(self.fp_min)
3685  oprot.writeFieldEnd()
3686  if self.fp_max is not None:
3687  oprot.writeFieldBegin('fp_max', TType.DOUBLE, 9)
3688  oprot.writeDouble(self.fp_max)
3689  oprot.writeFieldEnd()
3690  oprot.writeFieldStop()
3691  oprot.writeStructEnd()
3692 
3693  def validate(self):
3694  return
3695 
3696  def __repr__(self):
3697  L = ['%s=%r' % (key, value)
3698  for key, value in self.__dict__.items()]
3699  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3700 
3701  def __eq__(self, other):
3702  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3703 
3704  def __ne__(self, other):
3705  return not (self == other)
3706 
3707 
3709  """
3710  Attributes:
3711  - dict_id
3712  - entry_count
3713 
3714  """
3715 
3716 
3717  def __init__(self, dict_id=None, entry_count=None,):
3718  self.dict_id = dict_id
3719  self.entry_count = entry_count
3720 
3721  def read(self, iprot):
3722  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
3723  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
3724  return
3725  iprot.readStructBegin()
3726  while True:
3727  (fname, ftype, fid) = iprot.readFieldBegin()
3728  if ftype == TType.STOP:
3729  break
3730  if fid == 1:
3731  if ftype == TType.I32:
3732  self.dict_id = iprot.readI32()
3733  else:
3734  iprot.skip(ftype)
3735  elif fid == 2:
3736  if ftype == TType.I64:
3737  self.entry_count = iprot.readI64()
3738  else:
3739  iprot.skip(ftype)
3740  else:
3741  iprot.skip(ftype)
3742  iprot.readFieldEnd()
3743  iprot.readStructEnd()
3744 
3745  def write(self, oprot):
3746  if oprot._fast_encode is not None and self.thrift_spec is not None:
3747  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
3748  return
3749  oprot.writeStructBegin('TDictionaryGeneration')
3750  if self.dict_id is not None:
3751  oprot.writeFieldBegin('dict_id', TType.I32, 1)
3752  oprot.writeI32(self.dict_id)
3753  oprot.writeFieldEnd()
3754  if self.entry_count is not None:
3755  oprot.writeFieldBegin('entry_count', TType.I64, 2)
3756  oprot.writeI64(self.entry_count)
3757  oprot.writeFieldEnd()
3758  oprot.writeFieldStop()
3759  oprot.writeStructEnd()
3760 
3761  def validate(self):
3762  return
3763 
3764  def __repr__(self):
3765  L = ['%s=%r' % (key, value)
3766  for key, value in self.__dict__.items()]
3767  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3768 
3769  def __eq__(self, other):
3770  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3771 
3772  def __ne__(self, other):
3773  return not (self == other)
3774 
3775 
3776 class TTableGeneration(object):
3777  """
3778  Attributes:
3779  - table_id
3780  - tuple_count
3781  - start_rowid
3782 
3783  """
3784 
3785 
3786  def __init__(self, table_id=None, tuple_count=None, start_rowid=None,):
3787  self.table_id = table_id
3788  self.tuple_count = tuple_count
3789  self.start_rowid = start_rowid
3790 
3791  def read(self, iprot):
3792  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
3793  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
3794  return
3795  iprot.readStructBegin()
3796  while True:
3797  (fname, ftype, fid) = iprot.readFieldBegin()
3798  if ftype == TType.STOP:
3799  break
3800  if fid == 1:
3801  if ftype == TType.I32:
3802  self.table_id = iprot.readI32()
3803  else:
3804  iprot.skip(ftype)
3805  elif fid == 2:
3806  if ftype == TType.I64:
3807  self.tuple_count = iprot.readI64()
3808  else:
3809  iprot.skip(ftype)
3810  elif fid == 3:
3811  if ftype == TType.I64:
3812  self.start_rowid = iprot.readI64()
3813  else:
3814  iprot.skip(ftype)
3815  else:
3816  iprot.skip(ftype)
3817  iprot.readFieldEnd()
3818  iprot.readStructEnd()
3819 
3820  def write(self, oprot):
3821  if oprot._fast_encode is not None and self.thrift_spec is not None:
3822  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
3823  return
3824  oprot.writeStructBegin('TTableGeneration')
3825  if self.table_id is not None:
3826  oprot.writeFieldBegin('table_id', TType.I32, 1)
3827  oprot.writeI32(self.table_id)
3828  oprot.writeFieldEnd()
3829  if self.tuple_count is not None:
3830  oprot.writeFieldBegin('tuple_count', TType.I64, 2)
3831  oprot.writeI64(self.tuple_count)
3832  oprot.writeFieldEnd()
3833  if self.start_rowid is not None:
3834  oprot.writeFieldBegin('start_rowid', TType.I64, 3)
3835  oprot.writeI64(self.start_rowid)
3836  oprot.writeFieldEnd()
3837  oprot.writeFieldStop()
3838  oprot.writeStructEnd()
3839 
3840  def validate(self):
3841  return
3842 
3843  def __repr__(self):
3844  L = ['%s=%r' % (key, value)
3845  for key, value in self.__dict__.items()]
3846  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3847 
3848  def __eq__(self, other):
3849  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3850 
3851  def __ne__(self, other):
3852  return not (self == other)
3853 
3854 
3855 class TPendingQuery(object):
3856  """
3857  Attributes:
3858  - id
3859  - column_ranges
3860  - dictionary_generations
3861  - table_generations
3862  - parent_session_id
3863 
3864  """
3865 
3866 
3867  def __init__(self, id=None, column_ranges=None, dictionary_generations=None, table_generations=None, parent_session_id=None,):
3868  self.id = id
3869  self.column_ranges = column_ranges
3870  self.dictionary_generations = dictionary_generations
3871  self.table_generations = table_generations
3872  self.parent_session_id = parent_session_id
3873 
3874  def read(self, iprot):
3875  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
3876  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
3877  return
3878  iprot.readStructBegin()
3879  while True:
3880  (fname, ftype, fid) = iprot.readFieldBegin()
3881  if ftype == TType.STOP:
3882  break
3883  if fid == 1:
3884  if ftype == TType.I64:
3885  self.id = iprot.readI64()
3886  else:
3887  iprot.skip(ftype)
3888  elif fid == 2:
3889  if ftype == TType.LIST:
3890  self.column_ranges = []
3891  (_etype150, _size147) = iprot.readListBegin()
3892  for _i151 in range(_size147):
3893  _elem152 = TColumnRange()
3894  _elem152.read(iprot)
3895  self.column_ranges.append(_elem152)
3896  iprot.readListEnd()
3897  else:
3898  iprot.skip(ftype)
3899  elif fid == 3:
3900  if ftype == TType.LIST:
3901  self.dictionary_generations = []
3902  (_etype156, _size153) = iprot.readListBegin()
3903  for _i157 in range(_size153):
3904  _elem158 = TDictionaryGeneration()
3905  _elem158.read(iprot)
3906  self.dictionary_generations.append(_elem158)
3907  iprot.readListEnd()
3908  else:
3909  iprot.skip(ftype)
3910  elif fid == 4:
3911  if ftype == TType.LIST:
3912  self.table_generations = []
3913  (_etype162, _size159) = iprot.readListBegin()
3914  for _i163 in range(_size159):
3915  _elem164 = TTableGeneration()
3916  _elem164.read(iprot)
3917  self.table_generations.append(_elem164)
3918  iprot.readListEnd()
3919  else:
3920  iprot.skip(ftype)
3921  elif fid == 5:
3922  if ftype == TType.STRING:
3923  self.parent_session_id = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
3924  else:
3925  iprot.skip(ftype)
3926  else:
3927  iprot.skip(ftype)
3928  iprot.readFieldEnd()
3929  iprot.readStructEnd()
3930 
3931  def write(self, oprot):
3932  if oprot._fast_encode is not None and self.thrift_spec is not None:
3933  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
3934  return
3935  oprot.writeStructBegin('TPendingQuery')
3936  if self.id is not None:
3937  oprot.writeFieldBegin('id', TType.I64, 1)
3938  oprot.writeI64(self.id)
3939  oprot.writeFieldEnd()
3940  if self.column_ranges is not None:
3941  oprot.writeFieldBegin('column_ranges', TType.LIST, 2)
3942  oprot.writeListBegin(TType.STRUCT, len(self.column_ranges))
3943  for iter165 in self.column_ranges:
3944  iter165.write(oprot)
3945  oprot.writeListEnd()
3946  oprot.writeFieldEnd()
3947  if self.dictionary_generations is not None:
3948  oprot.writeFieldBegin('dictionary_generations', TType.LIST, 3)
3949  oprot.writeListBegin(TType.STRUCT, len(self.dictionary_generations))
3950  for iter166 in self.dictionary_generations:
3951  iter166.write(oprot)
3952  oprot.writeListEnd()
3953  oprot.writeFieldEnd()
3954  if self.table_generations is not None:
3955  oprot.writeFieldBegin('table_generations', TType.LIST, 4)
3956  oprot.writeListBegin(TType.STRUCT, len(self.table_generations))
3957  for iter167 in self.table_generations:
3958  iter167.write(oprot)
3959  oprot.writeListEnd()
3960  oprot.writeFieldEnd()
3961  if self.parent_session_id is not None:
3962  oprot.writeFieldBegin('parent_session_id', TType.STRING, 5)
3963  oprot.writeString(self.parent_session_id.encode('utf-8') if sys.version_info[0] == 2 else self.parent_session_id)
3964  oprot.writeFieldEnd()
3965  oprot.writeFieldStop()
3966  oprot.writeStructEnd()
3967 
3968  def validate(self):
3969  return
3970 
3971  def __repr__(self):
3972  L = ['%s=%r' % (key, value)
3973  for key, value in self.__dict__.items()]
3974  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3975 
3976  def __eq__(self, other):
3977  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3978 
3979  def __ne__(self, other):
3980  return not (self == other)
3981 
3982 
3983 class TVarLen(object):
3984  """
3985  Attributes:
3986  - payload
3987  - is_null
3988 
3989  """
3990 
3991 
3992  def __init__(self, payload=None, is_null=None,):
3993  self.payload = payload
3994  self.is_null = is_null
3995 
3996  def read(self, iprot):
3997  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
3998  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
3999  return
4000  iprot.readStructBegin()
4001  while True:
4002  (fname, ftype, fid) = iprot.readFieldBegin()
4003  if ftype == TType.STOP:
4004  break
4005  if fid == 1:
4006  if ftype == TType.STRING:
4007  self.payload = iprot.readBinary()
4008  else:
4009  iprot.skip(ftype)
4010  elif fid == 2:
4011  if ftype == TType.BOOL:
4012  self.is_null = iprot.readBool()
4013  else:
4014  iprot.skip(ftype)
4015  else:
4016  iprot.skip(ftype)
4017  iprot.readFieldEnd()
4018  iprot.readStructEnd()
4019 
4020  def write(self, oprot):
4021  if oprot._fast_encode is not None and self.thrift_spec is not None:
4022  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
4023  return
4024  oprot.writeStructBegin('TVarLen')
4025  if self.payload is not None:
4026  oprot.writeFieldBegin('payload', TType.STRING, 1)
4027  oprot.writeBinary(self.payload)
4028  oprot.writeFieldEnd()
4029  if self.is_null is not None:
4030  oprot.writeFieldBegin('is_null', TType.BOOL, 2)
4031  oprot.writeBool(self.is_null)
4032  oprot.writeFieldEnd()
4033  oprot.writeFieldStop()
4034  oprot.writeStructEnd()
4035 
4036  def validate(self):
4037  return
4038 
4039  def __repr__(self):
4040  L = ['%s=%r' % (key, value)
4041  for key, value in self.__dict__.items()]
4042  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4043 
4044  def __eq__(self, other):
4045  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4046 
4047  def __ne__(self, other):
4048  return not (self == other)
4049 
4050 
4051 class TDataBlockPtr(object):
4052  """
4053  Attributes:
4054  - fixed_len_data
4055  - var_len_data
4056 
4057  """
4058 
4059 
4060  def __init__(self, fixed_len_data=None, var_len_data=None,):
4061  self.fixed_len_data = fixed_len_data
4062  self.var_len_data = var_len_data
4063 
4064  def read(self, iprot):
4065  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
4066  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
4067  return
4068  iprot.readStructBegin()
4069  while True:
4070  (fname, ftype, fid) = iprot.readFieldBegin()
4071  if ftype == TType.STOP:
4072  break
4073  if fid == 1:
4074  if ftype == TType.STRING:
4075  self.fixed_len_data = iprot.readBinary()
4076  else:
4077  iprot.skip(ftype)
4078  elif fid == 2:
4079  if ftype == TType.LIST:
4080  self.var_len_data = []
4081  (_etype171, _size168) = iprot.readListBegin()
4082  for _i172 in range(_size168):
4083  _elem173 = TVarLen()
4084  _elem173.read(iprot)
4085  self.var_len_data.append(_elem173)
4086  iprot.readListEnd()
4087  else:
4088  iprot.skip(ftype)
4089  else:
4090  iprot.skip(ftype)
4091  iprot.readFieldEnd()
4092  iprot.readStructEnd()
4093 
4094  def write(self, oprot):
4095  if oprot._fast_encode is not None and self.thrift_spec is not None:
4096  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
4097  return
4098  oprot.writeStructBegin('TDataBlockPtr')
4099  if self.fixed_len_data is not None:
4100  oprot.writeFieldBegin('fixed_len_data', TType.STRING, 1)
4101  oprot.writeBinary(self.fixed_len_data)
4102  oprot.writeFieldEnd()
4103  if self.var_len_data is not None:
4104  oprot.writeFieldBegin('var_len_data', TType.LIST, 2)
4105  oprot.writeListBegin(TType.STRUCT, len(self.var_len_data))
4106  for iter174 in self.var_len_data:
4107  iter174.write(oprot)
4108  oprot.writeListEnd()
4109  oprot.writeFieldEnd()
4110  oprot.writeFieldStop()
4111  oprot.writeStructEnd()
4112 
4113  def validate(self):
4114  return
4115 
4116  def __repr__(self):
4117  L = ['%s=%r' % (key, value)
4118  for key, value in self.__dict__.items()]
4119  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4120 
4121  def __eq__(self, other):
4122  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4123 
4124  def __ne__(self, other):
4125  return not (self == other)
4126 
4127 
4128 class TInsertData(object):
4129  """
4130  Attributes:
4131  - db_id
4132  - table_id
4133  - column_ids
4134  - data
4135  - num_rows
4136 
4137  """
4138 
4139 
4140  def __init__(self, db_id=None, table_id=None, column_ids=None, data=None, num_rows=None,):
4141  self.db_id = db_id
4142  self.table_id = table_id
4143  self.column_ids = column_ids
4144  self.data = data
4145  self.num_rows = num_rows
4146 
4147  def read(self, iprot):
4148  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
4149  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
4150  return
4151  iprot.readStructBegin()
4152  while True:
4153  (fname, ftype, fid) = iprot.readFieldBegin()
4154  if ftype == TType.STOP:
4155  break
4156  if fid == 1:
4157  if ftype == TType.I32:
4158  self.db_id = iprot.readI32()
4159  else:
4160  iprot.skip(ftype)
4161  elif fid == 2:
4162  if ftype == TType.I32:
4163  self.table_id = iprot.readI32()
4164  else:
4165  iprot.skip(ftype)
4166  elif fid == 3:
4167  if ftype == TType.LIST:
4168  self.column_ids = []
4169  (_etype178, _size175) = iprot.readListBegin()
4170  for _i179 in range(_size175):
4171  _elem180 = iprot.readI32()
4172  self.column_ids.append(_elem180)
4173  iprot.readListEnd()
4174  else:
4175  iprot.skip(ftype)
4176  elif fid == 4:
4177  if ftype == TType.LIST:
4178  self.data = []
4179  (_etype184, _size181) = iprot.readListBegin()
4180  for _i185 in range(_size181):
4181  _elem186 = TDataBlockPtr()
4182  _elem186.read(iprot)
4183  self.data.append(_elem186)
4184  iprot.readListEnd()
4185  else:
4186  iprot.skip(ftype)
4187  elif fid == 5:
4188  if ftype == TType.I64:
4189  self.num_rows = iprot.readI64()
4190  else:
4191  iprot.skip(ftype)
4192  else:
4193  iprot.skip(ftype)
4194  iprot.readFieldEnd()
4195  iprot.readStructEnd()
4196 
4197  def write(self, oprot):
4198  if oprot._fast_encode is not None and self.thrift_spec is not None:
4199  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
4200  return
4201  oprot.writeStructBegin('TInsertData')
4202  if self.db_id is not None:
4203  oprot.writeFieldBegin('db_id', TType.I32, 1)
4204  oprot.writeI32(self.db_id)
4205  oprot.writeFieldEnd()
4206  if self.table_id is not None:
4207  oprot.writeFieldBegin('table_id', TType.I32, 2)
4208  oprot.writeI32(self.table_id)
4209  oprot.writeFieldEnd()
4210  if self.column_ids is not None:
4211  oprot.writeFieldBegin('column_ids', TType.LIST, 3)
4212  oprot.writeListBegin(TType.I32, len(self.column_ids))
4213  for iter187 in self.column_ids:
4214  oprot.writeI32(iter187)
4215  oprot.writeListEnd()
4216  oprot.writeFieldEnd()
4217  if self.data is not None:
4218  oprot.writeFieldBegin('data', TType.LIST, 4)
4219  oprot.writeListBegin(TType.STRUCT, len(self.data))
4220  for iter188 in self.data:
4221  iter188.write(oprot)
4222  oprot.writeListEnd()
4223  oprot.writeFieldEnd()
4224  if self.num_rows is not None:
4225  oprot.writeFieldBegin('num_rows', TType.I64, 5)
4226  oprot.writeI64(self.num_rows)
4227  oprot.writeFieldEnd()
4228  oprot.writeFieldStop()
4229  oprot.writeStructEnd()
4230 
4231  def validate(self):
4232  return
4233 
4234  def __repr__(self):
4235  L = ['%s=%r' % (key, value)
4236  for key, value in self.__dict__.items()]
4237  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4238 
4239  def __eq__(self, other):
4240  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4241 
4242  def __ne__(self, other):
4243  return not (self == other)
4244 
4245 
4246 class TPendingRenderQuery(object):
4247  """
4248  Attributes:
4249  - id
4250 
4251  """
4252 
4253 
4254  def __init__(self, id=None,):
4255  self.id = id
4256 
4257  def read(self, iprot):
4258  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
4259  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
4260  return
4261  iprot.readStructBegin()
4262  while True:
4263  (fname, ftype, fid) = iprot.readFieldBegin()
4264  if ftype == TType.STOP:
4265  break
4266  if fid == 1:
4267  if ftype == TType.I64:
4268  self.id = iprot.readI64()
4269  else:
4270  iprot.skip(ftype)
4271  else:
4272  iprot.skip(ftype)
4273  iprot.readFieldEnd()
4274  iprot.readStructEnd()
4275 
4276  def write(self, oprot):
4277  if oprot._fast_encode is not None and self.thrift_spec is not None:
4278  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
4279  return
4280  oprot.writeStructBegin('TPendingRenderQuery')
4281  if self.id is not None:
4282  oprot.writeFieldBegin('id', TType.I64, 1)
4283  oprot.writeI64(self.id)
4284  oprot.writeFieldEnd()
4285  oprot.writeFieldStop()
4286  oprot.writeStructEnd()
4287 
4288  def validate(self):
4289  return
4290 
4291  def __repr__(self):
4292  L = ['%s=%r' % (key, value)
4293  for key, value in self.__dict__.items()]
4294  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4295 
4296  def __eq__(self, other):
4297  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4298 
4299  def __ne__(self, other):
4300  return not (self == other)
4301 
4302 
4303 class TRenderParseResult(object):
4304  """
4305  Attributes:
4306  - merge_type
4307  - node_id
4308  - execution_time_ms
4309  - render_time_ms
4310  - total_time_ms
4311 
4312  """
4313 
4314 
4315  def __init__(self, merge_type=None, node_id=None, execution_time_ms=None, render_time_ms=None, total_time_ms=None,):
4316  self.merge_type = merge_type
4317  self.node_id = node_id
4318  self.execution_time_ms = execution_time_ms
4319  self.render_time_ms = render_time_ms
4320  self.total_time_ms = total_time_ms
4321 
4322  def read(self, iprot):
4323  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
4324  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
4325  return
4326  iprot.readStructBegin()
4327  while True:
4328  (fname, ftype, fid) = iprot.readFieldBegin()
4329  if ftype == TType.STOP:
4330  break
4331  if fid == 1:
4332  if ftype == TType.I32:
4333  self.merge_type = iprot.readI32()
4334  else:
4335  iprot.skip(ftype)
4336  elif fid == 2:
4337  if ftype == TType.I32:
4338  self.node_id = iprot.readI32()
4339  else:
4340  iprot.skip(ftype)
4341  elif fid == 3:
4342  if ftype == TType.I64:
4343  self.execution_time_ms = iprot.readI64()
4344  else:
4345  iprot.skip(ftype)
4346  elif fid == 4:
4347  if ftype == TType.I64:
4348  self.render_time_ms = iprot.readI64()
4349  else:
4350  iprot.skip(ftype)
4351  elif fid == 5:
4352  if ftype == TType.I64:
4353  self.total_time_ms = iprot.readI64()
4354  else:
4355  iprot.skip(ftype)
4356  else:
4357  iprot.skip(ftype)
4358  iprot.readFieldEnd()
4359  iprot.readStructEnd()
4360 
4361  def write(self, oprot):
4362  if oprot._fast_encode is not None and self.thrift_spec is not None:
4363  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
4364  return
4365  oprot.writeStructBegin('TRenderParseResult')
4366  if self.merge_type is not None:
4367  oprot.writeFieldBegin('merge_type', TType.I32, 1)
4368  oprot.writeI32(self.merge_type)
4369  oprot.writeFieldEnd()
4370  if self.node_id is not None:
4371  oprot.writeFieldBegin('node_id', TType.I32, 2)
4372  oprot.writeI32(self.node_id)
4373  oprot.writeFieldEnd()
4374  if self.execution_time_ms is not None:
4375  oprot.writeFieldBegin('execution_time_ms', TType.I64, 3)
4376  oprot.writeI64(self.execution_time_ms)
4377  oprot.writeFieldEnd()
4378  if self.render_time_ms is not None:
4379  oprot.writeFieldBegin('render_time_ms', TType.I64, 4)
4380  oprot.writeI64(self.render_time_ms)
4381  oprot.writeFieldEnd()
4382  if self.total_time_ms is not None:
4383  oprot.writeFieldBegin('total_time_ms', TType.I64, 5)
4384  oprot.writeI64(self.total_time_ms)
4385  oprot.writeFieldEnd()
4386  oprot.writeFieldStop()
4387  oprot.writeStructEnd()
4388 
4389  def validate(self):
4390  return
4391 
4392  def __repr__(self):
4393  L = ['%s=%r' % (key, value)
4394  for key, value in self.__dict__.items()]
4395  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4396 
4397  def __eq__(self, other):
4398  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4399 
4400  def __ne__(self, other):
4401  return not (self == other)
4402 
4403 
4405  """
4406  Attributes:
4407  - num_pixel_channels
4408  - num_pixel_samples
4409  - pixels
4410  - row_ids_A
4411  - row_ids_B
4412  - table_ids
4413  - accum_data
4414  - accum_depth
4415 
4416  """
4417 
4418 
4419  def __init__(self, num_pixel_channels=None, num_pixel_samples=None, pixels=None, row_ids_A=None, row_ids_B=None, table_ids=None, accum_data=None, accum_depth=None,):
4420  self.num_pixel_channels = num_pixel_channels
4421  self.num_pixel_samples = num_pixel_samples
4422  self.pixels = pixels
4423  self.row_ids_A = row_ids_A
4424  self.row_ids_B = row_ids_B
4425  self.table_ids = table_ids
4426  self.accum_data = accum_data
4427  self.accum_depth = accum_depth
4428 
4429  def read(self, iprot):
4430  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
4431  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
4432  return
4433  iprot.readStructBegin()
4434  while True:
4435  (fname, ftype, fid) = iprot.readFieldBegin()
4436  if ftype == TType.STOP:
4437  break
4438  if fid == 1:
4439  if ftype == TType.I32:
4440  self.num_pixel_channels = iprot.readI32()
4441  else:
4442  iprot.skip(ftype)
4443  elif fid == 2:
4444  if ftype == TType.I32:
4445  self.num_pixel_samples = iprot.readI32()
4446  else:
4447  iprot.skip(ftype)
4448  elif fid == 3:
4449  if ftype == TType.STRING:
4450  self.pixels = iprot.readBinary()
4451  else:
4452  iprot.skip(ftype)
4453  elif fid == 4:
4454  if ftype == TType.STRING:
4455  self.row_ids_A = iprot.readBinary()
4456  else:
4457  iprot.skip(ftype)
4458  elif fid == 5:
4459  if ftype == TType.STRING:
4460  self.row_ids_B = iprot.readBinary()
4461  else:
4462  iprot.skip(ftype)
4463  elif fid == 6:
4464  if ftype == TType.STRING:
4465  self.table_ids = iprot.readBinary()
4466  else:
4467  iprot.skip(ftype)
4468  elif fid == 7:
4469  if ftype == TType.STRING:
4470  self.accum_data = iprot.readBinary()
4471  else:
4472  iprot.skip(ftype)
4473  elif fid == 8:
4474  if ftype == TType.I32:
4475  self.accum_depth = iprot.readI32()
4476  else:
4477  iprot.skip(ftype)
4478  else:
4479  iprot.skip(ftype)
4480  iprot.readFieldEnd()
4481  iprot.readStructEnd()
4482 
4483  def write(self, oprot):
4484  if oprot._fast_encode is not None and self.thrift_spec is not None:
4485  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
4486  return
4487  oprot.writeStructBegin('TRawRenderPassDataResult')
4488  if self.num_pixel_channels is not None:
4489  oprot.writeFieldBegin('num_pixel_channels', TType.I32, 1)
4490  oprot.writeI32(self.num_pixel_channels)
4491  oprot.writeFieldEnd()
4492  if self.num_pixel_samples is not None:
4493  oprot.writeFieldBegin('num_pixel_samples', TType.I32, 2)
4494  oprot.writeI32(self.num_pixel_samples)
4495  oprot.writeFieldEnd()
4496  if self.pixels is not None:
4497  oprot.writeFieldBegin('pixels', TType.STRING, 3)
4498  oprot.writeBinary(self.pixels)
4499  oprot.writeFieldEnd()
4500  if self.row_ids_A is not None:
4501  oprot.writeFieldBegin('row_ids_A', TType.STRING, 4)
4502  oprot.writeBinary(self.row_ids_A)
4503  oprot.writeFieldEnd()
4504  if self.row_ids_B is not None:
4505  oprot.writeFieldBegin('row_ids_B', TType.STRING, 5)
4506  oprot.writeBinary(self.row_ids_B)
4507  oprot.writeFieldEnd()
4508  if self.table_ids is not None:
4509  oprot.writeFieldBegin('table_ids', TType.STRING, 6)
4510  oprot.writeBinary(self.table_ids)
4511  oprot.writeFieldEnd()
4512  if self.accum_data is not None:
4513  oprot.writeFieldBegin('accum_data', TType.STRING, 7)
4514  oprot.writeBinary(self.accum_data)
4515  oprot.writeFieldEnd()
4516  if self.accum_depth is not None:
4517  oprot.writeFieldBegin('accum_depth', TType.I32, 8)
4518  oprot.writeI32(self.accum_depth)
4519  oprot.writeFieldEnd()
4520  oprot.writeFieldStop()
4521  oprot.writeStructEnd()
4522 
4523  def validate(self):
4524  return
4525 
4526  def __repr__(self):
4527  L = ['%s=%r' % (key, value)
4528  for key, value in self.__dict__.items()]
4529  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4530 
4531  def __eq__(self, other):
4532  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4533 
4534  def __ne__(self, other):
4535  return not (self == other)
4536 
4537 
4538 class TRawPixelData(object):
4539  """
4540  Attributes:
4541  - width
4542  - height
4543  - render_pass_map
4544 
4545  """
4546 
4547 
4548  def __init__(self, width=None, height=None, render_pass_map=None,):
4549  self.width = width
4550  self.height = height
4551  self.render_pass_map = render_pass_map
4552 
4553  def read(self, iprot):
4554  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
4555  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
4556  return
4557  iprot.readStructBegin()
4558  while True:
4559  (fname, ftype, fid) = iprot.readFieldBegin()
4560  if ftype == TType.STOP:
4561  break
4562  if fid == 1:
4563  if ftype == TType.I32:
4564  self.width = iprot.readI32()
4565  else:
4566  iprot.skip(ftype)
4567  elif fid == 2:
4568  if ftype == TType.I32:
4569  self.height = iprot.readI32()
4570  else:
4571  iprot.skip(ftype)
4572  elif fid == 3:
4573  if ftype == TType.MAP:
4574  self.render_pass_map = {}
4575  (_ktype190, _vtype191, _size189) = iprot.readMapBegin()
4576  for _i193 in range(_size189):
4577  _key194 = iprot.readI32()
4578  _val195 = TRawRenderPassDataResult()
4579  _val195.read(iprot)
4580  self.render_pass_map[_key194] = _val195
4581  iprot.readMapEnd()
4582  else:
4583  iprot.skip(ftype)
4584  else:
4585  iprot.skip(ftype)
4586  iprot.readFieldEnd()
4587  iprot.readStructEnd()
4588 
4589  def write(self, oprot):
4590  if oprot._fast_encode is not None and self.thrift_spec is not None:
4591  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
4592  return
4593  oprot.writeStructBegin('TRawPixelData')
4594  if self.width is not None:
4595  oprot.writeFieldBegin('width', TType.I32, 1)
4596  oprot.writeI32(self.width)
4597  oprot.writeFieldEnd()
4598  if self.height is not None:
4599  oprot.writeFieldBegin('height', TType.I32, 2)
4600  oprot.writeI32(self.height)
4601  oprot.writeFieldEnd()
4602  if self.render_pass_map is not None:
4603  oprot.writeFieldBegin('render_pass_map', TType.MAP, 3)
4604  oprot.writeMapBegin(TType.I32, TType.STRUCT, len(self.render_pass_map))
4605  for kiter196, viter197 in self.render_pass_map.items():
4606  oprot.writeI32(kiter196)
4607  viter197.write(oprot)
4608  oprot.writeMapEnd()
4609  oprot.writeFieldEnd()
4610  oprot.writeFieldStop()
4611  oprot.writeStructEnd()
4612 
4613  def validate(self):
4614  return
4615 
4616  def __repr__(self):
4617  L = ['%s=%r' % (key, value)
4618  for key, value in self.__dict__.items()]
4619  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4620 
4621  def __eq__(self, other):
4622  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4623 
4624  def __ne__(self, other):
4625  return not (self == other)
4626 
4627 
4628 class TRenderDatum(object):
4629  """
4630  Attributes:
4631  - type
4632  - cnt
4633  - value
4634 
4635  """
4636 
4637 
4638  def __init__(self, type=None, cnt=None, value=None,):
4639  self.type = type
4640  self.cnt = cnt
4641  self.value = value
4642 
4643  def read(self, iprot):
4644  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
4645  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
4646  return
4647  iprot.readStructBegin()
4648  while True:
4649  (fname, ftype, fid) = iprot.readFieldBegin()
4650  if ftype == TType.STOP:
4651  break
4652  if fid == 1:
4653  if ftype == TType.I32:
4654  self.type = iprot.readI32()
4655  else:
4656  iprot.skip(ftype)
4657  elif fid == 2:
4658  if ftype == TType.I32:
4659  self.cnt = iprot.readI32()
4660  else:
4661  iprot.skip(ftype)
4662  elif fid == 3:
4663  if ftype == TType.STRING:
4664  self.value = iprot.readBinary()
4665  else:
4666  iprot.skip(ftype)
4667  else:
4668  iprot.skip(ftype)
4669  iprot.readFieldEnd()
4670  iprot.readStructEnd()
4671 
4672  def write(self, oprot):
4673  if oprot._fast_encode is not None and self.thrift_spec is not None:
4674  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
4675  return
4676  oprot.writeStructBegin('TRenderDatum')
4677  if self.type is not None:
4678  oprot.writeFieldBegin('type', TType.I32, 1)
4679  oprot.writeI32(self.type)
4680  oprot.writeFieldEnd()
4681  if self.cnt is not None:
4682  oprot.writeFieldBegin('cnt', TType.I32, 2)
4683  oprot.writeI32(self.cnt)
4684  oprot.writeFieldEnd()
4685  if self.value is not None:
4686  oprot.writeFieldBegin('value', TType.STRING, 3)
4687  oprot.writeBinary(self.value)
4688  oprot.writeFieldEnd()
4689  oprot.writeFieldStop()
4690  oprot.writeStructEnd()
4691 
4692  def validate(self):
4693  return
4694 
4695  def __repr__(self):
4696  L = ['%s=%r' % (key, value)
4697  for key, value in self.__dict__.items()]
4698  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4699 
4700  def __eq__(self, other):
4701  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4702 
4703  def __ne__(self, other):
4704  return not (self == other)
4705 
4706 
4707 class TRenderStepResult(object):
4708  """
4709  Attributes:
4710  - merge_data
4711  - raw_pixel_data
4712  - execution_time_ms
4713  - render_time_ms
4714  - total_time_ms
4715 
4716  """
4717 
4718 
4719  def __init__(self, merge_data=None, raw_pixel_data=None, execution_time_ms=None, render_time_ms=None, total_time_ms=None,):
4720  self.merge_data = merge_data
4721  self.raw_pixel_data = raw_pixel_data
4722  self.execution_time_ms = execution_time_ms
4723  self.render_time_ms = render_time_ms
4724  self.total_time_ms = total_time_ms
4725 
4726  def read(self, iprot):
4727  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
4728  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
4729  return
4730  iprot.readStructBegin()
4731  while True:
4732  (fname, ftype, fid) = iprot.readFieldBegin()
4733  if ftype == TType.STOP:
4734  break
4735  if fid == 1:
4736  if ftype == TType.MAP:
4737  self.merge_data = {}
4738  (_ktype199, _vtype200, _size198) = iprot.readMapBegin()
4739  for _i202 in range(_size198):
4740  _key203 = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
4741  _val204 = {}
4742  (_ktype206, _vtype207, _size205) = iprot.readMapBegin()
4743  for _i209 in range(_size205):
4744  _key210 = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
4745  _val211 = {}
4746  (_ktype213, _vtype214, _size212) = iprot.readMapBegin()
4747  for _i216 in range(_size212):
4748  _key217 = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
4749  _val218 = {}
4750  (_ktype220, _vtype221, _size219) = iprot.readMapBegin()
4751  for _i223 in range(_size219):
4752  _key224 = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
4753  _val225 = []
4754  (_etype229, _size226) = iprot.readListBegin()
4755  for _i230 in range(_size226):
4756  _elem231 = TRenderDatum()
4757  _elem231.read(iprot)
4758  _val225.append(_elem231)
4759  iprot.readListEnd()
4760  _val218[_key224] = _val225
4761  iprot.readMapEnd()
4762  _val211[_key217] = _val218
4763  iprot.readMapEnd()
4764  _val204[_key210] = _val211
4765  iprot.readMapEnd()
4766  self.merge_data[_key203] = _val204
4767  iprot.readMapEnd()
4768  else:
4769  iprot.skip(ftype)
4770  elif fid == 2:
4771  if ftype == TType.STRUCT:
4772  self.raw_pixel_data = TRawPixelData()
4773  self.raw_pixel_data.read(iprot)
4774  else:
4775  iprot.skip(ftype)
4776  elif fid == 3:
4777  if ftype == TType.I64:
4778  self.execution_time_ms = iprot.readI64()
4779  else:
4780  iprot.skip(ftype)
4781  elif fid == 4:
4782  if ftype == TType.I64:
4783  self.render_time_ms = iprot.readI64()
4784  else:
4785  iprot.skip(ftype)
4786  elif fid == 5:
4787  if ftype == TType.I64:
4788  self.total_time_ms = iprot.readI64()
4789  else:
4790  iprot.skip(ftype)
4791  else:
4792  iprot.skip(ftype)
4793  iprot.readFieldEnd()
4794  iprot.readStructEnd()
4795 
4796  def write(self, oprot):
4797  if oprot._fast_encode is not None and self.thrift_spec is not None:
4798  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
4799  return
4800  oprot.writeStructBegin('TRenderStepResult')
4801  if self.merge_data is not None:
4802  oprot.writeFieldBegin('merge_data', TType.MAP, 1)
4803  oprot.writeMapBegin(TType.STRING, TType.MAP, len(self.merge_data))
4804  for kiter232, viter233 in self.merge_data.items():
4805  oprot.writeString(kiter232.encode('utf-8') if sys.version_info[0] == 2 else kiter232)
4806  oprot.writeMapBegin(TType.STRING, TType.MAP, len(viter233))
4807  for kiter234, viter235 in viter233.items():
4808  oprot.writeString(kiter234.encode('utf-8') if sys.version_info[0] == 2 else kiter234)
4809  oprot.writeMapBegin(TType.STRING, TType.MAP, len(viter235))
4810  for kiter236, viter237 in viter235.items():
4811  oprot.writeString(kiter236.encode('utf-8') if sys.version_info[0] == 2 else kiter236)
4812  oprot.writeMapBegin(TType.STRING, TType.LIST, len(viter237))
4813  for kiter238, viter239 in viter237.items():
4814  oprot.writeString(kiter238.encode('utf-8') if sys.version_info[0] == 2 else kiter238)
4815  oprot.writeListBegin(TType.STRUCT, len(viter239))
4816  for iter240 in viter239:
4817  iter240.write(oprot)
4818  oprot.writeListEnd()
4819  oprot.writeMapEnd()
4820  oprot.writeMapEnd()
4821  oprot.writeMapEnd()
4822  oprot.writeMapEnd()
4823  oprot.writeFieldEnd()
4824  if self.raw_pixel_data is not None:
4825  oprot.writeFieldBegin('raw_pixel_data', TType.STRUCT, 2)
4826  self.raw_pixel_data.write(oprot)
4827  oprot.writeFieldEnd()
4828  if self.execution_time_ms is not None:
4829  oprot.writeFieldBegin('execution_time_ms', TType.I64, 3)
4830  oprot.writeI64(self.execution_time_ms)
4831  oprot.writeFieldEnd()
4832  if self.render_time_ms is not None:
4833  oprot.writeFieldBegin('render_time_ms', TType.I64, 4)
4834  oprot.writeI64(self.render_time_ms)
4835  oprot.writeFieldEnd()
4836  if self.total_time_ms is not None:
4837  oprot.writeFieldBegin('total_time_ms', TType.I64, 5)
4838  oprot.writeI64(self.total_time_ms)
4839  oprot.writeFieldEnd()
4840  oprot.writeFieldStop()
4841  oprot.writeStructEnd()
4842 
4843  def validate(self):
4844  return
4845 
4846  def __repr__(self):
4847  L = ['%s=%r' % (key, value)
4848  for key, value in self.__dict__.items()]
4849  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4850 
4851  def __eq__(self, other):
4852  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4853 
4854  def __ne__(self, other):
4855  return not (self == other)
4856 
4857 
4858 class TDatabasePermissions(object):
4859  """
4860  Attributes:
4861  - create_
4862  - delete_
4863  - view_sql_editor_
4864  - access_
4865 
4866  """
4867 
4868 
4869  def __init__(self, create_=None, delete_=None, view_sql_editor_=None, access_=None,):
4870  self.create_ = create_
4871  self.delete_ = delete_
4872  self.view_sql_editor_ = view_sql_editor_
4873  self.access_ = access_
4874 
4875  def read(self, iprot):
4876  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
4877  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
4878  return
4879  iprot.readStructBegin()
4880  while True:
4881  (fname, ftype, fid) = iprot.readFieldBegin()
4882  if ftype == TType.STOP:
4883  break
4884  if fid == 1:
4885  if ftype == TType.BOOL:
4886  self.create_ = iprot.readBool()
4887  else:
4888  iprot.skip(ftype)
4889  elif fid == 2:
4890  if ftype == TType.BOOL:
4891  self.delete_ = iprot.readBool()
4892  else:
4893  iprot.skip(ftype)
4894  elif fid == 3:
4895  if ftype == TType.BOOL:
4896  self.view_sql_editor_ = iprot.readBool()
4897  else:
4898  iprot.skip(ftype)
4899  elif fid == 4:
4900  if ftype == TType.BOOL:
4901  self.access_ = iprot.readBool()
4902  else:
4903  iprot.skip(ftype)
4904  else:
4905  iprot.skip(ftype)
4906  iprot.readFieldEnd()
4907  iprot.readStructEnd()
4908 
4909  def write(self, oprot):
4910  if oprot._fast_encode is not None and self.thrift_spec is not None:
4911  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
4912  return
4913  oprot.writeStructBegin('TDatabasePermissions')
4914  if self.create_ is not None:
4915  oprot.writeFieldBegin('create_', TType.BOOL, 1)
4916  oprot.writeBool(self.create_)
4917  oprot.writeFieldEnd()
4918  if self.delete_ is not None:
4919  oprot.writeFieldBegin('delete_', TType.BOOL, 2)
4920  oprot.writeBool(self.delete_)
4921  oprot.writeFieldEnd()
4922  if self.view_sql_editor_ is not None:
4923  oprot.writeFieldBegin('view_sql_editor_', TType.BOOL, 3)
4924  oprot.writeBool(self.view_sql_editor_)
4925  oprot.writeFieldEnd()
4926  if self.access_ is not None:
4927  oprot.writeFieldBegin('access_', TType.BOOL, 4)
4928  oprot.writeBool(self.access_)
4929  oprot.writeFieldEnd()
4930  oprot.writeFieldStop()
4931  oprot.writeStructEnd()
4932 
4933  def validate(self):
4934  return
4935 
4936  def __repr__(self):
4937  L = ['%s=%r' % (key, value)
4938  for key, value in self.__dict__.items()]
4939  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4940 
4941  def __eq__(self, other):
4942  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4943 
4944  def __ne__(self, other):
4945  return not (self == other)
4946 
4947 
4948 class TTablePermissions(object):
4949  """
4950  Attributes:
4951  - create_
4952  - drop_
4953  - select_
4954  - insert_
4955  - update_
4956  - delete_
4957  - truncate_
4958  - alter_
4959 
4960  """
4961 
4962 
4963  def __init__(self, create_=None, drop_=None, select_=None, insert_=None, update_=None, delete_=None, truncate_=None, alter_=None,):
4964  self.create_ = create_
4965  self.drop_ = drop_
4966  self.select_ = select_
4967  self.insert_ = insert_
4968  self.update_ = update_
4969  self.delete_ = delete_
4970  self.truncate_ = truncate_
4971  self.alter_ = alter_
4972 
4973  def read(self, iprot):
4974  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
4975  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
4976  return
4977  iprot.readStructBegin()
4978  while True:
4979  (fname, ftype, fid) = iprot.readFieldBegin()
4980  if ftype == TType.STOP:
4981  break
4982  if fid == 1:
4983  if ftype == TType.BOOL:
4984  self.create_ = iprot.readBool()
4985  else:
4986  iprot.skip(ftype)
4987  elif fid == 2:
4988  if ftype == TType.BOOL:
4989  self.drop_ = iprot.readBool()
4990  else:
4991  iprot.skip(ftype)
4992  elif fid == 3:
4993  if ftype == TType.BOOL:
4994  self.select_ = iprot.readBool()
4995  else:
4996  iprot.skip(ftype)
4997  elif fid == 4:
4998  if ftype == TType.BOOL:
4999  self.insert_ = iprot.readBool()
5000  else:
5001  iprot.skip(ftype)
5002  elif fid == 5:
5003  if ftype == TType.BOOL:
5004  self.update_ = iprot.readBool()
5005  else:
5006  iprot.skip(ftype)
5007  elif fid == 6:
5008  if ftype == TType.BOOL:
5009  self.delete_ = iprot.readBool()
5010  else:
5011  iprot.skip(ftype)
5012  elif fid == 7:
5013  if ftype == TType.BOOL:
5014  self.truncate_ = iprot.readBool()
5015  else:
5016  iprot.skip(ftype)
5017  elif fid == 8:
5018  if ftype == TType.BOOL:
5019  self.alter_ = iprot.readBool()
5020  else:
5021  iprot.skip(ftype)
5022  else:
5023  iprot.skip(ftype)
5024  iprot.readFieldEnd()
5025  iprot.readStructEnd()
5026 
5027  def write(self, oprot):
5028  if oprot._fast_encode is not None and self.thrift_spec is not None:
5029  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
5030  return
5031  oprot.writeStructBegin('TTablePermissions')
5032  if self.create_ is not None:
5033  oprot.writeFieldBegin('create_', TType.BOOL, 1)
5034  oprot.writeBool(self.create_)
5035  oprot.writeFieldEnd()
5036  if self.drop_ is not None:
5037  oprot.writeFieldBegin('drop_', TType.BOOL, 2)
5038  oprot.writeBool(self.drop_)
5039  oprot.writeFieldEnd()
5040  if self.select_ is not None:
5041  oprot.writeFieldBegin('select_', TType.BOOL, 3)
5042  oprot.writeBool(self.select_)
5043  oprot.writeFieldEnd()
5044  if self.insert_ is not None:
5045  oprot.writeFieldBegin('insert_', TType.BOOL, 4)
5046  oprot.writeBool(self.insert_)
5047  oprot.writeFieldEnd()
5048  if self.update_ is not None:
5049  oprot.writeFieldBegin('update_', TType.BOOL, 5)
5050  oprot.writeBool(self.update_)
5051  oprot.writeFieldEnd()
5052  if self.delete_ is not None:
5053  oprot.writeFieldBegin('delete_', TType.BOOL, 6)
5054  oprot.writeBool(self.delete_)
5055  oprot.writeFieldEnd()
5056  if self.truncate_ is not None:
5057  oprot.writeFieldBegin('truncate_', TType.BOOL, 7)
5058  oprot.writeBool(self.truncate_)
5059  oprot.writeFieldEnd()
5060  if self.alter_ is not None:
5061  oprot.writeFieldBegin('alter_', TType.BOOL, 8)
5062  oprot.writeBool(self.alter_)
5063  oprot.writeFieldEnd()
5064  oprot.writeFieldStop()
5065  oprot.writeStructEnd()
5066 
5067  def validate(self):
5068  return
5069 
5070  def __repr__(self):
5071  L = ['%s=%r' % (key, value)
5072  for key, value in self.__dict__.items()]
5073  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
5074 
5075  def __eq__(self, other):
5076  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
5077 
5078  def __ne__(self, other):
5079  return not (self == other)
5080 
5081 
5083  """
5084  Attributes:
5085  - create_
5086  - delete_
5087  - view_
5088  - edit_
5089 
5090  """
5091 
5092 
5093  def __init__(self, create_=None, delete_=None, view_=None, edit_=None,):
5094  self.create_ = create_
5095  self.delete_ = delete_
5096  self.view_ = view_
5097  self.edit_ = edit_
5098 
5099  def read(self, iprot):
5100  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
5101  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
5102  return
5103  iprot.readStructBegin()
5104  while True:
5105  (fname, ftype, fid) = iprot.readFieldBegin()
5106  if ftype == TType.STOP:
5107  break
5108  if fid == 1:
5109  if ftype == TType.BOOL:
5110  self.create_ = iprot.readBool()
5111  else:
5112  iprot.skip(ftype)
5113  elif fid == 2:
5114  if ftype == TType.BOOL:
5115  self.delete_ = iprot.readBool()
5116  else:
5117  iprot.skip(ftype)
5118  elif fid == 3:
5119  if ftype == TType.BOOL:
5120  self.view_ = iprot.readBool()
5121  else:
5122  iprot.skip(ftype)
5123  elif fid == 4:
5124  if ftype == TType.BOOL:
5125  self.edit_ = iprot.readBool()
5126  else:
5127  iprot.skip(ftype)
5128  else:
5129  iprot.skip(ftype)
5130  iprot.readFieldEnd()
5131  iprot.readStructEnd()
5132 
5133  def write(self, oprot):
5134  if oprot._fast_encode is not None and self.thrift_spec is not None:
5135  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
5136  return
5137  oprot.writeStructBegin('TDashboardPermissions')
5138  if self.create_ is not None:
5139  oprot.writeFieldBegin('create_', TType.BOOL, 1)
5140  oprot.writeBool(self.create_)
5141  oprot.writeFieldEnd()
5142  if self.delete_ is not None:
5143  oprot.writeFieldBegin('delete_', TType.BOOL, 2)
5144  oprot.writeBool(self.delete_)
5145  oprot.writeFieldEnd()
5146  if self.view_ is not None:
5147  oprot.writeFieldBegin('view_', TType.BOOL, 3)
5148  oprot.writeBool(self.view_)
5149  oprot.writeFieldEnd()
5150  if self.edit_ is not None:
5151  oprot.writeFieldBegin('edit_', TType.BOOL, 4)
5152  oprot.writeBool(self.edit_)
5153  oprot.writeFieldEnd()
5154  oprot.writeFieldStop()
5155  oprot.writeStructEnd()
5156 
5157  def validate(self):
5158  return
5159 
5160  def __repr__(self):
5161  L = ['%s=%r' % (key, value)
5162  for key, value in self.__dict__.items()]
5163  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
5164 
5165  def __eq__(self, other):
5166  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
5167 
5168  def __ne__(self, other):
5169  return not (self == other)
5170 
5171 
5172 class TViewPermissions(object):
5173  """
5174  Attributes:
5175  - create_
5176  - drop_
5177  - select_
5178  - insert_
5179  - update_
5180  - delete_
5181 
5182  """
5183 
5184 
5185  def __init__(self, create_=None, drop_=None, select_=None, insert_=None, update_=None, delete_=None,):
5186  self.create_ = create_
5187  self.drop_ = drop_
5188  self.select_ = select_
5189  self.insert_ = insert_
5190  self.update_ = update_
5191  self.delete_ = delete_
5192 
5193  def read(self, iprot):
5194  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
5195  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
5196  return
5197  iprot.readStructBegin()
5198  while