incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [2/4] git commit: Thrift generated code.
Date Sat, 28 Mar 2015 15:14:24 GMT
Thrift generated code.


Project: http://git-wip-us.apache.org/repos/asf/incubator-blur/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-blur/commit/55c3abbe
Tree: http://git-wip-us.apache.org/repos/asf/incubator-blur/tree/55c3abbe
Diff: http://git-wip-us.apache.org/repos/asf/incubator-blur/diff/55c3abbe

Branch: refs/heads/master
Commit: 55c3abbefefad1cd2212a6183c4a3c443b282548
Parents: 285ce58
Author: Aaron McCurry <amccurry@gmail.com>
Authored: Sat Mar 28 11:04:17 2015 -0400
Committer: Aaron McCurry <amccurry@gmail.com>
Committed: Sat Mar 28 11:04:17 2015 -0400

----------------------------------------------------------------------
 .../blur/thrift/generated/TableStats.java       | 224 ++++++++++++++++++-
 .../main/scripts/interface/gen-html/Blur.html   |   4 +
 .../blur/thrift/generated/TableStats.java       | 224 ++++++++++++++++++-
 .../main/scripts/interface/gen-js/Blur_types.js |  32 +++
 .../scripts/interface/gen-perl/Blur/Types.pm    |  32 ++-
 .../main/scripts/interface/gen-rb/blur_types.rb |   8 +-
 docs/Blur.html                                  |   4 +
 7 files changed, 518 insertions(+), 10 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/55c3abbe/blur-thrift/src/main/java/org/apache/blur/thrift/generated/TableStats.java
----------------------------------------------------------------------
diff --git a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/TableStats.java b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/TableStats.java
index 94a622e..ec06333 100644
--- a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/TableStats.java
+++ b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/TableStats.java
@@ -59,6 +59,8 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
   private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField BYTES_FIELD_DESC
= new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("bytes", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64,
(short)2);
   private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField RECORD_COUNT_FIELD_DESC
= new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("recordCount", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64,
(short)3);
   private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField ROW_COUNT_FIELD_DESC
= new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("rowCount", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64,
(short)4);
+  private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField SEGMENT_IMPORT_PENDING_COUNT_FIELD_DESC
= new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("segmentImportPendingCount",
org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64, (short)5);
+  private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField SEGMENT_IMPORT_IN_PROGRESS_COUNT_FIELD_DESC
= new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("segmentImportInProgressCount",
org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64, (short)6);
 
   private static final Map<Class<? extends IScheme>, SchemeFactory> schemes =
new HashMap<Class<? extends IScheme>, SchemeFactory>();
   static {
@@ -82,6 +84,14 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
    * The row count.
    */
   public long rowCount; // required
+  /**
+   * The number of pending segment imports for this table.
+   */
+  public long segmentImportPendingCount; // required
+  /**
+   * The number of segment imports in progress for this table.
+   */
+  public long segmentImportInProgressCount; // required
 
   /** The set of fields this struct contains, along with convenience methods for finding
and manipulating them. */
   public enum _Fields implements org.apache.blur.thirdparty.thrift_0_9_0.TFieldIdEnum {
@@ -100,7 +110,15 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
     /**
      * The row count.
      */
-    ROW_COUNT((short)4, "rowCount");
+    ROW_COUNT((short)4, "rowCount"),
+    /**
+     * The number of pending segment imports for this table.
+     */
+    SEGMENT_IMPORT_PENDING_COUNT((short)5, "segmentImportPendingCount"),
+    /**
+     * The number of segment imports in progress for this table.
+     */
+    SEGMENT_IMPORT_IN_PROGRESS_COUNT((short)6, "segmentImportInProgressCount");
 
     private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
 
@@ -123,6 +141,10 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
           return RECORD_COUNT;
         case 4: // ROW_COUNT
           return ROW_COUNT;
+        case 5: // SEGMENT_IMPORT_PENDING_COUNT
+          return SEGMENT_IMPORT_PENDING_COUNT;
+        case 6: // SEGMENT_IMPORT_IN_PROGRESS_COUNT
+          return SEGMENT_IMPORT_IN_PROGRESS_COUNT;
         default:
           return null;
       }
@@ -166,6 +188,8 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
   private static final int __BYTES_ISSET_ID = 0;
   private static final int __RECORDCOUNT_ISSET_ID = 1;
   private static final int __ROWCOUNT_ISSET_ID = 2;
+  private static final int __SEGMENTIMPORTPENDINGCOUNT_ISSET_ID = 3;
+  private static final int __SEGMENTIMPORTINPROGRESSCOUNT_ISSET_ID = 4;
   private byte __isset_bitfield = 0;
   public static final Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData>
metaDataMap;
   static {
@@ -178,18 +202,28 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
         new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64)));
     tmpMap.put(_Fields.ROW_COUNT, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("rowCount",
org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, 
         new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64)));
