in core/src/main/thrift-gen-java/org/apache/accumulo/core/tabletserver/thrift/ActiveCompaction.java [1302:1463]
public void read(org.apache.thrift.protocol.TProtocol iprot, ActiveCompaction struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TField schemeField;
iprot.readStructBegin();
while (true)
{
schemeField = iprot.readFieldBegin();
if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
break;
}
switch (schemeField.id) {
case 1: // EXTENT
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.extent = new org.apache.accumulo.core.dataImpl.thrift.TKeyExtent();
struct.extent.read(iprot);
struct.setExtentIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 2: // AGE
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.age = iprot.readI64();
struct.setAgeIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 3: // INPUT_FILES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list0 = iprot.readListBegin();
struct.inputFiles = new java.util.ArrayList<java.lang.String>(_list0.size);
@org.apache.thrift.annotation.Nullable java.lang.String _elem1;
for (int _i2 = 0; _i2 < _list0.size; ++_i2)
{
_elem1 = iprot.readString();
struct.inputFiles.add(_elem1);
}
iprot.readListEnd();
}
struct.setInputFilesIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 4: // OUTPUT_FILE
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.outputFile = iprot.readString();
struct.setOutputFileIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 5: // TYPE
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.type = org.apache.accumulo.core.tabletserver.thrift.TCompactionType.findByValue(iprot.readI32());
struct.setTypeIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 6: // REASON
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.reason = org.apache.accumulo.core.tabletserver.thrift.TCompactionReason.findByValue(iprot.readI32());
struct.setReasonIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 7: // LOCALITY_GROUP
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.localityGroup = iprot.readString();
struct.setLocalityGroupIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 8: // ENTRIES_READ
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.entriesRead = iprot.readI64();
struct.setEntriesReadIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 9: // ENTRIES_WRITTEN
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.entriesWritten = iprot.readI64();
struct.setEntriesWrittenIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 10: // SSI_LIST
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list3 = iprot.readListBegin();
struct.ssiList = new java.util.ArrayList<org.apache.accumulo.core.dataImpl.thrift.IterInfo>(_list3.size);
@org.apache.thrift.annotation.Nullable org.apache.accumulo.core.dataImpl.thrift.IterInfo _elem4;
for (int _i5 = 0; _i5 < _list3.size; ++_i5)
{
_elem4 = new org.apache.accumulo.core.dataImpl.thrift.IterInfo();
_elem4.read(iprot);
struct.ssiList.add(_elem4);
}
iprot.readListEnd();
}
struct.setSsiListIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 11: // SSIO
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
org.apache.thrift.protocol.TMap _map6 = iprot.readMapBegin();
struct.ssio = new java.util.HashMap<java.lang.String,java.util.Map<java.lang.String,java.lang.String>>(2*_map6.size);
@org.apache.thrift.annotation.Nullable java.lang.String _key7;
@org.apache.thrift.annotation.Nullable java.util.Map<java.lang.String,java.lang.String> _val8;
for (int _i9 = 0; _i9 < _map6.size; ++_i9)
{
_key7 = iprot.readString();
{
org.apache.thrift.protocol.TMap _map10 = iprot.readMapBegin();
_val8 = new java.util.HashMap<java.lang.String,java.lang.String>(2*_map10.size);
@org.apache.thrift.annotation.Nullable java.lang.String _key11;
@org.apache.thrift.annotation.Nullable java.lang.String _val12;
for (int _i13 = 0; _i13 < _map10.size; ++_i13)
{
_key11 = iprot.readString();
_val12 = iprot.readString();
_val8.put(_key11, _val12);
}
iprot.readMapEnd();
}
struct.ssio.put(_key7, _val8);
}
iprot.readMapEnd();
}
struct.setSsioIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 12: // TIMES_PAUSED
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.timesPaused = iprot.readI64();
struct.setTimesPausedIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
default:
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
iprot.readFieldEnd();
}
iprot.readStructEnd();
// check for required fields of primitive type, which can't be checked in the validate method
struct.validate();
}