9 from thrift.Thrift
import TType, TMessageType, TFrozenDict, TException, TApplicationException
10 from thrift.protocol.TProtocol
import TProtocolException
11 from thrift.TRecursive
import fix_spec
19 from thrift.transport
import TTransport
100 "UNSUPPORTED_GEO": 3,
126 STRING_DICTIONARY = 3
132 3:
"STRING_DICTIONARY",
139 "STRING_DICTIONARY": 3,
339 AbstractDBObjectType = 0
340 DatabaseDBObjectType = 1
341 TableDBObjectType = 2
342 DashboardDBObjectType = 3
344 ServerDBObjectType = 5
347 0:
"AbstractDBObjectType",
348 1:
"DatabaseDBObjectType",
349 2:
"TableDBObjectType",
350 3:
"DashboardDBObjectType",
351 4:
"ViewDBObjectType",
352 5:
"ServerDBObjectType",
356 "AbstractDBObjectType": 0,
357 "DatabaseDBObjectType": 1,
358 "TableDBObjectType": 2,
359 "DashboardDBObjectType": 3,
360 "ViewDBObjectType": 4,
361 "ServerDBObjectType": 5,
388 def __init__(self, int_val=None, real_val=None, str_val=None, arr_val=None,):
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])
398 iprot.readStructBegin()
400 (fname, ftype, fid) = iprot.readFieldBegin()
401 if ftype == TType.STOP:
404 if ftype == TType.I64:
409 if ftype == TType.DOUBLE:
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()
419 if ftype == TType.LIST:
421 (_etype3, _size0) = iprot.readListBegin()
422 for _i4
in range(_size0):
425 self.arr_val.append(_elem5)
432 iprot.readStructEnd()
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]))
438 oprot.writeStructBegin(
'TDatumVal')
440 oprot.writeFieldBegin(
'int_val', TType.I64, 1)
442 oprot.writeFieldEnd()
444 oprot.writeFieldBegin(
'real_val', TType.DOUBLE, 2)
446 oprot.writeFieldEnd()
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()
452 oprot.writeFieldBegin(
'arr_val', TType.LIST, 4)
453 oprot.writeListBegin(TType.STRUCT, len(self.
arr_val))
457 oprot.writeFieldEnd()
458 oprot.writeFieldStop()
459 oprot.writeStructEnd()
465 L = [
'%s=%r' % (key, value)
466 for key, value
in self.__dict__.items()]
467 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
470 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
473 return not (self == other)
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])
493 iprot.readStructBegin()
495 (fname, ftype, fid) = iprot.readFieldBegin()
496 if ftype == TType.STOP:
499 if ftype == TType.STRUCT:
505 if ftype == TType.BOOL:
506 self.
is_null = iprot.readBool()
512 iprot.readStructEnd()
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]))
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()
524 oprot.writeFieldBegin(
'is_null', TType.BOOL, 2)
526 oprot.writeFieldEnd()
527 oprot.writeFieldStop()
528 oprot.writeStructEnd()
534 L = [
'%s=%r' % (key, value)
535 for key, value
in self.__dict__.items()]
536 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
539 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
542 return not (self == other)
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])
562 iprot.readStructBegin()
564 (fname, ftype, fid) = iprot.readFieldBegin()
565 if ftype == TType.STOP:
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()
573 if ftype == TType.BOOL:
574 self.
is_null = iprot.readBool()
580 iprot.readStructEnd()
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]))
586 oprot.writeStructBegin(
'TStringValue')
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()
592 oprot.writeFieldBegin(
'is_null', TType.BOOL, 2)
594 oprot.writeFieldEnd()
595 oprot.writeFieldStop()
596 oprot.writeStructEnd()
602 L = [
'%s=%r' % (key, value)
603 for key, value
in self.__dict__.items()]
604 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
607 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
610 return not (self == other)
618 - is_reserved_keyword
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,):
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])
642 iprot.readStructBegin()
644 (fname, ftype, fid) = iprot.readFieldBegin()
645 if ftype == TType.STOP:
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()
653 if ftype == TType.STRUCT:
655 self.col_type.read(iprot)
659 if ftype == TType.BOOL:
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()
669 if ftype == TType.BOOL:
674 if ftype == TType.BOOL:
679 if ftype == TType.I64:
680 self.
col_id = iprot.readI64()
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()
691 iprot.readStructEnd()
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]))
697 oprot.writeStructBegin(
'TColumnType')
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()
703 oprot.writeFieldBegin(
'col_type', TType.STRUCT, 2)
704 self.col_type.write(oprot)
705 oprot.writeFieldEnd()
707 oprot.writeFieldBegin(
'is_reserved_keyword', TType.BOOL, 3)
709 oprot.writeFieldEnd()
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()
715 oprot.writeFieldBegin(
'is_system', TType.BOOL, 5)
717 oprot.writeFieldEnd()
719 oprot.writeFieldBegin(
'is_physical', TType.BOOL, 6)
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()
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()
737 L = [
'%s=%r' % (key, value)
738 for key, value
in self.__dict__.items()]
739 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
742 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
745 return not (self == other)
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])
763 iprot.readStructBegin()
765 (fname, ftype, fid) = iprot.readFieldBegin()
766 if ftype == TType.STOP:
769 if ftype == TType.LIST:
771 (_etype10, _size7) = iprot.readListBegin()
772 for _i11
in range(_size7):
775 self.cols.append(_elem12)
782 iprot.readStructEnd()
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]))
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:
795 oprot.writeFieldEnd()
796 oprot.writeFieldStop()
797 oprot.writeStructEnd()
803 L = [
'%s=%r' % (key, value)
804 for key, value
in self.__dict__.items()]
805 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
808 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
811 return not (self == other)
825 def __init__(self, int_col=None, real_col=None, str_col=None, arr_col=None,):
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])
835 iprot.readStructBegin()
837 (fname, ftype, fid) = iprot.readFieldBegin()
838 if ftype == TType.STOP:
841 if ftype == TType.LIST:
843 (_etype17, _size14) = iprot.readListBegin()
844 for _i18
in range(_size14):
845 _elem19 = iprot.readI64()
846 self.int_col.append(_elem19)
851 if ftype == TType.LIST:
853 (_etype23, _size20) = iprot.readListBegin()
854 for _i24
in range(_size20):
855 _elem25 = iprot.readDouble()
856 self.real_col.append(_elem25)
861 if ftype == TType.LIST:
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)
871 if ftype == TType.LIST:
873 (_etype35, _size32) = iprot.readListBegin()
874 for _i36
in range(_size32):
877 self.arr_col.append(_elem37)
884 iprot.readStructEnd()
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]))
890 oprot.writeStructBegin(
'TColumnData')
892 oprot.writeFieldBegin(
'int_col', TType.LIST, 1)
893 oprot.writeListBegin(TType.I64, len(self.
int_col))
895 oprot.writeI64(iter38)
897 oprot.writeFieldEnd()
899 oprot.writeFieldBegin(
'real_col', TType.LIST, 2)
900 oprot.writeListBegin(TType.DOUBLE, len(self.
real_col))
902 oprot.writeDouble(iter39)
904 oprot.writeFieldEnd()
906 oprot.writeFieldBegin(
'str_col', TType.LIST, 3)
907 oprot.writeListBegin(TType.STRING, len(self.
str_col))
909 oprot.writeString(iter40.encode(
'utf-8')
if sys.version_info[0] == 2
else iter40)
911 oprot.writeFieldEnd()
913 oprot.writeFieldBegin(
'arr_col', TType.LIST, 4)
914 oprot.writeListBegin(TType.STRUCT, len(self.
arr_col))
918 oprot.writeFieldEnd()
919 oprot.writeFieldStop()
920 oprot.writeStructEnd()
926 L = [
'%s=%r' % (key, value)
927 for key, value
in self.__dict__.items()]
928 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
931 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
934 return not (self == other)
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])
954 iprot.readStructBegin()
956 (fname, ftype, fid) = iprot.readFieldBegin()
957 if ftype == TType.STOP:
960 if ftype == TType.STRUCT:
962 self.data.read(iprot)
966 if ftype == TType.LIST:
968 (_etype45, _size42) = iprot.readListBegin()
969 for _i46
in range(_size42):
970 _elem47 = iprot.readBool()
971 self.nulls.append(_elem47)
978 iprot.readStructEnd()
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]))
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)
995 oprot.writeFieldEnd()
996 oprot.writeFieldStop()
997 oprot.writeStructEnd()
1003 L = [
'%s=%r' % (key, value)
1004 for key, value
in self.__dict__.items()]
1005 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
1008 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
1011 return not (self == other)
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])
1029 iprot.readStructBegin()
1031 (fname, ftype, fid) = iprot.readFieldBegin()
1032 if ftype == TType.STOP:
1035 if ftype == TType.LIST:
1037 (_etype52, _size49) = iprot.readListBegin()
1038 for _i53
in range(_size49):
1041 self.cols.append(_elem54)
1047 iprot.readFieldEnd()
1048 iprot.readStructEnd()
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]))
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:
1060 oprot.writeListEnd()
1061 oprot.writeFieldEnd()
1062 oprot.writeFieldStop()
1063 oprot.writeStructEnd()
1069 L = [
'%s=%r' % (key, value)
1070 for key, value
in self.__dict__.items()]
1071 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
1074 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
1077 return not (self == other)
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])
1097 iprot.readStructBegin()
1099 (fname, ftype, fid) = iprot.readFieldBegin()
1100 if ftype == TType.STOP:
1103 if ftype == TType.STRING:
1104 self.
sessionId = iprot.readString().decode(
'utf-8', errors=
'replace')
if sys.version_info[0] == 2
else iprot.readString()
1108 if ftype == TType.STRING:
1109 self.
krbToken = iprot.readString().decode(
'utf-8', errors=
'replace')
if sys.version_info[0] == 2
else iprot.readString()
1114 iprot.readFieldEnd()
1115 iprot.readStructEnd()
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]))
1121 oprot.writeStructBegin(
'TKrb5Session')
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()
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()
1137 L = [
'%s=%r' % (key, value)
1138 for key, value
in self.__dict__.items()]
1139 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
1142 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
1145 return not (self == other)
1152 - execution_finished
1161 def __init__(self, serialized_rows=None, execution_finished=None, merge_type=None, sharded=None, row_desc=None, node_id=None,):
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])
1173 iprot.readStructBegin()
1175 (fname, ftype, fid) = iprot.readFieldBegin()
1176 if ftype == TType.STOP:
1179 if ftype == TType.STRUCT:
1181 self.serialized_rows.read(iprot)
1185 if ftype == TType.BOOL:
1190 if ftype == TType.I32:
1195 if ftype == TType.BOOL:
1196 self.
sharded = iprot.readBool()
1200 if ftype == TType.LIST:
1202 (_etype59, _size56) = iprot.readListBegin()
1203 for _i60
in range(_size56):
1206 self.row_desc.append(_elem61)
1211 if ftype == TType.I32:
1212 self.
node_id = iprot.readI32()
1217 iprot.readFieldEnd()
1218 iprot.readStructEnd()
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]))
1224 oprot.writeStructBegin(
'TStepResult')
1226 oprot.writeFieldBegin(
'serialized_rows', TType.STRUCT, 1)
1227 self.serialized_rows.write(oprot)
1228 oprot.writeFieldEnd()
1230 oprot.writeFieldBegin(
'execution_finished', TType.BOOL, 2)
1232 oprot.writeFieldEnd()
1234 oprot.writeFieldBegin(
'merge_type', TType.I32, 3)
1236 oprot.writeFieldEnd()
1238 oprot.writeFieldBegin(
'sharded', TType.BOOL, 4)
1240 oprot.writeFieldEnd()
1242 oprot.writeFieldBegin(
'row_desc', TType.LIST, 5)
1243 oprot.writeListBegin(TType.STRUCT, len(self.
row_desc))
1246 oprot.writeListEnd()
1247 oprot.writeFieldEnd()
1249 oprot.writeFieldBegin(
'node_id', TType.I32, 6)
1251 oprot.writeFieldEnd()
1252 oprot.writeFieldStop()
1253 oprot.writeStructEnd()
1259 L = [
'%s=%r' % (key, value)
1260 for key, value
in self.__dict__.items()]
1261 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
1264 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
1267 return not (self == other)
1281 def __init__(self, row_desc=None, rows=None, columns=None, is_columnar=None,):
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])
1291 iprot.readStructBegin()
1293 (fname, ftype, fid) = iprot.readFieldBegin()
1294 if ftype == TType.STOP:
1297 if ftype == TType.LIST:
1299 (_etype66, _size63) = iprot.readListBegin()
1300 for _i67
in range(_size63):
1303 self.row_desc.append(_elem68)
1308 if ftype == TType.LIST:
1310 (_etype72, _size69) = iprot.readListBegin()
1311 for _i73
in range(_size69):
1314 self.rows.append(_elem74)
1319 if ftype == TType.LIST:
1321 (_etype78, _size75) = iprot.readListBegin()
1322 for _i79
in range(_size75):
1325 self.columns.append(_elem80)
1330 if ftype == TType.BOOL:
1336 iprot.readFieldEnd()
1337 iprot.readStructEnd()
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]))
1343 oprot.writeStructBegin(
'TRowSet')
1345 oprot.writeFieldBegin(
'row_desc', TType.LIST, 1)
1346 oprot.writeListBegin(TType.STRUCT, len(self.
row_desc))
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:
1356 oprot.writeListEnd()
1357 oprot.writeFieldEnd()
1359 oprot.writeFieldBegin(
'columns', TType.LIST, 3)
1360 oprot.writeListBegin(TType.STRUCT, len(self.
columns))
1363 oprot.writeListEnd()
1364 oprot.writeFieldEnd()
1366 oprot.writeFieldBegin(
'is_columnar', TType.BOOL, 4)
1368 oprot.writeFieldEnd()
1369 oprot.writeFieldStop()
1370 oprot.writeStructEnd()
1376 L = [
'%s=%r' % (key, value)
1377 for key, value
in self.__dict__.items()]
1378 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
1381 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
1384 return not (self == other)
1401 def __init__(self, row_set=None, execution_time_ms=None, total_time_ms=None, nonce=None, debug=None, success=True, query_type=0,):
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])
1414 iprot.readStructBegin()
1416 (fname, ftype, fid) = iprot.readFieldBegin()
1417 if ftype == TType.STOP:
1420 if ftype == TType.STRUCT:
1422 self.row_set.read(iprot)
1426 if ftype == TType.I64:
1431 if ftype == TType.I64:
1436 if ftype == TType.STRING:
1437 self.
nonce = iprot.readString().decode(
'utf-8', errors=
'replace')
if sys.version_info[0] == 2
else iprot.readString()
1441 if ftype == TType.STRING:
1442 self.
debug = iprot.readString().decode(
'utf-8', errors=
'replace')
if sys.version_info[0] == 2
else iprot.readString()
1446 if ftype == TType.BOOL:
1447 self.
success = iprot.readBool()
1451 if ftype == TType.I32:
1457 iprot.readFieldEnd()
1458 iprot.readStructEnd()
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]))
1464 oprot.writeStructBegin(
'TQueryResult')
1466 oprot.writeFieldBegin(
'row_set', TType.STRUCT, 1)
1467 self.row_set.write(oprot)
1468 oprot.writeFieldEnd()
1470 oprot.writeFieldBegin(
'execution_time_ms', TType.I64, 2)
1472 oprot.writeFieldEnd()
1474 oprot.writeFieldBegin(
'total_time_ms', TType.I64, 3)
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()
1486 oprot.writeFieldBegin(
'success', TType.BOOL, 6)
1488 oprot.writeFieldEnd()
1490 oprot.writeFieldBegin(
'query_type', TType.I32, 7)
1492 oprot.writeFieldEnd()
1493 oprot.writeFieldStop()
1494 oprot.writeStructEnd()
1500 L = [
'%s=%r' % (key, value)
1501 for key, value
in self.__dict__.items()]
1502 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
1505 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
1508 return not (self == other)
1519 - arrow_conversion_time_ms
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,):
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])
1538 iprot.readStructBegin()
1540 (fname, ftype, fid) = iprot.readFieldBegin()
1541 if ftype == TType.STOP:
1544 if ftype == TType.STRING:
1549 if ftype == TType.I64:
1550 self.
sm_size = iprot.readI64()
1554 if ftype == TType.STRING:
1559 if ftype == TType.I64:
1560 self.
df_size = iprot.readI64()
1564 if ftype == TType.I64:
1569 if ftype == TType.I64:
1574 if ftype == TType.STRING:
1580 iprot.readFieldEnd()
1581 iprot.readStructEnd()
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]))
1587 oprot.writeStructBegin(
'TDataFrame')
1589 oprot.writeFieldBegin(
'sm_handle', TType.STRING, 1)
1591 oprot.writeFieldEnd()
1593 oprot.writeFieldBegin(
'sm_size', TType.I64, 2)
1595 oprot.writeFieldEnd()
1597 oprot.writeFieldBegin(
'df_handle', TType.STRING, 3)
1599 oprot.writeFieldEnd()
1601 oprot.writeFieldBegin(
'df_size', TType.I64, 4)
1603 oprot.writeFieldEnd()
1605 oprot.writeFieldBegin(
'execution_time_ms', TType.I64, 5)
1607 oprot.writeFieldEnd()
1609 oprot.writeFieldBegin(
'arrow_conversion_time_ms', TType.I64, 6)
1611 oprot.writeFieldEnd()
1613 oprot.writeFieldBegin(
'df_buffer', TType.STRING, 7)
1615 oprot.writeFieldEnd()
1616 oprot.writeFieldStop()
1617 oprot.writeStructEnd()
1623 L = [
'%s=%r' % (key, value)
1624 for key, value
in self.__dict__.items()]
1625 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
1628 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
1631 return not (self == other)
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])
1651 iprot.readStructBegin()
1653 (fname, ftype, fid) = iprot.readFieldBegin()
1654 if ftype == TType.STOP:
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()
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()
1668 iprot.readFieldEnd()
1669 iprot.readStructEnd()
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]))
1675 oprot.writeStructBegin(
'TDBInfo')
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()
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()
1691 L = [
'%s=%r' % (key, value)
1692 for key, value
in self.__dict__.items()]
1693 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
1696 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
1699 return not (self == other)
1711 super(TDBException, self).
__setattr__(
'error_msg', error_msg)
1714 raise TypeError(
"can't modify immutable instance")
1717 raise TypeError(
"can't modify immutable instance")
1720 return hash(self.__class__) ^ hash((self.error_msg, ))
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()
1729 (fname, ftype, fid) = iprot.readFieldBegin()
1730 if ftype == TType.STOP:
1733 if ftype == TType.STRING:
1734 error_msg = iprot.readString().decode(
'utf-8', errors=
'replace')
if sys.version_info[0] == 2
else iprot.readString()
1739 iprot.readFieldEnd()
1740 iprot.readStructEnd()
1742 error_msg=error_msg,
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]))
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()
1764 L = [
'%s=%r' % (key, value)
1765 for key, value
in self.__dict__.items()]
1766 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
1769 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
1772 return not (self == other)
1793 - geo_coords_encoding
1794 - geo_coords_comp_param
1797 - sanitize_column_names
1800 - geo_assign_render_groups
1801 - geo_explode_collections
1805 - raster_import_bands
1806 - raster_scanlines_per_thread
1807 - raster_point_transform
1808 - raster_point_compute_angle
1809 - raster_import_dimensions
1811 - odbc_connection_string
1815 - odbc_credential_string
1816 - add_metadata_columns
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,):
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])
1866 iprot.readStructBegin()
1868 (fname, ftype, fid) = iprot.readFieldBegin()
1869 if ftype == TType.STOP:
1872 if ftype == TType.STRING:
1873 self.
delimiter = iprot.readString().decode(
'utf-8', errors=
'replace')
if sys.version_info[0] == 2
else iprot.readString()
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()
1882 if ftype == TType.I32:
1887 if ftype == TType.BOOL:
1888 self.
quoted = iprot.readBool()
1892 if ftype == TType.STRING:
1893 self.
quote = iprot.readString().decode(
'utf-8', errors=
'replace')
if sys.version_info[0] == 2
else iprot.readString()
1897 if ftype == TType.STRING:
1898 self.
escape = iprot.readString().decode(
'utf-8', errors=
'replace')
if sys.version_info[0] == 2
else iprot.readString()
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()
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()
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()
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()
1922 if ftype == TType.I32:
1923 self.
threads = iprot.readI32()
1927 if ftype == TType.I32:
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()
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()
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()
1947 if ftype == TType.I32:
1952 if ftype == TType.I32:
1957 if ftype == TType.I32:
1962 if ftype == TType.I32:
1967 if ftype == TType.BOOL:
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()
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()
1982 if ftype == TType.BOOL:
1987 if ftype == TType.BOOL:
1992 if ftype == TType.I32:
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()
2002 if ftype == TType.I32:
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()
2012 if ftype == TType.I32:
2017 if ftype == TType.I32:
2022 if ftype == TType.BOOL:
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()
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()
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()
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()
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()
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()
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()
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()
2068 iprot.readFieldEnd()
2069 iprot.readStructEnd()
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]))
2075 oprot.writeStructBegin(
'TCopyParams')
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()
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()
2085 oprot.writeFieldBegin(
'has_header', TType.I32, 3)
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()
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()
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()
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()
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()
2117 oprot.writeFieldBegin(
'threads', TType.I32, 11)
2119 oprot.writeFieldEnd()
2121 oprot.writeFieldBegin(
'source_type', TType.I32, 12)
2123 oprot.writeFieldEnd()
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()
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()
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()
2137 oprot.writeFieldBegin(
'geo_coords_encoding', TType.I32, 16)
2139 oprot.writeFieldEnd()
2141 oprot.writeFieldBegin(
'geo_coords_comp_param', TType.I32, 17)
2143 oprot.writeFieldEnd()
2145 oprot.writeFieldBegin(
'geo_coords_type', TType.I32, 18)
2147 oprot.writeFieldEnd()
2149 oprot.writeFieldBegin(
'geo_coords_srid', TType.I32, 19)
2151 oprot.writeFieldEnd()
2153 oprot.writeFieldBegin(
'sanitize_column_names', TType.BOOL, 20)
2155 oprot.writeFieldEnd()
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()
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()
2165 oprot.writeFieldBegin(
'geo_assign_render_groups', TType.BOOL, 23)
2167 oprot.writeFieldEnd()
2169 oprot.writeFieldBegin(
'geo_explode_collections', TType.BOOL, 24)
2171 oprot.writeFieldEnd()
2173 oprot.writeFieldBegin(
'source_srid', TType.I32, 25)
2175 oprot.writeFieldEnd()
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()
2181 oprot.writeFieldBegin(
'raster_point_type', TType.I32, 27)
2183 oprot.writeFieldEnd()
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()
2189 oprot.writeFieldBegin(
'raster_scanlines_per_thread', TType.I32, 29)
2191 oprot.writeFieldEnd()
2193 oprot.writeFieldBegin(
'raster_point_transform', TType.I32, 30)
2195 oprot.writeFieldEnd()
2197 oprot.writeFieldBegin(
'raster_point_compute_angle', TType.BOOL, 31)
2199 oprot.writeFieldEnd()
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()
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()
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()
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()
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()
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()
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()
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()
2239 L = [
'%s=%r' % (key, value)
2240 for key, value
in self.__dict__.items()]
2241 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
2244 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
2247 return not (self == other)
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])
2265 iprot.readStructBegin()
2267 (fname, ftype, fid) = iprot.readFieldBegin()
2268 if ftype == TType.STOP:
2271 if ftype == TType.BOOL:
2277 iprot.readFieldEnd()
2278 iprot.readStructEnd()
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]))
2284 oprot.writeStructBegin(
'TCreateParams')
2286 oprot.writeFieldBegin(
'is_replicated', TType.BOOL, 1)
2288 oprot.writeFieldEnd()
2289 oprot.writeFieldStop()
2290 oprot.writeStructEnd()
2296 L = [
'%s=%r' % (key, value)
2297 for key, value
in self.__dict__.items()]
2298 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
2301 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
2304 return not (self == other)
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])
2324 iprot.readStructBegin()
2326 (fname, ftype, fid) = iprot.readFieldBegin()
2327 if ftype == TType.STOP:
2330 if ftype == TType.STRUCT:
2332 self.row_set.read(iprot)
2336 if ftype == TType.STRUCT:
2338 self.copy_params.read(iprot)
2343 iprot.readFieldEnd()
2344 iprot.readStructEnd()
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]))
2350 oprot.writeStructBegin(
'TDetectResult')
2352 oprot.writeFieldBegin(
'row_set', TType.STRUCT, 1)
2353 self.row_set.write(oprot)
2354 oprot.writeFieldEnd()
2356 oprot.writeFieldBegin(
'copy_params', TType.STRUCT, 2)
2357 self.copy_params.write(oprot)
2358 oprot.writeFieldEnd()
2359 oprot.writeFieldStop()
2360 oprot.writeStructEnd()
2366 L = [
'%s=%r' % (key, value)
2367 for key, value
in self.__dict__.items()]
2368 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
2371 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
2374 return not (self == other)
2388 def __init__(self, elapsed=None, rows_completed=None, rows_estimated=None, rows_rejected=None,):
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])
2398 iprot.readStructBegin()
2400 (fname, ftype, fid) = iprot.readFieldBegin()
2401 if ftype == TType.STOP:
2404 if ftype == TType.I64:
2405 self.
elapsed = iprot.readI64()
2409 if ftype == TType.I64:
2414 if ftype == TType.I64:
2419 if ftype == TType.I64:
2425 iprot.readFieldEnd()
2426 iprot.readStructEnd()
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]))
2432 oprot.writeStructBegin(
'TImportStatus')
2434 oprot.writeFieldBegin(
'elapsed', TType.I64, 1)
2436 oprot.writeFieldEnd()
2438 oprot.writeFieldBegin(
'rows_completed', TType.I64, 2)
2440 oprot.writeFieldEnd()
2442 oprot.writeFieldBegin(
'rows_estimated', TType.I64, 3)
2444 oprot.writeFieldEnd()
2446 oprot.writeFieldBegin(
'rows_rejected', TType.I64, 4)
2448 oprot.writeFieldEnd()
2449 oprot.writeFieldStop()
2450 oprot.writeStructEnd()
2456 L = [
'%s=%r' % (key, value)
2457 for key, value
in self.__dict__.items()]
2458 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
2461 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
2464 return not (self == other)
2479 def __init__(self, view_name=None, view_state=None, image_hash=None, update_time=None, view_metadata=None,):
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])
2490 iprot.readStructBegin()
2492 (fname, ftype, fid) = iprot.readFieldBegin()
2493 if ftype == TType.STOP:
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()
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()
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()
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()
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()
2522 iprot.readFieldEnd()
2523 iprot.readStructEnd()
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]))
2529 oprot.writeStructBegin(
'TFrontendView')
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()
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()
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()
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()
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()
2557 L = [
'%s=%r' % (key, value)
2558 for key, value
in self.__dict__.items()]
2559 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
2562 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
2565 return not (self == other)
2577 - poly_rendering_enabled
2579 - renderer_status_json
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,):
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])
2599 iprot.readStructBegin()
2601 (fname, ftype, fid) = iprot.readFieldBegin()
2602 if ftype == TType.STOP:
2605 if ftype == TType.BOOL:
2610 if ftype == TType.STRING:
2611 self.
version = iprot.readString().decode(
'utf-8', errors=
'replace')
if sys.version_info[0] == 2
else iprot.readString()
2615 if ftype == TType.BOOL:
2620 if ftype == TType.I64:
2625 if ftype == TType.STRING:
2626 self.
edition = iprot.readString().decode(
'utf-8', errors=
'replace')
if sys.version_info[0] == 2
else iprot.readString()
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()
2635 if ftype == TType.BOOL:
2640 if ftype == TType.I32:
2641 self.
role = iprot.readI32()
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()
2651 iprot.readFieldEnd()
2652 iprot.readStructEnd()
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]))
2658 oprot.writeStructBegin(
'TServerStatus')
2660 oprot.writeFieldBegin(
'read_only', TType.BOOL, 1)
2662 oprot.writeFieldEnd()
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()
2668 oprot.writeFieldBegin(
'rendering_enabled', TType.BOOL, 3)
2670 oprot.writeFieldEnd()
2672 oprot.writeFieldBegin(
'start_time', TType.I64, 4)
2674 oprot.writeFieldEnd()
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()
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()
2684 oprot.writeFieldBegin(
'poly_rendering_enabled', TType.BOOL, 7)
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()
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()
2702 L = [
'%s=%r' % (key, value)
2703 for key, value
in self.__dict__.items()]
2704 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
2707 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
2710 return not (self == other)
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])
2730 iprot.readStructBegin()
2732 (fname, ftype, fid) = iprot.readFieldBegin()
2733 if ftype == TType.STOP:
2736 if ftype == TType.I64:
2737 self.
x = iprot.readI64()
2741 if ftype == TType.I64:
2742 self.
y = iprot.readI64()
2747 iprot.readFieldEnd()
2748 iprot.readStructEnd()
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]))
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()
2770 L = [
'%s=%r' % (key, value)
2771 for key, value
in self.__dict__.items()]
2772 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
2775 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
2778 return not (self == other)
2794 def __init__(self, pixel=None, vega_table_name=None, table_id=None, row_id=None, row_set=None, nonce=None,):
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])
2806 iprot.readStructBegin()
2808 (fname, ftype, fid) = iprot.readFieldBegin()
2809 if ftype == TType.STOP:
2812 if ftype == TType.STRUCT:
2814 self.pixel.read(iprot)
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()
2823 if ftype == TType.LIST:
2825 (_etype87, _size84) = iprot.readListBegin()
2826 for _i88
in range(_size84):
2827 _elem89 = iprot.readI64()
2828 self.table_id.append(_elem89)
2833 if ftype == TType.LIST:
2835 (_etype93, _size90) = iprot.readListBegin()
2836 for _i94
in range(_size90):
2837 _elem95 = iprot.readI64()
2838 self.row_id.append(_elem95)
2843 if ftype == TType.STRUCT:
2845 self.row_set.read(iprot)
2849 if ftype == TType.STRING:
2850 self.
nonce = iprot.readString().decode(
'utf-8', errors=
'replace')
if sys.version_info[0] == 2
else iprot.readString()
2855 iprot.readFieldEnd()
2856 iprot.readStructEnd()
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]))
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()
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()
2872 oprot.writeFieldBegin(
'table_id', TType.LIST, 3)
2873 oprot.writeListBegin(TType.I64, len(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()
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()
2900 L = [
'%s=%r' % (key, value)
2901 for key, value
in self.__dict__.items()]
2902 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
2905 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
2908 return not (self == other)
2924 def __init__(self, image=None, nonce=None, execution_time_ms=None, render_time_ms=None, total_time_ms=None, vega_metadata=None,):
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])
2936 iprot.readStructBegin()
2938 (fname, ftype, fid) = iprot.readFieldBegin()
2939 if ftype == TType.STOP:
2942 if ftype == TType.STRING:
2943 self.
image = iprot.readBinary()
2947 if ftype == TType.STRING:
2948 self.
nonce = iprot.readString().decode(
'utf-8', errors=
'replace')
if sys.version_info[0] == 2
else iprot.readString()
2952 if ftype == TType.I64:
2957 if ftype == TType.I64:
2962 if ftype == TType.I64:
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()
2973 iprot.readFieldEnd()
2974 iprot.readStructEnd()
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]))
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()
2990 oprot.writeFieldBegin(
'execution_time_ms', TType.I64, 3)
2992 oprot.writeFieldEnd()
2994 oprot.writeFieldBegin(
'render_time_ms', TType.I64, 4)
2996 oprot.writeFieldEnd()
2998 oprot.writeFieldBegin(
'total_time_ms', TType.I64, 5)
3000 oprot.writeFieldEnd()
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()
3012 L = [
'%s=%r' % (key, value)
3013 for key, value
in self.__dict__.items()]
3014 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
3017 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
3020 return not (self == other)
3027 - clock_frequency_kHz
3029 - compute_capability_major
3030 - compute_capability_minor
3035 def __init__(self, num_sm=None, clock_frequency_kHz=None, memory=None, compute_capability_major=None, compute_capability_minor=None,):
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])
3046 iprot.readStructBegin()
3048 (fname, ftype, fid) = iprot.readFieldBegin()
3049 if ftype == TType.STOP:
3052 if ftype == TType.I32:
3053 self.
num_sm = iprot.readI32()
3057 if ftype == TType.I64:
3062 if ftype == TType.I64:
3063 self.
memory = iprot.readI64()
3067 if ftype == TType.I16:
3072 if ftype == TType.I16:
3078 iprot.readFieldEnd()
3079 iprot.readStructEnd()
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]))
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()
3091 oprot.writeFieldBegin(
'clock_frequency_kHz', TType.I64, 2)
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()
3099 oprot.writeFieldBegin(
'compute_capability_major', TType.I16, 4)
3101 oprot.writeFieldEnd()
3103 oprot.writeFieldBegin(
'compute_capability_minor', TType.I16, 5)
3105 oprot.writeFieldEnd()
3106 oprot.writeFieldStop()
3107 oprot.writeStructEnd()
3113 L = [
'%s=%r' % (key, value)
3114 for key, value
in self.__dict__.items()]
3115 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
3118 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
3121 return not (self == other)
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,):
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])
3149 iprot.readStructBegin()
3151 (fname, ftype, fid) = iprot.readFieldBegin()
3152 if ftype == TType.STOP:
3155 if ftype == TType.I16:
3160 if ftype == TType.I16:
3165 if ftype == TType.I16:
3170 if ftype == TType.I16:
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()
3180 if ftype == TType.LIST:
3182 (_etype101, _size98) = iprot.readListBegin()
3183 for _i102
in range(_size98):
3185 _elem103.read(iprot)
3186 self.gpu_info.append(_elem103)
3192 iprot.readFieldEnd()
3193 iprot.readStructEnd()
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]))
3199 oprot.writeStructBegin(
'THardwareInfo')
3201 oprot.writeFieldBegin(
'num_gpu_hw', TType.I16, 1)
3203 oprot.writeFieldEnd()
3205 oprot.writeFieldBegin(
'num_cpu_hw', TType.I16, 2)
3207 oprot.writeFieldEnd()
3209 oprot.writeFieldBegin(
'num_gpu_allocated', TType.I16, 3)
3211 oprot.writeFieldEnd()
3213 oprot.writeFieldBegin(
'start_gpu', TType.I16, 4)
3215 oprot.writeFieldEnd()
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()
3221 oprot.writeFieldBegin(
'gpu_info', TType.LIST, 6)
3222 oprot.writeListBegin(TType.STRUCT, len(self.
gpu_info))
3224 iter104.write(oprot)
3225 oprot.writeListEnd()
3226 oprot.writeFieldEnd()
3227 oprot.writeFieldStop()
3228 oprot.writeStructEnd()
3234 L = [
'%s=%r' % (key, value)
3235 for key, value
in self.__dict__.items()]
3236 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
3239 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
3242 return not (self == other)
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])
3260 iprot.readStructBegin()
3262 (fname, ftype, fid) = iprot.readFieldBegin()
3263 if ftype == TType.STOP:
3266 if ftype == TType.LIST:
3268 (_etype108, _size105) = iprot.readListBegin()
3269 for _i109
in range(_size105):
3271 _elem110.read(iprot)
3272 self.hardware_info.append(_elem110)
3278 iprot.readFieldEnd()
3279 iprot.readStructEnd()
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]))
3285 oprot.writeStructBegin(
'TClusterHardwareInfo')
3287 oprot.writeFieldBegin(
'hardware_info', TType.LIST, 1)
3290 iter111.write(oprot)
3291 oprot.writeListEnd()
3292 oprot.writeFieldEnd()
3293 oprot.writeFieldStop()
3294 oprot.writeStructEnd()
3300 L = [
'%s=%r' % (key, value)
3301 for key, value
in self.__dict__.items()]
3302 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
3305 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
3308 return not (self == other)
3325 def __init__(self, slab=None, start_page=None, num_pages=None, touch=None, chunk_key=None, buffer_epoch=None, is_free=None,):
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])
3338 iprot.readStructBegin()
3340 (fname, ftype, fid) = iprot.readFieldBegin()
3341 if ftype == TType.STOP:
3344 if ftype == TType.I64:
3345 self.
slab = iprot.readI64()
3349 if ftype == TType.I32:
3354 if ftype == TType.I64:
3359 if ftype == TType.I32:
3360 self.
touch = iprot.readI32()
3364 if ftype == TType.LIST:
3366 (_etype115, _size112) = iprot.readListBegin()
3367 for _i116
in range(_size112):
3368 _elem117 = iprot.readI64()
3369 self.chunk_key.append(_elem117)
3374 if ftype == TType.I32:
3379 if ftype == TType.BOOL:
3380 self.
is_free = iprot.readBool()
3385 iprot.readFieldEnd()
3386 iprot.readStructEnd()
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]))
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()
3398 oprot.writeFieldBegin(
'start_page', TType.I32, 2)
3400 oprot.writeFieldEnd()
3402 oprot.writeFieldBegin(
'num_pages', TType.I64, 3)
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()
3410 oprot.writeFieldBegin(
'chunk_key', TType.LIST, 5)
3411 oprot.writeListBegin(TType.I64, len(self.
chunk_key))
3413 oprot.writeI64(iter118)
3414 oprot.writeListEnd()
3415 oprot.writeFieldEnd()
3417 oprot.writeFieldBegin(
'buffer_epoch', TType.I32, 6)
3419 oprot.writeFieldEnd()
3421 oprot.writeFieldBegin(
'is_free', TType.BOOL, 7)
3423 oprot.writeFieldEnd()
3424 oprot.writeFieldStop()
3425 oprot.writeStructEnd()
3431 L = [
'%s=%r' % (key, value)
3432 for key, value
in self.__dict__.items()]
3433 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
3436 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
3439 return not (self == other)
3448 - num_pages_allocated
3449 - is_allocation_capped
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,):
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])
3467 iprot.readStructBegin()
3469 (fname, ftype, fid) = iprot.readFieldBegin()
3470 if ftype == TType.STOP:
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()
3478 if ftype == TType.I64:
3483 if ftype == TType.I64:
3488 if ftype == TType.I64:
3493 if ftype == TType.BOOL:
3498 if ftype == TType.LIST:
3500 (_etype122, _size119) = iprot.readListBegin()
3501 for _i123
in range(_size119):
3503 _elem124.read(iprot)
3504 self.node_memory_data.append(_elem124)
3510 iprot.readFieldEnd()
3511 iprot.readStructEnd()
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]))
3517 oprot.writeStructBegin(
'TNodeMemoryInfo')
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()
3523 oprot.writeFieldBegin(
'page_size', TType.I64, 2)
3525 oprot.writeFieldEnd()
3527 oprot.writeFieldBegin(
'max_num_pages', TType.I64, 3)
3529 oprot.writeFieldEnd()
3531 oprot.writeFieldBegin(
'num_pages_allocated', TType.I64, 4)
3533 oprot.writeFieldEnd()
3535 oprot.writeFieldBegin(
'is_allocation_capped', TType.BOOL, 5)
3537 oprot.writeFieldEnd()
3539 oprot.writeFieldBegin(
'node_memory_data', TType.LIST, 6)
3542 iter125.write(oprot)
3543 oprot.writeListEnd()
3544 oprot.writeFieldEnd()
3545 oprot.writeFieldStop()
3546 oprot.writeStructEnd()
3552 L = [
'%s=%r' % (key, value)
3553 for key, value
in self.__dict__.items()]
3554 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
3557 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
3560 return not (self == other)
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,):
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])
3596 iprot.readStructBegin()
3598 (fname, ftype, fid) = iprot.readFieldBegin()
3599 if ftype == TType.STOP:
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()
3607 if ftype == TType.I64:
3612 if ftype == TType.BOOL:
3613 self.
is_view = iprot.readBool()
3617 if ftype == TType.BOOL:
3622 if ftype == TType.I64:
3627 if ftype == TType.I64:
3632 if ftype == TType.I64:
3637 if ftype == TType.I64:
3642 if ftype == TType.LIST:
3644 (_etype129, _size126) = iprot.readListBegin()
3645 for _i130
in range(_size126):
3647 _elem131.read(iprot)
3648 self.col_types.append(_elem131)
3653 if ftype == TType.LIST:
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)
3664 iprot.readFieldEnd()
3665 iprot.readStructEnd()
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]))
3671 oprot.writeStructBegin(
'TTableMeta')
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()
3677 oprot.writeFieldBegin(
'num_cols', TType.I64, 2)
3679 oprot.writeFieldEnd()
3681 oprot.writeFieldBegin(
'is_view', TType.BOOL, 4)
3683 oprot.writeFieldEnd()
3685 oprot.writeFieldBegin(
'is_replicated', TType.BOOL, 5)
3687 oprot.writeFieldEnd()
3689 oprot.writeFieldBegin(
'shard_count', TType.I64, 6)
3691 oprot.writeFieldEnd()
3693 oprot.writeFieldBegin(
'max_rows', TType.I64, 7)
3695 oprot.writeFieldEnd()
3697 oprot.writeFieldBegin(
'table_id', TType.I64, 8)
3699 oprot.writeFieldEnd()
3701 oprot.writeFieldBegin(
'max_table_id', TType.I64, 9)
3703 oprot.writeFieldEnd()
3705 oprot.writeFieldBegin(
'col_types', TType.LIST, 10)
3706 oprot.writeListBegin(TType.STRUCT, len(self.
col_types))
3708 iter138.write(oprot)
3709 oprot.writeListEnd()
3710 oprot.writeFieldEnd()
3712 oprot.writeFieldBegin(
'col_names', TType.LIST, 11)
3713 oprot.writeListBegin(TType.STRING, len(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()
3725 L = [
'%s=%r' % (key, value)
3726 for key, value
in self.__dict__.items()]
3727 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
3730 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
3733 return not (self == other)
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,):
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])
3763 iprot.readStructBegin()
3765 (fname, ftype, fid) = iprot.readFieldBegin()
3766 if ftype == TType.STOP:
3769 if ftype == TType.I32:
3774 if ftype == TType.I32:
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()
3784 if ftype == TType.I32:
3789 if ftype == TType.I64:
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()
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()
3805 iprot.readFieldEnd()
3806 iprot.readStructEnd()
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]))
3812 oprot.writeStructBegin(
'TTableRefreshInfo')
3814 oprot.writeFieldBegin(
'update_type', TType.I32, 1)
3816 oprot.writeFieldEnd()
3818 oprot.writeFieldBegin(
'timing_type', TType.I32, 2)
3820 oprot.writeFieldEnd()
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()
3826 oprot.writeFieldBegin(
'interval_type', TType.I32, 4)
3828 oprot.writeFieldEnd()
3830 oprot.writeFieldBegin(
'interval_count', TType.I64, 5)
3832 oprot.writeFieldEnd()
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()
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()
3848 L = [
'%s=%r' % (key, value)
3849 for key, value
in self.__dict__.items()]
3850 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
3853 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
3856 return not (self == other)
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,):
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])
3894 iprot.readStructBegin()
3896 (fname, ftype, fid) = iprot.readFieldBegin()
3897 if ftype == TType.STOP:
3900 if ftype == TType.LIST:
3902 (_etype143, _size140) = iprot.readListBegin()
3903 for _i144
in range(_size140):
3905 _elem145.read(iprot)
3906 self.row_desc.append(_elem145)
3911 if ftype == TType.I64:
3916 if ftype == TType.I64:
3921 if ftype == TType.I64:
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()
3931 if ftype == TType.I64:
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()
3941 if ftype == TType.BOOL:
3946 if ftype == TType.I32:
3951 if ftype == TType.I32:
3956 if ftype == TType.STRUCT:
3958 self.refresh_info.read(iprot)
3963 iprot.readFieldEnd()
3964 iprot.readStructEnd()
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]))
3970 oprot.writeStructBegin(
'TTableDetails')
3972 oprot.writeFieldBegin(
'row_desc', TType.LIST, 1)
3973 oprot.writeListBegin(TType.STRUCT, len(self.
row_desc))
3975 iter146.write(oprot)
3976 oprot.writeListEnd()
3977 oprot.writeFieldEnd()
3979 oprot.writeFieldBegin(
'fragment_size', TType.I64, 2)
3981 oprot.writeFieldEnd()
3983 oprot.writeFieldBegin(
'page_size', TType.I64, 3)
3985 oprot.writeFieldEnd()
3987 oprot.writeFieldBegin(
'max_rows', TType.I64, 4)
3989 oprot.writeFieldEnd()
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()
3995 oprot.writeFieldBegin(
'shard_count', TType.I64, 6)
3997 oprot.writeFieldEnd()
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()
4003 oprot.writeFieldBegin(
'is_temporary', TType.BOOL, 8)
4005 oprot.writeFieldEnd()
4007 oprot.writeFieldBegin(
'partition_detail', TType.I32, 9)
4009 oprot.writeFieldEnd()
4011 oprot.writeFieldBegin(
'table_type', TType.I32, 10)
4013 oprot.writeFieldEnd()
4015 oprot.writeFieldBegin(
'refresh_info', TType.STRUCT, 11)
4016 self.refresh_info.write(oprot)
4017 oprot.writeFieldEnd()
4018 oprot.writeFieldStop()
4019 oprot.writeStructEnd()
4025 L = [
'%s=%r' % (key, value)
4026 for key, value
in self.__dict__.items()]
4027 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
4030 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
4033 return not (self == other)
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,):
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])
4067 iprot.readStructBegin()
4069 (fname, ftype, fid) = iprot.readFieldBegin()
4070 if ftype == TType.STOP:
4073 if ftype == TType.I32:
4074 self.
type = iprot.readI32()
4078 if ftype == TType.I32:
4079 self.
col_id = iprot.readI32()
4083 if ftype == TType.I32:
4088 if ftype == TType.BOOL:
4093 if ftype == TType.I64:
4094 self.
int_min = iprot.readI64()
4098 if ftype == TType.I64:
4099 self.
int_max = iprot.readI64()
4103 if ftype == TType.I64:
4104 self.
bucket = iprot.readI64()
4108 if ftype == TType.DOUBLE:
4109 self.
fp_min = iprot.readDouble()
4113 if ftype == TType.DOUBLE:
4114 self.
fp_max = iprot.readDouble()
4119 iprot.readFieldEnd()
4120 iprot.readStructEnd()
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]))
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()
4136 oprot.writeFieldBegin(
'table_id', TType.I32, 3)
4138 oprot.writeFieldEnd()
4140 oprot.writeFieldBegin(
'has_nulls', TType.BOOL, 4)
4142 oprot.writeFieldEnd()
4144 oprot.writeFieldBegin(
'int_min', TType.I64, 5)
4146 oprot.writeFieldEnd()
4148 oprot.writeFieldBegin(
'int_max', TType.I64, 6)
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()
4170 L = [
'%s=%r' % (key, value)
4171 for key, value
in self.__dict__.items()]
4172 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
4175 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
4178 return not (self == other)
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])
4198 iprot.readStructBegin()
4200 (fname, ftype, fid) = iprot.readFieldBegin()
4201 if ftype == TType.STOP:
4204 if ftype == TType.I32:
4205 self.
dict_id = iprot.readI32()
4209 if ftype == TType.I64:
4215 iprot.readFieldEnd()
4216 iprot.readStructEnd()
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]))
4222 oprot.writeStructBegin(
'TDictionaryGeneration')
4224 oprot.writeFieldBegin(
'dict_id', TType.I32, 1)
4226 oprot.writeFieldEnd()
4228 oprot.writeFieldBegin(
'entry_count', TType.I64, 2)
4230 oprot.writeFieldEnd()
4231 oprot.writeFieldStop()
4232 oprot.writeStructEnd()
4238 L = [
'%s=%r' % (key, value)
4239 for key, value
in self.__dict__.items()]
4240 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
4243 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
4246 return not (self == other)
4259 def __init__(self, table_id=None, tuple_count=None, start_rowid=None,):
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])
4268 iprot.readStructBegin()
4270 (fname, ftype, fid) = iprot.readFieldBegin()
4271 if ftype == TType.STOP:
4274 if ftype == TType.I32:
4279 if ftype == TType.I64:
4284 if ftype == TType.I64:
4290 iprot.readFieldEnd()
4291 iprot.readStructEnd()
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]))
4297 oprot.writeStructBegin(
'TTableGeneration')
4299 oprot.writeFieldBegin(
'table_id', TType.I32, 1)
4301 oprot.writeFieldEnd()
4303 oprot.writeFieldBegin(
'tuple_count', TType.I64, 2)
4305 oprot.writeFieldEnd()
4307 oprot.writeFieldBegin(
'start_rowid', TType.I64, 3)
4309 oprot.writeFieldEnd()
4310 oprot.writeFieldStop()
4311 oprot.writeStructEnd()
4317 L = [
'%s=%r' % (key, value)
4318 for key, value
in self.__dict__.items()]
4319 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
4322 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
4325 return not (self == other)
4333 - dictionary_generations
4340 def __init__(self, id=None, column_ranges=None, dictionary_generations=None, table_generations=None, parent_session_id=None,):
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])
4351 iprot.readStructBegin()
4353 (fname, ftype, fid) = iprot.readFieldBegin()
4354 if ftype == TType.STOP:
4357 if ftype == TType.I64:
4358 self.
id = iprot.readI64()
4362 if ftype == TType.LIST:
4364 (_etype150, _size147) = iprot.readListBegin()
4365 for _i151
in range(_size147):
4367 _elem152.read(iprot)
4368 self.column_ranges.append(_elem152)
4373 if ftype == TType.LIST:
4375 (_etype156, _size153) = iprot.readListBegin()
4376 for _i157
in range(_size153):
4378 _elem158.read(iprot)
4379 self.dictionary_generations.append(_elem158)
4384 if ftype == TType.LIST:
4386 (_etype162, _size159) = iprot.readListBegin()
4387 for _i163
in range(_size159):
4389 _elem164.read(iprot)
4390 self.table_generations.append(_elem164)
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()
4401 iprot.readFieldEnd()
4402 iprot.readStructEnd()
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]))
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()
4414 oprot.writeFieldBegin(
'column_ranges', TType.LIST, 2)
4417 iter165.write(oprot)
4418 oprot.writeListEnd()
4419 oprot.writeFieldEnd()
4421 oprot.writeFieldBegin(
'dictionary_generations', TType.LIST, 3)
4424 iter166.write(oprot)
4425 oprot.writeListEnd()
4426 oprot.writeFieldEnd()
4428 oprot.writeFieldBegin(
'table_generations', TType.LIST, 4)
4431 iter167.write(oprot)
4432 oprot.writeListEnd()
4433 oprot.writeFieldEnd()
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()
4445 L = [
'%s=%r' % (key, value)
4446 for key, value
in self.__dict__.items()]
4447 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
4450 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
4453 return not (self == other)
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])
4473 iprot.readStructBegin()
4475 (fname, ftype, fid) = iprot.readFieldBegin()
4476 if ftype == TType.STOP:
4479 if ftype == TType.STRING:
4480 self.
payload = iprot.readBinary()
4484 if ftype == TType.BOOL:
4485 self.
is_null = iprot.readBool()
4490 iprot.readFieldEnd()
4491 iprot.readStructEnd()
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]))
4497 oprot.writeStructBegin(
'TVarLen')
4499 oprot.writeFieldBegin(
'payload', TType.STRING, 1)
4500 oprot.writeBinary(self.
payload)
4501 oprot.writeFieldEnd()
4503 oprot.writeFieldBegin(
'is_null', TType.BOOL, 2)
4505 oprot.writeFieldEnd()
4506 oprot.writeFieldStop()
4507 oprot.writeStructEnd()
4513 L = [
'%s=%r' % (key, value)
4514 for key, value
in self.__dict__.items()]
4515 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
4518 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
4521 return not (self == other)
4533 def __init__(self, fixed_len_data=None, var_len_data=None,):
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])
4541 iprot.readStructBegin()
4543 (fname, ftype, fid) = iprot.readFieldBegin()
4544 if ftype == TType.STOP:
4547 if ftype == TType.STRING:
4552 if ftype == TType.LIST:
4554 (_etype171, _size168) = iprot.readListBegin()
4555 for _i172
in range(_size168):
4557 _elem173.read(iprot)
4558 self.var_len_data.append(_elem173)
4564 iprot.readFieldEnd()
4565 iprot.readStructEnd()
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]))
4571 oprot.writeStructBegin(
'TDataBlockPtr')
4573 oprot.writeFieldBegin(
'fixed_len_data', TType.STRING, 1)
4575 oprot.writeFieldEnd()
4577 oprot.writeFieldBegin(
'var_len_data', TType.LIST, 2)
4578 oprot.writeListBegin(TType.STRUCT, len(self.
var_len_data))
4580 iter174.write(oprot)
4581 oprot.writeListEnd()
4582 oprot.writeFieldEnd()
4583 oprot.writeFieldStop()
4584 oprot.writeStructEnd()
4590 L = [
'%s=%r' % (key, value)
4591 for key, value
in self.__dict__.items()]
4592 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
4595 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
4598 return not (self == other)
4614 def __init__(self, db_id=None, table_id=None, column_ids=None, data=None, num_rows=None, is_default=None,):
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])
4626 iprot.readStructBegin()
4628 (fname, ftype, fid) = iprot.readFieldBegin()
4629 if ftype == TType.STOP:
4632 if ftype == TType.I32:
4633 self.
db_id = iprot.readI32()
4637 if ftype == TType.I32:
4642 if ftype == TType.LIST:
4644 (_etype178, _size175) = iprot.readListBegin()
4645 for _i179
in range(_size175):
4646 _elem180 = iprot.readI32()
4647 self.column_ids.append(_elem180)
4652 if ftype == TType.LIST:
4654 (_etype184, _size181) = iprot.readListBegin()
4655 for _i185
in range(_size181):
4657 _elem186.read(iprot)
4658 self.data.append(_elem186)
4663 if ftype == TType.I64:
4668 if ftype == TType.LIST:
4670 (_etype190, _size187) = iprot.readListBegin()
4671 for _i191
in range(_size187):
4672 _elem192 = iprot.readBool()
4673 self.is_default.append(_elem192)
4679 iprot.readFieldEnd()
4680 iprot.readStructEnd()
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]))
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()
4692 oprot.writeFieldBegin(
'table_id', TType.I32, 2)
4694 oprot.writeFieldEnd()
4696 oprot.writeFieldBegin(
'column_ids', TType.LIST, 3)
4697 oprot.writeListBegin(TType.I32, len(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()
4710 oprot.writeFieldBegin(
'num_rows', TType.I64, 5)
4712 oprot.writeFieldEnd()
4714 oprot.writeFieldBegin(
'is_default', TType.LIST, 6)
4715 oprot.writeListBegin(TType.BOOL, len(self.
is_default))
4717 oprot.writeBool(iter195)
4718 oprot.writeListEnd()
4719 oprot.writeFieldEnd()
4720 oprot.writeFieldStop()
4721 oprot.writeStructEnd()
4727 L = [
'%s=%r' % (key, value)
4728 for key, value
in self.__dict__.items()]
4729 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
4732 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
4735 return not (self == other)
4747 def __init__(self, data_buffer=None, index_buffer=None,):
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])
4755 iprot.readStructBegin()
4757 (fname, ftype, fid) = iprot.readFieldBegin()
4758 if ftype == TType.STOP:
4761 if ftype == TType.STRING:
4766 if ftype == TType.STRING:
4772 iprot.readFieldEnd()
4773 iprot.readStructEnd()
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]))
4779 oprot.writeStructBegin(
'TChunkData')
4781 oprot.writeFieldBegin(
'data_buffer', TType.STRING, 1)
4783 oprot.writeFieldEnd()
4785 oprot.writeFieldBegin(
'index_buffer', TType.STRING, 2)
4787 oprot.writeFieldEnd()
4788 oprot.writeFieldStop()
4789 oprot.writeStructEnd()
4795 L = [
'%s=%r' % (key, value)
4796 for key, value
in self.__dict__.items()]
4797 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
4800 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
4803 return not (self == other)
4818 def __init__(self, db_id=None, table_id=None, data=None, valid_indices=None, num_rows=None,):
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])
4829 iprot.readStructBegin()
4831 (fname, ftype, fid) = iprot.readFieldBegin()
4832 if ftype == TType.STOP:
4835 if ftype == TType.I32:
4836 self.
db_id = iprot.readI32()
4840 if ftype == TType.I32:
4845 if ftype == TType.LIST:
4847 (_etype199, _size196) = iprot.readListBegin()
4848 for _i200
in range(_size196):
4850 _elem201.read(iprot)
4851 self.data.append(_elem201)
4856 if ftype == TType.LIST:
4858 (_etype205, _size202) = iprot.readListBegin()
4859 for _i206
in range(_size202):
4860 _elem207 = iprot.readI64()
4861 self.valid_indices.append(_elem207)
4866 if ftype == TType.I64:
4872 iprot.readFieldEnd()
4873 iprot.readStructEnd()
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]))
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()
4885 oprot.writeFieldBegin(
'table_id', TType.I32, 2)
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()
4896 oprot.writeFieldBegin(
'valid_indices', TType.LIST, 4)
4899 oprot.writeI64(iter209)
4900 oprot.writeListEnd()
4901 oprot.writeFieldEnd()
4903 oprot.writeFieldBegin(
'num_rows', TType.I64, 5)
4905 oprot.writeFieldEnd()
4906 oprot.writeFieldStop()
4907 oprot.writeStructEnd()
4913 L = [
'%s=%r' % (key, value)
4914 for key, value
in self.__dict__.items()]
4915 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
4918 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
4921 return not (self == other)
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])
4939 iprot.readStructBegin()
4941 (fname, ftype, fid) = iprot.readFieldBegin()
4942 if ftype == TType.STOP:
4945 if ftype == TType.I64:
4946 self.
id = iprot.readI64()
4951 iprot.readFieldEnd()
4952 iprot.readStructEnd()
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]))
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()
4970 L = [
'%s=%r' % (key, value)
4971 for key, value
in self.__dict__.items()]
4972 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
4975 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
4978 return not (self == other)
4993 def __init__(self, merge_type=None, node_id=None, execution_time_ms=None, render_time_ms=None, total_time_ms=None,):
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])
5004 iprot.readStructBegin()
5006 (fname, ftype, fid) = iprot.readFieldBegin()
5007 if ftype == TType.STOP:
5010 if ftype == TType.I32:
5015 if ftype == TType.I32:
5016 self.
node_id = iprot.readI32()
5020 if ftype == TType.I64:
5025 if ftype == TType.I64:
5030 if ftype == TType.I64:
5036 iprot.readFieldEnd()
5037 iprot.readStructEnd()
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]))
5043 oprot.writeStructBegin(
'TRenderParseResult')
5045 oprot.writeFieldBegin(
'merge_type', TType.I32, 1)
5047 oprot.writeFieldEnd()
5049 oprot.writeFieldBegin(
'node_id', TType.I32, 2)
5051 oprot.writeFieldEnd()
5053 oprot.writeFieldBegin(
'execution_time_ms', TType.I64, 3)
5055 oprot.writeFieldEnd()
5057 oprot.writeFieldBegin(
'render_time_ms', TType.I64, 4)
5059 oprot.writeFieldEnd()
5061 oprot.writeFieldBegin(
'total_time_ms', TType.I64, 5)
5063 oprot.writeFieldEnd()
5064 oprot.writeFieldStop()
5065 oprot.writeStructEnd()
5071 L = [
'%s=%r' % (key, value)
5072 for key, value
in self.__dict__.items()]
5073 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
5076 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
5079 return not (self == other)
5085 - num_pixel_channels
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,):
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])
5111 iprot.readStructBegin()
5113 (fname, ftype, fid) = iprot.readFieldBegin()
5114 if ftype == TType.STOP:
5117 if ftype == TType.I32:
5122 if ftype == TType.I32:
5127 if ftype == TType.STRING:
5128 self.
pixels = iprot.readBinary()
5132 if ftype == TType.STRING:
5137 if ftype == TType.STRING:
5142 if ftype == TType.STRING:
5147 if ftype == TType.STRING:
5152 if ftype == TType.I32:
5158 iprot.readFieldEnd()
5159 iprot.readStructEnd()
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]))
5165 oprot.writeStructBegin(
'TRawRenderPassDataResult')
5167 oprot.writeFieldBegin(
'num_pixel_channels', TType.I32, 1)
5169 oprot.writeFieldEnd()
5171 oprot.writeFieldBegin(
'num_pixel_samples', TType.I32, 2)
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()
5179 oprot.writeFieldBegin(
'row_ids_A', TType.STRING, 4)
5180 oprot.writeBinary(self.