+    tmpMap.put(_Fields.SEGMENT_IMPORT_PENDING_COUNT, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("segmentImportPendingCount",
org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, 
+        new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64)));
+    tmpMap.put(_Fields.SEGMENT_IMPORT_IN_PROGRESS_COUNT, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("segmentImportInProgressCount",
org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, 
+        new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64)));
     metaDataMap = Collections.unmodifiableMap(tmpMap);
     org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(TableStats.class,
metaDataMap);
   }
 
   public TableStats() {
+    this.segmentImportPendingCount = 0L;
+
+    this.segmentImportInProgressCount = 0L;
+
   }
 
   public TableStats(
     String tableName,
     long bytes,
     long recordCount,
-    long rowCount)
+    long rowCount,
+    long segmentImportPendingCount,
+    long segmentImportInProgressCount)
   {
     this();
     this.tableName = tableName;
@@ -199,6 +233,10 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
     setRecordCountIsSet(true);
     this.rowCount = rowCount;
     setRowCountIsSet(true);
+    this.segmentImportPendingCount = segmentImportPendingCount;
+    setSegmentImportPendingCountIsSet(true);
+    this.segmentImportInProgressCount = segmentImportInProgressCount;
+    setSegmentImportInProgressCountIsSet(true);
   }
 
   /**
@@ -212,6 +250,8 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
     this.bytes = other.bytes;
     this.recordCount = other.recordCount;
     this.rowCount = other.rowCount;
+    this.segmentImportPendingCount = other.segmentImportPendingCount;
+    this.segmentImportInProgressCount = other.segmentImportInProgressCount;
   }
 
   public TableStats deepCopy() {
@@ -227,6 +267,10 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
     this.recordCount = 0;
     setRowCountIsSet(false);
     this.rowCount = 0;
+    this.segmentImportPendingCount = 0L;
+
+    this.segmentImportInProgressCount = 0L;
+
   }
 
   /**
@@ -346,6 +390,64 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
     __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ROWCOUNT_ISSET_ID, value);
   }
 
+  /**
+   * The number of pending segment imports for this table.
+   */
+  public long getSegmentImportPendingCount() {
+    return this.segmentImportPendingCount;
+  }
+
+  /**
+   * The number of pending segment imports for this table.
+   */
+  public TableStats setSegmentImportPendingCount(long segmentImportPendingCount) {
+    this.segmentImportPendingCount = segmentImportPendingCount;
+    setSegmentImportPendingCountIsSet(true);
+    return this;
+  }
+
+  public void unsetSegmentImportPendingCount() {
+    __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __SEGMENTIMPORTPENDINGCOUNT_ISSET_ID);
+  }
+
+  /** Returns true if field segmentImportPendingCount is set (has been assigned a value)
and false otherwise */
+  public boolean isSetSegmentImportPendingCount() {
+    return EncodingUtils.testBit(__isset_bitfield, __SEGMENTIMPORTPENDINGCOUNT_ISSET_ID);
+  }
+
+  public void setSegmentImportPendingCountIsSet(boolean value) {
+    __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __SEGMENTIMPORTPENDINGCOUNT_ISSET_ID,
value);
+  }
+
+  /**
+   * The number of segment imports in progress for this table.
+   */
+  public long getSegmentImportInProgressCount() {
+    return this.segmentImportInProgressCount;
+  }
+
+  /**
+   * The number of segment imports in progress for this table.
+   */
+  public TableStats setSegmentImportInProgressCount(long segmentImportInProgressCount) {
+    this.segmentImportInProgressCount = segmentImportInProgressCount;
+    setSegmentImportInProgressCountIsSet(true);
+    return this;
+  }
+
+  public void unsetSegmentImportInProgressCount() {
+    __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __SEGMENTIMPORTINPROGRESSCOUNT_ISSET_ID);
+  }
+
+  /** Returns true if field segmentImportInProgressCount is set (has been assigned a value)
and false otherwise */
+  public boolean isSetSegmentImportInProgressCount() {
+    return EncodingUtils.testBit(__isset_bitfield, __SEGMENTIMPORTINPROGRESSCOUNT_ISSET_ID);
+  }
+
+  public void setSegmentImportInProgressCountIsSet(boolean value) {
+    __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __SEGMENTIMPORTINPROGRESSCOUNT_ISSET_ID,
value);
+  }
+
   public void setFieldValue(_Fields field, Object value) {
     switch (field) {
     case TABLE_NAME:
@@ -380,6 +482,22 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
       }
       break;
 
+    case SEGMENT_IMPORT_PENDING_COUNT:
+      if (value == null) {
+        unsetSegmentImportPendingCount();
+      } else {
+        setSegmentImportPendingCount((Long)value);
+      }
+      break;
+
+    case SEGMENT_IMPORT_IN_PROGRESS_COUNT:
+      if (value == null) {
+        unsetSegmentImportInProgressCount();
+      } else {
+        setSegmentImportInProgressCount((Long)value);
+      }
+      break;
+
     }
   }
 
@@ -397,6 +515,12 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
     case ROW_COUNT:
       return Long.valueOf(getRowCount());
 
+    case SEGMENT_IMPORT_PENDING_COUNT:
+      return Long.valueOf(getSegmentImportPendingCount());
+
+    case SEGMENT_IMPORT_IN_PROGRESS_COUNT:
+      return Long.valueOf(getSegmentImportInProgressCount());
+
     }
     throw new IllegalStateException();
   }
