http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/e5ae88af/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/CpuTime.java ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/CpuTime.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/CpuTime.java deleted file mode 100644 index bbc1ab9..0000000 --- a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/CpuTime.java +++ /dev/null @@ -1,524 +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; - -/** - * Holds the cpu time for a query executing on a single shard in a table. - */ -public class CpuTime implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<CpuTime, CpuTime._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("CpuTime"); - - private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField CPU_TIME_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("cpuTime", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64, (short)1); - private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField REAL_TIME_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("realTime", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64, (short)2); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new CpuTimeStandardSchemeFactory()); - schemes.put(TupleScheme.class, new CpuTimeTupleSchemeFactory()); - } - - /** - * The total cpu time for the query on the given shard. - */ - public long cpuTime; // required - /** - * The real time of the query execution for a given shard. - */ - public long realTime; // 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 { - /** - * The total cpu time for the query on the given shard. - */ - CPU_TIME((short)1, "cpuTime"), - /** - * The real time of the query execution for a given shard. - */ - REAL_TIME((short)2, "realTime"); - - 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: // CPU_TIME - return CPU_TIME; - case 2: // REAL_TIME - return REAL_TIME; - 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 __CPUTIME_ISSET_ID = 0; - private static final int __REALTIME_ISSET_ID = 1; - private byte __isset_bitfield = 0; - 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.CPU_TIME, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("cpuTime", 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.I64))); - tmpMap.put(_Fields.REAL_TIME, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("realTime", 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.I64))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(CpuTime.class, metaDataMap); - } - - public CpuTime() { - } - - public CpuTime( - long cpuTime, - long realTime) - { - this(); - this.cpuTime = cpuTime; - setCpuTimeIsSet(true); - this.realTime = realTime; - setRealTimeIsSet(true); - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public CpuTime(CpuTime other) { - __isset_bitfield = other.__isset_bitfield; - this.cpuTime = other.cpuTime; - this.realTime = other.realTime; - } - - public CpuTime deepCopy() { - return new CpuTime(this); - } - - @Override - public void clear() { - setCpuTimeIsSet(false); - this.cpuTime = 0; - setRealTimeIsSet(false); - this.realTime = 0; - } - - /** - * The total cpu time for the query on the given shard. - */ - public long getCpuTime() { - return this.cpuTime; - } - - /** - * The total cpu time for the query on the given shard. - */ - public CpuTime setCpuTime(long cpuTime) { - this.cpuTime = cpuTime; - setCpuTimeIsSet(true); - return this; - } - - public void unsetCpuTime() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __CPUTIME_ISSET_ID); - } - - /** Returns true if field cpuTime is set (has been assigned a value) and false otherwise */ - public boolean isSetCpuTime() { - return EncodingUtils.testBit(__isset_bitfield, __CPUTIME_ISSET_ID); - } - - public void setCpuTimeIsSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __CPUTIME_ISSET_ID, value); - } - - /** - * The real time of the query execution for a given shard. - */ - public long getRealTime() { - return this.realTime; - } - - /** - * The real time of the query execution for a given shard. - */ - public CpuTime setRealTime(long realTime) { - this.realTime = realTime; - setRealTimeIsSet(true); - return this; - } - - public void unsetRealTime() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __REALTIME_ISSET_ID); - } - - /** Returns true if field realTime is set (has been assigned a value) and false otherwise */ - public boolean isSetRealTime() { - return EncodingUtils.testBit(__isset_bitfield, __REALTIME_ISSET_ID); - } - - public void setRealTimeIsSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __REALTIME_ISSET_ID, value); - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case CPU_TIME: - if (value == null) { - unsetCpuTime(); - } else { - setCpuTime((Long)value); - } - break; - - case REAL_TIME: - if (value == null) { - unsetRealTime(); - } else { - setRealTime((Long)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case CPU_TIME: - return Long.valueOf(getCpuTime()); - - case REAL_TIME: - return Long.valueOf(getRealTime()); - - } - 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 CPU_TIME: - return isSetCpuTime(); - case REAL_TIME: - return isSetRealTime(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof CpuTime) - return this.equals((CpuTime)that); - return false; - } - - public boolean equals(CpuTime that) { - if (that == null) - return false; - - boolean this_present_cpuTime = true; - boolean that_present_cpuTime = true; - if (this_present_cpuTime || that_present_cpuTime) { - if (!(this_present_cpuTime && that_present_cpuTime)) - return false; - if (this.cpuTime != that.cpuTime) - return false; - } - - boolean this_present_realTime = true; - boolean that_present_realTime = true; - if (this_present_realTime || that_present_realTime) { - if (!(this_present_realTime && that_present_realTime)) - return false; - if (this.realTime != that.realTime) - return false; - } - - return true; - } - - @Override - public int hashCode() { - return 0; - } - - public int compareTo(CpuTime other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - CpuTime typedOther = (CpuTime)other; - - lastComparison = Boolean.valueOf(isSetCpuTime()).compareTo(typedOther.isSetCpuTime()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetCpuTime()) { - lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.cpuTime, typedOther.cpuTime); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetRealTime()).compareTo(typedOther.isSetRealTime()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetRealTime()) { - lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.realTime, typedOther.realTime); - 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("CpuTime("); - boolean first = true; - - sb.append("cpuTime:"); - sb.append(this.cpuTime); - first = false; - if (!first) sb.append(", "); - sb.append("realTime:"); - sb.append(this.realTime); - 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 { - // 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.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 CpuTimeStandardSchemeFactory implements SchemeFactory { - public CpuTimeStandardScheme getScheme() { - return new CpuTimeStandardScheme(); - } - } - - private static class CpuTimeStandardScheme extends StandardScheme<CpuTime> { - - public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, CpuTime 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: // CPU_TIME - if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64) { - struct.cpuTime = iprot.readI64(); - struct.setCpuTimeIsSet(true); - } else { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // REAL_TIME - if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64) { - struct.realTime = iprot.readI64(); - struct.setRealTimeIsSet(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, CpuTime struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - oprot.writeFieldBegin(CPU_TIME_FIELD_DESC); - oprot.writeI64(struct.cpuTime); - oprot.writeFieldEnd(); - oprot.writeFieldBegin(REAL_TIME_FIELD_DESC); - oprot.writeI64(struct.realTime); - oprot.writeFieldEnd(); - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class CpuTimeTupleSchemeFactory implements SchemeFactory { - public CpuTimeTupleScheme getScheme() { - return new CpuTimeTupleScheme(); - } - } - - private static class CpuTimeTupleScheme extends TupleScheme<CpuTime> { - - @Override - public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, CpuTime struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.isSetCpuTime()) { - optionals.set(0); - } - if (struct.isSetRealTime()) { - optionals.set(1); - } - oprot.writeBitSet(optionals, 2); - if (struct.isSetCpuTime()) { - oprot.writeI64(struct.cpuTime); - } - if (struct.isSetRealTime()) { - oprot.writeI64(struct.realTime); - } - } - - @Override - public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, CpuTime 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.cpuTime = iprot.readI64(); - struct.setCpuTimeIsSet(true); - } - if (incoming.get(1)) { - struct.realTime = iprot.readI64(); - struct.setRealTimeIsSet(true); - } - } - } - -} -
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/e5ae88af/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/ErrorType.java ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/ErrorType.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/ErrorType.java deleted file mode 100644 index 56c205e..0000000 --- a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/ErrorType.java +++ /dev/null @@ -1,83 +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 java.util.Map; -import java.util.HashMap; -import org.apache.blur.thirdparty.thrift_0_9_0.TEnum; - -/** - * <table class="table-bordered table-striped table-condensed"> - * <tr><td colspan="2">The error type of a BlurException.</td></tr> - * <tr><td>UNKNOWN</td><td>Unknown error.</td></tr> - * <tr><td>QUERY_CANCEL</td><td>Query has been cancel.</td></tr> - * <tr><td>QUERY_TIMEOUT</td><td>Query has timed out.</td></tr> - * <tr><td>BACK_PRESSURE</td><td>Server has run out of memory and is trying to prevent a failure.</td></tr> - * <tr><td>REQUEST_TIMEOUT</td><td>The TCP connection has timed out.</td></tr> - * </table> - */ -public enum ErrorType implements org.apache.blur.thirdparty.thrift_0_9_0.TEnum { - UNKNOWN(0), - QUERY_CANCEL(1), - QUERY_TIMEOUT(2), - BACK_PRESSURE(3), - REQUEST_TIMEOUT(4); - - private final int value; - - private ErrorType(int value) { - this.value = value; - } - - /** - * Get the integer value of this enum value, as defined in the Thrift IDL. - */ - public int getValue() { - return value; - } - - /** - * Find a the enum type by its integer value, as defined in the Thrift IDL. - * @return null if the value is not found. - */ - public static ErrorType findByValue(int value) { - switch (value) { - case 0: - return UNKNOWN; - case 1: - return QUERY_CANCEL; - case 2: - return QUERY_TIMEOUT; - case 3: - return BACK_PRESSURE; - case 4: - return REQUEST_TIMEOUT; - default: - return null; - } - } -} http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/e5ae88af/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Facet.java ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Facet.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Facet.java deleted file mode 100644 index b0794f0..0000000 --- a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Facet.java +++ /dev/null @@ -1,552 +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; - -/** - * Blur facet. - */ -public class Facet implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Facet, Facet._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("Facet"); - - private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField QUERY_STR_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("queryStr", 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 MINIMUM_NUMBER_OF_BLUR_RESULTS_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("minimumNumberOfBlurResults", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64, (short)2); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new FacetStandardSchemeFactory()); - schemes.put(TupleScheme.class, new FacetTupleSchemeFactory()); - } - - /** - * The facet query. - */ - public String queryStr; // required - /** - * The minimum number of results before no longer processing the facet. This - * is a good way to decrease the strain on the system while using many facets. For - * example if you set this attribute to 1000, then the shard server will stop - * processing the facet at the 1000 mark. However because this is processed at - * the shard server level the controller will likely return more than the minimum - * because it sums the answers from the shard servers. - */ - public long minimumNumberOfBlurResults; // 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 { - /** - * The facet query. - */ - QUERY_STR((short)1, "queryStr"), - /** - * The minimum number of results before no longer processing the facet. This - * is a good way to decrease the strain on the system while using many facets. For - * example if you set this attribute to 1000, then the shard server will stop - * processing the facet at the 1000 mark. However because this is processed at - * the shard server level the controller will likely return more than the minimum - * because it sums the answers from the shard servers. - */ - MINIMUM_NUMBER_OF_BLUR_RESULTS((short)2, "minimumNumberOfBlurResults"); - - 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_STR - return QUERY_STR; - case 2: // MINIMUM_NUMBER_OF_BLUR_RESULTS - return MINIMUM_NUMBER_OF_BLUR_RESULTS; - 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 __MINIMUMNUMBEROFBLURRESULTS_ISSET_ID = 0; - private byte __isset_bitfield = 0; - 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.QUERY_STR, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("queryStr", 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.MINIMUM_NUMBER_OF_BLUR_RESULTS, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("minimumNumberOfBlurResults", 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.I64))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(Facet.class, metaDataMap); - } - - public Facet() { - this.minimumNumberOfBlurResults = 9223372036854775807L; - - } - - public Facet( - String queryStr, - long minimumNumberOfBlurResults) - { - this(); - this.queryStr = queryStr; - this.minimumNumberOfBlurResults = minimumNumberOfBlurResults; - setMinimumNumberOfBlurResultsIsSet(true); - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public Facet(Facet other) { - __isset_bitfield = other.__isset_bitfield; - if (other.isSetQueryStr()) { - this.queryStr = other.queryStr; - } - this.minimumNumberOfBlurResults = other.minimumNumberOfBlurResults; - } - - public Facet deepCopy() { - return new Facet(this); - } - - @Override - public void clear() { - this.queryStr = null; - this.minimumNumberOfBlurResults = 9223372036854775807L; - - } - - /** - * The facet query. - */ - public String getQueryStr() { - return this.queryStr; - } - - /** - * The facet query. - */ - public Facet setQueryStr(String queryStr) { - this.queryStr = queryStr; - return this; - } - - public void unsetQueryStr() { - this.queryStr = null; - } - - /** Returns true if field queryStr is set (has been assigned a value) and false otherwise */ - public boolean isSetQueryStr() { - return this.queryStr != null; - } - - public void setQueryStrIsSet(boolean value) { - if (!value) { - this.queryStr = null; - } - } - - /** - * The minimum number of results before no longer processing the facet. This - * is a good way to decrease the strain on the system while using many facets. For - * example if you set this attribute to 1000, then the shard server will stop - * processing the facet at the 1000 mark. However because this is processed at - * the shard server level the controller will likely return more than the minimum - * because it sums the answers from the shard servers. - */ - public long getMinimumNumberOfBlurResults() { - return this.minimumNumberOfBlurResults; - } - - /** - * The minimum number of results before no longer processing the facet. This - * is a good way to decrease the strain on the system while using many facets. For - * example if you set this attribute to 1000, then the shard server will stop - * processing the facet at the 1000 mark. However because this is processed at - * the shard server level the controller will likely return more than the minimum - * because it sums the answers from the shard servers. - */ - public Facet setMinimumNumberOfBlurResults(long minimumNumberOfBlurResults) { - this.minimumNumberOfBlurResults = minimumNumberOfBlurResults; - setMinimumNumberOfBlurResultsIsSet(true); - return this; - } - - public void unsetMinimumNumberOfBlurResults() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __MINIMUMNUMBEROFBLURRESULTS_ISSET_ID); - } - - /** Returns true if field minimumNumberOfBlurResults is set (has been assigned a value) and false otherwise */ - public boolean isSetMinimumNumberOfBlurResults() { - return EncodingUtils.testBit(__isset_bitfield, __MINIMUMNUMBEROFBLURRESULTS_ISSET_ID); - } - - public void setMinimumNumberOfBlurResultsIsSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __MINIMUMNUMBEROFBLURRESULTS_ISSET_ID, value); - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case QUERY_STR: - if (value == null) { - unsetQueryStr(); - } else { - setQueryStr((String)value); - } - break; - - case MINIMUM_NUMBER_OF_BLUR_RESULTS: - if (value == null) { - unsetMinimumNumberOfBlurResults(); - } else { - setMinimumNumberOfBlurResults((Long)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case QUERY_STR: - return getQueryStr(); - - case MINIMUM_NUMBER_OF_BLUR_RESULTS: - return Long.valueOf(getMinimumNumberOfBlurResults()); - - } - 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_STR: - return isSetQueryStr(); - case MINIMUM_NUMBER_OF_BLUR_RESULTS: - return isSetMinimumNumberOfBlurResults(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof Facet) - return this.equals((Facet)that); - return false; - } - - public boolean equals(Facet that) { - if (that == null) - return false; - - boolean this_present_queryStr = true && this.isSetQueryStr(); - boolean that_present_queryStr = true && that.isSetQueryStr(); - if (this_present_queryStr || that_present_queryStr) { - if (!(this_present_queryStr && that_present_queryStr)) - return false; - if (!this.queryStr.equals(that.queryStr)) - return false; - } - - boolean this_present_minimumNumberOfBlurResults = true; - boolean that_present_minimumNumberOfBlurResults = true; - if (this_present_minimumNumberOfBlurResults || that_present_minimumNumberOfBlurResults) { - if (!(this_present_minimumNumberOfBlurResults && that_present_minimumNumberOfBlurResults)) - return false; - if (this.minimumNumberOfBlurResults != that.minimumNumberOfBlurResults) - return false; - } - - return true; - } - - @Override - public int hashCode() { - return 0; - } - - public int compareTo(Facet other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - Facet typedOther = (Facet)other; - - lastComparison = Boolean.valueOf(isSetQueryStr()).compareTo(typedOther.isSetQueryStr()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetQueryStr()) { - lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.queryStr, typedOther.queryStr); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetMinimumNumberOfBlurResults()).compareTo(typedOther.isSetMinimumNumberOfBlurResults()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetMinimumNumberOfBlurResults()) { - lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.minimumNumberOfBlurResults, typedOther.minimumNumberOfBlurResults); - 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("Facet("); - boolean first = true; - - sb.append("queryStr:"); - if (this.queryStr == null) { - sb.append("null"); - } else { - sb.append(this.queryStr); - } - first = false; - if (!first) sb.append(", "); - sb.append("minimumNumberOfBlurResults:"); - sb.append(this.minimumNumberOfBlurResults); - 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 { - // 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.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 FacetStandardSchemeFactory implements SchemeFactory { - public FacetStandardScheme getScheme() { - return new FacetStandardScheme(); - } - } - - private static class FacetStandardScheme extends StandardScheme<Facet> { - - public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, Facet 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: // QUERY_STR - if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING) { - struct.queryStr = iprot.readString(); - struct.setQueryStrIsSet(true); - } else { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // MINIMUM_NUMBER_OF_BLUR_RESULTS - if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64) { - struct.minimumNumberOfBlurResults = iprot.readI64(); - struct.setMinimumNumberOfBlurResultsIsSet(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, Facet struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.queryStr != null) { - oprot.writeFieldBegin(QUERY_STR_FIELD_DESC); - oprot.writeString(struct.queryStr); - oprot.writeFieldEnd(); - } - oprot.writeFieldBegin(MINIMUM_NUMBER_OF_BLUR_RESULTS_FIELD_DESC); - oprot.writeI64(struct.minimumNumberOfBlurResults); - oprot.writeFieldEnd(); - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class FacetTupleSchemeFactory implements SchemeFactory { - public FacetTupleScheme getScheme() { - return new FacetTupleScheme(); - } - } - - private static class FacetTupleScheme extends TupleScheme<Facet> { - - @Override - public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, Facet struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.isSetQueryStr()) { - optionals.set(0); - } - if (struct.isSetMinimumNumberOfBlurResults()) { - optionals.set(1); - } - oprot.writeBitSet(optionals, 2); - if (struct.isSetQueryStr()) { - oprot.writeString(struct.queryStr); - } - if (struct.isSetMinimumNumberOfBlurResults()) { - oprot.writeI64(struct.minimumNumberOfBlurResults); - } - } - - @Override - public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, Facet 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.queryStr = iprot.readString(); - struct.setQueryStrIsSet(true); - } - if (incoming.get(1)) { - struct.minimumNumberOfBlurResults = iprot.readI64(); - struct.setMinimumNumberOfBlurResultsIsSet(true); - } - } - } - -} - http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/e5ae88af/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/FetchRecordResult.java ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/FetchRecordResult.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/FetchRecordResult.java deleted file mode 100644 index 60e7051..0000000 --- a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/FetchRecordResult.java +++ /dev/null @@ -1,537 +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; - -/** - * FetchRecordResult contains rowid of the record and the record result from a fetch. - */ -public class FetchRecordResult implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<FetchRecordResult, FetchRecordResult._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("FetchRecordResult"); - - private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField ROWID_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("rowid", 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 RECORD_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("record", 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 FetchRecordResultStandardSchemeFactory()); - schemes.put(TupleScheme.class, new FetchRecordResultTupleSchemeFactory()); - } - - /** - * The row id of the record being fetched. - */ - public String rowid; // required - /** - * The record fetched. - */ - public Record record; // 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 { - /** - * The row id of the record being fetched. - */ - ROWID((short)1, "rowid"), - /** - * The record fetched. - */ - RECORD((short)2, "record"); - - 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: // ROWID - return ROWID; - case 2: // RECORD - return RECORD; - 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.ROWID, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("rowid", 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.RECORD, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("record", 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, Record.class))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(FetchRecordResult.class, metaDataMap); - } - - public FetchRecordResult() { - } - - public FetchRecordResult( - String rowid, - Record record) - { - this(); - this.rowid = rowid; - this.record = record; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public FetchRecordResult(FetchRecordResult other) { - if (other.isSetRowid()) { - this.rowid = other.rowid; - } - if (other.isSetRecord()) { - this.record = new Record(other.record); - } - } - - public FetchRecordResult deepCopy() { - return new FetchRecordResult(this); - } - - @Override - public void clear() { - this.rowid = null; - this.record = null; - } - - /** - * The row id of the record being fetched. - */ - public String getRowid() { - return this.rowid; - } - - /** - * The row id of the record being fetched. - */ - public FetchRecordResult setRowid(String rowid) { - this.rowid = rowid; - return this; - } - - public void unsetRowid() { - this.rowid = null; - } - - /** Returns true if field rowid is set (has been assigned a value) and false otherwise */ - public boolean isSetRowid() { - return this.rowid != null; - } - - public void setRowidIsSet(boolean value) { - if (!value) { - this.rowid = null; - } - } - - /** - * The record fetched. - */ - public Record getRecord() { - return this.record; - } - - /** - * The record fetched. - */ - public FetchRecordResult setRecord(Record record) { - this.record = record; - return this; - } - - public void unsetRecord() { - this.record = null; - } - - /** Returns true if field record is set (has been assigned a value) and false otherwise */ - public boolean isSetRecord() { - return this.record != null; - } - - public void setRecordIsSet(boolean value) { - if (!value) { - this.record = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case ROWID: - if (value == null) { - unsetRowid(); - } else { - setRowid((String)value); - } - break; - - case RECORD: - if (value == null) { - unsetRecord(); - } else { - setRecord((Record)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case ROWID: - return getRowid(); - - case RECORD: - return getRecord(); - - } - 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 ROWID: - return isSetRowid(); - case RECORD: - return isSetRecord(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof FetchRecordResult) - return this.equals((FetchRecordResult)that); - return false; - } - - public boolean equals(FetchRecordResult that) { - if (that == null) - return false; - - boolean this_present_rowid = true && this.isSetRowid(); - boolean that_present_rowid = true && that.isSetRowid(); - if (this_present_rowid || that_present_rowid) { - if (!(this_present_rowid && that_present_rowid)) - return false; - if (!this.rowid.equals(that.rowid)) - return false; - } - - boolean this_present_record = true && this.isSetRecord(); - boolean that_present_record = true && that.isSetRecord(); - if (this_present_record || that_present_record) { - if (!(this_present_record && that_present_record)) - return false; - if (!this.record.equals(that.record)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - return 0; - } - - public int compareTo(FetchRecordResult other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - FetchRecordResult typedOther = (FetchRecordResult)other; - - lastComparison = Boolean.valueOf(isSetRowid()).compareTo(typedOther.isSetRowid()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetRowid()) { - lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.rowid, typedOther.rowid); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetRecord()).compareTo(typedOther.isSetRecord()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetRecord()) { - lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.record, typedOther.record); - 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("FetchRecordResult("); - boolean first = true; - - sb.append("rowid:"); - if (this.rowid == null) { - sb.append("null"); - } else { - sb.append(this.rowid); - } - first = false; - if (!first) sb.append(", "); - sb.append("record:"); - if (this.record == null) { - sb.append("null"); - } else { - sb.append(this.record); - } - 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 (record != null) { - record.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 FetchRecordResultStandardSchemeFactory implements SchemeFactory { - public FetchRecordResultStandardScheme getScheme() { - return new FetchRecordResultStandardScheme(); - } - } - - private static class FetchRecordResultStandardScheme extends StandardScheme<FetchRecordResult> { - - public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, FetchRecordResult 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: // ROWID - if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING) { - struct.rowid = iprot.readString(); - struct.setRowidIsSet(true); - } else { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // RECORD - if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT) { - struct.record = new Record(); - struct.record.read(iprot); - struct.setRecordIsSet(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, FetchRecordResult struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.rowid != null) { - oprot.writeFieldBegin(ROWID_FIELD_DESC); - oprot.writeString(struct.rowid); - oprot.writeFieldEnd(); - } - if (struct.record != null) { - oprot.writeFieldBegin(RECORD_FIELD_DESC); - struct.record.write(oprot); - oprot.writeFieldEnd(); - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class FetchRecordResultTupleSchemeFactory implements SchemeFactory { - public FetchRecordResultTupleScheme getScheme() { - return new FetchRecordResultTupleScheme(); - } - } - - private static class FetchRecordResultTupleScheme extends TupleScheme<FetchRecordResult> { - - @Override - public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, FetchRecordResult struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.isSetRowid()) { - optionals.set(0); - } - if (struct.isSetRecord()) { - optionals.set(1); - } - oprot.writeBitSet(optionals, 2); - if (struct.isSetRowid()) { - oprot.writeString(struct.rowid); - } - if (struct.isSetRecord()) { - struct.record.write(oprot); - } - } - - @Override - public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, FetchRecordResult 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.rowid = iprot.readString(); - struct.setRowidIsSet(true); - } - if (incoming.get(1)) { - struct.record = new Record(); - struct.record.read(iprot); - struct.setRecordIsSet(true); - } - } - } - -} -
