in core/src/main/thrift-gen-java/org/apache/accumulo/core/tabletscan/thrift/ActiveScan.java [1496:1684]
public void read(org.apache.thrift.protocol.TProtocol iprot, ActiveScan 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 2: // CLIENT
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.client = iprot.readString();
struct.setClientIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 3: // USER
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.user = iprot.readString();
struct.setUserIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 4: // TABLE_ID
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.tableId = iprot.readString();
struct.setTableIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 5: // 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 6: // IDLE_TIME
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.idleTime = iprot.readI64();
struct.setIdleTimeIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 7: // TYPE
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.type = org.apache.accumulo.core.tabletscan.thrift.ScanType.findByValue(iprot.readI32());
struct.setTypeIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 8: // STATE
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.state = org.apache.accumulo.core.tabletscan.thrift.ScanState.findByValue(iprot.readI32());
struct.setStateIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 9: // 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 10: // COLUMNS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list10 = iprot.readListBegin();
struct.columns = new java.util.ArrayList<org.apache.accumulo.core.dataImpl.thrift.TColumn>(_list10.size);
@org.apache.thrift.annotation.Nullable org.apache.accumulo.core.dataImpl.thrift.TColumn _elem11;
for (int _i12 = 0; _i12 < _list10.size; ++_i12)
{
_elem11 = new org.apache.accumulo.core.dataImpl.thrift.TColumn();
_elem11.read(iprot);
struct.columns.add(_elem11);
}
iprot.readListEnd();
}
struct.setColumnsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 11: // SSI_LIST
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list13 = iprot.readListBegin();
struct.ssiList = new java.util.ArrayList<org.apache.accumulo.core.dataImpl.thrift.IterInfo>(_list13.size);
@org.apache.thrift.annotation.Nullable org.apache.accumulo.core.dataImpl.thrift.IterInfo _elem14;
for (int _i15 = 0; _i15 < _list13.size; ++_i15)
{
_elem14 = new org.apache.accumulo.core.dataImpl.thrift.IterInfo();
_elem14.read(iprot);
struct.ssiList.add(_elem14);
}
iprot.readListEnd();
}
struct.setSsiListIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 12: // SSIO
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
org.apache.thrift.protocol.TMap _map16 = iprot.readMapBegin();
struct.ssio = new java.util.HashMap<java.lang.String,java.util.Map<java.lang.String,java.lang.String>>(2*_map16.size);
@org.apache.thrift.annotation.Nullable java.lang.String _key17;
@org.apache.thrift.annotation.Nullable java.util.Map<java.lang.String,java.lang.String> _val18;
for (int _i19 = 0; _i19 < _map16.size; ++_i19)
{
_key17 = iprot.readString();
{
org.apache.thrift.protocol.TMap _map20 = iprot.readMapBegin();
_val18 = new java.util.HashMap<java.lang.String,java.lang.String>(2*_map20.size);
@org.apache.thrift.annotation.Nullable java.lang.String _key21;
@org.apache.thrift.annotation.Nullable java.lang.String _val22;
for (int _i23 = 0; _i23 < _map20.size; ++_i23)
{
_key21 = iprot.readString();
_val22 = iprot.readString();
_val18.put(_key21, _val22);
}
iprot.readMapEnd();
}
struct.ssio.put(_key17, _val18);
}
iprot.readMapEnd();
}
struct.setSsioIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 13: // AUTHORIZATIONS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list24 = iprot.readListBegin();
struct.authorizations = new java.util.ArrayList<java.nio.ByteBuffer>(_list24.size);
@org.apache.thrift.annotation.Nullable java.nio.ByteBuffer _elem25;
for (int _i26 = 0; _i26 < _list24.size; ++_i26)
{
_elem25 = iprot.readBinary();
struct.authorizations.add(_elem25);
}
iprot.readListEnd();
}
struct.setAuthorizationsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 14: // SCAN_ID
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.scanId = iprot.readI64();
struct.setScanIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 15: // CLASS_LOADER_CONTEXT
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.classLoaderContext = iprot.readString();
struct.setClassLoaderContextIsSet(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();
}