@@ -416,6 +540,10 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
       return isSetRecordCount();
     case ROW_COUNT:
       return isSetRowCount();
+    case SEGMENT_IMPORT_PENDING_COUNT:
+      return isSetSegmentImportPendingCount();
+    case SEGMENT_IMPORT_IN_PROGRESS_COUNT:
+      return isSetSegmentImportInProgressCount();
     }
     throw new IllegalStateException();
   }
@@ -469,6 +597,24 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
         return false;
     }
 
+    boolean this_present_segmentImportPendingCount = true;
+    boolean that_present_segmentImportPendingCount = true;
+    if (this_present_segmentImportPendingCount || that_present_segmentImportPendingCount)
{
+      if (!(this_present_segmentImportPendingCount && that_present_segmentImportPendingCount))
+        return false;
+      if (this.segmentImportPendingCount != that.segmentImportPendingCount)
+        return false;
+    }
+
+    boolean this_present_segmentImportInProgressCount = true;
+    boolean that_present_segmentImportInProgressCount = true;
+    if (this_present_segmentImportInProgressCount || that_present_segmentImportInProgressCount)
{
+      if (!(this_present_segmentImportInProgressCount && that_present_segmentImportInProgressCount))
+        return false;
+      if (this.segmentImportInProgressCount != that.segmentImportInProgressCount)
+        return false;
+    }
+
     return true;
   }
 
@@ -525,6 +671,26 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
         return lastComparison;
       }
     }
+    lastComparison = Boolean.valueOf(isSetSegmentImportPendingCount()).compareTo(typedOther.isSetSegmentImportPendingCount());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetSegmentImportPendingCount()) {
+      lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.segmentImportPendingCount,
typedOther.segmentImportPendingCount);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetSegmentImportInProgressCount()).compareTo(typedOther.isSetSegmentImportInProgressCount());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetSegmentImportInProgressCount()) {
+      lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.segmentImportInProgressCount,
typedOther.segmentImportInProgressCount);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
     return 0;
   }
 
@@ -564,6 +730,14 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
     sb.append("rowCount:");
     sb.append(this.rowCount);
     first = false;
+    if (!first) sb.append(", ");
+    sb.append("segmentImportPendingCount:");
+    sb.append(this.segmentImportPendingCount);
+    first = false;
+    if (!first) sb.append(", ");
+    sb.append("segmentImportInProgressCount:");
+    sb.append(this.segmentImportInProgressCount);
+    first = false;
     sb.append(")");
     return sb.toString();
   }
@@ -641,6 +815,22 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
               org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot,
schemeField.type);
             }
             break;
+          case 5: // SEGMENT_IMPORT_PENDING_COUNT
+            if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64)
{
+              struct.segmentImportPendingCount = iprot.readI64();
+              struct.setSegmentImportPendingCountIsSet(true);
+            } else { 
+              org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot,
schemeField.type);
+            }
+            break;
+          case 6: // SEGMENT_IMPORT_IN_PROGRESS_COUNT
+            if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64)
{
+              struct.segmentImportInProgressCount = iprot.readI64();
+              struct.setSegmentImportInProgressCountIsSet(true);
+            } else { 
+              org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot,
schemeField.type);
+            }
+            break;
           default:
             org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type);
         }
@@ -670,6 +860,12 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
       oprot.writeFieldBegin(ROW_COUNT_FIELD_DESC);
       oprot.writeI64(struct.rowCount);
       oprot.writeFieldEnd();
+      oprot.writeFieldBegin(SEGMENT_IMPORT_PENDING_COUNT_FIELD_DESC);
+      oprot.writeI64(struct.segmentImportPendingCount);
+      oprot.writeFieldEnd();
+      oprot.writeFieldBegin(SEGMENT_IMPORT_IN_PROGRESS_COUNT_FIELD_DESC);
+      oprot.writeI64(struct.segmentImportInProgressCount);
+      oprot.writeFieldEnd();
       oprot.writeFieldStop();
       oprot.writeStructEnd();
     }
@@ -700,7 +896,13 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
       if (struct.isSetRowCount()) {
         optionals.set(3);
       }
-      oprot.writeBitSet(optionals, 4);
+      if (struct.isSetSegmentImportPendingCount()) {
+        optionals.set(4);
+      }
+      if (struct.isSetSegmentImportInProgressCount()) {
+        optionals.set(5);
+      }
+      oprot.writeBitSet(optionals, 6);
       if (struct.isSetTableName()) {
         oprot.writeString(struct.tableName);
       }
@@ -713,12 +915,18 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
       if (struct.isSetRowCount()) {
         oprot.writeI64(struct.rowCount);
       }
+      if (struct.isSetSegmentImportPendingCount()) {
+        oprot.writeI64(struct.segmentImportPendingCount);
+      }
+      if (struct.isSetSegmentImportInProgressCount()) {
+        oprot.writeI64(struct.segmentImportInProgressCount);
+      }
     }
 
     @Override
     public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, TableStats
struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
       TTupleProtocol iprot = (TTupleProtocol) prot;
