http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/c46eb880/blur-status/src/main/resources/webapp/js/Blur.js ---------------------------------------------------------------------- diff --git a/blur-status/src/main/resources/webapp/js/Blur.js b/blur-status/src/main/resources/webapp/js/Blur.js index bc51fd3..ea6c267 100644 --- a/blur-status/src/main/resources/webapp/js/Blur.js +++ b/blur-status/src/main/resources/webapp/js/Blur.js @@ -7,16 +7,10 @@ //HELPER FUNCTIONS AND STRUCTURES -Blur_createTable_args = function(args) { - this.tableDescriptor = null; - if (args) { - if (args.tableDescriptor !== undefined) { - this.tableDescriptor = args.tableDescriptor; - } - } +Blur_listInstalledCommands_args = function(args) { }; -Blur_createTable_args.prototype = {}; -Blur_createTable_args.prototype.read = function(input) { +Blur_listInstalledCommands_args.prototype = {}; +Blur_listInstalledCommands_args.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -27,54 +21,38 @@ Blur_createTable_args.prototype.read = function(input) { if (ftype == Thrift.Type.STOP) { break; } - switch (fid) - { - case 1: - if (ftype == Thrift.Type.STRUCT) { - this.tableDescriptor = new TableDescriptor(); - this.tableDescriptor.read(input); - } else { - input.skip(ftype); - } - break; - case 0: - input.skip(ftype); - break; - default: - input.skip(ftype); - } + input.skip(ftype); input.readFieldEnd(); } input.readStructEnd(); return; }; -Blur_createTable_args.prototype.write = function(output) { - output.writeStructBegin('Blur_createTable_args'); - if (this.tableDescriptor !== null && this.tableDescriptor !== undefined) { - output.writeFieldBegin('tableDescriptor', Thrift.Type.STRUCT, 1); - this.tableDescriptor.write(output); - output.writeFieldEnd(); - } +Blur_listInstalledCommands_args.prototype.write = function(output) { + output.writeStructBegin('Blur_listInstalledCommands_args'); output.writeFieldStop(); output.writeStructEnd(); return; }; -Blur_createTable_result = function(args) { +Blur_listInstalledCommands_result = function(args) { + this.success = null; this.ex = null; if (args instanceof BlurException) { this.ex = args; return; } if (args) { + if (args.success !== undefined) { + this.success = args.success; + } if (args.ex !== undefined) { this.ex = args.ex; } } }; -Blur_createTable_result.prototype = {}; -Blur_createTable_result.prototype.read = function(input) { +Blur_listInstalledCommands_result.prototype = {}; +Blur_listInstalledCommands_result.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -87,6 +65,27 @@ Blur_createTable_result.prototype.read = function(input) { } switch (fid) { + case 0: + if (ftype == Thrift.Type.LIST) { + var _size290 = 0; + var _rtmp3294; + this.success = []; + var _etype293 = 0; + _rtmp3294 = input.readListBegin(); + _etype293 = _rtmp3294.etype; + _size290 = _rtmp3294.size; + for (var _i295 = 0; _i295 < _size290; ++_i295) + { + var elem296 = null; + elem296 = new CommandDescriptor(); + elem296.read(input); + this.success.push(elem296); + } + input.readListEnd(); + } else { + input.skip(ftype); + } + break; case 1: if (ftype == Thrift.Type.STRUCT) { this.ex = new BlurException(); @@ -95,9 +94,6 @@ Blur_createTable_result.prototype.read = function(input) { input.skip(ftype); } break; - case 0: - input.skip(ftype); - break; default: input.skip(ftype); } @@ -107,8 +103,22 @@ Blur_createTable_result.prototype.read = function(input) { return; }; -Blur_createTable_result.prototype.write = function(output) { - output.writeStructBegin('Blur_createTable_result'); +Blur_listInstalledCommands_result.prototype.write = function(output) { + output.writeStructBegin('Blur_listInstalledCommands_result'); + if (this.success !== null && this.success !== undefined) { + output.writeFieldBegin('success', Thrift.Type.LIST, 0); + output.writeListBegin(Thrift.Type.STRUCT, this.success.length); + for (var iter297 in this.success) + { + if (this.success.hasOwnProperty(iter297)) + { + iter297 = this.success[iter297]; + iter297.write(output); + } + } + output.writeListEnd(); + output.writeFieldEnd(); + } if (this.ex !== null && this.ex !== undefined) { output.writeFieldBegin('ex', Thrift.Type.STRUCT, 1); this.ex.write(output); @@ -119,16 +129,20 @@ Blur_createTable_result.prototype.write = function(output) { return; }; -Blur_enableTable_args = function(args) { - this.table = null; +Blur_execute_args = function(args) { + this.commandName = null; + this.arguments = null; if (args) { - if (args.table !== undefined) { - this.table = args.table; + if (args.commandName !== undefined) { + this.commandName = args.commandName; + } + if (args.arguments !== undefined) { + this.arguments = args.arguments; } } }; -Blur_enableTable_args.prototype = {}; -Blur_enableTable_args.prototype.read = function(input) { +Blur_execute_args.prototype = {}; +Blur_execute_args.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -143,14 +157,19 @@ Blur_enableTable_args.prototype.read = function(input) { { case 1: if (ftype == Thrift.Type.STRING) { - this.table = input.readString().value; + this.commandName = input.readString().value; } else { input.skip(ftype); } break; - case 0: + case 2: + if (ftype == Thrift.Type.STRUCT) { + this.arguments = new Arguments(); + this.arguments.read(input); + } else { input.skip(ftype); - break; + } + break; default: input.skip(ftype); } @@ -160,11 +179,16 @@ Blur_enableTable_args.prototype.read = function(input) { return; }; -Blur_enableTable_args.prototype.write = function(output) { - output.writeStructBegin('Blur_enableTable_args'); - if (this.table !== null && this.table !== undefined) { - output.writeFieldBegin('table', Thrift.Type.STRING, 1); - output.writeString(this.table); +Blur_execute_args.prototype.write = function(output) { + output.writeStructBegin('Blur_execute_args'); + if (this.commandName !== null && this.commandName !== undefined) { + output.writeFieldBegin('commandName', Thrift.Type.STRING, 1); + output.writeString(this.commandName); + output.writeFieldEnd(); + } + if (this.arguments !== null && this.arguments !== undefined) { + output.writeFieldBegin('arguments', Thrift.Type.STRUCT, 2); + this.arguments.write(output); output.writeFieldEnd(); } output.writeFieldStop(); @@ -172,20 +196,32 @@ Blur_enableTable_args.prototype.write = function(output) { return; }; -Blur_enableTable_result = function(args) { - this.ex = null; +Blur_execute_result = function(args) { + this.success = null; + this.bex = null; + this.tex = null; if (args instanceof BlurException) { - this.ex = args; + this.bex = args; + return; + } + if (args instanceof TimeoutException) { + this.tex = args; return; } if (args) { - if (args.ex !== undefined) { - this.ex = args.ex; + if (args.success !== undefined) { + this.success = args.success; + } + if (args.bex !== undefined) { + this.bex = args.bex; + } + if (args.tex !== undefined) { + this.tex = args.tex; } } }; -Blur_enableTable_result.prototype = {}; -Blur_enableTable_result.prototype.read = function(input) { +Blur_execute_result.prototype = {}; +Blur_execute_result.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -198,17 +234,30 @@ Blur_enableTable_result.prototype.read = function(input) { } switch (fid) { + case 0: + if (ftype == Thrift.Type.STRUCT) { + this.success = new Response(); + this.success.read(input); + } else { + input.skip(ftype); + } + break; case 1: if (ftype == Thrift.Type.STRUCT) { - this.ex = new BlurException(); - this.ex.read(input); + this.bex = new BlurException(); + this.bex.read(input); } else { input.skip(ftype); } break; - case 0: + case 2: + if (ftype == Thrift.Type.STRUCT) { + this.tex = new TimeoutException(); + this.tex.read(input); + } else { input.skip(ftype); - break; + } + break; default: input.skip(ftype); } @@ -218,11 +267,21 @@ Blur_enableTable_result.prototype.read = function(input) { return; }; -Blur_enableTable_result.prototype.write = function(output) { - output.writeStructBegin('Blur_enableTable_result'); - if (this.ex !== null && this.ex !== undefined) { - output.writeFieldBegin('ex', Thrift.Type.STRUCT, 1); - this.ex.write(output); +Blur_execute_result.prototype.write = function(output) { + output.writeStructBegin('Blur_execute_result'); + if (this.success !== null && this.success !== undefined) { + output.writeFieldBegin('success', Thrift.Type.STRUCT, 0); + this.success.write(output); + output.writeFieldEnd(); + } + if (this.bex !== null && this.bex !== undefined) { + output.writeFieldBegin('bex', Thrift.Type.STRUCT, 1); + this.bex.write(output); + output.writeFieldEnd(); + } + if (this.tex !== null && this.tex !== undefined) { + output.writeFieldBegin('tex', Thrift.Type.STRUCT, 2); + this.tex.write(output); output.writeFieldEnd(); } output.writeFieldStop(); @@ -230,16 +289,16 @@ Blur_enableTable_result.prototype.write = function(output) { return; }; -Blur_disableTable_args = function(args) { - this.table = null; +Blur_reconnect_args = function(args) { + this.instanceExecutionId = null; if (args) { - if (args.table !== undefined) { - this.table = args.table; + if (args.instanceExecutionId !== undefined) { + this.instanceExecutionId = args.instanceExecutionId; } } }; -Blur_disableTable_args.prototype = {}; -Blur_disableTable_args.prototype.read = function(input) { +Blur_reconnect_args.prototype = {}; +Blur_reconnect_args.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -253,8 +312,8 @@ Blur_disableTable_args.prototype.read = function(input) { switch (fid) { case 1: - if (ftype == Thrift.Type.STRING) { - this.table = input.readString().value; + if (ftype == Thrift.Type.I64) { + this.instanceExecutionId = input.readI64().value; } else { input.skip(ftype); } @@ -271,11 +330,11 @@ Blur_disableTable_args.prototype.read = function(input) { return; }; -Blur_disableTable_args.prototype.write = function(output) { - output.writeStructBegin('Blur_disableTable_args'); - if (this.table !== null && this.table !== undefined) { - output.writeFieldBegin('table', Thrift.Type.STRING, 1); - output.writeString(this.table); +Blur_reconnect_args.prototype.write = function(output) { + output.writeStructBegin('Blur_reconnect_args'); + if (this.instanceExecutionId !== null && this.instanceExecutionId !== undefined) { + output.writeFieldBegin('instanceExecutionId', Thrift.Type.I64, 1); + output.writeI64(this.instanceExecutionId); output.writeFieldEnd(); } output.writeFieldStop(); @@ -283,20 +342,32 @@ Blur_disableTable_args.prototype.write = function(output) { return; }; -Blur_disableTable_result = function(args) { - this.ex = null; +Blur_reconnect_result = function(args) { + this.success = null; + this.bex = null; + this.tex = null; if (args instanceof BlurException) { - this.ex = args; + this.bex = args; + return; + } + if (args instanceof TimeoutException) { + this.tex = args; return; } if (args) { - if (args.ex !== undefined) { - this.ex = args.ex; + if (args.success !== undefined) { + this.success = args.success; + } + if (args.bex !== undefined) { + this.bex = args.bex; + } + if (args.tex !== undefined) { + this.tex = args.tex; } } }; -Blur_disableTable_result.prototype = {}; -Blur_disableTable_result.prototype.read = function(input) { +Blur_reconnect_result.prototype = {}; +Blur_reconnect_result.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -309,17 +380,30 @@ Blur_disableTable_result.prototype.read = function(input) { } switch (fid) { + case 0: + if (ftype == Thrift.Type.STRUCT) { + this.success = new Response(); + this.success.read(input); + } else { + input.skip(ftype); + } + break; case 1: if (ftype == Thrift.Type.STRUCT) { - this.ex = new BlurException(); - this.ex.read(input); + this.bex = new BlurException(); + this.bex.read(input); } else { input.skip(ftype); } break; - case 0: + case 2: + if (ftype == Thrift.Type.STRUCT) { + this.tex = new TimeoutException(); + this.tex.read(input); + } else { input.skip(ftype); - break; + } + break; default: input.skip(ftype); } @@ -329,11 +413,21 @@ Blur_disableTable_result.prototype.read = function(input) { return; }; -Blur_disableTable_result.prototype.write = function(output) { - output.writeStructBegin('Blur_disableTable_result'); - if (this.ex !== null && this.ex !== undefined) { - output.writeFieldBegin('ex', Thrift.Type.STRUCT, 1); - this.ex.write(output); +Blur_reconnect_result.prototype.write = function(output) { + output.writeStructBegin('Blur_reconnect_result'); + if (this.success !== null && this.success !== undefined) { + output.writeFieldBegin('success', Thrift.Type.STRUCT, 0); + this.success.write(output); + output.writeFieldEnd(); + } + if (this.bex !== null && this.bex !== undefined) { + output.writeFieldBegin('bex', Thrift.Type.STRUCT, 1); + this.bex.write(output); + output.writeFieldEnd(); + } + if (this.tex !== null && this.tex !== undefined) { + output.writeFieldBegin('tex', Thrift.Type.STRUCT, 2); + this.tex.write(output); output.writeFieldEnd(); } output.writeFieldStop(); @@ -341,20 +435,24 @@ Blur_disableTable_result.prototype.write = function(output) { return; }; -Blur_removeTable_args = function(args) { - this.table = null; - this.deleteIndexFiles = null; +Blur_commandStatusList_args = function(args) { + this.startingAt = null; + this.fetch = null; + this.state = null; if (args) { - if (args.table !== undefined) { - this.table = args.table; + if (args.startingAt !== undefined) { + this.startingAt = args.startingAt; } - if (args.deleteIndexFiles !== undefined) { - this.deleteIndexFiles = args.deleteIndexFiles; + if (args.fetch !== undefined) { + this.fetch = args.fetch; + } + if (args.state !== undefined) { + this.state = args.state; } } }; -Blur_removeTable_args.prototype = {}; -Blur_removeTable_args.prototype.read = function(input) { +Blur_commandStatusList_args.prototype = {}; +Blur_commandStatusList_args.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -368,15 +466,22 @@ Blur_removeTable_args.prototype.read = function(input) { switch (fid) { case 1: - if (ftype == Thrift.Type.STRING) { - this.table = input.readString().value; + if (ftype == Thrift.Type.I32) { + this.startingAt = input.readI32().value; } else { input.skip(ftype); } break; case 2: - if (ftype == Thrift.Type.BOOL) { - this.deleteIndexFiles = input.readBool().value; + if (ftype == Thrift.Type.I16) { + this.fetch = input.readI16().value; + } else { + input.skip(ftype); + } + break; + case 3: + if (ftype == Thrift.Type.I32) { + this.state = input.readI32().value; } else { input.skip(ftype); } @@ -390,16 +495,21 @@ Blur_removeTable_args.prototype.read = function(input) { return; }; -Blur_removeTable_args.prototype.write = function(output) { - output.writeStructBegin('Blur_removeTable_args'); - if (this.table !== null && this.table !== undefined) { - output.writeFieldBegin('table', Thrift.Type.STRING, 1); - output.writeString(this.table); +Blur_commandStatusList_args.prototype.write = function(output) { + output.writeStructBegin('Blur_commandStatusList_args'); + if (this.startingAt !== null && this.startingAt !== undefined) { + output.writeFieldBegin('startingAt', Thrift.Type.I32, 1); + output.writeI32(this.startingAt); output.writeFieldEnd(); } - if (this.deleteIndexFiles !== null && this.deleteIndexFiles !== undefined) { - output.writeFieldBegin('deleteIndexFiles', Thrift.Type.BOOL, 2); - output.writeBool(this.deleteIndexFiles); + if (this.fetch !== null && this.fetch !== undefined) { + output.writeFieldBegin('fetch', Thrift.Type.I16, 2); + output.writeI16(this.fetch); + output.writeFieldEnd(); + } + if (this.state !== null && this.state !== undefined) { + output.writeFieldBegin('state', Thrift.Type.I32, 3); + output.writeI32(this.state); output.writeFieldEnd(); } output.writeFieldStop(); @@ -407,20 +517,24 @@ Blur_removeTable_args.prototype.write = function(output) { return; }; -Blur_removeTable_result = function(args) { +Blur_commandStatusList_result = function(args) { + this.success = null; this.ex = null; if (args instanceof BlurException) { this.ex = args; return; } if (args) { + if (args.success !== undefined) { + this.success = args.success; + } if (args.ex !== undefined) { this.ex = args.ex; } } }; -Blur_removeTable_result.prototype = {}; -Blur_removeTable_result.prototype.read = function(input) { +Blur_commandStatusList_result.prototype = {}; +Blur_commandStatusList_result.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -433,6 +547,26 @@ Blur_removeTable_result.prototype.read = function(input) { } switch (fid) { + case 0: + if (ftype == Thrift.Type.LIST) { + var _size298 = 0; + var _rtmp3302; + this.success = []; + var _etype301 = 0; + _rtmp3302 = input.readListBegin(); + _etype301 = _rtmp3302.etype; + _size298 = _rtmp3302.size; + for (var _i303 = 0; _i303 < _size298; ++_i303) + { + var elem304 = null; + elem304 = input.readString().value; + this.success.push(elem304); + } + input.readListEnd(); + } else { + input.skip(ftype); + } + break; case 1: if (ftype == Thrift.Type.STRUCT) { this.ex = new BlurException(); @@ -441,9 +575,6 @@ Blur_removeTable_result.prototype.read = function(input) { input.skip(ftype); } break; - case 0: - input.skip(ftype); - break; default: input.skip(ftype); } @@ -453,8 +584,22 @@ Blur_removeTable_result.prototype.read = function(input) { return; }; -Blur_removeTable_result.prototype.write = function(output) { - output.writeStructBegin('Blur_removeTable_result'); +Blur_commandStatusList_result.prototype.write = function(output) { + output.writeStructBegin('Blur_commandStatusList_result'); + if (this.success !== null && this.success !== undefined) { + output.writeFieldBegin('success', Thrift.Type.LIST, 0); + output.writeListBegin(Thrift.Type.STRING, this.success.length); + for (var iter305 in this.success) + { + if (this.success.hasOwnProperty(iter305)) + { + iter305 = this.success[iter305]; + output.writeString(iter305); + } + } + output.writeListEnd(); + output.writeFieldEnd(); + } if (this.ex !== null && this.ex !== undefined) { output.writeFieldBegin('ex', Thrift.Type.STRUCT, 1); this.ex.write(output); @@ -465,20 +610,16 @@ Blur_removeTable_result.prototype.write = function(output) { return; }; -Blur_addColumnDefinition_args = function(args) { - this.table = null; - this.columnDefinition = null; +Blur_commandStatus_args = function(args) { + this.commandExecutionId = null; if (args) { - if (args.table !== undefined) { - this.table = args.table; - } - if (args.columnDefinition !== undefined) { - this.columnDefinition = args.columnDefinition; + if (args.commandExecutionId !== undefined) { + this.commandExecutionId = args.commandExecutionId; } } }; -Blur_addColumnDefinition_args.prototype = {}; -Blur_addColumnDefinition_args.prototype.read = function(input) { +Blur_commandStatus_args.prototype = {}; +Blur_commandStatus_args.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -493,19 +634,14 @@ Blur_addColumnDefinition_args.prototype.read = function(input) { { case 1: if (ftype == Thrift.Type.STRING) { - this.table = input.readString().value; + this.commandExecutionId = input.readString().value; } else { input.skip(ftype); } break; - case 2: - if (ftype == Thrift.Type.STRUCT) { - this.columnDefinition = new ColumnDefinition(); - this.columnDefinition.read(input); - } else { + case 0: input.skip(ftype); - } - break; + break; default: input.skip(ftype); } @@ -515,16 +651,11 @@ Blur_addColumnDefinition_args.prototype.read = function(input) { return; }; -Blur_addColumnDefinition_args.prototype.write = function(output) { - output.writeStructBegin('Blur_addColumnDefinition_args'); - if (this.table !== null && this.table !== undefined) { - output.writeFieldBegin('table', Thrift.Type.STRING, 1); - output.writeString(this.table); - output.writeFieldEnd(); - } - if (this.columnDefinition !== null && this.columnDefinition !== undefined) { - output.writeFieldBegin('columnDefinition', Thrift.Type.STRUCT, 2); - this.columnDefinition.write(output); +Blur_commandStatus_args.prototype.write = function(output) { + output.writeStructBegin('Blur_commandStatus_args'); + if (this.commandExecutionId !== null && this.commandExecutionId !== undefined) { + output.writeFieldBegin('commandExecutionId', Thrift.Type.STRING, 1); + output.writeString(this.commandExecutionId); output.writeFieldEnd(); } output.writeFieldStop(); @@ -532,7 +663,7 @@ Blur_addColumnDefinition_args.prototype.write = function(output) { return; }; -Blur_addColumnDefinition_result = function(args) { +Blur_commandStatus_result = function(args) { this.success = null; this.ex = null; if (args instanceof BlurException) { @@ -548,8 +679,8 @@ Blur_addColumnDefinition_result = function(args) { } } }; -Blur_addColumnDefinition_result.prototype = {}; -Blur_addColumnDefinition_result.prototype.read = function(input) { +Blur_commandStatus_result.prototype = {}; +Blur_commandStatus_result.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -563,8 +694,9 @@ Blur_addColumnDefinition_result.prototype.read = function(input) { switch (fid) { case 0: - if (ftype == Thrift.Type.BOOL) { - this.success = input.readBool().value; + if (ftype == Thrift.Type.STRUCT) { + this.success = new CommandStatus(); + this.success.read(input); } else { input.skip(ftype); } @@ -586,11 +718,11 @@ Blur_addColumnDefinition_result.prototype.read = function(input) { return; }; -Blur_addColumnDefinition_result.prototype.write = function(output) { - output.writeStructBegin('Blur_addColumnDefinition_result'); +Blur_commandStatus_result.prototype.write = function(output) { + output.writeStructBegin('Blur_commandStatus_result'); if (this.success !== null && this.success !== undefined) { - output.writeFieldBegin('success', Thrift.Type.BOOL, 0); - output.writeBool(this.success); + output.writeFieldBegin('success', Thrift.Type.STRUCT, 0); + this.success.write(output); output.writeFieldEnd(); } if (this.ex !== null && this.ex !== undefined) { @@ -603,10 +735,16 @@ Blur_addColumnDefinition_result.prototype.write = function(output) { return; }; -Blur_tableList_args = function(args) { +Blur_commandCancel_args = function(args) { + this.commandExecutionId = null; + if (args) { + if (args.commandExecutionId !== undefined) { + this.commandExecutionId = args.commandExecutionId; + } + } }; -Blur_tableList_args.prototype = {}; -Blur_tableList_args.prototype.read = function(input) { +Blur_commandCancel_args.prototype = {}; +Blur_commandCancel_args.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -617,38 +755,53 @@ Blur_tableList_args.prototype.read = function(input) { if (ftype == Thrift.Type.STOP) { break; } - input.skip(ftype); + switch (fid) + { + case 1: + if (ftype == Thrift.Type.STRING) { + this.commandExecutionId = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 0: + input.skip(ftype); + break; + default: + input.skip(ftype); + } input.readFieldEnd(); } input.readStructEnd(); return; }; -Blur_tableList_args.prototype.write = function(output) { - output.writeStructBegin('Blur_tableList_args'); +Blur_commandCancel_args.prototype.write = function(output) { + output.writeStructBegin('Blur_commandCancel_args'); + if (this.commandExecutionId !== null && this.commandExecutionId !== undefined) { + output.writeFieldBegin('commandExecutionId', Thrift.Type.STRING, 1); + output.writeString(this.commandExecutionId); + output.writeFieldEnd(); + } output.writeFieldStop(); output.writeStructEnd(); return; }; -Blur_tableList_result = function(args) { - this.success = null; +Blur_commandCancel_result = function(args) { this.ex = null; if (args instanceof BlurException) { this.ex = args; return; } if (args) { - if (args.success !== undefined) { - this.success = args.success; - } if (args.ex !== undefined) { this.ex = args.ex; } } }; -Blur_tableList_result.prototype = {}; -Blur_tableList_result.prototype.read = function(input) { +Blur_commandCancel_result.prototype = {}; +Blur_commandCancel_result.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -661,26 +814,6 @@ Blur_tableList_result.prototype.read = function(input) { } switch (fid) { - case 0: - if (ftype == Thrift.Type.LIST) { - var _size208 = 0; - var _rtmp3212; - this.success = []; - var _etype211 = 0; - _rtmp3212 = input.readListBegin(); - _etype211 = _rtmp3212.etype; - _size208 = _rtmp3212.size; - for (var _i213 = 0; _i213 < _size208; ++_i213) - { - var elem214 = null; - elem214 = input.readString().value; - this.success.push(elem214); - } - input.readListEnd(); - } else { - input.skip(ftype); - } - break; case 1: if (ftype == Thrift.Type.STRUCT) { this.ex = new BlurException(); @@ -689,6 +822,9 @@ Blur_tableList_result.prototype.read = function(input) { input.skip(ftype); } break; + case 0: + input.skip(ftype); + break; default: input.skip(ftype); } @@ -698,22 +834,8 @@ Blur_tableList_result.prototype.read = function(input) { return; }; -Blur_tableList_result.prototype.write = function(output) { - output.writeStructBegin('Blur_tableList_result'); - if (this.success !== null && this.success !== undefined) { - output.writeFieldBegin('success', Thrift.Type.LIST, 0); - output.writeListBegin(Thrift.Type.STRING, this.success.length); - for (var iter215 in this.success) - { - if (this.success.hasOwnProperty(iter215)) - { - iter215 = this.success[iter215]; - output.writeString(iter215); - } - } - output.writeListEnd(); - output.writeFieldEnd(); - } +Blur_commandCancel_result.prototype.write = function(output) { + output.writeStructBegin('Blur_commandCancel_result'); if (this.ex !== null && this.ex !== undefined) { output.writeFieldBegin('ex', Thrift.Type.STRUCT, 1); this.ex.write(output); @@ -724,16 +846,72 @@ Blur_tableList_result.prototype.write = function(output) { return; }; -Blur_tableListByCluster_args = function(args) { - this.cluster = null; +Blur_refresh_args = function(args) { +}; +Blur_refresh_args.prototype = {}; +Blur_refresh_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; + } + input.skip(ftype); + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +Blur_refresh_args.prototype.write = function(output) { + output.writeStructBegin('Blur_refresh_args'); + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +Blur_refresh_result = function(args) { +}; +Blur_refresh_result.prototype = {}; +Blur_refresh_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; + } + input.skip(ftype); + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +Blur_refresh_result.prototype.write = function(output) { + output.writeStructBegin('Blur_refresh_result'); + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +Blur_createTable_args = function(args) { + this.tableDescriptor = null; if (args) { - if (args.cluster !== undefined) { - this.cluster = args.cluster; + if (args.tableDescriptor !== undefined) { + this.tableDescriptor = args.tableDescriptor; } } }; -Blur_tableListByCluster_args.prototype = {}; -Blur_tableListByCluster_args.prototype.read = function(input) { +Blur_createTable_args.prototype = {}; +Blur_createTable_args.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -747,8 +925,9 @@ Blur_tableListByCluster_args.prototype.read = function(input) { switch (fid) { case 1: - if (ftype == Thrift.Type.STRING) { - this.cluster = input.readString().value; + if (ftype == Thrift.Type.STRUCT) { + this.tableDescriptor = new TableDescriptor(); + this.tableDescriptor.read(input); } else { input.skip(ftype); } @@ -765,11 +944,11 @@ Blur_tableListByCluster_args.prototype.read = function(input) { return; }; -Blur_tableListByCluster_args.prototype.write = function(output) { - output.writeStructBegin('Blur_tableListByCluster_args'); - if (this.cluster !== null && this.cluster !== undefined) { - output.writeFieldBegin('cluster', Thrift.Type.STRING, 1); - output.writeString(this.cluster); +Blur_createTable_args.prototype.write = function(output) { + output.writeStructBegin('Blur_createTable_args'); + if (this.tableDescriptor !== null && this.tableDescriptor !== undefined) { + output.writeFieldBegin('tableDescriptor', Thrift.Type.STRUCT, 1); + this.tableDescriptor.write(output); output.writeFieldEnd(); } output.writeFieldStop(); @@ -777,24 +956,20 @@ Blur_tableListByCluster_args.prototype.write = function(output) { return; }; -Blur_tableListByCluster_result = function(args) { - this.success = null; +Blur_createTable_result = function(args) { this.ex = null; if (args instanceof BlurException) { this.ex = args; return; } if (args) { - if (args.success !== undefined) { - this.success = args.success; - } if (args.ex !== undefined) { this.ex = args.ex; } } }; -Blur_tableListByCluster_result.prototype = {}; -Blur_tableListByCluster_result.prototype.read = function(input) { +Blur_createTable_result.prototype = {}; +Blur_createTable_result.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -807,26 +982,6 @@ Blur_tableListByCluster_result.prototype.read = function(input) { } switch (fid) { - case 0: - if (ftype == Thrift.Type.LIST) { - var _size216 = 0; - var _rtmp3220; - this.success = []; - var _etype219 = 0; - _rtmp3220 = input.readListBegin(); - _etype219 = _rtmp3220.etype; - _size216 = _rtmp3220.size; - for (var _i221 = 0; _i221 < _size216; ++_i221) - { - var elem222 = null; - elem222 = input.readString().value; - this.success.push(elem222); - } - input.readListEnd(); - } else { - input.skip(ftype); - } - break; case 1: if (ftype == Thrift.Type.STRUCT) { this.ex = new BlurException(); @@ -835,6 +990,9 @@ Blur_tableListByCluster_result.prototype.read = function(input) { input.skip(ftype); } break; + case 0: + input.skip(ftype); + break; default: input.skip(ftype); } @@ -844,22 +1002,8 @@ Blur_tableListByCluster_result.prototype.read = function(input) { return; }; -Blur_tableListByCluster_result.prototype.write = function(output) { - output.writeStructBegin('Blur_tableListByCluster_result'); - if (this.success !== null && this.success !== undefined) { - output.writeFieldBegin('success', Thrift.Type.LIST, 0); - output.writeListBegin(Thrift.Type.STRING, this.success.length); - for (var iter223 in this.success) - { - if (this.success.hasOwnProperty(iter223)) - { - iter223 = this.success[iter223]; - output.writeString(iter223); - } - } - output.writeListEnd(); - output.writeFieldEnd(); - } +Blur_createTable_result.prototype.write = function(output) { + output.writeStructBegin('Blur_createTable_result'); if (this.ex !== null && this.ex !== undefined) { output.writeFieldBegin('ex', Thrift.Type.STRUCT, 1); this.ex.write(output); @@ -870,7 +1014,7 @@ Blur_tableListByCluster_result.prototype.write = function(output) { return; }; -Blur_describe_args = function(args) { +Blur_enableTable_args = function(args) { this.table = null; if (args) { if (args.table !== undefined) { @@ -878,8 +1022,8 @@ Blur_describe_args = function(args) { } } }; -Blur_describe_args.prototype = {}; -Blur_describe_args.prototype.read = function(input) { +Blur_enableTable_args.prototype = {}; +Blur_enableTable_args.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -911,8 +1055,8 @@ Blur_describe_args.prototype.read = function(input) { return; }; -Blur_describe_args.prototype.write = function(output) { - output.writeStructBegin('Blur_describe_args'); +Blur_enableTable_args.prototype.write = function(output) { + output.writeStructBegin('Blur_enableTable_args'); if (this.table !== null && this.table !== undefined) { output.writeFieldBegin('table', Thrift.Type.STRING, 1); output.writeString(this.table); @@ -923,24 +1067,20 @@ Blur_describe_args.prototype.write = function(output) { return; }; -Blur_describe_result = function(args) { - this.success = null; +Blur_enableTable_result = function(args) { this.ex = null; if (args instanceof BlurException) { this.ex = args; return; } if (args) { - if (args.success !== undefined) { - this.success = args.success; - } if (args.ex !== undefined) { this.ex = args.ex; } } }; -Blur_describe_result.prototype = {}; -Blur_describe_result.prototype.read = function(input) { +Blur_enableTable_result.prototype = {}; +Blur_enableTable_result.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -953,22 +1093,17 @@ Blur_describe_result.prototype.read = function(input) { } switch (fid) { - case 0: + case 1: if (ftype == Thrift.Type.STRUCT) { - this.success = new TableDescriptor(); - this.success.read(input); + this.ex = new BlurException(); + this.ex.read(input); } else { input.skip(ftype); } break; - case 1: - if (ftype == Thrift.Type.STRUCT) { - this.ex = new BlurException(); - this.ex.read(input); - } else { + case 0: input.skip(ftype); - } - break; + break; default: input.skip(ftype); } @@ -978,13 +1113,8 @@ Blur_describe_result.prototype.read = function(input) { return; }; -Blur_describe_result.prototype.write = function(output) { - output.writeStructBegin('Blur_describe_result'); - if (this.success !== null && this.success !== undefined) { - output.writeFieldBegin('success', Thrift.Type.STRUCT, 0); - this.success.write(output); - output.writeFieldEnd(); - } +Blur_enableTable_result.prototype.write = function(output) { + output.writeStructBegin('Blur_enableTable_result'); if (this.ex !== null && this.ex !== undefined) { output.writeFieldBegin('ex', Thrift.Type.STRUCT, 1); this.ex.write(output); @@ -995,7 +1125,7 @@ Blur_describe_result.prototype.write = function(output) { return; }; -Blur_schema_args = function(args) { +Blur_disableTable_args = function(args) { this.table = null; if (args) { if (args.table !== undefined) { @@ -1003,8 +1133,8 @@ Blur_schema_args = function(args) { } } }; -Blur_schema_args.prototype = {}; -Blur_schema_args.prototype.read = function(input) { +Blur_disableTable_args.prototype = {}; +Blur_disableTable_args.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -1036,8 +1166,8 @@ Blur_schema_args.prototype.read = function(input) { return; }; -Blur_schema_args.prototype.write = function(output) { - output.writeStructBegin('Blur_schema_args'); +Blur_disableTable_args.prototype.write = function(output) { + output.writeStructBegin('Blur_disableTable_args'); if (this.table !== null && this.table !== undefined) { output.writeFieldBegin('table', Thrift.Type.STRING, 1); output.writeString(this.table); @@ -1048,24 +1178,20 @@ Blur_schema_args.prototype.write = function(output) { return; }; -Blur_schema_result = function(args) { - this.success = null; +Blur_disableTable_result = function(args) { this.ex = null; if (args instanceof BlurException) { this.ex = args; return; } if (args) { - if (args.success !== undefined) { - this.success = args.success; - } if (args.ex !== undefined) { this.ex = args.ex; } } }; -Blur_schema_result.prototype = {}; -Blur_schema_result.prototype.read = function(input) { +Blur_disableTable_result.prototype = {}; +Blur_disableTable_result.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -1078,14 +1204,6 @@ Blur_schema_result.prototype.read = function(input) { } switch (fid) { - case 0: - if (ftype == Thrift.Type.STRUCT) { - this.success = new Schema(); - this.success.read(input); - } else { - input.skip(ftype); - } - break; case 1: if (ftype == Thrift.Type.STRUCT) { this.ex = new BlurException(); @@ -1094,6 +1212,9 @@ Blur_schema_result.prototype.read = function(input) { input.skip(ftype); } break; + case 0: + input.skip(ftype); + break; default: input.skip(ftype); } @@ -1103,13 +1224,8 @@ Blur_schema_result.prototype.read = function(input) { return; }; -Blur_schema_result.prototype.write = function(output) { - output.writeStructBegin('Blur_schema_result'); - if (this.success !== null && this.success !== undefined) { - output.writeFieldBegin('success', Thrift.Type.STRUCT, 0); - this.success.write(output); - output.writeFieldEnd(); - } +Blur_disableTable_result.prototype.write = function(output) { + output.writeStructBegin('Blur_disableTable_result'); if (this.ex !== null && this.ex !== undefined) { output.writeFieldBegin('ex', Thrift.Type.STRUCT, 1); this.ex.write(output); @@ -1120,20 +1236,20 @@ Blur_schema_result.prototype.write = function(output) { return; }; -Blur_parseQuery_args = function(args) { +Blur_removeTable_args = function(args) { this.table = null; - this.query = null; + this.deleteIndexFiles = null; if (args) { if (args.table !== undefined) { this.table = args.table; } - if (args.query !== undefined) { - this.query = args.query; + if (args.deleteIndexFiles !== undefined) { + this.deleteIndexFiles = args.deleteIndexFiles; } } }; -Blur_parseQuery_args.prototype = {}; -Blur_parseQuery_args.prototype.read = function(input) { +Blur_removeTable_args.prototype = {}; +Blur_removeTable_args.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -1154,9 +1270,8 @@ Blur_parseQuery_args.prototype.read = function(input) { } break; case 2: - if (ftype == Thrift.Type.STRUCT) { - this.query = new Query(); - this.query.read(input); + if (ftype == Thrift.Type.BOOL) { + this.deleteIndexFiles = input.readBool().value; } else { input.skip(ftype); } @@ -1170,16 +1285,16 @@ Blur_parseQuery_args.prototype.read = function(input) { return; }; -Blur_parseQuery_args.prototype.write = function(output) { - output.writeStructBegin('Blur_parseQuery_args'); +Blur_removeTable_args.prototype.write = function(output) { + output.writeStructBegin('Blur_removeTable_args'); if (this.table !== null && this.table !== undefined) { output.writeFieldBegin('table', Thrift.Type.STRING, 1); output.writeString(this.table); output.writeFieldEnd(); } - if (this.query !== null && this.query !== undefined) { - output.writeFieldBegin('query', Thrift.Type.STRUCT, 2); - this.query.write(output); + if (this.deleteIndexFiles !== null && this.deleteIndexFiles !== undefined) { + output.writeFieldBegin('deleteIndexFiles', Thrift.Type.BOOL, 2); + output.writeBool(this.deleteIndexFiles); output.writeFieldEnd(); } output.writeFieldStop(); @@ -1187,24 +1302,20 @@ Blur_parseQuery_args.prototype.write = function(output) { return; }; -Blur_parseQuery_result = function(args) { - this.success = null; +Blur_removeTable_result = function(args) { this.ex = null; if (args instanceof BlurException) { this.ex = args; return; } if (args) { - if (args.success !== undefined) { - this.success = args.success; - } if (args.ex !== undefined) { this.ex = args.ex; } } }; -Blur_parseQuery_result.prototype = {}; -Blur_parseQuery_result.prototype.read = function(input) { +Blur_removeTable_result.prototype = {}; +Blur_removeTable_result.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -1217,13 +1328,6 @@ Blur_parseQuery_result.prototype.read = function(input) { } switch (fid) { - case 0: - if (ftype == Thrift.Type.STRING) { - this.success = input.readString().value; - } else { - input.skip(ftype); - } - break; case 1: if (ftype == Thrift.Type.STRUCT) { this.ex = new BlurException(); @@ -1232,6 +1336,9 @@ Blur_parseQuery_result.prototype.read = function(input) { input.skip(ftype); } break; + case 0: + input.skip(ftype); + break; default: input.skip(ftype); } @@ -1241,13 +1348,8 @@ Blur_parseQuery_result.prototype.read = function(input) { return; }; -Blur_parseQuery_result.prototype.write = function(output) { - output.writeStructBegin('Blur_parseQuery_result'); - if (this.success !== null && this.success !== undefined) { - output.writeFieldBegin('success', Thrift.Type.STRING, 0); - output.writeString(this.success); - output.writeFieldEnd(); - } +Blur_removeTable_result.prototype.write = function(output) { + output.writeStructBegin('Blur_removeTable_result'); if (this.ex !== null && this.ex !== undefined) { output.writeFieldBegin('ex', Thrift.Type.STRUCT, 1); this.ex.write(output); @@ -1258,16 +1360,20 @@ Blur_parseQuery_result.prototype.write = function(output) { return; }; -Blur_tableStats_args = function(args) { +Blur_addColumnDefinition_args = function(args) { this.table = null; + this.columnDefinition = null; if (args) { if (args.table !== undefined) { this.table = args.table; } + if (args.columnDefinition !== undefined) { + this.columnDefinition = args.columnDefinition; + } } }; -Blur_tableStats_args.prototype = {}; -Blur_tableStats_args.prototype.read = function(input) { +Blur_addColumnDefinition_args.prototype = {}; +Blur_addColumnDefinition_args.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -1287,9 +1393,14 @@ Blur_tableStats_args.prototype.read = function(input) { input.skip(ftype); } break; - case 0: + case 2: + if (ftype == Thrift.Type.STRUCT) { + this.columnDefinition = new ColumnDefinition(); + this.columnDefinition.read(input); + } else { input.skip(ftype); - break; + } + break; default: input.skip(ftype); } @@ -1299,19 +1410,24 @@ Blur_tableStats_args.prototype.read = function(input) { return; }; -Blur_tableStats_args.prototype.write = function(output) { - output.writeStructBegin('Blur_tableStats_args'); +Blur_addColumnDefinition_args.prototype.write = function(output) { + output.writeStructBegin('Blur_addColumnDefinition_args'); if (this.table !== null && this.table !== undefined) { output.writeFieldBegin('table', Thrift.Type.STRING, 1); output.writeString(this.table); output.writeFieldEnd(); } + if (this.columnDefinition !== null && this.columnDefinition !== undefined) { + output.writeFieldBegin('columnDefinition', Thrift.Type.STRUCT, 2); + this.columnDefinition.write(output); + output.writeFieldEnd(); + } output.writeFieldStop(); output.writeStructEnd(); return; }; -Blur_tableStats_result = function(args) { +Blur_addColumnDefinition_result = function(args) { this.success = null; this.ex = null; if (args instanceof BlurException) { @@ -1327,8 +1443,8 @@ Blur_tableStats_result = function(args) { } } }; -Blur_tableStats_result.prototype = {}; -Blur_tableStats_result.prototype.read = function(input) { +Blur_addColumnDefinition_result.prototype = {}; +Blur_addColumnDefinition_result.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -1342,9 +1458,8 @@ Blur_tableStats_result.prototype.read = function(input) { switch (fid) { case 0: - if (ftype == Thrift.Type.STRUCT) { - this.success = new TableStats(); - this.success.read(input); + if (ftype == Thrift.Type.BOOL) { + this.success = input.readBool().value; } else { input.skip(ftype); } @@ -1366,11 +1481,11 @@ Blur_tableStats_result.prototype.read = function(input) { return; }; -Blur_tableStats_result.prototype.write = function(output) { - output.writeStructBegin('Blur_tableStats_result'); +Blur_addColumnDefinition_result.prototype.write = function(output) { + output.writeStructBegin('Blur_addColumnDefinition_result'); if (this.success !== null && this.success !== undefined) { - output.writeFieldBegin('success', Thrift.Type.STRUCT, 0); - this.success.write(output); + output.writeFieldBegin('success', Thrift.Type.BOOL, 0); + output.writeBool(this.success); output.writeFieldEnd(); } if (this.ex !== null && this.ex !== undefined) { @@ -1383,20 +1498,10 @@ Blur_tableStats_result.prototype.write = function(output) { return; }; -Blur_optimize_args = function(args) { - this.table = null; - this.numberOfSegmentsPerShard = null; - if (args) { - if (args.table !== undefined) { - this.table = args.table; - } - if (args.numberOfSegmentsPerShard !== undefined) { - this.numberOfSegmentsPerShard = args.numberOfSegmentsPerShard; - } - } +Blur_tableList_args = function(args) { }; -Blur_optimize_args.prototype = {}; -Blur_optimize_args.prototype.read = function(input) { +Blur_tableList_args.prototype = {}; +Blur_tableList_args.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -1407,62 +1512,38 @@ Blur_optimize_args.prototype.read = function(input) { 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.I32) { - this.numberOfSegmentsPerShard = input.readI32().value; - } else { - input.skip(ftype); - } - break; - default: - input.skip(ftype); - } + input.skip(ftype); input.readFieldEnd(); } input.readStructEnd(); return; }; -Blur_optimize_args.prototype.write = function(output) { - output.writeStructBegin('Blur_optimize_args'); - if (this.table !== null && this.table !== undefined) { - output.writeFieldBegin('table', Thrift.Type.STRING, 1); - output.writeString(this.table); - output.writeFieldEnd(); - } - if (this.numberOfSegmentsPerShard !== null && this.numberOfSegmentsPerShard !== undefined) { - output.writeFieldBegin('numberOfSegmentsPerShard', Thrift.Type.I32, 2); - output.writeI32(this.numberOfSegmentsPerShard); - output.writeFieldEnd(); - } +Blur_tableList_args.prototype.write = function(output) { + output.writeStructBegin('Blur_tableList_args'); output.writeFieldStop(); output.writeStructEnd(); return; }; -Blur_optimize_result = function(args) { +Blur_tableList_result = function(args) { + this.success = null; this.ex = null; if (args instanceof BlurException) { this.ex = args; return; } if (args) { + if (args.success !== undefined) { + this.success = args.success; + } if (args.ex !== undefined) { this.ex = args.ex; } } }; -Blur_optimize_result.prototype = {}; -Blur_optimize_result.prototype.read = function(input) { +Blur_tableList_result.prototype = {}; +Blur_tableList_result.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -1475,6 +1556,26 @@ Blur_optimize_result.prototype.read = function(input) { } switch (fid) { + case 0: + if (ftype == Thrift.Type.LIST) { + var _size306 = 0; + var _rtmp3310; + this.success = []; + var _etype309 = 0; + _rtmp3310 = input.readListBegin(); + _etype309 = _rtmp3310.etype; + _size306 = _rtmp3310.size; + for (var _i311 = 0; _i311 < _size306; ++_i311) + { + var elem312 = null; + elem312 = input.readString().value; + this.success.push(elem312); + } + input.readListEnd(); + } else { + input.skip(ftype); + } + break; case 1: if (ftype == Thrift.Type.STRUCT) { this.ex = new BlurException(); @@ -1483,9 +1584,6 @@ Blur_optimize_result.prototype.read = function(input) { input.skip(ftype); } break; - case 0: - input.skip(ftype); - break; default: input.skip(ftype); } @@ -1495,8 +1593,22 @@ Blur_optimize_result.prototype.read = function(input) { return; }; -Blur_optimize_result.prototype.write = function(output) { - output.writeStructBegin('Blur_optimize_result'); +Blur_tableList_result.prototype.write = function(output) { + output.writeStructBegin('Blur_tableList_result'); + if (this.success !== null && this.success !== undefined) { + output.writeFieldBegin('success', Thrift.Type.LIST, 0); + output.writeListBegin(Thrift.Type.STRING, this.success.length); + for (var iter313 in this.success) + { + if (this.success.hasOwnProperty(iter313)) + { + iter313 = this.success[iter313]; + output.writeString(iter313); + } + } + output.writeListEnd(); + output.writeFieldEnd(); + } if (this.ex !== null && this.ex !== undefined) { output.writeFieldBegin('ex', Thrift.Type.STRUCT, 1); this.ex.write(output); @@ -1507,20 +1619,16 @@ Blur_optimize_result.prototype.write = function(output) { return; }; -Blur_createSnapshot_args = function(args) { - this.table = null; - this.name = null; +Blur_tableListByCluster_args = function(args) { + this.cluster = null; if (args) { - if (args.table !== undefined) { - this.table = args.table; - } - if (args.name !== undefined) { - this.name = args.name; + if (args.cluster !== undefined) { + this.cluster = args.cluster; } } }; -Blur_createSnapshot_args.prototype = {}; -Blur_createSnapshot_args.prototype.read = function(input) { +Blur_tableListByCluster_args.prototype = {}; +Blur_tableListByCluster_args.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -1535,18 +1643,14 @@ Blur_createSnapshot_args.prototype.read = function(input) { { case 1: if (ftype == Thrift.Type.STRING) { - this.table = input.readString().value; + this.cluster = input.readString().value; } else { input.skip(ftype); } break; - case 2: - if (ftype == Thrift.Type.STRING) { - this.name = input.readString().value; - } else { + case 0: input.skip(ftype); - } - break; + break; default: input.skip(ftype); } @@ -1556,16 +1660,11 @@ Blur_createSnapshot_args.prototype.read = function(input) { return; }; -Blur_createSnapshot_args.prototype.write = function(output) { - output.writeStructBegin('Blur_createSnapshot_args'); - if (this.table !== null && this.table !== undefined) { - output.writeFieldBegin('table', Thrift.Type.STRING, 1); - output.writeString(this.table); - output.writeFieldEnd(); - } - if (this.name !== null && this.name !== undefined) { - output.writeFieldBegin('name', Thrift.Type.STRING, 2); - output.writeString(this.name); +Blur_tableListByCluster_args.prototype.write = function(output) { + output.writeStructBegin('Blur_tableListByCluster_args'); + if (this.cluster !== null && this.cluster !== undefined) { + output.writeFieldBegin('cluster', Thrift.Type.STRING, 1); + output.writeString(this.cluster); output.writeFieldEnd(); } output.writeFieldStop(); @@ -1573,20 +1672,24 @@ Blur_createSnapshot_args.prototype.write = function(output) { return; }; -Blur_createSnapshot_result = function(args) { +Blur_tableListByCluster_result = function(args) { + this.success = null; this.ex = null; if (args instanceof BlurException) { this.ex = args; return; } if (args) { + if (args.success !== undefined) { + this.success = args.success; + } if (args.ex !== undefined) { this.ex = args.ex; } } }; -Blur_createSnapshot_result.prototype = {}; -Blur_createSnapshot_result.prototype.read = function(input) { +Blur_tableListByCluster_result.prototype = {}; +Blur_tableListByCluster_result.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -1599,6 +1702,26 @@ Blur_createSnapshot_result.prototype.read = function(input) { } switch (fid) { + case 0: + if (ftype == Thrift.Type.LIST) { + var _size314 = 0; + var _rtmp3318; + this.success = []; + var _etype317 = 0; + _rtmp3318 = input.readListBegin(); + _etype317 = _rtmp3318.etype; + _size314 = _rtmp3318.size; + for (var _i319 = 0; _i319 < _size314; ++_i319) + { + var elem320 = null; + elem320 = input.readString().value; + this.success.push(elem320); + } + input.readListEnd(); + } else { + input.skip(ftype); + } + break; case 1: if (ftype == Thrift.Type.STRUCT) { this.ex = new BlurException(); @@ -1607,9 +1730,6 @@ Blur_createSnapshot_result.prototype.read = function(input) { input.skip(ftype); } break; - case 0: - input.skip(ftype); - break; default: input.skip(ftype); } @@ -1619,8 +1739,22 @@ Blur_createSnapshot_result.prototype.read = function(input) { return; }; -Blur_createSnapshot_result.prototype.write = function(output) { - output.writeStructBegin('Blur_createSnapshot_result'); +Blur_tableListByCluster_result.prototype.write = function(output) { + output.writeStructBegin('Blur_tableListByCluster_result'); + if (this.success !== null && this.success !== undefined) { + output.writeFieldBegin('success', Thrift.Type.LIST, 0); + output.writeListBegin(Thrift.Type.STRING, this.success.length); + for (var iter321 in this.success) + { + if (this.success.hasOwnProperty(iter321)) + { + iter321 = this.success[iter321]; + output.writeString(iter321); + } + } + output.writeListEnd(); + output.writeFieldEnd(); + } if (this.ex !== null && this.ex !== undefined) { output.writeFieldBegin('ex', Thrift.Type.STRUCT, 1); this.ex.write(output); @@ -1631,20 +1765,16 @@ Blur_createSnapshot_result.prototype.write = function(output) { return; }; -Blur_removeSnapshot_args = function(args) { +Blur_describe_args = function(args) { this.table = null; - this.name = null; if (args) { if (args.table !== undefined) { this.table = args.table; } - if (args.name !== undefined) { - this.name = args.name; - } } }; -Blur_removeSnapshot_args.prototype = {}; -Blur_removeSnapshot_args.prototype.read = function(input) { +Blur_describe_args.prototype = {}; +Blur_describe_args.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -1664,13 +1794,9 @@ Blur_removeSnapshot_args.prototype.read = function(input) { input.skip(ftype); } break; - case 2: - if (ftype == Thrift.Type.STRING) { - this.name = input.readString().value; - } else { + case 0: input.skip(ftype); - } - break; + break; default: input.skip(ftype); } @@ -1680,37 +1806,36 @@ Blur_removeSnapshot_args.prototype.read = function(input) { return; }; -Blur_removeSnapshot_args.prototype.write = function(output) { - output.writeStructBegin('Blur_removeSnapshot_args'); +Blur_describe_args.prototype.write = function(output) { + output.writeStructBegin('Blur_describe_args'); if (this.table !== null && this.table !== undefined) { output.writeFieldBegin('table', Thrift.Type.STRING, 1); output.writeString(this.table); output.writeFieldEnd(); } - if (this.name !== null && this.name !== undefined) { - output.writeFieldBegin('name', Thrift.Type.STRING, 2); - output.writeString(this.name); - output.writeFieldEnd(); - } output.writeFieldStop(); output.writeStructEnd(); return; }; -Blur_removeSnapshot_result = function(args) { +Blur_describe_result = function(args) { + this.success = null; this.ex = null; if (args instanceof BlurException) { this.ex = args; return; } if (args) { + if (args.success !== undefined) { + this.success = args.success; + } if (args.ex !== undefined) { this.ex = args.ex; } } }; -Blur_removeSnapshot_result.prototype = {}; -Blur_removeSnapshot_result.prototype.read = function(input) { +Blur_describe_result.prototype = {}; +Blur_describe_result.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -1723,6 +1848,14 @@ Blur_removeSnapshot_result.prototype.read = function(input) { } switch (fid) { + case 0: + if (ftype == Thrift.Type.STRUCT) { + this.success = new TableDescriptor(); + this.success.read(input); + } else { + input.skip(ftype); + } + break; case 1: if (ftype == Thrift.Type.STRUCT) { this.ex = new BlurException(); @@ -1731,9 +1864,6 @@ Blur_removeSnapshot_result.prototype.read = function(input) { input.skip(ftype); } break; - case 0: - input.skip(ftype); - break; default: input.skip(ftype); } @@ -1743,8 +1873,13 @@ Blur_removeSnapshot_result.prototype.read = function(input) { return; }; -Blur_removeSnapshot_result.prototype.write = function(output) { - output.writeStructBegin('Blur_removeSnapshot_result'); +Blur_describe_result.prototype.write = function(output) { + output.writeStructBegin('Blur_describe_result'); + if (this.success !== null && this.success !== undefined) { + output.writeFieldBegin('success', Thrift.Type.STRUCT, 0); + this.success.write(output); + output.writeFieldEnd(); + } if (this.ex !== null && this.ex !== undefined) { output.writeFieldBegin('ex', Thrift.Type.STRUCT, 1); this.ex.write(output); @@ -1755,7 +1890,7 @@ Blur_removeSnapshot_result.prototype.write = function(output) { return; }; -Blur_listSnapshots_args = function(args) { +Blur_schema_args = function(args) { this.table = null; if (args) { if (args.table !== undefined) { @@ -1763,8 +1898,8 @@ Blur_listSnapshots_args = function(args) { } } }; -Blur_listSnapshots_args.prototype = {}; -Blur_listSnapshots_args.prototype.read = function(input) { +Blur_schema_args.prototype = {}; +Blur_schema_args.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -1796,8 +1931,8 @@ Blur_listSnapshots_args.prototype.read = function(input) { return; }; -Blur_listSnapshots_args.prototype.write = function(output) { - output.writeStructBegin('Blur_listSnapshots_args'); +Blur_schema_args.prototype.write = function(output) { + output.writeStructBegin('Blur_schema_args'); if (this.table !== null && this.table !== undefined) { output.writeFieldBegin('table', Thrift.Type.STRING, 1); output.writeString(this.table); @@ -1808,7 +1943,7 @@ Blur_listSnapshots_args.prototype.write = function(output) { return; }; -Blur_listSnapshots_result = function(args) { +Blur_schema_result = function(args) { this.success = null; this.ex = null; if (args instanceof BlurException) { @@ -1824,8 +1959,8 @@ Blur_listSnapshots_result = function(args) { } } }; -Blur_listSnapshots_result.prototype = {}; -Blur_listSnapshots_result.prototype.read = function(input) { +Blur_schema_result.prototype = {}; +Blur_schema_result.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -1839,43 +1974,9 @@ Blur_listSnapshots_result.prototype.read = function(input) { switch (fid) { case 0: - if (ftype == Thrift.Type.MAP) { - var _size224 = 0; - var _rtmp3228; - this.success = {}; - var _ktype225 = 0; - var _vtype226 = 0; - _rtmp3228 = input.readMapBegin(); - _ktype225 = _rtmp3228.ktype; - _vtype226 = _rtmp3228.vtype; - _size224 = _rtmp3228.size; - for (var _i229 = 0; _i229 < _size224; ++_i229) - { - if (_i229 > 0 ) { - if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { - input.rstack.pop(); - } - } - var key230 = null; - var val231 = null; - key230 = input.readString().value; - var _size232 = 0; - var _rtmp3236; - val231 = []; - var _etype235 = 0; - _rtmp3236 = input.readListBegin(); - _etype235 = _rtmp3236.etype; - _size232 = _rtmp3236.size; - for (var _i237 = 0; _i237 < _size232; ++_i237) - { - var elem238 = null; - elem238 = input.readString().value; - val231.push(elem238); - } - input.readListEnd(); - this.success[key230] = val231; - } - input.readMapEnd(); + if (ftype == Thrift.Type.STRUCT) { + this.success = new Schema(); + this.success.read(input); } else { input.skip(ftype); } @@ -1897,30 +1998,11 @@ Blur_listSnapshots_result.prototype.read = function(input) { return; }; -Blur_listSnapshots_result.prototype.write = function(output) { - output.writeStructBegin('Blur_listSnapshots_result'); +Blur_schema_result.prototype.write = function(output) { + output.writeStructBegin('Blur_schema_result'); if (this.success !== null && this.success !== undefined) { - output.writeFieldBegin('success', Thrift.Type.MAP, 0); - output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.LIST, Thrift.objectLength(this.success)); - for (var kiter239 in this.success) - { - if (this.success.hasOwnProperty(kiter239)) - { - var viter240 = this.success[kiter239]; - output.writeString(kiter239); - output.writeListBegin(Thrift.Type.STRING, viter240.length); - for (var iter241 in viter240) - { - if (viter240.hasOwnProperty(iter241)) - { - iter241 = viter240[iter241]; - output.writeString(iter241); - } - } - output.writeListEnd(); - } - } - output.writeMapEnd(); + output.writeFieldBegin('success', Thrift.Type.STRUCT, 0); + this.success.write(output); output.writeFieldEnd(); } if (this.ex !== null && this.ex !== undefined) { @@ -1933,16 +2015,20 @@ Blur_listSnapshots_result.prototype.write = function(output) { return; }; -Blur_setUser_args = function(args) { - this.user = null; +Blur_parseQuery_args = function(args) { + this.table = null; + this.query = null; if (args) { - if (args.user !== undefined) { - this.user = args.user; + if (args.table !== undefined) { + this.table = args.table; + } + if (args.query !== undefined) { + this.query = args.query; } } }; -Blur_setUser_args.prototype = {}; -Blur_setUser_args.prototype.read = function(input) { +Blur_parseQuery_args.prototype = {}; +Blur_parseQuery_args.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -1956,16 +2042,20 @@ Blur_setUser_args.prototype.read = function(input) { switch (fid) { case 1: - if (ftype == Thrift.Type.STRUCT) { - this.user = new User(); - this.user.read(input); + if (ftype == Thrift.Type.STRING) { + this.table = input.readString().value; } else { input.skip(ftype); } break; - case 0: + case 2: + if (ftype == Thrift.Type.STRUCT) { + this.query = new Query(); + this.query.read(input); + } else { input.skip(ftype); - break; + } + break; default: input.skip(ftype); } @@ -1975,11 +2065,16 @@ Blur_setUser_args.prototype.read = function(input) { return; }; -Blur_setUser_args.prototype.write = function(output) { - output.writeStructBegin('Blur_setUser_args'); - if (this.user !== null && this.user !== undefined) { - output.writeFieldBegin('user', Thrift.Type.STRUCT, 1); - this.user.write(output); +Blur_parseQuery_args.prototype.write = function(output) { + output.writeStructBegin('Blur_parseQuery_args'); + if (this.table !== null && this.table !== undefined) { + output.writeFieldBegin('table', Thrift.Type.STRING, 1); + output.writeString(this.table); + output.writeFieldEnd(); + } + if (this.query !== null && this.query !== undefined) { + output.writeFieldBegin('query', Thrift.Type.STRUCT, 2); + this.query.write(output); output.writeFieldEnd(); } output.writeFieldStop(); @@ -1987,10 +2082,24 @@ Blur_setUser_args.prototype.write = function(output) { return; }; -Blur_setUser_result = function(args) { +Blur_parseQuery_result = function(args) { + this.success = null; + this.ex = null; + if (args instanceof BlurException) { + this.ex = args; + return; + } + if (args) { + if (args.success !== undefined) { + this.success = args.success; + } + if (args.ex !== undefined) { + this.ex = args.ex; + } + } }; -Blur_setUser_result.prototype = {}; -Blur_setUser_result.prototype.read = function(input) { +Blur_parseQuery_result.prototype = {}; +Blur_parseQuery_result.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -2001,34 +2110,59 @@ Blur_setUser_result.prototype.read = function(input) { if (ftype == Thrift.Type.STOP) { break; } - input.skip(ftype); - input.readFieldEnd(); - } - input.readStructEnd(); - return; -}; - -Blur_setUser_result.prototype.write = function(output) { - output.writeStructBegin('Blur_setUser_result'); - output.writeFieldStop(); - output.writeStructEnd(); - return; + switch (fid) + { + case 0: + if (ftype == Thrift.Type.STRING) { + this.success = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 1: + if (ftype == Thrift.Type.STRUCT) { + this.ex = new BlurException(); + this.ex.read(input); + } else { + input.skip(ftype); + } + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; }; -Blur_query_args = function(args) { +Blur_parseQuery_result.prototype.write = function(output) { + output.writeStructBegin('Blur_parseQuery_result'); + if (this.success !== null && this.success !== undefined) { + output.writeFieldBegin('success', Thrift.Type.STRING, 0); + output.writeString(this.success); + output.writeFieldEnd(); + } + 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_tableStats_args = function(args) { this.table = null; - this.blurQuery = null; if (args) { if (args.table !== undefined) { this.table = args.table; } - if (args.blurQuery !== undefined) { - this.blurQuery = args.blurQuery; - } } }; -Blur_query_args.prototype = {}; -Blur_query_args.prototype.read = function(input) { +Blur_tableStats_args.prototype = {}; +Blur_tableStats_args.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -2048,14 +2182,9 @@ Blur_query_args.prototype.read = function(input) { input.skip(ftype); } break; - case 2: - if (ftype == Thrift.Type.STRUCT) { - this.blurQuery = new BlurQuery(); - this.blurQuery.read(input); - } else { + case 0: input.skip(ftype); - } - break; + break; default: input.skip(ftype); } @@ -2065,24 +2194,19 @@ Blur_query_args.prototype.read = function(input) { return; }; -Blur_query_args.prototype.write = function(output) { - output.writeStructBegin('Blur_query_args'); +Blur_tableStats_args.prototype.write = function(output) { + output.writeStructBegin('Blur_tableStats_args'); if (this.table !== null && this.table !== undefined) { output.writeFieldBegin('table', Thrift.Type.STRING, 1); output.writeString(this.table); output.writeFieldEnd(); } - if (this.blurQuery !== null && this.blurQuery !== undefined) { - output.writeFieldBegin('blurQuery', Thrift.Type.STRUCT, 2); - this.blurQuery.write(output); - output.writeFieldEnd(); - } output.writeFieldStop(); output.writeStructEnd(); return; }; -Blur_query_result = function(args) { +Blur_tableStats_result = function(args) { this.success = null; this.ex = null; if (args instanceof BlurException) { @@ -2098,8 +2222,8 @@ Blur_query_result = function(args) { } } }; -Blur_query_result.prototype = {}; -Blur_query_result.prototype.read = function(input) { +Blur_tableStats_result.prototype = {}; +Blur_tableStats_result.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -2114,7 +2238,7 @@ Blur_query_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.STRUCT) { - this.success = new BlurResults(); + this.success = new TableStats(); this.success.read(input); } else { input.skip(ftype); @@ -2137,8 +2261,8 @@ Blur_query_result.prototype.read = function(input) { return; }; -Blur_query_result.prototype.write = function(output) { - output.writeStructBegin('Blur_query_result'); +Blur_tableStats_result.prototype.write = function(output) { + output.writeStructBegin('Blur_tableStats_result'); if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.STRUCT, 0); this.success.write(output); @@ -2154,20 +2278,20 @@ Blur_query_result.prototype.write = function(output) { return; }; -Blur_fetchRow_args = function(args) { +Blur_optimize_args = function(args) { this.table = null; - this.selector = null; + this.numberOfSegmentsPerShard = null; if (args) { if (args.table !== undefined) { this.table = args.table; } - if (args.selector !== undefined) { - this.selector = args.selector; + if (args.numberOfSegmentsPerShard !== undefined) { + this.numberOfSegmentsPerShard = args.numberOfSegmentsPerShard; } } }; -Blur_fetchRow_args.prototype = {}; -Blur_fetchRow_args.prototype.read = function(input) { +Blur_optimize_args.prototype = {}; +Blur_optimize_args.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -2188,9 +2312,8 @@ Blur_fetchRow_args.prototype.read = function(input) { } break; case 2: - if (ftype == Thrift.Type.STRUCT) { - this.selector = new Selector(); - this.selector.read(input); + if (ftype == Thrift.Type.I32) { + this.numberOfSegmentsPerShard = input.readI32().value; } else { input.skip(ftype); } @@ -2204,16 +2327,16 @@ Blur_fetchRow_args.prototype.read = function(input) { return; }; -Blur_fetchRow_args.prototype.write = function(output) { - output.writeStructBegin('Blur_fetchRow_args'); +Blur_optimize_args.prototype.write = function(output) { + output.writeStructBegin('Blur_optimize_args'); if (this.table !== null && this.table !== undefined) { output.writeFieldBegin('table', Thrift.Type.STRING, 1); output.writeString(this.table); output.writeFieldEnd(); } - if (this.selector !== null && this.selector !== undefined) { - output.writeFieldBegin('selector', Thrift.Type.STRUCT, 2); - this.selector.write(output); + if (this.numberOfSegmentsPerShard !== null && this.numberOfSegmentsPerShard !== undefined) { + output.writeFieldBegin('numberOfSegmentsPerShard', Thrift.Type.I32, 2); + output.writeI32(this.numberOfSegmentsPerShard); output.writeFieldEnd(); } output.writeFieldStop(); @@ -2221,24 +2344,20 @@ Blur_fetchRow_args.prototype.write = function(output) { return; }; -Blur_fetchRow_result = function(args) { - this.success = null; +Blur_optimize_result = function(args) { this.ex = null; if (args instanceof BlurException) { this.ex = args; return; } if (args) { - if (args.success !== undefined) { - this.success = args.success; - } if (args.ex !== undefined) { this.ex = args.ex; } } }; -Blur_fetchRow_result.prototype = {}; -Blur_fetchRow_result.prototype.read = function(input) { +Blur_optimize_result.prototype = {}; +Blur_optimize_result.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -2251,14 +2370,6 @@ Blur_fetchRow_result.prototype.read = function(input) { } switch (fid) { - case 0: - if (ftype == Thrift.Type.STRUCT) { - this.success = new FetchResult(); - this.success.read(input); - } else { - input.skip(ftype); - } - break; case 1: if (ftype == Thrift.Type.STRUCT) { this.ex = new BlurException(); @@ -2267,6 +2378,9 @@ Blur_fetchRow_result.prototype.read = function(input) { input.skip(ftype); } break; + case 0: + input.skip(ftype); + break; default: input.skip(ftype); } @@ -2276,13 +2390,8 @@ Blur_fetchRow_result.prototype.read = function(input) { return; }; -Blur_fetchRow_result.prototype.write = function(output) { - output.writeStructBegin('Blur_fetchRow_result'); - if (this.success !== null && this.success !== undefined) { - output.writeFieldBegin('success', Thrift.Type.STRUCT, 0); - this.success.write(output); - output.writeFieldEnd(); - } +Blur_optimize_result.prototype.write = function(output) { + output.writeStructBegin('Blur_optimize_result'); if (this.ex !== null && this.ex !== undefined) { output.writeFieldBegin('ex', Thrift.Type.STRUCT, 1); this.ex.write(output); @@ -2293,20 +2402,20 @@ Blur_fetchRow_result.prototype.write = function(output) { return; }; -Blur_fetchRowBatch_args = function(args) { +Blur_createSnapshot_args = function(args) { this.table = null; - this.selectors = null; + this.name = null; if (args) { if (args.table !== undefined) { this.table = args.table; } - if (args.selectors !== undefined) { - this.selectors = args.selectors; + if (args.name !== undefined) { + this.name = args.name; } } }; -Blur_fetchRowBatch_args.prototype = {}; -Blur_fetchRowBatch_args.prototype.read = function(input) { +Blur_createSnapshot_args.prototype = {}; +Blur_createSnapshot_args.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -2327,22 +2436,8 @@ Blur_fetchRowBatch_args.prototype.read = function(input) { } break; case 2: - if (ftype == Thrift.Type.LIST) { - var _size242 = 0; - var _rtmp3246; - this.selectors = []; - var _etype245 = 0; - _rtmp3246 = input.readListBegin(); - _etype245 = _rtmp3246.etype; - _size242 = _rtmp3246.size; - for (var _i247 = 0; _i247 < _size242; ++_i247) - { - var elem248 = null; - elem248 = new Selector(); - elem248.read(input); - this.selectors.push(elem248); - } - input.readListEnd(); + if (ftype == Thrift.Type.STRING) { + this.name = input.readString().value; } else { input.skip(ftype); } @@ -2356,25 +2451,16 @@ Blur_fetchRowBatch_args.prototype.read = function(input) { return; }; -Blur_fetchRowBatch_args.prototype.write = function(output) { - output.writeStructBegin('Blur_fetchRowBatch_args'); +Blur_createSnapshot_args.prototype.write = function(output) { + output.writeStructBegin('Blur_createSnapshot_args'); if (this.table !== null && this.table !== undefined) { output.writeFieldBegin('table', Thrift.Type.STRING, 1); output.writeString(this.table); output.writeFieldEnd(); } - if (this.selectors !== null && this.selectors !== undefined) { - output.writeFieldBegin('selectors', Thrift.Type.LIST, 2); - output.writeListBegin(Thrift.Type.STRUCT, this.selectors.length); - for (var iter249 in this.selectors) - { - if (this.selectors.hasOwnProperty(iter249)) - { - iter249 = this.selectors[iter249]; - iter249.write(output); - } - } - output.writeListEnd(); + if (this.name !== null && this.name !== undefined) { + output.writeFieldBegin('name', Thrift.Type.STRING, 2); + output.writeString(this.name); output.writeFieldEnd(); } output.writeFieldStop(); @@ -2382,24 +2468,20 @@ Blur_fetchRowBatch_args.prototype.write = function(output) { return; }; -Blur_fetchRowBatch_result = function(args) { - this.success = null; +Blur_createSnapshot_result = function(args) { this.ex = null; if (args instanceof BlurException) { this.ex = args; return; } if (args) { - if (args.success !== undefined) { - this.success = args.success; - } if (args.ex !== undefined) { this.ex = args.ex; } } }; -Blur_fetchRowBatch_result.prototype = {}; -Blur_fetchRowBatch_result.prototype.read = function(input) { +Blur_createSnapshot_result.prototype = {}; +Blur_createSnapshot_result.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -2412,27 +2494,6 @@ Blur_fetchRowBatch_result.prototype.read = function(input) { } switch (fid) { - case 0: - if (ftype == Thrift.Type.LIST) { - var _size250 = 0; - var _rtmp3254; - this.success = []; - var _etype253 = 0; - _rtmp3254 = input.readListBegin(); - _etype253 = _rtmp3254.etype; - _size250 = _rtmp3254.size; - for (var _i255 = 0; _i255 < _size250; ++_i255) - { - var elem256 = null; - elem256 = new FetchResult(); - elem256.read(input); - this.success.push(elem256); - } - input.readListEnd(); - } else { - input.skip(ftype); - } - break; case 1: if (ftype == Thrift.Type.STRUCT) { this.ex = new BlurException(); @@ -2441,6 +2502,9 @@ Blur_fetchRowBatch_result.prototype.read = function(input) { input.skip(ftype); } break; + case 0: + input.skip(ftype); + break; default: input.skip(ftype); } @@ -2450,22 +2514,8 @@ Blur_fetchRowBatch_result.prototype.read = function(input) { return; }; -Blur_fetchRowBatch_result.prototype.write = function(output) { - output.writeStructBegin('Blur_fetchRowBatch_result'); - if (this.success !== null && this.success !== undefined) { - output.writeFieldBegin('success', Thrift.Type.LIST, 0); - output.writeListBegin(Thrift.Type.STRUCT, this.success.length); - for (var iter257 in this.success) - { - if (this.success.hasOwnProperty(iter257)) - { - iter257 = this.success[iter257]; - iter257.write(output); - } - } - output.writeListEnd(); - output.writeFieldEnd(); - } +Blur_createSnapshot_result.prototype.write = function(output) { + output.writeStructBegin('Blur_createSnapshot_result'); if (this.ex !== null && this.ex !== undefined) { output.writeFieldBegin('ex', Thrift.Type.STRUCT, 1); this.ex.write(output); @@ -2476,16 +2526,20 @@ Blur_fetchRowBatch_result.prototype.write = function(output) { return; }; -Blur_mutate_args = function(args) { - this.mutation = null; +Blur_removeSnapshot_args = function(args) { + this.table = null; + this.name = null; if (args) { - if (args.mutation !== undefined) { - this.mutation = args.mutation; + if (args.table !== undefined) { + this.table = args.table; + } + if (args.name !== undefined) { + this.name = args.name; } } }; -Blur_mutate_args.prototype = {}; -Blur_mutate_args.prototype.read = function(input) { +Blur_removeSnapshot_args.prototype = {}; +Blur_removeSnapshot_args.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -2499,16 +2553,19 @@ Blur_mutate_args.prototype.read = function(input) { switch (fid) { case 1: - if (ftype == Thrift.Type.STRUCT) { - this.mutation = new RowMutation(); - this.mutation.read(input); + if (ftype == Thrift.Type.STRING) { + this.table = input.readString().value; } else { input.skip(ftype); } break; - case 0: + case 2: + if (ftype == Thrift.Type.STRING) { + this.name = input.readString().value; + } else { input.skip(ftype); - break; + } + break; default: input.skip(ftype); } @@ -2518,11 +2575,16 @@ Blur_mutate_args.prototype.read = function(input) { return; }; -Blur_mutate_args.prototype.write = function(output) { - output.writeStructBegin('Blur_mutate_args'); - if (this.mutation !== null && this.mutation !== undefined) { - output.writeFieldBegin('mutation', Thrift.Type.STRUCT, 1); - this.mutation.write(output); +Blur_removeSnapshot_args.prototype.write = function(output) { + output.writeStructBegin('Blur_removeSnapshot_args'); + if (this.table !== null && this.table !== undefined) { + output.writeFieldBegin('table', Thrift.Type.STRING, 1); + output.writeString(this.table); + output.writeFieldEnd(); + } + if (this.name !== null && this.name !== undefined) { + output.writeFieldBegin('name', Thrift.Type.STRING, 2); + output.writeString(this.name); output.writeFieldEnd(); } output.writeFieldStop(); @@ -2530,7 +2592,7 @@ Blur_mutate_args.prototype.write = function(output) { return; }; -Blur_mutate_result = function(args) { +Blur_removeSnapshot_result = function(args) { this.ex = null; if (args instanceof BlurException) { this.ex = args; @@ -2542,8 +2604,8 @@ Blur_mutate_result = function(args) { } } }; -Blur_mutate_result.prototype = {}; -Blur_mutate_result.prototype.read = function(input) { +Blur_removeSnapshot_result.prototype = {}; +Blur_removeSnapshot_result.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -2576,8 +2638,8 @@ Blur_mutate_result.prototype.read = function(input) { return; }; -Blur_mutate_result.prototype.write = function(output) { - output.writeStructBegin('Blur_mutate_result'); +Blur_removeSnapshot_result.prototype.write = function(output) { + output.writeStructBegin('Blur_removeSnapshot_result'); if (this.ex !== null && this.ex !== undefined) { output.writeFieldBegin('ex', Thrift.Type.STRUCT, 1); this.ex.write(output); @@ -2588,16 +2650,16 @@ Blur_mutate_result.prototype.write = function(output) { return; }; -Blur_mutateBatch_args = function(args) { - this.mutations = null; +Blur_listSnapshots_args = function(args) { + this.table = null; if (args) { - if (args.mutations !== undefined) { - this.mutations = args.mutations; + if (args.table !== undefined) { + this.table = args.table; } } }; -Blur_mutateBatch_args.prototype = {}; -Blur_mutateBatch_args.prototype.read = function(input) { +Blur_listSnapshots_args.prototype = {}; +Blur_listSnapshots_args.prototype.read = function(input) { input.readStructBegin(); while (true) { @@ -2611,22 +2673,8 @@ Blur_mutateBatch_args.prototype.read = function(input) { switch (fid) { case 1: - if (ftype == Thrift.Type.LIST) { - var _size258 = 0; - var _rtmp3262; - this.mutations = []; - var _etype261 = 0; - _rtmp3262 = input.readListBegin(); - _etype261 = _rtmp3262.etype; - _size258 = _rtmp3262.size; - for (var _i263 = 0; _i263 < _size258; ++_i263) - { - var elem264 = null; - elem264 = new RowMutation(); - elem264.read(input); - this.mutations.push(elem264); - } - input.readListEnd(); + if (ftype == Thrift.Type.STRING) { + this.table = input.readString().value; } else { input.skip(ftype); } @@ -2643,20 +2691,11 @@ Blur_mutateBatch_args.prototype.read = function(input) { return; }; -Blur_mutateBatch_args.prototype.write = function(output) { - output.writeStructBegin('Blur_mutateBatch_args'); - if (this.mutations !== null && this.mutations !== undefined) { - output.writeFieldBegin('mutations', Thrift.Type.LIST, 1); - output.writeListBegin(Thrift.Type.STRUCT, this.mutations.length); - for (var iter265 in this.mutations) - { - if (this.mutations.hasOwnProperty(iter265)) - { - iter265 = this.mutations[iter265]; - iter265.write(output); - } - } - output.writeListEnd(); +Blur_listSnapshots_args.prototype.write = function(output) { + output.writeStructBegin('Blur_listSnapshots_args'); + if (this.table !== null && this.table !== undefined) { + output.writeFieldBegin('table', Thrift.Type.STRING, 1); + output.writeString(this.table); output.writeFieldEnd(); } output.writeFieldStop(); @@ -2664,20 +2703,24 @@ Blur_mutateBatch_args.prototype.write = function(output) { return; }; -Blur_mutateBatch_result = function(args) { +Blur_listSnapshots_result = function(args) { + this.success =
<TRUNCATED>
