in core/src/main/thrift-gen-java/org/apache/accumulo/core/manager/thrift/ManagerMonitorInfo.java [1128:1287]
public void read(org.apache.thrift.protocol.TProtocol iprot, ManagerMonitorInfo 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: // TABLE_MAP
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
org.apache.thrift.protocol.TMap _map26 = iprot.readMapBegin();
struct.tableMap = new java.util.HashMap<java.lang.String,TableInfo>(2*_map26.size);
@org.apache.thrift.annotation.Nullable java.lang.String _key27;
@org.apache.thrift.annotation.Nullable TableInfo _val28;
for (int _i29 = 0; _i29 < _map26.size; ++_i29)
{
_key27 = iprot.readString();
_val28 = new TableInfo();
_val28.read(iprot);
struct.tableMap.put(_key27, _val28);
}
iprot.readMapEnd();
}
struct.setTableMapIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 2: // T_SERVER_INFO
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list30 = iprot.readListBegin();
struct.tServerInfo = new java.util.ArrayList<TabletServerStatus>(_list30.size);
@org.apache.thrift.annotation.Nullable TabletServerStatus _elem31;
for (int _i32 = 0; _i32 < _list30.size; ++_i32)
{
_elem31 = new TabletServerStatus();
_elem31.read(iprot);
struct.tServerInfo.add(_elem31);
}
iprot.readListEnd();
}
struct.setTServerInfoIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 3: // BAD_TSERVERS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
org.apache.thrift.protocol.TMap _map33 = iprot.readMapBegin();
struct.badTServers = new java.util.HashMap<java.lang.String,java.lang.Byte>(2*_map33.size);
@org.apache.thrift.annotation.Nullable java.lang.String _key34;
byte _val35;
for (int _i36 = 0; _i36 < _map33.size; ++_i36)
{
_key34 = iprot.readString();
_val35 = iprot.readByte();
struct.badTServers.put(_key34, _val35);
}
iprot.readMapEnd();
}
struct.setBadTServersIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 4: // STATE
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.state = org.apache.accumulo.core.manager.thrift.ManagerState.findByValue(iprot.readI32());
struct.setStateIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 5: // GOAL_STATE
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.goalState = org.apache.accumulo.core.manager.thrift.ManagerGoalState.findByValue(iprot.readI32());
struct.setGoalStateIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 6: // UNASSIGNED_TABLETS
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.unassignedTablets = iprot.readI32();
struct.setUnassignedTabletsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 7: // SERVERS_SHUTTING_DOWN
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
org.apache.thrift.protocol.TSet _set37 = iprot.readSetBegin();
struct.serversShuttingDown = new java.util.HashSet<java.lang.String>(2*_set37.size);
@org.apache.thrift.annotation.Nullable java.lang.String _elem38;
for (int _i39 = 0; _i39 < _set37.size; ++_i39)
{
_elem38 = iprot.readString();
struct.serversShuttingDown.add(_elem38);
}
iprot.readSetEnd();
}
struct.setServersShuttingDownIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 8: // DEAD_TABLET_SERVERS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list40 = iprot.readListBegin();
struct.deadTabletServers = new java.util.ArrayList<DeadServer>(_list40.size);
@org.apache.thrift.annotation.Nullable DeadServer _elem41;
for (int _i42 = 0; _i42 < _list40.size; ++_i42)
{
_elem41 = new DeadServer();
_elem41.read(iprot);
struct.deadTabletServers.add(_elem41);
}
iprot.readListEnd();
}
struct.setDeadTabletServersIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 9: // BULK_IMPORTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list43 = iprot.readListBegin();
struct.bulkImports = new java.util.ArrayList<BulkImportStatus>(_list43.size);
@org.apache.thrift.annotation.Nullable BulkImportStatus _elem44;
for (int _i45 = 0; _i45 < _list43.size; ++_i45)
{
_elem44 = new BulkImportStatus();
_elem44.read(iprot);
struct.bulkImports.add(_elem44);
}
iprot.readListEnd();
}
struct.setBulkImportsIsSet(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();
}