http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/e5ae88af/scripts/interface/gen-java/org/apache/blur/thrift/generated/Metric.java ---------------------------------------------------------------------- diff --git a/scripts/interface/gen-java/org/apache/blur/thrift/generated/Metric.java b/scripts/interface/gen-java/org/apache/blur/thrift/generated/Metric.java new file mode 100644 index 0000000..ccb417c --- /dev/null +++ b/scripts/interface/gen-java/org/apache/blur/thrift/generated/Metric.java @@ -0,0 +1,945 @@ +/** + * 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; + +/** + * The Metric will hold all the information for a given Metric. + */ +public class Metric implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Metric, Metric._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("Metric"); + + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField NAME_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("name", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, (short)1); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField STR_MAP_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("strMap", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP, (short)2); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField LONG_MAP_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("longMap", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP, (short)3); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField DOUBLE_MAP_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("doubleMap", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP, (short)4); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new MetricStandardSchemeFactory()); + schemes.put(TupleScheme.class, new MetricTupleSchemeFactory()); + } + + /** + * metric name. + */ + public String name; // required + /** + * map of string values emitted by the Metric. + */ + public Map<String,String> strMap; // required + /** + * map of long values emitted by the Metric. + */ + public Map<String,Long> longMap; // required + /** + * map of double values emitted by the Metric. + */ + public Map<String,Double> doubleMap; // 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 { + /** + * metric name. + */ + NAME((short)1, "name"), + /** + * map of string values emitted by the Metric. + */ + STR_MAP((short)2, "strMap"), + /** + * map of long values emitted by the Metric. + */ + LONG_MAP((short)3, "longMap"), + /** + * map of double values emitted by the Metric. + */ + DOUBLE_MAP((short)4, "doubleMap"); + + private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); + + static { + for (_Fields field : EnumSet.allOf(_Fields.class)) { + byName.put(field.getFieldName(), field); + } + } + + /** + * Find the _Fields constant that matches fieldId, or null if its not found. + */ + public static _Fields findByThriftId(int fieldId) { + switch(fieldId) { + case 1: // NAME + return NAME; + case 2: // STR_MAP + return STR_MAP; + case 3: // LONG_MAP + return LONG_MAP; + case 4: // DOUBLE_MAP + return DOUBLE_MAP; + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + + // isset id assignments + public static final Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> metaDataMap; + static { + Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData>(_Fields.class); + tmpMap.put(_Fields.NAME, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("name", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING))); + tmpMap.put(_Fields.STR_MAP, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("strMap", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.MapMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING), + 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.LONG_MAP, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("longMap", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.MapMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING), + 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.DOUBLE_MAP, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("doubleMap", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.MapMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING), + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.DOUBLE)))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(Metric.class, metaDataMap); + } + + public Metric() { + } + + public Metric( + String name, + Map<String,String> strMap, + Map<String,Long> longMap, + Map<String,Double> doubleMap) + { + this(); + this.name = name; + this.strMap = strMap; + this.longMap = longMap; + this.doubleMap = doubleMap; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public Metric(Metric other) { + if (other.isSetName()) { + this.name = other.name; + } + if (other.isSetStrMap()) { + Map<String,String> __this__strMap = new HashMap<String,String>(); + for (Map.Entry<String, String> other_element : other.strMap.entrySet()) { + + String other_element_key = other_element.getKey(); + String other_element_value = other_element.getValue(); + + String __this__strMap_copy_key = other_element_key; + + String __this__strMap_copy_value = other_element_value; + + __this__strMap.put(__this__strMap_copy_key, __this__strMap_copy_value); + } + this.strMap = __this__strMap; + } + if (other.isSetLongMap()) { + Map<String,Long> __this__longMap = new HashMap<String,Long>(); + for (Map.Entry<String, Long> other_element : other.longMap.entrySet()) { + + String other_element_key = other_element.getKey(); + Long other_element_value = other_element.getValue(); + + String __this__longMap_copy_key = other_element_key; + + Long __this__longMap_copy_value = other_element_value; + + __this__longMap.put(__this__longMap_copy_key, __this__longMap_copy_value); + } + this.longMap = __this__longMap; + } + if (other.isSetDoubleMap()) { + Map<String,Double> __this__doubleMap = new HashMap<String,Double>(); + for (Map.Entry<String, Double> other_element : other.doubleMap.entrySet()) { + + String other_element_key = other_element.getKey(); + Double other_element_value = other_element.getValue(); + + String __this__doubleMap_copy_key = other_element_key; + + Double __this__doubleMap_copy_value = other_element_value; + + __this__doubleMap.put(__this__doubleMap_copy_key, __this__doubleMap_copy_value); + } + this.doubleMap = __this__doubleMap; + } + } + + public Metric deepCopy() { + return new Metric(this); + } + + @Override + public void clear() { + this.name = null; + this.strMap = null; + this.longMap = null; + this.doubleMap = null; + } + + /** + * metric name. + */ + public String getName() { + return this.name; + } + + /** + * metric name. + */ + public Metric setName(String name) { + this.name = name; + return this; + } + + public void unsetName() { + this.name = null; + } + + /** Returns true if field name is set (has been assigned a value) and false otherwise */ + public boolean isSetName() { + return this.name != null; + } + + public void setNameIsSet(boolean value) { + if (!value) { + this.name = null; + } + } + + public int getStrMapSize() { + return (this.strMap == null) ? 0 : this.strMap.size(); + } + + public void putToStrMap(String key, String val) { + if (this.strMap == null) { + this.strMap = new HashMap<String,String>(); + } + this.strMap.put(key, val); + } + + /** + * map of string values emitted by the Metric. + */ + public Map<String,String> getStrMap() { + return this.strMap; + } + + /** + * map of string values emitted by the Metric. + */ + public Metric setStrMap(Map<String,String> strMap) { + this.strMap = strMap; + return this; + } + + public void unsetStrMap() { + this.strMap = null; + } + + /** Returns true if field strMap is set (has been assigned a value) and false otherwise */ + public boolean isSetStrMap() { + return this.strMap != null; + } + + public void setStrMapIsSet(boolean value) { + if (!value) { + this.strMap = null; + } + } + + public int getLongMapSize() { + return (this.longMap == null) ? 0 : this.longMap.size(); + } + + public void putToLongMap(String key, long val) { + if (this.longMap == null) { + this.longMap = new HashMap<String,Long>(); + } + this.longMap.put(key, val); + } + + /** + * map of long values emitted by the Metric. + */ + public Map<String,Long> getLongMap() { + return this.longMap; + } + + /** + * map of long values emitted by the Metric. + */ + public Metric setLongMap(Map<String,Long> longMap) { + this.longMap = longMap; + return this; + } + + public void unsetLongMap() { + this.longMap = null; + } + + /** Returns true if field longMap is set (has been assigned a value) and false otherwise */ + public boolean isSetLongMap() { + return this.longMap != null; + } + + public void setLongMapIsSet(boolean value) { + if (!value) { + this.longMap = null; + } + } + + public int getDoubleMapSize() { + return (this.doubleMap == null) ? 0 : this.doubleMap.size(); + } + + public void putToDoubleMap(String key, double val) { + if (this.doubleMap == null) { + this.doubleMap = new HashMap<String,Double>(); + } + this.doubleMap.put(key, val); + } + + /** + * map of double values emitted by the Metric. + */ + public Map<String,Double> getDoubleMap() { + return this.doubleMap; + } + + /** + * map of double values emitted by the Metric. + */ + public Metric setDoubleMap(Map<String,Double> doubleMap) { + this.doubleMap = doubleMap; + return this; + } + + public void unsetDoubleMap() { + this.doubleMap = null; + } + + /** Returns true if field doubleMap is set (has been assigned a value) and false otherwise */ + public boolean isSetDoubleMap() { + return this.doubleMap != null; + } + + public void setDoubleMapIsSet(boolean value) { + if (!value) { + this.doubleMap = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case NAME: + if (value == null) { + unsetName(); + } else { + setName((String)value); + } + break; + + case STR_MAP: + if (value == null) { + unsetStrMap(); + } else { + setStrMap((Map<String,String>)value); + } + break; + + case LONG_MAP: + if (value == null) { + unsetLongMap(); + } else { + setLongMap((Map<String,Long>)value); + } + break; + + case DOUBLE_MAP: + if (value == null) { + unsetDoubleMap(); + } else { + setDoubleMap((Map<String,Double>)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case NAME: + return getName(); + + case STR_MAP: + return getStrMap(); + + case LONG_MAP: + return getLongMap(); + + case DOUBLE_MAP: + return getDoubleMap(); + + } + throw new IllegalStateException(); + } + + /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ + public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + + switch (field) { + case NAME: + return isSetName(); + case STR_MAP: + return isSetStrMap(); + case LONG_MAP: + return isSetLongMap(); + case DOUBLE_MAP: + return isSetDoubleMap(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof Metric) + return this.equals((Metric)that); + return false; + } + + public boolean equals(Metric that) { + if (that == null) + return false; + + boolean this_present_name = true && this.isSetName(); + boolean that_present_name = true && that.isSetName(); + if (this_present_name || that_present_name) { + if (!(this_present_name && that_present_name)) + return false; + if (!this.name.equals(that.name)) + return false; + } + + boolean this_present_strMap = true && this.isSetStrMap(); + boolean that_present_strMap = true && that.isSetStrMap(); + if (this_present_strMap || that_present_strMap) { + if (!(this_present_strMap && that_present_strMap)) + return false; + if (!this.strMap.equals(that.strMap)) + return false; + } + + boolean this_present_longMap = true && this.isSetLongMap(); + boolean that_present_longMap = true && that.isSetLongMap(); + if (this_present_longMap || that_present_longMap) { + if (!(this_present_longMap && that_present_longMap)) + return false; + if (!this.longMap.equals(that.longMap)) + return false; + } + + boolean this_present_doubleMap = true && this.isSetDoubleMap(); + boolean that_present_doubleMap = true && that.isSetDoubleMap(); + if (this_present_doubleMap || that_present_doubleMap) { + if (!(this_present_doubleMap && that_present_doubleMap)) + return false; + if (!this.doubleMap.equals(that.doubleMap)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + return 0; + } + + public int compareTo(Metric other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + Metric typedOther = (Metric)other; + + lastComparison = Boolean.valueOf(isSetName()).compareTo(typedOther.isSetName()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetName()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.name, typedOther.name); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetStrMap()).compareTo(typedOther.isSetStrMap()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetStrMap()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.strMap, typedOther.strMap); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetLongMap()).compareTo(typedOther.isSetLongMap()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetLongMap()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.longMap, typedOther.longMap); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetDoubleMap()).compareTo(typedOther.isSetDoubleMap()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetDoubleMap()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.doubleMap, typedOther.doubleMap); + 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("Metric("); + boolean first = true; + + sb.append("name:"); + if (this.name == null) { + sb.append("null"); + } else { + sb.append(this.name); + } + first = false; + if (!first) sb.append(", "); + sb.append("strMap:"); + if (this.strMap == null) { + sb.append("null"); + } else { + sb.append(this.strMap); + } + first = false; + if (!first) sb.append(", "); + sb.append("longMap:"); + if (this.longMap == null) { + sb.append("null"); + } else { + sb.append(this.longMap); + } + first = false; + if (!first) sb.append(", "); + sb.append("doubleMap:"); + if (this.doubleMap == null) { + sb.append("null"); + } else { + sb.append(this.doubleMap); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + // check for required fields + // check for sub-struct validity + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TCompactProtocol(new org.apache.blur.thirdparty.thrift_0_9_0.transport.TIOStreamTransport(out))); + } catch (org.apache.blur.thirdparty.thrift_0_9_0.TException te) { + throw new java.io.IOException(te); + } + } + + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + try { + read(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TCompactProtocol(new org.apache.blur.thirdparty.thrift_0_9_0.transport.TIOStreamTransport(in))); + } catch (org.apache.blur.thirdparty.thrift_0_9_0.TException te) { + throw new java.io.IOException(te); + } + } + + private static class MetricStandardSchemeFactory implements SchemeFactory { + public MetricStandardScheme getScheme() { + return new MetricStandardScheme(); + } + } + + private static class MetricStandardScheme extends StandardScheme<Metric> { + + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, Metric struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField schemeField; + iprot.readStructBegin(); + while (true) + { + schemeField = iprot.readFieldBegin(); + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STOP) { + break; + } + switch (schemeField.id) { + case 1: // NAME + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING) { + struct.name = iprot.readString(); + struct.setNameIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // STR_MAP + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP) { + { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map202 = iprot.readMapBegin(); + struct.strMap = new HashMap<String,String>(2*_map202.size); + for (int _i203 = 0; _i203 < _map202.size; ++_i203) + { + String _key204; // required + String _val205; // required + _key204 = iprot.readString(); + _val205 = iprot.readString(); + struct.strMap.put(_key204, _val205); + } + iprot.readMapEnd(); + } + struct.setStrMapIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 3: // LONG_MAP + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP) { + { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map206 = iprot.readMapBegin(); + struct.longMap = new HashMap<String,Long>(2*_map206.size); + for (int _i207 = 0; _i207 < _map206.size; ++_i207) + { + String _key208; // required + long _val209; // required + _key208 = iprot.readString(); + _val209 = iprot.readI64(); + struct.longMap.put(_key208, _val209); + } + iprot.readMapEnd(); + } + struct.setLongMapIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 4: // DOUBLE_MAP + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP) { + { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map210 = iprot.readMapBegin(); + struct.doubleMap = new HashMap<String,Double>(2*_map210.size); + for (int _i211 = 0; _i211 < _map210.size; ++_i211) + { + String _key212; // required + double _val213; // required + _key212 = iprot.readString(); + _val213 = iprot.readDouble(); + struct.doubleMap.put(_key212, _val213); + } + iprot.readMapEnd(); + } + struct.setDoubleMapIsSet(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, Metric struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.name != null) { + oprot.writeFieldBegin(NAME_FIELD_DESC); + oprot.writeString(struct.name); + oprot.writeFieldEnd(); + } + if (struct.strMap != null) { + oprot.writeFieldBegin(STR_MAP_FIELD_DESC); + { + oprot.writeMapBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, struct.strMap.size())); + for (Map.Entry<String, String> _iter214 : struct.strMap.entrySet()) + { + oprot.writeString(_iter214.getKey()); + oprot.writeString(_iter214.getValue()); + } + oprot.writeMapEnd(); + } + oprot.writeFieldEnd(); + } + if (struct.longMap != null) { + oprot.writeFieldBegin(LONG_MAP_FIELD_DESC); + { + oprot.writeMapBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64, struct.longMap.size())); + for (Map.Entry<String, Long> _iter215 : struct.longMap.entrySet()) + { + oprot.writeString(_iter215.getKey()); + oprot.writeI64(_iter215.getValue()); + } + oprot.writeMapEnd(); + } + oprot.writeFieldEnd(); + } + if (struct.doubleMap != null) { + oprot.writeFieldBegin(DOUBLE_MAP_FIELD_DESC); + { + oprot.writeMapBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.DOUBLE, struct.doubleMap.size())); + for (Map.Entry<String, Double> _iter216 : struct.doubleMap.entrySet()) + { + oprot.writeString(_iter216.getKey()); + oprot.writeDouble(_iter216.getValue()); + } + oprot.writeMapEnd(); + } + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class MetricTupleSchemeFactory implements SchemeFactory { + public MetricTupleScheme getScheme() { + return new MetricTupleScheme(); + } + } + + private static class MetricTupleScheme extends TupleScheme<Metric> { + + @Override + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, Metric struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetName()) { + optionals.set(0); + } + if (struct.isSetStrMap()) { + optionals.set(1); + } + if (struct.isSetLongMap()) { + optionals.set(2); + } + if (struct.isSetDoubleMap()) { + optionals.set(3); + } + oprot.writeBitSet(optionals, 4); + if (struct.isSetName()) { + oprot.writeString(struct.name); + } + if (struct.isSetStrMap()) { + { + oprot.writeI32(struct.strMap.size()); + for (Map.Entry<String, String> _iter217 : struct.strMap.entrySet()) + { + oprot.writeString(_iter217.getKey()); + oprot.writeString(_iter217.getValue()); + } + } + } + if (struct.isSetLongMap()) { + { + oprot.writeI32(struct.longMap.size()); + for (Map.Entry<String, Long> _iter218 : struct.longMap.entrySet()) + { + oprot.writeString(_iter218.getKey()); + oprot.writeI64(_iter218.getValue()); + } + } + } + if (struct.isSetDoubleMap()) { + { + oprot.writeI32(struct.doubleMap.size()); + for (Map.Entry<String, Double> _iter219 : struct.doubleMap.entrySet()) + { + oprot.writeString(_iter219.getKey()); + oprot.writeDouble(_iter219.getValue()); + } + } + } + } + + @Override + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, Metric struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(4); + if (incoming.get(0)) { + struct.name = iprot.readString(); + struct.setNameIsSet(true); + } + if (incoming.get(1)) { + { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map220 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, iprot.readI32()); + struct.strMap = new HashMap<String,String>(2*_map220.size); + for (int _i221 = 0; _i221 < _map220.size; ++_i221) + { + String _key222; // required + String _val223; // required + _key222 = iprot.readString(); + _val223 = iprot.readString(); + struct.strMap.put(_key222, _val223); + } + } + struct.setStrMapIsSet(true); + } + if (incoming.get(2)) { + { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map224 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64, iprot.readI32()); + struct.longMap = new HashMap<String,Long>(2*_map224.size); + for (int _i225 = 0; _i225 < _map224.size; ++_i225) + { + String _key226; // required + long _val227; // required + _key226 = iprot.readString(); + _val227 = iprot.readI64(); + struct.longMap.put(_key226, _val227); + } + } + struct.setLongMapIsSet(true); + } + if (incoming.get(3)) { + { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map228 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.DOUBLE, iprot.readI32()); + struct.doubleMap = new HashMap<String,Double>(2*_map228.size); + for (int _i229 = 0; _i229 < _map228.size; ++_i229) + { + String _key230; // required + double _val231; // required + _key230 = iprot.readString(); + _val231 = iprot.readDouble(); + struct.doubleMap.put(_key230, _val231); + } + } + struct.setDoubleMapIsSet(true); + } + } + } + +} +
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/e5ae88af/scripts/interface/gen-java/org/apache/blur/thrift/generated/Query.java ---------------------------------------------------------------------- diff --git a/scripts/interface/gen-java/org/apache/blur/thrift/generated/Query.java b/scripts/interface/gen-java/org/apache/blur/thrift/generated/Query.java new file mode 100644 index 0000000..8d8f3b0 --- /dev/null +++ b/scripts/interface/gen-java/org/apache/blur/thrift/generated/Query.java @@ -0,0 +1,896 @@ +/** + * 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; + +/** + * The Query object holds the query string (normal Lucene syntax), + * filters and type of scoring (used when super query is on). + */ +public class Query implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Query, Query._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("Query"); + + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField QUERY_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("query", 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 ROW_QUERY_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("rowQuery", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.BOOL, (short)2); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField SCORE_TYPE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("scoreType", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32, (short)3); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField ROW_FILTER_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("rowFilter", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, (short)4); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField RECORD_FILTER_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("recordFilter", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, (short)5); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new QueryStandardSchemeFactory()); + schemes.put(TupleScheme.class, new QueryTupleSchemeFactory()); + } + + /** + * A Lucene syntax based query. + */ + public String query; // required + /** + * If the Row query is on, meaning the query will be perform against all the + * Records (joining records in some cases) and the result will be Rows (groupings of Record). + */ + public boolean rowQuery; // required + /** + * The scoring type, see the document on ScoreType for explanation of each score type. + * + * @see ScoreType + */ + public ScoreType scoreType; // required + /** + * The Row filter (normal Lucene syntax), is a filter performed + * after the join to filter out entire Rows from the results. This + * field is ignored when rowQuery is false. + */ + public String rowFilter; // required + /** + * The Record filter (normal Lucene syntax), is a filter performed + * before the join to filter out Records from the results. + */ + public String recordFilter; // 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 { + /** + * A Lucene syntax based query. + */ + QUERY((short)1, "query"), + /** + * If the Row query is on, meaning the query will be perform against all the + * Records (joining records in some cases) and the result will be Rows (groupings of Record). + */ + ROW_QUERY((short)2, "rowQuery"), + /** + * The scoring type, see the document on ScoreType for explanation of each score type. + * + * @see ScoreType + */ + SCORE_TYPE((short)3, "scoreType"), + /** + * The Row filter (normal Lucene syntax), is a filter performed + * after the join to filter out entire Rows from the results. This + * field is ignored when rowQuery is false. + */ + ROW_FILTER((short)4, "rowFilter"), + /** + * The Record filter (normal Lucene syntax), is a filter performed + * before the join to filter out Records from the results. + */ + RECORD_FILTER((short)5, "recordFilter"); + + private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); + + static { + for (_Fields field : EnumSet.allOf(_Fields.class)) { + byName.put(field.getFieldName(), field); + } + } + + /** + * Find the _Fields constant that matches fieldId, or null if its not found. + */ + public static _Fields findByThriftId(int fieldId) { + switch(fieldId) { + case 1: // QUERY + return QUERY; + case 2: // ROW_QUERY + return ROW_QUERY; + case 3: // SCORE_TYPE + return SCORE_TYPE; + case 4: // ROW_FILTER + return ROW_FILTER; + case 5: // RECORD_FILTER + return RECORD_FILTER; + 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 __ROWQUERY_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, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("query", 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.ROW_QUERY, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("rowQuery", 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.BOOL))); + tmpMap.put(_Fields.SCORE_TYPE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("scoreType", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.EnumMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.ENUM, ScoreType.class))); + tmpMap.put(_Fields.ROW_FILTER, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("rowFilter", 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_FILTER, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("recordFilter", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(Query.class, metaDataMap); + } + + public Query() { + this.rowQuery = true; + + this.scoreType = org.apache.blur.thrift.generated.ScoreType.SUPER; + + } + + public Query( + String query, + boolean rowQuery, + ScoreType scoreType, + String rowFilter, + String recordFilter) + { + this(); + this.query = query; + this.rowQuery = rowQuery; + setRowQueryIsSet(true); + this.scoreType = scoreType; + this.rowFilter = rowFilter; + this.recordFilter = recordFilter; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public Query(Query other) { + __isset_bitfield = other.__isset_bitfield; + if (other.isSetQuery()) { + this.query = other.query; + } + this.rowQuery = other.rowQuery; + if (other.isSetScoreType()) { + this.scoreType = other.scoreType; + } + if (other.isSetRowFilter()) { + this.rowFilter = other.rowFilter; + } + if (other.isSetRecordFilter()) { + this.recordFilter = other.recordFilter; + } + } + + public Query deepCopy() { + return new Query(this); + } + + @Override + public void clear() { + this.query = null; + this.rowQuery = true; + + this.scoreType = org.apache.blur.thrift.generated.ScoreType.SUPER; + + this.rowFilter = null; + this.recordFilter = null; + } + + /** + * A Lucene syntax based query. + */ + public String getQuery() { + return this.query; + } + + /** + * A Lucene syntax based query. + */ + public Query setQuery(String query) { + this.query = query; + return this; + } + + public void unsetQuery() { + this.query = null; + } + + /** Returns true if field query is set (has been assigned a value) and false otherwise */ + public boolean isSetQuery() { + return this.query != null; + } + + public void setQueryIsSet(boolean value) { + if (!value) { + this.query = null; + } + } + + /** + * If the Row query is on, meaning the query will be perform against all the + * Records (joining records in some cases) and the result will be Rows (groupings of Record). + */ + public boolean isRowQuery() { + return this.rowQuery; + } + + /** + * If the Row query is on, meaning the query will be perform against all the + * Records (joining records in some cases) and the result will be Rows (groupings of Record). + */ + public Query setRowQuery(boolean rowQuery) { + this.rowQuery = rowQuery; + setRowQueryIsSet(true); + return this; + } + + public void unsetRowQuery() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ROWQUERY_ISSET_ID); + } + + /** Returns true if field rowQuery is set (has been assigned a value) and false otherwise */ + public boolean isSetRowQuery() { + return EncodingUtils.testBit(__isset_bitfield, __ROWQUERY_ISSET_ID); + } + + public void setRowQueryIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ROWQUERY_ISSET_ID, value); + } + + /** + * The scoring type, see the document on ScoreType for explanation of each score type. + * + * @see ScoreType + */ + public ScoreType getScoreType() { + return this.scoreType; + } + + /** + * The scoring type, see the document on ScoreType for explanation of each score type. + * + * @see ScoreType + */ + public Query setScoreType(ScoreType scoreType) { + this.scoreType = scoreType; + return this; + } + + public void unsetScoreType() { + this.scoreType = null; + } + + /** Returns true if field scoreType is set (has been assigned a value) and false otherwise */ + public boolean isSetScoreType() { + return this.scoreType != null; + } + + public void setScoreTypeIsSet(boolean value) { + if (!value) { + this.scoreType = null; + } + } + + /** + * The Row filter (normal Lucene syntax), is a filter performed + * after the join to filter out entire Rows from the results. This + * field is ignored when rowQuery is false. + */ + public String getRowFilter() { + return this.rowFilter; + } + + /** + * The Row filter (normal Lucene syntax), is a filter performed + * after the join to filter out entire Rows from the results. This + * field is ignored when rowQuery is false. + */ + public Query setRowFilter(String rowFilter) { + this.rowFilter = rowFilter; + return this; + } + + public void unsetRowFilter() { + this.rowFilter = null; + } + + /** Returns true if field rowFilter is set (has been assigned a value) and false otherwise */ + public boolean isSetRowFilter() { + return this.rowFilter != null; + } + + public void setRowFilterIsSet(boolean value) { + if (!value) { + this.rowFilter = null; + } + } + + /** + * The Record filter (normal Lucene syntax), is a filter performed + * before the join to filter out Records from the results. + */ + public String getRecordFilter() { + return this.recordFilter; + } + + /** + * The Record filter (normal Lucene syntax), is a filter performed + * before the join to filter out Records from the results. + */ + public Query setRecordFilter(String recordFilter) { + this.recordFilter = recordFilter; + return this; + } + + public void unsetRecordFilter() { + this.recordFilter = null; + } + + /** Returns true if field recordFilter is set (has been assigned a value) and false otherwise */ + public boolean isSetRecordFilter() { + return this.recordFilter != null; + } + + public void setRecordFilterIsSet(boolean value) { + if (!value) { + this.recordFilter = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case QUERY: + if (value == null) { + unsetQuery(); + } else { + setQuery((String)value); + } + break; + + case ROW_QUERY: + if (value == null) { + unsetRowQuery(); + } else { + setRowQuery((Boolean)value); + } + break; + + case SCORE_TYPE: + if (value == null) { + unsetScoreType(); + } else { + setScoreType((ScoreType)value); + } + break; + + case ROW_FILTER: + if (value == null) { + unsetRowFilter(); + } else { + setRowFilter((String)value); + } + break; + + case RECORD_FILTER: + if (value == null) { + unsetRecordFilter(); + } else { + setRecordFilter((String)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case QUERY: + return getQuery(); + + case ROW_QUERY: + return Boolean.valueOf(isRowQuery()); + + case SCORE_TYPE: + return getScoreType(); + + case ROW_FILTER: + return getRowFilter(); + + case RECORD_FILTER: + return getRecordFilter(); + + } + throw new IllegalStateException(); + } + + /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ + public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + + switch (field) { + case QUERY: + return isSetQuery(); + case ROW_QUERY: + return isSetRowQuery(); + case SCORE_TYPE: + return isSetScoreType(); + case ROW_FILTER: + return isSetRowFilter(); + case RECORD_FILTER: + return isSetRecordFilter(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof Query) + return this.equals((Query)that); + return false; + } + + public boolean equals(Query that) { + if (that == null) + return false; + + boolean this_present_query = true && this.isSetQuery(); + boolean that_present_query = true && that.isSetQuery(); + if (this_present_query || that_present_query) { + if (!(this_present_query && that_present_query)) + return false; + if (!this.query.equals(that.query)) + return false; + } + + boolean this_present_rowQuery = true; + boolean that_present_rowQuery = true; + if (this_present_rowQuery || that_present_rowQuery) { + if (!(this_present_rowQuery && that_present_rowQuery)) + return false; + if (this.rowQuery != that.rowQuery) + return false; + } + + boolean this_present_scoreType = true && this.isSetScoreType(); + boolean that_present_scoreType = true && that.isSetScoreType(); + if (this_present_scoreType || that_present_scoreType) { + if (!(this_present_scoreType && that_present_scoreType)) + return false; + if (!this.scoreType.equals(that.scoreType)) + return false; + } + + boolean this_present_rowFilter = true && this.isSetRowFilter(); + boolean that_present_rowFilter = true && that.isSetRowFilter(); + if (this_present_rowFilter || that_present_rowFilter) { + if (!(this_present_rowFilter && that_present_rowFilter)) + return false; + if (!this.rowFilter.equals(that.rowFilter)) + return false; + } + + boolean this_present_recordFilter = true && this.isSetRecordFilter(); + boolean that_present_recordFilter = true && that.isSetRecordFilter(); + if (this_present_recordFilter || that_present_recordFilter) { + if (!(this_present_recordFilter && that_present_recordFilter)) + return false; + if (!this.recordFilter.equals(that.recordFilter)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + return 0; + } + + public int compareTo(Query other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + Query typedOther = (Query)other; + + lastComparison = Boolean.valueOf(isSetQuery()).compareTo(typedOther.isSetQuery()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetQuery()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.query, typedOther.query); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetRowQuery()).compareTo(typedOther.isSetRowQuery()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetRowQuery()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.rowQuery, typedOther.rowQuery); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetScoreType()).compareTo(typedOther.isSetScoreType()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetScoreType()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.scoreType, typedOther.scoreType); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetRowFilter()).compareTo(typedOther.isSetRowFilter()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetRowFilter()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.rowFilter, typedOther.rowFilter); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetRecordFilter()).compareTo(typedOther.isSetRecordFilter()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetRecordFilter()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.recordFilter, typedOther.recordFilter); + 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("Query("); + boolean first = true; + + sb.append("query:"); + if (this.query == null) { + sb.append("null"); + } else { + sb.append(this.query); + } + first = false; + if (!first) sb.append(", "); + sb.append("rowQuery:"); + sb.append(this.rowQuery); + first = false; + if (!first) sb.append(", "); + sb.append("scoreType:"); + if (this.scoreType == null) { + sb.append("null"); + } else { + sb.append(this.scoreType); + } + first = false; + if (!first) sb.append(", "); + sb.append("rowFilter:"); + if (this.rowFilter == null) { + sb.append("null"); + } else { + sb.append(this.rowFilter); + } + first = false; + if (!first) sb.append(", "); + sb.append("recordFilter:"); + if (this.recordFilter == null) { + sb.append("null"); + } else { + sb.append(this.recordFilter); + } + 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 QueryStandardSchemeFactory implements SchemeFactory { + public QueryStandardScheme getScheme() { + return new QueryStandardScheme(); + } + } + + private static class QueryStandardScheme extends StandardScheme<Query> { + + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, Query 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 + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING) { + struct.query = iprot.readString(); + struct.setQueryIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // ROW_QUERY + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.BOOL) { + struct.rowQuery = iprot.readBool(); + struct.setRowQueryIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 3: // SCORE_TYPE + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32) { + struct.scoreType = ScoreType.findByValue(iprot.readI32()); + struct.setScoreTypeIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 4: // ROW_FILTER + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING) { + struct.rowFilter = iprot.readString(); + struct.setRowFilterIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 5: // RECORD_FILTER + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING) { + struct.recordFilter = iprot.readString(); + struct.setRecordFilterIsSet(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, Query struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.query != null) { + oprot.writeFieldBegin(QUERY_FIELD_DESC); + oprot.writeString(struct.query); + oprot.writeFieldEnd(); + } + oprot.writeFieldBegin(ROW_QUERY_FIELD_DESC); + oprot.writeBool(struct.rowQuery); + oprot.writeFieldEnd(); + if (struct.scoreType != null) { + oprot.writeFieldBegin(SCORE_TYPE_FIELD_DESC); + oprot.writeI32(struct.scoreType.getValue()); + oprot.writeFieldEnd(); + } + if (struct.rowFilter != null) { + oprot.writeFieldBegin(ROW_FILTER_FIELD_DESC); + oprot.writeString(struct.rowFilter); + oprot.writeFieldEnd(); + } + if (struct.recordFilter != null) { + oprot.writeFieldBegin(RECORD_FILTER_FIELD_DESC); + oprot.writeString(struct.recordFilter); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class QueryTupleSchemeFactory implements SchemeFactory { + public QueryTupleScheme getScheme() { + return new QueryTupleScheme(); + } + } + + private static class QueryTupleScheme extends TupleScheme<Query> { + + @Override + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, Query struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetQuery()) { + optionals.set(0); + } + if (struct.isSetRowQuery()) { + optionals.set(1); + } + if (struct.isSetScoreType()) { + optionals.set(2); + } + if (struct.isSetRowFilter()) { + optionals.set(3); + } + if (struct.isSetRecordFilter()) { + optionals.set(4); + } + oprot.writeBitSet(optionals, 5); + if (struct.isSetQuery()) { + oprot.writeString(struct.query); + } + if (struct.isSetRowQuery()) { + oprot.writeBool(struct.rowQuery); + } + if (struct.isSetScoreType()) { + oprot.writeI32(struct.scoreType.getValue()); + } + if (struct.isSetRowFilter()) { + oprot.writeString(struct.rowFilter); + } + if (struct.isSetRecordFilter()) { + oprot.writeString(struct.recordFilter); + } + } + + @Override + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, Query struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(5); + if (incoming.get(0)) { + struct.query = iprot.readString(); + struct.setQueryIsSet(true); + } + if (incoming.get(1)) { + struct.rowQuery = iprot.readBool(); + struct.setRowQueryIsSet(true); + } + if (incoming.get(2)) { + struct.scoreType = ScoreType.findByValue(iprot.readI32()); + struct.setScoreTypeIsSet(true); + } + if (incoming.get(3)) { + struct.rowFilter = iprot.readString(); + struct.setRowFilterIsSet(true); + } + if (incoming.get(4)) { + struct.recordFilter = iprot.readString(); + struct.setRecordFilterIsSet(true); + } + } + } + +} + http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/e5ae88af/scripts/interface/gen-java/org/apache/blur/thrift/generated/QueryState.java ---------------------------------------------------------------------- diff --git a/scripts/interface/gen-java/org/apache/blur/thrift/generated/QueryState.java b/scripts/interface/gen-java/org/apache/blur/thrift/generated/QueryState.java new file mode 100644 index 0000000..4b9ad48 --- /dev/null +++ b/scripts/interface/gen-java/org/apache/blur/thrift/generated/QueryState.java @@ -0,0 +1,78 @@ +/** + * 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 state of a query.</td></tr> + * <tr><td>RUNNING</td><td>Query is running.</td></tr> + * <tr><td>INTERRUPTED</td><td>Query has been interrupted.</td></tr> + * <tr><td>COMPLETE</td><td>Query is complete.</td></tr> + * </table> + */ +public enum QueryState implements org.apache.blur.thirdparty.thrift_0_9_0.TEnum { + RUNNING(0), + INTERRUPTED(1), + COMPLETE(2), + BACK_PRESSURE_INTERRUPTED(3); + + private final int value; + + private QueryState(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 QueryState findByValue(int value) { + switch (value) { + case 0: + return RUNNING; + case 1: + return INTERRUPTED; + case 2: + return COMPLETE; + case 3: + return BACK_PRESSURE_INTERRUPTED; + default: + return null; + } + } +}
