accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From els...@apache.org
Subject [13/15] ACCUMULO-652 merged changes from trunk
Date Mon, 22 Sep 2014 20:45:11 GMT
http://git-wip-us.apache.org/repos/asf/accumulo/blob/58fcad6e/proxy/pom.xml
----------------------------------------------------------------------
diff --cc proxy/pom.xml
index 0000000,d886c7c..3d015b3
mode 000000,100644..100644
--- a/proxy/pom.xml
+++ b/proxy/pom.xml
@@@ -1,0 -1,150 +1,150 @@@
+ <?xml version="1.0"?>
+ <!--
+   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.
+ -->
+ <project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" xmlns="http://maven.apache.org/POM/4.0.0"
+   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
+   <modelVersion>4.0.0</modelVersion>
+   <parent>
+     <artifactId>accumulo</artifactId>
+     <groupId>org.apache.accumulo</groupId>
 -    <version>1.5.0-SNAPSHOT</version>
++    <version>ACCUMULO-652-SNAPSHOT</version>
+   </parent>
+   <artifactId>accumulo-proxy</artifactId>
+   <name>accumulo-proxy</name>
+   <url>http://maven.apache.org</url>
+   <properties>
+     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+   </properties>
+   <build>
+     <pluginManagement>
+       <plugins>
+         <plugin>
+           <artifactId>maven-jar-plugin</artifactId>
+           <configuration>
+             <outputDirectory>../lib</outputDirectory>
+           </configuration>
+         </plugin>
+       </plugins>
+     </pluginManagement>
+     <plugins>
+       <plugin>
+         <groupId>org.codehaus.mojo</groupId>
+         <artifactId>exec-maven-plugin</artifactId>
+         <executions>
+           <execution>
+             <id>generate-thrift</id>
+             <phase>generate-sources</phase>
+             <goals>
+               <goal>exec</goal>
+             </goals>
+             <configuration>
+               <executable>${basedir}/src/main/scripts/generate-thrift.sh</executable>
+             </configuration>
+           </execution>
+         </executions>
+       </plugin>
+     </plugins>
+   </build>
+   <dependencies>
+     <dependency>
+       <groupId>org.apache.accumulo</groupId>
+       <artifactId>accumulo-core</artifactId>
+       <scope>compile</scope>
+     </dependency>
+     <dependency>
+       <groupId>org.apache.zookeeper</groupId>
+       <artifactId>zookeeper</artifactId>
+       <scope>compile</scope>
+     </dependency>
+     <dependency>
+       <groupId>junit</groupId>
+       <artifactId>junit</artifactId>
+       <scope>test</scope>
+     </dependency>
+     <dependency>
+       <groupId>org.apache.thrift</groupId>
+       <artifactId>libthrift</artifactId>
+       <scope>compile</scope>
+     </dependency>
+     <dependency>
+       <groupId>com.google.guava</groupId>
+       <artifactId>guava</artifactId>
+       <version>13.0.1</version>
+       <scope>compile</scope>
+     </dependency>
+     <dependency>
+       <groupId>commons-cli</groupId>
+       <artifactId>commons-cli</artifactId>
+       <scope>compile</scope>
+     </dependency>
+     <dependency>
+       <groupId>com.beust</groupId>
+       <artifactId>jcommander</artifactId>
+     </dependency>
+     <dependency>
+     	<groupId>org.apache.accumulo</groupId>
+     	<artifactId>instamo</artifactId>
 -    	<version>1.5.0-SNAPSHOT</version>
++    	<version>ACCUMULO-652-SNAPSHOT</version>
+     	<scope>test</scope>
+     </dependency>
+     <dependency>
+     	<groupId>org.apache.accumulo</groupId>
+     	<artifactId>examples-simple</artifactId>
+     	<scope>test</scope>
+     </dependency>
+   </dependencies>
+ 
+   <profiles>
+     <!-- profile for building against Hadoop 1.0.x
+     Activate by not specifying hadoop.profile -->
+     <profile>
+       <id>hadoop-1.0</id>
+       <activation>
+         <property>
+           <name>!hadoop.profile</name>
+         </property>
+       </activation>
+       <dependencies>
+         <dependency>
+           <groupId>org.apache.hadoop</groupId>
+           <artifactId>hadoop-core</artifactId>
+         </dependency>
+       </dependencies>
+     </profile>
+     <!-- profile for building against Hadoop 2.0.x
+     Activate using: mvn -Dhadoop.profile=2.0 -->
+     <profile>
+       <id>hadoop-2.0</id>
+       <activation>
+         <property>
+           <name>hadoop.profile</name>
+           <value>2.0</value>
+         </property>
+       </activation>
+       <dependencies>
+         <dependency>
+           <groupId>org.apache.hadoop</groupId>
+           <artifactId>hadoop-client</artifactId>
+         </dependency>
+         <dependency>
+           <groupId>org.apache.avro</groupId>
+           <artifactId>avro</artifactId>
+         </dependency>
+       </dependencies>
+     </profile>
+   </profiles>
+ </project>

