OmniSciDB  72c90bc290
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
Public Member Functions | Public Attributes | Private Attributes | List of all members
heavydb.thrift.ttypes.TStepResult Class Reference
+ Inheritance diagram for heavydb.thrift.ttypes.TStepResult:
+ Collaboration diagram for heavydb.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 1148 of file ttypes.py.

Constructor & Destructor Documentation

def heavydb.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 1161 of file ttypes.py.

1161 
1162  def __init__(self, serialized_rows=None, execution_finished=None, merge_type=None, sharded=None, row_desc=None, node_id=None,):
1163  self.serialized_rows = serialized_rows
1164  self.execution_finished = execution_finished
1165  self.merge_type = merge_type
1166  self.sharded = sharded
1167  self.row_desc = row_desc
1168  self.node_id = node_id

Member Function Documentation

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

Definition at line 1263 of file ttypes.py.

1263 
1264  def __eq__(self, other):
1265  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
def heavydb.thrift.ttypes.TStepResult.__ne__ (   self,
  other 
)

Definition at line 1266 of file ttypes.py.

1266 
1267  def __ne__(self, other):
1268  return not (self == other)
1269 
def heavydb.thrift.ttypes.TStepResult.__repr__ (   self)

Definition at line 1258 of file ttypes.py.

1258 
1259  def __repr__(self):
1260  L = ['%s=%r' % (key, value)
1261  for key, value in self.__dict__.items()]
1262  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
join
std::string join(T const &container, std::string const &delim)
Definition: StringTransform.h:63

+ Here is the call graph for this function:

def heavydb.thrift.ttypes.TStepResult.read (   self,
  iprot 
)

Definition at line 1169 of file ttypes.py.

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

1169 
1170  def read(self, iprot):
1171  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
1172  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
1173  return
1174  iprot.readStructBegin()
1175  while True:
1176  (fname, ftype, fid) = iprot.readFieldBegin()
1177  if ftype == TType.STOP:
1178  break
1179  if fid == 1:
1180  if ftype == TType.STRUCT:
1181  self.serialized_rows = heavydb.serialized_result_set.ttypes.TSerializedRows()
1182  self.serialized_rows.read(iprot)
1183  else:
1184  iprot.skip(ftype)
1185  elif fid == 2:
1186  if ftype == TType.BOOL:
1187  self.execution_finished = iprot.readBool()
1188  else:
1189  iprot.skip(ftype)
1190  elif fid == 3:
1191  if ftype == TType.I32:
1192  self.merge_type = iprot.readI32()
1193  else:
1194  iprot.skip(ftype)
1195  elif fid == 4:
1196  if ftype == TType.BOOL:
1197  self.sharded = iprot.readBool()
1198  else:
1199  iprot.skip(ftype)
1200  elif fid == 5:
1201  if ftype == TType.LIST:
1202  self.row_desc = []
1203  (_etype59, _size56) = iprot.readListBegin()
1204  for _i60 in range(_size56):
1205  _elem61 = TColumnType()
1206  _elem61.read(iprot)
1207  self.row_desc.append(_elem61)
1208  iprot.readListEnd()
1209  else:
1210  iprot.skip(ftype)
1211  elif fid == 6:
1212  if ftype == TType.I32:
1213  self.node_id = iprot.readI32()
1214  else:
1215  iprot.skip(ftype)
1216  else:
1217  iprot.skip(ftype)
1218  iprot.readFieldEnd()
1219  iprot.readStructEnd()
heavydb.serialized_result_set.ttypes.TSerializedRows
Definition: ttypes.py:856
def heavydb.thrift.ttypes.TStepResult.validate (   self)

Definition at line 1255 of file ttypes.py.

1255 
1256  def validate(self):
1257  return
def heavydb.thrift.ttypes.TStepResult.write (   self,
  oprot 
)

Definition at line 1220 of file ttypes.py.

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

1220 
1221  def write(self, oprot):
1222  if oprot._fast_encode is not None and self.thrift_spec is not None:
1223  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
1224  return
1225  oprot.writeStructBegin('TStepResult')
1226  if self.serialized_rows is not None:
1227  oprot.writeFieldBegin('serialized_rows', TType.STRUCT, 1)
1228  self.serialized_rows.write(oprot)
1229  oprot.writeFieldEnd()
1230  if self.execution_finished is not None:
1231  oprot.writeFieldBegin('execution_finished', TType.BOOL, 2)
1232  oprot.writeBool(self.execution_finished)
1233  oprot.writeFieldEnd()
1234  if self.merge_type is not None:
1235  oprot.writeFieldBegin('merge_type', TType.I32, 3)
1236  oprot.writeI32(self.merge_type)
1237  oprot.writeFieldEnd()
1238  if self.sharded is not None:
1239  oprot.writeFieldBegin('sharded', TType.BOOL, 4)
1240  oprot.writeBool(self.sharded)
1241  oprot.writeFieldEnd()
1242  if self.row_desc is not None:
1243  oprot.writeFieldBegin('row_desc', TType.LIST, 5)
1244  oprot.writeListBegin(TType.STRUCT, len(self.row_desc))
1245  for iter62 in self.row_desc:
1246  iter62.write(oprot)
1247  oprot.writeListEnd()
1248  oprot.writeFieldEnd()
1249  if self.node_id is not None:
1250  oprot.writeFieldBegin('node_id', TType.I32, 6)
1251  oprot.writeI32(self.node_id)
1252  oprot.writeFieldEnd()
1253  oprot.writeFieldStop()
1254  oprot.writeStructEnd()

Member Data Documentation

heavydb.thrift.ttypes.TStepResult.__dict__
private

Definition at line 1264 of file ttypes.py.

Referenced by TableFunctionsFactory_node.Node.copy().

heavydb.thrift.ttypes.TStepResult.execution_finished

Definition at line 1163 of file ttypes.py.

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

heavydb.thrift.ttypes.TStepResult.merge_type

Definition at line 1164 of file ttypes.py.

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

heavydb.thrift.ttypes.TStepResult.node_id

Definition at line 1167 of file ttypes.py.

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

heavydb.thrift.ttypes.TStepResult.row_desc

Definition at line 1166 of file ttypes.py.

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

heavydb.thrift.ttypes.TStepResult.serialized_rows

Definition at line 1162 of file ttypes.py.

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

heavydb.thrift.ttypes.TStepResult.sharded

Definition at line 1165 of file ttypes.py.

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

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