9 from thrift.Thrift
import TType, TMessageType, TFrozenDict, TException, TApplicationException
10 from thrift.protocol.TProtocol
import TProtocolException
11 from thrift.TRecursive
import fix_spec
16 from thrift.transport
import TTransport
21 GroupByPerfectHash = 0
22 GroupByBaselineHash = 1
24 NonGroupedAggregate = 3
27 0:
"GroupByPerfectHash",
28 1:
"GroupByBaselineHash",
30 3:
"NonGroupedAggregate",
34 "GroupByPerfectHash": 0,
35 "GroupByBaselineHash": 1,
37 "NonGroupedAggregate": 3,
65 APPROX_COUNT_DISTINCT = 5
75 5:
"APPROX_COUNT_DISTINCT",
86 "APPROX_COUNT_DISTINCT": 5,
106 if iprot._fast_decode
is not None and isinstance(iprot.trans, TTransport.CReadableTransport)
and self.thrift_spec
is not None:
107 iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
109 iprot.readStructBegin()
111 (fname, ftype, fid) = iprot.readFieldBegin()
112 if ftype == TType.STOP:
115 if ftype == TType.I16:
116 self.
padded = iprot.readI16()
120 if ftype == TType.I16:
127 iprot.readStructEnd()
130 if oprot._fast_encode
is not None and self.thrift_spec
is not None:
131 oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
133 oprot.writeStructBegin(
'TSlotSize')
134 if self.
padded is not None:
135 oprot.writeFieldBegin(
'padded', TType.I16, 1)
136 oprot.writeI16(self.
padded)
137 oprot.writeFieldEnd()
139 oprot.writeFieldBegin(
'logical', TType.I16, 2)
141 oprot.writeFieldEnd()
142 oprot.writeFieldStop()
143 oprot.writeStructEnd()
149 L = [
'%s=%r' % (key, value)
150 for key, value
in self.__dict__.items()]
151 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
154 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
157 return not (self == other)
169 def __init__(self, slot_sizes=None, col_to_slot_map=None,):
174 if iprot._fast_decode
is not None and isinstance(iprot.trans, TTransport.CReadableTransport)
and self.thrift_spec
is not None:
175 iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
177 iprot.readStructBegin()
179 (fname, ftype, fid) = iprot.readFieldBegin()
180 if ftype == TType.STOP:
183 if ftype == TType.LIST:
185 (_etype3, _size0) = iprot.readListBegin()
186 for _i4
in range(_size0):
189 self.slot_sizes.append(_elem5)
194 if ftype == TType.LIST:
196 (_etype9, _size6) = iprot.readListBegin()
197 for _i10
in range(_size6):
199 (_etype15, _size12) = iprot.readListBegin()
200 for _i16
in range(_size12):
201 _elem17 = iprot.readI32()
202 _elem11.append(_elem17)
204 self.col_to_slot_map.append(_elem11)
211 iprot.readStructEnd()
214 if oprot._fast_encode
is not None and self.thrift_spec
is not None:
215 oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
217 oprot.writeStructBegin(
'TColSlotContext')
219 oprot.writeFieldBegin(
'slot_sizes', TType.LIST, 1)
220 oprot.writeListBegin(TType.STRUCT, len(self.
slot_sizes))
224 oprot.writeFieldEnd()
226 oprot.writeFieldBegin(
'col_to_slot_map', TType.LIST, 2)
229 oprot.writeListBegin(TType.I32, len(iter19))
230 for iter20
in iter19:
231 oprot.writeI32(iter20)
234 oprot.writeFieldEnd()
235 oprot.writeFieldStop()
236 oprot.writeStructEnd()
242 L = [
'%s=%r' % (key, value)
243 for key, value
in self.__dict__.items()]
244 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
247 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
250 return not (self == other)
266 def __init__(self, impl_type=None, min_val=None, bitmap_sz_bits=None, approximate=None, device_type=None, sub_bitmap_count=None,):
275 if iprot._fast_decode
is not None and isinstance(iprot.trans, TTransport.CReadableTransport)
and self.thrift_spec
is not None:
276 iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
278 iprot.readStructBegin()
280 (fname, ftype, fid) = iprot.readFieldBegin()
281 if ftype == TType.STOP:
284 if ftype == TType.I32:
289 if ftype == TType.I64:
294 if ftype == TType.I64:
299 if ftype == TType.BOOL:
304 if ftype == TType.I32:
309 if ftype == TType.I64:
316 iprot.readStructEnd()
319 if oprot._fast_encode
is not None and self.thrift_spec
is not None:
320 oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
322 oprot.writeStructBegin(
'TCountDistinctDescriptor')
324 oprot.writeFieldBegin(
'impl_type', TType.I32, 1)
326 oprot.writeFieldEnd()
328 oprot.writeFieldBegin(
'min_val', TType.I64, 2)
330 oprot.writeFieldEnd()
332 oprot.writeFieldBegin(
'bitmap_sz_bits', TType.I64, 3)
334 oprot.writeFieldEnd()
336 oprot.writeFieldBegin(
'approximate', TType.BOOL, 4)
338 oprot.writeFieldEnd()
340 oprot.writeFieldBegin(
'device_type', TType.I32, 5)
342 oprot.writeFieldEnd()
344 oprot.writeFieldBegin(
'sub_bitmap_count', TType.I64, 6)
346 oprot.writeFieldEnd()
347 oprot.writeFieldStop()
348 oprot.writeStructEnd()
354 L = [
'%s=%r' % (key, value)
355 for key, value
in self.__dict__.items()]
356 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
359 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
362 return not (self == other)
378 - target_groupby_indices
379 - count_distinct_descriptors
385 def __init__(self, layout=None, keyless=None, entry_count=None, idx_target_as_key=None, min_val=None, max_val=None, bucket=None, group_col_widths=None, key_bytewidth=None, col_slot_context=None, target_groupby_indices=None, count_distinct_descriptors=None, force_4byte_float=None,):
401 if iprot._fast_decode
is not None and isinstance(iprot.trans, TTransport.CReadableTransport)
and self.thrift_spec
is not None:
402 iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
404 iprot.readStructBegin()
406 (fname, ftype, fid) = iprot.readFieldBegin()
407 if ftype == TType.STOP:
410 if ftype == TType.I32:
411 self.
layout = iprot.readI32()
415 if ftype == TType.BOOL:
416 self.
keyless = iprot.readBool()
420 if ftype == TType.I32:
425 if ftype == TType.I32:
430 if ftype == TType.I64:
435 if ftype == TType.I64:
440 if ftype == TType.I64:
441 self.
bucket = iprot.readI64()
445 if ftype == TType.LIST:
447 (_etype24, _size21) = iprot.readListBegin()
448 for _i25
in range(_size21):
449 _elem26 = iprot.readI16()
450 self.group_col_widths.append(_elem26)
455 if ftype == TType.I16:
460 if ftype == TType.STRUCT:
462 self.col_slot_context.read(iprot)
466 if ftype == TType.LIST:
468 (_etype30, _size27) = iprot.readListBegin()
469 for _i31
in range(_size27):
470 _elem32 = iprot.readI32()
471 self.target_groupby_indices.append(_elem32)
476 if ftype == TType.LIST:
478 (_etype36, _size33) = iprot.readListBegin()
479 for _i37
in range(_size33):
482 self.count_distinct_descriptors.append(_elem38)
487 if ftype == TType.BOOL:
494 iprot.readStructEnd()
497 if oprot._fast_encode
is not None and self.thrift_spec
is not None:
498 oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
500 oprot.writeStructBegin(
'TResultSetBufferDescriptor')
501 if self.
layout is not None:
502 oprot.writeFieldBegin(
'layout', TType.I32, 1)
503 oprot.writeI32(self.
layout)
504 oprot.writeFieldEnd()
506 oprot.writeFieldBegin(
'keyless', TType.BOOL, 2)
508 oprot.writeFieldEnd()
510 oprot.writeFieldBegin(
'entry_count', TType.I32, 3)
512 oprot.writeFieldEnd()
514 oprot.writeFieldBegin(
'idx_target_as_key', TType.I32, 4)
516 oprot.writeFieldEnd()
518 oprot.writeFieldBegin(
'min_val', TType.I64, 5)
520 oprot.writeFieldEnd()
522 oprot.writeFieldBegin(
'max_val', TType.I64, 6)
524 oprot.writeFieldEnd()
525 if self.
bucket is not None:
526 oprot.writeFieldBegin(
'bucket', TType.I64, 7)
527 oprot.writeI64(self.
bucket)
528 oprot.writeFieldEnd()
530 oprot.writeFieldBegin(
'group_col_widths', TType.LIST, 8)
533 oprot.writeI16(iter39)
535 oprot.writeFieldEnd()
537 oprot.writeFieldBegin(
'key_bytewidth', TType.I16, 9)
539 oprot.writeFieldEnd()
541 oprot.writeFieldBegin(
'col_slot_context', TType.STRUCT, 10)
542 self.col_slot_context.write(oprot)
543 oprot.writeFieldEnd()
545 oprot.writeFieldBegin(
'target_groupby_indices', TType.LIST, 11)
548 oprot.writeI32(iter40)
550 oprot.writeFieldEnd()
552 oprot.writeFieldBegin(
'count_distinct_descriptors', TType.LIST, 12)
557 oprot.writeFieldEnd()
559 oprot.writeFieldBegin(
'force_4byte_float', TType.BOOL, 13)
561 oprot.writeFieldEnd()
562 oprot.writeFieldStop()
563 oprot.writeStructEnd()
569 L = [
'%s=%r' % (key, value)
570 for key, value
in self.__dict__.items()]
571 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
574 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
577 return not (self == other)
593 def __init__(self, is_agg=None, kind=None, type=None, arg_type=None, skip_nulls=None, is_distinct=None,):
602 if iprot._fast_decode
is not None and isinstance(iprot.trans, TTransport.CReadableTransport)
and self.thrift_spec
is not None:
603 iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
605 iprot.readStructBegin()
607 (fname, ftype, fid) = iprot.readFieldBegin()
608 if ftype == TType.STOP:
611 if ftype == TType.BOOL:
612 self.
is_agg = iprot.readBool()
616 if ftype == TType.I32:
617 self.
kind = iprot.readI32()
621 if ftype == TType.STRUCT:
623 self.type.read(iprot)
627 if ftype == TType.STRUCT:
629 self.arg_type.read(iprot)
633 if ftype == TType.BOOL:
638 if ftype == TType.BOOL:
645 iprot.readStructEnd()
648 if oprot._fast_encode
is not None and self.thrift_spec
is not None:
649 oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
651 oprot.writeStructBegin(
'TTargetInfo')
652 if self.
is_agg is not None:
653 oprot.writeFieldBegin(
'is_agg', TType.BOOL, 1)
654 oprot.writeBool(self.
is_agg)
655 oprot.writeFieldEnd()
656 if self.
kind is not None:
657 oprot.writeFieldBegin(
'kind', TType.I32, 2)
658 oprot.writeI32(self.
kind)
659 oprot.writeFieldEnd()
660 if self.
type is not None:
661 oprot.writeFieldBegin(
'type', TType.STRUCT, 3)
662 self.type.write(oprot)
663 oprot.writeFieldEnd()
665 oprot.writeFieldBegin(
'arg_type', TType.STRUCT, 4)
666 self.arg_type.write(oprot)
667 oprot.writeFieldEnd()
669 oprot.writeFieldBegin(
'skip_nulls', TType.BOOL, 5)
671 oprot.writeFieldEnd()
673 oprot.writeFieldBegin(
'is_distinct', TType.BOOL, 6)
675 oprot.writeFieldEnd()
676 oprot.writeFieldStop()
677 oprot.writeStructEnd()
683 L = [
'%s=%r' % (key, value)
684 for key, value
in self.__dict__.items()]
685 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
688 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
691 return not (self == other)
708 if iprot._fast_decode
is not None and isinstance(iprot.trans, TTransport.CReadableTransport)
and self.thrift_spec
is not None:
709 iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
711 iprot.readStructBegin()
713 (fname, ftype, fid) = iprot.readFieldBegin()
714 if ftype == TType.STOP:
717 if ftype == TType.STRING:
718 self.
bitmap = iprot.readBinary()
722 if ftype == TType.SET:
724 (_etype45, _size42) = iprot.readSetBegin()
725 for _i46
in range(_size42):
726 _elem47 = iprot.readI64()
727 self.sparse_set.add(_elem47)
734 iprot.readStructEnd()
737 if oprot._fast_encode
is not None and self.thrift_spec
is not None:
738 oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
740 oprot.writeStructBegin(
'TCountDistinctSetStorage')
741 if self.
bitmap is not None:
742 oprot.writeFieldBegin(
'bitmap', TType.STRING, 1)
743 oprot.writeBinary(self.
bitmap)
744 oprot.writeFieldEnd()
746 oprot.writeFieldBegin(
'sparse_set', TType.SET, 2)
747 oprot.writeSetBegin(TType.I64, len(self.
sparse_set))
749 oprot.writeI64(iter48)
751 oprot.writeFieldEnd()
752 oprot.writeFieldStop()
753 oprot.writeStructEnd()
759 L = [
'%s=%r' % (key, value)
760 for key, value
in self.__dict__.items()]
761 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
764 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
767 return not (self == other)
780 def __init__(self, type=None, storage=None, remote_ptr=None,):
786 if iprot._fast_decode
is not None and isinstance(iprot.trans, TTransport.CReadableTransport)
and self.thrift_spec
is not None:
787 iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
789 iprot.readStructBegin()
791 (fname, ftype, fid) = iprot.readFieldBegin()
792 if ftype == TType.STOP:
795 if ftype == TType.I32:
796 self.
type = iprot.readI32()
800 if ftype == TType.STRUCT:
802 self.storage.read(iprot)
806 if ftype == TType.I64:
813 iprot.readStructEnd()
816 if oprot._fast_encode
is not None and self.thrift_spec
is not None:
817 oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
819 oprot.writeStructBegin(
'TCountDistinctSet')
820 if self.
type is not None:
821 oprot.writeFieldBegin(
'type', TType.I32, 1)
822 oprot.writeI32(self.
type)
823 oprot.writeFieldEnd()
825 oprot.writeFieldBegin(
'storage', TType.STRUCT, 2)
826 self.storage.write(oprot)
827 oprot.writeFieldEnd()
829 oprot.writeFieldBegin(
'remote_ptr', TType.I64, 3)
831 oprot.writeFieldEnd()
832 oprot.writeFieldStop()
833 oprot.writeStructEnd()
839 L = [
'%s=%r' % (key, value)
840 for key, value
in self.__dict__.items()]
841 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
844 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
847 return not (self == other)
856 - total_compression_time_ms
861 - count_distinct_sets
867 def __init__(self, buffers=None, buffer_lengths=None, buffers_total_size=None, total_compression_time_ms=None, descriptor=None, targets=None, target_init_vals=None, varlen_buffer=None, count_distinct_sets=None, explanation=None,):
880 if iprot._fast_decode
is not None and isinstance(iprot.trans, TTransport.CReadableTransport)
and self.thrift_spec
is not None:
881 iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
883 iprot.readStructBegin()
885 (fname, ftype, fid) = iprot.readFieldBegin()
886 if ftype == TType.STOP:
889 if ftype == TType.LIST:
891 (_etype52, _size49) = iprot.readListBegin()
892 for _i53
in range(_size49):
893 _elem54 = iprot.readBinary()
894 self.buffers.append(_elem54)
899 if ftype == TType.LIST:
901 (_etype58, _size55) = iprot.readListBegin()
902 for _i59
in range(_size55):
903 _elem60 = iprot.readI64()
904 self.buffer_lengths.append(_elem60)
909 if ftype == TType.I64:
914 if ftype == TType.I32:
919 if ftype == TType.STRUCT:
921 self.descriptor.read(iprot)
925 if ftype == TType.LIST:
927 (_etype64, _size61) = iprot.readListBegin()
928 for _i65
in range(_size61):
931 self.targets.append(_elem66)
936 if ftype == TType.LIST:
938 (_etype70, _size67) = iprot.readListBegin()
939 for _i71
in range(_size67):
940 _elem72 = iprot.readI64()
941 self.target_init_vals.append(_elem72)
946 if ftype == TType.LIST:
948 (_etype76, _size73) = iprot.readListBegin()
949 for _i77
in range(_size73):
950 _elem78 = iprot.readBinary()
951 self.varlen_buffer.append(_elem78)
956 if ftype == TType.LIST:
958 (_etype82, _size79) = iprot.readListBegin()
959 for _i83
in range(_size79):
962 self.count_distinct_sets.append(_elem84)
967 if ftype == TType.STRING:
968 self.
explanation = iprot.readString().decode(
'utf-8', errors=
'replace')
if sys.version_info[0] == 2
else iprot.readString()
974 iprot.readStructEnd()
977 if oprot._fast_encode
is not None and self.thrift_spec
is not None:
978 oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
980 oprot.writeStructBegin(
'TSerializedRows')
982 oprot.writeFieldBegin(
'buffers', TType.LIST, 1)
983 oprot.writeListBegin(TType.STRING, len(self.
buffers))
985 oprot.writeBinary(iter85)
987 oprot.writeFieldEnd()
989 oprot.writeFieldBegin(
'buffer_lengths', TType.LIST, 2)
992 oprot.writeI64(iter86)
994 oprot.writeFieldEnd()
996 oprot.writeFieldBegin(
'buffers_total_size', TType.I64, 3)
998 oprot.writeFieldEnd()
1000 oprot.writeFieldBegin(
'total_compression_time_ms', TType.I32, 4)
1002 oprot.writeFieldEnd()
1004 oprot.writeFieldBegin(
'descriptor', TType.STRUCT, 5)
1005 self.descriptor.write(oprot)
1006 oprot.writeFieldEnd()
1008 oprot.writeFieldBegin(
'targets', TType.LIST, 6)
1009 oprot.writeListBegin(TType.STRUCT, len(self.
targets))
1012 oprot.writeListEnd()
1013 oprot.writeFieldEnd()
1015 oprot.writeFieldBegin(
'target_init_vals', TType.LIST, 7)
1018 oprot.writeI64(iter88)
1019 oprot.writeListEnd()
1020 oprot.writeFieldEnd()
1022 oprot.writeFieldBegin(
'varlen_buffer', TType.LIST, 8)
1025 oprot.writeBinary(iter89)
1026 oprot.writeListEnd()
1027 oprot.writeFieldEnd()
1029 oprot.writeFieldBegin(
'count_distinct_sets', TType.LIST, 9)
1033 oprot.writeListEnd()
1034 oprot.writeFieldEnd()
1036 oprot.writeFieldBegin(
'explanation', TType.STRING, 10)
1037 oprot.writeString(self.explanation.encode(
'utf-8')
if sys.version_info[0] == 2
else self.
explanation)
1038 oprot.writeFieldEnd()
1039 oprot.writeFieldStop()
1040 oprot.writeStructEnd()
1046 L = [
'%s=%r' % (key, value)
1047 for key, value
in self.__dict__.items()]
1048 return '%s(%s)' % (self.__class__.__name__,
', '.
join(L))
1051 return isinstance(other, self.__class__)
and self.
__dict__ == other.__dict__
1054 return not (self == other)
1055 all_structs.append(TSlotSize)
1056 TSlotSize.thrift_spec = (
1058 (1, TType.I16,
'padded',
None,
None, ),
1059 (2, TType.I16,
'logical',
None,
None, ),
1061 all_structs.append(TColSlotContext)
1062 TColSlotContext.thrift_spec = (
1064 (1, TType.LIST,
'slot_sizes', (TType.STRUCT, [TSlotSize,
None],
False),
None, ),
1065 (2, TType.LIST,
'col_to_slot_map', (TType.LIST, (TType.I32,
None,
False),
False),
None, ),
1067 all_structs.append(TCountDistinctDescriptor)
1068 TCountDistinctDescriptor.thrift_spec = (
1070 (1, TType.I32,
'impl_type',
None,
None, ),
1071 (2, TType.I64,
'min_val',
None,
None, ),
1072 (3, TType.I64,
'bitmap_sz_bits',
None,
None, ),
1073 (4, TType.BOOL,
'approximate',
None,
None, ),
1074 (5, TType.I32,
'device_type',
None,
None, ),
1075 (6, TType.I64,
'sub_bitmap_count',
None,
None, ),
1077 all_structs.append(TResultSetBufferDescriptor)
1078 TResultSetBufferDescriptor.thrift_spec = (
1080 (1, TType.I32,
'layout',
None,
None, ),
1081 (2, TType.BOOL,
'keyless',
None,
None, ),
1082 (3, TType.I32,
'entry_count',
None,
None, ),
1083 (4, TType.I32,
'idx_target_as_key',
None,
None, ),
1084 (5, TType.I64,
'min_val',
None,
None, ),
1085 (6, TType.I64,
'max_val',
None,
None, ),
1086 (7, TType.I64,
'bucket',
None,
None, ),
1087 (8, TType.LIST,
'group_col_widths', (TType.I16,
None,
False),
None, ),
1088 (9, TType.I16,
'key_bytewidth',
None,
None, ),
1089 (10, TType.STRUCT,
'col_slot_context', [TColSlotContext,
None],
None, ),
1090 (11, TType.LIST,
'target_groupby_indices', (TType.I32,
None,
False),
None, ),
1091 (12, TType.LIST,
'count_distinct_descriptors', (TType.STRUCT, [TCountDistinctDescriptor,
None],
False),
None, ),
1092 (13, TType.BOOL,
'force_4byte_float',
None,
None, ),
1094 all_structs.append(TTargetInfo)
1095 TTargetInfo.thrift_spec = (
1097 (1, TType.BOOL,
'is_agg',
None,
None, ),
1098 (2, TType.I32,
'kind',
None,
None, ),
1101 (5, TType.BOOL,
'skip_nulls',
None,
None, ),
1102 (6, TType.BOOL,
'is_distinct',
None,
None, ),
1104 all_structs.append(TCountDistinctSetStorage)
1105 TCountDistinctSetStorage.thrift_spec = (
1107 (1, TType.STRING,
'bitmap',
'BINARY',
None, ),
1108 (2, TType.SET,
'sparse_set', (TType.I64,
None,
False),
None, ),
1110 all_structs.append(TCountDistinctSet)
1111 TCountDistinctSet.thrift_spec = (
1113 (1, TType.I32,
'type',
None,
None, ),
1114 (2, TType.STRUCT,
'storage', [TCountDistinctSetStorage,
None],
None, ),
1115 (3, TType.I64,
'remote_ptr',
None,
None, ),
1117 all_structs.append(TSerializedRows)
1118 TSerializedRows.thrift_spec = (
1120 (1, TType.LIST,
'buffers', (TType.STRING,
'BINARY',
False),
None, ),
1121 (2, TType.LIST,
'buffer_lengths', (TType.I64,
None,
False),
None, ),
1122 (3, TType.I64,
'buffers_total_size',
None,
None, ),
1123 (4, TType.I32,
'total_compression_time_ms',
None,
None, ),
1124 (5, TType.STRUCT,
'descriptor', [TResultSetBufferDescriptor,
None],
None, ),
1125 (6, TType.LIST,
'targets', (TType.STRUCT, [TTargetInfo,
None],
False),
None, ),
1126 (7, TType.LIST,
'target_init_vals', (TType.I64,
None,
False),
None, ),
1127 (8, TType.LIST,
'varlen_buffer', (TType.STRING,
'BINARY',
False),
None, ),
1128 (9, TType.LIST,
'count_distinct_sets', (TType.STRUCT, [TCountDistinctSet,
None],
False),
None, ),
1129 (10, TType.STRING,
'explanation',
'UTF8',
None, ),
1131 fix_spec(all_structs)
count_distinct_descriptors
total_compression_time_ms