-      BitSet incoming = iprot.readBitSet(4);
+      BitSet incoming = iprot.readBitSet(6);
       if (incoming.get(0)) {
         struct.tableName = iprot.readString();
         struct.setTableNameIsSet(true);
@@ -735,6 +943,14 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
         struct.rowCount = iprot.readI64();
         struct.setRowCountIsSet(true);
       }
+      if (incoming.get(4)) {
+        struct.segmentImportPendingCount = iprot.readI64();
+        struct.setSegmentImportPendingCountIsSet(true);
+      }
+      if (incoming.get(5)) {
+        struct.segmentImportInProgressCount = iprot.readI64();
+        struct.setSegmentImportInProgressCountIsSet(true);
+      }
     }
   }
 

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/55c3abbe/distribution/src/main/scripts/interface/gen-html/Blur.html
----------------------------------------------------------------------
diff --git a/distribution/src/main/scripts/interface/gen-html/Blur.html b/distribution/src/main/scripts/interface/gen-html/Blur.html
index 4bf71fd..16dc9fd 100644
--- a/distribution/src/main/scripts/interface/gen-html/Blur.html
+++ b/distribution/src/main/scripts/interface/gen-html/Blur.html
@@ -538,6 +538,10 @@ shards that are complete, etc.
 </td><td>default</td><td></td></tr>
 <tr><td>4</td><td>rowCount</td><td><code>i64</code></td><td>The
row count.
 </td><td>default</td><td></td></tr>
+<tr><td>5</td><td>segmentImportPendingCount</td><td><code>i64</code></td><td>The
number of pending segment imports for this table.
+</td><td>default</td><td>0</td></tr>
+<tr><td>6</td><td>segmentImportInProgressCount</td><td><code>i64</code></td><td>The
number of segment imports in progress for this table.
+</td><td>default</td><td>0</td></tr>
 </table><br/>TableStats holds the statistics for a given table.
 <br/></div><div class="definition"><h3 id="Struct_ColumnDefinition">Struct:
ColumnDefinition</h3>
 <table class="table-bordered table-striped table-condensed"><thead><th>Key</th><th>Field</th><th>Type</th><th>Description</th><th>Requiredness</th><th>Default
value</th></thead>

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/55c3abbe/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/TableStats.java
----------------------------------------------------------------------
diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/TableStats.java
b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/TableStats.java
index 94a622e..ec06333 100644
--- a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/TableStats.java
+++ b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/TableStats.java
@@ -59,6 +59,8 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
   private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField BYTES_FIELD_DESC
= new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("bytes", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64,
(short)2);
   private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField RECORD_COUNT_FIELD_DESC
= new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("recordCount", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64,
(short)3);
   private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField ROW_COUNT_FIELD_DESC
= new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("rowCount", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64,
(short)4);
+  private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField SEGMENT_IMPORT_PENDING_COUNT_FIELD_DESC
= new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("segmentImportPendingCount",
org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64, (short)5);
+  private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField SEGMENT_IMPORT_IN_PROGRESS_COUNT_FIELD_DESC
= new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("segmentImportInProgressCount",
org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64, (short)6);
 
   private static final Map<Class<? extends IScheme>, SchemeFactory> schemes =
new HashMap<Class<? extends IScheme>, SchemeFactory>();
   static {
@@ -82,6 +84,14 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
    * The row count.
    */
   public long rowCount; // required
+  /**
+   * The number of pending segment imports for this table.
+   */
+  public long segmentImportPendingCount; // required
+  /**
+   * The number of segment imports in progress for this table.
+   */
+  public long segmentImportInProgressCount; // required
 
   /** The set of fields this struct contains, along with convenience methods for finding
and manipulating them. */
   public enum _Fields implements org.apache.blur.thirdparty.thrift_0_9_0.TFieldIdEnum {
@@ -100,7 +110,15 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
     /**
      * The row count.
      */
-    ROW_COUNT((short)4, "rowCount");
+    ROW_COUNT((short)4, "rowCount"),
+    /**
+     * The number of pending segment imports for this table.
+     */
+    SEGMENT_IMPORT_PENDING_COUNT((short)5, "segmentImportPendingCount"),
+    /**
+     * The number of segment imports in progress for this table.
+     */
+    SEGMENT_IMPORT_IN_PROGRESS_COUNT((short)6, "segmentImportInProgressCount");
 
     private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
 
@@ -123,6 +141,10 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
           return RECORD_COUNT;
         case 4: // ROW_COUNT
           return ROW_COUNT;
+        case 5: // SEGMENT_IMPORT_PENDING_COUNT
+          return SEGMENT_IMPORT_PENDING_COUNT;
+        case 6: // SEGMENT_IMPORT_IN_PROGRESS_COUNT
+          return SEGMENT_IMPORT_IN_PROGRESS_COUNT;
         default:
           return null;
       }
@@ -166,6 +188,8 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
   private static final int __BYTES_ISSET_ID = 0;
   private static final int __RECORDCOUNT_ISSET_ID = 1;
   private static final int __ROWCOUNT_ISSET_ID = 2;
+  private static final int __SEGMENTIMPORTPENDINGCOUNT_ISSET_ID = 3;
+  private static final int __SEGMENTIMPORTINPROGRESSCOUNT_ISSET_ID = 4;
   private byte __isset_bitfield = 0;
   public static final Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData>
metaDataMap;
   static {
@@ -178,18 +202,28 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
         new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64)));
     tmpMap.put(_Fields.ROW_COUNT, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("rowCount",
org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, 
         new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64)));
