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"> enqueueMutateBatch</a></li> <li><a href="#Fn_Blur_bulkMutateStart"> bulkMutateStart</a></li> <li><a href="#Fn_Blur_bulkMutateAdd"> bulkMutateAdd</a></li> +<li><a href="#Fn_Blur_bulkMutateAddMultiple"> bulkMutateAddMultiple</a></li> <li><a href="#Fn_Blur_bulkMutateFinish"> bulkMutateFinish</a></li> <li><a href="#Fn_Blur_cancelQuery"> cancelQuery</a></li> <li><a href="#Fn_Blur_queryStatusIdList"> 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<<code><a href="Blur.html#Struct_RowMutation">RowMutation</a></code>></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,
