OmniSciDB  94e8789169
 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 850 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 867 of file ttypes.py.

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

Member Function Documentation

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

Definition at line 1050 of file ttypes.py.

1050 
1051  def __eq__(self, other):
1052  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
omnisci.serialized_result_set.ttypes.TSerializedRows.__eq__
def __eq__
Definition: ttypes.py:1050
omnisci.serialized_result_set.ttypes.TSerializedRows.__dict__
__dict__
Definition: ttypes.py:1051
def omnisci.serialized_result_set.ttypes.TSerializedRows.__ne__ (   self,
  other 
)

Definition at line 1053 of file ttypes.py.

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

Definition at line 1045 of file ttypes.py.

1045 
1046  def __repr__(self):
1047  L = ['%s=%r' % (key, value)
1048  for key, value in self.__dict__.items()]
1049  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:1045

+ Here is the call graph for this function:

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

Definition at line 879 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.

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

Definition at line 1042 of file ttypes.py.

1042 
1043  def validate(self):
1044  return
omnisci.serialized_result_set.ttypes.TSerializedRows.validate
def validate
Definition: ttypes.py:1042
def omnisci.serialized_result_set.ttypes.TSerializedRows.write (   self,
  oprot 
)

Definition at line 976 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.

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

Member Data Documentation

omnisci.serialized_result_set.ttypes.TSerializedRows.__dict__
private

Definition at line 1051 of file ttypes.py.

omnisci.serialized_result_set.ttypes.TSerializedRows.buffer_lengths

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.buffers

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.buffers_total_size

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.count_distinct_sets

Definition at line 876 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 872 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 877 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 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.targets

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.total_compression_time_ms

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.varlen_buffer

Definition at line 875 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: