http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/dcaf106c/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 6354606..1e36a12 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; // required + Shard _key242; // optional 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; // required + Server _key246; // optional 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; // required + Shard _key252; // optional 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; // required + Server _key256; // optional ValueObject _val257; // required _key256 = new Server(); _key256.read(iprot);
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/dcaf106c/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 ef3191c..39e1dbb 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; // required + String _key148; // optional 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; // required + String _key152; // optional 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; // required + String _key160; // optional 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; // required + String _key164; // optional ColumnDefinition _val165; // required _key164 = iprot.readString(); _val165 = new ColumnDefinition(); http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/dcaf106c/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 37385d7..af622c5 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; // required + String _key31; // optional 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; // required + String _key52; // optional Set<String> _val53; // required _key52 = iprot.readString(); { http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/dcaf106c/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 3793c00..1a08bc0 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; // required + String _key174; // optional 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; // required + String _key178; // optional 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; // required + String _key196; // optional 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; // required + String _key200; // optional String _val201; // required _key200 = iprot.readString(); _val201 = iprot.readString(); http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/dcaf106c/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 8f152a6..33b0f91 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; // required - String _val3; // optional + String _key2; // optional + String _val3; // required _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; // required - String _val9; // optional + String _key8; // optional + String _val9; // required _key8 = iprot.readString(); _val9 = iprot.readString(); struct.attributes.put(_key8, _val9); http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/dcaf106c/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 ddd43c2..2dfcb11 100644 --- a/distribution/src/main/scripts/interface/gen-js/Blur.js +++ b/distribution/src/main/scripts/interface/gen-js/Blur.js @@ -3988,12 +3988,8 @@ Blur_enqueueMutateBatch_result.prototype.write = function(output) { }; Blur_bulkMutateStart_args = function(args) { - this.table = null; this.bulkId = null; if (args) { - if (args.table !== undefined) { - this.table = args.table; - } if (args.bulkId !== undefined) { this.bulkId = args.bulkId; } @@ -4015,18 +4011,14 @@ Blur_bulkMutateStart_args.prototype.read = function(input) { { 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 0: + input.skip(ftype); + break; default: input.skip(ftype); } @@ -4038,13 +4030,8 @@ Blur_bulkMutateStart_args.prototype.read = function(input) { Blur_bulkMutateStart_args.prototype.write = function(output) { output.writeStructBegin('Blur_bulkMutateStart_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.writeFieldBegin('bulkId', Thrift.Type.STRING, 1); output.writeString(this.bulkId); output.writeFieldEnd(); } @@ -4112,13 +4099,9 @@ Blur_bulkMutateStart_result.prototype.write = function(output) { }; Blur_bulkMutateAdd_args = function(args) { - this.table = null; this.bulkId = null; this.rowMutation = null; if (args) { - if (args.table !== undefined) { - this.table = args.table; - } if (args.bulkId !== undefined) { this.bulkId = args.bulkId; } @@ -4143,19 +4126,12 @@ Blur_bulkMutateAdd_args.prototype.read = function(input) { { 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: + case 2: if (ftype == Thrift.Type.STRUCT) { this.rowMutation = new RowMutation(); this.rowMutation.read(input); @@ -4174,18 +4150,13 @@ Blur_bulkMutateAdd_args.prototype.read = function(input) { Blur_bulkMutateAdd_args.prototype.write = function(output) { output.writeStructBegin('Blur_bulkMutateAdd_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.writeFieldBegin('bulkId', Thrift.Type.STRING, 1); output.writeString(this.bulkId); output.writeFieldEnd(); } if (this.rowMutation !== null && this.rowMutation !== undefined) { - output.writeFieldBegin('rowMutation', Thrift.Type.STRUCT, 3); + output.writeFieldBegin('rowMutation', Thrift.Type.STRUCT, 2); this.rowMutation.write(output); output.writeFieldEnd(); } @@ -4253,13 +4224,9 @@ Blur_bulkMutateAdd_result.prototype.write = function(output) { }; 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; } @@ -4284,19 +4251,12 @@ Blur_bulkMutateAddMultiple_args.prototype.read = function(input) { { 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: + case 2: if (ftype == Thrift.Type.LIST) { var _size372 = 0; var _rtmp3376; @@ -4328,18 +4288,13 @@ Blur_bulkMutateAddMultiple_args.prototype.read = function(input) { 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.writeFieldBegin('bulkId', Thrift.Type.STRING, 1); output.writeString(this.bulkId); output.writeFieldEnd(); } if (this.rowMutations !== null && this.rowMutations !== undefined) { - output.writeFieldBegin('rowMutations', Thrift.Type.LIST, 3); + output.writeFieldBegin('rowMutations', Thrift.Type.LIST, 2); output.writeListBegin(Thrift.Type.STRUCT, this.rowMutations.length); for (var iter379 in this.rowMutations) { @@ -4416,14 +4371,10 @@ Blur_bulkMutateAddMultiple_result.prototype.write = function(output) { }; Blur_bulkMutateFinish_args = function(args) { - this.table = null; this.bulkId = null; this.apply = null; this.blockUntilComplete = null; if (args) { - if (args.table !== undefined) { - this.table = args.table; - } if (args.bulkId !== undefined) { this.bulkId = args.bulkId; } @@ -4451,26 +4402,19 @@ Blur_bulkMutateFinish_args.prototype.read = function(input) { { 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: + case 2: if (ftype == Thrift.Type.BOOL) { this.apply = input.readBool().value; } else { input.skip(ftype); } break; - case 4: + case 3: if (ftype == Thrift.Type.BOOL) { this.blockUntilComplete = input.readBool().value; } else { @@ -4488,23 +4432,18 @@ Blur_bulkMutateFinish_args.prototype.read = function(input) { Blur_bulkMutateFinish_args.prototype.write = function(output) { output.writeStructBegin('Blur_bulkMutateFinish_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.writeFieldBegin('bulkId', Thrift.Type.STRING, 1); output.writeString(this.bulkId); output.writeFieldEnd(); } if (this.apply !== null && this.apply !== undefined) { - output.writeFieldBegin('apply', Thrift.Type.BOOL, 3); + output.writeFieldBegin('apply', Thrift.Type.BOOL, 2); output.writeBool(this.apply); output.writeFieldEnd(); } if (this.blockUntilComplete !== null && this.blockUntilComplete !== undefined) { - output.writeFieldBegin('blockUntilComplete', Thrift.Type.BOOL, 4); + output.writeFieldBegin('blockUntilComplete', Thrift.Type.BOOL, 3); output.writeBool(this.blockUntilComplete); output.writeFieldEnd(); } @@ -8476,15 +8415,14 @@ BlurClient.prototype.recv_enqueueMutateBatch = function() { } return; }; -BlurClient.prototype.bulkMutateStart = function(table, bulkId) { - this.send_bulkMutateStart(table, bulkId); +BlurClient.prototype.bulkMutateStart = function(bulkId) { + this.send_bulkMutateStart(bulkId); this.recv_bulkMutateStart(); }; -BlurClient.prototype.send_bulkMutateStart = function(table, bulkId) { +BlurClient.prototype.send_bulkMutateStart = function(bulkId) { this.output.writeMessageBegin('bulkMutateStart', Thrift.MessageType.CALL, this.seqid); var args = new Blur_bulkMutateStart_args(); - args.table = table; args.bulkId = bulkId; args.write(this.output); this.output.writeMessageEnd(); @@ -8511,15 +8449,14 @@ BlurClient.prototype.recv_bulkMutateStart = function() { } return; }; -BlurClient.prototype.bulkMutateAdd = function(table, bulkId, rowMutation) { - this.send_bulkMutateAdd(table, bulkId, rowMutation); +BlurClient.prototype.bulkMutateAdd = function(bulkId, rowMutation) { + this.send_bulkMutateAdd(bulkId, rowMutation); this.recv_bulkMutateAdd(); }; -BlurClient.prototype.send_bulkMutateAdd = function(table, bulkId, rowMutation) { +BlurClient.prototype.send_bulkMutateAdd = function(bulkId, rowMutation) { this.output.writeMessageBegin('bulkMutateAdd', Thrift.MessageType.CALL, this.seqid); var args = new Blur_bulkMutateAdd_args(); - args.table = table; args.bulkId = bulkId; args.rowMutation = rowMutation; args.write(this.output); @@ -8547,15 +8484,14 @@ BlurClient.prototype.recv_bulkMutateAdd = function() { } return; }; -BlurClient.prototype.bulkMutateAddMultiple = function(table, bulkId, rowMutations) { - this.send_bulkMutateAddMultiple(table, bulkId, rowMutations); +BlurClient.prototype.bulkMutateAddMultiple = function(bulkId, rowMutations) { + this.send_bulkMutateAddMultiple(bulkId, rowMutations); this.recv_bulkMutateAddMultiple(); }; -BlurClient.prototype.send_bulkMutateAddMultiple = function(table, bulkId, rowMutations) { +BlurClient.prototype.send_bulkMutateAddMultiple = function(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); @@ -8583,15 +8519,14 @@ BlurClient.prototype.recv_bulkMutateAddMultiple = function() { } return; }; -BlurClient.prototype.bulkMutateFinish = function(table, bulkId, apply, blockUntilComplete) { - this.send_bulkMutateFinish(table, bulkId, apply, blockUntilComplete); +BlurClient.prototype.bulkMutateFinish = function(bulkId, apply, blockUntilComplete) { + this.send_bulkMutateFinish(bulkId, apply, blockUntilComplete); this.recv_bulkMutateFinish(); }; -BlurClient.prototype.send_bulkMutateFinish = function(table, bulkId, apply, blockUntilComplete) { +BlurClient.prototype.send_bulkMutateFinish = function(bulkId, apply, blockUntilComplete) { this.output.writeMessageBegin('bulkMutateFinish', Thrift.MessageType.CALL, this.seqid); var args = new Blur_bulkMutateFinish_args(); - args.table = table; args.bulkId = bulkId; args.apply = apply; args.blockUntilComplete = blockUntilComplete; http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/dcaf106c/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 2c51e04..f1d5c65 100644 --- a/distribution/src/main/scripts/interface/gen-perl/Blur/Blur.pm +++ b/distribution/src/main/scripts/interface/gen-perl/Blur/Blur.pm @@ -4624,18 +4624,14 @@ sub write { package Blur::Blur_bulkMutateStart_args; use base qw(Class::Accessor); -Blur::Blur_bulkMutateStart_args->mk_accessors( qw( table bulkId ) ); +Blur::Blur_bulkMutateStart_args->mk_accessors( qw( bulkId ) ); sub new { my $classname = shift; my $self = {}; my $vals = shift || {}; - $self->{table} = undef; $self->{bulkId} = undef; if (UNIVERSAL::isa($vals,'HASH')) { - if (defined $vals->{table}) { - $self->{table} = $vals->{table}; - } if (defined $vals->{bulkId}) { $self->{bulkId} = $vals->{bulkId}; } @@ -4663,12 +4659,6 @@ sub read { 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); @@ -4686,13 +4676,8 @@ sub write { my ($self, $output) = @_; my $xfer = 0; $xfer += $output->writeStructBegin('Blur_bulkMutateStart_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->writeFieldBegin('bulkId', TType::STRING, 1); $xfer += $output->writeString($self->{bulkId}); $xfer += $output->writeFieldEnd(); } @@ -4768,19 +4753,15 @@ sub write { package Blur::Blur_bulkMutateAdd_args; use base qw(Class::Accessor); -Blur::Blur_bulkMutateAdd_args->mk_accessors( qw( table bulkId rowMutation ) ); +Blur::Blur_bulkMutateAdd_args->mk_accessors( qw( bulkId rowMutation ) ); sub new { my $classname = shift; my $self = {}; my $vals = shift || {}; - $self->{table} = undef; $self->{bulkId} = undef; $self->{rowMutation} = undef; if (UNIVERSAL::isa($vals,'HASH')) { - if (defined $vals->{table}) { - $self->{table} = $vals->{table}; - } if (defined $vals->{bulkId}) { $self->{bulkId} = $vals->{bulkId}; } @@ -4811,18 +4792,12 @@ sub read { 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::STRUCT) { + /^2$/ && do{ if ($ftype == TType::STRUCT) { $self->{rowMutation} = new Blur::RowMutation(); $xfer += $self->{rowMutation}->read($input); } else { @@ -4841,18 +4816,13 @@ sub write { my ($self, $output) = @_; my $xfer = 0; $xfer += $output->writeStructBegin('Blur_bulkMutateAdd_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->writeFieldBegin('bulkId', TType::STRING, 1); $xfer += $output->writeString($self->{bulkId}); $xfer += $output->writeFieldEnd(); } if (defined $self->{rowMutation}) { - $xfer += $output->writeFieldBegin('rowMutation', TType::STRUCT, 3); + $xfer += $output->writeFieldBegin('rowMutation', TType::STRUCT, 2); $xfer += $self->{rowMutation}->write($output); $xfer += $output->writeFieldEnd(); } @@ -4928,19 +4898,15 @@ sub write { package Blur::Blur_bulkMutateAddMultiple_args; use base qw(Class::Accessor); -Blur::Blur_bulkMutateAddMultiple_args->mk_accessors( qw( table bulkId rowMutations ) ); +Blur::Blur_bulkMutateAddMultiple_args->mk_accessors( qw( 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}; } @@ -4971,18 +4937,12 @@ sub read { 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) { + /^2$/ && do{ if ($ftype == TType::LIST) { { my $_size330 = 0; $self->{rowMutations} = []; @@ -5013,18 +4973,13 @@ 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->writeFieldBegin('bulkId', TType::STRING, 1); $xfer += $output->writeString($self->{bulkId}); $xfer += $output->writeFieldEnd(); } if (defined $self->{rowMutations}) { - $xfer += $output->writeFieldBegin('rowMutations', TType::LIST, 3); + $xfer += $output->writeFieldBegin('rowMutations', TType::LIST, 2); { $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{rowMutations}})); { @@ -5109,20 +5064,16 @@ sub write { package Blur::Blur_bulkMutateFinish_args; use base qw(Class::Accessor); -Blur::Blur_bulkMutateFinish_args->mk_accessors( qw( table bulkId apply blockUntilComplete ) ); +Blur::Blur_bulkMutateFinish_args->mk_accessors( qw( bulkId apply blockUntilComplete ) ); sub new { my $classname = shift; my $self = {}; my $vals = shift || {}; - $self->{table} = undef; $self->{bulkId} = undef; $self->{apply} = undef; $self->{blockUntilComplete} = undef; if (UNIVERSAL::isa($vals,'HASH')) { - if (defined $vals->{table}) { - $self->{table} = $vals->{table}; - } if (defined $vals->{bulkId}) { $self->{bulkId} = $vals->{bulkId}; } @@ -5156,24 +5107,18 @@ sub read { 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::BOOL) { + /^2$/ && do{ if ($ftype == TType::BOOL) { $xfer += $input->readBool(\$self->{apply}); } else { $xfer += $input->skip($ftype); } last; }; - /^4$/ && do{ if ($ftype == TType::BOOL) { + /^3$/ && do{ if ($ftype == TType::BOOL) { $xfer += $input->readBool(\$self->{blockUntilComplete}); } else { $xfer += $input->skip($ftype); @@ -5191,23 +5136,18 @@ sub write { my ($self, $output) = @_; my $xfer = 0; $xfer += $output->writeStructBegin('Blur_bulkMutateFinish_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->writeFieldBegin('bulkId', TType::STRING, 1); $xfer += $output->writeString($self->{bulkId}); $xfer += $output->writeFieldEnd(); } if (defined $self->{apply}) { - $xfer += $output->writeFieldBegin('apply', TType::BOOL, 3); + $xfer += $output->writeFieldBegin('apply', TType::BOOL, 2); $xfer += $output->writeBool($self->{apply}); $xfer += $output->writeFieldEnd(); } if (defined $self->{blockUntilComplete}) { - $xfer += $output->writeFieldBegin('blockUntilComplete', TType::BOOL, 4); + $xfer += $output->writeFieldBegin('blockUntilComplete', TType::BOOL, 3); $xfer += $output->writeBool($self->{blockUntilComplete}); $xfer += $output->writeFieldEnd(); } @@ -8778,7 +8718,6 @@ sub enqueueMutateBatch{ sub bulkMutateStart{ my $self = shift; - my $table = shift; my $bulkId = shift; die 'implement interface'; @@ -8786,7 +8725,6 @@ sub bulkMutateStart{ sub bulkMutateAdd{ my $self = shift; - my $table = shift; my $bulkId = shift; my $rowMutation = shift; @@ -8795,7 +8733,6 @@ sub bulkMutateAdd{ sub bulkMutateAddMultiple{ my $self = shift; - my $table = shift; my $bulkId = shift; my $rowMutations = shift; @@ -8804,7 +8741,6 @@ sub bulkMutateAddMultiple{ sub bulkMutateFinish{ my $self = shift; - my $table = shift; my $bulkId = shift; my $apply = shift; my $blockUntilComplete = shift; @@ -9207,37 +9143,33 @@ sub enqueueMutateBatch{ sub bulkMutateStart{ my ($self, $request) = @_; - my $table = ($request->{'table'}) ? $request->{'table'} : undef; my $bulkId = ($request->{'bulkId'}) ? $request->{'bulkId'} : undef; - return $self->{impl}->bulkMutateStart($table, $bulkId); + return $self->{impl}->bulkMutateStart($bulkId); } sub bulkMutateAdd{ my ($self, $request) = @_; - my $table = ($request->{'table'}) ? $request->{'table'} : undef; my $bulkId = ($request->{'bulkId'}) ? $request->{'bulkId'} : undef; my $rowMutation = ($request->{'rowMutation'}) ? $request->{'rowMutation'} : undef; - return $self->{impl}->bulkMutateAdd($table, $bulkId, $rowMutation); + return $self->{impl}->bulkMutateAdd($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); + return $self->{impl}->bulkMutateAddMultiple($bulkId, $rowMutations); } sub bulkMutateFinish{ my ($self, $request) = @_; - my $table = ($request->{'table'}) ? $request->{'table'} : undef; my $bulkId = ($request->{'bulkId'}) ? $request->{'bulkId'} : undef; my $apply = ($request->{'apply'}) ? $request->{'apply'} : undef; my $blockUntilComplete = ($request->{'blockUntilComplete'}) ? $request->{'blockUntilComplete'} : undef; - return $self->{impl}->bulkMutateFinish($table, $bulkId, $apply, $blockUntilComplete); + return $self->{impl}->bulkMutateFinish($bulkId, $apply, $blockUntilComplete); } sub cancelQuery{ @@ -10775,21 +10707,18 @@ sub recv_enqueueMutateBatch{ } sub bulkMutateStart{ my $self = shift; - my $table = shift; my $bulkId = shift; - $self->send_bulkMutateStart($table, $bulkId); + $self->send_bulkMutateStart($bulkId); $self->recv_bulkMutateStart(); } sub send_bulkMutateStart{ my $self = shift; - my $table = shift; my $bulkId = shift; $self->{output}->writeMessageBegin('bulkMutateStart', TMessageType::CALL, $self->{seqid}); my $args = new Blur::Blur_bulkMutateStart_args(); - $args->{table} = $table; $args->{bulkId} = $bulkId; $args->write($self->{output}); $self->{output}->writeMessageEnd(); @@ -10821,23 +10750,20 @@ sub recv_bulkMutateStart{ } sub bulkMutateAdd{ my $self = shift; - my $table = shift; my $bulkId = shift; my $rowMutation = shift; - $self->send_bulkMutateAdd($table, $bulkId, $rowMutation); + $self->send_bulkMutateAdd($bulkId, $rowMutation); $self->recv_bulkMutateAdd(); } sub send_bulkMutateAdd{ my $self = shift; - my $table = shift; my $bulkId = shift; my $rowMutation = shift; $self->{output}->writeMessageBegin('bulkMutateAdd', TMessageType::CALL, $self->{seqid}); my $args = new Blur::Blur_bulkMutateAdd_args(); - $args->{table} = $table; $args->{bulkId} = $bulkId; $args->{rowMutation} = $rowMutation; $args->write($self->{output}); @@ -10870,23 +10796,20 @@ sub recv_bulkMutateAdd{ } sub bulkMutateAddMultiple{ my $self = shift; - my $table = shift; my $bulkId = shift; my $rowMutations = shift; - $self->send_bulkMutateAddMultiple($table, $bulkId, $rowMutations); + $self->send_bulkMutateAddMultiple($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}); @@ -10919,25 +10842,22 @@ sub recv_bulkMutateAddMultiple{ } sub bulkMutateFinish{ my $self = shift; - my $table = shift; my $bulkId = shift; my $apply = shift; my $blockUntilComplete = shift; - $self->send_bulkMutateFinish($table, $bulkId, $apply, $blockUntilComplete); + $self->send_bulkMutateFinish($bulkId, $apply, $blockUntilComplete); $self->recv_bulkMutateFinish(); } sub send_bulkMutateFinish{ my $self = shift; - my $table = shift; my $bulkId = shift; my $apply = shift; my $blockUntilComplete = shift; $self->{output}->writeMessageBegin('bulkMutateFinish', TMessageType::CALL, $self->{seqid}); my $args = new Blur::Blur_bulkMutateFinish_args(); - $args->{table} = $table; $args->{bulkId} = $bulkId; $args->{apply} = $apply; $args->{blockUntilComplete} = $blockUntilComplete; @@ -12461,7 +12381,7 @@ sub process_bulkMutateStart { $input->readMessageEnd(); my $result = new Blur::Blur_bulkMutateStart_result(); eval { - $self->{handler}->bulkMutateStart($args->table, $args->bulkId); + $self->{handler}->bulkMutateStart($args->bulkId); }; if( UNIVERSAL::isa($@,'Blur::BlurException') ){ $result->{ex} = $@; } @@ -12478,7 +12398,7 @@ sub process_bulkMutateAdd { $input->readMessageEnd(); my $result = new Blur::Blur_bulkMutateAdd_result(); eval { - $self->{handler}->bulkMutateAdd($args->table, $args->bulkId, $args->rowMutation); + $self->{handler}->bulkMutateAdd($args->bulkId, $args->rowMutation); }; if( UNIVERSAL::isa($@,'Blur::BlurException') ){ $result->{ex} = $@; } @@ -12495,7 +12415,7 @@ sub process_bulkMutateAddMultiple { $input->readMessageEnd(); my $result = new Blur::Blur_bulkMutateAddMultiple_result(); eval { - $self->{handler}->bulkMutateAddMultiple($args->table, $args->bulkId, $args->rowMutations); + $self->{handler}->bulkMutateAddMultiple($args->bulkId, $args->rowMutations); }; if( UNIVERSAL::isa($@,'Blur::BlurException') ){ $result->{ex} = $@; } @@ -12512,7 +12432,7 @@ sub process_bulkMutateFinish { $input->readMessageEnd(); my $result = new Blur::Blur_bulkMutateFinish_result(); eval { - $self->{handler}->bulkMutateFinish($args->table, $args->bulkId, $args->apply, $args->blockUntilComplete); + $self->{handler}->bulkMutateFinish($args->bulkId, $args->apply, $args->blockUntilComplete); }; if( UNIVERSAL::isa($@,'Blur::BlurException') ){ $result->{ex} = $@; } http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/dcaf106c/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 8949e21..e30b83b 100644 --- a/distribution/src/main/scripts/interface/gen-rb/blur.rb +++ b/distribution/src/main/scripts/interface/gen-rb/blur.rb @@ -479,13 +479,13 @@ module Blur return end - def bulkMutateStart(table, bulkId) - send_bulkMutateStart(table, bulkId) + def bulkMutateStart(bulkId) + send_bulkMutateStart(bulkId) recv_bulkMutateStart() end - def send_bulkMutateStart(table, bulkId) - send_message('bulkMutateStart', BulkMutateStart_args, :table => table, :bulkId => bulkId) + def send_bulkMutateStart(bulkId) + send_message('bulkMutateStart', BulkMutateStart_args, :bulkId => bulkId) end def recv_bulkMutateStart() @@ -494,13 +494,13 @@ module Blur return end - def bulkMutateAdd(table, bulkId, rowMutation) - send_bulkMutateAdd(table, bulkId, rowMutation) + def bulkMutateAdd(bulkId, rowMutation) + send_bulkMutateAdd(bulkId, rowMutation) recv_bulkMutateAdd() end - def send_bulkMutateAdd(table, bulkId, rowMutation) - send_message('bulkMutateAdd', BulkMutateAdd_args, :table => table, :bulkId => bulkId, :rowMutation => rowMutation) + def send_bulkMutateAdd(bulkId, rowMutation) + send_message('bulkMutateAdd', BulkMutateAdd_args, :bulkId => bulkId, :rowMutation => rowMutation) end def recv_bulkMutateAdd() @@ -509,13 +509,13 @@ module Blur return end - def bulkMutateAddMultiple(table, bulkId, rowMutations) - send_bulkMutateAddMultiple(table, bulkId, rowMutations) + def bulkMutateAddMultiple(bulkId, rowMutations) + send_bulkMutateAddMultiple(bulkId, rowMutations) recv_bulkMutateAddMultiple() end - def send_bulkMutateAddMultiple(table, bulkId, rowMutations) - send_message('bulkMutateAddMultiple', BulkMutateAddMultiple_args, :table => table, :bulkId => bulkId, :rowMutations => rowMutations) + def send_bulkMutateAddMultiple(bulkId, rowMutations) + send_message('bulkMutateAddMultiple', BulkMutateAddMultiple_args, :bulkId => bulkId, :rowMutations => rowMutations) end def recv_bulkMutateAddMultiple() @@ -524,13 +524,13 @@ module Blur return end - def bulkMutateFinish(table, bulkId, apply, blockUntilComplete) - send_bulkMutateFinish(table, bulkId, apply, blockUntilComplete) + def bulkMutateFinish(bulkId, apply, blockUntilComplete) + send_bulkMutateFinish(bulkId, apply, blockUntilComplete) recv_bulkMutateFinish() end - def send_bulkMutateFinish(table, bulkId, apply, blockUntilComplete) - send_message('bulkMutateFinish', BulkMutateFinish_args, :table => table, :bulkId => bulkId, :apply => apply, :blockUntilComplete => blockUntilComplete) + def send_bulkMutateFinish(bulkId, apply, blockUntilComplete) + send_message('bulkMutateFinish', BulkMutateFinish_args, :bulkId => bulkId, :apply => apply, :blockUntilComplete => blockUntilComplete) end def recv_bulkMutateFinish() @@ -1204,7 +1204,7 @@ module Blur args = read_args(iprot, BulkMutateStart_args) result = BulkMutateStart_result.new() begin - @handler.bulkMutateStart(args.table, args.bulkId) + @handler.bulkMutateStart(args.bulkId) rescue ::Blur::BlurException => ex result.ex = ex end @@ -1215,7 +1215,7 @@ module Blur args = read_args(iprot, BulkMutateAdd_args) result = BulkMutateAdd_result.new() begin - @handler.bulkMutateAdd(args.table, args.bulkId, args.rowMutation) + @handler.bulkMutateAdd(args.bulkId, args.rowMutation) rescue ::Blur::BlurException => ex result.ex = ex end @@ -1226,7 +1226,7 @@ module Blur args = read_args(iprot, BulkMutateAddMultiple_args) result = BulkMutateAddMultiple_result.new() begin - @handler.bulkMutateAddMultiple(args.table, args.bulkId, args.rowMutations) + @handler.bulkMutateAddMultiple(args.bulkId, args.rowMutations) rescue ::Blur::BlurException => ex result.ex = ex end @@ -1237,7 +1237,7 @@ module Blur args = read_args(iprot, BulkMutateFinish_args) result = BulkMutateFinish_result.new() begin - @handler.bulkMutateFinish(args.table, args.bulkId, args.apply, args.blockUntilComplete) + @handler.bulkMutateFinish(args.bulkId, args.apply, args.blockUntilComplete) rescue ::Blur::BlurException => ex result.ex = ex end @@ -2552,12 +2552,9 @@ module Blur class BulkMutateStart_args include ::Thrift::Struct, ::Thrift::Struct_Union - TABLE = 1 - BULKID = 2 + BULKID = 1 FIELDS = { - # The table name. - TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}, # The bulk id. BULKID => {:type => ::Thrift::Types::STRING, :name => 'bulkId'} } @@ -2588,13 +2585,10 @@ module Blur class BulkMutateAdd_args include ::Thrift::Struct, ::Thrift::Struct_Union - TABLE = 1 - BULKID = 2 - ROWMUTATION = 3 + BULKID = 1 + ROWMUTATION = 2 FIELDS = { - # The table name. - TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}, # The bulk id. BULKID => {:type => ::Thrift::Types::STRING, :name => 'bulkId'}, # The row mutation. @@ -2627,13 +2621,10 @@ module Blur class BulkMutateAddMultiple_args include ::Thrift::Struct, ::Thrift::Struct_Union - TABLE = 1 - BULKID = 2 - ROWMUTATIONS = 3 + BULKID = 1 + ROWMUTATIONS = 2 FIELDS = { - # The table name. - TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}, # The bulk id. BULKID => {:type => ::Thrift::Types::STRING, :name => 'bulkId'}, # The row mutation. @@ -2666,14 +2657,11 @@ module Blur class BulkMutateFinish_args include ::Thrift::Struct, ::Thrift::Struct_Union - TABLE = 1 - BULKID = 2 - APPLY = 3 - BLOCKUNTILCOMPLETE = 4 + BULKID = 1 + APPLY = 2 + BLOCKUNTILCOMPLETE = 3 FIELDS = { - # The table name. - TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}, # The bulk id. BULKID => {:type => ::Thrift::Types::STRING, :name => 'bulkId'}, # Apply the bulk mutate flag. http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/dcaf106c/docs/Blur.html ---------------------------------------------------------------------- diff --git a/docs/Blur.html b/docs/Blur.html index 1e68f3f..0eeafd1 100644 --- a/docs/Blur.html +++ b/docs/Blur.html @@ -38,7 +38,6 @@ limitations under the License. <ul class="nav navbar-nav"> <li><a href="index.html">Main</a></li> <li><a href="getting-started.html">Getting Started</a></li> -<li><a href="platform.html">Platform</a></li> <li><a href="data-model.html">Data Model</a></li> <li><a href="cluster-setup.html">Cluster Setup</a></li> <li><a href="using-blur.html">Using Blur</a></li> @@ -965,52 +964,40 @@ throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code> <table class="table-bordered table-striped table-condensed"><thead><th>Name</th><th>Description</th></thead><tr><td>mutations</td><td>the batch of RowMutations. </td></tr> </table></p></section><section><div class="page-header"><h4 id="Fn_Blur_bulkMutateStart">Function: Blur.bulkMutateStart</h4></div><p class="lead"> -<pre><code>void</code> bulkMutateStart(<code>string</code> table, -<code>string</code> bulkId) +<pre><code>void</code> bulkMutateStart(<code>string</code> bulkId) throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code> </pre>Starts a transaction for update (e.g. Mutate). Returns a transaction id. <br/><br/><h4 id="Parameters_Blur_bulkMutateStart">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. +<table class="table-bordered table-striped table-condensed"><thead><th>Name</th><th>Description</th></thead><tr><td>bulkId</td><td>The bulk id. </td></tr> </table></p></section><section><div class="page-header"><h4 id="Fn_Blur_bulkMutateAdd">Function: Blur.bulkMutateAdd</h4></div><p class="lead"> -<pre><code>void</code> bulkMutateAdd(<code>string</code> table, -<code>string</code> bulkId, +<pre><code>void</code> bulkMutateAdd(<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. <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> -<tr><td>bulkId</td><td>The bulk id. +<table class="table-bordered table-striped table-condensed"><thead><th>Name</th><th>Description</th></thead><tr><td>bulkId</td><td>The bulk id. </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, +<pre><code>void</code> bulkMutateAddMultiple(<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. +<table class="table-bordered table-striped table-condensed"><thead><th>Name</th><th>Description</th></thead><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, +<pre><code>void</code> bulkMutateFinish(<code>string</code> bulkId, <code>bool</code> apply, <code>bool</code> blockUntilComplete) throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code> </pre>Finishes the bulk mutate. If apply is true the mutations are applied and committed. If false the bulk mutate is deleted and not applied. <br/><br/><h4 id="Parameters_Blur_bulkMutateFinish">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. +<table class="table-bordered table-striped table-condensed"><thead><th>Name</th><th>Description</th></thead><tr><td>bulkId</td><td>The bulk id. </td></tr> <tr><td>apply</td><td>Apply the bulk mutate flag. </td></tr>