http://git-wip-us.apache.org/repos/asf/accumulo/blob/58fcad6e/proxy/src/main/java/org/apache/accumulo/proxy/thrift/IOException.java
----------------------------------------------------------------------
diff --cc proxy/src/main/java/org/apache/accumulo/proxy/thrift/IOException.java
index 0000000,0000000..574c5be
new file mode 100644
--- /dev/null
+++ b/proxy/src/main/java/org/apache/accumulo/proxy/thrift/IOException.java
@@@ -1,0 -1,0 +1,402 @@@
++/*
++ * 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 Compiler (0.9.0)
++ *
++ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
++ *  @generated
++ */
++package org.apache.accumulo.proxy.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 org.apache.thrift.protocol.TProtocolException;
++import org.apache.thrift.EncodingUtils;
++import org.apache.thrift.TException;
++import java.util.List;
++import java.util.ArrayList;
++import java.util.Map;
++import java.util.HashMap;
++import java.util.EnumMap;
++import java.util.Set;
++import java.util.HashSet;
++import java.util.EnumSet;
++import java.util.Collections;
++import java.util.BitSet;
++import java.nio.ByteBuffer;
++import java.util.Arrays;
++import org.slf4j.Logger;
++import org.slf4j.LoggerFactory;
++
++@SuppressWarnings("all") public class IOException extends TException implements org.apache.thrift.TBase<IOException, IOException._Fields>, java.io.Serializable, Cloneable {
++  private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("IOException");
++
++  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);
++
++  private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
++  static {
++    schemes.put(StandardScheme.class, new IOExceptionStandardSchemeFactory());
++    schemes.put(TupleScheme.class, new IOExceptionTupleSchemeFactory());
++  }
++
++  public String msg; // required
++
++  /** 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(IOException.class, metaDataMap);
++  }
++
++  public IOException() {
++  }
++
++  public IOException(
++    String msg)
++  {
++    this();
++    this.msg = msg;
++  }
++
++  /**
++   * Performs a deep copy on <i>other</i>.
++   */
++  public IOException(IOException other) {
++    if (other.isSetMsg()) {
++      this.msg = other.msg;
++    }
++  }
++
++  public IOException deepCopy() {
++    return new IOException(this);
++  }
++
++  @Override
++  public void clear() {
++    this.msg = null;
++  }
++
++  public String getMsg() {
++    return this.msg;
++  }
++
++  public IOException 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 IOException)
++      return this.equals((IOException)that);
++    return false;
++  }
++
++  public boolean equals(IOException 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(IOException other) {
++    if (!getClass().equals(other.getClass())) {
++      return getClass().getName().compareTo(other.getClass().getName());
++    }
++
++    int lastComparison = 0;
++    IOException typedOther = (IOException)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 {
++    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("IOException(");
++    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
++    // check for sub-struct validity
++  }
++
++  private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
++    try {
++      write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
++    } catch (org.apache.thrift.TException te) {
++      throw new java.io.IOException(te);
++    }
++  }
++
++  private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
++    try {
++      read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
++    } catch (org.apache.thrift.TException te) {
++      throw new java.io.IOException(te);
++    }
++  }
++
++  private static class IOExceptionStandardSchemeFactory implements SchemeFactory {
++    public IOExceptionStandardScheme getScheme() {
++      return new IOExceptionStandardScheme();
++    }
++  }
++
++  private static class IOExceptionStandardScheme extends StandardScheme<IOException> {
++
++    public void read(org.apache.thrift.protocol.TProtocol iprot, IOException 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: // MSG
++            if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
++              struct.msg = iprot.readString();
++              struct.setMsgIsSet(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, IOException struct) throws org.apache.thrift.TException {
++      struct.validate();
++
++      oprot.writeStructBegin(STRUCT_DESC);
++      if (struct.msg != null) {
++        oprot.writeFieldBegin(MSG_FIELD_DESC);
++        oprot.writeString(struct.msg);
++        oprot.writeFieldEnd();
++      }
++      oprot.writeFieldStop();
++      oprot.writeStructEnd();
++    }
++
++  }
++
++  private static class IOExceptionTupleSchemeFactory implements SchemeFactory {
++    public IOExceptionTupleScheme getScheme() {
++      return new IOExceptionTupleScheme();
++    }
++  }
++
++  private static class IOExceptionTupleScheme extends TupleScheme<IOException> {
++
++    @Override
++    public void write(org.apache.thrift.protocol.TProtocol prot, IOException struct) throws org.apache.thrift.TException {
++      TTupleProtocol oprot = (TTupleProtocol) prot;
++      BitSet optionals = new BitSet();
++      if (struct.isSetMsg()) {
++        optionals.set(0);
++      }
++      oprot.writeBitSet(optionals, 1);
++      if (struct.isSetMsg()) {
++        oprot.writeString(struct.msg);
++      }
++    }
++
++    @Override
++    public void read(org.apache.thrift.protocol.TProtocol prot, IOException struct) throws org.apache.thrift.TException {
++      TTupleProtocol iprot = (TTupleProtocol) prot;
++      BitSet incoming = iprot.readBitSet(1);
++      if (incoming.get(0)) {
++        struct.msg = iprot.readString();
++        struct.setMsgIsSet(true);
++      }
++    }
++  }
++
++}
++

