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