http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/e5ae88af/scripts/interface/gen-java/org/apache/blur/thrift/generated/CpuTime.java ---------------------------------------------------------------------- diff --git a/scripts/interface/gen-java/org/apache/blur/thrift/generated/CpuTime.java b/scripts/interface/gen-java/org/apache/blur/thrift/generated/CpuTime.java new file mode 100644 index 0000000..bbc1ab9 --- /dev/null +++ b/scripts/interface/gen-java/org/apache/blur/thrift/generated/CpuTime.java @@ -0,0 +1,524 @@ +/** + * 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/scripts/interface/gen-java/org/apache/blur/thrift/generated/ErrorType.java ---------------------------------------------------------------------- diff --git a/scripts/interface/gen-java/org/apache/blur/thrift/generated/ErrorType.java b/scripts/interface/gen-java/org/apache/blur/thrift/generated/ErrorType.java new file mode 100644 index 0000000..56c205e --- /dev/null +++ b/scripts/interface/gen-java/org/apache/blur/thrift/generated/ErrorType.java @@ -0,0 +1,83 @@ +/** + * 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/scripts/interface/gen-java/org/apache/blur/thrift/generated/Facet.java ---------------------------------------------------------------------- diff --git a/scripts/interface/gen-java/org/apache/blur/thrift/generated/Facet.java b/scripts/interface/gen-java/org/apache/blur/thrift/generated/Facet.java new file mode 100644 index 0000000..b0794f0 --- /dev/null +++ b/scripts/interface/gen-java/org/apache/blur/thrift/generated/Facet.java @@ -0,0 +1,552 @@ +/** + * 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/scripts/interface/gen-java/org/apache/blur/thrift/generated/FetchRecordResult.java ---------------------------------------------------------------------- diff --git a/scripts/interface/gen-java/org/apache/blur/thrift/generated/FetchRecordResult.java b/scripts/interface/gen-java/org/apache/blur/thrift/generated/FetchRecordResult.java new file mode 100644 index 0000000..60e7051 --- /dev/null +++ b/scripts/interface/gen-java/org/apache/blur/thrift/generated/FetchRecordResult.java @@ -0,0 +1,537 @@ +/** + * 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); + } + } + } + +} +
