OmniSciDB  fe05a0c208
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
omnisci.thrift.ttypes.TStepResult Class Reference
+ Inheritance diagram for omnisci.thrift.ttypes.TStepResult:
+ Collaboration diagram for omnisci.thrift.ttypes.TStepResult:

Public Member Functions

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

Public Attributes

 serialized_rows
 
 execution_finished
 
 merge_type
 
 sharded
 
 row_desc
 
 node_id
 

Private Attributes

 __dict__
 

Detailed Description

Attributes:
 - serialized_rows
 - execution_finished
 - merge_type
 - sharded
 - row_desc
 - node_id

Definition at line 999 of file ttypes.py.

Constructor & Destructor Documentation

def omnisci.thrift.ttypes.TStepResult.__init__ (   self,
  serialized_rows = None,
  execution_finished = None,
  merge_type = None,
  sharded = None,
  row_desc = None,
  node_id = None 
)

Definition at line 1012 of file ttypes.py.

1013  def __init__(self, serialized_rows=None, execution_finished=None, merge_type=None, sharded=None, row_desc=None, node_id=None,):
1014  self.serialized_rows = serialized_rows
1015  self.execution_finished = execution_finished
1016  self.merge_type = merge_type
1017  self.sharded = sharded
1018  self.row_desc = row_desc
1019  self.node_id = node_id

Member Function Documentation

def omnisci.thrift.ttypes.TStepResult.__eq__ (   self,
  other 
)

Definition at line 1114 of file ttypes.py.

1115  def __eq__(self, other):
1116  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
def omnisci.thrift.ttypes.TStepResult.__ne__ (   self,
  other 
)

Definition at line 1117 of file ttypes.py.

1118  def __ne__(self, other):
1119  return not (self == other)
1120 
def omnisci.thrift.ttypes.TStepResult.__repr__ (   self)

Definition at line 1109 of file ttypes.py.

1110  def __repr__(self):
1111  L = ['%s=%r' % (key, value)
1112  for key, value in self.__dict__.items()]
1113  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 omnisci.thrift.ttypes.TStepResult.read (   self,
  iprot 
)

Definition at line 1020 of file ttypes.py.

References omnisci.thrift.ttypes.TStepResult.execution_finished, omnisci.thrift.ttypes.TStepResult.merge_type, omnisci.thrift.ttypes.TStepResult.node_id, omnisci.thrift.ttypes.TStepResult.row_desc, omnisci.thrift.OmniSci.create_table_args.row_desc, omnisci.thrift.OmniSci.import_geo_table_args.row_desc, omnisci.thrift.OmniSci.broadcast_serialized_rows_args.row_desc, omnisci.thrift.ttypes.TStepResult.serialized_rows, omnisci.thrift.OmniSci.broadcast_serialized_rows_args.serialized_rows, and omnisci.thrift.ttypes.TStepResult.sharded.

1021  def read(self, iprot):
1022  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
1023  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
1024  return
1025  iprot.readStructBegin()
1026  while True:
1027  (fname, ftype, fid) = iprot.readFieldBegin()
1028  if ftype == TType.STOP:
1029  break
1030  if fid == 1:
1031  if ftype == TType.STRUCT:
1033  self.serialized_rows.read(iprot)
1034  else:
1035  iprot.skip(ftype)
1036  elif fid == 2:
1037  if ftype == TType.BOOL:
1038  self.execution_finished = iprot.readBool()
1039  else:
1040  iprot.skip(ftype)
1041  elif fid == 3:
1042  if ftype == TType.I32:
1043  self.merge_type = iprot.readI32()
1044  else:
1045  iprot.skip(ftype)
1046  elif fid == 4:
1047  if ftype == TType.BOOL:
1048  self.sharded = iprot.readBool()
1049  else:
1050  iprot.skip(ftype)
1051  elif fid == 5:
1052  if ftype == TType.LIST:
1053  self.row_desc = []
1054  (_etype59, _size56) = iprot.readListBegin()
1055  for _i60 in range(_size56):
1056  _elem61 = TColumnType()
1057  _elem61.read(iprot)
1058  self.row_desc.append(_elem61)
1059  iprot.readListEnd()
1060  else:
1061  iprot.skip(ftype)
1062  elif fid == 6:
1063  if ftype == TType.I32:
1064  self.node_id = iprot.readI32()
1065  else:
1066  iprot.skip(ftype)
1067  else:
1068  iprot.skip(ftype)
1069  iprot.readFieldEnd()
1070  iprot.readStructEnd()
def omnisci.thrift.ttypes.TStepResult.validate (   self)

Definition at line 1106 of file ttypes.py.

