OmniSciDB  72c90bc290
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
heavydb.serialized_result_set.ttypes.TSerializedRows Class Reference
+ Inheritance diagram for heavydb.serialized_result_set.ttypes.TSerializedRows:
+ Collaboration diagram for heavydb.serialized_result_set.ttypes.TSerializedRows:

Public Member Functions

def __init__
 
def read
 
def write
 
def validate
 
def __repr__
 
def __eq__
 
def __ne__
 

Public Attributes

 buffers
 
 buffer_lengths
 
 buffers_total_size
 
 total_compression_time_ms
 
 descriptor
 
 targets
 
 target_init_vals
 
 varlen_buffer
 
 count_distinct_sets
 
 explanation
 

Private Attributes

 __dict__
 

Detailed Description

Attributes:
 - buffers
 - buffer_lengths
 - buffers_total_size
 - total_compression_time_ms
 - descriptor
 - targets
 - target_init_vals
 - varlen_buffer
 - count_distinct_sets
 - explanation

Definition at line 856 of file ttypes.py.

Constructor & Destructor Documentation

def heavydb.serialized_result_set.ttypes.TSerializedRows.__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 
)

Definition at line 873 of file ttypes.py.

874  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,):
875  self.buffers = buffers
876  self.buffer_lengths = buffer_lengths
877  self.buffers_total_size = buffers_total_size
878  self.total_compression_time_ms = total_compression_time_ms
879  self.descriptor = descriptor
880  self.targets = targets
881  self.target_init_vals = target_init_vals
882  self.varlen_buffer = varlen_buffer
883  self.count_distinct_sets = count_distinct_sets
884  self.explanation = explanation

Member Function Documentation

def heavydb.serialized_result_set.ttypes.TSerializedRows.__eq__ (   self,
  other 
)

Definition at line 1056 of file ttypes.py.

1057  def __eq__(self, other):
1058  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
def heavydb.serialized_result_set.ttypes.TSerializedRows.__ne__ (   self,
  other 
)

Definition at line 1059 of file ttypes.py.