+    tmpMap.put(_Fields.SEGMENT_IMPORT_PENDING_COUNT, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("segmentImportPendingCount",
org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, 
+        new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64)));
+    tmpMap.put(_Fields.SEGMENT_IMPORT_IN_PROGRESS_COUNT, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("segmentImportInProgressCount",
org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, 
+        new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64)));
     metaDataMap = Collections.unmodifiableMap(tmpMap);
     org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(TableStats.class,
metaDataMap);
   }
 
   public TableStats() {
+    this.segmentImportPendingCount = 0L;
+
+    this.segmentImportInProgressCount = 0L;
+
   }
 
   public TableStats(
     String tableName,
     long bytes,
     long recordCount,
-    long rowCount)
+    long rowCount,
+    long segmentImportPendingCount,
+    long segmentImportInProgressCount)
   {
     this();
     this.tableName = tableName;
@@ -199,6 +233,10 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
     setRecordCountIsSet(true);
     this.rowCount = rowCount;
     setRowCountIsSet(true);
+    this.segmentImportPendingCount = segmentImportPendingCount;
+    setSegmentImportPendingCountIsSet(true);
+    this.segmentImportInProgressCount = segmentImportInProgressCount;
+    setSegmentImportInProgressCountIsSet(true);
   }
 
   /**
@@ -212,6 +250,8 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
     this.bytes = other.bytes;
     this.recordCount = other.recordCount;
     this.rowCount = other.rowCount;
+    this.segmentImportPendingCount = other.segmentImportPendingCount;
+    this.segmentImportInProgressCount = other.segmentImportInProgressCount;
   }
 
   public TableStats deepCopy() {
@@ -227,6 +267,10 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
     this.recordCount = 0;
     setRowCountIsSet(false);
     this.rowCount = 0;
+    this.segmentImportPendingCount = 0L;
+
+    this.segmentImportInProgressCount = 0L;
+
   }
 
   /**
@@ -346,6 +390,64 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
     __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ROWCOUNT_ISSET_ID, value);
   }
 
+  /**
+   * The number of pending segment imports for this table.
+   */
+  public long getSegmentImportPendingCount() {
+    return this.segmentImportPendingCount;
+  }
+
+  /**
+   * The number of pending segment imports for this table.
+   */
+  public TableStats setSegmentImportPendingCount(long segmentImportPendingCount) {
+    this.segmentImportPendingCount = segmentImportPendingCount;
+    setSegmentImportPendingCountIsSet(true);
+    return this;
+  }
+
+  public void unsetSegmentImportPendingCount() {
+    __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __SEGMENTIMPORTPENDINGCOUNT_ISSET_ID);
+  }
+
+  /** Returns true if field segmentImportPendingCount is set (has been assigned a value)
and false otherwise */
+  public boolean isSetSegmentImportPendingCount() {
+    return EncodingUtils.testBit(__isset_bitfield, __SEGMENTIMPORTPENDINGCOUNT_ISSET_ID);
+  }
+
+  public void setSegmentImportPendingCountIsSet(boolean value) {
+    __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __SEGMENTIMPORTPENDINGCOUNT_ISSET_ID,
value);
+  }
+
+  /**
+   * The number of segment imports in progress for this table.
+   */
+  public long getSegmentImportInProgressCount() {
+    return this.segmentImportInProgressCount;
+  }
+
+  /**
+   * The number of segment imports in progress for this table.
+   */
+  public TableStats setSegmentImportInProgressCount(long segmentImportInProgressCount) {
+    this.segmentImportInProgressCount = segmentImportInProgressCount;
+    setSegmentImportInProgressCountIsSet(true);
+    return this;
+  }
+
+  public void unsetSegmentImportInProgressCount() {
+    __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __SEGMENTIMPORTINPROGRESSCOUNT_ISSET_ID);
+  }
+
+  /** Returns true if field segmentImportInProgressCount is set (has been assigned a value)
and false otherwise */
+  public boolean isSetSegmentImportInProgressCount() {
+    return EncodingUtils.testBit(__isset_bitfield, __SEGMENTIMPORTINPROGRESSCOUNT_ISSET_ID);
+  }
+
+  public void setSegmentImportInProgressCountIsSet(boolean value) {
+    __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __SEGMENTIMPORTINPROGRESSCOUNT_ISSET_ID,
value);
+  }
+
   public void setFieldValue(_Fields field, Object value) {
     switch (field) {
     case TABLE_NAME:
@@ -380,6 +482,22 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
       }
       break;
 
+    case SEGMENT_IMPORT_PENDING_COUNT:
+      if (value == null) {
+        unsetSegmentImportPendingCount();
+      } else {
+        setSegmentImportPendingCount((Long)value);
+      }
+      break;
+
+    case SEGMENT_IMPORT_IN_PROGRESS_COUNT:
+      if (value == null) {
+        unsetSegmentImportInProgressCount();
+      } else {
+        setSegmentImportInProgressCount((Long)value);
+      }
+      break;
+
     }
   }
 
