incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [6/9] Initial commit for the new platform work. This commit only contains working shard server logic and two primitive command implementations. DocumentCount and DocumentCountAggregator.
Date Wed, 27 Aug 2014 13:01:10 GMT
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/94d579dd/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Response.java
----------------------------------------------------------------------
diff --git a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Response.java b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Response.java
new file mode 100644
index 0000000..bbe28de
--- /dev/null
+++ b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Response.java
@@ -0,0 +1,418 @@
+/**
+ * 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 Response extends org.apache.blur.thirdparty.thrift_0_9_0.TUnion<Response, Response._Fields> {
+  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("Response");
+  private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField SHARD_TO_VALUE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("shardToValue", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP, (short)1);
+  private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField VALUE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("value", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, (short)2);
+
+  /** 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 {
+    SHARD_TO_VALUE((short)1, "shardToValue"),
+    VALUE((short)2, "value");
+
+    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: // SHARD_TO_VALUE
+          return SHARD_TO_VALUE;
+        case 2: // VALUE
+          return VALUE;
+        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;
+    }
+  }
+
+  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.SHARD_TO_VALUE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("shardToValue", 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))));
+    tmpMap.put(_Fields.VALUE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("value", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, 
+        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(Response.class, metaDataMap);
+  }
+
+  public Response() {
+    super();
+  }
+
+  public Response(_Fields setField, Object value) {
+    super(setField, value);
+  }
+
+  public Response(Response other) {
+    super(other);
+  }
+  public Response deepCopy() {
+    return new Response(this);
+  }
+
+  public static Response shardToValue(Map<String,Value> value) {
+    Response x = new Response();
+    x.setShardToValue(value);
+    return x;
+  }
+
+  public static Response value(Value value) {
+    Response x = new Response();
+    x.setValue(value);
+    return x;
+  }
+
+
+  @Override
+  protected void checkType(_Fields setField, Object value) throws ClassCastException {
+    switch (setField) {
+      case SHARD_TO_VALUE:
+        if (value instanceof Map) {
+          break;
+        }
+        throw new ClassCastException("Was expecting value of type Map<String,Value> for field 'shardToValue', but got " + value.getClass().getSimpleName());
+      case VALUE:
+        if (value instanceof Value) {
+          break;
+        }
+        throw new ClassCastException("Was expecting value of type Value for field 'value', but got " + value.getClass().getSimpleName());
+      default:
+        throw new IllegalArgumentException("Unknown field id " + setField);
+    }
+  }
+
+  @Override
+  protected Object standardSchemeReadValue(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField field) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+    _Fields setField = _Fields.findByThriftId(field.id);
+    if (setField != null) {
+      switch (setField) {
+        case SHARD_TO_VALUE:
+          if (field.type == SHARD_TO_VALUE_FIELD_DESC.type) {
+            Map<String,Value> shardToValue;
+            {
+              org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map232 = iprot.readMapBegin();
+              shardToValue = new HashMap<String,Value>(2*_map232.size);
+              for (int _i233 = 0; _i233 < _map232.size; ++_i233)
+              {
+                String _key234; // optional
+                Value _val235; // required
+                _key234 = iprot.readString();
+                _val235 = new Value();
+                _val235.read(iprot);
+                shardToValue.put(_key234, _val235);
+              }
+              iprot.readMapEnd();
+            }
+            return shardToValue;
+          } else {
+            org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, field.type);
+            return null;
+          }
+        case VALUE:
+          if (field.type == VALUE_FIELD_DESC.type) {
+            Value value;
+            value = new Value();
+            value.read(iprot);
+            return value;
+          } else {
+            org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, field.type);
+            return null;
+          }
+        default:
+          throw new IllegalStateException("setField wasn't null, but didn't match any of the case statements!");
+      }
+    } else {
+      return null;
+    }
+  }
+
+  @Override
+  protected void standardSchemeWriteValue(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+    switch (setField_) {
+      case SHARD_TO_VALUE:
+        Map<String,Value> shardToValue = (Map<String,Value>)value_;
+        {
+          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, shardToValue.size()));
+          for (Map.Entry<String, Value> _iter236 : shardToValue.entrySet())
+          {
+            oprot.writeString(_iter236.getKey());
+            _iter236.getValue().write(oprot);
+          }
+          oprot.writeMapEnd();
+        }
+        return;
+      case VALUE:
+        Value value = (Value)value_;
+        value.write(oprot);
+        return;
+      default:
+        throw new IllegalStateException("Cannot write union with unknown field " + setField_);
+    }
+  }
+
+  @Override
+  protected Object tupleSchemeReadValue(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, short fieldID) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+    _Fields setField = _Fields.findByThriftId(fieldID);
+    if (setField != null) {
+      switch (setField) {
+        case SHARD_TO_VALUE:
+          Map<String,Value> shardToValue;
+          {
+            org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map237 = iprot.readMapBegin();
+            shardToValue = new HashMap<String,Value>(2*_map237.size);
+            for (int _i238 = 0; _i238 < _map237.size; ++_i238)
+            {
+              String _key239; // optional
+              Value _val240; // required
+              _key239 = iprot.readString();
+              _val240 = new Value();
+              _val240.read(iprot);
+              shardToValue.put(_key239, _val240);
+            }
+            iprot.readMapEnd();
+          }
+          return shardToValue;
+        case VALUE:
+          Value value;
+          value = new Value();
+          value.read(iprot);
+          return value;
+        default:
+          throw new IllegalStateException("setField wasn't null, but didn't match any of the case statements!");
+      }
+    } else {
+      throw new TProtocolException("Couldn't find a field with field id " + fieldID);
+    }
+  }
+
+  @Override
+  protected void tupleSchemeWriteValue(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+    switch (setField_) {
+      case SHARD_TO_VALUE:
+        Map<String,Value> shardToValue = (Map<String,Value>)value_;
+        {
+          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, shardToValue.size()));
+          for (Map.Entry<String, Value> _iter241 : shardToValue.entrySet())
+          {
+            oprot.writeString(_iter241.getKey());
+            _iter241.getValue().write(oprot);
+          }
+          oprot.writeMapEnd();
+        }
+        return;
+      case VALUE:
+        Value value = (Value)value_;
+        value.write(oprot);
+        return;
+      default:
+        throw new IllegalStateException("Cannot write union with unknown field " + setField_);
+    }
+  }
+
+  @Override
+  protected org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField getFieldDesc(_Fields setField) {
+    switch (setField) {
+      case SHARD_TO_VALUE:
+        return SHARD_TO_VALUE_FIELD_DESC;
+      case VALUE:
+        return VALUE_FIELD_DESC;
+      default:
+        throw new IllegalArgumentException("Unknown field id " + setField);
+    }
+  }
+
+  @Override
+  protected org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct getStructDesc() {
+    return STRUCT_DESC;
+  }
+
+  @Override
+  protected _Fields enumForId(short id) {
+    return _Fields.findByThriftIdOrThrow(id);
+  }
+
+  public _Fields fieldForId(int fieldId) {
+    return _Fields.findByThriftId(fieldId);
+  }
+
+
+  public Map<String,Value> getShardToValue() {
+    if (getSetField() == _Fields.SHARD_TO_VALUE) {
+      return (Map<String,Value>)getFieldValue();
+    } else {
+      throw new RuntimeException("Cannot get field 'shardToValue' because union is currently set to " + getFieldDesc(getSetField()).name);
+    }
+  }
+
+  public void setShardToValue(Map<String,Value> value) {
+    if (value == null) throw new NullPointerException();
+    setField_ = _Fields.SHARD_TO_VALUE;
+    value_ = value;
+  }
+
+  public Value getValue() {
+    if (getSetField() == _Fields.VALUE) {
+      return (Value)getFieldValue();
+    } else {
+      throw new RuntimeException("Cannot get field 'value' because union is currently set to " + getFieldDesc(getSetField()).name);
+    }
+  }
+
+  public void setValue(Value value) {
+    if (value == null) throw new NullPointerException();
+    setField_ = _Fields.VALUE;
+    value_ = value;
+  }
+
+  public boolean isSetShardToValue() {
+    return setField_ == _Fields.SHARD_TO_VALUE;
+  }
+
+
+  public boolean isSetValue() {
+    return setField_ == _Fields.VALUE;
+  }
+
+
+  public boolean equals(Object other) {
+    if (other instanceof Response) {
+      return equals((Response)other);
+    } else {
+      return false;
+    }
+  }
+
+  public boolean equals(Response other) {
+    return other != null && getSetField() == other.getSetField() && getFieldValue().equals(other.getFieldValue());
+  }
+
+  @Override
+  public int compareTo(Response other) {
+    int lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(getSetField(), other.getSetField());
+    if (lastComparison == 0) {
+      return org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(getFieldValue(), other.getFieldValue());
+    }
+    return lastComparison;
+  }
+
+
+  /**
+   * If you'd like this to perform more respectably, use the hashcode generator option.
+   */
+  @Override
+  public int hashCode() {
+    return 0;
+  }
+
+  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);
+    }
+  }
+
+
+}

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/94d579dd/blur-thrift/src/main/java/org/apache/blur/thrift/generated/SafeClientGen.java
----------------------------------------------------------------------
diff --git a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/SafeClientGen.java b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/SafeClientGen.java
index 7a7249a..5f2bbb4 100644
--- a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/SafeClientGen.java
+++ b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/SafeClientGen.java
@@ -28,12 +28,13 @@ package org.apache.blur.thrift.generated;
 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.TProtocol;
 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;