1060  def __ne__(self, other):
1061  return not (self == other)
1062 all_structs.append(TSlotSize)
TSlotSize.thrift_spec = (
def heavydb.serialized_result_set.ttypes.TSerializedRows.__repr__ (   self)

Definition at line 1051 of file ttypes.py.

1052  def __repr__(self):
1053  L = ['%s=%r' % (key, value)
1054  for key, value in self.__dict__.items()]
1055  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
std::string join(T const &container, std::string const &delim)

+ Here is the call graph for this function:

def heavydb.serialized_result_set.ttypes.TSerializedRows.read (   self,
  iprot 
)

Definition at line 885 of file ttypes.py.

References heavydb.serialized_result_set.ttypes.TSerializedRows.buffer_lengths, heavydb.serialized_result_set.ttypes.TSerializedRows.buffers, heavydb.serialized_result_set.ttypes.TSerializedRows.buffers_total_size, heavydb.serialized_result_set.ttypes.TSerializedRows.count_distinct_sets, heavydb.serialized_result_set.ttypes.TSerializedRows.descriptor, heavydb.serialized_result_set.ttypes.TSerializedRows.explanation, heavydb.serialized_result_set.ttypes.TSerializedRows.target_init_vals, heavydb.serialized_result_set.ttypes.TSerializedRows.targets, heavydb.serialized_result_set.ttypes.TSerializedRows.total_compression_time_ms, and heavydb.serialized_result_set.ttypes.TSerializedRows.varlen_buffer.

886  def read(self, iprot):
887  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
888  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
889  return
890  iprot.readStructBegin()
891  while True:
892  (fname, ftype, fid) = iprot.readFieldBegin()
893  if ftype == TType.STOP:
894  break
895  if fid == 1:
896  if ftype == TType.LIST:
897  self.buffers = []
898  (_etype52, _size49) = iprot.readListBegin()
899  for _i53 in range(_size49):
900  _elem54 = iprot.readBinary()
901  self.buffers.append(_elem54)
902  iprot.readListEnd()
903  else:
904  iprot.skip(ftype)
905  elif fid == 2:
906  if ftype == TType.LIST:
907  self.buffer_lengths = []
908  (_etype58, _size55) = iprot.readListBegin()
909  for _i59 in range(_size55):
910  _elem60 = iprot.readI64()
911  self.buffer_lengths.append(_elem60)
912  iprot.readListEnd()
913  else:
914  iprot.skip(ftype)
915  elif fid == 3:
916  if ftype == TType.I64:
917  self.buffers_total_size = iprot.readI64()
918  else:
919  iprot.skip(ftype)
920  elif fid == 4:
921  if ftype == TType.I32:
922  self.total_compression_time_ms = iprot.readI32()
923  else:
924  iprot.skip(ftype)
925  elif fid == 5:
926  if ftype == TType.STRUCT:
928  self.descriptor.read(iprot)
929  else:
930  iprot.skip(ftype)
931  elif fid == 6:
932  if ftype == TType.LIST:
933  self.targets = []
934  (_etype64, _size61) = iprot.readListBegin()
935  for _i65 in range(_size61):
936  _elem66 = TTargetInfo()
937  _elem66.read(iprot)
938  self.targets.append(_elem66)
939  iprot.readListEnd()
940  else:
941  iprot.skip(ftype)
942  elif fid == 7:
943  if ftype == TType.LIST:
944  self.target_init_vals = []
945  (_etype70, _size67) = iprot.readListBegin()
946  for _i71 in range(_size67):
947  _elem72 = iprot.readI64()
948  self.target_init_vals.append(_elem72)
949  iprot.readListEnd()
950  else:
951  iprot.skip(ftype)
952  elif fid == 8:
953  if ftype == TType.LIST:
954  self.varlen_buffer = []
955  (_etype76, _size73) = iprot.readListBegin()
956  for _i77 in range(_size73):
957  _elem78 = iprot.readBinary()
958  self.varlen_buffer.append(_elem78)
959  iprot.readListEnd()
960  else:
961  iprot.skip(ftype)
962  elif fid == 9:
963  if ftype == TType.LIST:
964  self.count_distinct_sets = []
965  (_etype82, _size79) = iprot.readListBegin()
966  for _i83 in range(_size79):
967  _elem84 = TCountDistinctSet()
968  _elem84.read(iprot)
969  self.count_distinct_sets.append(_elem84)
970  iprot.readListEnd()
971  else:
972  iprot.skip(ftype)
973  elif fid == 10:
974  if ftype == TType.STRING:
975  self.explanation = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
976  else:
977  iprot.skip(ftype)
978  else:
979  iprot.skip(ftype)
980  iprot.readFieldEnd()
981  iprot.readStructEnd()
def heavydb.serialized_result_set.ttypes.TSerializedRows.validate (   self)

Definition at line 1048 of file ttypes.py.

1049  def validate(self):
1050  return
def heavydb.serialized_result_set.ttypes.TSerializedRows.write (   self,
  oprot 
)

Definition at line 982 of file ttypes.py.

References heavydb.serialized_result_set.ttypes.TSerializedRows.buffer_lengths, heavydb.serialized_result_set.ttypes.TSerializedRows.buffers, heavydb.serialized_result_set.ttypes.TSerializedRows.buffers_total_size, heavydb.serialized_result_set.ttypes.TSerializedRows.count_distinct_sets, heavydb.serialized_result_set.ttypes.TSerializedRows.descriptor, heavydb.serialized_result_set.ttypes.TSerializedRows.explanation, heavydb.serialized_result_set.ttypes.TSerializedRows.target_init_vals, heavydb.serialized_result_set.ttypes.TSerializedRows.targets, heavydb.serialized_result_set.ttypes.TSerializedRows.total_compression_time_ms, and heavydb.serialized_result_set.ttypes.TSerializedRows.varlen_buffer.

983  def write(self, oprot):
984  if oprot._fast_encode is not None and self.thrift_spec is not None:
985  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
986  return
987  oprot.writeStructBegin('TSerializedRows')
988  if self.buffers is not None:
989  oprot.writeFieldBegin('buffers', TType.LIST, 1)
990  oprot.writeListBegin(TType.STRING, len(self.buffers))
991  for iter85 in self.buffers:
992  oprot.writeBinary(iter85)
993  oprot.writeListEnd()
994  oprot.writeFieldEnd()
995  if self.buffer_lengths is not None:
996  oprot.writeFieldBegin('buffer_lengths', TType.LIST, 2)
997  oprot.writeListBegin(TType.I64, len(self.buffer_lengths))
998  for iter86 in self.buffer_lengths:
999  oprot.writeI64(iter86)
1000  oprot.writeListEnd()
1001  oprot.writeFieldEnd()
1002  if self.buffers_total_size is not None:
1003  oprot.writeFieldBegin('buffers_total_size', TType.I64, 3)
1004  oprot.writeI64(self.buffers_total_size)
1005  oprot.writeFieldEnd()
1006  if self.total_compression_time_ms is not None:
1007  oprot.writeFieldBegin('total_compression_time_ms', TType.I32, 4)
1008  oprot.writeI32(self.total_compression_time_ms)
1009  oprot.writeFieldEnd()
1010  if self.descriptor is not None:
1011  oprot.writeFieldBegin('descriptor', TType.STRUCT, 5)
1012  self.descriptor.write(oprot)
1013  oprot.writeFieldEnd()
1014  if self.targets is not None:
1015  oprot.writeFieldBegin('targets', TType.LIST, 6)
1016  oprot.writeListBegin(TType.STRUCT, len(self.targets))
1017  for iter87 in self.targets:
1018  iter87.write(oprot)
1019  oprot.writeListEnd()
1020  oprot.writeFieldEnd()
1021  if self.target_init_vals is not None:
1022  oprot.writeFieldBegin('target_init_vals', TType.LIST, 7)
1023  oprot.writeListBegin(TType.I64, len(self.target_init_vals))
1024  for iter88 in self.target_init_vals:
1025  oprot.writeI64(iter88)
1026  oprot.writeListEnd()
1027  oprot.writeFieldEnd()
1028  if self.varlen_buffer is not None:
1029  oprot.writeFieldBegin('varlen_buffer', TType.LIST, 8)
1030  oprot.writeListBegin(TType.STRING, len(self.varlen_buffer))
1031  for iter89 in self.varlen_buffer:
1032  oprot.writeBinary(iter89)
1033  oprot.writeListEnd()
1034  oprot.writeFieldEnd()
1035  if self.count_distinct_sets is not None:
1036  oprot.writeFieldBegin('count_distinct_sets', TType.LIST, 9)
1037  oprot.writeListBegin(TType.STRUCT, len(self.count_distinct_sets))
1038  for iter90 in self.count_distinct_sets:
1039  iter90.write(oprot)
1040  oprot.writeListEnd()
1041  oprot.writeFieldEnd()
1042  if self.explanation is not None:
1043  oprot.writeFieldBegin('explanation', TType.STRING, 10)
1044  oprot.writeString(self.explanation.encode('utf-8') if sys.version_info[0] == 2 else self.explanation)
1045  oprot.writeFieldEnd()
1046  oprot.writeFieldStop()
1047  oprot.writeStructEnd()

Member Data Documentation

heavydb.serialized_result_set.ttypes.TSerializedRows.__dict__
private

Definition at line 1057 of file ttypes.py.

Referenced by TableFunctionsFactory_node.Node.copy().

heavydb.serialized_result_set.ttypes.TSerializedRows.buffer_lengths

Definition at line 875 of file ttypes.py.

Referenced by heavydb.serialized_result_set.ttypes.TSerializedRows.read(), and heavydb.serialized_result_set.ttypes.TSerializedRows.write().

heavydb.serialized_result_set.ttypes.TSerializedRows.buffers

Definition at line 874 of file ttypes.py.

Referenced by heavydb.serialized_result_set.ttypes.TSerializedRows.read(), and heavydb.serialized_result_set.ttypes.TSerializedRows.write().

heavydb.serialized_result_set.ttypes.TSerializedRows.buffers_total_size

Definition at line 876 of file ttypes.py.

Referenced by heavydb.serialized_result_set.ttypes.TSerializedRows.read(), and heavydb.serialized_result_set.ttypes.TSerializedRows.write().

heavydb.serialized_result_set.ttypes.TSerializedRows.count_distinct_sets

Definition at line 882 of file ttypes.py.

Referenced by heavydb.serialized_result_set.ttypes.TSerializedRows.read(), and heavydb.serialized_result_set.ttypes.TSerializedRows.write().

heavydb.serialized_result_set.ttypes.TSerializedRows.descriptor

Definition at line 878 of file ttypes.py.

Referenced by heavydb.serialized_result_set.ttypes.TSerializedRows.read(), and heavydb.serialized_result_set.ttypes.TSerializedRows.write().

heavydb.serialized_result_set.ttypes.TSerializedRows.explanation

Definition at line 883 of file ttypes.py.

Referenced by heavydb.serialized_result_set.ttypes.TSerializedRows.read(), and heavydb.serialized_result_set.ttypes.TSerializedRows.write().

heavydb.serialized_result_set.ttypes.TSerializedRows.target_init_vals

Definition at line 880 of file ttypes.py.

Referenced by heavydb.serialized_result_set.ttypes.TSerializedRows.read(), and heavydb.serialized_result_set.ttypes.TSerializedRows.write().

heavydb.serialized_result_set.ttypes.TSerializedRows.targets

Definition at line 879 of file ttypes.py.

Referenced by heavydb.serialized_result_set.ttypes.TSerializedRows.read(), and heavydb.serialized_result_set.ttypes.TSerializedRows.write().

heavydb.serialized_result_set.ttypes.TSerializedRows.total_compression_time_ms

Definition at line 877 of file ttypes.py.

Referenced by heavydb.serialized_result_set.ttypes.TSerializedRows.read(), and heavydb.serialized_result_set.ttypes.TSerializedRows.write().

heavydb.serialized_result_set.ttypes.TSerializedRows.varlen_buffer

Definition at line 881 of file ttypes.py.

Referenced by heavydb.serialized_result_set.ttypes.TSerializedRows.read(), and heavydb.serialized_result_set.ttypes.TSerializedRows.write().


The documentation for this class was generated from the following file: