incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [3/7] git commit: Generated files.
Date Tue, 30 Dec 2014 14:53:02 GMT
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/36c8130b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Blur.java
----------------------------------------------------------------------
diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Blur.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Blur.java
index 34a0d9f..e7e658b 100644
--- a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Blur.java
+++ b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Blur.java
@@ -316,7 +316,7 @@ public class Blur {
     public void bulkMutateStart(String table, String bulkId) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException;
 
     /**
-     * Adds to the specified transaction.  The
+     * Adds to the specified transaction.
      * 
      * @param table The table name.
      * 
@@ -327,6 +327,17 @@ public class Blur {
     public void bulkMutateAdd(String table, String bulkId, RowMutation rowMutation) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException;
 
     /**
+     * Adds to the specified transaction.
+     * 
+     * @param table The table name.
+     * 
+     * @param bulkId The bulk id.
+     * 
+     * @param rowMutations The row mutation.
+     */
+    public void bulkMutateAddMultiple(String table, String bulkId, List<RowMutation> rowMutations) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException;
+
+    /**
      * Finishes the bulk mutate.  If apply is true the mutations are applied and committed.  If false the bulk mutate is deleted and not applied.
      * 
      * @param table The table name.
@@ -602,6 +613,8 @@ public class Blur {
 
     public void bulkMutateAdd(String table, String bulkId, RowMutation rowMutation, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.bulkMutateAdd_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException;
 
+    public void bulkMutateAddMultiple(String table, String bulkId, List<RowMutation> rowMutations, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.bulkMutateAddMultiple_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException;
+
     public void bulkMutateFinish(String table, String bulkId, boolean apply, boolean blockUntilComplete, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.bulkMutateFinish_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException;
 
     public void cancelQuery(String table, String uuid, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.cancelQuery_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException;
@@ -1472,6 +1485,31 @@ public class Blur {
       return;
     }
 
+    public void bulkMutateAddMultiple(String table, String bulkId, List<RowMutation> rowMutations) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException
+    {
+      send_bulkMutateAddMultiple(table, bulkId, rowMutations);
+      recv_bulkMutateAddMultiple();
+    }
+
+    public void send_bulkMutateAddMultiple(String table, String bulkId, List<RowMutation> rowMutations) throws org.apache.blur.thirdparty.thrift_0_9_0.TException
+    {
+      bulkMutateAddMultiple_args args = new bulkMutateAddMultiple_args();
+      args.setTable(table);
+      args.setBulkId(bulkId);
+      args.setRowMutations(rowMutations);
+      sendBase("bulkMutateAddMultiple", args);
+    }
+
+    public void recv_bulkMutateAddMultiple() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException
+    {
+      bulkMutateAddMultiple_result result = new bulkMutateAddMultiple_result();
+      receiveBase(result, "bulkMutateAddMultiple");
+      if (result.ex != null) {
+        throw result.ex;
+      }
+      return;
+    }
+
     public void bulkMutateFinish(String table, String bulkId, boolean apply, boolean blockUntilComplete) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException
     {
       send_bulkMutateFinish(table, bulkId, apply, blockUntilComplete);
@@ -3129,6 +3167,44 @@ public class Blur {
       }
     }
 
+    public void bulkMutateAddMultiple(String table, String bulkId, List<RowMutation> rowMutations, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<bulkMutateAddMultiple_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      checkReady();
+      bulkMutateAddMultiple_call method_call = new bulkMutateAddMultiple_call(table, bulkId, rowMutations, resultHandler, this, ___protocolFactory, ___transport);
+      this.___currentMethod = method_call;
+      ___manager.call(method_call);
+    }
+
+    public static class bulkMutateAddMultiple_call extends org.apache.blur.thirdparty.thrift_0_9_0.async.TAsyncMethodCall {
+      private String table;
+      private String bulkId;
+      private List<RowMutation> rowMutations;
+      public bulkMutateAddMultiple_call(String table, String bulkId, List<RowMutation> rowMutations, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<bulkMutateAddMultiple_call> resultHandler, org.apache.blur.thirdparty.thrift_0_9_0.async.TAsyncClient client, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolFactory protocolFactory, org.apache.blur.thirdparty.thrift_0_9_0.transport.TNonblockingTransport transport) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+        super(client, protocolFactory, transport, resultHandler, false);
+        this.table = table;
+        this.bulkId = bulkId;
+        this.rowMutations = rowMutations;
+      }
+
+      public void write_args(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+        prot.writeMessageBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMessage("bulkMutateAddMultiple", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMessageType.CALL, 0));
+        bulkMutateAddMultiple_args args = new bulkMutateAddMultiple_args();
+        args.setTable(table);
+        args.setBulkId(bulkId);
+        args.setRowMutations(rowMutations);
+        args.write(prot);
+        prot.writeMessageEnd();
+      }
+
+      public void getResult() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+        if (getState() != org.apache.blur.thirdparty.thrift_0_9_0.async.TAsyncMethodCall.State.RESPONSE_READ) {
+          throw new IllegalStateException("Method call not finished!");
+        }
+        org.apache.blur.thirdparty.thrift_0_9_0.transport.TMemoryInputTransport memoryTransport = new org.apache.blur.thirdparty.thrift_0_9_0.transport.TMemoryInputTransport(getFrameBuffer().array());
+        org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+        (new Client(prot)).recv_bulkMutateAddMultiple();
+      }
+    }
+
     public void bulkMutateFinish(String table, String bulkId, boolean apply, boolean blockUntilComplete, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<bulkMutateFinish_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
       checkReady();
       bulkMutateFinish_call method_call = new bulkMutateFinish_call(table, bulkId, apply, blockUntilComplete, resultHandler, this, ___protocolFactory, ___transport);
@@ -3905,6 +3981,7 @@ public class Blur {
       processMap.put("enqueueMutateBatch", new enqueueMutateBatch());
       processMap.put("bulkMutateStart", new bulkMutateStart());
       processMap.put("bulkMutateAdd", new bulkMutateAdd());
+      processMap.put("bulkMutateAddMultiple", new bulkMutateAddMultiple());
       processMap.put("bulkMutateFinish", new bulkMutateFinish());
       processMap.put("cancelQuery", new cancelQuery());
       processMap.put("queryStatusIdList", new queryStatusIdList());
@@ -4717,6 +4794,30 @@ public class Blur {
       }
     }
 
+    public static class bulkMutateAddMultiple<I extends Iface> extends org.apache.blur.thirdparty.thrift_0_9_0.ProcessFunction<I, bulkMutateAddMultiple_args> {
+      public bulkMutateAddMultiple() {
+        super("bulkMutateAddMultiple");
+      }
+
+      public bulkMutateAddMultiple_args getEmptyArgsInstance() {
+        return new bulkMutateAddMultiple_args();
+      }
+
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public bulkMutateAddMultiple_result getResult(I iface, bulkMutateAddMultiple_args args) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+        bulkMutateAddMultiple_result result = new bulkMutateAddMultiple_result();
+        try {
+          iface.bulkMutateAddMultiple(args.table, args.bulkId, args.rowMutations);
+        } catch (BlurException ex) {
+          result.ex = ex;
+        }
+        return result;
+      }
+    }
+
     public static class bulkMutateFinish<I extends Iface> extends org.apache.blur.thirdparty.thrift_0_9_0.ProcessFunction<I, bulkMutateFinish_args> {
       public bulkMutateFinish() {
         super("bulkMutateFinish");
@@ -22963,7 +23064,7 @@ public class Blur {
                   struct.success = new HashMap<String,List<String>>(2*_map322.size);
                   for (int _i323 = 0; _i323 < _map322.size; ++_i323)
                   {
-                    String _key324; // optional
+                    String _key324; // required
                     List<String> _val325; // required
                     _key324 = iprot.readString();
                     {
@@ -23091,7 +23192,7 @@ public class Blur {
             struct.success = new HashMap<String,List<String>>(2*_map333.size);
             for (int _i334 = 0; _i334 < _map333.size; ++_i334)
             {
-              String _key335; // optional
+              String _key335; // required
               List<String> _val336; // required
               _key335 = iprot.readString();
               {
@@ -26512,123 +26613,900 @@ public class Blur {
     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.TABLE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("table", 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.LOCATION, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("location", 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.TABLE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("table", 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.LOCATION, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("location", 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)));
+      metaDataMap = Collections.unmodifiableMap(tmpMap);
+      org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(loadData_args.class, metaDataMap);
+    }
+
+    public loadData_args() {
+    }
+
+    public loadData_args(
+      String table,
+      String location)
+    {
+      this();
+      this.table = table;
+      this.location = location;
+    }
+
+    /**
+     * Performs a deep copy on <i>other</i>.
+     */
+    public loadData_args(loadData_args other) {
+      if (other.isSetTable()) {
+        this.table = other.table;
+      }
+      if (other.isSetLocation()) {
+        this.location = other.location;
+      }
+    }
+
+    public loadData_args deepCopy() {
+      return new loadData_args(this);
+    }
+
+    @Override
+    public void clear() {
+      this.table = null;
+      this.location = null;
+    }
+
+    /**
+     * The table name.
+     */
+    public String getTable() {
+      return this.table;
+    }
+
+    /**
+     * The table name.
+     */
+    public loadData_args setTable(String table) {
+      this.table = table;
+      return this;
+    }
+
+    public void unsetTable() {
+      this.table = null;
+    }
+
+    /** Returns true if field table is set (has been assigned a value) and false otherwise */
+    public boolean isSetTable() {
+      return this.table != null;
+    }
+
+    public void setTableIsSet(boolean value) {
+      if (!value) {
+        this.table = null;
+      }
+    }
+
+    /**
+     * Location of bulk data load.
+     */
+    public String getLocation() {
+      return this.location;
+    }
+
+    /**
+     * Location of bulk data load.
+     */
+    public loadData_args setLocation(String location) {
+      this.location = location;
+      return this;
+    }
+
+    public void unsetLocation() {
+      this.location = null;
+    }
+
+    /** Returns true if field location is set (has been assigned a value) and false otherwise */
+    public boolean isSetLocation() {
+      return this.location != null;
+    }
+
+    public void setLocationIsSet(boolean value) {
+      if (!value) {
+        this.location = null;
+      }
+    }
+
+    public void setFieldValue(_Fields field, Object value) {
+      switch (field) {
+      case TABLE:
+        if (value == null) {
+          unsetTable();
+        } else {
+          setTable((String)value);
+        }
+        break;
+
+      case LOCATION:
+        if (value == null) {
+          unsetLocation();
+        } else {
+          setLocation((String)value);
+        }
+        break;
+
+      }
+    }
+
+    public Object getFieldValue(_Fields field) {
+      switch (field) {
+      case TABLE:
+        return getTable();
+
+      case LOCATION:
+        return getLocation();
+
+      }
+      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 TABLE:
+        return isSetTable();
+      case LOCATION:
+        return isSetLocation();
+      }
+      throw new IllegalStateException();
+    }
+
+    @Override
+    public boolean equals(Object that) {
+      if (that == null)
+        return false;
+      if (that instanceof loadData_args)
+        return this.equals((loadData_args)that);
+      return false;
+    }
+
+    public boolean equals(loadData_args that) {
+      if (that == null)
+        return false;
+
+      boolean this_present_table = true && this.isSetTable();
+      boolean that_present_table = true && that.isSetTable();
+      if (this_present_table || that_present_table) {
+        if (!(this_present_table && that_present_table))
+          return false;
+        if (!this.table.equals(that.table))
+          return false;
+      }
+
+      boolean this_present_location = true && this.isSetLocation();
+      boolean that_present_location = true && that.isSetLocation();
+      if (this_present_location || that_present_location) {
+        if (!(this_present_location && that_present_location))
+          return false;
+        if (!this.location.equals(that.location))
+          return false;
+      }
+
+      return true;
+    }
+
+    @Override
+    public int hashCode() {
+      return 0;
+    }
+
+    public int compareTo(loadData_args other) {
+      if (!getClass().equals(other.getClass())) {
+        return getClass().getName().compareTo(other.getClass().getName());
+      }
+
+      int lastComparison = 0;
+      loadData_args typedOther = (loadData_args)other;
+
+      lastComparison = Boolean.valueOf(isSetTable()).compareTo(typedOther.isSetTable());
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+      if (isSetTable()) {
+        lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.table, typedOther.table);
+        if (lastComparison != 0) {
+          return lastComparison;
+        }
+      }
+      lastComparison = Boolean.valueOf(isSetLocation()).compareTo(typedOther.isSetLocation());
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+      if (isSetLocation()) {
+        lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.location, typedOther.location);
+        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("loadData_args(");
+      boolean first = true;
+
+      sb.append("table:");
+      if (this.table == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.table);
+      }
+      first = false;
+      if (!first) sb.append(", ");
+      sb.append("location:");
+      if (this.location == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.location);
+      }
+      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 loadData_argsStandardSchemeFactory implements SchemeFactory {
+      public loadData_argsStandardScheme getScheme() {
+        return new loadData_argsStandardScheme();
+      }
+    }
+
+    private static class loadData_argsStandardScheme extends StandardScheme<loadData_args> {
+
+      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, loadData_args 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: // TABLE
+              if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING) {
+                struct.table = iprot.readString();
+                struct.setTableIsSet(true);
+              } else { 
+                org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+              }
+              break;
+            case 2: // LOCATION
+              if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING) {
+                struct.location = iprot.readString();
+                struct.setLocationIsSet(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, loadData_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+        struct.validate();
+
+        oprot.writeStructBegin(STRUCT_DESC);
+        if (struct.table != null) {
+          oprot.writeFieldBegin(TABLE_FIELD_DESC);
+          oprot.writeString(struct.table);
+          oprot.writeFieldEnd();
+        }
+        if (struct.location != null) {
+          oprot.writeFieldBegin(LOCATION_FIELD_DESC);
+          oprot.writeString(struct.location);
+          oprot.writeFieldEnd();
+        }
+        oprot.writeFieldStop();
+        oprot.writeStructEnd();
+      }
+
+    }
+
+    private static class loadData_argsTupleSchemeFactory implements SchemeFactory {
+      public loadData_argsTupleScheme getScheme() {
+        return new loadData_argsTupleScheme();
+      }
+    }
+
+    private static class loadData_argsTupleScheme extends TupleScheme<loadData_args> {
+
+      @Override
+      public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, loadData_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+        TTupleProtocol oprot = (TTupleProtocol) prot;
+        BitSet optionals = new BitSet();
+        if (struct.isSetTable()) {
+          optionals.set(0);
+        }
+        if (struct.isSetLocation()) {
+          optionals.set(1);
+        }
+        oprot.writeBitSet(optionals, 2);
+        if (struct.isSetTable()) {
+          oprot.writeString(struct.table);
+        }
+        if (struct.isSetLocation()) {
+          oprot.writeString(struct.location);
+        }
+      }
+
+      @Override
+      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, loadData_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+        TTupleProtocol iprot = (TTupleProtocol) prot;
+        BitSet incoming = iprot.readBitSet(2);
+        if (incoming.get(0)) {
+          struct.table = iprot.readString();
+          struct.setTableIsSet(true);
+        }
+        if (incoming.get(1)) {
+          struct.location = iprot.readString();
+          struct.setLocationIsSet(true);
+        }
+      }
+    }
+
+  }
+
+  public static class loadData_result implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<loadData_result, loadData_result._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("loadData_result");
+
+    private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField EX_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("ex", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, (short)1);
+
+    private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+    static {
+      schemes.put(StandardScheme.class, new loadData_resultStandardSchemeFactory());
+      schemes.put(TupleScheme.class, new loadData_resultTupleSchemeFactory());
+    }
+
+    public BlurException ex; // 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 {
+      EX((short)1, "ex");
+
+      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: // EX
+            return EX;
+          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.EX, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("ex", 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.STRUCT)));
+      metaDataMap = Collections.unmodifiableMap(tmpMap);
+      org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(loadData_result.class, metaDataMap);
+    }
+
+    public loadData_result() {
+    }
+
+    public loadData_result(
+      BlurException ex)
+    {
+      this();
+      this.ex = ex;
+    }
+
+    /**
+     * Performs a deep copy on <i>other</i>.
+     */
+    public loadData_result(loadData_result other) {
+      if (other.isSetEx()) {
+        this.ex = new BlurException(other.ex);
+      }
+    }
+
+    public loadData_result deepCopy() {
+      return new loadData_result(this);
+    }
+
+    @Override
+    public void clear() {
+      this.ex = null;
+    }
+
+    public BlurException getEx() {
+      return this.ex;
+    }
+
+    public loadData_result setEx(BlurException ex) {
+      this.ex = ex;
+      return this;
+    }
+
+    public void unsetEx() {
+      this.ex = null;
+    }
+
+    /** Returns true if field ex is set (has been assigned a value) and false otherwise */
+    public boolean isSetEx() {
+      return this.ex != null;
+    }
+
+    public void setExIsSet(boolean value) {
+      if (!value) {
+        this.ex = null;
+      }
+    }
+
+    public void setFieldValue(_Fields field, Object value) {
+      switch (field) {
+      case EX:
+        if (value == null) {
+          unsetEx();
+        } else {
+          setEx((BlurException)value);
+        }
+        break;
+
+      }
+    }
+
+    public Object getFieldValue(_Fields field) {
+      switch (field) {
+      case EX:
+        return getEx();
+
+      }
+      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 EX:
+        return isSetEx();
+      }
+      throw new IllegalStateException();
+    }
+
+    @Override
+    public boolean equals(Object that) {
+      if (that == null)
+        return false;
+      if (that instanceof loadData_result)
+        return this.equals((loadData_result)that);
+      return false;
+    }
+
+    public boolean equals(loadData_result that) {
+      if (that == null)
+        return false;
+
+      boolean this_present_ex = true && this.isSetEx();
+      boolean that_present_ex = true && that.isSetEx();
+      if (this_present_ex || that_present_ex) {
+        if (!(this_present_ex && that_present_ex))
+          return false;
+        if (!this.ex.equals(that.ex))
+          return false;
+      }
+
+      return true;
+    }
+
+    @Override
+    public int hashCode() {
+      return 0;
+    }
+
+    public int compareTo(loadData_result other) {
+      if (!getClass().equals(other.getClass())) {
+        return getClass().getName().compareTo(other.getClass().getName());
+      }
+
+      int lastComparison = 0;
+      loadData_result typedOther = (loadData_result)other;
+
+      lastComparison = Boolean.valueOf(isSetEx()).compareTo(typedOther.isSetEx());
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+      if (isSetEx()) {
+        lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.ex, typedOther.ex);
+        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("loadData_result(");
+      boolean first = true;
+
+      sb.append("ex:");
+      if (this.ex == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.ex);
+      }
+      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 loadData_resultStandardSchemeFactory implements SchemeFactory {
+      public loadData_resultStandardScheme getScheme() {
+        return new loadData_resultStandardScheme();
+      }
+    }
+
+    private static class loadData_resultStandardScheme extends StandardScheme<loadData_result> {
+
+      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, loadData_result 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: // EX
+              if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT) {
+                struct.ex = new BlurException();
+                struct.ex.read(iprot);
+                struct.setExIsSet(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, loadData_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+        struct.validate();
+
+        oprot.writeStructBegin(STRUCT_DESC);
+        if (struct.ex != null) {
+          oprot.writeFieldBegin(EX_FIELD_DESC);
+          struct.ex.write(oprot);
+          oprot.writeFieldEnd();
+        }
+        oprot.writeFieldStop();
+        oprot.writeStructEnd();
+      }
+
+    }
+
+    private static class loadData_resultTupleSchemeFactory implements SchemeFactory {
+      public loadData_resultTupleScheme getScheme() {
+        return new loadData_resultTupleScheme();
+      }
+    }
+
+    private static class loadData_resultTupleScheme extends TupleScheme<loadData_result> {
+
+      @Override
+      public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, loadData_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+        TTupleProtocol oprot = (TTupleProtocol) prot;
+        BitSet optionals = new BitSet();
+        if (struct.isSetEx()) {
+          optionals.set(0);
+        }
+        oprot.writeBitSet(optionals, 1);
+        if (struct.isSetEx()) {
+          struct.ex.write(oprot);
+        }
+      }
+
+      @Override
+      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, loadData_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+        TTupleProtocol iprot = (TTupleProtocol) prot;
+        BitSet incoming = iprot.readBitSet(1);
+        if (incoming.get(0)) {
+          struct.ex = new BlurException();
+          struct.ex.read(iprot);
+          struct.setExIsSet(true);
+        }
+      }
+    }
+
+  }
+
+  public static class mutate_args implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<mutate_args, mutate_args._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("mutate_args");
+
+    private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField MUTATION_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("mutation", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, (short)1);
+
+    private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+    static {
+      schemes.put(StandardScheme.class, new mutate_argsStandardSchemeFactory());
+      schemes.put(TupleScheme.class, new mutate_argsTupleSchemeFactory());
+    }
+
+    /**
+     * the RowMutation.
+     */
+    public RowMutation mutation; // 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 {
+      /**
+       * the RowMutation.
+       */
+      MUTATION((short)1, "mutation");
+
+      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: // MUTATION
+            return MUTATION;
+          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.MUTATION, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("mutation", 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, RowMutation.class)));
       metaDataMap = Collections.unmodifiableMap(tmpMap);