1107  def validate(self):
1108  return
def omnisci.thrift.ttypes.TStepResult.write (   self,
  oprot 
)

Definition at line 1071 of file ttypes.py.

References omnisci.thrift.ttypes.TStepResult.execution_finished, omnisci.thrift.ttypes.TStepResult.merge_type, omnisci.thrift.ttypes.TStepResult.node_id, omnisci.thrift.ttypes.TStepResult.row_desc, omnisci.thrift.OmniSci.create_table_args.row_desc, omnisci.thrift.OmniSci.import_geo_table_args.row_desc, omnisci.thrift.OmniSci.broadcast_serialized_rows_args.row_desc, omnisci.thrift.ttypes.TStepResult.serialized_rows, omnisci.thrift.OmniSci.broadcast_serialized_rows_args.serialized_rows, and omnisci.thrift.ttypes.TStepResult.sharded.

1072  def write(self, oprot):
1073  if oprot._fast_encode is not None and self.thrift_spec is not None:
1074  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
1075  return
1076  oprot.writeStructBegin('TStepResult')
1077  if self.serialized_rows is not None:
1078  oprot.writeFieldBegin('serialized_rows', TType.STRUCT, 1)
1079  self.serialized_rows.write(oprot)
1080  oprot.writeFieldEnd()
1081  if self.execution_finished is not None:
1082  oprot.writeFieldBegin('execution_finished', TType.BOOL, 2)
1083  oprot.writeBool(self.execution_finished)
1084  oprot.writeFieldEnd()
1085  if self.merge_type is not None:
1086  oprot.writeFieldBegin('merge_type', TType.I32, 3)
1087  oprot.writeI32(self.merge_type)
1088  oprot.writeFieldEnd()
1089  if self.sharded is not None:
1090  oprot.writeFieldBegin('sharded', TType.BOOL, 4)
1091  oprot.writeBool(self.sharded)
1092  oprot.writeFieldEnd()
1093  if self.row_desc is not None:
1094  oprot.writeFieldBegin('row_desc', TType.LIST, 5)
1095  oprot.writeListBegin(TType.STRUCT, len(self.row_desc))
1096  for iter62 in self.row_desc:
1097  iter62.write(oprot)
1098  oprot.writeListEnd()
1099  oprot.writeFieldEnd()
1100  if self.node_id is not None:
1101  oprot.writeFieldBegin('node_id', TType.I32, 6)
1102  oprot.writeI32(self.node_id)
1103  oprot.writeFieldEnd()
1104  oprot.writeFieldStop()
1105  oprot.writeStructEnd()

Member Data Documentation

omnisci.thrift.ttypes.TStepResult.__dict__
private

Definition at line 1115 of file ttypes.py.

omnisci.thrift.ttypes.TStepResult.execution_finished

Definition at line 1014 of file ttypes.py.

Referenced by omnisci.thrift.ttypes.TStepResult.read(), and omnisci.thrift.ttypes.TStepResult.write().

omnisci.thrift.ttypes.TStepResult.merge_type

Definition at line 1015 of file ttypes.py.

Referenced by omnisci.thrift.ttypes.TStepResult.read(), omnisci.thrift.ttypes.TRenderParseResult.read(), omnisci.thrift.ttypes.TStepResult.write(), and omnisci.thrift.ttypes.TRenderParseResult.write().

omnisci.thrift.ttypes.TStepResult.node_id

Definition at line 1018 of file ttypes.py.

Referenced by omnisci.thrift.ttypes.TStepResult.read(), omnisci.thrift.ttypes.TRenderParseResult.read(), omnisci.thrift.ttypes.TStepResult.write(), and omnisci.thrift.ttypes.TRenderParseResult.write().

omnisci.thrift.ttypes.TStepResult.row_desc

Definition at line 1017 of file ttypes.py.

Referenced by omnisci.thrift.ttypes.TStepResult.read(), omnisci.thrift.ttypes.TRowSet.read(), omnisci.thrift.ttypes.TTableDetails.read(), omnisci.thrift.ttypes.TStepResult.write(), omnisci.thrift.ttypes.TRowSet.write(), and omnisci.thrift.ttypes.TTableDetails.write().

omnisci.thrift.ttypes.TStepResult.serialized_rows

Definition at line 1013 of file ttypes.py.

Referenced by omnisci.thrift.ttypes.TStepResult.read(), and omnisci.thrift.ttypes.TStepResult.write().

omnisci.thrift.ttypes.TStepResult.sharded

Definition at line 1016 of file ttypes.py.

Referenced by omnisci.thrift.ttypes.TStepResult.read(), and omnisci.thrift.ttypes.TStepResult.write().


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