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.Heavy.broadcast_serialized_rows_args Class Reference
+ Inheritance diagram for heavydb.thrift.Heavy.broadcast_serialized_rows_args:
+ Collaboration diagram for heavydb.thrift.Heavy.broadcast_serialized_rows_args:

Public Member Functions

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

Public Attributes

 serialized_rows
 
 row_desc
 
 query_id
 
 subquery_id
 
 is_final_subquery_result
 

Private Attributes

 __dict__
 

Detailed Description

Attributes:
 - serialized_rows
 - row_desc
 - query_id
 - subquery_id
 - is_final_subquery_result

Definition at line 20076 of file Heavy.py.

Constructor & Destructor Documentation

def heavydb.thrift.Heavy.broadcast_serialized_rows_args.__init__ (   self,
  serialized_rows = None,
  row_desc = None,
  query_id = None,
  subquery_id = None,
  is_final_subquery_result = None 
)

Definition at line 20088 of file Heavy.py.

20088 
20089  def __init__(self, serialized_rows=None, row_desc=None, query_id=None, subquery_id=None, is_final_subquery_result=None,):
20090  self.serialized_rows = serialized_rows
20091  self.row_desc = row_desc
20092  self.query_id = query_id
20093  self.subquery_id = subquery_id
20094  self.is_final_subquery_result = is_final_subquery_result
heavydb.thrift.Heavy.broadcast_serialized_rows_args.serialized_rows
serialized_rows
Definition: Heavy.py:20089
heavydb.thrift.Heavy.broadcast_serialized_rows_args.is_final_subquery_result
is_final_subquery_result
Definition: Heavy.py:20093
heavydb.thrift.Heavy.broadcast_serialized_rows_args.row_desc
row_desc
Definition: Heavy.py:20090
heavydb.thrift.Heavy.broadcast_serialized_rows_args.query_id
query_id
Definition: Heavy.py:20091
heavydb.thrift.Heavy.broadcast_serialized_rows_args.__init__
def __init__
Definition: Heavy.py:20088
heavydb.thrift.Heavy.broadcast_serialized_rows_args.subquery_id
subquery_id
Definition: Heavy.py:20092

Member Function Documentation

def heavydb.thrift.Heavy.broadcast_serialized_rows_args.__eq__ (   self,
  other 
)

Definition at line 20180 of file Heavy.py.

20180 
20181  def __eq__(self, other):
20182  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
heavydb.thrift.Heavy.broadcast_serialized_rows_args.__eq__
def __eq__
Definition: Heavy.py:20180
heavydb.thrift.Heavy.broadcast_serialized_rows_args.__dict__
__dict__
Definition: Heavy.py:20181
def heavydb.thrift.Heavy.broadcast_serialized_rows_args.__ne__ (   self,
  other 
)

Definition at line 20183 of file Heavy.py.