-      org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(loadData_args.class, metaDataMap);
+      org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(mutate_args.class, metaDataMap);
     }
 
-    public loadData_args() {
+    public mutate_args() {
     }
 
-    public loadData_args(
-      String table,
-      String location)
+    public mutate_args(
+      RowMutation mutation)
     {
       this();
-      this.table = table;
-      this.location = location;
+      this.mutation = mutation;
     }
 
     /**
      * Performs a deep copy on <i>other</i>.
      */
-    public loadData_args(loadData_args other) {
-      if (other.isSetTable()) {
-        this.table = other.table;
-      }
-      if (other.isSetLocation()) {
-        this.location = other.location;
+    public mutate_args(mutate_args other) {
+      if (other.isSetMutation()) {
+        this.mutation = new RowMutation(other.mutation);
       }
     }
 
-    public loadData_args deepCopy() {
-      return new loadData_args(this);
+    public mutate_args deepCopy() {
+      return new mutate_args(this);
     }
 
     @Override
     public void clear() {
-      this.table = null;
-      this.location = null;
-    }
-
-    /**
-     * The table name.
-     */
-    public String getTable() {
-      return this.table;
-    }
-
-    /**
-     * The table name.
-     */
-    public loadData_args setTable(String table) {
-      this.table = table;
-      return this;
-    }
-
-    public void unsetTable() {
-      this.table = null;
-    }
-
-    /** Returns true if field table is set (has been assigned a value) and false otherwise */
-    public boolean isSetTable() {
-      return this.table != null;
-    }
-
-    public void setTableIsSet(boolean value) {
-      if (!value) {
-        this.table = null;
-      }
+      this.mutation = null;
     }
 
     /**
-     * Location of bulk data load.
+     * the RowMutation.
      */
-    public String getLocation() {
-      return this.location;
+    public RowMutation getMutation() {
+      return this.mutation;
     }
 
     /**
-     * Location of bulk data load.
+     * the RowMutation.
      */
-    public loadData_args setLocation(String location) {
-      this.location = location;
+    public mutate_args setMutation(RowMutation mutation) {
+      this.mutation = mutation;
       return this;
     }
 
-    public void unsetLocation() {
-      this.location = null;
+    public void unsetMutation() {
+      this.mutation = null;
     }
 
-    /** Returns true if field location is set (has been assigned a value) and false otherwise */
-    public boolean isSetLocation() {
-      return this.location != null;
+    /** Returns true if field mutation is set (has been assigned a value) and false otherwise */
+    public boolean isSetMutation() {
+      return this.mutation != null;
     }
 
-    public void setLocationIsSet(boolean value) {
+    public void setMutationIsSet(boolean value) {
       if (!value) {
-        this.location = null;
+        this.mutation = null;
       }
     }
 
     public void setFieldValue(_Fields field, Object value) {
       switch (field) {
-      case TABLE:
-        if (value == null) {
-          unsetTable();
-        } else {
-          setTable((String)value);
-        }
-        break;
-
-      case LOCATION:
+      case MUTATION:
         if (value == null) {
-          unsetLocation();
+          unsetMutation();
         } else {
-          setLocation((String)value);
+          setMutation((RowMutation)value);
         }
         break;
 
@@ -26637,11 +27515,8 @@ public class Blur {
 
     public Object getFieldValue(_Fields field) {
       switch (field) {
-      case TABLE:
-        return getTable();
-
-      case LOCATION:
-        return getLocation();
+      case MUTATION:
+        return getMutation();
 
       }
       throw new IllegalStateException();
@@ -26654,10 +27529,8 @@ public class Blur {
       }
 
       switch (field) {
-      case TABLE:
-        return isSetTable();
-      case LOCATION:
-        return isSetLocation();
+      case MUTATION:
+        return isSetMutation();
       }
       throw new IllegalStateException();
     }
@@ -26666,30 +27539,21 @@ public class Blur {
     public boolean equals(Object that) {
       if (that == null)
         return false;
-      if (that instanceof loadData_args)
-        return this.equals((loadData_args)that);
+      if (that instanceof mutate_args)
+        return this.equals((mutate_args)that);
       return false;
     }
 
-    public boolean equals(loadData_args that) {
+    public boolean equals(mutate_args that) {
       if (that == null)
         return false;
 
-      boolean this_present_table = true && this.isSetTable();
-      boolean that_present_table = true && that.isSetTable();
-      if (this_present_table || that_present_table) {
-        if (!(this_present_table && that_present_table))
-          return false;
-        if (!this.table.equals(that.table))
-          return false;
-      }
-
-      boolean this_present_location = true && this.isSetLocation();
-      boolean that_present_location = true && that.isSetLocation();
-      if (this_present_location || that_present_location) {
-        if (!(this_present_location && that_present_location))
+      boolean this_present_mutation = true && this.isSetMutation();
+      boolean that_present_mutation = true && that.isSetMutation();
+      if (this_present_mutation || that_present_mutation) {
+        if (!(this_present_mutation && that_present_mutation))
           return false;
-        if (!this.location.equals(that.location))
+        if (!this.mutation.equals(that.mutation))
           return false;
       }
 
@@ -26701,30 +27565,20 @@ public class Blur {
       return 0;
     }
 
-    public int compareTo(loadData_args other) {
+    public int compareTo(mutate_args other) {
       if (!getClass().equals(other.getClass())) {
         return getClass().getName().compareTo(other.getClass().getName());
       }
 
       int lastComparison = 0;
-      loadData_args typedOther = (loadData_args)other;
+      mutate_args typedOther = (mutate_args)other;
 
-      lastComparison = Boolean.valueOf(isSetTable()).compareTo(typedOther.isSetTable());
-      if (lastComparison != 0) {
-        return lastComparison;
-      }
-      if (isSetTable()) {
-        lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.table, typedOther.table);
-        if (lastComparison != 0) {
-          return lastComparison;
-        }
-      }
-      lastComparison = Boolean.valueOf(isSetLocation()).compareTo(typedOther.isSetLocation());
+      lastComparison = Boolean.valueOf(isSetMutation()).compareTo(typedOther.isSetMutation());
       if (lastComparison != 0) {
         return lastComparison;
       }
-      if (isSetLocation()) {
-        lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.location, typedOther.location);
+      if (isSetMutation()) {
+        lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.mutation, typedOther.mutation);
         if (lastComparison != 0) {
           return lastComparison;
         }
@@ -26746,22 +27600,14 @@ public class Blur {
 
     @Override
     public String toString() {
-      StringBuilder sb = new StringBuilder("loadData_args(");
+      StringBuilder sb = new StringBuilder("mutate_args(");
       boolean first = true;
 
-      sb.append("table:");
-      if (this.table == null) {
-        sb.append("null");
-      } else {
-        sb.append(this.table);
-      }
-      first = false;
-      if (!first) sb.append(", ");
-      sb.append("location:");
-      if (this.location == null) {
+      sb.append("mutation:");
+      if (this.mutation == null) {
         sb.append("null");
       } else {
-        sb.append(this.location);
+        sb.append(this.mutation);
       }
       first = false;
       sb.append(")");
@@ -26771,6 +27617,9 @@ public class Blur {
     public void validate() throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
       // check for required fields
       // check for sub-struct validity
+      if (mutation != null) {
+        mutation.validate();
+      }
     }
 
     private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -26789,15 +27638,15 @@ public class Blur {
       }
     }
 
-    private static class loadData_argsStandardSchemeFactory implements SchemeFactory {
-      public loadData_argsStandardScheme getScheme() {
-        return new loadData_argsStandardScheme();
+    private static class mutate_argsStandardSchemeFactory implements SchemeFactory {
+      public mutate_argsStandardScheme getScheme() {
+        return new mutate_argsStandardScheme();
       }
     }
 
-    private static class loadData_argsStandardScheme extends StandardScheme<loadData_args> {
+    private static class mutate_argsStandardScheme extends StandardScheme<mutate_args> {
 
-      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, loadData_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, mutate_args 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)
@@ -26807,18 +27656,11 @@ public class Blur {
             break;
           }
           switch (schemeField.id) {
-            case 1: // TABLE
-              if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING) {
-                struct.table = iprot.readString();
-                struct.setTableIsSet(true);
-              } else { 
-                org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type);
-              }
-              break;
-            case 2: // LOCATION
-              if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING) {
-                struct.location = iprot.readString();
-                struct.setLocationIsSet(true);
+            case 1: // MUTATION
+              if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT) {
+                struct.mutation = new RowMutation();
+                struct.mutation.read(iprot);
+                struct.setMutationIsSet(true);
               } else { 
                 org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type);
               }
@@ -26834,18 +27676,13 @@ public class Blur {
         struct.validate();
       }
 
-      public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot, loadData_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot, mutate_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
         struct.validate();
 
         oprot.writeStructBegin(STRUCT_DESC);
-        if (struct.table != null) {
-          oprot.writeFieldBegin(TABLE_FIELD_DESC);
-          oprot.writeString(struct.table);
-          oprot.writeFieldEnd();
-        }
-        if (struct.location != null) {
-          oprot.writeFieldBegin(LOCATION_FIELD_DESC);
-          oprot.writeString(struct.location);
+        if (struct.mutation != null) {
+          oprot.writeFieldBegin(MUTATION_FIELD_DESC);
+          struct.mutation.write(oprot);
           oprot.writeFieldEnd();
         }
         oprot.writeFieldStop();
@@ -26854,59 +27691,50 @@ public class Blur {
 
     }
 
-    private static class loadData_argsTupleSchemeFactory implements SchemeFactory {
-      public loadData_argsTupleScheme getScheme() {
-        return new loadData_argsTupleScheme();
+    private static class mutate_argsTupleSchemeFactory implements SchemeFactory {
+      public mutate_argsTupleScheme getScheme() {
+        return new mutate_argsTupleScheme();
       }
     }
 
-    private static class loadData_argsTupleScheme extends TupleScheme<loadData_args> {
+    private static class mutate_argsTupleScheme extends TupleScheme<mutate_args> {
 
       @Override
-      public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, loadData_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, mutate_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
         TTupleProtocol oprot = (TTupleProtocol) prot;
         BitSet optionals = new BitSet();
-        if (struct.isSetTable()) {
+        if (struct.isSetMutation()) {
           optionals.set(0);
         }
-        if (struct.isSetLocation()) {
-          optionals.set(1);
-        }
-        oprot.writeBitSet(optionals, 2);
-        if (struct.isSetTable()) {
-          oprot.writeString(struct.table);
-        }
-        if (struct.isSetLocation()) {
-          oprot.writeString(struct.location);
+        oprot.writeBitSet(optionals, 1);
+        if (struct.isSetMutation()) {
+          struct.mutation.write(oprot);
         }
       }
 
       @Override
-      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, loadData_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, mutate_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
         TTupleProtocol iprot = (TTupleProtocol) prot;
-        BitSet incoming = iprot.readBitSet(2);
+        BitSet incoming = iprot.readBitSet(1);
         if (incoming.get(0)) {
-          struct.table = iprot.readString();
-          struct.setTableIsSet(true);
-        }
-        if (incoming.get(1)) {
-          struct.location = iprot.readString();
-          struct.setLocationIsSet(true);
+          struct.mutation = new RowMutation();
+          struct.mutation.read(iprot);
+          struct.setMutationIsSet(true);
         }
       }
     }
 
   }
 
-  public static class loadData_result implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<loadData_result, loadData_result._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("loadData_result");
+  public static class mutate_result implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<mutate_result, mutate_result._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("mutate_result");
 
     private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField EX_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("ex", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, (short)1);
 
     private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
     static {
-      schemes.put(StandardScheme.class, new loadData_resultStandardSchemeFactory());
-      schemes.put(TupleScheme.class, new loadData_resultTupleSchemeFactory());
+      schemes.put(StandardScheme.class, new mutate_resultStandardSchemeFactory());
+      schemes.put(TupleScheme.class, new mutate_resultTupleSchemeFactory());
     }
 
     public BlurException ex; // required
@@ -26976,13 +27804,13 @@ public class Blur {
       tmpMap.put(_Fields.EX, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("ex", 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.STRUCT)));
       metaDataMap = Collections.unmodifiableMap(tmpMap);
-      org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(loadData_result.class, metaDataMap);
+      org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(mutate_result.class, metaDataMap);
     }
 
-    public loadData_result() {
+    public mutate_result() {
     }
 
-    public loadData_result(
+    public mutate_result(
       BlurException ex)
     {
       this();
@@ -26992,14 +27820,14 @@ public class Blur {
     /**
      * Performs a deep copy on <i>other</i>.
      */
-    public loadData_result(loadData_result other) {
+    public mutate_result(mutate_result other) {
       if (other.isSetEx()) {
         this.ex = new BlurException(other.ex);
       }
     }
 
-    public loadData_result deepCopy() {
-      return new loadData_result(this);
+    public mutate_result deepCopy() {
+      return new mutate_result(this);
     }
 
     @Override
@@ -27011,7 +27839,7 @@ public class Blur {
       return this.ex;
     }
 
-    public loadData_result setEx(BlurException ex) {
+    public mutate_result setEx(BlurException ex) {
       this.ex = ex;
       return this;
     }
@@ -27070,12 +27898,12 @@ public class Blur {
     public boolean equals(Object that) {
       if (that == null)
         return false;
-      if (that instanceof loadData_result)
-        return this.equals((loadData_result)that);
+      if (that instanceof mutate_result)
+        return this.equals((mutate_result)that);
       return false;
     }
 
-    public boolean equals(loadData_result that) {
+    public boolean equals(mutate_result that) {
       if (that == null)
         return false;
 
@@ -27096,13 +27924,13 @@ public class Blur {
       return 0;
     }
 
-    public int compareTo(loadData_result other) {
+    public int compareTo(mutate_result other) {
       if (!getClass().equals(other.getClass())) {
         return getClass().getName().compareTo(other.getClass().getName());
       }
 
       int lastComparison = 0;
-      loadData_result typedOther = (loadData_result)other;
+      mutate_result typedOther = (mutate_result)other;
 
       lastComparison = Boolean.valueOf(isSetEx()).compareTo(typedOther.isSetEx());
       if (lastComparison != 0) {
@@ -27131,7 +27959,7 @@ public class Blur {
 
     @Override
     public String toString() {
-      StringBuilder sb = new StringBuilder("loadData_result(");
+      StringBuilder sb = new StringBuilder("mutate_result(");
       boolean first = true;
 
       sb.append("ex:");
@@ -27166,15 +27994,15 @@ public class Blur {
       }
     }
 
-    private static class loadData_resultStandardSchemeFactory implements SchemeFactory {
-      public loadData_resultStandardScheme getScheme() {
-        return new loadData_resultStandardScheme();
+    private static class mutate_resultStandardSchemeFactory implements SchemeFactory {
+      public mutate_resultStandardScheme getScheme() {
+        return new mutate_resultStandardScheme();
       }
     }
 
-    private static class loadData_resultStandardScheme extends StandardScheme<loadData_result> {
+    private static class mutate_resultStandardScheme extends StandardScheme<mutate_result> {
 
-      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, loadData_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, mutate_result 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)
@@ -27204,7 +28032,7 @@ public class Blur {
         struct.validate();
       }
 
-      public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot, loadData_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot, mutate_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
         struct.validate();
 
         oprot.writeStructBegin(STRUCT_DESC);
@@ -27219,16 +28047,16 @@ public class Blur {
 
     }
 
-    private static class loadData_resultTupleSchemeFactory implements SchemeFactory {
-      public loadData_resultTupleScheme getScheme() {
-        return new loadData_resultTupleScheme();
+    private static class mutate_resultTupleSchemeFactory implements SchemeFactory {
+      public mutate_resultTupleScheme getScheme() {
+        return new mutate_resultTupleScheme();
       }
     }
 
-    private static class loadData_resultTupleScheme extends TupleScheme<loadData_result> {
+    private static class mutate_resultTupleScheme extends TupleScheme<mutate_result> {
 
       @Override
-      public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, loadData_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, mutate_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
         TTupleProtocol oprot = (TTupleProtocol) prot;
         BitSet optionals = new BitSet();
         if (struct.isSetEx()) {
@@ -27241,7 +28069,7 @@ public class Blur {
       }
 
       @Override
-      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, loadData_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, mutate_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
         TTupleProtocol iprot = (TTupleProtocol) prot;
         BitSet incoming = iprot.readBitSet(1);
         if (incoming.get(0)) {
@@ -27254,15 +28082,15 @@ public class Blur {
 
   }
 
-  public static class mutate_args implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<mutate_args, mutate_args._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("mutate_args");
+  public static class enqueueMutate_args implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<enqueueMutate_args, enqueueMutate_args._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("enqueueMutate_args");
 
     private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField MUTATION_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("mutation", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, (short)1);
 
     private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
     static {
-      schemes.put(StandardScheme.class, new mutate_argsStandardSchemeFactory());
-      schemes.put(TupleScheme.class, new mutate_argsTupleSchemeFactory());
+      schemes.put(StandardScheme.class, new enqueueMutate_argsStandardSchemeFactory());
+      schemes.put(TupleScheme.class, new enqueueMutate_argsTupleSchemeFactory());
     }
 
     /**
@@ -27338,13 +28166,13 @@ public class Blur {
       tmpMap.put(_Fields.MUTATION, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("mutation", 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, RowMutation.class)));
       metaDataMap = Collections.unmodifiableMap(tmpMap);
-      org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(mutate_args.class, metaDataMap);
+      org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(enqueueMutate_args.class, metaDataMap);
     }
 
-    public mutate_args() {
+    public enqueueMutate_args() {
     }
 
-    public mutate_args(
+    public enqueueMutate_args(
       RowMutation mutation)
     {
       this();
@@ -27354,14 +28182,14 @@ public class Blur {
     /**
      * Performs a deep copy on <i>other</i>.
      */
-    public mutate_args(mutate_args other) {
+    public enqueueMutate_args(enqueueMutate_args other) {
       if (other.isSetMutation()) {
         this.mutation = new RowMutation(other.mutation);
       }
     }
 
-    public mutate_args deepCopy() {
-      return new mutate_args(this);
+    public enqueueMutate_args deepCopy() {
+      return new enqueueMutate_args(this);
     }
 
     @Override
@@ -27379,7 +28207,7 @@ public class Blur {
     /**
      * the RowMutation.
      */
-    public mutate_args setMutation(RowMutation mutation) {
+    public enqueueMutate_args setMutation(RowMutation mutation) {
       this.mutation = mutation;
       return this;
     }
@@ -27438,12 +28266,12 @@ public class Blur {
     public boolean equals(Object that) {
       if (that == null)
         return false;
-      if (that instanceof mutate_args)
-        return this.equals((mutate_args)that);
+      if (that instanceof enqueueMutate_args)
+        return this.equals((enqueueMutate_args)that);
       return false;
     }
 
-    public boolean equals(mutate_args that) {
+    public boolean equals(enqueueMutate_args that) {
       if (that == null)
         return false;
 
@@ -27464,13 +28292,13 @@ public class Blur {
       return 0;
     }
 
-    public int compareTo(mutate_args other) {
+    public int compareTo(enqueueMutate_args other) {
       if (!getClass().equals(other.getClass())) {
         return getClass().getName().compareTo(other.getClass().getName());
       }
 
       int lastComparison = 0;
-      mutate_args typedOther = (mutate_args)other;
+      enqueueMutate_args typedOther = (enqueueMutate_args)other;
 
       lastComparison = Boolean.valueOf(isSetMutation()).compareTo(typedOther.isSetMutation());
       if (lastComparison != 0) {
@@ -27499,7 +28327,7 @@ public class Blur {
 
     @Override
     public String toString() {
-      StringBuilder sb = new StringBuilder("mutate_args(");
+      StringBuilder sb = new StringBuilder("enqueueMutate_args(");
       boolean first = true;
 
       sb.append("mutation:");
@@ -27537,15 +28365,15 @@ public class Blur {
       }
     }
 
-    private static class mutate_argsStandardSchemeFactory implements SchemeFactory {
-      public mutate_argsStandardScheme getScheme() {
-        return new mutate_argsStandardScheme();
+    private static class enqueueMutate_argsStandardSchemeFactory implements SchemeFactory {
+      public enqueueMutate_argsStandardScheme getScheme() {
+        return new enqueueMutate_argsStandardScheme();
       }
     }
 
-    private static class mutate_argsStandardScheme extends StandardScheme<mutate_args> {
+    private static class enqueueMutate_argsStandardScheme extends StandardScheme<enqueueMutate_args> {
 
-      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, mutate_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, enqueueMutate_args 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)
@@ -27575,7 +28403,7 @@ public class Blur {
         struct.validate();
       }
 
-      public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot, mutate_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot, enqueueMutate_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
         struct.validate();
 
         oprot.writeStructBegin(STRUCT_DESC);
@@ -27590,16 +28418,16 @@ public class Blur {
 
     }
 
-    private static class mutate_argsTupleSchemeFactory implements SchemeFactory {
-      public mutate_argsTupleScheme getScheme() {
-        return new mutate_argsTupleScheme();
+    private static class enqueueMutate_argsTupleSchemeFactory implements SchemeFactory {
+      public enqueueMutate_argsTupleScheme getScheme() {
+        return new enqueueMutate_argsTupleScheme();
       }
     }
 
-    private static class mutate_argsTupleScheme extends TupleScheme<mutate_args> {
+    private static class enqueueMutate_argsTupleScheme extends TupleScheme<enqueueMutate_args> {
 
       @Override
-      public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, mutate_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, enqueueMutate_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
         TTupleProtocol oprot = (TTupleProtocol) prot;
         BitSet optionals = new BitSet();
         if (struct.isSetMutation()) {
@@ -27612,7 +28440,7 @@ public class Blur {
       }
 
       @Override
-      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, mutate_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, enqueueMutate_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
         TTupleProtocol iprot = (TTupleProtocol) prot;
         BitSet incoming = iprot.readBitSet(1);
         if (incoming.get(0)) {
@@ -27625,15 +28453,15 @@ public class Blur {
 
   }
 
-  public static class mutate_result implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<mutate_result, mutate_result._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("mutate_result");
+  public static class enqueueMutate_result implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<enqueueMutate_result, enqueueMutate_result._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("enqueueMutate_result");
 
     private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField EX_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("ex", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, (short)1);
 
     private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
     static {
-      schemes.put(StandardScheme.class, new mutate_resultStandardSchemeFactory());
-      schemes.put(TupleScheme.class, new mutate_resultTupleSchemeFactory());
+      schemes.put(StandardScheme.class, new enqueueMutate_resultStandardSchemeFactory());
+      schemes.put(TupleScheme.class, new enqueueMutate_resultTupleSchemeFactory());
     }
 
     public BlurException ex; // required
@@ -27703,13 +28531,13 @@ public class Blur {
       tmpMap.put(_Fields.EX, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("ex", 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.STRUCT)));
       metaDataMap = Collections.unmodifiableMap(tmpMap);
-      org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(mutate_result.class, metaDataMap);
+      org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(enqueueMutate_result.class, metaDataMap);
     }
 
-    public mutate_result() {
+    public enqueueMutate_result() {
     }
 
-    public mutate_result(
+    public enqueueMutate_result(
       BlurException ex)
     {
       this();
@@ -27719,14 +28547,14 @@ public class Blur {
     /**
      * Performs a deep copy on <i>other</i>.
      */
-    public mutate_result(mutate_result other) {
+    public enqueueMutate_result(enqueueMutate_result other) {
       if (other.isSetEx()) {
         this.ex = new BlurException(other.ex);
       }
     }
 
-    public mutate_result deepCopy() {
-      return new mutate_result(this);
+    public enqueueMutate_result deepCopy() {
+      return new enqueueMutate_result(this);
     }
 
     @Override
@@ -27738,7 +28566,7 @@ public class Blur {
       return this.ex;
     }
 
-    public mutate_result setEx(BlurException ex) {
+    public enqueueMutate_result setEx(BlurException ex) {
       this.ex = ex;
       return this;
     }
@@ -27797,12 +28625,12 @@ public class Blur {
     public boolean equals(Object that) {
       if (that == null)
         return false;
-      if (that instanceof mutate_result)
-        return this.equals((mutate_result)that);
+      if (that instanceof enqueueMutate_result)
+        return this.equals((enqueueMutate_result)that);
       return false;
     }
 
-    public boolean equals(mutate_result that) {
+    public boolean equals(enqueueMutate_result that) {
       if (that == null)
         return false;
 
@@ -27823,13 +28651,13 @@ public class Blur {
       return 0;
     }
 
-    public int compareTo(mutate_result other) {
+    public int compareTo(enqueueMutate_result other) {
       if (!getClass().equals(other.getClass())) {
         return getClass().getName().compareTo(other.getClass().getName());
       }
 
       int lastComparison = 0;
-      mutate_result typedOther = (mutate_result)other;
+      enqueueMutate_result typedOther = (enqueueMutate_result)other;
 
       lastComparison = Boolean.valueOf(isSetEx()).compareTo(typedOther.isSetEx());
       if (lastComparison != 0) {
@@ -27858,7 +28686,7 @@ public class Blur {
 
     @Override
     public String toString() {
-      StringBuilder sb = new StringBuilder("mutate_result(");
+      StringBuilder sb = new StringBuilder("enqueueMutate_result(");
       boolean first = true;
 
       sb.append("ex:");
@@ -27893,15 +28721,15 @@ public class Blur {
       }
     }
 
-    private static class mutate_resultStandardSchemeFactory implements SchemeFactory {
-      public mutate_resultStandardScheme getScheme() {
-        return new mutate_resultStandardScheme();
+    private static class enqueueMutate_resultStandardSchemeFactory implements SchemeFactory {
+      public enqueueMutate_resultStandardScheme getScheme() {
+        return new enqueueMutate_resultStandardScheme();
       }
     }
 
-    private static class mutate_resultStandardScheme extends StandardScheme<mutate_result> {
+    private static class enqueueMutate_resultStandardScheme extends StandardScheme<enqueueMutate_result> {
 
-      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, mutate_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, enqueueMutate_result 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)
@@ -27931,7 +28759,7 @@ public class Blur {
         struct.validate();
       }
 
-      public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot, mutate_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot, enqueueMutate_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
         struct.validate();
 
         oprot.writeStructBegin(STRUCT_DESC);
@@ -27946,16 +28774,16 @@ public class Blur {
 
     }
 
-    private static class mutate_resultTupleSchemeFactory implements SchemeFactory {
-      public mutate_resultTupleScheme getScheme() {
-        return new mutate_resultTupleScheme();
+    private static class enqueueMutate_resultTupleSchemeFactory implements SchemeFactory {
+      public enqueueMutate_resultTupleScheme getScheme() {
+        return new enqueueMutate_resultTupleScheme();
       }
     }
 
-    private static class mutate_resultTupleScheme extends TupleScheme<mutate_result> {
+    private static class enqueueMutate_resultTupleScheme extends TupleScheme<enqueueMutate_result> {
 
       @Override
-      public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, mutate_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, enqueueMutate_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
         TTupleProtocol oprot = (TTupleProtocol) prot;
         BitSet optionals = new BitSet();
         if (struct.isSetEx()) {
@@ -27968,7 +28796,7 @@ public class Blur {
       }
 
       @Override
-      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, mutate_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, enqueueMutate_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
         TTupleProtocol iprot = (TTupleProtocol) prot;
         BitSet incoming = iprot.readBitSet(1);
         if (incoming.get(0)) {
@@ -27981,28 +28809,28 @@ public class Blur {
 
   }
 
-  public static class enqueueMutate_args implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<enqueueMutate_args, enqueueMutate_args._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("enqueueMutate_args");
+  public static class mutateBatch_args implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<mutateBatch_args, mutateBatch_args._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("mutateBatch_args");
 
-    private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField MUTATION_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("mutation", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, (short)1);
+    private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField MUTATIONS_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("mutations", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST, (short)1);
 
     private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
     static {
-      schemes.put(StandardScheme.class, new enqueueMutate_argsStandardSchemeFactory());
-      schemes.put(TupleScheme.class, new enqueueMutate_argsTupleSchemeFactory());
+      schemes.put(StandardScheme.class, new mutateBatch_argsStandardSchemeFactory());
+      schemes.put(TupleScheme.class, new mutateBatch_argsTupleSchemeFactory());
     }
 
     /**
-     * the RowMutation.
+     * the batch of RowMutations.
      */
-    public RowMutation mutation; // required
+    public List<RowMutation> mutations; // 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 {
       /**
-       * the RowMutation.
+       * the batch of RowMutations.
        */
-      MUTATION((short)1, "mutation");
+      MUTATIONS((short)1, "mutations");
 
       private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
 
@@ -28017,8 +28845,8 @@ public class Blur {
        */
       public static _Fields findByThriftId(int fieldId) {
         switch(fieldId) {
-          case 1: // MUTATION
-            return MUTATION;
+          case 1: // MUTATIONS
+            return MUTATIONS;
           default:
             return null;
         }
@@ -28062,77 +28890,97 @@ public class Blur {
     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.MUTATION, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("mutation", 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, RowMutation.class)));
+      tmpMap.put(_Fields.MUTATIONS, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("mutations", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, 
+          new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.ListMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST, 
+              new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.StructMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, RowMutation.class))));
       metaDataMap = Collections.unmodifiableMap(tmpMap);
-      org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(enqueueMutate_args.class, metaDataMap);
+      org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(mutateBatch_args.class, metaDataMap);
     }
 
-    public enqueueMutate_args() {
+    public mutateBatch_args() {
     }
 
-    public enqueueMutate_args(
-      RowMutation mutation)
+    public mutateBatch_args(
+      List<RowMutation> mutations)
     {
       this();
-      this.mutation = mutation;
+      this.mutations = mutations;
     }
 
     /**
      * Performs a deep copy on <i>other</i>.
      */
-    public enqueueMutate_args(enqueueMutate_args other) {
-      if (other.isSetMutation()) {
-        this.mutation = new RowMutation(other.mutation);
+    public mutateBatch_args(mutateBatch_args other) {
+      if (other.isSetMutations()) {
+        List<RowMutation> __this__mutations = new ArrayList<RowMutation>();
+        for (RowMutation other_element : other.mutations) {
+          __this__mutations.add(new RowMutation(other_element));
+        }
+        this.mutations = __this__mutations;
       }
     }
 
-    public enqueueMutate_args deepCopy() {
-      return new enqueueMutate_args(this);
+    public mutateBatch_args deepCopy() {
+      return new mutateBatch_args(this);
     }
 
     @Override
     public void clear() {
-      this.mutation = null;
+      this.mutations = null;
+    }
+
+    public int getMutationsSize() {
+      return (this.mutations == null) ? 0 : this.mutations.size();
+    }
+
+    public java.util.Iterator<RowMutation> getMutationsIterator() {
+      return (this.mutations == null) ? null : this.mutations.iterator();
+    }
+
+    public void addToMutations(RowMutation elem) {
+      if (this.mutations == null) {
+        this.mutations = new ArrayList<RowMutation>();
+      }
+      this.mutations.add(elem);
     }
 
     /**
-     * the RowMutation.
+     * the batch of RowMutations.
      */
-    public RowMutation getMutation() {
-      return this.mutation;
+    public List<RowMutation> getMutations() {
+      return this.mutations;
     }
 
     /**
-     * the RowMutation.
+     * the batch of RowMutations.
      */
-    public enqueueMutate_args setMutation(RowMutation mutation) {
-      this.mutation = mutation;
+    public mutateBatch_args setMutations(List<RowMutation> mutations) {
+      this.mutations = mutations;
       return this;
     }
 
-    public void unsetMutation() {
-      this.mutation = null;
+    public void unsetMutations() {
+      this.mutations = null;
     }
 
-    /** Returns true if field mutation is set (has been assigned a value) and false otherwise */
-    public boolean isSetMutation() {
-      return this.mutation != null;
+    /** Returns true if field mutations is set (has been assigned a value) and false otherwise */
+    public boolean isSetMutations() {
+      return this.mutations != null;
     }
 
-    public void setMutationIsSet(boolean value) {
+    public void setMutationsIsSet(boolean value) {
       if (!value) {
-        this.mutation = null;
+        this.mutations = null;
       }
     }
 
     public void setFieldValue(_Fields field, Object value) {
       switch (field) {
-      case MUTATION:
+      case MUTATIONS:
         if (value == null) {
-          unsetMutation();
+          unsetMutations();
         } else {
-          setMutation((RowMutation)value);
+          setMutations((List<RowMutation>)value);
         }
         break;
 
@@ -28141,8 +28989,8 @@ public class Blur {
 
     public Object getFieldValue(_Fields field) {
       switch (field) {
-      case MUTATION:
-        return getMutation();
+      case MUTATIONS:
+        return getMutations();
 
       }
       throw new IllegalStateException();
@@ -28155,8 +29003,8 @@ public class Blur {
       }
 
       switch (field) {
-      case MUTATION:
-        return isSetMutation();
+      case MUTATIONS:
+        return isSetMutations();
       }
       throw new IllegalStateException();
     }
@@ -28165,21 +29013,21 @@ public class Blur {
     public boolean equals(Object that) {
       if (that == null)
         return false;
-      if (that instanceof enqueueMutate_args)
-        return this.equals((enqueueMutate_args)that);
+      if (that instanceof mutateBatch_args)
+        return this.equals((mutateBatch_args)that);
       return false;
     }
 
-    public boolean equals(enqueueMutate_args that) {
+    public boolean equals(mutateBatch_args that) {
       if (that == null)
         return false;
 
-      boolean this_present_mutation = true && this.isSetMutation();
-      boolean that_present_mutation = true && that.isSetMutation();
-      if (this_present_mutation || that_present_mutation) {
-        if (!(this_present_mutation && that_present_mutation))
+      boolean this_present_mutations = true && this.isSetMutations();
+      boolean that_present_mutations = true && that.isSetMutations();
+      if (this_present_mutations || that_present_mutations) {
+        if (!(this_present_mutations && that_present_mutations))
           return false;
-        if (!this.mutation.equals(that.mutation))
+        if (!this.mutations.equals(that.mutations))
           return false;
       }
 
@@ -28191,20 +29039,20 @@ public class Blur {
       return 0;
     }
 
-    public int compareTo(enqueueMutate_args other) {
+    public int compareTo(mutateBatch_args other) {
       if (!getClass().equals(other.getClass())) {
         return getClass().getName().compareTo(other.getClass().getName());
       }
 
       int lastComparison = 0;
-      enqueueMutate_args typedOther = (enqueueMutate_args)other;
+      mutateBatch_args typedOther = (mutateBatch_args)other;
 
-      lastComparison = Boolean.valueOf(isSetMutation()).compareTo(typedOther.isSetMutation());
+      lastComparison = Boolean.valueOf(isSetMutations()).compareTo(typedOther.isSetMutations());
       if (lastComparison != 0) {
         return lastComparison;
       }
-      if (isSetMutation()) {
-        lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.mutation, typedOther.mutation);
+      if (isSetMutations()) {
+        lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.mutations, typedOther.mutations);
         if (lastComparison != 0) {
           return lastComparison;
         }
@@ -28226,14 +29074,14 @@ public class Blur {
 
     @Override
     public String toString() {
-      StringBuilder sb = new StringBuilder("enqueueMutate_args(");
+      StringBuilder sb = new StringBuilder("mutateBatch_args(");
       boolean first = true;
 
-      sb.append("mutation:");
-      if (this.mutation == null) {
+      sb.append("mutations:");
+      if (this.mutations == null) {
         sb.append("null");
       } else {
-        sb.append(this.mutation);
+        sb.append(this.mutations);
       }
       first = false;
       sb.append(")");
@@ -28243,9 +29091,6 @@ public class Blur {
     public void validate() throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
       // check for required fields
       // check for sub-struct validity
-      if (mutation != null) {
-        mutation.validate();
-      }
     }
 
     private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -28264,15 +29109,15 @@ public class Blur {
       }
     }
 
-    private static class enqueueMutate_argsStandardSchemeFactory implements SchemeFactory {
-      public enqueueMutate_argsStandardScheme getScheme() {
-        return new enqueueMutate_argsStandardScheme();
+    private static class mutateBatch_argsStandardSchemeFactory implements SchemeFactory {
+      public mutateBatch_argsStandardScheme getScheme() {
+        return new mutateBatch_argsStandardScheme();
       }
     }
 
-    private stat

<TRUNCATED>

Mime
View raw message