Propchange:
accumulo/branches/1.4/src/proxy/src/main/java/org/apache/accumulo/proxy/thrift/AccumuloProxy.java
------------------------------------------------------------------------------
svn:eol-style = native
Added:
accumulo/branches/1.4/src/proxy/src/main/java/org/apache/accumulo/proxy/thrift/AccumuloSecurityException.java
URL:
http://svn.apache.org/viewvc/accumulo/branches/1.4/src/proxy/src/main/java/org/apache/accumulo/proxy/thrift/AccumuloSecurityException.java?rev=1467287&view=auto
==============================================================================
---
accumulo/branches/1.4/src/proxy/src/main/java/org/apache/accumulo/proxy/thrift/AccumuloSecurityException.java
(added)
+++
accumulo/branches/1.4/src/proxy/src/main/java/org/apache/accumulo/proxy/thrift/AccumuloSecurityException.java
Fri Apr 12 14:37:09 2013
@@ -0,0 +1,335 @@
+/*
+ * 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.
+ */
+/**
+ * Autogenerated by Thrift
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ */
+package org.apache.accumulo.proxy.thrift;
+
+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 AccumuloSecurityException extends
Exception implements org.apache.thrift.TBase<AccumuloSecurityException,
AccumuloSecurityException._Fields>, java.io.Serializable, Cloneable {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new
org.apache.thrift.protocol.TStruct("AccumuloSecurityException");
+
+ private static final org.apache.thrift.protocol.TField MSG_FIELD_DESC = new
org.apache.thrift.protocol.TField("msg",
org.apache.thrift.protocol.TType.STRING, (short)1);
+
+ public String msg;
+
+ /** The set of fields this struct contains, along with convenience methods
for finding and manipulating them. */
+ @SuppressWarnings("all") public enum _Fields implements
org.apache.thrift.TFieldIdEnum {
+ MSG((short)1, "msg");
+
+ 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: // MSG
+ return MSG;
+ default:
+ return null;
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, throwing an exception
+ * if it is not found.
+ */
+ public static _Fields findByThriftIdOrThrow(int fieldId) {
+ _Fields fields = findByThriftId(fieldId);
+ if (fields == null) throw new IllegalArgumentException("Field " +
fieldId + " doesn't exist!");
+ return fields;
+ }
+
+ /**
+ * Find the _Fields constant that matches name, or null if its not found.
+ */
+ public static _Fields findByName(String name) {
+ return byName.get(name);
+ }
+
+ private final short _thriftId;
+ private final String _fieldName;
+
+ _Fields(short thriftId, String fieldName) {
+ _thriftId = thriftId;
+ _fieldName = fieldName;
+ }
+
+ public short getThriftFieldId() {
+ return _thriftId;
+ }
+
+ public String getFieldName() {
+ return _fieldName;
+ }
+ }
+
+ // isset id assignments
+
+ public static final Map<_Fields, org.apache.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.MSG, new
org.apache.thrift.meta_data.FieldMetaData("msg",
org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new
org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(AccumuloSecurityException.class,
metaDataMap);
+ }
+
+ public AccumuloSecurityException() {
+ }
+
+ public AccumuloSecurityException(
+ String msg)
+ {
+ this();
+ this.msg = msg;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public AccumuloSecurityException(AccumuloSecurityException other) {
+ if (other.isSetMsg()) {
+ this.msg = other.msg;
+ }
+ }
+
+ public AccumuloSecurityException deepCopy() {
+ return new AccumuloSecurityException(this);
+ }
+
+ @Override
+ public void clear() {
+ this.msg = null;
+ }
+
+ public String getMsg() {
+ return this.msg;
+ }
+
+ public AccumuloSecurityException setMsg(String msg) {
+ this.msg = msg;
+ return this;
+ }
+
+ public void unsetMsg() {
+ this.msg = null;
+ }
+
+ /** Returns true if field msg is set (has been assigned a value) and false
otherwise */
+ public boolean isSetMsg() {
+ return this.msg != null;
+ }
+
+ public void setMsgIsSet(boolean value) {
+ if (!value) {
+ this.msg = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case MSG:
+ if (value == null) {
+ unsetMsg();
+ } else {
+ setMsg((String)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case MSG:
+ return getMsg();
+
+ }
+ 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 MSG:
+ return isSetMsg();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof AccumuloSecurityException)
+ return this.equals((AccumuloSecurityException)that);
+ return false;
+ }
+
+ public boolean equals(AccumuloSecurityException that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_msg = true && this.isSetMsg();
+ boolean that_present_msg = true && that.isSetMsg();
+ if (this_present_msg || that_present_msg) {
+ if (!(this_present_msg && that_present_msg))
+ return false;
+ if (!this.msg.equals(that.msg))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ return 0;
+ }
+
+ public int compareTo(AccumuloSecurityException other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+ AccumuloSecurityException typedOther = (AccumuloSecurityException)other;
+
+ lastComparison =
Boolean.valueOf(isSetMsg()).compareTo(typedOther.isSetMsg());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetMsg()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.msg,
typedOther.msg);
+ 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 {
+ org.apache.thrift.protocol.TField field;
+ iprot.readStructBegin();
+ while (true)
+ {
+ field = iprot.readFieldBegin();
+ if (field.type == org.apache.thrift.protocol.TType.STOP) {
+ break;
+ }
+ switch (field.id) {
+ case 1: // MSG
+ if (field.type == org.apache.thrift.protocol.TType.STRING) {
+ this.msg = iprot.readString();
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ default:
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+ }
+ iprot.readFieldEnd();
+ }
+ iprot.readStructEnd();
+
+ // check for required fields of primitive type, which can't be checked in
the validate method
+ validate();
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot) throws
org.apache.thrift.TException {
+ validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (this.msg != null) {
+ oprot.writeFieldBegin(MSG_FIELD_DESC);
+ oprot.writeString(this.msg);
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder("AccumuloSecurityException(");
+ boolean first = true;
+
+ sb.append("msg:");
+ if (this.msg == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.msg);
+ }
+ 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 {
+ 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);
+ }
+ }
+
+}
+
Propchange:
accumulo/branches/1.4/src/proxy/src/main/java/org/apache/accumulo/proxy/thrift/AccumuloSecurityException.java
------------------------------------------------------------------------------
svn:eol-style = native
Added:
accumulo/branches/1.4/src/proxy/src/main/java/org/apache/accumulo/proxy/thrift/ActiveCompaction.java
URL:
http://svn.apache.org/viewvc/accumulo/branches/1.4/src/proxy/src/main/java/org/apache/accumulo/proxy/thrift/ActiveCompaction.java?rev=1467287&view=auto
==============================================================================
---
accumulo/branches/1.4/src/proxy/src/main/java/org/apache/accumulo/proxy/thrift/ActiveCompaction.java
(added)
+++
accumulo/branches/1.4/src/proxy/src/main/java/org/apache/accumulo/proxy/thrift/ActiveCompaction.java
Fri Apr 12 14:37:09 2013
@@ -0,0 +1,1234 @@
+/*
+ * 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.
+ */
+/**
+ * Autogenerated by Thrift
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ */
+package org.apache.accumulo.proxy.thrift;
+
+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 ActiveCompaction implements
org.apache.thrift.TBase<ActiveCompaction, ActiveCompaction._Fields>,
java.io.Serializable, Cloneable {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new
org.apache.thrift.protocol.TStruct("ActiveCompaction");
+
+ private static final org.apache.thrift.protocol.TField EXTENT_FIELD_DESC =
new org.apache.thrift.protocol.TField("extent",
org.apache.thrift.protocol.TType.STRUCT, (short)1);
+ private static final org.apache.thrift.protocol.TField AGE_FIELD_DESC = new
org.apache.thrift.protocol.TField("age", org.apache.thrift.protocol.TType.I64,
(short)2);
+ private static final org.apache.thrift.protocol.TField
INPUT_FILES_FIELD_DESC = new org.apache.thrift.protocol.TField("inputFiles",
org.apache.thrift.protocol.TType.LIST, (short)3);
+ private static final org.apache.thrift.protocol.TField
OUTPUT_FILE_FIELD_DESC = new org.apache.thrift.protocol.TField("outputFile",
org.apache.thrift.protocol.TType.STRING, (short)4);
+ private static final org.apache.thrift.protocol.TField TYPE_FIELD_DESC = new
org.apache.thrift.protocol.TField("type", org.apache.thrift.protocol.TType.I32,
(short)5);
+ private static final org.apache.thrift.protocol.TField REASON_FIELD_DESC =
new org.apache.thrift.protocol.TField("reason",
org.apache.thrift.protocol.TType.I32, (short)6);
+ private static final org.apache.thrift.protocol.TField
LOCALITY_GROUP_FIELD_DESC = new
org.apache.thrift.protocol.TField("localityGroup",
org.apache.thrift.protocol.TType.STRING, (short)7);
+ private static final org.apache.thrift.protocol.TField
ENTRIES_READ_FIELD_DESC = new org.apache.thrift.protocol.TField("entriesRead",
org.apache.thrift.protocol.TType.I64, (short)8);
+ private static final org.apache.thrift.protocol.TField
ENTRIES_WRITTEN_FIELD_DESC = new
org.apache.thrift.protocol.TField("entriesWritten",
org.apache.thrift.protocol.TType.I64, (short)9);
+ private static final org.apache.thrift.protocol.TField ITERATORS_FIELD_DESC
= new org.apache.thrift.protocol.TField("iterators",
org.apache.thrift.protocol.TType.LIST, (short)10);
+
+ public KeyExtent extent;
+ public long age;
+ public List<String> inputFiles;
+ public String outputFile;
+ /**
+ *
+ * @see CompactionType
+ */
+ public CompactionType type;
+ /**
+ *
+ * @see CompactionReason
+ */
+ public CompactionReason reason;
+ public String localityGroup;
+ public long entriesRead;
+ public long entriesWritten;
+ public List<IteratorSetting> iterators;
+
+ /** The set of fields this struct contains, along with convenience methods
for finding and manipulating them. */
+ @SuppressWarnings("all") public enum _Fields implements
org.apache.thrift.TFieldIdEnum {
+ EXTENT((short)1, "extent"),
+ AGE((short)2, "age"),
+ INPUT_FILES((short)3, "inputFiles"),
+ OUTPUT_FILE((short)4, "outputFile"),
+ /**
+ *
+ * @see CompactionType
+ */
+ TYPE((short)5, "type"),
+ /**
+ *
+ * @see CompactionReason
+ */
+ REASON((short)6, "reason"),
+ LOCALITY_GROUP((short)7, "localityGroup"),
+ ENTRIES_READ((short)8, "entriesRead"),
+ ENTRIES_WRITTEN((short)9, "entriesWritten"),
+ ITERATORS((short)10, "iterators");
+
+ 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: // EXTENT
+ return EXTENT;
+ case 2: // AGE
+ return AGE;
+ case 3: // INPUT_FILES
+ return INPUT_FILES;
+ case 4: // OUTPUT_FILE
+ return OUTPUT_FILE;
+ case 5: // TYPE
+ return TYPE;
+ case 6: // REASON
+ return REASON;
+ case 7: // LOCALITY_GROUP
+ return LOCALITY_GROUP;
+ case 8: // ENTRIES_READ
+ return ENTRIES_READ;
+ case 9: // ENTRIES_WRITTEN
+ return ENTRIES_WRITTEN;
+ case 10: // ITERATORS
+ return ITERATORS;
+ 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 __AGE_ISSET_ID = 0;
+ private static final int __ENTRIESREAD_ISSET_ID = 1;
+ private static final int __ENTRIESWRITTEN_ISSET_ID = 2;
+ private BitSet __isset_bit_vector = new BitSet(3);
+
+ 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.EXTENT, new
org.apache.thrift.meta_data.FieldMetaData("extent",
org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new
org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT,
KeyExtent.class)));
+ tmpMap.put(_Fields.AGE, new
org.apache.thrift.meta_data.FieldMetaData("age",
org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new
org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
+ tmpMap.put(_Fields.INPUT_FILES, new
org.apache.thrift.meta_data.FieldMetaData("inputFiles",
org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new
org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ new
org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))));
+ tmpMap.put(_Fields.OUTPUT_FILE, new
org.apache.thrift.meta_data.FieldMetaData("outputFile",
org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new
org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.TYPE, new
org.apache.thrift.meta_data.FieldMetaData("type",
org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new
org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM,
CompactionType.class)));
+ tmpMap.put(_Fields.REASON, new
org.apache.thrift.meta_data.FieldMetaData("reason",
org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new
org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM,
CompactionReason.class)));
+ tmpMap.put(_Fields.LOCALITY_GROUP, new
org.apache.thrift.meta_data.FieldMetaData("localityGroup",
org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new
org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.ENTRIES_READ, new
org.apache.thrift.meta_data.FieldMetaData("entriesRead",
org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new
org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
+ tmpMap.put(_Fields.ENTRIES_WRITTEN, new
org.apache.thrift.meta_data.FieldMetaData("entriesWritten",
org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new
org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
+ tmpMap.put(_Fields.ITERATORS, new
org.apache.thrift.meta_data.FieldMetaData("iterators",
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,
IteratorSetting.class))));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ActiveCompaction.class,
metaDataMap);
+ }
+
+ public ActiveCompaction() {
+ }
+
+ public ActiveCompaction(
+ KeyExtent extent,
+ long age,
+ List<String> inputFiles,
+ String outputFile,
+ CompactionType type,
+ CompactionReason reason,
+ String localityGroup,
+ long entriesRead,
+ long entriesWritten,
+ List<IteratorSetting> iterators)
+ {
+ this();
+ this.extent = extent;
+ this.age = age;
+ setAgeIsSet(true);
+ this.inputFiles = inputFiles;
+ this.outputFile = outputFile;
+ this.type = type;
+ this.reason = reason;
+ this.localityGroup = localityGroup;
+ this.entriesRead = entriesRead;
+ setEntriesReadIsSet(true);
+ this.entriesWritten = entriesWritten;
+ setEntriesWrittenIsSet(true);
+ this.iterators = iterators;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public ActiveCompaction(ActiveCompaction other) {
+ __isset_bit_vector.clear();
+ __isset_bit_vector.or(other.__isset_bit_vector);
+ if (other.isSetExtent()) {
+ this.extent = new KeyExtent(other.extent);
+ }
+ this.age = other.age;
+ if (other.isSetInputFiles()) {
+ List<String> __this__inputFiles = new ArrayList<String>();
+ for (String other_element : other.inputFiles) {
+ __this__inputFiles.add(other_element);
+ }
+ this.inputFiles = __this__inputFiles;
+ }
+ if (other.isSetOutputFile()) {
+ this.outputFile = other.outputFile;
+ }
+ if (other.isSetType()) {
+ this.type = other.type;
+ }
+ if (other.isSetReason()) {
+ this.reason = other.reason;
+ }
+ if (other.isSetLocalityGroup()) {
+ this.localityGroup = other.localityGroup;
+ }
+ this.entriesRead = other.entriesRead;
+ this.entriesWritten = other.entriesWritten;
+ if (other.isSetIterators()) {
+ List<IteratorSetting> __this__iterators = new
ArrayList<IteratorSetting>();
+ for (IteratorSetting other_element : other.iterators) {
+ __this__iterators.add(new IteratorSetting(other_element));
+ }
+ this.iterators = __this__iterators;
+ }
+ }
+
+ public ActiveCompaction deepCopy() {
+ return new ActiveCompaction(this);
+ }
+
+ @Override
+ public void clear() {
+ this.extent = null;
+ setAgeIsSet(false);
+ this.age = 0;
+ this.inputFiles = null;
+ this.outputFile = null;
+ this.type = null;
+ this.reason = null;
+ this.localityGroup = null;
+ setEntriesReadIsSet(false);
+ this.entriesRead = 0;
+ setEntriesWrittenIsSet(false);
+ this.entriesWritten = 0;
+ this.iterators = null;
+ }
+
+ public KeyExtent getExtent() {
+ return this.extent;
+ }
+
+ public ActiveCompaction setExtent(KeyExtent extent) {
+ this.extent = extent;
+ return this;
+ }
+
+ public void unsetExtent() {
+ this.extent = null;
+ }
+
+ /** Returns true if field extent is set (has been assigned a value) and
false otherwise */
+ public boolean isSetExtent() {
+ return this.extent != null;
+ }
+
+ public void setExtentIsSet(boolean value) {
+ if (!value) {
+ this.extent = null;
+ }
+ }
+
+ public long getAge() {
+ return this.age;
+ }
+
+ public ActiveCompaction setAge(long age) {
+ this.age = age;
+ setAgeIsSet(true);
+ return this;
+ }
+
+ public void unsetAge() {
+ __isset_bit_vector.clear(__AGE_ISSET_ID);
+ }
+
+ /** Returns true if field age is set (has been assigned a value) and false
otherwise */
+ public boolean isSetAge() {
+ return __isset_bit_vector.get(__AGE_ISSET_ID);
+ }
+
+ public void setAgeIsSet(boolean value) {
+ __isset_bit_vector.set(__AGE_ISSET_ID, value);
+ }
+
+ public int getInputFilesSize() {
+ return (this.inputFiles == null) ? 0 : this.inputFiles.size();
+ }
+
+ public java.util.Iterator<String> getInputFilesIterator() {
+ return (this.inputFiles == null) ? null : this.inputFiles.iterator();
+ }
+
+ public void addToInputFiles(String elem) {
+ if (this.inputFiles == null) {
+ this.inputFiles = new ArrayList<String>();
+ }
+ this.inputFiles.add(elem);
+ }
+
+ public List<String> getInputFiles() {
+ return this.inputFiles;
+ }
+
+ public ActiveCompaction setInputFiles(List<String> inputFiles) {
+ this.inputFiles = inputFiles;
+ return this;
+ }
+
+ public void unsetInputFiles() {
+ this.inputFiles = null;
+ }
+
+ /** Returns true if field inputFiles is set (has been assigned a value) and
false otherwise */
+ public boolean isSetInputFiles() {
+ return this.inputFiles != null;
+ }
+
+ public void setInputFilesIsSet(boolean value) {
+ if (!value) {
+ this.inputFiles = null;
+ }
+ }
+
+ public String getOutputFile() {
+ return this.outputFile;
+ }
+
+ public ActiveCompaction setOutputFile(String outputFile) {
+ this.outputFile = outputFile;
+ return this;
+ }
+
+ public void unsetOutputFile() {
+ this.outputFile = null;
+ }
+
+ /** Returns true if field outputFile is set (has been assigned a value) and
false otherwise */
+ public boolean isSetOutputFile() {
+ return this.outputFile != null;
+ }
+
+ public void setOutputFileIsSet(boolean value) {
+ if (!value) {
+ this.outputFile = null;
+ }
+ }
+
+ /**
+ *
+ * @see CompactionType
+ */
+ public CompactionType getType() {
+ return this.type;
+ }
+
+ /**
+ *
+ * @see CompactionType
+ */
+ public ActiveCompaction setType(CompactionType type) {
+ this.type = type;
+ return this;
+ }
+
+ public void unsetType() {
+ this.type = null;
+ }
+
+ /** Returns true if field type is set (has been assigned a value) and false
otherwise */
+ public boolean isSetType() {
+ return this.type != null;
+ }
+
+ public void setTypeIsSet(boolean value) {
+ if (!value) {
+ this.type = null;
+ }
+ }
+
+ /**
+ *
+ * @see CompactionReason
+ */
+ public CompactionReason getReason() {
+ return this.reason;
+ }
+
+ /**
+ *
+ * @see CompactionReason
+ */
+ public ActiveCompaction setReason(CompactionReason reason) {
+ this.reason = reason;
+ return this;
+ }
+
+ public void unsetReason() {
+ this.reason = null;
+ }
+
+ /** Returns true if field reason is set (has been assigned a value) and
false otherwise */
+ public boolean isSetReason() {
+ return this.reason != null;
+ }
+
+ public void setReasonIsSet(boolean value) {
+ if (!value) {
+ this.reason = null;
+ }
+ }
+
+ public String getLocalityGroup() {
+ return this.localityGroup;
+ }
+
+ public ActiveCompaction setLocalityGroup(String localityGroup) {
+ this.localityGroup = localityGroup;
+ return this;
+ }
+
+ public void unsetLocalityGroup() {
+ this.localityGroup = null;
+ }
+
+ /** Returns true if field localityGroup is set (has been assigned a value)
and false otherwise */
+ public boolean isSetLocalityGroup() {
+ return this.localityGroup != null;
+ }
+
+ public void setLocalityGroupIsSet(boolean value) {
+ if (!value) {
+ this.localityGroup = null;
+ }
+ }
+
+ public long getEntriesRead() {
+ return this.entriesRead;
+ }
+
+ public ActiveCompaction setEntriesRead(long entriesRead) {
+ this.entriesRead = entriesRead;
+ setEntriesReadIsSet(true);
+ return this;
+ }
+
+ public void unsetEntriesRead() {
+ __isset_bit_vector.clear(__ENTRIESREAD_ISSET_ID);
+ }
+
+ /** Returns true if field entriesRead is set (has been assigned a value) and
false otherwise */
+ public boolean isSetEntriesRead() {
+ return __isset_bit_vector.get(__ENTRIESREAD_ISSET_ID);
+ }
+
+ public void setEntriesReadIsSet(boolean value) {
+ __isset_bit_vector.set(__ENTRIESREAD_ISSET_ID, value);
+ }
+
+ public long getEntriesWritten() {
+ return this.entriesWritten;
+ }
+
+ public ActiveCompaction setEntriesWritten(long entriesWritten) {
+ this.entriesWritten = entriesWritten;
+ setEntriesWrittenIsSet(true);
+ return this;
+ }
+
+ public void unsetEntriesWritten() {
+ __isset_bit_vector.clear(__ENTRIESWRITTEN_ISSET_ID);
+ }
+
+ /** Returns true if field entriesWritten is set (has been assigned a value)
and false otherwise */
+ public boolean isSetEntriesWritten() {
+ return __isset_bit_vector.get(__ENTRIESWRITTEN_ISSET_ID);
+ }
+
+ public void setEntriesWrittenIsSet(boolean value) {
+ __isset_bit_vector.set(__ENTRIESWRITTEN_ISSET_ID, value);
+ }
+
+ public int getIteratorsSize() {
+ return (this.iterators == null) ? 0 : this.iterators.size();
+ }
+
+ public java.util.Iterator<IteratorSetting> getIteratorsIterator() {
+ return (this.iterators == null) ? null : this.iterators.iterator();
+ }
+
+ public void addToIterators(IteratorSetting elem) {
+ if (this.iterators == null) {
+ this.iterators = new ArrayList<IteratorSetting>();
+ }
+ this.iterators.add(elem);
+ }
+
+ public List<IteratorSetting> getIterators() {
+ return this.iterators;
+ }
+
+ public ActiveCompaction setIterators(List<IteratorSetting> iterators) {
+ this.iterators = iterators;
+ return this;
+ }
+
+ public void unsetIterators() {
+ this.iterators = null;
+ }
+
+ /** Returns true if field iterators is set (has been assigned a value) and
false otherwise */
+ public boolean isSetIterators() {
+ return this.iterators != null;
+ }
+
+ public void setIteratorsIsSet(boolean value) {
+ if (!value) {
+ this.iterators = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case EXTENT:
+ if (value == null) {
+ unsetExtent();
+ } else {
+ setExtent((KeyExtent)value);
+ }
+ break;
+
+ case AGE:
+ if (value == null) {
+ unsetAge();
+ } else {
+ setAge((Long)value);
+ }
+ break;
+
+ case INPUT_FILES:
+ if (value == null) {
+ unsetInputFiles();
+ } else {
+ setInputFiles((List<String>)value);
+ }
+ break;
+
+ case OUTPUT_FILE:
+ if (value == null) {
+ unsetOutputFile();
+ } else {
+ setOutputFile((String)value);
+ }
+ break;
+
+ case TYPE:
+ if (value == null) {
+ unsetType();
+ } else {
+ setType((CompactionType)value);
+ }
+ break;
+
+ case REASON:
+ if (value == null) {
+ unsetReason();
+ } else {
+ setReason((CompactionReason)value);
+ }
+ break;
+
+ case LOCALITY_GROUP:
+ if (value == null) {
+ unsetLocalityGroup();
+ } else {
+ setLocalityGroup((String)value);
+ }
+ break;
+
+ case ENTRIES_READ:
+ if (value == null) {
+ unsetEntriesRead();
+ } else {
+ setEntriesRead((Long)value);
+ }
+ break;
+
+ case ENTRIES_WRITTEN:
+ if (value == null) {
+ unsetEntriesWritten();
+ } else {
+ setEntriesWritten((Long)value);
+ }
+ break;
+
+ case ITERATORS:
+ if (value == null) {
+ unsetIterators();
+ } else {
+ setIterators((List<IteratorSetting>)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case EXTENT:
+ return getExtent();
+
+ case AGE:
+ return new Long(getAge());
+
+ case INPUT_FILES:
+ return getInputFiles();
+
+ case OUTPUT_FILE:
+ return getOutputFile();
+
+ case TYPE:
+ return getType();
+
+ case REASON:
+ return getReason();
+
+ case LOCALITY_GROUP:
+ return getLocalityGroup();
+
+ case ENTRIES_READ:
+ return new Long(getEntriesRead());
+
+ case ENTRIES_WRITTEN:
+ return new Long(getEntriesWritten());
+
+ case ITERATORS:
+ return getIterators();
+
+ }
+ 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 EXTENT:
+ return isSetExtent();
+ case AGE:
+ return isSetAge();
+ case INPUT_FILES:
+ return isSetInputFiles();
+ case OUTPUT_FILE:
+ return isSetOutputFile();
+ case TYPE:
+ return isSetType();
+ case REASON:
+ return isSetReason();
+ case LOCALITY_GROUP:
+ return isSetLocalityGroup();
+ case ENTRIES_READ:
+ return isSetEntriesRead();
+ case ENTRIES_WRITTEN:
+ return isSetEntriesWritten();
+ case ITERATORS:
+ return isSetIterators();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof ActiveCompaction)
+ return this.equals((ActiveCompaction)that);
+ return false;
+ }
+
+ public boolean equals(ActiveCompaction that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_extent = true && this.isSetExtent();
+ boolean that_present_extent = true && that.isSetExtent();
+ if (this_present_extent || that_present_extent) {
+ if (!(this_present_extent && that_present_extent))
+ return false;
+ if (!this.extent.equals(that.extent))
+ return false;
+ }
+
+ boolean this_present_age = true;
+ boolean that_present_age = true;
+ if (this_present_age || that_present_age) {
+ if (!(this_present_age && that_present_age))
+ return false;
+ if (this.age != that.age)
+ return false;
+ }
+
+ boolean this_present_inputFiles = true && this.isSetInputFiles();
+ boolean that_present_inputFiles = true && that.isSetInputFiles();
+ if (this_present_inputFiles || that_present_inputFiles) {
+ if (!(this_present_inputFiles && that_present_inputFiles))
+ return false;
+ if (!this.inputFiles.equals(that.inputFiles))
+ return false;
+ }
+
+ boolean this_present_outputFile = true && this.isSetOutputFile();
+ boolean that_present_outputFile = true && that.isSetOutputFile();
+ if (this_present_outputFile || that_present_outputFile) {
+ if (!(this_present_outputFile && that_present_outputFile))
+ return false;
+ if (!this.outputFile.equals(that.outputFile))
+ return false;
+ }
+
+ boolean this_present_type = true && this.isSetType();
+ boolean that_present_type = true && that.isSetType();
+ if (this_present_type || that_present_type) {
+ if (!(this_present_type && that_present_type))
+ return false;
+ if (!this.type.equals(that.type))
+ return false;
+ }
+
+ boolean this_present_reason = true && this.isSetReason();
+ boolean that_present_reason = true && that.isSetReason();
+ if (this_present_reason || that_present_reason) {
+ if (!(this_present_reason && that_present_reason))
+ return false;
+ if (!this.reason.equals(that.reason))
+ return false;
+ }
+
+ boolean this_present_localityGroup = true && this.isSetLocalityGroup();
+ boolean that_present_localityGroup = true && that.isSetLocalityGroup();
+ if (this_present_localityGroup || that_present_localityGroup) {
+ if (!(this_present_localityGroup && that_present_localityGroup))
+ return false;
+ if (!this.localityGroup.equals(that.localityGroup))
+ return false;
+ }
+
+ boolean this_present_entriesRead = true;
+ boolean that_present_entriesRead = true;
+ if (this_present_entriesRead || that_present_entriesRead) {
+ if (!(this_present_entriesRead && that_present_entriesRead))
+ return false;
+ if (this.entriesRead != that.entriesRead)
+ return false;
+ }
+
+ boolean this_present_entriesWritten = true;
+ boolean that_present_entriesWritten = true;
+ if (this_present_entriesWritten || that_present_entriesWritten) {
+ if (!(this_present_entriesWritten && that_present_entriesWritten))
+ return false;
+ if (this.entriesWritten != that.entriesWritten)
+ return false;
+ }
+
+ boolean this_present_iterators = true && this.isSetIterators();
+ boolean that_present_iterators = true && that.isSetIterators();
+ if (this_present_iterators || that_present_iterators) {
+ if (!(this_present_iterators && that_present_iterators))
+ return false;
+ if (!this.iterators.equals(that.iterators))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ return 0;
+ }
+
+ public int compareTo(ActiveCompaction other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+ ActiveCompaction typedOther = (ActiveCompaction)other;
+
+ lastComparison =
Boolean.valueOf(isSetExtent()).compareTo(typedOther.isSetExtent());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetExtent()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.extent,
typedOther.extent);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison =
Boolean.valueOf(isSetAge()).compareTo(typedOther.isSetAge());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetAge()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.age,
typedOther.age);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison =
Boolean.valueOf(isSetInputFiles()).compareTo(typedOther.isSetInputFiles());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetInputFiles()) {
+ lastComparison =
org.apache.thrift.TBaseHelper.compareTo(this.inputFiles, typedOther.inputFiles);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison =
Boolean.valueOf(isSetOutputFile()).compareTo(typedOther.isSetOutputFile());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetOutputFile()) {
+ lastComparison =
org.apache.thrift.TBaseHelper.compareTo(this.outputFile, typedOther.outputFile);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison =
Boolean.valueOf(isSetType()).compareTo(typedOther.isSetType());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetType()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.type,
typedOther.type);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison =
Boolean.valueOf(isSetReason()).compareTo(typedOther.isSetReason());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetReason()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.reason,
typedOther.reason);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison =
Boolean.valueOf(isSetLocalityGroup()).compareTo(typedOther.isSetLocalityGroup());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetLocalityGroup()) {
+ lastComparison =
org.apache.thrift.TBaseHelper.compareTo(this.localityGroup,
typedOther.localityGroup);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison =
Boolean.valueOf(isSetEntriesRead()).compareTo(typedOther.isSetEntriesRead());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetEntriesRead()) {
+ lastComparison =
org.apache.thrift.TBaseHelper.compareTo(this.entriesRead,
typedOther.entriesRead);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison =
Boolean.valueOf(isSetEntriesWritten()).compareTo(typedOther.isSetEntriesWritten());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetEntriesWritten()) {
+ lastComparison =
org.apache.thrift.TBaseHelper.compareTo(this.entriesWritten,
typedOther.entriesWritten);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison =
Boolean.valueOf(isSetIterators()).compareTo(typedOther.isSetIterators());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetIterators()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.iterators,
typedOther.iterators);
+ 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 {
+ org.apache.thrift.protocol.TField field;
+ iprot.readStructBegin();
+ while (true)
+ {
+ field = iprot.readFieldBegin();
+ if (field.type == org.apache.thrift.protocol.TType.STOP) {
+ break;
+ }
+ switch (field.id) {
+ case 1: // EXTENT
+ if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
+ this.extent = new KeyExtent();
+ this.extent.read(iprot);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 2: // AGE
+ if (field.type == org.apache.thrift.protocol.TType.I64) {
+ this.age = iprot.readI64();
+ setAgeIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 3: // INPUT_FILES
+ if (field.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list49 = iprot.readListBegin();
+ this.inputFiles = new ArrayList<String>(_list49.size);
+ for (int _i50 = 0; _i50 < _list49.size; ++_i50)
+ {
+ String _elem51;
+ _elem51 = iprot.readString();
+ this.inputFiles.add(_elem51);
+ }
+ iprot.readListEnd();
+ }
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 4: // OUTPUT_FILE
+ if (field.type == org.apache.thrift.protocol.TType.STRING) {
+ this.outputFile = iprot.readString();
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 5: // TYPE
+ if (field.type == org.apache.thrift.protocol.TType.I32) {
+ this.type = CompactionType.findByValue(iprot.readI32());
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 6: // REASON
+ if (field.type == org.apache.thrift.protocol.TType.I32) {
+ this.reason = CompactionReason.findByValue(iprot.readI32());
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 7: // LOCALITY_GROUP
+ if (field.type == org.apache.thrift.protocol.TType.STRING) {
+ this.localityGroup = iprot.readString();
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 8: // ENTRIES_READ
+ if (field.type == org.apache.thrift.protocol.TType.I64) {
+ this.entriesRead = iprot.readI64();
+ setEntriesReadIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 9: // ENTRIES_WRITTEN
+ if (field.type == org.apache.thrift.protocol.TType.I64) {
+ this.entriesWritten = iprot.readI64();
+ setEntriesWrittenIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 10: // ITERATORS
+ if (field.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list52 = iprot.readListBegin();
+ this.iterators = new ArrayList<IteratorSetting>(_list52.size);
+ for (int _i53 = 0; _i53 < _list52.size; ++_i53)
+ {
+ IteratorSetting _elem54;
+ _elem54 = new IteratorSetting();
+ _elem54.read(iprot);
+ this.iterators.add(_elem54);
+ }
+ iprot.readListEnd();
+ }
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ default:
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+ }
+ iprot.readFieldEnd();
+ }
+ iprot.readStructEnd();
+
+ // check for required fields of primitive type, which can't be checked in
the validate method
+ validate();
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot) throws
org.apache.thrift.TException {
+ validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (this.extent != null) {
+ oprot.writeFieldBegin(EXTENT_FIELD_DESC);
+ this.extent.write(oprot);
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldBegin(AGE_FIELD_DESC);
+ oprot.writeI64(this.age);
+ oprot.writeFieldEnd();
+ if (this.inputFiles != null) {
+ oprot.writeFieldBegin(INPUT_FILES_FIELD_DESC);
+ {
+ oprot.writeListBegin(new
org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING,
this.inputFiles.size()));
+ for (String _iter55 : this.inputFiles)
+ {
+ oprot.writeString(_iter55);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ if (this.outputFile != null) {
+ oprot.writeFieldBegin(OUTPUT_FILE_FIELD_DESC);
+ oprot.writeString(this.outputFile);
+ oprot.writeFieldEnd();
+ }
+ if (this.type != null) {
+ oprot.writeFieldBegin(TYPE_FIELD_DESC);
+ oprot.writeI32(this.type.getValue());
+ oprot.writeFieldEnd();
+ }
+ if (this.reason != null) {
+ oprot.writeFieldBegin(REASON_FIELD_DESC);
+ oprot.writeI32(this.reason.getValue());
+ oprot.writeFieldEnd();
+ }
+ if (this.localityGroup != null) {
+ oprot.writeFieldBegin(LOCALITY_GROUP_FIELD_DESC);
+ oprot.writeString(this.localityGroup);
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldBegin(ENTRIES_READ_FIELD_DESC);
+ oprot.writeI64(this.entriesRead);
+ oprot.writeFieldEnd();
+ oprot.writeFieldBegin(ENTRIES_WRITTEN_FIELD_DESC);
+ oprot.writeI64(this.entriesWritten);
+ oprot.writeFieldEnd();
+ if (this.iterators != null) {
+ oprot.writeFieldBegin(ITERATORS_FIELD_DESC);
+ {
+ oprot.writeListBegin(new
org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT,
this.iterators.size()));
+ for (IteratorSetting _iter56 : this.iterators)
+ {
+ _iter56.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder("ActiveCompaction(");
+ boolean first = true;
+
+ sb.append("extent:");
+ if (this.extent == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.extent);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("age:");
+ sb.append(this.age);
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("inputFiles:");
+ if (this.inputFiles == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.inputFiles);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("outputFile:");
+ if (this.outputFile == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.outputFile);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("type:");
+ if (this.type == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.type);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("reason:");
+ if (this.reason == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.reason);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("localityGroup:");
+ if (this.localityGroup == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.localityGroup);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("entriesRead:");
+ sb.append(this.entriesRead);
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("entriesWritten:");
+ sb.append(this.entriesWritten);
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("iterators:");
+ if (this.iterators == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.iterators);
+ }
+ 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);
+ }
+ }
+
+}
+
Propchange:
accumulo/branches/1.4/src/proxy/src/main/java/org/apache/accumulo/proxy/thrift/ActiveCompaction.java
------------------------------------------------------------------------------
svn:eol-style = native
