OmniSciDB  cde582ebc3
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
heavydb.thrift.Heavy.execute_query_step_args Class Reference
+ Inheritance diagram for heavydb.thrift.Heavy.execute_query_step_args:
+ Collaboration diagram for heavydb.thrift.Heavy.execute_query_step_args:

Public Member Functions

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

Public Attributes

 pending_query
 
 subquery_id
 
 start_time_str
 

Private Attributes

 __dict__
 

Detailed Description

Attributes:
 - pending_query
 - subquery_id
 - start_time_str

Definition at line 19978 of file Heavy.py.

Constructor & Destructor Documentation

def heavydb.thrift.Heavy.execute_query_step_args.__init__ (   self,
  pending_query = None,
  subquery_id = None,
  start_time_str = None 
)

Definition at line 19988 of file Heavy.py.

19989  def __init__(self, pending_query=None, subquery_id=None, start_time_str=None,):
19990  self.pending_query = pending_query
19991  self.subquery_id = subquery_id
19992  self.start_time_str = start_time_str

Member Function Documentation

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

Definition at line 20051 of file Heavy.py.

20052  def __eq__(self, other):
20053  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
def heavydb.thrift.Heavy.execute_query_step_args.__ne__ (   self,
  other 
)

Definition at line 20054 of file Heavy.py.

20055  def __ne__(self, other):
20056  return not (self == other)
20057 all_structs.append(execute_query_step_args)
execute_query_step_args.thrift_spec = (
def heavydb.thrift.Heavy.execute_query_step_args.__repr__ (   self)

Definition at line 20046 of file Heavy.py.

20047  def __repr__(self):
20048  L = ['%s=%r' % (key, value)
20049  for key, value in self.__dict__.items()]
20050  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 heavydb.thrift.Heavy.execute_query_step_args.read (   self,
  iprot 
)

Definition at line 19993 of file Heavy.py.

References heavydb.thrift.Heavy.execute_query_step_args.pending_query, heavydb.thrift.Heavy.set_cur_session_args.start_time_str, heavydb.thrift.Heavy.invalidate_cur_session_args.start_time_str, heavydb.thrift.Heavy.start_query_args.start_time_str, heavydb.thrift.Heavy.execute_query_step_args.start_time_str, and heavydb.thrift.Heavy.execute_query_step_args.subquery_id.

19994  def read(self, iprot):
19995  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
19996  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
19997  return
19998  iprot.readStructBegin()
19999  while True:
20000  (fname, ftype, fid) = iprot.readFieldBegin()
20001  if ftype == TType.STOP:
20002  break
20003  if fid == 1:
20004  if ftype == TType.STRUCT:
20005  self.pending_query = TPendingQuery()
20006  self.pending_query.read(iprot)
20007  else:
20008  iprot.skip(ftype)
20009  elif fid == 2:
20010  if ftype == TType.I64:
20011  self.subquery_id = iprot.readI64()
20012  else:
20013  iprot.skip(ftype)
20014  elif fid == 3:
20015  if ftype == TType.STRING:
20016  self.start_time_str = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
20017  else:
20018  iprot.skip(ftype)
20019  else:
20020  iprot.skip(ftype)
20021  iprot.readFieldEnd()
20022  iprot.readStructEnd()
def heavydb.thrift.Heavy.execute_query_step_args.validate (   self)

Definition at line 20043 of file Heavy.py.

20044  def validate(self):
20045  return
def heavydb.thrift.Heavy.execute_query_step_args.write (   self,
  oprot 
)

Definition at line 20023 of file Heavy.py.

References heavydb.thrift.Heavy.execute_query_step_args.pending_query, heavydb.thrift.Heavy.set_cur_session_args.start_time_str, heavydb.thrift.Heavy.invalidate_cur_session_args.start_time_str, heavydb.thrift.Heavy.start_query_args.start_time_str, heavydb.thrift.Heavy.execute_query_step_args.start_time_str, and heavydb.thrift.Heavy.execute_query_step_args.subquery_id.

20024  def write(self, oprot):
20025  if oprot._fast_encode is not None and self.thrift_spec is not None:
20026  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
20027  return
20028  oprot.writeStructBegin('execute_query_step_args')
20029  if self.pending_query is not None:
20030  oprot.writeFieldBegin('pending_query', TType.STRUCT, 1)
20031  self.pending_query.write(oprot)
20032  oprot.writeFieldEnd()
20033  if self.subquery_id is not None:
20034  oprot.writeFieldBegin('subquery_id', TType.I64, 2)
20035  oprot.writeI64(self.subquery_id)
20036  oprot.writeFieldEnd()
20037  if self.start_time_str is not None:
20038  oprot.writeFieldBegin('start_time_str', TType.STRING, 3)
20039  oprot.writeString(self.start_time_str.encode('utf-8') if sys.version_info[0] == 2 else self.start_time_str)
20040  oprot.writeFieldEnd()
20041  oprot.writeFieldStop()
20042  oprot.writeStructEnd()

Member Data Documentation

heavydb.thrift.Heavy.execute_query_step_args.__dict__
private

Definition at line 20052 of file Heavy.py.

Referenced by generate_TableFunctionsFactory_init.Node.copy().

heavydb.thrift.Heavy.execute_query_step_args.pending_query

Definition at line 19989 of file Heavy.py.

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

heavydb.thrift.Heavy.execute_query_step_args.start_time_str

Definition at line 19991 of file Heavy.py.

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

heavydb.thrift.Heavy.execute_query_step_args.subquery_id

Definition at line 19990 of file Heavy.py.

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


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