http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/90bcb15e/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/CommandDescriptor.java ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/CommandDescriptor.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/CommandDescriptor.java new file mode 100644 index 0000000..3bbf1a3 --- /dev/null +++ b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/CommandDescriptor.java @@ -0,0 +1,1031 @@ +/** + * Autogenerated by Thrift Compiler (0.9.0) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.blur.thrift.generated; + +/** + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + + + +import org.apache.blur.thirdparty.thrift_0_9_0.scheme.IScheme; +import org.apache.blur.thirdparty.thrift_0_9_0.scheme.SchemeFactory; +import org.apache.blur.thirdparty.thrift_0_9_0.scheme.StandardScheme; + +import org.apache.blur.thirdparty.thrift_0_9_0.scheme.TupleScheme; +import org.apache.blur.thirdparty.thrift_0_9_0.protocol.TTupleProtocol; +import org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolException; +import org.apache.blur.thirdparty.thrift_0_9_0.EncodingUtils; +import org.apache.blur.thirdparty.thrift_0_9_0.TException; +import java.util.List; +import java.util.ArrayList; +import java.util.Map; +import java.util.HashMap; +import java.util.EnumMap; +import java.util.Set; +import java.util.HashSet; +import java.util.EnumSet; +import java.util.Collections; +import java.util.BitSet; +import java.nio.ByteBuffer; +import java.util.Arrays; +//import org.slf4j.Logger; +//import org.slf4j.LoggerFactory; + +public class CommandDescriptor implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<CommandDescriptor, CommandDescriptor._Fields>, java.io.Serializable, Cloneable { + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct STRUCT_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct("CommandDescriptor"); + + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField COMMAND_NAME_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("commandName", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, (short)1); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField DESCRIPTION_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("description", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, (short)2); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField REQUIRED_ARGUMENTS_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("requiredArguments", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP, (short)3); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField OPTIONAL_ARGUMENTS_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("optionalArguments", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP, (short)4); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField RETURN_TYPE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("returnType", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, (short)5); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField VERSION_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("version", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, (short)6); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new CommandDescriptorStandardSchemeFactory()); + schemes.put(TupleScheme.class, new CommandDescriptorTupleSchemeFactory()); + } + + public String commandName; // required + public String description; // required + public Map<String,String> requiredArguments; // required + public Map<String,String> optionalArguments; // required + public String returnType; // required + public String version; // required + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + public enum _Fields implements org.apache.blur.thirdparty.thrift_0_9_0.TFieldIdEnum { + COMMAND_NAME((short)1, "commandName"), + DESCRIPTION((short)2, "description"), + REQUIRED_ARGUMENTS((short)3, "requiredArguments"), + OPTIONAL_ARGUMENTS((short)4, "optionalArguments"), + RETURN_TYPE((short)5, "returnType"), + VERSION((short)6, "version"); + + private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); + + static { + for (_Fields field : EnumSet.allOf(_Fields.class)) { + byName.put(field.getFieldName(), field); + } + } + + /** + * Find the _Fields constant that matches fieldId, or null if its not found. + */ + public static _Fields findByThriftId(int fieldId) { + switch(fieldId) { + case 1: // COMMAND_NAME + return COMMAND_NAME; + case 2: // DESCRIPTION + return DESCRIPTION; + case 3: // REQUIRED_ARGUMENTS + return REQUIRED_ARGUMENTS; + case 4: // OPTIONAL_ARGUMENTS + return OPTIONAL_ARGUMENTS; + case 5: // RETURN_TYPE + return RETURN_TYPE; + case 6: // VERSION + return VERSION; + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + + // isset id assignments + public static final Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> metaDataMap; + static { + Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData>(_Fields.class); + tmpMap.put(_Fields.COMMAND_NAME, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("commandName", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING))); + tmpMap.put(_Fields.DESCRIPTION, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("description", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING))); + tmpMap.put(_Fields.REQUIRED_ARGUMENTS, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("requiredArguments", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.MapMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING), + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING)))); + tmpMap.put(_Fields.OPTIONAL_ARGUMENTS, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("optionalArguments", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.MapMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING), + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING)))); + tmpMap.put(_Fields.RETURN_TYPE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("returnType", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING))); + tmpMap.put(_Fields.VERSION, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("version", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(CommandDescriptor.class, metaDataMap); + } + + public CommandDescriptor() { + } + + public CommandDescriptor( + String commandName, + String description, + Map<String,String> requiredArguments, + Map<String,String> optionalArguments, + String returnType, + String version) + { + this(); + this.commandName = commandName; + this.description = description; + this.requiredArguments = requiredArguments; + this.optionalArguments = optionalArguments; + this.returnType = returnType; + this.version = version; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public CommandDescriptor(CommandDescriptor other) { + if (other.isSetCommandName()) { + this.commandName = other.commandName; + } + if (other.isSetDescription()) { + this.description = other.description; + } + if (other.isSetRequiredArguments()) { + Map<String,String> __this__requiredArguments = new HashMap<String,String>(); + for (Map.Entry<String, String> other_element : other.requiredArguments.entrySet()) { + + String other_element_key = other_element.getKey(); + String other_element_value = other_element.getValue(); + + String __this__requiredArguments_copy_key = other_element_key; + + String __this__requiredArguments_copy_value = other_element_value; + + __this__requiredArguments.put(__this__requiredArguments_copy_key, __this__requiredArguments_copy_value); + } + this.requiredArguments = __this__requiredArguments; + } + if (other.isSetOptionalArguments()) { + Map<String,String> __this__optionalArguments = new HashMap<String,String>(); + for (Map.Entry<String, String> other_element : other.optionalArguments.entrySet()) { + + String other_element_key = other_element.getKey(); + String other_element_value = other_element.getValue(); + + String __this__optionalArguments_copy_key = other_element_key; + + String __this__optionalArguments_copy_value = other_element_value; + + __this__optionalArguments.put(__this__optionalArguments_copy_key, __this__optionalArguments_copy_value); + } + this.optionalArguments = __this__optionalArguments; + } + if (other.isSetReturnType()) { + this.returnType = other.returnType; + } + if (other.isSetVersion()) { + this.version = other.version; + } + } + + public CommandDescriptor deepCopy() { + return new CommandDescriptor(this); + } + + @Override + public void clear() { + this.commandName = null; + this.description = null; + this.requiredArguments = null; + this.optionalArguments = null; + this.returnType = null; + this.version = null; + } + + public String getCommandName() { + return this.commandName; + } + + public CommandDescriptor setCommandName(String commandName) { + this.commandName = commandName; + return this; + } + + public void unsetCommandName() { + this.commandName = null; + } + + /** Returns true if field commandName is set (has been assigned a value) and false otherwise */ + public boolean isSetCommandName() { + return this.commandName != null; + } + + public void setCommandNameIsSet(boolean value) { + if (!value) { + this.commandName = null; + } + } + + public String getDescription() { + return this.description; + } + + public CommandDescriptor setDescription(String description) { + this.description = description; + return this; + } + + public void unsetDescription() { + this.description = null; + } + + /** Returns true if field description is set (has been assigned a value) and false otherwise */ + public boolean isSetDescription() { + return this.description != null; + } + + public void setDescriptionIsSet(boolean value) { + if (!value) { + this.description = null; + } + } + + public int getRequiredArgumentsSize() { + return (this.requiredArguments == null) ? 0 : this.requiredArguments.size(); + } + + public void putToRequiredArguments(String key, String val) { + if (this.requiredArguments == null) { + this.requiredArguments = new HashMap<String,String>(); + } + this.requiredArguments.put(key, val); + } + + public Map<String,String> getRequiredArguments() { + return this.requiredArguments; + } + + public CommandDescriptor setRequiredArguments(Map<String,String> requiredArguments) { + this.requiredArguments = requiredArguments; + return this; + } + + public void unsetRequiredArguments() { + this.requiredArguments = null; + } + + /** Returns true if field requiredArguments is set (has been assigned a value) and false otherwise */ + public boolean isSetRequiredArguments() { + return this.requiredArguments != null; + } + + public void setRequiredArgumentsIsSet(boolean value) { + if (!value) { + this.requiredArguments = null; + } + } + + public int getOptionalArgumentsSize() { + return (this.optionalArguments == null) ? 0 : this.optionalArguments.size(); + } + + public void putToOptionalArguments(String key, String val) { + if (this.optionalArguments == null) { + this.optionalArguments = new HashMap<String,String>(); + } + this.optionalArguments.put(key, val); + } + + public Map<String,String> getOptionalArguments() { + return this.optionalArguments; + } + + public CommandDescriptor setOptionalArguments(Map<String,String> optionalArguments) { + this.optionalArguments = optionalArguments; + return this; + } + + public void unsetOptionalArguments() { + this.optionalArguments = null; + } + + /** Returns true if field optionalArguments is set (has been assigned a value) and false otherwise */ + public boolean isSetOptionalArguments() { + return this.optionalArguments != null; + } + + public void setOptionalArgumentsIsSet(boolean value) { + if (!value) { + this.optionalArguments = null; + } + } + + public String getReturnType() { + return this.returnType; + } + + public CommandDescriptor setReturnType(String returnType) { + this.returnType = returnType; + return this; + } + + public void unsetReturnType() { + this.returnType = null; + } + + /** Returns true if field returnType is set (has been assigned a value) and false otherwise */ + public boolean isSetReturnType() { + return this.returnType != null; + } + + public void setReturnTypeIsSet(boolean value) { + if (!value) { + this.returnType = null; + } + } + + public String getVersion() { + return this.version; + } + + public CommandDescriptor setVersion(String version) { + this.version = version; + return this; + } + + public void unsetVersion() { + this.version = null; + } + + /** Returns true if field version is set (has been assigned a value) and false otherwise */ + public boolean isSetVersion() { + return this.version != null; + } + + public void setVersionIsSet(boolean value) { + if (!value) { + this.version = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case COMMAND_NAME: + if (value == null) { + unsetCommandName(); + } else { + setCommandName((String)value); + } + break; + + case DESCRIPTION: + if (value == null) { + unsetDescription(); + } else { + setDescription((String)value); + } + break; + + case REQUIRED_ARGUMENTS: + if (value == null) { + unsetRequiredArguments(); + } else { + setRequiredArguments((Map<String,String>)value); + } + break; + + case OPTIONAL_ARGUMENTS: + if (value == null) { + unsetOptionalArguments(); + } else { + setOptionalArguments((Map<String,String>)value); + } + break; + + case RETURN_TYPE: + if (value == null) { + unsetReturnType(); + } else { + setReturnType((String)value); + } + break; + + case VERSION: + if (value == null) { + unsetVersion(); + } else { + setVersion((String)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case COMMAND_NAME: + return getCommandName(); + + case DESCRIPTION: + return getDescription(); + + case REQUIRED_ARGUMENTS: + return getRequiredArguments(); + + case OPTIONAL_ARGUMENTS: + return getOptionalArguments(); + + case RETURN_TYPE: + return getReturnType(); + + case VERSION: + return getVersion(); + + } + throw new IllegalStateException(); + } + + /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ + public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + + switch (field) { + case COMMAND_NAME: + return isSetCommandName(); + case DESCRIPTION: + return isSetDescription(); + case REQUIRED_ARGUMENTS: + return isSetRequiredArguments(); + case OPTIONAL_ARGUMENTS: + return isSetOptionalArguments(); + case RETURN_TYPE: + return isSetReturnType(); + case VERSION: + return isSetVersion(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof CommandDescriptor) + return this.equals((CommandDescriptor)that); + return false; + } + + public boolean equals(CommandDescriptor that) { + if (that == null) + return false; + + boolean this_present_commandName = true && this.isSetCommandName(); + boolean that_present_commandName = true && that.isSetCommandName(); + if (this_present_commandName || that_present_commandName) { + if (!(this_present_commandName && that_present_commandName)) + return false; + if (!this.commandName.equals(that.commandName)) + return false; + } + + boolean this_present_description = true && this.isSetDescription(); + boolean that_present_description = true && that.isSetDescription(); + if (this_present_description || that_present_description) { + if (!(this_present_description && that_present_description)) + return false; + if (!this.description.equals(that.description)) + return false; + } + + boolean this_present_requiredArguments = true && this.isSetRequiredArguments(); + boolean that_present_requiredArguments = true && that.isSetRequiredArguments(); + if (this_present_requiredArguments || that_present_requiredArguments) { + if (!(this_present_requiredArguments && that_present_requiredArguments)) + return false; + if (!this.requiredArguments.equals(that.requiredArguments)) + return false; + } + + boolean this_present_optionalArguments = true && this.isSetOptionalArguments(); + boolean that_present_optionalArguments = true && that.isSetOptionalArguments(); + if (this_present_optionalArguments || that_present_optionalArguments) { + if (!(this_present_optionalArguments && that_present_optionalArguments)) + return false; + if (!this.optionalArguments.equals(that.optionalArguments)) + return false; + } + + boolean this_present_returnType = true && this.isSetReturnType(); + boolean that_present_returnType = true && that.isSetReturnType(); + if (this_present_returnType || that_present_returnType) { + if (!(this_present_returnType && that_present_returnType)) + return false; + if (!this.returnType.equals(that.returnType)) + return false; + } + + boolean this_present_version = true && this.isSetVersion(); + boolean that_present_version = true && that.isSetVersion(); + if (this_present_version || that_present_version) { + if (!(this_present_version && that_present_version)) + return false; + if (!this.version.equals(that.version)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + return 0; + } + + public int compareTo(CommandDescriptor other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + CommandDescriptor typedOther = (CommandDescriptor)other; + + lastComparison = Boolean.valueOf(isSetCommandName()).compareTo(typedOther.isSetCommandName()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetCommandName()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.commandName, typedOther.commandName); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetDescription()).compareTo(typedOther.isSetDescription()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetDescription()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.description, typedOther.description); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetRequiredArguments()).compareTo(typedOther.isSetRequiredArguments()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetRequiredArguments()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.requiredArguments, typedOther.requiredArguments); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetOptionalArguments()).compareTo(typedOther.isSetOptionalArguments()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetOptionalArguments()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.optionalArguments, typedOther.optionalArguments); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetReturnType()).compareTo(typedOther.isSetReturnType()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetReturnType()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.returnType, typedOther.returnType); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetVersion()).compareTo(typedOther.isSetVersion()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetVersion()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.version, typedOther.version); + if (lastComparison != 0) { + return lastComparison; + } + } + return 0; + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + } + + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("CommandDescriptor("); + boolean first = true; + + sb.append("commandName:"); + if (this.commandName == null) { + sb.append("null"); + } else { + sb.append(this.commandName); + } + first = false; + if (!first) sb.append(", "); + sb.append("description:"); + if (this.description == null) { + sb.append("null"); + } else { + sb.append(this.description); + } + first = false; + if (!first) sb.append(", "); + sb.append("requiredArguments:"); + if (this.requiredArguments == null) { + sb.append("null"); + } else { + sb.append(this.requiredArguments); + } + first = false; + if (!first) sb.append(", "); + sb.append("optionalArguments:"); + if (this.optionalArguments == null) { + sb.append("null"); + } else { + sb.append(this.optionalArguments); + } + first = false; + if (!first) sb.append(", "); + sb.append("returnType:"); + if (this.returnType == null) { + sb.append("null"); + } else { + sb.append(this.returnType); + } + first = false; + if (!first) sb.append(", "); + sb.append("version:"); + if (this.version == null) { + sb.append("null"); + } else { + sb.append(this.version); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + // check for required fields + // check for sub-struct validity + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TCompactProtocol(new org.apache.blur.thirdparty.thrift_0_9_0.transport.TIOStreamTransport(out))); + } catch (org.apache.blur.thirdparty.thrift_0_9_0.TException te) { + throw new java.io.IOException(te); + } + } + + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + try { + read(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TCompactProtocol(new org.apache.blur.thirdparty.thrift_0_9_0.transport.TIOStreamTransport(in))); + } catch (org.apache.blur.thirdparty.thrift_0_9_0.TException te) { + throw new java.io.IOException(te); + } + } + + private static class CommandDescriptorStandardSchemeFactory implements SchemeFactory { + public CommandDescriptorStandardScheme getScheme() { + return new CommandDescriptorStandardScheme(); + } + } + + private static class CommandDescriptorStandardScheme extends StandardScheme<CommandDescriptor> { + + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, CommandDescriptor struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField schemeField; + iprot.readStructBegin(); + while (true) + { + schemeField = iprot.readFieldBegin(); + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STOP) { + break; + } + switch (schemeField.id) { + case 1: // COMMAND_NAME + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING) { + struct.commandName = iprot.readString(); + struct.setCommandNameIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // DESCRIPTION + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING) { + struct.description = iprot.readString(); + struct.setDescriptionIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 3: // REQUIRED_ARGUMENTS + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP) { + { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map270 = iprot.readMapBegin(); + struct.requiredArguments = new HashMap<String,String>(2*_map270.size); + for (int _i271 = 0; _i271 < _map270.size; ++_i271) + { + String _key272; // optional + String _val273; // required + _key272 = iprot.readString(); + _val273 = iprot.readString(); + struct.requiredArguments.put(_key272, _val273); + } + iprot.readMapEnd(); + } + struct.setRequiredArgumentsIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 4: // OPTIONAL_ARGUMENTS + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP) { + { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map274 = iprot.readMapBegin(); + struct.optionalArguments = new HashMap<String,String>(2*_map274.size); + for (int _i275 = 0; _i275 < _map274.size; ++_i275) + { + String _key276; // optional + String _val277; // required + _key276 = iprot.readString(); + _val277 = iprot.readString(); + struct.optionalArguments.put(_key276, _val277); + } + iprot.readMapEnd(); + } + struct.setOptionalArgumentsIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 5: // RETURN_TYPE + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING) { + struct.returnType = iprot.readString(); + struct.setReturnTypeIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 6: // VERSION + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING) { + struct.version = iprot.readString(); + struct.setVersionIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + default: + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + iprot.readFieldEnd(); + } + iprot.readStructEnd(); + + // check for required fields of primitive type, which can't be checked in the validate method + struct.validate(); + } + + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot, CommandDescriptor struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.commandName != null) { + oprot.writeFieldBegin(COMMAND_NAME_FIELD_DESC); + oprot.writeString(struct.commandName); + oprot.writeFieldEnd(); + } + if (struct.description != null) { + oprot.writeFieldBegin(DESCRIPTION_FIELD_DESC); + oprot.writeString(struct.description); + oprot.writeFieldEnd(); + } + if (struct.requiredArguments != null) { + oprot.writeFieldBegin(REQUIRED_ARGUMENTS_FIELD_DESC); + { + oprot.writeMapBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, struct.requiredArguments.size())); + for (Map.Entry<String, String> _iter278 : struct.requiredArguments.entrySet()) + { + oprot.writeString(_iter278.getKey()); + oprot.writeString(_iter278.getValue()); + } + oprot.writeMapEnd(); + } + oprot.writeFieldEnd(); + } + if (struct.optionalArguments != null) { + oprot.writeFieldBegin(OPTIONAL_ARGUMENTS_FIELD_DESC); + { + oprot.writeMapBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, struct.optionalArguments.size())); + for (Map.Entry<String, String> _iter279 : struct.optionalArguments.entrySet()) + { + oprot.writeString(_iter279.getKey()); + oprot.writeString(_iter279.getValue()); + } + oprot.writeMapEnd(); + } + oprot.writeFieldEnd(); + } + if (struct.returnType != null) { + oprot.writeFieldBegin(RETURN_TYPE_FIELD_DESC); + oprot.writeString(struct.returnType); + oprot.writeFieldEnd(); + } + if (struct.version != null) { + oprot.writeFieldBegin(VERSION_FIELD_DESC); + oprot.writeString(struct.version); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class CommandDescriptorTupleSchemeFactory implements SchemeFactory { + public CommandDescriptorTupleScheme getScheme() { + return new CommandDescriptorTupleScheme(); + } + } + + private static class CommandDescriptorTupleScheme extends TupleScheme<CommandDescriptor> { + + @Override + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, CommandDescriptor struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetCommandName()) { + optionals.set(0); + } + if (struct.isSetDescription()) { + optionals.set(1); + } + if (struct.isSetRequiredArguments()) { + optionals.set(2); + } + if (struct.isSetOptionalArguments()) { + optionals.set(3); + } + if (struct.isSetReturnType()) { + optionals.set(4); + } + if (struct.isSetVersion()) { + optionals.set(5); + } + oprot.writeBitSet(optionals, 6); + if (struct.isSetCommandName()) { + oprot.writeString(struct.commandName); + } + if (struct.isSetDescription()) { + oprot.writeString(struct.description); + } + if (struct.isSetRequiredArguments()) { + { + oprot.writeI32(struct.requiredArguments.size()); + for (Map.Entry<String, String> _iter280 : struct.requiredArguments.entrySet()) + { + oprot.writeString(_iter280.getKey()); + oprot.writeString(_iter280.getValue()); + } + } + } + if (struct.isSetOptionalArguments()) { + { + oprot.writeI32(struct.optionalArguments.size()); + for (Map.Entry<String, String> _iter281 : struct.optionalArguments.entrySet()) + { + oprot.writeString(_iter281.getKey()); + oprot.writeString(_iter281.getValue()); + } + } + } + if (struct.isSetReturnType()) { + oprot.writeString(struct.returnType); + } + if (struct.isSetVersion()) { + oprot.writeString(struct.version); + } + } + + @Override + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, CommandDescriptor struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(6); + if (incoming.get(0)) { + struct.commandName = iprot.readString(); + struct.setCommandNameIsSet(true); + } + if (incoming.get(1)) { + struct.description = iprot.readString(); + struct.setDescriptionIsSet(true); + } + if (incoming.get(2)) { + { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map282 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, iprot.readI32()); + struct.requiredArguments = new HashMap<String,String>(2*_map282.size); + for (int _i283 = 0; _i283 < _map282.size; ++_i283) + { + String _key284; // optional + String _val285; // required + _key284 = iprot.readString(); + _val285 = iprot.readString(); + struct.requiredArguments.put(_key284, _val285); + } + } + struct.setRequiredArgumentsIsSet(true); + } + if (incoming.get(3)) { + { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map286 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, iprot.readI32()); + struct.optionalArguments = new HashMap<String,String>(2*_map286.size); + for (int _i287 = 0; _i287 < _map286.size; ++_i287) + { + String _key288; // optional + String _val289; // required + _key288 = iprot.readString(); + _val289 = iprot.readString(); + struct.optionalArguments.put(_key288, _val289); + } + } + struct.setOptionalArgumentsIsSet(true); + } + if (incoming.get(4)) { + struct.returnType = iprot.readString(); + struct.setReturnTypeIsSet(true); + } + if (incoming.get(5)) { + struct.version = iprot.readString(); + struct.setVersionIsSet(true); + } + } + } + +} +
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/90bcb15e/distribution/src/main/scripts/interface/gen-js/Blur.js ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-js/Blur.js b/distribution/src/main/scripts/interface/gen-js/Blur.js index 70b57c3..cfdf433 100644 --- a/distribution/src/main/scripts/interface/gen-js/Blur.js +++ b/distribution/src/main/scripts/interface/gen-js/Blur.js @@ -7,6 +7,128 @@ //HELPER FUNCTIONS AND STRUCTURES +Blur_listInstalledCommands_args = function(args) { +}; +Blur_listInstalledCommands_args.prototype = {}; +Blur_listInstalledCommands_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_listInstalledCommands_args.prototype.write = function(output) { + output.writeStructBegin('Blur_listInstalledCommands_args'); + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +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_listInstalledCommands_result.prototype = {}; +Blur_listInstalledCommands_result.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 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(); + this.ex.read(input); + } else { + input.skip(ftype); + } + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +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); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + Blur_execute_args = function(args) { this.commandName = null; this.arguments = null; @@ -427,18 +549,18 @@ Blur_commandStatusList_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size270 = 0; - var _rtmp3274; + var _size298 = 0; + var _rtmp3302; this.success = []; - var _etype273 = 0; - _rtmp3274 = input.readListBegin(); - _etype273 = _rtmp3274.etype; - _size270 = _rtmp3274.size; - for (var _i275 = 0; _i275 < _size270; ++_i275) + var _etype301 = 0; + _rtmp3302 = input.readListBegin(); + _etype301 = _rtmp3302.etype; + _size298 = _rtmp3302.size; + for (var _i303 = 0; _i303 < _size298; ++_i303) { - var elem276 = null; - elem276 = input.readString().value; - this.success.push(elem276); + var elem304 = null; + elem304 = input.readString().value; + this.success.push(elem304); } input.readListEnd(); } else { @@ -467,12 +589,12 @@ Blur_commandStatusList_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.LIST, 0); output.writeListBegin(Thrift.Type.STRING, this.success.length); - for (var iter277 in this.success) + for (var iter305 in this.success) { - if (this.success.hasOwnProperty(iter277)) + if (this.success.hasOwnProperty(iter305)) { - iter277 = this.success[iter277]; - output.writeString(iter277); + iter305 = this.success[iter305]; + output.writeString(iter305); } } output.writeListEnd(); @@ -1436,18 +1558,18 @@ Blur_tableList_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size278 = 0; - var _rtmp3282; + var _size306 = 0; + var _rtmp3310; this.success = []; - var _etype281 = 0; - _rtmp3282 = input.readListBegin(); - _etype281 = _rtmp3282.etype; - _size278 = _rtmp3282.size; - for (var _i283 = 0; _i283 < _size278; ++_i283) + var _etype309 = 0; + _rtmp3310 = input.readListBegin(); + _etype309 = _rtmp3310.etype; + _size306 = _rtmp3310.size; + for (var _i311 = 0; _i311 < _size306; ++_i311) { - var elem284 = null; - elem284 = input.readString().value; - this.success.push(elem284); + var elem312 = null; + elem312 = input.readString().value; + this.success.push(elem312); } input.readListEnd(); } else { @@ -1476,12 +1598,12 @@ Blur_tableList_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.LIST, 0); output.writeListBegin(Thrift.Type.STRING, this.success.length); - for (var iter285 in this.success) + for (var iter313 in this.success) { - if (this.success.hasOwnProperty(iter285)) + if (this.success.hasOwnProperty(iter313)) { - iter285 = this.success[iter285]; - output.writeString(iter285); + iter313 = this.success[iter313]; + output.writeString(iter313); } } output.writeListEnd(); @@ -1582,18 +1704,18 @@ Blur_tableListByCluster_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size286 = 0; - var _rtmp3290; + var _size314 = 0; + var _rtmp3318; this.success = []; - var _etype289 = 0; - _rtmp3290 = input.readListBegin(); - _etype289 = _rtmp3290.etype; - _size286 = _rtmp3290.size; - for (var _i291 = 0; _i291 < _size286; ++_i291) + var _etype317 = 0; + _rtmp3318 = input.readListBegin(); + _etype317 = _rtmp3318.etype; + _size314 = _rtmp3318.size; + for (var _i319 = 0; _i319 < _size314; ++_i319) { - var elem292 = null; - elem292 = input.readString().value; - this.success.push(elem292); + var elem320 = null; + elem320 = input.readString().value; + this.success.push(elem320); } input.readListEnd(); } else { @@ -1622,12 +1744,12 @@ Blur_tableListByCluster_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.LIST, 0); output.writeListBegin(Thrift.Type.STRING, this.success.length); - for (var iter293 in this.success) + for (var iter321 in this.success) { - if (this.success.hasOwnProperty(iter293)) + if (this.success.hasOwnProperty(iter321)) { - iter293 = this.success[iter293]; - output.writeString(iter293); + iter321 = this.success[iter321]; + output.writeString(iter321); } } output.writeListEnd(); @@ -2613,40 +2735,40 @@ Blur_listSnapshots_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.MAP) { - var _size294 = 0; - var _rtmp3298; + var _size322 = 0; + var _rtmp3326; this.success = {}; - var _ktype295 = 0; - var _vtype296 = 0; - _rtmp3298 = input.readMapBegin(); - _ktype295 = _rtmp3298.ktype; - _vtype296 = _rtmp3298.vtype; - _size294 = _rtmp3298.size; - for (var _i299 = 0; _i299 < _size294; ++_i299) + var _ktype323 = 0; + var _vtype324 = 0; + _rtmp3326 = input.readMapBegin(); + _ktype323 = _rtmp3326.ktype; + _vtype324 = _rtmp3326.vtype; + _size322 = _rtmp3326.size; + for (var _i327 = 0; _i327 < _size322; ++_i327) { - if (_i299 > 0 ) { + if (_i327 > 0 ) { if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { input.rstack.pop(); } } - var key300 = null; - var val301 = null; - key300 = input.readString().value; - var _size302 = 0; - var _rtmp3306; - val301 = []; - var _etype305 = 0; - _rtmp3306 = input.readListBegin(); - _etype305 = _rtmp3306.etype; - _size302 = _rtmp3306.size; - for (var _i307 = 0; _i307 < _size302; ++_i307) + var key328 = null; + var val329 = null; + key328 = input.readString().value; + var _size330 = 0; + var _rtmp3334; + val329 = []; + var _etype333 = 0; + _rtmp3334 = input.readListBegin(); + _etype333 = _rtmp3334.etype; + _size330 = _rtmp3334.size; + for (var _i335 = 0; _i335 < _size330; ++_i335) { - var elem308 = null; - elem308 = input.readString().value; - val301.push(elem308); + var elem336 = null; + elem336 = input.readString().value; + val329.push(elem336); } input.readListEnd(); - this.success[key300] = val301; + this.success[key328] = val329; } input.readMapEnd(); } else { @@ -2675,19 +2797,19 @@ Blur_listSnapshots_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.MAP, 0); output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.LIST, Thrift.objectLength(this.success)); - for (var kiter309 in this.success) + for (var kiter337 in this.success) { - if (this.success.hasOwnProperty(kiter309)) + if (this.success.hasOwnProperty(kiter337)) { - var viter310 = this.success[kiter309]; - output.writeString(kiter309); - output.writeListBegin(Thrift.Type.STRING, viter310.length); - for (var iter311 in viter310) + var viter338 = this.success[kiter337]; + output.writeString(kiter337); + output.writeListBegin(Thrift.Type.STRING, viter338.length); + for (var iter339 in viter338) { - if (viter310.hasOwnProperty(iter311)) + if (viter338.hasOwnProperty(iter339)) { - iter311 = viter310[iter311]; - output.writeString(iter311); + iter339 = viter338[iter339]; + output.writeString(iter339); } } output.writeListEnd(); @@ -3101,19 +3223,19 @@ Blur_fetchRowBatch_args.prototype.read = function(input) { break; case 2: if (ftype == Thrift.Type.LIST) { - var _size312 = 0; - var _rtmp3316; + var _size340 = 0; + var _rtmp3344; this.selectors = []; - var _etype315 = 0; - _rtmp3316 = input.readListBegin(); - _etype315 = _rtmp3316.etype; - _size312 = _rtmp3316.size; - for (var _i317 = 0; _i317 < _size312; ++_i317) + var _etype343 = 0; + _rtmp3344 = input.readListBegin(); + _etype343 = _rtmp3344.etype; + _size340 = _rtmp3344.size; + for (var _i345 = 0; _i345 < _size340; ++_i345) { - var elem318 = null; - elem318 = new Selector(); - elem318.read(input); - this.selectors.push(elem318); + var elem346 = null; + elem346 = new Selector(); + elem346.read(input); + this.selectors.push(elem346); } input.readListEnd(); } else { @@ -3139,12 +3261,12 @@ Blur_fetchRowBatch_args.prototype.write = function(output) { if (this.selectors !== null && this.selectors !== undefined) { output.writeFieldBegin('selectors', Thrift.Type.LIST, 2); output.writeListBegin(Thrift.Type.STRUCT, this.selectors.length); - for (var iter319 in this.selectors) + for (var iter347 in this.selectors) { - if (this.selectors.hasOwnProperty(iter319)) + if (this.selectors.hasOwnProperty(iter347)) { - iter319 = this.selectors[iter319]; - iter319.write(output); + iter347 = this.selectors[iter347]; + iter347.write(output); } } output.writeListEnd(); @@ -3187,19 +3309,19 @@ Blur_fetchRowBatch_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size320 = 0; - var _rtmp3324; + var _size348 = 0; + var _rtmp3352; this.success = []; - var _etype323 = 0; - _rtmp3324 = input.readListBegin(); - _etype323 = _rtmp3324.etype; - _size320 = _rtmp3324.size; - for (var _i325 = 0; _i325 < _size320; ++_i325) + var _etype351 = 0; + _rtmp3352 = input.readListBegin(); + _etype351 = _rtmp3352.etype; + _size348 = _rtmp3352.size; + for (var _i353 = 0; _i353 < _size348; ++_i353) { - var elem326 = null; - elem326 = new FetchResult(); - elem326.read(input); - this.success.push(elem326); + var elem354 = null; + elem354 = new FetchResult(); + elem354.read(input); + this.success.push(elem354); } input.readListEnd(); } else { @@ -3228,12 +3350,12 @@ Blur_fetchRowBatch_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.LIST, 0); output.writeListBegin(Thrift.Type.STRUCT, this.success.length); - for (var iter327 in this.success) + for (var iter355 in this.success) { - if (this.success.hasOwnProperty(iter327)) + if (this.success.hasOwnProperty(iter355)) { - iter327 = this.success[iter327]; - iter327.write(output); + iter355 = this.success[iter355]; + iter355.write(output); } } output.writeListEnd(); @@ -3497,19 +3619,19 @@ Blur_mutateBatch_args.prototype.read = function(input) { { case 1: if (ftype == Thrift.Type.LIST) { - var _size328 = 0; - var _rtmp3332; + var _size356 = 0; + var _rtmp3360; this.mutations = []; - var _etype331 = 0; - _rtmp3332 = input.readListBegin(); - _etype331 = _rtmp3332.etype; - _size328 = _rtmp3332.size; - for (var _i333 = 0; _i333 < _size328; ++_i333) + var _etype359 = 0; + _rtmp3360 = input.readListBegin(); + _etype359 = _rtmp3360.etype; + _size356 = _rtmp3360.size; + for (var _i361 = 0; _i361 < _size356; ++_i361) { - var elem334 = null; - elem334 = new RowMutation(); - elem334.read(input); - this.mutations.push(elem334); + var elem362 = null; + elem362 = new RowMutation(); + elem362.read(input); + this.mutations.push(elem362); } input.readListEnd(); } else { @@ -3533,12 +3655,12 @@ Blur_mutateBatch_args.prototype.write = function(output) { if (this.mutations !== null && this.mutations !== undefined) { output.writeFieldBegin('mutations', Thrift.Type.LIST, 1); output.writeListBegin(Thrift.Type.STRUCT, this.mutations.length); - for (var iter335 in this.mutations) + for (var iter363 in this.mutations) { - if (this.mutations.hasOwnProperty(iter335)) + if (this.mutations.hasOwnProperty(iter363)) { - iter335 = this.mutations[iter335]; - iter335.write(output); + iter363 = this.mutations[iter363]; + iter363.write(output); } } output.writeListEnd(); @@ -3631,19 +3753,19 @@ Blur_enqueueMutateBatch_args.prototype.read = function(input) { { case 1: if (ftype == Thrift.Type.LIST) { - var _size336 = 0; - var _rtmp3340; + var _size364 = 0; + var _rtmp3368; this.mutations = []; - var _etype339 = 0; - _rtmp3340 = input.readListBegin(); - _etype339 = _rtmp3340.etype; - _size336 = _rtmp3340.size; - for (var _i341 = 0; _i341 < _size336; ++_i341) + var _etype367 = 0; + _rtmp3368 = input.readListBegin(); + _etype367 = _rtmp3368.etype; + _size364 = _rtmp3368.size; + for (var _i369 = 0; _i369 < _size364; ++_i369) { - var elem342 = null; - elem342 = new RowMutation(); - elem342.read(input); - this.mutations.push(elem342); + var elem370 = null; + elem370 = new RowMutation(); + elem370.read(input); + this.mutations.push(elem370); } input.readListEnd(); } else { @@ -3667,12 +3789,12 @@ Blur_enqueueMutateBatch_args.prototype.write = function(output) { if (this.mutations !== null && this.mutations !== undefined) { output.writeFieldBegin('mutations', Thrift.Type.LIST, 1); output.writeListBegin(Thrift.Type.STRUCT, this.mutations.length); - for (var iter343 in this.mutations) + for (var iter371 in this.mutations) { - if (this.mutations.hasOwnProperty(iter343)) + if (this.mutations.hasOwnProperty(iter371)) { - iter343 = this.mutations[iter343]; - iter343.write(output); + iter371 = this.mutations[iter371]; + iter371.write(output); } } output.writeListEnd(); @@ -3950,18 +4072,18 @@ Blur_queryStatusIdList_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size344 = 0; - var _rtmp3348; + var _size372 = 0; + var _rtmp3376; this.success = []; - var _etype347 = 0; - _rtmp3348 = input.readListBegin(); - _etype347 = _rtmp3348.etype; - _size344 = _rtmp3348.size; - for (var _i349 = 0; _i349 < _size344; ++_i349) + var _etype375 = 0; + _rtmp3376 = input.readListBegin(); + _etype375 = _rtmp3376.etype; + _size372 = _rtmp3376.size; + for (var _i377 = 0; _i377 < _size372; ++_i377) { - var elem350 = null; - elem350 = input.readString().value; - this.success.push(elem350); + var elem378 = null; + elem378 = input.readString().value; + this.success.push(elem378); } input.readListEnd(); } else { @@ -3990,12 +4112,12 @@ Blur_queryStatusIdList_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.LIST, 0); output.writeListBegin(Thrift.Type.STRING, this.success.length); - for (var iter351 in this.success) + for (var iter379 in this.success) { - if (this.success.hasOwnProperty(iter351)) + if (this.success.hasOwnProperty(iter379)) { - iter351 = this.success[iter351]; - output.writeString(iter351); + iter379 = this.success[iter379]; + output.writeString(iter379); } } output.writeListEnd(); @@ -4295,18 +4417,18 @@ Blur_terms_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size352 = 0; - var _rtmp3356; + var _size380 = 0; + var _rtmp3384; this.success = []; - var _etype355 = 0; - _rtmp3356 = input.readListBegin(); - _etype355 = _rtmp3356.etype; - _size352 = _rtmp3356.size; - for (var _i357 = 0; _i357 < _size352; ++_i357) + var _etype383 = 0; + _rtmp3384 = input.readListBegin(); + _etype383 = _rtmp3384.etype; + _size380 = _rtmp3384.size; + for (var _i385 = 0; _i385 < _size380; ++_i385) { - var elem358 = null; - elem358 = input.readString().value; - this.success.push(elem358); + var elem386 = null; + elem386 = input.readString().value; + this.success.push(elem386); } input.readListEnd(); } else { @@ -4335,12 +4457,12 @@ Blur_terms_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.LIST, 0); output.writeListBegin(Thrift.Type.STRING, this.success.length); - for (var iter359 in this.success) + for (var iter387 in this.success) { - if (this.success.hasOwnProperty(iter359)) + if (this.success.hasOwnProperty(iter387)) { - iter359 = this.success[iter359]; - output.writeString(iter359); + iter387 = this.success[iter387]; + output.writeString(iter387); } } output.writeListEnd(); @@ -4585,18 +4707,18 @@ Blur_shardClusterList_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size360 = 0; - var _rtmp3364; + var _size388 = 0; + var _rtmp3392; this.success = []; - var _etype363 = 0; - _rtmp3364 = input.readListBegin(); - _etype363 = _rtmp3364.etype; - _size360 = _rtmp3364.size; - for (var _i365 = 0; _i365 < _size360; ++_i365) + var _etype391 = 0; + _rtmp3392 = input.readListBegin(); + _etype391 = _rtmp3392.etype; + _size388 = _rtmp3392.size; + for (var _i393 = 0; _i393 < _size388; ++_i393) { - var elem366 = null; - elem366 = input.readString().value; - this.success.push(elem366); + var elem394 = null; + elem394 = input.readString().value; + this.success.push(elem394); } input.readListEnd(); } else { @@ -4625,12 +4747,12 @@ Blur_shardClusterList_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.LIST, 0); output.writeListBegin(Thrift.Type.STRING, this.success.length); - for (var iter367 in this.success) + for (var iter395 in this.success) { - if (this.success.hasOwnProperty(iter367)) + if (this.success.hasOwnProperty(iter395)) { - iter367 = this.success[iter367]; - output.writeString(iter367); + iter395 = this.success[iter395]; + output.writeString(iter395); } } output.writeListEnd(); @@ -4731,18 +4853,18 @@ Blur_shardServerList_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size368 = 0; - var _rtmp3372; + var _size396 = 0; + var _rtmp3400; this.success = []; - var _etype371 = 0; - _rtmp3372 = input.readListBegin(); - _etype371 = _rtmp3372.etype; - _size368 = _rtmp3372.size; - for (var _i373 = 0; _i373 < _size368; ++_i373) + var _etype399 = 0; + _rtmp3400 = input.readListBegin(); + _etype399 = _rtmp3400.etype; + _size396 = _rtmp3400.size; + for (var _i401 = 0; _i401 < _size396; ++_i401) { - var elem374 = null; - elem374 = input.readString().value; - this.success.push(elem374); + var elem402 = null; + elem402 = input.readString().value; + this.success.push(elem402); } input.readListEnd(); } else { @@ -4771,12 +4893,12 @@ Blur_shardServerList_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.LIST, 0); output.writeListBegin(Thrift.Type.STRING, this.success.length); - for (var iter375 in this.success) + for (var iter403 in this.success) { - if (this.success.hasOwnProperty(iter375)) + if (this.success.hasOwnProperty(iter403)) { - iter375 = this.success[iter375]; - output.writeString(iter375); + iter403 = this.success[iter403]; + output.writeString(iter403); } } output.writeListEnd(); @@ -4852,18 +4974,18 @@ Blur_controllerServerList_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size376 = 0; - var _rtmp3380; + var _size404 = 0; + var _rtmp3408; this.success = []; - var _etype379 = 0; - _rtmp3380 = input.readListBegin(); - _etype379 = _rtmp3380.etype; - _size376 = _rtmp3380.size; - for (var _i381 = 0; _i381 < _size376; ++_i381) + var _etype407 = 0; + _rtmp3408 = input.readListBegin(); + _etype407 = _rtmp3408.etype; + _size404 = _rtmp3408.size; + for (var _i409 = 0; _i409 < _size404; ++_i409) { - var elem382 = null; - elem382 = input.readString().value; - this.success.push(elem382); + var elem410 = null; + elem410 = input.readString().value; + this.success.push(elem410); } input.readListEnd(); } else { @@ -4892,12 +5014,12 @@ Blur_controllerServerList_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.LIST, 0); output.writeListBegin(Thrift.Type.STRING, this.success.length); - for (var iter383 in this.success) + for (var iter411 in this.success) { - if (this.success.hasOwnProperty(iter383)) + if (this.success.hasOwnProperty(iter411)) { - iter383 = this.success[iter383]; - output.writeString(iter383); + iter411 = this.success[iter411]; + output.writeString(iter411); } } output.writeListEnd(); @@ -4998,27 +5120,27 @@ Blur_shardServerLayout_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.MAP) { - var _size384 = 0; - var _rtmp3388; + var _size412 = 0; + var _rtmp3416; this.success = {}; - var _ktype385 = 0; - var _vtype386 = 0; - _rtmp3388 = input.readMapBegin(); - _ktype385 = _rtmp3388.ktype; - _vtype386 = _rtmp3388.vtype; - _size384 = _rtmp3388.size; - for (var _i389 = 0; _i389 < _size384; ++_i389) + var _ktype413 = 0; + var _vtype414 = 0; + _rtmp3416 = input.readMapBegin(); + _ktype413 = _rtmp3416.ktype; + _vtype414 = _rtmp3416.vtype; + _size412 = _rtmp3416.size; + for (var _i417 = 0; _i417 < _size412; ++_i417) { - if (_i389 > 0 ) { + if (_i417 > 0 ) { if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { input.rstack.pop(); } } - var key390 = null; - var val391 = null; - key390 = input.readString().value; - val391 = input.readString().value; - this.success[key390] = val391; + var key418 = null; + var val419 = null; + key418 = input.readString().value; + val419 = input.readString().value; + this.success[key418] = val419; } input.readMapEnd(); } else { @@ -5047,13 +5169,13 @@ Blur_shardServerLayout_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.MAP, 0); output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.STRING, Thrift.objectLength(this.success)); - for (var kiter392 in this.success) + for (var kiter420 in this.success) { - if (this.success.hasOwnProperty(kiter392)) + if (this.success.hasOwnProperty(kiter420)) { - var viter393 = this.success[kiter392]; - output.writeString(kiter392); - output.writeString(viter393); + var viter421 = this.success[kiter420]; + output.writeString(kiter420); + output.writeString(viter421); } } output.writeMapEnd(); @@ -5154,49 +5276,49 @@ Blur_shardServerLayoutState_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.MAP) { - var _size394 = 0; - var _rtmp3398; + var _size422 = 0; + var _rtmp3426; this.success = {}; - var _ktype395 = 0; - var _vtype396 = 0; - _rtmp3398 = input.readMapBegin(); - _ktype395 = _rtmp3398.ktype; - _vtype396 = _rtmp3398.vtype; - _size394 = _rtmp3398.size; - for (var _i399 = 0; _i399 < _size394; ++_i399) + var _ktype423 = 0; + var _vtype424 = 0; + _rtmp3426 = input.readMapBegin(); + _ktype423 = _rtmp3426.ktype; + _vtype424 = _rtmp3426.vtype; + _size422 = _rtmp3426.size; + for (var _i427 = 0; _i427 < _size422; ++_i427) { - if (_i399 > 0 ) { + if (_i427 > 0 ) { if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { input.rstack.pop(); } } - var key400 = null; - var val401 = null; - key400 = input.readString().value; - var _size402 = 0; - var _rtmp3406; - val401 = {}; - var _ktype403 = 0; - var _vtype404 = 0; - _rtmp3406 = input.readMapBegin(); - _ktype403 = _rtmp3406.ktype; - _vtype404 = _rtmp3406.vtype; - _size402 = _rtmp3406.size; - for (var _i407 = 0; _i407 < _size402; ++_i407) + var key428 = null; + var val429 = null; + key428 = input.readString().value; + var _size430 = 0; + var _rtmp3434; + val429 = {}; + var _ktype431 = 0; + var _vtype432 = 0; + _rtmp3434 = input.readMapBegin(); + _ktype431 = _rtmp3434.ktype; + _vtype432 = _rtmp3434.vtype; + _size430 = _rtmp3434.size; + for (var _i435 = 0; _i435 < _size430; ++_i435) { - if (_i407 > 0 ) { + if (_i435 > 0 ) { if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { input.rstack.pop(); } } - var key408 = null; - var val409 = null; - key408 = input.readString().value; - val409 = input.readI32().value; - val401[key408] = val409; + var key436 = null; + var val437 = null; + key436 = input.readString().value; + val437 = input.readI32().value; + val429[key436] = val437; } input.readMapEnd(); - this.success[key400] = val401; + this.success[key428] = val429; } input.readMapEnd(); } else { @@ -5225,20 +5347,20 @@ Blur_shardServerLayoutState_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.MAP, 0); output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.MAP, Thrift.objectLength(this.success)); - for (var kiter410 in this.success) + for (var kiter438 in this.success) { - if (this.success.hasOwnProperty(kiter410)) + if (this.success.hasOwnProperty(kiter438)) { - var viter411 = this.success[kiter410]; - output.writeString(kiter410); - output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.I32, Thrift.objectLength(viter411)); - for (var kiter412 in viter411) + var viter439 = this.success[kiter438]; + output.writeString(kiter438); + output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.I32, Thrift.objectLength(viter439)); + for (var kiter440 in viter439) { - if (viter411.hasOwnProperty(kiter412)) + if (viter439.hasOwnProperty(kiter440)) { - var viter413 = viter411[kiter412]; - output.writeString(kiter412); - output.writeI32(viter413); + var viter441 = viter439[kiter440]; + output.writeString(kiter440); + output.writeI32(viter441); } } output.writeMapEnd(); @@ -5441,27 +5563,27 @@ Blur_configuration_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.MAP) { - var _size414 = 0; - var _rtmp3418; + var _size442 = 0; + var _rtmp3446; this.success = {}; - var _ktype415 = 0; - var _vtype416 = 0; - _rtmp3418 = input.readMapBegin(); - _ktype415 = _rtmp3418.ktype; - _vtype416 = _rtmp3418.vtype; - _size414 = _rtmp3418.size; - for (var _i419 = 0; _i419 < _size414; ++_i419) + var _ktype443 = 0; + var _vtype444 = 0; + _rtmp3446 = input.readMapBegin(); + _ktype443 = _rtmp3446.ktype; + _vtype444 = _rtmp3446.vtype; + _size442 = _rtmp3446.size; + for (var _i447 = 0; _i447 < _size442; ++_i447) { - if (_i419 > 0 ) { + if (_i447 > 0 ) { if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { input.rstack.pop(); } } - var key420 = null; - var val421 = null; - key420 = input.readString().value; - val421 = input.readString().value; - this.success[key420] = val421; + var key448 = null; + var val449 = null; + key448 = input.readString().value; + val449 = input.readString().value; + this.success[key448] = val449; } input.readMapEnd(); } else { @@ -5490,13 +5612,13 @@ Blur_configuration_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.MAP, 0); output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.STRING, Thrift.objectLength(this.success)); - for (var kiter422 in this.success) + for (var kiter450 in this.success) { - if (this.success.hasOwnProperty(kiter422)) + if (this.success.hasOwnProperty(kiter450)) { - var viter423 = this.success[kiter422]; - output.writeString(kiter422); - output.writeString(viter423); + var viter451 = this.success[kiter450]; + output.writeString(kiter450); + output.writeString(viter451); } } output.writeMapEnd(); @@ -5536,18 +5658,18 @@ Blur_metrics_args.prototype.read = function(input) { { case 1: if (ftype == Thrift.Type.SET) { - var _size424 = 0; - var _rtmp3428; + var _size452 = 0; + var _rtmp3456; this.metrics = []; - var _etype427 = 0; - _rtmp3428 = input.readSetBegin(); - _etype427 = _rtmp3428.etype; - _size424 = _rtmp3428.size; - for (var _i429 = 0; _i429 < _size424; ++_i429) + var _etype455 = 0; + _rtmp3456 = input.readSetBegin(); + _etype455 = _rtmp3456.etype; + _size452 = _rtmp3456.size; + for (var _i457 = 0; _i457 < _size452; ++_i457) { - var elem430 = null; - elem430 = input.readString().value; - this.metrics.push(elem430); + var elem458 = null; + elem458 = input.readString().value; + this.metrics.push(elem458); } input.readSetEnd(); } else { @@ -5571,12 +5693,12 @@ Blur_metrics_args.prototype.write = function(output) { if (this.metrics !== null && this.metrics !== undefined) { output.writeFieldBegin('metrics', Thrift.Type.SET, 1); output.writeSetBegin(Thrift.Type.STRING, this.metrics.length); - for (var iter431 in this.metrics) + for (var iter459 in this.metrics) { - if (this.metrics.hasOwnProperty(iter431)) + if (this.metrics.hasOwnProperty(iter459)) { - iter431 = this.metrics[iter431]; - output.writeString(iter431); + iter459 = this.metrics[iter459]; + output.writeString(iter459); } } output.writeSetEnd(); @@ -5619,28 +5741,28 @@ Blur_metrics_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.MAP) { - var _size432 = 0; - var _rtmp3436; + var _size460 = 0; + var _rtmp3464; this.success = {}; - var _ktype433 = 0; - var _vtype434 = 0; - _rtmp3436 = input.readMapBegin(); - _ktype433 = _rtmp3436.ktype; - _vtype434 = _rtmp3436.vtype; - _size432 = _rtmp3436.size; - for (var _i437 = 0; _i437 < _size432; ++_i437) + var _ktype461 = 0; + var _vtype462 = 0; + _rtmp3464 = input.readMapBegin(); + _ktype461 = _rtmp3464.ktype; + _vtype462 = _rtmp3464.vtype; + _size460 = _rtmp3464.size; + for (var _i465 = 0; _i465 < _size460; ++_i465) { - if (_i437 > 0 ) { + if (_i465 > 0 ) { if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { input.rstack.pop(); } } - var key438 = null; - var val439 = null; - key438 = input.readString().value; - val439 = new Metric(); - val439.read(input); - this.success[key438] = val439; + var key466 = null; + var val467 = null; + key466 = input.readString().value; + val467 = new Metric(); + val467.read(input); + this.success[key466] = val467; } input.readMapEnd(); } else { @@ -5669,13 +5791,13 @@ Blur_metrics_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.MAP, 0); output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.STRUCT, Thrift.objectLength(this.success)); - for (var kiter440 in this.success) + for (var kiter468 in this.success) { - if (this.success.hasOwnProperty(kiter440)) + if (this.success.hasOwnProperty(kiter468)) { - var viter441 = this.success[kiter440]; - output.writeString(kiter440); - viter441.write(output); + var viter469 = this.success[kiter468]; + output.writeString(kiter468); + viter469.write(output); } } output.writeMapEnd(); @@ -5845,18 +5967,18 @@ Blur_traceList_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size442 = 0; - var _rtmp3446; + var _size470 = 0; + var _rtmp3474; this.success = []; - var _etype445 = 0; - _rtmp3446 = input.readListBegin(); - _etype445 = _rtmp3446.etype; - _size442 = _rtmp3446.size; - for (var _i447 = 0; _i447 < _size442; ++_i447) + var _etype473 = 0; + _rtmp3474 = input.readListBegin(); + _etype473 = _rtmp3474.etype; + _size470 = _rtmp3474.size; + for (var _i475 = 0; _i475 < _size470; ++_i475) { - var elem448 = null; - elem448 = input.readString().value; - this.success.push(elem448); + var elem476 = null; + elem476 = input.readString().value; + this.success.push(elem476); } input.readListEnd(); } else { @@ -5885,12 +6007,12 @@ Blur_traceList_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.LIST, 0); output.writeListBegin(Thrift.Type.STRING, this.success.length); - for (var iter449 in this.success) + for (var iter477 in this.success) { - if (this.success.hasOwnProperty(iter449)) + if (this.success.hasOwnProperty(iter477)) { - iter449 = this.success[iter449]; - output.writeString(iter449); + iter477 = this.success[iter477]; + output.writeString(iter477); } } output.writeListEnd(); @@ -5991,18 +6113,18 @@ Blur_traceRequestList_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size450 = 0; - var _rtmp3454; + var _size478 = 0; + var _rtmp3482; this.success = []; - var _etype453 = 0; - _rtmp3454 = input.readListBegin(); - _etype453 = _rtmp3454.etype; - _size450 = _rtmp3454.size; - for (var _i455 = 0; _i455 < _size450; ++_i455) + var _etype481 = 0; + _rtmp3482 = input.readListBegin(); + _etype481 = _rtmp3482.etype; + _size478 = _rtmp3482.size; + for (var _i483 = 0; _i483 < _size478; ++_i483) { - var elem456 = null; - elem456 = input.readString().value; - this.success.push(elem456); + var elem484 = null; + elem484 = input.readString().value; + this.success.push(elem484); } input.readListEnd(); } else { @@ -6031,12 +6153,12 @@ Blur_traceRequestList_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.LIST, 0); output.writeListBegin(Thrift.Type.STRING, this.success.length); - for (var iter457 in this.success) + for (var iter485 in this.success) { - if (this.success.hasOwnProperty(iter457)) + if (this.success.hasOwnProperty(iter485)) { - iter457 = this.success[iter457]; - output.writeString(iter457); + iter485 = this.success[iter485]; + output.writeString(iter485); } } output.writeListEnd(); @@ -6572,6 +6694,42 @@ BlurClient = function(input, output) { this.seqid = 0; }; BlurClient.prototype = {}; +BlurClient.prototype.listInstalledCommands = function() { + this.send_listInstalledCommands(); + return this.recv_listInstalledCommands(); +}; + +BlurClient.prototype.send_listInstalledCommands = function() { + this.output.writeMessageBegin('listInstalledCommands', Thrift.MessageType.CALL, this.seqid); + var args = new Blur_listInstalledCommands_args(); + args.write(this.output); + this.output.writeMessageEnd(); + return this.output.getTransport().flush(); +}; + +BlurClient.prototype.recv_listInstalledCommands = function() { + var ret = this.input.readMessageBegin(); + var fname = ret.fname; + var mtype = ret.mtype; + var rseqid = ret.rseqid; + if (mtype == Thrift.MessageType.EXCEPTION) { + var x = new Thrift.TApplicationException(); + x.read(this.input); + this.input.readMessageEnd(); + throw x; + } + var result = new Blur_listInstalledCommands_result(); + result.read(this.input); + this.input.readMessageEnd(); + + if (null !== result.ex) { + throw result.ex; + } + if (null !== result.success) { + return result.success; + } + throw 'listInstalledCommands failed: unknown result'; +}; BlurClient.prototype.execute = function(commandName, arguments) { this.send_execute(commandName, arguments); return this.recv_execute();
