OmniSciDB  340b00dbf6
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
Public Member Functions | Public Attributes | Private Attributes | List of all members
omnisci.serialized_result_set.ttypes.TSerializedRows Class Reference
+ Inheritance diagram for omnisci.serialized_result_set.ttypes.TSerializedRows:
+ Collaboration diagram for omnisci.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 847 of file ttypes.py.

Constructor & Destructor Documentation

def omnisci.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 864 of file ttypes.py.

864 
865  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,):
866  self.buffers = buffers
867  self.buffer_lengths = buffer_lengths
868  self.buffers_total_size = buffers_total_size
869  self.total_compression_time_ms = total_compression_time_ms
870  self.descriptor = descriptor
871  self.targets = targets
872  self.target_init_vals = target_init_vals
873  self.varlen_buffer = varlen_buffer
874  self.count_distinct_sets = count_distinct_sets
875  self.explanation = explanation
omnisci.serialized_result_set.ttypes.TSerializedRows.buffers_total_size
buffers_total_size
Definition: ttypes.py:867
omnisci.serialized_result_set.ttypes.TSerializedRows.total_compression_time_ms
total_compression_time_ms
Definition: ttypes.py:868
omnisci.serialized_result_set.ttypes.TSerializedRows.varlen_buffer
varlen_buffer
Definition: ttypes.py:872
omnisci.serialized_result_set.ttypes.TSerializedRows.explanation
explanation
Definition: ttypes.py:874
omnisci.serialized_result_set.ttypes.TSerializedRows.targets
targets
Definition: ttypes.py:870
omnisci.serialized_result_set.ttypes.TSerializedRows.count_distinct_sets
count_distinct_sets
Definition: ttypes.py:873
omnisci.serialized_result_set.ttypes.TSerializedRows.buffers
buffers
Definition: ttypes.py:865
omnisci.serialized_result_set.ttypes.TSerializedRows.descriptor
descriptor
Definition: ttypes.py:869
omnisci.serialized_result_set.ttypes.TSerializedRows.__init__
def __init__
Definition: ttypes.py:864
omnisci.serialized_result_set.ttypes.TSerializedRows.target_init_vals
target_init_vals
Definition: ttypes.py:871
omnisci.serialized_result_set.ttypes.TSerializedRows.buffer_lengths
buffer_lengths
Definition: ttypes.py:866

Member Function Documentation

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

Definition at line 1047 of file ttypes.py.

1047 
1048  def __eq__(self, other):
1049  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
omnisci.serialized_result_set.ttypes.TSerializedRows.__eq__
def __eq__
Definition: ttypes.py:1047
omnisci.serialized_result_set.ttypes.TSerializedRows.__dict__
__dict__
Definition: ttypes.py:1048
def omnisci.serialized_result_set.ttypes.TSerializedRows.__ne__ (   self,
  other 
)

Definition at line 1050 of file ttypes.py.

