http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/e5ae88af/scripts/interface/gen-java/org/apache/blur/thrift/generated/RowMutation.java ---------------------------------------------------------------------- diff --git a/scripts/interface/gen-java/org/apache/blur/thrift/generated/RowMutation.java b/scripts/interface/gen-java/org/apache/blur/thrift/generated/RowMutation.java new file mode 100644 index 0000000..f1d1d85 --- /dev/null +++ b/scripts/interface/gen-java/org/apache/blur/thrift/generated/RowMutation.java @@ -0,0 +1,821 @@ +/** + * 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/scripts/interface/gen-java/org/apache/blur/thrift/generated/RowMutationType.java ---------------------------------------------------------------------- diff --git a/scripts/interface/gen-java/org/apache/blur/thrift/generated/RowMutationType.java b/scripts/interface/gen-java/org/apache/blur/thrift/generated/RowMutationType.java new file mode 100644 index 0000000..64ab0f9 --- /dev/null +++ b/scripts/interface/gen-java/org/apache/blur/thrift/generated/RowMutationType.java @@ -0,0 +1,75 @@ +/** + * 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/scripts/interface/gen-java/org/apache/blur/thrift/generated/Schema.java ---------------------------------------------------------------------- diff --git a/scripts/interface/gen-java/org/apache/blur/thrift/generated/Schema.java b/scripts/interface/gen-java/org/apache/blur/thrift/generated/Schema.java new file mode 100644 index 0000000..ef3191c --- /dev/null +++ b/scripts/interface/gen-java/org/apache/blur/thrift/generated/Schema.java @@ -0,0 +1,648 @@ +/** + * 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; // required + 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; // required + 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; // required + 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; // required + 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/scripts/interface/gen-java/org/apache/blur/thrift/generated/ScoreType.java ---------------------------------------------------------------------- diff --git a/scripts/interface/gen-java/org/apache/blur/thrift/generated/ScoreType.java b/scripts/interface/gen-java/org/apache/blur/thrift/generated/ScoreType.java new file mode 100644 index 0000000..7e7cc5e --- /dev/null +++ b/scripts/interface/gen-java/org/apache/blur/thrift/generated/ScoreType.java @@ -0,0 +1,79 @@ +/** + * 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; + } + } +}
