OmniSciDB: heavydb.thrift.Heavy.execute_query_step

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

Definition at line 19991 of file Heavy.py.

 
     def __ne__(self, other):
         return not (self == other)
 all_structs.append(execute_query_step_args)

execute_query_step_args.thrift_spec = (

heavydb.thrift.Heavy.execute_query_step_args.__ne__

def __ne__

Definition: Heavy.py:19991

def heavydb.thrift.Heavy.execute_query_step_args.__repr__ ( self )

Definition at line 19983 of file Heavy.py.

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

def __repr__

Definition: Heavy.py:19983

Here is the call graph for this function:

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

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

 
     def read(self, iprot):
         if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
             iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
             return
         iprot.readStructBegin()
         while True:
             (fname, ftype, fid) = iprot.readFieldBegin()
             if ftype == TType.STOP:
                 break
             if fid == 1:
                 if ftype == TType.STRUCT:
                     self.pending_query = TPendingQuery()
                     self.pending_query.read(iprot)
                 else:
                     iprot.skip(ftype)
             elif fid == 2:
                 if ftype == TType.I64:
                     self.subquery_id = iprot.readI64()
                 else:
                     iprot.skip(ftype)
             elif fid == 3:
                 if ftype == TType.STRING:
                     self.start_time_str = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
                 else:
                     iprot.skip(ftype)
             else:
                 iprot.skip(ftype)
             iprot.readFieldEnd()
         iprot.readStructEnd()

heavydb.thrift.Heavy.execute_query_step_args.start_time_str

start_time_str

Definition: Heavy.py:19928

heavydb.thrift.Heavy.execute_query_step_args.read

def read

Definition: Heavy.py:19930

heavydb.thrift.Heavy.execute_query_step_args.subquery_id

subquery_id

Definition: Heavy.py:19927

heavydb.thrift.Heavy.execute_query_step_args.pending_query

pending_query

Definition: Heavy.py:19926

def heavydb.thrift.Heavy.execute_query_step_args.validate ( self )

Definition at line 19980 of file Heavy.py.

 
     def validate(self):
         return

heavydb.thrift.Heavy.execute_query_step_args.validate

def validate

Definition: Heavy.py:19980

def heavydb.thrift.Heavy.execute_query_step_args.write	(	self,
		oprot
	)

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

 
     def write(self, oprot):
         if oprot._fast_encode is not None and self.thrift_spec is not None:
             oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
             return
         oprot.writeStructBegin('execute_query_step_args')
         if self.pending_query is not None:
             oprot.writeFieldBegin('pending_query', TType.STRUCT, 1)
             self.pending_query.write(oprot)
             oprot.writeFieldEnd()
         if self.subquery_id is not None:
             oprot.writeFieldBegin('subquery_id', TType.I64, 2)
             oprot.writeI64(self.subquery_id)
             oprot.writeFieldEnd()
         if self.start_time_str is not None:
             oprot.writeFieldBegin('start_time_str', TType.STRING, 3)
             oprot.writeString(self.start_time_str.encode('utf-8') if sys.version_info[0] == 2 else self.start_time_str)
             oprot.writeFieldEnd()
         oprot.writeFieldStop()
         oprot.writeStructEnd()