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 <[email protected]> Authored: Sat Mar 28 11:04:17 2015 -0400 Committer: Aaron McCurry <[email protected]> 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>
