http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/32e1d176/interface/gen-java/org/apache/blur/thrift/generated/BlurQueryStatus.java ---------------------------------------------------------------------- diff --git a/interface/gen-java/org/apache/blur/thrift/generated/BlurQueryStatus.java b/interface/gen-java/org/apache/blur/thrift/generated/BlurQueryStatus.java deleted file mode 100644 index 9a69659..0000000 --- a/interface/gen-java/org/apache/blur/thrift/generated/BlurQueryStatus.java +++ /dev/null @@ -1,1044 +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.thrift.scheme.IScheme; -import org.apache.thrift.scheme.SchemeFactory; -import org.apache.thrift.scheme.StandardScheme; - -import org.apache.thrift.scheme.TupleScheme; -import org.apache.thrift.protocol.TTupleProtocol; -import org.apache.thrift.protocol.TProtocolException; -import org.apache.thrift.EncodingUtils; -import org.apache.thrift.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 BlurQueryStatus implements org.apache.thrift.TBase<BlurQueryStatus, BlurQueryStatus._Fields>, java.io.Serializable, Cloneable { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("BlurQueryStatus"); - - private static final org.apache.thrift.protocol.TField QUERY_FIELD_DESC = new org.apache.thrift.protocol.TField("query", org.apache.thrift.protocol.TType.STRUCT, (short)1); - private static final org.apache.thrift.protocol.TField CPU_TIMES_FIELD_DESC = new org.apache.thrift.protocol.TField("cpuTimes", org.apache.thrift.protocol.TType.MAP, (short)2); - private static final org.apache.thrift.protocol.TField COMPLETE_SHARDS_FIELD_DESC = new org.apache.thrift.protocol.TField("completeShards", org.apache.thrift.protocol.TType.I32, (short)3); - private static final org.apache.thrift.protocol.TField TOTAL_SHARDS_FIELD_DESC = new org.apache.thrift.protocol.TField("totalShards", org.apache.thrift.protocol.TType.I32, (short)4); - private static final org.apache.thrift.protocol.TField STATE_FIELD_DESC = new org.apache.thrift.protocol.TField("state", org.apache.thrift.protocol.TType.I32, (short)5); - private static final org.apache.thrift.protocol.TField UUID_FIELD_DESC = new org.apache.thrift.protocol.TField("uuid", org.apache.thrift.protocol.TType.I64, (short)6); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new BlurQueryStatusStandardSchemeFactory()); - schemes.put(TupleScheme.class, new BlurQueryStatusTupleSchemeFactory()); - } - - /** - * - */ - public BlurQuery query; // required - /** - * - */ - public Map<String,CpuTime> cpuTimes; // required - /** - * - */ - public int completeShards; // required - /** - * - */ - public int totalShards; // required - /** - * - * - * @see QueryState - */ - public QueryState state; // required - /** - * - */ - public long uuid; // required - - /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - public enum _Fields implements org.apache.thrift.TFieldIdEnum { - /** - * - */ - QUERY((short)1, "query"), - /** - * - */ - CPU_TIMES((short)2, "cpuTimes"), - /** - * - */ - COMPLETE_SHARDS((short)3, "completeShards"), - /** - * - */ - TOTAL_SHARDS((short)4, "totalShards"), - /** - * - * - * @see QueryState - */ - STATE((short)5, "state"), - /** - * - */ - UUID((short)6, "uuid"); - - 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: // QUERY - return QUERY; - case 2: // CPU_TIMES - return CPU_TIMES; - case 3: // COMPLETE_SHARDS - return COMPLETE_SHARDS; - case 4: // TOTAL_SHARDS - return TOTAL_SHARDS; - case 5: // STATE - return STATE; - case 6: // UUID - return UUID; - 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 - private static final int __COMPLETESHARDS_ISSET_ID = 0; - private static final int __TOTALSHARDS_ISSET_ID = 1; - private static final int __UUID_ISSET_ID = 2; - private byte __isset_bitfield = 0; - public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; - static { - Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); - tmpMap.put(_Fields.QUERY, new org.apache.thrift.meta_data.FieldMetaData("query", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, BlurQuery.class))); - tmpMap.put(_Fields.CPU_TIMES, new org.apache.thrift.meta_data.FieldMetaData("cpuTimes", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING), - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, CpuTime.class)))); - tmpMap.put(_Fields.COMPLETE_SHARDS, new org.apache.thrift.meta_data.FieldMetaData("completeShards", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); - tmpMap.put(_Fields.TOTAL_SHARDS, new org.apache.thrift.meta_data.FieldMetaData("totalShards", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); - tmpMap.put(_Fields.STATE, new org.apache.thrift.meta_data.FieldMetaData("state", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, QueryState.class))); - tmpMap.put(_Fields.UUID, new org.apache.thrift.meta_data.FieldMetaData("uuid", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(BlurQueryStatus.class, metaDataMap); - } - - public BlurQueryStatus() { - } - - public BlurQueryStatus( - BlurQuery query, - Map<String,CpuTime> cpuTimes, - int completeShards, - int totalShards, - QueryState state, - long uuid) - { - this(); - this.query = query; - this.cpuTimes = cpuTimes; - this.completeShards = completeShards; - setCompleteShardsIsSet(true); - this.totalShards = totalShards; - setTotalShardsIsSet(true); - this.state = state; - this.uuid = uuid; - setUuidIsSet(true); - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public BlurQueryStatus(BlurQueryStatus other) { - __isset_bitfield = other.__isset_bitfield; - if (other.isSetQuery()) { - this.query = new BlurQuery(other.query); - } - if (other.isSetCpuTimes()) { - Map<String,CpuTime> __this__cpuTimes = new HashMap<String,CpuTime>(); - for (Map.Entry<String, CpuTime> other_element : other.cpuTimes.entrySet()) { - - String other_element_key = other_element.getKey(); - CpuTime other_element_value = other_element.getValue(); - - String __this__cpuTimes_copy_key = other_element_key; - - CpuTime __this__cpuTimes_copy_value = new CpuTime(other_element_value); - - __this__cpuTimes.put(__this__cpuTimes_copy_key, __this__cpuTimes_copy_value); - } - this.cpuTimes = __this__cpuTimes; - } - this.completeShards = other.completeShards; - this.totalShards = other.totalShards; - if (other.isSetState()) { - this.state = other.state; - } - this.uuid = other.uuid; - } - - public BlurQueryStatus deepCopy() { - return new BlurQueryStatus(this); - } - - @Override - public void clear() { - this.query = null; - this.cpuTimes = null; - setCompleteShardsIsSet(false); - this.completeShards = 0; - setTotalShardsIsSet(false); - this.totalShards = 0; - this.state = null; - setUuidIsSet(false); - this.uuid = 0; - } - - /** - * - */ - public BlurQuery getQuery() { - return this.query; - } - - /** - * - */ - public BlurQueryStatus setQuery(BlurQuery query) { - this.query = query; - return this; - } - - public void unsetQuery() { - this.query = null; - } - - /** Returns true if field query is set (has been assigned a value) and false otherwise */ - public boolean isSetQuery() { - return this.query != null; - } - - public void setQueryIsSet(boolean value) { - if (!value) { - this.query = null; - } - } - - public int getCpuTimesSize() { - return (this.cpuTimes == null) ? 0 : this.cpuTimes.size(); - } - - public void putToCpuTimes(String key, CpuTime val) { - if (this.cpuTimes == null) { - this.cpuTimes = new HashMap<String,CpuTime>(); - } - this.cpuTimes.put(key, val); - } - - /** - * - */ - public Map<String,CpuTime> getCpuTimes() { - return this.cpuTimes; - } - - /** - * - */ - public BlurQueryStatus setCpuTimes(Map<String,CpuTime> cpuTimes) { - this.cpuTimes = cpuTimes; - return this; - } - - public void unsetCpuTimes() { - this.cpuTimes = null; - } - - /** Returns true if field cpuTimes is set (has been assigned a value) and false otherwise */ - public boolean isSetCpuTimes() { - return this.cpuTimes != null; - } - - public void setCpuTimesIsSet(boolean value) { - if (!value) { - this.cpuTimes = null; - } - } - - /** - * - */ - public int getCompleteShards() { - return this.completeShards; - } - - /** - * - */ - public BlurQueryStatus setCompleteShards(int completeShards) { - this.completeShards = completeShards; - setCompleteShardsIsSet(true); - return this; - } - - public void unsetCompleteShards() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __COMPLETESHARDS_ISSET_ID); - } - - /** Returns true if field completeShards is set (has been assigned a value) and false otherwise */ - public boolean isSetCompleteShards() { - return EncodingUtils.testBit(__isset_bitfield, __COMPLETESHARDS_ISSET_ID); - } - - public void setCompleteShardsIsSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __COMPLETESHARDS_ISSET_ID, value); - } - - /** - * - */ - public int getTotalShards() { - return this.totalShards; - } - - /** - * - */ - public BlurQueryStatus setTotalShards(int totalShards) { - this.totalShards = totalShards; - setTotalShardsIsSet(true); - return this; - } - - public void unsetTotalShards() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TOTALSHARDS_ISSET_ID); - } - - /** Returns true if field totalShards is set (has been assigned a value) and false otherwise */ - public boolean isSetTotalShards() { - return EncodingUtils.testBit(__isset_bitfield, __TOTALSHARDS_ISSET_ID); - } - - public void setTotalShardsIsSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TOTALSHARDS_ISSET_ID, value); - } - - /** - * - * - * @see QueryState - */ - public QueryState getState() { - return this.state; - } - - /** - * - * - * @see QueryState - */ - public BlurQueryStatus setState(QueryState 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 long getUuid() { - return this.uuid; - } - - /** - * - */ - public BlurQueryStatus setUuid(long uuid) { - this.uuid = uuid; - setUuidIsSet(true); - return this; - } - - public void unsetUuid() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __UUID_ISSET_ID); - } - - /** Returns true if field uuid is set (has been assigned a value) and false otherwise */ - public boolean isSetUuid() { - return EncodingUtils.testBit(__isset_bitfield, __UUID_ISSET_ID); - } - - public void setUuidIsSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __UUID_ISSET_ID, value); - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case QUERY: - if (value == null) { - unsetQuery(); - } else { - setQuery((BlurQuery)value); - } - break; - - case CPU_TIMES: - if (value == null) { - unsetCpuTimes(); - } else { - setCpuTimes((Map<String,CpuTime>)value); - } - break; - - case COMPLETE_SHARDS: - if (value == null) { - unsetCompleteShards(); - } else { - setCompleteShards((Integer)value); - } - break; - - case TOTAL_SHARDS: - if (value == null) { - unsetTotalShards(); - } else { - setTotalShards((Integer)value); - } - break; - - case STATE: - if (value == null) { - unsetState(); - } else { - setState((QueryState)value); - } - break; - - case UUID: - if (value == null) { - unsetUuid(); - } else { - setUuid((Long)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case QUERY: - return getQuery(); - - case CPU_TIMES: - return getCpuTimes(); - - case COMPLETE_SHARDS: - return Integer.valueOf(getCompleteShards()); - - case TOTAL_SHARDS: - return Integer.valueOf(getTotalShards()); - - case STATE: - return getState(); - - case UUID: - return Long.valueOf(getUuid()); - - } - 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 QUERY: - return isSetQuery(); - case CPU_TIMES: - return isSetCpuTimes(); - case COMPLETE_SHARDS: - return isSetCompleteShards(); - case TOTAL_SHARDS: - return isSetTotalShards(); - case STATE: - return isSetState(); - case UUID: - return isSetUuid(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof BlurQueryStatus) - return this.equals((BlurQueryStatus)that); - return false; - } - - public boolean equals(BlurQueryStatus that) { - if (that == null) - return false; - - boolean this_present_query = true && this.isSetQuery(); - boolean that_present_query = true && that.isSetQuery(); - if (this_present_query || that_present_query) { - if (!(this_present_query && that_present_query)) - return false; - if (!this.query.equals(that.query)) - return false; - } - - boolean this_present_cpuTimes = true && this.isSetCpuTimes(); - boolean that_present_cpuTimes = true && that.isSetCpuTimes(); - if (this_present_cpuTimes || that_present_cpuTimes) { - if (!(this_present_cpuTimes && that_present_cpuTimes)) - return false; - if (!this.cpuTimes.equals(that.cpuTimes)) - return false; - } - - boolean this_present_completeShards = true; - boolean that_present_completeShards = true; - if (this_present_completeShards || that_present_completeShards) { - if (!(this_present_completeShards && that_present_completeShards)) - return false; - if (this.completeShards != that.completeShards) - return false; - } - - boolean this_present_totalShards = true; - boolean that_present_totalShards = true; - if (this_present_totalShards || that_present_totalShards) { - if (!(this_present_totalShards && that_present_totalShards)) - return false; - if (this.totalShards != that.totalShards) - 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; - } - - boolean this_present_uuid = true; - boolean that_present_uuid = true; - if (this_present_uuid || that_present_uuid) { - if (!(this_present_uuid && that_present_uuid)) - return false; - if (this.uuid != that.uuid) - return false; - } - - return true; - } - - @Override - public int hashCode() { - return 0; - } - - public int compareTo(BlurQueryStatus other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - BlurQueryStatus typedOther = (BlurQueryStatus)other; - - lastComparison = Boolean.valueOf(isSetQuery()).compareTo(typedOther.isSetQuery()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetQuery()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.query, typedOther.query); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetCpuTimes()).compareTo(typedOther.isSetCpuTimes()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetCpuTimes()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.cpuTimes, typedOther.cpuTimes); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetCompleteShards()).compareTo(typedOther.isSetCompleteShards()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetCompleteShards()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.completeShards, typedOther.completeShards); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetTotalShards()).compareTo(typedOther.isSetTotalShards()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetTotalShards()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.totalShards, typedOther.totalShards); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetState()).compareTo(typedOther.isSetState()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetState()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.state, typedOther.state); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetUuid()).compareTo(typedOther.isSetUuid()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetUuid()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.uuid, typedOther.uuid); - if (lastComparison != 0) { - return lastComparison; - } - } - return 0; - } - - public _Fields fieldForId(int fieldId) { - return _Fields.findByThriftId(fieldId); - } - - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { - schemes.get(iprot.getScheme()).getScheme().read(iprot, this); - } - - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { - schemes.get(oprot.getScheme()).getScheme().write(oprot, this); - } - - @Override - public String toString() { - StringBuilder sb = new StringBuilder("BlurQueryStatus("); - boolean first = true; - - sb.append("query:"); - if (this.query == null) { - sb.append("null"); - } else { - sb.append(this.query); - } - first = false; - if (!first) sb.append(", "); - sb.append("cpuTimes:"); - if (this.cpuTimes == null) { - sb.append("null"); - } else { - sb.append(this.cpuTimes); - } - first = false; - if (!first) sb.append(", "); - sb.append("completeShards:"); - sb.append(this.completeShards); - first = false; - if (!first) sb.append(", "); - sb.append("totalShards:"); - sb.append(this.totalShards); - first = false; - if (!first) sb.append(", "); - sb.append("state:"); - if (this.state == null) { - sb.append("null"); - } else { - sb.append(this.state); - } - first = false; - if (!first) sb.append(", "); - sb.append("uuid:"); - sb.append(this.uuid); - first = false; - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - // check for sub-struct validity - if (query != null) { - query.validate(); - } - } - - private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { - try { - write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { - try { - // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor. - __isset_bitfield = 0; - read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private static class BlurQueryStatusStandardSchemeFactory implements SchemeFactory { - public BlurQueryStatusStandardScheme getScheme() { - return new BlurQueryStatusStandardScheme(); - } - } - - private static class BlurQueryStatusStandardScheme extends StandardScheme<BlurQueryStatus> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, BlurQueryStatus struct) throws org.apache.thrift.TException { - org.apache.thrift.protocol.TField schemeField; - iprot.readStructBegin(); - while (true) - { - schemeField = iprot.readFieldBegin(); - if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { - break; - } - switch (schemeField.id) { - case 1: // QUERY - if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.query = new BlurQuery(); - struct.query.read(iprot); - struct.setQueryIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // CPU_TIMES - if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { - { - org.apache.thrift.protocol.TMap _map92 = iprot.readMapBegin(); - struct.cpuTimes = new HashMap<String,CpuTime>(2*_map92.size); - for (int _i93 = 0; _i93 < _map92.size; ++_i93) - { - String _key94; // required - CpuTime _val95; // optional - _key94 = iprot.readString(); - _val95 = new CpuTime(); - _val95.read(iprot); - struct.cpuTimes.put(_key94, _val95); - } - iprot.readMapEnd(); - } - struct.setCpuTimesIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 3: // COMPLETE_SHARDS - if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.completeShards = iprot.readI32(); - struct.setCompleteShardsIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 4: // TOTAL_SHARDS - if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.totalShards = iprot.readI32(); - struct.setTotalShardsIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 5: // STATE - if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.state = QueryState.findByValue(iprot.readI32()); - struct.setStateIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 6: // UUID - if (schemeField.type == org.apache.thrift.protocol.TType.I64) { - struct.uuid = iprot.readI64(); - struct.setUuidIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - default: - org.apache.thrift.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.thrift.protocol.TProtocol oprot, BlurQueryStatus struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.query != null) { - oprot.writeFieldBegin(QUERY_FIELD_DESC); - struct.query.write(oprot); - oprot.writeFieldEnd(); - } - if (struct.cpuTimes != null) { - oprot.writeFieldBegin(CPU_TIMES_FIELD_DESC); - { - oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.cpuTimes.size())); - for (Map.Entry<String, CpuTime> _iter96 : struct.cpuTimes.entrySet()) - { - oprot.writeString(_iter96.getKey()); - _iter96.getValue().write(oprot); - } - oprot.writeMapEnd(); - } - oprot.writeFieldEnd(); - } - oprot.writeFieldBegin(COMPLETE_SHARDS_FIELD_DESC); - oprot.writeI32(struct.completeShards); - oprot.writeFieldEnd(); - oprot.writeFieldBegin(TOTAL_SHARDS_FIELD_DESC); - oprot.writeI32(struct.totalShards); - oprot.writeFieldEnd(); - if (struct.state != null) { - oprot.writeFieldBegin(STATE_FIELD_DESC); - oprot.writeI32(struct.state.getValue()); - oprot.writeFieldEnd(); - } - oprot.writeFieldBegin(UUID_FIELD_DESC); - oprot.writeI64(struct.uuid); - oprot.writeFieldEnd(); - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class BlurQueryStatusTupleSchemeFactory implements SchemeFactory { - public BlurQueryStatusTupleScheme getScheme() { - return new BlurQueryStatusTupleScheme(); - } - } - - private static class BlurQueryStatusTupleScheme extends TupleScheme<BlurQueryStatus> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, BlurQueryStatus struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.isSetQuery()) { - optionals.set(0); - } - if (struct.isSetCpuTimes()) { - optionals.set(1); - } - if (struct.isSetCompleteShards()) { - optionals.set(2); - } - if (struct.isSetTotalShards()) { - optionals.set(3); - } - if (struct.isSetState()) { - optionals.set(4); - } - if (struct.isSetUuid()) { - optionals.set(5); - } - oprot.writeBitSet(optionals, 6); - if (struct.isSetQuery()) { - struct.query.write(oprot); - } - if (struct.isSetCpuTimes()) { - { - oprot.writeI32(struct.cpuTimes.size()); - for (Map.Entry<String, CpuTime> _iter97 : struct.cpuTimes.entrySet()) - { - oprot.writeString(_iter97.getKey()); - _iter97.getValue().write(oprot); - } - } - } - if (struct.isSetCompleteShards()) { - oprot.writeI32(struct.completeShards); - } - if (struct.isSetTotalShards()) { - oprot.writeI32(struct.totalShards); - } - if (struct.isSetState()) { - oprot.writeI32(struct.state.getValue()); - } - if (struct.isSetUuid()) { - oprot.writeI64(struct.uuid); - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, BlurQueryStatus struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(6); - if (incoming.get(0)) { - struct.query = new BlurQuery(); - struct.query.read(iprot); - struct.setQueryIsSet(true); - } - if (incoming.get(1)) { - { - org.apache.thrift.protocol.TMap _map98 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.cpuTimes = new HashMap<String,CpuTime>(2*_map98.size); - for (int _i99 = 0; _i99 < _map98.size; ++_i99) - { - String _key100; // required - CpuTime _val101; // optional - _key100 = iprot.readString(); - _val101 = new CpuTime(); - _val101.read(iprot); - struct.cpuTimes.put(_key100, _val101); - } - } - struct.setCpuTimesIsSet(true); - } - if (incoming.get(2)) { - struct.completeShards = iprot.readI32(); - struct.setCompleteShardsIsSet(true); - } - if (incoming.get(3)) { - struct.totalShards = iprot.readI32(); - struct.setTotalShardsIsSet(true); - } - if (incoming.get(4)) { - struct.state = QueryState.findByValue(iprot.readI32()); - struct.setStateIsSet(true); - } - if (incoming.get(5)) { - struct.uuid = iprot.readI64(); - struct.setUuidIsSet(true); - } - } - } - -} -
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/32e1d176/interface/gen-java/org/apache/blur/thrift/generated/BlurResult.java ---------------------------------------------------------------------- diff --git a/interface/gen-java/org/apache/blur/thrift/generated/BlurResult.java b/interface/gen-java/org/apache/blur/thrift/generated/BlurResult.java deleted file mode 100644 index bf7cacd..0000000 --- a/interface/gen-java/org/apache/blur/thrift/generated/BlurResult.java +++ /dev/null @@ -1,647 +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.thrift.scheme.IScheme; -import org.apache.thrift.scheme.SchemeFactory; -import org.apache.thrift.scheme.StandardScheme; - -import org.apache.thrift.scheme.TupleScheme; -import org.apache.thrift.protocol.TTupleProtocol; -import org.apache.thrift.protocol.TProtocolException; -import org.apache.thrift.EncodingUtils; -import org.apache.thrift.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 BlurResult implements org.apache.thrift.TBase<BlurResult, BlurResult._Fields>, java.io.Serializable, Cloneable { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("BlurResult"); - - private static final org.apache.thrift.protocol.TField LOCATION_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("locationId", org.apache.thrift.protocol.TType.STRING, (short)1); - private static final org.apache.thrift.protocol.TField SCORE_FIELD_DESC = new org.apache.thrift.protocol.TField("score", org.apache.thrift.protocol.TType.DOUBLE, (short)2); - private static final org.apache.thrift.protocol.TField FETCH_RESULT_FIELD_DESC = new org.apache.thrift.protocol.TField("fetchResult", org.apache.thrift.protocol.TType.STRUCT, (short)3); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new BlurResultStandardSchemeFactory()); - schemes.put(TupleScheme.class, new BlurResultTupleSchemeFactory()); - } - - /** - * - */ - public String locationId; // required - /** - * - */ - public double score; // required - /** - * - */ - public FetchResult fetchResult; // required - - /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - public enum _Fields implements org.apache.thrift.TFieldIdEnum { - /** - * - */ - LOCATION_ID((short)1, "locationId"), - /** - * - */ - SCORE((short)2, "score"), - /** - * - */ - FETCH_RESULT((short)3, "fetchResult"); - - 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: // LOCATION_ID - return LOCATION_ID; - case 2: // SCORE - return SCORE; - case 3: // FETCH_RESULT - return FETCH_RESULT; - 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 - private static final int __SCORE_ISSET_ID = 0; - private byte __isset_bitfield = 0; - public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; - static { - Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); - tmpMap.put(_Fields.LOCATION_ID, new org.apache.thrift.meta_data.FieldMetaData("locationId", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.SCORE, new org.apache.thrift.meta_data.FieldMetaData("score", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.DOUBLE))); - tmpMap.put(_Fields.FETCH_RESULT, new org.apache.thrift.meta_data.FieldMetaData("fetchResult", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, FetchResult.class))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(BlurResult.class, metaDataMap); - } - - public BlurResult() { - } - - public BlurResult( - String locationId, - double score, - FetchResult fetchResult) - { - this(); - this.locationId = locationId; - this.score = score; - setScoreIsSet(true); - this.fetchResult = fetchResult; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public BlurResult(BlurResult other) { - __isset_bitfield = other.__isset_bitfield; - if (other.isSetLocationId()) { - this.locationId = other.locationId; - } - this.score = other.score; - if (other.isSetFetchResult()) { - this.fetchResult = new FetchResult(other.fetchResult); - } - } - - public BlurResult deepCopy() { - return new BlurResult(this); - } - - @Override - public void clear() { - this.locationId = null; - setScoreIsSet(false); - this.score = 0.0; - this.fetchResult = null; - } - - /** - * - */ - public String getLocationId() { - return this.locationId; - } - - /** - * - */ - public BlurResult setLocationId(String locationId) { - this.locationId = locationId; - return this; - } - - public void unsetLocationId() { - this.locationId = null; - } - - /** Returns true if field locationId is set (has been assigned a value) and false otherwise */ - public boolean isSetLocationId() { - return this.locationId != null; - } - - public void setLocationIdIsSet(boolean value) { - if (!value) { - this.locationId = null; - } - } - - /** - * - */ - public double getScore() { - return this.score; - } - - /** - * - */ - public BlurResult setScore(double score) { - this.score = score; - setScoreIsSet(true); - return this; - } - - public void unsetScore() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __SCORE_ISSET_ID); - } - - /** Returns true if field score is set (has been assigned a value) and false otherwise */ - public boolean isSetScore() { - return EncodingUtils.testBit(__isset_bitfield, __SCORE_ISSET_ID); - } - - public void setScoreIsSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __SCORE_ISSET_ID, value); - } - - /** - * - */ - public FetchResult getFetchResult() { - return this.fetchResult; - } - - /** - * - */ - public BlurResult setFetchResult(FetchResult fetchResult) { - this.fetchResult = fetchResult; - return this; - } - - public void unsetFetchResult() { - this.fetchResult = null; - } - - /** Returns true if field fetchResult is set (has been assigned a value) and false otherwise */ - public boolean isSetFetchResult() { - return this.fetchResult != null; - } - - public void setFetchResultIsSet(boolean value) { - if (!value) { - this.fetchResult = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case LOCATION_ID: - if (value == null) { - unsetLocationId(); - } else { - setLocationId((String)value); - } - break; - - case SCORE: - if (value == null) { - unsetScore(); - } else { - setScore((Double)value); - } - break; - - case FETCH_RESULT: - if (value == null) { - unsetFetchResult(); - } else { - setFetchResult((FetchResult)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case LOCATION_ID: - return getLocationId(); - - case SCORE: - return Double.valueOf(getScore()); - - case FETCH_RESULT: - return getFetchResult(); - - } - 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 LOCATION_ID: - return isSetLocationId(); - case SCORE: - return isSetScore(); - case FETCH_RESULT: - return isSetFetchResult(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof BlurResult) - return this.equals((BlurResult)that); - return false; - } - - public boolean equals(BlurResult that) { - if (that == null) - return false; - - boolean this_present_locationId = true && this.isSetLocationId(); - boolean that_present_locationId = true && that.isSetLocationId(); - if (this_present_locationId || that_present_locationId) { - if (!(this_present_locationId && that_present_locationId)) - return false; - if (!this.locationId.equals(that.locationId)) - return false; - } - - boolean this_present_score = true; - boolean that_present_score = true; - if (this_present_score || that_present_score) { - if (!(this_present_score && that_present_score)) - return false; - if (this.score != that.score) - return false; - } - - boolean this_present_fetchResult = true && this.isSetFetchResult(); - boolean that_present_fetchResult = true && that.isSetFetchResult(); - if (this_present_fetchResult || that_present_fetchResult) { - if (!(this_present_fetchResult && that_present_fetchResult)) - return false; - if (!this.fetchResult.equals(that.fetchResult)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - return 0; - } - - public int compareTo(BlurResult other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - BlurResult typedOther = (BlurResult)other; - - lastComparison = Boolean.valueOf(isSetLocationId()).compareTo(typedOther.isSetLocationId()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetLocationId()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.locationId, typedOther.locationId); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetScore()).compareTo(typedOther.isSetScore()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetScore()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.score, typedOther.score); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetFetchResult()).compareTo(typedOther.isSetFetchResult()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetFetchResult()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.fetchResult, typedOther.fetchResult); - if (lastComparison != 0) { - return lastComparison; - } - } - return 0; - } - - public _Fields fieldForId(int fieldId) { - return _Fields.findByThriftId(fieldId); - } - - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { - schemes.get(iprot.getScheme()).getScheme().read(iprot, this); - } - - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { - schemes.get(oprot.getScheme()).getScheme().write(oprot, this); - } - - @Override - public String toString() { - StringBuilder sb = new StringBuilder("BlurResult("); - boolean first = true; - - sb.append("locationId:"); - if (this.locationId == null) { - sb.append("null"); - } else { - sb.append(this.locationId); - } - first = false; - if (!first) sb.append(", "); - sb.append("score:"); - sb.append(this.score); - first = false; - if (!first) sb.append(", "); - sb.append("fetchResult:"); - if (this.fetchResult == null) { - sb.append("null"); - } else { - sb.append(this.fetchResult); - } - first = false; - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - // check for sub-struct validity - if (fetchResult != null) { - fetchResult.validate(); - } - } - - private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { - try { - write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { - try { - // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor. - __isset_bitfield = 0; - read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private static class BlurResultStandardSchemeFactory implements SchemeFactory { - public BlurResultStandardScheme getScheme() { - return new BlurResultStandardScheme(); - } - } - - private static class BlurResultStandardScheme extends StandardScheme<BlurResult> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, BlurResult struct) throws org.apache.thrift.TException { - org.apache.thrift.protocol.TField schemeField; - iprot.readStructBegin(); - while (true) - { - schemeField = iprot.readFieldBegin(); - if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { - break; - } - switch (schemeField.id) { - case 1: // LOCATION_ID - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.locationId = iprot.readString(); - struct.setLocationIdIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // SCORE - if (schemeField.type == org.apache.thrift.protocol.TType.DOUBLE) { - struct.score = iprot.readDouble(); - struct.setScoreIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 3: // FETCH_RESULT - if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.fetchResult = new FetchResult(); - struct.fetchResult.read(iprot); - struct.setFetchResultIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - default: - org.apache.thrift.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.thrift.protocol.TProtocol oprot, BlurResult struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.locationId != null) { - oprot.writeFieldBegin(LOCATION_ID_FIELD_DESC); - oprot.writeString(struct.locationId); - oprot.writeFieldEnd(); - } - oprot.writeFieldBegin(SCORE_FIELD_DESC); - oprot.writeDouble(struct.score); - oprot.writeFieldEnd(); - if (struct.fetchResult != null) { - oprot.writeFieldBegin(FETCH_RESULT_FIELD_DESC); - struct.fetchResult.write(oprot); - oprot.writeFieldEnd(); - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class BlurResultTupleSchemeFactory implements SchemeFactory { - public BlurResultTupleScheme getScheme() { - return new BlurResultTupleScheme(); - } - } - - private static class BlurResultTupleScheme extends TupleScheme<BlurResult> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, BlurResult struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.isSetLocationId()) { - optionals.set(0); - } - if (struct.isSetScore()) { - optionals.set(1); - } - if (struct.isSetFetchResult()) { - optionals.set(2); - } - oprot.writeBitSet(optionals, 3); - if (struct.isSetLocationId()) { - oprot.writeString(struct.locationId); - } - if (struct.isSetScore()) { - oprot.writeDouble(struct.score); - } - if (struct.isSetFetchResult()) { - struct.fetchResult.write(oprot); - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, BlurResult struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(3); - if (incoming.get(0)) { - struct.locationId = iprot.readString(); - struct.setLocationIdIsSet(true); - } - if (incoming.get(1)) { - struct.score = iprot.readDouble(); - struct.setScoreIsSet(true); - } - if (incoming.get(2)) { - struct.fetchResult = new FetchResult(); - struct.fetchResult.read(iprot); - struct.setFetchResultIsSet(true); - } - } - } - -} -
