You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@fluo.apache.org by GitBox <gi...@apache.org> on 2018/11/06 15:10:11 UTC
[GitHub] cjmctague closed pull request #1056: Update Thrift to 0.11.0 to
match Accumulo
cjmctague closed pull request #1056: Update Thrift to 0.11.0 to match Accumulo
URL: https://github.com/apache/fluo/pull/1056
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):
diff --git a/modules/core/pom.xml b/modules/core/pom.xml
index 7406acf0..e1201d34 100644
--- a/modules/core/pom.xml
+++ b/modules/core/pom.xml
@@ -72,7 +72,7 @@
<dependency>
<groupId>org.apache.thrift</groupId>
<artifactId>libthrift</artifactId>
- <version>0.9.1</version>
+ <version>0.11.0</version>
<optional>true</optional>
</dependency>
<dependency>
diff --git a/modules/core/src/main/java/org/apache/fluo/core/thrift/OracleService.java b/modules/core/src/main/java/org/apache/fluo/core/thrift/OracleService.java
index df1aa62c..3ae06af0 100644
--- a/modules/core/src/main/java/org/apache/fluo/core/thrift/OracleService.java
+++ b/modules/core/src/main/java/org/apache/fluo/core/thrift/OracleService.java
@@ -1,37 +1,19 @@
/**
- * Autogenerated by Thrift Compiler (0.9.1)
+ * Autogenerated by Thrift Compiler (0.11.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
- *
- * @generated
+ * @generated
*/
package org.apache.fluo.core.thrift;
-import java.util.BitSet;
-import java.util.Collections;
-import java.util.EnumMap;
-import java.util.EnumSet;
-import java.util.HashMap;
-import java.util.Map;
-
-import org.apache.thrift.EncodingUtils;
-import org.apache.thrift.TException;
-import org.apache.thrift.async.AsyncMethodCallback;
-import org.apache.thrift.protocol.TTupleProtocol;
-import org.apache.thrift.scheme.IScheme;
-import org.apache.thrift.scheme.SchemeFactory;
-import org.apache.thrift.scheme.StandardScheme;
-import org.apache.thrift.scheme.TupleScheme;
-import org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-@SuppressWarnings({"rawtypes", "unused", "serial", "unchecked"})
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
+@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.11.0)",
+ date = "2018-10-30")
public class OracleService {
public interface Iface {
- public Stamps getTimestamps(String id, int num) throws org.apache.thrift.TException;
+ public Stamps getTimestamps(java.lang.String id, int num) throws org.apache.thrift.TException;
public boolean isLeader() throws org.apache.thrift.TException;
@@ -39,11 +21,12 @@
public interface AsyncIface {
- public void getTimestamps(String id, int num,
- org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ public void getTimestamps(java.lang.String id, int num,
+ org.apache.thrift.async.AsyncMethodCallback<Stamps> resultHandler)
throws org.apache.thrift.TException;
- public void isLeader(org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ public void isLeader(
+ org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean> resultHandler)
throws org.apache.thrift.TException;
}
@@ -71,12 +54,13 @@ public Client(org.apache.thrift.protocol.TProtocol iprot,
super(iprot, oprot);
}
- public Stamps getTimestamps(String id, int num) throws org.apache.thrift.TException {
+ public Stamps getTimestamps(java.lang.String id, int num) throws org.apache.thrift.TException {
send_getTimestamps(id, num);
return recv_getTimestamps();
}
- public void send_getTimestamps(String id, int num) throws org.apache.thrift.TException {
+ public void send_getTimestamps(java.lang.String id, int num)
+ throws org.apache.thrift.TException {
getTimestamps_args args = new getTimestamps_args();
args.setId(id);
args.setNum(num);
@@ -141,8 +125,8 @@ public AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory,
super(protocolFactory, clientManager, transport);
}
- public void getTimestamps(String id, int num,
- org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ public void getTimestamps(java.lang.String id, int num,
+ org.apache.thrift.async.AsyncMethodCallback<Stamps> resultHandler)
throws org.apache.thrift.TException {
checkReady();
getTimestamps_call method_call =
@@ -151,12 +135,13 @@ public void getTimestamps(String id, int num,
___manager.call(method_call);
}
- public static class getTimestamps_call extends org.apache.thrift.async.TAsyncMethodCall {
- private String id;
+ public static class getTimestamps_call
+ extends org.apache.thrift.async.TAsyncMethodCall<Stamps> {
+ private java.lang.String id;
private int num;
- public getTimestamps_call(String id, int num,
- org.apache.thrift.async.AsyncMethodCallback resultHandler,
+ public getTimestamps_call(java.lang.String id, int num,
+ org.apache.thrift.async.AsyncMethodCallback<Stamps> resultHandler,
org.apache.thrift.async.TAsyncClient client,
org.apache.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.thrift.transport.TNonblockingTransport transport)
@@ -179,7 +164,7 @@ public void write_args(org.apache.thrift.protocol.TProtocol prot)
public Stamps getResult() throws org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
+ throw new java.lang.IllegalStateException("Method call not finished!");
}
org.apache.thrift.transport.TMemoryInputTransport memoryTransport =
new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
@@ -189,7 +174,8 @@ public Stamps getResult() throws org.apache.thrift.TException {
}
}
- public void isLeader(org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ public void isLeader(
+ org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean> resultHandler)
throws org.apache.thrift.TException {
checkReady();
isLeader_call method_call =
@@ -198,8 +184,10 @@ public void isLeader(org.apache.thrift.async.AsyncMethodCallback resultHandler)
___manager.call(method_call);
}
- public static class isLeader_call extends org.apache.thrift.async.TAsyncMethodCall {
- public isLeader_call(org.apache.thrift.async.AsyncMethodCallback resultHandler,
+ public static class isLeader_call
+ extends org.apache.thrift.async.TAsyncMethodCall<java.lang.Boolean> {
+ public isLeader_call(
+ org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean> resultHandler,
org.apache.thrift.async.TAsyncClient client,
org.apache.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.thrift.transport.TNonblockingTransport transport)
@@ -216,9 +204,9 @@ public void write_args(org.apache.thrift.protocol.TProtocol prot)
prot.writeMessageEnd();
}
- public boolean getResult() throws org.apache.thrift.TException {
+ public java.lang.Boolean getResult() throws org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
+ throw new java.lang.IllegalStateException("Method call not finished!");
}
org.apache.thrift.transport.TMemoryInputTransport memoryTransport =
new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
@@ -232,20 +220,21 @@ public boolean getResult() throws org.apache.thrift.TException {
public static class Processor<I extends Iface> extends org.apache.thrift.TBaseProcessor<I>
implements org.apache.thrift.TProcessor {
- private static final Logger LOGGER = LoggerFactory.getLogger(Processor.class.getName());
+ private static final org.slf4j.Logger _LOGGER =
+ org.slf4j.LoggerFactory.getLogger(Processor.class.getName());
public Processor(I iface) {
super(iface, getProcessMap(
- new HashMap<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>>()));
+ new java.util.HashMap<java.lang.String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>>()));
}
protected Processor(I iface,
- Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) {
+ java.util.Map<java.lang.String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) {
super(iface, getProcessMap(processMap));
}
- private static <I extends Iface> Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> getProcessMap(
- Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) {
+ private static <I extends Iface> java.util.Map<java.lang.String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> getProcessMap(
+ java.util.Map<java.lang.String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) {
processMap.put("getTimestamps", new getTimestamps());
processMap.put("isLeader", new isLeader());
return processMap;
@@ -265,6 +254,11 @@ protected boolean isOneway() {
return false;
}
+ @Override
+ protected boolean handleRuntimeExceptions() {
+ return false;
+ }
+
public getTimestamps_result getResult(I iface, getTimestamps_args args)
throws org.apache.thrift.TException {
getTimestamps_result result = new getTimestamps_result();
@@ -287,6 +281,11 @@ protected boolean isOneway() {
return false;
}
+ @Override
+ protected boolean handleRuntimeExceptions() {
+ return false;
+ }
+
public isLeader_result getResult(I iface, isLeader_args args)
throws org.apache.thrift.TException {
isLeader_result result = new isLeader_result();
@@ -300,20 +299,21 @@ public isLeader_result getResult(I iface, isLeader_args args)
public static class AsyncProcessor<I extends AsyncIface>
extends org.apache.thrift.TBaseAsyncProcessor<I> {
- private static final Logger LOGGER = LoggerFactory.getLogger(AsyncProcessor.class.getName());
+ private static final org.slf4j.Logger _LOGGER =
+ org.slf4j.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, ?>>()));
+ new java.util.HashMap<java.lang.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) {
+ java.util.Map<java.lang.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) {
+ private static <I extends AsyncIface> java.util.Map<java.lang.String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>> getProcessMap(
+ java.util.Map<java.lang.String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>> processMap) {
processMap.put("getTimestamps", new getTimestamps());
processMap.put("isLeader", new isLeader());
return processMap;
@@ -329,38 +329,49 @@ public getTimestamps_args getEmptyArgsInstance() {
return new getTimestamps_args();
}
- public AsyncMethodCallback<Stamps> getResultHandler(final AsyncFrameBuffer fb,
+ public org.apache.thrift.async.AsyncMethodCallback<Stamps> getResultHandler(
+ final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb,
final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Stamps>() {
+ return new org.apache.thrift.async.AsyncMethodCallback<Stamps>() {
public void onComplete(Stamps o) {
getTimestamps_result result = new getTimestamps_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);
+ } catch (org.apache.thrift.transport.TTransportException e) {
+ _LOGGER.error("TTransportException writing to internal frame buffer", e);
+ fb.close();
+ } catch (java.lang.Exception e) {
+ _LOGGER.error("Exception writing to internal frame buffer", e);
+ onError(e);
}
- fb.close();
}
- public void onError(Exception e) {
+ public void onError(java.lang.Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
- org.apache.thrift.TBase msg;
+ org.apache.thrift.TSerializable msg;
getTimestamps_result result = new getTimestamps_result();
- {
+ if (e instanceof org.apache.thrift.transport.TTransportException) {
+ _LOGGER.error("TTransportException inside handler", e);
+ fb.close();
+ return;
+ } else if (e instanceof org.apache.thrift.TApplicationException) {
+ _LOGGER.error("TApplicationException inside handler", e);
msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
- msg = (org.apache.thrift.TBase) new org.apache.thrift.TApplicationException(
+ msg = (org.apache.thrift.TApplicationException) e;
+ } else {
+ _LOGGER.error("Exception inside handler", e);
+ msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
+ msg = 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);
+ } catch (java.lang.Exception ex) {
+ _LOGGER.error("Exception writing to internal frame buffer", ex);
+ fb.close();
}
- fb.close();
}
};
}
@@ -370,13 +381,14 @@ protected boolean isOneway() {
}
public void start(I iface, getTimestamps_args args,
- org.apache.thrift.async.AsyncMethodCallback<Stamps> resultHandler) throws TException {
+ org.apache.thrift.async.AsyncMethodCallback<Stamps> resultHandler)
+ throws org.apache.thrift.TException {
iface.getTimestamps(args.id, args.num, resultHandler);
}
}
public static class isLeader<I extends AsyncIface>
- extends org.apache.thrift.AsyncProcessFunction<I, isLeader_args, Boolean> {
+ extends org.apache.thrift.AsyncProcessFunction<I, isLeader_args, java.lang.Boolean> {
public isLeader() {
super("isLeader");
}
@@ -385,39 +397,50 @@ public isLeader_args getEmptyArgsInstance() {
return new isLeader_args();
}
- public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb,
+ public org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean> getResultHandler(
+ final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb,
final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Boolean>() {
- public void onComplete(Boolean o) {
+ return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean>() {
+ public void onComplete(java.lang.Boolean o) {
isLeader_result result = new isLeader_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);
+ } catch (org.apache.thrift.transport.TTransportException e) {
+ _LOGGER.error("TTransportException writing to internal frame buffer", e);
+ fb.close();
+ } catch (java.lang.Exception e) {
+ _LOGGER.error("Exception writing to internal frame buffer", e);
+ onError(e);
}
- fb.close();
}
- public void onError(Exception e) {
+ public void onError(java.lang.Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
- org.apache.thrift.TBase msg;
+ org.apache.thrift.TSerializable msg;
isLeader_result result = new isLeader_result();
- {
+ if (e instanceof org.apache.thrift.transport.TTransportException) {
+ _LOGGER.error("TTransportException inside handler", e);
+ fb.close();
+ return;
+ } else if (e instanceof org.apache.thrift.TApplicationException) {
+ _LOGGER.error("TApplicationException inside handler", e);
+ msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
+ msg = (org.apache.thrift.TApplicationException) e;
+ } else {
+ _LOGGER.error("Exception inside handler", e);
msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
- msg = (org.apache.thrift.TBase) new org.apache.thrift.TApplicationException(
+ msg = 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);
+ } catch (java.lang.Exception ex) {
+ _LOGGER.error("Exception writing to internal frame buffer", ex);
+ fb.close();
}
- fb.close();
}
};
}
@@ -427,7 +450,8 @@ protected boolean isOneway() {
}
public void start(I iface, isLeader_args args,
- org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean> resultHandler)
+ throws org.apache.thrift.TException {
iface.isLeader(resultHandler);
}
}
@@ -447,14 +471,12 @@ public void start(I iface, isLeader_args args,
new org.apache.thrift.protocol.TField("num", org.apache.thrift.protocol.TType.I32,
(short) 2);
- private static final Map<Class<? extends IScheme>, SchemeFactory> schemes =
- new HashMap<Class<? extends IScheme>, SchemeFactory>();
- static {
- schemes.put(StandardScheme.class, new getTimestamps_argsStandardSchemeFactory());
- schemes.put(TupleScheme.class, new getTimestamps_argsTupleSchemeFactory());
- }
+ private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY =
+ new getTimestamps_argsStandardSchemeFactory();
+ private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY =
+ new getTimestamps_argsTupleSchemeFactory();
- public String id; // required
+ public java.lang.String id; // required
public int num; // required
/**
@@ -464,10 +486,11 @@ public void start(I iface, isLeader_args args,
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
ID((short) 1, "id"), NUM((short) 2, "num");
- private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+ private static final java.util.Map<java.lang.String, _Fields> byName =
+ new java.util.HashMap<java.lang.String, _Fields>();
static {
- for (_Fields field : EnumSet.allOf(_Fields.class)) {
+ for (_Fields field : java.util.EnumSet.allOf(_Fields.class)) {
byName.put(field.getFieldName(), field);
}
}
@@ -492,21 +515,21 @@ public static _Fields findByThriftId(int fieldId) {
public static _Fields findByThriftIdOrThrow(int fieldId) {
_Fields fields = findByThriftId(fieldId);
if (fields == null)
- throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+ throw new java.lang.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) {
+ public static _Fields findByName(java.lang.String name) {
return byName.get(name);
}
private final short _thriftId;
- private final String _fieldName;
+ private final java.lang.String _fieldName;
- _Fields(short thriftId, String fieldName) {
+ _Fields(short thriftId, java.lang.String fieldName) {
_thriftId = thriftId;
_fieldName = fieldName;
}
@@ -515,7 +538,7 @@ public short getThriftFieldId() {
return _thriftId;
}
- public String getFieldName() {
+ public java.lang.String getFieldName() {
return _fieldName;
}
}
@@ -523,10 +546,10 @@ public String getFieldName() {
// isset id assignments
private static final int __NUM_ISSET_ID = 0;
private byte __isset_bitfield = 0;
- public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
+ public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
- Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap =
- new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
+ java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap =
+ new java.util.EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
tmpMap.put(_Fields.ID,
new org.apache.thrift.meta_data.FieldMetaData("id",
org.apache.thrift.TFieldRequirementType.DEFAULT,
@@ -537,14 +560,14 @@ public String getFieldName() {
org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(
org.apache.thrift.protocol.TType.I32)));
- metaDataMap = Collections.unmodifiableMap(tmpMap);
+ metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getTimestamps_args.class,
metaDataMap);
}
public getTimestamps_args() {}
- public getTimestamps_args(String id, int num) {
+ public getTimestamps_args(java.lang.String id, int num) {
this();
this.id = id;
this.num = num;
@@ -573,11 +596,11 @@ public void clear() {
this.num = 0;
}
- public String getId() {
+ public java.lang.String getId() {
return this.id;
}
- public getTimestamps_args setId(String id) {
+ public getTimestamps_args setId(java.lang.String id) {
this.id = id;
return this;
}
@@ -608,25 +631,26 @@ public getTimestamps_args setNum(int num) {
}
public void unsetNum() {
- __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NUM_ISSET_ID);
+ __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __NUM_ISSET_ID);
}
/** Returns true if field num is set (has been assigned a value) and false otherwise */
public boolean isSetNum() {
- return EncodingUtils.testBit(__isset_bitfield, __NUM_ISSET_ID);
+ return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __NUM_ISSET_ID);
}
public void setNumIsSet(boolean value) {
- __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NUM_ISSET_ID, value);
+ __isset_bitfield =
+ org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __NUM_ISSET_ID, value);
}
- public void setFieldValue(_Fields field, Object value) {
+ public void setFieldValue(_Fields field, java.lang.Object value) {
switch (field) {
case ID:
if (value == null) {
unsetId();
} else {
- setId((String) value);
+ setId((java.lang.String) value);
}
break;
@@ -634,23 +658,23 @@ public void setFieldValue(_Fields field, Object value) {
if (value == null) {
unsetNum();
} else {
- setNum((Integer) value);
+ setNum((java.lang.Integer) value);
}
break;
}
}
- public Object getFieldValue(_Fields field) {
+ public java.lang.Object getFieldValue(_Fields field) {
switch (field) {
case ID:
return getId();
case NUM:
- return Integer.valueOf(getNum());
+ return getNum();
}
- throw new IllegalStateException();
+ throw new java.lang.IllegalStateException();
}
/**
@@ -659,7 +683,7 @@ public Object getFieldValue(_Fields field) {
*/
public boolean isSet(_Fields field) {
if (field == null) {
- throw new IllegalArgumentException();
+ throw new java.lang.IllegalArgumentException();
}
switch (field) {
@@ -668,11 +692,11 @@ public boolean isSet(_Fields field) {
case NUM:
return isSetNum();
}
- throw new IllegalStateException();
+ throw new java.lang.IllegalStateException();
}
@Override
- public boolean equals(Object that) {
+ public boolean equals(java.lang.Object that) {
if (that == null)
return false;
if (that instanceof getTimestamps_args)
@@ -683,6 +707,8 @@ public boolean equals(Object that) {
public boolean equals(getTimestamps_args that) {
if (that == null)
return false;
+ if (this == that)
+ return true;
boolean this_present_id = true && this.isSetId();
boolean that_present_id = true && that.isSetId();
@@ -707,7 +733,15 @@ public boolean equals(getTimestamps_args that) {
@Override
public int hashCode() {
- return 0;
+ int hashCode = 1;
+
+ hashCode = hashCode * 8191 + ((isSetId()) ? 131071 : 524287);
+ if (isSetId())
+ hashCode = hashCode * 8191 + id.hashCode();
+
+ hashCode = hashCode * 8191 + num;
+
+ return hashCode;
}
@Override
@@ -718,7 +752,7 @@ public int compareTo(getTimestamps_args other) {
int lastComparison = 0;
- lastComparison = Boolean.valueOf(isSetId()).compareTo(other.isSetId());
+ lastComparison = java.lang.Boolean.valueOf(isSetId()).compareTo(other.isSetId());
if (lastComparison != 0) {
return lastComparison;
}
@@ -728,7 +762,7 @@ public int compareTo(getTimestamps_args other) {
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(isSetNum()).compareTo(other.isSetNum());
+ lastComparison = java.lang.Boolean.valueOf(isSetNum()).compareTo(other.isSetNum());
if (lastComparison != 0) {
return lastComparison;
}
@@ -747,17 +781,17 @@ public _Fields fieldForId(int fieldId) {
public void read(org.apache.thrift.protocol.TProtocol iprot)
throws org.apache.thrift.TException {
- schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
+ scheme(iprot).read(iprot, this);
}
public void write(org.apache.thrift.protocol.TProtocol oprot)
throws org.apache.thrift.TException {
- schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
+ scheme(oprot).write(oprot, this);
}
@Override
- public String toString() {
- StringBuilder sb = new StringBuilder("getTimestamps_args(");
+ public java.lang.String toString() {
+ java.lang.StringBuilder sb = new java.lang.StringBuilder("getTimestamps_args(");
boolean first = true;
sb.append("id:");
@@ -791,7 +825,7 @@ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOExcept
}
private void readObject(java.io.ObjectInputStream in)
- throws java.io.IOException, ClassNotFoundException {
+ throws java.io.IOException, java.lang.ClassNotFoundException {
try {
// it doesn't seem like you should have to do this, but java serialization is wacky, and
// doesn't call the default constructor.
@@ -803,14 +837,15 @@ private void readObject(java.io.ObjectInputStream in)
}
}
- private static class getTimestamps_argsStandardSchemeFactory implements SchemeFactory {
+ private static class getTimestamps_argsStandardSchemeFactory
+ implements org.apache.thrift.scheme.SchemeFactory {
public getTimestamps_argsStandardScheme getScheme() {
return new getTimestamps_argsStandardScheme();
}
}
private static class getTimestamps_argsStandardScheme
- extends StandardScheme<getTimestamps_args> {
+ extends org.apache.thrift.scheme.StandardScheme<getTimestamps_args> {
public void read(org.apache.thrift.protocol.TProtocol iprot, getTimestamps_args struct)
throws org.apache.thrift.TException {
@@ -869,19 +904,22 @@ public void write(org.apache.thrift.protocol.TProtocol oprot, getTimestamps_args
}
- private static class getTimestamps_argsTupleSchemeFactory implements SchemeFactory {
+ private static class getTimestamps_argsTupleSchemeFactory
+ implements org.apache.thrift.scheme.SchemeFactory {
public getTimestamps_argsTupleScheme getScheme() {
return new getTimestamps_argsTupleScheme();
}
}
- private static class getTimestamps_argsTupleScheme extends TupleScheme<getTimestamps_args> {
+ private static class getTimestamps_argsTupleScheme
+ extends org.apache.thrift.scheme.TupleScheme<getTimestamps_args> {
@Override
public void write(org.apache.thrift.protocol.TProtocol prot, getTimestamps_args struct)
throws org.apache.thrift.TException {
- TTupleProtocol oprot = (TTupleProtocol) prot;
- BitSet optionals = new BitSet();
+ org.apache.thrift.protocol.TTupleProtocol oprot =
+ (org.apache.thrift.protocol.TTupleProtocol) prot;
+ java.util.BitSet optionals = new java.util.BitSet();
if (struct.isSetId()) {
optionals.set(0);
}
@@ -900,8 +938,9 @@ public void write(org.apache.thrift.protocol.TProtocol prot, getTimestamps_args
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, getTimestamps_args struct)
throws org.apache.thrift.TException {
- TTupleProtocol iprot = (TTupleProtocol) prot;
- BitSet incoming = iprot.readBitSet(2);
+ org.apache.thrift.protocol.TTupleProtocol iprot =
+ (org.apache.thrift.protocol.TTupleProtocol) prot;
+ java.util.BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
struct.id = iprot.readString();
struct.setIdIsSet(true);
@@ -913,6 +952,12 @@ public void read(org.apache.thrift.protocol.TProtocol prot, getTimestamps_args s
}
}
+ private static <S extends org.apache.thrift.scheme.IScheme> S scheme(
+ org.apache.thrift.protocol.TProtocol proto) {
+ return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme())
+ ? STANDARD_SCHEME_FACTORY
+ : TUPLE_SCHEME_FACTORY).getScheme();
+ }
}
public static class getTimestamps_result
@@ -925,12 +970,10 @@ public void read(org.apache.thrift.protocol.TProtocol prot, getTimestamps_args s
new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.STRUCT,
(short) 0);
- private static final Map<Class<? extends IScheme>, SchemeFactory> schemes =
- new HashMap<Class<? extends IScheme>, SchemeFactory>();
- static {
- schemes.put(StandardScheme.class, new getTimestamps_resultStandardSchemeFactory());
- schemes.put(TupleScheme.class, new getTimestamps_resultTupleSchemeFactory());
- }
+ private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY =
+ new getTimestamps_resultStandardSchemeFactory();
+ private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY =
+ new getTimestamps_resultTupleSchemeFactory();
public Stamps success; // required
@@ -941,10 +984,11 @@ public void read(org.apache.thrift.protocol.TProtocol prot, getTimestamps_args s
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
SUCCESS((short) 0, "success");
- private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+ private static final java.util.Map<java.lang.String, _Fields> byName =
+ new java.util.HashMap<java.lang.String, _Fields>();
static {
- for (_Fields field : EnumSet.allOf(_Fields.class)) {
+ for (_Fields field : java.util.EnumSet.allOf(_Fields.class)) {
byName.put(field.getFieldName(), field);
}
}
@@ -967,21 +1011,21 @@ public static _Fields findByThriftId(int fieldId) {
public static _Fields findByThriftIdOrThrow(int fieldId) {
_Fields fields = findByThriftId(fieldId);
if (fields == null)
- throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+ throw new java.lang.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) {
+ public static _Fields findByName(java.lang.String name) {
return byName.get(name);
}
private final short _thriftId;
- private final String _fieldName;
+ private final java.lang.String _fieldName;
- _Fields(short thriftId, String fieldName) {
+ _Fields(short thriftId, java.lang.String fieldName) {
_thriftId = thriftId;
_fieldName = fieldName;
}
@@ -990,22 +1034,22 @@ public short getThriftFieldId() {
return _thriftId;
}
- public String getFieldName() {
+ public java.lang.String getFieldName() {
return _fieldName;
}
}
// isset id assignments
- public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
+ public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
- Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap =
- new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
+ java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap =
+ new java.util.EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
tmpMap.put(_Fields.SUCCESS,
new org.apache.thrift.meta_data.FieldMetaData("success",
org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.StructMetaData(
org.apache.thrift.protocol.TType.STRUCT, Stamps.class)));
- metaDataMap = Collections.unmodifiableMap(tmpMap);
+ metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getTimestamps_result.class,
metaDataMap);
}
@@ -1059,7 +1103,7 @@ public void setSuccessIsSet(boolean value) {
}
}
- public void setFieldValue(_Fields field, Object value) {
+ public void setFieldValue(_Fields field, java.lang.Object value) {
switch (field) {
case SUCCESS:
if (value == null) {
@@ -1072,13 +1116,13 @@ public void setFieldValue(_Fields field, Object value) {
}
}
- public Object getFieldValue(_Fields field) {
+ public java.lang.Object getFieldValue(_Fields field) {
switch (field) {
case SUCCESS:
return getSuccess();
}
- throw new IllegalStateException();
+ throw new java.lang.IllegalStateException();
}
/**
@@ -1087,18 +1131,18 @@ public Object getFieldValue(_Fields field) {
*/
public boolean isSet(_Fields field) {
if (field == null) {
- throw new IllegalArgumentException();
+ throw new java.lang.IllegalArgumentException();
}
switch (field) {
case SUCCESS:
return isSetSuccess();
}
- throw new IllegalStateException();
+ throw new java.lang.IllegalStateException();
}
@Override
- public boolean equals(Object that) {
+ public boolean equals(java.lang.Object that) {
if (that == null)
return false;
if (that instanceof getTimestamps_result)
@@ -1109,6 +1153,8 @@ public boolean equals(Object that) {
public boolean equals(getTimestamps_result that) {
if (that == null)
return false;
+ if (this == that)
+ return true;
boolean this_present_success = true && this.isSetSuccess();
boolean that_present_success = true && that.isSetSuccess();
@@ -1124,7 +1170,13 @@ public boolean equals(getTimestamps_result that) {
@Override
public int hashCode() {
- return 0;
+ int hashCode = 1;
+
+ hashCode = hashCode * 8191 + ((isSetSuccess()) ? 131071 : 524287);
+ if (isSetSuccess())
+ hashCode = hashCode * 8191 + success.hashCode();
+
+ return hashCode;
}
@Override
@@ -1135,7 +1187,7 @@ public int compareTo(getTimestamps_result other) {
int lastComparison = 0;
- lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(other.isSetSuccess());
+ lastComparison = java.lang.Boolean.valueOf(isSetSuccess()).compareTo(other.isSetSuccess());
if (lastComparison != 0) {
return lastComparison;
}
@@ -1154,17 +1206,17 @@ public _Fields fieldForId(int fieldId) {
public void read(org.apache.thrift.protocol.TProtocol iprot)
throws org.apache.thrift.TException {
- schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
+ scheme(iprot).read(iprot, this);
}
public void write(org.apache.thrift.protocol.TProtocol oprot)
throws org.apache.thrift.TException {
- schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
+ scheme(oprot).write(oprot, this);
}
@Override
- public String toString() {
- StringBuilder sb = new StringBuilder("getTimestamps_result(");
+ public java.lang.String toString() {
+ java.lang.StringBuilder sb = new java.lang.StringBuilder("getTimestamps_result(");
boolean first = true;
sb.append("success:");
@@ -1196,7 +1248,7 @@ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOExcept
}
private void readObject(java.io.ObjectInputStream in)
- throws java.io.IOException, ClassNotFoundException {
+ throws java.io.IOException, java.lang.ClassNotFoundException {
try {
read(new org.apache.thrift.protocol.TCompactProtocol(
new org.apache.thrift.transport.TIOStreamTransport(in)));
@@ -1205,14 +1257,15 @@ private void readObject(java.io.ObjectInputStream in)
}
}
- private static class getTimestamps_resultStandardSchemeFactory implements SchemeFactory {
+ private static class getTimestamps_resultStandardSchemeFactory
+ implements org.apache.thrift.scheme.SchemeFactory {
public getTimestamps_resultStandardScheme getScheme() {
return new getTimestamps_resultStandardScheme();
}
}
private static class getTimestamps_resultStandardScheme
- extends StandardScheme<getTimestamps_result> {
+ extends org.apache.thrift.scheme.StandardScheme<getTimestamps_result> {
public void read(org.apache.thrift.protocol.TProtocol iprot, getTimestamps_result struct)
throws org.apache.thrift.TException {
@@ -1261,19 +1314,22 @@ public void write(org.apache.thrift.protocol.TProtocol oprot, getTimestamps_resu
}
- private static class getTimestamps_resultTupleSchemeFactory implements SchemeFactory {
+ private static class getTimestamps_resultTupleSchemeFactory
+ implements org.apache.thrift.scheme.SchemeFactory {
public getTimestamps_resultTupleScheme getScheme() {
return new getTimestamps_resultTupleScheme();
}
}
- private static class getTimestamps_resultTupleScheme extends TupleScheme<getTimestamps_result> {
+ private static class getTimestamps_resultTupleScheme
+ extends org.apache.thrift.scheme.TupleScheme<getTimestamps_result> {
@Override
public void write(org.apache.thrift.protocol.TProtocol prot, getTimestamps_result struct)
throws org.apache.thrift.TException {
- TTupleProtocol oprot = (TTupleProtocol) prot;
- BitSet optionals = new BitSet();
+ org.apache.thrift.protocol.TTupleProtocol oprot =
+ (org.apache.thrift.protocol.TTupleProtocol) prot;
+ java.util.BitSet optionals = new java.util.BitSet();
if (struct.isSetSuccess()) {
optionals.set(0);
}
@@ -1286,8 +1342,9 @@ public void write(org.apache.thrift.protocol.TProtocol prot, getTimestamps_resul
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, getTimestamps_result struct)
throws org.apache.thrift.TException {
- TTupleProtocol iprot = (TTupleProtocol) prot;
- BitSet incoming = iprot.readBitSet(1);
+ org.apache.thrift.protocol.TTupleProtocol iprot =
+ (org.apache.thrift.protocol.TTupleProtocol) prot;
+ java.util.BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
struct.success = new Stamps();
struct.success.read(iprot);
@@ -1296,6 +1353,12 @@ public void read(org.apache.thrift.protocol.TProtocol prot, getTimestamps_result
}
}
+ private static <S extends org.apache.thrift.scheme.IScheme> S scheme(
+ org.apache.thrift.protocol.TProtocol proto) {
+ return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme())
+ ? STANDARD_SCHEME_FACTORY
+ : TUPLE_SCHEME_FACTORY).getScheme();
+ }
}
public static class isLeader_args
@@ -1305,12 +1368,10 @@ public void read(org.apache.thrift.protocol.TProtocol prot, getTimestamps_result
new org.apache.thrift.protocol.TStruct("isLeader_args");
- private static final Map<Class<? extends IScheme>, SchemeFactory> schemes =
- new HashMap<Class<? extends IScheme>, SchemeFactory>();
- static {
- schemes.put(StandardScheme.class, new isLeader_argsStandardSchemeFactory());
- schemes.put(TupleScheme.class, new isLeader_argsTupleSchemeFactory());
- }
+ private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY =
+ new isLeader_argsStandardSchemeFactory();
+ private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY =
+ new isLeader_argsTupleSchemeFactory();
/**
@@ -1320,10 +1381,11 @@ public void read(org.apache.thrift.protocol.TProtocol prot, getTimestamps_result
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
;
- private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+ private static final java.util.Map<java.lang.String, _Fields> byName =
+ new java.util.HashMap<java.lang.String, _Fields>();
static {
- for (_Fields field : EnumSet.allOf(_Fields.class)) {
+ for (_Fields field : java.util.EnumSet.allOf(_Fields.class)) {
byName.put(field.getFieldName(), field);
}
}
@@ -1344,21 +1406,21 @@ public static _Fields findByThriftId(int fieldId) {
public static _Fields findByThriftIdOrThrow(int fieldId) {
_Fields fields = findByThriftId(fieldId);
if (fields == null)
- throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+ throw new java.lang.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) {
+ public static _Fields findByName(java.lang.String name) {
return byName.get(name);
}
private final short _thriftId;
- private final String _fieldName;
+ private final java.lang.String _fieldName;
- _Fields(short thriftId, String fieldName) {
+ _Fields(short thriftId, java.lang.String fieldName) {
_thriftId = thriftId;
_fieldName = fieldName;
}
@@ -1367,16 +1429,16 @@ public short getThriftFieldId() {
return _thriftId;
}
- public String getFieldName() {
+ public java.lang.String getFieldName() {
return _fieldName;
}
}
- public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
+ public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
- Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap =
- new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
- metaDataMap = Collections.unmodifiableMap(tmpMap);
+ java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap =
+ new java.util.EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
+ metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(isLeader_args.class,
metaDataMap);
}
@@ -1395,15 +1457,15 @@ public isLeader_args deepCopy() {
@Override
public void clear() {}
- public void setFieldValue(_Fields field, Object value) {
+ public void setFieldValue(_Fields field, java.lang.Object value) {
switch (field) {
}
}
- public Object getFieldValue(_Fields field) {
+ public java.lang.Object getFieldValue(_Fields field) {
switch (field) {
}
- throw new IllegalStateException();
+ throw new java.lang.IllegalStateException();
}
/**
@@ -1412,16 +1474,16 @@ public Object getFieldValue(_Fields field) {
*/
public boolean isSet(_Fields field) {
if (field == null) {
- throw new IllegalArgumentException();
+ throw new java.lang.IllegalArgumentException();
}
switch (field) {
}
- throw new IllegalStateException();
+ throw new java.lang.IllegalStateException();
}
@Override
- public boolean equals(Object that) {
+ public boolean equals(java.lang.Object that) {
if (that == null)
return false;
if (that instanceof isLeader_args)
@@ -1432,13 +1494,17 @@ public boolean equals(Object that) {
public boolean equals(isLeader_args that) {
if (that == null)
return false;
+ if (this == that)
+ return true;
return true;
}
@Override
public int hashCode() {
- return 0;
+ int hashCode = 1;
+
+ return hashCode;
}
@Override
@@ -1458,17 +1524,17 @@ public _Fields fieldForId(int fieldId) {
public void read(org.apache.thrift.protocol.TProtocol iprot)
throws org.apache.thrift.TException {
- schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
+ scheme(iprot).read(iprot, this);
}
public void write(org.apache.thrift.protocol.TProtocol oprot)
throws org.apache.thrift.TException {
- schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
+ scheme(oprot).write(oprot, this);
}
@Override
- public String toString() {
- StringBuilder sb = new StringBuilder("isLeader_args(");
+ public java.lang.String toString() {
+ java.lang.StringBuilder sb = new java.lang.StringBuilder("isLeader_args(");
boolean first = true;
sb.append(")");
@@ -1490,7 +1556,7 @@ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOExcept
}
private void readObject(java.io.ObjectInputStream in)
- throws java.io.IOException, ClassNotFoundException {
+ throws java.io.IOException, java.lang.ClassNotFoundException {
try {
read(new org.apache.thrift.protocol.TCompactProtocol(
new org.apache.thrift.transport.TIOStreamTransport(in)));
@@ -1499,13 +1565,15 @@ private void readObject(java.io.ObjectInputStream in)
}
}
- private static class isLeader_argsStandardSchemeFactory implements SchemeFactory {
+ private static class isLeader_argsStandardSchemeFactory
+ implements org.apache.thrift.scheme.SchemeFactory {
public isLeader_argsStandardScheme getScheme() {
return new isLeader_argsStandardScheme();
}
}
- private static class isLeader_argsStandardScheme extends StandardScheme<isLeader_args> {
+ private static class isLeader_argsStandardScheme
+ extends org.apache.thrift.scheme.StandardScheme<isLeader_args> {
public void read(org.apache.thrift.protocol.TProtocol iprot, isLeader_args struct)
throws org.apache.thrift.TException {
@@ -1540,27 +1608,37 @@ public void write(org.apache.thrift.protocol.TProtocol oprot, isLeader_args stru
}
- private static class isLeader_argsTupleSchemeFactory implements SchemeFactory {
+ private static class isLeader_argsTupleSchemeFactory
+ implements org.apache.thrift.scheme.SchemeFactory {
public isLeader_argsTupleScheme getScheme() {
return new isLeader_argsTupleScheme();
}
}
- private static class isLeader_argsTupleScheme extends TupleScheme<isLeader_args> {
+ private static class isLeader_argsTupleScheme
+ extends org.apache.thrift.scheme.TupleScheme<isLeader_args> {
@Override
public void write(org.apache.thrift.protocol.TProtocol prot, isLeader_args struct)
throws org.apache.thrift.TException {
- TTupleProtocol oprot = (TTupleProtocol) prot;
+ org.apache.thrift.protocol.TTupleProtocol oprot =
+ (org.apache.thrift.protocol.TTupleProtocol) prot;
}
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, isLeader_args struct)
throws org.apache.thrift.TException {
- TTupleProtocol iprot = (TTupleProtocol) prot;
+ org.apache.thrift.protocol.TTupleProtocol iprot =
+ (org.apache.thrift.protocol.TTupleProtocol) prot;
}
}
+ private static <S extends org.apache.thrift.scheme.IScheme> S scheme(
+ org.apache.thrift.protocol.TProtocol proto) {
+ return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme())
+ ? STANDARD_SCHEME_FACTORY
+ : TUPLE_SCHEME_FACTORY).getScheme();
+ }
}
public static class isLeader_result
@@ -1573,12 +1651,10 @@ public void read(org.apache.thrift.protocol.TProtocol prot, isLeader_args struct
new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.BOOL,
(short) 0);
- private static final Map<Class<? extends IScheme>, SchemeFactory> schemes =
- new HashMap<Class<? extends IScheme>, SchemeFactory>();
- static {
- schemes.put(StandardScheme.class, new isLeader_resultStandardSchemeFactory());
- schemes.put(TupleScheme.class, new isLeader_resultTupleSchemeFactory());
- }
+ private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY =
+ new isLeader_resultStandardSchemeFactory();
+ private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY =
+ new isLeader_resultTupleSchemeFactory();
public boolean success; // required
@@ -1589,10 +1665,11 @@ public void read(org.apache.thrift.protocol.TProtocol prot, isLeader_args struct
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
SUCCESS((short) 0, "success");
- private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+ private static final java.util.Map<java.lang.String, _Fields> byName =
+ new java.util.HashMap<java.lang.String, _Fields>();
static {
- for (_Fields field : EnumSet.allOf(_Fields.class)) {
+ for (_Fields field : java.util.EnumSet.allOf(_Fields.class)) {
byName.put(field.getFieldName(), field);
}
}
@@ -1615,21 +1692,21 @@ public static _Fields findByThriftId(int fieldId) {
public static _Fields findByThriftIdOrThrow(int fieldId) {
_Fields fields = findByThriftId(fieldId);
if (fields == null)
- throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+ throw new java.lang.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) {
+ public static _Fields findByName(java.lang.String name) {
return byName.get(name);
}
private final short _thriftId;
- private final String _fieldName;
+ private final java.lang.String _fieldName;
- _Fields(short thriftId, String fieldName) {
+ _Fields(short thriftId, java.lang.String fieldName) {
_thriftId = thriftId;
_fieldName = fieldName;
}
@@ -1638,7 +1715,7 @@ public short getThriftFieldId() {
return _thriftId;
}
- public String getFieldName() {
+ public java.lang.String getFieldName() {
return _fieldName;
}
}
@@ -1646,16 +1723,16 @@ public String getFieldName() {
// isset id assignments
private static final int __SUCCESS_ISSET_ID = 0;
private byte __isset_bitfield = 0;
- public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
+ public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
- Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap =
- new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
+ java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap =
+ new java.util.EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
tmpMap.put(_Fields.SUCCESS,
new org.apache.thrift.meta_data.FieldMetaData("success",
org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(
org.apache.thrift.protocol.TType.BOOL)));
- metaDataMap = Collections.unmodifiableMap(tmpMap);
+ metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(isLeader_result.class,
metaDataMap);
}
@@ -1697,38 +1774,40 @@ public isLeader_result setSuccess(boolean success) {
}
public void unsetSuccess() {
- __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __SUCCESS_ISSET_ID);
+ __isset_bitfield =
+ org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __SUCCESS_ISSET_ID);
}
/** Returns true if field success is set (has been assigned a value) and false otherwise */
public boolean isSetSuccess() {
- return EncodingUtils.testBit(__isset_bitfield, __SUCCESS_ISSET_ID);
+ return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __SUCCESS_ISSET_ID);
}
public void setSuccessIsSet(boolean value) {
- __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __SUCCESS_ISSET_ID, value);
+ __isset_bitfield =
+ org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __SUCCESS_ISSET_ID, value);
}
- public void setFieldValue(_Fields field, Object value) {
+ public void setFieldValue(_Fields field, java.lang.Object value) {
switch (field) {
case SUCCESS:
if (value == null) {
unsetSuccess();
} else {
- setSuccess((Boolean) value);
+ setSuccess((java.lang.Boolean) value);
}
break;
}
}
- public Object getFieldValue(_Fields field) {
+ public java.lang.Object getFieldValue(_Fields field) {
switch (field) {
case SUCCESS:
- return Boolean.valueOf(isSuccess());
+ return isSuccess();
}
- throw new IllegalStateException();
+ throw new java.lang.IllegalStateException();
}
/**
@@ -1737,18 +1816,18 @@ public Object getFieldValue(_Fields field) {
*/
public boolean isSet(_Fields field) {
if (field == null) {
- throw new IllegalArgumentException();
+ throw new java.lang.IllegalArgumentException();
}
switch (field) {
case SUCCESS:
return isSetSuccess();
}
- throw new IllegalStateException();
+ throw new java.lang.IllegalStateException();
}
@Override
- public boolean equals(Object that) {
+ public boolean equals(java.lang.Object that) {
if (that == null)
return false;
if (that instanceof isLeader_result)
@@ -1759,6 +1838,8 @@ public boolean equals(Object that) {
public boolean equals(isLeader_result that) {
if (that == null)
return false;
+ if (this == that)
+ return true;
boolean this_present_success = true;
boolean that_present_success = true;
@@ -1774,7 +1855,11 @@ public boolean equals(isLeader_result that) {
@Override
public int hashCode() {
- return 0;
+ int hashCode = 1;
+
+ hashCode = hashCode * 8191 + ((success) ? 131071 : 524287);
+
+ return hashCode;
}
@Override
@@ -1785,7 +1870,7 @@ public int compareTo(isLeader_result other) {
int lastComparison = 0;
- lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(other.isSetSuccess());
+ lastComparison = java.lang.Boolean.valueOf(isSetSuccess()).compareTo(other.isSetSuccess());
if (lastComparison != 0) {
return lastComparison;
}
@@ -1804,17 +1889,17 @@ public _Fields fieldForId(int fieldId) {
public void read(org.apache.thrift.protocol.TProtocol iprot)
throws org.apache.thrift.TException {
- schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
+ scheme(iprot).read(iprot, this);
}
public void write(org.apache.thrift.protocol.TProtocol oprot)
throws org.apache.thrift.TException {
- schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
+ scheme(oprot).write(oprot, this);
}
@Override
- public String toString() {
- StringBuilder sb = new StringBuilder("isLeader_result(");
+ public java.lang.String toString() {
+ java.lang.StringBuilder sb = new java.lang.StringBuilder("isLeader_result(");
boolean first = true;
sb.append("success:");
@@ -1839,7 +1924,7 @@ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOExcept
}
private void readObject(java.io.ObjectInputStream in)
- throws java.io.IOException, ClassNotFoundException {
+ throws java.io.IOException, java.lang.ClassNotFoundException {
try {
// it doesn't seem like you should have to do this, but java serialization is wacky, and
// doesn't call the default constructor.
@@ -1851,13 +1936,15 @@ private void readObject(java.io.ObjectInputStream in)
}
}
- private static class isLeader_resultStandardSchemeFactory implements SchemeFactory {
+ private static class isLeader_resultStandardSchemeFactory
+ implements org.apache.thrift.scheme.SchemeFactory {
public isLeader_resultStandardScheme getScheme() {
return new isLeader_resultStandardScheme();
}
}
- private static class isLeader_resultStandardScheme extends StandardScheme<isLeader_result> {
+ private static class isLeader_resultStandardScheme
+ extends org.apache.thrift.scheme.StandardScheme<isLeader_result> {
public void read(org.apache.thrift.protocol.TProtocol iprot, isLeader_result struct)
throws org.apache.thrift.TException {
@@ -1905,19 +1992,22 @@ public void write(org.apache.thrift.protocol.TProtocol oprot, isLeader_result st
}
- private static class isLeader_resultTupleSchemeFactory implements SchemeFactory {
+ private static class isLeader_resultTupleSchemeFactory
+ implements org.apache.thrift.scheme.SchemeFactory {
public isLeader_resultTupleScheme getScheme() {
return new isLeader_resultTupleScheme();
}
}
- private static class isLeader_resultTupleScheme extends TupleScheme<isLeader_result> {
+ private static class isLeader_resultTupleScheme
+ extends org.apache.thrift.scheme.TupleScheme<isLeader_result> {
@Override
public void write(org.apache.thrift.protocol.TProtocol prot, isLeader_result struct)
throws org.apache.thrift.TException {
- TTupleProtocol oprot = (TTupleProtocol) prot;
- BitSet optionals = new BitSet();
+ org.apache.thrift.protocol.TTupleProtocol oprot =
+ (org.apache.thrift.protocol.TTupleProtocol) prot;
+ java.util.BitSet optionals = new java.util.BitSet();
if (struct.isSetSuccess()) {
optionals.set(0);
}
@@ -1930,8 +2020,9 @@ public void write(org.apache.thrift.protocol.TProtocol prot, isLeader_result str
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, isLeader_result struct)
throws org.apache.thrift.TException {
- TTupleProtocol iprot = (TTupleProtocol) prot;
- BitSet incoming = iprot.readBitSet(1);
+ org.apache.thrift.protocol.TTupleProtocol iprot =
+ (org.apache.thrift.protocol.TTupleProtocol) prot;
+ java.util.BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
struct.success = iprot.readBool();
struct.setSuccessIsSet(true);
@@ -1939,6 +2030,12 @@ public void read(org.apache.thrift.protocol.TProtocol prot, isLeader_result stru
}
}
+ private static <S extends org.apache.thrift.scheme.IScheme> S scheme(
+ org.apache.thrift.protocol.TProtocol proto) {
+ return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme())
+ ? STANDARD_SCHEME_FACTORY
+ : TUPLE_SCHEME_FACTORY).getScheme();
+ }
}
}
diff --git a/modules/core/src/main/java/org/apache/fluo/core/thrift/Stamps.java b/modules/core/src/main/java/org/apache/fluo/core/thrift/Stamps.java
index c63c8e6d..7df4dd7e 100644
--- a/modules/core/src/main/java/org/apache/fluo/core/thrift/Stamps.java
+++ b/modules/core/src/main/java/org/apache/fluo/core/thrift/Stamps.java
@@ -1,27 +1,14 @@
/**
- * Autogenerated by Thrift Compiler (0.9.1)
+ * Autogenerated by Thrift Compiler (0.11.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
- *
- * @generated
+ * @generated
*/
package org.apache.fluo.core.thrift;
-import java.util.BitSet;
-import java.util.Collections;
-import java.util.EnumMap;
-import java.util.EnumSet;
-import java.util.HashMap;
-import java.util.Map;
-
-import org.apache.thrift.EncodingUtils;
-import org.apache.thrift.protocol.TTupleProtocol;
-import org.apache.thrift.scheme.IScheme;
-import org.apache.thrift.scheme.SchemeFactory;
-import org.apache.thrift.scheme.StandardScheme;
-import org.apache.thrift.scheme.TupleScheme;
-
-@SuppressWarnings({"rawtypes", "unused", "serial", "unchecked"})
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
+@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.11.0)",
+ date = "2018-10-30")
public class Stamps implements org.apache.thrift.TBase<Stamps, Stamps._Fields>,
java.io.Serializable, Cloneable, Comparable<Stamps> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC =
@@ -34,12 +21,10 @@
new org.apache.thrift.protocol.TField("gcStamp", org.apache.thrift.protocol.TType.I64,
(short) 2);
- private static final Map<Class<? extends IScheme>, SchemeFactory> schemes =
- new HashMap<Class<? extends IScheme>, SchemeFactory>();
- static {
- schemes.put(StandardScheme.class, new StampsStandardSchemeFactory());
- schemes.put(TupleScheme.class, new StampsTupleSchemeFactory());
- }
+ private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY =
+ new StampsStandardSchemeFactory();
+ private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY =
+ new StampsTupleSchemeFactory();
public long txStampsStart; // required
public long gcStamp; // required
@@ -51,10 +36,11 @@
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
TX_STAMPS_START((short) 1, "txStampsStart"), GC_STAMP((short) 2, "gcStamp");
- private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+ private static final java.util.Map<java.lang.String, _Fields> byName =
+ new java.util.HashMap<java.lang.String, _Fields>();
static {
- for (_Fields field : EnumSet.allOf(_Fields.class)) {
+ for (_Fields field : java.util.EnumSet.allOf(_Fields.class)) {
byName.put(field.getFieldName(), field);
}
}
@@ -79,32 +65,30 @@ public static _Fields findByThriftId(int fieldId) {
public static _Fields findByThriftIdOrThrow(int fieldId) {
_Fields fields = findByThriftId(fieldId);
if (fields == null)
- throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+ throw new java.lang.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) {
+ public static _Fields findByName(java.lang.String name) {
return byName.get(name);
}
private final short _thriftId;
- private final String _fieldName;
+ private final java.lang.String _fieldName;
- _Fields(short thriftId, String fieldName) {
+ _Fields(short thriftId, java.lang.String fieldName) {
_thriftId = thriftId;
_fieldName = fieldName;
}
- @Override
public short getThriftFieldId() {
return _thriftId;
}
- @Override
- public String getFieldName() {
+ public java.lang.String getFieldName() {
return _fieldName;
}
}
@@ -113,17 +97,17 @@ public String getFieldName() {
private static final int __TXSTAMPSSTART_ISSET_ID = 0;
private static final int __GCSTAMP_ISSET_ID = 1;
private byte __isset_bitfield = 0;
- public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
+ public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
- Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap =
- new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
+ java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap =
+ new java.util.EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
tmpMap.put(_Fields.TX_STAMPS_START, new org.apache.thrift.meta_data.FieldMetaData(
"txStampsStart", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
tmpMap.put(_Fields.GC_STAMP, new org.apache.thrift.meta_data.FieldMetaData("gcStamp",
org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
- metaDataMap = Collections.unmodifiableMap(tmpMap);
+ metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(Stamps.class, metaDataMap);
}
@@ -146,7 +130,6 @@ public Stamps(Stamps other) {
this.gcStamp = other.gcStamp;
}
- @Override
public Stamps deepCopy() {
return new Stamps(this);
}
@@ -170,16 +153,18 @@ public Stamps setTxStampsStart(long txStampsStart) {
}
public void unsetTxStampsStart() {
- __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TXSTAMPSSTART_ISSET_ID);
+ __isset_bitfield =
+ org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __TXSTAMPSSTART_ISSET_ID);
}
/** Returns true if field txStampsStart is set (has been assigned a value) and false otherwise */
public boolean isSetTxStampsStart() {
- return EncodingUtils.testBit(__isset_bitfield, __TXSTAMPSSTART_ISSET_ID);
+ return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __TXSTAMPSSTART_ISSET_ID);
}
public void setTxStampsStartIsSet(boolean value) {
- __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TXSTAMPSSTART_ISSET_ID, value);
+ __isset_bitfield =
+ org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __TXSTAMPSSTART_ISSET_ID, value);
}
public long getGcStamp() {
@@ -193,26 +178,27 @@ public Stamps setGcStamp(long gcStamp) {
}
public void unsetGcStamp() {
- __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __GCSTAMP_ISSET_ID);
+ __isset_bitfield =
+ org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __GCSTAMP_ISSET_ID);
}
/** Returns true if field gcStamp is set (has been assigned a value) and false otherwise */
public boolean isSetGcStamp() {
- return EncodingUtils.testBit(__isset_bitfield, __GCSTAMP_ISSET_ID);
+ return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __GCSTAMP_ISSET_ID);
}
public void setGcStampIsSet(boolean value) {
- __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __GCSTAMP_ISSET_ID, value);
+ __isset_bitfield =
+ org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __GCSTAMP_ISSET_ID, value);
}
- @Override
- public void setFieldValue(_Fields field, Object value) {
+ public void setFieldValue(_Fields field, java.lang.Object value) {
switch (field) {
case TX_STAMPS_START:
if (value == null) {
unsetTxStampsStart();
} else {
- setTxStampsStart((Long) value);
+ setTxStampsStart((java.lang.Long) value);
}
break;
@@ -220,34 +206,32 @@ public void setFieldValue(_Fields field, Object value) {
if (value == null) {
unsetGcStamp();
} else {
- setGcStamp((Long) value);
+ setGcStamp((java.lang.Long) value);
}
break;
}
}
- @Override
- public Object getFieldValue(_Fields field) {
+ public java.lang.Object getFieldValue(_Fields field) {
switch (field) {
case TX_STAMPS_START:
- return Long.valueOf(getTxStampsStart());
+ return getTxStampsStart();
case GC_STAMP:
- return Long.valueOf(getGcStamp());
+ return getGcStamp();
}
- throw new IllegalStateException();
+ throw new java.lang.IllegalStateException();
}
/**
* Returns true if field corresponding to fieldID is set (has been assigned a value) and false
* otherwise
*/
- @Override
public boolean isSet(_Fields field) {
if (field == null) {
- throw new IllegalArgumentException();
+ throw new java.lang.IllegalArgumentException();
}
switch (field) {
@@ -256,11 +240,11 @@ public boolean isSet(_Fields field) {
case GC_STAMP:
return isSetGcStamp();
}
- throw new IllegalStateException();
+ throw new java.lang.IllegalStateException();
}
@Override
- public boolean equals(Object that) {
+ public boolean equals(java.lang.Object that) {
if (that == null)
return false;
if (that instanceof Stamps)
@@ -271,6 +255,8 @@ public boolean equals(Object that) {
public boolean equals(Stamps that) {
if (that == null)
return false;
+ if (this == that)
+ return true;
boolean this_present_txStampsStart = true;
boolean that_present_txStampsStart = true;
@@ -295,7 +281,13 @@ public boolean equals(Stamps that) {
@Override
public int hashCode() {
- return 0;
+ int hashCode = 1;
+
+ hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(txStampsStart);
+
+ hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(gcStamp);
+
+ return hashCode;
}
@Override
@@ -306,7 +298,8 @@ public int compareTo(Stamps other) {
int lastComparison = 0;
- lastComparison = Boolean.valueOf(isSetTxStampsStart()).compareTo(other.isSetTxStampsStart());
+ lastComparison =
+ java.lang.Boolean.valueOf(isSetTxStampsStart()).compareTo(other.isSetTxStampsStart());
if (lastComparison != 0) {
return lastComparison;
}
@@ -317,7 +310,7 @@ public int compareTo(Stamps other) {
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(isSetGcStamp()).compareTo(other.isSetGcStamp());
+ lastComparison = java.lang.Boolean.valueOf(isSetGcStamp()).compareTo(other.isSetGcStamp());
if (lastComparison != 0) {
return lastComparison;
}
@@ -330,25 +323,22 @@ public int compareTo(Stamps other) {
return 0;
}
- @Override
public _Fields fieldForId(int fieldId) {
return _Fields.findByThriftId(fieldId);
}
- @Override
public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
- schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
+ scheme(iprot).read(iprot, this);
}
- @Override
public void write(org.apache.thrift.protocol.TProtocol oprot)
throws org.apache.thrift.TException {
- schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
+ scheme(oprot).write(oprot, this);
}
@Override
- public String toString() {
- StringBuilder sb = new StringBuilder("Stamps(");
+ public java.lang.String toString() {
+ java.lang.StringBuilder sb = new java.lang.StringBuilder("Stamps(");
boolean first = true;
sb.append("txStampsStart:");
@@ -378,7 +368,7 @@ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOExcept
}
private void readObject(java.io.ObjectInputStream in)
- throws java.io.IOException, ClassNotFoundException {
+ throws java.io.IOException, java.lang.ClassNotFoundException {
try {
// it doesn't seem like you should have to do this, but java serialization is wacky, and
// doesn't call the default constructor.
@@ -390,16 +380,16 @@ private void readObject(java.io.ObjectInputStream in)
}
}
- private static class StampsStandardSchemeFactory implements SchemeFactory {
- @Override
+ private static class StampsStandardSchemeFactory
+ implements org.apache.thrift.scheme.SchemeFactory {
public StampsStandardScheme getScheme() {
return new StampsStandardScheme();
}
}
- private static class StampsStandardScheme extends StandardScheme<Stamps> {
+ private static class StampsStandardScheme
+ extends org.apache.thrift.scheme.StandardScheme<Stamps> {
- @Override
public void read(org.apache.thrift.protocol.TProtocol iprot, Stamps struct)
throws org.apache.thrift.TException {
org.apache.thrift.protocol.TField schemeField;
@@ -437,7 +427,6 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, Stamps struct)
struct.validate();
}
- @Override
public void write(org.apache.thrift.protocol.TProtocol oprot, Stamps struct)
throws org.apache.thrift.TException {
struct.validate();
@@ -455,20 +444,20 @@ public void write(org.apache.thrift.protocol.TProtocol oprot, Stamps struct)
}
- private static class StampsTupleSchemeFactory implements SchemeFactory {
- @Override
+ private static class StampsTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public StampsTupleScheme getScheme() {
return new StampsTupleScheme();
}
}
- private static class StampsTupleScheme extends TupleScheme<Stamps> {
+ private static class StampsTupleScheme extends org.apache.thrift.scheme.TupleScheme<Stamps> {
@Override
public void write(org.apache.thrift.protocol.TProtocol prot, Stamps struct)
throws org.apache.thrift.TException {
- TTupleProtocol oprot = (TTupleProtocol) prot;
- BitSet optionals = new BitSet();
+ org.apache.thrift.protocol.TTupleProtocol oprot =
+ (org.apache.thrift.protocol.TTupleProtocol) prot;
+ java.util.BitSet optionals = new java.util.BitSet();
if (struct.isSetTxStampsStart()) {
optionals.set(0);
}
@@ -487,8 +476,9 @@ public void write(org.apache.thrift.protocol.TProtocol prot, Stamps struct)
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, Stamps struct)
throws org.apache.thrift.TException {
- TTupleProtocol iprot = (TTupleProtocol) prot;
- BitSet incoming = iprot.readBitSet(2);
+ org.apache.thrift.protocol.TTupleProtocol iprot =
+ (org.apache.thrift.protocol.TTupleProtocol) prot;
+ java.util.BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
struct.txStampsStart = iprot.readI64();
struct.setTxStampsStartIsSet(true);
@@ -500,4 +490,10 @@ public void read(org.apache.thrift.protocol.TProtocol prot, Stamps struct)
}
}
+ private static <S extends org.apache.thrift.scheme.IScheme> S scheme(
+ org.apache.thrift.protocol.TProtocol proto) {
+ return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme())
+ ? STANDARD_SCHEME_FACTORY
+ : TUPLE_SCHEME_FACTORY).getScheme();
+ }
}
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
With regards,
Apache Git Services