20183 
20184  def __ne__(self, other):
20185  return not (self == other)
20186 all_structs.append(broadcast_serialized_rows_args)
broadcast_serialized_rows_args.thrift_spec = (
heavydb.thrift.Heavy.broadcast_serialized_rows_args.__ne__
def __ne__
Definition: Heavy.py:20183
def heavydb.thrift.Heavy.broadcast_serialized_rows_args.__repr__ (   self)

Definition at line 20175 of file Heavy.py.

20175 
20176  def __repr__(self):
20177  L = ['%s=%r' % (key, value)
20178  for key, value in self.__dict__.items()]
20179  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
join
std::string join(T const &container, std::string const &delim)
Definition: StringTransform.h:63
heavydb.thrift.Heavy.broadcast_serialized_rows_args.__repr__
def __repr__
Definition: Heavy.py:20175

+ Here is the call graph for this function:

def heavydb.thrift.Heavy.broadcast_serialized_rows_args.read (   self,
  iprot 
)

Definition at line 20095 of file Heavy.py.

References heavydb.thrift.Heavy.broadcast_serialized_rows_args.is_final_subquery_result, heavydb.thrift.Heavy.broadcast_serialized_rows_args.query_id, 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.Heavy.broadcast_serialized_rows_args.serialized_rows, heavydb.thrift.Heavy.execute_query_step_args.subquery_id, and heavydb.thrift.Heavy.broadcast_serialized_rows_args.subquery_id.

20095 
20096  def read(self, iprot):
20097  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
20098  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
20099  return
20100  iprot.readStructBegin()
20101  while True:
20102  (fname, ftype, fid) = iprot.readFieldBegin()
20103  if ftype == TType.STOP:
20104  break
20105  if fid == 1:
20106  if ftype == TType.STRUCT:
20107  self.serialized_rows = heavydb.serialized_result_set.ttypes.TSerializedRows()
20108  self.serialized_rows.read(iprot)
20109  else:
20110  iprot.skip(ftype)
20111  elif fid == 2:
20112  if ftype == TType.LIST:
20113  self.row_desc = []
20114  (_etype568, _size565) = iprot.readListBegin()
20115  for _i569 in range(_size565):
20116  _elem570 = TColumnType()
20117  _elem570.read(iprot)
20118  self.row_desc.append(_elem570)
20119  iprot.readListEnd()
20120  else:
20121  iprot.skip(ftype)
20122  elif fid == 3:
20123  if ftype == TType.I64:
20124  self.query_id = iprot.readI64()
20125  else:
20126  iprot.skip(ftype)
20127  elif fid == 4:
20128  if ftype == TType.I64:
20129  self.subquery_id = iprot.readI64()
20130  else:
20131  iprot.skip(ftype)
20132  elif fid == 5:
20133  if ftype == TType.BOOL:
20134  self.is_final_subquery_result = iprot.readBool()
20135  else:
20136  iprot.skip(ftype)
20137  else:
20138  iprot.skip(ftype)
20139  iprot.readFieldEnd()
20140  iprot.readStructEnd()
heavydb.thrift.Heavy.broadcast_serialized_rows_args.serialized_rows
serialized_rows
Definition: Heavy.py:20089
heavydb.thrift.Heavy.broadcast_serialized_rows_args.is_final_subquery_result
is_final_subquery_result
Definition: Heavy.py:20093
heavydb.serialized_result_set.ttypes.TSerializedRows
Definition: ttypes.py:856
heavydb.thrift.Heavy.broadcast_serialized_rows_args.row_desc
row_desc
Definition: Heavy.py:20090
heavydb.thrift.Heavy.broadcast_serialized_rows_args.read
def read
Definition: Heavy.py:20095
heavydb.thrift.Heavy.broadcast_serialized_rows_args.query_id
query_id
Definition: Heavy.py:20091
heavydb.thrift.Heavy.broadcast_serialized_rows_args.subquery_id
subquery_id
Definition: Heavy.py:20092
def heavydb.thrift.Heavy.broadcast_serialized_rows_args.validate (   self)

Definition at line 20172 of file Heavy.py.

20172 
20173  def validate(self):
20174  return
heavydb.thrift.Heavy.broadcast_serialized_rows_args.validate
def validate
Definition: Heavy.py:20172
def heavydb.thrift.Heavy.broadcast_serialized_rows_args.write (   self,
  oprot 
)

Definition at line 20141 of file Heavy.py.

References heavydb.thrift.Heavy.broadcast_serialized_rows_args.is_final_subquery_result, heavydb.thrift.Heavy.broadcast_serialized_rows_args.query_id, 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.Heavy.broadcast_serialized_rows_args.serialized_rows, heavydb.thrift.Heavy.execute_query_step_args.subquery_id, and heavydb.thrift.Heavy.broadcast_serialized_rows_args.subquery_id.

20141 
20142  def write(self, oprot):
20143  if oprot._fast_encode is not None and self.thrift_spec is not None:
20144  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
20145  return
20146  oprot.writeStructBegin('broadcast_serialized_rows_args')
20147  if self.serialized_rows is not None:
20148  oprot.writeFieldBegin('serialized_rows', TType.STRUCT, 1)
20149  self.serialized_rows.write(oprot)
20150  oprot.writeFieldEnd()
20151  if self.row_desc is not None:
20152  oprot.writeFieldBegin('row_desc', TType.LIST, 2)
20153  oprot.writeListBegin(TType.STRUCT, len(self.row_desc))
20154  for iter571 in self.row_desc:
20155  iter571.write(oprot)
20156  oprot.writeListEnd()
20157  oprot.writeFieldEnd()
20158  if self.query_id is not None:
20159  oprot.writeFieldBegin('query_id', TType.I64, 3)
20160  oprot.writeI64(self.query_id)
20161  oprot.writeFieldEnd()
20162  if self.subquery_id is not None:
20163  oprot.writeFieldBegin('subquery_id', TType.I64, 4)
20164  oprot.writeI64(self.subquery_id)
20165  oprot.writeFieldEnd()
20166  if self.is_final_subquery_result is not None:
20167  oprot.writeFieldBegin('is_final_subquery_result', TType.BOOL, 5)
20168  oprot.writeBool(self.is_final_subquery_result)
20169  oprot.writeFieldEnd()
20170  oprot.writeFieldStop()
20171  oprot.writeStructEnd()
heavydb.thrift.Heavy.broadcast_serialized_rows_args.serialized_rows
serialized_rows
Definition: Heavy.py:20089
heavydb.thrift.Heavy.broadcast_serialized_rows_args.is_final_subquery_result
is_final_subquery_result
Definition: Heavy.py:20093
heavydb.thrift.Heavy.broadcast_serialized_rows_args.row_desc
row_desc
Definition: Heavy.py:20090
heavydb.thrift.Heavy.broadcast_serialized_rows_args.query_id
query_id
Definition: Heavy.py:20091
heavydb.thrift.Heavy.broadcast_serialized_rows_args.write
def write
Definition: Heavy.py:20141
heavydb.thrift.Heavy.broadcast_serialized_rows_args.subquery_id
subquery_id
Definition: Heavy.py:20092

Member Data Documentation

heavydb.thrift.Heavy.broadcast_serialized_rows_args.__dict__
private

Definition at line 20181 of file Heavy.py.

Referenced by TableFunctionsFactory_node.Node.copy().

heavydb.thrift.Heavy.broadcast_serialized_rows_args.is_final_subquery_result

Definition at line 20093 of file Heavy.py.

Referenced by heavydb.thrift.Heavy.broadcast_serialized_rows_args.read(), and heavydb.thrift.Heavy.broadcast_serialized_rows_args.write().

heavydb.thrift.Heavy.broadcast_serialized_rows_args.query_id

Definition at line 20091 of file Heavy.py.

Referenced by heavydb.thrift.Heavy.broadcast_serialized_rows_args.read(), and heavydb.thrift.Heavy.broadcast_serialized_rows_args.write().

heavydb.thrift.Heavy.broadcast_serialized_rows_args.row_desc

Definition at line 20090 of file Heavy.py.

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

heavydb.thrift.Heavy.broadcast_serialized_rows_args.serialized_rows

Definition at line 20089 of file Heavy.py.

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

heavydb.thrift.Heavy.broadcast_serialized_rows_args.subquery_id

Definition at line 20092 of file Heavy.py.

Referenced by heavydb.thrift.Heavy.broadcast_serialized_rows_args.read(), and heavydb.thrift.Heavy.broadcast_serialized_rows_args.write().

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