@@ -397,6 +515,12 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
     case ROW_COUNT:
       return Long.valueOf(getRowCount());
 
+    case SEGMENT_IMPORT_PENDING_COUNT:
+      return Long.valueOf(getSegmentImportPendingCount());
+
+    case SEGMENT_IMPORT_IN_PROGRESS_COUNT:
+      return Long.valueOf(getSegmentImportInProgressCount());
+
     }
     throw new IllegalStateException();
   }
@@ -416,6 +540,10 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
       return isSetRecordCount();
     case ROW_COUNT:
       return isSetRowCount();
+    case SEGMENT_IMPORT_PENDING_COUNT:
+      return isSetSegmentImportPendingCount();
+    case SEGMENT_IMPORT_IN_PROGRESS_COUNT:
+      return isSetSegmentImportInProgressCount();
     }
     throw new IllegalStateException();
   }
@@ -469,6 +597,24 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
         return false;
     }
 
+    boolean this_present_segmentImportPendingCount = true;
+    boolean that_present_segmentImportPendingCount = true;
+    if (this_present_segmentImportPendingCount || that_present_segmentImportPendingCount)
{
+      if (!(this_present_segmentImportPendingCount && that_present_segmentImportPendingCount))
+        return false;
+      if (this.segmentImportPendingCount != that.segmentImportPendingCount)
+        return false;
+    }
+
+    boolean this_present_segmentImportInProgressCount = true;
+    boolean that_present_segmentImportInProgressCount = true;
+    if (this_present_segmentImportInProgressCount || that_present_segmentImportInProgressCount)
{
+      if (!(this_present_segmentImportInProgressCount && that_present_segmentImportInProgressCount))
+        return false;
+      if (this.segmentImportInProgressCount != that.segmentImportInProgressCount)
+        return false;
+    }
+
     return true;
   }
 
@@ -525,6 +671,26 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
         return lastComparison;
       }
     }
+    lastComparison = Boolean.valueOf(isSetSegmentImportPendingCount()).compareTo(typedOther.isSetSegmentImportPendingCount());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetSegmentImportPendingCount()) {
+      lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.segmentImportPendingCount,
typedOther.segmentImportPendingCount);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetSegmentImportInProgressCount()).compareTo(typedOther.isSetSegmentImportInProgressCount());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetSegmentImportInProgressCount()) {
+      lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.segmentImportInProgressCount,
typedOther.segmentImportInProgressCount);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
     return 0;
   }
 
@@ -564,6 +730,14 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
     sb.append("rowCount:");
     sb.append(this.rowCount);
     first = false;
+    if (!first) sb.append(", ");
+    sb.append("segmentImportPendingCount:");
+    sb.append(this.segmentImportPendingCount);
+    first = false;
+    if (!first) sb.append(", ");
+    sb.append("segmentImportInProgressCount:");
+    sb.append(this.segmentImportInProgressCount);
+    first = false;
     sb.append(")");
     return sb.toString();
   }
@@ -641,6 +815,22 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
               org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot,
schemeField.type);
             }
             break;
+          case 5: // SEGMENT_IMPORT_PENDING_COUNT
+            if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64)
{
+              struct.segmentImportPendingCount = iprot.readI64();
+              struct.setSegmentImportPendingCountIsSet(true);
+            } else { 
+              org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot,
schemeField.type);
+            }
+            break;
+          case 6: // SEGMENT_IMPORT_IN_PROGRESS_COUNT
+            if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64)
{
+              struct.segmentImportInProgressCount = iprot.readI64();
+              struct.setSegmentImportInProgressCountIsSet(true);
+            } else { 
+              org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot,
schemeField.type);
+            }
+            break;
           default:
             org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type);
         }
@@ -670,6 +860,12 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
       oprot.writeFieldBegin(ROW_COUNT_FIELD_DESC);
       oprot.writeI64(struct.rowCount);
       oprot.writeFieldEnd();
+      oprot.writeFieldBegin(SEGMENT_IMPORT_PENDING_COUNT_FIELD_DESC);
+      oprot.writeI64(struct.segmentImportPendingCount);
+      oprot.writeFieldEnd();
+      oprot.writeFieldBegin(SEGMENT_IMPORT_IN_PROGRESS_COUNT_FIELD_DESC);
+      oprot.writeI64(struct.segmentImportInProgressCount);
+      oprot.writeFieldEnd();
       oprot.writeFieldStop();
       oprot.writeStructEnd();
     }
@@ -700,7 +896,13 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
       if (struct.isSetRowCount()) {
         optionals.set(3);
       }
-      oprot.writeBitSet(optionals, 4);
+      if (struct.isSetSegmentImportPendingCount()) {
+        optionals.set(4);
+      }
+      if (struct.isSetSegmentImportInProgressCount()) {
+        optionals.set(5);
+      }
+      oprot.writeBitSet(optionals, 6);
       if (struct.isSetTableName()) {
         oprot.writeString(struct.tableName);
       }
@@ -713,12 +915,18 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
       if (struct.isSetRowCount()) {
         oprot.writeI64(struct.rowCount);
       }
