OmniSciDB  cde582ebc3
 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_username
1814  - odbc_password
1815  - odbc_credential_string
1816  - add_metadata_columns
1817 
1818  """
1819 
1820 
1821  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_username=None, odbc_password=None, odbc_credential_string=None, add_metadata_columns=None,):
1822  self.delimiter = delimiter
1823  self.null_str = null_str
1824  self.has_header = has_header
1825  self.quoted = quoted
1826  self.quote = quote
1827  self.escape = escape
1828  self.line_delim = line_delim
1829  self.array_delim = array_delim
1830  self.array_begin = array_begin
1831  self.array_end = array_end
1832  self.threads = threads
1833  self.source_type = source_type
1834  self.s3_access_key = s3_access_key
1835  self.s3_secret_key = s3_secret_key
1836  self.s3_region = s3_region
1837  self.geo_coords_encoding = geo_coords_encoding
1838  self.geo_coords_comp_param = geo_coords_comp_param
1839  self.geo_coords_type = geo_coords_type
1840  self.geo_coords_srid = geo_coords_srid
1841  self.sanitize_column_names = sanitize_column_names
1842  self.geo_layer_name = geo_layer_name
1843  self.s3_endpoint = s3_endpoint
1844  self.geo_assign_render_groups = geo_assign_render_groups
1845  self.geo_explode_collections = geo_explode_collections
1846  self.source_srid = source_srid
1847  self.s3_session_token = s3_session_token
1848  self.raster_point_type = raster_point_type
1849  self.raster_import_bands = raster_import_bands
1850  self.raster_scanlines_per_thread = raster_scanlines_per_thread
1851  self.raster_point_transform = raster_point_transform
1852  self.raster_point_compute_angle = raster_point_compute_angle
1853  self.raster_import_dimensions = raster_import_dimensions
1854  self.odbc_dsn = odbc_dsn
1855  self.odbc_connection_string = odbc_connection_string
1856  self.odbc_sql_select = odbc_sql_select
1857  self.odbc_username = odbc_username
1858  self.odbc_password = odbc_password
1859  self.odbc_credential_string = odbc_credential_string
1860  self.add_metadata_columns = add_metadata_columns
1861 
1862  def read(self, iprot):
1863  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
1864  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
1865  return
1866  iprot.readStructBegin()
1867  while True:
1868  (fname, ftype, fid) = iprot.readFieldBegin()
1869  if ftype == TType.STOP:
1870  break
1871  if fid == 1:
1872  if ftype == TType.STRING:
1873  self.delimiter = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
1874  else:
1875  iprot.skip(ftype)
1876  elif fid == 2:
1877  if ftype == TType.STRING:
1878  self.null_str = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
1879  else:
1880  iprot.skip(ftype)
1881  elif fid == 3:
1882  if ftype == TType.I32:
1883  self.has_header = iprot.readI32()
1884  else:
1885  iprot.skip(ftype)
1886  elif fid == 4:
1887  if ftype == TType.BOOL:
1888  self.quoted = iprot.readBool()
1889  else:
1890  iprot.skip(ftype)
1891  elif fid == 5:
1892  if ftype == TType.STRING:
1893  self.quote = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
1894  else:
1895  iprot.skip(ftype)
1896  elif fid == 6:
1897  if ftype == TType.STRING:
1898  self.escape = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
1899  else:
1900  iprot.skip(ftype)
1901  elif fid == 7:
1902  if ftype == TType.STRING:
1903  self.line_delim = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
1904  else:
1905  iprot.skip(ftype)
1906  elif fid == 8:
1907  if ftype == TType.STRING:
1908  self.array_delim = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
1909  else:
1910  iprot.skip(ftype)
1911  elif fid == 9:
1912  if ftype == TType.STRING:
1913  self.array_begin = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
1914  else:
1915  iprot.skip(ftype)
1916  elif fid == 10:
1917  if ftype == TType.STRING:
1918  self.array_end = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
1919  else:
1920  iprot.skip(ftype)
1921  elif fid == 11:
1922  if ftype == TType.I32:
1923  self.threads = iprot.readI32()
1924  else:
1925  iprot.skip(ftype)
1926  elif fid == 12:
1927  if ftype == TType.I32:
1928  self.source_type = iprot.readI32()
1929  else:
1930  iprot.skip(ftype)
1931  elif fid == 13:
1932  if ftype == TType.STRING:
1933  self.s3_access_key = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
1934  else:
1935  iprot.skip(ftype)
1936  elif fid == 14:
1937  if ftype == TType.STRING:
1938  self.s3_secret_key = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
1939  else:
1940  iprot.skip(ftype)
1941  elif fid == 15:
1942  if ftype == TType.STRING:
1943  self.s3_region = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
1944  else:
1945  iprot.skip(ftype)
1946  elif fid == 16:
1947  if ftype == TType.I32:
1948  self.geo_coords_encoding = iprot.readI32()
1949  else:
1950  iprot.skip(ftype)
1951  elif fid == 17:
1952  if ftype == TType.I32:
1953  self.geo_coords_comp_param = iprot.readI32()
1954  else:
1955  iprot.skip(ftype)
1956  elif fid == 18:
1957  if ftype == TType.I32:
1958  self.geo_coords_type = iprot.readI32()
1959  else:
1960  iprot.skip(ftype)
1961  elif fid == 19:
1962  if ftype == TType.I32:
1963  self.geo_coords_srid = iprot.readI32()
1964  else:
1965  iprot.skip(ftype)
1966  elif fid == 20:
1967  if ftype == TType.BOOL:
1968  self.sanitize_column_names = iprot.readBool()
1969  else:
1970  iprot.skip(ftype)
1971  elif fid == 21:
1972  if ftype == TType.STRING:
1973  self.geo_layer_name = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
1974  else:
1975  iprot.skip(ftype)
1976  elif fid == 22:
1977  if ftype == TType.STRING:
1978  self.s3_endpoint = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
1979  else:
1980  iprot.skip(ftype)
1981  elif fid == 23:
1982  if ftype == TType.BOOL:
1983  self.geo_assign_render_groups = iprot.readBool()
1984  else:
1985  iprot.skip(ftype)
1986  elif fid == 24:
1987  if ftype == TType.BOOL:
1988  self.geo_explode_collections = iprot.readBool()
1989  else:
1990  iprot.skip(ftype)
1991  elif fid == 25:
1992  if ftype == TType.I32:
1993  self.source_srid = iprot.readI32()
1994  else:
1995  iprot.skip(ftype)
1996  elif fid == 26:
1997  if ftype == TType.STRING:
1998  self.s3_session_token = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
1999  else:
2000  iprot.skip(ftype)
2001  elif fid == 27:
2002  if ftype == TType.I32:
2003  self.raster_point_type = iprot.readI32()
2004  else:
2005  iprot.skip(ftype)
2006  elif fid == 28:
2007  if ftype == TType.STRING:
2008  self.raster_import_bands = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2009  else:
2010  iprot.skip(ftype)
2011  elif fid == 29:
2012  if ftype == TType.I32:
2013  self.raster_scanlines_per_thread = iprot.readI32()
2014  else:
2015  iprot.skip(ftype)
2016  elif fid == 30:
2017  if ftype == TType.I32:
2018  self.raster_point_transform = iprot.readI32()
2019  else:
2020  iprot.skip(ftype)
2021  elif fid == 31:
2022  if ftype == TType.BOOL:
2023  self.raster_point_compute_angle = iprot.readBool()
2024  else:
2025  iprot.skip(ftype)
2026  elif fid == 32:
2027  if ftype == TType.STRING:
2028  self.raster_import_dimensions = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2029  else:
2030  iprot.skip(ftype)
2031  elif fid == 33:
2032  if ftype == TType.STRING:
2033  self.odbc_dsn = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2034  else:
2035  iprot.skip(ftype)
2036  elif fid == 34:
2037  if ftype == TType.STRING:
2038  self.odbc_connection_string = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2039  else:
2040  iprot.skip(ftype)
2041  elif fid == 35:
2042  if ftype == TType.STRING:
2043  self.odbc_sql_select = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2044  else:
2045  iprot.skip(ftype)
2046  elif fid == 36:
2047  if ftype == TType.STRING:
2048  self.odbc_username = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2049  else:
2050  iprot.skip(ftype)
2051  elif fid == 37:
2052  if ftype == TType.STRING:
2053  self.odbc_password = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2054  else:
2055  iprot.skip(ftype)
2056  elif fid == 38:
2057  if ftype == TType.STRING:
2058  self.odbc_credential_string = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2059  else:
2060  iprot.skip(ftype)
2061  elif fid == 39:
2062  if ftype == TType.STRING:
2063  self.add_metadata_columns = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2064  else:
2065  iprot.skip(ftype)
2066  else:
2067  iprot.skip(ftype)
2068  iprot.readFieldEnd()
2069  iprot.readStructEnd()
2070 
2071  def write(self, oprot):
2072  if oprot._fast_encode is not None and self.thrift_spec is not None:
2073  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
2074  return
2075  oprot.writeStructBegin('TCopyParams')
2076  if self.delimiter is not None:
2077  oprot.writeFieldBegin('delimiter', TType.STRING, 1)
2078  oprot.writeString(self.delimiter.encode('utf-8') if sys.version_info[0] == 2 else self.delimiter)
2079  oprot.writeFieldEnd()
2080  if self.null_str is not None:
2081  oprot.writeFieldBegin('null_str', TType.STRING, 2)
2082  oprot.writeString(self.null_str.encode('utf-8') if sys.version_info[0] == 2 else self.null_str)
2083  oprot.writeFieldEnd()
2084  if self.has_header is not None:
2085  oprot.writeFieldBegin('has_header', TType.I32, 3)
2086  oprot.writeI32(self.has_header)
2087  oprot.writeFieldEnd()
2088  if self.quoted is not None:
2089  oprot.writeFieldBegin('quoted', TType.BOOL, 4)
2090  oprot.writeBool(self.quoted)
2091  oprot.writeFieldEnd()
2092  if self.quote is not None:
2093  oprot.writeFieldBegin('quote', TType.STRING, 5)
2094  oprot.writeString(self.quote.encode('utf-8') if sys.version_info[0] == 2 else self.quote)
2095  oprot.writeFieldEnd()
2096  if self.escape is not None:
2097  oprot.writeFieldBegin('escape', TType.STRING, 6)
2098  oprot.writeString(self.escape.encode('utf-8') if sys.version_info[0] == 2 else self.escape)
2099  oprot.writeFieldEnd()
2100  if self.line_delim is not None:
2101  oprot.writeFieldBegin('line_delim', TType.STRING, 7)
2102  oprot.writeString(self.line_delim.encode('utf-8') if sys.version_info[0] == 2 else self.line_delim)
2103  oprot.writeFieldEnd()
2104  if self.array_delim is not None:
2105  oprot.writeFieldBegin('array_delim', TType.STRING, 8)
2106  oprot.writeString(self.array_delim.encode('utf-8') if sys.version_info[0] == 2 else self.array_delim)
2107  oprot.writeFieldEnd()
2108  if self.array_begin is not None:
2109  oprot.writeFieldBegin('array_begin', TType.STRING, 9)
2110  oprot.writeString(self.array_begin.encode('utf-8') if sys.version_info[0] == 2 else self.array_begin)
2111  oprot.writeFieldEnd()
2112  if self.array_end is not None:
2113  oprot.writeFieldBegin('array_end', TType.STRING, 10)
2114  oprot.writeString(self.array_end.encode('utf-8') if sys.version_info[0] == 2 else self.array_end)
2115  oprot.writeFieldEnd()
2116  if self.threads is not None:
2117  oprot.writeFieldBegin('threads', TType.I32, 11)
2118  oprot.writeI32(self.threads)
2119  oprot.writeFieldEnd()
2120  if self.source_type is not None:
2121  oprot.writeFieldBegin('source_type', TType.I32, 12)
2122  oprot.writeI32(self.source_type)
2123  oprot.writeFieldEnd()
2124  if self.s3_access_key is not None:
2125  oprot.writeFieldBegin('s3_access_key', TType.STRING, 13)
2126  oprot.writeString(self.s3_access_key.encode('utf-8') if sys.version_info[0] == 2 else self.s3_access_key)
2127  oprot.writeFieldEnd()
2128  if self.s3_secret_key is not None:
2129  oprot.writeFieldBegin('s3_secret_key', TType.STRING, 14)
2130  oprot.writeString(self.s3_secret_key.encode('utf-8') if sys.version_info[0] == 2 else self.s3_secret_key)
2131  oprot.writeFieldEnd()
2132  if self.s3_region is not None:
2133  oprot.writeFieldBegin('s3_region', TType.STRING, 15)
2134  oprot.writeString(self.s3_region.encode('utf-8') if sys.version_info[0] == 2 else self.s3_region)
2135  oprot.writeFieldEnd()
2136  if self.geo_coords_encoding is not None:
2137  oprot.writeFieldBegin('geo_coords_encoding', TType.I32, 16)
2138  oprot.writeI32(self.geo_coords_encoding)
2139  oprot.writeFieldEnd()
2140  if self.geo_coords_comp_param is not None:
2141  oprot.writeFieldBegin('geo_coords_comp_param', TType.I32, 17)
2142  oprot.writeI32(self.geo_coords_comp_param)
2143  oprot.writeFieldEnd()
2144  if self.geo_coords_type is not None:
2145  oprot.writeFieldBegin('geo_coords_type', TType.I32, 18)
2146  oprot.writeI32(self.geo_coords_type)
2147  oprot.writeFieldEnd()
2148  if self.geo_coords_srid is not None:
2149  oprot.writeFieldBegin('geo_coords_srid', TType.I32, 19)
2150  oprot.writeI32(self.geo_coords_srid)
2151  oprot.writeFieldEnd()
2152  if self.sanitize_column_names is not None:
2153  oprot.writeFieldBegin('sanitize_column_names', TType.BOOL, 20)
2154  oprot.writeBool(self.sanitize_column_names)
2155  oprot.writeFieldEnd()
2156  if self.geo_layer_name is not None:
2157  oprot.writeFieldBegin('geo_layer_name', TType.STRING, 21)
2158  oprot.writeString(self.geo_layer_name.encode('utf-8') if sys.version_info[0] == 2 else self.geo_layer_name)
2159  oprot.writeFieldEnd()
2160  if self.s3_endpoint is not None:
2161  oprot.writeFieldBegin('s3_endpoint', TType.STRING, 22)
2162  oprot.writeString(self.s3_endpoint.encode('utf-8') if sys.version_info[0] == 2 else self.s3_endpoint)
2163  oprot.writeFieldEnd()
2164  if self.geo_assign_render_groups is not None:
2165  oprot.writeFieldBegin('geo_assign_render_groups', TType.BOOL, 23)
2166  oprot.writeBool(self.geo_assign_render_groups)
2167  oprot.writeFieldEnd()
2168  if self.geo_explode_collections is not None:
2169  oprot.writeFieldBegin('geo_explode_collections', TType.BOOL, 24)
2170  oprot.writeBool(self.geo_explode_collections)
2171  oprot.writeFieldEnd()
2172  if self.source_srid is not None:
2173  oprot.writeFieldBegin('source_srid', TType.I32, 25)
2174  oprot.writeI32(self.source_srid)
2175  oprot.writeFieldEnd()
2176  if self.s3_session_token is not None:
2177  oprot.writeFieldBegin('s3_session_token', TType.STRING, 26)
2178  oprot.writeString(self.s3_session_token.encode('utf-8') if sys.version_info[0] == 2 else self.s3_session_token)
2179  oprot.writeFieldEnd()
2180  if self.raster_point_type is not None:
2181  oprot.writeFieldBegin('raster_point_type', TType.I32, 27)
2182  oprot.writeI32(self.raster_point_type)
2183  oprot.writeFieldEnd()
2184  if self.raster_import_bands is not None:
2185  oprot.writeFieldBegin('raster_import_bands', TType.STRING, 28)
2186  oprot.writeString(self.raster_import_bands.encode('utf-8') if sys.version_info[0] == 2 else self.raster_import_bands)
2187  oprot.writeFieldEnd()
2188  if self.raster_scanlines_per_thread is not None:
2189  oprot.writeFieldBegin('raster_scanlines_per_thread', TType.I32, 29)
2190  oprot.writeI32(self.raster_scanlines_per_thread)
2191  oprot.writeFieldEnd()
2192  if self.raster_point_transform is not None:
2193  oprot.writeFieldBegin('raster_point_transform', TType.I32, 30)
2194  oprot.writeI32(self.raster_point_transform)
2195  oprot.writeFieldEnd()
2196  if self.raster_point_compute_angle is not None:
2197  oprot.writeFieldBegin('raster_point_compute_angle', TType.BOOL, 31)
2198  oprot.writeBool(self.raster_point_compute_angle)
2199  oprot.writeFieldEnd()
2200  if self.raster_import_dimensions is not None:
2201  oprot.writeFieldBegin('raster_import_dimensions', TType.STRING, 32)
2202  oprot.writeString(self.raster_import_dimensions.encode('utf-8') if sys.version_info[0] == 2 else self.raster_import_dimensions)
2203  oprot.writeFieldEnd()
2204  if self.odbc_dsn is not None:
2205  oprot.writeFieldBegin('odbc_dsn', TType.STRING, 33)
2206  oprot.writeString(self.odbc_dsn.encode('utf-8') if sys.version_info[0] == 2 else self.odbc_dsn)
2207  oprot.writeFieldEnd()
2208  if self.odbc_connection_string is not None:
2209  oprot.writeFieldBegin('odbc_connection_string', TType.STRING, 34)
2210  oprot.writeString(self.odbc_connection_string.encode('utf-8') if sys.version_info[0] == 2 else self.odbc_connection_string)
2211  oprot.writeFieldEnd()
2212  if self.odbc_sql_select is not None:
2213  oprot.writeFieldBegin('odbc_sql_select', TType.STRING, 35)
2214  oprot.writeString(self.odbc_sql_select.encode('utf-8') if sys.version_info[0] == 2 else self.odbc_sql_select)
2215  oprot.writeFieldEnd()
2216  if self.odbc_username is not None:
2217  oprot.writeFieldBegin('odbc_username', TType.STRING, 36)
2218  oprot.writeString(self.odbc_username.encode('utf-8') if sys.version_info[0] == 2 else self.odbc_username)
2219  oprot.writeFieldEnd()
2220  if self.odbc_password is not None:
2221  oprot.writeFieldBegin('odbc_password', TType.STRING, 37)
2222  oprot.writeString(self.odbc_password.encode('utf-8') if sys.version_info[0] == 2 else self.odbc_password)
2223  oprot.writeFieldEnd()
2224  if self.odbc_credential_string is not None:
2225  oprot.writeFieldBegin('odbc_credential_string', TType.STRING, 38)
2226  oprot.writeString(self.odbc_credential_string.encode('utf-8') if sys.version_info[0] == 2 else self.odbc_credential_string)
2227  oprot.writeFieldEnd()
2228  if self.add_metadata_columns is not None:
2229  oprot.writeFieldBegin('add_metadata_columns', TType.STRING, 39)
2230  oprot.writeString(self.add_metadata_columns.encode('utf-8') if sys.version_info[0] == 2 else self.add_metadata_columns)
2231  oprot.writeFieldEnd()
2232  oprot.writeFieldStop()
2233  oprot.writeStructEnd()
2234 
2235  def validate(self):
2236  return
2237 
2238  def __repr__(self):
2239  L = ['%s=%r' % (key, value)
2240  for key, value in self.__dict__.items()]
2241  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2242 
2243  def __eq__(self, other):
2244  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2245 
2246  def __ne__(self, other):
2247  return not (self == other)
2248 
2249 
2250 class TCreateParams(object):
2251  """
2252  Attributes:
2253  - is_replicated
2254 
2255  """
2256 
2257 
2258  def __init__(self, is_replicated=None,):
2259  self.is_replicated = is_replicated
2260 
2261  def read(self, iprot):
2262  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
2263  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
2264  return
2265  iprot.readStructBegin()
2266  while True:
2267  (fname, ftype, fid) = iprot.readFieldBegin()
2268  if ftype == TType.STOP:
2269  break
2270  if fid == 1:
2271  if ftype == TType.BOOL:
2272  self.is_replicated = iprot.readBool()
2273  else:
2274  iprot.skip(ftype)
2275  else:
2276  iprot.skip(ftype)
2277  iprot.readFieldEnd()
2278  iprot.readStructEnd()
2279 
2280  def write(self, oprot):
2281  if oprot._fast_encode is not None and self.thrift_spec is not None:
2282  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
2283  return
2284  oprot.writeStructBegin('TCreateParams')
2285  if self.is_replicated is not None:
2286  oprot.writeFieldBegin('is_replicated', TType.BOOL, 1)
2287  oprot.writeBool(self.is_replicated)
2288  oprot.writeFieldEnd()
2289  oprot.writeFieldStop()
2290  oprot.writeStructEnd()
2291 
2292  def validate(self):
2293  return
2294 
2295  def __repr__(self):
2296  L = ['%s=%r' % (key, value)
2297  for key, value in self.__dict__.items()]
2298  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2299 
2300  def __eq__(self, other):
2301  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2302 
2303  def __ne__(self, other):
2304  return not (self == other)
2305 
2306 
2307 class TDetectResult(object):
2308  """
2309  Attributes:
2310  - row_set
2311  - copy_params
2312 
2313  """
2314 
2315 
2316  def __init__(self, row_set=None, copy_params=None,):
2317  self.row_set = row_set
2318  self.copy_params = copy_params
2319 
2320  def read(self, iprot):
2321  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
2322  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
2323  return
2324  iprot.readStructBegin()
2325  while True:
2326  (fname, ftype, fid) = iprot.readFieldBegin()
2327  if ftype == TType.STOP:
2328  break
2329  if fid == 1:
2330  if ftype == TType.STRUCT:
2331  self.row_set = TRowSet()
2332  self.row_set.read(iprot)
2333  else:
2334  iprot.skip(ftype)
2335  elif fid == 2:
2336  if ftype == TType.STRUCT:
2337  self.copy_params = TCopyParams()
2338  self.copy_params.read(iprot)
2339  else:
2340  iprot.skip(ftype)
2341  else:
2342  iprot.skip(ftype)
2343  iprot.readFieldEnd()
2344  iprot.readStructEnd()
2345 
2346  def write(self, oprot):
2347  if oprot._fast_encode is not None and self.thrift_spec is not None:
2348  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
2349  return
2350  oprot.writeStructBegin('TDetectResult')
2351  if self.row_set is not None:
2352  oprot.writeFieldBegin('row_set', TType.STRUCT, 1)
2353  self.row_set.write(oprot)
2354  oprot.writeFieldEnd()
2355  if self.copy_params is not None:
2356  oprot.writeFieldBegin('copy_params', TType.STRUCT, 2)
2357  self.copy_params.write(oprot)
2358  oprot.writeFieldEnd()
2359  oprot.writeFieldStop()
2360  oprot.writeStructEnd()
2361 
2362  def validate(self):
2363  return
2364 
2365  def __repr__(self):
2366  L = ['%s=%r' % (key, value)
2367  for key, value in self.__dict__.items()]
2368  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2369 
2370  def __eq__(self, other):
2371  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2372 
2373  def __ne__(self, other):
2374  return not (self == other)
2375 
2376 
2377 class TImportStatus(object):
2378  """
2379  Attributes:
2380  - elapsed
2381  - rows_completed
2382  - rows_estimated
2383  - rows_rejected
2384 
2385  """
2386 
2387 
2388  def __init__(self, elapsed=None, rows_completed=None, rows_estimated=None, rows_rejected=None,):
2389  self.elapsed = elapsed
2390  self.rows_completed = rows_completed
2391  self.rows_estimated = rows_estimated
2392  self.rows_rejected = rows_rejected
2393 
2394  def read(self, iprot):
2395  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
2396  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
2397  return
2398  iprot.readStructBegin()
2399  while True:
2400  (fname, ftype, fid) = iprot.readFieldBegin()
2401  if ftype == TType.STOP:
2402  break
2403  if fid == 1:
2404  if ftype == TType.I64:
2405  self.elapsed = iprot.readI64()
2406  else:
2407  iprot.skip(ftype)
2408  elif fid == 2:
2409  if ftype == TType.I64:
2410  self.rows_completed = iprot.readI64()
2411  else:
2412  iprot.skip(ftype)
2413  elif fid == 3:
2414  if ftype == TType.I64:
2415  self.rows_estimated = iprot.readI64()
2416  else:
2417  iprot.skip(ftype)
2418  elif fid == 4:
2419  if ftype == TType.I64:
2420  self.rows_rejected = iprot.readI64()
2421  else:
2422  iprot.skip(ftype)
2423  else:
2424  iprot.skip(ftype)
2425  iprot.readFieldEnd()
2426  iprot.readStructEnd()
2427 
2428  def write(self, oprot):
2429  if oprot._fast_encode is not None and self.thrift_spec is not None:
2430  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
2431  return
2432  oprot.writeStructBegin('TImportStatus')
2433  if self.elapsed is not None:
2434  oprot.writeFieldBegin('elapsed', TType.I64, 1)
2435  oprot.writeI64(self.elapsed)
2436  oprot.writeFieldEnd()
2437  if self.rows_completed is not None:
2438  oprot.writeFieldBegin('rows_completed', TType.I64, 2)
2439  oprot.writeI64(self.rows_completed)
2440  oprot.writeFieldEnd()
2441  if self.rows_estimated is not None:
2442  oprot.writeFieldBegin('rows_estimated', TType.I64, 3)
2443  oprot.writeI64(self.rows_estimated)
2444  oprot.writeFieldEnd()
2445  if self.rows_rejected is not None:
2446  oprot.writeFieldBegin('rows_rejected', TType.I64, 4)
2447  oprot.writeI64(self.rows_rejected)
2448  oprot.writeFieldEnd()
2449  oprot.writeFieldStop()
2450  oprot.writeStructEnd()
2451 
2452  def validate(self):
2453  return
2454 
2455  def __repr__(self):
2456  L = ['%s=%r' % (key, value)
2457  for key, value in self.__dict__.items()]
2458  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2459 
2460  def __eq__(self, other):
2461  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2462 
2463  def __ne__(self, other):
2464  return not (self == other)
2465 
2466 
2467 class TFrontendView(object):
2468  """
2469  Attributes:
2470  - view_name
2471  - view_state
2472  - image_hash
2473  - update_time
2474  - view_metadata
2475 
2476  """
2477 
2478 
2479  def __init__(self, view_name=None, view_state=None, image_hash=None, update_time=None, view_metadata=None,):
2480  self.view_name = view_name
2481  self.view_state = view_state
2482  self.image_hash = image_hash
2483  self.update_time = update_time
2484  self.view_metadata = view_metadata
2485 
2486  def read(self, iprot):
2487  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
2488  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
2489  return
2490  iprot.readStructBegin()
2491  while True:
2492  (fname, ftype, fid) = iprot.readFieldBegin()
2493  if ftype == TType.STOP:
2494  break
2495  if fid == 1:
2496  if ftype == TType.STRING:
2497  self.view_name = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2498  else:
2499  iprot.skip(ftype)
2500  elif fid == 2:
2501  if ftype == TType.STRING:
2502  self.view_state = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2503  else:
2504  iprot.skip(ftype)
2505  elif fid == 3:
2506  if ftype == TType.STRING:
2507  self.image_hash = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2508  else:
2509  iprot.skip(ftype)
2510  elif fid == 4:
2511  if ftype == TType.STRING:
2512  self.update_time = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2513  else:
2514  iprot.skip(ftype)
2515  elif fid == 5:
2516  if ftype == TType.STRING:
2517  self.view_metadata = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2518  else:
2519  iprot.skip(ftype)
2520  else:
2521  iprot.skip(ftype)
2522  iprot.readFieldEnd()
2523  iprot.readStructEnd()
2524 
2525  def write(self, oprot):
2526  if oprot._fast_encode is not None and self.thrift_spec is not None:
2527  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
2528  return
2529  oprot.writeStructBegin('TFrontendView')
2530  if self.view_name is not None:
2531  oprot.writeFieldBegin('view_name', TType.STRING, 1)
2532  oprot.writeString(self.view_name.encode('utf-8') if sys.version_info[0] == 2 else self.view_name)
2533  oprot.writeFieldEnd()
2534  if self.view_state is not None:
2535  oprot.writeFieldBegin('view_state', TType.STRING, 2)
2536  oprot.writeString(self.view_state.encode('utf-8') if sys.version_info[0] == 2 else self.view_state)
2537  oprot.writeFieldEnd()
2538  if self.image_hash is not None:
2539  oprot.writeFieldBegin('image_hash', TType.STRING, 3)
2540  oprot.writeString(self.image_hash.encode('utf-8') if sys.version_info[0] == 2 else self.image_hash)
2541  oprot.writeFieldEnd()
2542  if self.update_time is not None:
2543  oprot.writeFieldBegin('update_time', TType.STRING, 4)
2544  oprot.writeString(self.update_time.encode('utf-8') if sys.version_info[0] == 2 else self.update_time)
2545  oprot.writeFieldEnd()
2546  if self.view_metadata is not None:
2547  oprot.writeFieldBegin('view_metadata', TType.STRING, 5)
2548  oprot.writeString(self.view_metadata.encode('utf-8') if sys.version_info[0] == 2 else self.view_metadata)
2549  oprot.writeFieldEnd()
2550  oprot.writeFieldStop()
2551  oprot.writeStructEnd()
2552 
2553  def validate(self):
2554  return
2555 
2556  def __repr__(self):
2557  L = ['%s=%r' % (key, value)
2558  for key, value in self.__dict__.items()]
2559  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2560 
2561  def __eq__(self, other):
2562  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2563 
2564  def __ne__(self, other):
2565  return not (self == other)
2566 
2567 
2568 class TServerStatus(object):
2569  """
2570  Attributes:
2571  - read_only
2572  - version
2573  - rendering_enabled
2574  - start_time
2575  - edition
2576  - host_name
2577  - poly_rendering_enabled
2578  - role
2579  - renderer_status_json
2580 
2581  """
2582 
2583 
2584  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,):
2585  self.read_only = read_only
2586  self.version = version
2587  self.rendering_enabled = rendering_enabled
2588  self.start_time = start_time
2589  self.edition = edition
2590  self.host_name = host_name
2591  self.poly_rendering_enabled = poly_rendering_enabled
2592  self.role = role
2593  self.renderer_status_json = renderer_status_json
2594 
2595  def read(self, iprot):
2596  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
2597  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
2598  return
2599  iprot.readStructBegin()
2600  while True:
2601  (fname, ftype, fid) = iprot.readFieldBegin()
2602  if ftype == TType.STOP:
2603  break
2604  if fid == 1:
2605  if ftype == TType.BOOL:
2606  self.read_only = iprot.readBool()
2607  else:
2608  iprot.skip(ftype)
2609  elif fid == 2:
2610  if ftype == TType.STRING:
2611  self.version = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2612  else:
2613  iprot.skip(ftype)
2614  elif fid == 3:
2615  if ftype == TType.BOOL:
2616  self.rendering_enabled = iprot.readBool()
2617  else:
2618  iprot.skip(ftype)
2619  elif fid == 4:
2620  if ftype == TType.I64:
2621  self.start_time = iprot.readI64()
2622  else:
2623  iprot.skip(ftype)
2624  elif fid == 5:
2625  if ftype == TType.STRING:
2626  self.edition = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2627  else:
2628  iprot.skip(ftype)
2629  elif fid == 6:
2630  if ftype == TType.STRING:
2631  self.host_name = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2632  else:
2633  iprot.skip(ftype)
2634  elif fid == 7:
2635  if ftype == TType.BOOL:
2636  self.poly_rendering_enabled = iprot.readBool()
2637  else:
2638  iprot.skip(ftype)
2639  elif fid == 8:
2640  if ftype == TType.I32:
2641  self.role = iprot.readI32()
2642  else:
2643  iprot.skip(ftype)
2644  elif fid == 9:
2645  if ftype == TType.STRING:
2646  self.renderer_status_json = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2647  else:
2648  iprot.skip(ftype)
2649  else:
2650  iprot.skip(ftype)
2651  iprot.readFieldEnd()
2652  iprot.readStructEnd()
2653 
2654  def write(self, oprot):
2655  if oprot._fast_encode is not None and self.thrift_spec is not None:
2656  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
2657  return
2658  oprot.writeStructBegin('TServerStatus')
2659  if self.read_only is not None:
2660  oprot.writeFieldBegin('read_only', TType.BOOL, 1)
2661  oprot.writeBool(self.read_only)
2662  oprot.writeFieldEnd()
2663  if self.version is not None:
2664  oprot.writeFieldBegin('version', TType.STRING, 2)
2665  oprot.writeString(self.version.encode('utf-8') if sys.version_info[0] == 2 else self.version)
2666  oprot.writeFieldEnd()
2667  if self.rendering_enabled is not None:
2668  oprot.writeFieldBegin('rendering_enabled', TType.BOOL, 3)
2669  oprot.writeBool(self.rendering_enabled)
2670  oprot.writeFieldEnd()
2671  if self.start_time is not None:
2672  oprot.writeFieldBegin('start_time', TType.I64, 4)
2673  oprot.writeI64(self.start_time)
2674  oprot.writeFieldEnd()
2675  if self.edition is not None:
2676  oprot.writeFieldBegin('edition', TType.STRING, 5)
2677  oprot.writeString(self.edition.encode('utf-8') if sys.version_info[0] == 2 else self.edition)
2678  oprot.writeFieldEnd()
2679  if self.host_name is not None:
2680  oprot.writeFieldBegin('host_name', TType.STRING, 6)
2681  oprot.writeString(self.host_name.encode('utf-8') if sys.version_info[0] == 2 else self.host_name)
2682  oprot.writeFieldEnd()
2683  if self.poly_rendering_enabled is not None:
2684  oprot.writeFieldBegin('poly_rendering_enabled', TType.BOOL, 7)
2685  oprot.writeBool(self.poly_rendering_enabled)
2686  oprot.writeFieldEnd()
2687  if self.role is not None:
2688  oprot.writeFieldBegin('role', TType.I32, 8)
2689  oprot.writeI32(self.role)
2690  oprot.writeFieldEnd()
2691  if self.renderer_status_json is not None:
2692  oprot.writeFieldBegin('renderer_status_json', TType.STRING, 9)
2693  oprot.writeString(self.renderer_status_json.encode('utf-8') if sys.version_info[0] == 2 else self.renderer_status_json)
2694  oprot.writeFieldEnd()
2695  oprot.writeFieldStop()
2696  oprot.writeStructEnd()
2697 
2698  def validate(self):
2699  return
2700 
2701  def __repr__(self):
2702  L = ['%s=%r' % (key, value)
2703  for key, value in self.__dict__.items()]
2704  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2705 
2706  def __eq__(self, other):
2707  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2708 
2709  def __ne__(self, other):
2710  return not (self == other)
2711 
2712 
2713 class TPixel(object):
2714  """
2715  Attributes:
2716  - x
2717  - y
2718 
2719  """
2720 
2721 
2722  def __init__(self, x=None, y=None,):
2723  self.x = x
2724  self.y = y
2725 
2726  def read(self, iprot):
2727  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
2728  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
2729  return
2730  iprot.readStructBegin()
2731  while True:
2732  (fname, ftype, fid) = iprot.readFieldBegin()
2733  if ftype == TType.STOP:
2734  break
2735  if fid == 1:
2736  if ftype == TType.I64:
2737  self.x = iprot.readI64()
2738  else:
2739  iprot.skip(ftype)
2740  elif fid == 2:
2741  if ftype == TType.I64:
2742  self.y = iprot.readI64()
2743  else:
2744  iprot.skip(ftype)
2745  else:
2746  iprot.skip(ftype)
2747  iprot.readFieldEnd()
2748  iprot.readStructEnd()
2749 
2750  def write(self, oprot):
2751  if oprot._fast_encode is not None and self.thrift_spec is not None:
2752  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
2753  return
2754  oprot.writeStructBegin('TPixel')
2755  if self.x is not None:
2756  oprot.writeFieldBegin('x', TType.I64, 1)
2757  oprot.writeI64(self.x)
2758  oprot.writeFieldEnd()
2759  if self.y is not None:
2760  oprot.writeFieldBegin('y', TType.I64, 2)
2761  oprot.writeI64(self.y)
2762  oprot.writeFieldEnd()
2763  oprot.writeFieldStop()
2764  oprot.writeStructEnd()
2765 
2766  def validate(self):
2767  return
2768 
2769  def __repr__(self):
2770  L = ['%s=%r' % (key, value)
2771  for key, value in self.__dict__.items()]
2772  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2773 
2774  def __eq__(self, other):
2775  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2776 
2777  def __ne__(self, other):
2778  return not (self == other)
2779 
2780 
2781 class TPixelTableRowResult(object):
2782  """
2783  Attributes:
2784  - pixel
2785  - vega_table_name
2786  - table_id
2787  - row_id
2788  - row_set
2789  - nonce
2790 
2791  """
2792 
2793 
2794  def __init__(self, pixel=None, vega_table_name=None, table_id=None, row_id=None, row_set=None, nonce=None,):
2795  self.pixel = pixel
2796  self.vega_table_name = vega_table_name
2797  self.table_id = table_id
2798  self.row_id = row_id
2799  self.row_set = row_set
2800  self.nonce = nonce
2801 
2802  def read(self, iprot):
2803  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
2804  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
2805  return
2806  iprot.readStructBegin()
2807  while True:
2808  (fname, ftype, fid) = iprot.readFieldBegin()
2809  if ftype == TType.STOP:
2810  break
2811  if fid == 1:
2812  if ftype == TType.STRUCT:
2813  self.pixel = TPixel()
2814  self.pixel.read(iprot)
2815  else:
2816  iprot.skip(ftype)
2817  elif fid == 2:
2818  if ftype == TType.STRING:
2819  self.vega_table_name = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2820  else:
2821  iprot.skip(ftype)
2822  elif fid == 3:
2823  if ftype == TType.LIST:
2824  self.table_id = []
2825  (_etype87, _size84) = iprot.readListBegin()
2826  for _i88 in range(_size84):
2827  _elem89 = iprot.readI64()
2828  self.table_id.append(_elem89)
2829  iprot.readListEnd()
2830  else:
2831  iprot.skip(ftype)
2832  elif fid == 4:
2833  if ftype == TType.LIST:
2834  self.row_id = []
2835  (_etype93, _size90) = iprot.readListBegin()
2836  for _i94 in range(_size90):
2837  _elem95 = iprot.readI64()
2838  self.row_id.append(_elem95)
2839  iprot.readListEnd()
2840  else:
2841  iprot.skip(ftype)
2842  elif fid == 5:
2843  if ftype == TType.STRUCT:
2844  self.row_set = TRowSet()
2845  self.row_set.read(iprot)
2846  else:
2847  iprot.skip(ftype)
2848  elif fid == 6:
2849  if ftype == TType.STRING:
2850  self.nonce = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2851  else:
2852  iprot.skip(ftype)
2853  else:
2854  iprot.skip(ftype)
2855  iprot.readFieldEnd()
2856  iprot.readStructEnd()
2857 
2858  def write(self, oprot):
2859  if oprot._fast_encode is not None and self.thrift_spec is not None:
2860  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
2861  return
2862  oprot.writeStructBegin('TPixelTableRowResult')
2863  if self.pixel is not None:
2864  oprot.writeFieldBegin('pixel', TType.STRUCT, 1)
2865  self.pixel.write(oprot)
2866  oprot.writeFieldEnd()
2867  if self.vega_table_name is not None:
2868  oprot.writeFieldBegin('vega_table_name', TType.STRING, 2)
2869  oprot.writeString(self.vega_table_name.encode('utf-8') if sys.version_info[0] == 2 else self.vega_table_name)
2870  oprot.writeFieldEnd()
2871  if self.table_id is not None:
2872  oprot.writeFieldBegin('table_id', TType.LIST, 3)
2873  oprot.writeListBegin(TType.I64, len(self.table_id))
2874  for iter96 in self.table_id:
2875  oprot.writeI64(iter96)
2876  oprot.writeListEnd()
2877  oprot.writeFieldEnd()
2878  if self.row_id is not None:
2879  oprot.writeFieldBegin('row_id', TType.LIST, 4)
2880  oprot.writeListBegin(TType.I64, len(self.row_id))
2881  for iter97 in self.row_id:
2882  oprot.writeI64(iter97)
2883  oprot.writeListEnd()
2884  oprot.writeFieldEnd()
2885  if self.row_set is not None:
2886  oprot.writeFieldBegin('row_set', TType.STRUCT, 5)
2887  self.row_set.write(oprot)
2888  oprot.writeFieldEnd()
2889  if self.nonce is not None:
2890  oprot.writeFieldBegin('nonce', TType.STRING, 6)
2891  oprot.writeString(self.nonce.encode('utf-8') if sys.version_info[0] == 2 else self.nonce)
2892  oprot.writeFieldEnd()
2893  oprot.writeFieldStop()
2894  oprot.writeStructEnd()
2895 
2896  def validate(self):
2897  return
2898 
2899  def __repr__(self):
2900  L = ['%s=%r' % (key, value)
2901  for key, value in self.__dict__.items()]
2902  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2903 
2904  def __eq__(self, other):
2905  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2906 
2907  def __ne__(self, other):
2908  return not (self == other)
2909 
2910 
2911 class TRenderResult(object):
2912  """
2913  Attributes:
2914  - image
2915  - nonce
2916  - execution_time_ms
2917  - render_time_ms
2918  - total_time_ms
2919  - vega_metadata
2920 
2921  """
2922 
2923 
2924  def __init__(self, image=None, nonce=None, execution_time_ms=None, render_time_ms=None, total_time_ms=None, vega_metadata=None,):
2925  self.image = image
2926  self.nonce = nonce
2927  self.execution_time_ms = execution_time_ms
2928  self.render_time_ms = render_time_ms
2929  self.total_time_ms = total_time_ms
2930  self.vega_metadata = vega_metadata
2931 
2932  def read(self, iprot):
2933  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
2934  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
2935  return
2936  iprot.readStructBegin()
2937  while True:
2938  (fname, ftype, fid) = iprot.readFieldBegin()
2939  if ftype == TType.STOP:
2940  break
2941  if fid == 1:
2942  if ftype == TType.STRING:
2943  self.image = iprot.readBinary()
2944  else:
2945  iprot.skip(ftype)
2946  elif fid == 2:
2947  if ftype == TType.STRING:
2948  self.nonce = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2949  else:
2950  iprot.skip(ftype)
2951  elif fid == 3:
2952  if ftype == TType.I64:
2953  self.execution_time_ms = iprot.readI64()
2954  else:
2955  iprot.skip(ftype)
2956  elif fid == 4:
2957  if ftype == TType.I64:
2958  self.render_time_ms = iprot.readI64()
2959  else:
2960  iprot.skip(ftype)
2961  elif fid == 5:
2962  if ftype == TType.I64:
2963  self.total_time_ms = iprot.readI64()
2964  else:
2965  iprot.skip(ftype)
2966  elif fid == 6:
2967  if ftype == TType.STRING:
2968  self.vega_metadata = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2969  else:
2970  iprot.skip(ftype)
2971  else:
2972  iprot.skip(ftype)
2973  iprot.readFieldEnd()
2974  iprot.readStructEnd()
2975 
2976  def write(self, oprot):
2977  if oprot._fast_encode is not None and self.thrift_spec is not None:
2978  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
2979  return
2980  oprot.writeStructBegin('TRenderResult')
2981  if self.image is not None:
2982  oprot.writeFieldBegin('image', TType.STRING, 1)
2983  oprot.writeBinary(self.image)
2984  oprot.writeFieldEnd()
2985  if self.nonce is not None:
2986  oprot.writeFieldBegin('nonce', TType.STRING, 2)
2987  oprot.writeString(self.nonce.encode('utf-8') if sys.version_info[0] == 2 else self.nonce)
2988  oprot.writeFieldEnd()
2989  if self.execution_time_ms is not None:
2990  oprot.writeFieldBegin('execution_time_ms', TType.I64, 3)
2991  oprot.writeI64(self.execution_time_ms)
2992  oprot.writeFieldEnd()
2993  if self.render_time_ms is not None:
2994  oprot.writeFieldBegin('render_time_ms', TType.I64, 4)
2995  oprot.writeI64(self.render_time_ms)
2996  oprot.writeFieldEnd()
2997  if self.total_time_ms is not None:
2998  oprot.writeFieldBegin('total_time_ms', TType.I64, 5)
2999  oprot.writeI64(self.total_time_ms)
3000  oprot.writeFieldEnd()
3001  if self.vega_metadata is not None:
3002  oprot.writeFieldBegin('vega_metadata', TType.STRING, 6)
3003  oprot.writeString(self.vega_metadata.encode('utf-8') if sys.version_info[0] == 2 else self.vega_metadata)
3004  oprot.writeFieldEnd()
3005  oprot.writeFieldStop()
3006  oprot.writeStructEnd()
3007 
3008  def validate(self):
3009  return
3010 
3011  def __repr__(self):
3012  L = ['%s=%r' % (key, value)
3013  for key, value in self.__dict__.items()]
3014  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3015 
3016  def __eq__(self, other):
3017  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3018 
3019  def __ne__(self, other):
3020  return not (self == other)
3021 
3022 
3023 class TGpuSpecification(object):
3024  """
3025  Attributes:
3026  - num_sm
3027  - clock_frequency_kHz
3028  - memory
3029  - compute_capability_major
3030  - compute_capability_minor
3031 
3032  """
3033 
3034 
3035  def __init__(self, num_sm=None, clock_frequency_kHz=None, memory=None, compute_capability_major=None, compute_capability_minor=None,):
3036  self.num_sm = num_sm
3037  self.clock_frequency_kHz = clock_frequency_kHz
3038  self.memory = memory
3039  self.compute_capability_major = compute_capability_major
3040  self.compute_capability_minor = compute_capability_minor
3041 
3042  def read(self, iprot):
3043  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
3044  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
3045  return
3046  iprot.readStructBegin()
3047  while True:
3048  (fname, ftype, fid) = iprot.readFieldBegin()
3049  if ftype == TType.STOP:
3050  break
3051  if fid == 1:
3052  if ftype == TType.I32:
3053  self.num_sm = iprot.readI32()
3054  else:
3055  iprot.skip(ftype)
3056  elif fid == 2:
3057  if ftype == TType.I64:
3058  self.clock_frequency_kHz = iprot.readI64()
3059  else:
3060  iprot.skip(ftype)
3061  elif fid == 3:
3062  if ftype == TType.I64:
3063  self.memory = iprot.readI64()
3064  else:
3065  iprot.skip(ftype)
3066  elif fid == 4:
3067  if ftype == TType.I16:
3068  self.compute_capability_major = iprot.readI16()
3069  else:
3070  iprot.skip(ftype)
3071  elif fid == 5:
3072  if ftype == TType.I16:
3073  self.compute_capability_minor = iprot.readI16()
3074  else:
3075  iprot.skip(ftype)
3076  else:
3077  iprot.skip(ftype)
3078  iprot.readFieldEnd()
3079  iprot.readStructEnd()
3080 
3081  def write(self, oprot):
3082  if oprot._fast_encode is not None and self.thrift_spec is not None:
3083  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
3084  return
3085  oprot.writeStructBegin('TGpuSpecification')
3086  if self.num_sm is not None:
3087  oprot.writeFieldBegin('num_sm', TType.I32, 1)
3088  oprot.writeI32(self.num_sm)
3089  oprot.writeFieldEnd()
3090  if self.clock_frequency_kHz is not None:
3091  oprot.writeFieldBegin('clock_frequency_kHz', TType.I64, 2)
3092  oprot.writeI64(self.clock_frequency_kHz)
3093  oprot.writeFieldEnd()
3094  if self.memory is not None:
3095  oprot.writeFieldBegin('memory', TType.I64, 3)
3096  oprot.writeI64(self.memory)
3097  oprot.writeFieldEnd()
3098  if self.compute_capability_major is not None:
3099  oprot.writeFieldBegin('compute_capability_major', TType.I16, 4)
3100  oprot.writeI16(self.compute_capability_major)
3101  oprot.writeFieldEnd()
3102  if self.compute_capability_minor is not None:
3103  oprot.writeFieldBegin('compute_capability_minor', TType.I16, 5)
3104  oprot.writeI16(self.compute_capability_minor)
3105  oprot.writeFieldEnd()
3106  oprot.writeFieldStop()
3107  oprot.writeStructEnd()
3108 
3109  def validate(self):
3110  return
3111 
3112  def __repr__(self):
3113  L = ['%s=%r' % (key, value)
3114  for key, value in self.__dict__.items()]
3115  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3116 
3117  def __eq__(self, other):
3118  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3119 
3120  def __ne__(self, other):
3121  return not (self == other)
3122 
3123 
3124 class THardwareInfo(object):
3125  """
3126  Attributes:
3127  - num_gpu_hw
3128  - num_cpu_hw
3129  - num_gpu_allocated
3130  - start_gpu
3131  - host_name
3132  - gpu_info
3133 
3134  """
3135 
3136 
3137  def __init__(self, num_gpu_hw=None, num_cpu_hw=None, num_gpu_allocated=None, start_gpu=None, host_name=None, gpu_info=None,):
3138  self.num_gpu_hw = num_gpu_hw
3139  self.num_cpu_hw = num_cpu_hw
3140  self.num_gpu_allocated = num_gpu_allocated
3141  self.start_gpu = start_gpu
3142  self.host_name = host_name
3143  self.gpu_info = gpu_info
3144 
3145  def read(self, iprot):
3146  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
3147  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
3148  return
3149  iprot.readStructBegin()
3150  while True:
3151  (fname, ftype, fid) = iprot.readFieldBegin()
3152  if ftype == TType.STOP:
3153  break
3154  if fid == 1:
3155  if ftype == TType.I16:
3156  self.num_gpu_hw = iprot.readI16()
3157  else:
3158  iprot.skip(ftype)
3159  elif fid == 2:
3160  if ftype == TType.I16:
3161  self.num_cpu_hw = iprot.readI16()
3162  else:
3163  iprot.skip(ftype)
3164  elif fid == 3:
3165  if ftype == TType.I16:
3166  self.num_gpu_allocated = iprot.readI16()
3167  else:
3168  iprot.skip(ftype)
3169  elif fid == 4:
3170  if ftype == TType.I16:
3171  self.start_gpu = iprot.readI16()
3172  else:
3173  iprot.skip(ftype)
3174  elif fid == 5:
3175  if ftype == TType.STRING:
3176  self.host_name = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
3177  else:
3178  iprot.skip(ftype)
3179  elif fid == 6:
3180  if ftype == TType.LIST:
3181  self.gpu_info = []
3182  (_etype101, _size98) = iprot.readListBegin()
3183  for _i102 in range(_size98):
3184  _elem103 = TGpuSpecification()
3185  _elem103.read(iprot)
3186  self.gpu_info.append(_elem103)
3187  iprot.readListEnd()
3188  else:
3189  iprot.skip(ftype)
3190  else:
3191  iprot.skip(ftype)
3192  iprot.readFieldEnd()
3193  iprot.readStructEnd()
3194 
3195  def write(self, oprot):
3196  if oprot._fast_encode is not None and self.thrift_spec is not None:
3197  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
3198  return
3199  oprot.writeStructBegin('THardwareInfo')
3200  if self.num_gpu_hw is not None:
3201  oprot.writeFieldBegin('num_gpu_hw', TType.I16, 1)
3202  oprot.writeI16(self.num_gpu_hw)
3203  oprot.writeFieldEnd()
3204  if self.num_cpu_hw is not None:
3205  oprot.writeFieldBegin('num_cpu_hw', TType.I16, 2)
3206  oprot.writeI16(self.num_cpu_hw)
3207  oprot.writeFieldEnd()
3208  if self.num_gpu_allocated is not None:
3209  oprot.writeFieldBegin('num_gpu_allocated', TType.I16, 3)
3210  oprot.writeI16(self.num_gpu_allocated)
3211  oprot.writeFieldEnd()
3212  if self.start_gpu is not None:
3213  oprot.writeFieldBegin('start_gpu', TType.I16, 4)
3214  oprot.writeI16(self.start_gpu)
3215  oprot.writeFieldEnd()
3216  if self.host_name is not None:
3217  oprot.writeFieldBegin('host_name', TType.STRING, 5)
3218  oprot.writeString(self.host_name.encode('utf-8') if sys.version_info[0] == 2 else self.host_name)
3219  oprot.writeFieldEnd()
3220  if self.gpu_info is not None:
3221  oprot.writeFieldBegin('gpu_info', TType.LIST, 6)
3222  oprot.writeListBegin(TType.STRUCT, len(self.gpu_info))
3223  for iter104 in self.gpu_info:
3224  iter104.write(oprot)
3225  oprot.writeListEnd()
3226  oprot.writeFieldEnd()
3227  oprot.writeFieldStop()
3228  oprot.writeStructEnd()
3229 
3230  def validate(self):
3231  return
3232 
3233  def __repr__(self):
3234  L = ['%s=%r' % (key, value)
3235  for key, value in self.__dict__.items()]
3236  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3237 
3238  def __eq__(self, other):
3239  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3240 
3241  def __ne__(self, other):
3242  return not (self == other)
3243 
3244 
3245 class TClusterHardwareInfo(object):
3246  """
3247  Attributes:
3248  - hardware_info
3249 
3250  """
3251 
3252 
3253  def __init__(self, hardware_info=None,):
3254  self.hardware_info = hardware_info
3255 
3256  def read(self, iprot):
3257  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
3258  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
3259  return
3260  iprot.readStructBegin()
3261  while True:
3262  (fname, ftype, fid) = iprot.readFieldBegin()
3263  if ftype == TType.STOP:
3264  break
3265  if fid == 1:
3266  if ftype == TType.LIST:
3267  self.hardware_info = []
3268  (_etype108, _size105) = iprot.readListBegin()
3269  for _i109 in range(_size105):
3270  _elem110 = THardwareInfo()
3271  _elem110.read(iprot)
3272  self.hardware_info.append(_elem110)
3273  iprot.readListEnd()
3274  else:
3275  iprot.skip(ftype)
3276  else:
3277  iprot.skip(ftype)
3278  iprot.readFieldEnd()
3279  iprot.readStructEnd()
3280 
3281  def write(self, oprot):
3282  if oprot._fast_encode is not None and self.thrift_spec is not None:
3283  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
3284  return
3285  oprot.writeStructBegin('TClusterHardwareInfo')
3286  if self.hardware_info is not None:
3287  oprot.writeFieldBegin('hardware_info', TType.LIST, 1)
3288  oprot.writeListBegin(TType.STRUCT, len(self.hardware_info))
3289  for iter111 in self.hardware_info:
3290  iter111.write(oprot)
3291  oprot.writeListEnd()
3292  oprot.writeFieldEnd()
3293  oprot.writeFieldStop()
3294  oprot.writeStructEnd()
3295 
3296  def validate(self):
3297  return
3298 
3299  def __repr__(self):
3300  L = ['%s=%r' % (key, value)
3301  for key, value in self.__dict__.items()]
3302  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3303 
3304  def __eq__(self, other):
3305  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3306 
3307  def __ne__(self, other):
3308  return not (self == other)
3309 
3310 
3311 class TMemoryData(object):
3312  """
3313  Attributes:
3314  - slab
3315  - start_page
3316  - num_pages
3317  - touch
3318  - chunk_key
3319  - buffer_epoch
3320  - is_free
3321 
3322  """
3323 
3324 
3325  def __init__(self, slab=None, start_page=None, num_pages=None, touch=None, chunk_key=None, buffer_epoch=None, is_free=None,):
3326  self.slab = slab
3327  self.start_page = start_page
3328  self.num_pages = num_pages
3329  self.touch = touch
3330  self.chunk_key = chunk_key
3331  self.buffer_epoch = buffer_epoch
3332  self.is_free = is_free
3333 
3334  def read(self, iprot):
3335  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
3336  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
3337  return
3338  iprot.readStructBegin()
3339  while True:
3340  (fname, ftype, fid) = iprot.readFieldBegin()
3341  if ftype == TType.STOP:
3342  break
3343  if fid == 1:
3344  if ftype == TType.I64:
3345  self.slab = iprot.readI64()
3346  else:
3347  iprot.skip(ftype)
3348  elif fid == 2:
3349  if ftype == TType.I32:
3350  self.start_page = iprot.readI32()
3351  else:
3352  iprot.skip(ftype)
3353  elif fid == 3:
3354  if ftype == TType.I64:
3355  self.num_pages = iprot.readI64()
3356  else:
3357  iprot.skip(ftype)
3358  elif fid == 4:
3359  if ftype == TType.I32:
3360  self.touch = iprot.readI32()
3361  else:
3362  iprot.skip(ftype)
3363  elif fid == 5:
3364  if ftype == TType.LIST:
3365  self.chunk_key = []
3366  (_etype115, _size112) = iprot.readListBegin()
3367  for _i116 in range(_size112):
3368  _elem117 = iprot.readI64()
3369  self.chunk_key.append(_elem117)
3370  iprot.readListEnd()
3371  else:
3372  iprot.skip(ftype)
3373  elif fid == 6:
3374  if ftype == TType.I32:
3375  self.buffer_epoch = iprot.readI32()
3376  else:
3377  iprot.skip(ftype)
3378  elif fid == 7:
3379  if ftype == TType.BOOL:
3380  self.is_free = iprot.readBool()
3381  else:
3382  iprot.skip(ftype)
3383  else:
3384  iprot.skip(ftype)
3385  iprot.readFieldEnd()
3386  iprot.readStructEnd()
3387 
3388  def write(self, oprot):
3389  if oprot._fast_encode is not None and self.thrift_spec is not None:
3390  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
3391  return
3392  oprot.writeStructBegin('TMemoryData')
3393  if self.slab is not None:
3394  oprot.writeFieldBegin('slab', TType.I64, 1)
3395  oprot.writeI64(self.slab)
3396  oprot.writeFieldEnd()
3397  if self.start_page is not None:
3398  oprot.writeFieldBegin('start_page', TType.I32, 2)
3399  oprot.writeI32(self.start_page)
3400  oprot.writeFieldEnd()
3401  if self.num_pages is not None:
3402  oprot.writeFieldBegin('num_pages', TType.I64, 3)
3403  oprot.writeI64(self.num_pages)
3404  oprot.writeFieldEnd()
3405  if self.touch is not None:
3406  oprot.writeFieldBegin('touch', TType.I32, 4)
3407  oprot.writeI32(self.touch)
3408  oprot.writeFieldEnd()
3409  if self.chunk_key is not None:
3410  oprot.writeFieldBegin('chunk_key', TType.LIST, 5)
3411  oprot.writeListBegin(TType.I64, len(self.chunk_key))
3412  for iter118 in self.chunk_key:
3413  oprot.writeI64(iter118)
3414  oprot.writeListEnd()
3415  oprot.writeFieldEnd()
3416  if self.buffer_epoch is not None:
3417  oprot.writeFieldBegin('buffer_epoch', TType.I32, 6)
3418  oprot.writeI32(self.buffer_epoch)
3419  oprot.writeFieldEnd()
3420  if self.is_free is not None:
3421  oprot.writeFieldBegin('is_free', TType.BOOL, 7)
3422  oprot.writeBool(self.is_free)
3423  oprot.writeFieldEnd()
3424  oprot.writeFieldStop()
3425  oprot.writeStructEnd()
3426 
3427  def validate(self):
3428  return
3429 
3430  def __repr__(self):
3431  L = ['%s=%r' % (key, value)
3432  for key, value in self.__dict__.items()]
3433  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3434 
3435  def __eq__(self, other):
3436  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3437 
3438  def __ne__(self, other):
3439  return not (self == other)
3440 
3441 
3442 class TNodeMemoryInfo(object):
3443  """
3444  Attributes:
3445  - host_name
3446  - page_size
3447  - max_num_pages
3448  - num_pages_allocated
3449  - is_allocation_capped
3450  - node_memory_data
3451 
3452  """
3453 
3454 
3455  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,):
3456  self.host_name = host_name
3457  self.page_size = page_size
3458  self.max_num_pages = max_num_pages
3459  self.num_pages_allocated = num_pages_allocated
3460  self.is_allocation_capped = is_allocation_capped
3461  self.node_memory_data = node_memory_data
3462 
3463  def read(self, iprot):
3464  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
3465  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
3466  return
3467  iprot.readStructBegin()
3468  while True:
3469  (fname, ftype, fid) = iprot.readFieldBegin()
3470  if ftype == TType.STOP:
3471  break
3472  if fid == 1:
3473  if ftype == TType.STRING:
3474  self.host_name = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
3475  else:
3476  iprot.skip(ftype)
3477  elif fid == 2:
3478  if ftype == TType.I64:
3479  self.page_size = iprot.readI64()
3480  else:
3481  iprot.skip(ftype)
3482  elif fid == 3:
3483  if ftype == TType.I64:
3484  self.max_num_pages = iprot.readI64()
3485  else:
3486  iprot.skip(ftype)
3487  elif fid == 4:
3488  if ftype == TType.I64:
3489  self.num_pages_allocated = iprot.readI64()
3490  else:
3491  iprot.skip(ftype)
3492  elif fid == 5:
3493  if ftype == TType.BOOL:
3494  self.is_allocation_capped = iprot.readBool()
3495  else:
3496  iprot.skip(ftype)
3497  elif fid == 6:
3498  if ftype == TType.LIST:
3499  self.node_memory_data = []
3500  (_etype122, _size119) = iprot.readListBegin()
3501  for _i123 in range(_size119):
3502  _elem124 = TMemoryData()
3503  _elem124.read(iprot)
3504  self.node_memory_data.append(_elem124)
3505  iprot.readListEnd()
3506  else:
3507  iprot.skip(ftype)
3508  else:
3509  iprot.skip(ftype)
3510  iprot.readFieldEnd()
3511  iprot.readStructEnd()
3512 
3513  def write(self, oprot):
3514  if oprot._fast_encode is not None and self.thrift_spec is not None:
3515  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
3516  return
3517  oprot.writeStructBegin('TNodeMemoryInfo')
3518  if self.host_name is not None:
3519  oprot.writeFieldBegin('host_name', TType.STRING, 1)
3520  oprot.writeString(self.host_name.encode('utf-8') if sys.version_info[0] == 2 else self.host_name)
3521  oprot.writeFieldEnd()
3522  if self.page_size is not None:
3523  oprot.writeFieldBegin('page_size', TType.I64, 2)
3524  oprot.writeI64(self.page_size)
3525  oprot.writeFieldEnd()
3526  if self.max_num_pages is not None:
3527  oprot.writeFieldBegin('max_num_pages', TType.I64, 3)
3528  oprot.writeI64(self.max_num_pages)
3529  oprot.writeFieldEnd()
3530  if self.num_pages_allocated is not None:
3531  oprot.writeFieldBegin('num_pages_allocated', TType.I64, 4)
3532  oprot.writeI64(self.num_pages_allocated)
3533  oprot.writeFieldEnd()
3534  if self.is_allocation_capped is not None:
3535  oprot.writeFieldBegin('is_allocation_capped', TType.BOOL, 5)
3536  oprot.writeBool(self.is_allocation_capped)
3537  oprot.writeFieldEnd()
3538  if self.node_memory_data is not None:
3539  oprot.writeFieldBegin('node_memory_data', TType.LIST, 6)
3540  oprot.writeListBegin(TType.STRUCT, len(self.node_memory_data))
3541  for iter125 in self.node_memory_data:
3542  iter125.write(oprot)
3543  oprot.writeListEnd()
3544  oprot.writeFieldEnd()
3545  oprot.writeFieldStop()
3546  oprot.writeStructEnd()
3547 
3548  def validate(self):
3549  return
3550 
3551  def __repr__(self):
3552  L = ['%s=%r' % (key, value)
3553  for key, value in self.__dict__.items()]
3554  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3555 
3556  def __eq__(self, other):
3557  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3558 
3559  def __ne__(self, other):
3560  return not (self == other)
3561 
3562 
3563 class TTableMeta(object):
3564  """
3565  Attributes:
3566  - table_name
3567  - num_cols
3568  - is_view
3569  - is_replicated
3570  - shard_count
3571  - max_rows
3572  - table_id
3573  - max_table_id
3574  - col_types
3575  - col_names
3576 
3577  """
3578 
3579 
3580  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,):
3581  self.table_name = table_name
3582  self.num_cols = num_cols
3583  self.is_view = is_view
3584  self.is_replicated = is_replicated
3585  self.shard_count = shard_count
3586  self.max_rows = max_rows
3587  self.table_id = table_id
3588  self.max_table_id = max_table_id
3589  self.col_types = col_types
3590  self.col_names = col_names
3591 
3592  def read(self, iprot):
3593  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
3594  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
3595  return
3596  iprot.readStructBegin()
3597  while True:
3598  (fname, ftype, fid) = iprot.readFieldBegin()
3599  if ftype == TType.STOP:
3600  break
3601  if fid == 1:
3602  if ftype == TType.STRING:
3603  self.table_name = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
3604  else:
3605  iprot.skip(ftype)
3606  elif fid == 2:
3607  if ftype == TType.I64:
3608  self.num_cols = iprot.readI64()
3609  else:
3610  iprot.skip(ftype)
3611  elif fid == 4:
3612  if ftype == TType.BOOL:
3613  self.is_view = iprot.readBool()
3614  else:
3615  iprot.skip(ftype)
3616  elif fid == 5:
3617  if ftype == TType.BOOL:
3618  self.is_replicated = iprot.readBool()
3619  else:
3620  iprot.skip(ftype)
3621  elif fid == 6:
3622  if ftype == TType.I64:
3623  self.shard_count = iprot.readI64()
3624  else:
3625  iprot.skip(ftype)
3626  elif fid == 7:
3627  if ftype == TType.I64:
3628  self.max_rows = iprot.readI64()
3629  else:
3630  iprot.skip(ftype)
3631  elif fid == 8:
3632  if ftype == TType.I64:
3633  self.table_id = iprot.readI64()
3634  else:
3635  iprot.skip(ftype)
3636  elif fid == 9:
3637  if ftype == TType.I64:
3638  self.max_table_id = iprot.readI64()
3639  else:
3640  iprot.skip(ftype)
3641  elif fid == 10:
3642  if ftype == TType.LIST:
3643  self.col_types = []
3644  (_etype129, _size126) = iprot.readListBegin()
3645  for _i130 in range(_size126):
3646  _elem131 = heavydb.common.ttypes.TTypeInfo()
3647  _elem131.read(iprot)
3648  self.col_types.append(_elem131)
3649  iprot.readListEnd()
3650  else:
3651  iprot.skip(ftype)
3652  elif fid == 11:
3653  if ftype == TType.LIST:
3654  self.col_names = []
3655  (_etype135, _size132) = iprot.readListBegin()
3656  for _i136 in range(_size132):
3657  _elem137 = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
3658  self.col_names.append(_elem137)
3659  iprot.readListEnd()
3660  else:
3661  iprot.skip(ftype)
3662  else:
3663  iprot.skip(ftype)
3664  iprot.readFieldEnd()
3665  iprot.readStructEnd()
3666 
3667  def write(self, oprot):
3668  if oprot._fast_encode is not None and self.thrift_spec is not None:
3669  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
3670  return
3671  oprot.writeStructBegin('TTableMeta')
3672  if self.table_name is not None:
3673  oprot.writeFieldBegin('table_name', TType.STRING, 1)
3674  oprot.writeString(self.table_name.encode('utf-8') if sys.version_info[0] == 2 else self.table_name)
3675  oprot.writeFieldEnd()
3676  if self.num_cols is not None:
3677  oprot.writeFieldBegin('num_cols', TType.I64, 2)
3678  oprot.writeI64(self.num_cols)
3679  oprot.writeFieldEnd()
3680  if self.is_view is not None:
3681  oprot.writeFieldBegin('is_view', TType.BOOL, 4)
3682  oprot.writeBool(self.is_view)
3683  oprot.writeFieldEnd()
3684  if self.is_replicated is not None:
3685  oprot.writeFieldBegin('is_replicated', TType.BOOL, 5)
3686  oprot.writeBool(self.is_replicated)
3687  oprot.writeFieldEnd()
3688  if self.shard_count is not None:
3689  oprot.writeFieldBegin('shard_count', TType.I64, 6)
3690  oprot.writeI64(self.shard_count)
3691  oprot.writeFieldEnd()
3692  if self.max_rows is not None:
3693  oprot.writeFieldBegin('max_rows', TType.I64, 7)
3694  oprot.writeI64(self.max_rows)
3695  oprot.writeFieldEnd()
3696  if self.table_id is not None:
3697  oprot.writeFieldBegin('table_id', TType.I64, 8)
3698  oprot.writeI64(self.table_id)
3699  oprot.writeFieldEnd()
3700  if self.max_table_id is not None:
3701  oprot.writeFieldBegin('max_table_id', TType.I64, 9)
3702  oprot.writeI64(self.max_table_id)
3703  oprot.writeFieldEnd()
3704  if self.col_types is not None:
3705  oprot.writeFieldBegin('col_types', TType.LIST, 10)
3706  oprot.writeListBegin(TType.STRUCT, len(self.col_types))
3707  for iter138 in self.col_types:
3708  iter138.write(oprot)
3709  oprot.writeListEnd()
3710  oprot.writeFieldEnd()
3711  if self.col_names is not None:
3712  oprot.writeFieldBegin('col_names', TType.LIST, 11)
3713  oprot.writeListBegin(TType.STRING, len(self.col_names))
3714  for iter139 in self.col_names:
3715  oprot.writeString(iter139.encode('utf-8') if sys.version_info[0] == 2 else iter139)
3716  oprot.writeListEnd()
3717  oprot.writeFieldEnd()
3718  oprot.writeFieldStop()
3719  oprot.writeStructEnd()
3720 
3721  def validate(self):
3722  return
3723 
3724  def __repr__(self):
3725  L = ['%s=%r' % (key, value)
3726  for key, value in self.__dict__.items()]
3727  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3728 
3729  def __eq__(self, other):
3730  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3731 
3732  def __ne__(self, other):
3733  return not (self == other)
3734 
3735 
3736 class TTableRefreshInfo(object):
3737  """
3738  Attributes:
3739  - update_type
3740  - timing_type
3741  - start_date_time
3742  - interval_type
3743  - interval_count
3744  - last_refresh_time
3745  - next_refresh_time
3746 
3747  """
3748 
3749 
3750  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,):
3751  self.update_type = update_type
3752  self.timing_type = timing_type
3753  self.start_date_time = start_date_time
3754  self.interval_type = interval_type
3755  self.interval_count = interval_count
3756  self.last_refresh_time = last_refresh_time
3757  self.next_refresh_time = next_refresh_time
3758 
3759  def read(self, iprot):
3760  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
3761  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
3762  return
3763  iprot.readStructBegin()
3764  while True:
3765  (fname, ftype, fid) = iprot.readFieldBegin()
3766  if ftype == TType.STOP:
3767  break
3768  if fid == 1:
3769  if ftype == TType.I32:
3770  self.update_type = iprot.readI32()
3771  else:
3772  iprot.skip(ftype)
3773  elif fid == 2:
3774  if ftype == TType.I32:
3775  self.timing_type = iprot.readI32()
3776  else:
3777  iprot.skip(ftype)
3778  elif fid == 3:
3779  if ftype == TType.STRING:
3780  self.start_date_time = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
3781  else:
3782  iprot.skip(ftype)
3783  elif fid == 4:
3784  if ftype == TType.I32:
3785  self.interval_type = iprot.readI32()
3786  else:
3787  iprot.skip(ftype)
3788  elif fid == 5:
3789  if ftype == TType.I64:
3790  self.interval_count = iprot.readI64()
3791  else:
3792  iprot.skip(ftype)
3793  elif fid == 6:
3794  if ftype == TType.STRING:
3795  self.last_refresh_time = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
3796  else:
3797  iprot.skip(ftype)
3798  elif fid == 7:
3799  if ftype == TType.STRING:
3800  self.next_refresh_time = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
3801  else:
3802  iprot.skip(ftype)
3803  else:
3804  iprot.skip(ftype)
3805  iprot.readFieldEnd()
3806  iprot.readStructEnd()
3807 
3808  def write(self, oprot):
3809  if oprot._fast_encode is not None and self.thrift_spec is not None:
3810  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
3811  return
3812  oprot.writeStructBegin('TTableRefreshInfo')
3813  if self.update_type is not None:
3814  oprot.writeFieldBegin('update_type', TType.I32, 1)
3815  oprot.writeI32(self.update_type)
3816  oprot.writeFieldEnd()
3817  if self.timing_type is not None:
3818  oprot.writeFieldBegin('timing_type', TType.I32, 2)
3819  oprot.writeI32(self.timing_type)
3820  oprot.writeFieldEnd()
3821  if self.start_date_time is not None:
3822  oprot.writeFieldBegin('start_date_time', TType.STRING, 3)
3823  oprot.writeString(self.start_date_time.encode('utf-8') if sys.version_info[0] == 2 else self.start_date_time)
3824  oprot.writeFieldEnd()
3825  if self.interval_type is not None:
3826  oprot.writeFieldBegin('interval_type', TType.I32, 4)
3827  oprot.writeI32(self.interval_type)
3828  oprot.writeFieldEnd()
3829  if self.interval_count is not None:
3830  oprot.writeFieldBegin('interval_count', TType.I64, 5)
3831  oprot.writeI64(self.interval_count)
3832  oprot.writeFieldEnd()
3833  if self.last_refresh_time is not None:
3834  oprot.writeFieldBegin('last_refresh_time', TType.STRING, 6)
3835  oprot.writeString(self.last_refresh_time.encode('utf-8') if sys.version_info[0] == 2 else self.last_refresh_time)
3836  oprot.writeFieldEnd()
3837  if self.next_refresh_time is not None:
3838  oprot.writeFieldBegin('next_refresh_time', TType.STRING, 7)
3839  oprot.writeString(self.next_refresh_time.encode('utf-8') if sys.version_info[0] == 2 else self.next_refresh_time)
3840  oprot.writeFieldEnd()
3841  oprot.writeFieldStop()
3842  oprot.writeStructEnd()
3843 
3844  def validate(self):
3845  return
3846 
3847  def __repr__(self):
3848  L = ['%s=%r' % (key, value)
3849  for key, value in self.__dict__.items()]
3850  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3851 
3852  def __eq__(self, other):
3853  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3854 
3855  def __ne__(self, other):
3856  return not (self == other)
3857 
3858 
3859 class TTableDetails(object):
3860  """
3861  Attributes:
3862  - row_desc
3863  - fragment_size
3864  - page_size
3865  - max_rows
3866  - view_sql
3867  - shard_count
3868  - key_metainfo
3869  - is_temporary
3870  - partition_detail
3871  - table_type
3872  - refresh_info
3873 
3874  """
3875 
3876 
3877  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,):
3878  self.row_desc = row_desc
3879  self.fragment_size = fragment_size
3880  self.page_size = page_size
3881  self.max_rows = max_rows
3882  self.view_sql = view_sql
3883  self.shard_count = shard_count
3884  self.key_metainfo = key_metainfo
3885  self.is_temporary = is_temporary
3886  self.partition_detail = partition_detail
3887  self.table_type = table_type
3888  self.refresh_info = refresh_info
3889 
3890  def read(self, iprot):
3891  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
3892  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
3893  return
3894  iprot.readStructBegin()
3895  while True:
3896  (fname, ftype, fid) = iprot.readFieldBegin()
3897  if ftype == TType.STOP:
3898  break
3899  if fid == 1:
3900  if ftype == TType.LIST:
3901  self.row_desc = []
3902  (_etype143, _size140) = iprot.readListBegin()
3903  for _i144 in range(_size140):
3904  _elem145 = TColumnType()
3905  _elem145.read(iprot)
3906  self.row_desc.append(_elem145)
3907  iprot.readListEnd()
3908  else:
3909  iprot.skip(ftype)
3910  elif fid == 2:
3911  if ftype == TType.I64:
3912  self.fragment_size = iprot.readI64()
3913  else:
3914  iprot.skip(ftype)
3915  elif fid == 3:
3916  if ftype == TType.I64:
3917  self.page_size = iprot.readI64()
3918  else:
3919  iprot.skip(ftype)
3920  elif fid == 4:
3921  if ftype == TType.I64:
3922  self.max_rows = iprot.readI64()
3923  else:
3924  iprot.skip(ftype)
3925  elif fid == 5:
3926  if ftype == TType.STRING:
3927  self.view_sql = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
3928  else:
3929  iprot.skip(ftype)
3930  elif fid == 6:
3931  if ftype == TType.I64:
3932  self.shard_count = iprot.readI64()
3933  else:
3934  iprot.skip(ftype)
3935  elif fid == 7:
3936  if ftype == TType.STRING:
3937  self.key_metainfo = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
3938  else:
3939  iprot.skip(ftype)
3940  elif fid == 8:
3941  if ftype == TType.BOOL:
3942  self.is_temporary = iprot.readBool()
3943  else:
3944  iprot.skip(ftype)
3945  elif fid == 9:
3946  if ftype == TType.I32:
3947  self.partition_detail = iprot.readI32()
3948  else:
3949  iprot.skip(ftype)
3950  elif fid == 10:
3951  if ftype == TType.I32:
3952  self.table_type = iprot.readI32()
3953  else:
3954  iprot.skip(ftype)
3955  elif fid == 11:
3956  if ftype == TType.STRUCT:
3958  self.refresh_info.read(iprot)
3959  else:
3960  iprot.skip(ftype)
3961  else:
3962  iprot.skip(ftype)
3963  iprot.readFieldEnd()
3964  iprot.readStructEnd()
3965 
3966  def write(self, oprot):
3967  if oprot._fast_encode is not None and self.thrift_spec is not None:
3968  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
3969  return
3970  oprot.writeStructBegin('TTableDetails')
3971  if self.row_desc is not None:
3972  oprot.writeFieldBegin('row_desc', TType.LIST, 1)
3973  oprot.writeListBegin(TType.STRUCT, len(self.row_desc))
3974  for iter146 in self.row_desc:
3975  iter146.write(oprot)
3976  oprot.writeListEnd()
3977  oprot.writeFieldEnd()
3978  if self.fragment_size is not None:
3979  oprot.writeFieldBegin('fragment_size', TType.I64, 2)
3980  oprot.writeI64(self.fragment_size)
3981  oprot.writeFieldEnd()
3982  if self.page_size is not None:
3983  oprot.writeFieldBegin('page_size', TType.I64, 3)
3984  oprot.writeI64(self.page_size)
3985  oprot.writeFieldEnd()
3986  if self.max_rows is not None:
3987  oprot.writeFieldBegin('max_rows', TType.I64, 4)
3988  oprot.writeI64(self.max_rows)
3989  oprot.writeFieldEnd()
3990  if self.view_sql is not None:
3991  oprot.writeFieldBegin('view_sql', TType.STRING, 5)
3992  oprot.writeString(self.view_sql.encode('utf-8') if sys.version_info[0] == 2 else self.view_sql)
3993  oprot.writeFieldEnd()
3994  if self.shard_count is not None:
3995  oprot.writeFieldBegin('shard_count', TType.I64, 6)
3996  oprot.writeI64(self.shard_count)
3997  oprot.writeFieldEnd()
3998  if self.key_metainfo is not None:
3999  oprot.writeFieldBegin('key_metainfo', TType.STRING, 7)
4000  oprot.writeString(self.key_metainfo.encode('utf-8') if sys.version_info[0] == 2 else self.key_metainfo)
4001  oprot.writeFieldEnd()
4002  if self.is_temporary is not None:
4003  oprot.writeFieldBegin('is_temporary', TType.BOOL, 8)
4004  oprot.writeBool(self.is_temporary)
4005  oprot.writeFieldEnd()
4006  if self.partition_detail is not None:
4007  oprot.writeFieldBegin('partition_detail', TType.I32, 9)
4008  oprot.writeI32(self.partition_detail)
4009  oprot.writeFieldEnd()
4010  if self.table_type is not None:
4011  oprot.writeFieldBegin('table_type', TType.I32, 10)
4012  oprot.writeI32(self.table_type)
4013  oprot.writeFieldEnd()
4014  if self.refresh_info is not None:
4015  oprot.writeFieldBegin('refresh_info', TType.STRUCT, 11)
4016  self.refresh_info.write(oprot)
4017  oprot.writeFieldEnd()
4018  oprot.writeFieldStop()
4019  oprot.writeStructEnd()
4020 
4021  def validate(self):
4022  return
4023 
4024  def __repr__(self):
4025  L = ['%s=%r' % (key, value)
4026  for key, value in self.__dict__.items()]
4027  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4028 
4029  def __eq__(self, other):
4030  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4031 
4032  def __ne__(self, other):
4033  return not (self == other)
4034 
4035 
4036 class TColumnRange(object):
4037  """
4038  Attributes:
4039  - type
4040  - col_id
4041  - table_id
4042  - has_nulls
4043  - int_min
4044  - int_max
4045  - bucket
4046  - fp_min
4047  - fp_max
4048 
4049  """
4050 
4051 
4052  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,):
4053  self.type = type
4054  self.col_id = col_id
4055  self.table_id = table_id
4056  self.has_nulls = has_nulls
4057  self.int_min = int_min
4058  self.int_max = int_max
4059  self.bucket = bucket
4060  self.fp_min = fp_min
4061  self.fp_max = fp_max
4062 
4063  def read(self, iprot):
4064  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
4065  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
4066  return
4067  iprot.readStructBegin()
4068  while True:
4069  (fname, ftype, fid) = iprot.readFieldBegin()
4070  if ftype == TType.STOP:
4071  break
4072  if fid == 1:
4073  if ftype == TType.I32:
4074  self.type = iprot.readI32()
4075  else:
4076  iprot.skip(ftype)
4077  elif fid == 2:
4078  if ftype == TType.I32:
4079  self.col_id = iprot.readI32()
4080  else:
4081  iprot.skip(ftype)
4082  elif fid == 3:
4083  if ftype == TType.I32:
4084  self.table_id = iprot.readI32()
4085  else:
4086  iprot.skip(ftype)
4087  elif fid == 4:
4088  if ftype == TType.BOOL:
4089  self.has_nulls = iprot.readBool()
4090  else:
4091  iprot.skip(ftype)
4092  elif fid == 5:
4093  if ftype == TType.I64:
4094  self.int_min = iprot.readI64()
4095  else:
4096  iprot.skip(ftype)
4097  elif fid == 6:
4098  if ftype == TType.I64:
4099  self.int_max = iprot.readI64()
4100  else:
4101  iprot.skip(ftype)
4102  elif fid == 7:
4103  if ftype == TType.I64:
4104  self.bucket = iprot.readI64()
4105  else:
4106  iprot.skip(ftype)
4107  elif fid == 8:
4108  if ftype == TType.DOUBLE:
4109  self.fp_min = iprot.readDouble()
4110  else:
4111  iprot.skip(ftype)
4112  elif fid == 9:
4113  if ftype == TType.DOUBLE:
4114  self.fp_max = iprot.readDouble()
4115  else:
4116  iprot.skip(ftype)
4117  else:
4118  iprot.skip(ftype)
4119  iprot.readFieldEnd()
4120  iprot.readStructEnd()
4121 
4122  def write(self, oprot):
4123  if oprot._fast_encode is not None and self.thrift_spec is not None:
4124  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
4125  return
4126  oprot.writeStructBegin('TColumnRange')
4127  if self.type is not None:
4128  oprot.writeFieldBegin('type', TType.I32, 1)
4129  oprot.writeI32(self.type)
4130  oprot.writeFieldEnd()
4131  if self.col_id is not None:
4132  oprot.writeFieldBegin('col_id', TType.I32, 2)
4133  oprot.writeI32(self.col_id)
4134  oprot.writeFieldEnd()
4135  if self.table_id is not None:
4136  oprot.writeFieldBegin('table_id', TType.I32, 3)
4137  oprot.writeI32(self.table_id)
4138  oprot.writeFieldEnd()
4139  if self.has_nulls is not None:
4140  oprot.writeFieldBegin('has_nulls', TType.BOOL, 4)
4141  oprot.writeBool(self.has_nulls)
4142  oprot.writeFieldEnd()
4143  if self.int_min is not None:
4144  oprot.writeFieldBegin('int_min', TType.I64, 5)
4145  oprot.writeI64(self.int_min)
4146  oprot.writeFieldEnd()
4147  if self.int_max is not None:
4148  oprot.writeFieldBegin('int_max', TType.I64, 6)
4149  oprot.writeI64(self.int_max)
4150  oprot.writeFieldEnd()
4151  if self.bucket is not None:
4152  oprot.writeFieldBegin('bucket', TType.I64, 7)
4153  oprot.writeI64(self.bucket)
4154  oprot.writeFieldEnd()
4155  if self.fp_min is not None:
4156  oprot.writeFieldBegin('fp_min', TType.DOUBLE, 8)
4157  oprot.writeDouble(self.fp_min)
4158  oprot.writeFieldEnd()
4159  if self.fp_max is not None:
4160  oprot.writeFieldBegin('fp_max', TType.DOUBLE, 9)
4161  oprot.writeDouble(self.fp_max)
4162  oprot.writeFieldEnd()
4163  oprot.writeFieldStop()
4164  oprot.writeStructEnd()
4165 
4166  def validate(self):
4167  return
4168 
4169  def __repr__(self):
4170  L = ['%s=%r' % (key, value)
4171  for key, value in self.__dict__.items()]
4172  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4173 
4174  def __eq__(self, other):
4175  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4176 
4177  def __ne__(self, other):
4178  return not (self == other)
4179 
4180 
4182  """
4183  Attributes:
4184  - dict_id
4185  - entry_count
4186 
4187  """
4188 
4189 
4190  def __init__(self, dict_id=None, entry_count=None,):
4191  self.dict_id = dict_id
4192  self.entry_count = entry_count
4193 
4194  def read(self, iprot):
4195  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
4196  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
4197  return
4198  iprot.readStructBegin()
4199  while True:
4200  (fname, ftype, fid) = iprot.readFieldBegin()
4201  if ftype == TType.STOP:
4202  break
4203  if fid == 1:
4204  if ftype == TType.I32:
4205  self.dict_id = iprot.readI32()
4206  else:
4207  iprot.skip(ftype)
4208  elif fid == 2:
4209  if ftype == TType.I64:
4210  self.entry_count = iprot.readI64()
4211  else:
4212  iprot.skip(ftype)
4213  else:
4214  iprot.skip(ftype)
4215  iprot.readFieldEnd()
4216  iprot.readStructEnd()
4217 
4218  def write(self, oprot):
4219  if oprot._fast_encode is not None and self.thrift_spec is not None:
4220  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
4221  return
4222  oprot.writeStructBegin('TDictionaryGeneration')
4223  if self.dict_id is not None:
4224  oprot.writeFieldBegin('dict_id', TType.I32, 1)
4225  oprot.writeI32(self.dict_id)
4226  oprot.writeFieldEnd()
4227  if self.entry_count is not None:
4228  oprot.writeFieldBegin('entry_count', TType.I64, 2)
4229  oprot.writeI64(self.entry_count)
4230  oprot.writeFieldEnd()
4231  oprot.writeFieldStop()
4232  oprot.writeStructEnd()
4233 
4234  def validate(self):
4235  return
4236 
4237  def __repr__(self):
4238  L = ['%s=%r' % (key, value)
4239  for key, value in self.__dict__.items()]
4240  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4241 
4242  def __eq__(self, other):
4243  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4244 
4245  def __ne__(self, other):
4246  return not (self == other)
4247 
4248 
4249 class TTableGeneration(object):
4250  """
4251  Attributes:
4252  - table_id
4253  - tuple_count
4254  - start_rowid
4255 
4256  """
4257 
4258 
4259  def __init__(self, table_id=None, tuple_count=None, start_rowid=None,):
4260  self.table_id = table_id
4261  self.tuple_count = tuple_count
4262  self.start_rowid = start_rowid
4263 
4264  def read(self, iprot):
4265  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
4266  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
4267  return
4268  iprot.readStructBegin()
4269  while True:
4270  (fname, ftype, fid) = iprot.readFieldBegin()
4271  if ftype == TType.STOP:
4272  break
4273  if fid == 1:
4274  if ftype == TType.I32:
4275  self.table_id = iprot.readI32()
4276  else:
4277  iprot.skip(ftype)
4278  elif fid == 2:
4279  if ftype == TType.I64:
4280  self.tuple_count = iprot.readI64()
4281  else:
4282  iprot.skip(ftype)
4283  elif fid == 3:
4284  if ftype == TType.I64:
4285  self.start_rowid = iprot.readI64()
4286  else:
4287  iprot.skip(ftype)
4288  else:
4289  iprot.skip(ftype)
4290  iprot.readFieldEnd()
4291  iprot.readStructEnd()
4292 
4293  def write(self, oprot):
4294  if oprot._fast_encode is not None and self.thrift_spec is not None:
4295  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
4296  return
4297  oprot.writeStructBegin('TTableGeneration')
4298  if self.table_id is not None:
4299  oprot.writeFieldBegin('table_id', TType.I32, 1)
4300  oprot.writeI32(self.table_id)
4301  oprot.writeFieldEnd()
4302  if self.tuple_count is not None:
4303  oprot.writeFieldBegin('tuple_count', TType.I64, 2)
4304  oprot.writeI64(self.tuple_count)
4305  oprot.writeFieldEnd()
4306  if self.start_rowid is not None:
4307  oprot.writeFieldBegin('start_rowid', TType.I64, 3)
4308  oprot.writeI64(self.start_rowid)
4309  oprot.writeFieldEnd()
4310  oprot.writeFieldStop()
4311  oprot.writeStructEnd()
4312 
4313  def validate(self):
4314  return
4315 
4316  def __repr__(self):
4317  L = ['%s=%r' % (key, value)
4318  for key, value in self.__dict__.items()]
4319  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4320 
4321  def __eq__(self, other):
4322  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4323 
4324  def __ne__(self, other):
4325  return not (self == other)
4326 
4327 
4328 class TPendingQuery(object):
4329  """
4330  Attributes:
4331  - id
4332  - column_ranges
4333  - dictionary_generations
4334  - table_generations
4335  - parent_session_id
4336 
4337  """
4338 
4339 
4340  def __init__(self, id=None, column_ranges=None, dictionary_generations=None, table_generations=None, parent_session_id=None,):
4341  self.id = id
4342  self.column_ranges = column_ranges
4343  self.dictionary_generations = dictionary_generations
4344  self.table_generations = table_generations
4345  self.parent_session_id = parent_session_id
4346 
4347  def read(self, iprot):
4348  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
4349  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
4350  return
4351  iprot.readStructBegin()
4352  while True:
4353  (fname, ftype, fid) = iprot.readFieldBegin()
4354  if ftype == TType.STOP:
4355  break
4356  if fid == 1:
4357  if ftype == TType.I64:
4358  self.id = iprot.readI64()
4359  else:
4360  iprot.skip(ftype)
4361  elif fid == 2:
4362  if ftype == TType.LIST:
4363  self.column_ranges = []
4364  (_etype150, _size147) = iprot.readListBegin()
4365  for _i151 in range(_size147):
4366  _elem152 = TColumnRange()
4367  _elem152.read(iprot)
4368  self.column_ranges.append(_elem152)
4369  iprot.readListEnd()
4370  else:
4371  iprot.skip(ftype)
4372  elif fid == 3:
4373  if ftype == TType.LIST:
4374  self.dictionary_generations = []
4375  (_etype156, _size153) = iprot.readListBegin()
4376  for _i157 in range(_size153):
4377  _elem158 = TDictionaryGeneration()
4378  _elem158.read(iprot)
4379  self.dictionary_generations.append(_elem158)
4380  iprot.readListEnd()
4381  else:
4382  iprot.skip(ftype)
4383  elif fid == 4:
4384  if ftype == TType.LIST:
4385  self.table_generations = []
4386  (_etype162, _size159) = iprot.readListBegin()
4387  for _i163 in range(_size159):
4388  _elem164 = TTableGeneration()
4389  _elem164.read(iprot)
4390  self.table_generations.append(_elem164)
4391  iprot.readListEnd()
4392  else:
4393  iprot.skip(ftype)
4394  elif fid == 5:
4395  if ftype == TType.STRING:
4396  self.parent_session_id = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
4397  else:
4398  iprot.skip(ftype)
4399  else:
4400  iprot.skip(ftype)
4401  iprot.readFieldEnd()
4402  iprot.readStructEnd()
4403 
4404  def write(self, oprot):
4405  if oprot._fast_encode is not None and self.thrift_spec is not None:
4406  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
4407  return
4408  oprot.writeStructBegin('TPendingQuery')
4409  if self.id is not None:
4410  oprot.writeFieldBegin('id', TType.I64, 1)
4411  oprot.writeI64(self.id)
4412  oprot.writeFieldEnd()
4413  if self.column_ranges is not None:
4414  oprot.writeFieldBegin('column_ranges', TType.LIST, 2)
4415  oprot.writeListBegin(TType.STRUCT, len(self.column_ranges))
4416  for iter165 in self.column_ranges:
4417  iter165.write(oprot)
4418  oprot.writeListEnd()
4419  oprot.writeFieldEnd()
4420  if self.dictionary_generations is not None:
4421  oprot.writeFieldBegin('dictionary_generations', TType.LIST, 3)
4422  oprot.writeListBegin(TType.STRUCT, len(self.dictionary_generations))
4423  for iter166 in self.dictionary_generations:
4424  iter166.write(oprot)
4425  oprot.writeListEnd()
4426  oprot.writeFieldEnd()
4427  if self.table_generations is not None:
4428  oprot.writeFieldBegin('table_generations', TType.LIST, 4)
4429  oprot.writeListBegin(TType.STRUCT, len(self.table_generations))
4430  for iter167 in self.table_generations:
4431  iter167.write(oprot)
4432  oprot.writeListEnd()
4433  oprot.writeFieldEnd()
4434  if self.parent_session_id is not None:
4435  oprot.writeFieldBegin('parent_session_id', TType.STRING, 5)
4436  oprot.writeString(self.parent_session_id.encode('utf-8') if sys.version_info[0] == 2 else self.parent_session_id)
4437  oprot.writeFieldEnd()
4438  oprot.writeFieldStop()
4439  oprot.writeStructEnd()
4440 
4441  def validate(self):
4442  return
4443 
4444  def __repr__(self):
4445  L = ['%s=%r' % (key, value)
4446  for key, value in self.__dict__.items()]
4447  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4448 
4449  def __eq__(self, other):
4450  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4451 
4452  def __ne__(self, other):
4453  return not (self == other)
4454 
4455 
4456 class TVarLen(object):
4457  """
4458  Attributes:
4459  - payload
4460  - is_null
4461 
4462  """
4463 
4464 
4465  def __init__(self, payload=None, is_null=None,):
4466  self.payload = payload
4467  self.is_null = is_null
4468 
4469  def read(self, iprot):
4470  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
4471  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
4472  return
4473  iprot.readStructBegin()
4474  while True:
4475  (fname, ftype, fid) = iprot.readFieldBegin()
4476  if ftype == TType.STOP:
4477  break
4478  if fid == 1:
4479  if ftype == TType.STRING:
4480  self.payload = iprot.readBinary()
4481  else:
4482  iprot.skip(ftype)
4483  elif fid == 2:
4484  if ftype == TType.BOOL:
4485  self.is_null = iprot.readBool()
4486  else:
4487  iprot.skip(ftype)
4488  else:
4489  iprot.skip(ftype)
4490  iprot.readFieldEnd()
4491  iprot.readStructEnd()
4492 
4493  def write(self, oprot):
4494  if oprot._fast_encode is not None and self.thrift_spec is not None:
4495  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
4496  return
4497  oprot.writeStructBegin('TVarLen')
4498  if self.payload is not None:
4499  oprot.writeFieldBegin('payload', TType.STRING, 1)
4500  oprot.writeBinary(self.payload)
4501  oprot.writeFieldEnd()
4502  if self.is_null is not None:
4503  oprot.writeFieldBegin('is_null', TType.BOOL, 2)
4504  oprot.writeBool(self.is_null)
4505  oprot.writeFieldEnd()
4506  oprot.writeFieldStop()
4507  oprot.writeStructEnd()
4508 
4509  def validate(self):
4510  return
4511 
4512  def __repr__(self):
4513  L = ['%s=%r' % (key, value)
4514  for key, value in self.__dict__.items()]
4515  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4516 
4517  def __eq__(self, other):
4518  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4519 
4520  def __ne__(self, other):
4521  return not (self == other)
4522 
4523 
4524 class TDataBlockPtr(object):
4525  """
4526  Attributes:
4527  - fixed_len_data
4528  - var_len_data
4529 
4530  """
4531 
4532 
4533  def __init__(self, fixed_len_data=None, var_len_data=None,):
4534  self.fixed_len_data = fixed_len_data
4535  self.var_len_data = var_len_data
4536 
4537  def read(self, iprot):
4538  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
4539  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
4540  return
4541  iprot.readStructBegin()
4542  while True:
4543  (fname, ftype, fid) = iprot.readFieldBegin()
4544  if ftype == TType.STOP:
4545  break
4546  if fid == 1:
4547  if ftype == TType.STRING:
4548  self.fixed_len_data = iprot.readBinary()
4549  else:
4550  iprot.skip(ftype)
4551  elif fid == 2:
4552  if ftype == TType.LIST:
4553  self.var_len_data = []
4554  (_etype171, _size168) = iprot.readListBegin()
4555  for _i172 in range(_size168):
4556  _elem173 = TVarLen()
4557  _elem173.read(iprot)
4558  self.var_len_data.append(_elem173)
4559  iprot.readListEnd()
4560  else:
4561  iprot.skip(ftype)
4562  else:
4563  iprot.skip(ftype)
4564  iprot.readFieldEnd()
4565  iprot.readStructEnd()
4566 
4567  def write(self, oprot):
4568  if oprot._fast_encode is not None and self.thrift_spec is not None:
4569  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
4570  return
4571  oprot.writeStructBegin('TDataBlockPtr')
4572  if self.fixed_len_data is not None:
4573  oprot.writeFieldBegin('fixed_len_data', TType.STRING, 1)
4574  oprot.writeBinary(self.fixed_len_data)
4575  oprot.writeFieldEnd()
4576  if self.var_len_data is not None:
4577  oprot.writeFieldBegin('var_len_data', TType.LIST, 2)
4578  oprot.writeListBegin(TType.STRUCT, len(self.var_len_data))
4579  for iter174 in self.var_len_data:
4580  iter174.write(oprot)
4581  oprot.writeListEnd()
4582  oprot.writeFieldEnd()
4583  oprot.writeFieldStop()
4584  oprot.writeStructEnd()
4585 
4586  def validate(self):
4587  return
4588 
4589  def __repr__(self):
4590  L = ['%s=%r' % (key, value)
4591  for key, value in self.__dict__.items()]
4592  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4593 
4594  def __eq__(self, other):
4595  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4596 
4597  def __ne__(self, other):
4598  return not (self == other)
4599 
4600 
4601 class TInsertData(object):
4602  """
4603  Attributes:
4604  - db_id
4605  - table_id
4606  - column_ids
4607  - data
4608  - num_rows
4609  - is_default
4610 
4611  """
4612 
4613 
4614  def __init__(self, db_id=None, table_id=None, column_ids=None, data=None, num_rows=None, is_default=None,):
4615  self.db_id = db_id
4616  self.table_id = table_id
4617  self.column_ids = column_ids
4618  self.data = data
4619  self.num_rows = num_rows
4620  self.is_default = is_default
4621 
4622  def read(self, iprot):
4623  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
4624  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
4625  return
4626  iprot.readStructBegin()
4627  while True:
4628  (fname, ftype, fid) = iprot.readFieldBegin()
4629  if ftype == TType.STOP:
4630  break
4631  if fid == 1:
4632  if ftype == TType.I32:
4633  self.db_id = iprot.readI32()
4634  else:
4635  iprot.skip(ftype)
4636  elif fid == 2:
4637  if ftype == TType.I32:
4638  self.table_id = iprot.readI32()
4639  else:
4640  iprot.skip(ftype)
4641  elif fid == 3:
4642  if ftype == TType.LIST:
4643  self.column_ids = []
4644  (_etype178, _size175) = iprot.readListBegin()
4645  for _i179 in range(_size175):
4646  _elem180 = iprot.readI32()
4647  self.column_ids.append(_elem180)
4648  iprot.readListEnd()
4649  else:
4650  iprot.skip(ftype)
4651  elif fid == 4:
4652  if ftype == TType.LIST:
4653  self.data = []
4654  (_etype184, _size181) = iprot.readListBegin()
4655  for _i185 in range(_size181):
4656  _elem186 = TDataBlockPtr()
4657  _elem186.read(iprot)
4658  self.data.append(_elem186)
4659  iprot.readListEnd()
4660  else:
4661  iprot.skip(ftype)
4662  elif fid == 5:
4663  if ftype == TType.I64:
4664  self.num_rows = iprot.readI64()
4665  else:
4666  iprot.skip(ftype)
4667  elif fid == 6:
4668  if ftype == TType.LIST:
4669  self.is_default = []
4670  (_etype190, _size187) = iprot.readListBegin()
4671  for _i191 in range(_size187):
4672  _elem192 = iprot.readBool()
4673  self.is_default.append(_elem192)
4674  iprot.readListEnd()
4675  else:
4676  iprot.skip(ftype)
4677  else:
4678  iprot.skip(ftype)
4679  iprot.readFieldEnd()
4680  iprot.readStructEnd()
4681 
4682  def write(self, oprot):
4683  if oprot._fast_encode is not None and self.thrift_spec is not None:
4684  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
4685  return
4686  oprot.writeStructBegin('TInsertData')
4687  if self.db_id is not None:
4688  oprot.writeFieldBegin('db_id', TType.I32, 1)
4689  oprot.writeI32(self.db_id)
4690  oprot.writeFieldEnd()
4691  if self.table_id is not None:
4692  oprot.writeFieldBegin('table_id', TType.I32, 2)
4693  oprot.writeI32(self.table_id)
4694  oprot.writeFieldEnd()
4695  if self.column_ids is not None:
4696  oprot.writeFieldBegin('column_ids', TType.LIST, 3)
4697  oprot.writeListBegin(TType.I32, len(self.column_ids))
4698  for iter193 in self.column_ids:
4699  oprot.writeI32(iter193)
4700  oprot.writeListEnd()
4701  oprot.writeFieldEnd()
4702  if self.data is not None:
4703  oprot.writeFieldBegin('data', TType.LIST, 4)
4704  oprot.writeListBegin(TType.STRUCT, len(self.data))
4705  for iter194 in self.data:
4706  iter194.write(oprot)
4707  oprot.writeListEnd()
4708  oprot.writeFieldEnd()
4709  if self.num_rows is not None:
4710  oprot.writeFieldBegin('num_rows', TType.I64, 5)
4711  oprot.writeI64(self.num_rows)
4712  oprot.writeFieldEnd()
4713  if self.is_default is not None:
4714  oprot.writeFieldBegin('is_default', TType.LIST, 6)
4715  oprot.writeListBegin(TType.BOOL, len(self.is_default))
4716  for iter195 in self.is_default:
4717  oprot.writeBool(iter195)
4718  oprot.writeListEnd()
4719  oprot.writeFieldEnd()
4720  oprot.writeFieldStop()
4721  oprot.writeStructEnd()
4722 
4723  def validate(self):
4724  return
4725 
4726  def __repr__(self):
4727  L = ['%s=%r' % (key, value)
4728  for key, value in self.__dict__.items()]
4729  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4730 
4731  def __eq__(self, other):
4732  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4733 
4734  def __ne__(self, other):
4735  return not (self == other)
4736 
4737 
4738 class TChunkData(object):
4739  """
4740  Attributes:
4741  - data_buffer
4742  - index_buffer
4743 
4744  """
4745 
4746 
4747  def __init__(self, data_buffer=None, index_buffer=None,):
4748  self.data_buffer = data_buffer
4749  self.index_buffer = index_buffer
4750 
4751  def read(self, iprot):
4752  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
4753  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
4754  return
4755  iprot.readStructBegin()
4756  while True:
4757  (fname, ftype, fid) = iprot.readFieldBegin()
4758  if ftype == TType.STOP:
4759  break
4760  if fid == 1:
4761  if ftype == TType.STRING:
4762  self.data_buffer = iprot.readBinary()
4763  else:
4764  iprot.skip(ftype)
4765  elif fid == 2:
4766  if ftype == TType.STRING:
4767  self.index_buffer = iprot.readBinary()
4768  else:
4769  iprot.skip(ftype)
4770  else:
4771  iprot.skip(ftype)
4772  iprot.readFieldEnd()
4773  iprot.readStructEnd()
4774 
4775  def write(self, oprot):
4776  if oprot._fast_encode is not None and self.thrift_spec is not None:
4777  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
4778  return
4779  oprot.writeStructBegin('TChunkData')
4780  if self.data_buffer is not None:
4781  oprot.writeFieldBegin('data_buffer', TType.STRING, 1)
4782  oprot.writeBinary(self.data_buffer)
4783  oprot.writeFieldEnd()
4784  if self.index_buffer is not None:
4785  oprot.writeFieldBegin('index_buffer', TType.STRING, 2)
4786  oprot.writeBinary(self.index_buffer)
4787  oprot.writeFieldEnd()
4788  oprot.writeFieldStop()
4789  oprot.writeStructEnd()
4790 
4791  def validate(self):
4792  return
4793 
4794  def __repr__(self):
4795  L = ['%s=%r' % (key, value)
4796  for key, value in self.__dict__.items()]
4797  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4798 
4799  def __eq__(self, other):
4800  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4801 
4802  def __ne__(self, other):
4803  return not (self == other)
4804 
4805 
4806 class TInsertChunks(object):
4807  """
4808  Attributes:
4809  - db_id
4810  - table_id
4811  - data
4812  - valid_indices
4813  - num_rows
4814 
4815  """
4816 
4817 
4818  def __init__(self, db_id=None, table_id=None, data=None, valid_indices=None, num_rows=None,):
4819  self.db_id = db_id
4820  self.table_id = table_id
4821  self.data = data
4822  self.valid_indices = valid_indices
4823  self.num_rows = num_rows
4824 
4825  def read(self, iprot):
4826  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
4827  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
4828  return
4829  iprot.readStructBegin()
4830  while True:
4831  (fname, ftype, fid) = iprot.readFieldBegin()
4832  if ftype == TType.STOP:
4833  break
4834  if fid == 1:
4835  if ftype == TType.I32:
4836  self.db_id = iprot.readI32()
4837  else:
4838  iprot.skip(ftype)
4839  elif fid == 2:
4840  if ftype == TType.I32:
4841  self.table_id = iprot.readI32()
4842  else:
4843  iprot.skip(ftype)
4844  elif fid == 3:
4845  if ftype == TType.LIST:
4846  self.data = []
4847  (_etype199, _size196) = iprot.readListBegin()
4848  for _i200 in range(_size196):
4849  _elem201 = TChunkData()
4850  _elem201.read(iprot)
4851  self.data.append(_elem201)
4852  iprot.readListEnd()
4853  else:
4854  iprot.skip(ftype)
4855  elif fid == 4:
4856  if ftype == TType.LIST:
4857  self.valid_indices = []
4858  (_etype205, _size202) = iprot.readListBegin()
4859  for _i206 in range(_size202):
4860  _elem207 = iprot.readI64()
4861  self.valid_indices.append(_elem207)
4862  iprot.readListEnd()
4863  else:
4864  iprot.skip(ftype)
4865  elif fid == 5:
4866  if ftype == TType.I64:
4867  self.num_rows = iprot.readI64()
4868  else:
4869  iprot.skip(ftype)
4870  else:
4871  iprot.skip(ftype)
4872  iprot.readFieldEnd()
4873  iprot.readStructEnd()
4874 
4875  def write(self, oprot):
4876  if oprot._fast_encode is not None and self.thrift_spec is not None:
4877  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
4878  return
4879  oprot.writeStructBegin('TInsertChunks')
4880  if self.db_id is not None:
4881  oprot.writeFieldBegin('db_id', TType.I32, 1)
4882  oprot.writeI32(self.db_id)
4883  oprot.writeFieldEnd()
4884  if self.table_id is not None:
4885  oprot.writeFieldBegin('table_id', TType.I32, 2)
4886  oprot.writeI32(self.table_id)
4887  oprot.writeFieldEnd()
4888  if self.data is not None:
4889  oprot.writeFieldBegin('data', TType.LIST, 3)
4890  oprot.writeListBegin(TType.STRUCT, len(self.data))
4891  for iter208 in self.data:
4892  iter208.write(oprot)
4893  oprot.writeListEnd()
4894  oprot.writeFieldEnd()
4895  if self.valid_indices is not None:
4896  oprot.writeFieldBegin('valid_indices', TType.LIST, 4)
4897  oprot.writeListBegin(TType.I64, len(self.valid_indices))
4898  for iter209 in self.valid_indices:
4899  oprot.writeI64(iter209)
4900  oprot.writeListEnd()
4901  oprot.writeFieldEnd()
4902  if self.num_rows is not None:
4903  oprot.writeFieldBegin('num_rows', TType.I64, 5)
4904  oprot.writeI64(self.num_rows)
4905  oprot.writeFieldEnd()
4906  oprot.writeFieldStop()
4907  oprot.writeStructEnd()
4908 
4909  def validate(self):
4910  return
4911 
4912  def __repr__(self):
4913  L = ['%s=%r' % (key, value)
4914  for key, value in self.__dict__.items()]
4915  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4916 
4917  def __eq__(self, other):
4918  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4919 
4920  def __ne__(self, other):
4921  return not (self == other)
4922 
4923 
4924 class TPendingRenderQuery(object):
4925  """
4926  Attributes:
4927  - id
4928 
4929  """
4930 
4931 
4932  def __init__(self, id=None,):
4933  self.id = id
4934 
4935  def read(self, iprot):
4936  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
4937  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
4938  return
4939  iprot.readStructBegin()
4940  while True:
4941  (fname, ftype, fid) = iprot.readFieldBegin()
4942  if ftype == TType.STOP:
4943  break
4944  if fid == 1:
4945  if ftype == TType.I64:
4946  self.id = iprot.readI64()
4947  else:
4948  iprot.skip(ftype)
4949  else:
4950  iprot.skip(ftype)
4951  iprot.readFieldEnd()
4952  iprot.readStructEnd()
4953 
4954  def write(self, oprot):
4955  if oprot._fast_encode is not None and self.thrift_spec is not None:
4956  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
4957  return
4958  oprot.writeStructBegin('TPendingRenderQuery')
4959  if self.id is not None:
4960  oprot.writeFieldBegin('id', TType.I64, 1)
4961  oprot.writeI64(self.id)
4962  oprot.writeFieldEnd()
4963  oprot.writeFieldStop()
4964  oprot.writeStructEnd()
4965 
4966  def validate(self):
4967  return
4968 
4969  def __repr__(self):
4970  L = ['%s=%r' % (key, value)
4971  for key, value in self.__dict__.items()]
4972  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
4973 
4974  def __eq__(self, other):
4975  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
4976 
4977  def __ne__(self, other):
4978  return not (self == other)
4979 
4980 
4981 class TRenderParseResult(object):
4982  """
4983  Attributes:
4984  - merge_type
4985  - node_id
4986  - execution_time_ms
4987  - render_time_ms
4988  - total_time_ms
4989 
4990  """
4991 
4992 
4993  def __init__(self, merge_type=None, node_id=None, execution_time_ms=None, render_time_ms=None, total_time_ms=None,):
4994  self.merge_type = merge_type
4995  self.node_id = node_id
4996  self.execution_time_ms = execution_time_ms
4997  self.render_time_ms = render_time_ms
4998  self.total_time_ms = total_time_ms
4999 
5000  def read(self, iprot):
5001  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
5002  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
5003  return
5004  iprot.readStructBegin()
5005  while True:
5006  (fname, ftype, fid) = iprot.readFieldBegin()
5007  if ftype == TType.STOP:
5008  break
5009  if fid == 1:
5010  if ftype == TType.I32:
5011  self.merge_type = iprot.readI32()
5012  else:
5013  iprot.skip(ftype)
5014  elif fid == 2:
5015  if ftype == TType.I32:
5016  self.node_id = iprot.readI32()
5017  else:
5018  iprot.skip(ftype)
5019  elif fid == 3:
5020  if ftype == TType.I64:
5021  self.execution_time_ms = iprot.readI64()
5022  else:
5023  iprot.skip(ftype)
5024  elif fid == 4:
5025  if ftype == TType.I64:
5026  self.render_time_ms = iprot.readI64()
5027  else:
5028  iprot.skip(ftype)
5029  elif fid == 5:
5030  if ftype == TType.I64:
5031  self.total_time_ms = iprot.readI64()
5032  else:
5033  iprot.skip(ftype)
5034  else:
5035  iprot.skip(ftype)
5036  iprot.readFieldEnd()
5037  iprot.readStructEnd()
5038 
5039  def write(self, oprot):
5040  if oprot._fast_encode is not None and self.thrift_spec is not None:
5041  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
5042  return
5043  oprot.writeStructBegin('TRenderParseResult')
5044  if self.merge_type is not None:
5045  oprot.writeFieldBegin('merge_type', TType.I32, 1)
5046  oprot.writeI32(self.merge_type)
5047  oprot.writeFieldEnd()
5048  if self.node_id is not None:
5049  oprot.writeFieldBegin('node_id', TType.I32, 2)
5050  oprot.writeI32(self.node_id)
5051  oprot.writeFieldEnd()
5052  if self.execution_time_ms is not None:
5053  oprot.writeFieldBegin('execution_time_ms', TType.I64, 3)
5054  oprot.writeI64(self.execution_time_ms)
5055  oprot.writeFieldEnd()
5056  if self.render_time_ms is not None:
5057  oprot.writeFieldBegin('render_time_ms', TType.I64, 4)
5058  oprot.writeI64(self.render_time_ms)
5059  oprot.writeFieldEnd()
5060  if self.total_time_ms is not None:
5061  oprot.writeFieldBegin('total_time_ms', TType.I64, 5)
5062  oprot.writeI64(self.total_time_ms)
5063  oprot.writeFieldEnd()
5064  oprot.writeFieldStop()
5065  oprot.writeStructEnd()
5066 
5067  def validate(self):
5068  return
5069 
5070  def __repr__(self):
5071  L = ['%s=%r' % (key, value)
5072  for key, value in self.__dict__.items()]
5073  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
5074 
5075  def __eq__(self, other):
5076  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
5077 
5078  def __ne__(self, other):
5079  return not (self == other)
5080 
5081 
5083  """
5084  Attributes:
5085  - num_pixel_channels
5086  - num_pixel_samples
5087  - pixels
5088  - row_ids_A
5089  - row_ids_B
5090  - table_ids
5091  - accum_data
5092  - accum_depth
5093 
5094  """
5095 
5096 
5097  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,):
5098  self.num_pixel_channels = num_pixel_channels
5099  self.num_pixel_samples = num_pixel_samples
5100  self.pixels = pixels
5101  self.row_ids_A = row_ids_A
5102  self.row_ids_B = row_ids_B
5103  self.table_ids = table_ids
5104  self.accum_data = accum_data
5105  self.accum_depth = accum_depth
5106 
5107  def read(self, iprot):
5108  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
5109  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
5110  return
5111  iprot.readStructBegin()
5112  while True:
5113  (fname, ftype, fid) = iprot.readFieldBegin()
5114  if ftype == TType.STOP:
5115  break
5116  if fid == 1:
5117  if ftype == TType.I32:
5118  self.num_pixel_channels = iprot.readI32()
5119  else:
5120  iprot.skip(ftype)
5121  elif fid == 2:
5122  if ftype == TType.I32:
5123  self.num_pixel_samples = iprot.readI32()
5124  else:
5125  iprot.skip(ftype)
5126  elif fid == 3:
5127  if ftype == TType.STRING:
5128  self.pixels = iprot.readBinary()
5129  else:
5130  iprot.skip(ftype)
5131  elif fid == 4:
5132  if ftype == TType.STRING:
5133  self.row_ids_A = iprot.readBinary()
5134  else:
5135  iprot.skip(ftype)
5136  elif fid == 5:
5137  if ftype == TType.STRING:
5138  self.row_ids_B = iprot.readBinary()
5139  else:
5140  iprot.skip(ftype)
5141  elif fid == 6:
5142  if ftype == TType.STRING:
5143  self.table_ids = iprot.readBinary()
5144  else:
5145  iprot.skip(ftype)
5146  elif fid == 7:
5147  if ftype == TType.STRING:
5148  self.accum_data = iprot.readBinary()
5149  else:
5150  iprot.skip(ftype)
5151  elif fid == 8:
5152  if ftype == TType.I32:
5153  self.accum_depth = iprot.readI32()
5154  else:
5155  iprot.skip(ftype)
5156  else:
5157  iprot.skip(ftype)
5158  iprot.readFieldEnd()
5159  iprot.readStructEnd()
5160 
5161  def write(self, oprot):
5162  if oprot._fast_encode is not None and self.thrift_spec is not None:
5163  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
5164  return
5165  oprot.writeStructBegin('TRawRenderPassDataResult')
5166  if self.num_pixel_channels is not None:
5167  oprot.writeFieldBegin('num_pixel_channels', TType.I32, 1)
5168  oprot.writeI32(self.num_pixel_channels)
5169  oprot.writeFieldEnd()
5170  if self.num_pixel_samples is not None:
5171  oprot.writeFieldBegin('num_pixel_samples', TType.I32, 2)
5172  oprot.writeI32(self.num_pixel_samples)
5173  oprot.writeFieldEnd()
5174  if self.pixels is not None:
5175  oprot.writeFieldBegin('pixels', TType.STRING, 3)
5176  oprot.writeBinary(self.pixels)
5177  oprot.writeFieldEnd()
5178  if self.row_ids_A is not None:
5179  oprot.writeFieldBegin('row_ids_A', TType.STRING, 4)
5180  oprot.writeBinary(self.