You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ct...@apache.org on 2016/03/03 22:59:56 UTC
[31/61] [abbrv] [partial] accumulo git commit: ACCUMULO-722 put trunk
in my sandbox
http://git-wip-us.apache.org/repos/asf/accumulo/blob/7bdbfccb/1.5/core/src/main/java/org/apache/accumulo/core/data/thrift/MapFileInfo.java
----------------------------------------------------------------------
diff --git a/1.5/core/src/main/java/org/apache/accumulo/core/data/thrift/MapFileInfo.java b/1.5/core/src/main/java/org/apache/accumulo/core/data/thrift/MapFileInfo.java
new file mode 100644
index 0000000..5dd04f5
--- /dev/null
+++ b/1.5/core/src/main/java/org/apache/accumulo/core/data/thrift/MapFileInfo.java
@@ -0,0 +1,381 @@
+/**
+ * Autogenerated by Thrift Compiler (0.8.0)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package org.apache.accumulo.core.data.thrift;
+
+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.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;
+
+@SuppressWarnings("all") public class MapFileInfo implements org.apache.thrift.TBase<MapFileInfo, MapFileInfo._Fields>, java.io.Serializable, Cloneable {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("MapFileInfo");
+
+ private static final org.apache.thrift.protocol.TField ESTIMATED_SIZE_FIELD_DESC = new org.apache.thrift.protocol.TField("estimatedSize", org.apache.thrift.protocol.TType.I64, (short)1);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new MapFileInfoStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new MapFileInfoTupleSchemeFactory());
+ }
+
+ public long estimatedSize; // 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 {
+ ESTIMATED_SIZE((short)1, "estimatedSize");
+
+ 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: // ESTIMATED_SIZE
+ return ESTIMATED_SIZE;
+ 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 __ESTIMATEDSIZE_ISSET_ID = 0;
+ private BitSet __isset_bit_vector = new BitSet(1);
+ 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.ESTIMATED_SIZE, new org.apache.thrift.meta_data.FieldMetaData("estimatedSize", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(MapFileInfo.class, metaDataMap);
+ }
+
+ public MapFileInfo() {
+ }
+
+ public MapFileInfo(
+ long estimatedSize)
+ {
+ this();
+ this.estimatedSize = estimatedSize;
+ setEstimatedSizeIsSet(true);
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public MapFileInfo(MapFileInfo other) {
+ __isset_bit_vector.clear();
+ __isset_bit_vector.or(other.__isset_bit_vector);
+ this.estimatedSize = other.estimatedSize;
+ }
+
+ public MapFileInfo deepCopy() {
+ return new MapFileInfo(this);
+ }
+
+ @Override
+ public void clear() {
+ setEstimatedSizeIsSet(false);
+ this.estimatedSize = 0;
+ }
+
+ public long getEstimatedSize() {
+ return this.estimatedSize;
+ }
+
+ public MapFileInfo setEstimatedSize(long estimatedSize) {
+ this.estimatedSize = estimatedSize;
+ setEstimatedSizeIsSet(true);
+ return this;
+ }
+
+ public void unsetEstimatedSize() {
+ __isset_bit_vector.clear(__ESTIMATEDSIZE_ISSET_ID);
+ }
+
+ /** Returns true if field estimatedSize is set (has been assigned a value) and false otherwise */
+ public boolean isSetEstimatedSize() {
+ return __isset_bit_vector.get(__ESTIMATEDSIZE_ISSET_ID);
+ }
+
+ public void setEstimatedSizeIsSet(boolean value) {
+ __isset_bit_vector.set(__ESTIMATEDSIZE_ISSET_ID, value);
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case ESTIMATED_SIZE:
+ if (value == null) {
+ unsetEstimatedSize();
+ } else {
+ setEstimatedSize((Long)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case ESTIMATED_SIZE:
+ return Long.valueOf(getEstimatedSize());
+
+ }
+ 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 ESTIMATED_SIZE:
+ return isSetEstimatedSize();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof MapFileInfo)
+ return this.equals((MapFileInfo)that);
+ return false;
+ }
+
+ public boolean equals(MapFileInfo that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_estimatedSize = true;
+ boolean that_present_estimatedSize = true;
+ if (this_present_estimatedSize || that_present_estimatedSize) {
+ if (!(this_present_estimatedSize && that_present_estimatedSize))
+ return false;
+ if (this.estimatedSize != that.estimatedSize)
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ return 0;
+ }
+
+ public int compareTo(MapFileInfo other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+ MapFileInfo typedOther = (MapFileInfo)other;
+
+ lastComparison = Boolean.valueOf(isSetEstimatedSize()).compareTo(typedOther.isSetEstimatedSize());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetEstimatedSize()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.estimatedSize, typedOther.estimatedSize);
+ 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("MapFileInfo(");
+ boolean first = true;
+
+ sb.append("estimatedSize:");
+ sb.append(this.estimatedSize);
+ first = false;
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ }
+
+ 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_bit_vector = new BitSet(1);
+ 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 MapFileInfoStandardSchemeFactory implements SchemeFactory {
+ public MapFileInfoStandardScheme getScheme() {
+ return new MapFileInfoStandardScheme();
+ }
+ }
+
+ private static class MapFileInfoStandardScheme extends StandardScheme<MapFileInfo> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, MapFileInfo 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: // ESTIMATED_SIZE
+ if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+ struct.estimatedSize = iprot.readI64();
+ struct.setEstimatedSizeIsSet(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, MapFileInfo struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ oprot.writeFieldBegin(ESTIMATED_SIZE_FIELD_DESC);
+ oprot.writeI64(struct.estimatedSize);
+ oprot.writeFieldEnd();
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class MapFileInfoTupleSchemeFactory implements SchemeFactory {
+ public MapFileInfoTupleScheme getScheme() {
+ return new MapFileInfoTupleScheme();
+ }
+ }
+
+ private static class MapFileInfoTupleScheme extends TupleScheme<MapFileInfo> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, MapFileInfo struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.isSetEstimatedSize()) {
+ optionals.set(0);
+ }
+ oprot.writeBitSet(optionals, 1);
+ if (struct.isSetEstimatedSize()) {
+ oprot.writeI64(struct.estimatedSize);
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, MapFileInfo struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(1);
+ if (incoming.get(0)) {
+ struct.estimatedSize = iprot.readI64();
+ struct.setEstimatedSizeIsSet(true);
+ }
+ }
+ }
+
+}
+
http://git-wip-us.apache.org/repos/asf/accumulo/blob/7bdbfccb/1.5/core/src/main/java/org/apache/accumulo/core/data/thrift/MultiScanResult.java
----------------------------------------------------------------------
diff --git a/1.5/core/src/main/java/org/apache/accumulo/core/data/thrift/MultiScanResult.java b/1.5/core/src/main/java/org/apache/accumulo/core/data/thrift/MultiScanResult.java
new file mode 100644
index 0000000..3891635
--- /dev/null
+++ b/1.5/core/src/main/java/org/apache/accumulo/core/data/thrift/MultiScanResult.java
@@ -0,0 +1,1172 @@
+/**
+ * Autogenerated by Thrift Compiler (0.8.0)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package org.apache.accumulo.core.data.thrift;
+
+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.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;
+
+@SuppressWarnings("all") public class MultiScanResult implements org.apache.thrift.TBase<MultiScanResult, MultiScanResult._Fields>, java.io.Serializable, Cloneable {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("MultiScanResult");
+
+ private static final org.apache.thrift.protocol.TField RESULTS_FIELD_DESC = new org.apache.thrift.protocol.TField("results", org.apache.thrift.protocol.TType.LIST, (short)1);
+ private static final org.apache.thrift.protocol.TField FAILURES_FIELD_DESC = new org.apache.thrift.protocol.TField("failures", org.apache.thrift.protocol.TType.MAP, (short)2);
+ private static final org.apache.thrift.protocol.TField FULL_SCANS_FIELD_DESC = new org.apache.thrift.protocol.TField("fullScans", org.apache.thrift.protocol.TType.LIST, (short)3);
+ private static final org.apache.thrift.protocol.TField PART_SCAN_FIELD_DESC = new org.apache.thrift.protocol.TField("partScan", org.apache.thrift.protocol.TType.STRUCT, (short)4);
+ private static final org.apache.thrift.protocol.TField PART_NEXT_KEY_FIELD_DESC = new org.apache.thrift.protocol.TField("partNextKey", org.apache.thrift.protocol.TType.STRUCT, (short)5);
+ private static final org.apache.thrift.protocol.TField PART_NEXT_KEY_INCLUSIVE_FIELD_DESC = new org.apache.thrift.protocol.TField("partNextKeyInclusive", org.apache.thrift.protocol.TType.BOOL, (short)6);
+ private static final org.apache.thrift.protocol.TField MORE_FIELD_DESC = new org.apache.thrift.protocol.TField("more", org.apache.thrift.protocol.TType.BOOL, (short)7);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new MultiScanResultStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new MultiScanResultTupleSchemeFactory());
+ }
+
+ public List<TKeyValue> results; // required
+ public Map<TKeyExtent,List<TRange>> failures; // required
+ public List<TKeyExtent> fullScans; // required
+ public TKeyExtent partScan; // required
+ public TKey partNextKey; // required
+ public boolean partNextKeyInclusive; // required
+ public boolean more; // 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 {
+ RESULTS((short)1, "results"),
+ FAILURES((short)2, "failures"),
+ FULL_SCANS((short)3, "fullScans"),
+ PART_SCAN((short)4, "partScan"),
+ PART_NEXT_KEY((short)5, "partNextKey"),
+ PART_NEXT_KEY_INCLUSIVE((short)6, "partNextKeyInclusive"),
+ MORE((short)7, "more");
+
+ 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: // RESULTS
+ return RESULTS;
+ case 2: // FAILURES
+ return FAILURES;
+ case 3: // FULL_SCANS
+ return FULL_SCANS;
+ case 4: // PART_SCAN
+ return PART_SCAN;
+ case 5: // PART_NEXT_KEY
+ return PART_NEXT_KEY;
+ case 6: // PART_NEXT_KEY_INCLUSIVE
+ return PART_NEXT_KEY_INCLUSIVE;
+ case 7: // MORE
+ return MORE;
+ 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 __PARTNEXTKEYINCLUSIVE_ISSET_ID = 0;
+ private static final int __MORE_ISSET_ID = 1;
+ private BitSet __isset_bit_vector = new BitSet(2);
+ 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.RESULTS, new org.apache.thrift.meta_data.FieldMetaData("results", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TKeyValue.class))));
+ tmpMap.put(_Fields.FAILURES, new org.apache.thrift.meta_data.FieldMetaData("failures", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.MAP , "ScanBatch")));
+ tmpMap.put(_Fields.FULL_SCANS, new org.apache.thrift.meta_data.FieldMetaData("fullScans", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TKeyExtent.class))));
+ tmpMap.put(_Fields.PART_SCAN, new org.apache.thrift.meta_data.FieldMetaData("partScan", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TKeyExtent.class)));
+ tmpMap.put(_Fields.PART_NEXT_KEY, new org.apache.thrift.meta_data.FieldMetaData("partNextKey", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TKey.class)));
+ tmpMap.put(_Fields.PART_NEXT_KEY_INCLUSIVE, new org.apache.thrift.meta_data.FieldMetaData("partNextKeyInclusive", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
+ tmpMap.put(_Fields.MORE, new org.apache.thrift.meta_data.FieldMetaData("more", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(MultiScanResult.class, metaDataMap);
+ }
+
+ public MultiScanResult() {
+ }
+
+ public MultiScanResult(
+ List<TKeyValue> results,
+ Map<TKeyExtent,List<TRange>> failures,
+ List<TKeyExtent> fullScans,
+ TKeyExtent partScan,
+ TKey partNextKey,
+ boolean partNextKeyInclusive,
+ boolean more)
+ {
+ this();
+ this.results = results;
+ this.failures = failures;
+ this.fullScans = fullScans;
+ this.partScan = partScan;
+ this.partNextKey = partNextKey;
+ this.partNextKeyInclusive = partNextKeyInclusive;
+ setPartNextKeyInclusiveIsSet(true);
+ this.more = more;
+ setMoreIsSet(true);
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public MultiScanResult(MultiScanResult other) {
+ __isset_bit_vector.clear();
+ __isset_bit_vector.or(other.__isset_bit_vector);
+ if (other.isSetResults()) {
+ List<TKeyValue> __this__results = new ArrayList<TKeyValue>();
+ for (TKeyValue other_element : other.results) {
+ __this__results.add(new TKeyValue(other_element));
+ }
+ this.results = __this__results;
+ }
+ if (other.isSetFailures()) {
+ this.failures = other.failures;
+ }
+ if (other.isSetFullScans()) {
+ List<TKeyExtent> __this__fullScans = new ArrayList<TKeyExtent>();
+ for (TKeyExtent other_element : other.fullScans) {
+ __this__fullScans.add(new TKeyExtent(other_element));
+ }
+ this.fullScans = __this__fullScans;
+ }
+ if (other.isSetPartScan()) {
+ this.partScan = new TKeyExtent(other.partScan);
+ }
+ if (other.isSetPartNextKey()) {
+ this.partNextKey = new TKey(other.partNextKey);
+ }
+ this.partNextKeyInclusive = other.partNextKeyInclusive;
+ this.more = other.more;
+ }
+
+ public MultiScanResult deepCopy() {
+ return new MultiScanResult(this);
+ }
+
+ @Override
+ public void clear() {
+ this.results = null;
+ this.failures = null;
+ this.fullScans = null;
+ this.partScan = null;
+ this.partNextKey = null;
+ setPartNextKeyInclusiveIsSet(false);
+ this.partNextKeyInclusive = false;
+ setMoreIsSet(false);
+ this.more = false;
+ }
+
+ public int getResultsSize() {
+ return (this.results == null) ? 0 : this.results.size();
+ }
+
+ public java.util.Iterator<TKeyValue> getResultsIterator() {
+ return (this.results == null) ? null : this.results.iterator();
+ }
+
+ public void addToResults(TKeyValue elem) {
+ if (this.results == null) {
+ this.results = new ArrayList<TKeyValue>();
+ }
+ this.results.add(elem);
+ }
+
+ public List<TKeyValue> getResults() {
+ return this.results;
+ }
+
+ public MultiScanResult setResults(List<TKeyValue> results) {
+ this.results = results;
+ return this;
+ }
+
+ public void unsetResults() {
+ this.results = null;
+ }
+
+ /** Returns true if field results is set (has been assigned a value) and false otherwise */
+ public boolean isSetResults() {
+ return this.results != null;
+ }
+
+ public void setResultsIsSet(boolean value) {
+ if (!value) {
+ this.results = null;
+ }
+ }
+
+ public int getFailuresSize() {
+ return (this.failures == null) ? 0 : this.failures.size();
+ }
+
+ public void putToFailures(TKeyExtent key, List<TRange> val) {
+ if (this.failures == null) {
+ this.failures = new HashMap<TKeyExtent,List<TRange>>();
+ }
+ this.failures.put(key, val);
+ }
+
+ public Map<TKeyExtent,List<TRange>> getFailures() {
+ return this.failures;
+ }
+
+ public MultiScanResult setFailures(Map<TKeyExtent,List<TRange>> failures) {
+ this.failures = failures;
+ return this;
+ }
+
+ public void unsetFailures() {
+ this.failures = null;
+ }
+
+ /** Returns true if field failures is set (has been assigned a value) and false otherwise */
+ public boolean isSetFailures() {
+ return this.failures != null;
+ }
+
+ public void setFailuresIsSet(boolean value) {
+ if (!value) {
+ this.failures = null;
+ }
+ }
+
+ public int getFullScansSize() {
+ return (this.fullScans == null) ? 0 : this.fullScans.size();
+ }
+
+ public java.util.Iterator<TKeyExtent> getFullScansIterator() {
+ return (this.fullScans == null) ? null : this.fullScans.iterator();
+ }
+
+ public void addToFullScans(TKeyExtent elem) {
+ if (this.fullScans == null) {
+ this.fullScans = new ArrayList<TKeyExtent>();
+ }
+ this.fullScans.add(elem);
+ }
+
+ public List<TKeyExtent> getFullScans() {
+ return this.fullScans;
+ }
+
+ public MultiScanResult setFullScans(List<TKeyExtent> fullScans) {
+ this.fullScans = fullScans;
+ return this;
+ }
+
+ public void unsetFullScans() {
+ this.fullScans = null;
+ }
+
+ /** Returns true if field fullScans is set (has been assigned a value) and false otherwise */
+ public boolean isSetFullScans() {
+ return this.fullScans != null;
+ }
+
+ public void setFullScansIsSet(boolean value) {
+ if (!value) {
+ this.fullScans = null;
+ }
+ }
+
+ public TKeyExtent getPartScan() {
+ return this.partScan;
+ }
+
+ public MultiScanResult setPartScan(TKeyExtent partScan) {
+ this.partScan = partScan;
+ return this;
+ }
+
+ public void unsetPartScan() {
+ this.partScan = null;
+ }
+
+ /** Returns true if field partScan is set (has been assigned a value) and false otherwise */
+ public boolean isSetPartScan() {
+ return this.partScan != null;
+ }
+
+ public void setPartScanIsSet(boolean value) {
+ if (!value) {
+ this.partScan = null;
+ }
+ }
+
+ public TKey getPartNextKey() {
+ return this.partNextKey;
+ }
+
+ public MultiScanResult setPartNextKey(TKey partNextKey) {
+ this.partNextKey = partNextKey;
+ return this;
+ }
+
+ public void unsetPartNextKey() {
+ this.partNextKey = null;
+ }
+
+ /** Returns true if field partNextKey is set (has been assigned a value) and false otherwise */
+ public boolean isSetPartNextKey() {
+ return this.partNextKey != null;
+ }
+
+ public void setPartNextKeyIsSet(boolean value) {
+ if (!value) {
+ this.partNextKey = null;
+ }
+ }
+
+ public boolean isPartNextKeyInclusive() {
+ return this.partNextKeyInclusive;
+ }
+
+ public MultiScanResult setPartNextKeyInclusive(boolean partNextKeyInclusive) {
+ this.partNextKeyInclusive = partNextKeyInclusive;
+ setPartNextKeyInclusiveIsSet(true);
+ return this;
+ }
+
+ public void unsetPartNextKeyInclusive() {
+ __isset_bit_vector.clear(__PARTNEXTKEYINCLUSIVE_ISSET_ID);
+ }
+
+ /** Returns true if field partNextKeyInclusive is set (has been assigned a value) and false otherwise */
+ public boolean isSetPartNextKeyInclusive() {
+ return __isset_bit_vector.get(__PARTNEXTKEYINCLUSIVE_ISSET_ID);
+ }
+
+ public void setPartNextKeyInclusiveIsSet(boolean value) {
+ __isset_bit_vector.set(__PARTNEXTKEYINCLUSIVE_ISSET_ID, value);
+ }
+
+ public boolean isMore() {
+ return this.more;
+ }
+
+ public MultiScanResult setMore(boolean more) {
+ this.more = more;
+ setMoreIsSet(true);
+ return this;
+ }
+
+ public void unsetMore() {
+ __isset_bit_vector.clear(__MORE_ISSET_ID);
+ }
+
+ /** Returns true if field more is set (has been assigned a value) and false otherwise */
+ public boolean isSetMore() {
+ return __isset_bit_vector.get(__MORE_ISSET_ID);
+ }
+
+ public void setMoreIsSet(boolean value) {
+ __isset_bit_vector.set(__MORE_ISSET_ID, value);
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case RESULTS:
+ if (value == null) {
+ unsetResults();
+ } else {
+ setResults((List<TKeyValue>)value);
+ }
+ break;
+
+ case FAILURES:
+ if (value == null) {
+ unsetFailures();
+ } else {
+ setFailures((Map<TKeyExtent,List<TRange>>)value);
+ }
+ break;
+
+ case FULL_SCANS:
+ if (value == null) {
+ unsetFullScans();
+ } else {
+ setFullScans((List<TKeyExtent>)value);
+ }
+ break;
+
+ case PART_SCAN:
+ if (value == null) {
+ unsetPartScan();
+ } else {
+ setPartScan((TKeyExtent)value);
+ }
+ break;
+
+ case PART_NEXT_KEY:
+ if (value == null) {
+ unsetPartNextKey();
+ } else {
+ setPartNextKey((TKey)value);
+ }
+ break;
+
+ case PART_NEXT_KEY_INCLUSIVE:
+ if (value == null) {
+ unsetPartNextKeyInclusive();
+ } else {
+ setPartNextKeyInclusive((Boolean)value);
+ }
+ break;
+
+ case MORE:
+ if (value == null) {
+ unsetMore();
+ } else {
+ setMore((Boolean)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case RESULTS:
+ return getResults();
+
+ case FAILURES:
+ return getFailures();
+
+ case FULL_SCANS:
+ return getFullScans();
+
+ case PART_SCAN:
+ return getPartScan();
+
+ case PART_NEXT_KEY:
+ return getPartNextKey();
+
+ case PART_NEXT_KEY_INCLUSIVE:
+ return Boolean.valueOf(isPartNextKeyInclusive());
+
+ case MORE:
+ return Boolean.valueOf(isMore());
+
+ }
+ 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 RESULTS:
+ return isSetResults();
+ case FAILURES:
+ return isSetFailures();
+ case FULL_SCANS:
+ return isSetFullScans();
+ case PART_SCAN:
+ return isSetPartScan();
+ case PART_NEXT_KEY:
+ return isSetPartNextKey();
+ case PART_NEXT_KEY_INCLUSIVE:
+ return isSetPartNextKeyInclusive();
+ case MORE:
+ return isSetMore();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof MultiScanResult)
+ return this.equals((MultiScanResult)that);
+ return false;
+ }
+
+ public boolean equals(MultiScanResult that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_results = true && this.isSetResults();
+ boolean that_present_results = true && that.isSetResults();
+ if (this_present_results || that_present_results) {
+ if (!(this_present_results && that_present_results))
+ return false;
+ if (!this.results.equals(that.results))
+ return false;
+ }
+
+ boolean this_present_failures = true && this.isSetFailures();
+ boolean that_present_failures = true && that.isSetFailures();
+ if (this_present_failures || that_present_failures) {
+ if (!(this_present_failures && that_present_failures))
+ return false;
+ if (!this.failures.equals(that.failures))
+ return false;
+ }
+
+ boolean this_present_fullScans = true && this.isSetFullScans();
+ boolean that_present_fullScans = true && that.isSetFullScans();
+ if (this_present_fullScans || that_present_fullScans) {
+ if (!(this_present_fullScans && that_present_fullScans))
+ return false;
+ if (!this.fullScans.equals(that.fullScans))
+ return false;
+ }
+
+ boolean this_present_partScan = true && this.isSetPartScan();
+ boolean that_present_partScan = true && that.isSetPartScan();
+ if (this_present_partScan || that_present_partScan) {
+ if (!(this_present_partScan && that_present_partScan))
+ return false;
+ if (!this.partScan.equals(that.partScan))
+ return false;
+ }
+
+ boolean this_present_partNextKey = true && this.isSetPartNextKey();
+ boolean that_present_partNextKey = true && that.isSetPartNextKey();
+ if (this_present_partNextKey || that_present_partNextKey) {
+ if (!(this_present_partNextKey && that_present_partNextKey))
+ return false;
+ if (!this.partNextKey.equals(that.partNextKey))
+ return false;
+ }
+
+ boolean this_present_partNextKeyInclusive = true;
+ boolean that_present_partNextKeyInclusive = true;
+ if (this_present_partNextKeyInclusive || that_present_partNextKeyInclusive) {
+ if (!(this_present_partNextKeyInclusive && that_present_partNextKeyInclusive))
+ return false;
+ if (this.partNextKeyInclusive != that.partNextKeyInclusive)
+ return false;
+ }
+
+ boolean this_present_more = true;
+ boolean that_present_more = true;
+ if (this_present_more || that_present_more) {
+ if (!(this_present_more && that_present_more))
+ return false;
+ if (this.more != that.more)
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ return 0;
+ }
+
+ public int compareTo(MultiScanResult other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+ MultiScanResult typedOther = (MultiScanResult)other;
+
+ lastComparison = Boolean.valueOf(isSetResults()).compareTo(typedOther.isSetResults());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetResults()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.results, typedOther.results);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetFailures()).compareTo(typedOther.isSetFailures());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetFailures()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.failures, typedOther.failures);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetFullScans()).compareTo(typedOther.isSetFullScans());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetFullScans()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.fullScans, typedOther.fullScans);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetPartScan()).compareTo(typedOther.isSetPartScan());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetPartScan()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.partScan, typedOther.partScan);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetPartNextKey()).compareTo(typedOther.isSetPartNextKey());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetPartNextKey()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.partNextKey, typedOther.partNextKey);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetPartNextKeyInclusive()).compareTo(typedOther.isSetPartNextKeyInclusive());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetPartNextKeyInclusive()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.partNextKeyInclusive, typedOther.partNextKeyInclusive);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetMore()).compareTo(typedOther.isSetMore());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetMore()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.more, typedOther.more);
+ 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("MultiScanResult(");
+ boolean first = true;
+
+ sb.append("results:");
+ if (this.results == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.results);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("failures:");
+ if (this.failures == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.failures);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("fullScans:");
+ if (this.fullScans == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.fullScans);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("partScan:");
+ if (this.partScan == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.partScan);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("partNextKey:");
+ if (this.partNextKey == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.partNextKey);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("partNextKeyInclusive:");
+ sb.append(this.partNextKeyInclusive);
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("more:");
+ sb.append(this.more);
+ first = false;
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ }
+
+ 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_bit_vector = new BitSet(1);
+ 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 MultiScanResultStandardSchemeFactory implements SchemeFactory {
+ public MultiScanResultStandardScheme getScheme() {
+ return new MultiScanResultStandardScheme();
+ }
+ }
+
+ private static class MultiScanResultStandardScheme extends StandardScheme<MultiScanResult> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, MultiScanResult 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: // RESULTS
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list16 = iprot.readListBegin();
+ struct.results = new ArrayList<TKeyValue>(_list16.size);
+ for (int _i17 = 0; _i17 < _list16.size; ++_i17)
+ {
+ TKeyValue _elem18; // required
+ _elem18 = new TKeyValue();
+ _elem18.read(iprot);
+ struct.results.add(_elem18);
+ }
+ iprot.readListEnd();
+ }
+ struct.setResultsIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // FAILURES
+ if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
+ {
+ org.apache.thrift.protocol.TMap _map19 = iprot.readMapBegin();
+ struct.failures = new HashMap<TKeyExtent,List<TRange>>(2*_map19.size);
+ for (int _i20 = 0; _i20 < _map19.size; ++_i20)
+ {
+ TKeyExtent _key21; // required
+ List<TRange> _val22; // required
+ _key21 = new TKeyExtent();
+ _key21.read(iprot);
+ {
+ org.apache.thrift.protocol.TList _list23 = iprot.readListBegin();
+ _val22 = new ArrayList<TRange>(_list23.size);
+ for (int _i24 = 0; _i24 < _list23.size; ++_i24)
+ {
+ TRange _elem25; // required
+ _elem25 = new TRange();
+ _elem25.read(iprot);
+ _val22.add(_elem25);
+ }
+ iprot.readListEnd();
+ }
+ struct.failures.put(_key21, _val22);
+ }
+ iprot.readMapEnd();
+ }
+ struct.setFailuresIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 3: // FULL_SCANS
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list26 = iprot.readListBegin();
+ struct.fullScans = new ArrayList<TKeyExtent>(_list26.size);
+ for (int _i27 = 0; _i27 < _list26.size; ++_i27)
+ {
+ TKeyExtent _elem28; // required
+ _elem28 = new TKeyExtent();
+ _elem28.read(iprot);
+ struct.fullScans.add(_elem28);
+ }
+ iprot.readListEnd();
+ }
+ struct.setFullScansIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 4: // PART_SCAN
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+ struct.partScan = new TKeyExtent();
+ struct.partScan.read(iprot);
+ struct.setPartScanIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 5: // PART_NEXT_KEY
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+ struct.partNextKey = new TKey();
+ struct.partNextKey.read(iprot);
+ struct.setPartNextKeyIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 6: // PART_NEXT_KEY_INCLUSIVE
+ if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
+ struct.partNextKeyInclusive = iprot.readBool();
+ struct.setPartNextKeyInclusiveIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 7: // MORE
+ if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
+ struct.more = iprot.readBool();
+ struct.setMoreIsSet(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, MultiScanResult struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.results != null) {
+ oprot.writeFieldBegin(RESULTS_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.results.size()));
+ for (TKeyValue _iter29 : struct.results)
+ {
+ _iter29.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ if (struct.failures != null) {
+ oprot.writeFieldBegin(FAILURES_FIELD_DESC);
+ {
+ oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.LIST, struct.failures.size()));
+ for (Map.Entry<TKeyExtent, List<TRange>> _iter30 : struct.failures.entrySet())
+ {
+ _iter30.getKey().write(oprot);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, _iter30.getValue().size()));
+ for (TRange _iter31 : _iter30.getValue())
+ {
+ _iter31.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
+ }
+ oprot.writeMapEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ if (struct.fullScans != null) {
+ oprot.writeFieldBegin(FULL_SCANS_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.fullScans.size()));
+ for (TKeyExtent _iter32 : struct.fullScans)
+ {
+ _iter32.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ if (struct.partScan != null) {
+ oprot.writeFieldBegin(PART_SCAN_FIELD_DESC);
+ struct.partScan.write(oprot);
+ oprot.writeFieldEnd();
+ }
+ if (struct.partNextKey != null) {
+ oprot.writeFieldBegin(PART_NEXT_KEY_FIELD_DESC);
+ struct.partNextKey.write(oprot);
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldBegin(PART_NEXT_KEY_INCLUSIVE_FIELD_DESC);
+ oprot.writeBool(struct.partNextKeyInclusive);
+ oprot.writeFieldEnd();
+ oprot.writeFieldBegin(MORE_FIELD_DESC);
+ oprot.writeBool(struct.more);
+ oprot.writeFieldEnd();
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class MultiScanResultTupleSchemeFactory implements SchemeFactory {
+ public MultiScanResultTupleScheme getScheme() {
+ return new MultiScanResultTupleScheme();
+ }
+ }
+
+ private static class MultiScanResultTupleScheme extends TupleScheme<MultiScanResult> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, MultiScanResult struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.isSetResults()) {
+ optionals.set(0);
+ }
+ if (struct.isSetFailures()) {
+ optionals.set(1);
+ }
+ if (struct.isSetFullScans()) {
+ optionals.set(2);
+ }
+ if (struct.isSetPartScan()) {
+ optionals.set(3);
+ }
+ if (struct.isSetPartNextKey()) {
+ optionals.set(4);
+ }
+ if (struct.isSetPartNextKeyInclusive()) {
+ optionals.set(5);
+ }
+ if (struct.isSetMore()) {
+ optionals.set(6);
+ }
+ oprot.writeBitSet(optionals, 7);
+ if (struct.isSetResults()) {
+ {
+ oprot.writeI32(struct.results.size());
+ for (TKeyValue _iter33 : struct.results)
+ {
+ _iter33.write(oprot);
+ }
+ }
+ }
+ if (struct.isSetFailures()) {
+ {
+ oprot.writeI32(struct.failures.size());
+ for (Map.Entry<TKeyExtent, List<TRange>> _iter34 : struct.failures.entrySet())
+ {
+ _iter34.getKey().write(oprot);
+ {
+ oprot.writeI32(_iter34.getValue().size());
+ for (TRange _iter35 : _iter34.getValue())
+ {
+ _iter35.write(oprot);
+ }
+ }
+ }
+ }
+ }
+ if (struct.isSetFullScans()) {
+ {
+ oprot.writeI32(struct.fullScans.size());
+ for (TKeyExtent _iter36 : struct.fullScans)
+ {
+ _iter36.write(oprot);
+ }
+ }
+ }
+ if (struct.isSetPartScan()) {
+ struct.partScan.write(oprot);
+ }
+ if (struct.isSetPartNextKey()) {
+ struct.partNextKey.write(oprot);
+ }
+ if (struct.isSetPartNextKeyInclusive()) {
+ oprot.writeBool(struct.partNextKeyInclusive);
+ }
+ if (struct.isSetMore()) {
+ oprot.writeBool(struct.more);
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, MultiScanResult struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(7);
+ if (incoming.get(0)) {
+ {
+ org.apache.thrift.protocol.TList _list37 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.results = new ArrayList<TKeyValue>(_list37.size);
+ for (int _i38 = 0; _i38 < _list37.size; ++_i38)
+ {
+ TKeyValue _elem39; // required
+ _elem39 = new TKeyValue();
+ _elem39.read(iprot);
+ struct.results.add(_elem39);
+ }
+ }
+ struct.setResultsIsSet(true);
+ }
+ if (incoming.get(1)) {
+ {
+ org.apache.thrift.protocol.TMap _map40 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.LIST, iprot.readI32());
+ struct.failures = new HashMap<TKeyExtent,List<TRange>>(2*_map40.size);
+ for (int _i41 = 0; _i41 < _map40.size; ++_i41)
+ {
+ TKeyExtent _key42; // required
+ List<TRange> _val43; // required
+ _key42 = new TKeyExtent();
+ _key42.read(iprot);
+ {
+ org.apache.thrift.protocol.TList _list44 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ _val43 = new ArrayList<TRange>(_list44.size);
+ for (int _i45 = 0; _i45 < _list44.size; ++_i45)
+ {
+ TRange _elem46; // required
+ _elem46 = new TRange();
+ _elem46.read(iprot);
+ _val43.add(_elem46);
+ }
+ }
+ struct.failures.put(_key42, _val43);
+ }
+ }
+ struct.setFailuresIsSet(true);
+ }
+ if (incoming.get(2)) {
+ {
+ org.apache.thrift.protocol.TList _list47 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.fullScans = new ArrayList<TKeyExtent>(_list47.size);
+ for (int _i48 = 0; _i48 < _list47.size; ++_i48)
+ {
+ TKeyExtent _elem49; // required
+ _elem49 = new TKeyExtent();
+ _elem49.read(iprot);
+ struct.fullScans.add(_elem49);
+ }
+ }
+ struct.setFullScansIsSet(true);
+ }
+ if (incoming.get(3)) {
+ struct.partScan = new TKeyExtent();
+ struct.partScan.read(iprot);
+ struct.setPartScanIsSet(true);
+ }
+ if (incoming.get(4)) {
+ struct.partNextKey = new TKey();
+ struct.partNextKey.read(iprot);
+ struct.setPartNextKeyIsSet(true);
+ }
+ if (incoming.get(5)) {
+ struct.partNextKeyInclusive = iprot.readBool();
+ struct.setPartNextKeyInclusiveIsSet(true);
+ }
+ if (incoming.get(6)) {
+ struct.more = iprot.readBool();
+ struct.setMoreIsSet(true);
+ }
+ }
+ }
+
+}
+
http://git-wip-us.apache.org/repos/asf/accumulo/blob/7bdbfccb/1.5/core/src/main/java/org/apache/accumulo/core/data/thrift/ScanResult.java
----------------------------------------------------------------------
diff --git a/1.5/core/src/main/java/org/apache/accumulo/core/data/thrift/ScanResult.java b/1.5/core/src/main/java/org/apache/accumulo/core/data/thrift/ScanResult.java
new file mode 100644
index 0000000..b846a30
--- /dev/null
+++ b/1.5/core/src/main/java/org/apache/accumulo/core/data/thrift/ScanResult.java
@@ -0,0 +1,535 @@
+/**
+ * Autogenerated by Thrift Compiler (0.8.0)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package org.apache.accumulo.core.data.thrift;
+
+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.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;
+
+@SuppressWarnings("all") public class ScanResult implements org.apache.thrift.TBase<ScanResult, ScanResult._Fields>, java.io.Serializable, Cloneable {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ScanResult");
+
+ private static final org.apache.thrift.protocol.TField RESULTS_FIELD_DESC = new org.apache.thrift.protocol.TField("results", org.apache.thrift.protocol.TType.LIST, (short)1);
+ private static final org.apache.thrift.protocol.TField MORE_FIELD_DESC = new org.apache.thrift.protocol.TField("more", org.apache.thrift.protocol.TType.BOOL, (short)2);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new ScanResultStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new ScanResultTupleSchemeFactory());
+ }
+
+ public List<TKeyValue> results; // required
+ public boolean more; // 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 {
+ RESULTS((short)1, "results"),
+ MORE((short)2, "more");
+
+ 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: // RESULTS
+ return RESULTS;
+ case 2: // MORE
+ return MORE;
+ 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 __MORE_ISSET_ID = 0;
+ private BitSet __isset_bit_vector = new BitSet(1);
+ 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.RESULTS, new org.apache.thrift.meta_data.FieldMetaData("results", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TKeyValue.class))));
+ tmpMap.put(_Fields.MORE, new org.apache.thrift.meta_data.FieldMetaData("more", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ScanResult.class, metaDataMap);
+ }
+
+ public ScanResult() {
+ }
+
+ public ScanResult(
+ List<TKeyValue> results,
+ boolean more)
+ {
+ this();
+ this.results = results;
+ this.more = more;
+ setMoreIsSet(true);
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public ScanResult(ScanResult other) {
+ __isset_bit_vector.clear();
+ __isset_bit_vector.or(other.__isset_bit_vector);
+ if (other.isSetResults()) {
+ List<TKeyValue> __this__results = new ArrayList<TKeyValue>();
+ for (TKeyValue other_element : other.results) {
+ __this__results.add(new TKeyValue(other_element));
+ }
+ this.results = __this__results;
+ }
+ this.more = other.more;
+ }
+
+ public ScanResult deepCopy() {
+ return new ScanResult(this);
+ }
+
+ @Override
+ public void clear() {
+ this.results = null;
+ setMoreIsSet(false);
+ this.more = false;
+ }
+
+ public int getResultsSize() {
+ return (this.results == null) ? 0 : this.results.size();
+ }
+
+ public java.util.Iterator<TKeyValue> getResultsIterator() {
+ return (this.results == null) ? null : this.results.iterator();
+ }
+
+ public void addToResults(TKeyValue elem) {
+ if (this.results == null) {
+ this.results = new ArrayList<TKeyValue>();
+ }
+ this.results.add(elem);
+ }
+
+ public List<TKeyValue> getResults() {
+ return this.results;
+ }
+
+ public ScanResult setResults(List<TKeyValue> results) {
+ this.results = results;
+ return this;
+ }
+
+ public void unsetResults() {
+ this.results = null;
+ }
+
+ /** Returns true if field results is set (has been assigned a value) and false otherwise */
+ public boolean isSetResults() {
+ return this.results != null;
+ }
+
+ public void setResultsIsSet(boolean value) {
+ if (!value) {
+ this.results = null;
+ }
+ }
+
+ public boolean isMore() {
+ return this.more;
+ }
+
+ public ScanResult setMore(boolean more) {
+ this.more = more;
+ setMoreIsSet(true);
+ return this;
+ }
+
+ public void unsetMore() {
+ __isset_bit_vector.clear(__MORE_ISSET_ID);
+ }
+
+ /** Returns true if field more is set (has been assigned a value) and false otherwise */
+ public boolean isSetMore() {
+ return __isset_bit_vector.get(__MORE_ISSET_ID);
+ }
+
+ public void setMoreIsSet(boolean value) {
+ __isset_bit_vector.set(__MORE_ISSET_ID, value);
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case RESULTS:
+ if (value == null) {
+ unsetResults();
+ } else {
+ setResults((List<TKeyValue>)value);
+ }
+ break;
+
+ case MORE:
+ if (value == null) {
+ unsetMore();
+ } else {
+ setMore((Boolean)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case RESULTS:
+ return getResults();
+
+ case MORE:
+ return Boolean.valueOf(isMore());
+
+ }
+ 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 RESULTS:
+ return isSetResults();
+ case MORE:
+ return isSetMore();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof ScanResult)
+ return this.equals((ScanResult)that);
+ return false;
+ }
+
+ public boolean equals(ScanResult that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_results = true && this.isSetResults();
+ boolean that_present_results = true && that.isSetResults();
+ if (this_present_results || that_present_results) {
+ if (!(this_present_results && that_present_results))
+ return false;
+ if (!this.results.equals(that.results))
+ return false;
+ }
+
+ boolean this_present_more = true;
+ boolean that_present_more = true;
+ if (this_present_more || that_present_more) {
+ if (!(this_present_more && that_present_more))
+ return false;
+ if (this.more != that.more)
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ return 0;
+ }
+
+ public int compareTo(ScanResult other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+ ScanResult typedOther = (ScanResult)other;
+
+ lastComparison = Boolean.valueOf(isSetResults()).compareTo(typedOther.isSetResults());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetResults()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.results, typedOther.results);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetMore()).compareTo(typedOther.isSetMore());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetMore()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.more, typedOther.more);
+ 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("ScanResult(");
+ boolean first = true;
+
+ sb.append("results:");
+ if (this.results == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.results);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("more:");
+ sb.append(this.more);
+ first = false;
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ }
+
+ 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_bit_vector = new BitSet(1);
+ 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 ScanResultStandardSchemeFactory implements SchemeFactory {
+ public ScanResultStandardScheme getScheme() {
+ return new ScanResultStandardScheme();
+ }
+ }
+
+ private static class ScanResultStandardScheme extends StandardScheme<ScanResult> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, ScanResult 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: // RESULTS
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list8 = iprot.readListBegin();
+ struct.results = new ArrayList<TKeyValue>(_list8.size);
+ for (int _i9 = 0; _i9 < _list8.size; ++_i9)
+ {
+ TKeyValue _elem10; // required
+ _elem10 = new TKeyValue();
+ _elem10.read(iprot);
+ struct.results.add(_elem10);
+ }
+ iprot.readListEnd();
+ }
+ struct.setResultsIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // MORE
+ if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
+ struct.more = iprot.readBool();
+ struct.setMoreIsSet(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, ScanResult struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.results != null) {
+ oprot.writeFieldBegin(RESULTS_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.results.size()));
+ for (TKeyValue _iter11 : struct.results)
+ {
+ _iter11.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldBegin(MORE_FIELD_DESC);
+ oprot.writeBool(struct.more);
+ oprot.writeFieldEnd();
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class ScanResultTupleSchemeFactory implements SchemeFactory {
+ public ScanResultTupleScheme getScheme() {
+ return new ScanResultTupleScheme();
+ }
+ }
+
+ private static class ScanResultTupleScheme extends TupleScheme<ScanResult> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, ScanResult struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.isSetResults()) {
+ optionals.set(0);
+ }
+ if (struct.isSetMore()) {
+ optionals.set(1);
+ }
+ oprot.writeBitSet(optionals, 2);
+ if (struct.isSetResults()) {
+ {
+ oprot.writeI32(struct.results.size());
+ for (TKeyValue _iter12 : struct.results)
+ {
+ _iter12.write(oprot);
+ }
+ }
+ }
+ if (struct.isSetMore()) {
+ oprot.writeBool(struct.more);
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, ScanResult struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(2);
+ if (incoming.get(0)) {
+ {
+ org.apache.thrift.protocol.TList _list13 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.results = new ArrayList<TKeyValue>(_list13.size);
+ for (int _i14 = 0; _i14 < _list13.size; ++_i14)
+ {
+ TKeyValue _elem15; // required
+ _elem15 = new TKeyValue();
+ _elem15.read(iprot);
+ struct.results.add(_elem15);
+ }
+ }
+ struct.setResultsIsSet(true);
+ }
+ if (incoming.get(1)) {
+ struct.more = iprot.readBool();
+ struct.setMoreIsSet(true);
+ }
+ }
+ }
+
+}
+