Return-Path: X-Original-To: apmail-incubator-accumulo-commits-archive@minotaur.apache.org Delivered-To: apmail-incubator-accumulo-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 890949A78 for ; Thu, 27 Oct 2011 15:27:42 +0000 (UTC) Received: (qmail 65752 invoked by uid 500); 27 Oct 2011 15:27:42 -0000 Delivered-To: apmail-incubator-accumulo-commits-archive@incubator.apache.org Received: (qmail 65724 invoked by uid 500); 27 Oct 2011 15:27:42 -0000 Mailing-List: contact accumulo-commits-help@incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: accumulo-dev@incubator.apache.org Delivered-To: mailing list accumulo-commits@incubator.apache.org Received: (qmail 65703 invoked by uid 99); 27 Oct 2011 15:27:41 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 27 Oct 2011 15:27:41 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 27 Oct 2011 15:27:24 +0000 Received: from eris.apache.org (localhost [127.0.0.1]) by eris.apache.org (Postfix) with ESMTP id 20EC42388C4E; Thu, 27 Oct 2011 15:26:15 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit 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 -0000 To: accumulo-commits@incubator.apache.org From: vines@apache.org X-Mailer: svnmailer-1.0.8-patched Message-Id: <20111027152615.20EC42388C4E@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org 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 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 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 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 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 files) + throws TException; + } - + public static class Client implements TServiceClient, Iface { public static class Factory implements TServiceClientFactory { 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 mutations) throws NoSuchLogIDException, TException - { + + public void logManyTablets(cloudtrace.thrift.TInfo tinfo, long id, java.util.List mutations) throws NoSuchLogIDException, TException { send_logManyTablets(tinfo, id, mutations); recv_logManyTablets(); } - - public void send_logManyTablets(cloudtrace.thrift.TInfo tinfo, long id, java.util.List mutations) throws TException - { + + public void send_logManyTablets(cloudtrace.thrift.TInfo tinfo, long id, java.util.List 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 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 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 recv_getClosedLogs() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException - { + + public java.util.List 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 files) throws TException - { + + public void remove(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, java.util.List 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 files) throws TException - { + + public void send_remove(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, java.util.List 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 processMap_ = new java.util.HashMap(); - - 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, java.io.Serializable, Cloneable { + public static class create_args implements TBase, 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 byName = new java.util.HashMap(); - + TINFO((short) 3, "tinfo"), CREDENTIALS((short) 1, "credentials"), TSERVER_SESSION((short) 2, "tserverSession"); + + private static final java.util.Map byName = new java.util.HashMap(); + 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 other. */ @@ -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, java.io.Serializable, Cloneable { + public static class create_result implements TBase, 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 byName = new java.util.HashMap(); - + SUCCESS((short) 0, "success"), SEC((short) 1, "sec"); + + private static final java.util.Map byName = new java.util.HashMap(); + 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 other. */ @@ -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, java.io.Serializable, Cloneable { + public static class defineTablet_args implements TBase, 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 byName = new java.util.HashMap(); - + 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 byName = new java.util.HashMap(); + 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 other. */ @@ -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, java.io.Serializable, Cloneable { + public static class defineTablet_result implements TBase, 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 byName = new java.util.HashMap(); - + NSLI((short) 1, "nsli"); + + private static final java.util.Map byName = new java.util.HashMap(); + 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 other. */ @@ -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, java.io.Serializable, Cloneable { + public static class log_args implements TBase, 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 ...]