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.thrift.OmniSci.broadcast_serialized_rows_args Class Reference
+ Inheritance diagram for omnisci.thrift.OmniSci.broadcast_serialized_rows_args:
+ Collaboration diagram for omnisci.thrift.OmniSci.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 17047 of file OmniSci.py.

Constructor & Destructor Documentation

def omnisci.thrift.OmniSci.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 17059 of file OmniSci.py.

17059 
17060  def __init__(self, serialized_rows=None, row_desc=None, query_id=None, subquery_id=None, is_final_subquery_result=None,):
17061  self.serialized_rows = serialized_rows
17062  self.row_desc = row_desc
17063  self.query_id = query_id
17064  self.subquery_id = subquery_id
17065  self.is_final_subquery_result = is_final_subquery_result
omnisci.thrift.OmniSci.broadcast_serialized_rows_args.is_final_subquery_result
is_final_subquery_result
Definition: OmniSci.py:17064
omnisci.thrift.OmniSci.broadcast_serialized_rows_args.subquery_id
subquery_id
Definition: OmniSci.py:17063
omnisci.thrift.OmniSci.broadcast_serialized_rows_args.serialized_rows
serialized_rows
Definition: OmniSci.py:17060
omnisci.thrift.OmniSci.broadcast_serialized_rows_args.row_desc
row_desc
Definition: OmniSci.py:17061
omnisci.thrift.OmniSci.broadcast_serialized_rows_args.__init__
def __init__
Definition: OmniSci.py:17059
omnisci.thrift.OmniSci.broadcast_serialized_rows_args.query_id
query_id
Definition: OmniSci.py:17062

Member Function Documentation

def omnisci.thrift.OmniSci.broadcast_serialized_rows_args.__eq__ (   self,
  other 
)

Definition at line 17151 of file OmniSci.py.

17151 
17152  def __eq__(self, other):
17153  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
omnisci.thrift.OmniSci.broadcast_serialized_rows_args.__dict__
__dict__
Definition: OmniSci.py:17152
omnisci.thrift.OmniSci.broadcast_serialized_rows_args.__eq__
def __eq__
Definition: OmniSci.py:17151
def omnisci.thrift.OmniSci.broadcast_serialized_rows_args.__ne__ (   self,
  other 
)

Definition at line 17154 of file OmniSci.py.

