http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/e5ae88af/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/RowMutation.java ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/RowMutation.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/RowMutation.java deleted file mode 100644 index f1d1d85..0000000 --- a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/RowMutation.java +++ /dev/null @@ -1,821 +0,0 @@ -/** - * Autogenerated by Thrift Compiler (0.9.0) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -package org.apache.blur.thrift.generated; - -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - - - -import org.apache.blur.thirdparty.thrift_0_9_0.scheme.IScheme; -import org.apache.blur.thirdparty.thrift_0_9_0.scheme.SchemeFactory; -import org.apache.blur.thirdparty.thrift_0_9_0.scheme.StandardScheme; - -import org.apache.blur.thirdparty.thrift_0_9_0.scheme.TupleScheme; -import org.apache.blur.thirdparty.thrift_0_9_0.protocol.TTupleProtocol; -import org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolException; -import org.apache.blur.thirdparty.thrift_0_9_0.EncodingUtils; -import org.apache.blur.thirdparty.thrift_0_9_0.TException; -import java.util.List; -import java.util.ArrayList; -import java.util.Map; -import java.util.HashMap; -import java.util.EnumMap; -import java.util.Set; -import java.util.HashSet; -import java.util.EnumSet; -import java.util.Collections; -import java.util.BitSet; -import java.nio.ByteBuffer; -import java.util.Arrays; -//import org.slf4j.Logger; -//import org.slf4j.LoggerFactory; - -/** - * The RowMutation defines how the given Row is to be mutated. - */ -public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<RowMutation, RowMutation._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("RowMutation"); - - private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField TABLE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("table", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, (short)1); - private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField ROW_ID_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)2); - private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField ROW_MUTATION_TYPE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("rowMutationType", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32, (short)4); - private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField RECORD_MUTATIONS_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("recordMutations", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST, (short)5); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new RowMutationStandardSchemeFactory()); - schemes.put(TupleScheme.class, new RowMutationTupleSchemeFactory()); - } - - /** - * The table that the row mutation is to act upon. - */ - public String table; // required - /** - * The row id that the row mutation is to act upon. - */ - public String rowId; // required - /** - * The RowMutationType to define how to mutate the given Row. - * - * @see RowMutationType - */ - public RowMutationType rowMutationType; // required - /** - * The RecordMutations if any for this Row. - */ - public List<RecordMutation> recordMutations; // 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 table that the row mutation is to act upon. - */ - TABLE((short)1, "table"), - /** - * The row id that the row mutation is to act upon. - */ - ROW_ID((short)2, "rowId"), - /** - * The RowMutationType to define how to mutate the given Row. - * - * @see RowMutationType - */ - ROW_MUTATION_TYPE((short)4, "rowMutationType"), - /** - * The RecordMutations if any for this Row. - */ - RECORD_MUTATIONS((short)5, "recordMutations"); - - 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: // TABLE - return TABLE; - case 2: // ROW_ID - return ROW_ID; - case 4: // ROW_MUTATION_TYPE - return ROW_MUTATION_TYPE; - case 5: // RECORD_MUTATIONS - return RECORD_MUTATIONS; - 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.TABLE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("table", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, - new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING))); - tmpMap.put(_Fields.ROW_ID, 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.ROW_MUTATION_TYPE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("rowMutationType", 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, RowMutationType.class))); - tmpMap.put(_Fields.RECORD_MUTATIONS, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("recordMutations", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, - new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.ListMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST, - new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.StructMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, RecordMutation.class)))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(RowMutation.class, metaDataMap); - } - - public RowMutation() { - this.rowMutationType = org.apache.blur.thrift.generated.RowMutationType.REPLACE_ROW; - - } - - public RowMutation( - String table, - String rowId, - RowMutationType rowMutationType, - List<RecordMutation> recordMutations) - { - this(); - this.table = table; - this.rowId = rowId; - this.rowMutationType = rowMutationType; - this.recordMutations = recordMutations; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public RowMutation(RowMutation other) { - if (other.isSetTable()) { - this.table = other.table; - } - if (other.isSetRowId()) { - this.rowId = other.rowId; - } - if (other.isSetRowMutationType()) { - this.rowMutationType = other.rowMutationType; - } - if (other.isSetRecordMutations()) { - List<RecordMutation> __this__recordMutations = new ArrayList<RecordMutation>(); - for (RecordMutation other_element : other.recordMutations) { - __this__recordMutations.add(new RecordMutation(other_element)); - } - this.recordMutations = __this__recordMutations; - } - } - - public RowMutation deepCopy() { - return new RowMutation(this); - } - - @Override - public void clear() { - this.table = null; - this.rowId = null; - this.rowMutationType = org.apache.blur.thrift.generated.RowMutationType.REPLACE_ROW; - - this.recordMutations = null; - } - - /** - * The table that the row mutation is to act upon. - */ - public String getTable() { - return this.table; - } - - /** - * The table that the row mutation is to act upon. - */ - public RowMutation setTable(String table) { - this.table = table; - return this; - } - - public void unsetTable() { - this.table = null; - } - - /** Returns true if field table is set (has been assigned a value) and false otherwise */ - public boolean isSetTable() { - return this.table != null; - } - - public void setTableIsSet(boolean value) { - if (!value) { - this.table = null; - } - } - - /** - * The row id that the row mutation is to act upon. - */ - public String getRowId() { - return this.rowId; - } - - /** - * The row id that the row mutation is to act upon. - */ - public RowMutation 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 RowMutationType to define how to mutate the given Row. - * - * @see RowMutationType - */ - public RowMutationType getRowMutationType() { - return this.rowMutationType; - } - - /** - * The RowMutationType to define how to mutate the given Row. - * - * @see RowMutationType - */ - public RowMutation setRowMutationType(RowMutationType rowMutationType) { - this.rowMutationType = rowMutationType; - return this; - } - - public void unsetRowMutationType() { - this.rowMutationType = null; - } - - /** Returns true if field rowMutationType is set (has been assigned a value) and false otherwise */ - public boolean isSetRowMutationType() { - return this.rowMutationType != null; - } - - public void setRowMutationTypeIsSet(boolean value) { - if (!value) { - this.rowMutationType = null; - } - } - - public int getRecordMutationsSize() { - return (this.recordMutations == null) ? 0 : this.recordMutations.size(); - } - - public java.util.Iterator<RecordMutation> getRecordMutationsIterator() { - return (this.recordMutations == null) ? null : this.recordMutations.iterator(); - } - - public void addToRecordMutations(RecordMutation elem) { - if (this.recordMutations == null) { - this.recordMutations = new ArrayList<RecordMutation>(); - } - this.recordMutations.add(elem); - } - - /** - * The RecordMutations if any for this Row. - */ - public List<RecordMutation> getRecordMutations() { - return this.recordMutations; - } - - /** - * The RecordMutations if any for this Row. - */ - public RowMutation setRecordMutations(List<RecordMutation> recordMutations) { - this.recordMutations = recordMutations; - return this; - } - - public void unsetRecordMutations() { - this.recordMutations = null; - } - - /** Returns true if field recordMutations is set (has been assigned a value) and false otherwise */ - public boolean isSetRecordMutations() { - return this.recordMutations != null; - } - - public void setRecordMutationsIsSet(boolean value) { - if (!value) { - this.recordMutations = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case TABLE: - if (value == null) { - unsetTable(); - } else { - setTable((String)value); - } - break; - - case ROW_ID: - if (value == null) { - unsetRowId(); - } else { - setRowId((String)value); - } - break; - - case ROW_MUTATION_TYPE: - if (value == null) { - unsetRowMutationType(); - } else { - setRowMutationType((RowMutationType)value); - } - break; - - case RECORD_MUTATIONS: - if (value == null) { - unsetRecordMutations(); - } else { - setRecordMutations((List<RecordMutation>)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case TABLE: - return getTable(); - - case ROW_ID: - return getRowId(); - - case ROW_MUTATION_TYPE: - return getRowMutationType(); - - case RECORD_MUTATIONS: - return getRecordMutations(); - - } - 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 TABLE: - return isSetTable(); - case ROW_ID: - return isSetRowId(); - case ROW_MUTATION_TYPE: - return isSetRowMutationType(); - case RECORD_MUTATIONS: - return isSetRecordMutations(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof RowMutation) - return this.equals((RowMutation)that); - return false; - } - - public boolean equals(RowMutation that) { - if (that == null) - return false; - - boolean this_present_table = true && this.isSetTable(); - boolean that_present_table = true && that.isSetTable(); - if (this_present_table || that_present_table) { - if (!(this_present_table && that_present_table)) - return false; - if (!this.table.equals(that.table)) - return false; - } - - boolean this_present_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_rowMutationType = true && this.isSetRowMutationType(); - boolean that_present_rowMutationType = true && that.isSetRowMutationType(); - if (this_present_rowMutationType || that_present_rowMutationType) { - if (!(this_present_rowMutationType && that_present_rowMutationType)) - return false; - if (!this.rowMutationType.equals(that.rowMutationType)) - return false; - } - - boolean this_present_recordMutations = true && this.isSetRecordMutations(); - boolean that_present_recordMutations = true && that.isSetRecordMutations(); - if (this_present_recordMutations || that_present_recordMutations) { - if (!(this_present_recordMutations && that_present_recordMutations)) - return false; - if (!this.recordMutations.equals(that.recordMutations)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - return 0; - } - - public int compareTo(RowMutation other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - RowMutation typedOther = (RowMutation)other; - - lastComparison = Boolean.valueOf(isSetTable()).compareTo(typedOther.isSetTable()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetTable()) { - lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.table, typedOther.table); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(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(isSetRowMutationType()).compareTo(typedOther.isSetRowMutationType()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetRowMutationType()) { - lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.rowMutationType, typedOther.rowMutationType); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetRecordMutations()).compareTo(typedOther.isSetRecordMutations()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetRecordMutations()) { - lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.recordMutations, typedOther.recordMutations); - 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("RowMutation("); - boolean first = true; - - sb.append("table:"); - if (this.table == null) { - sb.append("null"); - } else { - sb.append(this.table); - } - first = false; - if (!first) sb.append(", "); - sb.append("rowId:"); - if (this.rowId == null) { - sb.append("null"); - } else { - sb.append(this.rowId); - } - first = false; - if (!first) sb.append(", "); - sb.append("rowMutationType:"); - if (this.rowMutationType == null) { - sb.append("null"); - } else { - sb.append(this.rowMutationType); - } - first = false; - if (!first) sb.append(", "); - sb.append("recordMutations:"); - if (this.recordMutations == null) { - sb.append("null"); - } else { - sb.append(this.recordMutations); - } - 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 RowMutationStandardSchemeFactory implements SchemeFactory { - public RowMutationStandardScheme getScheme() { - return new RowMutationStandardScheme(); - } - } - - private static class RowMutationStandardScheme extends StandardScheme<RowMutation> { - - public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, RowMutation 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: // TABLE - if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING) { - struct.table = iprot.readString(); - struct.setTableIsSet(true); - } else { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // ROW_ID - 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 4: // ROW_MUTATION_TYPE - if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32) { - struct.rowMutationType = RowMutationType.findByValue(iprot.readI32()); - struct.setRowMutationTypeIsSet(true); - } else { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 5: // RECORD_MUTATIONS - if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST) { - { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list118 = iprot.readListBegin(); - struct.recordMutations = new ArrayList<RecordMutation>(_list118.size); - for (int _i119 = 0; _i119 < _list118.size; ++_i119) - { - RecordMutation _elem120; // required - _elem120 = new RecordMutation(); - _elem120.read(iprot); - struct.recordMutations.add(_elem120); - } - iprot.readListEnd(); - } - struct.setRecordMutationsIsSet(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, RowMutation struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.table != null) { - oprot.writeFieldBegin(TABLE_FIELD_DESC); - oprot.writeString(struct.table); - oprot.writeFieldEnd(); - } - if (struct.rowId != null) { - oprot.writeFieldBegin(ROW_ID_FIELD_DESC); - oprot.writeString(struct.rowId); - oprot.writeFieldEnd(); - } - if (struct.rowMutationType != null) { - oprot.writeFieldBegin(ROW_MUTATION_TYPE_FIELD_DESC); - oprot.writeI32(struct.rowMutationType.getValue()); - oprot.writeFieldEnd(); - } - if (struct.recordMutations != null) { - oprot.writeFieldBegin(RECORD_MUTATIONS_FIELD_DESC); - { - oprot.writeListBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, struct.recordMutations.size())); - for (RecordMutation _iter121 : struct.recordMutations) - { - _iter121.write(oprot); - } - oprot.writeListEnd(); - } - oprot.writeFieldEnd(); - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class RowMutationTupleSchemeFactory implements SchemeFactory { - public RowMutationTupleScheme getScheme() { - return new RowMutationTupleScheme(); - } - } - - private static class RowMutationTupleScheme extends TupleScheme<RowMutation> { - - @Override - public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, RowMutation struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.isSetTable()) { - optionals.set(0); - } - if (struct.isSetRowId()) { - optionals.set(1); - } - if (struct.isSetRowMutationType()) { - optionals.set(2); - } - if (struct.isSetRecordMutations()) { - optionals.set(3); - } - oprot.writeBitSet(optionals, 4); - if (struct.isSetTable()) { - oprot.writeString(struct.table); - } - if (struct.isSetRowId()) { - oprot.writeString(struct.rowId); - } - if (struct.isSetRowMutationType()) { - oprot.writeI32(struct.rowMutationType.getValue()); - } - if (struct.isSetRecordMutations()) { - { - oprot.writeI32(struct.recordMutations.size()); - for (RecordMutation _iter122 : struct.recordMutations) - { - _iter122.write(oprot); - } - } - } - } - - @Override - public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, RowMutation 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.table = iprot.readString(); - struct.setTableIsSet(true); - } - if (incoming.get(1)) { - struct.rowId = iprot.readString(); - struct.setRowIdIsSet(true); - } - if (incoming.get(2)) { - struct.rowMutationType = RowMutationType.findByValue(iprot.readI32()); - struct.setRowMutationTypeIsSet(true); - } - if (incoming.get(3)) { - { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list123 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, iprot.readI32()); - struct.recordMutations = new ArrayList<RecordMutation>(_list123.size); - for (int _i124 = 0; _i124 < _list123.size; ++_i124) - { - RecordMutation _elem125; // required - _elem125 = new RecordMutation(); - _elem125.read(iprot); - struct.recordMutations.add(_elem125); - } - } - struct.setRecordMutationsIsSet(true); - } - } - } - -} -
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/e5ae88af/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/RowMutationType.java ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/RowMutationType.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/RowMutationType.java deleted file mode 100644 index 64ab0f9..0000000 --- a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/RowMutationType.java +++ /dev/null @@ -1,75 +0,0 @@ -/** - * Autogenerated by Thrift Compiler (0.9.0) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -package org.apache.blur.thrift.generated; - -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - - - - -import java.util.Map; -import java.util.HashMap; -import org.apache.blur.thirdparty.thrift_0_9_0.TEnum; - -/** - * <table class="table-bordered table-striped table-condensed"> - * <tr><td colspan="2">Specifies the type of Row mutation that should occur during a mutation of a given Row.</td></tr> - * <tr><td>DELETE_ROW</td><td>Indicates that the entire Row is to be deleted. No changes are made if the specified row does not exist.</td></tr> - * <tr><td>REPLACE_ROW</td><td>Indicates that the entire Row is to be deleted, and then a new Row with the same id is to be added. If the specified row does not exist, the new row will still be created.</td></tr> - * <tr><td>UPDATE_ROW</td><td>Indicates that mutations of the underlying Records will be processed individually. Mutation will result in a BlurException if the specified row does not exist.</td></tr> - * </table> - */ -public enum RowMutationType implements org.apache.blur.thirdparty.thrift_0_9_0.TEnum { - DELETE_ROW(0), - REPLACE_ROW(1), - UPDATE_ROW(2); - - private final int value; - - private RowMutationType(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 RowMutationType findByValue(int value) { - switch (value) { - case 0: - return DELETE_ROW; - case 1: - return REPLACE_ROW; - case 2: - return UPDATE_ROW; - default: - return null; - } - } -} http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/e5ae88af/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Schema.java ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Schema.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Schema.java deleted file mode 100644 index 39e1dbb..0000000 --- a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Schema.java +++ /dev/null @@ -1,648 +0,0 @@ -/** - * Autogenerated by Thrift Compiler (0.9.0) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -package org.apache.blur.thrift.generated; - -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - - - -import org.apache.blur.thirdparty.thrift_0_9_0.scheme.IScheme; -import org.apache.blur.thirdparty.thrift_0_9_0.scheme.SchemeFactory; -import org.apache.blur.thirdparty.thrift_0_9_0.scheme.StandardScheme; - -import org.apache.blur.thirdparty.thrift_0_9_0.scheme.TupleScheme; -import org.apache.blur.thirdparty.thrift_0_9_0.protocol.TTupleProtocol; -import org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolException; -import org.apache.blur.thirdparty.thrift_0_9_0.EncodingUtils; -import org.apache.blur.thirdparty.thrift_0_9_0.TException; -import java.util.List; -import java.util.ArrayList; -import java.util.Map; -import java.util.HashMap; -import java.util.EnumMap; -import java.util.Set; -import java.util.HashSet; -import java.util.EnumSet; -import java.util.Collections; -import java.util.BitSet; -import java.nio.ByteBuffer; -import java.util.Arrays; -//import org.slf4j.Logger; -//import org.slf4j.LoggerFactory; - -/** - * The current schema of the table. - */ -public class Schema implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Schema, Schema._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("Schema"); - - private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField TABLE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("table", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, (short)1); - private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField FAMILIES_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("families", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP, (short)2); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new SchemaStandardSchemeFactory()); - schemes.put(TupleScheme.class, new SchemaTupleSchemeFactory()); - } - - /** - * The table name. - */ - public String table; // required - /** - * Families and the column definitions within them. - */ - public Map<String,Map<String,ColumnDefinition>> families; // 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 table name. - */ - TABLE((short)1, "table"), - /** - * Families and the column definitions within them. - */ - FAMILIES((short)2, "families"); - - 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: // TABLE - return TABLE; - case 2: // FAMILIES - return FAMILIES; - 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.TABLE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("table", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, - new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING))); - tmpMap.put(_Fields.FAMILIES, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("families", 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.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.StructMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, ColumnDefinition.class))))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(Schema.class, metaDataMap); - } - - public Schema() { - } - - public Schema( - String table, - Map<String,Map<String,ColumnDefinition>> families) - { - this(); - this.table = table; - this.families = families; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public Schema(Schema other) { - if (other.isSetTable()) { - this.table = other.table; - } - if (other.isSetFamilies()) { - Map<String,Map<String,ColumnDefinition>> __this__families = new HashMap<String,Map<String,ColumnDefinition>>(); - for (Map.Entry<String, Map<String,ColumnDefinition>> other_element : other.families.entrySet()) { - - String other_element_key = other_element.getKey(); - Map<String,ColumnDefinition> other_element_value = other_element.getValue(); - - String __this__families_copy_key = other_element_key; - - Map<String,ColumnDefinition> __this__families_copy_value = new HashMap<String,ColumnDefinition>(); - for (Map.Entry<String, ColumnDefinition> other_element_value_element : other_element_value.entrySet()) { - - String other_element_value_element_key = other_element_value_element.getKey(); - ColumnDefinition other_element_value_element_value = other_element_value_element.getValue(); - - String __this__families_copy_value_copy_key = other_element_value_element_key; - - ColumnDefinition __this__families_copy_value_copy_value = new ColumnDefinition(other_element_value_element_value); - - __this__families_copy_value.put(__this__families_copy_value_copy_key, __this__families_copy_value_copy_value); - } - - __this__families.put(__this__families_copy_key, __this__families_copy_value); - } - this.families = __this__families; - } - } - - public Schema deepCopy() { - return new Schema(this); - } - - @Override - public void clear() { - this.table = null; - this.families = null; - } - - /** - * The table name. - */ - public String getTable() { - return this.table; - } - - /** - * The table name. - */ - public Schema setTable(String table) { - this.table = table; - return this; - } - - public void unsetTable() { - this.table = null; - } - - /** Returns true if field table is set (has been assigned a value) and false otherwise */ - public boolean isSetTable() { - return this.table != null; - } - - public void setTableIsSet(boolean value) { - if (!value) { - this.table = null; - } - } - - public int getFamiliesSize() { - return (this.families == null) ? 0 : this.families.size(); - } - - public void putToFamilies(String key, Map<String,ColumnDefinition> val) { - if (this.families == null) { - this.families = new HashMap<String,Map<String,ColumnDefinition>>(); - } - this.families.put(key, val); - } - - /** - * Families and the column definitions within them. - */ - public Map<String,Map<String,ColumnDefinition>> getFamilies() { - return this.families; - } - - /** - * Families and the column definitions within them. - */ - public Schema setFamilies(Map<String,Map<String,ColumnDefinition>> families) { - this.families = families; - return this; - } - - public void unsetFamilies() { - this.families = null; - } - - /** Returns true if field families is set (has been assigned a value) and false otherwise */ - public boolean isSetFamilies() { - return this.families != null; - } - - public void setFamiliesIsSet(boolean value) { - if (!value) { - this.families = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case TABLE: - if (value == null) { - unsetTable(); - } else { - setTable((String)value); - } - break; - - case FAMILIES: - if (value == null) { - unsetFamilies(); - } else { - setFamilies((Map<String,Map<String,ColumnDefinition>>)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case TABLE: - return getTable(); - - case FAMILIES: - return getFamilies(); - - } - 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 TABLE: - return isSetTable(); - case FAMILIES: - return isSetFamilies(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof Schema) - return this.equals((Schema)that); - return false; - } - - public boolean equals(Schema that) { - if (that == null) - return false; - - boolean this_present_table = true && this.isSetTable(); - boolean that_present_table = true && that.isSetTable(); - if (this_present_table || that_present_table) { - if (!(this_present_table && that_present_table)) - return false; - if (!this.table.equals(that.table)) - return false; - } - - boolean this_present_families = true && this.isSetFamilies(); - boolean that_present_families = true && that.isSetFamilies(); - if (this_present_families || that_present_families) { - if (!(this_present_families && that_present_families)) - return false; - if (!this.families.equals(that.families)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - return 0; - } - - public int compareTo(Schema other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - Schema typedOther = (Schema)other; - - lastComparison = Boolean.valueOf(isSetTable()).compareTo(typedOther.isSetTable()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetTable()) { - lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.table, typedOther.table); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetFamilies()).compareTo(typedOther.isSetFamilies()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetFamilies()) { - lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.families, typedOther.families); - 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("Schema("); - boolean first = true; - - sb.append("table:"); - if (this.table == null) { - sb.append("null"); - } else { - sb.append(this.table); - } - first = false; - if (!first) sb.append(", "); - sb.append("families:"); - if (this.families == null) { - sb.append("null"); - } else { - sb.append(this.families); - } - 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 SchemaStandardSchemeFactory implements SchemeFactory { - public SchemaStandardScheme getScheme() { - return new SchemaStandardScheme(); - } - } - - private static class SchemaStandardScheme extends StandardScheme<Schema> { - - public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, Schema 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: // TABLE - if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING) { - struct.table = iprot.readString(); - struct.setTableIsSet(true); - } else { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // FAMILIES - if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP) { - { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map146 = iprot.readMapBegin(); - struct.families = new HashMap<String,Map<String,ColumnDefinition>>(2*_map146.size); - for (int _i147 = 0; _i147 < _map146.size; ++_i147) - { - String _key148; // optional - Map<String,ColumnDefinition> _val149; // required - _key148 = iprot.readString(); - { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map150 = iprot.readMapBegin(); - _val149 = new HashMap<String,ColumnDefinition>(2*_map150.size); - for (int _i151 = 0; _i151 < _map150.size; ++_i151) - { - String _key152; // optional - ColumnDefinition _val153; // required - _key152 = iprot.readString(); - _val153 = new ColumnDefinition(); - _val153.read(iprot); - _val149.put(_key152, _val153); - } - iprot.readMapEnd(); - } - struct.families.put(_key148, _val149); - } - iprot.readMapEnd(); - } - struct.setFamiliesIsSet(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, Schema struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.table != null) { - oprot.writeFieldBegin(TABLE_FIELD_DESC); - oprot.writeString(struct.table); - oprot.writeFieldEnd(); - } - if (struct.families != null) { - oprot.writeFieldBegin(FAMILIES_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.MAP, struct.families.size())); - for (Map.Entry<String, Map<String,ColumnDefinition>> _iter154 : struct.families.entrySet()) - { - oprot.writeString(_iter154.getKey()); - { - 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.STRUCT, _iter154.getValue().size())); - for (Map.Entry<String, ColumnDefinition> _iter155 : _iter154.getValue().entrySet()) - { - oprot.writeString(_iter155.getKey()); - _iter155.getValue().write(oprot); - } - oprot.writeMapEnd(); - } - } - oprot.writeMapEnd(); - } - oprot.writeFieldEnd(); - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class SchemaTupleSchemeFactory implements SchemeFactory { - public SchemaTupleScheme getScheme() { - return new SchemaTupleScheme(); - } - } - - private static class SchemaTupleScheme extends TupleScheme<Schema> { - - @Override - public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, Schema struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.isSetTable()) { - optionals.set(0); - } - if (struct.isSetFamilies()) { - optionals.set(1); - } - oprot.writeBitSet(optionals, 2); - if (struct.isSetTable()) { - oprot.writeString(struct.table); - } - if (struct.isSetFamilies()) { - { - oprot.writeI32(struct.families.size()); - for (Map.Entry<String, Map<String,ColumnDefinition>> _iter156 : struct.families.entrySet()) - { - oprot.writeString(_iter156.getKey()); - { - oprot.writeI32(_iter156.getValue().size()); - for (Map.Entry<String, ColumnDefinition> _iter157 : _iter156.getValue().entrySet()) - { - oprot.writeString(_iter157.getKey()); - _iter157.getValue().write(oprot); - } - } - } - } - } - } - - @Override - public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, Schema 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.table = iprot.readString(); - struct.setTableIsSet(true); - } - if (incoming.get(1)) { - { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map158 = 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.MAP, iprot.readI32()); - struct.families = new HashMap<String,Map<String,ColumnDefinition>>(2*_map158.size); - for (int _i159 = 0; _i159 < _map158.size; ++_i159) - { - String _key160; // optional - Map<String,ColumnDefinition> _val161; // required - _key160 = iprot.readString(); - { - org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map162 = 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.STRUCT, iprot.readI32()); - _val161 = new HashMap<String,ColumnDefinition>(2*_map162.size); - for (int _i163 = 0; _i163 < _map162.size; ++_i163) - { - String _key164; // optional - ColumnDefinition _val165; // required - _key164 = iprot.readString(); - _val165 = new ColumnDefinition(); - _val165.read(iprot); - _val161.put(_key164, _val165); - } - } - struct.families.put(_key160, _val161); - } - } - struct.setFamiliesIsSet(true); - } - } - } - -} - http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/e5ae88af/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/ScoreType.java ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/ScoreType.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/ScoreType.java deleted file mode 100644 index 7e7cc5e..0000000 --- a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/ScoreType.java +++ /dev/null @@ -1,79 +0,0 @@ -/** - * Autogenerated by Thrift Compiler (0.9.0) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -package org.apache.blur.thrift.generated; - -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - - - - -import java.util.Map; -import java.util.HashMap; -import org.apache.blur.thirdparty.thrift_0_9_0.TEnum; - -/** - * <table class="table-bordered table-striped table-condensed"> - * <tr><td colspan="2">The scoring type used during a SuperQuery to score multi Record hits within a ColumnFamily.</td></tr> - * <tr><td>SUPER</td><td>During a multi Record match, a calculation of the best match Record plus how often it occurs within the match Row produces the score that is used in the scoring of the SuperQuery.</td></tr> - * <tr><td>AGGREGATE</td><td>During a multi Record match, the aggregate score of all the Records within a ColumnFamily is used in the scoring of the SuperQuery.</td></tr> - * <tr><td>BEST</td><td>During a multi Record match, the best score of all the Records within a ColumnFamily is used in the scoring of the SuperQuery.</td></tr> - * <tr><td>CONSTANT</td><td>A constant score of 1 is used in the scoring of the SuperQuery.</td></tr> - * </table> - */ -public enum ScoreType implements org.apache.blur.thirdparty.thrift_0_9_0.TEnum { - SUPER(0), - AGGREGATE(1), - BEST(2), - CONSTANT(3); - - private final int value; - - private ScoreType(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 ScoreType findByValue(int value) { - switch (value) { - case 0: - return SUPER; - case 1: - return AGGREGATE; - case 2: - return BEST; - case 3: - return CONSTANT; - default: - return null; - } - } -}
