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