1050 
1051  def __ne__(self, other):
1052  return not (self == other)
1053 all_structs.append(TSlotSize)
TSlotSize.thrift_spec = (
omnisci.serialized_result_set.ttypes.TSerializedRows.__ne__
def __ne__
Definition: ttypes.py:1050
def omnisci.serialized_result_set.ttypes.TSerializedRows.__repr__ (   self)

Definition at line 1042 of file ttypes.py.

1042 
1043  def __repr__(self):
1044  L = ['%s=%r' % (key, value)
1045  for key, value in self.__dict__.items()]
1046  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
join
std::string join(T const &container, std::string const &delim)
Definition: StringTransform.h:60
omnisci.serialized_result_set.ttypes.TSerializedRows.__repr__
def __repr__
Definition: ttypes.py:1042

+ Here is the call graph for this function:

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

Definition at line 876 of file ttypes.py.

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

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

Definition at line 1039 of file ttypes.py.

1039 
1040  def validate(self):
1041  return
omnisci.serialized_result_set.ttypes.TSerializedRows.validate
def validate
Definition: ttypes.py:1039
def omnisci.serialized_result_set.ttypes.TSerializedRows.write (   self,
  oprot 
)

Definition at line 973 of file ttypes.py.

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

973 
974  def write(self, oprot):
975  if oprot._fast_encode is not None and self.thrift_spec is not None:
976  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
977  return
978  oprot.writeStructBegin('TSerializedRows')
979  if self.buffers is not None:
980  oprot.writeFieldBegin('buffers', TType.LIST, 1)
981  oprot.writeListBegin(TType.STRING, len(self.buffers))
982  for iter85 in self.buffers:
983  oprot.writeBinary(iter85)
984  oprot.writeListEnd()
985  oprot.writeFieldEnd()
986  if self.buffer_lengths is not None:
987  oprot.writeFieldBegin('buffer_lengths', TType.LIST, 2)
988  oprot.writeListBegin(TType.I64, len(self.buffer_lengths))
989  for iter86 in self.buffer_lengths:
990  oprot.writeI64(iter86)
991  oprot.writeListEnd()
992  oprot.writeFieldEnd()
993  if self.buffers_total_size is not None:
994  oprot.writeFieldBegin('buffers_total_size', TType.I64, 3)
995  oprot.writeI64(self.buffers_total_size)
996  oprot.writeFieldEnd()
997  if self.total_compression_time_ms is not None:
998  oprot.writeFieldBegin('total_compression_time_ms', TType.I32, 4)
999  oprot.writeI32(self.total_compression_time_ms)
1000  oprot.writeFieldEnd()
1001  if self.descriptor is not None:
1002  oprot.writeFieldBegin('descriptor', TType.STRUCT, 5)
1003  self.descriptor.write(oprot)
1004  oprot.writeFieldEnd()
1005  if self.targets is not None:
1006  oprot.writeFieldBegin('targets', TType.LIST, 6)
1007  oprot.writeListBegin(TType.STRUCT, len(self.targets))
1008  for iter87 in self.targets:
1009  iter87.write(oprot)
1010  oprot.writeListEnd()
1011  oprot.writeFieldEnd()
1012  if self.target_init_vals is not None:
1013  oprot.writeFieldBegin('target_init_vals', TType.LIST, 7)
1014  oprot.writeListBegin(TType.I64, len(self.target_init_vals))
1015  for iter88 in self.target_init_vals:
1016  oprot.writeI64(iter88)
1017  oprot.writeListEnd()
1018  oprot.writeFieldEnd()
1019  if self.varlen_buffer is not None:
1020  oprot.writeFieldBegin('varlen_buffer', TType.LIST, 8)
1021  oprot.writeListBegin(TType.STRING, len(self.varlen_buffer))
1022  for iter89 in self.varlen_buffer:
1023  oprot.writeBinary(iter89)
1024  oprot.writeListEnd()
1025  oprot.writeFieldEnd()
1026  if self.count_distinct_sets is not None:
1027  oprot.writeFieldBegin('count_distinct_sets', TType.LIST, 9)
1028  oprot.writeListBegin(TType.STRUCT, len(self.count_distinct_sets))
1029  for iter90 in self.count_distinct_sets:
1030  iter90.write(oprot)
1031  oprot.writeListEnd()
1032  oprot.writeFieldEnd()
1033  if self.explanation is not None:
1034  oprot.writeFieldBegin('explanation', TType.STRING, 10)
1035  oprot.writeString(self.explanation.encode('utf-8') if sys.version_info[0] == 2 else self.explanation)
1036  oprot.writeFieldEnd()
1037  oprot.writeFieldStop()
1038  oprot.writeStructEnd()
omnisci.serialized_result_set.ttypes.TSerializedRows.buffers_total_size
buffers_total_size
Definition: ttypes.py:867
omnisci.serialized_result_set.ttypes.TSerializedRows.total_compression_time_ms
total_compression_time_ms
Definition: ttypes.py:868
omnisci.serialized_result_set.ttypes.TSerializedRows.varlen_buffer
varlen_buffer
Definition: ttypes.py:872
omnisci.serialized_result_set.ttypes.TSerializedRows.write
def write
Definition: ttypes.py:973
omnisci.serialized_result_set.ttypes.TSerializedRows.explanation
explanation
Definition: ttypes.py:874
omnisci.serialized_result_set.ttypes.TSerializedRows.targets
targets
Definition: ttypes.py:870
omnisci.serialized_result_set.ttypes.TSerializedRows.count_distinct_sets
count_distinct_sets
Definition: ttypes.py:873
omnisci.serialized_result_set.ttypes.TSerializedRows.buffers
buffers
Definition: ttypes.py:865
omnisci.serialized_result_set.ttypes.TSerializedRows.descriptor
descriptor
Definition: ttypes.py:869
omnisci.serialized_result_set.ttypes.TSerializedRows.target_init_vals
target_init_vals
Definition: ttypes.py:871
omnisci.serialized_result_set.ttypes.TSerializedRows.buffer_lengths
buffer_lengths
Definition: ttypes.py:866

Member Data Documentation

omnisci.serialized_result_set.ttypes.TSerializedRows.__dict__
private

Definition at line 1048 of file ttypes.py.

omnisci.serialized_result_set.ttypes.TSerializedRows.buffer_lengths

Definition at line 866 of file ttypes.py.

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

omnisci.serialized_result_set.ttypes.TSerializedRows.buffers

Definition at line 865 of file ttypes.py.

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

omnisci.serialized_result_set.ttypes.TSerializedRows.buffers_total_size

Definition at line 867 of file ttypes.py.

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

omnisci.serialized_result_set.ttypes.TSerializedRows.count_distinct_sets

Definition at line 873 of file ttypes.py.

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

omnisci.serialized_result_set.ttypes.TSerializedRows.descriptor

Definition at line 869 of file ttypes.py.

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

omnisci.serialized_result_set.ttypes.TSerializedRows.explanation

Definition at line 874 of file ttypes.py.

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

omnisci.serialized_result_set.ttypes.TSerializedRows.target_init_vals

Definition at line 871 of file ttypes.py.

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

omnisci.serialized_result_set.ttypes.TSerializedRows.targets

Definition at line 870 of file ttypes.py.

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

omnisci.serialized_result_set.ttypes.TSerializedRows.total_compression_time_ms

Definition at line 868 of file ttypes.py.

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

omnisci.serialized_result_set.ttypes.TSerializedRows.varlen_buffer

Definition at line 872 of file ttypes.py.

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

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