@@ -51,924 +52,12 @@ import java.util.Arrays;
 
 public class SafeClientGen extends org.apache.blur.thrift.generated.Blur.Client {
 
-private final org.apache.blur.thrift.ClientLock _lock = new org.apache.blur.thrift.ClientLock("client");
-
-public SafeClientGen(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot) {
-super(iprot, oprot);
-}
-
-public SafeClientGen(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot) {
-super(prot);
-}
-
-@Override
-public boolean addColumnDefinition(java.lang.String arg0, org.apache.blur.thrift.generated.ColumnDefinition arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.addColumnDefinition(arg0, arg1);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void cancelQuery(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.cancelQuery(arg0, arg1);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.util.Map configuration() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.configuration();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.util.List controllerServerList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.controllerServerList();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void createSnapshot(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.createSnapshot(arg0, arg1);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void createTable(org.apache.blur.thrift.generated.TableDescriptor arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.createTable(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public org.apache.blur.thrift.generated.TableDescriptor describe(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.describe(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void disableTable(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.disableTable(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void enableTable(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.enableTable(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void enqueueMutate(org.apache.blur.thrift.generated.RowMutation arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.enqueueMutate(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void enqueueMutateBatch(java.util.List arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.enqueueMutateBatch(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public org.apache.blur.thrift.generated.FetchResult fetchRow(java.lang.String arg0, org.apache.blur.thrift.generated.Selector arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.fetchRow(arg0, arg1);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.util.List fetchRowBatch(java.lang.String arg0, java.util.List arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.fetchRowBatch(arg0, arg1);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public boolean isInSafeMode(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.isInSafeMode(arg0);
-  } finally {_lock.unlock();}
-}
+  public SafeClientGen(TProtocol iprot, TProtocol oprot) {
+    super(iprot, oprot);
+  }
 
-@Override
-public java.util.Map listSnapshots(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.listSnapshots(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void logging(java.lang.String arg0, org.apache.blur.thrift.generated.Level arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.logging(arg0, arg1);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.util.Map metrics(java.util.Set arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.metrics(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void mutate(org.apache.blur.thrift.generated.RowMutation arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.mutate(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void mutateBatch(java.util.List arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.mutateBatch(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void optimize(java.lang.String arg0, int arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.optimize(arg0, arg1);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.lang.String parseQuery(java.lang.String arg0, org.apache.blur.thrift.generated.Query arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.parseQuery(arg0, arg1);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void ping() throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.ping();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public org.apache.blur.thrift.generated.BlurResults query(java.lang.String arg0, org.apache.blur.thrift.generated.BlurQuery arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.query(arg0, arg1);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public org.apache.blur.thrift.generated.BlurQueryStatus queryStatusById(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.queryStatusById(arg0, arg1);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.util.List queryStatusIdList(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.queryStatusIdList(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public long recordFrequency(java.lang.String arg0, java.lang.String arg1, java.lang.String arg2, java.lang.String arg3) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.recordFrequency(arg0, arg1, arg2, arg3);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public boolean recv_addColumnDefinition() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.recv_addColumnDefinition();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void recv_cancelQuery() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.recv_cancelQuery();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.util.Map recv_configuration() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.recv_configuration();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.util.List recv_controllerServerList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.recv_controllerServerList();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void recv_createSnapshot() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.recv_createSnapshot();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void recv_createTable() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.recv_createTable();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public org.apache.blur.thrift.generated.TableDescriptor recv_describe() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.recv_describe();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void recv_disableTable() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.recv_disableTable();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void recv_enableTable() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.recv_enableTable();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void recv_enqueueMutate() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.recv_enqueueMutate();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void recv_enqueueMutateBatch() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.recv_enqueueMutateBatch();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public org.apache.blur.thrift.generated.FetchResult recv_fetchRow() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.recv_fetchRow();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.util.List recv_fetchRowBatch() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.recv_fetchRowBatch();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public boolean recv_isInSafeMode() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.recv_isInSafeMode();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.util.Map recv_listSnapshots() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.recv_listSnapshots();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void recv_logging() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.recv_logging();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.util.Map recv_metrics() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.recv_metrics();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void recv_mutate() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.recv_mutate();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void recv_mutateBatch() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.recv_mutateBatch();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void recv_optimize() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.recv_optimize();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.lang.String recv_parseQuery() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.recv_parseQuery();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void recv_ping() throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.recv_ping();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public org.apache.blur.thrift.generated.BlurResults recv_query() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.recv_query();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public org.apache.blur.thrift.generated.BlurQueryStatus recv_queryStatusById() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.recv_queryStatusById();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.util.List recv_queryStatusIdList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.recv_queryStatusIdList();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public long recv_recordFrequency() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.recv_recordFrequency();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void recv_removeSnapshot() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.recv_removeSnapshot();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void recv_removeTable() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.recv_removeTable();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void recv_resetLogging() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.recv_resetLogging();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public org.apache.blur.thrift.generated.Schema recv_schema() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.recv_schema();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.util.List recv_shardClusterList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.recv_shardClusterList();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.util.Map recv_shardServerLayout() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.recv_shardServerLayout();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.util.Map recv_shardServerLayoutState() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.recv_shardServerLayoutState();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.util.List recv_shardServerList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.recv_shardServerList();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.util.List recv_tableList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.recv_tableList();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.util.List recv_tableListByCluster() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.recv_tableListByCluster();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public org.apache.blur.thrift.generated.TableStats recv_tableStats() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.recv_tableStats();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.util.List recv_terms() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.recv_terms();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.util.List recv_traceList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.recv_traceList();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void recv_traceRemove() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.recv_traceRemove();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.lang.String recv_traceRequestFetch() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.recv_traceRequestFetch();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.util.List recv_traceRequestList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.recv_traceRequestList();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void removeSnapshot(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.removeSnapshot(arg0, arg1);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void removeTable(java.lang.String arg0, boolean arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.removeTable(arg0, arg1);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void resetLogging() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.resetLogging();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public org.apache.blur.thrift.generated.Schema schema(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.schema(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_addColumnDefinition(java.lang.String arg0, org.apache.blur.thrift.generated.ColumnDefinition arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_addColumnDefinition(arg0, arg1);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_cancelQuery(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_cancelQuery(arg0, arg1);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_configuration() throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_configuration();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_controllerServerList() throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_controllerServerList();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_createSnapshot(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_createSnapshot(arg0, arg1);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_createTable(org.apache.blur.thrift.generated.TableDescriptor arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_createTable(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_describe(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_describe(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_disableTable(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_disableTable(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_enableTable(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_enableTable(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_enqueueMutate(org.apache.blur.thrift.generated.RowMutation arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_enqueueMutate(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_enqueueMutateBatch(java.util.List arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_enqueueMutateBatch(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_fetchRow(java.lang.String arg0, org.apache.blur.thrift.generated.Selector arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_fetchRow(arg0, arg1);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_fetchRowBatch(java.lang.String arg0, java.util.List arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_fetchRowBatch(arg0, arg1);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_isInSafeMode(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_isInSafeMode(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_listSnapshots(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_listSnapshots(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_logging(java.lang.String arg0, org.apache.blur.thrift.generated.Level arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_logging(arg0, arg1);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_metrics(java.util.Set arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_metrics(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_mutate(org.apache.blur.thrift.generated.RowMutation arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_mutate(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_mutateBatch(java.util.List arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_mutateBatch(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_optimize(java.lang.String arg0, int arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_optimize(arg0, arg1);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_parseQuery(java.lang.String arg0, org.apache.blur.thrift.generated.Query arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_parseQuery(arg0, arg1);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_ping() throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_ping();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_query(java.lang.String arg0, org.apache.blur.thrift.generated.BlurQuery arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_query(arg0, arg1);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_queryStatusById(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_queryStatusById(arg0, arg1);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_queryStatusIdList(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_queryStatusIdList(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_recordFrequency(java.lang.String arg0, java.lang.String arg1, java.lang.String arg2, java.lang.String arg3) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_recordFrequency(arg0, arg1, arg2, arg3);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_removeSnapshot(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_removeSnapshot(arg0, arg1);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_removeTable(java.lang.String arg0, boolean arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_removeTable(arg0, arg1);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_resetLogging() throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_resetLogging();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_schema(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_schema(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_setUser(org.apache.blur.thrift.generated.User arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_setUser(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_shardClusterList() throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_shardClusterList();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_shardServerLayout(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_shardServerLayout(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_shardServerLayoutState(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_shardServerLayoutState(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_shardServerList(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_shardServerList(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_startTrace(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_startTrace(arg0, arg1);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_tableList() throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_tableList();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_tableListByCluster(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_tableListByCluster(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_tableStats(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_tableStats(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_terms(java.lang.String arg0, java.lang.String arg1, java.lang.String arg2, java.lang.String arg3, short arg4) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_terms(arg0, arg1, arg2, arg3, arg4);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_traceList() throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_traceList();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_traceRemove(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_traceRemove(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_traceRequestFetch(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_traceRequestFetch(arg0, arg1);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void send_traceRequestList(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.send_traceRequestList(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void setUser(org.apache.blur.thrift.generated.User arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.setUser(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.util.List shardClusterList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.shardClusterList();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.util.Map shardServerLayout(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.shardServerLayout(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.util.Map shardServerLayoutState(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.shardServerLayoutState(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.util.List shardServerList(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.shardServerList(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void startTrace(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.startTrace(arg0, arg1);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.util.List tableList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.tableList();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.util.List tableListByCluster(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.tableListByCluster(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public org.apache.blur.thrift.generated.TableStats tableStats(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.tableStats(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.util.List terms(java.lang.String arg0, java.lang.String arg1, java.lang.String arg2, java.lang.String arg3, short arg4) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.terms(arg0, arg1, arg2, arg3, arg4);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.util.List traceList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.traceList();
-  } finally {_lock.unlock();}
-}
-
-@Override
-public void traceRemove(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    super.traceRemove(arg0);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.lang.String traceRequestFetch(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.traceRequestFetch(arg0, arg1);
-  } finally {_lock.unlock();}
-}
-
-@Override
-public java.util.List traceRequestList(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
-  _lock.errorFailLock(); try {
-    return super.traceRequestList(arg0);
-  } finally {_lock.unlock();}
-}
+  public SafeClientGen(TProtocol prot) {
+    super(prot);
+  }
 
 }

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/94d579dd/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Value.java
----------------------------------------------------------------------
diff --git a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Value.java b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Value.java
new file mode 100644
index 0000000..f120fd1
--- /dev/null
+++ b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Value.java
@@ -0,0 +1,794 @@
+/**
+ * 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 Value extends org.apache.blur.thirdparty.thrift_0_9_0.TUnion<Value, Value._Fields> {
+  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("Value");
+  private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField STRING_VALUE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("stringValue", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, (short)1);
+  private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField INT_VALUE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("intValue", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32, (short)2);
+  private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField SHORT_VALUE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("shortValue", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I16, (short)3);
+  private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField LONG_VALUE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("longValue", 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 DOUBLE_VALUE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("doubleValue", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.DOUBLE, (short)5);
+  private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField FLOAT_VALUE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("floatValue", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.DOUBLE, (short)6);
+  private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField BINARY_VALUE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("binaryValue", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, (short)7);
+  private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField BOOLEAN_VALUE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("booleanValue", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.BOOL, (short)8);
+  private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField NULL_VALUE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("nullValue", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.BOOL, (short)9);
+
+  /** 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 {
+    STRING_VALUE((short)1, "stringValue"),
+    INT_VALUE((short)2, "intValue"),
+    SHORT_VALUE((short)3, "shortValue"),
+    LONG_VALUE((short)4, "longValue"),
+    DOUBLE_VALUE((short)5, "doubleValue"),
+    FLOAT_VALUE((short)6, "floatValue"),
+    BINARY_VALUE((short)7, "binaryValue"),
+    BOOLEAN_VALUE((short)8, "booleanValue"),
+    NULL_VALUE((short)9, "nullValue");
+
+    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: // STRING_VALUE
+          return STRING_VALUE;
+        case 2: // INT_VALUE
+          return INT_VALUE;
+        case 3: // SHORT_VALUE
+          return SHORT_VALUE;
+        case 4: // LONG_VALUE
+          return LONG_VALUE;
+        case 5: // DOUBLE_VALUE
+          return DOUBLE_VALUE;
+        case 6: // FLOAT_VALUE
+          return FLOAT_VALUE;
+        case 7: // BINARY_VALUE
+          return BINARY_VALUE;
+        case 8: // BOOLEAN_VALUE
+          return BOOLEAN_VALUE;
+        case 9: // NULL_VALUE
+          return NULL_VALUE;
+        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;
+    }
+  }
+
+  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.STRING_VALUE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("stringValue", 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.STRING)));
+    tmpMap.put(_Fields.INT_VALUE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("intValue", 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.I32)));
+    tmpMap.put(_Fields.SHORT_VALUE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("shortValue", 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.I16)));
+    tmpMap.put(_Fields.LONG_VALUE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("longValue", 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.DOUBLE_VALUE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("doubleValue", 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.DOUBLE)));
+    tmpMap.put(_Fields.FLOAT_VALUE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("floatValue", 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.DOUBLE)));
+    tmpMap.put(_Fields.BINARY_VALUE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("binaryValue", 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.STRING        , true)));
+    tmpMap.put(_Fields.BOOLEAN_VALUE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("booleanValue", 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.BOOL)));
+    tmpMap.put(_Fields.NULL_VALUE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("nullValue", 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.BOOL)));
+    metaDataMap = Collections.unmodifiableMap(tmpMap);
+    org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(Value.class, metaDataMap);
+  }
+
+  public Value() {
+    super();
+  }
+
+  public Value(_Fields setField, Object value) {
+    super(setField, value);
+  }
+
+  public Value(Value other) {
+    super(other);
+  }
+  public Value deepCopy() {
+    return new Value(this);
+  }
+
+  public static Value stringValue(String value) {
+    Value x = new Value();
+    x.setStringValue(value);
+    return x;
+  }
+
+  public static Value intValue(int value) {
+    Value x = new Value();
+    x.setIntValue(value);
+    return x;
+  }
+
+  public static Value shortValue(short value) {
+    Value x = new Value();
+    x.setShortValue(value);
+    return x;
+  }
+
+  public static Value longValue(long value) {
+    Value x = new Value();
+    x.setLongValue(value);
+    return x;
+  }
+
+  public static Value doubleValue(double value) {
+    Value x = new Value();
+    x.setDoubleValue(value);
+    return x;
+  }
+
+  public static Value floatValue(double value) {
+    Value x = new Value();
+    x.setFloatValue(value);
+    return x;
+  }
+
+  public static Value binaryValue(ByteBuffer value) {
+    Value x = new Value();
+    x.setBinaryValue(value);
+    return x;
+  }
+
+  public static Value binaryValue(byte[] value) {
+    Value x = new Value();
+    x.setBinaryValue(ByteBuffer.wrap(value));
+    return x;
+  }
+
+  public static Value booleanValue(boolean value) {
+    Value x = new Value();
+    x.setBooleanValue(value);
+    return x;
+  }
+
+  public static Value nullValue(boolean value) {
+    Value x = new Value();
+    x.setNullValue(value);
+    return x;
+  }
+
+
+  @Override
+  protected void checkType(_Fields setField, Object value) throws ClassCastException {
+    switch (setField) {
+      case STRING_VALUE:
+        if (value instanceof String) {
+          break;
+        }
+        throw new ClassCastException("Was expecting value of type String for field 'stringValue', but got " + value.getClass().getSimpleName());
+      case INT_VALUE:
+        if (value instanceof Integer) {
+          break;
+        }
+        throw new ClassCastException("Was expecting value of type Integer for field 'intValue', but got " + value.getClass().getSimpleName());
+      case SHORT_VALUE:
+        if (value instanceof Short) {
+          break;
+        }
+        throw new ClassCastException("Was expecting value of type Short for field 'shortValue', but got " + value.getClass().getSimpleName());
+      case LONG_VALUE:
+        if (value instanceof Long) {
+          break;
+        }
+        throw new ClassCastException("Was expecting value of type Long for field 'longValue', but got " + value.getClass().getSimpleName());
+      case DOUBLE_VALUE:
+        if (value instanceof Double) {
+          break;
+        }
+        throw new ClassCastException("Was expecting value of type Double for field 'doubleValue', but got " + value.getClass().getSimpleName());
+      case FLOAT_VALUE:
+        if (value instanceof Double) {
+          break;
+        }
+        throw new ClassCastException("Was expecting value of type Double for field 'floatValue', but got " + value.getClass().getSimpleName());
+      case BINARY_VALUE:
+        if (value instanceof ByteBuffer) {
+          break;
+        }
+        throw new ClassCastException("Was expecting value of type ByteBuffer for field 'binaryValue', but got " + value.getClass().getSimpleName());
+      case BOOLEAN_VALUE:
+        if (value instanceof Boolean) {
+          break;
+        }
+        throw new ClassCastException("Was expecting value of type Boolean for field 'booleanValue', but got " + value.getClass().getSimpleName());
+      case NULL_VALUE:
+        if (value instanceof Boolean) {
+          break;
+        }
+        throw new ClassCastException("Was expecting value of type Boolean for field 'nullValue', but got " + value.getClass().getSimpleName());
+      default:
+        throw new IllegalArgumentException("Unknown field id " + setField);
+    }
+  }
+
+  @Override
+  protected Object standardSchemeReadValue(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField field) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+    _Fields setField = _Fields.findByThriftId(field.id);
+    if (setField != null) {
+      switch (setField) {
+        case STRING_VALUE:
+          if (field.type == STRING_VALUE_FIELD_DESC.type) {
+            String stringValue;
+            stringValue = iprot.readString();
+            return stringValue;
+          } else {
+            org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, field.type);
+            return null;
+          }
+        case INT_VALUE:
+          if (field.type == INT_VALUE_FIELD_DESC.type) {
+            Integer intValue;
+            intValue = iprot.readI32();
+            return intValue;
+          } else {
+            org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, field.type);
+            return null;
+          }
+        case SHORT_VALUE:
+          if (field.type == SHORT_VALUE_FIELD_DESC.type) {
+            Short shortValue;
+            shortValue = iprot.readI16();
+            return shortValue;
+          } else {
+            org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, field.type);
+            return null;
+          }
+        case LONG_VALUE:
+          if (field.type == LONG_VALUE_FIELD_DESC.type) {
+            Long longValue;
+            longValue = iprot.readI64();
+            return longValue;
+          } else {
+            org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, field.type);
+            return null;
+          }
+        case DOUBLE_VALUE:
+          if (field.type == DOUBLE_VALUE_FIELD_DESC.type) {
+            Double doubleValue;
+            doubleValue = iprot.readDouble();
+            return doubleValue;
+          } else {
+            org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, field.type);
+            return null;
+          }
+        case FLOAT_VALUE:
+          if (field.type == FLOAT_VALUE_FIELD_DESC.type) {
+            Double floatValue;
+            floatValue = iprot.readDouble();
+            return floatValue;
+          } else {
+            org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, field.type);
+            return null;
+          }
+        case BINARY_VALUE:
+          if (field.type == BINARY_VALUE_FIELD_DESC.type) {
+            ByteBuffer binaryValue;
+            binaryValue = iprot.readBinary();
+            return binaryValue;
+          } else {
+            org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, field.type);
+            return null;
+          }
+        case BOOLEAN_VALUE:
+          if (field.type == BOOLEAN_VALUE_FIELD_DESC.type) {
+            Boolean booleanValue;
+            booleanValue = iprot.readBool();
+            return booleanValue;
+          } else {
+            org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, field.type);
+            return null;
+          }
+        case NULL_VALUE:
+          if (field.type == NULL_VALUE_FIELD_DESC.type) {
+            Boolean nullValue;
+            nullValue = iprot.readBool();
+            return nullValue;
+          } else {
+            org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, field.type);
+            return null;
+          }
+        default:
+          throw new IllegalStateException("setField wasn't null, but didn't match any of the case statements!");
+      }
+    } else {
+      return null;
+    }
+  }
+
+  @Override
+  protected void standardSchemeWriteValue(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+    switch (setField_) {
+      case STRING_VALUE:
+        String stringValue = (String)value_;
+        oprot.writeString(stringValue);
+        return;
+      case INT_VALUE:
+        Integer intValue = (Integer)value_;
+        oprot.writeI32(intValue);
+        return;
+      case SHORT_VALUE:
+        Short shortValue = (Short)value_;
+        oprot.writeI16(shortValue);
+        return;
+      case LONG_VALUE:
+        Long longValue = (Long)value_;
+        oprot.writeI64(longValue);
+        return;
+      case DOUBLE_VALUE:
+        Double doubleValue = (Double)value_;
+        oprot.writeDouble(doubleValue);
+        return;
+      case FLOAT_VALUE:
+        Double floatValue = (Double)value_;
+        oprot.writeDouble(floatValue);
+        return;
+      case BINARY_VALUE:
+        ByteBuffer binaryValue = (ByteBuffer)value_;
+        oprot.writeBinary(binaryValue);
+        return;
+      case BOOLEAN_VALUE:
+        Boolean booleanValue = (Boolean)value_;
+        oprot.writeBool(booleanValue);
+        return;
+      case NULL_VALUE:
+        Boolean nullValue = (Boolean)value_;
+        oprot.writeBool(nullValue);
+        return;
+      default:
+        throw new IllegalStateException("Cannot write union with unknown field " + setField_);
+    }
+  }
+
+  @Override
+  protected Object tupleSchemeReadValue(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, short fieldID) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+    _Fields setField = _Fields.findByThriftId(fieldID);
+    if (setField != null) {
+      switch (setField) {
+        case STRING_VALUE:
+          String stringValue;
+          stringValue = iprot.readString();
+          return stringValue;
+        case INT_VALUE:
+          Integer intValue;
+          intValue = iprot.readI32();
+          return intValue;
+        case SHORT_VALUE:
+          Short shortValue;
+          shortValue = iprot.readI16();
+          return shortValue;
+        case LONG_VALUE:
+          Long longValue;
+          longValue = iprot.readI64();
+          return longValue;
+        case DOUBLE_VALUE:
+          Double doubleValue;
+          doubleValue = iprot.readDouble();
+          return doubleValue;
+        case FLOAT_VALUE:
+          Double floatValue;
+          floatValue = iprot.readDouble();
+          return floatValue;
+        case BINARY_VALUE:
+          ByteBuffer binaryValue;
+          binaryValue = iprot.readBinary();
+          return binaryValue;
+        case BOOLEAN_VALUE:
+          Boolean booleanValue;
+          booleanValue = iprot.readBool();
+          return booleanValue;
+        case NULL_VALUE:
+          Boolean nullValue;
+          nullValue = iprot.readBool();
+          return nullValue;
+        default:
+          throw new IllegalStateException("setField wasn't null, but didn't match any of the case statements!");
+      }
+    } else {
+      throw new TProtocolException("Couldn't find a field with field id " + fieldID);
+    }
+  }
+
+  @Override
+  protected void tupleSchemeWriteValue(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+    switch (setField_) {
+      case STRING_VALUE:
+        String stringValue = (String)value_;
+        oprot.writeString(stringValue);
+        return;
+      case INT_VALUE:
+        Integer intValue = (Integer)value_;
+        oprot.writeI32(intValue);
+        return;
+      case SHORT_VALUE:
+        Short shortValue = (Short)value_;
+        oprot.writeI16(shortValue);
+        return;
+      case LONG_VALUE:
+        Long longValue = (Long)value_;
+        oprot.writeI64(longValue);
+        return;
+      case DOUBLE_VALUE:
+        Double doubleValue = (Double)value_;
+        oprot.writeDouble(doubleValue);
+        return;
+      case FLOAT_VALUE:
+        Double floatValue = (Double)value_;
+        oprot.writeDouble(floatValue);
+        return;
+      case BINARY_VALUE:
+        ByteBuffer binaryValue = (ByteBuffer)value_;
+        oprot.writeBinary(binaryValue);
+        return;
+      case BOOLEAN_VALUE:
+        Boolean booleanValue = (Boolean)value_;
+        oprot.writeBool(booleanValue);
+        return;
+      case NULL_VALUE:
+        Boolean nullValue = (Boolean)value_;
+        oprot.writeBool(nullValue);
+        return;
+      default:
+        throw new IllegalStateException("Cannot write union with unknown field " + setField_);
+    }
+  }
+
+  @Override
+  protected org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField getFieldDesc(_Fields setField) {
+    switch (setField) {
+      case STRING_VALUE:
+        return STRING_VALUE_FIELD_DESC;
+      case INT_VALUE:
+        return INT_VALUE_FIELD_DESC;
+      case SHORT_VALUE:
+        return SHORT_VALUE_FIELD_DESC;
+      case LONG_VALUE:
+        return LONG_VALUE_FIELD_DESC;
+      case DOUBLE_VALUE:
+        return DOUBLE_VALUE_FIELD_DESC;
+      case FLOAT_VALUE:
+        return FLOAT_VALUE_FIELD_DESC;
+      case BINARY_VALUE:
+        return BINARY_VALUE_FIELD_DESC;
+      case BOOLEAN_VALUE:
+        return BOOLEAN_VALUE_FIELD_DESC;
+      case NULL_VALUE:
+        return NULL_VALUE_FIELD_DESC;
+      default:
+        throw new IllegalArgumentException("Unknown field id " + setField);
+    }
+  }
+
+  @Override
+  protected org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct getStructDesc() {
+    return STRUCT_DESC;
+  }
+
+  @Override
+  protected _Fields enumForId(short id) {
+    return _Fields.findByThriftIdOrThrow(id);
+  }
+
+  public _Fields fieldForId(int fieldId) {
+    return _Fields.findByThriftId(fieldId);
+  }
+
+
+  public String getStringValue() {
+    if (getSetField() == _Fields.STRING_VALUE) {
+      return (String)getFieldValue();
+    } else {
+      throw new RuntimeException("Cannot get field 'stringValue' because union is currently set to " + getFieldDesc(getSetField()).name);
+    }
+  }
+
+  public void setStringValue(String value) {
+    if (value == null) throw new NullPointerException();
+    setField_ = _Fields.STRING_VALUE;
+    value_ = value;
+  }
+
+  public int getIntValue() {
+    if (getSetField() == _Fields.INT_VALUE) {
+      return (Integer)getFieldValue();
+    } else {
+      throw new RuntimeException("Cannot get field 'intValue' because union is currently set to " + getFieldDesc(getSetField()).name);
+    }
+  }
+
+  public void setIntValue(int value) {
+    setField_ = _Fields.INT_VALUE;
+    value_ = value;
+  }
+
+  public short getShortValue() {
+    if (getSetField() == _Fields.SHORT_VALUE) {
+      return (Short)getFieldValue();
+    } else {
+      throw new RuntimeException("Cannot get field 'shortValue' because union is currently set to " + getFieldDesc(getSetField()).name);
+    }
+  }
+
+  public void setShortValue(short value) {
+    setField_ = _Fields.SHORT_VALUE;
+    value_ = value;
+  }
+
+  public long getLongValue() {
+    if (getSetField() == _Fields.LONG_VALUE) {
+      return (Long)getFieldValue();
+    } else {
+      throw new RuntimeException("Cannot get field 'longValue' because union is currently set to " + getFieldDesc(getSetField()).name);
+    }
+  }
+
+  public void setLongValue(long value) {
+    setField_ = _Fields.LONG_VALUE;
+    value_ = value;
+  }
+
+  public double getDoubleValue() {
+    if (getSetField() == _Fields.DOUBLE_VALUE) {
+      return (Double)getFieldValue();
+    } else {
+      throw new RuntimeException("Cannot get field 'doubleValue' because union is currently set to " + getFieldDesc(getSetField()).name);
+    }
+  }
+
+  public void setDoubleValue(double value) {
+    setField_ = _Fields.DOUBLE_VALUE;
+    value_ = value;
+  }
+
+  public double getFloatValue() {
+    if (getSetField() == _Fields.FLOAT_VALUE) {
+      return (Double)getFieldValue();
+    } else {
+      throw new RuntimeException("Cannot get field 'floatValue' because union is currently set to " + getFieldDesc(getSetField()).name);
+    }
+  }
+
+  public void setFloatValue(double value) {
+    setField_ = _Fields.FLOAT_VALUE;
+    value_ = value;
+  }
+
+  public byte[] getBinaryValue() {
+    setBinaryValue(org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.rightSize(bufferForBinaryValue()));
+    ByteBuffer b = bufferForBinaryValue();
+    return b == null ? null : b.array();
+  }
+
+  public ByteBuffer bufferForBinaryValue() {
+    if (getSetField() == _Fields.BINARY_VALUE) {
+      return (ByteBuffer)getFieldValue();
+    } else {
+      throw new RuntimeException("Cannot get field 'binaryValue' because union is currently set to " + getFieldDesc(getSetField()).name);
+    }
+  }
+
+  public void setBinaryValue(byte[] value) {
+    setBinaryValue(ByteBuffer.wrap(value));
+  }
+
+  public void setBinaryValue(ByteBuffer value) {
+    if (value == null) throw new NullPointerException();
+    setField_ = _Fields.BINARY_VALUE;
+    value_ = value;
+  }
+
+  public boolean getBooleanValue() {
+    if (getSetField() == _Fields.BOOLEAN_VALUE) {
+      return (Boolean)getFieldValue();
+    } else {
+      throw new RuntimeException("Cannot get field 'booleanValue' because union is currently set to " + getFieldDesc(getSetField()).name);
+    }
+  }
+
+  public void setBooleanValue(boolean value) {
+    setField_ = _Fields.BOOLEAN_VALUE;
+    value_ = value;
+  }
+
+  public boolean getNullValue() {
+    if (getSetField() == _Fields.NULL_VALUE) {
+      return (Boolean)getFieldValue();
+    } else {
+      throw new RuntimeException("Cannot get field 'nullValue' because union is currently set to " + getFieldDesc(getSetField()).name);
+    }
+  }
+
+  public void setNullValue(boolean value) {
+    setField_ = _Fields.NULL_VALUE;
+    value_ = value;
+  }
+
+  public boolean isSetStringValue() {
+    return setField_ == _Fields.STRING_VALUE;
+  }
+
+
+  public boolean isSetIntValue() {
+    return setField_ == _Fields.INT_VALUE;
+  }
+
+
+  public boolean isSetShortValue() {
+    return setField_ == _Fields.SHORT_VALUE;
+  }
+
+
+  public boolean isSetLongValue() {
+    return setField_ == _Fields.LONG_VALUE;
+  }
+
+
+  public boolean isSetDoubleValue() {
+    return setField_ == _Fields.DOUBLE_VALUE;
+  }
+
+
+  public boolean isSetFloatValue() {
+    return setField_ == _Fields.FLOAT_VALUE;
+  }
+
+
+  public boolean isSetBinaryValue() {
+    return setField_ == _Fields.BINARY_VALUE;
+  }
+
+
+  public boolean isSetBooleanValue() {
+    return setField_ == _Fields.BOOLEAN_VALUE;
+  }
+
+
+  public boolean isSetNullValue() {
+    return setField_ == _Fields.NULL_VALUE;
+  }
+
+
+  public boolean equals(Object other) {
+    if (other instanceof Value) {
+      return equals((Value)other);
+    } else {
+      return false;
+    }
+  }
+
+  public boolean equals(Value other) {
+    return other != null && getSetField() == other.getSetField() && getFieldValue().equals(other.getFieldValue());
+  }
+
+  @Override
+  public int compareTo(Value other) {
+    int lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(getSetField(), other.getSetField());
+    if (lastComparison == 0) {
+      return org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(getFieldValue(), other.getFieldValue());
+    }
+    return lastComparison;
+  }
+
+
+  /**
+   * If you'd like this to perform more respectably, use the hashcode generator option.
+   */
+  @Override
+  public int hashCode() {
+    return 0;
+  }
+
+  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);
+    }
+  }
+
+
+}

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/94d579dd/blur-thrift/src/main/java/org/apache/blur/thrift/util/CommandExample.java
----------------------------------------------------------------------
diff --git a/blur-thrift/src/main/java/org/apache/blur/thrift/util/CommandExample.java b/blur-thrift/src/main/java/org/apache/blur/thrift/util/CommandExample.java
new file mode 100644
index 0000000..3bfd1ac
--- /dev/null
+++ b/blur-thrift/src/main/java/org/apache/blur/thrift/util/CommandExample.java
@@ -0,0 +1,33 @@
+package org.apache.blur.thrift.util;
+
+/**
+ * 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 java.io.IOException;
+
+import org.apache.blur.thirdparty.thrift_0_9_0.TException;
+import org.apache.blur.thrift.BlurClient;
+import org.apache.blur.thrift.generated.Blur.Iface;
+import org.apache.blur.thrift.generated.BlurException;
+
+public class CommandExample {
+
+  public static void main(String[] args) throws BlurException, TException, IOException {
+    Iface client = BlurClient.getClient("localhost:40020");
+    System.out.println(client.execute("test", "docCount", null));
+    System.out.println(client.execute("test", "docCountAggregate", null));
+  }
+}

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/94d579dd/distribution/src/main/scripts/interface/Blur.thrift
----------------------------------------------------------------------
diff --git a/distribution/src/main/scripts/interface/Blur.thrift b/distribution/src/main/scripts/interface/Blur.thrift
index 9781d16..6692657 100644
--- a/distribution/src/main/scripts/interface/Blur.thrift
+++ b/distribution/src/main/scripts/interface/Blur.thrift
@@ -830,12 +830,35 @@ enum Level {
   ALL
 }
 
+union Value {
+  1:string stringValue,
+  2:i32 intValue,
+  3:i16 shortValue,
+  4:i64 longValue,
+  5:double doubleValue,
+  6:double floatValue,
+  7:binary binaryValue,
+  8:bool booleanValue,
+  9:bool nullValue
+}
+
+union Response {
+  1:map<string, Value> shardToValue,
+  2:Value value
+}
+
+struct Arguments {
+  1:map<string,Value> values
+}
+
 /**
  * The Blur service API.  This API is the same for both controller servers as well as 
  * shards servers.  Each of the methods are documented.
  */
 service Blur {
 
+  Response execute(1:string table, 2:string commandName, 3:Arguments arguments) throws (1:BlurException ex)
+
   //Table Commands
 
   /**
@@ -1246,6 +1269,7 @@ service Blur {
    * Resets the logging for this instance to match the log4j file.  NOTE: This will allow for dynamically changing to logging file at runtime.
    */
   void resetLogging() throws (1:BlurException ex)
+
 }
 
 


Mime
View raw message