http://git-wip-us.apache.org/repos/asf/accumulo/blob/58fcad6e/proxy/src/main/java/org/apache/accumulo/proxy/thrift/PColumn.java
----------------------------------------------------------------------
diff --cc proxy/src/main/java/org/apache/accumulo/proxy/thrift/PColumn.java
index 0000000,0000000..35a83ca
new file mode 100644
--- /dev/null
+++ b/proxy/src/main/java/org/apache/accumulo/proxy/thrift/PColumn.java
@@@ -1,0 -1,0 +1,737 @@@
++/*
++ * 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 Compiler (0.9.0)
++ *
++ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
++ *  @generated
++ */
++package org.apache.accumulo.proxy.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 org.apache.thrift.protocol.TProtocolException;
++import org.apache.thrift.EncodingUtils;
++import org.apache.thrift.TException;
++import java.util.List;
++import java.util.ArrayList;
++import java.util.Map;
++import java.util.HashMap;
++import java.util.EnumMap;
++import java.util.Set;
++import java.util.HashSet;
++import java.util.EnumSet;
++import java.util.Collections;
++import java.util.BitSet;
++import java.nio.ByteBuffer;
++import java.util.Arrays;
++import org.slf4j.Logger;
++import org.slf4j.LoggerFactory;
++
++@SuppressWarnings("all") public class PColumn implements org.apache.thrift.TBase<PColumn, PColumn._Fields>, java.io.Serializable, Cloneable {
++  private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("PColumn");
++
++  private static final org.apache.thrift.protocol.TField COL_FAMILY_FIELD_DESC = new org.apache.thrift.protocol.TField("colFamily", org.apache.thrift.protocol.TType.STRING, (short)1);
++  private static final org.apache.thrift.protocol.TField COL_QUALIFIER_FIELD_DESC = new org.apache.thrift.protocol.TField("colQualifier", org.apache.thrift.protocol.TType.STRING, (short)2);
++  private static final org.apache.thrift.protocol.TField COL_VISIBILITY_FIELD_DESC = new org.apache.thrift.protocol.TField("colVisibility", org.apache.thrift.protocol.TType.STRING, (short)3);
++  private static final org.apache.thrift.protocol.TField TIMESTAMP_FIELD_DESC = new org.apache.thrift.protocol.TField("timestamp", org.apache.thrift.protocol.TType.I64, (short)4);
++
++  private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
++  static {
++    schemes.put(StandardScheme.class, new PColumnStandardSchemeFactory());
++    schemes.put(TupleScheme.class, new PColumnTupleSchemeFactory());
++  }
++
++  public ByteBuffer colFamily; // required
++  public ByteBuffer colQualifier; // required
++  public ByteBuffer colVisibility; // optional
++  public long timestamp; // optional
++
++  /** 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 {
++    COL_FAMILY((short)1, "colFamily"),
++    COL_QUALIFIER((short)2, "colQualifier"),
++    COL_VISIBILITY((short)3, "colVisibility"),
++    TIMESTAMP((short)4, "timestamp");
++
++    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: // COL_FAMILY
++          return COL_FAMILY;
++        case 2: // COL_QUALIFIER
++          return COL_QUALIFIER;
++        case 3: // COL_VISIBILITY
++          return COL_VISIBILITY;
++        case 4: // TIMESTAMP
++          return TIMESTAMP;
++        default:
++          return null;
++      }
++    }
++
++    /**
++     * Find the _Fields constant that matches fieldId, throwing an exception
++     * if it is not found.
++     */
++    public static _Fields findByThriftIdOrThrow(int fieldId) {
++      _Fields fields = findByThriftId(fieldId);
++      if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
++      return fields;
++    }
++
++    /**
++     * Find the _Fields constant that matches name, or null if its not found.
++     */
++    public static _Fields findByName(String name) {
++      return byName.get(name);
++    }
++
++    private final short _thriftId;
++    private final String _fieldName;
++
++    _Fields(short thriftId, String fieldName) {
++      _thriftId = thriftId;
++      _fieldName = fieldName;
++    }
++
++    public short getThriftFieldId() {
++      return _thriftId;
++    }
++
++    public String getFieldName() {
++      return _fieldName;
++    }
++  }
++
++  // isset id assignments
++  private static final int __TIMESTAMP_ISSET_ID = 0;
++  private byte __isset_bitfield = 0;
++  private _Fields optionals[] = {_Fields.COL_VISIBILITY,_Fields.TIMESTAMP};
++  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.COL_FAMILY, new org.apache.thrift.meta_data.FieldMetaData("colFamily", org.apache.thrift.TFieldRequirementType.DEFAULT, 
++        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING        , true)));
++    tmpMap.put(_Fields.COL_QUALIFIER, new org.apache.thrift.meta_data.FieldMetaData("colQualifier", org.apache.thrift.TFieldRequirementType.DEFAULT, 
++        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING        , true)));
++    tmpMap.put(_Fields.COL_VISIBILITY, new org.apache.thrift.meta_data.FieldMetaData("colVisibility", org.apache.thrift.TFieldRequirementType.OPTIONAL, 
++        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING        , true)));
++    tmpMap.put(_Fields.TIMESTAMP, new org.apache.thrift.meta_data.FieldMetaData("timestamp", org.apache.thrift.TFieldRequirementType.OPTIONAL, 
++        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
++    metaDataMap = Collections.unmodifiableMap(tmpMap);
++    org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(PColumn.class, metaDataMap);
++  }
++
++  public PColumn() {
++  }
++
++  public PColumn(
++    ByteBuffer colFamily,
++    ByteBuffer colQualifier)
++  {
++    this();
++    this.colFamily = colFamily;
++    this.colQualifier = colQualifier;
++  }
++
++  /**
++   * Performs a deep copy on <i>other</i>.
++   */
++  public PColumn(PColumn other) {
++    __isset_bitfield = other.__isset_bitfield;
++    if (other.isSetColFamily()) {
++      this.colFamily = org.apache.thrift.TBaseHelper.copyBinary(other.colFamily);
++;
++    }
++    if (other.isSetColQualifier()) {
++      this.colQualifier = org.apache.thrift.TBaseHelper.copyBinary(other.colQualifier);
++;
++    }
++    if (other.isSetColVisibility()) {
++      this.colVisibility = org.apache.thrift.TBaseHelper.copyBinary(other.colVisibility);
++;
++    }
++    this.timestamp = other.timestamp;
++  }
++
++  public PColumn deepCopy() {
++    return new PColumn(this);
++  }
++
++  @Override
++  public void clear() {
++    this.colFamily = null;
++    this.colQualifier = null;
++    this.colVisibility = null;
++    setTimestampIsSet(false);
++    this.timestamp = 0;
++  }
++
++  public byte[] getColFamily() {
++    setColFamily(org.apache.thrift.TBaseHelper.rightSize(colFamily));
++    return colFamily == null ? null : colFamily.array();
++  }
++
++  public ByteBuffer bufferForColFamily() {
++    return colFamily;
++  }
++
++  public PColumn setColFamily(byte[] colFamily) {
++    setColFamily(colFamily == null ? (ByteBuffer)null : ByteBuffer.wrap(colFamily));
++    return this;
++  }
++
++  public PColumn setColFamily(ByteBuffer colFamily) {
++    this.colFamily = colFamily;
++    return this;
++  }
++
++  public void unsetColFamily() {
++    this.colFamily = null;
++  }
++
++  /** Returns true if field colFamily is set (has been assigned a value) and false otherwise */
++  public boolean isSetColFamily() {
++    return this.colFamily != null;
++  }
++
++  public void setColFamilyIsSet(boolean value) {
++    if (!value) {
++      this.colFamily = null;
++    }
++  }
++
++  public byte[] getColQualifier() {
++    setColQualifier(org.apache.thrift.TBaseHelper.rightSize(colQualifier));
++    return colQualifier == null ? null : colQualifier.array();
++  }
++
++  public ByteBuffer bufferForColQualifier() {
++    return colQualifier;
++  }
++
++  public PColumn setColQualifier(byte[] colQualifier) {
++    setColQualifier(colQualifier == null ? (ByteBuffer)null : ByteBuffer.wrap(colQualifier));
++    return this;
++  }
++
++  public PColumn setColQualifier(ByteBuffer colQualifier) {
++    this.colQualifier = colQualifier;
++    return this;
++  }
++
++  public void unsetColQualifier() {
++    this.colQualifier = null;
++  }
++
++  /** Returns true if field colQualifier is set (has been assigned a value) and false otherwise */
++  public boolean isSetColQualifier() {
++    return this.colQualifier != null;
++  }
++
++  public void setColQualifierIsSet(boolean value) {
++    if (!value) {
++      this.colQualifier = null;
++    }
++  }
++
++  public byte[] getColVisibility() {
++    setColVisibility(org.apache.thrift.TBaseHelper.rightSize(colVisibility));
++    return colVisibility == null ? null : colVisibility.array();
++  }
++
++  public ByteBuffer bufferForColVisibility() {
++    return colVisibility;
++  }
++
++  public PColumn setColVisibility(byte[] colVisibility) {
++    setColVisibility(colVisibility == null ? (ByteBuffer)null : ByteBuffer.wrap(colVisibility));
++    return this;
++  }
++
++  public PColumn setColVisibility(ByteBuffer colVisibility) {
++    this.colVisibility = colVisibility;
++    return this;
++  }
++
++  public void unsetColVisibility() {
++    this.colVisibility = null;
++  }
++
++  /** Returns true if field colVisibility is set (has been assigned a value) and false otherwise */
++  public boolean isSetColVisibility() {
++    return this.colVisibility != null;
++  }
++
++  public void setColVisibilityIsSet(boolean value) {
++    if (!value) {
++      this.colVisibility = null;
++    }
++  }
++
++  public long getTimestamp() {
++    return this.timestamp;
++  }
++
++  public PColumn setTimestamp(long timestamp) {
++    this.timestamp = timestamp;
++    setTimestampIsSet(true);
++    return this;
++  }
++
++  public void unsetTimestamp() {
++    __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TIMESTAMP_ISSET_ID);
++  }
++
++  /** Returns true if field timestamp is set (has been assigned a value) and false otherwise */
++  public boolean isSetTimestamp() {
++    return EncodingUtils.testBit(__isset_bitfield, __TIMESTAMP_ISSET_ID);
++  }
++
++  public void setTimestampIsSet(boolean value) {
++    __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TIMESTAMP_ISSET_ID, value);
++  }
++
++  public void setFieldValue(_Fields field, Object value) {
++    switch (field) {
++    case COL_FAMILY:
++      if (value == null) {
++        unsetColFamily();
++      } else {
++        setColFamily((ByteBuffer)value);
++      }
++      break;
++
++    case COL_QUALIFIER:
++      if (value == null) {
++        unsetColQualifier();
++      } else {
++        setColQualifier((ByteBuffer)value);
++      }
++      break;
++
++    case COL_VISIBILITY:
++      if (value == null) {
++        unsetColVisibility();
++      } else {
++        setColVisibility((ByteBuffer)value);
++      }
++      break;
++
++    case TIMESTAMP:
++      if (value == null) {
++        unsetTimestamp();
++      } else {
++        setTimestamp((Long)value);
++      }
++      break;
++
++    }
++  }
++
++  public Object getFieldValue(_Fields field) {
++    switch (field) {
++    case COL_FAMILY:
++      return getColFamily();
++
++    case COL_QUALIFIER:
++      return getColQualifier();
++
++    case COL_VISIBILITY:
++      return getColVisibility();
++
++    case TIMESTAMP:
++      return Long.valueOf(getTimestamp());
++
++    }
++    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 COL_FAMILY:
++      return isSetColFamily();
++    case COL_QUALIFIER:
++      return isSetColQualifier();
++    case COL_VISIBILITY:
++      return isSetColVisibility();
++    case TIMESTAMP:
++      return isSetTimestamp();
++    }
++    throw new IllegalStateException();
++  }
++
++  @Override
++  public boolean equals(Object that) {
++    if (that == null)
++      return false;
++    if (that instanceof PColumn)
++      return this.equals((PColumn)that);
++    return false;
++  }
++
++  public boolean equals(PColumn that) {
++    if (that == null)
++      return false;
++
++    boolean this_present_colFamily = true && this.isSetColFamily();
++    boolean that_present_colFamily = true && that.isSetColFamily();
++    if (this_present_colFamily || that_present_colFamily) {
++      if (!(this_present_colFamily && that_present_colFamily))
++        return false;
++      if (!this.colFamily.equals(that.colFamily))
++        return false;
++    }
++
++    boolean this_present_colQualifier = true && this.isSetColQualifier();
++    boolean that_present_colQualifier = true && that.isSetColQualifier();
++    if (this_present_colQualifier || that_present_colQualifier) {
++      if (!(this_present_colQualifier && that_present_colQualifier))
++        return false;
++      if (!this.colQualifier.equals(that.colQualifier))
++        return false;
++    }
++
++    boolean this_present_colVisibility = true && this.isSetColVisibility();
++    boolean that_present_colVisibility = true && that.isSetColVisibility();
++    if (this_present_colVisibility || that_present_colVisibility) {
++      if (!(this_present_colVisibility && that_present_colVisibility))
++        return false;
++      if (!this.colVisibility.equals(that.colVisibility))
++        return false;
++    }
++
++    boolean this_present_timestamp = true && this.isSetTimestamp();
++    boolean that_present_timestamp = true && that.isSetTimestamp();
++    if (this_present_timestamp || that_present_timestamp) {
++      if (!(this_present_timestamp && that_present_timestamp))
++        return false;
++      if (this.timestamp != that.timestamp)
++        return false;
++    }
++
++    return true;
++  }
++
++  @Override
++  public int hashCode() {
++    return 0;
++  }
++
++  public int compareTo(PColumn other) {
++    if (!getClass().equals(other.getClass())) {
++      return getClass().getName().compareTo(other.getClass().getName());
++    }
++
++    int lastComparison = 0;
++    PColumn typedOther = (PColumn)other;
++
++    lastComparison = Boolean.valueOf(isSetColFamily()).compareTo(typedOther.isSetColFamily());
++    if (lastComparison != 0) {
++      return lastComparison;
++    }
++    if (isSetColFamily()) {
++      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.colFamily, typedOther.colFamily);
++      if (lastComparison != 0) {
++        return lastComparison;
++      }
++    }
++    lastComparison = Boolean.valueOf(isSetColQualifier()).compareTo(typedOther.isSetColQualifier());
++    if (lastComparison != 0) {
++      return lastComparison;
++    }
++    if (isSetColQualifier()) {
++      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.colQualifier, typedOther.colQualifier);
++      if (lastComparison != 0) {
++        return lastComparison;
++      }
++    }
++    lastComparison = Boolean.valueOf(isSetColVisibility()).compareTo(typedOther.isSetColVisibility());
++    if (lastComparison != 0) {
++      return lastComparison;
++    }
++    if (isSetColVisibility()) {
++      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.colVisibility, typedOther.colVisibility);
++      if (lastComparison != 0) {
++        return lastComparison;
++      }
++    }
++    lastComparison = Boolean.valueOf(isSetTimestamp()).compareTo(typedOther.isSetTimestamp());
++    if (lastComparison != 0) {
++      return lastComparison;
++    }
++    if (isSetTimestamp()) {
++      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.timestamp, typedOther.timestamp);
++      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("PColumn(");
++    boolean first = true;
++
++    sb.append("colFamily:");
++    if (this.colFamily == null) {
++      sb.append("null");
++    } else {
++      org.apache.thrift.TBaseHelper.toString(this.colFamily, sb);
++    }
++    first = false;
++    if (!first) sb.append(", ");
++    sb.append("colQualifier:");
++    if (this.colQualifier == null) {
++      sb.append("null");
++    } else {
++      org.apache.thrift.TBaseHelper.toString(this.colQualifier, sb);
++    }
++    first = false;
++    if (isSetColVisibility()) {
++      if (!first) sb.append(", ");
++      sb.append("colVisibility:");
++      if (this.colVisibility == null) {
++        sb.append("null");
++      } else {
++        org.apache.thrift.TBaseHelper.toString(this.colVisibility, sb);
++      }
++      first = false;
++    }
++    if (isSetTimestamp()) {
++      if (!first) sb.append(", ");
++      sb.append("timestamp:");
++      sb.append(this.timestamp);
++      first = false;
++    }
++    sb.append(")");
++    return sb.toString();
++  }
++
++  public void validate() throws org.apache.thrift.TException {
++    // check for required fields
++    // check for sub-struct validity
++  }
++
++  private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
++    try {
++      write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
++    } catch (org.apache.thrift.TException te) {
++      throw new java.io.IOException(te);
++    }
++  }
++
++  private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
++    try {
++      // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
++      __isset_bitfield = 0;
++      read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
++    } catch (org.apache.thrift.TException te) {
++      throw new java.io.IOException(te);
++    }
++  }
++
++  private static class PColumnStandardSchemeFactory implements SchemeFactory {
++    public PColumnStandardScheme getScheme() {
++      return new PColumnStandardScheme();
++    }
++  }
++
++  private static class PColumnStandardScheme extends StandardScheme<PColumn> {
++
++    public void read(org.apache.thrift.protocol.TProtocol iprot, PColumn 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: // COL_FAMILY
++            if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
++              struct.colFamily = iprot.readBinary();
++              struct.setColFamilyIsSet(true);
++            } else { 
++              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
++            }
++            break;
++          case 2: // COL_QUALIFIER
++            if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
++              struct.colQualifier = iprot.readBinary();
++              struct.setColQualifierIsSet(true);
++            } else { 
++              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
++            }
++            break;
++          case 3: // COL_VISIBILITY
++            if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
++              struct.colVisibility = iprot.readBinary();
++              struct.setColVisibilityIsSet(true);
++            } else { 
++              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
++            }
++            break;
++          case 4: // TIMESTAMP
++            if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
++              struct.timestamp = iprot.readI64();
++              struct.setTimestampIsSet(true);
++            } else { 
++              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
++            }
++            break;
++          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, PColumn struct) throws org.apache.thrift.TException {
++      struct.validate();
++
++      oprot.writeStructBegin(STRUCT_DESC);
++      if (struct.colFamily != null) {
++        oprot.writeFieldBegin(COL_FAMILY_FIELD_DESC);
++        oprot.writeBinary(struct.colFamily);
++        oprot.writeFieldEnd();
++      }
++      if (struct.colQualifier != null) {
++        oprot.writeFieldBegin(COL_QUALIFIER_FIELD_DESC);
++        oprot.writeBinary(struct.colQualifier);
++        oprot.writeFieldEnd();
++      }
++      if (struct.colVisibility != null) {
++        if (struct.isSetColVisibility()) {
++          oprot.writeFieldBegin(COL_VISIBILITY_FIELD_DESC);
++          oprot.writeBinary(struct.colVisibility);
++          oprot.writeFieldEnd();
++        }
++      }
++      if (struct.isSetTimestamp()) {
++        oprot.writeFieldBegin(TIMESTAMP_FIELD_DESC);
++        oprot.writeI64(struct.timestamp);
++        oprot.writeFieldEnd();
++      }
++      oprot.writeFieldStop();
++      oprot.writeStructEnd();
++    }
++
++  }
++
++  private static class PColumnTupleSchemeFactory implements SchemeFactory {
++    public PColumnTupleScheme getScheme() {
++      return new PColumnTupleScheme();
++    }
++  }
++
++  private static class PColumnTupleScheme extends TupleScheme<PColumn> {
++
++    @Override
++    public void write(org.apache.thrift.protocol.TProtocol prot, PColumn struct) throws org.apache.thrift.TException {
++      TTupleProtocol oprot = (TTupleProtocol) prot;
++      BitSet optionals = new BitSet();
++      if (struct.isSetColFamily()) {
++        optionals.set(0);
++      }
++      if (struct.isSetColQualifier()) {
++        optionals.set(1);
++      }
++      if (struct.isSetColVisibility()) {
++        optionals.set(2);
++      }
++      if (struct.isSetTimestamp()) {
++        optionals.set(3);
++      }
++      oprot.writeBitSet(optionals, 4);
++      if (struct.isSetColFamily()) {
++        oprot.writeBinary(struct.colFamily);
++      }
++      if (struct.isSetColQualifier()) {
++        oprot.writeBinary(struct.colQualifier);
++      }
++      if (struct.isSetColVisibility()) {
++        oprot.writeBinary(struct.colVisibility);
++      }
++      if (struct.isSetTimestamp()) {
++        oprot.writeI64(struct.timestamp);
++      }
++    }
++
++    @Override
++    public void read(org.apache.thrift.protocol.TProtocol prot, PColumn struct) throws org.apache.thrift.TException {
++      TTupleProtocol iprot = (TTupleProtocol) prot;
++      BitSet incoming = iprot.readBitSet(4);
++      if (incoming.get(0)) {
++        struct.colFamily = iprot.readBinary();
++        struct.setColFamilyIsSet(true);
++      }
++      if (incoming.get(1)) {
++        struct.colQualifier = iprot.readBinary();
++        struct.setColQualifierIsSet(true);
++      }
++      if (incoming.get(2)) {
++        struct.colVisibility = iprot.readBinary();
++        struct.setColVisibilityIsSet(true);
++      }
++      if (incoming.get(3)) {
++        struct.timestamp = iprot.readI64();
++        struct.setTimestampIsSet(true);
++      }
++    }
++  }
++
++}
++

