http://git-wip-us.apache.org/repos/asf/cassandra/blob/4881d9c3/interface/thrift/gen-java/org/apache/cassandra/thrift/CfSplit.java ---------------------------------------------------------------------- diff --git a/interface/thrift/gen-java/org/apache/cassandra/thrift/CfSplit.java b/interface/thrift/gen-java/org/apache/cassandra/thrift/CfSplit.java deleted file mode 100644 index b654f86..0000000 --- a/interface/thrift/gen-java/org/apache/cassandra/thrift/CfSplit.java +++ /dev/null @@ -1,601 +0,0 @@ -/** - * Autogenerated by Thrift Compiler (0.9.1) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -package org.apache.cassandra.thrift; -/* - * - * 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.commons.lang3.builder.HashCodeBuilder; -import org.apache.thrift.scheme.IScheme; -import org.apache.thrift.scheme.SchemeFactory; -import org.apache.thrift.scheme.StandardScheme; - -import org.apache.thrift.scheme.TupleScheme; -import org.apache.thrift.protocol.TTupleProtocol; -import org.apache.thrift.EncodingUtils; -import java.util.Map; -import java.util.HashMap; -import java.util.EnumMap; -import java.util.EnumSet; -import java.util.Collections; - -/** - * Represents input splits used by hadoop ColumnFamilyRecordReaders - */ -public class CfSplit implements org.apache.thrift.TBase<CfSplit, CfSplit._Fields>, java.io.Serializable, Cloneable, Comparable<CfSplit> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("CfSplit"); - - private static final org.apache.thrift.protocol.TField START_TOKEN_FIELD_DESC = new org.apache.thrift.protocol.TField("start_token", org.apache.thrift.protocol.TType.STRING, (short)1); - private static final org.apache.thrift.protocol.TField END_TOKEN_FIELD_DESC = new org.apache.thrift.protocol.TField("end_token", org.apache.thrift.protocol.TType.STRING, (short)2); - private static final org.apache.thrift.protocol.TField ROW_COUNT_FIELD_DESC = new org.apache.thrift.protocol.TField("row_count", org.apache.thrift.protocol.TType.I64, (short)3); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new CfSplitStandardSchemeFactory()); - schemes.put(TupleScheme.class, new CfSplitTupleSchemeFactory()); - } - - public String start_token; // required - public String end_token; // required - public long row_count; // required - - /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - public enum _Fields implements org.apache.thrift.TFieldIdEnum { - START_TOKEN((short)1, "start_token"), - END_TOKEN((short)2, "end_token"), - ROW_COUNT((short)3, "row_count"); - - 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: // START_TOKEN - return START_TOKEN; - case 2: // END_TOKEN - return END_TOKEN; - case 3: // ROW_COUNT - return ROW_COUNT; - default: - return null; - } - } - - /** - * Find the _Fields constant that matches fieldId, throwing an exception - * if it is not found. - */ - public static _Fields findByThriftIdOrThrow(int fieldId) { - _Fields fields = findByThriftId(fieldId); - if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); - return fields; - } - - /** - * Find the _Fields constant that matches name, or null if its not found. - */ - public static _Fields findByName(String name) { - return byName.get(name); - } - - private final short _thriftId; - private final String _fieldName; - - _Fields(short thriftId, String fieldName) { - _thriftId = thriftId; - _fieldName = fieldName; - } - - public short getThriftFieldId() { - return _thriftId; - } - - public String getFieldName() { - return _fieldName; - } - } - - // isset id assignments - private static final int __ROW_COUNT_ISSET_ID = 0; - private byte __isset_bitfield = 0; - public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; - static { - Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); - tmpMap.put(_Fields.START_TOKEN, new org.apache.thrift.meta_data.FieldMetaData("start_token", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.END_TOKEN, new org.apache.thrift.meta_data.FieldMetaData("end_token", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.ROW_COUNT, new org.apache.thrift.meta_data.FieldMetaData("row_count", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(CfSplit.class, metaDataMap); - } - - public CfSplit() { - } - - public CfSplit( - String start_token, - String end_token, - long row_count) - { - this(); - this.start_token = start_token; - this.end_token = end_token; - this.row_count = row_count; - setRow_countIsSet(true); - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public CfSplit(CfSplit other) { - __isset_bitfield = other.__isset_bitfield; - if (other.isSetStart_token()) { - this.start_token = other.start_token; - } - if (other.isSetEnd_token()) { - this.end_token = other.end_token; - } - this.row_count = other.row_count; - } - - public CfSplit deepCopy() { - return new CfSplit(this); - } - - @Override - public void clear() { - this.start_token = null; - this.end_token = null; - setRow_countIsSet(false); - this.row_count = 0; - } - - public String getStart_token() { - return this.start_token; - } - - public CfSplit setStart_token(String start_token) { - this.start_token = start_token; - return this; - } - - public void unsetStart_token() { - this.start_token = null; - } - - /** Returns true if field start_token is set (has been assigned a value) and false otherwise */ - public boolean isSetStart_token() { - return this.start_token != null; - } - - public void setStart_tokenIsSet(boolean value) { - if (!value) { - this.start_token = null; - } - } - - public String getEnd_token() { - return this.end_token; - } - - public CfSplit setEnd_token(String end_token) { - this.end_token = end_token; - return this; - } - - public void unsetEnd_token() { - this.end_token = null; - } - - /** Returns true if field end_token is set (has been assigned a value) and false otherwise */ - public boolean isSetEnd_token() { - return this.end_token != null; - } - - public void setEnd_tokenIsSet(boolean value) { - if (!value) { - this.end_token = null; - } - } - - public long getRow_count() { - return this.row_count; - } - - public CfSplit setRow_count(long row_count) { - this.row_count = row_count; - setRow_countIsSet(true); - return this; - } - - public void unsetRow_count() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ROW_COUNT_ISSET_ID); - } - - /** Returns true if field row_count is set (has been assigned a value) and false otherwise */ - public boolean isSetRow_count() { - return EncodingUtils.testBit(__isset_bitfield, __ROW_COUNT_ISSET_ID); - } - - public void setRow_countIsSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ROW_COUNT_ISSET_ID, value); - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case START_TOKEN: - if (value == null) { - unsetStart_token(); - } else { - setStart_token((String)value); - } - break; - - case END_TOKEN: - if (value == null) { - unsetEnd_token(); - } else { - setEnd_token((String)value); - } - break; - - case ROW_COUNT: - if (value == null) { - unsetRow_count(); - } else { - setRow_count((Long)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case START_TOKEN: - return getStart_token(); - - case END_TOKEN: - return getEnd_token(); - - case ROW_COUNT: - return Long.valueOf(getRow_count()); - - } - 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 START_TOKEN: - return isSetStart_token(); - case END_TOKEN: - return isSetEnd_token(); - case ROW_COUNT: - return isSetRow_count(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof CfSplit) - return this.equals((CfSplit)that); - return false; - } - - public boolean equals(CfSplit that) { - if (that == null) - return false; - - boolean this_present_start_token = true && this.isSetStart_token(); - boolean that_present_start_token = true && that.isSetStart_token(); - if (this_present_start_token || that_present_start_token) { - if (!(this_present_start_token && that_present_start_token)) - return false; - if (!this.start_token.equals(that.start_token)) - return false; - } - - boolean this_present_end_token = true && this.isSetEnd_token(); - boolean that_present_end_token = true && that.isSetEnd_token(); - if (this_present_end_token || that_present_end_token) { - if (!(this_present_end_token && that_present_end_token)) - return false; - if (!this.end_token.equals(that.end_token)) - return false; - } - - boolean this_present_row_count = true; - boolean that_present_row_count = true; - if (this_present_row_count || that_present_row_count) { - if (!(this_present_row_count && that_present_row_count)) - return false; - if (this.row_count != that.row_count) - return false; - } - - return true; - } - - @Override - public int hashCode() { - HashCodeBuilder builder = new HashCodeBuilder(); - - boolean present_start_token = true && (isSetStart_token()); - builder.append(present_start_token); - if (present_start_token) - builder.append(start_token); - - boolean present_end_token = true && (isSetEnd_token()); - builder.append(present_end_token); - if (present_end_token) - builder.append(end_token); - - boolean present_row_count = true; - builder.append(present_row_count); - if (present_row_count) - builder.append(row_count); - - return builder.toHashCode(); - } - - @Override - public int compareTo(CfSplit other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(isSetStart_token()).compareTo(other.isSetStart_token()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetStart_token()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.start_token, other.start_token); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetEnd_token()).compareTo(other.isSetEnd_token()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetEnd_token()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.end_token, other.end_token); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetRow_count()).compareTo(other.isSetRow_count()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetRow_count()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.row_count, other.row_count); - if (lastComparison != 0) { - return lastComparison; - } - } - return 0; - } - - public _Fields fieldForId(int fieldId) { - return _Fields.findByThriftId(fieldId); - } - - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { - schemes.get(iprot.getScheme()).getScheme().read(iprot, this); - } - - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { - schemes.get(oprot.getScheme()).getScheme().write(oprot, this); - } - - @Override - public String toString() { - StringBuilder sb = new StringBuilder("CfSplit("); - boolean first = true; - - sb.append("start_token:"); - if (this.start_token == null) { - sb.append("null"); - } else { - sb.append(this.start_token); - } - first = false; - if (!first) sb.append(", "); - sb.append("end_token:"); - if (this.end_token == null) { - sb.append("null"); - } else { - sb.append(this.end_token); - } - first = false; - if (!first) sb.append(", "); - sb.append("row_count:"); - sb.append(this.row_count); - first = false; - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - if (start_token == null) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'start_token' was not present! Struct: " + toString()); - } - if (end_token == null) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'end_token' was not present! Struct: " + toString()); - } - // alas, we cannot check 'row_count' because it's a primitive and you chose the non-beans generator. - // check for sub-struct validity - } - - private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { - try { - write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { - try { - // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor. - __isset_bitfield = 0; - read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private static class CfSplitStandardSchemeFactory implements SchemeFactory { - public CfSplitStandardScheme getScheme() { - return new CfSplitStandardScheme(); - } - } - - private static class CfSplitStandardScheme extends StandardScheme<CfSplit> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, CfSplit struct) throws org.apache.thrift.TException { - org.apache.thrift.protocol.TField schemeField; - iprot.readStructBegin(); - while (true) - { - schemeField = iprot.readFieldBegin(); - if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { - break; - } - switch (schemeField.id) { - case 1: // START_TOKEN - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.start_token = iprot.readString(); - struct.setStart_tokenIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // END_TOKEN - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.end_token = iprot.readString(); - struct.setEnd_tokenIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 3: // ROW_COUNT - if (schemeField.type == org.apache.thrift.protocol.TType.I64) { - struct.row_count = iprot.readI64(); - struct.setRow_countIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - default: - org.apache.thrift.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 - if (!struct.isSetRow_count()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'row_count' was not found in serialized data! Struct: " + toString()); - } - struct.validate(); - } - - public void write(org.apache.thrift.protocol.TProtocol oprot, CfSplit struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.start_token != null) { - oprot.writeFieldBegin(START_TOKEN_FIELD_DESC); - oprot.writeString(struct.start_token); - oprot.writeFieldEnd(); - } - if (struct.end_token != null) { - oprot.writeFieldBegin(END_TOKEN_FIELD_DESC); - oprot.writeString(struct.end_token); - oprot.writeFieldEnd(); - } - oprot.writeFieldBegin(ROW_COUNT_FIELD_DESC); - oprot.writeI64(struct.row_count); - oprot.writeFieldEnd(); - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class CfSplitTupleSchemeFactory implements SchemeFactory { - public CfSplitTupleScheme getScheme() { - return new CfSplitTupleScheme(); - } - } - - private static class CfSplitTupleScheme extends TupleScheme<CfSplit> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, CfSplit struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - oprot.writeString(struct.start_token); - oprot.writeString(struct.end_token); - oprot.writeI64(struct.row_count); - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, CfSplit struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - struct.start_token = iprot.readString(); - struct.setStart_tokenIsSet(true); - struct.end_token = iprot.readString(); - struct.setEnd_tokenIsSet(true); - struct.row_count = iprot.readI64(); - struct.setRow_countIsSet(true); - } - } - -} -
http://git-wip-us.apache.org/repos/asf/cassandra/blob/4881d9c3/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java ---------------------------------------------------------------------- diff --git a/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java b/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java deleted file mode 100644 index e24a4e4..0000000 --- a/interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java +++ /dev/null @@ -1,743 +0,0 @@ -/** - * Autogenerated by Thrift Compiler (0.9.1) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -package org.apache.cassandra.thrift; -/* - * - * 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.commons.lang3.builder.HashCodeBuilder; -import org.apache.thrift.scheme.IScheme; -import org.apache.thrift.scheme.SchemeFactory; -import org.apache.thrift.scheme.StandardScheme; - -import org.apache.thrift.scheme.TupleScheme; -import org.apache.thrift.protocol.TTupleProtocol; -import org.apache.thrift.EncodingUtils; -import java.util.Map; -import java.util.HashMap; -import java.util.EnumMap; -import java.util.EnumSet; -import java.util.Collections; -import java.util.BitSet; -import java.nio.ByteBuffer; - -/** - * Basic unit of data within a ColumnFamily. - * @param name, the name by which this column is set and retrieved. Maximum 64KB long. - * @param value. The data associated with the name. Maximum 2GB long, but in practice you should limit it to small numbers of MB (since Thrift must read the full value into memory to operate on it). - * @param timestamp. The timestamp is used for conflict detection/resolution when two columns with same name need to be compared. - * @param ttl. An optional, positive delay (in seconds) after which the column will be automatically deleted. - */ -public class Column implements org.apache.thrift.TBase<Column, Column._Fields>, java.io.Serializable, Cloneable, Comparable<Column> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Column"); - - private static final org.apache.thrift.protocol.TField NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("name", org.apache.thrift.protocol.TType.STRING, (short)1); - private static final org.apache.thrift.protocol.TField VALUE_FIELD_DESC = new org.apache.thrift.protocol.TField("value", org.apache.thrift.protocol.TType.STRING, (short)2); - private static final org.apache.thrift.protocol.TField TIMESTAMP_FIELD_DESC = new org.apache.thrift.protocol.TField("timestamp", org.apache.thrift.protocol.TType.I64, (short)3); - private static final org.apache.thrift.protocol.TField TTL_FIELD_DESC = new org.apache.thrift.protocol.TField("ttl", org.apache.thrift.protocol.TType.I32, (short)4); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new ColumnStandardSchemeFactory()); - schemes.put(TupleScheme.class, new ColumnTupleSchemeFactory()); - } - - public ByteBuffer name; // required - public ByteBuffer value; // optional - public long timestamp; // optional - public int ttl; // optional - - /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - public enum _Fields implements org.apache.thrift.TFieldIdEnum { - NAME((short)1, "name"), - VALUE((short)2, "value"), - TIMESTAMP((short)3, "timestamp"), - TTL((short)4, "ttl"); - - private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); - - static { - for (_Fields field : EnumSet.allOf(_Fields.class)) { - byName.put(field.getFieldName(), field); - } - } - - /** - * Find the _Fields constant that matches fieldId, or null if its not found. - */ - public static _Fields findByThriftId(int fieldId) { - switch(fieldId) { - case 1: // NAME - return NAME; - case 2: // VALUE - return VALUE; - case 3: // TIMESTAMP - return TIMESTAMP; - case 4: // TTL - return TTL; - default: - return null; - } - } - - /** - * Find the _Fields constant that matches fieldId, throwing an exception - * if it is not found. - */ - public static _Fields findByThriftIdOrThrow(int fieldId) { - _Fields fields = findByThriftId(fieldId); - if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); - return fields; - } - - /** - * Find the _Fields constant that matches name, or null if its not found. - */ - public static _Fields findByName(String name) { - return byName.get(name); - } - - private final short _thriftId; - private final String _fieldName; - - _Fields(short thriftId, String fieldName) { - _thriftId = thriftId; - _fieldName = fieldName; - } - - public short getThriftFieldId() { - return _thriftId; - } - - public String getFieldName() { - return _fieldName; - } - } - - // isset id assignments - private static final int __TIMESTAMP_ISSET_ID = 0; - private static final int __TTL_ISSET_ID = 1; - private byte __isset_bitfield = 0; - private _Fields optionals[] = {_Fields.VALUE,_Fields.TIMESTAMP,_Fields.TTL}; - public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; - static { - Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); - tmpMap.put(_Fields.NAME, new org.apache.thrift.meta_data.FieldMetaData("name", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true))); - tmpMap.put(_Fields.VALUE, new org.apache.thrift.meta_data.FieldMetaData("value", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true))); - tmpMap.put(_Fields.TIMESTAMP, new org.apache.thrift.meta_data.FieldMetaData("timestamp", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); - tmpMap.put(_Fields.TTL, new org.apache.thrift.meta_data.FieldMetaData("ttl", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(Column.class, metaDataMap); - } - - public Column() { - } - - public Column( - ByteBuffer name) - { - this(); - this.name = name; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public Column(Column other) { - __isset_bitfield = other.__isset_bitfield; - if (other.isSetName()) { - this.name = org.apache.thrift.TBaseHelper.copyBinary(other.name); -; - } - if (other.isSetValue()) { - this.value = org.apache.thrift.TBaseHelper.copyBinary(other.value); -; - } - this.timestamp = other.timestamp; - this.ttl = other.ttl; - } - - public Column deepCopy() { - return new Column(this); - } - - @Override - public void clear() { - this.name = null; - this.value = null; - setTimestampIsSet(false); - this.timestamp = 0; - setTtlIsSet(false); - this.ttl = 0; - } - - public byte[] getName() { - setName(org.apache.thrift.TBaseHelper.rightSize(name)); - return name == null ? null : name.array(); - } - - public ByteBuffer bufferForName() { - return name; - } - - public Column setName(byte[] name) { - setName(name == null ? (ByteBuffer)null : ByteBuffer.wrap(name)); - return this; - } - - public Column setName(ByteBuffer name) { - this.name = name; - return this; - } - - public void unsetName() { - this.name = null; - } - - /** Returns true if field name is set (has been assigned a value) and false otherwise */ - public boolean isSetName() { - return this.name != null; - } - - public void setNameIsSet(boolean value) { - if (!value) { - this.name = null; - } - } - - public byte[] getValue() { - setValue(org.apache.thrift.TBaseHelper.rightSize(value)); - return value == null ? null : value.array(); - } - - public ByteBuffer bufferForValue() { - return value; - } - - public Column setValue(byte[] value) { - setValue(value == null ? (ByteBuffer)null : ByteBuffer.wrap(value)); - return this; - } - - public Column setValue(ByteBuffer value) { - this.value = value; - return this; - } - - public void unsetValue() { - this.value = null; - } - - /** Returns true if field value is set (has been assigned a value) and false otherwise */ - public boolean isSetValue() { - return this.value != null; - } - - public void setValueIsSet(boolean value) { - if (!value) { - this.value = null; - } - } - - public long getTimestamp() { - return this.timestamp; - } - - public Column setTimestamp(long timestamp) { - this.timestamp = timestamp; - setTimestampIsSet(true); - return this; - } - - public void unsetTimestamp() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TIMESTAMP_ISSET_ID); - } - - /** Returns true if field timestamp is set (has been assigned a value) and false otherwise */ - public boolean isSetTimestamp() { - return EncodingUtils.testBit(__isset_bitfield, __TIMESTAMP_ISSET_ID); - } - - public void setTimestampIsSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TIMESTAMP_ISSET_ID, value); - } - - public int getTtl() { - return this.ttl; - } - - public Column setTtl(int ttl) { - this.ttl = ttl; - setTtlIsSet(true); - return this; - } - - public void unsetTtl() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TTL_ISSET_ID); - } - - /** Returns true if field ttl is set (has been assigned a value) and false otherwise */ - public boolean isSetTtl() { - return EncodingUtils.testBit(__isset_bitfield, __TTL_ISSET_ID); - } - - public void setTtlIsSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TTL_ISSET_ID, value); - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case NAME: - if (value == null) { - unsetName(); - } else { - setName((ByteBuffer)value); - } - break; - - case VALUE: - if (value == null) { - unsetValue(); - } else { - setValue((ByteBuffer)value); - } - break; - - case TIMESTAMP: - if (value == null) { - unsetTimestamp(); - } else { - setTimestamp((Long)value); - } - break; - - case TTL: - if (value == null) { - unsetTtl(); - } else { - setTtl((Integer)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case NAME: - return getName(); - - case VALUE: - return getValue(); - - case TIMESTAMP: - return Long.valueOf(getTimestamp()); - - case TTL: - return Integer.valueOf(getTtl()); - - } - throw new IllegalStateException(); - } - - /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ - public boolean isSet(_Fields field) { - if (field == null) { - throw new IllegalArgumentException(); - } - - switch (field) { - case NAME: - return isSetName(); - case VALUE: - return isSetValue(); - case TIMESTAMP: - return isSetTimestamp(); - case TTL: - return isSetTtl(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof Column) - return this.equals((Column)that); - return false; - } - - public boolean equals(Column that) { - if (that == null) - return false; - - boolean this_present_name = true && this.isSetName(); - boolean that_present_name = true && that.isSetName(); - if (this_present_name || that_present_name) { - if (!(this_present_name && that_present_name)) - return false; - if (!this.name.equals(that.name)) - return false; - } - - boolean this_present_value = true && this.isSetValue(); - boolean that_present_value = true && that.isSetValue(); - if (this_present_value || that_present_value) { - if (!(this_present_value && that_present_value)) - return false; - if (!this.value.equals(that.value)) - return false; - } - - boolean this_present_timestamp = true && this.isSetTimestamp(); - boolean that_present_timestamp = true && that.isSetTimestamp(); - if (this_present_timestamp || that_present_timestamp) { - if (!(this_present_timestamp && that_present_timestamp)) - return false; - if (this.timestamp != that.timestamp) - return false; - } - - boolean this_present_ttl = true && this.isSetTtl(); - boolean that_present_ttl = true && that.isSetTtl(); - if (this_present_ttl || that_present_ttl) { - if (!(this_present_ttl && that_present_ttl)) - return false; - if (this.ttl != that.ttl) - return false; - } - - return true; - } - - @Override - public int hashCode() { - HashCodeBuilder builder = new HashCodeBuilder(); - - boolean present_name = true && (isSetName()); - builder.append(present_name); - if (present_name) - builder.append(name); - - boolean present_value = true && (isSetValue()); - builder.append(present_value); - if (present_value) - builder.append(value); - - boolean present_timestamp = true && (isSetTimestamp()); - builder.append(present_timestamp); - if (present_timestamp) - builder.append(timestamp); - - boolean present_ttl = true && (isSetTtl()); - builder.append(present_ttl); - if (present_ttl) - builder.append(ttl); - - return builder.toHashCode(); - } - - @Override - public int compareTo(Column other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(isSetName()).compareTo(other.isSetName()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetName()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.name, other.name); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetValue()).compareTo(other.isSetValue()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetValue()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.value, other.value); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetTimestamp()).compareTo(other.isSetTimestamp()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetTimestamp()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.timestamp, other.timestamp); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetTtl()).compareTo(other.isSetTtl()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetTtl()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.ttl, other.ttl); - if (lastComparison != 0) { - return lastComparison; - } - } - return 0; - } - - public _Fields fieldForId(int fieldId) { - return _Fields.findByThriftId(fieldId); - } - - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { - schemes.get(iprot.getScheme()).getScheme().read(iprot, this); - } - - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { - schemes.get(oprot.getScheme()).getScheme().write(oprot, this); - } - - @Override - public String toString() { - StringBuilder sb = new StringBuilder("Column("); - boolean first = true; - - sb.append("name:"); - if (this.name == null) { - sb.append("null"); - } else { - org.apache.thrift.TBaseHelper.toString(this.name, sb); - } - first = false; - if (isSetValue()) { - if (!first) sb.append(", "); - sb.append("value:"); - if (this.value == null) { - sb.append("null"); - } else { - org.apache.thrift.TBaseHelper.toString(this.value, sb); - } - first = false; - } - if (isSetTimestamp()) { - if (!first) sb.append(", "); - sb.append("timestamp:"); - sb.append(this.timestamp); - first = false; - } - if (isSetTtl()) { - if (!first) sb.append(", "); - sb.append("ttl:"); - sb.append(this.ttl); - first = false; - } - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - if (name == null) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'name' was not present! Struct: " + toString()); - } - // check for sub-struct validity - } - - private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { - try { - write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { - try { - // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor. - __isset_bitfield = 0; - read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private static class ColumnStandardSchemeFactory implements SchemeFactory { - public ColumnStandardScheme getScheme() { - return new ColumnStandardScheme(); - } - } - - private static class ColumnStandardScheme extends StandardScheme<Column> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, Column struct) throws org.apache.thrift.TException { - org.apache.thrift.protocol.TField schemeField; - iprot.readStructBegin(); - while (true) - { - schemeField = iprot.readFieldBegin(); - if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { - break; - } - switch (schemeField.id) { - case 1: // NAME - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.name = iprot.readBinary(); - struct.setNameIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // VALUE - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.value = iprot.readBinary(); - struct.setValueIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 3: // TIMESTAMP - if (schemeField.type == org.apache.thrift.protocol.TType.I64) { - struct.timestamp = iprot.readI64(); - struct.setTimestampIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 4: // TTL - if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.ttl = iprot.readI32(); - struct.setTtlIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - default: - org.apache.thrift.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.thrift.protocol.TProtocol oprot, Column struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.name != null) { - oprot.writeFieldBegin(NAME_FIELD_DESC); - oprot.writeBinary(struct.name); - oprot.writeFieldEnd(); - } - if (struct.value != null) { - if (struct.isSetValue()) { - oprot.writeFieldBegin(VALUE_FIELD_DESC); - oprot.writeBinary(struct.value); - oprot.writeFieldEnd(); - } - } - if (struct.isSetTimestamp()) { - oprot.writeFieldBegin(TIMESTAMP_FIELD_DESC); - oprot.writeI64(struct.timestamp); - oprot.writeFieldEnd(); - } - if (struct.isSetTtl()) { - oprot.writeFieldBegin(TTL_FIELD_DESC); - oprot.writeI32(struct.ttl); - oprot.writeFieldEnd(); - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class ColumnTupleSchemeFactory implements SchemeFactory { - public ColumnTupleScheme getScheme() { - return new ColumnTupleScheme(); - } - } - - private static class ColumnTupleScheme extends TupleScheme<Column> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, Column struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - oprot.writeBinary(struct.name); - BitSet optionals = new BitSet(); - if (struct.isSetValue()) { - optionals.set(0); - } - if (struct.isSetTimestamp()) { - optionals.set(1); - } - if (struct.isSetTtl()) { - optionals.set(2); - } - oprot.writeBitSet(optionals, 3); - if (struct.isSetValue()) { - oprot.writeBinary(struct.value); - } - if (struct.isSetTimestamp()) { - oprot.writeI64(struct.timestamp); - } - if (struct.isSetTtl()) { - oprot.writeI32(struct.ttl); - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, Column struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - struct.name = iprot.readBinary(); - struct.setNameIsSet(true); - BitSet incoming = iprot.readBitSet(3); - if (incoming.get(0)) { - struct.value = iprot.readBinary(); - struct.setValueIsSet(true); - } - if (incoming.get(1)) { - struct.timestamp = iprot.readI64(); - struct.setTimestampIsSet(true); - } - if (incoming.get(2)) { - struct.ttl = iprot.readI32(); - struct.setTtlIsSet(true); - } - } - } - -} - http://git-wip-us.apache.org/repos/asf/cassandra/blob/4881d9c3/interface/thrift/gen-java/org/apache/cassandra/thrift/ColumnDef.java ---------------------------------------------------------------------- diff --git a/interface/thrift/gen-java/org/apache/cassandra/thrift/ColumnDef.java b/interface/thrift/gen-java/org/apache/cassandra/thrift/ColumnDef.java deleted file mode 100644 index 409e4ac..0000000 --- a/interface/thrift/gen-java/org/apache/cassandra/thrift/ColumnDef.java +++ /dev/null @@ -1,903 +0,0 @@ -/** - * Autogenerated by Thrift Compiler (0.9.1) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -package org.apache.cassandra.thrift; -/* - * - * 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.commons.lang3.builder.HashCodeBuilder; -import org.apache.thrift.scheme.IScheme; -import org.apache.thrift.scheme.SchemeFactory; -import org.apache.thrift.scheme.StandardScheme; - -import org.apache.thrift.scheme.TupleScheme; -import org.apache.thrift.protocol.TTupleProtocol; -import java.util.Map; -import java.util.HashMap; -import java.util.EnumMap; -import java.util.EnumSet; -import java.util.Collections; -import java.util.BitSet; -import java.nio.ByteBuffer; - -public class ColumnDef implements org.apache.thrift.TBase<ColumnDef, ColumnDef._Fields>, java.io.Serializable, Cloneable, Comparable<ColumnDef> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ColumnDef"); - - private static final org.apache.thrift.protocol.TField NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("name", org.apache.thrift.protocol.TType.STRING, (short)1); - private static final org.apache.thrift.protocol.TField VALIDATION_CLASS_FIELD_DESC = new org.apache.thrift.protocol.TField("validation_class", org.apache.thrift.protocol.TType.STRING, (short)2); - private static final org.apache.thrift.protocol.TField INDEX_TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("index_type", org.apache.thrift.protocol.TType.I32, (short)3); - private static final org.apache.thrift.protocol.TField INDEX_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("index_name", org.apache.thrift.protocol.TType.STRING, (short)4); - private static final org.apache.thrift.protocol.TField INDEX_OPTIONS_FIELD_DESC = new org.apache.thrift.protocol.TField("index_options", org.apache.thrift.protocol.TType.MAP, (short)5); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new ColumnDefStandardSchemeFactory()); - schemes.put(TupleScheme.class, new ColumnDefTupleSchemeFactory()); - } - - public ByteBuffer name; // required - public String validation_class; // required - /** - * - * @see IndexType - */ - public IndexType index_type; // optional - public String index_name; // optional - public Map<String,String> index_options; // optional - - /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - public enum _Fields implements org.apache.thrift.TFieldIdEnum { - NAME((short)1, "name"), - VALIDATION_CLASS((short)2, "validation_class"), - /** - * - * @see IndexType - */ - INDEX_TYPE((short)3, "index_type"), - INDEX_NAME((short)4, "index_name"), - INDEX_OPTIONS((short)5, "index_options"); - - private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); - - static { - for (_Fields field : EnumSet.allOf(_Fields.class)) { - byName.put(field.getFieldName(), field); - } - } - - /** - * Find the _Fields constant that matches fieldId, or null if its not found. - */ - public static _Fields findByThriftId(int fieldId) { - switch(fieldId) { - case 1: // NAME - return NAME; - case 2: // VALIDATION_CLASS - return VALIDATION_CLASS; - case 3: // INDEX_TYPE - return INDEX_TYPE; - case 4: // INDEX_NAME - return INDEX_NAME; - case 5: // INDEX_OPTIONS - return INDEX_OPTIONS; - default: - return null; - } - } - - /** - * Find the _Fields constant that matches fieldId, throwing an exception - * if it is not found. - */ - public static _Fields findByThriftIdOrThrow(int fieldId) { - _Fields fields = findByThriftId(fieldId); - if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); - return fields; - } - - /** - * Find the _Fields constant that matches name, or null if its not found. - */ - public static _Fields findByName(String name) { - return byName.get(name); - } - - private final short _thriftId; - private final String _fieldName; - - _Fields(short thriftId, String fieldName) { - _thriftId = thriftId; - _fieldName = fieldName; - } - - public short getThriftFieldId() { - return _thriftId; - } - - public String getFieldName() { - return _fieldName; - } - } - - // isset id assignments - private _Fields optionals[] = {_Fields.INDEX_TYPE,_Fields.INDEX_NAME,_Fields.INDEX_OPTIONS}; - public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; - static { - Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); - tmpMap.put(_Fields.NAME, new org.apache.thrift.meta_data.FieldMetaData("name", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true))); - tmpMap.put(_Fields.VALIDATION_CLASS, new org.apache.thrift.meta_data.FieldMetaData("validation_class", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.INDEX_TYPE, new org.apache.thrift.meta_data.FieldMetaData("index_type", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, IndexType.class))); - tmpMap.put(_Fields.INDEX_NAME, new org.apache.thrift.meta_data.FieldMetaData("index_name", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.INDEX_OPTIONS, new org.apache.thrift.meta_data.FieldMetaData("index_options", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING), - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ColumnDef.class, metaDataMap); - } - - public ColumnDef() { - } - - public ColumnDef( - ByteBuffer name, - String validation_class) - { - this(); - this.name = name; - this.validation_class = validation_class; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public ColumnDef(ColumnDef other) { - if (other.isSetName()) { - this.name = org.apache.thrift.TBaseHelper.copyBinary(other.name); -; - } - if (other.isSetValidation_class()) { - this.validation_class = other.validation_class; - } - if (other.isSetIndex_type()) { - this.index_type = other.index_type; - } - if (other.isSetIndex_name()) { - this.index_name = other.index_name; - } - if (other.isSetIndex_options()) { - Map<String,String> __this__index_options = new HashMap<String,String>(other.index_options); - this.index_options = __this__index_options; - } - } - - public ColumnDef deepCopy() { - return new ColumnDef(this); - } - - @Override - public void clear() { - this.name = null; - this.validation_class = null; - this.index_type = null; - this.index_name = null; - this.index_options = null; - } - - public byte[] getName() { - setName(org.apache.thrift.TBaseHelper.rightSize(name)); - return name == null ? null : name.array(); - } - - public ByteBuffer bufferForName() { - return name; - } - - public ColumnDef setName(byte[] name) { - setName(name == null ? (ByteBuffer)null : ByteBuffer.wrap(name)); - return this; - } - - public ColumnDef setName(ByteBuffer name) { - this.name = name; - return this; - } - - public void unsetName() { - this.name = null; - } - - /** Returns true if field name is set (has been assigned a value) and false otherwise */ - public boolean isSetName() { - return this.name != null; - } - - public void setNameIsSet(boolean value) { - if (!value) { - this.name = null; - } - } - - public String getValidation_class() { - return this.validation_class; - } - - public ColumnDef setValidation_class(String validation_class) { - this.validation_class = validation_class; - return this; - } - - public void unsetValidation_class() { - this.validation_class = null; - } - - /** Returns true if field validation_class is set (has been assigned a value) and false otherwise */ - public boolean isSetValidation_class() { - return this.validation_class != null; - } - - public void setValidation_classIsSet(boolean value) { - if (!value) { - this.validation_class = null; - } - } - - /** - * - * @see IndexType - */ - public IndexType getIndex_type() { - return this.index_type; - } - - /** - * - * @see IndexType - */ - public ColumnDef setIndex_type(IndexType index_type) { - this.index_type = index_type; - return this; - } - - public void unsetIndex_type() { - this.index_type = null; - } - - /** Returns true if field index_type is set (has been assigned a value) and false otherwise */ - public boolean isSetIndex_type() { - return this.index_type != null; - } - - public void setIndex_typeIsSet(boolean value) { - if (!value) { - this.index_type = null; - } - } - - public String getIndex_name() { - return this.index_name; - } - - public ColumnDef setIndex_name(String index_name) { - this.index_name = index_name; - return this; - } - - public void unsetIndex_name() { - this.index_name = null; - } - - /** Returns true if field index_name is set (has been assigned a value) and false otherwise */ - public boolean isSetIndex_name() { - return this.index_name != null; - } - - public void setIndex_nameIsSet(boolean value) { - if (!value) { - this.index_name = null; - } - } - - public int getIndex_optionsSize() { - return (this.index_options == null) ? 0 : this.index_options.size(); - } - - public void putToIndex_options(String key, String val) { - if (this.index_options == null) { - this.index_options = new HashMap<String,String>(); - } - this.index_options.put(key, val); - } - - public Map<String,String> getIndex_options() { - return this.index_options; - } - - public ColumnDef setIndex_options(Map<String,String> index_options) { - this.index_options = index_options; - return this; - } - - public void unsetIndex_options() { - this.index_options = null; - } - - /** Returns true if field index_options is set (has been assigned a value) and false otherwise */ - public boolean isSetIndex_options() { - return this.index_options != null; - } - - public void setIndex_optionsIsSet(boolean value) { - if (!value) { - this.index_options = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case NAME: - if (value == null) { - unsetName(); - } else { - setName((ByteBuffer)value); - } - break; - - case VALIDATION_CLASS: - if (value == null) { - unsetValidation_class(); - } else { - setValidation_class((String)value); - } - break; - - case INDEX_TYPE: - if (value == null) { - unsetIndex_type(); - } else { - setIndex_type((IndexType)value); - } - break; - - case INDEX_NAME: - if (value == null) { - unsetIndex_name(); - } else { - setIndex_name((String)value); - } - break; - - case INDEX_OPTIONS: - if (value == null) { - unsetIndex_options(); - } else { - setIndex_options((Map<String,String>)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case NAME: - return getName(); - - case VALIDATION_CLASS: - return getValidation_class(); - - case INDEX_TYPE: - return getIndex_type(); - - case INDEX_NAME: - return getIndex_name(); - - case INDEX_OPTIONS: - return getIndex_options(); - - } - throw new IllegalStateException(); - } - - /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ - public boolean isSet(_Fields field) { - if (field == null) { - throw new IllegalArgumentException(); - } - - switch (field) { - case NAME: - return isSetName(); - case VALIDATION_CLASS: - return isSetValidation_class(); - case INDEX_TYPE: - return isSetIndex_type(); - case INDEX_NAME: - return isSetIndex_name(); - case INDEX_OPTIONS: - return isSetIndex_options(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof ColumnDef) - return this.equals((ColumnDef)that); - return false; - } - - public boolean equals(ColumnDef that) { - if (that == null) - return false; - - boolean this_present_name = true && this.isSetName(); - boolean that_present_name = true && that.isSetName(); - if (this_present_name || that_present_name) { - if (!(this_present_name && that_present_name)) - return false; - if (!this.name.equals(that.name)) - return false; - } - - boolean this_present_validation_class = true && this.isSetValidation_class(); - boolean that_present_validation_class = true && that.isSetValidation_class(); - if (this_present_validation_class || that_present_validation_class) { - if (!(this_present_validation_class && that_present_validation_class)) - return false; - if (!this.validation_class.equals(that.validation_class)) - return false; - } - - boolean this_present_index_type = true && this.isSetIndex_type(); - boolean that_present_index_type = true && that.isSetIndex_type(); - if (this_present_index_type || that_present_index_type) { - if (!(this_present_index_type && that_present_index_type)) - return false; - if (!this.index_type.equals(that.index_type)) - return false; - } - - boolean this_present_index_name = true && this.isSetIndex_name(); - boolean that_present_index_name = true && that.isSetIndex_name(); - if (this_present_index_name || that_present_index_name) { - if (!(this_present_index_name && that_present_index_name)) - return false; - if (!this.index_name.equals(that.index_name)) - return false; - } - - boolean this_present_index_options = true && this.isSetIndex_options(); - boolean that_present_index_options = true && that.isSetIndex_options(); - if (this_present_index_options || that_present_index_options) { - if (!(this_present_index_options && that_present_index_options)) - return false; - if (!this.index_options.equals(that.index_options)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - HashCodeBuilder builder = new HashCodeBuilder(); - - boolean present_name = true && (isSetName()); - builder.append(present_name); - if (present_name) - builder.append(name); - - boolean present_validation_class = true && (isSetValidation_class()); - builder.append(present_validation_class); - if (present_validation_class) - builder.append(validation_class); - - boolean present_index_type = true && (isSetIndex_type()); - builder.append(present_index_type); - if (present_index_type) - builder.append(index_type.getValue()); - - boolean present_index_name = true && (isSetIndex_name()); - builder.append(present_index_name); - if (present_index_name) - builder.append(index_name); - - boolean present_index_options = true && (isSetIndex_options()); - builder.append(present_index_options); - if (present_index_options) - builder.append(index_options); - - return builder.toHashCode(); - } - - @Override - public int compareTo(ColumnDef other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(isSetName()).compareTo(other.isSetName()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetName()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.name, other.name); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetValidation_class()).compareTo(other.isSetValidation_class()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetValidation_class()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.validation_class, other.validation_class); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetIndex_type()).compareTo(other.isSetIndex_type()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetIndex_type()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.index_type, other.index_type); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetIndex_name()).compareTo(other.isSetIndex_name()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetIndex_name()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.index_name, other.index_name); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetIndex_options()).compareTo(other.isSetIndex_options()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetIndex_options()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.index_options, other.index_options); - if (lastComparison != 0) { - return lastComparison; - } - } - return 0; - } - - public _Fields fieldForId(int fieldId) { - return _Fields.findByThriftId(fieldId); - } - - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { - schemes.get(iprot.getScheme()).getScheme().read(iprot, this); - } - - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { - schemes.get(oprot.getScheme()).getScheme().write(oprot, this); - } - - @Override - public String toString() { - StringBuilder sb = new StringBuilder("ColumnDef("); - boolean first = true; - - sb.append("name:"); - if (this.name == null) { - sb.append("null"); - } else { - org.apache.thrift.TBaseHelper.toString(this.name, sb); - } - first = false; - if (!first) sb.append(", "); - sb.append("validation_class:"); - if (this.validation_class == null) { - sb.append("null"); - } else { - sb.append(this.validation_class); - } - first = false; - if (isSetIndex_type()) { - if (!first) sb.append(", "); - sb.append("index_type:"); - if (this.index_type == null) { - sb.append("null"); - } else { - sb.append(this.index_type); - } - first = false; - } - if (isSetIndex_name()) { - if (!first) sb.append(", "); - sb.append("index_name:"); - if (this.index_name == null) { - sb.append("null"); - } else { - sb.append(this.index_name); - } - first = false; - } - if (isSetIndex_options()) { - if (!first) sb.append(", "); - sb.append("index_options:"); - if (this.index_options == null) { - sb.append("null"); - } else { - sb.append(this.index_options); - } - first = false; - } - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - if (name == null) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'name' was not present! Struct: " + toString()); - } - if (validation_class == null) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'validation_class' was not present! Struct: " + toString()); - } - // check for sub-struct validity - } - - private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { - try { - write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); - } catch (org.apache.thrift.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.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private static class ColumnDefStandardSchemeFactory implements SchemeFactory { - public ColumnDefStandardScheme getScheme() { - return new ColumnDefStandardScheme(); - } - } - - private static class ColumnDefStandardScheme extends StandardScheme<ColumnDef> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, ColumnDef struct) throws org.apache.thrift.TException { - org.apache.thrift.protocol.TField schemeField; - iprot.readStructBegin(); - while (true) - { - schemeField = iprot.readFieldBegin(); - if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { - break; - } - switch (schemeField.id) { - case 1: // NAME - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.name = iprot.readBinary(); - struct.setNameIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // VALIDATION_CLASS - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.validation_class = iprot.readString(); - struct.setValidation_classIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 3: // INDEX_TYPE - if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.index_type = IndexType.findByValue(iprot.readI32()); - struct.setIndex_typeIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 4: // INDEX_NAME - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.index_name = iprot.readString(); - struct.setIndex_nameIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 5: // INDEX_OPTIONS - if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { - { - org.apache.thrift.protocol.TMap _map90 = iprot.readMapBegin(); - struct.index_options = new HashMap<String,String>(2*_map90.size); - for (int _i91 = 0; _i91 < _map90.size; ++_i91) - { - String _key92; - String _val93; - _key92 = iprot.readString(); - _val93 = iprot.readString(); - struct.index_options.put(_key92, _val93); - } - iprot.readMapEnd(); - } - struct.setIndex_optionsIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - default: - org.apache.thrift.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.thrift.protocol.TProtocol oprot, ColumnDef struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.name != null) { - oprot.writeFieldBegin(NAME_FIELD_DESC); - oprot.writeBinary(struct.name); - oprot.writeFieldEnd(); - } - if (struct.validation_class != null) { - oprot.writeFieldBegin(VALIDATION_CLASS_FIELD_DESC); - oprot.writeString(struct.validation_class); - oprot.writeFieldEnd(); - } - if (struct.index_type != null) { - if (struct.isSetIndex_type()) { - oprot.writeFieldBegin(INDEX_TYPE_FIELD_DESC); - oprot.writeI32(struct.index_type.getValue()); - oprot.writeFieldEnd(); - } - } - if (struct.index_name != null) { - if (struct.isSetIndex_name()) { - oprot.writeFieldBegin(INDEX_NAME_FIELD_DESC); - oprot.writeString(struct.index_name); - oprot.writeFieldEnd(); - } - } - if (struct.index_options != null) { - if (struct.isSetIndex_options()) { - oprot.writeFieldBegin(INDEX_OPTIONS_FIELD_DESC); - { - oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.index_options.size())); - for (Map.Entry<String, String> _iter94 : struct.index_options.entrySet()) - { - oprot.writeString(_iter94.getKey()); - oprot.writeString(_iter94.getValue()); - } - oprot.writeMapEnd(); - } - oprot.writeFieldEnd(); - } - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class ColumnDefTupleSchemeFactory implements SchemeFactory { - public ColumnDefTupleScheme getScheme() { - return new ColumnDefTupleScheme(); - } - } - - private static class ColumnDefTupleScheme extends TupleScheme<ColumnDef> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, ColumnDef struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - oprot.writeBinary(struct.name); - oprot.writeString(struct.validation_class); - BitSet optionals = new BitSet(); - if (struct.isSetIndex_type()) { - optionals.set(0); - } - if (struct.isSetIndex_name()) { - optionals.set(1); - } - if (struct.isSetIndex_options()) { - optionals.set(2); - } - oprot.writeBitSet(optionals, 3); - if (struct.isSetIndex_type()) { - oprot.writeI32(struct.index_type.getValue()); - } - if (struct.isSetIndex_name()) { - oprot.writeString(struct.index_name); - } - if (struct.isSetIndex_options()) { - { - oprot.writeI32(struct.index_options.size()); - for (Map.Entry<String, String> _iter95 : struct.index_options.entrySet()) - { - oprot.writeString(_iter95.getKey()); - oprot.writeString(_iter95.getValue()); - } - } - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, ColumnDef struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - struct.name = iprot.readBinary(); - struct.setNameIsSet(true); - struct.validation_class = iprot.readString(); - struct.setValidation_classIsSet(true); - BitSet incoming = iprot.readBitSet(3); - if (incoming.get(0)) { - struct.index_type = IndexType.findByValue(iprot.readI32()); - struct.setIndex_typeIsSet(true); - } - if (incoming.get(1)) { - struct.index_name = iprot.readString(); - struct.setIndex_nameIsSet(true); - } - if (incoming.get(2)) { - { - org.apache.thrift.protocol.TMap _map96 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.index_options = new HashMap<String,String>(2*_map96.size); - for (int _i97 = 0; _i97 < _map96.size; ++_i97) - { - String _key98; - String _val99; - _key98 = iprot.readString(); - _val99 = iprot.readString(); - struct.index_options.put(_key98, _val99); - } - } - struct.setIndex_optionsIsSet(true); - } - } - } - -} -
