You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by vi...@apache.org on 2011/10/27 17:25:17 UTC
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/...
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 ...]