in src/main/python/accumulo/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('ActiveCompaction')
if self.extent is not None:
oprot.writeFieldBegin('extent', TType.STRUCT, 1)
self.extent.write(oprot)
oprot.writeFieldEnd()
if self.age is not None:
oprot.writeFieldBegin('age', TType.I64, 2)
oprot.writeI64(self.age)
oprot.writeFieldEnd()
if self.inputFiles is not None:
oprot.writeFieldBegin('inputFiles', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.inputFiles))
for iter133 in self.inputFiles:
oprot.writeString(iter133.encode('utf-8') if sys.version_info[0] == 2 else iter133)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.outputFile is not None:
oprot.writeFieldBegin('outputFile', TType.STRING, 4)
oprot.writeString(self.outputFile.encode('utf-8') if sys.version_info[0] == 2 else self.outputFile)
oprot.writeFieldEnd()
if self.type is not None:
oprot.writeFieldBegin('type', TType.I32, 5)
oprot.writeI32(self.type)
oprot.writeFieldEnd()
if self.reason is not None:
oprot.writeFieldBegin('reason', TType.I32, 6)
oprot.writeI32(self.reason)
oprot.writeFieldEnd()
if self.localityGroup is not None:
oprot.writeFieldBegin('localityGroup', TType.STRING, 7)
oprot.writeString(self.localityGroup.encode('utf-8') if sys.version_info[0] == 2 else self.localityGroup)
oprot.writeFieldEnd()
if self.entriesRead is not None:
oprot.writeFieldBegin('entriesRead', TType.I64, 8)
oprot.writeI64(self.entriesRead)
oprot.writeFieldEnd()
if self.entriesWritten is not None:
oprot.writeFieldBegin('entriesWritten', TType.I64, 9)
oprot.writeI64(self.entriesWritten)
oprot.writeFieldEnd()
if self.iterators is not None:
oprot.writeFieldBegin('iterators', TType.LIST, 10)
oprot.writeListBegin(TType.STRUCT, len(self.iterators))
for iter134 in self.iterators:
iter134.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()