http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/77a4f849/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/CommandStatus.java ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/CommandStatus.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/CommandStatus.java new file mode 100644 index 0000000..0c0d422 --- /dev/null +++ b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/CommandStatus.java @@ -0,0 +1,826 @@ +/** + * 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 CommandStatus implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<CommandStatus, CommandStatus._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("CommandStatus"); + + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField EXECUTION_ID_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("executionId", 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 TABLE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("table", 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 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)3); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField ARGUMENTS_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("arguments", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, (short)4); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField STATE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("state", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32, (short)5); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new CommandStatusStandardSchemeFactory()); + schemes.put(TupleScheme.class, new CommandStatusTupleSchemeFactory()); + } + + public String executionId; // required + public String table; // required + public String commandName; // required + public Arguments arguments; // required + /** + * + * @see CommandStatusState + */ + public CommandStatusState state; // 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 { + EXECUTION_ID((short)1, "executionId"), + TABLE((short)2, "table"), + COMMAND_NAME((short)3, "commandName"), + ARGUMENTS((short)4, "arguments"), + /** + * + * @see CommandStatusState + */ + STATE((short)5, "state"); + + 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: // EXECUTION_ID + return EXECUTION_ID; + case 2: // TABLE + return TABLE; + case 3: // COMMAND_NAME + return COMMAND_NAME; + case 4: // ARGUMENTS + return ARGUMENTS; + case 5: // STATE + return STATE; + 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.EXECUTION_ID, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("executionId", 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.TABLE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("table", 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.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.ARGUMENTS, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("arguments", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.StructMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, Arguments.class))); + tmpMap.put(_Fields.STATE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("state", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.EnumMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.ENUM, CommandStatusState.class))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(CommandStatus.class, metaDataMap); + } + + public CommandStatus() { + } + + public CommandStatus( + String executionId, + String table, + String commandName, + Arguments arguments, + CommandStatusState state) + { + this(); + this.executionId = executionId; + this.table = table; + this.commandName = commandName; + this.arguments = arguments; + this.state = state; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public CommandStatus(CommandStatus other) { + if (other.isSetExecutionId()) { + this.executionId = other.executionId; + } + if (other.isSetTable()) { + this.table = other.table; + } + if (other.isSetCommandName()) { + this.commandName = other.commandName; + } + if (other.isSetArguments()) { + this.arguments = new Arguments(other.arguments); + } + if (other.isSetState()) { + this.state = other.state; + } + } + + public CommandStatus deepCopy() { + return new CommandStatus(this); + } + + @Override + public void clear() { + this.executionId = null; + this.table = null; + this.commandName = null; + this.arguments = null; + this.state = null; + } + + public String getExecutionId() { + return this.executionId; + } + + public CommandStatus setExecutionId(String executionId) { + this.executionId = executionId; + return this; + } + + public void unsetExecutionId() { + this.executionId = null; + } + + /** Returns true if field executionId is set (has been assigned a value) and false otherwise */ + public boolean isSetExecutionId() { + return this.executionId != null; + } + + public void setExecutionIdIsSet(boolean value) { + if (!value) { + this.executionId = null; + } + } + + public String getTable() { + return this.table; + } + + public CommandStatus setTable(String table) { + this.table = table; + return this; + } + + public void unsetTable() { + this.table = null; + } + + /** Returns true if field table is set (has been assigned a value) and false otherwise */ + public boolean isSetTable() { + return this.table != null; + } + + public void setTableIsSet(boolean value) { + if (!value) { + this.table = null; + } + } + + public String getCommandName() { + return this.commandName; + } + + public CommandStatus 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 Arguments getArguments() { + return this.arguments; + } + + public CommandStatus setArguments(Arguments arguments) { + this.arguments = arguments; + return this; + } + + public void unsetArguments() { + this.arguments = null; + } + + /** Returns true if field arguments is set (has been assigned a value) and false otherwise */ + public boolean isSetArguments() { + return this.arguments != null; + } + + public void setArgumentsIsSet(boolean value) { + if (!value) { + this.arguments = null; + } + } + + /** + * + * @see CommandStatusState + */ + public CommandStatusState getState() { + return this.state; + } + + /** + * + * @see CommandStatusState + */ + public CommandStatus setState(CommandStatusState state) { + this.state = state; + return this; + } + + public void unsetState() { + this.state = null; + } + + /** Returns true if field state is set (has been assigned a value) and false otherwise */ + public boolean isSetState() { + return this.state != null; + } + + public void setStateIsSet(boolean value) { + if (!value) { + this.state = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case EXECUTION_ID: + if (value == null) { + unsetExecutionId(); + } else { + setExecutionId((String)value); + } + break; + + case TABLE: + if (value == null) { + unsetTable(); + } else { + setTable((String)value); + } + break; + + case COMMAND_NAME: + if (value == null) { + unsetCommandName(); + } else { + setCommandName((String)value); + } + break; + + case ARGUMENTS: + if (value == null) { + unsetArguments(); + } else { + setArguments((Arguments)value); + } + break; + + case STATE: + if (value == null) { + unsetState(); + } else { + setState((CommandStatusState)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case EXECUTION_ID: + return getExecutionId(); + + case TABLE: + return getTable(); + + case COMMAND_NAME: + return getCommandName(); + + case ARGUMENTS: + return getArguments(); + + case STATE: + return getState(); + + } + 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 EXECUTION_ID: + return isSetExecutionId(); + case TABLE: + return isSetTable(); + case COMMAND_NAME: + return isSetCommandName(); + case ARGUMENTS: + return isSetArguments(); + case STATE: + return isSetState(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof CommandStatus) + return this.equals((CommandStatus)that); + return false; + } + + public boolean equals(CommandStatus that) { + if (that == null) + return false; + + boolean this_present_executionId = true && this.isSetExecutionId(); + boolean that_present_executionId = true && that.isSetExecutionId(); + if (this_present_executionId || that_present_executionId) { + if (!(this_present_executionId && that_present_executionId)) + return false; + if (!this.executionId.equals(that.executionId)) + return false; + } + + boolean this_present_table = true && this.isSetTable(); + boolean that_present_table = true && that.isSetTable(); + if (this_present_table || that_present_table) { + if (!(this_present_table && that_present_table)) + return false; + if (!this.table.equals(that.table)) + 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_arguments = true && this.isSetArguments(); + boolean that_present_arguments = true && that.isSetArguments(); + if (this_present_arguments || that_present_arguments) { + if (!(this_present_arguments && that_present_arguments)) + return false; + if (!this.arguments.equals(that.arguments)) + return false; + } + + boolean this_present_state = true && this.isSetState(); + boolean that_present_state = true && that.isSetState(); + if (this_present_state || that_present_state) { + if (!(this_present_state && that_present_state)) + return false; + if (!this.state.equals(that.state)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + return 0; + } + + public int compareTo(CommandStatus other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + CommandStatus typedOther = (CommandStatus)other; + + lastComparison = Boolean.valueOf(isSetExecutionId()).compareTo(typedOther.isSetExecutionId()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetExecutionId()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.executionId, typedOther.executionId); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetTable()).compareTo(typedOther.isSetTable()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetTable()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.table, typedOther.table); + if (lastComparison != 0) { + return lastComparison; + } + } + 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(isSetArguments()).compareTo(typedOther.isSetArguments()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetArguments()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.arguments, typedOther.arguments); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetState()).compareTo(typedOther.isSetState()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetState()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.state, typedOther.state); + 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("CommandStatus("); + boolean first = true; + + sb.append("executionId:"); + if (this.executionId == null) { + sb.append("null"); + } else { + sb.append(this.executionId); + } + first = false; + if (!first) sb.append(", "); + sb.append("table:"); + if (this.table == null) { + sb.append("null"); + } else { + sb.append(this.table); + } + first = false; + if (!first) sb.append(", "); + sb.append("commandName:"); + if (this.commandName == null) { + sb.append("null"); + } else { + sb.append(this.commandName); + } + first = false; + if (!first) sb.append(", "); + sb.append("arguments:"); + if (this.arguments == null) { + sb.append("null"); + } else { + sb.append(this.arguments); + } + first = false; + if (!first) sb.append(", "); + sb.append("state:"); + if (this.state == null) { + sb.append("null"); + } else { + sb.append(this.state); + } + 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 + if (arguments != null) { + arguments.validate(); + } + } + + 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 CommandStatusStandardSchemeFactory implements SchemeFactory { + public CommandStatusStandardScheme getScheme() { + return new CommandStatusStandardScheme(); + } + } + + private static class CommandStatusStandardScheme extends StandardScheme<CommandStatus> { + + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, CommandStatus 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: // EXECUTION_ID + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING) { + struct.executionId = iprot.readString(); + struct.setExecutionIdIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // TABLE + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING) { + struct.table = iprot.readString(); + struct.setTableIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 3: // 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 4: // ARGUMENTS + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT) { + struct.arguments = new Arguments(); + struct.arguments.read(iprot); + struct.setArgumentsIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 5: // STATE + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32) { + struct.state = CommandStatusState.findByValue(iprot.readI32()); + struct.setStateIsSet(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, CommandStatus struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.executionId != null) { + oprot.writeFieldBegin(EXECUTION_ID_FIELD_DESC); + oprot.writeString(struct.executionId); + oprot.writeFieldEnd(); + } + if (struct.table != null) { + oprot.writeFieldBegin(TABLE_FIELD_DESC); + oprot.writeString(struct.table); + oprot.writeFieldEnd(); + } + if (struct.commandName != null) { + oprot.writeFieldBegin(COMMAND_NAME_FIELD_DESC); + oprot.writeString(struct.commandName); + oprot.writeFieldEnd(); + } + if (struct.arguments != null) { + oprot.writeFieldBegin(ARGUMENTS_FIELD_DESC); + struct.arguments.write(oprot); + oprot.writeFieldEnd(); + } + if (struct.state != null) { + oprot.writeFieldBegin(STATE_FIELD_DESC); + oprot.writeI32(struct.state.getValue()); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class CommandStatusTupleSchemeFactory implements SchemeFactory { + public CommandStatusTupleScheme getScheme() { + return new CommandStatusTupleScheme(); + } + } + + private static class CommandStatusTupleScheme extends TupleScheme<CommandStatus> { + + @Override + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, CommandStatus struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetExecutionId()) { + optionals.set(0); + } + if (struct.isSetTable()) { + optionals.set(1); + } + if (struct.isSetCommandName()) { + optionals.set(2); + } + if (struct.isSetArguments()) { + optionals.set(3); + } + if (struct.isSetState()) { + optionals.set(4); + } + oprot.writeBitSet(optionals, 5); + if (struct.isSetExecutionId()) { + oprot.writeString(struct.executionId); + } + if (struct.isSetTable()) { + oprot.writeString(struct.table); + } + if (struct.isSetCommandName()) { + oprot.writeString(struct.commandName); + } + if (struct.isSetArguments()) { + struct.arguments.write(oprot); + } + if (struct.isSetState()) { + oprot.writeI32(struct.state.getValue()); + } + } + + @Override + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, CommandStatus struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(5); + if (incoming.get(0)) { + struct.executionId = iprot.readString(); + struct.setExecutionIdIsSet(true); + } + if (incoming.get(1)) { + struct.table = iprot.readString(); + struct.setTableIsSet(true); + } + if (incoming.get(2)) { + struct.commandName = iprot.readString(); + struct.setCommandNameIsSet(true); + } + if (incoming.get(3)) { + struct.arguments = new Arguments(); + struct.arguments.read(iprot); + struct.setArgumentsIsSet(true); + } + if (incoming.get(4)) { + struct.state = CommandStatusState.findByValue(iprot.readI32()); + struct.setStateIsSet(true); + } + } + } + +} +
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/77a4f849/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/CommandStatusState.java ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/CommandStatusState.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/CommandStatusState.java new file mode 100644 index 0000000..4acdf8f --- /dev/null +++ b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/CommandStatusState.java @@ -0,0 +1,70 @@ +/** + * 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 java.util.Map; +import java.util.HashMap; +import org.apache.blur.thirdparty.thrift_0_9_0.TEnum; + +public enum CommandStatusState implements org.apache.blur.thirdparty.thrift_0_9_0.TEnum { + RUNNING(0), + INTERRUPTED(1), + COMPLETE(2), + BACK_PRESSURE_INTERRUPTED(3); + + private final int value; + + private CommandStatusState(int value) { + this.value = value; + } + + /** + * Get the integer value of this enum value, as defined in the Thrift IDL. + */ + public int getValue() { + return value; + } + + /** + * Find a the enum type by its integer value, as defined in the Thrift IDL. + * @return null if the value is not found. + */ + public static CommandStatusState findByValue(int value) { + switch (value) { + case 0: + return RUNNING; + case 1: + return INTERRUPTED; + case 2: + return COMPLETE; + case 3: + return BACK_PRESSURE_INTERRUPTED; + default: + return null; + } + } +} http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/77a4f849/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 863826e..2e075d4 100644 --- a/distribution/src/main/scripts/interface/gen-js/Blur.js +++ b/distribution/src/main/scripts/interface/gen-js/Blur.js @@ -329,6 +329,417 @@ Blur_reconnect_result.prototype.write = function(output) { return; }; +Blur_commandStatusList_args = function(args) { + this.startingAt = null; + this.fetch = null; + this.state = null; + if (args) { + if (args.startingAt !== undefined) { + this.startingAt = args.startingAt; + } + if (args.fetch !== undefined) { + this.fetch = args.fetch; + } + if (args.state !== undefined) { + this.state = args.state; + } + } +}; +Blur_commandStatusList_args.prototype = {}; +Blur_commandStatusList_args.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.I32) { + this.startingAt = input.readI32().value; + } else { + input.skip(ftype); + } + break; + case 2: + if (ftype == Thrift.Type.I16) { + this.fetch = input.readI16().value; + } else { + input.skip(ftype); + } + break; + case 3: + if (ftype == Thrift.Type.I32) { + this.state = input.readI32().value; + } else { + input.skip(ftype); + } + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +Blur_commandStatusList_args.prototype.write = function(output) { + output.writeStructBegin('Blur_commandStatusList_args'); + if (this.startingAt !== null && this.startingAt !== undefined) { + output.writeFieldBegin('startingAt', Thrift.Type.I32, 1); + output.writeI32(this.startingAt); + output.writeFieldEnd(); + } + if (this.fetch !== null && this.fetch !== undefined) { + output.writeFieldBegin('fetch', Thrift.Type.I16, 2); + output.writeI16(this.fetch); + output.writeFieldEnd(); + } + if (this.state !== null && this.state !== undefined) { + output.writeFieldBegin('state', Thrift.Type.I32, 3); + output.writeI32(this.state); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +Blur_commandStatusList_result = function(args) { + this.success = null; + this.ex = null; + if (args instanceof BlurException) { + this.ex = args; + return; + } + if (args) { + if (args.success !== undefined) { + this.success = args.success; + } + if (args.ex !== undefined) { + this.ex = args.ex; + } + } +}; +Blur_commandStatusList_result.prototype = {}; +Blur_commandStatusList_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 _size270 = 0; + var _rtmp3274; + this.success = []; + var _etype273 = 0; + _rtmp3274 = input.readListBegin(); + _etype273 = _rtmp3274.etype; + _size270 = _rtmp3274.size; + for (var _i275 = 0; _i275 < _size270; ++_i275) + { + var elem276 = null; + elem276 = input.readString().value; + this.success.push(elem276); + } + 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_commandStatusList_result.prototype.write = function(output) { + output.writeStructBegin('Blur_commandStatusList_result'); + if (this.success !== null && this.success !== undefined) { + output.writeFieldBegin('success', Thrift.Type.LIST, 0); + output.writeListBegin(Thrift.Type.STRING, this.success.length); + for (var iter277 in this.success) + { + if (this.success.hasOwnProperty(iter277)) + { + iter277 = this.success[iter277]; + output.writeString(iter277); + } + } + 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_commandStatus_args = function(args) { + this.executionId = null; + if (args) { + if (args.executionId !== undefined) { + this.executionId = args.executionId; + } + } +}; +Blur_commandStatus_args.prototype = {}; +Blur_commandStatus_args.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.STRING) { + this.executionId = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 0: + input.skip(ftype); + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +Blur_commandStatus_args.prototype.write = function(output) { + output.writeStructBegin('Blur_commandStatus_args'); + if (this.executionId !== null && this.executionId !== undefined) { + output.writeFieldBegin('executionId', Thrift.Type.STRING, 1); + output.writeString(this.executionId); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +Blur_commandStatus_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_commandStatus_result.prototype = {}; +Blur_commandStatus_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.STRUCT) { + this.success = new CommandStatus(); + this.success.read(input); + } 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_commandStatus_result.prototype.write = function(output) { + output.writeStructBegin('Blur_commandStatus_result'); + if (this.success !== null && this.success !== undefined) { + output.writeFieldBegin('success', Thrift.Type.STRUCT, 0); + this.success.write(output); + output.writeFieldEnd(); + } + if (this.ex !== null && this.ex !== undefined) { + output.writeFieldBegin('ex', Thrift.Type.STRUCT, 1); + this.ex.write(output); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +Blur_commandCancel_args = function(args) { + this.executionId = null; + if (args) { + if (args.executionId !== undefined) { + this.executionId = args.executionId; + } + } +}; +Blur_commandCancel_args.prototype = {}; +Blur_commandCancel_args.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.STRING) { + this.executionId = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 0: + input.skip(ftype); + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +Blur_commandCancel_args.prototype.write = function(output) { + output.writeStructBegin('Blur_commandCancel_args'); + if (this.executionId !== null && this.executionId !== undefined) { + output.writeFieldBegin('executionId', Thrift.Type.STRING, 1); + output.writeString(this.executionId); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +Blur_commandCancel_result = function(args) { + this.ex = null; + if (args instanceof BlurException) { + this.ex = args; + return; + } + if (args) { + if (args.ex !== undefined) { + this.ex = args.ex; + } + } +}; +Blur_commandCancel_result.prototype = {}; +Blur_commandCancel_result.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.STRUCT) { + this.ex = new BlurException(); + this.ex.read(input); + } else { + input.skip(ftype); + } + break; + case 0: + input.skip(ftype); + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +Blur_commandCancel_result.prototype.write = function(output) { + output.writeStructBegin('Blur_commandCancel_result'); + if (this.ex !== null && this.ex !== undefined) { + output.writeFieldBegin('ex', Thrift.Type.STRUCT, 1); + this.ex.write(output); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + Blur_refresh_args = function(args) { }; Blur_refresh_args.prototype = {}; @@ -1041,18 +1452,18 @@ Blur_tableList_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size270 = 0; - var _rtmp3274; + var _size278 = 0; + var _rtmp3282; this.success = []; - var _etype273 = 0; - _rtmp3274 = input.readListBegin(); - _etype273 = _rtmp3274.etype; - _size270 = _rtmp3274.size; - for (var _i275 = 0; _i275 < _size270; ++_i275) + var _etype281 = 0; + _rtmp3282 = input.readListBegin(); + _etype281 = _rtmp3282.etype; + _size278 = _rtmp3282.size; + for (var _i283 = 0; _i283 < _size278; ++_i283) { - var elem276 = null; - elem276 = input.readString().value; - this.success.push(elem276); + var elem284 = null; + elem284 = input.readString().value; + this.success.push(elem284); } input.readListEnd(); } else { @@ -1081,12 +1492,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 iter277 in this.success) + for (var iter285 in this.success) { - if (this.success.hasOwnProperty(iter277)) + if (this.success.hasOwnProperty(iter285)) { - iter277 = this.success[iter277]; - output.writeString(iter277); + iter285 = this.success[iter285]; + output.writeString(iter285); } } output.writeListEnd(); @@ -1187,18 +1598,18 @@ Blur_tableListByCluster_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size278 = 0; - var _rtmp3282; + var _size286 = 0; + var _rtmp3290; this.success = []; - var _etype281 = 0; - _rtmp3282 = input.readListBegin(); - _etype281 = _rtmp3282.etype; - _size278 = _rtmp3282.size; - for (var _i283 = 0; _i283 < _size278; ++_i283) + var _etype289 = 0; + _rtmp3290 = input.readListBegin(); + _etype289 = _rtmp3290.etype; + _size286 = _rtmp3290.size; + for (var _i291 = 0; _i291 < _size286; ++_i291) { - var elem284 = null; - elem284 = input.readString().value; - this.success.push(elem284); + var elem292 = null; + elem292 = input.readString().value; + this.success.push(elem292); } input.readListEnd(); } else { @@ -1227,12 +1638,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 iter285 in this.success) + for (var iter293 in this.success) { - if (this.success.hasOwnProperty(iter285)) + if (this.success.hasOwnProperty(iter293)) { - iter285 = this.success[iter285]; - output.writeString(iter285); + iter293 = this.success[iter293]; + output.writeString(iter293); } } output.writeListEnd(); @@ -2218,40 +2629,40 @@ Blur_listSnapshots_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.MAP) { - var _size286 = 0; - var _rtmp3290; + var _size294 = 0; + var _rtmp3298; this.success = {}; - var _ktype287 = 0; - var _vtype288 = 0; - _rtmp3290 = input.readMapBegin(); - _ktype287 = _rtmp3290.ktype; - _vtype288 = _rtmp3290.vtype; - _size286 = _rtmp3290.size; - for (var _i291 = 0; _i291 < _size286; ++_i291) + 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) { - if (_i291 > 0 ) { + if (_i299 > 0 ) { if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { input.rstack.pop(); } } - var key292 = null; - var val293 = null; - key292 = input.readString().value; - var _size294 = 0; - var _rtmp3298; - val293 = []; - var _etype297 = 0; - _rtmp3298 = input.readListBegin(); - _etype297 = _rtmp3298.etype; - _size294 = _rtmp3298.size; - for (var _i299 = 0; _i299 < _size294; ++_i299) + 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 elem300 = null; - elem300 = input.readString().value; - val293.push(elem300); + var elem308 = null; + elem308 = input.readString().value; + val301.push(elem308); } input.readListEnd(); - this.success[key292] = val293; + this.success[key300] = val301; } input.readMapEnd(); } else { @@ -2280,19 +2691,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 kiter301 in this.success) + for (var kiter309 in this.success) { - if (this.success.hasOwnProperty(kiter301)) + if (this.success.hasOwnProperty(kiter309)) { - var viter302 = this.success[kiter301]; - output.writeString(kiter301); - output.writeListBegin(Thrift.Type.STRING, viter302.length); - for (var iter303 in viter302) + var viter310 = this.success[kiter309]; + output.writeString(kiter309); + output.writeListBegin(Thrift.Type.STRING, viter310.length); + for (var iter311 in viter310) { - if (viter302.hasOwnProperty(iter303)) + if (viter310.hasOwnProperty(iter311)) { - iter303 = viter302[iter303]; - output.writeString(iter303); + iter311 = viter310[iter311]; + output.writeString(iter311); } } output.writeListEnd(); @@ -2706,19 +3117,19 @@ Blur_fetchRowBatch_args.prototype.read = function(input) { break; case 2: if (ftype == Thrift.Type.LIST) { - var _size304 = 0; - var _rtmp3308; + var _size312 = 0; + var _rtmp3316; this.selectors = []; - var _etype307 = 0; - _rtmp3308 = input.readListBegin(); - _etype307 = _rtmp3308.etype; - _size304 = _rtmp3308.size; - for (var _i309 = 0; _i309 < _size304; ++_i309) + var _etype315 = 0; + _rtmp3316 = input.readListBegin(); + _etype315 = _rtmp3316.etype; + _size312 = _rtmp3316.size; + for (var _i317 = 0; _i317 < _size312; ++_i317) { - var elem310 = null; - elem310 = new Selector(); - elem310.read(input); - this.selectors.push(elem310); + var elem318 = null; + elem318 = new Selector(); + elem318.read(input); + this.selectors.push(elem318); } input.readListEnd(); } else { @@ -2744,12 +3155,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 iter311 in this.selectors) + for (var iter319 in this.selectors) { - if (this.selectors.hasOwnProperty(iter311)) + if (this.selectors.hasOwnProperty(iter319)) { - iter311 = this.selectors[iter311]; - iter311.write(output); + iter319 = this.selectors[iter319]; + iter319.write(output); } } output.writeListEnd(); @@ -2792,19 +3203,19 @@ Blur_fetchRowBatch_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size312 = 0; - var _rtmp3316; + var _size320 = 0; + var _rtmp3324; this.success = []; - var _etype315 = 0; - _rtmp3316 = input.readListBegin(); - _etype315 = _rtmp3316.etype; - _size312 = _rtmp3316.size; - for (var _i317 = 0; _i317 < _size312; ++_i317) + var _etype323 = 0; + _rtmp3324 = input.readListBegin(); + _etype323 = _rtmp3324.etype; + _size320 = _rtmp3324.size; + for (var _i325 = 0; _i325 < _size320; ++_i325) { - var elem318 = null; - elem318 = new FetchResult(); - elem318.read(input); - this.success.push(elem318); + var elem326 = null; + elem326 = new FetchResult(); + elem326.read(input); + this.success.push(elem326); } input.readListEnd(); } else { @@ -2833,12 +3244,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 iter319 in this.success) + for (var iter327 in this.success) { - if (this.success.hasOwnProperty(iter319)) + if (this.success.hasOwnProperty(iter327)) { - iter319 = this.success[iter319]; - iter319.write(output); + iter327 = this.success[iter327]; + iter327.write(output); } } output.writeListEnd(); @@ -3102,19 +3513,19 @@ Blur_mutateBatch_args.prototype.read = function(input) { { case 1: if (ftype == Thrift.Type.LIST) { - var _size320 = 0; - var _rtmp3324; + var _size328 = 0; + var _rtmp3332; this.mutations = []; - var _etype323 = 0; - _rtmp3324 = input.readListBegin(); - _etype323 = _rtmp3324.etype; - _size320 = _rtmp3324.size; - for (var _i325 = 0; _i325 < _size320; ++_i325) + var _etype331 = 0; + _rtmp3332 = input.readListBegin(); + _etype331 = _rtmp3332.etype; + _size328 = _rtmp3332.size; + for (var _i333 = 0; _i333 < _size328; ++_i333) { - var elem326 = null; - elem326 = new RowMutation(); - elem326.read(input); - this.mutations.push(elem326); + var elem334 = null; + elem334 = new RowMutation(); + elem334.read(input); + this.mutations.push(elem334); } input.readListEnd(); } else { @@ -3138,12 +3549,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 iter327 in this.mutations) + for (var iter335 in this.mutations) { - if (this.mutations.hasOwnProperty(iter327)) + if (this.mutations.hasOwnProperty(iter335)) { - iter327 = this.mutations[iter327]; - iter327.write(output); + iter335 = this.mutations[iter335]; + iter335.write(output); } } output.writeListEnd(); @@ -3236,19 +3647,19 @@ Blur_enqueueMutateBatch_args.prototype.read = function(input) { { case 1: if (ftype == Thrift.Type.LIST) { - var _size328 = 0; - var _rtmp3332; + var _size336 = 0; + var _rtmp3340; this.mutations = []; - var _etype331 = 0; - _rtmp3332 = input.readListBegin(); - _etype331 = _rtmp3332.etype; - _size328 = _rtmp3332.size; - for (var _i333 = 0; _i333 < _size328; ++_i333) + var _etype339 = 0; + _rtmp3340 = input.readListBegin(); + _etype339 = _rtmp3340.etype; + _size336 = _rtmp3340.size; + for (var _i341 = 0; _i341 < _size336; ++_i341) { - var elem334 = null; - elem334 = new RowMutation(); - elem334.read(input); - this.mutations.push(elem334); + var elem342 = null; + elem342 = new RowMutation(); + elem342.read(input); + this.mutations.push(elem342); } input.readListEnd(); } else { @@ -3272,12 +3683,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 iter335 in this.mutations) + for (var iter343 in this.mutations) { - if (this.mutations.hasOwnProperty(iter335)) + if (this.mutations.hasOwnProperty(iter343)) { - iter335 = this.mutations[iter335]; - iter335.write(output); + iter343 = this.mutations[iter343]; + iter343.write(output); } } output.writeListEnd(); @@ -3555,18 +3966,18 @@ Blur_queryStatusIdList_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size336 = 0; - var _rtmp3340; + var _size344 = 0; + var _rtmp3348; this.success = []; - var _etype339 = 0; - _rtmp3340 = input.readListBegin(); - _etype339 = _rtmp3340.etype; - _size336 = _rtmp3340.size; - for (var _i341 = 0; _i341 < _size336; ++_i341) + var _etype347 = 0; + _rtmp3348 = input.readListBegin(); + _etype347 = _rtmp3348.etype; + _size344 = _rtmp3348.size; + for (var _i349 = 0; _i349 < _size344; ++_i349) { - var elem342 = null; - elem342 = input.readString().value; - this.success.push(elem342); + var elem350 = null; + elem350 = input.readString().value; + this.success.push(elem350); } input.readListEnd(); } else { @@ -3595,12 +4006,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 iter343 in this.success) + for (var iter351 in this.success) { - if (this.success.hasOwnProperty(iter343)) + if (this.success.hasOwnProperty(iter351)) { - iter343 = this.success[iter343]; - output.writeString(iter343); + iter351 = this.success[iter351]; + output.writeString(iter351); } } output.writeListEnd(); @@ -3900,18 +4311,18 @@ Blur_terms_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size344 = 0; - var _rtmp3348; + var _size352 = 0; + var _rtmp3356; this.success = []; - var _etype347 = 0; - _rtmp3348 = input.readListBegin(); - _etype347 = _rtmp3348.etype; - _size344 = _rtmp3348.size; - for (var _i349 = 0; _i349 < _size344; ++_i349) + var _etype355 = 0; + _rtmp3356 = input.readListBegin(); + _etype355 = _rtmp3356.etype; + _size352 = _rtmp3356.size; + for (var _i357 = 0; _i357 < _size352; ++_i357) { - var elem350 = null; - elem350 = input.readString().value; - this.success.push(elem350); + var elem358 = null; + elem358 = input.readString().value; + this.success.push(elem358); } input.readListEnd(); } else { @@ -3940,12 +4351,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 iter351 in this.success) + for (var iter359 in this.success) { - if (this.success.hasOwnProperty(iter351)) + if (this.success.hasOwnProperty(iter359)) { - iter351 = this.success[iter351]; - output.writeString(iter351); + iter359 = this.success[iter359]; + output.writeString(iter359); } } output.writeListEnd(); @@ -4190,18 +4601,18 @@ Blur_shardClusterList_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size352 = 0; - var _rtmp3356; + var _size360 = 0; + var _rtmp3364; this.success = []; - var _etype355 = 0; - _rtmp3356 = input.readListBegin(); - _etype355 = _rtmp3356.etype; - _size352 = _rtmp3356.size; - for (var _i357 = 0; _i357 < _size352; ++_i357) + var _etype363 = 0; + _rtmp3364 = input.readListBegin(); + _etype363 = _rtmp3364.etype; + _size360 = _rtmp3364.size; + for (var _i365 = 0; _i365 < _size360; ++_i365) { - var elem358 = null; - elem358 = input.readString().value; - this.success.push(elem358); + var elem366 = null; + elem366 = input.readString().value; + this.success.push(elem366); } input.readListEnd(); } else { @@ -4230,12 +4641,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 iter359 in this.success) + for (var iter367 in this.success) { - if (this.success.hasOwnProperty(iter359)) + if (this.success.hasOwnProperty(iter367)) { - iter359 = this.success[iter359]; - output.writeString(iter359); + iter367 = this.success[iter367]; + output.writeString(iter367); } } output.writeListEnd(); @@ -4336,18 +4747,18 @@ Blur_shardServerList_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size360 = 0; - var _rtmp3364; + var _size368 = 0; + var _rtmp3372; this.success = []; - var _etype363 = 0; - _rtmp3364 = input.readListBegin(); - _etype363 = _rtmp3364.etype; - _size360 = _rtmp3364.size; - for (var _i365 = 0; _i365 < _size360; ++_i365) + var _etype371 = 0; + _rtmp3372 = input.readListBegin(); + _etype371 = _rtmp3372.etype; + _size368 = _rtmp3372.size; + for (var _i373 = 0; _i373 < _size368; ++_i373) { - var elem366 = null; - elem366 = input.readString().value; - this.success.push(elem366); + var elem374 = null; + elem374 = input.readString().value; + this.success.push(elem374); } input.readListEnd(); } else { @@ -4376,12 +4787,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 iter367 in this.success) + for (var iter375 in this.success) { - if (this.success.hasOwnProperty(iter367)) + if (this.success.hasOwnProperty(iter375)) { - iter367 = this.success[iter367]; - output.writeString(iter367); + iter375 = this.success[iter375]; + output.writeString(iter375); } } output.writeListEnd(); @@ -4457,18 +4868,18 @@ Blur_controllerServerList_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size368 = 0; - var _rtmp3372; + var _size376 = 0; + var _rtmp3380; this.success = []; - var _etype371 = 0; - _rtmp3372 = input.readListBegin(); - _etype371 = _rtmp3372.etype; - _size368 = _rtmp3372.size; - for (var _i373 = 0; _i373 < _size368; ++_i373) + var _etype379 = 0; + _rtmp3380 = input.readListBegin(); + _etype379 = _rtmp3380.etype; + _size376 = _rtmp3380.size; + for (var _i381 = 0; _i381 < _size376; ++_i381) { - var elem374 = null; - elem374 = input.readString().value; - this.success.push(elem374); + var elem382 = null; + elem382 = input.readString().value; + this.success.push(elem382); } input.readListEnd(); } else { @@ -4497,12 +4908,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 iter375 in this.success) + for (var iter383 in this.success) { - if (this.success.hasOwnProperty(iter375)) + if (this.success.hasOwnProperty(iter383)) { - iter375 = this.success[iter375]; - output.writeString(iter375); + iter383 = this.success[iter383]; + output.writeString(iter383); } } output.writeListEnd(); @@ -4603,27 +5014,27 @@ Blur_shardServerLayout_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.MAP) { - var _size376 = 0; - var _rtmp3380; + var _size384 = 0; + var _rtmp3388; this.success = {}; - var _ktype377 = 0; - var _vtype378 = 0; - _rtmp3380 = input.readMapBegin(); - _ktype377 = _rtmp3380.ktype; - _vtype378 = _rtmp3380.vtype; - _size376 = _rtmp3380.size; - for (var _i381 = 0; _i381 < _size376; ++_i381) + 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) { - if (_i381 > 0 ) { + if (_i389 > 0 ) { if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { input.rstack.pop(); } } - var key382 = null; - var val383 = null; - key382 = input.readString().value; - val383 = input.readString().value; - this.success[key382] = val383; + var key390 = null; + var val391 = null; + key390 = input.readString().value; + val391 = input.readString().value; + this.success[key390] = val391; } input.readMapEnd(); } else { @@ -4652,13 +5063,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 kiter384 in this.success) + for (var kiter392 in this.success) { - if (this.success.hasOwnProperty(kiter384)) + if (this.success.hasOwnProperty(kiter392)) { - var viter385 = this.success[kiter384]; - output.writeString(kiter384); - output.writeString(viter385); + var viter393 = this.success[kiter392]; + output.writeString(kiter392); + output.writeString(viter393); } } output.writeMapEnd(); @@ -4759,49 +5170,49 @@ Blur_shardServerLayoutState_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.MAP) { - var _size386 = 0; - var _rtmp3390; + var _size394 = 0; + var _rtmp3398; this.success = {}; - var _ktype387 = 0; - var _vtype388 = 0; - _rtmp3390 = input.readMapBegin(); - _ktype387 = _rtmp3390.ktype; - _vtype388 = _rtmp3390.vtype; - _size386 = _rtmp3390.size; - for (var _i391 = 0; _i391 < _size386; ++_i391) + 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) { - if (_i391 > 0 ) { + if (_i399 > 0 ) { if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { input.rstack.pop(); } } - var key392 = null; - var val393 = null; - key392 = input.readString().value; - var _size394 = 0; - var _rtmp3398; - val393 = {}; - 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 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) { - if (_i399 > 0 ) { + if (_i407 > 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; - val401 = input.readI32().value; - val393[key400] = val401; + var key408 = null; + var val409 = null; + key408 = input.readString().value; + val409 = input.readI32().value; + val401[key408] = val409; } input.readMapEnd(); - this.success[key392] = val393; + this.success[key400] = val401; } input.readMapEnd(); } else { @@ -4830,20 +5241,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 kiter402 in this.success) + for (var kiter410 in this.success) { - if (this.success.hasOwnProperty(kiter402)) + if (this.success.hasOwnProperty(kiter410)) { - var viter403 = this.success[kiter402]; - output.writeString(kiter402); - output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.I32, Thrift.objectLength(viter403)); - for (var kiter404 in viter403) + var viter411 = this.success[kiter410]; + output.writeString(kiter410); + output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.I32, Thrift.objectLength(viter411)); + for (var kiter412 in viter411) { - if (viter403.hasOwnProperty(kiter404)) + if (viter411.hasOwnProperty(kiter412)) { - var viter405 = viter403[kiter404]; - output.writeString(kiter404); - output.writeI32(viter405); + var viter413 = viter411[kiter412]; + output.writeString(kiter412); + output.writeI32(viter413); } } output.writeMapEnd(); @@ -5046,27 +5457,27 @@ Blur_configuration_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.MAP) { - var _size406 = 0; - var _rtmp3410; + var _size414 = 0; + var _rtmp3418; this.success = {}; - var _ktype407 = 0; - var _vtype408 = 0; - _rtmp3410 = input.readMapBegin(); - _ktype407 = _rtmp3410.ktype; - _vtype408 = _rtmp3410.vtype; - _size406 = _rtmp3410.size; - for (var _i411 = 0; _i411 < _size406; ++_i411) + 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) { - if (_i411 > 0 ) { + if (_i419 > 0 ) { if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { input.rstack.pop(); } } - var key412 = null; - var val413 = null; - key412 = input.readString().value; - val413 = input.readString().value; - this.success[key412] = val413; + var key420 = null; + var val421 = null; + key420 = input.readString().value; + val421 = input.readString().value; + this.success[key420] = val421; } input.readMapEnd(); } else { @@ -5095,13 +5506,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 kiter414 in this.success) + for (var kiter422 in this.success) { - if (this.success.hasOwnProperty(kiter414)) + if (this.success.hasOwnProperty(kiter422)) { - var viter415 = this.success[kiter414]; - output.writeString(kiter414); - output.writeString(viter415); + var viter423 = this.success[kiter422]; + output.writeString(kiter422); + output.writeString(viter423); } } output.writeMapEnd(); @@ -5141,18 +5552,18 @@ Blur_metrics_args.prototype.read = function(input) { { case 1: if (ftype == Thrift.Type.SET) { - var _size416 = 0; - var _rtmp3420; + var _size424 = 0; + var _rtmp3428; this.metrics = []; - var _etype419 = 0; - _rtmp3420 = input.readSetBegin(); - _etype419 = _rtmp3420.etype; - _size416 = _rtmp3420.size; - for (var _i421 = 0; _i421 < _size416; ++_i421) + var _etype427 = 0; + _rtmp3428 = input.readSetBegin(); + _etype427 = _rtmp3428.etype; + _size424 = _rtmp3428.size; + for (var _i429 = 0; _i429 < _size424; ++_i429) { - var elem422 = null; - elem422 = input.readString().value; - this.metrics.push(elem422); + var elem430 = null; + elem430 = input.readString().value; + this.metrics.push(elem430); } input.readSetEnd(); } else { @@ -5176,12 +5587,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 iter423 in this.metrics) + for (var iter431 in this.metrics) { - if (this.metrics.hasOwnProperty(iter423)) + if (this.metrics.hasOwnProperty(iter431)) { - iter423 = this.metrics[iter423]; - output.writeString(iter423); + iter431 = this.metrics[iter431]; + output.writeString(iter431); } } output.writeSetEnd(); @@ -5224,28 +5635,28 @@ Blur_metrics_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.MAP) { - var _size424 = 0; - var _rtmp3428; + var _size432 = 0; + var _rtmp3436; this.success = {}; - var _ktype425 = 0; - var _vtype426 = 0; - _rtmp3428 = input.readMapBegin(); - _ktype425 = _rtmp3428.ktype; - _vtype426 = _rtmp3428.vtype; - _size424 = _rtmp3428.size; - for (var _i429 = 0; _i429 < _size424; ++_i429) + 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) { - if (_i429 > 0 ) { + if (_i437 > 0 ) { if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { input.rstack.pop(); } } - var key430 = null; - var val431 = null; - key430 = input.readString().value; - val431 = new Metric(); - val431.read(input); - this.success[key430] = val431; + var key438 = null; + var val439 = null; + key438 = input.readString().value; + val439 = new Metric(); + val439.read(input); + this.success[key438] = val439; } input.readMapEnd(); } else { @@ -5274,13 +5685,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 kiter432 in this.success) + for (var kiter440 in this.success) { - if (this.success.hasOwnProperty(kiter432)) + if (this.success.hasOwnProperty(kiter440)) { - var viter433 = this.success[kiter432]; - output.writeString(kiter432); - viter433.write(output); + var viter441 = this.success[kiter440]; + output.writeString(kiter440); + viter441.write(output); } } output.writeMapEnd(); @@ -5450,18 +5861,18 @@ Blur_traceList_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size434 = 0; - var _rtmp3438; + var _size442 = 0; + var _rtmp3446; this.success = []; - var _etype437 = 0; - _rtmp3438 = input.readListBegin(); - _etype437 = _rtmp3438.etype; - _size434 = _rtmp3438.size; - for (var _i439 = 0; _i439 < _size434; ++_i439) + var _etype445 = 0; + _rtmp3446 = input.readListBegin(); + _etype445 = _rtmp3446.etype; + _size442 = _rtmp3446.size; + for (var _i447 = 0; _i447 < _size442; ++_i447) { - var elem440 = null; - elem440 = input.readString().value; - this.success.push(elem440); + var elem448 = null; + elem448 = input.readString().value; + this.success.push(elem448); } input.readListEnd(); } else { @@ -5490,12 +5901,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 iter441 in this.success) + for (var iter449 in this.success) { - if (this.success.hasOwnProperty(iter441)) + if (this.success.hasOwnProperty(iter449)) { - iter441 = this.success[iter441]; - output.writeString(iter441); + iter449 = this.success[iter449]; + output.writeString(iter449); } } output.writeListEnd(); @@ -5596,18 +6007,18 @@ Blur_traceRequestList_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size442 = 0; - var _rtmp3446; + var _size450 = 0; + var _rtmp3454; this.success = []; - var _etype445 = 0; - _rtmp3446 = input.readListBegin(); - _etype445 = _rtmp3446.etype; - _size442 = _rtmp3446.size; - for (var _i447 = 0; _i447 < _size442; ++_i447) + var _etype453 = 0; + _rtmp3454 = input.readListBegin(); + _etype453 = _rtmp3454.etype; + _size450 = _rtmp3454.size; + for (var _i455 = 0; _i455 < _size450; ++_i455) { - var elem448 = null; - elem448 = input.readString().value; - this.success.push(elem448); + var elem456 = null; + elem456 = input.readString().value; + this.success.push(elem456); } input.readListEnd(); } else { @@ -5636,12 +6047,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 iter449 in this.success) + for (var iter457 in this.success) { - if (this.success.hasOwnProperty(iter449)) + if (this.success.hasOwnProperty(iter457)) { - iter449 = this.success[iter449]; - output.writeString(iter449); + iter457 = this.success[iter457]; + output.writeString(iter457); } } output.writeListEnd(); @@ -6259,6 +6670,116 @@ BlurClient.prototype.recv_reconnect = function() { } throw 'reconnect failed: unknown result'; }; +BlurClient.prototype.commandStatusList = function(startingAt, fetch, state) { + this.send_commandStatusList(startingAt, fetch, state); + return this.recv_commandStatusList(); +}; + +BlurClient.prototype.send_commandStatusList = function(startingAt, fetch, state) { + this.output.writeMessageBegin('commandStatusList', Thrift.MessageType.CALL, this.seqid); + var args = new Blur_commandStatusList_args(); + args.startingAt = startingAt; + args.fetch = fetch; + args.state = state; + args.write(this.output); + this.output.writeMessageEnd(); + return this.output.getTransport().flush(); +}; + +BlurClient.prototype.recv_commandStatusList = 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_commandStatusList_result(); + result.read(this.input); + this.input.readMessageEnd(); + + if (null !== result.ex) { + throw result.ex; + } + if (null !== result.success) { + return result.success; + } + throw 'commandStatusList failed: unknown result'; +}; +BlurClient.prototype.commandStatus = function(executionId) { + this.send_commandStatus(executionId); + return this.recv_commandStatus(); +}; + +BlurClient.prototype.send_commandStatus = function(executionId) { + this.output.writeMessageBegin('commandStatus', Thrift.MessageType.CALL, this.seqid); + var args = new Blur_commandStatus_args(); + args.executionId = executionId; + args.write(this.output); + this.output.writeMessageEnd(); + return this.output.getTransport().flush(); +}; + +BlurClient.prototype.recv_commandStatus = 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_commandStatus_result(); + result.read(this.input); + this.input.readMessageEnd(); + + if (null !== result.ex) { + throw result.ex; + } + if (null !== result.success) { + return result.success; + } + throw 'commandStatus failed: unknown result'; +}; +BlurClient.prototype.commandCancel = function(executionId) { + this.send_commandCancel(executionId); + this.recv_commandCancel(); +}; + +BlurClient.prototype.send_commandCancel = function(executionId) { + this.output.writeMessageBegin('commandCancel', Thrift.MessageType.CALL, this.seqid); + var args = new Blur_commandCancel_args(); + args.executionId = executionId; + args.write(this.output); + this.output.writeMessageEnd(); + return this.output.getTransport().flush(); +}; + +BlurClient.prototype.recv_commandCancel = 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_commandCancel_result(); + result.read(this.input); + this.input.readMessageEnd(); + + if (null !== result.ex) { + throw result.ex; + } + return; +}; BlurClient.prototype.refresh = function() { this.send_refresh(); }; http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/77a4f849/distribution/src/main/scripts/interface/gen-js/Blur_types.js ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-js/Blur_types.js b/distribution/src/main/scripts/interface/gen-js/Blur_types.js index ad22058..5b7fb9e 100644 --- a/distribution/src/main/scripts/interface/gen-js/Blur_types.js +++ b/distribution/src/main/scripts/interface/gen-js/Blur_types.js @@ -62,6 +62,12 @@ BlurObjectType = { 'NAME' : 2, 'VALUE' : 3 }; +CommandStatusState = { +'RUNNING' : 0, +'INTERRUPTED' : 1, +'COMPLETE' : 2, +'BACK_PRESSURE_INTERRUPTED' : 3 +}; BlurException = function(args) { this.message = null; this.stackTraceStr = null; @@ -4410,3 +4416,118 @@ Arguments.prototype.write = function(output) { return; }; +CommandStatus = function(args) { + this.executionId = null; + this.table = null; + this.commandName = null; + this.arguments = null; + this.state = null; + if (args) { + if (args.executionId !== undefined) { + this.executionId = args.executionId; + } + if (args.table !== undefined) { + this.table = args.table; + } + if (args.commandName !== undefined) { + this.commandName = args.commandName; + } + if (args.arguments !== undefined) { + this.arguments = args.arguments; + } + if (args.state !== undefined) { + this.state = args.state; + } + } +}; +CommandStatus.prototype = {}; +CommandStatus.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.executionId = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 2: + if (ftype == Thrift.Type.STRING) { + this.table = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 3: + if (ftype == Thrift.Type.STRING) { + this.commandName = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 4: + if (ftype == Thrift.Type.STRUCT) { + this.arguments = new Arguments(); + this.arguments.read(input); + } else { + input.skip(ftype); + } + break; + case 5: + if (ftype == Thrift.Type.I32) { + this.state = input.readI32().value; + } else { + input.skip(ftype); + } + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +CommandStatus.prototype.write = function(output) { + output.writeStructBegin('CommandStatus'); + if (this.executionId !== null && this.executionId !== undefined) { + output.writeFieldBegin('executionId', Thrift.Type.STRING, 1); + output.writeString(this.executionId); + output.writeFieldEnd(); + } + if (this.table !== null && this.table !== undefined) { + output.writeFieldBegin('table', Thrift.Type.STRING, 2); + output.writeString(this.table); + output.writeFieldEnd(); + } + if (this.commandName !== null && this.commandName !== undefined) { + output.writeFieldBegin('commandName', Thrift.Type.STRING, 3); + output.writeString(this.commandName); + output.writeFieldEnd(); + } + if (this.arguments !== null && this.arguments !== undefined) { + output.writeFieldBegin('arguments', Thrift.Type.STRUCT, 4); + this.arguments.write(output); + output.writeFieldEnd(); + } + if (this.state !== null && this.state !== undefined) { + output.writeFieldBegin('state', Thrift.Type.I32, 5); + output.writeI32(this.state); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; +
