http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/94d579dd/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 9b3f3d3..db28370 100644 --- a/distribution/src/main/scripts/interface/gen-html/Blur.html +++ b/distribution/src/main/scripts/interface/gen-html/Blur.html @@ -22,6 +22,7 @@ <li><a href="Blur.html#Fn_Blur_enableTable">enableTable</a></li> <li><a href="Blur.html#Fn_Blur_enqueueMutate">enqueueMutate</a></li> <li><a href="Blur.html#Fn_Blur_enqueueMutateBatch">enqueueMutateBatch</a></li> +<li><a href="Blur.html#Fn_Blur_execute">execute</a></li> <li><a href="Blur.html#Fn_Blur_fetchRow">fetchRow</a></li> <li><a href="Blur.html#Fn_Blur_fetchRowBatch">fetchRowBatch</a></li> <li><a href="Blur.html#Fn_Blur_isInSafeMode">isInSafeMode</a></li> @@ -57,7 +58,8 @@ <li><a href="Blur.html#Fn_Blur_traceRequestList">traceRequestList</a></li> </ul> </td> -<td><a href="Blur.html#Struct_BlurException">BlurException</a><br/> +<td><a href="Blur.html#Struct_Arguments">Arguments</a><br/> +<a href="Blur.html#Struct_BlurException">BlurException</a><br/> <a href="Blur.html#Struct_BlurQuery">BlurQuery</a><br/> <a href="Blur.html#Struct_BlurQueryStatus">BlurQueryStatus</a><br/> <a href="Blur.html#Struct_BlurResult">BlurResult</a><br/> @@ -78,6 +80,7 @@ <a href="Blur.html#Struct_Record">Record</a><br/> <a href="Blur.html#Struct_RecordMutation">RecordMutation</a><br/> <a href="Blur.html#Enum_RecordMutationType">RecordMutationType</a><br/> +<a href="Blur.html#Struct_Response">Response</a><br/> <a href="Blur.html#Struct_Row">Row</a><br/> <a href="Blur.html#Struct_RowMutation">RowMutation</a><br/> <a href="Blur.html#Enum_RowMutationType">RowMutationType</a><br/> @@ -91,6 +94,7 @@ <a href="Blur.html#Struct_TableDescriptor">TableDescriptor</a><br/> <a href="Blur.html#Struct_TableStats">TableStats</a><br/> <a href="Blur.html#Struct_User">User</a><br/> +<a href="Blur.html#Struct_Value">Value</a><br/> </td> <td></code></td> </tr></table> @@ -574,11 +578,34 @@ be family dot column, "family.column". <tr><td>4</td><td>doubleMap</td><td><code>map<<code>string</code>, <code>double</code>></code></td><td>map of double values emitted by the Metric. </td><td>default</td><td></td></tr> </table><br/>The Metric will hold all the information for a given Metric. -<br/></div><hr/><h2 id="Services">Services</h2> +<br/></div><div class="definition"><h3 id="Struct_Value">Struct: Value</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> +<tr><td>1</td><td>stringValue</td><td><code>string</code></td><td></td><td>default</td><td></td></tr> +<tr><td>2</td><td>intValue</td><td><code>i32</code></td><td></td><td>default</td><td></td></tr> +<tr><td>3</td><td>shortValue</td><td><code>i16</code></td><td></td><td>default</td><td></td></tr> +<tr><td>4</td><td>longValue</td><td><code>i64</code></td><td></td><td>default</td><td></td></tr> +<tr><td>5</td><td>doubleValue</td><td><code>double</code></td><td></td><td>default</td><td></td></tr> +<tr><td>6</td><td>floatValue</td><td><code>double</code></td><td></td><td>default</td><td></td></tr> +<tr><td>7</td><td>binaryValue</td><td><code>binary</code></td><td></td><td>default</td><td></td></tr> +<tr><td>8</td><td>booleanValue</td><td><code>bool</code></td><td></td><td>default</td><td></td></tr> +<tr><td>9</td><td>nullValue</td><td><code>bool</code></td><td></td><td>default</td><td></td></tr> +</table><br/></div><div class="definition"><h3 id="Struct_Response">Struct: Response</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> +<tr><td>1</td><td>shardToValue</td><td><code>map<<code>string</code>, <code><a href="Blur.html#Struct_Value">Value</a></code>></code></td><td></td><td>default</td><td></td></tr> +<tr><td>2</td><td>value</td><td><code><a href="Blur.html#Struct_Value">Value</a></code></td><td></td><td>default</td><td></td></tr> +</table><br/></div><div class="definition"><h3 id="Struct_Arguments">Struct: Arguments</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> +<tr><td>1</td><td>values</td><td><code>map<<code>string</code>, <code><a href="Blur.html#Struct_Value">Value</a></code>></code></td><td></td><td>default</td><td></td></tr> +</table><br/></div><hr/><h2 id="Services">Services</h2> <h3 id="Svc_Blur">Service: Blur</h3> The Blur service API. This API is the same for both controller servers as well as shards servers. Each of the methods are documented. -<br/><div class="definition"><h4 id="Fn_Blur_createTable">Function: Blur.createTable</h4> +<br/><div class="definition"><h4 id="Fn_Blur_execute">Function: Blur.execute</h4> +<pre><code><a href="Blur.html#Struct_Response">Response</a></code> execute(<code>string</code> table, + <code>string</code> commandName, + <code><a href="Blur.html#Struct_Arguments">Arguments</a></code> arguments) + throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code> +</pre></div><div class="definition"><h4 id="Fn_Blur_createTable">Function: Blur.createTable</h4> <pre><code>void</code> createTable(<code><a href="Blur.html#Struct_TableDescriptor">TableDescriptor</a></code> tableDescriptor) throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code> </pre>Creates a table with the given TableDescriptor.
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/94d579dd/distribution/src/main/scripts/interface/gen-html/index.html ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-html/index.html b/distribution/src/main/scripts/interface/gen-html/index.html index b9834e3..45edf65 100644 --- a/distribution/src/main/scripts/interface/gen-html/index.html +++ b/distribution/src/main/scripts/interface/gen-html/index.html @@ -18,6 +18,7 @@ <li><a href="Blur.html#Fn_Blur_enableTable">enableTable</a></li> <li><a href="Blur.html#Fn_Blur_enqueueMutate">enqueueMutate</a></li> <li><a href="Blur.html#Fn_Blur_enqueueMutateBatch">enqueueMutateBatch</a></li> +<li><a href="Blur.html#Fn_Blur_execute">execute</a></li> <li><a href="Blur.html#Fn_Blur_fetchRow">fetchRow</a></li> <li><a href="Blur.html#Fn_Blur_fetchRowBatch">fetchRowBatch</a></li> <li><a href="Blur.html#Fn_Blur_isInSafeMode">isInSafeMode</a></li> @@ -53,7 +54,8 @@ <li><a href="Blur.html#Fn_Blur_traceRequestList">traceRequestList</a></li> </ul> </td> -<td><a href="Blur.html#Struct_BlurException">BlurException</a><br/> +<td><a href="Blur.html#Struct_Arguments">Arguments</a><br/> +<a href="Blur.html#Struct_BlurException">BlurException</a><br/> <a href="Blur.html#Struct_BlurQuery">BlurQuery</a><br/> <a href="Blur.html#Struct_BlurQueryStatus">BlurQueryStatus</a><br/> <a href="Blur.html#Struct_BlurResult">BlurResult</a><br/> @@ -74,6 +76,7 @@ <a href="Blur.html#Struct_Record">Record</a><br/> <a href="Blur.html#Struct_RecordMutation">RecordMutation</a><br/> <a href="Blur.html#Enum_RecordMutationType">RecordMutationType</a><br/> +<a href="Blur.html#Struct_Response">Response</a><br/> <a href="Blur.html#Struct_Row">Row</a><br/> <a href="Blur.html#Struct_RowMutation">RowMutation</a><br/> <a href="Blur.html#Enum_RowMutationType">RowMutationType</a><br/> @@ -87,6 +90,7 @@ <a href="Blur.html#Struct_TableDescriptor">TableDescriptor</a><br/> <a href="Blur.html#Struct_TableStats">TableStats</a><br/> <a href="Blur.html#Struct_User">User</a><br/> +<a href="Blur.html#Struct_Value">Value</a><br/> </td> <td></code></td> </tr></table> http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/94d579dd/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Arguments.java ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Arguments.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Arguments.java new file mode 100644 index 0000000..68d6916 --- /dev/null +++ b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Arguments.java @@ -0,0 +1,470 @@ +/** + * Autogenerated by Thrift Compiler (0.9.0) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.blur.thrift.generated; + +/** + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + + + +import org.apache.blur.thirdparty.thrift_0_9_0.scheme.IScheme; +import org.apache.blur.thirdparty.thrift_0_9_0.scheme.SchemeFactory; +import org.apache.blur.thirdparty.thrift_0_9_0.scheme.StandardScheme; + +import org.apache.blur.thirdparty.thrift_0_9_0.scheme.TupleScheme; +import org.apache.blur.thirdparty.thrift_0_9_0.protocol.TTupleProtocol; +import org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolException; +import org.apache.blur.thirdparty.thrift_0_9_0.EncodingUtils; +import org.apache.blur.thirdparty.thrift_0_9_0.TException; +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; + +public class Arguments implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Arguments, Arguments._Fields>, java.io.Serializable, Cloneable { + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct STRUCT_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct("Arguments"); + + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField VALUES_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("values", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP, (short)1); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new ArgumentsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new ArgumentsTupleSchemeFactory()); + } + + public Map<String,Value> values; // 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 { + VALUES((short)1, "values"); + + 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: // VALUES + return VALUES; + 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 + public static final Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> metaDataMap; + static { + Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData>(_Fields.class); + tmpMap.put(_Fields.VALUES, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("values", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.MapMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING), + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.StructMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, Value.class)))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(Arguments.class, metaDataMap); + } + + public Arguments() { + } + + public Arguments( + Map<String,Value> values) + { + this(); + this.values = values; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public Arguments(Arguments other) { + if (other.isSetValues()) { + Map<String,Value> __this__values = new HashMap<String,Value>(); + for (Map.Entry<String, Value> other_element : other.values.entrySet()) { + + String other_element_key = other_element.getKey(); + Value other_element_value = other_element.getValue(); + + String __this__values_copy_key = other_element_key; + + Value __this__values_copy_value = new Value(other_element_value); + + __this__values.put(__this__values_copy_key, __this__values_copy_value); + } + this.values = __this__values; + } + } + + public Arguments deepCopy() { + return new Arguments(this); + } + + @Override + public void clear() { + this.values = null; + } + + public int getValuesSize() { + return (this.values == null) ? 0 : this.values.size(); + } + + public void putToValues(String key, Value val) { + if (this.values == null) { + this.values = new HashMap<String,Value>(); + } + this.values.put(key, val); + } + + public Map<String,Value> getValues() { + return this.values; + } + + public Arguments setValues(Map<String,Value> values) { + this.values = values; + return this; + } + + public void unsetValues() { + this.values = null; + } + + /** Returns true if field values is set (has been assigned a value) and false otherwise */ + public boolean isSetValues() { + return this.values != null; + } + + public void setValuesIsSet(boolean value) { + if (!value) { + this.values = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case VALUES: + if (value == null) { + unsetValues(); + } else { + setValues((Map<String,Value>)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case VALUES: + return getValues(); + + } + 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 VALUES: + return isSetValues(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof Arguments) + return this.equals((Arguments)that); + return false; + } + + public boolean equals(Arguments that) { + if (that == null) + return false; + + boolean this_present_values = true && this.isSetValues(); + boolean that_present_values = true && that.isSetValues(); + if (this_present_values || that_present_values) { + if (!(this_present_values && that_present_values)) + return false; + if (!this.values.equals(that.values)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + return 0; + } + + public int compareTo(Arguments other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + Arguments typedOther = (Arguments)other; + + lastComparison = Boolean.valueOf(isSetValues()).compareTo(typedOther.isSetValues()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetValues()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.values, typedOther.values); + if (lastComparison != 0) { + return lastComparison; + } + } + return 0; + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + } + + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("Arguments("); + boolean first = true; + + sb.append("values:"); + if (this.values == null) { + sb.append("null"); + } else { + sb.append(this.values); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + // check for required fields + // check for sub-struct validity + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TCompactProtocol(new org.apache.blur.thirdparty.thrift_0_9_0.transport.TIOStreamTransport(out))); + } catch (org.apache.blur.thirdparty.thrift_0_9_0.TException te) { + throw new java.io.IOException(te); + } + } + + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + try { + read(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TCompactProtocol(new org.apache.blur.thirdparty.thrift_0_9_0.transport.TIOStreamTransport(in))); + } catch (org.apache.blur.thirdparty.thrift_0_9_0.TException te) { + throw new java.io.IOException(te); + } + } + + private static class ArgumentsStandardSchemeFactory implements SchemeFactory { + public ArgumentsStandardScheme getScheme() { + return new ArgumentsStandardScheme(); + } + } + + private static class ArgumentsStandardScheme extends StandardScheme<Arguments> { + + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, Arguments struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField schemeField; + iprot.readStructBegin(); + while (true) + { + schemeField = iprot.readFieldBegin(); + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STOP) { + break; + } + switch (schemeField.id) { + case 1: // VALUES + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP) { + { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map242 = iprot.readMapBegin(); + struct.values = new HashMap<String,Value>(2*_map242.size); + for (int _i243 = 0; _i243 < _map242.size; ++_i243) + { + String _key244; // optional + Value _val245; // required + _key244 = iprot.readString(); + _val245 = new Value(); + _val245.read(iprot); + struct.values.put(_key244, _val245); + } + iprot.readMapEnd(); + } + struct.setValuesIsSet(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); + } + 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.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot, Arguments struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.values != null) { + oprot.writeFieldBegin(VALUES_FIELD_DESC); + { + oprot.writeMapBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, struct.values.size())); + for (Map.Entry<String, Value> _iter246 : struct.values.entrySet()) + { + oprot.writeString(_iter246.getKey()); + _iter246.getValue().write(oprot); + } + oprot.writeMapEnd(); + } + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class ArgumentsTupleSchemeFactory implements SchemeFactory { + public ArgumentsTupleScheme getScheme() { + return new ArgumentsTupleScheme(); + } + } + + private static class ArgumentsTupleScheme extends TupleScheme<Arguments> { + + @Override + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, Arguments struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetValues()) { + optionals.set(0); + } + oprot.writeBitSet(optionals, 1); + if (struct.isSetValues()) { + { + oprot.writeI32(struct.values.size()); + for (Map.Entry<String, Value> _iter247 : struct.values.entrySet()) + { + oprot.writeString(_iter247.getKey()); + _iter247.getValue().write(oprot); + } + } + } + } + + @Override + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, Arguments struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(1); + if (incoming.get(0)) { + { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map248 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, iprot.readI32()); + struct.values = new HashMap<String,Value>(2*_map248.size); + for (int _i249 = 0; _i249 < _map248.size; ++_i249) + { + String _key250; // optional + Value _val251; // required + _key250 = iprot.readString(); + _val251 = new Value(); + _val251.read(iprot); + struct.values.put(_key250, _val251); + } + } + struct.setValuesIsSet(true); + } + } + } + +} +
