You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ct...@apache.org on 2014/06/19 02:57:23 UTC
[13/36] ACCUMULO-2773 Regenerate sources for Thrift 0.9.1
http://git-wip-us.apache.org/repos/asf/accumulo/blob/011c1760/core/src/main/java/org/apache/accumulo/core/master/thrift/FateService.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/accumulo/core/master/thrift/FateService.java b/core/src/main/java/org/apache/accumulo/core/master/thrift/FateService.java
index cc4d175..6b337b4 100644
--- a/core/src/main/java/org/apache/accumulo/core/master/thrift/FateService.java
+++ b/core/src/main/java/org/apache/accumulo/core/master/thrift/FateService.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.0)
+ * Autogenerated by Thrift Compiler (0.9.1)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -31,6 +31,8 @@ import org.apache.thrift.protocol.TTupleProtocol;
import org.apache.thrift.protocol.TProtocolException;
import org.apache.thrift.EncodingUtils;
import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
@@ -62,13 +64,13 @@ import org.slf4j.LoggerFactory;
public interface AsyncIface {
- public void beginFateOperation(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.beginFateOperation_call> resultHandler) throws org.apache.thrift.TException;
+ public void beginFateOperation(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void executeFateOperation(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, long opid, FateOperation op, List<ByteBuffer> arguments, Map<String,String> options, boolean autoClean, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.executeFateOperation_call> resultHandler) throws org.apache.thrift.TException;
+ public void executeFateOperation(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, long opid, FateOperation op, List<ByteBuffer> arguments, Map<String,String> options, boolean autoClean, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void waitForFateOperation(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, long opid, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.waitForFateOperation_call> resultHandler) throws org.apache.thrift.TException;
+ public void waitForFateOperation(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, long opid, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void finishFateOperation(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, long opid, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.finishFateOperation_call> resultHandler) throws org.apache.thrift.TException;
+ public void finishFateOperation(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, long opid, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
}
@@ -225,7 +227,7 @@ import org.slf4j.LoggerFactory;
super(protocolFactory, clientManager, transport);
}
- public void beginFateOperation(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, org.apache.thrift.async.AsyncMethodCallback<beginFateOperation_call> resultHandler) throws org.apache.thrift.TException {
+ public void beginFateOperation(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
beginFateOperation_call method_call = new beginFateOperation_call(tinfo, credentials, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
@@ -235,7 +237,7 @@ import org.slf4j.LoggerFactory;
public static class beginFateOperation_call extends org.apache.thrift.async.TAsyncMethodCall {
private org.apache.accumulo.trace.thrift.TInfo tinfo;
private org.apache.accumulo.core.security.thrift.TCredentials credentials;
- public beginFateOperation_call(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, org.apache.thrift.async.AsyncMethodCallback<beginFateOperation_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ public beginFateOperation_call(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
this.tinfo = tinfo;
this.credentials = credentials;
@@ -260,7 +262,7 @@ import org.slf4j.LoggerFactory;
}
}
- public void executeFateOperation(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, long opid, FateOperation op, List<ByteBuffer> arguments, Map<String,String> options, boolean autoClean, org.apache.thrift.async.AsyncMethodCallback<executeFateOperation_call> resultHandler) throws org.apache.thrift.TException {
+ public void executeFateOperation(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, long opid, FateOperation op, List<ByteBuffer> arguments, Map<String,String> options, boolean autoClean, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
executeFateOperation_call method_call = new executeFateOperation_call(tinfo, credentials, opid, op, arguments, options, autoClean, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
@@ -275,7 +277,7 @@ import org.slf4j.LoggerFactory;
private List<ByteBuffer> arguments;
private Map<String,String> options;
private boolean autoClean;
- public executeFateOperation_call(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, long opid, FateOperation op, List<ByteBuffer> arguments, Map<String,String> options, boolean autoClean, org.apache.thrift.async.AsyncMethodCallback<executeFateOperation_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ public executeFateOperation_call(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, long opid, FateOperation op, List<ByteBuffer> arguments, Map<String,String> options, boolean autoClean, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
this.tinfo = tinfo;
this.credentials = credentials;
@@ -310,7 +312,7 @@ import org.slf4j.LoggerFactory;
}
}
- public void waitForFateOperation(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, long opid, org.apache.thrift.async.AsyncMethodCallback<waitForFateOperation_call> resultHandler) throws org.apache.thrift.TException {
+ public void waitForFateOperation(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, long opid, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
waitForFateOperation_call method_call = new waitForFateOperation_call(tinfo, credentials, opid, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
@@ -321,7 +323,7 @@ import org.slf4j.LoggerFactory;
private org.apache.accumulo.trace.thrift.TInfo tinfo;
private org.apache.accumulo.core.security.thrift.TCredentials credentials;
private long opid;
- public waitForFateOperation_call(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, long opid, org.apache.thrift.async.AsyncMethodCallback<waitForFateOperation_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ public waitForFateOperation_call(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, long opid, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
this.tinfo = tinfo;
this.credentials = credentials;
@@ -348,7 +350,7 @@ import org.slf4j.LoggerFactory;
}
}
- public void finishFateOperation(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, long opid, org.apache.thrift.async.AsyncMethodCallback<finishFateOperation_call> resultHandler) throws org.apache.thrift.TException {
+ public void finishFateOperation(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, long opid, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
finishFateOperation_call method_call = new finishFateOperation_call(tinfo, credentials, opid, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
@@ -359,7 +361,7 @@ import org.slf4j.LoggerFactory;
private org.apache.accumulo.trace.thrift.TInfo tinfo;
private org.apache.accumulo.core.security.thrift.TCredentials credentials;
private long opid;
- public finishFateOperation_call(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, long opid, org.apache.thrift.async.AsyncMethodCallback<finishFateOperation_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ public finishFateOperation_call(org.apache.accumulo.trace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.TCredentials credentials, long opid, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
this.tinfo = tinfo;
this.credentials = credentials;
@@ -509,7 +511,264 @@ import org.slf4j.LoggerFactory;
}
- public static class beginFateOperation_args implements org.apache.thrift.TBase<beginFateOperation_args, beginFateOperation_args._Fields>, java.io.Serializable, Cloneable {
+ public static class AsyncProcessor<I extends AsyncIface> extends org.apache.thrift.TBaseAsyncProcessor<I> {
+ private static final Logger LOGGER = LoggerFactory.getLogger(AsyncProcessor.class.getName());
+ public AsyncProcessor(I iface) {
+ super(iface, getProcessMap(new HashMap<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>>()));
+ }
+
+ protected AsyncProcessor(I iface, Map<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>> processMap) {
+ super(iface, getProcessMap(processMap));
+ }
+
+ private static <I extends AsyncIface> Map<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase,?>> getProcessMap(Map<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>> processMap) {
+ processMap.put("beginFateOperation", new beginFateOperation());
+ processMap.put("executeFateOperation", new executeFateOperation());
+ processMap.put("waitForFateOperation", new waitForFateOperation());
+ processMap.put("finishFateOperation", new finishFateOperation());
+ return processMap;
+ }
+
+ public static class beginFateOperation<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, beginFateOperation_args, Long> {
+ public beginFateOperation() {
+ super("beginFateOperation");
+ }
+
+ public beginFateOperation_args getEmptyArgsInstance() {
+ return new beginFateOperation_args();
+ }
+
+ public AsyncMethodCallback<Long> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.thrift.AsyncProcessFunction fcall = this;
+ return new AsyncMethodCallback<Long>() {
+ public void onComplete(Long o) {
+ beginFateOperation_result result = new beginFateOperation_result();
+ result.success = o;
+ result.setSuccessIsSet(true);
+ try {
+ fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
+ return;
+ } catch (Exception e) {
+ LOGGER.error("Exception writing to internal frame buffer", e);
+ }
+ fb.close();
+ }
+ public void onError(Exception e) {
+ byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
+ org.apache.thrift.TBase msg;
+ beginFateOperation_result result = new beginFateOperation_result();
+ if (e instanceof org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException) {
+ result.sec = (org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException) e;
+ result.setSecIsSet(true);
+ msg = result;
+ }
+ else
+ {
+ msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
+ msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
+ }
+ try {
+ fcall.sendResponse(fb,msg,msgType,seqid);
+ return;
+ } catch (Exception ex) {
+ LOGGER.error("Exception writing to internal frame buffer", ex);
+ }
+ fb.close();
+ }
+ };
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public void start(I iface, beginFateOperation_args args, org.apache.thrift.async.AsyncMethodCallback<Long> resultHandler) throws TException {
+ iface.beginFateOperation(args.tinfo, args.credentials,resultHandler);
+ }
+ }
+
+ public static class executeFateOperation<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, executeFateOperation_args, Void> {
+ public executeFateOperation() {
+ super("executeFateOperation");
+ }
+
+ public executeFateOperation_args getEmptyArgsInstance() {
+ return new executeFateOperation_args();
+ }
+
+ public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.thrift.AsyncProcessFunction fcall = this;
+ return new AsyncMethodCallback<Void>() {
+ public void onComplete(Void o) {
+ executeFateOperation_result result = new executeFateOperation_result();
+ try {
+ fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
+ return;
+ } catch (Exception e) {
+ LOGGER.error("Exception writing to internal frame buffer", e);
+ }
+ fb.close();
+ }
+ public void onError(Exception e) {
+ byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
+ org.apache.thrift.TBase msg;
+ executeFateOperation_result result = new executeFateOperation_result();
+ if (e instanceof org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException) {
+ result.sec = (org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException) e;
+ result.setSecIsSet(true);
+ msg = result;
+ }
+ else if (e instanceof org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException) {
+ result.tope = (org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException) e;
+ result.setTopeIsSet(true);
+ msg = result;
+ }
+ else
+ {
+ msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
+ msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
+ }
+ try {
+ fcall.sendResponse(fb,msg,msgType,seqid);
+ return;
+ } catch (Exception ex) {
+ LOGGER.error("Exception writing to internal frame buffer", ex);
+ }
+ fb.close();
+ }
+ };
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public void start(I iface, executeFateOperation_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
+ iface.executeFateOperation(args.tinfo, args.credentials, args.opid, args.op, args.arguments, args.options, args.autoClean,resultHandler);
+ }
+ }
+
+ public static class waitForFateOperation<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, waitForFateOperation_args, String> {
+ public waitForFateOperation() {
+ super("waitForFateOperation");
+ }
+
+ public waitForFateOperation_args getEmptyArgsInstance() {
+ return new waitForFateOperation_args();
+ }
+
+ public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.thrift.AsyncProcessFunction fcall = this;
+ return new AsyncMethodCallback<String>() {
+ public void onComplete(String o) {
+ waitForFateOperation_result result = new waitForFateOperation_result();
+ result.success = o;
+ try {
+ fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
+ return;
+ } catch (Exception e) {
+ LOGGER.error("Exception writing to internal frame buffer", e);
+ }
+ fb.close();
+ }
+ public void onError(Exception e) {
+ byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
+ org.apache.thrift.TBase msg;
+ waitForFateOperation_result result = new waitForFateOperation_result();
+ if (e instanceof org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException) {
+ result.sec = (org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException) e;
+ result.setSecIsSet(true);
+ msg = result;
+ }
+ else if (e instanceof org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException) {
+ result.tope = (org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException) e;
+ result.setTopeIsSet(true);
+ msg = result;
+ }
+ else
+ {
+ msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
+ msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
+ }
+ try {
+ fcall.sendResponse(fb,msg,msgType,seqid);
+ return;
+ } catch (Exception ex) {
+ LOGGER.error("Exception writing to internal frame buffer", ex);
+ }
+ fb.close();
+ }
+ };
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public void start(I iface, waitForFateOperation_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
+ iface.waitForFateOperation(args.tinfo, args.credentials, args.opid,resultHandler);
+ }
+ }
+
+ public static class finishFateOperation<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, finishFateOperation_args, Void> {
+ public finishFateOperation() {
+ super("finishFateOperation");
+ }
+
+ public finishFateOperation_args getEmptyArgsInstance() {
+ return new finishFateOperation_args();
+ }
+
+ public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.thrift.AsyncProcessFunction fcall = this;
+ return new AsyncMethodCallback<Void>() {
+ public void onComplete(Void o) {
+ finishFateOperation_result result = new finishFateOperation_result();
+ try {
+ fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
+ return;
+ } catch (Exception e) {
+ LOGGER.error("Exception writing to internal frame buffer", e);
+ }
+ fb.close();
+ }
+ public void onError(Exception e) {
+ byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
+ org.apache.thrift.TBase msg;
+ finishFateOperation_result result = new finishFateOperation_result();
+ if (e instanceof org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException) {
+ result.sec = (org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException) e;
+ result.setSecIsSet(true);
+ msg = result;
+ }
+ else
+ {
+ msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
+ msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
+ }
+ try {
+ fcall.sendResponse(fb,msg,msgType,seqid);
+ return;
+ } catch (Exception ex) {
+ LOGGER.error("Exception writing to internal frame buffer", ex);
+ }
+ fb.close();
+ }
+ };
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public void start(I iface, finishFateOperation_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
+ iface.finishFateOperation(args.tinfo, args.credentials, args.opid,resultHandler);
+ }
+ }
+
+ }
+
+ public static class beginFateOperation_args implements org.apache.thrift.TBase<beginFateOperation_args, beginFateOperation_args._Fields>, java.io.Serializable, Cloneable, Comparable<beginFateOperation_args> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("beginFateOperation_args");
private static final org.apache.thrift.protocol.TField TINFO_FIELD_DESC = new org.apache.thrift.protocol.TField("tinfo", org.apache.thrift.protocol.TType.STRUCT, (short)2);
@@ -766,30 +1025,30 @@ import org.slf4j.LoggerFactory;
return 0;
}
+ @Override
public int compareTo(beginFateOperation_args other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
- beginFateOperation_args typedOther = (beginFateOperation_args)other;
- lastComparison = Boolean.valueOf(isSetTinfo()).compareTo(typedOther.isSetTinfo());
+ lastComparison = Boolean.valueOf(isSetTinfo()).compareTo(other.isSetTinfo());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTinfo()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tinfo, typedOther.tinfo);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tinfo, other.tinfo);
if (lastComparison != 0) {
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(isSetCredentials()).compareTo(typedOther.isSetCredentials());
+ lastComparison = Boolean.valueOf(isSetCredentials()).compareTo(other.isSetCredentials());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetCredentials()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.credentials, typedOther.credentials);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.credentials, other.credentials);
if (lastComparison != 0) {
return lastComparison;
}
@@ -973,7 +1232,7 @@ import org.slf4j.LoggerFactory;
}
- public static class beginFateOperation_result implements org.apache.thrift.TBase<beginFateOperation_result, beginFateOperation_result._Fields>, java.io.Serializable, Cloneable {
+ public static class beginFateOperation_result implements org.apache.thrift.TBase<beginFateOperation_result, beginFateOperation_result._Fields>, java.io.Serializable, Cloneable, Comparable<beginFateOperation_result> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("beginFateOperation_result");
private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.I64, (short)0);
@@ -1232,30 +1491,30 @@ import org.slf4j.LoggerFactory;
return 0;
}
+ @Override
public int compareTo(beginFateOperation_result other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
- beginFateOperation_result typedOther = (beginFateOperation_result)other;
- lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess());
+ lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(other.isSetSuccess());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetSuccess()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, typedOther.success);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, other.success);
if (lastComparison != 0) {
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(isSetSec()).compareTo(typedOther.isSetSec());
+ lastComparison = Boolean.valueOf(isSetSec()).compareTo(other.isSetSec());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetSec()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.sec, typedOther.sec);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.sec, other.sec);
if (lastComparison != 0) {
return lastComparison;
}
@@ -1429,7 +1688,7 @@ import org.slf4j.LoggerFactory;
}
- public static class executeFateOperation_args implements org.apache.thrift.TBase<executeFateOperation_args, executeFateOperation_args._Fields>, java.io.Serializable, Cloneable {
+ public static class executeFateOperation_args implements org.apache.thrift.TBase<executeFateOperation_args, executeFateOperation_args._Fields>, java.io.Serializable, Cloneable, Comparable<executeFateOperation_args> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("executeFateOperation_args");
private static final org.apache.thrift.protocol.TField TINFO_FIELD_DESC = new org.apache.thrift.protocol.TField("tinfo", org.apache.thrift.protocol.TType.STRUCT, (short)7);
@@ -1606,27 +1865,11 @@ import org.slf4j.LoggerFactory;
this.op = other.op;
}
if (other.isSetArguments()) {
- List<ByteBuffer> __this__arguments = new ArrayList<ByteBuffer>();
- for (ByteBuffer other_element : other.arguments) {
- ByteBuffer temp_binary_element = org.apache.thrift.TBaseHelper.copyBinary(other_element);
-;
- __this__arguments.add(temp_binary_element);
- }
+ List<ByteBuffer> __this__arguments = new ArrayList<ByteBuffer>(other.arguments);
this.arguments = __this__arguments;
}
if (other.isSetOptions()) {
- Map<String,String> __this__options = new HashMap<String,String>();
- for (Map.Entry<String, String> other_element : other.options.entrySet()) {
-
- String other_element_key = other_element.getKey();
- String other_element_value = other_element.getValue();
-
- String __this__options_copy_key = other_element_key;
-
- String __this__options_copy_value = other_element_value;
-
- __this__options.put(__this__options_copy_key, __this__options_copy_value);
- }
+ Map<String,String> __this__options = new HashMap<String,String>(other.options);
this.options = __this__options;
}
this.autoClean = other.autoClean;
@@ -2046,80 +2289,80 @@ import org.slf4j.LoggerFactory;
return 0;
}
+ @Override
public int compareTo(executeFateOperation_args other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
- executeFateOperation_args typedOther = (executeFateOperation_args)other;
- lastComparison = Boolean.valueOf(isSetTinfo()).compareTo(typedOther.isSetTinfo());
+ lastComparison = Boolean.valueOf(isSetTinfo()).compareTo(other.isSetTinfo());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTinfo()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tinfo, typedOther.tinfo);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tinfo, other.tinfo);
if (lastComparison != 0) {
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(isSetCredentials()).compareTo(typedOther.isSetCredentials());
+ lastComparison = Boolean.valueOf(isSetCredentials()).compareTo(other.isSetCredentials());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetCredentials()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.credentials, typedOther.credentials);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.credentials, other.credentials);
if (lastComparison != 0) {
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(isSetOpid()).compareTo(typedOther.isSetOpid());
+ lastComparison = Boolean.valueOf(isSetOpid()).compareTo(other.isSetOpid());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetOpid()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.opid, typedOther.opid);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.opid, other.opid);
if (lastComparison != 0) {
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(isSetOp()).compareTo(typedOther.isSetOp());
+ lastComparison = Boolean.valueOf(isSetOp()).compareTo(other.isSetOp());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetOp()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.op, typedOther.op);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.op, other.op);
if (lastComparison != 0) {
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(isSetArguments()).compareTo(typedOther.isSetArguments());
+ lastComparison = Boolean.valueOf(isSetArguments()).compareTo(other.isSetArguments());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetArguments()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.arguments, typedOther.arguments);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.arguments, other.arguments);
if (lastComparison != 0) {
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(isSetOptions()).compareTo(typedOther.isSetOptions());
+ lastComparison = Boolean.valueOf(isSetOptions()).compareTo(other.isSetOptions());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetOptions()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.options, typedOther.options);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.options, other.options);
if (lastComparison != 0) {
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(isSetAutoClean()).compareTo(typedOther.isSetAutoClean());
+ lastComparison = Boolean.valueOf(isSetAutoClean()).compareTo(other.isSetAutoClean());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetAutoClean()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.autoClean, typedOther.autoClean);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.autoClean, other.autoClean);
if (lastComparison != 0) {
return lastComparison;
}
@@ -2283,7 +2526,7 @@ import org.slf4j.LoggerFactory;
struct.arguments = new ArrayList<ByteBuffer>(_list70.size);
for (int _i71 = 0; _i71 < _list70.size; ++_i71)
{
- ByteBuffer _elem72; // required
+ ByteBuffer _elem72;
_elem72 = iprot.readBinary();
struct.arguments.add(_elem72);
}
@@ -2301,8 +2544,8 @@ import org.slf4j.LoggerFactory;
struct.options = new HashMap<String,String>(2*_map73.size);
for (int _i74 = 0; _i74 < _map73.size; ++_i74)
{
- String _key75; // required
- String _val76; // required
+ String _key75;
+ String _val76;
_key75 = iprot.readString();
_val76 = iprot.readString();
struct.options.put(_key75, _val76);
@@ -2487,7 +2730,7 @@ import org.slf4j.LoggerFactory;
struct.arguments = new ArrayList<ByteBuffer>(_list81.size);
for (int _i82 = 0; _i82 < _list81.size; ++_i82)
{
- ByteBuffer _elem83; // required
+ ByteBuffer _elem83;
_elem83 = iprot.readBinary();
struct.arguments.add(_elem83);
}
@@ -2500,8 +2743,8 @@ import org.slf4j.LoggerFactory;
struct.options = new HashMap<String,String>(2*_map84.size);
for (int _i85 = 0; _i85 < _map84.size; ++_i85)
{
- String _key86; // required
- String _val87; // required
+ String _key86;
+ String _val87;
_key86 = iprot.readString();
_val87 = iprot.readString();
struct.options.put(_key86, _val87);
@@ -2518,7 +2761,7 @@ import org.slf4j.LoggerFactory;
}
- public static class executeFateOperation_result implements org.apache.thrift.TBase<executeFateOperation_result, executeFateOperation_result._Fields>, java.io.Serializable, Cloneable {
+ public static class executeFateOperation_result implements org.apache.thrift.TBase<executeFateOperation_result, executeFateOperation_result._Fields>, java.io.Serializable, Cloneable, Comparable<executeFateOperation_result> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("executeFateOperation_result");
private static final org.apache.thrift.protocol.TField SEC_FIELD_DESC = new org.apache.thrift.protocol.TField("sec", org.apache.thrift.protocol.TType.STRUCT, (short)1);
@@ -2775,30 +3018,30 @@ import org.slf4j.LoggerFactory;
return 0;
}
+ @Override
public int compareTo(executeFateOperation_result other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
- executeFateOperation_result typedOther = (executeFateOperation_result)other;
- lastComparison = Boolean.valueOf(isSetSec()).compareTo(typedOther.isSetSec());
+ lastComparison = Boolean.valueOf(isSetSec()).compareTo(other.isSetSec());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetSec()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.sec, typedOther.sec);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.sec, other.sec);
if (lastComparison != 0) {
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(isSetTope()).compareTo(typedOther.isSetTope());
+ lastComparison = Boolean.valueOf(isSetTope()).compareTo(other.isSetTope());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTope()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tope, typedOther.tope);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tope, other.tope);
if (lastComparison != 0) {
return lastComparison;
}
@@ -2976,7 +3219,7 @@ import org.slf4j.LoggerFactory;
}
- public static class waitForFateOperation_args implements org.apache.thrift.TBase<waitForFateOperation_args, waitForFateOperation_args._Fields>, java.io.Serializable, Cloneable {
+ public static class waitForFateOperation_args implements org.apache.thrift.TBase<waitForFateOperation_args, waitForFateOperation_args._Fields>, java.io.Serializable, Cloneable, Comparable<waitForFateOperation_args> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("waitForFateOperation_args");
private static final org.apache.thrift.protocol.TField TINFO_FIELD_DESC = new org.apache.thrift.protocol.TField("tinfo", org.apache.thrift.protocol.TType.STRUCT, (short)3);
@@ -3294,40 +3537,40 @@ import org.slf4j.LoggerFactory;
return 0;
}
+ @Override
public int compareTo(waitForFateOperation_args other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
- waitForFateOperation_args typedOther = (waitForFateOperation_args)other;
- lastComparison = Boolean.valueOf(isSetTinfo()).compareTo(typedOther.isSetTinfo());
+ lastComparison = Boolean.valueOf(isSetTinfo()).compareTo(other.isSetTinfo());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTinfo()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tinfo, typedOther.tinfo);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tinfo, other.tinfo);
if (lastComparison != 0) {
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(isSetCredentials()).compareTo(typedOther.isSetCredentials());
+ lastComparison = Boolean.valueOf(isSetCredentials()).compareTo(other.isSetCredentials());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetCredentials()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.credentials, typedOther.credentials);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.credentials, other.credentials);
if (lastComparison != 0) {
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(isSetOpid()).compareTo(typedOther.isSetOpid());
+ lastComparison = Boolean.valueOf(isSetOpid()).compareTo(other.isSetOpid());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetOpid()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.opid, typedOther.opid);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.opid, other.opid);
if (lastComparison != 0) {
return lastComparison;
}
@@ -3538,7 +3781,7 @@ import org.slf4j.LoggerFactory;
}
- public static class waitForFateOperation_result implements org.apache.thrift.TBase<waitForFateOperation_result, waitForFateOperation_result._Fields>, java.io.Serializable, Cloneable {
+ public static class waitForFateOperation_result implements org.apache.thrift.TBase<waitForFateOperation_result, waitForFateOperation_result._Fields>, java.io.Serializable, Cloneable, Comparable<waitForFateOperation_result> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("waitForFateOperation_result");
private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.STRING, (short)0);
@@ -3854,40 +4097,40 @@ import org.slf4j.LoggerFactory;
return 0;
}
+ @Override
public int compareTo(waitForFateOperation_result other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
- waitForFateOperation_result typedOther = (waitForFateOperation_result)other;
- lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess());
+ lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(other.isSetSuccess());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetSuccess()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, typedOther.success);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, other.success);
if (lastComparison != 0) {
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(isSetSec()).compareTo(typedOther.isSetSec());
+ lastComparison = Boolean.valueOf(isSetSec()).compareTo(other.isSetSec());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetSec()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.sec, typedOther.sec);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.sec, other.sec);
if (lastComparison != 0) {
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(isSetTope()).compareTo(typedOther.isSetTope());
+ lastComparison = Boolean.valueOf(isSetTope()).compareTo(other.isSetTope());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTope()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tope, typedOther.tope);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tope, other.tope);
if (lastComparison != 0) {
return lastComparison;
}
@@ -4096,7 +4339,7 @@ import org.slf4j.LoggerFactory;
}
- public static class finishFateOperation_args implements org.apache.thrift.TBase<finishFateOperation_args, finishFateOperation_args._Fields>, java.io.Serializable, Cloneable {
+ public static class finishFateOperation_args implements org.apache.thrift.TBase<finishFateOperation_args, finishFateOperation_args._Fields>, java.io.Serializable, Cloneable, Comparable<finishFateOperation_args> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("finishFateOperation_args");
private static final org.apache.thrift.protocol.TField TINFO_FIELD_DESC = new org.apache.thrift.protocol.TField("tinfo", org.apache.thrift.protocol.TType.STRUCT, (short)3);
@@ -4414,40 +4657,40 @@ import org.slf4j.LoggerFactory;
return 0;
}
+ @Override
public int compareTo(finishFateOperation_args other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
- finishFateOperation_args typedOther = (finishFateOperation_args)other;
- lastComparison = Boolean.valueOf(isSetTinfo()).compareTo(typedOther.isSetTinfo());
+ lastComparison = Boolean.valueOf(isSetTinfo()).compareTo(other.isSetTinfo());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTinfo()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tinfo, typedOther.tinfo);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tinfo, other.tinfo);
if (lastComparison != 0) {
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(isSetCredentials()).compareTo(typedOther.isSetCredentials());
+ lastComparison = Boolean.valueOf(isSetCredentials()).compareTo(other.isSetCredentials());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetCredentials()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.credentials, typedOther.credentials);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.credentials, other.credentials);
if (lastComparison != 0) {
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(isSetOpid()).compareTo(typedOther.isSetOpid());
+ lastComparison = Boolean.valueOf(isSetOpid()).compareTo(other.isSetOpid());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetOpid()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.opid, typedOther.opid);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.opid, other.opid);
if (lastComparison != 0) {
return lastComparison;
}
@@ -4658,7 +4901,7 @@ import org.slf4j.LoggerFactory;
}
- public static class finishFateOperation_result implements org.apache.thrift.TBase<finishFateOperation_result, finishFateOperation_result._Fields>, java.io.Serializable, Cloneable {
+ public static class finishFateOperation_result implements org.apache.thrift.TBase<finishFateOperation_result, finishFateOperation_result._Fields>, java.io.Serializable, Cloneable, Comparable<finishFateOperation_result> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("finishFateOperation_result");
private static final org.apache.thrift.protocol.TField SEC_FIELD_DESC = new org.apache.thrift.protocol.TField("sec", org.apache.thrift.protocol.TType.STRUCT, (short)1);
@@ -4856,20 +5099,20 @@ import org.slf4j.LoggerFactory;
return 0;
}
+ @Override
public int compareTo(finishFateOperation_result other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
- finishFateOperation_result typedOther = (finishFateOperation_result)other;
- lastComparison = Boolean.valueOf(isSetSec()).compareTo(typedOther.isSetSec());
+ lastComparison = Boolean.valueOf(isSetSec()).compareTo(other.isSetSec());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetSec()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.sec, typedOther.sec);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.sec, other.sec);
if (lastComparison != 0) {
return lastComparison;
}