17154 
17155  def __ne__(self, other):
17156  return not (self == other)
17157 all_structs.append(broadcast_serialized_rows_args)
broadcast_serialized_rows_args.thrift_spec = (
omnisci.thrift.OmniSci.broadcast_serialized_rows_args.__ne__
def __ne__
Definition: OmniSci.py:17154
def omnisci.thrift.OmniSci.broadcast_serialized_rows_args.__repr__ (   self)

Definition at line 17146 of file OmniSci.py.

17146 
17147  def __repr__(self):
17148  L = ['%s=%r' % (key, value)
17149  for key, value in self.__dict__.items()]
17150  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
join
std::string join(T const &container, std::string const &delim)
Definition: StringTransform.h:60
omnisci.thrift.OmniSci.broadcast_serialized_rows_args.__repr__
def __repr__
Definition: OmniSci.py:17146

+ Here is the call graph for this function:

def omnisci.thrift.OmniSci.broadcast_serialized_rows_args.read (   self,
  iprot 
)

Definition at line 17066 of file OmniSci.py.

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

17066 
17067  def read(self, iprot):
17068  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
17069  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
17070  return
17071  iprot.readStructBegin()
17072  while True:
17073  (fname, ftype, fid) = iprot.readFieldBegin()
17074  if ftype == TType.STOP:
17075  break
17076  if fid == 1:
17077  if ftype == TType.STRUCT:
17078  self.serialized_rows = omnisci.serialized_result_set.ttypes.TSerializedRows()
17079  self.serialized_rows.read(iprot)
17080  else:
17081  iprot.skip(ftype)
17082  elif fid == 2:
17083  if ftype == TType.LIST:
17084  self.row_desc = []
17085  (_etype512, _size509) = iprot.readListBegin()
17086  for _i513 in range(_size509):
17087  _elem514 = TColumnType()
17088  _elem514.read(iprot)
17089  self.row_desc.append(_elem514)
17090  iprot.readListEnd()
17091  else:
17092  iprot.skip(ftype)
17093  elif fid == 3:
17094  if ftype == TType.I64:
17095  self.query_id = iprot.readI64()
17096  else:
17097  iprot.skip(ftype)
17098  elif fid == 4:
17099  if ftype == TType.I64:
17100  self.subquery_id = iprot.readI64()
17101  else:
17102  iprot.skip(ftype)
17103  elif fid == 5:
17104  if ftype == TType.BOOL:
17105  self.is_final_subquery_result = iprot.readBool()
17106  else:
17107  iprot.skip(ftype)
17108  else:
17109  iprot.skip(ftype)
17110  iprot.readFieldEnd()
17111  iprot.readStructEnd()
omnisci.thrift.OmniSci.broadcast_serialized_rows_args.is_final_subquery_result
is_final_subquery_result
Definition: OmniSci.py:17064
omnisci.thrift.OmniSci.broadcast_serialized_rows_args.subquery_id
subquery_id
Definition: OmniSci.py:17063
omnisci.serialized_result_set.ttypes.TSerializedRows
Definition: ttypes.py:850
omnisci.thrift.OmniSci.broadcast_serialized_rows_args.serialized_rows
serialized_rows
Definition: OmniSci.py:17060
omnisci.thrift.OmniSci.broadcast_serialized_rows_args.read
def read
Definition: OmniSci.py:17066
omnisci.thrift.OmniSci.broadcast_serialized_rows_args.row_desc
row_desc
Definition: OmniSci.py:17061
omnisci.thrift.OmniSci.broadcast_serialized_rows_args.query_id
query_id
Definition: OmniSci.py:17062
def omnisci.thrift.OmniSci.broadcast_serialized_rows_args.validate (   self)

Definition at line 17143 of file OmniSci.py.

17143 
17144  def validate(self):
17145  return
omnisci.thrift.OmniSci.broadcast_serialized_rows_args.validate
def validate
Definition: OmniSci.py:17143
def omnisci.thrift.OmniSci.broadcast_serialized_rows_args.write (   self,
  oprot 
)

Definition at line 17112 of file OmniSci.py.

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

17112 
17113  def write(self, oprot):
17114  if oprot._fast_encode is not None and self.thrift_spec is not None:
17115  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
17116  return
17117  oprot.writeStructBegin('broadcast_serialized_rows_args')
17118  if self.serialized_rows is not None:
17119  oprot.writeFieldBegin('serialized_rows', TType.STRUCT, 1)
17120  self.serialized_rows.write(oprot)
17121  oprot.writeFieldEnd()
17122  if self.row_desc is not None:
17123  oprot.writeFieldBegin('row_desc', TType.LIST, 2)
17124  oprot.writeListBegin(TType.STRUCT, len(self.row_desc))
17125  for iter515 in self.row_desc:
17126  iter515.write(oprot)
17127  oprot.writeListEnd()
17128  oprot.writeFieldEnd()
17129  if self.query_id is not None:
17130  oprot.writeFieldBegin('query_id', TType.I64, 3)
17131  oprot.writeI64(self.query_id)
17132  oprot.writeFieldEnd()
17133  if self.subquery_id is not None:
17134  oprot.writeFieldBegin('subquery_id', TType.I64, 4)
17135  oprot.writeI64(self.subquery_id)
17136  oprot.writeFieldEnd()
17137  if self.is_final_subquery_result is not None:
17138  oprot.writeFieldBegin('is_final_subquery_result', TType.BOOL, 5)
17139  oprot.writeBool(self.is_final_subquery_result)
17140  oprot.writeFieldEnd()
17141  oprot.writeFieldStop()
17142  oprot.writeStructEnd()
omnisci.thrift.OmniSci.broadcast_serialized_rows_args.is_final_subquery_result
is_final_subquery_result
Definition: OmniSci.py:17064
omnisci.thrift.OmniSci.broadcast_serialized_rows_args.subquery_id
subquery_id
Definition: OmniSci.py:17063
omnisci.thrift.OmniSci.broadcast_serialized_rows_args.serialized_rows
serialized_rows
Definition: OmniSci.py:17060
omnisci.thrift.OmniSci.broadcast_serialized_rows_args.write
def write
Definition: OmniSci.py:17112
omnisci.thrift.OmniSci.broadcast_serialized_rows_args.row_desc
row_desc
Definition: OmniSci.py:17061
omnisci.thrift.OmniSci.broadcast_serialized_rows_args.query_id
query_id
Definition: OmniSci.py:17062

Member Data Documentation

omnisci.thrift.OmniSci.broadcast_serialized_rows_args.__dict__
private

Definition at line 17152 of file OmniSci.py.

omnisci.thrift.OmniSci.broadcast_serialized_rows_args.is_final_subquery_result

Definition at line 17064 of file OmniSci.py.

Referenced by omnisci.thrift.OmniSci.broadcast_serialized_rows_args.read(), and omnisci.thrift.OmniSci.broadcast_serialized_rows_args.write().

omnisci.thrift.OmniSci.broadcast_serialized_rows_args.query_id

Definition at line 17062 of file OmniSci.py.

Referenced by omnisci.thrift.OmniSci.broadcast_serialized_rows_args.read(), and omnisci.thrift.OmniSci.broadcast_serialized_rows_args.write().

omnisci.thrift.OmniSci.broadcast_serialized_rows_args.row_desc

Definition at line 17061 of file OmniSci.py.

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

omnisci.thrift.OmniSci.broadcast_serialized_rows_args.serialized_rows

Definition at line 17060 of file OmniSci.py.

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

omnisci.thrift.OmniSci.broadcast_serialized_rows_args.subquery_id

Definition at line 17063 of file OmniSci.py.

Referenced by omnisci.thrift.OmniSci.broadcast_serialized_rows_args.read(), and omnisci.thrift.OmniSci.broadcast_serialized_rows_args.write().

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