http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/93455749/blur-thrift/src/main/java/org/apache/blur/thrift/generated/CommandRequest.java ---------------------------------------------------------------------- diff --git a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/CommandRequest.java b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/CommandRequest.java deleted file mode 100644 index b7db466..0000000 --- a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/CommandRequest.java +++ /dev/null @@ -1,510 +0,0 @@ -/** - * 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 CommandRequest implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<CommandRequest, CommandRequest._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("CommandRequest"); - - private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField NAME_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("name", 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 TARGET_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("target", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, (short)2); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new CommandRequestStandardSchemeFactory()); - schemes.put(TupleScheme.class, new CommandRequestTupleSchemeFactory()); - } - - public String name; // required - public CommandTarget target; // 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 { - NAME((short)1, "name"), - TARGET((short)2, "target"); - - 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: // NAME - return NAME; - case 2: // TARGET - return TARGET; - 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.NAME, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("name", 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.TARGET, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("target", 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, CommandTarget.class))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(CommandRequest.class, metaDataMap); - } - - public CommandRequest() { - } - - public CommandRequest( - String name, - CommandTarget target) - { - this(); - this.name = name; - this.target = target; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public CommandRequest(CommandRequest other) { - if (other.isSetName()) { - this.name = other.name; - } - if (other.isSetTarget()) { - this.target = new CommandTarget(other.target); - } - } - - public CommandRequest deepCopy() { - return new CommandRequest(this); - } - - @Override - public void clear() { - this.name = null; - this.target = null; - } - - public String getName() { - return this.name; - } - - public CommandRequest setName(String name) { - this.name = name; - return this; - } - - public void unsetName() { - this.name = null; - } - - /** Returns true if field name is set (has been assigned a value) and false otherwise */ - public boolean isSetName() { - return this.name != null; - } - - public void setNameIsSet(boolean value) { - if (!value) { - this.name = null; - } - } - - public CommandTarget getTarget() { - return this.target; - } - - public CommandRequest setTarget(CommandTarget target) { - this.target = target; - return this; - } - - public void unsetTarget() { - this.target = null; - } - - /** Returns true if field target is set (has been assigned a value) and false otherwise */ - public boolean isSetTarget() { - return this.target != null; - } - - public void setTargetIsSet(boolean value) { - if (!value) { - this.target = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case NAME: - if (value == null) { - unsetName(); - } else { - setName((String)value); - } - break; - - case TARGET: - if (value == null) { - unsetTarget(); - } else { - setTarget((CommandTarget)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case NAME: - return getName(); - - case TARGET: - return getTarget(); - - } - 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 NAME: - return isSetName(); - case TARGET: - return isSetTarget(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof CommandRequest) - return this.equals((CommandRequest)that); - return false; - } - - public boolean equals(CommandRequest that) { - if (that == null) - return false; - - boolean this_present_name = true && this.isSetName(); - boolean that_present_name = true && that.isSetName(); - if (this_present_name || that_present_name) { - if (!(this_present_name && that_present_name)) - return false; - if (!this.name.equals(that.name)) - return false; - } - - boolean this_present_target = true && this.isSetTarget(); - boolean that_present_target = true && that.isSetTarget(); - if (this_present_target || that_present_target) { - if (!(this_present_target && that_present_target)) - return false; - if (!this.target.equals(that.target)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - return 0; - } - - public int compareTo(CommandRequest other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - CommandRequest typedOther = (CommandRequest)other; - - lastComparison = Boolean.valueOf(isSetName()).compareTo(typedOther.isSetName()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetName()) { - lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.name, typedOther.name); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetTarget()).compareTo(typedOther.isSetTarget()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetTarget()) { - lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.target, typedOther.target); - 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("CommandRequest("); - boolean first = true; - - sb.append("name:"); - if (this.name == null) { - sb.append("null"); - } else { - sb.append(this.name); - } - first = false; - if (!first) sb.append(", "); - sb.append("target:"); - if (this.target == null) { - sb.append("null"); - } else { - sb.append(this.target); - } - 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 (target != null) { - target.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 CommandRequestStandardSchemeFactory implements SchemeFactory { - public CommandRequestStandardScheme getScheme() { - return new CommandRequestStandardScheme(); - } - } - - private static class CommandRequestStandardScheme extends StandardScheme<CommandRequest> { - - public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, CommandRequest 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: // NAME - if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING) { - struct.name = iprot.readString(); - struct.setNameIsSet(true); - } else { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // TARGET - if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT) { - struct.target = new CommandTarget(); - struct.target.read(iprot); - struct.setTargetIsSet(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, CommandRequest struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.name != null) { - oprot.writeFieldBegin(NAME_FIELD_DESC); - oprot.writeString(struct.name); - oprot.writeFieldEnd(); - } - if (struct.target != null) { - oprot.writeFieldBegin(TARGET_FIELD_DESC); - struct.target.write(oprot); - oprot.writeFieldEnd(); - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class CommandRequestTupleSchemeFactory implements SchemeFactory { - public CommandRequestTupleScheme getScheme() { - return new CommandRequestTupleScheme(); - } - } - - private static class CommandRequestTupleScheme extends TupleScheme<CommandRequest> { - - @Override - public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, CommandRequest struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.isSetName()) { - optionals.set(0); - } - if (struct.isSetTarget()) { - optionals.set(1); - } - oprot.writeBitSet(optionals, 2); - if (struct.isSetName()) { - oprot.writeString(struct.name); - } - if (struct.isSetTarget()) { - struct.target.write(oprot); - } - } - - @Override - public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, CommandRequest struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(2); - if (incoming.get(0)) { - struct.name = iprot.readString(); - struct.setNameIsSet(true); - } - if (incoming.get(1)) { - struct.target = new CommandTarget(); - struct.target.read(iprot); - struct.setTargetIsSet(true); - } - } - } - -} -
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/93455749/blur-thrift/src/main/java/org/apache/blur/thrift/generated/CommandTarget.java ---------------------------------------------------------------------- diff --git a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/CommandTarget.java b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/CommandTarget.java deleted file mode 100644 index 811955e..0000000 --- a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/CommandTarget.java +++ /dev/null @@ -1,609 +0,0 @@ -/** - * 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 CommandTarget implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<CommandTarget, CommandTarget._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("CommandTarget"); - - private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField TABLES_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("tables", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.SET, (short)1); - private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField SHARDS_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("shards", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.SET, (short)2); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new CommandTargetStandardSchemeFactory()); - schemes.put(TupleScheme.class, new CommandTargetTupleSchemeFactory()); - } - - public Set<String> tables; // required - public Set<String> shards; // 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 { - TABLES((short)1, "tables"), - SHARDS((short)2, "shards"); - - 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: // TABLES - return TABLES; - case 2: // SHARDS - return SHARDS; - 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.TABLES, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("tables", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, - new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.SetMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.SET, - 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.SHARDS, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("shards", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, - new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.SetMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.SET, - 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(CommandTarget.class, metaDataMap); - } - - public CommandTarget() { - } - - public CommandTarget( - Set<String> tables, - Set<String> shards) - { - this(); - this.tables = tables; - this.shards = shards; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public CommandTarget(CommandTarget other) { - if (other.isSetTables()) { - Set<String> __this__tables = new HashSet<String>(); - for (String other_element : other.tables) { - __this__tables.add(other_element); - } - this.tables = __this__tables; - } - if (other.isSetShards()) { - Set<String> __this__shards = new HashSet<String>(); - for (String other_element : other.shards) { - __this__shards.add(other_element); - } - this.shards = __this__shards; - } - } - - public CommandTarget deepCopy() { - return new CommandTarget(this); - } - - @Override - public void clear() { - this.tables = null; - this.shards = null; - } - - public int getTablesSize() { - return (this.tables == null) ? 0 : this.tables.size(); - } - - public java.util.Iterator<String> getTablesIterator() { - return (this.tables == null) ? null : this.tables.iterator(); - } - - public void addToTables(String elem) { - if (this.tables == null) { - this.tables = new HashSet<String>(); - } - this.tables.add(elem); - } - - public Set<String> getTables() { - return this.tables; - } - - public CommandTarget setTables(Set<String> tables) { - this.tables = tables; - return this; - } - - public void unsetTables() { - this.tables = null; - } - - /** Returns true if field tables is set (has been assigned a value) and false otherwise */ - public boolean isSetTables() { - return this.tables != null; - } - - public void setTablesIsSet(boolean value) { - if (!value) { - this.tables = null; - } - } - - public int getShardsSize() { - return (this.shards == null) ? 0 : this.shards.size(); - } - - public java.util.Iterator<String> getShardsIterator() { - return (this.shards == null) ? null : this.shards.iterator(); - } - - public void addToShards(String elem) { - if (this.shards == null) { - this.shards = new HashSet<String>(); - } - this.shards.add(elem); - } - - public Set<String> getShards() { - return this.shards; - } - - public CommandTarget setShards(Set<String> shards) { - this.shards = shards; - return this; - } - - public void unsetShards() { - this.shards = null; - } - - /** Returns true if field shards is set (has been assigned a value) and false otherwise */ - public boolean isSetShards() { - return this.shards != null; - } - - public void setShardsIsSet(boolean value) { - if (!value) { - this.shards = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case TABLES: - if (value == null) { - unsetTables(); - } else { - setTables((Set<String>)value); - } - break; - - case SHARDS: - if (value == null) { - unsetShards(); - } else { - setShards((Set<String>)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case TABLES: - return getTables(); - - case SHARDS: - return getShards(); - - } - 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 TABLES: - return isSetTables(); - case SHARDS: - return isSetShards(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof CommandTarget) - return this.equals((CommandTarget)that); - return false; - } - - public boolean equals(CommandTarget that) { - if (that == null) - return false; - - boolean this_present_tables = true && this.isSetTables(); - boolean that_present_tables = true && that.isSetTables(); - if (this_present_tables || that_present_tables) { - if (!(this_present_tables && that_present_tables)) - return false; - if (!this.tables.equals(that.tables)) - return false; - } - - boolean this_present_shards = true && this.isSetShards(); - boolean that_present_shards = true && that.isSetShards(); - if (this_present_shards || that_present_shards) { - if (!(this_present_shards && that_present_shards)) - return false; - if (!this.shards.equals(that.shards)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - return 0; - } - - public int compareTo(CommandTarget other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - CommandTarget typedOther = (CommandTarget)other; - - lastComparison = Boolean.valueOf(isSetTables()).compareTo(typedOther.isSetTables()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetTables()) { - lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.tables, typedOther.tables); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetShards()).compareTo(typedOther.isSetShards()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetShards()) { - lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.shards, typedOther.shards); - 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("CommandTarget("); - boolean first = true; - - sb.append("tables:"); - if (this.tables == null) { - sb.append("null"); - } else { - sb.append(this.tables); - } - first = false; - if (!first) sb.append(", "); - sb.append("shards:"); - if (this.shards == null) { - sb.append("null"); - } else { - sb.append(this.shards); - } - 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 CommandTargetStandardSchemeFactory implements SchemeFactory { - public CommandTargetStandardScheme getScheme() { - return new CommandTargetStandardScheme(); - } - } - - private static class CommandTargetStandardScheme extends StandardScheme<CommandTarget> { - - public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, CommandTarget 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: // TABLES - if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.SET) { - { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TSet _set290 = iprot.readSetBegin(); - struct.tables = new HashSet<String>(2*_set290.size); - for (int _i291 = 0; _i291 < _set290.size; ++_i291) - { - String _elem292; // required - _elem292 = iprot.readString(); - struct.tables.add(_elem292); - } - iprot.readSetEnd(); - } - struct.setTablesIsSet(true); - } else { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // SHARDS - if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.SET) { - { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TSet _set293 = iprot.readSetBegin(); - struct.shards = new HashSet<String>(2*_set293.size); - for (int _i294 = 0; _i294 < _set293.size; ++_i294) - { - String _elem295; // required - _elem295 = iprot.readString(); - struct.shards.add(_elem295); - } - iprot.readSetEnd(); - } - struct.setShardsIsSet(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, CommandTarget struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.tables != null) { - oprot.writeFieldBegin(TABLES_FIELD_DESC); - { - oprot.writeSetBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TSet(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, struct.tables.size())); - for (String _iter296 : struct.tables) - { - oprot.writeString(_iter296); - } - oprot.writeSetEnd(); - } - oprot.writeFieldEnd(); - } - if (struct.shards != null) { - oprot.writeFieldBegin(SHARDS_FIELD_DESC); - { - oprot.writeSetBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TSet(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, struct.shards.size())); - for (String _iter297 : struct.shards) - { - oprot.writeString(_iter297); - } - oprot.writeSetEnd(); - } - oprot.writeFieldEnd(); - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class CommandTargetTupleSchemeFactory implements SchemeFactory { - public CommandTargetTupleScheme getScheme() { - return new CommandTargetTupleScheme(); - } - } - - private static class CommandTargetTupleScheme extends TupleScheme<CommandTarget> { - - @Override - public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, CommandTarget struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.isSetTables()) { - optionals.set(0); - } - if (struct.isSetShards()) { - optionals.set(1); - } - oprot.writeBitSet(optionals, 2); - if (struct.isSetTables()) { - { - oprot.writeI32(struct.tables.size()); - for (String _iter298 : struct.tables) - { - oprot.writeString(_iter298); - } - } - } - if (struct.isSetShards()) { - { - oprot.writeI32(struct.shards.size()); - for (String _iter299 : struct.shards) - { - oprot.writeString(_iter299); - } - } - } - } - - @Override - public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, CommandTarget struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(2); - if (incoming.get(0)) { - { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TSet _set300 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TSet(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, iprot.readI32()); - struct.tables = new HashSet<String>(2*_set300.size); - for (int _i301 = 0; _i301 < _set300.size; ++_i301) - { - String _elem302; // required - _elem302 = iprot.readString(); - struct.tables.add(_elem302); - } - } - struct.setTablesIsSet(true); - } - if (incoming.get(1)) { - { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TSet _set303 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TSet(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, iprot.readI32()); - struct.shards = new HashSet<String>(2*_set303.size); - for (int _i304 = 0; _i304 < _set303.size; ++_i304) - { - String _elem305; // required - _elem305 = iprot.readString(); - struct.shards.add(_elem305); - } - } - struct.setShardsIsSet(true); - } - } - } - -} - http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/93455749/blur-thrift/src/main/java/org/apache/blur/thrift/generated/SafeClientGen.java ---------------------------------------------------------------------- diff --git a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/SafeClientGen.java b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/SafeClientGen.java index 8a89b0d..575a79b 100644 --- a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/SafeClientGen.java +++ b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/SafeClientGen.java @@ -202,9 +202,9 @@ public org.apache.blur.thrift.generated.Response execute(java.lang.String arg0, } @Override -public void executeCommand(org.apache.blur.thrift.generated.CommandRequest arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { +public void executeShardOperation(org.apache.blur.thrift.generated.ShardOperationRequest arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { _lock.errorFailLock(); try { - super.executeCommand(arg0); + super.executeShardOperation(arg0); } finally {_lock.unlock();} } @@ -909,9 +909,9 @@ public void send_execute(java.lang.String arg0, org.apache.blur.thrift.generated } @Override -public void send_executeCommand(org.apache.blur.thrift.generated.CommandRequest arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { +public void send_executeShardOperation(org.apache.blur.thrift.generated.ShardOperationRequest arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { _lock.errorFailLock(); try { - super.send_executeCommand(arg0); + super.send_executeShardOperation(arg0); } finally {_lock.unlock();} } http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/93455749/blur-thrift/src/main/java/org/apache/blur/thrift/generated/ShardOperationRequest.java ---------------------------------------------------------------------- diff --git a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/ShardOperationRequest.java b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/ShardOperationRequest.java new file mode 100644 index 0000000..f93df90 --- /dev/null +++ b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/ShardOperationRequest.java @@ -0,0 +1,605 @@ +/** + * 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 ShardOperationRequest implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<ShardOperationRequest, ShardOperationRequest._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("ShardOperationRequest"); + + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField NAME_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("name", 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 SHARD_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("shard", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, (short)3); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new ShardOperationRequestStandardSchemeFactory()); + schemes.put(TupleScheme.class, new ShardOperationRequestTupleSchemeFactory()); + } + + public String name; // required + public String table; // required + public String shard; // 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 { + NAME((short)1, "name"), + TABLE((short)2, "table"), + SHARD((short)3, "shard"); + + 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: // NAME + return NAME; + case 2: // TABLE + return TABLE; + case 3: // SHARD + return SHARD; + 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.NAME, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("name", 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.SHARD, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("shard", 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(ShardOperationRequest.class, metaDataMap); + } + + public ShardOperationRequest() { + } + + public ShardOperationRequest( + String name, + String table, + String shard) + { + this(); + this.name = name; + this.table = table; + this.shard = shard; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public ShardOperationRequest(ShardOperationRequest other) { + if (other.isSetName()) { + this.name = other.name; + } + if (other.isSetTable()) { + this.table = other.table; + } + if (other.isSetShard()) { + this.shard = other.shard; + } + } + + public ShardOperationRequest deepCopy() { + return new ShardOperationRequest(this); + } + + @Override + public void clear() { + this.name = null; + this.table = null; + this.shard = null; + } + + public String getName() { + return this.name; + } + + public ShardOperationRequest setName(String name) { + this.name = name; + return this; + } + + public void unsetName() { + this.name = null; + } + + /** Returns true if field name is set (has been assigned a value) and false otherwise */ + public boolean isSetName() { + return this.name != null; + } + + public void setNameIsSet(boolean value) { + if (!value) { + this.name = null; + } + } + + public String getTable() { + return this.table; + } + + public ShardOperationRequest 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 getShard() { + return this.shard; + } + + public ShardOperationRequest setShard(String shard) { + this.shard = shard; + return this; + } + + public void unsetShard() { + this.shard = null; + } + + /** Returns true if field shard is set (has been assigned a value) and false otherwise */ + public boolean isSetShard() { + return this.shard != null; + } + + public void setShardIsSet(boolean value) { + if (!value) { + this.shard = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case NAME: + if (value == null) { + unsetName(); + } else { + setName((String)value); + } + break; + + case TABLE: + if (value == null) { + unsetTable(); + } else { + setTable((String)value); + } + break; + + case SHARD: + if (value == null) { + unsetShard(); + } else { + setShard((String)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case NAME: + return getName(); + + case TABLE: + return getTable(); + + case SHARD: + return getShard(); + + } + 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 NAME: + return isSetName(); + case TABLE: + return isSetTable(); + case SHARD: + return isSetShard(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof ShardOperationRequest) + return this.equals((ShardOperationRequest)that); + return false; + } + + public boolean equals(ShardOperationRequest that) { + if (that == null) + return false; + + boolean this_present_name = true && this.isSetName(); + boolean that_present_name = true && that.isSetName(); + if (this_present_name || that_present_name) { + if (!(this_present_name && that_present_name)) + return false; + if (!this.name.equals(that.name)) + 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_shard = true && this.isSetShard(); + boolean that_present_shard = true && that.isSetShard(); + if (this_present_shard || that_present_shard) { + if (!(this_present_shard && that_present_shard)) + return false; + if (!this.shard.equals(that.shard)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + return 0; + } + + public int compareTo(ShardOperationRequest other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + ShardOperationRequest typedOther = (ShardOperationRequest)other; + + lastComparison = Boolean.valueOf(isSetName()).compareTo(typedOther.isSetName()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetName()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.name, typedOther.name); + 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(isSetShard()).compareTo(typedOther.isSetShard()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetShard()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.shard, typedOther.shard); + 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("ShardOperationRequest("); + boolean first = true; + + sb.append("name:"); + if (this.name == null) { + sb.append("null"); + } else { + sb.append(this.name); + } + 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("shard:"); + if (this.shard == null) { + sb.append("null"); + } else { + sb.append(this.shard); + } + 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 ShardOperationRequestStandardSchemeFactory implements SchemeFactory { + public ShardOperationRequestStandardScheme getScheme() { + return new ShardOperationRequestStandardScheme(); + } + } + + private static class ShardOperationRequestStandardScheme extends StandardScheme<ShardOperationRequest> { + + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, ShardOperationRequest 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: // NAME + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING) { + struct.name = iprot.readString(); + struct.setNameIsSet(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: // SHARD + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING) { + struct.shard = iprot.readString(); + struct.setShardIsSet(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, ShardOperationRequest struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.name != null) { + oprot.writeFieldBegin(NAME_FIELD_DESC); + oprot.writeString(struct.name); + oprot.writeFieldEnd(); + } + if (struct.table != null) { + oprot.writeFieldBegin(TABLE_FIELD_DESC); + oprot.writeString(struct.table); + oprot.writeFieldEnd(); + } + if (struct.shard != null) { + oprot.writeFieldBegin(SHARD_FIELD_DESC); + oprot.writeString(struct.shard); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class ShardOperationRequestTupleSchemeFactory implements SchemeFactory { + public ShardOperationRequestTupleScheme getScheme() { + return new ShardOperationRequestTupleScheme(); + } + } + + private static class ShardOperationRequestTupleScheme extends TupleScheme<ShardOperationRequest> { + + @Override + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, ShardOperationRequest struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetName()) { + optionals.set(0); + } + if (struct.isSetTable()) { + optionals.set(1); + } + if (struct.isSetShard()) { + optionals.set(2); + } + oprot.writeBitSet(optionals, 3); + if (struct.isSetName()) { + oprot.writeString(struct.name); + } + if (struct.isSetTable()) { + oprot.writeString(struct.table); + } + if (struct.isSetShard()) { + oprot.writeString(struct.shard); + } + } + + @Override + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, ShardOperationRequest struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(3); + if (incoming.get(0)) { + struct.name = iprot.readString(); + struct.setNameIsSet(true); + } + if (incoming.get(1)) { + struct.table = iprot.readString(); + struct.setTableIsSet(true); + } + if (incoming.get(2)) { + struct.shard = iprot.readString(); + struct.setShardIsSet(true); + } + } + } + +} + http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/93455749/blur-thrift/src/main/java/org/apache/blur/thrift/generated/User.java ---------------------------------------------------------------------- diff --git a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/User.java b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/User.java index 8415554..8f152a6 100644 --- a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/User.java +++ b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/User.java @@ -481,7 +481,7 @@ public class User implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<User, for (int _i1 = 0; _i1 < _map0.size; ++_i1) { String _key2; // required - String _val3; // required + String _val3; // optional _key2 = iprot.readString(); _val3 = iprot.readString(); struct.attributes.put(_key2, _val3); @@ -581,7 +581,7 @@ public class User implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<User, for (int _i7 = 0; _i7 < _map6.size; ++_i7) { String _key8; // required - String _val9; // required + String _val9; // optional _key8 = iprot.readString(); _val9 = iprot.readString(); struct.attributes.put(_key8, _val9); http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/93455749/blur-thrift/src/main/java/org/apache/blur/thrift/util/ServerCommandExample.java ---------------------------------------------------------------------- diff --git a/blur-thrift/src/main/java/org/apache/blur/thrift/util/ServerCommandExample.java b/blur-thrift/src/main/java/org/apache/blur/thrift/util/ServerCommandExample.java index 5dc4c86..7306fe3 100644 --- a/blur-thrift/src/main/java/org/apache/blur/thrift/util/ServerCommandExample.java +++ b/blur-thrift/src/main/java/org/apache/blur/thrift/util/ServerCommandExample.java @@ -23,12 +23,12 @@ import org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol; import org.apache.blur.thrift.BlurClientManager; import org.apache.blur.thrift.Connection; import org.apache.blur.thrift.generated.Blur.Client; -import org.apache.blur.thrift.generated.CommandRequest; +//import org.apache.blur.thrift.generated.CommandRequest; public class ServerCommandExample { public static void main(String[] args) throws TException, IOException { - CommandRequest commandRequest = new CommandRequest(); + /* CommandRequest commandRequest = new CommandRequest(); commandRequest.setName("cool"); Client client = BlurClientManager.getClientPool().getClient(new Connection("localhost:40020")); client.executeCommand(commandRequest); @@ -47,6 +47,6 @@ public class ServerCommandExample { System.out.println(t); System.out.println(client.tableList()); - } + */ } } http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/93455749/docs/Blur.html ---------------------------------------------------------------------- diff --git a/docs/Blur.html b/docs/Blur.html index a386ab2..4b92921 100644 --- a/docs/Blur.html +++ b/docs/Blur.html @@ -105,8 +105,7 @@ limitations under the License. <li><a href="#Struct_CommandStatus">CommandStatus</a></li> <li><a href="#Struct_ArgumentDescriptor">ArgumentDescriptor</a></li> <li><a href="#Struct_CommandDescriptor">CommandDescriptor</a></li> -<li><a href="#Struct_CommandTarget">CommandTarget</a></li> -<li><a href="#Struct_CommandRequest">CommandRequest</a></li> +<li><a href="#Struct_ShardOperationRequest">ShardOperationRequest</a></li> </ul> </li> <li><a href="#Svc_Blur">Service</a> @@ -119,7 +118,7 @@ limitations under the License. <li><a href="#Fn_Blur_commandStatus"> commandStatus</a></li> <li><a href="#Fn_Blur_commandCancel"> commandCancel</a></li> <li><a href="#Fn_Blur_refresh"> refresh</a></li> -<li><a href="#Fn_Blur_executeCommand"> executeCommand</a></li> +<li><a href="#Fn_Blur_executeShardOperation"> executeShardOperation</a></li> <li><a href="#Fn_Blur_createTable"> createTable</a></li> <li><a href="#Fn_Blur_enableTable"> enableTable</a></li> <li><a href="#Fn_Blur_disableTable"> disableTable</a></li> @@ -743,14 +742,11 @@ be family dot column, "family.column". <tr><td>4</td><td>optionalArguments</td><td><code>map<<code>string</code>, <code><a href="Blur.html#Struct_ArgumentDescriptor">ArgumentDescriptor</a></code>></code></td><td></td><td>default</td><td></td></tr> <tr><td>5</td><td>returnType</td><td><code>string</code></td><td></td><td>default</td><td></td></tr> <tr><td>6</td><td>version</td><td><code>string</code></td><td></td><td>default</td><td></td></tr> -</table><br/></p></section><section><div class="page-header"><h3 id="Struct_CommandTarget">Struct: CommandTarget</h3></div><p class="lead"> -<table class="table-bordered table-striped table-condensed"><thead><th>Key</th><th>Field</th><th>Type</th><th>Description</th><th>Requiredness</th><th>Default value</th></thead> -<tr><td>1</td><td>tables</td><td><code>set<<code>string</code>></code></td><td></td><td>default</td><td></td></tr> -<tr><td>2</td><td>shards</td><td><code>set<<code>string</code>></code></td><td></td><td>default</td><td></td></tr> -</table><br/></p></section><section><div class="page-header"><h3 id="Struct_CommandRequest">Struct: CommandRequest</h3></div><p class="lead"> +</table><br/></p></section><section><div class="page-header"><h3 id="Struct_ShardOperationRequest">Struct: ShardOperationRequest</h3></div><p class="lead"> <table class="table-bordered table-striped table-condensed"><thead><th>Key</th><th>Field</th><th>Type</th><th>Description</th><th>Requiredness</th><th>Default value</th></thead> <tr><td>1</td><td>name</td><td><code>string</code></td><td></td><td>default</td><td></td></tr> -<tr><td>2</td><td>target</td><td><code><a href="Blur.html#Struct_CommandTarget">CommandTarget</a></code></td><td></td><td>default</td><td></td></tr> +<tr><td>2</td><td>table</td><td><code>string</code></td><td></td><td>default</td><td></td></tr> +<tr><td>3</td><td>shard</td><td><code>string</code></td><td></td><td>default</td><td></td></tr> </table><br/></p></section><hr/><h2 id="Services">Services</h2> <h3 id="Svc_Blur">Service: Blur</h3> The Blur service API. This API is the same for both controller servers as well as @@ -788,9 +784,9 @@ throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code> <pre><code>void</code> refresh() </pre>Releases and refreshes the read snapshots of the indexes in the session for the current connection. -<br/></p></section><section><div class="page-header"><h4 id="Fn_Blur_executeCommand">Function: Blur.executeCommand</h4></div><p class="lead"> -<pre><code>void</code> executeCommand(<code><a href="Blur.html#Struct_CommandRequest">CommandRequest</a></code> commandRequest) -</pre>Executes command. +<br/></p></section><section><div class="page-header"><h4 id="Fn_Blur_executeShardOperation">Function: Blur.executeShardOperation</h4></div><p class="lead"> +<pre><code>void</code> executeShardOperation(<code><a href="Blur.html#Struct_ShardOperationRequest">ShardOperationRequest</a></code> shardOperationRequest) +</pre>Executes a shard operation which allows for bidirectional communication. <br/></p></section><section><div class="page-header"><h4 id="Fn_Blur_createTable">Function: Blur.createTable</h4></div><p class="lead"> <pre><code>void</code> createTable(<code><a href="Blur.html#Struct_TableDescriptor">TableDescriptor</a></code> tableDescriptor) throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code> http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/93455749/scripts/interface/gen-html/Blur.html ---------------------------------------------------------------------- diff --git a/scripts/interface/gen-html/Blur.html b/scripts/interface/gen-html/Blur.html index d85a529..06dd1a4 100644 --- a/scripts/interface/gen-html/Blur.html +++ b/scripts/interface/gen-html/Blur.html @@ -31,7 +31,7 @@ <li><a href="Blur.html#Fn_Blur_enqueueMutate">enqueueMutate</a></li> <li><a href="Blur.html#Fn_Blur_enqueueMutateBatch">enqueueMutateBatch</a></li> <li><a href="Blur.html#Fn_Blur_execute">execute</a></li> -<li><a href="Blur.html#Fn_Blur_executeCommand">executeCommand</a></li> +<li><a href="Blur.html#Fn_Blur_executeShardOperation">executeShardOperation</a></li> <li><a href="Blur.html#Fn_Blur_fetchRow">fetchRow</a></li> <li><a href="Blur.html#Fn_Blur_fetchRowBatch">fetchRowBatch</a></li> <li><a href="Blur.html#Fn_Blur_isInSafeMode">isInSafeMode</a></li> @@ -85,10 +85,8 @@ <a href="Blur.html#Struct_Column">Column</a><br/> <a href="Blur.html#Struct_ColumnDefinition">ColumnDefinition</a><br/> <a href="Blur.html#Struct_CommandDescriptor">CommandDescriptor</a><br/> -<a href="Blur.html#Struct_CommandRequest">CommandRequest</a><br/> <a href="Blur.html#Struct_CommandStatus">CommandStatus</a><br/> <a href="Blur.html#Enum_CommandStatusState">CommandStatusState</a><br/> -<a href="Blur.html#Struct_CommandTarget">CommandTarget</a><br/> <a href="Blur.html#Struct_CpuTime">CpuTime</a><br/> <a href="Blur.html#Enum_ErrorType">ErrorType</a><br/> <a href="Blur.html#Struct_Facet">Facet</a><br/> @@ -112,6 +110,7 @@ <a href="Blur.html#Struct_Selector">Selector</a><br/> <a href="Blur.html#Struct_Server">Server</a><br/> <a href="Blur.html#Struct_Shard">Shard</a><br/> +<a href="Blur.html#Struct_ShardOperationRequest">ShardOperationRequest</a><br/> <a href="Blur.html#Enum_ShardState">ShardState</a><br/> <a href="Blur.html#Struct_SortField">SortField</a><br/> <a href="Blur.html#Struct_SortFieldResult">SortFieldResult</a><br/> @@ -685,14 +684,11 @@ be family dot column, "family.column". <tr><td>4</td><td>optionalArguments</td><td><code>map<<code>string</code>, <code><a href="Blur.html#Struct_ArgumentDescriptor">ArgumentDescriptor</a></code>></code></td><td></td><td>default</td><td></td></tr> <tr><td>5</td><td>returnType</td><td><code>string</code></td><td></td><td>default</td><td></td></tr> <tr><td>6</td><td>version</td><td><code>string</code></td><td></td><td>default</td><td></td></tr> -</table><br/></div><div class="definition"><h3 id="Struct_CommandTarget">Struct: CommandTarget</h3> -<table class="table-bordered table-striped table-condensed"><thead><th>Key</th><th>Field</th><th>Type</th><th>Description</th><th>Requiredness</th><th>Default value</th></thead> -<tr><td>1</td><td>tables</td><td><code>set<<code>string</code>></code></td><td></td><td>default</td><td></td></tr> -<tr><td>2</td><td>shards</td><td><code>set<<code>string</code>></code></td><td></td><td>default</td><td></td></tr> -</table><br/></div><div class="definition"><h3 id="Struct_CommandRequest">Struct: CommandRequest</h3> +</table><br/></div><div class="definition"><h3 id="Struct_ShardOperationRequest">Struct: ShardOperationRequest</h3> <table class="table-bordered table-striped table-condensed"><thead><th>Key</th><th>Field</th><th>Type</th><th>Description</th><th>Requiredness</th><th>Default value</th></thead> <tr><td>1</td><td>name</td><td><code>string</code></td><td></td><td>default</td><td></td></tr> -<tr><td>2</td><td>target</td><td><code><a href="Blur.html#Struct_CommandTarget">CommandTarget</a></code></td><td></td><td>default</td><td></td></tr> +<tr><td>2</td><td>table</td><td><code>string</code></td><td></td><td>default</td><td></td></tr> +<tr><td>3</td><td>shard</td><td><code>string</code></td><td></td><td>default</td><td></td></tr> </table><br/></div><hr/><h2 id="Services">Services</h2> <h3 id="Svc_Blur">Service: Blur</h3> The Blur service API. This API is the same for both controller servers as well as @@ -730,9 +726,9 @@ executing command. <pre><code>void</code> refresh() </pre>Releases and refreshes the read snapshots of the indexes in the session for the current connection. -<br/></div><div class="definition"><h4 id="Fn_Blur_executeCommand">Function: Blur.executeCommand</h4> -<pre><code>void</code> executeCommand(<code><a href="Blur.html#Struct_CommandRequest">CommandRequest</a></code> commandRequest) -</pre>Executes command. +<br/></div><div class="definition"><h4 id="Fn_Blur_executeShardOperation">Function: Blur.executeShardOperation</h4> +<pre><code>void</code> executeShardOperation(<code><a href="Blur.html#Struct_ShardOperationRequest">ShardOperationRequest</a></code> shardOperationRequest) +</pre>Executes a shard operation which allows for bidirectional communication. <br/></div><div class="definition"><h4 id="Fn_Blur_createTable">Function: Blur.createTable</h4> <pre><code>void</code> createTable(<code><a href="Blur.html#Struct_TableDescriptor">TableDescriptor</a></code> tableDescriptor) throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code> http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/93455749/scripts/interface/gen-html/index.html ---------------------------------------------------------------------- diff --git a/scripts/interface/gen-html/index.html b/scripts/interface/gen-html/index.html index e240fc1..1e713e8 100644 --- a/scripts/interface/gen-html/index.html +++ b/scripts/interface/gen-html/index.html @@ -27,7 +27,7 @@ <li><a href="Blur.html#Fn_Blur_enqueueMutate">enqueueMutate</a></li> <li><a href="Blur.html#Fn_Blur_enqueueMutateBatch">enqueueMutateBatch</a></li> <li><a href="Blur.html#Fn_Blur_execute">execute</a></li> -<li><a href="Blur.html#Fn_Blur_executeCommand">executeCommand</a></li> +<li><a href="Blur.html#Fn_Blur_executeShardOperation">executeShardOperation</a></li> <li><a href="Blur.html#Fn_Blur_fetchRow">fetchRow</a></li> <li><a href="Blur.html#Fn_Blur_fetchRowBatch">fetchRowBatch</a></li> <li><a href="Blur.html#Fn_Blur_isInSafeMode">isInSafeMode</a></li> @@ -81,10 +81,8 @@ <a href="Blur.html#Struct_Column">Column</a><br/> <a href="Blur.html#Struct_ColumnDefinition">ColumnDefinition</a><br/> <a href="Blur.html#Struct_CommandDescriptor">CommandDescriptor</a><br/> -<a href="Blur.html#Struct_CommandRequest">CommandRequest</a><br/> <a href="Blur.html#Struct_CommandStatus">CommandStatus</a><br/> <a href="Blur.html#Enum_CommandStatusState">CommandStatusState</a><br/> -<a href="Blur.html#Struct_CommandTarget">CommandTarget</a><br/> <a href="Blur.html#Struct_CpuTime">CpuTime</a><br/> <a href="Blur.html#Enum_ErrorType">ErrorType</a><br/> <a href="Blur.html#Struct_Facet">Facet</a><br/> @@ -108,6 +106,7 @@ <a href="Blur.html#Struct_Selector">Selector</a><br/> <a href="Blur.html#Struct_Server">Server</a><br/> <a href="Blur.html#Struct_Shard">Shard</a><br/> +<a href="Blur.html#Struct_ShardOperationRequest">ShardOperationRequest</a><br/> <a href="Blur.html#Enum_ShardState">ShardState</a><br/> <a href="Blur.html#Struct_SortField">SortField</a><br/> <a href="Blur.html#Struct_SortFieldResult">SortFieldResult</a><br/>
