OmniSciDB  340b00dbf6
 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 996 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 1009 of file ttypes.py.

1010  def __init__(self, serialized_rows=None, execution_finished=None, merge_type=None, sharded=None, row_desc=None, node_id=None,):
1011  self.serialized_rows = serialized_rows
1012  self.execution_finished = execution_finished
1013  self.merge_type = merge_type
1014  self.sharded = sharded
1015  self.row_desc = row_desc
1016  self.node_id = node_id

Member Function Documentation

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

Definition at line 1111 of file ttypes.py.

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

Definition at line 1114 of file ttypes.py.

1115  def __ne__(self, other):
1116  return not (self == other)
1117 
def omnisci.thrift.ttypes.TStepResult.__repr__ (   self)

Definition at line 1106 of file ttypes.py.

1107  def __repr__(self):
1108  L = ['%s=%r' % (key, value)
1109  for key, value in self.__dict__.items()]
1110  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 1017 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.

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

Definition at line 1103 of file ttypes.py.

1104  def validate(self):
1105  return
def omnisci.thrift.ttypes.TStepResult.write (   self,
  oprot 
)

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

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

Member Data Documentation

omnisci.thrift.ttypes.TStepResult.__dict__
private

Definition at line 1112 of file ttypes.py.

omnisci.thrift.ttypes.TStepResult.execution_finished

Definition at line 1011 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 1012 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 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.row_desc

Definition at line 1014 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 1010 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 1013 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: