incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [2/7] git commit: Generated files.
Date Tue, 30 Dec 2014 14:53:01 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/BlurQueryStatus.java
----------------------------------------------------------------------
diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/BlurQueryStatus.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/BlurQueryStatus.java
index 6cac5a1..a9caf29 100644
--- a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/BlurQueryStatus.java
+++ b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/BlurQueryStatus.java
@@ -1050,7 +1050,7 @@ public class BlurQueryStatus implements org.apache.blur.thirdparty.thrift_0_9_0.
                 struct.cpuTimes = new HashMap<String,CpuTime>(2*_map126.size);
                 for (int _i127 = 0; _i127 < _map126.size; ++_i127)
                 {
-                  String _key128; // optional
+                  String _key128; // required
                   CpuTime _val129; // required
                   _key128 = iprot.readString();
                   _val129 = new CpuTime();
@@ -1263,7 +1263,7 @@ public class BlurQueryStatus implements org.apache.blur.thirdparty.thrift_0_9_0.
           struct.cpuTimes = new HashMap<String,CpuTime>(2*_map132.size);
           for (int _i133 = 0; _i133 < _map132.size; ++_i133)
           {
-            String _key134; // optional
+            String _key134; // required
             CpuTime _val135; // required
             _key134 = iprot.readString();
             _val135 = new CpuTime();

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/36c8130b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/BlurResults.java
----------------------------------------------------------------------
diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/BlurResults.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/BlurResults.java
index aa923cc..a7fc566 100644
--- a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/BlurResults.java
+++ b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/BlurResults.java
@@ -900,7 +900,7 @@ public class BlurResults implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
                 struct.shardInfo = new HashMap<String,Long>(2*_map84.size);
                 for (int _i85 = 0; _i85 < _map84.size; ++_i85)
                 {
-                  String _key86; // optional
+                  String _key86; // required
                   long _val87; // required
                   _key86 = iprot.readString();
                   _val87 = iprot.readI64();
@@ -1146,7 +1146,7 @@ public class BlurResults implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
           struct.shardInfo = new HashMap<String,Long>(2*_map105.size);
           for (int _i106 = 0; _i106 < _map105.size; ++_i106)
           {
-            String _key107; // optional
+            String _key107; // required
             long _val108; // required
             _key107 = iprot.readString();
             _val108 = iprot.readI64();

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/36c8130b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/ColumnDefinition.java
----------------------------------------------------------------------
diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/ColumnDefinition.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/ColumnDefinition.java
index 55d1744..0ebf5a7 100644
--- a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/ColumnDefinition.java
+++ b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/ColumnDefinition.java
@@ -992,7 +992,7 @@ public class ColumnDefinition implements org.apache.blur.thirdparty.thrift_0_9_0
                 struct.properties = new HashMap<String,String>(2*_map136.size);
                 for (int _i137 = 0; _i137 < _map136.size; ++_i137)
                 {
-                  String _key138; // optional
+                  String _key138; // required
                   String _val139; // required
                   _key138 = iprot.readString();
                   _val139 = iprot.readString();
@@ -1167,7 +1167,7 @@ public class ColumnDefinition implements org.apache.blur.thirdparty.thrift_0_9_0
           struct.properties = new HashMap<String,String>(2*_map142.size);
           for (int _i143 = 0; _i143 < _map142.size; ++_i143)
           {
-            String _key144; // optional
+            String _key144; // required
             String _val145; // required
             _key144 = iprot.readString();
             _val145 = iprot.readString();

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/36c8130b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/CommandDescriptor.java
----------------------------------------------------------------------
diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/CommandDescriptor.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/CommandDescriptor.java
index 94ee231..5ccc1a1 100644
--- a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/CommandDescriptor.java
+++ b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/CommandDescriptor.java
@@ -793,7 +793,7 @@ public class CommandDescriptor implements org.apache.blur.thirdparty.thrift_0_9_
                 struct.requiredArguments = new HashMap<String,ArgumentDescriptor>(2*_map270.size);
                 for (int _i271 = 0; _i271 < _map270.size; ++_i271)
                 {
-                  String _key272; // optional
+                  String _key272; // required
                   ArgumentDescriptor _val273; // required
                   _key272 = iprot.readString();
                   _val273 = new ArgumentDescriptor();
@@ -814,7 +814,7 @@ public class CommandDescriptor implements org.apache.blur.thirdparty.thrift_0_9_
                 struct.optionalArguments = new HashMap<String,ArgumentDescriptor>(2*_map274.size);
                 for (int _i275 = 0; _i275 < _map274.size; ++_i275)
                 {
-                  String _key276; // optional
+                  String _key276; // required
                   ArgumentDescriptor _val277; // required
                   _key276 = iprot.readString();
                   _val277 = new ArgumentDescriptor();
@@ -994,7 +994,7 @@ public class CommandDescriptor implements org.apache.blur.thirdparty.thrift_0_9_
           struct.requiredArguments = new HashMap<String,ArgumentDescriptor>(2*_map282.size);
           for (int _i283 = 0; _i283 < _map282.size; ++_i283)
           {
-            String _key284; // optional
+            String _key284; // required
             ArgumentDescriptor _val285; // required
             _key284 = iprot.readString();
             _val285 = new ArgumentDescriptor();
@@ -1010,7 +1010,7 @@ public class CommandDescriptor implements org.apache.blur.thirdparty.thrift_0_9_
           struct.optionalArguments = new HashMap<String,ArgumentDescriptor>(2*_map286.size);
           for (int _i287 = 0; _i287 < _map286.size; ++_i287)
           {
-            String _key288; // optional
+            String _key288; // required
             ArgumentDescriptor _val289; // required
             _key288 = iprot.readString();
             _val289 = new ArgumentDescriptor();

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/36c8130b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Metric.java
----------------------------------------------------------------------
diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Metric.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Metric.java
index 8e2be42..ccb417c 100644
--- a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Metric.java
+++ b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Metric.java
@@ -707,7 +707,7 @@ public class Metric implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Met
                 struct.strMap = new HashMap<String,String>(2*_map202.size);
                 for (int _i203 = 0; _i203 < _map202.size; ++_i203)
                 {
-                  String _key204; // optional
+                  String _key204; // required
                   String _val205; // required
                   _key204 = iprot.readString();
                   _val205 = iprot.readString();
@@ -727,7 +727,7 @@ public class Metric implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Met
                 struct.longMap = new HashMap<String,Long>(2*_map206.size);
                 for (int _i207 = 0; _i207 < _map206.size; ++_i207)
                 {
-                  String _key208; // optional
+                  String _key208; // required
                   long _val209; // required
                   _key208 = iprot.readString();
                   _val209 = iprot.readI64();
@@ -747,7 +747,7 @@ public class Metric implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Met
                 struct.doubleMap = new HashMap<String,Double>(2*_map210.size);
                 for (int _i211 = 0; _i211 < _map210.size; ++_i211)
                 {
-                  String _key212; // optional
+                  String _key212; // required
                   double _val213; // required
                   _key212 = iprot.readString();
                   _val213 = iprot.readDouble();
@@ -899,7 +899,7 @@ public class Metric implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Met
           struct.strMap = new HashMap<String,String>(2*_map220.size);
           for (int _i221 = 0; _i221 < _map220.size; ++_i221)
           {
-            String _key222; // optional
+            String _key222; // required
             String _val223; // required
             _key222 = iprot.readString();
             _val223 = iprot.readString();
@@ -914,7 +914,7 @@ public class Metric implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Met
           struct.longMap = new HashMap<String,Long>(2*_map224.size);
           for (int _i225 = 0; _i225 < _map224.size; ++_i225)
           {
-            String _key226; // optional
+            String _key226; // required
             long _val227; // required
             _key226 = iprot.readString();
             _val227 = iprot.readI64();
@@ -929,7 +929,7 @@ public class Metric implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Met
           struct.doubleMap = new HashMap<String,Double>(2*_map228.size);
           for (int _i229 = 0; _i229 < _map228.size; ++_i229)
           {
-            String _key230; // optional
+            String _key230; // required
             double _val231; // required
             _key230 = iprot.readString();
             _val231 = iprot.readDouble();

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/36c8130b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Response.java
----------------------------------------------------------------------
diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Response.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Response.java
index 1e36a12..6354606 100644
--- a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Response.java
+++ b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Response.java
@@ -206,7 +206,7 @@ public class Response extends org.apache.blur.thirdparty.thrift_0_9_0.TUnion<Res
               shardToValue = new HashMap<Shard,ValueObject>(2*_map240.size);
               for (int _i241 = 0; _i241 < _map240.size; ++_i241)
               {
-                Shard _key242; // optional
+                Shard _key242; // required
                 ValueObject _val243; // required
                 _key242 = new Shard();
                 _key242.read(iprot);
@@ -229,7 +229,7 @@ public class Response extends org.apache.blur.thirdparty.thrift_0_9_0.TUnion<Res
               serverToValue = new HashMap<Server,ValueObject>(2*_map244.size);
               for (int _i245 = 0; _i245 < _map244.size; ++_i245)
               {
-                Server _key246; // optional
+                Server _key246; // required
                 ValueObject _val247; // required
                 _key246 = new Server();
                 _key246.read(iprot);
@@ -310,7 +310,7 @@ public class Response extends org.apache.blur.thirdparty.thrift_0_9_0.TUnion<Res
             shardToValue = new HashMap<Shard,ValueObject>(2*_map250.size);
             for (int _i251 = 0; _i251 < _map250.size; ++_i251)
             {
-              Shard _key252; // optional
+              Shard _key252; // required
               ValueObject _val253; // required
               _key252 = new Shard();
               _key252.read(iprot);
@@ -328,7 +328,7 @@ public class Response extends org.apache.blur.thirdparty.thrift_0_9_0.TUnion<Res
             serverToValue = new HashMap<Server,ValueObject>(2*_map254.size);
             for (int _i255 = 0; _i255 < _map254.size; ++_i255)
             {
-              Server _key256; // optional
+              Server _key256; // required
               ValueObject _val257; // required
               _key256 = new Server();
               _key256.read(iprot);

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/36c8130b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Schema.java
----------------------------------------------------------------------
diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Schema.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Schema.java
index 39e1dbb..ef3191c 100644
--- a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Schema.java
+++ b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Schema.java
@@ -492,7 +492,7 @@ public class Schema implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Sch
                 struct.families = new HashMap<String,Map<String,ColumnDefinition>>(2*_map146.size);
                 for (int _i147 = 0; _i147 < _map146.size; ++_i147)
                 {
-                  String _key148; // optional
+                  String _key148; // required
                   Map<String,ColumnDefinition> _val149; // required
                   _key148 = iprot.readString();
                   {
@@ -500,7 +500,7 @@ public class Schema implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Sch
                     _val149 = new HashMap<String,ColumnDefinition>(2*_map150.size);
                     for (int _i151 = 0; _i151 < _map150.size; ++_i151)
                     {
-                      String _key152; // optional
+                      String _key152; // required
                       ColumnDefinition _val153; // required
                       _key152 = iprot.readString();
                       _val153 = new ColumnDefinition();
@@ -620,7 +620,7 @@ public class Schema implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Sch
           struct.families = new HashMap<String,Map<String,ColumnDefinition>>(2*_map158.size);
           for (int _i159 = 0; _i159 < _map158.size; ++_i159)
           {
-            String _key160; // optional
+            String _key160; // required
             Map<String,ColumnDefinition> _val161; // required
             _key160 = iprot.readString();
             {
@@ -628,7 +628,7 @@ public class Schema implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Sch
               _val161 = new HashMap<String,ColumnDefinition>(2*_map162.size);
               for (int _i163 = 0; _i163 < _map162.size; ++_i163)
               {
-                String _key164; // optional
+                String _key164; // required
                 ColumnDefinition _val165; // required
                 _key164 = iprot.readString();
                 _val165 = new ColumnDefinition();

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/36c8130b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Selector.java
----------------------------------------------------------------------
diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Selector.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Selector.java
index af622c5..37385d7 100644
--- a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Selector.java
+++ b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Selector.java
@@ -1304,7 +1304,7 @@ public class Selector implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<S
                 struct.columnsToFetch = new HashMap<String,Set<String>>(2*_map29.size);
                 for (int _i30 = 0; _i30 < _map29.size; ++_i30)
                 {
-                  String _key31; // optional
+                  String _key31; // required
                   Set<String> _val32; // required
                   _key31 = iprot.readString();
                   {
@@ -1603,7 +1603,7 @@ public class Selector implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<S
           struct.columnsToFetch = new HashMap<String,Set<String>>(2*_map50.size);
           for (int _i51 = 0; _i51 < _map50.size; ++_i51)
           {
-            String _key52; // optional
+            String _key52; // required
             Set<String> _val53; // required
             _key52 = iprot.readString();
             {

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/36c8130b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/TableDescriptor.java
----------------------------------------------------------------------
diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/TableDescriptor.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/TableDescriptor.java
index 1a08bc0..3793c00 100644
--- a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/TableDescriptor.java
+++ b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/TableDescriptor.java
@@ -1799,7 +1799,7 @@ public class TableDescriptor implements org.apache.blur.thirdparty.thrift_0_9_0.
                 struct.tableProperties = new HashMap<String,String>(2*_map172.size);
                 for (int _i173 = 0; _i173 < _map172.size; ++_i173)
                 {
-                  String _key174; // optional
+                  String _key174; // required
                   String _val175; // required
                   _key174 = iprot.readString();
                   _val175 = iprot.readString();
@@ -1843,7 +1843,7 @@ public class TableDescriptor implements org.apache.blur.thirdparty.thrift_0_9_0.
                 struct.defaultMissingFieldProps = new HashMap<String,String>(2*_map176.size);
                 for (int _i177 = 0; _i177 < _map176.size; ++_i177)
                 {
-                  String _key178; // optional
+                  String _key178; // required
                   String _val179; // required
                   _key178 = iprot.readString();
                   _val179 = iprot.readString();
@@ -2169,7 +2169,7 @@ public class TableDescriptor implements org.apache.blur.thirdparty.thrift_0_9_0.
           struct.tableProperties = new HashMap<String,String>(2*_map194.size);
           for (int _i195 = 0; _i195 < _map194.size; ++_i195)
           {
-            String _key196; // optional
+            String _key196; // required
             String _val197; // required
             _key196 = iprot.readString();
             _val197 = iprot.readString();
@@ -2196,7 +2196,7 @@ public class TableDescriptor implements org.apache.blur.thirdparty.thrift_0_9_0.
           struct.defaultMissingFieldProps = new HashMap<String,String>(2*_map198.size);
           for (int _i199 = 0; _i199 < _map198.size; ++_i199)
           {
-            String _key200; // optional
+            String _key200; // required
             String _val201; // required
             _key200 = iprot.readString();
             _val201 = iprot.readString();

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/36c8130b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/User.java
----------------------------------------------------------------------
diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/User.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/User.java
index 33b0f91..8f152a6 100644
--- a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/User.java
+++ b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/User.java
@@ -480,8 +480,8 @@ public class User implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<User,
                 struct.attributes = new HashMap<String,String>(2*_map0.size);
                 for (int _i1 = 0; _i1 < _map0.size; ++_i1)
                 {
-                  String _key2; // optional
-                  String _val3; // required
+                  String _key2; // required
+                  String _val3; // optional
                   _key2 = iprot.readString();
                   _val3 = iprot.readString();
                   struct.attributes.put(_key2, _val3);
@@ -580,8 +580,8 @@ public class User implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<User,
           struct.attributes = new HashMap<String,String>(2*_map6.size);
           for (int _i7 = 0; _i7 < _map6.size; ++_i7)
           {
-            String _key8; // optional
-            String _val9; // required
+            String _key8; // required
+            String _val9; // optional
             _key8 = iprot.readString();
             _val9 = iprot.readString();
             struct.attributes.put(_key8, _val9);

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/36c8130b/distribution/src/main/scripts/interface/gen-js/Blur.js
----------------------------------------------------------------------
diff --git a/distribution/src/main/scripts/interface/gen-js/Blur.js b/distribution/src/main/scripts/interface/gen-js/Blur.js
index 0e6bf50..ddd43c2 100644
--- a/distribution/src/main/scripts/interface/gen-js/Blur.js
+++ b/distribution/src/main/scripts/interface/gen-js/Blur.js
@@ -4252,6 +4252,169 @@ Blur_bulkMutateAdd_result.prototype.write = function(output) {
   return;
 };
 
+Blur_bulkMutateAddMultiple_args = function(args) {
+  this.table = null;
+  this.bulkId = null;
+  this.rowMutations = null;
+  if (args) {
+    if (args.table !== undefined) {
+      this.table = args.table;
+    }
+    if (args.bulkId !== undefined) {
+      this.bulkId = args.bulkId;
+    }
+    if (args.rowMutations !== undefined) {
+      this.rowMutations = args.rowMutations;
+    }
+  }
+};
+Blur_bulkMutateAddMultiple_args.prototype = {};
+Blur_bulkMutateAddMultiple_args.prototype.read = function(input) {
+  input.readStructBegin();
+  while (true)
+  {
+    var ret = input.readFieldBegin();
+    var fname = ret.fname;
+    var ftype = ret.ftype;
+    var fid = ret.fid;
+    if (ftype == Thrift.Type.STOP) {
+      break;
+    }
+    switch (fid)
+    {
+      case 1:
+      if (ftype == Thrift.Type.STRING) {
+        this.table = input.readString().value;
+      } else {
+        input.skip(ftype);
+      }
+      break;
+      case 2:
+      if (ftype == Thrift.Type.STRING) {
+        this.bulkId = input.readString().value;
+      } else {
+        input.skip(ftype);
+      }
+      break;
+      case 3:
+      if (ftype == Thrift.Type.LIST) {
+        var _size372 = 0;
+        var _rtmp3376;
+        this.rowMutations = [];
+        var _etype375 = 0;
+        _rtmp3376 = input.readListBegin();
+        _etype375 = _rtmp3376.etype;
+        _size372 = _rtmp3376.size;
+        for (var _i377 = 0; _i377 < _size372; ++_i377)
+        {
+          var elem378 = null;
+          elem378 = new RowMutation();
+          elem378.read(input);
+          this.rowMutations.push(elem378);
+        }
+        input.readListEnd();
+      } else {
+        input.skip(ftype);
+      }
+      break;
+      default:
+        input.skip(ftype);
+    }
+    input.readFieldEnd();
+  }
+  input.readStructEnd();
+  return;
+};
+
+Blur_bulkMutateAddMultiple_args.prototype.write = function(output) {
+  output.writeStructBegin('Blur_bulkMutateAddMultiple_args');
+  if (this.table !== null && this.table !== undefined) {
+    output.writeFieldBegin('table', Thrift.Type.STRING, 1);
+    output.writeString(this.table);
+    output.writeFieldEnd();
+  }
+  if (this.bulkId !== null && this.bulkId !== undefined) {
+    output.writeFieldBegin('bulkId', Thrift.Type.STRING, 2);
+    output.writeString(this.bulkId);
+    output.writeFieldEnd();
+  }
+  if (this.rowMutations !== null && this.rowMutations !== undefined) {
+    output.writeFieldBegin('rowMutations', Thrift.Type.LIST, 3);
+    output.writeListBegin(Thrift.Type.STRUCT, this.rowMutations.length);
+    for (var iter379 in this.rowMutations)
+    {
+      if (this.rowMutations.hasOwnProperty(iter379))
+      {
+        iter379 = this.rowMutations[iter379];
+        iter379.write(output);
+      }
+    }
+    output.writeListEnd();
+    output.writeFieldEnd();
+  }
+  output.writeFieldStop();
+  output.writeStructEnd();
+  return;
+};
+
+Blur_bulkMutateAddMultiple_result = function(args) {
+  this.ex = null;
+  if (args instanceof BlurException) {
+    this.ex = args;
+    return;
+  }
+  if (args) {
+    if (args.ex !== undefined) {
+      this.ex = args.ex;
+    }
+  }
+};
+Blur_bulkMutateAddMultiple_result.prototype = {};
+Blur_bulkMutateAddMultiple_result.prototype.read = function(input) {
+  input.readStructBegin();
+  while (true)
+  {
+    var ret = input.readFieldBegin();
+    var fname = ret.fname;
+    var ftype = ret.ftype;
+    var fid = ret.fid;
+    if (ftype == Thrift.Type.STOP) {
+      break;
+    }
+    switch (fid)
+    {
+      case 1:
+      if (ftype == Thrift.Type.STRUCT) {
+        this.ex = new BlurException();
+        this.ex.read(input);
+      } else {
+        input.skip(ftype);
+      }
+      break;
+      case 0:
+        input.skip(ftype);
+        break;
+      default:
+        input.skip(ftype);
+    }
+    input.readFieldEnd();
+  }
+  input.readStructEnd();
+  return;
+};
+
+Blur_bulkMutateAddMultiple_result.prototype.write = function(output) {
+  output.writeStructBegin('Blur_bulkMutateAddMultiple_result');
+  if (this.ex !== null && this.ex !== undefined) {
+    output.writeFieldBegin('ex', Thrift.Type.STRUCT, 1);
+    this.ex.write(output);
+    output.writeFieldEnd();
+  }
+  output.writeFieldStop();
+  output.writeStructEnd();
+  return;
+};
+
 Blur_bulkMutateFinish_args = function(args) {
   this.table = null;
   this.bulkId = null;
@@ -4617,18 +4780,18 @@ Blur_queryStatusIdList_result.prototype.read = function(input) {
     {
       case 0:
       if (ftype == Thrift.Type.LIST) {
-        var _size372 = 0;
-        var _rtmp3376;
+        var _size380 = 0;
+        var _rtmp3384;
         this.success = [];
-        var _etype375 = 0;
-        _rtmp3376 = input.readListBegin();
-        _etype375 = _rtmp3376.etype;
-        _size372 = _rtmp3376.size;
-        for (var _i377 = 0; _i377 < _size372; ++_i377)
+        var _etype383 = 0;
+        _rtmp3384 = input.readListBegin();
+        _etype383 = _rtmp3384.etype;
+        _size380 = _rtmp3384.size;
+        for (var _i385 = 0; _i385 < _size380; ++_i385)
         {
-          var elem378 = null;
-          elem378 = input.readString().value;
-          this.success.push(elem378);
+          var elem386 = null;
+          elem386 = input.readString().value;
+          this.success.push(elem386);
         }
         input.readListEnd();
       } else {
@@ -4657,12 +4820,12 @@ Blur_queryStatusIdList_result.prototype.write = function(output) {
   if (this.success !== null && this.success !== undefined) {
     output.writeFieldBegin('success', Thrift.Type.LIST, 0);
     output.writeListBegin(Thrift.Type.STRING, this.success.length);
-    for (var iter379 in this.success)
+    for (var iter387 in this.success)
     {
-      if (this.success.hasOwnProperty(iter379))
+      if (this.success.hasOwnProperty(iter387))
       {
-        iter379 = this.success[iter379];
-        output.writeString(iter379);
+        iter387 = this.success[iter387];
+        output.writeString(iter387);
       }
     }
     output.writeListEnd();
@@ -4962,18 +5125,18 @@ Blur_terms_result.prototype.read = function(input) {
     {
       case 0:
       if (ftype == Thrift.Type.LIST) {
-        var _size380 = 0;
-        var _rtmp3384;
+        var _size388 = 0;
+        var _rtmp3392;
         this.success = [];
-        var _etype383 = 0;
-        _rtmp3384 = input.readListBegin();
-        _etype383 = _rtmp3384.etype;
-        _size380 = _rtmp3384.size;
-        for (var _i385 = 0; _i385 < _size380; ++_i385)
+        var _etype391 = 0;
+        _rtmp3392 = input.readListBegin();
+        _etype391 = _rtmp3392.etype;
+        _size388 = _rtmp3392.size;
+        for (var _i393 = 0; _i393 < _size388; ++_i393)
         {
-          var elem386 = null;
-          elem386 = input.readString().value;
-          this.success.push(elem386);
+          var elem394 = null;
+          elem394 = input.readString().value;
+          this.success.push(elem394);
         }
         input.readListEnd();
       } else {
@@ -5002,12 +5165,12 @@ Blur_terms_result.prototype.write = function(output) {
   if (this.success !== null && this.success !== undefined) {
     output.writeFieldBegin('success', Thrift.Type.LIST, 0);
     output.writeListBegin(Thrift.Type.STRING, this.success.length);
-    for (var iter387 in this.success)
+    for (var iter395 in this.success)
     {
-      if (this.success.hasOwnProperty(iter387))
+      if (this.success.hasOwnProperty(iter395))
       {
-        iter387 = this.success[iter387];
-        output.writeString(iter387);
+        iter395 = this.success[iter395];
+        output.writeString(iter395);
       }
     }
     output.writeListEnd();
@@ -5252,18 +5415,18 @@ Blur_shardClusterList_result.prototype.read = function(input) {
     {
       case 0:
       if (ftype == Thrift.Type.LIST) {
-        var _size388 = 0;
-        var _rtmp3392;
+        var _size396 = 0;
+        var _rtmp3400;
         this.success = [];
-        var _etype391 = 0;
-        _rtmp3392 = input.readListBegin();
-        _etype391 = _rtmp3392.etype;
-        _size388 = _rtmp3392.size;
-        for (var _i393 = 0; _i393 < _size388; ++_i393)
+        var _etype399 = 0;
+        _rtmp3400 = input.readListBegin();
+        _etype399 = _rtmp3400.etype;
+        _size396 = _rtmp3400.size;
+        for (var _i401 = 0; _i401 < _size396; ++_i401)
         {
-          var elem394 = null;
-          elem394 = input.readString().value;
-          this.success.push(elem394);
+          var elem402 = null;
+          elem402 = input.readString().value;
+          this.success.push(elem402);
         }
         input.readListEnd();
       } else {
@@ -5292,12 +5455,12 @@ Blur_shardClusterList_result.prototype.write = function(output) {
   if (this.success !== null && this.success !== undefined) {
     output.writeFieldBegin('success', Thrift.Type.LIST, 0);
     output.writeListBegin(Thrift.Type.STRING, this.success.length);
-    for (var iter395 in this.success)
+    for (var iter403 in this.success)
     {
-      if (this.success.hasOwnProperty(iter395))
+      if (this.success.hasOwnProperty(iter403))
       {
-        iter395 = this.success[iter395];
-        output.writeString(iter395);
+        iter403 = this.success[iter403];
+        output.writeString(iter403);
       }
     }
     output.writeListEnd();
@@ -5398,18 +5561,18 @@ Blur_shardServerList_result.prototype.read = function(input) {
     {
       case 0:
       if (ftype == Thrift.Type.LIST) {
-        var _size396 = 0;
-        var _rtmp3400;
+        var _size404 = 0;
+        var _rtmp3408;
         this.success = [];
-        var _etype399 = 0;
-        _rtmp3400 = input.readListBegin();
-        _etype399 = _rtmp3400.etype;
-        _size396 = _rtmp3400.size;
-        for (var _i401 = 0; _i401 < _size396; ++_i401)
+        var _etype407 = 0;
+        _rtmp3408 = input.readListBegin();
+        _etype407 = _rtmp3408.etype;
+        _size404 = _rtmp3408.size;
+        for (var _i409 = 0; _i409 < _size404; ++_i409)
         {
-          var elem402 = null;
-          elem402 = input.readString().value;
-          this.success.push(elem402);
+          var elem410 = null;
+          elem410 = input.readString().value;
+          this.success.push(elem410);
         }
         input.readListEnd();
       } else {
@@ -5438,12 +5601,12 @@ Blur_shardServerList_result.prototype.write = function(output) {
   if (this.success !== null && this.success !== undefined) {
     output.writeFieldBegin('success', Thrift.Type.LIST, 0);
     output.writeListBegin(Thrift.Type.STRING, this.success.length);
-    for (var iter403 in this.success)
+    for (var iter411 in this.success)
     {
-      if (this.success.hasOwnProperty(iter403))
+      if (this.success.hasOwnProperty(iter411))
       {
-        iter403 = this.success[iter403];
-        output.writeString(iter403);
+        iter411 = this.success[iter411];
+        output.writeString(iter411);
       }
     }
     output.writeListEnd();
@@ -5519,18 +5682,18 @@ Blur_controllerServerList_result.prototype.read = function(input) {
     {
       case 0:
       if (ftype == Thrift.Type.LIST) {
-        var _size404 = 0;
-        var _rtmp3408;
+        var _size412 = 0;
+        var _rtmp3416;
         this.success = [];
-        var _etype407 = 0;
-        _rtmp3408 = input.readListBegin();
-        _etype407 = _rtmp3408.etype;
-        _size404 = _rtmp3408.size;
-        for (var _i409 = 0; _i409 < _size404; ++_i409)
+        var _etype415 = 0;
+        _rtmp3416 = input.readListBegin();
+        _etype415 = _rtmp3416.etype;
+        _size412 = _rtmp3416.size;
+        for (var _i417 = 0; _i417 < _size412; ++_i417)
         {
-          var elem410 = null;
-          elem410 = input.readString().value;
-          this.success.push(elem410);
+          var elem418 = null;
+          elem418 = input.readString().value;
+          this.success.push(elem418);
         }
         input.readListEnd();
       } else {
@@ -5559,12 +5722,12 @@ Blur_controllerServerList_result.prototype.write = function(output) {
   if (this.success !== null && this.success !== undefined) {
     output.writeFieldBegin('success', Thrift.Type.LIST, 0);
     output.writeListBegin(Thrift.Type.STRING, this.success.length);
-    for (var iter411 in this.success)
+    for (var iter419 in this.success)
     {
-      if (this.success.hasOwnProperty(iter411))
+      if (this.success.hasOwnProperty(iter419))
       {
-        iter411 = this.success[iter411];
-        output.writeString(iter411);
+        iter419 = this.success[iter419];
+        output.writeString(iter419);
       }
     }
     output.writeListEnd();
@@ -5665,27 +5828,27 @@ Blur_shardServerLayout_result.prototype.read = function(input) {
     {
       case 0:
       if (ftype == Thrift.Type.MAP) {
-        var _size412 = 0;
-        var _rtmp3416;
+        var _size420 = 0;
+        var _rtmp3424;
         this.success = {};
-        var _ktype413 = 0;
-        var _vtype414 = 0;
-        _rtmp3416 = input.readMapBegin();
-        _ktype413 = _rtmp3416.ktype;
-        _vtype414 = _rtmp3416.vtype;
-        _size412 = _rtmp3416.size;
-        for (var _i417 = 0; _i417 < _size412; ++_i417)
+        var _ktype421 = 0;
+        var _vtype422 = 0;
+        _rtmp3424 = input.readMapBegin();
+        _ktype421 = _rtmp3424.ktype;
+        _vtype422 = _rtmp3424.vtype;
+        _size420 = _rtmp3424.size;
+        for (var _i425 = 0; _i425 < _size420; ++_i425)
         {
-          if (_i417 > 0 ) {
+          if (_i425 > 0 ) {
             if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) {
               input.rstack.pop();
             }
           }
-          var key418 = null;
-          var val419 = null;
-          key418 = input.readString().value;
-          val419 = input.readString().value;
-          this.success[key418] = val419;
+          var key426 = null;
+          var val427 = null;
+          key426 = input.readString().value;
+          val427 = input.readString().value;
+          this.success[key426] = val427;
         }
         input.readMapEnd();
       } else {
@@ -5714,13 +5877,13 @@ Blur_shardServerLayout_result.prototype.write = function(output) {
   if (this.success !== null && this.success !== undefined) {
     output.writeFieldBegin('success', Thrift.Type.MAP, 0);
     output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.STRING, Thrift.objectLength(this.success));
-    for (var kiter420 in this.success)
+    for (var kiter428 in this.success)
     {
-      if (this.success.hasOwnProperty(kiter420))
+      if (this.success.hasOwnProperty(kiter428))
       {
-        var viter421 = this.success[kiter420];
-        output.writeString(kiter420);
-        output.writeString(viter421);
+        var viter429 = this.success[kiter428];
+        output.writeString(kiter428);
+        output.writeString(viter429);
       }
     }
     output.writeMapEnd();
@@ -5821,49 +5984,49 @@ Blur_shardServerLayoutState_result.prototype.read = function(input) {
     {
       case 0:
       if (ftype == Thrift.Type.MAP) {
-        var _size422 = 0;
-        var _rtmp3426;
+        var _size430 = 0;
+        var _rtmp3434;
         this.success = {};
-        var _ktype423 = 0;
-        var _vtype424 = 0;
-        _rtmp3426 = input.readMapBegin();
-        _ktype423 = _rtmp3426.ktype;
-        _vtype424 = _rtmp3426.vtype;
-        _size422 = _rtmp3426.size;
-        for (var _i427 = 0; _i427 < _size422; ++_i427)
+        var _ktype431 = 0;
+        var _vtype432 = 0;
+        _rtmp3434 = input.readMapBegin();
+        _ktype431 = _rtmp3434.ktype;
+        _vtype432 = _rtmp3434.vtype;
+        _size430 = _rtmp3434.size;
+        for (var _i435 = 0; _i435 < _size430; ++_i435)
         {
-          if (_i427 > 0 ) {
+          if (_i435 > 0 ) {
             if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) {
               input.rstack.pop();
             }
           }
-          var key428 = null;
-          var val429 = null;
-          key428 = input.readString().value;
-          var _size430 = 0;
-          var _rtmp3434;
-          val429 = {};
-          var _ktype431 = 0;
-          var _vtype432 = 0;
-          _rtmp3434 = input.readMapBegin();
-          _ktype431 = _rtmp3434.ktype;
-          _vtype432 = _rtmp3434.vtype;
-          _size430 = _rtmp3434.size;
-          for (var _i435 = 0; _i435 < _size430; ++_i435)
+          var key436 = null;
+          var val437 = null;
+          key436 = input.readString().value;
+          var _size438 = 0;
+          var _rtmp3442;
+          val437 = {};
+          var _ktype439 = 0;
+          var _vtype440 = 0;
+          _rtmp3442 = input.readMapBegin();
+          _ktype439 = _rtmp3442.ktype;
+          _vtype440 = _rtmp3442.vtype;
+          _size438 = _rtmp3442.size;
+          for (var _i443 = 0; _i443 < _size438; ++_i443)
           {
-            if (_i435 > 0 ) {
+            if (_i443 > 0 ) {
               if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) {
                 input.rstack.pop();
               }
             }
-            var key436 = null;
-            var val437 = null;
-            key436 = input.readString().value;
-            val437 = input.readI32().value;
-            val429[key436] = val437;
+            var key444 = null;
+            var val445 = null;
+            key444 = input.readString().value;
+            val445 = input.readI32().value;
+            val437[key444] = val445;
           }
           input.readMapEnd();
-          this.success[key428] = val429;
+          this.success[key436] = val437;
         }
         input.readMapEnd();
       } else {
@@ -5892,20 +6055,20 @@ Blur_shardServerLayoutState_result.prototype.write = function(output) {
   if (this.success !== null && this.success !== undefined) {
     output.writeFieldBegin('success', Thrift.Type.MAP, 0);
     output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.MAP, Thrift.objectLength(this.success));
-    for (var kiter438 in this.success)
+    for (var kiter446 in this.success)
     {
-      if (this.success.hasOwnProperty(kiter438))
+      if (this.success.hasOwnProperty(kiter446))
       {
-        var viter439 = this.success[kiter438];
-        output.writeString(kiter438);
-        output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.I32, Thrift.objectLength(viter439));
-        for (var kiter440 in viter439)
+        var viter447 = this.success[kiter446];
+        output.writeString(kiter446);
+        output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.I32, Thrift.objectLength(viter447));
+        for (var kiter448 in viter447)
         {
-          if (viter439.hasOwnProperty(kiter440))
+          if (viter447.hasOwnProperty(kiter448))
           {
-            var viter441 = viter439[kiter440];
-            output.writeString(kiter440);
-            output.writeI32(viter441);
+            var viter449 = viter447[kiter448];
+            output.writeString(kiter448);
+            output.writeI32(viter449);
           }
         }
         output.writeMapEnd();
@@ -6108,27 +6271,27 @@ Blur_configuration_result.prototype.read = function(input) {
     {
       case 0:
       if (ftype == Thrift.Type.MAP) {
-        var _size442 = 0;
-        var _rtmp3446;
+        var _size450 = 0;
+        var _rtmp3454;
         this.success = {};
-        var _ktype443 = 0;
-        var _vtype444 = 0;
-        _rtmp3446 = input.readMapBegin();
-        _ktype443 = _rtmp3446.ktype;
-        _vtype444 = _rtmp3446.vtype;
-        _size442 = _rtmp3446.size;
-        for (var _i447 = 0; _i447 < _size442; ++_i447)
+        var _ktype451 = 0;
+        var _vtype452 = 0;
+        _rtmp3454 = input.readMapBegin();
+        _ktype451 = _rtmp3454.ktype;
+        _vtype452 = _rtmp3454.vtype;
+        _size450 = _rtmp3454.size;
+        for (var _i455 = 0; _i455 < _size450; ++_i455)
         {
-          if (_i447 > 0 ) {
+          if (_i455 > 0 ) {
             if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) {
               input.rstack.pop();
             }
           }
-          var key448 = null;
-          var val449 = null;
-          key448 = input.readString().value;
-          val449 = input.readString().value;
-          this.success[key448] = val449;
+          var key456 = null;
+          var val457 = null;
+          key456 = input.readString().value;
+          val457 = input.readString().value;
+          this.success[key456] = val457;
         }
         input.readMapEnd();
       } else {
@@ -6157,13 +6320,13 @@ Blur_configuration_result.prototype.write = function(output) {
   if (this.success !== null && this.success !== undefined) {
     output.writeFieldBegin('success', Thrift.Type.MAP, 0);
     output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.STRING, Thrift.objectLength(this.success));
-    for (var kiter450 in this.success)
+    for (var kiter458 in this.success)
     {
-      if (this.success.hasOwnProperty(kiter450))
+      if (this.success.hasOwnProperty(kiter458))
       {
-        var viter451 = this.success[kiter450];
-        output.writeString(kiter450);
-        output.writeString(viter451);
+        var viter459 = this.success[kiter458];
+        output.writeString(kiter458);
+        output.writeString(viter459);
       }
     }
     output.writeMapEnd();
@@ -6203,18 +6366,18 @@ Blur_metrics_args.prototype.read = function(input) {
     {
       case 1:
       if (ftype == Thrift.Type.SET) {
-        var _size452 = 0;
-        var _rtmp3456;
+        var _size460 = 0;
+        var _rtmp3464;
         this.metrics = [];
-        var _etype455 = 0;
-        _rtmp3456 = input.readSetBegin();
-        _etype455 = _rtmp3456.etype;
-        _size452 = _rtmp3456.size;
-        for (var _i457 = 0; _i457 < _size452; ++_i457)
+        var _etype463 = 0;
+        _rtmp3464 = input.readSetBegin();
+        _etype463 = _rtmp3464.etype;
+        _size460 = _rtmp3464.size;
+        for (var _i465 = 0; _i465 < _size460; ++_i465)
         {
-          var elem458 = null;
-          elem458 = input.readString().value;
-          this.metrics.push(elem458);
+          var elem466 = null;
+          elem466 = input.readString().value;
+          this.metrics.push(elem466);
         }
         input.readSetEnd();
       } else {
@@ -6238,12 +6401,12 @@ Blur_metrics_args.prototype.write = function(output) {
   if (this.metrics !== null && this.metrics !== undefined) {
     output.writeFieldBegin('metrics', Thrift.Type.SET, 1);
     output.writeSetBegin(Thrift.Type.STRING, this.metrics.length);
-    for (var iter459 in this.metrics)
+    for (var iter467 in this.metrics)
     {
-      if (this.metrics.hasOwnProperty(iter459))
+      if (this.metrics.hasOwnProperty(iter467))
       {
-        iter459 = this.metrics[iter459];
-        output.writeString(iter459);
+        iter467 = this.metrics[iter467];
+        output.writeString(iter467);
       }
     }
     output.writeSetEnd();
@@ -6286,28 +6449,28 @@ Blur_metrics_result.prototype.read = function(input) {
     {
       case 0:
       if (ftype == Thrift.Type.MAP) {
-        var _size460 = 0;
-        var _rtmp3464;
+        var _size468 = 0;
+        var _rtmp3472;
         this.success = {};
-        var _ktype461 = 0;
-        var _vtype462 = 0;
-        _rtmp3464 = input.readMapBegin();
-        _ktype461 = _rtmp3464.ktype;
-        _vtype462 = _rtmp3464.vtype;
-        _size460 = _rtmp3464.size;
-        for (var _i465 = 0; _i465 < _size460; ++_i465)
+        var _ktype469 = 0;
+        var _vtype470 = 0;
+        _rtmp3472 = input.readMapBegin();
+        _ktype469 = _rtmp3472.ktype;
+        _vtype470 = _rtmp3472.vtype;
+        _size468 = _rtmp3472.size;
+        for (var _i473 = 0; _i473 < _size468; ++_i473)
         {
-          if (_i465 > 0 ) {
+          if (_i473 > 0 ) {
             if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) {
               input.rstack.pop();
             }
           }
-          var key466 = null;
-          var val467 = null;
-          key466 = input.readString().value;
-          val467 = new Metric();
-          val467.read(input);
-          this.success[key466] = val467;
+          var key474 = null;
+          var val475 = null;
+          key474 = input.readString().value;
+          val475 = new Metric();
+          val475.read(input);
+          this.success[key474] = val475;
         }
         input.readMapEnd();
       } else {
@@ -6336,13 +6499,13 @@ Blur_metrics_result.prototype.write = function(output) {
   if (this.success !== null && this.success !== undefined) {
     output.writeFieldBegin('success', Thrift.Type.MAP, 0);
     output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.STRUCT, Thrift.objectLength(this.success));
-    for (var kiter468 in this.success)
+    for (var kiter476 in this.success)
     {
-      if (this.success.hasOwnProperty(kiter468))
+      if (this.success.hasOwnProperty(kiter476))
       {
-        var viter469 = this.success[kiter468];
-        output.writeString(kiter468);
-        viter469.write(output);
+        var viter477 = this.success[kiter476];
+        output.writeString(kiter476);
+        viter477.write(output);
       }
     }
     output.writeMapEnd();
@@ -6512,18 +6675,18 @@ Blur_traceList_result.prototype.read = function(input) {
     {
       case 0:
       if (ftype == Thrift.Type.LIST) {
-        var _size470 = 0;
-        var _rtmp3474;
+        var _size478 = 0;
+        var _rtmp3482;
         this.success = [];
-        var _etype473 = 0;
-        _rtmp3474 = input.readListBegin();
-        _etype473 = _rtmp3474.etype;
-        _size470 = _rtmp3474.size;
-        for (var _i475 = 0; _i475 < _size470; ++_i475)
+        var _etype481 = 0;
+        _rtmp3482 = input.readListBegin();
+        _etype481 = _rtmp3482.etype;
+        _size478 = _rtmp3482.size;
+        for (var _i483 = 0; _i483 < _size478; ++_i483)
         {
-          var elem476 = null;
-          elem476 = input.readString().value;
-          this.success.push(elem476);
+          var elem484 = null;
+          elem484 = input.readString().value;
+          this.success.push(elem484);
         }
         input.readListEnd();
       } else {
@@ -6552,12 +6715,12 @@ Blur_traceList_result.prototype.write = function(output) {
   if (this.success !== null && this.success !== undefined) {
     output.writeFieldBegin('success', Thrift.Type.LIST, 0);
     output.writeListBegin(Thrift.Type.STRING, this.success.length);
-    for (var iter477 in this.success)
+    for (var iter485 in this.success)
     {
-      if (this.success.hasOwnProperty(iter477))
+      if (this.success.hasOwnProperty(iter485))
       {
-        iter477 = this.success[iter477];
-        output.writeString(iter477);
+        iter485 = this.success[iter485];
+        output.writeString(iter485);
       }
     }
     output.writeListEnd();
@@ -6658,18 +6821,18 @@ Blur_traceRequestList_result.prototype.read = function(input) {
     {
       case 0:
       if (ftype == Thrift.Type.LIST) {
-        var _size478 = 0;
-        var _rtmp3482;
+        var _size486 = 0;
+        var _rtmp3490;
         this.success = [];
-        var _etype481 = 0;
-        _rtmp3482 = input.readListBegin();
-        _etype481 = _rtmp3482.etype;
-        _size478 = _rtmp3482.size;
-        for (var _i483 = 0; _i483 < _size478; ++_i483)
+        var _etype489 = 0;
+        _rtmp3490 = input.readListBegin();
+        _etype489 = _rtmp3490.etype;
+        _size486 = _rtmp3490.size;
+        for (var _i491 = 0; _i491 < _size486; ++_i491)
         {
-          var elem484 = null;
-          elem484 = input.readString().value;
-          this.success.push(elem484);
+          var elem492 = null;
+          elem492 = input.readString().value;
+          this.success.push(elem492);
         }
         input.readListEnd();
       } else {
@@ -6698,12 +6861,12 @@ Blur_traceRequestList_result.prototype.write = function(output) {
   if (this.success !== null && this.success !== undefined) {
     output.writeFieldBegin('success', Thrift.Type.LIST, 0);
     output.writeListBegin(Thrift.Type.STRING, this.success.length);
-    for (var iter485 in this.success)
+    for (var iter493 in this.success)
     {
-      if (this.success.hasOwnProperty(iter485))
+      if (this.success.hasOwnProperty(iter493))
       {
-        iter485 = this.success[iter485];
-        output.writeString(iter485);
+        iter493 = this.success[iter493];
+        output.writeString(iter493);
       }
     }
     output.writeListEnd();
@@ -8384,6 +8547,42 @@ BlurClient.prototype.recv_bulkMutateAdd = function() {
   }
   return;
 };
+BlurClient.prototype.bulkMutateAddMultiple = function(table, bulkId, rowMutations) {
+  this.send_bulkMutateAddMultiple(table, bulkId, rowMutations);
+  this.recv_bulkMutateAddMultiple();
+};
+
+BlurClient.prototype.send_bulkMutateAddMultiple = function(table, bulkId, rowMutations) {
+  this.output.writeMessageBegin('bulkMutateAddMultiple', Thrift.MessageType.CALL, this.seqid);
+  var args = new Blur_bulkMutateAddMultiple_args();
+  args.table = table;
+  args.bulkId = bulkId;
+  args.rowMutations = rowMutations;
+  args.write(this.output);
+  this.output.writeMessageEnd();
+  return this.output.getTransport().flush();
+};
+
+BlurClient.prototype.recv_bulkMutateAddMultiple = function() {
+  var ret = this.input.readMessageBegin();
+  var fname = ret.fname;
+  var mtype = ret.mtype;
+  var rseqid = ret.rseqid;
+  if (mtype == Thrift.MessageType.EXCEPTION) {
+    var x = new Thrift.TApplicationException();
+    x.read(this.input);
+    this.input.readMessageEnd();
+    throw x;
+  }
+  var result = new Blur_bulkMutateAddMultiple_result();
+  result.read(this.input);
+  this.input.readMessageEnd();
+
+  if (null !== result.ex) {
+    throw result.ex;
+  }
+  return;
+};
 BlurClient.prototype.bulkMutateFinish = function(table, bulkId, apply, blockUntilComplete) {
   this.send_bulkMutateFinish(table, bulkId, apply, blockUntilComplete);
   this.recv_bulkMutateFinish();

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/36c8130b/distribution/src/main/scripts/interface/gen-perl/Blur/Blur.pm
----------------------------------------------------------------------
diff --git a/distribution/src/main/scripts/interface/gen-perl/Blur/Blur.pm b/distribution/src/main/scripts/interface/gen-perl/Blur/Blur.pm
index 088af03..2c51e04 100644
--- a/distribution/src/main/scripts/interface/gen-perl/Blur/Blur.pm
+++ b/distribution/src/main/scripts/interface/gen-perl/Blur/Blur.pm
@@ -4926,6 +4926,187 @@ sub write {
   return $xfer;
 }
 
+package Blur::Blur_bulkMutateAddMultiple_args;
+use base qw(Class::Accessor);
+Blur::Blur_bulkMutateAddMultiple_args->mk_accessors( qw( table bulkId rowMutations ) );
+
+sub new {
+  my $classname = shift;
+  my $self      = {};
+  my $vals      = shift || {};
+  $self->{table} = undef;
+  $self->{bulkId} = undef;
+  $self->{rowMutations} = undef;
+  if (UNIVERSAL::isa($vals,'HASH')) {
+    if (defined $vals->{table}) {
+      $self->{table} = $vals->{table};
+    }
+    if (defined $vals->{bulkId}) {
+      $self->{bulkId} = $vals->{bulkId};
+    }
+    if (defined $vals->{rowMutations}) {
+      $self->{rowMutations} = $vals->{rowMutations};
+    }
+  }
+  return bless ($self, $classname);
+}
+
+sub getName {
+  return 'Blur_bulkMutateAddMultiple_args';
+}
+
+sub read {
+  my ($self, $input) = @_;
+  my $xfer  = 0;
+  my $fname;
+  my $ftype = 0;
+  my $fid   = 0;
+  $xfer += $input->readStructBegin(\$fname);
+  while (1) 
+  {
+    $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+    if ($ftype == TType::STOP) {
+      last;
+    }
+    SWITCH: for($fid)
+    {
+      /^1$/ && do{      if ($ftype == TType::STRING) {
+        $xfer += $input->readString(\$self->{table});
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+      /^2$/ && do{      if ($ftype == TType::STRING) {
+        $xfer += $input->readString(\$self->{bulkId});
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+      /^3$/ && do{      if ($ftype == TType::LIST) {
+        {
+          my $_size330 = 0;
+          $self->{rowMutations} = [];
+          my $_etype333 = 0;
+          $xfer += $input->readListBegin(\$_etype333, \$_size330);
+          for (my $_i334 = 0; $_i334 < $_size330; ++$_i334)
+          {
+            my $elem335 = undef;
+            $elem335 = new Blur::RowMutation();
+            $xfer += $elem335->read($input);
+            push(@{$self->{rowMutations}},$elem335);
+          }
+          $xfer += $input->readListEnd();
+        }
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+        $xfer += $input->skip($ftype);
+    }
+    $xfer += $input->readFieldEnd();
+  }
+  $xfer += $input->readStructEnd();
+  return $xfer;
+}
+
+sub write {
+  my ($self, $output) = @_;
+  my $xfer   = 0;
+  $xfer += $output->writeStructBegin('Blur_bulkMutateAddMultiple_args');
+  if (defined $self->{table}) {
+    $xfer += $output->writeFieldBegin('table', TType::STRING, 1);
+    $xfer += $output->writeString($self->{table});
+    $xfer += $output->writeFieldEnd();
+  }
+  if (defined $self->{bulkId}) {
+    $xfer += $output->writeFieldBegin('bulkId', TType::STRING, 2);
+    $xfer += $output->writeString($self->{bulkId});
+    $xfer += $output->writeFieldEnd();
+  }
+  if (defined $self->{rowMutations}) {
+    $xfer += $output->writeFieldBegin('rowMutations', TType::LIST, 3);
+    {
+      $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{rowMutations}}));
+      {
+        foreach my $iter336 (@{$self->{rowMutations}}) 
+        {
+          $xfer += ${iter336}->write($output);
+        }
+      }
+      $xfer += $output->writeListEnd();
+    }
+    $xfer += $output->writeFieldEnd();
+  }
+  $xfer += $output->writeFieldStop();
+  $xfer += $output->writeStructEnd();
+  return $xfer;
+}
+
+package Blur::Blur_bulkMutateAddMultiple_result;
+use base qw(Class::Accessor);
+Blur::Blur_bulkMutateAddMultiple_result->mk_accessors( qw( ) );
+
+sub new {
+  my $classname = shift;
+  my $self      = {};
+  my $vals      = shift || {};
+  $self->{ex} = undef;
+  if (UNIVERSAL::isa($vals,'HASH')) {
+    if (defined $vals->{ex}) {
+      $self->{ex} = $vals->{ex};
+    }
+  }
+  return bless ($self, $classname);
+}
+
+sub getName {
+  return 'Blur_bulkMutateAddMultiple_result';
+}
+
+sub read {
+  my ($self, $input) = @_;
+  my $xfer  = 0;
+  my $fname;
+  my $ftype = 0;
+  my $fid   = 0;
+  $xfer += $input->readStructBegin(\$fname);
+  while (1) 
+  {
+    $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+    if ($ftype == TType::STOP) {
+      last;
+    }
+    SWITCH: for($fid)
+    {
+      /^1$/ && do{      if ($ftype == TType::STRUCT) {
+        $self->{ex} = new Blur::BlurException();
+        $xfer += $self->{ex}->read($input);
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+        $xfer += $input->skip($ftype);
+    }
+    $xfer += $input->readFieldEnd();
+  }
+  $xfer += $input->readStructEnd();
+  return $xfer;
+}
+
+sub write {
+  my ($self, $output) = @_;
+  my $xfer   = 0;
+  $xfer += $output->writeStructBegin('Blur_bulkMutateAddMultiple_result');
+  if (defined $self->{ex}) {
+    $xfer += $output->writeFieldBegin('ex', TType::STRUCT, 1);
+    $xfer += $self->{ex}->write($output);
+    $xfer += $output->writeFieldEnd();
+  }
+  $xfer += $output->writeFieldStop();
+  $xfer += $output->writeStructEnd();
+  return $xfer;
+}
+
 package Blur::Blur_bulkMutateFinish_args;
 use base qw(Class::Accessor);
 Blur::Blur_bulkMutateFinish_args->mk_accessors( qw( table bulkId apply blockUntilComplete ) );
@@ -5350,15 +5531,15 @@ sub read {
     {
       /^0$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size330 = 0;
+          my $_size337 = 0;
           $self->{success} = [];
-          my $_etype333 = 0;
-          $xfer += $input->readListBegin(\$_etype333, \$_size330);
-          for (my $_i334 = 0; $_i334 < $_size330; ++$_i334)
+          my $_etype340 = 0;
+          $xfer += $input->readListBegin(\$_etype340, \$_size337);
+          for (my $_i341 = 0; $_i341 < $_size337; ++$_i341)
           {
-            my $elem335 = undef;
-            $xfer += $input->readString(\$elem335);
-            push(@{$self->{success}},$elem335);
+            my $elem342 = undef;
+            $xfer += $input->readString(\$elem342);
+            push(@{$self->{success}},$elem342);
           }
           $xfer += $input->readListEnd();
         }
@@ -5390,9 +5571,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRING, scalar(@{$self->{success}}));
       {
-        foreach my $iter336 (@{$self->{success}}) 
+        foreach my $iter343 (@{$self->{success}}) 
         {
-          $xfer += $output->writeString($iter336);
+          $xfer += $output->writeString($iter343);
         }
       }
       $xfer += $output->writeListEnd();
@@ -5735,15 +5916,15 @@ sub read {
     {
       /^0$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size337 = 0;
+          my $_size344 = 0;
           $self->{success} = [];
-          my $_etype340 = 0;
-          $xfer += $input->readListBegin(\$_etype340, \$_size337);
-          for (my $_i341 = 0; $_i341 < $_size337; ++$_i341)
+          my $_etype347 = 0;
+          $xfer += $input->readListBegin(\$_etype347, \$_size344);
+          for (my $_i348 = 0; $_i348 < $_size344; ++$_i348)
           {
-            my $elem342 = undef;
-            $xfer += $input->readString(\$elem342);
-            push(@{$self->{success}},$elem342);
+            my $elem349 = undef;
+            $xfer += $input->readString(\$elem349);
+            push(@{$self->{success}},$elem349);
           }
           $xfer += $input->readListEnd();
         }
@@ -5775,9 +5956,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRING, scalar(@{$self->{success}}));
       {
-        foreach my $iter343 (@{$self->{success}}) 
+        foreach my $iter350 (@{$self->{success}}) 
         {
-          $xfer += $output->writeString($iter343);
+          $xfer += $output->writeString($iter350);
         }
       }
       $xfer += $output->writeListEnd();
@@ -6071,15 +6252,15 @@ sub read {
     {
       /^0$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size344 = 0;
+          my $_size351 = 0;
           $self->{success} = [];
-          my $_etype347 = 0;
-          $xfer += $input->readListBegin(\$_etype347, \$_size344);
-          for (my $_i348 = 0; $_i348 < $_size344; ++$_i348)
+          my $_etype354 = 0;
+          $xfer += $input->readListBegin(\$_etype354, \$_size351);
+          for (my $_i355 = 0; $_i355 < $_size351; ++$_i355)
           {
-            my $elem349 = undef;
-            $xfer += $input->readString(\$elem349);
-            push(@{$self->{success}},$elem349);
+            my $elem356 = undef;
+            $xfer += $input->readString(\$elem356);
+            push(@{$self->{success}},$elem356);
           }
           $xfer += $input->readListEnd();
         }
@@ -6111,9 +6292,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRING, scalar(@{$self->{success}}));
       {
-        foreach my $iter350 (@{$self->{success}}) 
+        foreach my $iter357 (@{$self->{success}}) 
         {
-          $xfer += $output->writeString($iter350);
+          $xfer += $output->writeString($iter357);
         }
       }
       $xfer += $output->writeListEnd();
@@ -6236,15 +6417,15 @@ sub read {
     {
       /^0$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size351 = 0;
+          my $_size358 = 0;
           $self->{success} = [];
-          my $_etype354 = 0;
-          $xfer += $input->readListBegin(\$_etype354, \$_size351);
-          for (my $_i355 = 0; $_i355 < $_size351; ++$_i355)
+          my $_etype361 = 0;
+          $xfer += $input->readListBegin(\$_etype361, \$_size358);
+          for (my $_i362 = 0; $_i362 < $_size358; ++$_i362)
           {
-            my $elem356 = undef;
-            $xfer += $input->readString(\$elem356);
-            push(@{$self->{success}},$elem356);
+            my $elem363 = undef;
+            $xfer += $input->readString(\$elem363);
+            push(@{$self->{success}},$elem363);
           }
           $xfer += $input->readListEnd();
         }
@@ -6276,9 +6457,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRING, scalar(@{$self->{success}}));
       {
-        foreach my $iter357 (@{$self->{success}}) 
+        foreach my $iter364 (@{$self->{success}}) 
         {
-          $xfer += $output->writeString($iter357);
+          $xfer += $output->writeString($iter364);
         }
       }
       $xfer += $output->writeListEnd();
@@ -6383,15 +6564,15 @@ sub read {
     {
       /^0$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size358 = 0;
+          my $_size365 = 0;
           $self->{success} = [];
-          my $_etype361 = 0;
-          $xfer += $input->readListBegin(\$_etype361, \$_size358);
-          for (my $_i362 = 0; $_i362 < $_size358; ++$_i362)
+          my $_etype368 = 0;
+          $xfer += $input->readListBegin(\$_etype368, \$_size365);
+          for (my $_i369 = 0; $_i369 < $_size365; ++$_i369)
           {
-            my $elem363 = undef;
-            $xfer += $input->readString(\$elem363);
-            push(@{$self->{success}},$elem363);
+            my $elem370 = undef;
+            $xfer += $input->readString(\$elem370);
+            push(@{$self->{success}},$elem370);
           }
           $xfer += $input->readListEnd();
         }
@@ -6423,9 +6604,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRING, scalar(@{$self->{success}}));
       {
-        foreach my $iter364 (@{$self->{success}}) 
+        foreach my $iter371 (@{$self->{success}}) 
         {
-          $xfer += $output->writeString($iter364);
+          $xfer += $output->writeString($iter371);
         }
       }
       $xfer += $output->writeListEnd();
@@ -6548,18 +6729,18 @@ sub read {
     {
       /^0$/ && do{      if ($ftype == TType::MAP) {
         {
-          my $_size365 = 0;
+          my $_size372 = 0;
           $self->{success} = {};
-          my $_ktype366 = 0;
-          my $_vtype367 = 0;
-          $xfer += $input->readMapBegin(\$_ktype366, \$_vtype367, \$_size365);
-          for (my $_i369 = 0; $_i369 < $_size365; ++$_i369)
+          my $_ktype373 = 0;
+          my $_vtype374 = 0;
+          $xfer += $input->readMapBegin(\$_ktype373, \$_vtype374, \$_size372);
+          for (my $_i376 = 0; $_i376 < $_size372; ++$_i376)
           {
-            my $key370 = '';
-            my $val371 = '';
-            $xfer += $input->readString(\$key370);
-            $xfer += $input->readString(\$val371);
-            $self->{success}->{$key370} = $val371;
+            my $key377 = '';
+            my $val378 = '';
+            $xfer += $input->readString(\$key377);
+            $xfer += $input->readString(\$val378);
+            $self->{success}->{$key377} = $val378;
           }
           $xfer += $input->readMapEnd();
         }
@@ -6591,10 +6772,10 @@ sub write {
     {
       $xfer += $output->writeMapBegin(TType::STRING, TType::STRING, scalar(keys %{$self->{success}}));
       {
-        while( my ($kiter372,$viter373) = each %{$self->{success}}) 
+        while( my ($kiter379,$viter380) = each %{$self->{success}}) 
         {
-          $xfer += $output->writeString($kiter372);
-          $xfer += $output->writeString($viter373);
+          $xfer += $output->writeString($kiter379);
+          $xfer += $output->writeString($viter380);
         }
       }
       $xfer += $output->writeMapEnd();
@@ -6717,33 +6898,33 @@ sub read {
     {
       /^0$/ && do{      if ($ftype == TType::MAP) {
         {
-          my $_size374 = 0;
+          my $_size381 = 0;
           $self->{success} = {};
-          my $_ktype375 = 0;
-          my $_vtype376 = 0;
-          $xfer += $input->readMapBegin(\$_ktype375, \$_vtype376, \$_size374);
-          for (my $_i378 = 0; $_i378 < $_size374; ++$_i378)
+          my $_ktype382 = 0;
+          my $_vtype383 = 0;
+          $xfer += $input->readMapBegin(\$_ktype382, \$_vtype383, \$_size381);
+          for (my $_i385 = 0; $_i385 < $_size381; ++$_i385)
           {
-            my $key379 = '';
-            my $val380 = [];
-            $xfer += $input->readString(\$key379);
+            my $key386 = '';
+            my $val387 = [];
+            $xfer += $input->readString(\$key386);
             {
-              my $_size381 = 0;
-              $val380 = {};
-              my $_ktype382 = 0;
-              my $_vtype383 = 0;
-              $xfer += $input->readMapBegin(\$_ktype382, \$_vtype383, \$_size381);
-              for (my $_i385 = 0; $_i385 < $_size381; ++$_i385)
+              my $_size388 = 0;
+              $val387 = {};
+              my $_ktype389 = 0;
+              my $_vtype390 = 0;
+              $xfer += $input->readMapBegin(\$_ktype389, \$_vtype390, \$_size388);
+              for (my $_i392 = 0; $_i392 < $_size388; ++$_i392)
               {
-                my $key386 = '';
-                my $val387 = 0;
-                $xfer += $input->readString(\$key386);
-                $xfer += $input->readI32(\$val387);
-                $val380->{$key386} = $val387;
+                my $key393 = '';
+                my $val394 = 0;
+                $xfer += $input->readString(\$key393);
+                $xfer += $input->readI32(\$val394);
+                $val387->{$key393} = $val394;
               }
               $xfer += $input->readMapEnd();
             }
-            $self->{success}->{$key379} = $val380;
+            $self->{success}->{$key386} = $val387;
           }
           $xfer += $input->readMapEnd();
         }
@@ -6775,16 +6956,16 @@ sub write {
     {
       $xfer += $output->writeMapBegin(TType::STRING, TType::MAP, scalar(keys %{$self->{success}}));
       {
-        while( my ($kiter388,$viter389) = each %{$self->{success}}) 
+        while( my ($kiter395,$viter396) = each %{$self->{success}}) 
         {
-          $xfer += $output->writeString($kiter388);
+          $xfer += $output->writeString($kiter395);
           {
-            $xfer += $output->writeMapBegin(TType::STRING, TType::I32, scalar(keys %{${viter389}}));
+            $xfer += $output->writeMapBegin(TType::STRING, TType::I32, scalar(keys %{${viter396}}));
             {
-              while( my ($kiter390,$viter391) = each %{${viter389}}) 
+              while( my ($kiter397,$viter398) = each %{${viter396}}) 
               {
-                $xfer += $output->writeString($kiter390);
-                $xfer += $output->writeI32($viter391);
+                $xfer += $output->writeString($kiter397);
+                $xfer += $output->writeI32($viter398);
               }
             }
             $xfer += $output->writeMapEnd();
@@ -7037,18 +7218,18 @@ sub read {
     {
       /^0$/ && do{      if ($ftype == TType::MAP) {
         {
-          my $_size392 = 0;
+          my $_size399 = 0;
           $self->{success} = {};
-          my $_ktype393 = 0;
-          my $_vtype394 = 0;
-          $xfer += $input->readMapBegin(\$_ktype393, \$_vtype394, \$_size392);
-          for (my $_i396 = 0; $_i396 < $_size392; ++$_i396)
+          my $_ktype400 = 0;
+          my $_vtype401 = 0;
+          $xfer += $input->readMapBegin(\$_ktype400, \$_vtype401, \$_size399);
+          for (my $_i403 = 0; $_i403 < $_size399; ++$_i403)
           {
-            my $key397 = '';
-            my $val398 = '';
-            $xfer += $input->readString(\$key397);
-            $xfer += $input->readString(\$val398);
-            $self->{success}->{$key397} = $val398;
+            my $key404 = '';
+            my $val405 = '';
+            $xfer += $input->readString(\$key404);
+            $xfer += $input->readString(\$val405);
+            $self->{success}->{$key404} = $val405;
           }
           $xfer += $input->readMapEnd();
         }
@@ -7080,10 +7261,10 @@ sub write {
     {
       $xfer += $output->writeMapBegin(TType::STRING, TType::STRING, scalar(keys %{$self->{success}}));
       {
-        while( my ($kiter399,$viter400) = each %{$self->{success}}) 
+        while( my ($kiter406,$viter407) = each %{$self->{success}}) 
         {
-          $xfer += $output->writeString($kiter399);
-          $xfer += $output->writeString($viter400);
+          $xfer += $output->writeString($kiter406);
+          $xfer += $output->writeString($viter407);
         }
       }
       $xfer += $output->writeMapEnd();
@@ -7138,15 +7319,15 @@ sub read {
     {
       /^1$/ && do{      if ($ftype == TType::SET) {
         {
-          my $_size401 = 0;
+          my $_size408 = 0;
           $self->{metrics} = {};
-          my $_etype404 = 0;
-          $xfer += $input->readSetBegin(\$_etype404, \$_size401);
-          for (my $_i405 = 0; $_i405 < $_size401; ++$_i405)
+          my $_etype411 = 0;
+          $xfer += $input->readSetBegin(\$_etype411, \$_size408);
+          for (my $_i412 = 0; $_i412 < $_size408; ++$_i412)
           {
-            my $elem406 = undef;
-            $xfer += $input->readString(\$elem406);
-            $self->{metrics}->{$elem406} = 1;
+            my $elem413 = undef;
+            $xfer += $input->readString(\$elem413);
+            $self->{metrics}->{$elem413} = 1;
           }
           $xfer += $input->readSetEnd();
         }
@@ -7171,9 +7352,9 @@ sub write {
     {
       $xfer += $output->writeSetBegin(TType::STRING, scalar(@{$self->{metrics}}));
       {
-        foreach my $iter407 (@{$self->{metrics}})
+        foreach my $iter414 (@{$self->{metrics}})
         {
-          $xfer += $output->writeString($iter407);
+          $xfer += $output->writeString($iter414);
         }
       }
       $xfer += $output->writeSetEnd();
@@ -7227,19 +7408,19 @@ sub read {
     {
       /^0$/ && do{      if ($ftype == TType::MAP) {
         {
-          my $_size408 = 0;
+          my $_size415 = 0;
           $self->{success} = {};
-          my $_ktype409 = 0;
-          my $_vtype410 = 0;
-          $xfer += $input->readMapBegin(\$_ktype409, \$_vtype410, \$_size408);
-          for (my $_i412 = 0; $_i412 < $_size408; ++$_i412)
+          my $_ktype416 = 0;
+          my $_vtype417 = 0;
+          $xfer += $input->readMapBegin(\$_ktype416, \$_vtype417, \$_size415);
+          for (my $_i419 = 0; $_i419 < $_size415; ++$_i419)
           {
-            my $key413 = '';
-            my $val414 = new Blur::Metric();
-            $xfer += $input->readString(\$key413);
-            $val414 = new Blur::Metric();
-            $xfer += $val414->read($input);
-            $self->{success}->{$key413} = $val414;
+            my $key420 = '';
+            my $val421 = new Blur::Metric();
+            $xfer += $input->readString(\$key420);
+            $val421 = new Blur::Metric();
+            $xfer += $val421->read($input);
+            $self->{success}->{$key420} = $val421;
           }
           $xfer += $input->readMapEnd();
         }
@@ -7271,10 +7452,10 @@ sub write {
     {
       $xfer += $output->writeMapBegin(TType::STRING, TType::STRUCT, scalar(keys %{$self->{success}}));
       {
-        while( my ($kiter415,$viter416) = each %{$self->{success}}) 
+        while( my ($kiter422,$viter423) = each %{$self->{success}}) 
         {
-          $xfer += $output->writeString($kiter415);
-          $xfer += ${viter416}->write($output);
+          $xfer += $output->writeString($kiter422);
+          $xfer += ${viter423}->write($output);
         }
       }
       $xfer += $output->writeMapEnd();
@@ -7504,15 +7685,15 @@ sub read {
     {
       /^0$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size417 = 0;
+          my $_size424 = 0;
           $self->{success} = [];
-          my $_etype420 = 0;
-          $xfer += $input->readListBegin(\$_etype420, \$_size417);
-          for (my $_i421 = 0; $_i421 < $_size417; ++$_i421)
+          my $_etype427 = 0;
+          $xfer += $input->readListBegin(\$_etype427, \$_size424);
+          for (my $_i428 = 0; $_i428 < $_size424; ++$_i428)
           {
-            my $elem422 = undef;
-            $xfer += $input->readString(\$elem422);
-            push(@{$self->{success}},$elem422);
+            my $elem429 = undef;
+            $xfer += $input->readString(\$elem429);
+            push(@{$self->{success}},$elem429);
           }
           $xfer += $input->readListEnd();
         }
@@ -7544,9 +7725,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRING, scalar(@{$self->{success}}));
       {
-        foreach my $iter423 (@{$self->{success}}) 
+        foreach my $iter430 (@{$self->{success}}) 
         {
-          $xfer += $output->writeString($iter423);
+          $xfer += $output->writeString($iter430);
         }
       }
       $xfer += $output->writeListEnd();
@@ -7669,15 +7850,15 @@ sub read {
     {
       /^0$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size424 = 0;
+          my $_size431 = 0;
           $self->{success} = [];
-          my $_etype427 = 0;
-          $xfer += $input->readListBegin(\$_etype427, \$_size424);
-          for (my $_i428 = 0; $_i428 < $_size424; ++$_i428)
+          my $_etype434 = 0;
+          $xfer += $input->readListBegin(\$_etype434, \$_size431);
+          for (my $_i435 = 0; $_i435 < $_size431; ++$_i435)
           {
-            my $elem429 = undef;
-            $xfer += $input->readString(\$elem429);
-            push(@{$self->{success}},$elem429);
+            my $elem436 = undef;
+            $xfer += $input->readString(\$elem436);
+            push(@{$self->{success}},$elem436);
           }
           $xfer += $input->readListEnd();
         }
@@ -7709,9 +7890,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRING, scalar(@{$self->{success}}));
       {
-        foreach my $iter430 (@{$self->{success}}) 
+        foreach my $iter437 (@{$self->{success}}) 
         {
-          $xfer += $output->writeString($iter430);
+          $xfer += $output->writeString($iter437);
         }
       }
       $xfer += $output->writeListEnd();
@@ -8612,6 +8793,15 @@ sub bulkMutateAdd{
   die 'implement interface';
 }
 
+sub bulkMutateAddMultiple{
+  my $self = shift;
+  my $table = shift;
+  my $bulkId = shift;
+  my $rowMutations = shift;
+
+  die 'implement interface';
+}
+
 sub bulkMutateFinish{
   my $self = shift;
   my $table = shift;
@@ -9031,6 +9221,15 @@ sub bulkMutateAdd{
   return $self->{impl}->bulkMutateAdd($table, $bulkId, $rowMutation);
 }
 
+sub bulkMutateAddMultiple{
+  my ($self, $request) = @_;
+
+  my $table = ($request->{'table'}) ? $request->{'table'} : undef;
+  my $bulkId = ($request->{'bulkId'}) ? $request->{'bulkId'} : undef;
+  my $rowMutations = ($request->{'rowMutations'}) ? $request->{'rowMutations'} : undef;
+  return $self->{impl}->bulkMutateAddMultiple($table, $bulkId, $rowMutations);
+}
+
 sub bulkMutateFinish{
   my ($self, $request) = @_;
 
@@ -10669,6 +10868,55 @@ sub recv_bulkMutateAdd{
   }
   return;
 }
+sub bulkMutateAddMultiple{
+  my $self = shift;
+  my $table = shift;
+  my $bulkId = shift;
+  my $rowMutations = shift;
+
+    $self->send_bulkMutateAddMultiple($table, $bulkId, $rowMutations);
+  $self->recv_bulkMutateAddMultiple();
+}
+
+sub send_bulkMutateAddMultiple{
+  my $self = shift;
+  my $table = shift;
+  my $bulkId = shift;
+  my $rowMutations = shift;
+
+  $self->{output}->writeMessageBegin('bulkMutateAddMultiple', TMessageType::CALL, $self->{seqid});
+  my $args = new Blur::Blur_bulkMutateAddMultiple_args();
+  $args->{table} = $table;
+  $args->{bulkId} = $bulkId;
+  $args->{rowMutations} = $rowMutations;
+  $args->write($self->{output});
+  $self->{output}->writeMessageEnd();
+  $self->{output}->getTransport()->flush();
+}
+
+sub recv_bulkMutateAddMultiple{
+  my $self = shift;
+
+  my $rseqid = 0;
+  my $fname;
+  my $mtype = 0;
+
+  $self->{input}->readMessageBegin(\$fname, \$mtype, \$rseqid);
+  if ($mtype == TMessageType::EXCEPTION) {
+    my $x = new TApplicationException();
+    $x->read($self->{input});
+    $self->{input}->readMessageEnd();
+    die $x;
+  }
+  my $result = new Blur::Blur_bulkMutateAddMultiple_result();
+  $result->read($self->{input});
+  $self->{input}->readMessageEnd();
+
+  if (defined $result->{ex}) {
+    die $result->{ex};
+  }
+  return;
+}
 sub bulkMutateFinish{
   my $self = shift;
   my $table = shift;
@@ -12240,6 +12488,23 @@ sub process_bulkMutateAdd {
     $output->getTransport()->flush();
 }
 
+sub process_bulkMutateAddMultiple {
+    my ($self, $seqid, $input, $output) = @_;
+    my $args = new Blur::Blur_bulkMutateAddMultiple_args();
+    $args->read($input);
+    $input->readMessageEnd();
+    my $result = new Blur::Blur_bulkMutateAddMultiple_result();
+    eval {
+      $self->{handler}->bulkMutateAddMultiple($args->table, $args->bulkId, $args->rowMutations);
+    }; if( UNIVERSAL::isa($@,'Blur::BlurException') ){ 
+      $result->{ex} = $@;
+    }
+    $output->writeMessageBegin('bulkMutateAddMultiple', TMessageType::REPLY, $seqid);
+    $result->write($output);
+    $output->writeMessageEnd();
+    $output->getTransport()->flush();
+}
+
 sub process_bulkMutateFinish {
     my ($self, $seqid, $input, $output) = @_;
     my $args = new Blur::Blur_bulkMutateFinish_args();

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/36c8130b/distribution/src/main/scripts/interface/gen-rb/blur.rb
----------------------------------------------------------------------
diff --git a/distribution/src/main/scripts/interface/gen-rb/blur.rb b/distribution/src/main/scripts/interface/gen-rb/blur.rb
index 3a4fc3a..8949e21 100644
--- a/distribution/src/main/scripts/interface/gen-rb/blur.rb
+++ b/distribution/src/main/scripts/interface/gen-rb/blur.rb
@@ -509,6 +509,21 @@ module Blur
         return
       end
 
+      def bulkMutateAddMultiple(table, bulkId, rowMutations)
+        send_bulkMutateAddMultiple(table, bulkId, rowMutations)
+        recv_bulkMutateAddMultiple()
+      end
+
+      def send_bulkMutateAddMultiple(table, bulkId, rowMutations)
+        send_message('bulkMutateAddMultiple', BulkMutateAddMultiple_args, :table => table, :bulkId => bulkId, :rowMutations => rowMutations)
+      end
+
+      def recv_bulkMutateAddMultiple()
+        result = receive_message(BulkMutateAddMultiple_result)
+        raise result.ex unless result.ex.nil?
+        return
+      end
+
       def bulkMutateFinish(table, bulkId, apply, blockUntilComplete)
         send_bulkMutateFinish(table, bulkId, apply, blockUntilComplete)
         recv_bulkMutateFinish()
@@ -1207,6 +1222,17 @@ module Blur
         write_result(result, oprot, 'bulkMutateAdd', seqid)
       end
 
+      def process_bulkMutateAddMultiple(seqid, iprot, oprot)
+        args = read_args(iprot, BulkMutateAddMultiple_args)
+        result = BulkMutateAddMultiple_result.new()
+        begin
+          @handler.bulkMutateAddMultiple(args.table, args.bulkId, args.rowMutations)
+        rescue ::Blur::BlurException => ex
+          result.ex = ex
+        end
+        write_result(result, oprot, 'bulkMutateAddMultiple', seqid)
+      end
+
       def process_bulkMutateFinish(seqid, iprot, oprot)
         args = read_args(iprot, BulkMutateFinish_args)
         result = BulkMutateFinish_result.new()
@@ -2599,6 +2625,45 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
+    class BulkMutateAddMultiple_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      TABLE = 1
+      BULKID = 2
+      ROWMUTATIONS = 3
+
+      FIELDS = {
+        # The table name.
+        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
+        # The bulk id.
+        BULKID => {:type => ::Thrift::Types::STRING, :name => 'bulkId'},
+        # The row mutation.
+        ROWMUTATIONS => {:type => ::Thrift::Types::LIST, :name => 'rowMutations', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::RowMutation}}
+      }
+
+      def struct_fields; FIELDS; end
+
+      def validate
+      end
+
+      ::Thrift::Struct.generate_accessors self
+    end
+
+    class BulkMutateAddMultiple_result
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      EX = 1
+
+      FIELDS = {
+        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
+      }
+
+      def struct_fields; FIELDS; end
+
+      def validate
+      end
+
+      ::Thrift::Struct.generate_accessors self
+    end
+
     class BulkMutateFinish_args
       include ::Thrift::Struct, ::Thrift::Struct_Union
       TABLE = 1

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/36c8130b/docs/Blur.html
----------------------------------------------------------------------
diff --git a/docs/Blur.html b/docs/Blur.html
index 40c94c5..16daa14 100644
--- a/docs/Blur.html
+++ b/docs/Blur.html
@@ -147,6 +147,7 @@ limitations under the License.
 <li><a href="#Fn_Blur_enqueueMutateBatch">&nbsp;&nbsp;enqueueMutateBatch</a></li>
 <li><a href="#Fn_Blur_bulkMutateStart">&nbsp;&nbsp;bulkMutateStart</a></li>
 <li><a href="#Fn_Blur_bulkMutateAdd">&nbsp;&nbsp;bulkMutateAdd</a></li>
+<li><a href="#Fn_Blur_bulkMutateAddMultiple">&nbsp;&nbsp;bulkMutateAddMultiple</a></li>
 <li><a href="#Fn_Blur_bulkMutateFinish">&nbsp;&nbsp;bulkMutateFinish</a></li>
 <li><a href="#Fn_Blur_cancelQuery">&nbsp;&nbsp;cancelQuery</a></li>
 <li><a href="#Fn_Blur_queryStatusIdList">&nbsp;&nbsp;queryStatusIdList</a></li>
@@ -979,7 +980,7 @@ throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code>
 <code>string</code> bulkId,
 <code><a href="Blur.html#Struct_RowMutation">RowMutation</a></code> rowMutation)
 throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code>
-</pre>Adds to the specified transaction.  The
+</pre>Adds to the specified transaction.
 <br/><br/><h4 id="Parameters_Blur_bulkMutateAdd">Parameters</h4>
 <table class="table-bordered table-striped table-condensed"><thead><th>Name</th><th>Description</th></thead><tr><td>table</td><td>The table name.
 </td></tr>
@@ -987,6 +988,19 @@ throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code>
 </td></tr>
 <tr><td>rowMutation</td><td>The row mutation.
 </td></tr>
+</table></p></section><section><div class="page-header"><h4 id="Fn_Blur_bulkMutateAddMultiple">Function: Blur.bulkMutateAddMultiple</h4></div><p class="lead">
+<pre><code>void</code> bulkMutateAddMultiple(<code>string</code> table,
+<code>string</code> bulkId,
+<code>list&lt;<code><a href="Blur.html#Struct_RowMutation">RowMutation</a></code>&gt;</code> rowMutations)
+throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code>
+</pre>Adds to the specified transaction.
+<br/><br/><h4 id="Parameters_Blur_bulkMutateAddMultiple">Parameters</h4>
+<table class="table-bordered table-striped table-condensed"><thead><th>Name</th><th>Description</th></thead><tr><td>table</td><td>The table name.
+</td></tr>
+<tr><td>bulkId</td><td>The bulk id.
+</td></tr>
+<tr><td>rowMutations</td><td>The row mutation.
+</td></tr>
 </table></p></section><section><div class="page-header"><h4 id="Fn_Blur_bulkMutateFinish">Function: Blur.bulkMutateFinish</h4></div><p class="lead">
 <pre><code>void</code> bulkMutateFinish(<code>string</code> table,
 <code>string</code> bulkId,


Mime
View raw message