http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/dcd1bc0e/blur-status/src/main/resources/webapp/js/Blur_types.js ---------------------------------------------------------------------- diff --git a/blur-status/src/main/resources/webapp/js/Blur_types.js b/blur-status/src/main/resources/webapp/js/Blur_types.js new file mode 100644 index 0000000..4046d88 --- /dev/null +++ b/blur-status/src/main/resources/webapp/js/Blur_types.js @@ -0,0 +1,3258 @@ +// +// Autogenerated by Thrift Compiler (0.9.0) +// +// DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING +// + +ErrorType = { +'UNKNOWN' : 0, +'QUERY_CANCEL' : 1, +'QUERY_TIMEOUT' : 2, +'BACK_PRESSURE' : 3, +'REQUEST_TIMEOUT' : 4 +}; +ScoreType = { +'SUPER' : 0, +'AGGREGATE' : 1, +'BEST' : 2, +'CONSTANT' : 3 +}; +QueryState = { +'RUNNING' : 0, +'INTERRUPTED' : 1, +'COMPLETE' : 2, +'BACK_PRESSURE_INTERRUPTED' : 3 +}; +Status = { +'NOT_FOUND' : 0, +'FOUND' : 1 +}; +RowMutationType = { +'DELETE_ROW' : 0, +'REPLACE_ROW' : 1, +'UPDATE_ROW' : 2 +}; +RecordMutationType = { +'DELETE_ENTIRE_RECORD' : 0, +'REPLACE_ENTIRE_RECORD' : 1, +'REPLACE_COLUMNS' : 2, +'APPEND_COLUMN_VALUES' : 3 +}; +ShardState = { +'OPENING' : 0, +'OPEN' : 1, +'OPENING_ERROR' : 2, +'CLOSING' : 3, +'CLOSED' : 4, +'CLOSING_ERROR' : 5 +}; +BlurException = function(args) { + this.message = null; + this.stackTraceStr = null; + this.errorType = null; + if (args) { + if (args.message !== undefined) { + this.message = args.message; + } + if (args.stackTraceStr !== undefined) { + this.stackTraceStr = args.stackTraceStr; + } + if (args.errorType !== undefined) { + this.errorType = args.errorType; + } + } +}; +Thrift.inherits(BlurException, Thrift.TException); +BlurException.prototype.name = 'BlurException'; +BlurException.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.STRING) { + this.message = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 2: + if (ftype == Thrift.Type.STRING) { + this.stackTraceStr = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 3: + if (ftype == Thrift.Type.I32) { + this.errorType = input.readI32().value; + } else { + input.skip(ftype); + } + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +BlurException.prototype.write = function(output) { + output.writeStructBegin('BlurException'); + if (this.message !== null && this.message !== undefined) { + output.writeFieldBegin('message', Thrift.Type.STRING, 1); + output.writeString(this.message); + output.writeFieldEnd(); + } + if (this.stackTraceStr !== null && this.stackTraceStr !== undefined) { + output.writeFieldBegin('stackTraceStr', Thrift.Type.STRING, 2); + output.writeString(this.stackTraceStr); + output.writeFieldEnd(); + } + if (this.errorType !== null && this.errorType !== undefined) { + output.writeFieldBegin('errorType', Thrift.Type.I32, 3); + output.writeI32(this.errorType); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +Column = function(args) { + this.name = null; + this.value = null; + if (args) { + if (args.name !== undefined) { + this.name = args.name; + } + if (args.value !== undefined) { + this.value = args.value; + } + } +}; +Column.prototype = {}; +Column.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.STRING) { + this.name = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 2: + if (ftype == Thrift.Type.STRING) { + this.value = input.readString().value; + } else { + input.skip(ftype); + } + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +Column.prototype.write = function(output) { + output.writeStructBegin('Column'); + if (this.name !== null && this.name !== undefined) { + output.writeFieldBegin('name', Thrift.Type.STRING, 1); + output.writeString(this.name); + output.writeFieldEnd(); + } + if (this.value !== null && this.value !== undefined) { + output.writeFieldBegin('value', Thrift.Type.STRING, 2); + output.writeString(this.value); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +Record = function(args) { + this.recordId = null; + this.family = null; + this.columns = null; + if (args) { + if (args.recordId !== undefined) { + this.recordId = args.recordId; + } + if (args.family !== undefined) { + this.family = args.family; + } + if (args.columns !== undefined) { + this.columns = args.columns; + } + } +}; +Record.prototype = {}; +Record.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.STRING) { + this.recordId = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 2: + if (ftype == Thrift.Type.STRING) { + this.family = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 3: + if (ftype == Thrift.Type.LIST) { + var _size0 = 0; + var _rtmp34; + this.columns = []; + var _etype3 = 0; + _rtmp34 = input.readListBegin(); + _etype3 = _rtmp34.etype; + _size0 = _rtmp34.size; + for (var _i5 = 0; _i5 < _size0; ++_i5) + { + var elem6 = null; + elem6 = new Column(); + elem6.read(input); + this.columns.push(elem6); + } + input.readListEnd(); + } else { + input.skip(ftype); + } + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +Record.prototype.write = function(output) { + output.writeStructBegin('Record'); + if (this.recordId !== null && this.recordId !== undefined) { + output.writeFieldBegin('recordId', Thrift.Type.STRING, 1); + output.writeString(this.recordId); + output.writeFieldEnd(); + } + if (this.family !== null && this.family !== undefined) { + output.writeFieldBegin('family', Thrift.Type.STRING, 2); + output.writeString(this.family); + output.writeFieldEnd(); + } + if (this.columns !== null && this.columns !== undefined) { + output.writeFieldBegin('columns', Thrift.Type.LIST, 3); + output.writeListBegin(Thrift.Type.STRUCT, this.columns.length); + for (var iter7 in this.columns) + { + if (this.columns.hasOwnProperty(iter7)) + { + iter7 = this.columns[iter7]; + iter7.write(output); + } + } + output.writeListEnd(); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +Row = function(args) { + this.id = null; + this.records = null; + this.recordCount = null; + if (args) { + if (args.id !== undefined) { + this.id = args.id; + } + if (args.records !== undefined) { + this.records = args.records; + } + if (args.recordCount !== undefined) { + this.recordCount = args.recordCount; + } + } +}; +Row.prototype = {}; +Row.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.STRING) { + this.id = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 2: + if (ftype == Thrift.Type.LIST) { + var _size8 = 0; + var _rtmp312; + this.records = []; + var _etype11 = 0; + _rtmp312 = input.readListBegin(); + _etype11 = _rtmp312.etype; + _size8 = _rtmp312.size; + for (var _i13 = 0; _i13 < _size8; ++_i13) + { + var elem14 = null; + elem14 = new Record(); + elem14.read(input); + this.records.push(elem14); + } + input.readListEnd(); + } else { + input.skip(ftype); + } + break; + case 3: + if (ftype == Thrift.Type.I32) { + this.recordCount = input.readI32().value; + } else { + input.skip(ftype); + } + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +Row.prototype.write = function(output) { + output.writeStructBegin('Row'); + if (this.id !== null && this.id !== undefined) { + output.writeFieldBegin('id', Thrift.Type.STRING, 1); + output.writeString(this.id); + output.writeFieldEnd(); + } + if (this.records !== null && this.records !== undefined) { + output.writeFieldBegin('records', Thrift.Type.LIST, 2); + output.writeListBegin(Thrift.Type.STRUCT, this.records.length); + for (var iter15 in this.records) + { + if (this.records.hasOwnProperty(iter15)) + { + iter15 = this.records[iter15]; + iter15.write(output); + } + } + output.writeListEnd(); + output.writeFieldEnd(); + } + if (this.recordCount !== null && this.recordCount !== undefined) { + output.writeFieldBegin('recordCount', Thrift.Type.I32, 3); + output.writeI32(this.recordCount); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +Query = function(args) { + this.query = null; + this.rowQuery = true; + this.scoreType = 0; + this.rowFilter = null; + this.recordFilter = null; + if (args) { + if (args.query !== undefined) { + this.query = args.query; + } + if (args.rowQuery !== undefined) { + this.rowQuery = args.rowQuery; + } + if (args.scoreType !== undefined) { + this.scoreType = args.scoreType; + } + if (args.rowFilter !== undefined) { + this.rowFilter = args.rowFilter; + } + if (args.recordFilter !== undefined) { + this.recordFilter = args.recordFilter; + } + } +}; +Query.prototype = {}; +Query.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.STRING) { + this.query = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 2: + if (ftype == Thrift.Type.BOOL) { + this.rowQuery = input.readBool().value; + } else { + input.skip(ftype); + } + break; + case 3: + if (ftype == Thrift.Type.I32) { + this.scoreType = input.readI32().value; + } else { + input.skip(ftype); + } + break; + case 4: + if (ftype == Thrift.Type.STRING) { + this.rowFilter = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 5: + if (ftype == Thrift.Type.STRING) { + this.recordFilter = input.readString().value; + } else { + input.skip(ftype); + } + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +Query.prototype.write = function(output) { + output.writeStructBegin('Query'); + if (this.query !== null && this.query !== undefined) { + output.writeFieldBegin('query', Thrift.Type.STRING, 1); + output.writeString(this.query); + output.writeFieldEnd(); + } + if (this.rowQuery !== null && this.rowQuery !== undefined) { + output.writeFieldBegin('rowQuery', Thrift.Type.BOOL, 2); + output.writeBool(this.rowQuery); + output.writeFieldEnd(); + } + if (this.scoreType !== null && this.scoreType !== undefined) { + output.writeFieldBegin('scoreType', Thrift.Type.I32, 3); + output.writeI32(this.scoreType); + output.writeFieldEnd(); + } + if (this.rowFilter !== null && this.rowFilter !== undefined) { + output.writeFieldBegin('rowFilter', Thrift.Type.STRING, 4); + output.writeString(this.rowFilter); + output.writeFieldEnd(); + } + if (this.recordFilter !== null && this.recordFilter !== undefined) { + output.writeFieldBegin('recordFilter', Thrift.Type.STRING, 5); + output.writeString(this.recordFilter); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +HighlightOptions = function(args) { + this.query = null; + this.preTag = '<<<'; + this.postTag = '>>>'; + if (args) { + if (args.query !== undefined) { + this.query = args.query; + } + if (args.preTag !== undefined) { + this.preTag = args.preTag; + } + if (args.postTag !== undefined) { + this.postTag = args.postTag; + } + } +}; +HighlightOptions.prototype = {}; +HighlightOptions.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.STRUCT) { + this.query = new Query(); + this.query.read(input); + } else { + input.skip(ftype); + } + break; + case 2: + if (ftype == Thrift.Type.STRING) { + this.preTag = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 3: + if (ftype == Thrift.Type.STRING) { + this.postTag = input.readString().value; + } else { + input.skip(ftype); + } + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +HighlightOptions.prototype.write = function(output) { + output.writeStructBegin('HighlightOptions'); + if (this.query !== null && this.query !== undefined) { + output.writeFieldBegin('query', Thrift.Type.STRUCT, 1); + this.query.write(output); + output.writeFieldEnd(); + } + if (this.preTag !== null && this.preTag !== undefined) { + output.writeFieldBegin('preTag', Thrift.Type.STRING, 2); + output.writeString(this.preTag); + output.writeFieldEnd(); + } + if (this.postTag !== null && this.postTag !== undefined) { + output.writeFieldBegin('postTag', Thrift.Type.STRING, 3); + output.writeString(this.postTag); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +Selector = function(args) { + this.recordOnly = null; + this.locationId = null; + this.rowId = null; + this.recordId = null; + this.columnFamiliesToFetch = null; + this.columnsToFetch = null; + this.startRecord = 0; + this.maxRecordsToFetch = 1000; + this.highlightOptions = null; + if (args) { + if (args.recordOnly !== undefined) { + this.recordOnly = args.recordOnly; + } + if (args.locationId !== undefined) { + this.locationId = args.locationId; + } + if (args.rowId !== undefined) { + this.rowId = args.rowId; + } + if (args.recordId !== undefined) { + this.recordId = args.recordId; + } + if (args.columnFamiliesToFetch !== undefined) { + this.columnFamiliesToFetch = args.columnFamiliesToFetch; + } + if (args.columnsToFetch !== undefined) { + this.columnsToFetch = args.columnsToFetch; + } + if (args.startRecord !== undefined) { + this.startRecord = args.startRecord; + } + if (args.maxRecordsToFetch !== undefined) { + this.maxRecordsToFetch = args.maxRecordsToFetch; + } + if (args.highlightOptions !== undefined) { + this.highlightOptions = args.highlightOptions; + } + } +}; +Selector.prototype = {}; +Selector.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.BOOL) { + this.recordOnly = input.readBool().value; + } else { + input.skip(ftype); + } + break; + case 2: + if (ftype == Thrift.Type.STRING) { + this.locationId = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 3: + if (ftype == Thrift.Type.STRING) { + this.rowId = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 4: + if (ftype == Thrift.Type.STRING) { + this.recordId = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 5: + if (ftype == Thrift.Type.LIST) { + var _size16 = 0; + var _rtmp320; + this.columnFamiliesToFetch = []; + var _etype19 = 0; + _rtmp320 = input.readListBegin(); + _etype19 = _rtmp320.etype; + _size16 = _rtmp320.size; + for (var _i21 = 0; _i21 < _size16; ++_i21) + { + var elem22 = null; + elem22 = input.readString().value; + this.columnFamiliesToFetch.push(elem22); + } + input.readListEnd(); + } else { + input.skip(ftype); + } + break; + case 6: + if (ftype == Thrift.Type.MAP) { + var _size23 = 0; + var _rtmp327; + this.columnsToFetch = {}; + var _ktype24 = 0; + var _vtype25 = 0; + _rtmp327 = input.readMapBegin(); + _ktype24 = _rtmp327.ktype; + _vtype25 = _rtmp327.vtype; + _size23 = _rtmp327.size; + for (var _i28 = 0; _i28 < _size23; ++_i28) + { + if (_i28 > 0 ) { + if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { + input.rstack.pop(); + } + } + var key29 = null; + var val30 = null; + key29 = input.readString().value; + var _size31 = 0; + var _rtmp335; + val30 = []; + var _etype34 = 0; + _rtmp335 = input.readSetBegin(); + _etype34 = _rtmp335.etype; + _size31 = _rtmp335.size; + for (var _i36 = 0; _i36 < _size31; ++_i36) + { + var elem37 = null; + elem37 = input.readString().value; + val30.push(elem37); + } + input.readSetEnd(); + this.columnsToFetch[key29] = val30; + } + input.readMapEnd(); + } else { + input.skip(ftype); + } + break; + case 8: + if (ftype == Thrift.Type.I32) { + this.startRecord = input.readI32().value; + } else { + input.skip(ftype); + } + break; + case 9: + if (ftype == Thrift.Type.I32) { + this.maxRecordsToFetch = input.readI32().value; + } else { + input.skip(ftype); + } + break; + case 10: + if (ftype == Thrift.Type.STRUCT) { + this.highlightOptions = new HighlightOptions(); + this.highlightOptions.read(input); + } else { + input.skip(ftype); + } + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +Selector.prototype.write = function(output) { + output.writeStructBegin('Selector'); + if (this.recordOnly !== null && this.recordOnly !== undefined) { + output.writeFieldBegin('recordOnly', Thrift.Type.BOOL, 1); + output.writeBool(this.recordOnly); + output.writeFieldEnd(); + } + if (this.locationId !== null && this.locationId !== undefined) { + output.writeFieldBegin('locationId', Thrift.Type.STRING, 2); + output.writeString(this.locationId); + output.writeFieldEnd(); + } + if (this.rowId !== null && this.rowId !== undefined) { + output.writeFieldBegin('rowId', Thrift.Type.STRING, 3); + output.writeString(this.rowId); + output.writeFieldEnd(); + } + if (this.recordId !== null && this.recordId !== undefined) { + output.writeFieldBegin('recordId', Thrift.Type.STRING, 4); + output.writeString(this.recordId); + output.writeFieldEnd(); + } + if (this.columnFamiliesToFetch !== null && this.columnFamiliesToFetch !== undefined) { + output.writeFieldBegin('columnFamiliesToFetch', Thrift.Type.LIST, 5); + output.writeListBegin(Thrift.Type.STRING, this.columnFamiliesToFetch.length); + for (var iter38 in this.columnFamiliesToFetch) + { + if (this.columnFamiliesToFetch.hasOwnProperty(iter38)) + { + iter38 = this.columnFamiliesToFetch[iter38]; + output.writeString(iter38); + } + } + output.writeListEnd(); + output.writeFieldEnd(); + } + if (this.columnsToFetch !== null && this.columnsToFetch !== undefined) { + output.writeFieldBegin('columnsToFetch', Thrift.Type.MAP, 6); + output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.SET, Thrift.objectLength(this.columnsToFetch)); + for (var kiter39 in this.columnsToFetch) + { + if (this.columnsToFetch.hasOwnProperty(kiter39)) + { + var viter40 = this.columnsToFetch[kiter39]; + output.writeString(kiter39); + output.writeSetBegin(Thrift.Type.STRING, viter40.length); + for (var iter41 in viter40) + { + if (viter40.hasOwnProperty(iter41)) + { + iter41 = viter40[iter41]; + output.writeString(iter41); + } + } + output.writeSetEnd(); + } + } + output.writeMapEnd(); + output.writeFieldEnd(); + } + if (this.startRecord !== null && this.startRecord !== undefined) { + output.writeFieldBegin('startRecord', Thrift.Type.I32, 8); + output.writeI32(this.startRecord); + output.writeFieldEnd(); + } + if (this.maxRecordsToFetch !== null && this.maxRecordsToFetch !== undefined) { + output.writeFieldBegin('maxRecordsToFetch', Thrift.Type.I32, 9); + output.writeI32(this.maxRecordsToFetch); + output.writeFieldEnd(); + } + if (this.highlightOptions !== null && this.highlightOptions !== undefined) { + output.writeFieldBegin('highlightOptions', Thrift.Type.STRUCT, 10); + this.highlightOptions.write(output); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +FetchRowResult = function(args) { + this.row = null; + if (args) { + if (args.row !== undefined) { + this.row = args.row; + } + } +}; +FetchRowResult.prototype = {}; +FetchRowResult.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.STRUCT) { + this.row = new Row(); + this.row.read(input); + } else { + input.skip(ftype); + } + break; + case 0: + input.skip(ftype); + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +FetchRowResult.prototype.write = function(output) { + output.writeStructBegin('FetchRowResult'); + if (this.row !== null && this.row !== undefined) { + output.writeFieldBegin('row', Thrift.Type.STRUCT, 1); + this.row.write(output); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +FetchRecordResult = function(args) { + this.rowid = null; + this.record = null; + if (args) { + if (args.rowid !== undefined) { + this.rowid = args.rowid; + } + if (args.record !== undefined) { + this.record = args.record; + } + } +}; +FetchRecordResult.prototype = {}; +FetchRecordResult.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.STRING) { + this.rowid = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 2: + if (ftype == Thrift.Type.STRUCT) { + this.record = new Record(); + this.record.read(input); + } else { + input.skip(ftype); + } + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +FetchRecordResult.prototype.write = function(output) { + output.writeStructBegin('FetchRecordResult'); + if (this.rowid !== null && this.rowid !== undefined) { + output.writeFieldBegin('rowid', Thrift.Type.STRING, 1); + output.writeString(this.rowid); + output.writeFieldEnd(); + } + if (this.record !== null && this.record !== undefined) { + output.writeFieldBegin('record', Thrift.Type.STRUCT, 2); + this.record.write(output); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +FetchResult = function(args) { + this.exists = null; + this.deleted = null; + this.table = null; + this.rowResult = null; + this.recordResult = null; + if (args) { + if (args.exists !== undefined) { + this.exists = args.exists; + } + if (args.deleted !== undefined) { + this.deleted = args.deleted; + } + if (args.table !== undefined) { + this.table = args.table; + } + if (args.rowResult !== undefined) { + this.rowResult = args.rowResult; + } + if (args.recordResult !== undefined) { + this.recordResult = args.recordResult; + } + } +}; +FetchResult.prototype = {}; +FetchResult.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.BOOL) { + this.exists = input.readBool().value; + } else { + input.skip(ftype); + } + break; + case 2: + if (ftype == Thrift.Type.BOOL) { + this.deleted = input.readBool().value; + } else { + input.skip(ftype); + } + break; + case 3: + if (ftype == Thrift.Type.STRING) { + this.table = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 4: + if (ftype == Thrift.Type.STRUCT) { + this.rowResult = new FetchRowResult(); + this.rowResult.read(input); + } else { + input.skip(ftype); + } + break; + case 5: + if (ftype == Thrift.Type.STRUCT) { + this.recordResult = new FetchRecordResult(); + this.recordResult.read(input); + } else { + input.skip(ftype); + } + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +FetchResult.prototype.write = function(output) { + output.writeStructBegin('FetchResult'); + if (this.exists !== null && this.exists !== undefined) { + output.writeFieldBegin('exists', Thrift.Type.BOOL, 1); + output.writeBool(this.exists); + output.writeFieldEnd(); + } + if (this.deleted !== null && this.deleted !== undefined) { + output.writeFieldBegin('deleted', Thrift.Type.BOOL, 2); + output.writeBool(this.deleted); + output.writeFieldEnd(); + } + if (this.table !== null && this.table !== undefined) { + output.writeFieldBegin('table', Thrift.Type.STRING, 3); + output.writeString(this.table); + output.writeFieldEnd(); + } + if (this.rowResult !== null && this.rowResult !== undefined) { + output.writeFieldBegin('rowResult', Thrift.Type.STRUCT, 4); + this.rowResult.write(output); + output.writeFieldEnd(); + } + if (this.recordResult !== null && this.recordResult !== undefined) { + output.writeFieldBegin('recordResult', Thrift.Type.STRUCT, 5); + this.recordResult.write(output); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +Facet = function(args) { + this.queryStr = null; + this.minimumNumberOfBlurResults = 9223372036854775807; + if (args) { + if (args.queryStr !== undefined) { + this.queryStr = args.queryStr; + } + if (args.minimumNumberOfBlurResults !== undefined) { + this.minimumNumberOfBlurResults = args.minimumNumberOfBlurResults; + } + } +}; +Facet.prototype = {}; +Facet.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.STRING) { + this.queryStr = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 2: + if (ftype == Thrift.Type.I64) { + this.minimumNumberOfBlurResults = input.readI64().value; + } else { + input.skip(ftype); + } + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +Facet.prototype.write = function(output) { + output.writeStructBegin('Facet'); + if (this.queryStr !== null && this.queryStr !== undefined) { + output.writeFieldBegin('queryStr', Thrift.Type.STRING, 1); + output.writeString(this.queryStr); + output.writeFieldEnd(); + } + if (this.minimumNumberOfBlurResults !== null && this.minimumNumberOfBlurResults !== undefined) { + output.writeFieldBegin('minimumNumberOfBlurResults', Thrift.Type.I64, 2); + output.writeI64(this.minimumNumberOfBlurResults); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +BlurQuery = function(args) { + this.query = null; + this.facets = null; + this.selector = null; + this.useCacheIfPresent = true; + this.start = 0; + this.fetch = 10; + this.minimumNumberOfResults = 9223372036854775807; + this.maxQueryTime = 9223372036854775807; + this.uuid = null; + this.userContext = null; + this.cacheResult = true; + this.startTime = 0; + if (args) { + if (args.query !== undefined) { + this.query = args.query; + } + if (args.facets !== undefined) { + this.facets = args.facets; + } + if (args.selector !== undefined) { + this.selector = args.selector; + } + if (args.useCacheIfPresent !== undefined) { + this.useCacheIfPresent = args.useCacheIfPresent; + } + if (args.start !== undefined) { + this.start = args.start; + } + if (args.fetch !== undefined) { + this.fetch = args.fetch; + } + if (args.minimumNumberOfResults !== undefined) { + this.minimumNumberOfResults = args.minimumNumberOfResults; + } + if (args.maxQueryTime !== undefined) { + this.maxQueryTime = args.maxQueryTime; + } + if (args.uuid !== undefined) { + this.uuid = args.uuid; + } + if (args.userContext !== undefined) { + this.userContext = args.userContext; + } + if (args.cacheResult !== undefined) { + this.cacheResult = args.cacheResult; + } + if (args.startTime !== undefined) { + this.startTime = args.startTime; + } + } +}; +BlurQuery.prototype = {}; +BlurQuery.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.STRUCT) { + this.query = new Query(); + this.query.read(input); + } else { + input.skip(ftype); + } + break; + case 3: + if (ftype == Thrift.Type.LIST) { + var _size42 = 0; + var _rtmp346; + this.facets = []; + var _etype45 = 0; + _rtmp346 = input.readListBegin(); + _etype45 = _rtmp346.etype; + _size42 = _rtmp346.size; + for (var _i47 = 0; _i47 < _size42; ++_i47) + { + var elem48 = null; + elem48 = new Facet(); + elem48.read(input); + this.facets.push(elem48); + } + input.readListEnd(); + } else { + input.skip(ftype); + } + break; + case 4: + if (ftype == Thrift.Type.STRUCT) { + this.selector = new Selector(); + this.selector.read(input); + } else { + input.skip(ftype); + } + break; + case 6: + if (ftype == Thrift.Type.BOOL) { + this.useCacheIfPresent = input.readBool().value; + } else { + input.skip(ftype); + } + break; + case 7: + if (ftype == Thrift.Type.I64) { + this.start = input.readI64().value; + } else { + input.skip(ftype); + } + break; + case 8: + if (ftype == Thrift.Type.I32) { + this.fetch = input.readI32().value; + } else { + input.skip(ftype); + } + break; + case 9: + if (ftype == Thrift.Type.I64) { + this.minimumNumberOfResults = input.readI64().value; + } else { + input.skip(ftype); + } + break; + case 10: + if (ftype == Thrift.Type.I64) { + this.maxQueryTime = input.readI64().value; + } else { + input.skip(ftype); + } + break; + case 11: + if (ftype == Thrift.Type.STRING) { + this.uuid = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 12: + if (ftype == Thrift.Type.STRING) { + this.userContext = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 13: + if (ftype == Thrift.Type.BOOL) { + this.cacheResult = input.readBool().value; + } else { + input.skip(ftype); + } + break; + case 14: + if (ftype == Thrift.Type.I64) { + this.startTime = input.readI64().value; + } else { + input.skip(ftype); + } + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +BlurQuery.prototype.write = function(output) { + output.writeStructBegin('BlurQuery'); + if (this.query !== null && this.query !== undefined) { + output.writeFieldBegin('query', Thrift.Type.STRUCT, 1); + this.query.write(output); + output.writeFieldEnd(); + } + if (this.facets !== null && this.facets !== undefined) { + output.writeFieldBegin('facets', Thrift.Type.LIST, 3); + output.writeListBegin(Thrift.Type.STRUCT, this.facets.length); + for (var iter49 in this.facets) + { + if (this.facets.hasOwnProperty(iter49)) + { + iter49 = this.facets[iter49]; + iter49.write(output); + } + } + output.writeListEnd(); + output.writeFieldEnd(); + } + if (this.selector !== null && this.selector !== undefined) { + output.writeFieldBegin('selector', Thrift.Type.STRUCT, 4); + this.selector.write(output); + output.writeFieldEnd(); + } + if (this.useCacheIfPresent !== null && this.useCacheIfPresent !== undefined) { + output.writeFieldBegin('useCacheIfPresent', Thrift.Type.BOOL, 6); + output.writeBool(this.useCacheIfPresent); + output.writeFieldEnd(); + } + if (this.start !== null && this.start !== undefined) { + output.writeFieldBegin('start', Thrift.Type.I64, 7); + output.writeI64(this.start); + output.writeFieldEnd(); + } + if (this.fetch !== null && this.fetch !== undefined) { + output.writeFieldBegin('fetch', Thrift.Type.I32, 8); + output.writeI32(this.fetch); + output.writeFieldEnd(); + } + if (this.minimumNumberOfResults !== null && this.minimumNumberOfResults !== undefined) { + output.writeFieldBegin('minimumNumberOfResults', Thrift.Type.I64, 9); + output.writeI64(this.minimumNumberOfResults); + output.writeFieldEnd(); + } + if (this.maxQueryTime !== null && this.maxQueryTime !== undefined) { + output.writeFieldBegin('maxQueryTime', Thrift.Type.I64, 10); + output.writeI64(this.maxQueryTime); + output.writeFieldEnd(); + } + if (this.uuid !== null && this.uuid !== undefined) { + output.writeFieldBegin('uuid', Thrift.Type.STRING, 11); + output.writeString(this.uuid); + output.writeFieldEnd(); + } + if (this.userContext !== null && this.userContext !== undefined) { + output.writeFieldBegin('userContext', Thrift.Type.STRING, 12); + output.writeString(this.userContext); + output.writeFieldEnd(); + } + if (this.cacheResult !== null && this.cacheResult !== undefined) { + output.writeFieldBegin('cacheResult', Thrift.Type.BOOL, 13); + output.writeBool(this.cacheResult); + output.writeFieldEnd(); + } + if (this.startTime !== null && this.startTime !== undefined) { + output.writeFieldBegin('startTime', Thrift.Type.I64, 14); + output.writeI64(this.startTime); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +BlurResult = function(args) { + this.locationId = null; + this.score = null; + this.fetchResult = null; + if (args) { + if (args.locationId !== undefined) { + this.locationId = args.locationId; + } + if (args.score !== undefined) { + this.score = args.score; + } + if (args.fetchResult !== undefined) { + this.fetchResult = args.fetchResult; + } + } +}; +BlurResult.prototype = {}; +BlurResult.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.STRING) { + this.locationId = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 2: + if (ftype == Thrift.Type.DOUBLE) { + this.score = input.readDouble().value; + } else { + input.skip(ftype); + } + break; + case 3: + if (ftype == Thrift.Type.STRUCT) { + this.fetchResult = new FetchResult(); + this.fetchResult.read(input); + } else { + input.skip(ftype); + } + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +BlurResult.prototype.write = function(output) { + output.writeStructBegin('BlurResult'); + if (this.locationId !== null && this.locationId !== undefined) { + output.writeFieldBegin('locationId', Thrift.Type.STRING, 1); + output.writeString(this.locationId); + output.writeFieldEnd(); + } + if (this.score !== null && this.score !== undefined) { + output.writeFieldBegin('score', Thrift.Type.DOUBLE, 2); + output.writeDouble(this.score); + output.writeFieldEnd(); + } + if (this.fetchResult !== null && this.fetchResult !== undefined) { + output.writeFieldBegin('fetchResult', Thrift.Type.STRUCT, 3); + this.fetchResult.write(output); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +BlurResults = function(args) { + this.totalResults = 0; + this.shardInfo = null; + this.results = null; + this.facetCounts = null; + this.exceptions = null; + this.query = null; + if (args) { + if (args.totalResults !== undefined) { + this.totalResults = args.totalResults; + } + if (args.shardInfo !== undefined) { + this.shardInfo = args.shardInfo; + } + if (args.results !== undefined) { + this.results = args.results; + } + if (args.facetCounts !== undefined) { + this.facetCounts = args.facetCounts; + } + if (args.exceptions !== undefined) { + this.exceptions = args.exceptions; + } + if (args.query !== undefined) { + this.query = args.query; + } + } +}; +BlurResults.prototype = {}; +BlurResults.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.I64) { + this.totalResults = input.readI64().value; + } else { + input.skip(ftype); + } + break; + case 2: + if (ftype == Thrift.Type.MAP) { + var _size50 = 0; + var _rtmp354; + this.shardInfo = {}; + var _ktype51 = 0; + var _vtype52 = 0; + _rtmp354 = input.readMapBegin(); + _ktype51 = _rtmp354.ktype; + _vtype52 = _rtmp354.vtype; + _size50 = _rtmp354.size; + for (var _i55 = 0; _i55 < _size50; ++_i55) + { + if (_i55 > 0 ) { + if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { + input.rstack.pop(); + } + } + var key56 = null; + var val57 = null; + key56 = input.readString().value; + val57 = input.readI64().value; + this.shardInfo[key56] = val57; + } + input.readMapEnd(); + } else { + input.skip(ftype); + } + break; + case 3: + if (ftype == Thrift.Type.LIST) { + var _size58 = 0; + var _rtmp362; + this.results = []; + var _etype61 = 0; + _rtmp362 = input.readListBegin(); + _etype61 = _rtmp362.etype; + _size58 = _rtmp362.size; + for (var _i63 = 0; _i63 < _size58; ++_i63) + { + var elem64 = null; + elem64 = new BlurResult(); + elem64.read(input); + this.results.push(elem64); + } + input.readListEnd(); + } else { + input.skip(ftype); + } + break; + case 4: + if (ftype == Thrift.Type.LIST) { + var _size65 = 0; + var _rtmp369; + this.facetCounts = []; + var _etype68 = 0; + _rtmp369 = input.readListBegin(); + _etype68 = _rtmp369.etype; + _size65 = _rtmp369.size; + for (var _i70 = 0; _i70 < _size65; ++_i70) + { + var elem71 = null; + elem71 = input.readI64().value; + this.facetCounts.push(elem71); + } + input.readListEnd(); + } else { + input.skip(ftype); + } + break; + case 5: + if (ftype == Thrift.Type.LIST) { + var _size72 = 0; + var _rtmp376; + this.exceptions = []; + var _etype75 = 0; + _rtmp376 = input.readListBegin(); + _etype75 = _rtmp376.etype; + _size72 = _rtmp376.size; + for (var _i77 = 0; _i77 < _size72; ++_i77) + { + var elem78 = null; + elem78 = new BlurException(); + elem78.read(input); + this.exceptions.push(elem78); + } + input.readListEnd(); + } else { + input.skip(ftype); + } + break; + case 6: + if (ftype == Thrift.Type.STRUCT) { + this.query = new BlurQuery(); + this.query.read(input); + } else { + input.skip(ftype); + } + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +BlurResults.prototype.write = function(output) { + output.writeStructBegin('BlurResults'); + if (this.totalResults !== null && this.totalResults !== undefined) { + output.writeFieldBegin('totalResults', Thrift.Type.I64, 1); + output.writeI64(this.totalResults); + output.writeFieldEnd(); + } + if (this.shardInfo !== null && this.shardInfo !== undefined) { + output.writeFieldBegin('shardInfo', Thrift.Type.MAP, 2); + output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.I64, Thrift.objectLength(this.shardInfo)); + for (var kiter79 in this.shardInfo) + { + if (this.shardInfo.hasOwnProperty(kiter79)) + { + var viter80 = this.shardInfo[kiter79]; + output.writeString(kiter79); + output.writeI64(viter80); + } + } + output.writeMapEnd(); + output.writeFieldEnd(); + } + if (this.results !== null && this.results !== undefined) { + output.writeFieldBegin('results', Thrift.Type.LIST, 3); + output.writeListBegin(Thrift.Type.STRUCT, this.results.length); + for (var iter81 in this.results) + { + if (this.results.hasOwnProperty(iter81)) + { + iter81 = this.results[iter81]; + iter81.write(output); + } + } + output.writeListEnd(); + output.writeFieldEnd(); + } + if (this.facetCounts !== null && this.facetCounts !== undefined) { + output.writeFieldBegin('facetCounts', Thrift.Type.LIST, 4); + output.writeListBegin(Thrift.Type.I64, this.facetCounts.length); + for (var iter82 in this.facetCounts) + { + if (this.facetCounts.hasOwnProperty(iter82)) + { + iter82 = this.facetCounts[iter82]; + output.writeI64(iter82); + } + } + output.writeListEnd(); + output.writeFieldEnd(); + } + if (this.exceptions !== null && this.exceptions !== undefined) { + output.writeFieldBegin('exceptions', Thrift.Type.LIST, 5); + output.writeListBegin(Thrift.Type.STRUCT, this.exceptions.length); + for (var iter83 in this.exceptions) + { + if (this.exceptions.hasOwnProperty(iter83)) + { + iter83 = this.exceptions[iter83]; + iter83.write(output); + } + } + output.writeListEnd(); + output.writeFieldEnd(); + } + if (this.query !== null && this.query !== undefined) { + output.writeFieldBegin('query', Thrift.Type.STRUCT, 6); + this.query.write(output); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +RecordMutation = function(args) { + this.recordMutationType = 1; + this.record = null; + if (args) { + if (args.recordMutationType !== undefined) { + this.recordMutationType = args.recordMutationType; + } + if (args.record !== undefined) { + this.record = args.record; + } + } +}; +RecordMutation.prototype = {}; +RecordMutation.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.I32) { + this.recordMutationType = input.readI32().value; + } else { + input.skip(ftype); + } + break; + case 2: + if (ftype == Thrift.Type.STRUCT) { + this.record = new Record(); + this.record.read(input); + } else { + input.skip(ftype); + } + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +RecordMutation.prototype.write = function(output) { + output.writeStructBegin('RecordMutation'); + if (this.recordMutationType !== null && this.recordMutationType !== undefined) { + output.writeFieldBegin('recordMutationType', Thrift.Type.I32, 1); + output.writeI32(this.recordMutationType); + output.writeFieldEnd(); + } + if (this.record !== null && this.record !== undefined) { + output.writeFieldBegin('record', Thrift.Type.STRUCT, 2); + this.record.write(output); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +RowMutation = function(args) { + this.table = null; + this.rowId = null; + this.wal = true; + this.rowMutationType = 1; + this.recordMutations = null; + this.waitToBeVisible = false; + if (args) { + if (args.table !== undefined) { + this.table = args.table; + } + if (args.rowId !== undefined) { + this.rowId = args.rowId; + } + if (args.wal !== undefined) { + this.wal = args.wal; + } + if (args.rowMutationType !== undefined) { + this.rowMutationType = args.rowMutationType; + } + if (args.recordMutations !== undefined) { + this.recordMutations = args.recordMutations; + } + if (args.waitToBeVisible !== undefined) { + this.waitToBeVisible = args.waitToBeVisible; + } + } +}; +RowMutation.prototype = {}; +RowMutation.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.STRING) { + this.table = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 2: + if (ftype == Thrift.Type.STRING) { + this.rowId = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 3: + if (ftype == Thrift.Type.BOOL) { + this.wal = input.readBool().value; + } else { + input.skip(ftype); + } + break; + case 4: + if (ftype == Thrift.Type.I32) { + this.rowMutationType = input.readI32().value; + } else { + input.skip(ftype); + } + break; + case 5: + if (ftype == Thrift.Type.LIST) { + var _size84 = 0; + var _rtmp388; + this.recordMutations = []; + var _etype87 = 0; + _rtmp388 = input.readListBegin(); + _etype87 = _rtmp388.etype; + _size84 = _rtmp388.size; + for (var _i89 = 0; _i89 < _size84; ++_i89) + { + var elem90 = null; + elem90 = new RecordMutation(); + elem90.read(input); + this.recordMutations.push(elem90); + } + input.readListEnd(); + } else { + input.skip(ftype); + } + break; + case 6: + if (ftype == Thrift.Type.BOOL) { + this.waitToBeVisible = input.readBool().value; + } else { + input.skip(ftype); + } + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +RowMutation.prototype.write = function(output) { + output.writeStructBegin('RowMutation'); + if (this.table !== null && this.table !== undefined) { + output.writeFieldBegin('table', Thrift.Type.STRING, 1); + output.writeString(this.table); + output.writeFieldEnd(); + } + if (this.rowId !== null && this.rowId !== undefined) { + output.writeFieldBegin('rowId', Thrift.Type.STRING, 2); + output.writeString(this.rowId); + output.writeFieldEnd(); + } + if (this.wal !== null && this.wal !== undefined) { + output.writeFieldBegin('wal', Thrift.Type.BOOL, 3); + output.writeBool(this.wal); + output.writeFieldEnd(); + } + if (this.rowMutationType !== null && this.rowMutationType !== undefined) { + output.writeFieldBegin('rowMutationType', Thrift.Type.I32, 4); + output.writeI32(this.rowMutationType); + output.writeFieldEnd(); + } + if (this.recordMutations !== null && this.recordMutations !== undefined) { + output.writeFieldBegin('recordMutations', Thrift.Type.LIST, 5); + output.writeListBegin(Thrift.Type.STRUCT, this.recordMutations.length); + for (var iter91 in this.recordMutations) + { + if (this.recordMutations.hasOwnProperty(iter91)) + { + iter91 = this.recordMutations[iter91]; + iter91.write(output); + } + } + output.writeListEnd(); + output.writeFieldEnd(); + } + if (this.waitToBeVisible !== null && this.waitToBeVisible !== undefined) { + output.writeFieldBegin('waitToBeVisible', Thrift.Type.BOOL, 6); + output.writeBool(this.waitToBeVisible); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +CpuTime = function(args) { + this.cpuTime = null; + this.realTime = null; + if (args) { + if (args.cpuTime !== undefined) { + this.cpuTime = args.cpuTime; + } + if (args.realTime !== undefined) { + this.realTime = args.realTime; + } + } +}; +CpuTime.prototype = {}; +CpuTime.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.I64) { + this.cpuTime = input.readI64().value; + } else { + input.skip(ftype); + } + break; + case 2: + if (ftype == Thrift.Type.I64) { + this.realTime = input.readI64().value; + } else { + input.skip(ftype); + } + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +CpuTime.prototype.write = function(output) { + output.writeStructBegin('CpuTime'); + if (this.cpuTime !== null && this.cpuTime !== undefined) { + output.writeFieldBegin('cpuTime', Thrift.Type.I64, 1); + output.writeI64(this.cpuTime); + output.writeFieldEnd(); + } + if (this.realTime !== null && this.realTime !== undefined) { + output.writeFieldBegin('realTime', Thrift.Type.I64, 2); + output.writeI64(this.realTime); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +BlurQueryStatus = function(args) { + this.query = null; + this.cpuTimes = null; + this.completeShards = null; + this.totalShards = null; + this.state = null; + this.uuid = null; + this.status = null; + if (args) { + if (args.query !== undefined) { + this.query = args.query; + } + if (args.cpuTimes !== undefined) { + this.cpuTimes = args.cpuTimes; + } + if (args.completeShards !== undefined) { + this.completeShards = args.completeShards; + } + if (args.totalShards !== undefined) { + this.totalShards = args.totalShards; + } + if (args.state !== undefined) { + this.state = args.state; + } + if (args.uuid !== undefined) { + this.uuid = args.uuid; + } + if (args.status !== undefined) { + this.status = args.status; + } + } +}; +BlurQueryStatus.prototype = {}; +BlurQueryStatus.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.STRUCT) { + this.query = new BlurQuery(); + this.query.read(input); + } else { + input.skip(ftype); + } + break; + case 2: + if (ftype == Thrift.Type.MAP) { + var _size92 = 0; + var _rtmp396; + this.cpuTimes = {}; + var _ktype93 = 0; + var _vtype94 = 0; + _rtmp396 = input.readMapBegin(); + _ktype93 = _rtmp396.ktype; + _vtype94 = _rtmp396.vtype; + _size92 = _rtmp396.size; + for (var _i97 = 0; _i97 < _size92; ++_i97) + { + if (_i97 > 0 ) { + if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { + input.rstack.pop(); + } + } + var key98 = null; + var val99 = null; + key98 = input.readString().value; + val99 = new CpuTime(); + val99.read(input); + this.cpuTimes[key98] = val99; + } + input.readMapEnd(); + } else { + input.skip(ftype); + } + break; + case 3: + if (ftype == Thrift.Type.I32) { + this.completeShards = input.readI32().value; + } else { + input.skip(ftype); + } + break; + case 4: + if (ftype == Thrift.Type.I32) { + this.totalShards = input.readI32().value; + } else { + input.skip(ftype); + } + break; + case 5: + if (ftype == Thrift.Type.I32) { + this.state = input.readI32().value; + } else { + input.skip(ftype); + } + break; + case 6: + if (ftype == Thrift.Type.STRING) { + this.uuid = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 7: + if (ftype == Thrift.Type.I32) { + this.status = input.readI32().value; + } else { + input.skip(ftype); + } + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +BlurQueryStatus.prototype.write = function(output) { + output.writeStructBegin('BlurQueryStatus'); + if (this.query !== null && this.query !== undefined) { + output.writeFieldBegin('query', Thrift.Type.STRUCT, 1); + this.query.write(output); + output.writeFieldEnd(); + } + if (this.cpuTimes !== null && this.cpuTimes !== undefined) { + output.writeFieldBegin('cpuTimes', Thrift.Type.MAP, 2); + output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.STRUCT, Thrift.objectLength(this.cpuTimes)); + for (var kiter100 in this.cpuTimes) + { + if (this.cpuTimes.hasOwnProperty(kiter100)) + { + var viter101 = this.cpuTimes[kiter100]; + output.writeString(kiter100); + viter101.write(output); + } + } + output.writeMapEnd(); + output.writeFieldEnd(); + } + if (this.completeShards !== null && this.completeShards !== undefined) { + output.writeFieldBegin('completeShards', Thrift.Type.I32, 3); + output.writeI32(this.completeShards); + output.writeFieldEnd(); + } + if (this.totalShards !== null && this.totalShards !== undefined) { + output.writeFieldBegin('totalShards', Thrift.Type.I32, 4); + output.writeI32(this.totalShards); + output.writeFieldEnd(); + } + if (this.state !== null && this.state !== undefined) { + output.writeFieldBegin('state', Thrift.Type.I32, 5); + output.writeI32(this.state); + output.writeFieldEnd(); + } + if (this.uuid !== null && this.uuid !== undefined) { + output.writeFieldBegin('uuid', Thrift.Type.STRING, 6); + output.writeString(this.uuid); + output.writeFieldEnd(); + } + if (this.status !== null && this.status !== undefined) { + output.writeFieldBegin('status', Thrift.Type.I32, 7); + output.writeI32(this.status); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +TableStats = function(args) { + this.tableName = null; + this.bytes = null; + this.recordCount = null; + this.rowCount = null; + if (args) { + if (args.tableName !== undefined) { + this.tableName = args.tableName; + } + if (args.bytes !== undefined) { + this.bytes = args.bytes; + } + if (args.recordCount !== undefined) { + this.recordCount = args.recordCount; + } + if (args.rowCount !== undefined) { + this.rowCount = args.rowCount; + } + } +}; +TableStats.prototype = {}; +TableStats.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.STRING) { + this.tableName = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 2: + if (ftype == Thrift.Type.I64) { + this.bytes = input.readI64().value; + } else { + input.skip(ftype); + } + break; + case 3: + if (ftype == Thrift.Type.I64) { + this.recordCount = input.readI64().value; + } else { + input.skip(ftype); + } + break; + case 4: + if (ftype == Thrift.Type.I64) { + this.rowCount = input.readI64().value; + } else { + input.skip(ftype); + } + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +TableStats.prototype.write = function(output) { + output.writeStructBegin('TableStats'); + if (this.tableName !== null && this.tableName !== undefined) { + output.writeFieldBegin('tableName', Thrift.Type.STRING, 1); + output.writeString(this.tableName); + output.writeFieldEnd(); + } + if (this.bytes !== null && this.bytes !== undefined) { + output.writeFieldBegin('bytes', Thrift.Type.I64, 2); + output.writeI64(this.bytes); + output.writeFieldEnd(); + } + if (this.recordCount !== null && this.recordCount !== undefined) { + output.writeFieldBegin('recordCount', Thrift.Type.I64, 3); + output.writeI64(this.recordCount); + output.writeFieldEnd(); + } + if (this.rowCount !== null && this.rowCount !== undefined) { + output.writeFieldBegin('rowCount', Thrift.Type.I64, 4); + output.writeI64(this.rowCount); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +ColumnDefinition = function(args) { + this.family = null; + this.columnName = null; + this.subColumnName = null; + this.fieldLessIndexed = null; + this.fieldType = null; + this.properties = null; + if (args) { + if (args.family !== undefined) { + this.family = args.family; + } + if (args.columnName !== undefined) { + this.columnName = args.columnName; + } + if (args.subColumnName !== undefined) { + this.subColumnName = args.subColumnName; + } + if (args.fieldLessIndexed !== undefined) { + this.fieldLessIndexed = args.fieldLessIndexed; + } + if (args.fieldType !== undefined) { + this.fieldType = args.fieldType; + } + if (args.properties !== undefined) { + this.properties = args.properties; + } + } +}; +ColumnDefinition.prototype = {}; +ColumnDefinition.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.STRING) { + this.family = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 2: + if (ftype == Thrift.Type.STRING) { + this.columnName = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 3: + if (ftype == Thrift.Type.STRING) { + this.subColumnName = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 4: + if (ftype == Thrift.Type.BOOL) { + this.fieldLessIndexed = input.readBool().value; + } else { + input.skip(ftype); + } + break; + case 5: + if (ftype == Thrift.Type.STRING) { + this.fieldType = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 6: + if (ftype == Thrift.Type.MAP) { + var _size102 = 0; + var _rtmp3106; + this.properties = {}; + var _ktype103 = 0; + var _vtype104 = 0; + _rtmp3106 = input.readMapBegin(); + _ktype103 = _rtmp3106.ktype; + _vtype104 = _rtmp3106.vtype; + _size102 = _rtmp3106.size; + for (var _i107 = 0; _i107 < _size102; ++_i107) + { + if (_i107 > 0 ) { + if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { + input.rstack.pop(); + } + } + var key108 = null; + var val109 = null; + key108 = input.readString().value; + val109 = input.readString().value; + this.properties[key108] = val109; + } + input.readMapEnd(); + } else { + input.skip(ftype); + } + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +ColumnDefinition.prototype.write = function(output) { + output.writeStructBegin('ColumnDefinition'); + if (this.family !== null && this.family !== undefined) { + output.writeFieldBegin('family', Thrift.Type.STRING, 1); + output.writeString(this.family); + output.writeFieldEnd(); + } + if (this.columnName !== null && this.columnName !== undefined) { + output.writeFieldBegin('columnName', Thrift.Type.STRING, 2); + output.writeString(this.columnName); + output.writeFieldEnd(); + } + if (this.subColumnName !== null && this.subColumnName !== undefined) { + output.writeFieldBegin('subColumnName', Thrift.Type.STRING, 3); + output.writeString(this.subColumnName); + output.writeFieldEnd(); + } + if (this.fieldLessIndexed !== null && this.fieldLessIndexed !== undefined) { + output.writeFieldBegin('fieldLessIndexed', Thrift.Type.BOOL, 4); + output.writeBool(this.fieldLessIndexed); + output.writeFieldEnd(); + } + if (this.fieldType !== null && this.fieldType !== undefined) { + output.writeFieldBegin('fieldType', Thrift.Type.STRING, 5); + output.writeString(this.fieldType); + output.writeFieldEnd(); + } + if (this.properties !== null && this.properties !== undefined) { + output.writeFieldBegin('properties', Thrift.Type.MAP, 6); + output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.STRING, Thrift.objectLength(this.properties)); + for (var kiter110 in this.properties) + { + if (this.properties.hasOwnProperty(kiter110)) + { + var viter111 = this.properties[kiter110]; + output.writeString(kiter110); + output.writeString(viter111); + } + } + output.writeMapEnd(); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +Schema = function(args) { + this.table = null; + this.families = null; + if (args) { + if (args.table !== undefined) { + this.table = args.table; + } + if (args.families !== undefined) { + this.families = args.families; + } + } +}; +Schema.prototype = {}; +Schema.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.STRING) { + this.table = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 2: + if (ftype == Thrift.Type.MAP) { + var _size112 = 0; + var _rtmp3116; + this.families = {}; + var _ktype113 = 0; + var _vtype114 = 0; + _rtmp3116 = input.readMapBegin(); + _ktype113 = _rtmp3116.ktype; + _vtype114 = _rtmp3116.vtype; + _size112 = _rtmp3116.size; + for (var _i117 = 0; _i117 < _size112; ++_i117) + { + if (_i117 > 0 ) { + if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { + input.rstack.pop(); + } + } + var key118 = null; + var val119 = null; + key118 = input.readString().value; + var _size120 = 0; + var _rtmp3124; + val119 = {}; + var _ktype121 = 0; + var _vtype122 = 0; + _rtmp3124 = input.readMapBegin(); + _ktype121 = _rtmp3124.ktype; + _vtype122 = _rtmp3124.vtype; + _size120 = _rtmp3124.size; + for (var _i125 = 0; _i125 < _size120; ++_i125) + { + if (_i125 > 0 ) { + if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { + input.rstack.pop(); + } + } + var key126 = null; + var val127 = null; + key126 = input.readString().value; + val127 = new ColumnDefinition(); + val127.read(input); + val119[key126] = val127; + } + input.readMapEnd(); + this.families[key118] = val119; + } + input.readMapEnd(); + } else { + input.skip(ftype); + } + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +Schema.prototype.write = function(output) { + output.writeStructBegin('Schema'); + if (this.table !== null && this.table !== undefined) { + output.writeFieldBegin('table', Thrift.Type.STRING, 1); + output.writeString(this.table); + output.writeFieldEnd(); + } + if (this.families !== null && this.families !== undefined) { + output.writeFieldBegin('families', Thrift.Type.MAP, 2); + output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.MAP, Thrift.objectLength(this.families)); + for (var kiter128 in this.families) + { + if (this.families.hasOwnProperty(kiter128)) + { + var viter129 = this.families[kiter128]; + output.writeString(kiter128); + output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.STRUCT, Thrift.objectLength(viter129)); + for (var kiter130 in viter129) + { + if (viter129.hasOwnProperty(kiter130)) + { + var viter131 = viter129[kiter130]; + output.writeString(kiter130); + viter131.write(output); + } + } + output.writeMapEnd(); + } + } + output.writeMapEnd(); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +TableDescriptor = function(args) { + this.enabled = true; + this.shardCount = 1; + this.tableUri = null; + this.cluster = 'default'; + this.name = null; + this.similarityClass = null; + this.blockCaching = true; + this.blockCachingFileTypes = null; + this.readOnly = false; + this.preCacheCols = null; + this.tableProperties = null; + this.strictTypes = false; + this.defaultMissingFieldType = 'text'; + this.defaultMissingFieldLessIndexing = true; + this.defaultMissingFieldProps = null; + if (args) { + if (args.enabled !== undefined) { + this.enabled = args.enabled; + } + if (args.shardCount !== undefined) { + this.shardCount = args.shardCount; + } + if (args.tableUri !== undefined) { + this.tableUri = args.tableUri; + } + if (args.cluster !== undefined) { + this.cluster = args.cluster; + } + if (args.name !== undefined) { + this.name = args.name; + } + if (args.similarityClass !== undefined) { + this.similarityClass = args.similarityClass; + } + if (args.blockCaching !== undefined) { + this.blockCaching = args.blockCaching; + } + if (args.blockCachingFileTypes !== undefined) { + this.blockCachingFileTypes = args.blockCachingFileTypes; + } + if (args.readOnly !== undefined) { + this.readOnly = args.readOnly; + } + if (args.preCacheCols !== undefined) { + this.preCacheCols = args.preCacheCols; + } + if (args.tableProperties !== undefined) { + this.tableProperties = args.tableProperties; + } + if (args.strictTypes !== undefined) { + this.strictTypes = args.strictTypes; + } + if (args.defaultMissingFieldType !== undefined) { + this.defaultMissingFieldType = args.defaultMissingFieldType; + } + if (args.defaultMissingFieldLessIndexing !== undefined) { + this.defaultMissingFieldLessIndexing = args.defaultMissingFieldLessIndexing; + } + if (args.defaultMissingFieldProps !== undefined) { + this.defaultMissingFieldProps = args.defaultMissingFieldProps; + } + } +}; +TableDescriptor.prototype = {}; +TableDescriptor.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.BOOL) { + this.enabled = input.readBool().value; + } else { + input.skip(ftype); + } + break; + case 3: + if (ftype == Thrift.Type.I32) { + this.shardCount = input.readI32().value; + } else { + input.skip(ftype); + } + break; + case 4: + if (ftype == Thrift.Type.STRING) { + this.tableUri = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 7: + if (ftype == Thrift.Type.STRING) { + this.cluster = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 8: + if (ftype == Thrift.Type.STRING) { + this.name = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 9: + if (ftype == Thrift.Type.STRING) { + this.similarityClass = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 10: + if (ftype == Thrift.Type.BOOL) { + this.blockCaching = input.readBool().value; + } else { + input.skip(ftype); + } + break; + case 11: + if (ftype == Thrift.Type.SET) { + var _size132 = 0; + var _rtmp3136; + this.blockCachingFileTypes = []; + var _etype135 = 0; + _rtmp3136 = input.readSetBegin(); + _etype135 = _rtmp3136.etype; + _size132 = _rtmp3136.size; + for (var _i137 = 0; _i137 < _size132; ++_i137) + { + var elem138 = null; + elem138 = input.readString().value; + this.blockCachingFileTypes.push(elem138); + } + input.readSetEnd(); + } else { + input.skip(ftype); + } + break; + case 12: + if (ftype == Thrift.Type.BOOL) { + this.readOnly = input.readBool().value; + } else { + input.skip(ftype); + } + break; + case 13: + if (ftype == Thrift.Type.LIST) { + var _size139 = 0; + var _rtmp3143; + this.preCacheCols = []; + var _etype142 = 0; + _rtmp3143 = input.readListBegin(); + _etype142 = _rtmp3143.etype; + _size139 = _rtmp3143.size; + for (var _i144 = 0; _i144 < _size139; ++_i144) + { + var elem145 = null; + elem145 = input.readString().value; + this.preCacheCols.push(elem145); + } + input.readListEnd(); + } else { + input.skip(ftype); + } + break; + case 14: + if (ftype == Thrift.Type.MAP) { + var _size146 = 0; + var _rtmp3150; + this.tableProperties = {}; + var _ktype147 = 0; + var _vtype148 = 0; + _rtmp3150 = input.readMapBegin(); + _ktype147 = _rtmp3150.ktype; + _vtype148 = _rtmp3150.vtype; + _size146 = _rtmp3150.size; + for (var _i151 = 0; _i151 < _size146; ++_i151) + { + if (_i151 > 0 ) { + if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { + input.rstack.pop(); + } + } + var key152 = null; + var val153 = null; + key152 = input.readString().value; + val153 = input.readString().value; + this.tableProperties[key152] = val153; + } + input.readMapEnd(); + } else { + input.skip(ftype); + } + break; + case 15: + if (ftype == Thrift.Type.BOOL) { + this.strictTypes = input.readBool().value; + } else { + input.skip(ftype); + } + break; + case 16: + if (ftype == Thrift.Type.STRING) { + this.defaultMissingFieldType = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 17: + if (ftype == Thrift.Type.BOOL) { + this.defaultMissingFieldLessIndexing = input.readBool().value; + } else { + input.skip(ftype); + } + break; + case 18: + if (ftype == Thrift.Type.MAP) { + var _size154 = 0; + var _rtmp3158; + this.defaultMissingFieldProps = {}; + var _ktype155 = 0; + var _vtype156 = 0; + _rtmp3158 = input.readMapBegin(); + _ktype155 = _rtmp3158.ktype; + _vtype156 = _rtmp3158.vtype; + _size154 = _rtmp3158.size; + for (var _i159 = 0; _i159 < _size154; ++_i159) + { + if (_i159 > 0 ) { + if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { + input.rstack.pop(); + } + } + var key160 = null; + var val161 = null; + key160 = input.readString().value; + val161 = input.readString().value; + this.defaultMissingFieldProps[key160] = val161; + } + input.readMapEnd(); + } else { + input.skip(ftype); + } + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +TableDescriptor.prototype.write = function(output) { + output.writeStructBegin('TableDescriptor'); + if (this.enabled !== null && this.enabled !== undefined) { + output.writeFieldBegin('enabled', Thrift.Type.BOOL, 1); + output.writeBool(this.enabled); + output.writeFieldEnd(); + } + if (this.shardCount !== null && this.shardCount !== undefined) { + output.writeFieldBegin('shardCount', Thrift.Type.I32, 3); + output.writeI32(this.shardCount); + output.writeFieldEnd(); + } + if (this.tableUri !== null && this.tableUri !== undefined) { + output.writeFieldBegin('tableUri', Thrift.Type.STRING, 4); + output.writeString(this.tableUri); + output.writeFieldEnd(); + } + if (this.cluster !== null && this.cluster !== undefined) { + output.writeFieldBegin('cluster', Thrift.Type.STRING, 7); + output.writeString(this.cluster); + output.writeFieldEnd(); + } + if (this.name !== null && this.name !== undefined) { + output.writeFieldBegin('name', Thrift.Type.STRING, 8); + output.writeString(this.name); + output.writeFieldEnd(); + } + if (this.similarityClass !== null && this.similarityClass !== undefined) { + output.writeFieldBegin('similarityClass', Thrift.Type.STRING, 9); + output.writeString(this.similarityClass); + output.writeFieldEnd(); + } + if (this.blockCaching !== null && this.blockCaching !== undefined) { + output.writeFieldBegin('blockCaching', Thrift.Type.BOOL, 10); + output.writeBool(this.blockCaching); + output.writeFieldEnd(); + } + if (this.blockCachingFileTypes !== null && this.blockCachingFileTypes !== undefined) { + output.writeFieldBegin('blockCachingFileTypes', Thrift.Type.SET, 11); + output.writeSetBegin(Thrift.Type.STRING, this.blockCachingFileTypes.length); + for (var iter162 in this.blockCachingFileTypes) + { + if (this.blockCachingFileTypes.hasOwnProperty(iter162)) + { + iter162 = this.blockCachingFileTypes[iter162]; + output.writeString(iter162); + } + } + output.writeSetEnd(); + output.writeFieldEnd(); + } + if (this.readOnly !== null && this.readOnly !== undefined) { + output.writeFieldBegin('readOnly', Thrift.Type.BOOL, 12); + output.writeBool(this.readOnly); + output.writeFieldEnd(); + } + if (this.preCacheCols !== null && this.preCacheCols !== undefined) { + output.writeFieldBegin('preCacheCols', Thrift.Type.LIST, 13); + output.writeListBegin(Thrift.Type.STRING, this.preCacheCols.length); + for (var iter163 in this.preCacheCols) + { + if (this.preCacheCols.hasOwnProperty(iter163)) + { + iter163 = this.preCacheCols[iter163]; + output.writeString(iter163); + } + } + output.writeListEnd(); + output.writeFieldEnd(); + } + if (this.tableProperties !== null && this.tableProperties !== undefined) { + output.writeFieldBegin('tableProperties', Thrift.Type.MAP, 14); + output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.STRING, Thrift.objectLength(this.tableProperties)); + for (var kiter164 in this.tableProperties) + { + if (this.tableProperties.hasOwnProperty(kiter164)) + { + var viter165 = this.tableProperties[kiter164]; + output.writeString(kiter164); + output.writeString(viter165); + } + } + output.writeMapEnd(); + output.writeFieldEnd(); + } + if (this.strictTypes !== null && this.strictTypes !== undefined) { + output.writeFieldBegin('strictTypes', Thrift.Type.BOOL, 15); + output.writeBool(this.strictTypes); + output.writeFieldEnd(); + } + if (this.defaultMissingFieldType !== null && this.defaultMissingFieldType !== undefined) { + output.writeFieldBegin('defaultMissingFieldType', Thrift.Type.STRING, 16); + output.writeString(this.defaultMissingFieldType); + output.writeFieldEnd(); + } + if (this.defaultMissingFieldLessIndexing !== null && this.defaultMissingFieldLessIndexing !== undefined) { + output.writeFieldBegin('defaultMissingFieldLessIndexing', Thrift.Type.BOOL, 17); + output.writeBool(this.defaultMissingFieldLessIndexing); + output.writeFieldEnd(); + } + if (this.defaultMissingFieldProps !== null && this.defaultMissingFieldProps !== undefined) { + output.writeFieldBegin('defaultMissingFieldProps', Thrift.Type.MAP, 18); + output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.STRING, Thrift.objectLength(this.defaultMissingFieldProps)); + for (var kiter166 in this.defaultMissingFieldProps) + { + if (this.defaultMissingFieldProps.hasOwnProperty(kiter166)) + { + var viter167 = this.defaultMissingFieldProps[kiter166]; + output.writeString(kiter166); + output.writeString(viter167); + } + } + output.writeMapEnd(); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +Metric = function(args) { + this.name = null; + this.strMap = null; + this.longMap = null; + this.doubleMap = null; + if (args) { + if (args.name !== undefined) { + this.name = args.name; + } + if (args.strMap !== undefined) { + this.strMap = args.strMap; + } + if (args.longMap !== undefined) { + this.longMap = args.longMap; + } + if (args.doubleMap !== undefined) { + this.doubleMap = args.doubleMap; + } + } +}; +Metric.prototype = {}; +Metric.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.STRING) { + this.name = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 2: + if (ftype == Thrift.Type.MAP) { + var _size168 = 0; + var _rtmp3172; + this.strMap = {}; + var _ktype169 = 0; + var _vtype170 = 0; + _rtmp3172 = input.readMapBegin(); + _ktype169 = _rtmp3172.ktype; + _vtype170 = _rtmp3172.vtype; + _size168 = _rtmp3172.size; + for (var _i173 = 0; _i173 < _size168; ++_i173) + { + if (_i173 > 0 ) { + if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { + input.rstack.pop(); + } + } + var key174 = null; + var val175 = null; + key174 = input.readString().value; + val175 = input.readString().value; + this.strMap[key174] = val175; + } + input.readMapEnd(); + } else { + input.skip(ftype); + } + break; + case 3: + if (ftype == Thrift.Type.MAP) { + var _size176 = 0; + var _rtmp3180; + this.longMap = {}; + var _ktype177 = 0; + var _vtype178 = 0; + _rtmp3180 = input.readMapBegin(); + _ktype177 = _rtmp3180.ktype; + _vtype178 = _rtmp3180.vtype; + _size176 = _rtmp3180.size; + for (var _i181 = 0; _i181 < _size176; ++_i181) + { + if (_i181 > 0 ) { + if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { + input.rstack.pop(); + } + } + var key182 = null; + var val183 = null; + key182 = input.readString().value; + val183 = input.readI64().value; + this.longMap[key182] = val183; + } + input.readMapEnd(); + } else { + input.skip(ftype); + } + break; + case 4: + if (ftype == Thrift.Type.MAP) { + var _size184 = 0; + var _rtmp3188; + this.doubleMap = {}; + var _ktype185 = 0; + var _vtype186 = 0; + _rtmp3188 = input.readMapBegin(); + _ktype185 = _rtmp3188.ktype; + _vtype186 = _rtmp3188.vtype; + _size184 = _rtmp3188.size; + for (var _i189 = 0; _i189 < _size184; ++_i189) + { + if (_i189 > 0 ) { + if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { + input.rstack.pop(); + } + } + var key190 = null; + var val191 = null; + key190 = input.readString().value; + val191 = input.readDouble().value; + this.doubleMap[key190] = val191; + } + input.readMapEnd(); + } else { + input.skip(ftype); + } + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +Metric.prototype.write = function(output) { + output.writeStructBegin('Metric'); + if (this.name !== null && this.name !== undefined) { + output.writeFieldBegin('name', Thrift.Type.STRING, 1); + output.writeString(this.name); + output.writeFieldEnd(); + } + if (this.strMap !== null && this.strMap !== undefined) { + output.writeFieldBegin('strMap', Thrift.Type.MAP, 2); + output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.STRING, Thrift.objectLength(this.strMap)); + for (var kiter192 in this.strMap) + { + if (this.strMap.hasOwnProperty(kiter192)) + { + var viter193 = this.strMap[kiter192]; + output.writeString(kiter192); + output.writeString(viter193); + } + } + output.writeMapEnd(); + output.writeFieldEnd(); + } + if (this.longMap !== null && this.longMap !== undefined) { + output.writeFieldBegin('longMap', Thrift.Type.MAP, 3); + output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.I64, Thrift.objectLength(this.longMap)); + for (var kiter194 in this.longMap) + { + if (this.longMap.hasOwnProperty(kiter194)) + { + var viter195 = this.longMap[kiter194]; + output.writeString(kiter194); + output.writeI64(viter195); + } + } + output.writeMapEnd(); + output.writeFieldEnd(); + } + if (this.doubleMap !== null && this.doubleMap !== undefined) { + output.writeFieldBegin('doubleMap', Thrift.Type.MAP, 4); + output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.DOUBLE, Thrift.objectLength(this.doubleMap)); + for (var kiter196 in this.doubleMap) + { + if (this.doubleMap.hasOwnProperty(kiter196)) + { + var viter197 = this.doubleMap[kiter196]; + output.writeString(kiter196); + output.writeDouble(viter197); + } + } + output.writeMapEnd(); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +User = function(args) { + this.username = null; + this.attributes = null; + i
<TRUNCATED>
