accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ctubb...@apache.org
Subject [11/61] [abbrv] [partial] accumulo git commit: ACCUMULO-722 put trunk in my sandbox
Date Thu, 03 Mar 2016 21:59:36 GMT
http://git-wip-us.apache.org/repos/asf/accumulo/blob/7bdbfccb/1.5/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/ActionStats.java
----------------------------------------------------------------------
diff --git a/1.5/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/ActionStats.java b/1.5/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/ActionStats.java
new file mode 100644
index 0000000..87b4188
--- /dev/null
+++ b/1.5/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/ActionStats.java
@@ -0,0 +1,1039 @@
+/**
+ * Autogenerated by Thrift Compiler (0.8.0)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ *  @generated
+ */
+package org.apache.accumulo.core.tabletserver.thrift;
+
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings("all") public class ActionStats implements org.apache.thrift.TBase<ActionStats, ActionStats._Fields>, java.io.Serializable, Cloneable {
+  private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ActionStats");
+
+  private static final org.apache.thrift.protocol.TField STATUS_FIELD_DESC = new org.apache.thrift.protocol.TField("status", org.apache.thrift.protocol.TType.I32, (short)1);
+  private static final org.apache.thrift.protocol.TField ELAPSED_FIELD_DESC = new org.apache.thrift.protocol.TField("elapsed", org.apache.thrift.protocol.TType.DOUBLE, (short)2);
+  private static final org.apache.thrift.protocol.TField NUM_FIELD_DESC = new org.apache.thrift.protocol.TField("num", org.apache.thrift.protocol.TType.I32, (short)3);
+  private static final org.apache.thrift.protocol.TField COUNT_FIELD_DESC = new org.apache.thrift.protocol.TField("count", org.apache.thrift.protocol.TType.I64, (short)4);
+  private static final org.apache.thrift.protocol.TField SUM_DEV_FIELD_DESC = new org.apache.thrift.protocol.TField("sumDev", org.apache.thrift.protocol.TType.DOUBLE, (short)5);
+  private static final org.apache.thrift.protocol.TField FAIL_FIELD_DESC = new org.apache.thrift.protocol.TField("fail", org.apache.thrift.protocol.TType.I32, (short)6);
+  private static final org.apache.thrift.protocol.TField QUEUE_TIME_FIELD_DESC = new org.apache.thrift.protocol.TField("queueTime", org.apache.thrift.protocol.TType.DOUBLE, (short)7);
+  private static final org.apache.thrift.protocol.TField QUEUE_SUM_DEV_FIELD_DESC = new org.apache.thrift.protocol.TField("queueSumDev", org.apache.thrift.protocol.TType.DOUBLE, (short)8);
+
+  private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+  static {
+    schemes.put(StandardScheme.class, new ActionStatsStandardSchemeFactory());
+    schemes.put(TupleScheme.class, new ActionStatsTupleSchemeFactory());
+  }
+
+  public int status; // required
+  public double elapsed; // required
+  public int num; // required
+  public long count; // required
+  public double sumDev; // required
+  public int fail; // required
+  public double queueTime; // required
+  public double queueSumDev; // required
+
+  /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
+  public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+    STATUS((short)1, "status"),
+    ELAPSED((short)2, "elapsed"),
+    NUM((short)3, "num"),
+    COUNT((short)4, "count"),
+    SUM_DEV((short)5, "sumDev"),
+    FAIL((short)6, "fail"),
+    QUEUE_TIME((short)7, "queueTime"),
+    QUEUE_SUM_DEV((short)8, "queueSumDev");
+
+    private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+
+    static {
+      for (_Fields field : EnumSet.allOf(_Fields.class)) {
+        byName.put(field.getFieldName(), field);
+      }
+    }
+
+    /**
+     * Find the _Fields constant that matches fieldId, or null if its not found.
+     */
+    public static _Fields findByThriftId(int fieldId) {
+      switch(fieldId) {
+        case 1: // STATUS
+          return STATUS;
+        case 2: // ELAPSED
+          return ELAPSED;
+        case 3: // NUM
+          return NUM;
+        case 4: // COUNT
+          return COUNT;
+        case 5: // SUM_DEV
+          return SUM_DEV;
+        case 6: // FAIL
+          return FAIL;
+        case 7: // QUEUE_TIME
+          return QUEUE_TIME;
+        case 8: // QUEUE_SUM_DEV
+          return QUEUE_SUM_DEV;
+        default:
+          return null;
+      }
+    }
+
+    /**
+     * Find the _Fields constant that matches fieldId, throwing an exception
+     * if it is not found.
+     */
+    public static _Fields findByThriftIdOrThrow(int fieldId) {
+      _Fields fields = findByThriftId(fieldId);
+      if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+      return fields;
+    }
+
+    /**
+     * Find the _Fields constant that matches name, or null if its not found.
+     */
+    public static _Fields findByName(String name) {
+      return byName.get(name);
+    }
+
+    private final short _thriftId;
+    private final String _fieldName;
+
+    _Fields(short thriftId, String fieldName) {
+      _thriftId = thriftId;
+      _fieldName = fieldName;
+    }
+
+    public short getThriftFieldId() {
+      return _thriftId;
+    }
+
+    public String getFieldName() {
+      return _fieldName;
+    }
+  }
+
+  // isset id assignments
+  private static final int __STATUS_ISSET_ID = 0;
+  private static final int __ELAPSED_ISSET_ID = 1;
+  private static final int __NUM_ISSET_ID = 2;
+  private static final int __COUNT_ISSET_ID = 3;
+  private static final int __SUMDEV_ISSET_ID = 4;
+  private static final int __FAIL_ISSET_ID = 5;
+  private static final int __QUEUETIME_ISSET_ID = 6;
+  private static final int __QUEUESUMDEV_ISSET_ID = 7;
+  private BitSet __isset_bit_vector = new BitSet(8);
+  public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
+  static {
+    Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
+    tmpMap.put(_Fields.STATUS, new org.apache.thrift.meta_data.FieldMetaData("status", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
+    tmpMap.put(_Fields.ELAPSED, new org.apache.thrift.meta_data.FieldMetaData("elapsed", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.DOUBLE)));
+    tmpMap.put(_Fields.NUM, new org.apache.thrift.meta_data.FieldMetaData("num", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
+    tmpMap.put(_Fields.COUNT, new org.apache.thrift.meta_data.FieldMetaData("count", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
+    tmpMap.put(_Fields.SUM_DEV, new org.apache.thrift.meta_data.FieldMetaData("sumDev", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.DOUBLE)));
+    tmpMap.put(_Fields.FAIL, new org.apache.thrift.meta_data.FieldMetaData("fail", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
+    tmpMap.put(_Fields.QUEUE_TIME, new org.apache.thrift.meta_data.FieldMetaData("queueTime", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.DOUBLE)));
+    tmpMap.put(_Fields.QUEUE_SUM_DEV, new org.apache.thrift.meta_data.FieldMetaData("queueSumDev", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.DOUBLE)));
+    metaDataMap = Collections.unmodifiableMap(tmpMap);
+    org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ActionStats.class, metaDataMap);
+  }
+
+  public ActionStats() {
+  }
+
+  public ActionStats(
+    int status,
+    double elapsed,
+    int num,
+    long count,
+    double sumDev,
+    int fail,
+    double queueTime,
+    double queueSumDev)
+  {
+    this();
+    this.status = status;
+    setStatusIsSet(true);
+    this.elapsed = elapsed;
+    setElapsedIsSet(true);
+    this.num = num;
+    setNumIsSet(true);
+    this.count = count;
+    setCountIsSet(true);
+    this.sumDev = sumDev;
+    setSumDevIsSet(true);
+    this.fail = fail;
+    setFailIsSet(true);
+    this.queueTime = queueTime;
+    setQueueTimeIsSet(true);
+    this.queueSumDev = queueSumDev;
+    setQueueSumDevIsSet(true);
+  }
+
+  /**
+   * Performs a deep copy on <i>other</i>.
+   */
+  public ActionStats(ActionStats other) {
+    __isset_bit_vector.clear();
+    __isset_bit_vector.or(other.__isset_bit_vector);
+    this.status = other.status;
+    this.elapsed = other.elapsed;
+    this.num = other.num;
+    this.count = other.count;
+    this.sumDev = other.sumDev;
+    this.fail = other.fail;
+    this.queueTime = other.queueTime;
+    this.queueSumDev = other.queueSumDev;
+  }
+
+  public ActionStats deepCopy() {
+    return new ActionStats(this);
+  }
+
+  @Override
+  public void clear() {
+    setStatusIsSet(false);
+    this.status = 0;
+    setElapsedIsSet(false);
+    this.elapsed = 0.0;
+    setNumIsSet(false);
+    this.num = 0;
+    setCountIsSet(false);
+    this.count = 0;
+    setSumDevIsSet(false);
+    this.sumDev = 0.0;
+    setFailIsSet(false);
+    this.fail = 0;
+    setQueueTimeIsSet(false);
+    this.queueTime = 0.0;
+    setQueueSumDevIsSet(false);
+    this.queueSumDev = 0.0;
+  }
+
+  public int getStatus() {
+    return this.status;
+  }
+
+  public ActionStats setStatus(int status) {
+    this.status = status;
+    setStatusIsSet(true);
+    return this;
+  }
+
+  public void unsetStatus() {
+    __isset_bit_vector.clear(__STATUS_ISSET_ID);
+  }
+
+  /** Returns true if field status is set (has been assigned a value) and false otherwise */
+  public boolean isSetStatus() {
+    return __isset_bit_vector.get(__STATUS_ISSET_ID);
+  }
+
+  public void setStatusIsSet(boolean value) {
+    __isset_bit_vector.set(__STATUS_ISSET_ID, value);
+  }
+
+  public double getElapsed() {
+    return this.elapsed;
+  }
+
+  public ActionStats setElapsed(double elapsed) {
+    this.elapsed = elapsed;
+    setElapsedIsSet(true);
+    return this;
+  }
+
+  public void unsetElapsed() {
+    __isset_bit_vector.clear(__ELAPSED_ISSET_ID);
+  }
+
+  /** Returns true if field elapsed is set (has been assigned a value) and false otherwise */
+  public boolean isSetElapsed() {
+    return __isset_bit_vector.get(__ELAPSED_ISSET_ID);
+  }
+
+  public void setElapsedIsSet(boolean value) {
+    __isset_bit_vector.set(__ELAPSED_ISSET_ID, value);
+  }
+
+  public int getNum() {
+    return this.num;
+  }
+
+  public ActionStats setNum(int num) {
+    this.num = num;
+    setNumIsSet(true);
+    return this;
+  }
+
+  public void unsetNum() {
+    __isset_bit_vector.clear(__NUM_ISSET_ID);
+  }
+
+  /** Returns true if field num is set (has been assigned a value) and false otherwise */
+  public boolean isSetNum() {
+    return __isset_bit_vector.get(__NUM_ISSET_ID);
+  }
+
+  public void setNumIsSet(boolean value) {
+    __isset_bit_vector.set(__NUM_ISSET_ID, value);
+  }
+
+  public long getCount() {
+    return this.count;
+  }
+
+  public ActionStats setCount(long count) {
+    this.count = count;
+    setCountIsSet(true);
+    return this;
+  }
+
+  public void unsetCount() {
+    __isset_bit_vector.clear(__COUNT_ISSET_ID);
+  }
+
+  /** Returns true if field count is set (has been assigned a value) and false otherwise */
+  public boolean isSetCount() {
+    return __isset_bit_vector.get(__COUNT_ISSET_ID);
+  }
+
+  public void setCountIsSet(boolean value) {
+    __isset_bit_vector.set(__COUNT_ISSET_ID, value);
+  }
+
+  public double getSumDev() {
+    return this.sumDev;
+  }
+
+  public ActionStats setSumDev(double sumDev) {
+    this.sumDev = sumDev;
+    setSumDevIsSet(true);
+    return this;
+  }
+
+  public void unsetSumDev() {
+    __isset_bit_vector.clear(__SUMDEV_ISSET_ID);
+  }
+
+  /** Returns true if field sumDev is set (has been assigned a value) and false otherwise */
+  public boolean isSetSumDev() {
+    return __isset_bit_vector.get(__SUMDEV_ISSET_ID);
+  }
+
+  public void setSumDevIsSet(boolean value) {
+    __isset_bit_vector.set(__SUMDEV_ISSET_ID, value);
+  }
+
+  public int getFail() {
+    return this.fail;
+  }
+
+  public ActionStats setFail(int fail) {
+    this.fail = fail;
+    setFailIsSet(true);
+    return this;
+  }
+
+  public void unsetFail() {
+    __isset_bit_vector.clear(__FAIL_ISSET_ID);
+  }
+
+  /** Returns true if field fail is set (has been assigned a value) and false otherwise */
+  public boolean isSetFail() {
+    return __isset_bit_vector.get(__FAIL_ISSET_ID);
+  }
+
+  public void setFailIsSet(boolean value) {
+    __isset_bit_vector.set(__FAIL_ISSET_ID, value);
+  }
+
+  public double getQueueTime() {
+    return this.queueTime;
+  }
+
+  public ActionStats setQueueTime(double queueTime) {
+    this.queueTime = queueTime;
+    setQueueTimeIsSet(true);
+    return this;
+  }
+
+  public void unsetQueueTime() {
+    __isset_bit_vector.clear(__QUEUETIME_ISSET_ID);
+  }
+
+  /** Returns true if field queueTime is set (has been assigned a value) and false otherwise */
+  public boolean isSetQueueTime() {
+    return __isset_bit_vector.get(__QUEUETIME_ISSET_ID);
+  }
+
+  public void setQueueTimeIsSet(boolean value) {
+    __isset_bit_vector.set(__QUEUETIME_ISSET_ID, value);
+  }
+
+  public double getQueueSumDev() {
+    return this.queueSumDev;
+  }
+
+  public ActionStats setQueueSumDev(double queueSumDev) {
+    this.queueSumDev = queueSumDev;
+    setQueueSumDevIsSet(true);
+    return this;
+  }
+
+  public void unsetQueueSumDev() {
+    __isset_bit_vector.clear(__QUEUESUMDEV_ISSET_ID);
+  }
+
+  /** Returns true if field queueSumDev is set (has been assigned a value) and false otherwise */
+  public boolean isSetQueueSumDev() {
+    return __isset_bit_vector.get(__QUEUESUMDEV_ISSET_ID);
+  }
+
+  public void setQueueSumDevIsSet(boolean value) {
+    __isset_bit_vector.set(__QUEUESUMDEV_ISSET_ID, value);
+  }
+
+  public void setFieldValue(_Fields field, Object value) {
+    switch (field) {
+    case STATUS:
+      if (value == null) {
+        unsetStatus();
+      } else {
+        setStatus((Integer)value);
+      }
+      break;
+
+    case ELAPSED:
+      if (value == null) {
+        unsetElapsed();
+      } else {
+        setElapsed((Double)value);
+      }
+      break;
+
+    case NUM:
+      if (value == null) {
+        unsetNum();
+      } else {
+        setNum((Integer)value);
+      }
+      break;
+
+    case COUNT:
+      if (value == null) {
+        unsetCount();
+      } else {
+        setCount((Long)value);
+      }
+      break;
+
+    case SUM_DEV:
+      if (value == null) {
+        unsetSumDev();
+      } else {
+        setSumDev((Double)value);
+      }
+      break;
+
+    case FAIL:
+      if (value == null) {
+        unsetFail();
+      } else {
+        setFail((Integer)value);
+      }
+      break;
+
+    case QUEUE_TIME:
+      if (value == null) {
+        unsetQueueTime();
+      } else {
+        setQueueTime((Double)value);
+      }
+      break;
+
+    case QUEUE_SUM_DEV:
+      if (value == null) {
+        unsetQueueSumDev();
+      } else {
+        setQueueSumDev((Double)value);
+      }
+      break;
+
+    }
+  }
+
+  public Object getFieldValue(_Fields field) {
+    switch (field) {
+    case STATUS:
+      return Integer.valueOf(getStatus());
+
+    case ELAPSED:
+      return Double.valueOf(getElapsed());
+
+    case NUM:
+      return Integer.valueOf(getNum());
+
+    case COUNT:
+      return Long.valueOf(getCount());
+
+    case SUM_DEV:
+      return Double.valueOf(getSumDev());
+
+    case FAIL:
+      return Integer.valueOf(getFail());
+
+    case QUEUE_TIME:
+      return Double.valueOf(getQueueTime());
+
+    case QUEUE_SUM_DEV:
+      return Double.valueOf(getQueueSumDev());
+
+    }
+    throw new IllegalStateException();
+  }
+
+  /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
+  public boolean isSet(_Fields field) {
+    if (field == null) {
+      throw new IllegalArgumentException();
+    }
+
+    switch (field) {
+    case STATUS:
+      return isSetStatus();
+    case ELAPSED:
+      return isSetElapsed();
+    case NUM:
+      return isSetNum();
+    case COUNT:
+      return isSetCount();
+    case SUM_DEV:
+      return isSetSumDev();
+    case FAIL:
+      return isSetFail();
+    case QUEUE_TIME:
+      return isSetQueueTime();
+    case QUEUE_SUM_DEV:
+      return isSetQueueSumDev();
+    }
+    throw new IllegalStateException();
+  }
+
+  @Override
+  public boolean equals(Object that) {
+    if (that == null)
+      return false;
+    if (that instanceof ActionStats)
+      return this.equals((ActionStats)that);
+    return false;
+  }
+
+  public boolean equals(ActionStats that) {
+    if (that == null)
+      return false;
+
+    boolean this_present_status = true;
+    boolean that_present_status = true;
+    if (this_present_status || that_present_status) {
+      if (!(this_present_status && that_present_status))
+        return false;
+      if (this.status != that.status)
+        return false;
+    }
+
+    boolean this_present_elapsed = true;
+    boolean that_present_elapsed = true;
+    if (this_present_elapsed || that_present_elapsed) {
+      if (!(this_present_elapsed && that_present_elapsed))
+        return false;
+      if (this.elapsed != that.elapsed)
+        return false;
+    }
+
+    boolean this_present_num = true;
+    boolean that_present_num = true;
+    if (this_present_num || that_present_num) {
+      if (!(this_present_num && that_present_num))
+        return false;
+      if (this.num != that.num)
+        return false;
+    }
+
+    boolean this_present_count = true;
+    boolean that_present_count = true;
+    if (this_present_count || that_present_count) {
+      if (!(this_present_count && that_present_count))
+        return false;
+      if (this.count != that.count)
+        return false;
+    }
+
+    boolean this_present_sumDev = true;
+    boolean that_present_sumDev = true;
+    if (this_present_sumDev || that_present_sumDev) {
+      if (!(this_present_sumDev && that_present_sumDev))
+        return false;
+      if (this.sumDev != that.sumDev)
+        return false;
+    }
+
+    boolean this_present_fail = true;
+    boolean that_present_fail = true;
+    if (this_present_fail || that_present_fail) {
+      if (!(this_present_fail && that_present_fail))
+        return false;
+      if (this.fail != that.fail)
+        return false;
+    }
+
+    boolean this_present_queueTime = true;
+    boolean that_present_queueTime = true;
+    if (this_present_queueTime || that_present_queueTime) {
+      if (!(this_present_queueTime && that_present_queueTime))
+        return false;
+      if (this.queueTime != that.queueTime)
+        return false;
+    }
+
+    boolean this_present_queueSumDev = true;
+    boolean that_present_queueSumDev = true;
+    if (this_present_queueSumDev || that_present_queueSumDev) {
+      if (!(this_present_queueSumDev && that_present_queueSumDev))
+        return false;
+      if (this.queueSumDev != that.queueSumDev)
+        return false;
+    }
+
+    return true;
+  }
+
+  @Override
+  public int hashCode() {
+    return 0;
+  }
+
+  public int compareTo(ActionStats other) {
+    if (!getClass().equals(other.getClass())) {
+      return getClass().getName().compareTo(other.getClass().getName());
+    }
+
+    int lastComparison = 0;
+    ActionStats typedOther = (ActionStats)other;
+
+    lastComparison = Boolean.valueOf(isSetStatus()).compareTo(typedOther.isSetStatus());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetStatus()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.status, typedOther.status);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetElapsed()).compareTo(typedOther.isSetElapsed());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetElapsed()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.elapsed, typedOther.elapsed);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetNum()).compareTo(typedOther.isSetNum());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetNum()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.num, typedOther.num);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetCount()).compareTo(typedOther.isSetCount());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetCount()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.count, typedOther.count);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetSumDev()).compareTo(typedOther.isSetSumDev());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetSumDev()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.sumDev, typedOther.sumDev);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetFail()).compareTo(typedOther.isSetFail());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetFail()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.fail, typedOther.fail);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetQueueTime()).compareTo(typedOther.isSetQueueTime());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetQueueTime()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.queueTime, typedOther.queueTime);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetQueueSumDev()).compareTo(typedOther.isSetQueueSumDev());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetQueueSumDev()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.queueSumDev, typedOther.queueSumDev);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    return 0;
+  }
+
+  public _Fields fieldForId(int fieldId) {
+    return _Fields.findByThriftId(fieldId);
+  }
+
+  public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
+    schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
+  }
+
+  public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+    schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
+  }
+
+  @Override
+  public String toString() {
+    StringBuilder sb = new StringBuilder("ActionStats(");
+    boolean first = true;
+
+    sb.append("status:");
+    sb.append(this.status);
+    first = false;
+    if (!first) sb.append(", ");
+    sb.append("elapsed:");
+    sb.append(this.elapsed);
+    first = false;
+    if (!first) sb.append(", ");
+    sb.append("num:");
+    sb.append(this.num);
+    first = false;
+    if (!first) sb.append(", ");
+    sb.append("count:");
+    sb.append(this.count);
+    first = false;
+    if (!first) sb.append(", ");
+    sb.append("sumDev:");
+    sb.append(this.sumDev);
+    first = false;
+    if (!first) sb.append(", ");
+    sb.append("fail:");
+    sb.append(this.fail);
+    first = false;
+    if (!first) sb.append(", ");
+    sb.append("queueTime:");
+    sb.append(this.queueTime);
+    first = false;
+    if (!first) sb.append(", ");
+    sb.append("queueSumDev:");
+    sb.append(this.queueSumDev);
+    first = false;
+    sb.append(")");
+    return sb.toString();
+  }
+
+  public void validate() throws org.apache.thrift.TException {
+    // check for required fields
+  }
+
+  private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
+    try {
+      write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
+    } catch (org.apache.thrift.TException te) {
+      throw new java.io.IOException(te);
+    }
+  }
+
+  private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
+    try {
+      // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
+      __isset_bit_vector = new BitSet(1);
+      read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
+    } catch (org.apache.thrift.TException te) {
+      throw new java.io.IOException(te);
+    }
+  }
+
+  private static class ActionStatsStandardSchemeFactory implements SchemeFactory {
+    public ActionStatsStandardScheme getScheme() {
+      return new ActionStatsStandardScheme();
+    }
+  }
+
+  private static class ActionStatsStandardScheme extends StandardScheme<ActionStats> {
+
+    public void read(org.apache.thrift.protocol.TProtocol iprot, ActionStats 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: // STATUS
+            if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
+              struct.status = iprot.readI32();
+              struct.setStatusIsSet(true);
+            } else { 
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
+          case 2: // ELAPSED
+            if (schemeField.type == org.apache.thrift.protocol.TType.DOUBLE) {
+              struct.elapsed = iprot.readDouble();
+              struct.setElapsedIsSet(true);
+            } else { 
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
+          case 3: // NUM
+            if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
+              struct.num = iprot.readI32();
+              struct.setNumIsSet(true);
+            } else { 
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
+          case 4: // COUNT
+            if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+              struct.count = iprot.readI64();
+              struct.setCountIsSet(true);
+            } else { 
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
+          case 5: // SUM_DEV
+            if (schemeField.type == org.apache.thrift.protocol.TType.DOUBLE) {
+              struct.sumDev = iprot.readDouble();
+              struct.setSumDevIsSet(true);
+            } else { 
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
+          case 6: // FAIL
+            if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
+              struct.fail = iprot.readI32();
+              struct.setFailIsSet(true);
+            } else { 
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
+          case 7: // QUEUE_TIME
+            if (schemeField.type == org.apache.thrift.protocol.TType.DOUBLE) {
+              struct.queueTime = iprot.readDouble();
+              struct.setQueueTimeIsSet(true);
+            } else { 
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
+          case 8: // QUEUE_SUM_DEV
+            if (schemeField.type == org.apache.thrift.protocol.TType.DOUBLE) {
+              struct.queueSumDev = iprot.readDouble();
+              struct.setQueueSumDevIsSet(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();
+    }
+
+    public void write(org.apache.thrift.protocol.TProtocol oprot, ActionStats struct) throws org.apache.thrift.TException {
+      struct.validate();
+
+      oprot.writeStructBegin(STRUCT_DESC);
+      oprot.writeFieldBegin(STATUS_FIELD_DESC);
+      oprot.writeI32(struct.status);
+      oprot.writeFieldEnd();
+      oprot.writeFieldBegin(ELAPSED_FIELD_DESC);
+      oprot.writeDouble(struct.elapsed);
+      oprot.writeFieldEnd();
+      oprot.writeFieldBegin(NUM_FIELD_DESC);
+      oprot.writeI32(struct.num);
+      oprot.writeFieldEnd();
+      oprot.writeFieldBegin(COUNT_FIELD_DESC);
+      oprot.writeI64(struct.count);
+      oprot.writeFieldEnd();
+      oprot.writeFieldBegin(SUM_DEV_FIELD_DESC);
+      oprot.writeDouble(struct.sumDev);
+      oprot.writeFieldEnd();
+      oprot.writeFieldBegin(FAIL_FIELD_DESC);
+      oprot.writeI32(struct.fail);
+      oprot.writeFieldEnd();
+      oprot.writeFieldBegin(QUEUE_TIME_FIELD_DESC);
+      oprot.writeDouble(struct.queueTime);
+      oprot.writeFieldEnd();
+      oprot.writeFieldBegin(QUEUE_SUM_DEV_FIELD_DESC);
+      oprot.writeDouble(struct.queueSumDev);
+      oprot.writeFieldEnd();
+      oprot.writeFieldStop();
+      oprot.writeStructEnd();
+    }
+
+  }
+
+  private static class ActionStatsTupleSchemeFactory implements SchemeFactory {
+    public ActionStatsTupleScheme getScheme() {
+      return new ActionStatsTupleScheme();
+    }
+  }
+
+  private static class ActionStatsTupleScheme extends TupleScheme<ActionStats> {
+
+    @Override
+    public void write(org.apache.thrift.protocol.TProtocol prot, ActionStats struct) throws org.apache.thrift.TException {
+      TTupleProtocol oprot = (TTupleProtocol) prot;
+      BitSet optionals = new BitSet();
+      if (struct.isSetStatus()) {
+        optionals.set(0);
+      }
+      if (struct.isSetElapsed()) {
+        optionals.set(1);
+      }
+      if (struct.isSetNum()) {
+        optionals.set(2);
+      }
+      if (struct.isSetCount()) {
+        optionals.set(3);
+      }
+      if (struct.isSetSumDev()) {
+        optionals.set(4);
+      }
+      if (struct.isSetFail()) {
+        optionals.set(5);
+      }
+      if (struct.isSetQueueTime()) {
+        optionals.set(6);
+      }
+      if (struct.isSetQueueSumDev()) {
+        optionals.set(7);
+      }
+      oprot.writeBitSet(optionals, 8);
+      if (struct.isSetStatus()) {
+        oprot.writeI32(struct.status);
+      }
+      if (struct.isSetElapsed()) {
+        oprot.writeDouble(struct.elapsed);
+      }
+      if (struct.isSetNum()) {
+        oprot.writeI32(struct.num);
+      }
+      if (struct.isSetCount()) {
+        oprot.writeI64(struct.count);
+      }
+      if (struct.isSetSumDev()) {
+        oprot.writeDouble(struct.sumDev);
+      }
+      if (struct.isSetFail()) {
+        oprot.writeI32(struct.fail);
+      }
+      if (struct.isSetQueueTime()) {
+        oprot.writeDouble(struct.queueTime);
+      }
+      if (struct.isSetQueueSumDev()) {
+        oprot.writeDouble(struct.queueSumDev);
+      }
+    }
+
+    @Override
+    public void read(org.apache.thrift.protocol.TProtocol prot, ActionStats struct) throws org.apache.thrift.TException {
+      TTupleProtocol iprot = (TTupleProtocol) prot;
+      BitSet incoming = iprot.readBitSet(8);
+      if (incoming.get(0)) {
+        struct.status = iprot.readI32();
+        struct.setStatusIsSet(true);
+      }
+      if (incoming.get(1)) {
+        struct.elapsed = iprot.readDouble();
+        struct.setElapsedIsSet(true);
+      }
+      if (incoming.get(2)) {
+        struct.num = iprot.readI32();
+        struct.setNumIsSet(true);
+      }
+      if (incoming.get(3)) {
+        struct.count = iprot.readI64();
+        struct.setCountIsSet(true);
+      }
+      if (incoming.get(4)) {
+        struct.sumDev = iprot.readDouble();
+        struct.setSumDevIsSet(true);
+      }
+      if (incoming.get(5)) {
+        struct.fail = iprot.readI32();
+        struct.setFailIsSet(true);
+      }
+      if (incoming.get(6)) {
+        struct.queueTime = iprot.readDouble();
+        struct.setQueueTimeIsSet(true);
+      }
+      if (incoming.get(7)) {
+        struct.queueSumDev = iprot.readDouble();
+        struct.setQueueSumDevIsSet(true);
+      }
+    }
+  }
+
+}
+

http://git-wip-us.apache.org/repos/asf/accumulo/blob/7bdbfccb/1.5/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/ActiveScan.java
----------------------------------------------------------------------
diff --git a/1.5/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/ActiveScan.java b/1.5/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/ActiveScan.java
new file mode 100644
index 0000000..054422c
--- /dev/null
+++ b/1.5/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/ActiveScan.java
@@ -0,0 +1,1631 @@
+/**
+ * Autogenerated by Thrift Compiler (0.8.0)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ *  @generated
+ */
+package org.apache.accumulo.core.tabletserver.thrift;
+
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings("all") public class ActiveScan implements org.apache.thrift.TBase<ActiveScan, ActiveScan._Fields>, java.io.Serializable, Cloneable {
+  private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ActiveScan");
+
+  private static final org.apache.thrift.protocol.TField CLIENT_FIELD_DESC = new org.apache.thrift.protocol.TField("client", org.apache.thrift.protocol.TType.STRING, (short)2);
+  private static final org.apache.thrift.protocol.TField USER_FIELD_DESC = new org.apache.thrift.protocol.TField("user", org.apache.thrift.protocol.TType.STRING, (short)3);
+  private static final org.apache.thrift.protocol.TField TABLE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("tableId", org.apache.thrift.protocol.TType.STRING, (short)4);
+  private static final org.apache.thrift.protocol.TField AGE_FIELD_DESC = new org.apache.thrift.protocol.TField("age", org.apache.thrift.protocol.TType.I64, (short)5);
+  private static final org.apache.thrift.protocol.TField IDLE_TIME_FIELD_DESC = new org.apache.thrift.protocol.TField("idleTime", org.apache.thrift.protocol.TType.I64, (short)6);
+  private static final org.apache.thrift.protocol.TField TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("type", org.apache.thrift.protocol.TType.I32, (short)7);
+  private static final org.apache.thrift.protocol.TField STATE_FIELD_DESC = new org.apache.thrift.protocol.TField("state", org.apache.thrift.protocol.TType.I32, (short)8);
+  private static final org.apache.thrift.protocol.TField EXTENT_FIELD_DESC = new org.apache.thrift.protocol.TField("extent", org.apache.thrift.protocol.TType.STRUCT, (short)9);
+  private static final org.apache.thrift.protocol.TField COLUMNS_FIELD_DESC = new org.apache.thrift.protocol.TField("columns", org.apache.thrift.protocol.TType.LIST, (short)10);
+  private static final org.apache.thrift.protocol.TField SSI_LIST_FIELD_DESC = new org.apache.thrift.protocol.TField("ssiList", org.apache.thrift.protocol.TType.LIST, (short)11);
+  private static final org.apache.thrift.protocol.TField SSIO_FIELD_DESC = new org.apache.thrift.protocol.TField("ssio", org.apache.thrift.protocol.TType.MAP, (short)12);
+
+  private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+  static {
+    schemes.put(StandardScheme.class, new ActiveScanStandardSchemeFactory());
+    schemes.put(TupleScheme.class, new ActiveScanTupleSchemeFactory());
+  }
+
+  public String client; // required
+  public String user; // required
+  public String tableId; // required
+  public long age; // required
+  public long idleTime; // required
+  /**
+   * 
+   * @see ScanType
+   */
+  public ScanType type; // required
+  /**
+   * 
+   * @see ScanState
+   */
+  public ScanState state; // required
+  public org.apache.accumulo.core.data.thrift.TKeyExtent extent; // required
+  public List<org.apache.accumulo.core.data.thrift.TColumn> columns; // required
+  public List<org.apache.accumulo.core.data.thrift.IterInfo> ssiList; // required
+  public Map<String,Map<String,String>> ssio; // required
+
+  /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
+  public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+    CLIENT((short)2, "client"),
+    USER((short)3, "user"),
+    TABLE_ID((short)4, "tableId"),
+    AGE((short)5, "age"),
+    IDLE_TIME((short)6, "idleTime"),
+    /**
+     * 
+     * @see ScanType
+     */
+    TYPE((short)7, "type"),
+    /**
+     * 
+     * @see ScanState
+     */
+    STATE((short)8, "state"),
+    EXTENT((short)9, "extent"),
+    COLUMNS((short)10, "columns"),
+    SSI_LIST((short)11, "ssiList"),
+    SSIO((short)12, "ssio");
+
+    private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+
+    static {
+      for (_Fields field : EnumSet.allOf(_Fields.class)) {
+        byName.put(field.getFieldName(), field);
+      }
+    }
+
+    /**
+     * Find the _Fields constant that matches fieldId, or null if its not found.
+     */
+    public static _Fields findByThriftId(int fieldId) {
+      switch(fieldId) {
+        case 2: // CLIENT
+          return CLIENT;
+        case 3: // USER
+          return USER;
+        case 4: // TABLE_ID
+          return TABLE_ID;
+        case 5: // AGE
+          return AGE;
+        case 6: // IDLE_TIME
+          return IDLE_TIME;
+        case 7: // TYPE
+          return TYPE;
+        case 8: // STATE
+          return STATE;
+        case 9: // EXTENT
+          return EXTENT;
+        case 10: // COLUMNS
+          return COLUMNS;
+        case 11: // SSI_LIST
+          return SSI_LIST;
+        case 12: // SSIO
+          return SSIO;
+        default:
+          return null;
+      }
+    }
+
+    /**
+     * Find the _Fields constant that matches fieldId, throwing an exception
+     * if it is not found.
+     */
+    public static _Fields findByThriftIdOrThrow(int fieldId) {
+      _Fields fields = findByThriftId(fieldId);
+      if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+      return fields;
+    }
+
+    /**
+     * Find the _Fields constant that matches name, or null if its not found.
+     */
+    public static _Fields findByName(String name) {
+      return byName.get(name);
+    }
+
+    private final short _thriftId;
+    private final String _fieldName;
+
+    _Fields(short thriftId, String fieldName) {
+      _thriftId = thriftId;
+      _fieldName = fieldName;
+    }
+
+    public short getThriftFieldId() {
+      return _thriftId;
+    }
+
+    public String getFieldName() {
+      return _fieldName;
+    }
+  }
+
+  // isset id assignments
+  private static final int __AGE_ISSET_ID = 0;
+  private static final int __IDLETIME_ISSET_ID = 1;
+  private BitSet __isset_bit_vector = new BitSet(2);
+  public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
+  static {
+    Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
+    tmpMap.put(_Fields.CLIENT, new org.apache.thrift.meta_data.FieldMetaData("client", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+    tmpMap.put(_Fields.USER, new org.apache.thrift.meta_data.FieldMetaData("user", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+    tmpMap.put(_Fields.TABLE_ID, new org.apache.thrift.meta_data.FieldMetaData("tableId", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+    tmpMap.put(_Fields.AGE, new org.apache.thrift.meta_data.FieldMetaData("age", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
+    tmpMap.put(_Fields.IDLE_TIME, new org.apache.thrift.meta_data.FieldMetaData("idleTime", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
+    tmpMap.put(_Fields.TYPE, new org.apache.thrift.meta_data.FieldMetaData("type", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, ScanType.class)));
+    tmpMap.put(_Fields.STATE, new org.apache.thrift.meta_data.FieldMetaData("state", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, ScanState.class)));
+    tmpMap.put(_Fields.EXTENT, new org.apache.thrift.meta_data.FieldMetaData("extent", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.accumulo.core.data.thrift.TKeyExtent.class)));
+    tmpMap.put(_Fields.COLUMNS, new org.apache.thrift.meta_data.FieldMetaData("columns", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, 
+            new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.accumulo.core.data.thrift.TColumn.class))));
+    tmpMap.put(_Fields.SSI_LIST, new org.apache.thrift.meta_data.FieldMetaData("ssiList", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, 
+            new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.accumulo.core.data.thrift.IterInfo.class))));
+    tmpMap.put(_Fields.SSIO, new org.apache.thrift.meta_data.FieldMetaData("ssio", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+        new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP, 
+            new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING), 
+            new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP, 
+                new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING), 
+                new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)))));
+    metaDataMap = Collections.unmodifiableMap(tmpMap);
+    org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ActiveScan.class, metaDataMap);
+  }
+
+  public ActiveScan() {
+  }
+
+  public ActiveScan(
+    String client,
+    String user,
+    String tableId,
+    long age,
+    long idleTime,
+    ScanType type,
+    ScanState state,
+    org.apache.accumulo.core.data.thrift.TKeyExtent extent,
+    List<org.apache.accumulo.core.data.thrift.TColumn> columns,
+    List<org.apache.accumulo.core.data.thrift.IterInfo> ssiList,
+    Map<String,Map<String,String>> ssio)
+  {
+    this();
+    this.client = client;
+    this.user = user;
+    this.tableId = tableId;
+    this.age = age;
+    setAgeIsSet(true);
+    this.idleTime = idleTime;
+    setIdleTimeIsSet(true);
+    this.type = type;
+    this.state = state;
+    this.extent = extent;
+    this.columns = columns;
+    this.ssiList = ssiList;
+    this.ssio = ssio;
+  }
+
+  /**
+   * Performs a deep copy on <i>other</i>.
+   */
+  public ActiveScan(ActiveScan other) {
+    __isset_bit_vector.clear();
+    __isset_bit_vector.or(other.__isset_bit_vector);
+    if (other.isSetClient()) {
+      this.client = other.client;
+    }
+    if (other.isSetUser()) {
+      this.user = other.user;
+    }
+    if (other.isSetTableId()) {
+      this.tableId = other.tableId;
+    }
+    this.age = other.age;
+    this.idleTime = other.idleTime;
+    if (other.isSetType()) {
+      this.type = other.type;
+    }
+    if (other.isSetState()) {
+      this.state = other.state;
+    }
+    if (other.isSetExtent()) {
+      this.extent = new org.apache.accumulo.core.data.thrift.TKeyExtent(other.extent);
+    }
+    if (other.isSetColumns()) {
+      List<org.apache.accumulo.core.data.thrift.TColumn> __this__columns = new ArrayList<org.apache.accumulo.core.data.thrift.TColumn>();
+      for (org.apache.accumulo.core.data.thrift.TColumn other_element : other.columns) {
+        __this__columns.add(new org.apache.accumulo.core.data.thrift.TColumn(other_element));
+      }
+      this.columns = __this__columns;
+    }
+    if (other.isSetSsiList()) {
+      List<org.apache.accumulo.core.data.thrift.IterInfo> __this__ssiList = new ArrayList<org.apache.accumulo.core.data.thrift.IterInfo>();
+      for (org.apache.accumulo.core.data.thrift.IterInfo other_element : other.ssiList) {
+        __this__ssiList.add(new org.apache.accumulo.core.data.thrift.IterInfo(other_element));
+      }
+      this.ssiList = __this__ssiList;
+    }
+    if (other.isSetSsio()) {
+      Map<String,Map<String,String>> __this__ssio = new HashMap<String,Map<String,String>>();
+      for (Map.Entry<String, Map<String,String>> other_element : other.ssio.entrySet()) {
+
+        String other_element_key = other_element.getKey();
+        Map<String,String> other_element_value = other_element.getValue();
+
+        String __this__ssio_copy_key = other_element_key;
+
+        Map<String,String> __this__ssio_copy_value = new HashMap<String,String>();
+        for (Map.Entry<String, String> other_element_value_element : other_element_value.entrySet()) {
+
+          String other_element_value_element_key = other_element_value_element.getKey();
+          String other_element_value_element_value = other_element_value_element.getValue();
+
+          String __this__ssio_copy_value_copy_key = other_element_value_element_key;
+
+          String __this__ssio_copy_value_copy_value = other_element_value_element_value;
+
+          __this__ssio_copy_value.put(__this__ssio_copy_value_copy_key, __this__ssio_copy_value_copy_value);
+        }
+
+        __this__ssio.put(__this__ssio_copy_key, __this__ssio_copy_value);
+      }
+      this.ssio = __this__ssio;
+    }
+  }
+
+  public ActiveScan deepCopy() {
+    return new ActiveScan(this);
+  }
+
+  @Override
+  public void clear() {
+    this.client = null;
+    this.user = null;
+    this.tableId = null;
+    setAgeIsSet(false);
+    this.age = 0;
+    setIdleTimeIsSet(false);
+    this.idleTime = 0;
+    this.type = null;
+    this.state = null;
+    this.extent = null;
+    this.columns = null;
+    this.ssiList = null;
+    this.ssio = null;
+  }
+
+  public String getClient() {
+    return this.client;
+  }
+
+  public ActiveScan setClient(String client) {
+    this.client = client;
+    return this;
+  }
+
+  public void unsetClient() {
+    this.client = null;
+  }
+
+  /** Returns true if field client is set (has been assigned a value) and false otherwise */
+  public boolean isSetClient() {
+    return this.client != null;
+  }
+
+  public void setClientIsSet(boolean value) {
+    if (!value) {
+      this.client = null;
+    }
+  }
+
+  public String getUser() {
+    return this.user;
+  }
+
+  public ActiveScan setUser(String user) {
+    this.user = user;
+    return this;
+  }
+
+  public void unsetUser() {
+    this.user = null;
+  }
+
+  /** Returns true if field user is set (has been assigned a value) and false otherwise */
+  public boolean isSetUser() {
+    return this.user != null;
+  }
+
+  public void setUserIsSet(boolean value) {
+    if (!value) {
+      this.user = null;
+    }
+  }
+
+  public String getTableId() {
+    return this.tableId;
+  }
+
+  public ActiveScan setTableId(String tableId) {
+    this.tableId = tableId;
+    return this;
+  }
+
+  public void unsetTableId() {
+    this.tableId = null;
+  }
+
+  /** Returns true if field tableId is set (has been assigned a value) and false otherwise */
+  public boolean isSetTableId() {
+    return this.tableId != null;
+  }
+
+  public void setTableIdIsSet(boolean value) {
+    if (!value) {
+      this.tableId = null;
+    }
+  }
+
+  public long getAge() {
+    return this.age;
+  }
+
+  public ActiveScan setAge(long age) {
+    this.age = age;
+    setAgeIsSet(true);
+    return this;
+  }
+
+  public void unsetAge() {
+    __isset_bit_vector.clear(__AGE_ISSET_ID);
+  }
+
+  /** Returns true if field age is set (has been assigned a value) and false otherwise */
+  public boolean isSetAge() {
+    return __isset_bit_vector.get(__AGE_ISSET_ID);
+  }
+
+  public void setAgeIsSet(boolean value) {
+    __isset_bit_vector.set(__AGE_ISSET_ID, value);
+  }
+
+  public long getIdleTime() {
+    return this.idleTime;
+  }
+
+  public ActiveScan setIdleTime(long idleTime) {
+    this.idleTime = idleTime;
+    setIdleTimeIsSet(true);
+    return this;
+  }
+
+  public void unsetIdleTime() {
+    __isset_bit_vector.clear(__IDLETIME_ISSET_ID);
+  }
+
+  /** Returns true if field idleTime is set (has been assigned a value) and false otherwise */
+  public boolean isSetIdleTime() {
+    return __isset_bit_vector.get(__IDLETIME_ISSET_ID);
+  }
+
+  public void setIdleTimeIsSet(boolean value) {
+    __isset_bit_vector.set(__IDLETIME_ISSET_ID, value);
+  }
+
+  /**
+   * 
+   * @see ScanType
+   */
+  public ScanType getType() {
+    return this.type;
+  }
+
+  /**
+   * 
+   * @see ScanType
+   */
+  public ActiveScan setType(ScanType type) {
+    this.type = type;
+    return this;
+  }
+
+  public void unsetType() {
+    this.type = null;
+  }
+
+  /** Returns true if field type is set (has been assigned a value) and false otherwise */
+  public boolean isSetType() {
+    return this.type != null;
+  }
+
+  public void setTypeIsSet(boolean value) {
+    if (!value) {
+      this.type = null;
+    }
+  }
+
+  /**
+   * 
+   * @see ScanState
+   */
+  public ScanState getState() {
+    return this.state;
+  }
+
+  /**
+   * 
+   * @see ScanState
+   */
+  public ActiveScan setState(ScanState state) {
+    this.state = state;
+    return this;
+  }
+
+  public void unsetState() {
+    this.state = null;
+  }
+
+  /** Returns true if field state is set (has been assigned a value) and false otherwise */
+  public boolean isSetState() {
+    return this.state != null;
+  }
+
+  public void setStateIsSet(boolean value) {
+    if (!value) {
+      this.state = null;
+    }
+  }
+
+  public org.apache.accumulo.core.data.thrift.TKeyExtent getExtent() {
+    return this.extent;
+  }
+
+  public ActiveScan setExtent(org.apache.accumulo.core.data.thrift.TKeyExtent extent) {
+    this.extent = extent;
+    return this;
+  }
+
+  public void unsetExtent() {
+    this.extent = null;
+  }
+
+  /** Returns true if field extent is set (has been assigned a value) and false otherwise */
+  public boolean isSetExtent() {
+    return this.extent != null;
+  }
+
+  public void setExtentIsSet(boolean value) {
+    if (!value) {
+      this.extent = null;
+    }
+  }
+
+  public int getColumnsSize() {
+    return (this.columns == null) ? 0 : this.columns.size();
+  }
+
+  public java.util.Iterator<org.apache.accumulo.core.data.thrift.TColumn> getColumnsIterator() {
+    return (this.columns == null) ? null : this.columns.iterator();
+  }
+
+  public void addToColumns(org.apache.accumulo.core.data.thrift.TColumn elem) {
+    if (this.columns == null) {
+      this.columns = new ArrayList<org.apache.accumulo.core.data.thrift.TColumn>();
+    }
+    this.columns.add(elem);
+  }
+
+  public List<org.apache.accumulo.core.data.thrift.TColumn> getColumns() {
+    return this.columns;
+  }
+
+  public ActiveScan setColumns(List<org.apache.accumulo.core.data.thrift.TColumn> columns) {
+    this.columns = columns;
+    return this;
+  }
+
+  public void unsetColumns() {
+    this.columns = null;
+  }
+
+  /** Returns true if field columns is set (has been assigned a value) and false otherwise */
+  public boolean isSetColumns() {
+    return this.columns != null;
+  }
+
+  public void setColumnsIsSet(boolean value) {
+    if (!value) {
+      this.columns = null;
+    }
+  }
+
+  public int getSsiListSize() {
+    return (this.ssiList == null) ? 0 : this.ssiList.size();
+  }
+
+  public java.util.Iterator<org.apache.accumulo.core.data.thrift.IterInfo> getSsiListIterator() {
+    return (this.ssiList == null) ? null : this.ssiList.iterator();
+  }
+
+  public void addToSsiList(org.apache.accumulo.core.data.thrift.IterInfo elem) {
+    if (this.ssiList == null) {
+      this.ssiList = new ArrayList<org.apache.accumulo.core.data.thrift.IterInfo>();
+    }
+    this.ssiList.add(elem);
+  }
+
+  public List<org.apache.accumulo.core.data.thrift.IterInfo> getSsiList() {
+    return this.ssiList;
+  }
+
+  public ActiveScan setSsiList(List<org.apache.accumulo.core.data.thrift.IterInfo> ssiList) {
+    this.ssiList = ssiList;
+    return this;
+  }
+
+  public void unsetSsiList() {
+    this.ssiList = null;
+  }
+
+  /** Returns true if field ssiList is set (has been assigned a value) and false otherwise */
+  public boolean isSetSsiList() {
+    return this.ssiList != null;
+  }
+
+  public void setSsiListIsSet(boolean value) {
+    if (!value) {
+      this.ssiList = null;
+    }
+  }
+
+  public int getSsioSize() {
+    return (this.ssio == null) ? 0 : this.ssio.size();
+  }
+
+  public void putToSsio(String key, Map<String,String> val) {
+    if (this.ssio == null) {
+      this.ssio = new HashMap<String,Map<String,String>>();
+    }
+    this.ssio.put(key, val);
+  }
+
+  public Map<String,Map<String,String>> getSsio() {
+    return this.ssio;
+  }
+
+  public ActiveScan setSsio(Map<String,Map<String,String>> ssio) {
+    this.ssio = ssio;
+    return this;
+  }
+
+  public void unsetSsio() {
+    this.ssio = null;
+  }
+
+  /** Returns true if field ssio is set (has been assigned a value) and false otherwise */
+  public boolean isSetSsio() {
+    return this.ssio != null;
+  }
+
+  public void setSsioIsSet(boolean value) {
+    if (!value) {
+      this.ssio = null;
+    }
+  }
+
+  public void setFieldValue(_Fields field, Object value) {
+    switch (field) {
+    case CLIENT:
+      if (value == null) {
+        unsetClient();
+      } else {
+        setClient((String)value);
+      }
+      break;
+
+    case USER:
+      if (value == null) {
+        unsetUser();
+      } else {
+        setUser((String)value);
+      }
+      break;
+
+    case TABLE_ID:
+      if (value == null) {
+        unsetTableId();
+      } else {
+        setTableId((String)value);
+      }
+      break;
+
+    case AGE:
+      if (value == null) {
+        unsetAge();
+      } else {
+        setAge((Long)value);
+      }
+      break;
+
+    case IDLE_TIME:
+      if (value == null) {
+        unsetIdleTime();
+      } else {
+        setIdleTime((Long)value);
+      }
+      break;
+
+    case TYPE:
+      if (value == null) {
+        unsetType();
+      } else {
+        setType((ScanType)value);
+      }
+      break;
+
+    case STATE:
+      if (value == null) {
+        unsetState();
+      } else {
+        setState((ScanState)value);
+      }
+      break;
+
+    case EXTENT:
+      if (value == null) {
+        unsetExtent();
+      } else {
+        setExtent((org.apache.accumulo.core.data.thrift.TKeyExtent)value);
+      }
+      break;
+
+    case COLUMNS:
+      if (value == null) {
+        unsetColumns();
+      } else {
+        setColumns((List<org.apache.accumulo.core.data.thrift.TColumn>)value);
+      }
+      break;
+
+    case SSI_LIST:
+      if (value == null) {
+        unsetSsiList();
+      } else {
+        setSsiList((List<org.apache.accumulo.core.data.thrift.IterInfo>)value);
+      }
+      break;
+
+    case SSIO:
+      if (value == null) {
+        unsetSsio();
+      } else {
+        setSsio((Map<String,Map<String,String>>)value);
+      }
+      break;
+
+    }
+  }
+
+  public Object getFieldValue(_Fields field) {
+    switch (field) {
+    case CLIENT:
+      return getClient();
+
+    case USER:
+      return getUser();
+
+    case TABLE_ID:
+      return getTableId();
+
+    case AGE:
+      return Long.valueOf(getAge());
+
+    case IDLE_TIME:
+      return Long.valueOf(getIdleTime());
+
+    case TYPE:
+      return getType();
+
+    case STATE:
+      return getState();
+
+    case EXTENT:
+      return getExtent();
+
+    case COLUMNS:
+      return getColumns();
+
+    case SSI_LIST:
+      return getSsiList();
+
+    case SSIO:
+      return getSsio();
+
+    }
+    throw new IllegalStateException();
+  }
+
+  /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
+  public boolean isSet(_Fields field) {
+    if (field == null) {
+      throw new IllegalArgumentException();
+    }
+
+    switch (field) {
+    case CLIENT:
+      return isSetClient();
+    case USER:
+      return isSetUser();
+    case TABLE_ID:
+      return isSetTableId();
+    case AGE:
+      return isSetAge();
+    case IDLE_TIME:
+      return isSetIdleTime();
+    case TYPE:
+      return isSetType();
+    case STATE:
+      return isSetState();
+    case EXTENT:
+      return isSetExtent();
+    case COLUMNS:
+      return isSetColumns();
+    case SSI_LIST:
+      return isSetSsiList();
+    case SSIO:
+      return isSetSsio();
+    }
+    throw new IllegalStateException();
+  }
+
+  @Override
+  public boolean equals(Object that) {
+    if (that == null)
+      return false;
+    if (that instanceof ActiveScan)
+      return this.equals((ActiveScan)that);
+    return false;
+  }
+
+  public boolean equals(ActiveScan that) {
+    if (that == null)
+      return false;
+
+    boolean this_present_client = true && this.isSetClient();
+    boolean that_present_client = true && that.isSetClient();
+    if (this_present_client || that_present_client) {
+      if (!(this_present_client && that_present_client))
+        return false;
+      if (!this.client.equals(that.client))
+        return false;
+    }
+
+    boolean this_present_user = true && this.isSetUser();
+    boolean that_present_user = true && that.isSetUser();
+    if (this_present_user || that_present_user) {
+      if (!(this_present_user && that_present_user))
+        return false;
+      if (!this.user.equals(that.user))
+        return false;
+    }
+
+    boolean this_present_tableId = true && this.isSetTableId();
+    boolean that_present_tableId = true && that.isSetTableId();
+    if (this_present_tableId || that_present_tableId) {
+      if (!(this_present_tableId && that_present_tableId))
+        return false;
+      if (!this.tableId.equals(that.tableId))
+        return false;
+    }
+
+    boolean this_present_age = true;
+    boolean that_present_age = true;
+    if (this_present_age || that_present_age) {
+      if (!(this_present_age && that_present_age))
+        return false;
+      if (this.age != that.age)
+        return false;
+    }
+
+    boolean this_present_idleTime = true;
+    boolean that_present_idleTime = true;
+    if (this_present_idleTime || that_present_idleTime) {
+      if (!(this_present_idleTime && that_present_idleTime))
+        return false;
+      if (this.idleTime != that.idleTime)
+        return false;
+    }
+
+    boolean this_present_type = true && this.isSetType();
+    boolean that_present_type = true && that.isSetType();
+    if (this_present_type || that_present_type) {
+      if (!(this_present_type && that_present_type))
+        return false;
+      if (!this.type.equals(that.type))
+        return false;
+    }
+
+    boolean this_present_state = true && this.isSetState();
+    boolean that_present_state = true && that.isSetState();
+    if (this_present_state || that_present_state) {
+      if (!(this_present_state && that_present_state))
+        return false;
+      if (!this.state.equals(that.state))
+        return false;
+    }
+
+    boolean this_present_extent = true && this.isSetExtent();
+    boolean that_present_extent = true && that.isSetExtent();
+    if (this_present_extent || that_present_extent) {
+      if (!(this_present_extent && that_present_extent))
+        return false;
+      if (!this.extent.equals(that.extent))
+        return false;
+    }
+
+    boolean this_present_columns = true && this.isSetColumns();
+    boolean that_present_columns = true && that.isSetColumns();
+    if (this_present_columns || that_present_columns) {
+      if (!(this_present_columns && that_present_columns))
+        return false;
+      if (!this.columns.equals(that.columns))
+        return false;
+    }
+
+    boolean this_present_ssiList = true && this.isSetSsiList();
+    boolean that_present_ssiList = true && that.isSetSsiList();
+    if (this_present_ssiList || that_present_ssiList) {
+      if (!(this_present_ssiList && that_present_ssiList))
+        return false;
+      if (!this.ssiList.equals(that.ssiList))
+        return false;
+    }
+
+    boolean this_present_ssio = true && this.isSetSsio();
+    boolean that_present_ssio = true && that.isSetSsio();
+    if (this_present_ssio || that_present_ssio) {
+      if (!(this_present_ssio && that_present_ssio))
+        return false;
+      if (!this.ssio.equals(that.ssio))
+        return false;
+    }
+
+    return true;
+  }
+
+  @Override
+  public int hashCode() {
+    return 0;
+  }
+
+  public int compareTo(ActiveScan other) {
+    if (!getClass().equals(other.getClass())) {
+      return getClass().getName().compareTo(other.getClass().getName());
+    }
+
+    int lastComparison = 0;
+    ActiveScan typedOther = (ActiveScan)other;
+
+    lastComparison = Boolean.valueOf(isSetClient()).compareTo(typedOther.isSetClient());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetClient()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.client, typedOther.client);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetUser()).compareTo(typedOther.isSetUser());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetUser()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.user, typedOther.user);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetTableId()).compareTo(typedOther.isSetTableId());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetTableId()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tableId, typedOther.tableId);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetAge()).compareTo(typedOther.isSetAge());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetAge()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.age, typedOther.age);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetIdleTime()).compareTo(typedOther.isSetIdleTime());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetIdleTime()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.idleTime, typedOther.idleTime);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetType()).compareTo(typedOther.isSetType());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetType()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.type, typedOther.type);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetState()).compareTo(typedOther.isSetState());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetState()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.state, typedOther.state);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetExtent()).compareTo(typedOther.isSetExtent());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetExtent()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.extent, typedOther.extent);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetColumns()).compareTo(typedOther.isSetColumns());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetColumns()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.columns, typedOther.columns);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetSsiList()).compareTo(typedOther.isSetSsiList());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetSsiList()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.ssiList, typedOther.ssiList);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetSsio()).compareTo(typedOther.isSetSsio());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetSsio()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.ssio, typedOther.ssio);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    return 0;
+  }
+
+  public _Fields fieldForId(int fieldId) {
+    return _Fields.findByThriftId(fieldId);
+  }
+
+  public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
+    schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
+  }
+
+  public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+    schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
+  }
+
+  @Override
+  public String toString() {
+    StringBuilder sb = new StringBuilder("ActiveScan(");
+    boolean first = true;
+
+    sb.append("client:");
+    if (this.client == null) {
+      sb.append("null");
+    } else {
+      sb.append(this.client);
+    }
+    first = false;
+    if (!first) sb.append(", ");
+    sb.append("user:");
+    if (this.user == null) {
+      sb.append("null");
+    } else {
+      sb.append(this.user);
+    }
+    first = false;
+    if (!first) sb.append(", ");
+    sb.append("tableId:");
+    if (this.tableId == null) {
+      sb.append("null");
+    } else {
+      sb.append(this.tableId);
+    }
+    first = false;
+    if (!first) sb.append(", ");
+    sb.append("age:");
+    sb.append(this.age);
+    first = false;
+    if (!first) sb.append(", ");
+    sb.append("idleTime:");
+    sb.append(this.idleTime);
+    first = false;
+    if (!first) sb.append(", ");
+    sb.append("type:");
+    if (this.type == null) {
+      sb.append("null");
+    } else {
+      sb.append(this.type);
+    }
+    first = false;
+    if (!first) sb.append(", ");
+    sb.append("state:");
+    if (this.state == null) {
+      sb.append("null");
+    } else {
+      sb.append(this.state);
+    }
+    first = false;
+    if (!first) sb.append(", ");
+    sb.append("extent:");
+    if (this.extent == null) {
+      sb.append("null");
+    } else {
+      sb.append(this.extent);
+    }
+    first = false;
+    if (!first) sb.append(", ");
+    sb.append("columns:");
+    if (this.columns == null) {
+      sb.append("null");
+    } else {
+      sb.append(this.columns);
+    }
+    first = false;
+    if (!first) sb.append(", ");
+    sb.append("ssiList:");
+    if (this.ssiList == null) {
+      sb.append("null");
+    } else {
+      sb.append(this.ssiList);
+    }
+    first = false;
+    if (!first) sb.append(", ");
+    sb.append("ssio:");
+    if (this.ssio == null) {
+      sb.append("null");
+    } else {
+      sb.append(this.ssio);
+    }
+    first = false;
+    sb.append(")");
+    return sb.toString();
+  }
+
+  public void validate() throws org.apache.thrift.TException {
+    // check for required fields
+  }
+
+  private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
+    try {
+      write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
+    } catch (org.apache.thrift.TException te) {
+      throw new java.io.IOException(te);
+    }
+  }
+
+  private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
+    try {
+      // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
+      __isset_bit_vector = new BitSet(1);
+      read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
+    } catch (org.apache.thrift.TException te) {
+      throw new java.io.IOException(te);
+    }
+  }
+
+  private static class ActiveScanStandardSchemeFactory implements SchemeFactory {
+    public ActiveScanStandardScheme getScheme() {
+      return new ActiveScanStandardScheme();
+    }
+  }
+
+  private static class ActiveScanStandardScheme extends StandardScheme<ActiveScan> {
+
+    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 = 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 = 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.data.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 _list8 = iprot.readListBegin();
+                struct.columns = new ArrayList<org.apache.accumulo.core.data.thrift.TColumn>(_list8.size);
+                for (int _i9 = 0; _i9 < _list8.size; ++_i9)
+                {
+                  org.apache.accumulo.core.data.thrift.TColumn _elem10; // required
+                  _elem10 = new org.apache.accumulo.core.data.thrift.TColumn();
+                  _elem10.read(iprot);
+                  struct.columns.add(_elem10);
+                }
+                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 _list11 = iprot.readListBegin();
+                struct.ssiList = new ArrayList<org.apache.accumulo.core.data.thrift.IterInfo>(_list11.size);
+                for (int _i12 = 0; _i12 < _list11.size; ++_i12)
+                {
+                  org.apache.accumulo.core.data.thrift.IterInfo _elem13; // required
+                  _elem13 = new org.apache.accumulo.core.data.thrift.IterInfo();
+                  _elem13.read(iprot);
+                  struct.ssiList.add(_elem13);
+                }
+                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 _map14 = iprot.readMapBegin();
+                struct.ssio = new HashMap<String,Map<String,String>>(2*_map14.size);
+                for (int _i15 = 0; _i15 < _map14.size; ++_i15)
+                {
+                  String _key16; // required
+                  Map<String,String> _val17; // required
+                  _key16 = iprot.readString();
+                  {
+                    org.apache.thrift.protocol.TMap _map18 = iprot.readMapBegin();
+                    _val17 = new HashMap<String,String>(2*_map18.size);
+                    for (int _i19 = 0; _i19 < _map18.size; ++_i19)
+                    {
+                      String _key20; // required
+                      String _val21; // required
+                      _key20 = iprot.readString();
+                      _val21 = iprot.readString();
+                      _val17.put(_key20, _val21);
+                    }
+                    iprot.readMapEnd();
+                  }
+                  struct.ssio.put(_key16, _val17);
+                }
+                iprot.readMapEnd();
+              }
+              struct.setSsioIsSet(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();
+    }
+
+    public void write(org.apache.thrift.protocol.TProtocol oprot, ActiveScan struct) throws org.apache.thrift.TException {
+      struct.validate();
+
+      oprot.writeStructBegin(STRUCT_DESC);
+      if (struct.client != null) {
+        oprot.writeFieldBegin(CLIENT_FIELD_DESC);
+        oprot.writeString(struct.client);
+        oprot.writeFieldEnd();
+      }
+      if (struct.user != null) {
+        oprot.writeFieldBegin(USER_FIELD_DESC);
+        oprot.writeString(struct.user);
+        oprot.writeFieldEnd();
+      }
+      if (struct.tableId != null) {
+        oprot.writeFieldBegin(TABLE_ID_FIELD_DESC);
+        oprot.writeString(struct.tableId);
+        oprot.writeFieldEnd();
+      }
+      oprot.writeFieldBegin(AGE_FIELD_DESC);
+      oprot.writeI64(struct.age);
+      oprot.writeFieldEnd();
+      oprot.writeFieldBegin(IDLE_TIME_FIELD_DESC);
+      oprot.writeI64(struct.idleTime);
+      oprot.writeFieldEnd();
+      if (struct.type != null) {
+        oprot.writeFieldBegin(TYPE_FIELD_DESC);
+        oprot.writeI32(struct.type.getValue());
+        oprot.writeFieldEnd();
+      }
+      if (struct.state != null) {
+        oprot.writeFieldBegin(STATE_FIELD_DESC);
+        oprot.writeI32(struct.state.getValue());
+        oprot.writeFieldEnd();
+      }
+      if (struct.extent != null) {
+        oprot.writeFieldBegin(EXTENT_FIELD_DESC);
+        struct.extent.write(oprot);
+        oprot.writeFieldEnd();
+      }
+      if (struct.columns != null) {
+        oprot.writeFieldBegin(COLUMNS_FIELD_DESC);
+        {
+          oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.columns.size()));
+          for (org.apache.accumulo.core.data.thrift.TColumn _iter22 : struct.columns)
+          {
+            _iter22.write(oprot);
+          }
+          oprot.writeListEnd();
+        }
+        oprot.writeFieldEnd();
+      }
+      if (struct.ssiList != null) {
+        oprot.writeFieldBegin(SSI_LIST_FIELD_DESC);
+        {
+          oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.ssiList.size()));
+          for (org.apache.accumulo.core.data.thrift.IterInfo _iter23 : struct.ssiList)
+          {
+            _iter23.write(oprot);
+          }
+          oprot.writeListEnd();
+        }
+        oprot.writeFieldEnd();
+      }
+      if (struct.ssio != null) {
+        oprot.writeFieldBegin(SSIO_FIELD_DESC);
+        {
+          oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, struct.ssio.size()));
+          for (Map.Entry<String, Map<String,String>> _iter24 : struct.ssio.entrySet())
+          {
+            oprot.writeString(_iter24.getKey());
+            {
+              oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, _iter24.getValue().size()));
+              for (Map.Entry<String, String> _iter25 : _iter24.getValue().entrySet())
+              {
+                oprot.writeString(_iter25.getKey());
+                oprot.writeString(_iter25.getValue());
+              }
+              oprot.writeMapEnd();
+            }
+          }
+          oprot.writeMapEnd();
+        }
+        oprot.writeFieldEnd();
+      }
+      oprot.writeFieldStop();
+      oprot.writeStructEnd();
+    }
+
+  }
+
+  private static class ActiveScanTupleSchemeFactory implements SchemeFactory {
+    public ActiveScanTupleScheme getScheme() {
+      return new ActiveScanTupleScheme();
+    }
+  }
+
+  private static class ActiveScanTupleScheme extends TupleScheme<ActiveScan> {
+
+    @Override
+    public void write(org.apache.thrift.protocol.TProtocol prot, ActiveScan struct) throws org.apache.thrift.TException {
+      TTupleProtocol oprot = (TTupleProtocol) prot;
+      BitSet optionals = new BitSet();
+      if (struct.isSetClient()) {
+        optionals.set(0);
+      }
+      if (struct.isSetUser()) {
+        optionals.set(1);
+      }
+      if (struct.isSetTableId()) {
+        optionals.set(2);
+      }
+      if (struct.isSetAge()) {
+        optionals.set(3);
+      }
+      if (struct.isSetIdleTime()) {
+        optionals.set(4);
+      }
+      if (struct.isSetType()) {
+        optionals.set(5);
+      }
+      if (struct.isSetState()) {
+        optionals.set(6);
+      }
+      if (struct.isSetExtent()) {
+        optionals.set(7);
+      }
+      if (struct.isSetColumns()) {
+        optionals.set(8);
+      }
+      if (struct.isSetSsiList()) {
+        optionals.set(9);
+      }
+      if (struct.isSetSsio()) {
+        optionals.set(10);
+      }
+      oprot.writeBitSet(optionals, 11);
+      if (struct.isSetClient()) {
+        oprot.writeString(struct.client);
+      }
+      if (struct.isSetUser()) {
+        oprot.writeString(struct.user);
+      }
+      if (struct.isSetTableId()) {
+        oprot.writeString(struct.tableId);
+      }
+      if (struct.isSetAge()) {
+        oprot.writeI64(struct.age);
+      }
+      if (struct.isSetIdleTime()) {
+        oprot.writeI64(struct.idleTime);
+      }
+      if (struct.isSetType()) {
+        oprot.writeI32(struct.type.getValue());
+      }
+      if (struct.isSetState()) {
+        oprot.writeI32(struct.state.getValue());
+      }
+      if (struct.isSetExtent()) {
+        struct.extent.write(oprot);
+      }
+      if (struct.isSetColumns()) {
+        {
+          oprot.writeI32(struct.columns.size());
+          for (org.apache.accumulo.core.data.thrift.TColumn _iter26 : struct.columns)
+          {
+            _iter26.write(oprot);
+          }
+        }
+      }
+      if (struct.isSetSsiList()) {
+        {
+          oprot.writeI32(struct.ssiList.size());
+          for (org.apache.accumulo.core.data.thrift.IterInfo _iter27 : struct.ssiList)
+          {
+            _iter27.write(oprot);
+          }
+        }
+      }
+      if (struct.isSetSsio()) {
+        {
+          oprot.writeI32(struct.ssio.size());
+          for (Map.Entry<String, Map<String,String>> _iter28 : struct.ssio.entrySet())
+          {
+            oprot.writeString(_iter28.getKey());
+            {
+              oprot.writeI32(_iter28.getValue().size());
+              for (Map.Entry<String, String> _iter29 : _iter28.getValue().entrySet())
+              {
+                oprot.writeString(_iter29.getKey());
+                oprot.writeString(_iter29.getValue());
+              }
+            }
+          }
+        }
+      }
+    }
+
+    @Override
+    public void read(org.apache.thrift.protocol.TProtocol prot, ActiveScan struct) throws org.apache.thrift.TException {
+      TTupleProtocol iprot = (TTupleProtocol) prot;
+      BitSet incoming = iprot.readBitSet(11);
+      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 = ScanType.findByValue(iprot.readI32());
+        struct.setTypeIsSet(true);
+      }
+      if (incoming.get(6)) {
+        struct.state = ScanState.findByValue(iprot.readI32());
+        struct.setStateIsSet(true);
+      }
+      if (incoming.get(7)) {
+        struct.extent = new org.apache.accumulo.core.data.thrift.TKeyExtent();
+        struct.extent.read(iprot);
+        struct.setExtentIsSet(true);
+      }
+      if (incoming.get(8)) {
+        {
+          org.apache.thrift.protocol.TList _list30 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+          struct.columns = new ArrayList<org.apache.accumulo.core.data.thrift.TColumn>(_list30.size);
+          for (int _i31 = 0; _i31 < _list30.size; ++_i31)
+          {
+            org.apache.accumulo.core.data.thrift.TColumn _elem32; // required
+            _elem32 = new org.apache.accumulo.core.data.thrift.TColumn();
+            _elem32.read(iprot);
+            struct.columns.add(_elem32);
+          }
+        }
+        struct.setColumnsIsSet(true);
+      }
+      if (incoming.get(9)) {
+        {
+          org.apache.thrift.protocol.TList _list33 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+          struct.ssiList = new ArrayList<org.apache.accumulo.core.data.thrift.IterInfo>(_list33.size);
+          for (int _i34 = 0; _i34 < _list33.size; ++_i34)
+          {
+            org.apache.accumulo.core.data.thrift.IterInfo _elem35; // required
+            _elem35 = new org.apache.accumulo.core.data.thrift.IterInfo();
+            _elem35.read(iprot);
+            struct.ssiList.add(_elem35);
+          }
+        }
+        struct.setSsiListIsSet(true);
+      }
+      if (incoming.get(10)) {
+        {
+          org.apache.thrift.protocol.TMap _map36 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, iprot.readI32());
+          struct.ssio = new HashMap<String,Map<String,String>>(2*_map36.size);
+          for (int _i37 = 0; _i37 < _map36.size; ++_i37)
+          {
+            String _key38; // required
+            Map<String,String> _val39; // required
+            _key38 = iprot.readString();
+            {
+              org.apache.thrift.protocol.TMap _map40 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+              _val39 = new HashMap<String,String>(2*_map40.size);
+              for (int _i41 = 0; _i41 < _map40.size; ++_i41)
+              {
+                String _key42; // required
+                String _val43; // required
+                _key42 = iprot.readString();
+                _val43 = iprot.readString();
+                _val39.put(_key42, _val43);
+              }
+            }
+            struct.ssio.put(_key38, _val39);
+          }
+        }
+        struct.setSsioIsSet(true);
+      }
+    }
+  }
+
+}
+


Mime
View raw message