in heracles/hive/hive_metastore/ttypes.py [0:0]
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('ShowCompactResponseElement')
if self.dbname is not None:
oprot.writeFieldBegin('dbname', TType.STRING, 1)
oprot.writeString(self.dbname.encode('utf-8') if sys.version_info[0] == 2 else self.dbname)
oprot.writeFieldEnd()
if self.tablename is not None:
oprot.writeFieldBegin('tablename', TType.STRING, 2)
oprot.writeString(self.tablename.encode('utf-8') if sys.version_info[0] == 2 else self.tablename)
oprot.writeFieldEnd()
if self.partitionname is not None:
oprot.writeFieldBegin('partitionname', TType.STRING, 3)
oprot.writeString(self.partitionname.encode('utf-8') if sys.version_info[0] == 2 else self.partitionname)
oprot.writeFieldEnd()
if self.type is not None:
oprot.writeFieldBegin('type', TType.I32, 4)
oprot.writeI32(self.type)
oprot.writeFieldEnd()
if self.state is not None:
oprot.writeFieldBegin('state', TType.STRING, 5)
oprot.writeString(self.state.encode('utf-8') if sys.version_info[0] == 2 else self.state)
oprot.writeFieldEnd()
if self.workerid is not None:
oprot.writeFieldBegin('workerid', TType.STRING, 6)
oprot.writeString(self.workerid.encode('utf-8') if sys.version_info[0] == 2 else self.workerid)
oprot.writeFieldEnd()
if self.start is not None:
oprot.writeFieldBegin('start', TType.I64, 7)
oprot.writeI64(self.start)
oprot.writeFieldEnd()
if self.runAs is not None:
oprot.writeFieldBegin('runAs', TType.STRING, 8)
oprot.writeString(self.runAs.encode('utf-8') if sys.version_info[0] == 2 else self.runAs)
oprot.writeFieldEnd()
if self.hightestTxnId is not None:
oprot.writeFieldBegin('hightestTxnId', TType.I64, 9)
oprot.writeI64(self.hightestTxnId)
oprot.writeFieldEnd()
if self.metaInfo is not None:
oprot.writeFieldBegin('metaInfo', TType.STRING, 10)
oprot.writeString(self.metaInfo.encode('utf-8') if sys.version_info[0] == 2 else self.metaInfo)
oprot.writeFieldEnd()
if self.endTime is not None:
oprot.writeFieldBegin('endTime', TType.I64, 11)
oprot.writeI64(self.endTime)
oprot.writeFieldEnd()
if self.hadoopJobId is not None:
oprot.writeFieldBegin('hadoopJobId', TType.STRING, 12)
oprot.writeString(self.hadoopJobId.encode('utf-8') if sys.version_info[0] == 2 else self.hadoopJobId)
oprot.writeFieldEnd()
if self.id is not None:
oprot.writeFieldBegin('id', TType.I64, 13)
oprot.writeI64(self.id)
oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()