http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/e5ae88af/scripts/interface/gen-java/org/apache/blur/thrift/generated/Record.java ---------------------------------------------------------------------- diff --git a/scripts/interface/gen-java/org/apache/blur/thrift/generated/Record.java b/scripts/interface/gen-java/org/apache/blur/thrift/generated/Record.java new file mode 100644 index 0000000..2f4e7c0 --- /dev/null +++ b/scripts/interface/gen-java/org/apache/blur/thrift/generated/Record.java @@ -0,0 +1,698 @@ +/** + * 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; + +/** + * Records contain a list of columns, multiple columns with the same name are allowed. + */ +public class Record implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Record, Record._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("Record"); + + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField RECORD_ID_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("recordId", 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 FAMILY_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("family", 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 COLUMNS_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("columns", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST, (short)3); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new RecordStandardSchemeFactory()); + schemes.put(TupleScheme.class, new RecordTupleSchemeFactory()); + } + + /** + * Record id uniquely identifies a record within a single row. + */ + public String recordId; // required + /** + * The family in which this record resides. + */ + public String family; // required + /** + * A list of columns, multiple columns with the same name are allowed. + */ + public List<Column> columns; // 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 { + /** + * Record id uniquely identifies a record within a single row. + */ + RECORD_ID((short)1, "recordId"), + /** + * The family in which this record resides. + */ + FAMILY((short)2, "family"), + /** + * A list of columns, multiple columns with the same name are allowed. + */ + COLUMNS((short)3, "columns"); + + 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: // RECORD_ID + return RECORD_ID; + case 2: // FAMILY + return FAMILY; + case 3: // COLUMNS + return COLUMNS; + 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.RECORD_ID, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("recordId", 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.FAMILY, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("family", 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.COLUMNS, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("columns", 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, Column.class)))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(Record.class, metaDataMap); + } + + public Record() { + } + + public Record( + String recordId, + String family, + List<Column> columns) + { + this(); + this.recordId = recordId; + this.family = family; + this.columns = columns; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public Record(Record other) { + if (other.isSetRecordId()) { + this.recordId = other.recordId; + } + if (other.isSetFamily()) { + this.family = other.family; + } + if (other.isSetColumns()) { + List<Column> __this__columns = new ArrayList<Column>(); + for (Column other_element : other.columns) { + __this__columns.add(new Column(other_element)); + } + this.columns = __this__columns; + } + } + + public Record deepCopy() { + return new Record(this); + } + + @Override + public void clear() { + this.recordId = null; + this.family = null; + this.columns = null; + } + + /** + * Record id uniquely identifies a record within a single row. + */ + public String getRecordId() { + return this.recordId; + } + + /** + * Record id uniquely identifies a record within a single row. + */ + public Record setRecordId(String recordId) { + this.recordId = recordId; + return this; + } + + public void unsetRecordId() { + this.recordId = null; + } + + /** Returns true if field recordId is set (has been assigned a value) and false otherwise */ + public boolean isSetRecordId() { + return this.recordId != null; + } + + public void setRecordIdIsSet(boolean value) { + if (!value) { + this.recordId = null; + } + } + + /** + * The family in which this record resides. + */ + public String getFamily() { + return this.family; + } + + /** + * The family in which this record resides. + */ + public Record setFamily(String family) { + this.family = family; + return this; + } + + public void unsetFamily() { + this.family = null; + } + + /** Returns true if field family is set (has been assigned a value) and false otherwise */ + public boolean isSetFamily() { + return this.family != null; + } + + public void setFamilyIsSet(boolean value) { + if (!value) { + this.family = null; + } + } + + public int getColumnsSize() { + return (this.columns == null) ? 0 : this.columns.size(); + } + + public java.util.Iterator<Column> getColumnsIterator() { + return (this.columns == null) ? null : this.columns.iterator(); + } + + public void addToColumns(Column elem) { + if (this.columns == null) { + this.columns = new ArrayList<Column>(); + } + this.columns.add(elem); + } + + /** + * A list of columns, multiple columns with the same name are allowed. + */ + public List<Column> getColumns() { + return this.columns; + } + + /** + * A list of columns, multiple columns with the same name are allowed. + */ + public Record setColumns(List<Column> columns) { + this.columns = columns; + return this; + } + + public void unsetColumns() { + this.columns = null; + } + + /** Returns true if field columns is set (has been assigned a value) and false otherwise */ + public boolean isSetColumns() { + return this.columns != null; + } + + public void setColumnsIsSet(boolean value) { + if (!value) { + this.columns = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case RECORD_ID: + if (value == null) { + unsetRecordId(); + } else { + setRecordId((String)value); + } + break; + + case FAMILY: + if (value == null) { + unsetFamily(); + } else { + setFamily((String)value); + } + break; + + case COLUMNS: + if (value == null) { + unsetColumns(); + } else { + setColumns((List<Column>)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case RECORD_ID: + return getRecordId(); + + case FAMILY: + return getFamily(); + + case COLUMNS: + return getColumns(); + + } + 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 RECORD_ID: + return isSetRecordId(); + case FAMILY: + return isSetFamily(); + case COLUMNS: + return isSetColumns(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof Record) + return this.equals((Record)that); + return false; + } + + public boolean equals(Record that) { + if (that == null) + return false; + + boolean this_present_recordId = true && this.isSetRecordId(); + boolean that_present_recordId = true && that.isSetRecordId(); + if (this_present_recordId || that_present_recordId) { + if (!(this_present_recordId && that_present_recordId)) + return false; + if (!this.recordId.equals(that.recordId)) + return false; + } + + boolean this_present_family = true && this.isSetFamily(); + boolean that_present_family = true && that.isSetFamily(); + if (this_present_family || that_present_family) { + if (!(this_present_family && that_present_family)) + return false; + if (!this.family.equals(that.family)) + return false; + } + + boolean this_present_columns = true && this.isSetColumns(); + boolean that_present_columns = true && that.isSetColumns(); + if (this_present_columns || that_present_columns) { + if (!(this_present_columns && that_present_columns)) + return false; + if (!this.columns.equals(that.columns)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + return 0; + } + + public int compareTo(Record other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + Record typedOther = (Record)other; + + lastComparison = Boolean.valueOf(isSetRecordId()).compareTo(typedOther.isSetRecordId()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetRecordId()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.recordId, typedOther.recordId); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetFamily()).compareTo(typedOther.isSetFamily()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetFamily()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.family, typedOther.family); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetColumns()).compareTo(typedOther.isSetColumns()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetColumns()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.columns, typedOther.columns); + 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("Record("); + boolean first = true; + + sb.append("recordId:"); + if (this.recordId == null) { + sb.append("null"); + } else { + sb.append(this.recordId); + } + first = false; + if (!first) sb.append(", "); + sb.append("family:"); + if (this.family == null) { + sb.append("null"); + } else { + sb.append(this.family); + } + first = false; + if (!first) sb.append(", "); + sb.append("columns:"); + if (this.columns == null) { + sb.append("null"); + } else { + sb.append(this.columns); + } + 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 RecordStandardSchemeFactory implements SchemeFactory { + public RecordStandardScheme getScheme() { + return new RecordStandardScheme(); + } + } + + private static class RecordStandardScheme extends StandardScheme<Record> { + + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, Record 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: // RECORD_ID + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING) { + struct.recordId = iprot.readString(); + struct.setRecordIdIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // FAMILY + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING) { + struct.family = iprot.readString(); + struct.setFamilyIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 3: // COLUMNS + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST) { + { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list10 = iprot.readListBegin(); + struct.columns = new ArrayList<Column>(_list10.size); + for (int _i11 = 0; _i11 < _list10.size; ++_i11) + { + Column _elem12; // required + _elem12 = new Column(); + _elem12.read(iprot); + struct.columns.add(_elem12); + } + iprot.readListEnd(); + } + struct.setColumnsIsSet(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, Record struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.recordId != null) { + oprot.writeFieldBegin(RECORD_ID_FIELD_DESC); + oprot.writeString(struct.recordId); + oprot.writeFieldEnd(); + } + if (struct.family != null) { + oprot.writeFieldBegin(FAMILY_FIELD_DESC); + oprot.writeString(struct.family); + oprot.writeFieldEnd(); + } + if (struct.columns != null) { + oprot.writeFieldBegin(COLUMNS_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.columns.size())); + for (Column _iter13 : struct.columns) + { + _iter13.write(oprot); + } + oprot.writeListEnd(); + } + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class RecordTupleSchemeFactory implements SchemeFactory { + public RecordTupleScheme getScheme() { + return new RecordTupleScheme(); + } + } + + private static class RecordTupleScheme extends TupleScheme<Record> { + + @Override + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, Record struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetRecordId()) { + optionals.set(0); + } + if (struct.isSetFamily()) { + optionals.set(1); + } + if (struct.isSetColumns()) { + optionals.set(2); + } + oprot.writeBitSet(optionals, 3); + if (struct.isSetRecordId()) { + oprot.writeString(struct.recordId); + } + if (struct.isSetFamily()) { + oprot.writeString(struct.family); + } + if (struct.isSetColumns()) { + { + oprot.writeI32(struct.columns.size()); + for (Column _iter14 : struct.columns) + { + _iter14.write(oprot); + } + } + } + } + + @Override + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, Record struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(3); + if (incoming.get(0)) { + struct.recordId = iprot.readString(); + struct.setRecordIdIsSet(true); + } + if (incoming.get(1)) { + struct.family = iprot.readString(); + struct.setFamilyIsSet(true); + } + if (incoming.get(2)) { + { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list15 = 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.columns = new ArrayList<Column>(_list15.size); + for (int _i16 = 0; _i16 < _list15.size; ++_i16) + { + Column _elem17; // required + _elem17 = new Column(); + _elem17.read(iprot); + struct.columns.add(_elem17); + } + } + struct.setColumnsIsSet(true); + } + } + } + +} +
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/e5ae88af/scripts/interface/gen-java/org/apache/blur/thrift/generated/RecordMutation.java ---------------------------------------------------------------------- diff --git a/scripts/interface/gen-java/org/apache/blur/thrift/generated/RecordMutation.java b/scripts/interface/gen-java/org/apache/blur/thrift/generated/RecordMutation.java new file mode 100644 index 0000000..66b991a --- /dev/null +++ b/scripts/interface/gen-java/org/apache/blur/thrift/generated/RecordMutation.java @@ -0,0 +1,548 @@ +/** + * 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 Record is to be mutated. + */ +public class RecordMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<RecordMutation, RecordMutation._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("RecordMutation"); + + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField RECORD_MUTATION_TYPE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("recordMutationType", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32, (short)1); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField RECORD_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("record", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, (short)2); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new RecordMutationStandardSchemeFactory()); + schemes.put(TupleScheme.class, new RecordMutationTupleSchemeFactory()); + } + + /** + * Define how to mutate the given Record. + * + * @see RecordMutationType + */ + public RecordMutationType recordMutationType; // required + /** + * The Record to mutate. + */ + public Record record; // required + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + public enum _Fields implements org.apache.blur.thirdparty.thrift_0_9_0.TFieldIdEnum { + /** + * Define how to mutate the given Record. + * + * @see RecordMutationType + */ + RECORD_MUTATION_TYPE((short)1, "recordMutationType"), + /** + * The Record to mutate. + */ + RECORD((short)2, "record"); + + private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); + + static { + for (_Fields field : EnumSet.allOf(_Fields.class)) { + byName.put(field.getFieldName(), field); + } + } + + /** + * Find the _Fields constant that matches fieldId, or null if its not found. + */ + public static _Fields findByThriftId(int fieldId) { + switch(fieldId) { + case 1: // RECORD_MUTATION_TYPE + return RECORD_MUTATION_TYPE; + case 2: // RECORD + return RECORD; + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + + // isset id assignments + public static final Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> metaDataMap; + static { + Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData>(_Fields.class); + tmpMap.put(_Fields.RECORD_MUTATION_TYPE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("recordMutationType", 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, RecordMutationType.class))); + tmpMap.put(_Fields.RECORD, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("record", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.StructMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, Record.class))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(RecordMutation.class, metaDataMap); + } + + public RecordMutation() { + this.recordMutationType = org.apache.blur.thrift.generated.RecordMutationType.REPLACE_ENTIRE_RECORD; + + } + + public RecordMutation( + RecordMutationType recordMutationType, + Record record) + { + this(); + this.recordMutationType = recordMutationType; + this.record = record; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public RecordMutation(RecordMutation other) { + if (other.isSetRecordMutationType()) { + this.recordMutationType = other.recordMutationType; + } + if (other.isSetRecord()) { + this.record = new Record(other.record); + } + } + + public RecordMutation deepCopy() { + return new RecordMutation(this); + } + + @Override + public void clear() { + this.recordMutationType = org.apache.blur.thrift.generated.RecordMutationType.REPLACE_ENTIRE_RECORD; + + this.record = null; + } + + /** + * Define how to mutate the given Record. + * + * @see RecordMutationType + */ + public RecordMutationType getRecordMutationType() { + return this.recordMutationType; + } + + /** + * Define how to mutate the given Record. + * + * @see RecordMutationType + */ + public RecordMutation setRecordMutationType(RecordMutationType recordMutationType) { + this.recordMutationType = recordMutationType; + return this; + } + + public void unsetRecordMutationType() { + this.recordMutationType = null; + } + + /** Returns true if field recordMutationType is set (has been assigned a value) and false otherwise */ + public boolean isSetRecordMutationType() { + return this.recordMutationType != null; + } + + public void setRecordMutationTypeIsSet(boolean value) { + if (!value) { + this.recordMutationType = null; + } + } + + /** + * The Record to mutate. + */ + public Record getRecord() { + return this.record; + } + + /** + * The Record to mutate. + */ + public RecordMutation setRecord(Record record) { + this.record = record; + return this; + } + + public void unsetRecord() { + this.record = null; + } + + /** Returns true if field record is set (has been assigned a value) and false otherwise */ + public boolean isSetRecord() { + return this.record != null; + } + + public void setRecordIsSet(boolean value) { + if (!value) { + this.record = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case RECORD_MUTATION_TYPE: + if (value == null) { + unsetRecordMutationType(); + } else { + setRecordMutationType((RecordMutationType)value); + } + break; + + case RECORD: + if (value == null) { + unsetRecord(); + } else { + setRecord((Record)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case RECORD_MUTATION_TYPE: + return getRecordMutationType(); + + case RECORD: + return getRecord(); + + } + throw new IllegalStateException(); + } + + /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ + public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + + switch (field) { + case RECORD_MUTATION_TYPE: + return isSetRecordMutationType(); + case RECORD: + return isSetRecord(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof RecordMutation) + return this.equals((RecordMutation)that); + return false; + } + + public boolean equals(RecordMutation that) { + if (that == null) + return false; + + boolean this_present_recordMutationType = true && this.isSetRecordMutationType(); + boolean that_present_recordMutationType = true && that.isSetRecordMutationType(); + if (this_present_recordMutationType || that_present_recordMutationType) { + if (!(this_present_recordMutationType && that_present_recordMutationType)) + return false; + if (!this.recordMutationType.equals(that.recordMutationType)) + return false; + } + + boolean this_present_record = true && this.isSetRecord(); + boolean that_present_record = true && that.isSetRecord(); + if (this_present_record || that_present_record) { + if (!(this_present_record && that_present_record)) + return false; + if (!this.record.equals(that.record)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + return 0; + } + + public int compareTo(RecordMutation other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + RecordMutation typedOther = (RecordMutation)other; + + lastComparison = Boolean.valueOf(isSetRecordMutationType()).compareTo(typedOther.isSetRecordMutationType()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetRecordMutationType()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.recordMutationType, typedOther.recordMutationType); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetRecord()).compareTo(typedOther.isSetRecord()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetRecord()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.record, typedOther.record); + if (lastComparison != 0) { + return lastComparison; + } + } + return 0; + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + } + + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("RecordMutation("); + boolean first = true; + + sb.append("recordMutationType:"); + if (this.recordMutationType == null) { + sb.append("null"); + } else { + sb.append(this.recordMutationType); + } + first = false; + if (!first) sb.append(", "); + sb.append("record:"); + if (this.record == null) { + sb.append("null"); + } else { + sb.append(this.record); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + // check for required fields + // check for sub-struct validity + if (record != null) { + record.validate(); + } + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TCompactProtocol(new org.apache.blur.thirdparty.thrift_0_9_0.transport.TIOStreamTransport(out))); + } catch (org.apache.blur.thirdparty.thrift_0_9_0.TException te) { + throw new java.io.IOException(te); + } + } + + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + try { + read(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TCompactProtocol(new org.apache.blur.thirdparty.thrift_0_9_0.transport.TIOStreamTransport(in))); + } catch (org.apache.blur.thirdparty.thrift_0_9_0.TException te) { + throw new java.io.IOException(te); + } + } + + private static class RecordMutationStandardSchemeFactory implements SchemeFactory { + public RecordMutationStandardScheme getScheme() { + return new RecordMutationStandardScheme(); + } + } + + private static class RecordMutationStandardScheme extends StandardScheme<RecordMutation> { + + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, RecordMutation 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: // RECORD_MUTATION_TYPE + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32) { + struct.recordMutationType = RecordMutationType.findByValue(iprot.readI32()); + struct.setRecordMutationTypeIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // RECORD + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT) { + struct.record = new Record(); + struct.record.read(iprot); + struct.setRecordIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + default: + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + iprot.readFieldEnd(); + } + iprot.readStructEnd(); + + // check for required fields of primitive type, which can't be checked in the validate method + struct.validate(); + } + + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot, RecordMutation struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.recordMutationType != null) { + oprot.writeFieldBegin(RECORD_MUTATION_TYPE_FIELD_DESC); + oprot.writeI32(struct.recordMutationType.getValue()); + oprot.writeFieldEnd(); + } + if (struct.record != null) { + oprot.writeFieldBegin(RECORD_FIELD_DESC); + struct.record.write(oprot); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class RecordMutationTupleSchemeFactory implements SchemeFactory { + public RecordMutationTupleScheme getScheme() { + return new RecordMutationTupleScheme(); + } + } + + private static class RecordMutationTupleScheme extends TupleScheme<RecordMutation> { + + @Override + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, RecordMutation struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetRecordMutationType()) { + optionals.set(0); + } + if (struct.isSetRecord()) { + optionals.set(1); + } + oprot.writeBitSet(optionals, 2); + if (struct.isSetRecordMutationType()) { + oprot.writeI32(struct.recordMutationType.getValue()); + } + if (struct.isSetRecord()) { + struct.record.write(oprot); + } + } + + @Override + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, RecordMutation 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.recordMutationType = RecordMutationType.findByValue(iprot.readI32()); + struct.setRecordMutationTypeIsSet(true); + } + if (incoming.get(1)) { + struct.record = new Record(); + struct.record.read(iprot); + struct.setRecordIsSet(true); + } + } + } + +} + http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/e5ae88af/scripts/interface/gen-java/org/apache/blur/thrift/generated/RecordMutationType.java ---------------------------------------------------------------------- diff --git a/scripts/interface/gen-java/org/apache/blur/thrift/generated/RecordMutationType.java b/scripts/interface/gen-java/org/apache/blur/thrift/generated/RecordMutationType.java new file mode 100644 index 0000000..c256e6a --- /dev/null +++ b/scripts/interface/gen-java/org/apache/blur/thrift/generated/RecordMutationType.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">Specifies the type of Record mutation that should occur during a mutation of a given Record.</td></tr> + * <tr><td>DELETE_ENTIRE_RECORD</td><td>Indicates the Record with the given recordId in the given Row is to be deleted. If the target record does not exist, then no changes are made.</td></tr> + * <tr><td>REPLACE_ENTIRE_RECORD</td><td>Indicates the Record with the given recordId in the given Row is to be deleted, and a new Record with the same id is to be added. If the specified record does not exist the new record is still added.</td></tr> + * <tr><td>REPLACE_COLUMNS</td><td>Replace the columns that are specified in the Record mutation. If the target record does not exist then this mutation will result in a BlurException.</td></tr> + * <tr><td>APPEND_COLUMN_VALUES</td><td>Append the columns in the Record mutation to the Record that could already exist. If the target record does not exist then this mutation will result in a BlurException.</td></tr> + * </table> + */ +public enum RecordMutationType implements org.apache.blur.thirdparty.thrift_0_9_0.TEnum { + DELETE_ENTIRE_RECORD(0), + REPLACE_ENTIRE_RECORD(1), + REPLACE_COLUMNS(2), + APPEND_COLUMN_VALUES(3); + + private final int value; + + private RecordMutationType(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 RecordMutationType findByValue(int value) { + switch (value) { + case 0: + return DELETE_ENTIRE_RECORD; + case 1: + return REPLACE_ENTIRE_RECORD; + case 2: + return REPLACE_COLUMNS; + case 3: + return APPEND_COLUMN_VALUES; + default: + return null; + } + } +} http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/e5ae88af/scripts/interface/gen-java/org/apache/blur/thrift/generated/Response.java ---------------------------------------------------------------------- diff --git a/scripts/interface/gen-java/org/apache/blur/thrift/generated/Response.java b/scripts/interface/gen-java/org/apache/blur/thrift/generated/Response.java new file mode 100644 index 0000000..6354606 --- /dev/null +++ b/scripts/interface/gen-java/org/apache/blur/thrift/generated/Response.java @@ -0,0 +1,525 @@ +/** + * 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; + +public class Response extends org.apache.blur.thirdparty.thrift_0_9_0.TUnion<Response, Response._Fields> { + 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("Response"); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField SHARD_TO_VALUE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("shardToValue", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP, (short)1); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField SERVER_TO_VALUE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("serverToValue", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP, (short)2); + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField VALUE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("value", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, (short)3); + + /** 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 { + SHARD_TO_VALUE((short)1, "shardToValue"), + SERVER_TO_VALUE((short)2, "serverToValue"), + VALUE((short)3, "value"); + + 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: // SHARD_TO_VALUE + return SHARD_TO_VALUE; + case 2: // SERVER_TO_VALUE + return SERVER_TO_VALUE; + case 3: // VALUE + return VALUE; + 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; + } + } + + 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.SHARD_TO_VALUE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("shardToValue", 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.StructMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, Shard.class), + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.StructMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, ValueObject.class)))); + tmpMap.put(_Fields.SERVER_TO_VALUE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("serverToValue", 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.StructMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, Server.class), + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.StructMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, ValueObject.class)))); + tmpMap.put(_Fields.VALUE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("value", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, + new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.StructMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, ValueObject.class))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(Response.class, metaDataMap); + } + + public Response() { + super(); + } + + public Response(_Fields setField, Object value) { + super(setField, value); + } + + public Response(Response other) { + super(other); + } + public Response deepCopy() { + return new Response(this); + } + + public static Response shardToValue(Map<Shard,ValueObject> value) { + Response x = new Response(); + x.setShardToValue(value); + return x; + } + + public static Response serverToValue(Map<Server,ValueObject> value) { + Response x = new Response(); + x.setServerToValue(value); + return x; + } + + public static Response value(ValueObject value) { + Response x = new Response(); + x.setValue(value); + return x; + } + + + @Override + protected void checkType(_Fields setField, Object value) throws ClassCastException { + switch (setField) { + case SHARD_TO_VALUE: + if (value instanceof Map) { + break; + } + throw new ClassCastException("Was expecting value of type Map<Shard,ValueObject> for field 'shardToValue', but got " + value.getClass().getSimpleName()); + case SERVER_TO_VALUE: + if (value instanceof Map) { + break; + } + throw new ClassCastException("Was expecting value of type Map<Server,ValueObject> for field 'serverToValue', but got " + value.getClass().getSimpleName()); + case VALUE: + if (value instanceof ValueObject) { + break; + } + throw new ClassCastException("Was expecting value of type ValueObject for field 'value', but got " + value.getClass().getSimpleName()); + default: + throw new IllegalArgumentException("Unknown field id " + setField); + } + } + + @Override + protected Object standardSchemeReadValue(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField field) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + _Fields setField = _Fields.findByThriftId(field.id); + if (setField != null) { + switch (setField) { + case SHARD_TO_VALUE: + if (field.type == SHARD_TO_VALUE_FIELD_DESC.type) { + Map<Shard,ValueObject> shardToValue; + { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map240 = iprot.readMapBegin(); + shardToValue = new HashMap<Shard,ValueObject>(2*_map240.size); + for (int _i241 = 0; _i241 < _map240.size; ++_i241) + { + Shard _key242; // required + ValueObject _val243; // required + _key242 = new Shard(); + _key242.read(iprot); + _val243 = new ValueObject(); + _val243.read(iprot); + shardToValue.put(_key242, _val243); + } + iprot.readMapEnd(); + } + return shardToValue; + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, field.type); + return null; + } + case SERVER_TO_VALUE: + if (field.type == SERVER_TO_VALUE_FIELD_DESC.type) { + Map<Server,ValueObject> serverToValue; + { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map244 = iprot.readMapBegin(); + serverToValue = new HashMap<Server,ValueObject>(2*_map244.size); + for (int _i245 = 0; _i245 < _map244.size; ++_i245) + { + Server _key246; // required + ValueObject _val247; // required + _key246 = new Server(); + _key246.read(iprot); + _val247 = new ValueObject(); + _val247.read(iprot); + serverToValue.put(_key246, _val247); + } + iprot.readMapEnd(); + } + return serverToValue; + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, field.type); + return null; + } + case VALUE: + if (field.type == VALUE_FIELD_DESC.type) { + ValueObject value; + value = new ValueObject(); + value.read(iprot); + return value; + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, field.type); + return null; + } + default: + throw new IllegalStateException("setField wasn't null, but didn't match any of the case statements!"); + } + } else { + return null; + } + } + + @Override + protected void standardSchemeWriteValue(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + switch (setField_) { + case SHARD_TO_VALUE: + Map<Shard,ValueObject> shardToValue = (Map<Shard,ValueObject>)value_; + { + oprot.writeMapBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, shardToValue.size())); + for (Map.Entry<Shard, ValueObject> _iter248 : shardToValue.entrySet()) + { + _iter248.getKey().write(oprot); + _iter248.getValue().write(oprot); + } + oprot.writeMapEnd(); + } + return; + case SERVER_TO_VALUE: + Map<Server,ValueObject> serverToValue = (Map<Server,ValueObject>)value_; + { + oprot.writeMapBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, serverToValue.size())); + for (Map.Entry<Server, ValueObject> _iter249 : serverToValue.entrySet()) + { + _iter249.getKey().write(oprot); + _iter249.getValue().write(oprot); + } + oprot.writeMapEnd(); + } + return; + case VALUE: + ValueObject value = (ValueObject)value_; + value.write(oprot); + return; + default: + throw new IllegalStateException("Cannot write union with unknown field " + setField_); + } + } + + @Override + protected Object tupleSchemeReadValue(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, short fieldID) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + _Fields setField = _Fields.findByThriftId(fieldID); + if (setField != null) { + switch (setField) { + case SHARD_TO_VALUE: + Map<Shard,ValueObject> shardToValue; + { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map250 = iprot.readMapBegin(); + shardToValue = new HashMap<Shard,ValueObject>(2*_map250.size); + for (int _i251 = 0; _i251 < _map250.size; ++_i251) + { + Shard _key252; // required + ValueObject _val253; // required + _key252 = new Shard(); + _key252.read(iprot); + _val253 = new ValueObject(); + _val253.read(iprot); + shardToValue.put(_key252, _val253); + } + iprot.readMapEnd(); + } + return shardToValue; + case SERVER_TO_VALUE: + Map<Server,ValueObject> serverToValue; + { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map254 = iprot.readMapBegin(); + serverToValue = new HashMap<Server,ValueObject>(2*_map254.size); + for (int _i255 = 0; _i255 < _map254.size; ++_i255) + { + Server _key256; // required + ValueObject _val257; // required + _key256 = new Server(); + _key256.read(iprot); + _val257 = new ValueObject(); + _val257.read(iprot); + serverToValue.put(_key256, _val257); + } + iprot.readMapEnd(); + } + return serverToValue; + case VALUE: + ValueObject value; + value = new ValueObject(); + value.read(iprot); + return value; + default: + throw new IllegalStateException("setField wasn't null, but didn't match any of the case statements!"); + } + } else { + throw new TProtocolException("Couldn't find a field with field id " + fieldID); + } + } + + @Override + protected void tupleSchemeWriteValue(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + switch (setField_) { + case SHARD_TO_VALUE: + Map<Shard,ValueObject> shardToValue = (Map<Shard,ValueObject>)value_; + { + oprot.writeMapBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, shardToValue.size())); + for (Map.Entry<Shard, ValueObject> _iter258 : shardToValue.entrySet()) + { + _iter258.getKey().write(oprot); + _iter258.getValue().write(oprot); + } + oprot.writeMapEnd(); + } + return; + case SERVER_TO_VALUE: + Map<Server,ValueObject> serverToValue = (Map<Server,ValueObject>)value_; + { + oprot.writeMapBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, serverToValue.size())); + for (Map.Entry<Server, ValueObject> _iter259 : serverToValue.entrySet()) + { + _iter259.getKey().write(oprot); + _iter259.getValue().write(oprot); + } + oprot.writeMapEnd(); + } + return; + case VALUE: + ValueObject value = (ValueObject)value_; + value.write(oprot); + return; + default: + throw new IllegalStateException("Cannot write union with unknown field " + setField_); + } + } + + @Override + protected org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField getFieldDesc(_Fields setField) { + switch (setField) { + case SHARD_TO_VALUE: + return SHARD_TO_VALUE_FIELD_DESC; + case SERVER_TO_VALUE: + return SERVER_TO_VALUE_FIELD_DESC; + case VALUE: + return VALUE_FIELD_DESC; + default: + throw new IllegalArgumentException("Unknown field id " + setField); + } + } + + @Override + protected org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct getStructDesc() { + return STRUCT_DESC; + } + + @Override + protected _Fields enumForId(short id) { + return _Fields.findByThriftIdOrThrow(id); + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + + public Map<Shard,ValueObject> getShardToValue() { + if (getSetField() == _Fields.SHARD_TO_VALUE) { + return (Map<Shard,ValueObject>)getFieldValue(); + } else { + throw new RuntimeException("Cannot get field 'shardToValue' because union is currently set to " + getFieldDesc(getSetField()).name); + } + } + + public void setShardToValue(Map<Shard,ValueObject> value) { + if (value == null) throw new NullPointerException(); + setField_ = _Fields.SHARD_TO_VALUE; + value_ = value; + } + + public Map<Server,ValueObject> getServerToValue() { + if (getSetField() == _Fields.SERVER_TO_VALUE) { + return (Map<Server,ValueObject>)getFieldValue(); + } else { + throw new RuntimeException("Cannot get field 'serverToValue' because union is currently set to " + getFieldDesc(getSetField()).name); + } + } + + public void setServerToValue(Map<Server,ValueObject> value) { + if (value == null) throw new NullPointerException(); + setField_ = _Fields.SERVER_TO_VALUE; + value_ = value; + } + + public ValueObject getValue() { + if (getSetField() == _Fields.VALUE) { + return (ValueObject)getFieldValue(); + } else { + throw new RuntimeException("Cannot get field 'value' because union is currently set to " + getFieldDesc(getSetField()).name); + } + } + + public void setValue(ValueObject value) { + if (value == null) throw new NullPointerException(); + setField_ = _Fields.VALUE; + value_ = value; + } + + public boolean isSetShardToValue() { + return setField_ == _Fields.SHARD_TO_VALUE; + } + + + public boolean isSetServerToValue() { + return setField_ == _Fields.SERVER_TO_VALUE; + } + + + public boolean isSetValue() { + return setField_ == _Fields.VALUE; + } + + + public boolean equals(Object other) { + if (other instanceof Response) { + return equals((Response)other); + } else { + return false; + } + } + + public boolean equals(Response other) { + return other != null && getSetField() == other.getSetField() && getFieldValue().equals(other.getFieldValue()); + } + + @Override + public int compareTo(Response other) { + int lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(getSetField(), other.getSetField()); + if (lastComparison == 0) { + return org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(getFieldValue(), other.getFieldValue()); + } + return lastComparison; + } + + + /** + * If you'd like this to perform more respectably, use the hashcode generator option. + */ + @Override + public int hashCode() { + return 0; + } + + 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); + } + } + + +} http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/e5ae88af/scripts/interface/gen-java/org/apache/blur/thrift/generated/Row.java ---------------------------------------------------------------------- diff --git a/scripts/interface/gen-java/org/apache/blur/thrift/generated/Row.java b/scripts/interface/gen-java/org/apache/blur/thrift/generated/Row.java new file mode 100644 index 0000000..e450f9e --- /dev/null +++ b/scripts/interface/gen-java/org/apache/blur/thrift/generated/Row.java @@ -0,0 +1,590 @@ +/** + * 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; + +/** + * Rows contain a list of records. + */ +public class Row implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Row, Row._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("Row"); + + private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField ID_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("id", 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 RECORDS_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("records", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST, (short)2); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new RowStandardSchemeFactory()); + schemes.put(TupleScheme.class, new RowTupleSchemeFactory()); + } + + /** + * The row id. + */ + public String id; // required + /** + * The list records within the row. If paging is used this list will only + * reflect the paged records from the selector. + */ + public List<Record> records; // required + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + public enum _Fields implements org.apache.blur.thirdparty.thrift_0_9_0.TFieldIdEnum { + /** + * The row id. + */ + ID((short)1, "id"), + /** + * The list records within the row. If paging is used this list will only + * reflect the paged records from the selector. + */ + RECORDS((short)2, "records"); + + 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: // ID + return ID; + case 2: // RECORDS + return RECORDS; + 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.ID, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("id", 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.RECORDS, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("records", 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, Record.class)))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(Row.class, metaDataMap); + } + + public Row() { + } + + public Row( + String id, + List<Record> records) + { + this(); + this.id = id; + this.records = records; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public Row(Row other) { + if (other.isSetId()) { + this.id = other.id; + } + if (other.isSetRecords()) { + List<Record> __this__records = new ArrayList<Record>(); + for (Record other_element : other.records) { + __this__records.add(new Record(other_element)); + } + this.records = __this__records; + } + } + + public Row deepCopy() { + return new Row(this); + } + + @Override + public void clear() { + this.id = null; + this.records = null; + } + + /** + * The row id. + */ + public String getId() { + return this.id; + } + + /** + * The row id. + */ + public Row setId(String id) { + this.id = id; + return this; + } + + public void unsetId() { + this.id = null; + } + + /** Returns true if field id is set (has been assigned a value) and false otherwise */ + public boolean isSetId() { + return this.id != null; + } + + public void setIdIsSet(boolean value) { + if (!value) { + this.id = null; + } + } + + public int getRecordsSize() { + return (this.records == null) ? 0 : this.records.size(); + } + + public java.util.Iterator<Record> getRecordsIterator() { + return (this.records == null) ? null : this.records.iterator(); + } + + public void addToRecords(Record elem) { + if (this.records == null) { + this.records = new ArrayList<Record>(); + } + this.records.add(elem); + } + + /** + * The list records within the row. If paging is used this list will only + * reflect the paged records from the selector. + */ + public List<Record> getRecords() { + return this.records; + } + + /** + * The list records within the row. If paging is used this list will only + * reflect the paged records from the selector. + */ + public Row setRecords(List<Record> records) { + this.records = records; + return this; + } + + public void unsetRecords() { + this.records = null; + } + + /** Returns true if field records is set (has been assigned a value) and false otherwise */ + public boolean isSetRecords() { + return this.records != null; + } + + public void setRecordsIsSet(boolean value) { + if (!value) { + this.records = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case ID: + if (value == null) { + unsetId(); + } else { + setId((String)value); + } + break; + + case RECORDS: + if (value == null) { + unsetRecords(); + } else { + setRecords((List<Record>)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case ID: + return getId(); + + case RECORDS: + return getRecords(); + + } + 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 ID: + return isSetId(); + case RECORDS: + return isSetRecords(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof Row) + return this.equals((Row)that); + return false; + } + + public boolean equals(Row that) { + if (that == null) + return false; + + boolean this_present_id = true && this.isSetId(); + boolean that_present_id = true && that.isSetId(); + if (this_present_id || that_present_id) { + if (!(this_present_id && that_present_id)) + return false; + if (!this.id.equals(that.id)) + return false; + } + + boolean this_present_records = true && this.isSetRecords(); + boolean that_present_records = true && that.isSetRecords(); + if (this_present_records || that_present_records) { + if (!(this_present_records && that_present_records)) + return false; + if (!this.records.equals(that.records)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + return 0; + } + + public int compareTo(Row other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + Row typedOther = (Row)other; + + lastComparison = Boolean.valueOf(isSetId()).compareTo(typedOther.isSetId()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetId()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.id, typedOther.id); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetRecords()).compareTo(typedOther.isSetRecords()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetRecords()) { + lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.records, typedOther.records); + 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("Row("); + boolean first = true; + + sb.append("id:"); + if (this.id == null) { + sb.append("null"); + } else { + sb.append(this.id); + } + first = false; + if (!first) sb.append(", "); + sb.append("records:"); + if (this.records == null) { + sb.append("null"); + } else { + sb.append(this.records); + } + 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 RowStandardSchemeFactory implements SchemeFactory { + public RowStandardScheme getScheme() { + return new RowStandardScheme(); + } + } + + private static class RowStandardScheme extends StandardScheme<Row> { + + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, Row 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: // ID + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING) { + struct.id = iprot.readString(); + struct.setIdIsSet(true); + } else { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // RECORDS + if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST) { + { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list18 = iprot.readListBegin(); + struct.records = new ArrayList<Record>(_list18.size); + for (int _i19 = 0; _i19 < _list18.size; ++_i19) + { + Record _elem20; // required + _elem20 = new Record(); + _elem20.read(iprot); + struct.records.add(_elem20); + } + iprot.readListEnd(); + } + struct.setRecordsIsSet(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, Row struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.id != null) { + oprot.writeFieldBegin(ID_FIELD_DESC); + oprot.writeString(struct.id); + oprot.writeFieldEnd(); + } + if (struct.records != null) { + oprot.writeFieldBegin(RECORDS_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.records.size())); + for (Record _iter21 : struct.records) + { + _iter21.write(oprot); + } + oprot.writeListEnd(); + } + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class RowTupleSchemeFactory implements SchemeFactory { + public RowTupleScheme getScheme() { + return new RowTupleScheme(); + } + } + + private static class RowTupleScheme extends TupleScheme<Row> { + + @Override + public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, Row struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetId()) { + optionals.set(0); + } + if (struct.isSetRecords()) { + optionals.set(1); + } + oprot.writeBitSet(optionals, 2); + if (struct.isSetId()) { + oprot.writeString(struct.id); + } + if (struct.isSetRecords()) { + { + oprot.writeI32(struct.records.size()); + for (Record _iter22 : struct.records) + { + _iter22.write(oprot); + } + } + } + } + + @Override + public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, Row 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.id = iprot.readString(); + struct.setIdIsSet(true); + } + if (incoming.get(1)) { + { + org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list23 = 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.records = new ArrayList<Record>(_list23.size); + for (int _i24 = 0; _i24 < _list23.size; ++_i24) + { + Record _elem25; // required + _elem25 = new Record(); + _elem25.read(iprot); + struct.records.add(_elem25); + } + } + struct.setRecordsIsSet(true); + } + } + } + +} +
