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