public void read()

in core/src/main/thrift-gen-java/org/apache/accumulo/core/tabletscan/thrift/ActiveScan.java [1933:2044]
112 lines of code
20 McCabe index (conditional complexity)

    public void read(org.apache.thrift.protocol.TProtocol prot, ActiveScan struct) throws org.apache.thrift.TException {
      org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
      java.util.BitSet incoming = iprot.readBitSet(14);
      if (incoming.get(0)) {
        struct.client = iprot.readString();
        struct.setClientIsSet(true);
      }
      if (incoming.get(1)) {
        struct.user = iprot.readString();
        struct.setUserIsSet(true);
      }
      if (incoming.get(2)) {
        struct.tableId = iprot.readString();
        struct.setTableIdIsSet(true);
      }
      if (incoming.get(3)) {
        struct.age = iprot.readI64();
        struct.setAgeIsSet(true);
      }
      if (incoming.get(4)) {
        struct.idleTime = iprot.readI64();
        struct.setIdleTimeIsSet(true);
      }
      if (incoming.get(5)) {
        struct.type = org.apache.accumulo.core.tabletscan.thrift.ScanType.findByValue(iprot.readI32());
        struct.setTypeIsSet(true);
      }
      if (incoming.get(6)) {
        struct.state = org.apache.accumulo.core.tabletscan.thrift.ScanState.findByValue(iprot.readI32());
        struct.setStateIsSet(true);
      }
      if (incoming.get(7)) {
        struct.extent = new org.apache.accumulo.core.dataImpl.thrift.TKeyExtent();
        struct.extent.read(iprot);
        struct.setExtentIsSet(true);
      }
      if (incoming.get(8)) {
        {
          org.apache.thrift.protocol.TList _list37 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRUCT);
          struct.columns = new java.util.ArrayList<org.apache.accumulo.core.dataImpl.thrift.TColumn>(_list37.size);
          @org.apache.thrift.annotation.Nullable org.apache.accumulo.core.dataImpl.thrift.TColumn _elem38;
          for (int _i39 = 0; _i39 < _list37.size; ++_i39)
          {
            _elem38 = new org.apache.accumulo.core.dataImpl.thrift.TColumn();
            _elem38.read(iprot);
            struct.columns.add(_elem38);
          }
        }
        struct.setColumnsIsSet(true);
      }
      if (incoming.get(9)) {
        {
          org.apache.thrift.protocol.TList _list40 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRUCT);
          struct.ssiList = new java.util.ArrayList<org.apache.accumulo.core.dataImpl.thrift.IterInfo>(_list40.size);
          @org.apache.thrift.annotation.Nullable org.apache.accumulo.core.dataImpl.thrift.IterInfo _elem41;
          for (int _i42 = 0; _i42 < _list40.size; ++_i42)
          {
            _elem41 = new org.apache.accumulo.core.dataImpl.thrift.IterInfo();
            _elem41.read(iprot);
            struct.ssiList.add(_elem41);
          }
        }
        struct.setSsiListIsSet(true);
      }
      if (incoming.get(10)) {
        {
          org.apache.thrift.protocol.TMap _map43 = iprot.readMapBegin(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP); 
          struct.ssio = new java.util.HashMap<java.lang.String,java.util.Map<java.lang.String,java.lang.String>>(2*_map43.size);
          @org.apache.thrift.annotation.Nullable java.lang.String _key44;
          @org.apache.thrift.annotation.Nullable java.util.Map<java.lang.String,java.lang.String> _val45;
          for (int _i46 = 0; _i46 < _map43.size; ++_i46)
          {
            _key44 = iprot.readString();
            {
              org.apache.thrift.protocol.TMap _map47 = iprot.readMapBegin(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING); 
              _val45 = new java.util.HashMap<java.lang.String,java.lang.String>(2*_map47.size);
              @org.apache.thrift.annotation.Nullable java.lang.String _key48;
              @org.apache.thrift.annotation.Nullable java.lang.String _val49;
              for (int _i50 = 0; _i50 < _map47.size; ++_i50)
              {
                _key48 = iprot.readString();
                _val49 = iprot.readString();
                _val45.put(_key48, _val49);
              }
            }
            struct.ssio.put(_key44, _val45);
          }
        }
        struct.setSsioIsSet(true);
      }
      if (incoming.get(11)) {
        {
          org.apache.thrift.protocol.TList _list51 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRING);
          struct.authorizations = new java.util.ArrayList<java.nio.ByteBuffer>(_list51.size);
          @org.apache.thrift.annotation.Nullable java.nio.ByteBuffer _elem52;
          for (int _i53 = 0; _i53 < _list51.size; ++_i53)
          {
            _elem52 = iprot.readBinary();
            struct.authorizations.add(_elem52);
          }
        }
        struct.setAuthorizationsIsSet(true);
      }
      if (incoming.get(12)) {
        struct.scanId = iprot.readI64();
        struct.setScanIdIsSet(true);
      }
      if (incoming.get(13)) {
        struct.classLoaderContext = iprot.readString();
        struct.setClassLoaderContextIsSet(true);
      }
    }