+      if (struct.isSetSegmentImportPendingCount()) {
+        oprot.writeI64(struct.segmentImportPendingCount);
+      }
+      if (struct.isSetSegmentImportInProgressCount()) {
+        oprot.writeI64(struct.segmentImportInProgressCount);
+      }
     }
 
     @Override
     public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, TableStats
struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
       TTupleProtocol iprot = (TTupleProtocol) prot;
-      BitSet incoming = iprot.readBitSet(4);
+      BitSet incoming = iprot.readBitSet(6);
       if (incoming.get(0)) {
         struct.tableName = iprot.readString();
         struct.setTableNameIsSet(true);
@@ -735,6 +943,14 @@ public class TableStats implements org.apache.blur.thirdparty.thrift_0_9_0.TBase
         struct.rowCount = iprot.readI64();
         struct.setRowCountIsSet(true);
       }
+      if (incoming.get(4)) {
+        struct.segmentImportPendingCount = iprot.readI64();
+        struct.setSegmentImportPendingCountIsSet(true);
+      }
+      if (incoming.get(5)) {
+        struct.segmentImportInProgressCount = iprot.readI64();
+        struct.setSegmentImportInProgressCountIsSet(true);
+      }
     }
   }
 

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/55c3abbe/distribution/src/main/scripts/interface/gen-js/Blur_types.js
----------------------------------------------------------------------
diff --git a/distribution/src/main/scripts/interface/gen-js/Blur_types.js b/distribution/src/main/scripts/interface/gen-js/Blur_types.js
index 3851678..8c07ed9 100644
--- a/distribution/src/main/scripts/interface/gen-js/Blur_types.js
+++ b/distribution/src/main/scripts/interface/gen-js/Blur_types.js
@@ -2744,6 +2744,8 @@ TableStats = function(args) {
   this.bytes = null;
   this.recordCount = null;
   this.rowCount = null;
+  this.segmentImportPendingCount = 0;
+  this.segmentImportInProgressCount = 0;
   if (args) {
     if (args.tableName !== undefined) {
       this.tableName = args.tableName;
@@ -2757,6 +2759,12 @@ TableStats = function(args) {
     if (args.rowCount !== undefined) {
       this.rowCount = args.rowCount;
     }
+    if (args.segmentImportPendingCount !== undefined) {
+      this.segmentImportPendingCount = args.segmentImportPendingCount;
+    }
+    if (args.segmentImportInProgressCount !== undefined) {
+      this.segmentImportInProgressCount = args.segmentImportInProgressCount;
+    }
   }
 };
 TableStats.prototype = {};
@@ -2801,6 +2809,20 @@ TableStats.prototype.read = function(input) {
         input.skip(ftype);
       }
       break;
+      case 5:
+      if (ftype == Thrift.Type.I64) {
+        this.segmentImportPendingCount = input.readI64().value;
+      } else {
+        input.skip(ftype);
+      }
+      break;
+      case 6:
+      if (ftype == Thrift.Type.I64) {
+        this.segmentImportInProgressCount = input.readI64().value;
+      } else {
+        input.skip(ftype);
+      }
+      break;
       default:
         input.skip(ftype);
     }
@@ -2832,6 +2854,16 @@ TableStats.prototype.write = function(output) {
     output.writeI64(this.rowCount);
     output.writeFieldEnd();
   }
+  if (this.segmentImportPendingCount !== null && this.segmentImportPendingCount !==
undefined) {
+    output.writeFieldBegin('segmentImportPendingCount', Thrift.Type.I64, 5);
+    output.writeI64(this.segmentImportPendingCount);
+    output.writeFieldEnd();
+  }
+  if (this.segmentImportInProgressCount !== null && this.segmentImportInProgressCount
!== undefined) {
+    output.writeFieldBegin('segmentImportInProgressCount', Thrift.Type.I64, 6);
+    output.writeI64(this.segmentImportInProgressCount);
+    output.writeFieldEnd();
+  }
   output.writeFieldStop();
   output.writeStructEnd();
   return;

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/55c3abbe/distribution/src/main/scripts/interface/gen-perl/Blur/Types.pm
----------------------------------------------------------------------
diff --git a/distribution/src/main/scripts/interface/gen-perl/Blur/Types.pm b/distribution/src/main/scripts/interface/gen-perl/Blur/Types.pm
index 28e5206..32db537 100644
--- a/distribution/src/main/scripts/interface/gen-perl/Blur/Types.pm
+++ b/distribution/src/main/scripts/interface/gen-perl/Blur/Types.pm
@@ -2928,7 +2928,7 @@ sub write {
 
 package Blur::TableStats;
 use base qw(Class::Accessor);
-Blur::TableStats->mk_accessors( qw( tableName bytes recordCount rowCount ) );
+Blur::TableStats->mk_accessors( qw( tableName bytes recordCount rowCount segmentImportPendingCount
segmentImportInProgressCount ) );
 
 sub new {
   my $classname = shift;
@@ -2938,6 +2938,8 @@ sub new {
   $self->{bytes} = undef;
   $self->{recordCount} = undef;
   $self->{rowCount} = undef;
+  $self->{segmentImportPendingCount} = 0;
+  $self->{segmentImportInProgressCount} = 0;
   if (UNIVERSAL::isa($vals,'HASH')) {
     if (defined $vals->{tableName}) {
       $self->{tableName} = $vals->{tableName};
@@ -2951,6 +2953,12 @@ sub new {
     if (defined $vals->{rowCount}) {
       $self->{rowCount} = $vals->{rowCount};
     }
+    if (defined $vals->{segmentImportPendingCount}) {
+      $self->{segmentImportPendingCount} = $vals->{segmentImportPendingCount};
+    }
+    if (defined $vals->{segmentImportInProgressCount}) {
+      $self->{segmentImportInProgressCount} = $vals->{segmentImportInProgressCount};
+    }
   }
   return bless ($self, $classname);
 }
@@ -2998,6 +3006,18 @@ sub read {
         $xfer += $input->skip($ftype);
       }
       last; };
+      /^5$/ && do{      if ($ftype == TType::I64) {
+        $xfer += $input->readI64(\$self->{segmentImportPendingCount});
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+      /^6$/ && do{      if ($ftype == TType::I64) {
+        $xfer += $input->readI64(\$self->{segmentImportInProgressCount});
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
         $xfer += $input->skip($ftype);
     }
     $xfer += $input->readFieldEnd();
@@ -3030,6 +3050,16 @@ sub write {
     $xfer += $output->writeI64($self->{rowCount});
     $xfer += $output->writeFieldEnd();
   }
+  if (defined $self->{segmentImportPendingCount}) {
+    $xfer += $output->writeFieldBegin('segmentImportPendingCount', TType::I64, 5);
+    $xfer += $output->writeI64($self->{segmentImportPendingCount});
+    $xfer += $output->writeFieldEnd();
+  }
+  if (defined $self->{segmentImportInProgressCount}) {
+    $xfer += $output->writeFieldBegin('segmentImportInProgressCount', TType::I64, 6);
+    $xfer += $output->writeI64($self->{segmentImportInProgressCount});
+    $xfer += $output->writeFieldEnd();
+  }
   $xfer += $output->writeFieldStop();
   $xfer += $output->writeStructEnd();
   return $xfer;

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/55c3abbe/distribution/src/main/scripts/interface/gen-rb/blur_types.rb
----------------------------------------------------------------------
diff --git a/distribution/src/main/scripts/interface/gen-rb/blur_types.rb b/distribution/src/main/scripts/interface/gen-rb/blur_types.rb
index db739f1..902c566 100644
--- a/distribution/src/main/scripts/interface/gen-rb/blur_types.rb
+++ b/distribution/src/main/scripts/interface/gen-rb/blur_types.rb
@@ -795,6 +795,8 @@ module Blur
     BYTES = 2
     RECORDCOUNT = 3
     ROWCOUNT = 4
+    SEGMENTIMPORTPENDINGCOUNT = 5
+    SEGMENTIMPORTINPROGRESSCOUNT = 6
 
     FIELDS = {
       # The table name.
@@ -804,7 +806,11 @@ module Blur
       # The record count.
       RECORDCOUNT => {:type => ::Thrift::Types::I64, :name => 'recordCount'},
       # The row count.
-      ROWCOUNT => {:type => ::Thrift::Types::I64, :name => 'rowCount'}
+      ROWCOUNT => {:type => ::Thrift::Types::I64, :name => 'rowCount'},
+      # The number of pending segment imports for this table.
+      SEGMENTIMPORTPENDINGCOUNT => {:type => ::Thrift::Types::I64, :name => 'segmentImportPendingCount',
:default => 0},
+      # The number of segment imports in progress for this table.
+      SEGMENTIMPORTINPROGRESSCOUNT => {:type => ::Thrift::Types::I64, :name => 'segmentImportInProgressCount',
:default => 0}
     }
 
     def struct_fields; FIELDS; end

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/55c3abbe/docs/Blur.html
----------------------------------------------------------------------
diff --git a/docs/Blur.html b/docs/Blur.html
index 9fe4dac..11ed668 100644
--- a/docs/Blur.html
+++ b/docs/Blur.html
@@ -596,6 +596,10 @@ shards that are complete, etc.
 </td><td>default</td><td></td></tr>
 <tr><td>4</td><td>rowCount</td><td><code>i64</code></td><td>The
row count.
 </td><td>default</td><td></td></tr>
+<tr><td>5</td><td>segmentImportPendingCount</td><td><code>i64</code></td><td>The
number of pending segment imports for this table.
+</td><td>default</td><td>0</td></tr>
+<tr><td>6</td><td>segmentImportInProgressCount</td><td><code>i64</code></td><td>The
number of segment imports in progress for this table.
+</td><td>default</td><td>0</td></tr>
 </table><br/>TableStats holds the statistics for a given table.
 <br/></p></section><section><div class="page-header"><h3
id="Struct_ColumnDefinition">Struct: ColumnDefinition</h3></div><p class="lead">
 <table class="table-bordered table-striped table-condensed"><thead><th>Key</th><th>Field</th><th>Type</th><th>Description</th><th>Requiredness</th><th>Default
value</th></thead>


Mime
View raw message