http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/e5ae88af/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Record.java ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Record.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Record.java deleted file mode 100644 index 2f4e7c0..0000000 --- a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Record.java +++ /dev/null @@ -1,698 +0,0 @@ -/** - * Autogenerated by Thrift Compiler (0.9.0) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -package org.apache.blur.thrift.generated; - -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - - - -import org.apache.blur.thirdparty.thrift_0_9_0.scheme.IScheme; -import org.apache.blur.thirdparty.thrift_0_9_0.scheme.SchemeFactory; -import org.apache.blur.thirdparty.thrift_0_9_0.scheme.StandardScheme; - -import org.apache.blur.thirdparty.thrift_0_9_0.scheme.TupleScheme; -import org.apache.blur.thirdparty.thrift_0_9_0.protocol.TTupleProtocol; -import org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolException; -import org.apache.blur.thirdparty.thrift_0_9_0.EncodingUtils; -import org.apache.blur.thirdparty.thrift_0_9_0.TException; -import java.util.List; -import java.util.ArrayList; -import java.util.Map; -import java.util.HashMap; -import java.util.EnumMap; -import java.util.Set; -import java.util.HashSet; -import java.util.EnumSet; -import java.util.Collections; -import java.util.BitSet; -import java.nio.ByteBuffer; -import java.util.Arrays; -//import org.slf4j.Logger; -//import org.slf4j.LoggerFactory; - -/** - * 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/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/RecordMutation.java ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/RecordMutation.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/RecordMutation.java deleted file mode 100644 index 66b991a..0000000 --- a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/RecordMutation.java +++ /dev/null @@ -1,548 +0,0 @@ -/** - * Autogenerated by Thrift Compiler (0.9.0) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -package org.apache.blur.thrift.generated; - -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - - - -import org.apache.blur.thirdparty.thrift_0_9_0.scheme.IScheme; -import org.apache.blur.thirdparty.thrift_0_9_0.scheme.SchemeFactory; -import org.apache.blur.thirdparty.thrift_0_9_0.scheme.StandardScheme; - -import org.apache.blur.thirdparty.thrift_0_9_0.scheme.TupleScheme; -import org.apache.blur.thirdparty.thrift_0_9_0.protocol.TTupleProtocol; -import org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolException; -import org.apache.blur.thirdparty.thrift_0_9_0.EncodingUtils; -import org.apache.blur.thirdparty.thrift_0_9_0.TException; -import java.util.List; -import java.util.ArrayList; -import java.util.Map; -import java.util.HashMap; -import java.util.EnumMap; -import java.util.Set; -import java.util.HashSet; -import java.util.EnumSet; -import java.util.Collections; -import java.util.BitSet; -import java.nio.ByteBuffer; -import java.util.Arrays; -//import org.slf4j.Logger; -//import org.slf4j.LoggerFactory; - -/** - * The RowMutation defines how the given 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/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/RecordMutationType.java ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/RecordMutationType.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/RecordMutationType.java deleted file mode 100644 index c256e6a..0000000 --- a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/RecordMutationType.java +++ /dev/null @@ -1,79 +0,0 @@ -/** - * Autogenerated by Thrift Compiler (0.9.0) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -package org.apache.blur.thrift.generated; - -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - - - - -import java.util.Map; -import java.util.HashMap; -import org.apache.blur.thirdparty.thrift_0_9_0.TEnum; - -/** - * <table class="table-bordered table-striped table-condensed"> - * <tr><td colspan="2">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/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Response.java ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Response.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Response.java deleted file mode 100644 index 1e36a12..0000000 --- a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Response.java +++ /dev/null @@ -1,525 +0,0 @@ -/** - * Autogenerated by Thrift Compiler (0.9.0) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -package org.apache.blur.thrift.generated; - -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - - - -import org.apache.blur.thirdparty.thrift_0_9_0.scheme.IScheme; -import org.apache.blur.thirdparty.thrift_0_9_0.scheme.SchemeFactory; -import org.apache.blur.thirdparty.thrift_0_9_0.scheme.StandardScheme; - -import org.apache.blur.thirdparty.thrift_0_9_0.scheme.TupleScheme; -import org.apache.blur.thirdparty.thrift_0_9_0.protocol.TTupleProtocol; -import org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolException; -import org.apache.blur.thirdparty.thrift_0_9_0.EncodingUtils; -import org.apache.blur.thirdparty.thrift_0_9_0.TException; -import java.util.List; -import java.util.ArrayList; -import java.util.Map; -import java.util.HashMap; -import java.util.EnumMap; -import java.util.Set; -import java.util.HashSet; -import java.util.EnumSet; -import java.util.Collections; -import java.util.BitSet; -import java.nio.ByteBuffer; -import java.util.Arrays; -//import org.slf4j.Logger; -//import org.slf4j.LoggerFactory; - -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; // optional - 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; // optional - 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; // optional - 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; // optional - 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/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Row.java ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Row.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Row.java deleted file mode 100644 index e450f9e..0000000 --- a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Row.java +++ /dev/null @@ -1,590 +0,0 @@ -/** - * Autogenerated by Thrift Compiler (0.9.0) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -package org.apache.blur.thrift.generated; - -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - - - -import org.apache.blur.thirdparty.thrift_0_9_0.scheme.IScheme; -import org.apache.blur.thirdparty.thrift_0_9_0.scheme.SchemeFactory; -import org.apache.blur.thirdparty.thrift_0_9_0.scheme.StandardScheme; - -import org.apache.blur.thirdparty.thrift_0_9_0.scheme.TupleScheme; -import org.apache.blur.thirdparty.thrift_0_9_0.protocol.TTupleProtocol; -import org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolException; -import org.apache.blur.thirdparty.thrift_0_9_0.EncodingUtils; -import org.apache.blur.thirdparty.thrift_0_9_0.TException; -import java.util.List; -import java.util.ArrayList; -import java.util.Map; -import java.util.HashMap; -import java.util.EnumMap; -import java.util.Set; -import java.util.HashSet; -import java.util.EnumSet; -import java.util.Collections; -import java.util.BitSet; -import java.nio.ByteBuffer; -import java.util.Arrays; -//import org.slf4j.Logger; -//import org.slf4j.LoggerFactory; - -/** - * 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); - } - } - } - -} -
