incubator-accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vi...@apache.org
Subject svn commit: r1189806 [19/46] - in /incubator/accumulo: branches/1.3/contrib/ branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/ branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/admin/ branches/1.3/src/core/src/main/...
Date Thu, 27 Oct 2011 15:25:17 GMT
Modified: incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/MutationLogger.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/MutationLogger.java?rev=1189806&r1=1189805&r2=1189806&view=diff
==============================================================================
--- incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/MutationLogger.java (original)
+++ incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/MutationLogger.java Thu Oct 27 15:24:51 2011
@@ -5,83 +5,85 @@
  */
 package org.apache.accumulo.core.tabletserver.thrift;
 
-
-
 import org.apache.thrift.*;
 import org.apache.thrift.meta_data.*;
 import org.apache.thrift.protocol.*;
 
 public class MutationLogger {
-
+  
   public interface Iface {
-
-    public LogFile create(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tserverSession) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
-
-    public void defineTablet(cloudtrace.thrift.TInfo tinfo, long id, long seq, int tid, org.apache.accumulo.core.data.thrift.TKeyExtent tablet) throws NoSuchLogIDException, TException;
-
-    public void log(cloudtrace.thrift.TInfo tinfo, long id, long seq, int tid, org.apache.accumulo.core.data.thrift.TMutation mutation) throws NoSuchLogIDException, TException;
-
+    
+    public LogFile create(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tserverSession)
+        throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
+    
+    public void defineTablet(cloudtrace.thrift.TInfo tinfo, long id, long seq, int tid, org.apache.accumulo.core.data.thrift.TKeyExtent tablet)
+        throws NoSuchLogIDException, TException;
+    
+    public void log(cloudtrace.thrift.TInfo tinfo, long id, long seq, int tid, org.apache.accumulo.core.data.thrift.TMutation mutation)
+        throws NoSuchLogIDException, TException;
+    
     public void logManyTablets(cloudtrace.thrift.TInfo tinfo, long id, java.util.List<TabletMutations> mutations) throws NoSuchLogIDException, TException;
-
+    
     public void minorCompactionStarted(cloudtrace.thrift.TInfo tinfo, long id, long seq, int tid, String fqfn) throws NoSuchLogIDException, TException;
-
+    
     public void minorCompactionFinished(cloudtrace.thrift.TInfo tinfo, long id, long seq, int tid, String fqfn) throws NoSuchLogIDException, TException;
-
+    
     public void close(cloudtrace.thrift.TInfo tinfo, long id) throws NoSuchLogIDException, TException;
-
-    public long startCopy(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String name, String fullyQualifiedFileName, boolean sort) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
-
-    public java.util.List<String> getClosedLogs(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
-
-    public void remove(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, java.util.List<String> files) throws TException;
-
+    
+    public long startCopy(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String name,
+        String fullyQualifiedFileName, boolean sort) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
+    
+    public java.util.List<String> getClosedLogs(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials)
+        throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
+    
+    public void remove(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, java.util.List<String> files)
+        throws TException;
+    
   }
-
+  
   public static class Client implements TServiceClient, Iface {
     public static class Factory implements TServiceClientFactory<Client> {
       public Factory() {}
+      
       public Client getClient(TProtocol prot) {
         return new Client(prot);
       }
+      
       public Client getClient(TProtocol iprot, TProtocol oprot) {
         return new Client(iprot, oprot);
       }
     }
-
-    public Client(TProtocol prot)
-    {
+    
+    public Client(TProtocol prot) {
       this(prot, prot);
     }
-
-    public Client(TProtocol iprot, TProtocol oprot)
-    {
+    
+    public Client(TProtocol iprot, TProtocol oprot) {
       iprot_ = iprot;
       oprot_ = oprot;
     }
-
+    
     protected TProtocol iprot_;
     protected TProtocol oprot_;
-
+    
     protected int seqid_;
-
-    public TProtocol getInputProtocol()
-    {
+    
+    public TProtocol getInputProtocol() {
       return this.iprot_;
     }
-
-    public TProtocol getOutputProtocol()
-    {
+    
+    public TProtocol getOutputProtocol() {
       return this.oprot_;
     }
-
-    public LogFile create(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tserverSession) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
-    {
+    
+    public LogFile create(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tserverSession)
+        throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
       send_create(tinfo, credentials, tserverSession);
       return recv_create();
     }
-
-    public void send_create(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tserverSession) throws TException
-    {
+    
+    public void send_create(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tserverSession)
+        throws TException {
       oprot_.writeMessageBegin(new TMessage("create", TMessageType.CALL, ++seqid_));
       create_args args = new create_args();
       args.setTinfo(tinfo);
@@ -91,9 +93,8 @@ public class MutationLogger {
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
     }
-
-    public LogFile recv_create() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
-    {
+    
+    public LogFile recv_create() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
       TMessage msg = iprot_.readMessageBegin();
       if (msg.type == TMessageType.EXCEPTION) {
         TApplicationException x = TApplicationException.read(iprot_);
@@ -114,15 +115,15 @@ public class MutationLogger {
       }
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "create failed: unknown result");
     }
-
-    public void defineTablet(cloudtrace.thrift.TInfo tinfo, long id, long seq, int tid, org.apache.accumulo.core.data.thrift.TKeyExtent tablet) throws NoSuchLogIDException, TException
-    {
+    
+    public void defineTablet(cloudtrace.thrift.TInfo tinfo, long id, long seq, int tid, org.apache.accumulo.core.data.thrift.TKeyExtent tablet)
+        throws NoSuchLogIDException, TException {
       send_defineTablet(tinfo, id, seq, tid, tablet);
       recv_defineTablet();
     }
-
-    public void send_defineTablet(cloudtrace.thrift.TInfo tinfo, long id, long seq, int tid, org.apache.accumulo.core.data.thrift.TKeyExtent tablet) throws TException
-    {
+    
+    public void send_defineTablet(cloudtrace.thrift.TInfo tinfo, long id, long seq, int tid, org.apache.accumulo.core.data.thrift.TKeyExtent tablet)
+        throws TException {
       oprot_.writeMessageBegin(new TMessage("defineTablet", TMessageType.CALL, ++seqid_));
       defineTablet_args args = new defineTablet_args();
       args.setTinfo(tinfo);
@@ -134,9 +135,8 @@ public class MutationLogger {
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
     }
-
-    public void recv_defineTablet() throws NoSuchLogIDException, TException
-    {
+    
+    public void recv_defineTablet() throws NoSuchLogIDException, TException {
       TMessage msg = iprot_.readMessageBegin();
       if (msg.type == TMessageType.EXCEPTION) {
         TApplicationException x = TApplicationException.read(iprot_);
@@ -154,15 +154,14 @@ public class MutationLogger {
       }
       return;
     }
-
-    public void log(cloudtrace.thrift.TInfo tinfo, long id, long seq, int tid, org.apache.accumulo.core.data.thrift.TMutation mutation) throws NoSuchLogIDException, TException
-    {
+    
+    public void log(cloudtrace.thrift.TInfo tinfo, long id, long seq, int tid, org.apache.accumulo.core.data.thrift.TMutation mutation)
+        throws NoSuchLogIDException, TException {
       send_log(tinfo, id, seq, tid, mutation);
       recv_log();
     }
-
-    public void send_log(cloudtrace.thrift.TInfo tinfo, long id, long seq, int tid, org.apache.accumulo.core.data.thrift.TMutation mutation) throws TException
-    {
+    
+    public void send_log(cloudtrace.thrift.TInfo tinfo, long id, long seq, int tid, org.apache.accumulo.core.data.thrift.TMutation mutation) throws TException {
       oprot_.writeMessageBegin(new TMessage("log", TMessageType.CALL, ++seqid_));
       log_args args = new log_args();
       args.setTinfo(tinfo);
@@ -174,9 +173,8 @@ public class MutationLogger {
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
     }
-
-    public void recv_log() throws NoSuchLogIDException, TException
-    {
+    
+    public void recv_log() throws NoSuchLogIDException, TException {
       TMessage msg = iprot_.readMessageBegin();
       if (msg.type == TMessageType.EXCEPTION) {
         TApplicationException x = TApplicationException.read(iprot_);
@@ -194,15 +192,13 @@ public class MutationLogger {
       }
       return;
     }
-
-    public void logManyTablets(cloudtrace.thrift.TInfo tinfo, long id, java.util.List<TabletMutations> mutations) throws NoSuchLogIDException, TException
-    {
+    
+    public void logManyTablets(cloudtrace.thrift.TInfo tinfo, long id, java.util.List<TabletMutations> mutations) throws NoSuchLogIDException, TException {
       send_logManyTablets(tinfo, id, mutations);
       recv_logManyTablets();
     }
-
-    public void send_logManyTablets(cloudtrace.thrift.TInfo tinfo, long id, java.util.List<TabletMutations> mutations) throws TException
-    {
+    
+    public void send_logManyTablets(cloudtrace.thrift.TInfo tinfo, long id, java.util.List<TabletMutations> mutations) throws TException {
       oprot_.writeMessageBegin(new TMessage("logManyTablets", TMessageType.CALL, ++seqid_));
       logManyTablets_args args = new logManyTablets_args();
       args.setTinfo(tinfo);
@@ -212,9 +208,8 @@ public class MutationLogger {
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
     }
-
-    public void recv_logManyTablets() throws NoSuchLogIDException, TException
-    {
+    
+    public void recv_logManyTablets() throws NoSuchLogIDException, TException {
       TMessage msg = iprot_.readMessageBegin();
       if (msg.type == TMessageType.EXCEPTION) {
         TApplicationException x = TApplicationException.read(iprot_);
@@ -232,15 +227,13 @@ public class MutationLogger {
       }
       return;
     }
-
-    public void minorCompactionStarted(cloudtrace.thrift.TInfo tinfo, long id, long seq, int tid, String fqfn) throws NoSuchLogIDException, TException
-    {
+    
+    public void minorCompactionStarted(cloudtrace.thrift.TInfo tinfo, long id, long seq, int tid, String fqfn) throws NoSuchLogIDException, TException {
       send_minorCompactionStarted(tinfo, id, seq, tid, fqfn);
       recv_minorCompactionStarted();
     }
-
-    public void send_minorCompactionStarted(cloudtrace.thrift.TInfo tinfo, long id, long seq, int tid, String fqfn) throws TException
-    {
+    
+    public void send_minorCompactionStarted(cloudtrace.thrift.TInfo tinfo, long id, long seq, int tid, String fqfn) throws TException {
       oprot_.writeMessageBegin(new TMessage("minorCompactionStarted", TMessageType.CALL, ++seqid_));
       minorCompactionStarted_args args = new minorCompactionStarted_args();
       args.setTinfo(tinfo);
@@ -252,9 +245,8 @@ public class MutationLogger {
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
     }
-
-    public void recv_minorCompactionStarted() throws NoSuchLogIDException, TException
-    {
+    
+    public void recv_minorCompactionStarted() throws NoSuchLogIDException, TException {
       TMessage msg = iprot_.readMessageBegin();
       if (msg.type == TMessageType.EXCEPTION) {
         TApplicationException x = TApplicationException.read(iprot_);
@@ -272,15 +264,13 @@ public class MutationLogger {
       }
       return;
     }
-
-    public void minorCompactionFinished(cloudtrace.thrift.TInfo tinfo, long id, long seq, int tid, String fqfn) throws NoSuchLogIDException, TException
-    {
+    
+    public void minorCompactionFinished(cloudtrace.thrift.TInfo tinfo, long id, long seq, int tid, String fqfn) throws NoSuchLogIDException, TException {
       send_minorCompactionFinished(tinfo, id, seq, tid, fqfn);
       recv_minorCompactionFinished();
     }
-
-    public void send_minorCompactionFinished(cloudtrace.thrift.TInfo tinfo, long id, long seq, int tid, String fqfn) throws TException
-    {
+    
+    public void send_minorCompactionFinished(cloudtrace.thrift.TInfo tinfo, long id, long seq, int tid, String fqfn) throws TException {
       oprot_.writeMessageBegin(new TMessage("minorCompactionFinished", TMessageType.CALL, ++seqid_));
       minorCompactionFinished_args args = new minorCompactionFinished_args();
       args.setTinfo(tinfo);
@@ -292,9 +282,8 @@ public class MutationLogger {
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
     }
-
-    public void recv_minorCompactionFinished() throws NoSuchLogIDException, TException
-    {
+    
+    public void recv_minorCompactionFinished() throws NoSuchLogIDException, TException {
       TMessage msg = iprot_.readMessageBegin();
       if (msg.type == TMessageType.EXCEPTION) {
         TApplicationException x = TApplicationException.read(iprot_);
@@ -312,15 +301,13 @@ public class MutationLogger {
       }
       return;
     }
-
-    public void close(cloudtrace.thrift.TInfo tinfo, long id) throws NoSuchLogIDException, TException
-    {
+    
+    public void close(cloudtrace.thrift.TInfo tinfo, long id) throws NoSuchLogIDException, TException {
       send_close(tinfo, id);
       recv_close();
     }
-
-    public void send_close(cloudtrace.thrift.TInfo tinfo, long id) throws TException
-    {
+    
+    public void send_close(cloudtrace.thrift.TInfo tinfo, long id) throws TException {
       oprot_.writeMessageBegin(new TMessage("close", TMessageType.CALL, ++seqid_));
       close_args args = new close_args();
       args.setTinfo(tinfo);
@@ -329,9 +316,8 @@ public class MutationLogger {
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
     }
-
-    public void recv_close() throws NoSuchLogIDException, TException
-    {
+    
+    public void recv_close() throws NoSuchLogIDException, TException {
       TMessage msg = iprot_.readMessageBegin();
       if (msg.type == TMessageType.EXCEPTION) {
         TApplicationException x = TApplicationException.read(iprot_);
@@ -349,15 +335,15 @@ public class MutationLogger {
       }
       return;
     }
-
-    public long startCopy(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String name, String fullyQualifiedFileName, boolean sort) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
-    {
+    
+    public long startCopy(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String name,
+        String fullyQualifiedFileName, boolean sort) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
       send_startCopy(tinfo, credentials, name, fullyQualifiedFileName, sort);
       return recv_startCopy();
     }
-
-    public void send_startCopy(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String name, String fullyQualifiedFileName, boolean sort) throws TException
-    {
+    
+    public void send_startCopy(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String name,
+        String fullyQualifiedFileName, boolean sort) throws TException {
       oprot_.writeMessageBegin(new TMessage("startCopy", TMessageType.CALL, ++seqid_));
       startCopy_args args = new startCopy_args();
       args.setTinfo(tinfo);
@@ -369,9 +355,8 @@ public class MutationLogger {
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
     }
-
-    public long recv_startCopy() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
-    {
+    
+    public long recv_startCopy() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
       TMessage msg = iprot_.readMessageBegin();
       if (msg.type == TMessageType.EXCEPTION) {
         TApplicationException x = TApplicationException.read(iprot_);
@@ -392,15 +377,14 @@ public class MutationLogger {
       }
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "startCopy failed: unknown result");
     }
-
-    public java.util.List<String> getClosedLogs(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
-    {
+    
+    public java.util.List<String> getClosedLogs(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials)
+        throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
       send_getClosedLogs(tinfo, credentials);
       return recv_getClosedLogs();
     }
-
-    public void send_getClosedLogs(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws TException
-    {
+    
+    public void send_getClosedLogs(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws TException {
       oprot_.writeMessageBegin(new TMessage("getClosedLogs", TMessageType.CALL, ++seqid_));
       getClosedLogs_args args = new getClosedLogs_args();
       args.setTinfo(tinfo);
@@ -409,9 +393,8 @@ public class MutationLogger {
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
     }
-
-    public java.util.List<String> recv_getClosedLogs() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
-    {
+    
+    public java.util.List<String> recv_getClosedLogs() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
       TMessage msg = iprot_.readMessageBegin();
       if (msg.type == TMessageType.EXCEPTION) {
         TApplicationException x = TApplicationException.read(iprot_);
@@ -432,14 +415,14 @@ public class MutationLogger {
       }
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "getClosedLogs failed: unknown result");
     }
-
-    public void remove(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, java.util.List<String> files) throws TException
-    {
+    
+    public void remove(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, java.util.List<String> files)
+        throws TException {
       send_remove(tinfo, credentials, files);
     }
-
-    public void send_remove(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, java.util.List<String> files) throws TException
-    {
+    
+    public void send_remove(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, java.util.List<String> files)
+        throws TException {
       oprot_.writeMessageBegin(new TMessage("remove", TMessageType.CALL, ++seqid_));
       remove_args args = new remove_args();
       args.setTinfo(tinfo);
@@ -449,12 +432,13 @@ public class MutationLogger {
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
     }
-
+    
   }
+  
   public static class Processor implements TProcessor {
     private static final org.slf4j.Logger LOGGER = org.slf4j.LoggerFactory.getLogger(Processor.class.getName());
-    public Processor(Iface iface)
-    {
+    
+    public Processor(Iface iface) {
       iface_ = iface;
       processMap_.put("create", new create());
       processMap_.put("defineTablet", new defineTablet());
@@ -467,22 +451,21 @@ public class MutationLogger {
       processMap_.put("getClosedLogs", new getClosedLogs());
       processMap_.put("remove", new remove());
     }
-
+    
     protected static interface ProcessFunction {
       public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException;
     }
-
+    
     private Iface iface_;
     protected final java.util.HashMap<String,ProcessFunction> processMap_ = new java.util.HashMap<String,ProcessFunction>();
-
-    public boolean process(TProtocol iprot, TProtocol oprot) throws TException
-    {
+    
+    public boolean process(TProtocol iprot, TProtocol oprot) throws TException {
       TMessage msg = iprot.readMessageBegin();
       ProcessFunction fn = processMap_.get(msg.name);
       if (fn == null) {
         TProtocolUtil.skip(iprot, TType.STRUCT);
         iprot.readMessageEnd();
-        TApplicationException x = new TApplicationException(TApplicationException.UNKNOWN_METHOD, "Invalid method name: '"+msg.name+"'");
+        TApplicationException x = new TApplicationException(TApplicationException.UNKNOWN_METHOD, "Invalid method name: '" + msg.name + "'");
         oprot.writeMessageBegin(new TMessage(msg.name, TMessageType.EXCEPTION, msg.seqid));
         x.write(oprot);
         oprot.writeMessageEnd();
@@ -492,10 +475,9 @@ public class MutationLogger {
       fn.process(msg.seqid, iprot, oprot);
       return true;
     }
-
+    
     private class create implements ProcessFunction {
-      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
-      {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
         create_args args = new create_args();
         try {
           args.read(iprot);
@@ -528,12 +510,11 @@ public class MutationLogger {
         oprot.writeMessageEnd();
         oprot.getTransport().flush();
       }
-
+      
     }
-
+    
     private class defineTablet implements ProcessFunction {
-      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
-      {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
         defineTablet_args args = new defineTablet_args();
         try {
           args.read(iprot);
@@ -566,12 +547,11 @@ public class MutationLogger {
         oprot.writeMessageEnd();
         oprot.getTransport().flush();
       }
-
+      
     }
-
+    
     private class log implements ProcessFunction {
-      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
-      {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
         log_args args = new log_args();
         try {
           args.read(iprot);
@@ -604,12 +584,11 @@ public class MutationLogger {
         oprot.writeMessageEnd();
         oprot.getTransport().flush();
       }
-
+      
     }
-
+    
     private class logManyTablets implements ProcessFunction {
-      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
-      {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
         logManyTablets_args args = new logManyTablets_args();
         try {
           args.read(iprot);
@@ -642,12 +621,11 @@ public class MutationLogger {
         oprot.writeMessageEnd();
         oprot.getTransport().flush();
       }
-
+      
     }
-
+    
     private class minorCompactionStarted implements ProcessFunction {
-      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
-      {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
         minorCompactionStarted_args args = new minorCompactionStarted_args();
         try {
           args.read(iprot);
@@ -680,12 +658,11 @@ public class MutationLogger {
         oprot.writeMessageEnd();
         oprot.getTransport().flush();
       }
-
+      
     }
-
+    
     private class minorCompactionFinished implements ProcessFunction {
-      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
-      {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
         minorCompactionFinished_args args = new minorCompactionFinished_args();
         try {
           args.read(iprot);
@@ -718,12 +695,11 @@ public class MutationLogger {
         oprot.writeMessageEnd();
         oprot.getTransport().flush();
       }
-
+      
     }
-
+    
     private class close implements ProcessFunction {
-      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
-      {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
         close_args args = new close_args();
         try {
           args.read(iprot);
@@ -756,12 +732,11 @@ public class MutationLogger {
         oprot.writeMessageEnd();
         oprot.getTransport().flush();
       }
-
+      
     }
-
+    
     private class startCopy implements ProcessFunction {
-      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
-      {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
         startCopy_args args = new startCopy_args();
         try {
           args.read(iprot);
@@ -795,12 +770,11 @@ public class MutationLogger {
         oprot.writeMessageEnd();
         oprot.getTransport().flush();
       }
-
+      
     }
-
+    
     private class getClosedLogs implements ProcessFunction {
-      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
-      {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
         getClosedLogs_args args = new getClosedLogs_args();
         try {
           args.read(iprot);
@@ -833,12 +807,11 @@ public class MutationLogger {
         oprot.writeMessageEnd();
         oprot.getTransport().flush();
       }
-
+      
     }
-
+    
     private class remove implements ProcessFunction {
-      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
-      {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
         remove_args args = new remove_args();
         try {
           args.read(iprot);
@@ -856,40 +829,38 @@ public class MutationLogger {
         return;
       }
     }
-
+    
   }
-
+  
   @SuppressWarnings("serial")
-  public static class create_args implements TBase<create_args, create_args._Fields>, java.io.Serializable, Cloneable   {
+  public static class create_args implements TBase<create_args,create_args._Fields>, java.io.Serializable, Cloneable {
     private static final TStruct STRUCT_DESC = new TStruct("create_args");
-
-    private static final TField TINFO_FIELD_DESC = new TField("tinfo", TType.STRUCT, (short)3);
-    private static final TField CREDENTIALS_FIELD_DESC = new TField("credentials", TType.STRUCT, (short)1);
-    private static final TField TSERVER_SESSION_FIELD_DESC = new TField("tserverSession", TType.STRING, (short)2);
-
+    
+    private static final TField TINFO_FIELD_DESC = new TField("tinfo", TType.STRUCT, (short) 3);
+    private static final TField CREDENTIALS_FIELD_DESC = new TField("credentials", TType.STRUCT, (short) 1);
+    private static final TField TSERVER_SESSION_FIELD_DESC = new TField("tserverSession", TType.STRING, (short) 2);
+    
     public cloudtrace.thrift.TInfo tinfo;
     public org.apache.accumulo.core.security.thrift.AuthInfo credentials;
     public String tserverSession;
-
+    
     /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
     public enum _Fields implements TFieldIdEnum {
-      TINFO((short)3, "tinfo"),
-      CREDENTIALS((short)1, "credentials"),
-      TSERVER_SESSION((short)2, "tserverSession");
-
-      private static final java.util.Map<String, _Fields> byName = new java.util.HashMap<String, _Fields>();
-
+      TINFO((short) 3, "tinfo"), CREDENTIALS((short) 1, "credentials"), TSERVER_SESSION((short) 2, "tserverSession");
+      
+      private static final java.util.Map<String,_Fields> byName = new java.util.HashMap<String,_Fields>();
+      
       static {
         for (_Fields field : java.util.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) {
+        switch (fieldId) {
           case 3: // TINFO
             return TINFO;
           case 1: // CREDENTIALS
@@ -900,70 +871,63 @@ public class MutationLogger {
             return null;
         }
       }
-
+      
       /**
-       * Find the _Fields constant that matches fieldId, throwing an exception
-       * if it is not found.
+       * 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!");
+        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 java.util.Map<_Fields, FieldMetaData> metaDataMap;
+    
+    public static final java.util.Map<_Fields,FieldMetaData> metaDataMap;
     static {
-      java.util.Map<_Fields, FieldMetaData> tmpMap = new java.util.EnumMap<_Fields, FieldMetaData>(_Fields.class);
-      tmpMap.put(_Fields.TINFO, new FieldMetaData("tinfo", TFieldRequirementType.DEFAULT, 
-          new StructMetaData(TType.STRUCT, cloudtrace.thrift.TInfo.class)));
-      tmpMap.put(_Fields.CREDENTIALS, new FieldMetaData("credentials", TFieldRequirementType.DEFAULT, 
-          new StructMetaData(TType.STRUCT, org.apache.accumulo.core.security.thrift.AuthInfo.class)));
-      tmpMap.put(_Fields.TSERVER_SESSION, new FieldMetaData("tserverSession", TFieldRequirementType.DEFAULT, 
-          new FieldValueMetaData(TType.STRING)));
+      java.util.Map<_Fields,FieldMetaData> tmpMap = new java.util.EnumMap<_Fields,FieldMetaData>(_Fields.class);
+      tmpMap.put(_Fields.TINFO, new FieldMetaData("tinfo", TFieldRequirementType.DEFAULT, new StructMetaData(TType.STRUCT, cloudtrace.thrift.TInfo.class)));
+      tmpMap.put(_Fields.CREDENTIALS, new FieldMetaData("credentials", TFieldRequirementType.DEFAULT, new StructMetaData(TType.STRUCT,
+          org.apache.accumulo.core.security.thrift.AuthInfo.class)));
+      tmpMap.put(_Fields.TSERVER_SESSION, new FieldMetaData("tserverSession", TFieldRequirementType.DEFAULT, new FieldValueMetaData(TType.STRING)));
       metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
       FieldMetaData.addStructMetaDataMap(create_args.class, metaDataMap);
     }
-
-    public create_args() {
-    }
-
-    public create_args(
-      cloudtrace.thrift.TInfo tinfo,
-      org.apache.accumulo.core.security.thrift.AuthInfo credentials,
-      String tserverSession)
-    {
+    
+    public create_args() {}
+    
+    public create_args(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tserverSession) {
       this();
       this.tinfo = tinfo;
       this.credentials = credentials;
       this.tserverSession = tserverSession;
     }
-
+    
     /**
      * Performs a deep copy on <i>other</i>.
      */
@@ -978,170 +942,170 @@ public class MutationLogger {
         this.tserverSession = other.tserverSession;
       }
     }
-
+    
     public create_args deepCopy() {
       return new create_args(this);
     }
-
+    
     @Deprecated
     public create_args clone() {
       return new create_args(this);
     }
-
+    
     public cloudtrace.thrift.TInfo getTinfo() {
       return this.tinfo;
     }
-
+    
     public create_args setTinfo(cloudtrace.thrift.TInfo tinfo) {
       this.tinfo = tinfo;
       return this;
     }
-
+    
     public void unsetTinfo() {
       this.tinfo = null;
     }
-
+    
     /** Returns true if field tinfo is set (has been asigned a value) and false otherwise */
     public boolean isSetTinfo() {
       return this.tinfo != null;
     }
-
+    
     public void setTinfoIsSet(boolean value) {
       if (!value) {
         this.tinfo = null;
       }
     }
-
+    
     public org.apache.accumulo.core.security.thrift.AuthInfo getCredentials() {
       return this.credentials;
     }
-
+    
     public create_args setCredentials(org.apache.accumulo.core.security.thrift.AuthInfo credentials) {
       this.credentials = credentials;
       return this;
     }
-
+    
     public void unsetCredentials() {
       this.credentials = null;
     }
-
+    
     /** Returns true if field credentials is set (has been asigned a value) and false otherwise */
     public boolean isSetCredentials() {
       return this.credentials != null;
     }
-
+    
     public void setCredentialsIsSet(boolean value) {
       if (!value) {
         this.credentials = null;
       }
     }
-
+    
     public String getTserverSession() {
       return this.tserverSession;
     }
-
+    
     public create_args setTserverSession(String tserverSession) {
       this.tserverSession = tserverSession;
       return this;
     }
-
+    
     public void unsetTserverSession() {
       this.tserverSession = null;
     }
-
+    
     /** Returns true if field tserverSession is set (has been asigned a value) and false otherwise */
     public boolean isSetTserverSession() {
       return this.tserverSession != null;
     }
-
+    
     public void setTserverSessionIsSet(boolean value) {
       if (!value) {
         this.tserverSession = null;
       }
     }
-
+    
     public void setFieldValue(_Fields field, Object value) {
       switch (field) {
-      case TINFO:
-        if (value == null) {
-          unsetTinfo();
-        } else {
-          setTinfo((cloudtrace.thrift.TInfo)value);
-        }
-        break;
-
-      case CREDENTIALS:
-        if (value == null) {
-          unsetCredentials();
-        } else {
-          setCredentials((org.apache.accumulo.core.security.thrift.AuthInfo)value);
-        }
-        break;
-
-      case TSERVER_SESSION:
-        if (value == null) {
-          unsetTserverSession();
-        } else {
-          setTserverSession((String)value);
-        }
-        break;
-
+        case TINFO:
+          if (value == null) {
+            unsetTinfo();
+          } else {
+            setTinfo((cloudtrace.thrift.TInfo) value);
+          }
+          break;
+        
+        case CREDENTIALS:
+          if (value == null) {
+            unsetCredentials();
+          } else {
+            setCredentials((org.apache.accumulo.core.security.thrift.AuthInfo) value);
+          }
+          break;
+        
+        case TSERVER_SESSION:
+          if (value == null) {
+            unsetTserverSession();
+          } else {
+            setTserverSession((String) value);
+          }
+          break;
+      
       }
     }
-
+    
     public void setFieldValue(int fieldID, Object value) {
       setFieldValue(_Fields.findByThriftIdOrThrow(fieldID), value);
     }
-
+    
     public Object getFieldValue(_Fields field) {
       switch (field) {
-      case TINFO:
-        return getTinfo();
-
-      case CREDENTIALS:
-        return getCredentials();
-
-      case TSERVER_SESSION:
-        return getTserverSession();
-
+        case TINFO:
+          return getTinfo();
+          
+        case CREDENTIALS:
+          return getCredentials();
+          
+        case TSERVER_SESSION:
+          return getTserverSession();
+          
       }
       throw new IllegalStateException();
     }
-
+    
     public Object getFieldValue(int fieldId) {
       return getFieldValue(_Fields.findByThriftIdOrThrow(fieldId));
     }
-
+    
     /** Returns true if field corresponding to fieldID is set (has been asigned a value) and false otherwise */
     public boolean isSet(_Fields field) {
       switch (field) {
-      case TINFO:
-        return isSetTinfo();
-      case CREDENTIALS:
-        return isSetCredentials();
-      case TSERVER_SESSION:
-        return isSetTserverSession();
+        case TINFO:
+          return isSetTinfo();
+        case CREDENTIALS:
+          return isSetCredentials();
+        case TSERVER_SESSION:
+          return isSetTserverSession();
       }
       throw new IllegalStateException();
     }
-
+    
     public boolean isSet(int fieldID) {
       return isSet(_Fields.findByThriftIdOrThrow(fieldID));
     }
-
+    
     @Override
     public boolean equals(Object that) {
       if (that == null)
         return false;
       if (that instanceof create_args)
-        return this.equals((create_args)that);
+        return this.equals((create_args) that);
       return false;
     }
-
+    
     public boolean equals(create_args that) {
       if (that == null)
         return false;
-
+      
       boolean this_present_tinfo = true && this.isSetTinfo();
       boolean that_present_tinfo = true && that.isSetTinfo();
       if (this_present_tinfo || that_present_tinfo) {
@@ -1150,7 +1114,7 @@ public class MutationLogger {
         if (!this.tinfo.equals(that.tinfo))
           return false;
       }
-
+      
       boolean this_present_credentials = true && this.isSetCredentials();
       boolean that_present_credentials = true && that.isSetCredentials();
       if (this_present_credentials || that_present_credentials) {
@@ -1159,7 +1123,7 @@ public class MutationLogger {
         if (!this.credentials.equals(that.credentials))
           return false;
       }
-
+      
       boolean this_present_tserverSession = true && this.isSetTserverSession();
       boolean that_present_tserverSession = true && that.isSetTserverSession();
       if (this_present_tserverSession || that_present_tserverSession) {
@@ -1168,28 +1132,29 @@ public class MutationLogger {
         if (!this.tserverSession.equals(that.tserverSession))
           return false;
       }
-
+      
       return true;
     }
-
+    
     @Override
     public int hashCode() {
       return 0;
     }
-
+    
     public int compareTo(create_args other) {
       if (!getClass().equals(other.getClass())) {
         return getClass().getName().compareTo(other.getClass().getName());
       }
-
+      
       int lastComparison = 0;
-      create_args typedOther = (create_args)other;
-
+      create_args typedOther = (create_args) other;
+      
       lastComparison = Boolean.valueOf(isSetTinfo()).compareTo(typedOther.isSetTinfo());
       if (lastComparison != 0) {
         return lastComparison;
       }
-      if (isSetTinfo()) {        lastComparison = TBaseHelper.compareTo(this.tinfo, typedOther.tinfo);
+      if (isSetTinfo()) {
+        lastComparison = TBaseHelper.compareTo(this.tinfo, typedOther.tinfo);
         if (lastComparison != 0) {
           return lastComparison;
         }
@@ -1198,7 +1163,8 @@ public class MutationLogger {
       if (lastComparison != 0) {
         return lastComparison;
       }
-      if (isSetCredentials()) {        lastComparison = TBaseHelper.compareTo(this.credentials, typedOther.credentials);
+      if (isSetCredentials()) {
+        lastComparison = TBaseHelper.compareTo(this.credentials, typedOther.credentials);
         if (lastComparison != 0) {
           return lastComparison;
         }
@@ -1207,21 +1173,21 @@ public class MutationLogger {
       if (lastComparison != 0) {
         return lastComparison;
       }
-      if (isSetTserverSession()) {        lastComparison = TBaseHelper.compareTo(this.tserverSession, typedOther.tserverSession);
+      if (isSetTserverSession()) {
+        lastComparison = TBaseHelper.compareTo(this.tserverSession, typedOther.tserverSession);
         if (lastComparison != 0) {
           return lastComparison;
         }
       }
       return 0;
     }
-
+    
     public void read(TProtocol iprot) throws TException {
       TField field;
       iprot.readStructBegin();
-      while (true)
-      {
+      while (true) {
         field = iprot.readFieldBegin();
-        if (field.type == TType.STOP) { 
+        if (field.type == TType.STOP) {
           break;
         }
         switch (field.id) {
@@ -1229,7 +1195,7 @@ public class MutationLogger {
             if (field.type == TType.STRUCT) {
               this.tinfo = new cloudtrace.thrift.TInfo();
               this.tinfo.read(iprot);
-            } else { 
+            } else {
               TProtocolUtil.skip(iprot, field.type);
             }
             break;
@@ -1237,14 +1203,14 @@ public class MutationLogger {
             if (field.type == TType.STRUCT) {
               this.credentials = new org.apache.accumulo.core.security.thrift.AuthInfo();
               this.credentials.read(iprot);
-            } else { 
+            } else {
               TProtocolUtil.skip(iprot, field.type);
             }
             break;
           case 2: // TSERVER_SESSION
             if (field.type == TType.STRING) {
               this.tserverSession = iprot.readString();
-            } else { 
+            } else {
               TProtocolUtil.skip(iprot, field.type);
             }
             break;
@@ -1254,14 +1220,14 @@ public class MutationLogger {
         iprot.readFieldEnd();
       }
       iprot.readStructEnd();
-
+      
       // check for required fields of primitive type, which can't be checked in the validate method
       validate();
     }
-
+    
     public void write(TProtocol oprot) throws TException {
       validate();
-
+      
       oprot.writeStructBegin(STRUCT_DESC);
       if (this.credentials != null) {
         oprot.writeFieldBegin(CREDENTIALS_FIELD_DESC);
@@ -1281,7 +1247,7 @@ public class MutationLogger {
       oprot.writeFieldStop();
       oprot.writeStructEnd();
     }
-
+    
     @Override
     public String toString() {
       StringBuilder sb = new StringBuilder("create_args(");
@@ -1308,41 +1274,40 @@ public class MutationLogger {
       sb.append(")");
       return sb.toString();
     }
-
+    
     public void validate() throws TException {
       // check for required fields
     }
-
+    
   }
-
+  
   @SuppressWarnings("serial")
-  public static class create_result implements TBase<create_result, create_result._Fields>, java.io.Serializable, Cloneable   {
+  public static class create_result implements TBase<create_result,create_result._Fields>, java.io.Serializable, Cloneable {
     private static final TStruct STRUCT_DESC = new TStruct("create_result");
-
-    private static final TField SUCCESS_FIELD_DESC = new TField("success", TType.STRUCT, (short)0);
-    private static final TField SEC_FIELD_DESC = new TField("sec", TType.STRUCT, (short)1);
-
+    
+    private static final TField SUCCESS_FIELD_DESC = new TField("success", TType.STRUCT, (short) 0);
+    private static final TField SEC_FIELD_DESC = new TField("sec", TType.STRUCT, (short) 1);
+    
     public LogFile success;
     public org.apache.accumulo.core.security.thrift.ThriftSecurityException sec;
-
+    
     /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
     public enum _Fields implements TFieldIdEnum {
-      SUCCESS((short)0, "success"),
-      SEC((short)1, "sec");
-
-      private static final java.util.Map<String, _Fields> byName = new java.util.HashMap<String, _Fields>();
-
+      SUCCESS((short) 0, "success"), SEC((short) 1, "sec");
+      
+      private static final java.util.Map<String,_Fields> byName = new java.util.HashMap<String,_Fields>();
+      
       static {
         for (_Fields field : java.util.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) {
+        switch (fieldId) {
           case 0: // SUCCESS
             return SUCCESS;
           case 1: // SEC
@@ -1351,66 +1316,60 @@ public class MutationLogger {
             return null;
         }
       }
-
+      
       /**
-       * Find the _Fields constant that matches fieldId, throwing an exception
-       * if it is not found.
+       * 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!");
+        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 java.util.Map<_Fields, FieldMetaData> metaDataMap;
+    
+    public static final java.util.Map<_Fields,FieldMetaData> metaDataMap;
     static {
-      java.util.Map<_Fields, FieldMetaData> tmpMap = new java.util.EnumMap<_Fields, FieldMetaData>(_Fields.class);
-      tmpMap.put(_Fields.SUCCESS, new FieldMetaData("success", TFieldRequirementType.DEFAULT, 
-          new StructMetaData(TType.STRUCT, LogFile.class)));
-      tmpMap.put(_Fields.SEC, new FieldMetaData("sec", TFieldRequirementType.DEFAULT, 
-          new FieldValueMetaData(TType.STRUCT)));
+      java.util.Map<_Fields,FieldMetaData> tmpMap = new java.util.EnumMap<_Fields,FieldMetaData>(_Fields.class);
+      tmpMap.put(_Fields.SUCCESS, new FieldMetaData("success", TFieldRequirementType.DEFAULT, new StructMetaData(TType.STRUCT, LogFile.class)));
+      tmpMap.put(_Fields.SEC, new FieldMetaData("sec", TFieldRequirementType.DEFAULT, new FieldValueMetaData(TType.STRUCT)));
       metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
       FieldMetaData.addStructMetaDataMap(create_result.class, metaDataMap);
     }
-
-    public create_result() {
-    }
-
-    public create_result(
-      LogFile success,
-      org.apache.accumulo.core.security.thrift.ThriftSecurityException sec)
-    {
+    
+    public create_result() {}
+    
+    public create_result(LogFile success, org.apache.accumulo.core.security.thrift.ThriftSecurityException sec) {
       this();
       this.success = success;
       this.sec = sec;
     }
-
+    
     /**
      * Performs a deep copy on <i>other</i>.
      */
@@ -1422,133 +1381,133 @@ public class MutationLogger {
         this.sec = new org.apache.accumulo.core.security.thrift.ThriftSecurityException(other.sec);
       }
     }
-
+    
     public create_result deepCopy() {
       return new create_result(this);
     }
-
+    
     @Deprecated
     public create_result clone() {
       return new create_result(this);
     }
-
+    
     public LogFile getSuccess() {
       return this.success;
     }
-
+    
     public create_result setSuccess(LogFile success) {
       this.success = success;
       return this;
     }
-
+    
     public void unsetSuccess() {
       this.success = null;
     }
-
+    
     /** Returns true if field success is set (has been asigned a value) and false otherwise */
     public boolean isSetSuccess() {
       return this.success != null;
     }
-
+    
     public void setSuccessIsSet(boolean value) {
       if (!value) {
         this.success = null;
       }
     }
-
+    
     public org.apache.accumulo.core.security.thrift.ThriftSecurityException getSec() {
       return this.sec;
     }
-
+    
     public create_result setSec(org.apache.accumulo.core.security.thrift.ThriftSecurityException sec) {
       this.sec = sec;
       return this;
     }
-
+    
     public void unsetSec() {
       this.sec = null;
     }
-
+    
     /** Returns true if field sec is set (has been asigned a value) and false otherwise */
     public boolean isSetSec() {
       return this.sec != null;
     }
-
+    
     public void setSecIsSet(boolean value) {
       if (!value) {
         this.sec = null;
       }
     }
-
+    
     public void setFieldValue(_Fields field, Object value) {
       switch (field) {
-      case SUCCESS:
-        if (value == null) {
-          unsetSuccess();
-        } else {
-          setSuccess((LogFile)value);
-        }
-        break;
-
-      case SEC:
-        if (value == null) {
-          unsetSec();
-        } else {
-          setSec((org.apache.accumulo.core.security.thrift.ThriftSecurityException)value);
-        }
-        break;
-
+        case SUCCESS:
+          if (value == null) {
+            unsetSuccess();
+          } else {
+            setSuccess((LogFile) value);
+          }
+          break;
+        
+        case SEC:
+          if (value == null) {
+            unsetSec();
+          } else {
+            setSec((org.apache.accumulo.core.security.thrift.ThriftSecurityException) value);
+          }
+          break;
+      
       }
     }
-
+    
     public void setFieldValue(int fieldID, Object value) {
       setFieldValue(_Fields.findByThriftIdOrThrow(fieldID), value);
     }
-
+    
     public Object getFieldValue(_Fields field) {
       switch (field) {
-      case SUCCESS:
-        return getSuccess();
-
-      case SEC:
-        return getSec();
-
+        case SUCCESS:
+          return getSuccess();
+          
+        case SEC:
+          return getSec();
+          
       }
       throw new IllegalStateException();
     }
-
+    
     public Object getFieldValue(int fieldId) {
       return getFieldValue(_Fields.findByThriftIdOrThrow(fieldId));
     }
-
+    
     /** Returns true if field corresponding to fieldID is set (has been asigned a value) and false otherwise */
     public boolean isSet(_Fields field) {
       switch (field) {
-      case SUCCESS:
-        return isSetSuccess();
-      case SEC:
-        return isSetSec();
+        case SUCCESS:
+          return isSetSuccess();
+        case SEC:
+          return isSetSec();
       }
       throw new IllegalStateException();
     }
-
+    
     public boolean isSet(int fieldID) {
       return isSet(_Fields.findByThriftIdOrThrow(fieldID));
     }
-
+    
     @Override
     public boolean equals(Object that) {
       if (that == null)
         return false;
       if (that instanceof create_result)
-        return this.equals((create_result)that);
+        return this.equals((create_result) that);
       return false;
     }
-
+    
     public boolean equals(create_result that) {
       if (that == null)
         return false;
-
+      
       boolean this_present_success = true && this.isSetSuccess();
       boolean that_present_success = true && that.isSetSuccess();
       if (this_present_success || that_present_success) {
@@ -1557,7 +1516,7 @@ public class MutationLogger {
         if (!this.success.equals(that.success))
           return false;
       }
-
+      
       boolean this_present_sec = true && this.isSetSec();
       boolean that_present_sec = true && that.isSetSec();
       if (this_present_sec || that_present_sec) {
@@ -1566,28 +1525,29 @@ public class MutationLogger {
         if (!this.sec.equals(that.sec))
           return false;
       }
-
+      
       return true;
     }
-
+    
     @Override
     public int hashCode() {
       return 0;
     }
-
+    
     public int compareTo(create_result other) {
       if (!getClass().equals(other.getClass())) {
         return getClass().getName().compareTo(other.getClass().getName());
       }
-
+      
       int lastComparison = 0;
-      create_result typedOther = (create_result)other;
-
+      create_result typedOther = (create_result) other;
+      
       lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess());
       if (lastComparison != 0) {
         return lastComparison;
       }
-      if (isSetSuccess()) {        lastComparison = TBaseHelper.compareTo(this.success, typedOther.success);
+      if (isSetSuccess()) {
+        lastComparison = TBaseHelper.compareTo(this.success, typedOther.success);
         if (lastComparison != 0) {
           return lastComparison;
         }
@@ -1596,21 +1556,21 @@ public class MutationLogger {
       if (lastComparison != 0) {
         return lastComparison;
       }
-      if (isSetSec()) {        lastComparison = TBaseHelper.compareTo(this.sec, typedOther.sec);
+      if (isSetSec()) {
+        lastComparison = TBaseHelper.compareTo(this.sec, typedOther.sec);
         if (lastComparison != 0) {
           return lastComparison;
         }
       }
       return 0;
     }
-
+    
     public void read(TProtocol iprot) throws TException {
       TField field;
       iprot.readStructBegin();
-      while (true)
-      {
+      while (true) {
         field = iprot.readFieldBegin();
-        if (field.type == TType.STOP) { 
+        if (field.type == TType.STOP) {
           break;
         }
         switch (field.id) {
@@ -1618,7 +1578,7 @@ public class MutationLogger {
             if (field.type == TType.STRUCT) {
               this.success = new LogFile();
               this.success.read(iprot);
-            } else { 
+            } else {
               TProtocolUtil.skip(iprot, field.type);
             }
             break;
@@ -1626,7 +1586,7 @@ public class MutationLogger {
             if (field.type == TType.STRUCT) {
               this.sec = new org.apache.accumulo.core.security.thrift.ThriftSecurityException();
               this.sec.read(iprot);
-            } else { 
+            } else {
               TProtocolUtil.skip(iprot, field.type);
             }
             break;
@@ -1636,14 +1596,14 @@ public class MutationLogger {
         iprot.readFieldEnd();
       }
       iprot.readStructEnd();
-
+      
       // check for required fields of primitive type, which can't be checked in the validate method
       validate();
     }
-
+    
     public void write(TProtocol oprot) throws TException {
       oprot.writeStructBegin(STRUCT_DESC);
-
+      
       if (this.isSetSuccess()) {
         oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
         this.success.write(oprot);
@@ -1656,7 +1616,7 @@ public class MutationLogger {
       oprot.writeFieldStop();
       oprot.writeStructEnd();
     }
-
+    
     @Override
     public String toString() {
       StringBuilder sb = new StringBuilder("create_result(");
@@ -1676,50 +1636,46 @@ public class MutationLogger {
       sb.append(")");
       return sb.toString();
     }
-
+    
     public void validate() throws TException {
       // check for required fields
     }
-
+    
   }
-
+  
   @SuppressWarnings("serial")
-  public static class defineTablet_args implements TBase<defineTablet_args, defineTablet_args._Fields>, java.io.Serializable, Cloneable   {
+  public static class defineTablet_args implements TBase<defineTablet_args,defineTablet_args._Fields>, java.io.Serializable, Cloneable {
     private static final TStruct STRUCT_DESC = new TStruct("defineTablet_args");
-
-    private static final TField TINFO_FIELD_DESC = new TField("tinfo", TType.STRUCT, (short)5);
-    private static final TField ID_FIELD_DESC = new TField("id", TType.I64, (short)1);
-    private static final TField SEQ_FIELD_DESC = new TField("seq", TType.I64, (short)2);
-    private static final TField TID_FIELD_DESC = new TField("tid", TType.I32, (short)3);
-    private static final TField TABLET_FIELD_DESC = new TField("tablet", TType.STRUCT, (short)4);
-
+    
+    private static final TField TINFO_FIELD_DESC = new TField("tinfo", TType.STRUCT, (short) 5);
+    private static final TField ID_FIELD_DESC = new TField("id", TType.I64, (short) 1);
+    private static final TField SEQ_FIELD_DESC = new TField("seq", TType.I64, (short) 2);
+    private static final TField TID_FIELD_DESC = new TField("tid", TType.I32, (short) 3);
+    private static final TField TABLET_FIELD_DESC = new TField("tablet", TType.STRUCT, (short) 4);
+    
     public cloudtrace.thrift.TInfo tinfo;
     public long id;
     public long seq;
     public int tid;
     public org.apache.accumulo.core.data.thrift.TKeyExtent tablet;
-
+    
     /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
     public enum _Fields implements TFieldIdEnum {
-      TINFO((short)5, "tinfo"),
-      ID((short)1, "id"),
-      SEQ((short)2, "seq"),
-      TID((short)3, "tid"),
-      TABLET((short)4, "tablet");
-
-      private static final java.util.Map<String, _Fields> byName = new java.util.HashMap<String, _Fields>();
-
+      TINFO((short) 5, "tinfo"), ID((short) 1, "id"), SEQ((short) 2, "seq"), TID((short) 3, "tid"), TABLET((short) 4, "tablet");
+      
+      private static final java.util.Map<String,_Fields> byName = new java.util.HashMap<String,_Fields>();
+      
       static {
         for (_Fields field : java.util.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) {
+        switch (fieldId) {
           case 5: // TINFO
             return TINFO;
           case 1: // ID
@@ -1734,74 +1690,63 @@ public class MutationLogger {
             return null;
         }
       }
-
+      
       /**
-       * Find the _Fields constant that matches fieldId, throwing an exception
-       * if it is not found.
+       * 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!");
+        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 __ID_ISSET_ID = 0;
     private static final int __SEQ_ISSET_ID = 1;
     private static final int __TID_ISSET_ID = 2;
     private java.util.BitSet __isset_bit_vector = new java.util.BitSet(3);
-
-    public static final java.util.Map<_Fields, FieldMetaData> metaDataMap;
+    
+    public static final java.util.Map<_Fields,FieldMetaData> metaDataMap;
     static {
-      java.util.Map<_Fields, FieldMetaData> tmpMap = new java.util.EnumMap<_Fields, FieldMetaData>(_Fields.class);
-      tmpMap.put(_Fields.TINFO, new FieldMetaData("tinfo", TFieldRequirementType.DEFAULT, 
-          new StructMetaData(TType.STRUCT, cloudtrace.thrift.TInfo.class)));
-      tmpMap.put(_Fields.ID, new FieldMetaData("id", TFieldRequirementType.DEFAULT, 
-          new FieldValueMetaData(TType.I64          , "LogID")));
-      tmpMap.put(_Fields.SEQ, new FieldMetaData("seq", TFieldRequirementType.DEFAULT, 
-          new FieldValueMetaData(TType.I64)));
-      tmpMap.put(_Fields.TID, new FieldMetaData("tid", TFieldRequirementType.DEFAULT, 
-          new FieldValueMetaData(TType.I32          , "TabletID")));
-      tmpMap.put(_Fields.TABLET, new FieldMetaData("tablet", TFieldRequirementType.DEFAULT, 
-          new StructMetaData(TType.STRUCT, org.apache.accumulo.core.data.thrift.TKeyExtent.class)));
+      java.util.Map<_Fields,FieldMetaData> tmpMap = new java.util.EnumMap<_Fields,FieldMetaData>(_Fields.class);
+      tmpMap.put(_Fields.TINFO, new FieldMetaData("tinfo", TFieldRequirementType.DEFAULT, new StructMetaData(TType.STRUCT, cloudtrace.thrift.TInfo.class)));
+      tmpMap.put(_Fields.ID, new FieldMetaData("id", TFieldRequirementType.DEFAULT, new FieldValueMetaData(TType.I64, "LogID")));
+      tmpMap.put(_Fields.SEQ, new FieldMetaData("seq", TFieldRequirementType.DEFAULT, new FieldValueMetaData(TType.I64)));
+      tmpMap.put(_Fields.TID, new FieldMetaData("tid", TFieldRequirementType.DEFAULT, new FieldValueMetaData(TType.I32, "TabletID")));
+      tmpMap.put(_Fields.TABLET, new FieldMetaData("tablet", TFieldRequirementType.DEFAULT, new StructMetaData(TType.STRUCT,
+          org.apache.accumulo.core.data.thrift.TKeyExtent.class)));
       metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
       FieldMetaData.addStructMetaDataMap(defineTablet_args.class, metaDataMap);
     }
-
-    public defineTablet_args() {
-    }
-
-    public defineTablet_args(
-      cloudtrace.thrift.TInfo tinfo,
-      long id,
-      long seq,
-      int tid,
-      org.apache.accumulo.core.data.thrift.TKeyExtent tablet)
-    {
+    
+    public defineTablet_args() {}
+    
+    public defineTablet_args(cloudtrace.thrift.TInfo tinfo, long id, long seq, int tid, org.apache.accumulo.core.data.thrift.TKeyExtent tablet) {
       this();
       this.tinfo = tinfo;
       this.id = id;
@@ -1812,7 +1757,7 @@ public class MutationLogger {
       setTidIsSet(true);
       this.tablet = tablet;
     }
-
+    
     /**
      * Performs a deep copy on <i>other</i>.
      */
@@ -1829,241 +1774,241 @@ public class MutationLogger {
         this.tablet = new org.apache.accumulo.core.data.thrift.TKeyExtent(other.tablet);
       }
     }
-
+    
     public defineTablet_args deepCopy() {
       return new defineTablet_args(this);
     }
-
+    
     @Deprecated
     public defineTablet_args clone() {
       return new defineTablet_args(this);
     }
-
+    
     public cloudtrace.thrift.TInfo getTinfo() {
       return this.tinfo;
     }
-
+    
     public defineTablet_args setTinfo(cloudtrace.thrift.TInfo tinfo) {
       this.tinfo = tinfo;
       return this;
     }
-
+    
     public void unsetTinfo() {
       this.tinfo = null;
     }
-
+    
     /** Returns true if field tinfo is set (has been asigned a value) and false otherwise */
     public boolean isSetTinfo() {
       return this.tinfo != null;
     }
-
+    
     public void setTinfoIsSet(boolean value) {
       if (!value) {
         this.tinfo = null;
       }
     }
-
+    
     public long getId() {
       return this.id;
     }
-
+    
     public defineTablet_args setId(long id) {
       this.id = id;
       setIdIsSet(true);
       return this;
     }
-
+    
     public void unsetId() {
       __isset_bit_vector.clear(__ID_ISSET_ID);
     }
-
+    
     /** Returns true if field id is set (has been asigned a value) and false otherwise */
     public boolean isSetId() {
       return __isset_bit_vector.get(__ID_ISSET_ID);
     }
-
+    
     public void setIdIsSet(boolean value) {
       __isset_bit_vector.set(__ID_ISSET_ID, value);
     }
-
+    
     public long getSeq() {
       return this.seq;
     }
-
+    
     public defineTablet_args setSeq(long seq) {
       this.seq = seq;
       setSeqIsSet(true);
       return this;
     }
-
+    
     public void unsetSeq() {
       __isset_bit_vector.clear(__SEQ_ISSET_ID);
     }
-
+    
     /** Returns true if field seq is set (has been asigned a value) and false otherwise */
     public boolean isSetSeq() {
       return __isset_bit_vector.get(__SEQ_ISSET_ID);
     }
-
+    
     public void setSeqIsSet(boolean value) {
       __isset_bit_vector.set(__SEQ_ISSET_ID, value);
     }
-
+    
     public int getTid() {
       return this.tid;
     }
-
+    
     public defineTablet_args setTid(int tid) {
       this.tid = tid;
       setTidIsSet(true);
       return this;
     }
-
+    
     public void unsetTid() {
       __isset_bit_vector.clear(__TID_ISSET_ID);
     }
-
+    
     /** Returns true if field tid is set (has been asigned a value) and false otherwise */
     public boolean isSetTid() {
       return __isset_bit_vector.get(__TID_ISSET_ID);
     }
-
+    
     public void setTidIsSet(boolean value) {
       __isset_bit_vector.set(__TID_ISSET_ID, value);
     }
-
+    
     public org.apache.accumulo.core.data.thrift.TKeyExtent getTablet() {
       return this.tablet;
     }
-
+    
     public defineTablet_args setTablet(org.apache.accumulo.core.data.thrift.TKeyExtent tablet) {
       this.tablet = tablet;
       return this;
     }
-
+    
     public void unsetTablet() {
       this.tablet = null;
     }
-
+    
     /** Returns true if field tablet is set (has been asigned a value) and false otherwise */
     public boolean isSetTablet() {
       return this.tablet != null;
     }
-
+    
     public void setTabletIsSet(boolean value) {
       if (!value) {
         this.tablet = null;
       }
     }
-
+    
     public void setFieldValue(_Fields field, Object value) {
       switch (field) {
-      case TINFO:
-        if (value == null) {
-          unsetTinfo();
-        } else {
-          setTinfo((cloudtrace.thrift.TInfo)value);
-        }
-        break;
-
-      case ID:
-        if (value == null) {
-          unsetId();
-        } else {
-          setId((Long)value);
-        }
-        break;
-
-      case SEQ:
-        if (value == null) {
-          unsetSeq();
-        } else {
-          setSeq((Long)value);
-        }
-        break;
-
-      case TID:
-        if (value == null) {
-          unsetTid();
-        } else {
-          setTid((Integer)value);
-        }
-        break;
-
-      case TABLET:
-        if (value == null) {
-          unsetTablet();
-        } else {
-          setTablet((org.apache.accumulo.core.data.thrift.TKeyExtent)value);
-        }
-        break;
-
+        case TINFO:
+          if (value == null) {
+            unsetTinfo();
+          } else {
+            setTinfo((cloudtrace.thrift.TInfo) value);
+          }
+          break;
+        
+        case ID:
+          if (value == null) {
+            unsetId();
+          } else {
+            setId((Long) value);
+          }
+          break;
+        
+        case SEQ:
+          if (value == null) {
+            unsetSeq();
+          } else {
+            setSeq((Long) value);
+          }
+          break;
+        
+        case TID:
+          if (value == null) {
+            unsetTid();
+          } else {
+            setTid((Integer) value);
+          }
+          break;
+        
+        case TABLET:
+          if (value == null) {
+            unsetTablet();
+          } else {
+            setTablet((org.apache.accumulo.core.data.thrift.TKeyExtent) value);
+          }
+          break;
+      
       }
     }
-
+    
     public void setFieldValue(int fieldID, Object value) {
       setFieldValue(_Fields.findByThriftIdOrThrow(fieldID), value);
     }
-
+    
     public Object getFieldValue(_Fields field) {
       switch (field) {
-      case TINFO:
-        return getTinfo();
-
-      case ID:
-        return new Long(getId());
-
-      case SEQ:
-        return new Long(getSeq());
-
-      case TID:
-        return new Integer(getTid());
-
-      case TABLET:
-        return getTablet();
-
+        case TINFO:
+          return getTinfo();
+          
+        case ID:
+          return new Long(getId());
+          
+        case SEQ:
+          return new Long(getSeq());
+          
+        case TID:
+          return new Integer(getTid());
+          
+        case TABLET:
+          return getTablet();
+          
       }
       throw new IllegalStateException();
     }
-
+    
     public Object getFieldValue(int fieldId) {
       return getFieldValue(_Fields.findByThriftIdOrThrow(fieldId));
     }
-
+    
     /** Returns true if field corresponding to fieldID is set (has been asigned a value) and false otherwise */
     public boolean isSet(_Fields field) {
       switch (field) {
-      case TINFO:
-        return isSetTinfo();
-      case ID:
-        return isSetId();
-      case SEQ:
-        return isSetSeq();
-      case TID:
-        return isSetTid();
-      case TABLET:
-        return isSetTablet();
+        case TINFO:
+          return isSetTinfo();
+        case ID:
+          return isSetId();
+        case SEQ:
+          return isSetSeq();
+        case TID:
+          return isSetTid();
+        case TABLET:
+          return isSetTablet();
       }
       throw new IllegalStateException();
     }
-
+    
     public boolean isSet(int fieldID) {
       return isSet(_Fields.findByThriftIdOrThrow(fieldID));
     }
-
+    
     @Override
     public boolean equals(Object that) {
       if (that == null)
         return false;
       if (that instanceof defineTablet_args)
-        return this.equals((defineTablet_args)that);
+        return this.equals((defineTablet_args) that);
       return false;
     }
-
+    
     public boolean equals(defineTablet_args that) {
       if (that == null)
         return false;
-
+      
       boolean this_present_tinfo = true && this.isSetTinfo();
       boolean that_present_tinfo = true && that.isSetTinfo();
       if (this_present_tinfo || that_present_tinfo) {
@@ -2072,7 +2017,7 @@ public class MutationLogger {
         if (!this.tinfo.equals(that.tinfo))
           return false;
       }
-
+      
       boolean this_present_id = true;
       boolean that_present_id = true;
       if (this_present_id || that_present_id) {
@@ -2081,7 +2026,7 @@ public class MutationLogger {
         if (this.id != that.id)
           return false;
       }
-
+      
       boolean this_present_seq = true;
       boolean that_present_seq = true;
       if (this_present_seq || that_present_seq) {
@@ -2090,7 +2035,7 @@ public class MutationLogger {
         if (this.seq != that.seq)
           return false;
       }
-
+      
       boolean this_present_tid = true;
       boolean that_present_tid = true;
       if (this_present_tid || that_present_tid) {
@@ -2099,7 +2044,7 @@ public class MutationLogger {
         if (this.tid != that.tid)
           return false;
       }
-
+      
       boolean this_present_tablet = true && this.isSetTablet();
       boolean that_present_tablet = true && that.isSetTablet();
       if (this_present_tablet || that_present_tablet) {
@@ -2108,28 +2053,29 @@ public class MutationLogger {
         if (!this.tablet.equals(that.tablet))
           return false;
       }
-
+      
       return true;
     }
-
+    
     @Override
     public int hashCode() {
       return 0;
     }
-
+    
     public int compareTo(defineTablet_args other) {
       if (!getClass().equals(other.getClass())) {
         return getClass().getName().compareTo(other.getClass().getName());
       }
-
+      
       int lastComparison = 0;
-      defineTablet_args typedOther = (defineTablet_args)other;
-
+      defineTablet_args typedOther = (defineTablet_args) other;
+      
       lastComparison = Boolean.valueOf(isSetTinfo()).compareTo(typedOther.isSetTinfo());
       if (lastComparison != 0) {
         return lastComparison;
       }
-      if (isSetTinfo()) {        lastComparison = TBaseHelper.compareTo(this.tinfo, typedOther.tinfo);
+      if (isSetTinfo()) {
+        lastComparison = TBaseHelper.compareTo(this.tinfo, typedOther.tinfo);
         if (lastComparison != 0) {
           return lastComparison;
         }
@@ -2138,7 +2084,8 @@ public class MutationLogger {
       if (lastComparison != 0) {
         return lastComparison;
       }
-      if (isSetId()) {        lastComparison = TBaseHelper.compareTo(this.id, typedOther.id);
+      if (isSetId()) {
+        lastComparison = TBaseHelper.compareTo(this.id, typedOther.id);
         if (lastComparison != 0) {
           return lastComparison;
         }
@@ -2147,7 +2094,8 @@ public class MutationLogger {
       if (lastComparison != 0) {
         return lastComparison;
       }
-      if (isSetSeq()) {        lastComparison = TBaseHelper.compareTo(this.seq, typedOther.seq);
+      if (isSetSeq()) {
+        lastComparison = TBaseHelper.compareTo(this.seq, typedOther.seq);
         if (lastComparison != 0) {
           return lastComparison;
         }
@@ -2156,7 +2104,8 @@ public class MutationLogger {
       if (lastComparison != 0) {
         return lastComparison;
       }
-      if (isSetTid()) {        lastComparison = TBaseHelper.compareTo(this.tid, typedOther.tid);
+      if (isSetTid()) {
+        lastComparison = TBaseHelper.compareTo(this.tid, typedOther.tid);
         if (lastComparison != 0) {
           return lastComparison;
         }
@@ -2165,21 +2114,21 @@ public class MutationLogger {
       if (lastComparison != 0) {
         return lastComparison;
       }
-      if (isSetTablet()) {        lastComparison = TBaseHelper.compareTo(this.tablet, typedOther.tablet);
+      if (isSetTablet()) {
+        lastComparison = TBaseHelper.compareTo(this.tablet, typedOther.tablet);
         if (lastComparison != 0) {
           return lastComparison;
         }
       }
       return 0;
     }
-
+    
     public void read(TProtocol iprot) throws TException {
       TField field;
       iprot.readStructBegin();
-      while (true)
-      {
+      while (true) {
         field = iprot.readFieldBegin();
-        if (field.type == TType.STOP) { 
+        if (field.type == TType.STOP) {
           break;
         }
         switch (field.id) {
@@ -2187,7 +2136,7 @@ public class MutationLogger {
             if (field.type == TType.STRUCT) {
               this.tinfo = new cloudtrace.thrift.TInfo();
               this.tinfo.read(iprot);
-            } else { 
+            } else {
               TProtocolUtil.skip(iprot, field.type);
             }
             break;
@@ -2195,7 +2144,7 @@ public class MutationLogger {
             if (field.type == TType.I64) {
               this.id = iprot.readI64();
               setIdIsSet(true);
-            } else { 
+            } else {
               TProtocolUtil.skip(iprot, field.type);
             }
             break;
@@ -2203,7 +2152,7 @@ public class MutationLogger {
             if (field.type == TType.I64) {
               this.seq = iprot.readI64();
               setSeqIsSet(true);
-            } else { 
+            } else {
               TProtocolUtil.skip(iprot, field.type);
             }
             break;
@@ -2211,7 +2160,7 @@ public class MutationLogger {
             if (field.type == TType.I32) {
               this.tid = iprot.readI32();
               setTidIsSet(true);
-            } else { 
+            } else {
               TProtocolUtil.skip(iprot, field.type);
             }
             break;
@@ -2219,7 +2168,7 @@ public class MutationLogger {
             if (field.type == TType.STRUCT) {
               this.tablet = new org.apache.accumulo.core.data.thrift.TKeyExtent();
               this.tablet.read(iprot);
-            } else { 
+            } else {
               TProtocolUtil.skip(iprot, field.type);
             }
             break;
@@ -2229,14 +2178,14 @@ public class MutationLogger {
         iprot.readFieldEnd();
       }
       iprot.readStructEnd();
-
+      
       // check for required fields of primitive type, which can't be checked in the validate method
       validate();
     }
-
+    
     public void write(TProtocol oprot) throws TException {
       validate();
-
+      
       oprot.writeStructBegin(STRUCT_DESC);
       oprot.writeFieldBegin(ID_FIELD_DESC);
       oprot.writeI64(this.id);
@@ -2260,7 +2209,7 @@ public class MutationLogger {
       oprot.writeFieldStop();
       oprot.writeStructEnd();
     }
-
+    
     @Override
     public String toString() {
       StringBuilder sb = new StringBuilder("defineTablet_args(");
@@ -2289,100 +2238,96 @@ public class MutationLogger {
       sb.append(")");
       return sb.toString();
     }
-
+    
     public void validate() throws TException {
       // check for required fields
     }
-
+    
   }
-
+  
   @SuppressWarnings("serial")
-  public static class defineTablet_result implements TBase<defineTablet_result, defineTablet_result._Fields>, java.io.Serializable, Cloneable   {
+  public static class defineTablet_result implements TBase<defineTablet_result,defineTablet_result._Fields>, java.io.Serializable, Cloneable {
     private static final TStruct STRUCT_DESC = new TStruct("defineTablet_result");
-
-    private static final TField NSLI_FIELD_DESC = new TField("nsli", TType.STRUCT, (short)1);
-
+    
+    private static final TField NSLI_FIELD_DESC = new TField("nsli", TType.STRUCT, (short) 1);
+    
     public NoSuchLogIDException nsli;
-
+    
     /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
     public enum _Fields implements TFieldIdEnum {
-      NSLI((short)1, "nsli");
-
-      private static final java.util.Map<String, _Fields> byName = new java.util.HashMap<String, _Fields>();
-
+      NSLI((short) 1, "nsli");
+      
+      private static final java.util.Map<String,_Fields> byName = new java.util.HashMap<String,_Fields>();
+      
       static {
         for (_Fields field : java.util.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) {
+        switch (fieldId) {
           case 1: // NSLI
             return NSLI;
           default:
             return null;
         }
       }
-
+      
       /**
-       * Find the _Fields constant that matches fieldId, throwing an exception
-       * if it is not found.
+       * 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!");
+        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 java.util.Map<_Fields, FieldMetaData> metaDataMap;
+    
+    public static final java.util.Map<_Fields,FieldMetaData> metaDataMap;
     static {
-      java.util.Map<_Fields, FieldMetaData> tmpMap = new java.util.EnumMap<_Fields, FieldMetaData>(_Fields.class);
-      tmpMap.put(_Fields.NSLI, new FieldMetaData("nsli", TFieldRequirementType.DEFAULT, 
-          new FieldValueMetaData(TType.STRUCT)));
+      java.util.Map<_Fields,FieldMetaData> tmpMap = new java.util.EnumMap<_Fields,FieldMetaData>(_Fields.class);
+      tmpMap.put(_Fields.NSLI, new FieldMetaData("nsli", TFieldRequirementType.DEFAULT, new FieldValueMetaData(TType.STRUCT)));
       metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
       FieldMetaData.addStructMetaDataMap(defineTablet_result.class, metaDataMap);
     }
-
-    public defineTablet_result() {
-    }
-
-    public defineTablet_result(
-      NoSuchLogIDException nsli)
-    {
+    
+    public defineTablet_result() {}
+    
+    public defineTablet_result(NoSuchLogIDException nsli) {
       this();
       this.nsli = nsli;
     }
-
+    
     /**
      * Performs a deep copy on <i>other</i>.
      */
@@ -2391,96 +2336,96 @@ public class MutationLogger {
         this.nsli = new NoSuchLogIDException(other.nsli);
       }
     }
-
+    
     public defineTablet_result deepCopy() {
       return new defineTablet_result(this);
     }
-
+    
     @Deprecated
     public defineTablet_result clone() {
       return new defineTablet_result(this);
     }
-
+    
     public NoSuchLogIDException getNsli() {
       return this.nsli;
     }
-
+    
     public defineTablet_result setNsli(NoSuchLogIDException nsli) {
       this.nsli = nsli;
       return this;
     }
-
+    
     public void unsetNsli() {
       this.nsli = null;
     }
-
+    
     /** Returns true if field nsli is set (has been asigned a value) and false otherwise */
     public boolean isSetNsli() {
       return this.nsli != null;
     }
-
+    
     public void setNsliIsSet(boolean value) {
       if (!value) {
         this.nsli = null;
       }
     }
-
+    
     public void setFieldValue(_Fields field, Object value) {
       switch (field) {
-      case NSLI:
-        if (value == null) {
-          unsetNsli();
-        } else {
-          setNsli((NoSuchLogIDException)value);
-        }
-        break;
-
+        case NSLI:
+          if (value == null) {
+            unsetNsli();
+          } else {
+            setNsli((NoSuchLogIDException) value);
+          }
+          break;
+      
       }
     }
-
+    
     public void setFieldValue(int fieldID, Object value) {
       setFieldValue(_Fields.findByThriftIdOrThrow(fieldID), value);
     }
-
+    
     public Object getFieldValue(_Fields field) {
       switch (field) {
-      case NSLI:
-        return getNsli();
-
+        case NSLI:
+          return getNsli();
+          
       }
       throw new IllegalStateException();
     }
-
+    
     public Object getFieldValue(int fieldId) {
       return getFieldValue(_Fields.findByThriftIdOrThrow(fieldId));
     }
-
+    
     /** Returns true if field corresponding to fieldID is set (has been asigned a value) and false otherwise */
     public boolean isSet(_Fields field) {
       switch (field) {
-      case NSLI:
-        return isSetNsli();
+        case NSLI:
+          return isSetNsli();
       }
       throw new IllegalStateException();
     }
-
+    
     public boolean isSet(int fieldID) {
       return isSet(_Fields.findByThriftIdOrThrow(fieldID));
     }
-
+    
     @Override
     public boolean equals(Object that) {
       if (that == null)
         return false;
       if (that instanceof defineTablet_result)
-        return this.equals((defineTablet_result)that);
+        return this.equals((defineTablet_result) that);
       return false;
     }
-
+    
     public boolean equals(defineTablet_result that) {
       if (that == null)
         return false;
-
+      
       boolean this_present_nsli = true && this.isSetNsli();
       boolean that_present_nsli = true && that.isSetNsli();
       if (this_present_nsli || that_present_nsli) {
@@ -2489,42 +2434,42 @@ public class MutationLogger {
         if (!this.nsli.equals(that.nsli))
           return false;
       }
-
+      
       return true;
     }
-
+    
     @Override
     public int hashCode() {
       return 0;
     }
-
+    
     public int compareTo(defineTablet_result other) {
       if (!getClass().equals(other.getClass())) {
         return getClass().getName().compareTo(other.getClass().getName());
       }
-
+      
       int lastComparison = 0;
-      defineTablet_result typedOther = (defineTablet_result)other;
-
+      defineTablet_result typedOther = (defineTablet_result) other;
+      
       lastComparison = Boolean.valueOf(isSetNsli()).compareTo(typedOther.isSetNsli());
       if (lastComparison != 0) {
         return lastComparison;
       }
-      if (isSetNsli()) {        lastComparison = TBaseHelper.compareTo(this.nsli, typedOther.nsli);
+      if (isSetNsli()) {
+        lastComparison = TBaseHelper.compareTo(this.nsli, typedOther.nsli);
         if (lastComparison != 0) {
           return lastComparison;
         }
       }
       return 0;
     }
-
+    
     public void read(TProtocol iprot) throws TException {
       TField field;
       iprot.readStructBegin();
-      while (true)
-      {
+      while (true) {
         field = iprot.readFieldBegin();
-        if (field.type == TType.STOP) { 
+        if (field.type == TType.STOP) {
           break;
         }
         switch (field.id) {
@@ -2532,7 +2477,7 @@ public class MutationLogger {
             if (field.type == TType.STRUCT) {
               this.nsli = new NoSuchLogIDException();
               this.nsli.read(iprot);
-            } else { 
+            } else {
               TProtocolUtil.skip(iprot, field.type);
             }
             break;
@@ -2542,14 +2487,14 @@ public class MutationLogger {
         iprot.readFieldEnd();
       }
       iprot.readStructEnd();
-
+      
       // check for required fields of primitive type, which can't be checked in the validate method
       validate();
     }
-
+    
     public void write(TProtocol oprot) throws TException {
       oprot.writeStructBegin(STRUCT_DESC);
-
+      
       if (this.isSetNsli()) {
         oprot.writeFieldBegin(NSLI_FIELD_DESC);
         this.nsli.write(oprot);
@@ -2558,7 +2503,7 @@ public class MutationLogger {
       oprot.writeFieldStop();
       oprot.writeStructEnd();
     }
-
+    
     @Override
     public String toString() {
       StringBuilder sb = new StringBuilder("defineTablet_result(");
@@ -2571,50 +2516,46 @@ public class MutationLogger {
       sb.append(")");
       return sb.toString();
     }
-
+    
     public void validate() throws TException {
       // check for required fields
     }
-
+    
   }
-
+  
   @SuppressWarnings("serial")
-  public static class log_args implements TBase<log_args, log_args._Fields>, java.io.Serializable, Cloneable   {
+  public static class log_args implements TBase<log_args,log_args._Fields>, java.io.Serializable, Cloneable {
     private static final TStruct STRUCT_DESC = new TStruct("log_args");
-
-    private static final TField TINFO_FIELD_DESC = new TField("tinfo", TType.STRUCT, (short)5);
-    private static final TField ID_FIELD_DESC = new TField("id", TType.I64, (short)1);
-    private static final TField SEQ_FIELD_DESC = new TField("seq", TType.I64, (short)2);
-    private static final TField TID_FIELD_DESC = new TField("tid", TType.I32, (short)3);
-    private static final TField MUTATION_FIELD_DESC = new TField("mutation", TType.STRUCT, (short)4);
-
+    
+    private static final TField TINFO_FIELD_DESC = new TField("tinfo", TType.STRUCT, (short) 5);
+    private static final TField ID_FIELD_DESC = new TField("id", TType.I64, (short) 1);
+    private static final TField SEQ_FIELD_DESC = new TField("seq", TType.I64, (short) 2);
+    private static final TField TID_FIELD_DESC = new TField("tid", TType.I32, (short) 3);
+    private static final TField MUTATION_FIELD_DESC = new TField("mutation", TType.STRUCT, (short) 4);
+    
     public cloudtrace.thrift.TInfo tinfo;

[... 7603 lines stripped ...]


Mime
View raw message