http://git-wip-us.apache.org/repos/asf/accumulo/blob/58fcad6e/proxy/src/main/java/org/apache/accumulo/proxy/thrift/PColumnUpdate.java
----------------------------------------------------------------------
diff --cc proxy/src/main/java/org/apache/accumulo/proxy/thrift/PColumnUpdate.java
index 0000000,0000000..31e5c27
new file mode 100644
--- /dev/null
+++ b/proxy/src/main/java/org/apache/accumulo/proxy/thrift/PColumnUpdate.java
@@@ -1,0 -1,0 +1,848 @@@
++/*
++ * 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 Compiler (0.9.0)
++ *
++ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
++ *  @generated
++ */
++package org.apache.accumulo.proxy.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 org.apache.thrift.protocol.TProtocolException;
++import org.apache.thrift.EncodingUtils;
++import org.apache.thrift.TException;
++import java.util.List;
++import java.util.ArrayList;
++import java.util.Map;
++import java.util.HashMap;
++import java.util.EnumMap;
++import java.util.Set;
++import java.util.HashSet;
++import java.util.EnumSet;
++import java.util.Collections;
++import java.util.BitSet;
++import java.nio.ByteBuffer;
++import java.util.Arrays;
++import org.slf4j.Logger;
++import org.slf4j.LoggerFactory;
++
++@SuppressWarnings("all") public class PColumnUpdate implements org.apache.thrift.TBase<PColumnUpdate, PColumnUpdate._Fields>, java.io.Serializable, Cloneable {
++  private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("PColumnUpdate");
++
++  private static final org.apache.thrift.protocol.TField COL_FAMILY_FIELD_DESC = new org.apache.thrift.protocol.TField("colFamily", org.apache.thrift.protocol.TType.STRING, (short)1);
++  private static final org.apache.thrift.protocol.TField COL_QUALIFIER_FIELD_DESC = new org.apache.thrift.protocol.TField("colQualifier", org.apache.thrift.protocol.TType.STRING, (short)2);
++  private static final org.apache.thrift.protocol.TField COL_VISIBILITY_FIELD_DESC = new org.apache.thrift.protocol.TField("colVisibility", org.apache.thrift.protocol.TType.STRING, (short)3);
++  private static final org.apache.thrift.protocol.TField TIMESTAMP_FIELD_DESC = new org.apache.thrift.protocol.TField("timestamp", org.apache.thrift.protocol.TType.I64, (short)4);
++  private static final org.apache.thrift.protocol.TField VALUE_FIELD_DESC = new org.apache.thrift.protocol.TField("value", org.apache.thrift.protocol.TType.STRING, (short)5);
++
++  private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
++  static {
++    schemes.put(StandardScheme.class, new PColumnUpdateStandardSchemeFactory());
++    schemes.put(TupleScheme.class, new PColumnUpdateTupleSchemeFactory());
++  }
++
++  public ByteBuffer colFamily; // required
++  public ByteBuffer colQualifier; // required
++  public ByteBuffer colVisibility; // optional
++  public long timestamp; // optional
++  public ByteBuffer value; // required
++
++  /** 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 {
++    COL_FAMILY((short)1, "colFamily"),
++    COL_QUALIFIER((short)2, "colQualifier"),
++    COL_VISIBILITY((short)3, "colVisibility"),
++    TIMESTAMP((short)4, "timestamp"),
++    VALUE((short)5, "value");
++
++    private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
++
++    static {
++      for (_Fields field : EnumSet.allOf(_Fields.class)) {
++        byName.put(field.getFieldName(), field);
++      }
++    }
++
++    /**
++     * Find the _Fields constant that matches fieldId, or null if its not found.
++     */
++    public static _Fields findByThriftId(int fieldId) {
++      switch(fieldId) {
++        case 1: // COL_FAMILY
++          return COL_FAMILY;
++        case 2: // COL_QUALIFIER
++          return COL_QUALIFIER;
++        case 3: // COL_VISIBILITY
++          return COL_VISIBILITY;
++        case 4: // TIMESTAMP
++          return TIMESTAMP;
++        case 5: // VALUE
++          return VALUE;
++        default:
++          return null;
++      }
++    }
++
++    /**
++     * Find the _Fields constant that matches fieldId, throwing an exception
++     * if it is not found.
++     */
++    public static _Fields findByThriftIdOrThrow(int fieldId) {
++      _Fields fields = findByThriftId(fieldId);
++      if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
++      return fields;
++    }
++
++    /**
++     * Find the _Fields constant that matches name, or null if its not found.
++     */
++    public static _Fields findByName(String name) {
++      return byName.get(name);
++    }
++
++    private final short _thriftId;
++    private final String _fieldName;
++
++    _Fields(short thriftId, String fieldName) {
++      _thriftId = thriftId;
++      _fieldName = fieldName;
++    }
++
++    public short getThriftFieldId() {
++      return _thriftId;
++    }
++
++    public String getFieldName() {
++      return _fieldName;
++    }
++  }
++
++  // isset id assignments
++  private static final int __TIMESTAMP_ISSET_ID = 0;
++  private byte __isset_bitfield = 0;
++  private _Fields optionals[] = {_Fields.COL_VISIBILITY,_Fields.TIMESTAMP};
++  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.COL_FAMILY, new org.apache.thrift.meta_data.FieldMetaData("colFamily", org.apache.thrift.TFieldRequirementType.DEFAULT, 
++        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING        , true)));
++    tmpMap.put(_Fields.COL_QUALIFIER, new org.apache.thrift.meta_data.FieldMetaData("colQualifier", org.apache.thrift.TFieldRequirementType.DEFAULT, 
++        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING        , true)));
++    tmpMap.put(_Fields.COL_VISIBILITY, new org.apache.thrift.meta_data.FieldMetaData("colVisibility", org.apache.thrift.TFieldRequirementType.OPTIONAL, 
++        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING        , true)));
++    tmpMap.put(_Fields.TIMESTAMP, new org.apache.thrift.meta_data.FieldMetaData("timestamp", org.apache.thrift.TFieldRequirementType.OPTIONAL, 
++        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
++    tmpMap.put(_Fields.VALUE, new org.apache.thrift.meta_data.FieldMetaData("value", org.apache.thrift.TFieldRequirementType.DEFAULT, 
++        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING        , true)));
++    metaDataMap = Collections.unmodifiableMap(tmpMap);
++    org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(PColumnUpdate.class, metaDataMap);
++  }
++
++  public PColumnUpdate() {
++  }
++
++  public PColumnUpdate(
++    ByteBuffer colFamily,
++    ByteBuffer colQualifier,
++    ByteBuffer value)
++  {
++    this();
++    this.colFamily = colFamily;
++    this.colQualifier = colQualifier;
++    this.value = value;
++  }
++
++  /**
++   * Performs a deep copy on <i>other</i>.
++   */
++  public PColumnUpdate(PColumnUpdate other) {
++    __isset_bitfield = other.__isset_bitfield;
++    if (other.isSetColFamily()) {
++      this.colFamily = org.apache.thrift.TBaseHelper.copyBinary(other.colFamily);
++;
++    }
++    if (other.isSetColQualifier()) {
++      this.colQualifier = org.apache.thrift.TBaseHelper.copyBinary(other.colQualifier);
++;
++    }
++    if (other.isSetColVisibility()) {
++      this.colVisibility = org.apache.thrift.TBaseHelper.copyBinary(other.colVisibility);
++;
++    }
++    this.timestamp = other.timestamp;
++    if (other.isSetValue()) {
++      this.value = org.apache.thrift.TBaseHelper.copyBinary(other.value);
++;
++    }
++  }
++
++  public PColumnUpdate deepCopy() {
++    return new PColumnUpdate(this);
++  }
++
++  @Override
++  public void clear() {
++    this.colFamily = null;
++    this.colQualifier = null;
++    this.colVisibility = null;
++    setTimestampIsSet(false);
++    this.timestamp = 0;
++    this.value = null;
++  }
++
++  public byte[] getColFamily() {
++    setColFamily(org.apache.thrift.TBaseHelper.rightSize(colFamily));
++    return colFamily == null ? null : colFamily.array();
++  }
++
++  public ByteBuffer bufferForColFamily() {
++    return colFamily;
++  }
++
++  public PColumnUpdate setColFamily(byte[] colFamily) {
++    setColFamily(colFamily == null ? (ByteBuffer)null : ByteBuffer.wrap(colFamily));
++    return this;
++  }
++
++  public PColumnUpdate setColFamily(ByteBuffer colFamily) {
++    this.colFamily = colFamily;
++    return this;
++  }
++
++  public void unsetColFamily() {
++    this.colFamily = null;
++  }
++
++  /** Returns true if field colFamily is set (has been assigned a value) and false otherwise */
++  public boolean isSetColFamily() {
++    return this.colFamily != null;
++  }
++
++  public void setColFamilyIsSet(boolean value) {
++    if (!value) {
++      this.colFamily = null;
++    }
++  }
++
++  public byte[] getColQualifier() {
++    setColQualifier(org.apache.thrift.TBaseHelper.rightSize(colQualifier));
++    return colQualifier == null ? null : colQualifier.array();
++  }
++
++  public ByteBuffer bufferForColQualifier() {
++    return colQualifier;
++  }
++
++  public PColumnUpdate setColQualifier(byte[] colQualifier) {
++    setColQualifier(colQualifier == null ? (ByteBuffer)null : ByteBuffer.wrap(colQualifier));
++    return this;
++  }
++
++  public PColumnUpdate setColQualifier(ByteBuffer colQualifier) {
++    this.colQualifier = colQualifier;
++    return this;
++  }
++
++  public void unsetColQualifier() {
++    this.colQualifier = null;
++  }
++
++  /** Returns true if field colQualifier is set (has been assigned a value) and false otherwise */
++  public boolean isSetColQualifier() {
++    return this.colQualifier != null;
++  }
++
++  public void setColQualifierIsSet(boolean value) {
++    if (!value) {
++      this.colQualifier = null;
++    }
++  }
++
++  public byte[] getColVisibility() {
++    setColVisibility(org.apache.thrift.TBaseHelper.rightSize(colVisibility));
++    return colVisibility == null ? null : colVisibility.array();
++  }
++
++  public ByteBuffer bufferForColVisibility() {
++    return colVisibility;
++  }
++
++  public PColumnUpdate setColVisibility(byte[] colVisibility) {
++    setColVisibility(colVisibility == null ? (ByteBuffer)null : ByteBuffer.wrap(colVisibility));
++    return this;
++  }
++
++  public PColumnUpdate setColVisibility(ByteBuffer colVisibility) {
++    this.colVisibility = colVisibility;
++    return this;
++  }
++
++  public void unsetColVisibility() {
++    this.colVisibility = null;
++  }
++
++  /** Returns true if field colVisibility is set (has been assigned a value) and false otherwise */
++  public boolean isSetColVisibility() {
++    return this.colVisibility != null;
++  }
++
++  public void setColVisibilityIsSet(boolean value) {
++    if (!value) {
++      this.colVisibility = null;
++    }
++  }
++
++  public long getTimestamp() {
++    return this.timestamp;
++  }
++
++  public PColumnUpdate setTimestamp(long timestamp) {
++    this.timestamp = timestamp;
++    setTimestampIsSet(true);
++    return this;
++  }
++
++  public void unsetTimestamp() {
++    __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TIMESTAMP_ISSET_ID);
++  }
++
++  /** Returns true if field timestamp is set (has been assigned a value) and false otherwise */
++  public boolean isSetTimestamp() {
++    return EncodingUtils.testBit(__isset_bitfield, __TIMESTAMP_ISSET_ID);
++  }
++
++  public void setTimestampIsSet(boolean value) {
++    __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TIMESTAMP_ISSET_ID, value);
++  }
++
++  public byte[] getValue() {
++    setValue(org.apache.thrift.TBaseHelper.rightSize(value));
++    return value == null ? null : value.array();
++  }
++
++  public ByteBuffer bufferForValue() {
++    return value;
++  }
++
++  public PColumnUpdate setValue(byte[] value) {
++    setValue(value == null ? (ByteBuffer)null : ByteBuffer.wrap(value));
++    return this;
++  }
++
++  public PColumnUpdate setValue(ByteBuffer value) {
++    this.value = value;
++    return this;
++  }
++
++  public void unsetValue() {
++    this.value = null;
++  }
++
++  /** Returns true if field value is set (has been assigned a value) and false otherwise */
++  public boolean isSetValue() {
++    return this.value != null;
++  }
++
++  public void setValueIsSet(boolean value) {
++    if (!value) {
++      this.value = null;
++    }
++  }
++
++  public void setFieldValue(_Fields field, Object value) {
++    switch (field) {
++    case COL_FAMILY:
++      if (value == null) {
++        unsetColFamily();
++      } else {
++        setColFamily((ByteBuffer)value);
++      }
++      break;
++
++    case COL_QUALIFIER:
++      if (value == null) {
++        unsetColQualifier();
++      } else {
++        setColQualifier((ByteBuffer)value);
++      }
++      break;
++
++    case COL_VISIBILITY:
++      if (value == null) {
++        unsetColVisibility();
++      } else {
++        setColVisibility((ByteBuffer)value);
++      }
++      break;
++
++    case TIMESTAMP:
++      if (value == null) {
++        unsetTimestamp();
++      } else {
++        setTimestamp((Long)value);
++      }
++      break;
++
++    case VALUE:
++      if (value == null) {
++        unsetValue();
++      } else {
++        setValue((ByteBuffer)value);
++      }
++      break;
++
++    }
++  }
++
++  public Object getFieldValue(_Fields field) {
++    switch (field) {
++    case COL_FAMILY:
++      return getColFamily();
++
++    case COL_QUALIFIER:
++      return getColQualifier();
++
++    case COL_VISIBILITY:
++      return getColVisibility();
++
++    case TIMESTAMP:
++      return Long.valueOf(getTimestamp());
++
++    case VALUE:
++      return getValue();
++
++    }
++    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 COL_FAMILY:
++      return isSetColFamily();
++    case COL_QUALIFIER:
++      return isSetColQualifier();
++    case COL_VISIBILITY:
++      return isSetColVisibility();
++    case TIMESTAMP:
++      return isSetTimestamp();
++    case VALUE:
++      return isSetValue();
++    }
++    throw new IllegalStateException();
++  }
++
++  @Override
++  public boolean equals(Object that) {
++    if (that == null)
++      return false;
++    if (that instanceof PColumnUpdate)
++      return this.equals((PColumnUpdate)that);
++    return false;
++  }
++
++  public boolean equals(PColumnUpdate that) {
++    if (that == null)
++      return false;
++
++    boolean this_present_colFamily = true && this.isSetColFamily();
++    boolean that_present_colFamily = true && that.isSetColFamily();
++    if (this_present_colFamily || that_present_colFamily) {
++      if (!(this_present_colFamily && that_present_colFamily))
++        return false;
++      if (!this.colFamily.equals(that.colFamily))
++        return false;
++    }
++
++    boolean this_present_colQualifier = true && this.isSetColQualifier();
++    boolean that_present_colQualifier = true && that.isSetColQualifier();
++    if (this_present_colQualifier || that_present_colQualifier) {
++      if (!(this_present_colQualifier && that_present_colQualifier))
++        return false;
++      if (!this.colQualifier.equals(that.colQualifier))
++        return false;
++    }
++
++    boolean this_present_colVisibility = true && this.isSetColVisibility();
++    boolean that_present_colVisibility = true && that.isSetColVisibility();
++    if (this_present_colVisibility || that_present_colVisibility) {
++      if (!(this_present_colVisibility && that_present_colVisibility))
++        return false;
++      if (!this.colVisibility.equals(that.colVisibility))
++        return false;
++    }
++
++    boolean this_present_timestamp = true && this.isSetTimestamp();
++    boolean that_present_timestamp = true && that.isSetTimestamp();
++    if (this_present_timestamp || that_present_timestamp) {
++      if (!(this_present_timestamp && that_present_timestamp))
++        return false;
++      if (this.timestamp != that.timestamp)
++        return false;
++    }
++
++    boolean this_present_value = true && this.isSetValue();
++    boolean that_present_value = true && that.isSetValue();
++    if (this_present_value || that_present_value) {
++      if (!(this_present_value && that_present_value))
++        return false;
++      if (!this.value.equals(that.value))
++        return false;
++    }
++
++    return true;
++  }
++
++  @Override
++  public int hashCode() {
++    return 0;
++  }
++
++  public int compareTo(PColumnUpdate other) {
++    if (!getClass().equals(other.getClass())) {
++      return getClass().getName().compareTo(other.getClass().getName());
++    }
++
++    int lastComparison = 0;
++    PColumnUpdate typedOther = (PColumnUpdate)other;
++
++    lastComparison = Boolean.valueOf(isSetColFamily()).compareTo(typedOther.isSetColFamily());
++    if (lastComparison != 0) {
++      return lastComparison;
++    }
++    if (isSetColFamily()) {
++      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.colFamily, typedOther.colFamily);
++      if (lastComparison != 0) {
++        return lastComparison;
++      }
++    }
++    lastComparison = Boolean.valueOf(isSetColQualifier()).compareTo(typedOther.isSetColQualifier());
++    if (lastComparison != 0) {
++      return lastComparison;
++    }
++    if (isSetColQualifier()) {
++      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.colQualifier, typedOther.colQualifier);
++      if (lastComparison != 0) {
++        return lastComparison;
++      }
++    }
++    lastComparison = Boolean.valueOf(isSetColVisibility()).compareTo(typedOther.isSetColVisibility());
++    if (lastComparison != 0) {
++      return lastComparison;
++    }
++    if (isSetColVisibility()) {
++      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.colVisibility, typedOther.colVisibility);
++      if (lastComparison != 0) {
++        return lastComparison;
++      }
++    }
++    lastComparison = Boolean.valueOf(isSetTimestamp()).compareTo(typedOther.isSetTimestamp());
++    if (lastComparison != 0) {
++      return lastComparison;
++    }
++    if (isSetTimestamp()) {
++      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.timestamp, typedOther.timestamp);
++      if (lastComparison != 0) {
++        return lastComparison;
++      }
++    }
++    lastComparison = Boolean.valueOf(isSetValue()).compareTo(typedOther.isSetValue());
++    if (lastComparison != 0) {
++      return lastComparison;
++    }
++    if (isSetValue()) {
++      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.value, typedOther.value);
++      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("PColumnUpdate(");
++    boolean first = true;
++
++    sb.append("colFamily:");
++    if (this.colFamily == null) {
++      sb.append("null");
++    } else {
++      org.apache.thrift.TBaseHelper.toString(this.colFamily, sb);
++    }
++    first = false;
++    if (!first) sb.append(", ");
++    sb.append("colQualifier:");
++    if (this.colQualifier == null) {
++      sb.append("null");
++    } else {
++      org.apache.thrift.TBaseHelper.toString(this.colQualifier, sb);
++    }
++    first = false;
++    if (isSetColVisibility()) {
++      if (!first) sb.append(", ");
++      sb.append("colVisibility:");
++      if (this.colVisibility == null) {
++        sb.append("null");
++      } else {
++        org.apache.thrift.TBaseHelper.toString(this.colVisibility, sb);
++      }
++      first = false;
++    }
++    if (isSetTimestamp()) {
++      if (!first) sb.append(", ");
++      sb.append("timestamp:");
++      sb.append(this.timestamp);
++      first = false;
++    }
++    if (!first) sb.append(", ");
++    sb.append("value:");
++    if (this.value == null) {
++      sb.append("null");
++    } else {
++      org.apache.thrift.TBaseHelper.toString(this.value, sb);
++    }
++    first = false;
++    sb.append(")");
++    return sb.toString();
++  }
++
++  public void validate() throws org.apache.thrift.TException {
++    // check for required fields
++    // check for sub-struct validity
++  }
++
++  private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
++    try {
++      write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
++    } catch (org.apache.thrift.TException te) {
++      throw new java.io.IOException(te);
++    }
++  }
++
++  private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
++    try {
++      // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
++      __isset_bitfield = 0;
++      read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
++    } catch (org.apache.thrift.TException te) {
++      throw new java.io.IOException(te);
++    }
++  }
++
++  private static class PColumnUpdateStandardSchemeFactory implements SchemeFactory {
++    public PColumnUpdateStandardScheme getScheme() {
++      return new PColumnUpdateStandardScheme();
++    }
++  }
++
++  private static class PColumnUpdateStandardScheme extends StandardScheme<PColumnUpdate> {
++
++    public void read(org.apache.thrift.protocol.TProtocol iprot, PColumnUpdate 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: // COL_FAMILY
++            if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
++              struct.colFamily = iprot.readBinary();
++              struct.setColFamilyIsSet(true);
++            } else { 
++              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
++            }
++            break;
++          case 2: // COL_QUALIFIER
++            if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
++              struct.colQualifier = iprot.readBinary();
++              struct.setColQualifierIsSet(true);
++            } else { 
++              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
++            }
++            break;
++          case 3: // COL_VISIBILITY
++            if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
++              struct.colVisibility = iprot.readBinary();
++              struct.setColVisibilityIsSet(true);
++            } else { 
++              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
++            }
++            break;
++          case 4: // TIMESTAMP
++            if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
++              struct.timestamp = iprot.readI64();
++              struct.setTimestampIsSet(true);
++            } else { 
++              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
++            }
++            break;
++          case 5: // VALUE
++            if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
++              struct.value = iprot.readBinary();
++              struct.setValueIsSet(true);
++            } else { 
++              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
++            }
++            break;
++          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, PColumnUpdate struct) throws org.apache.thrift.TException {
++      struct.validate();
++
++      oprot.writeStructBegin(STRUCT_DESC);
++      if (struct.colFamily != null) {
++        oprot.writeFieldBegin(COL_FAMILY_FIELD_DESC);
++        oprot.writeBinary(struct.colFamily);
++        oprot.writeFieldEnd();
++      }
++      if (struct.colQualifier != null) {
++        oprot.writeFieldBegin(COL_QUALIFIER_FIELD_DESC);
++        oprot.writeBinary(struct.colQualifier);
++        oprot.writeFieldEnd();
++      }
++      if (struct.colVisibility != null) {
++        if (struct.isSetColVisibility()) {
++          oprot.writeFieldBegin(COL_VISIBILITY_FIELD_DESC);
++          oprot.writeBinary(struct.colVisibility);
++          oprot.writeFieldEnd();
++        }
++      }
++      if (struct.isSetTimestamp()) {
++        oprot.writeFieldBegin(TIMESTAMP_FIELD_DESC);
++        oprot.writeI64(struct.timestamp);
++        oprot.writeFieldEnd();
++      }
++      if (struct.value != null) {
++        oprot.writeFieldBegin(VALUE_FIELD_DESC);
++        oprot.writeBinary(struct.value);
++        oprot.writeFieldEnd();
++      }
++      oprot.writeFieldStop();
++      oprot.writeStructEnd();
++    }
++
++  }
++
++  private static class PColumnUpdateTupleSchemeFactory implements SchemeFactory {
++    public PColumnUpdateTupleScheme getScheme() {
++      return new PColumnUpdateTupleScheme();
++    }
++  }
++
++  private static class PColumnUpdateTupleScheme extends TupleScheme<PColumnUpdate> {
++
++    @Override
++    public void write(org.apache.thrift.protocol.TProtocol prot, PColumnUpdate struct) throws org.apache.thrift.TException {
++      TTupleProtocol oprot = (TTupleProtocol) prot;
++      BitSet optionals = new BitSet();
++      if (struct.isSetColFamily()) {
++        optionals.set(0);
++      }
++      if (struct.isSetColQualifier()) {
++        optionals.set(1);
++      }
++      if (struct.isSetColVisibility()) {
++        optionals.set(2);
++      }
++      if (struct.isSetTimestamp()) {
++        optionals.set(3);
++      }
++      if (struct.isSetValue()) {
++        optionals.set(4);
++      }
++      oprot.writeBitSet(optionals, 5);
++      if (struct.isSetColFamily()) {
++        oprot.writeBinary(struct.colFamily);
++      }
++      if (struct.isSetColQualifier()) {
++        oprot.writeBinary(struct.colQualifier);
++      }
++      if (struct.isSetColVisibility()) {
++        oprot.writeBinary(struct.colVisibility);
++      }
++      if (struct.isSetTimestamp()) {
++        oprot.writeI64(struct.timestamp);
++      }
++      if (struct.isSetValue()) {
++        oprot.writeBinary(struct.value);
++      }
++    }
++
++    @Override
++    public void read(org.apache.thrift.protocol.TProtocol prot, PColumnUpdate struct) throws org.apache.thrift.TException {
++      TTupleProtocol iprot = (TTupleProtocol) prot;
++      BitSet incoming = iprot.readBitSet(5);
++      if (incoming.get(0)) {
++        struct.colFamily = iprot.readBinary();
++        struct.setColFamilyIsSet(true);
++      }
++      if (incoming.get(1)) {
++        struct.colQualifier = iprot.readBinary();
++        struct.setColQualifierIsSet(true);
++      }
++      if (incoming.get(2)) {
++        struct.colVisibility = iprot.readBinary();
++        struct.setColVisibilityIsSet(true);
++      }
++      if (incoming.get(3)) {
++        struct.timestamp = iprot.readI64();
++        struct.setTimestampIsSet(true);
++      }
++      if (incoming.get(4)) {
++        struct.value = iprot.readBinary();
++        struct.setValueIsSet(true);
++      }
++    }
++  }
++
++}
++


Mime
View raw message