This is an automated email from the ASF dual-hosted git repository.
kturner pushed a commit to branch 1451-external-compactions-feature
in repository https://gitbox.apache.org/repos/asf/accumulo.git
commit 4553d84c15117110f99068485d7f8cf090ce199a
Author: Keith Turner <ktur...@apache.org>
AuthorDate: Thu Mar 11 19:56:52 2021 -0500
regenerated thrift
---
.../compaction/thrift/CompactionCoordinator.java | 976 ++++++++++-----------
1 file changed, 488 insertions(+), 488 deletions(-)
diff --git
a/core/src/main/java/org/apache/accumulo/core/compaction/thrift/CompactionCoordinator.java
b/core/src/main/java/org/apache/accumulo/core/compaction/thrift/CompactionCoordinator.java
index d2f38f0..99ec016 100644
---
a/core/src/main/java/org/apache/accumulo/core/compaction/thrift/CompactionCoordinator.java
+++
b/core/src/main/java/org/apache/accumulo/core/compaction/thrift/CompactionCoordinator.java
@@ -31,11 +31,11 @@ public class CompactionCoordinator {
public void cancelCompaction(java.lang.String externalCompactionId) throws
UnknownCompactionIdException, org.apache.thrift.TException;
- public java.util.List<Status> getCompactionStatus(java.lang.String
externalCompactionId) throws UnknownCompactionIdException,
org.apache.thrift.TException;
+ public void compactionCompleted(java.lang.String externalCompactionId,
org.apache.accumulo.core.tabletserver.thrift.CompactionStats stats) throws
UnknownCompactionIdException, org.apache.thrift.TException;
public org.apache.accumulo.core.tabletserver.thrift.TExternalCompactionJob
getCompactionJob(java.lang.String queueName, java.lang.String compactor) throws
org.apache.thrift.TException;
- public void compactionCompleted(java.lang.String externalCompactionId,
org.apache.accumulo.core.tabletserver.thrift.CompactionStats stats) throws
UnknownCompactionIdException, org.apache.thrift.TException;
+ public java.util.List<Status> getCompactionStatus(java.lang.String
externalCompactionId) throws UnknownCompactionIdException,
org.apache.thrift.TException;
public void updateCompactionStatus(java.lang.String externalCompactionId,
CompactionState state, java.lang.String message, long timestamp) throws
UnknownCompactionIdException, org.apache.thrift.TException;
@@ -45,11 +45,11 @@ public class CompactionCoordinator {
public void cancelCompaction(java.lang.String externalCompactionId,
org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws
org.apache.thrift.TException;
- public void getCompactionStatus(java.lang.String externalCompactionId,
org.apache.thrift.async.AsyncMethodCallback<java.util.List<Status>>
resultHandler) throws org.apache.thrift.TException;
+ public void compactionCompleted(java.lang.String externalCompactionId,
org.apache.accumulo.core.tabletserver.thrift.CompactionStats stats,
org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws
org.apache.thrift.TException;
public void getCompactionJob(java.lang.String queueName, java.lang.String
compactor,
org.apache.thrift.async.AsyncMethodCallback<org.apache.accumulo.core.tabletserver.thrift.TExternalCompactionJob>
resultHandler) throws org.apache.thrift.TException;
- public void compactionCompleted(java.lang.String externalCompactionId,
org.apache.accumulo.core.tabletserver.thrift.CompactionStats stats,
org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws
org.apache.thrift.TException;
+ public void getCompactionStatus(java.lang.String externalCompactionId,
org.apache.thrift.async.AsyncMethodCallback<java.util.List<Status>>
resultHandler) throws org.apache.thrift.TException;
public void updateCompactionStatus(java.lang.String externalCompactionId,
CompactionState state, java.lang.String message, long timestamp,
org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws
org.apache.thrift.TException;
@@ -98,30 +98,28 @@ public class CompactionCoordinator {
return;
}
- public java.util.List<Status> getCompactionStatus(java.lang.String
externalCompactionId) throws UnknownCompactionIdException,
org.apache.thrift.TException
+ public void compactionCompleted(java.lang.String externalCompactionId,
org.apache.accumulo.core.tabletserver.thrift.CompactionStats stats) throws
UnknownCompactionIdException, org.apache.thrift.TException
{
- send_getCompactionStatus(externalCompactionId);
- return recv_getCompactionStatus();
+ send_compactionCompleted(externalCompactionId, stats);
+ recv_compactionCompleted();
}
- public void send_getCompactionStatus(java.lang.String
externalCompactionId) throws org.apache.thrift.TException
+ public void send_compactionCompleted(java.lang.String
externalCompactionId,
org.apache.accumulo.core.tabletserver.thrift.CompactionStats stats) throws
org.apache.thrift.TException
{
- getCompactionStatus_args args = new getCompactionStatus_args();
+ compactionCompleted_args args = new compactionCompleted_args();
args.setExternalCompactionId(externalCompactionId);
- sendBase("getCompactionStatus", args);
+ args.setStats(stats);
+ sendBase("compactionCompleted", args);
}
- public java.util.List<Status> recv_getCompactionStatus() throws
UnknownCompactionIdException, org.apache.thrift.TException
+ public void recv_compactionCompleted() throws
UnknownCompactionIdException, org.apache.thrift.TException
{
- getCompactionStatus_result result = new getCompactionStatus_result();
- receiveBase(result, "getCompactionStatus");
- if (result.isSetSuccess()) {
- return result.success;
- }
+ compactionCompleted_result result = new compactionCompleted_result();
+ receiveBase(result, "compactionCompleted");
if (result.e != null) {
throw result.e;
}
- throw new
org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT,
"getCompactionStatus failed: unknown result");
+ return;
}
public org.apache.accumulo.core.tabletserver.thrift.TExternalCompactionJob
getCompactionJob(java.lang.String queueName, java.lang.String compactor) throws
org.apache.thrift.TException
@@ -148,28 +146,30 @@ public class CompactionCoordinator {
throw new
org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT,
"getCompactionJob failed: unknown result");
}
- public void compactionCompleted(java.lang.String externalCompactionId,
org.apache.accumulo.core.tabletserver.thrift.CompactionStats stats) throws
UnknownCompactionIdException, org.apache.thrift.TException
+ public java.util.List<Status> getCompactionStatus(java.lang.String
externalCompactionId) throws UnknownCompactionIdException,
org.apache.thrift.TException
{
- send_compactionCompleted(externalCompactionId, stats);
- recv_compactionCompleted();
+ send_getCompactionStatus(externalCompactionId);
+ return recv_getCompactionStatus();
}
- public void send_compactionCompleted(java.lang.String
externalCompactionId,
org.apache.accumulo.core.tabletserver.thrift.CompactionStats stats) throws
org.apache.thrift.TException
+ public void send_getCompactionStatus(java.lang.String
externalCompactionId) throws org.apache.thrift.TException
{
- compactionCompleted_args args = new compactionCompleted_args();
+ getCompactionStatus_args args = new getCompactionStatus_args();
args.setExternalCompactionId(externalCompactionId);
- args.setStats(stats);
- sendBase("compactionCompleted", args);
+ sendBase("getCompactionStatus", args);
}
- public void recv_compactionCompleted() throws
UnknownCompactionIdException, org.apache.thrift.TException
+ public java.util.List<Status> recv_getCompactionStatus() throws
UnknownCompactionIdException, org.apache.thrift.TException
{
- compactionCompleted_result result = new compactionCompleted_result();
- receiveBase(result, "compactionCompleted");
+ getCompactionStatus_result result = new getCompactionStatus_result();
+ receiveBase(result, "getCompactionStatus");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
if (result.e != null) {
throw result.e;
}
- return;
+ throw new
org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT,
"getCompactionStatus failed: unknown result");
}
public void updateCompactionStatus(java.lang.String externalCompactionId,
CompactionState state, java.lang.String message, long timestamp) throws
UnknownCompactionIdException, org.apache.thrift.TException
@@ -248,35 +248,38 @@ public class CompactionCoordinator {
}
}
- public void getCompactionStatus(java.lang.String externalCompactionId,
org.apache.thrift.async.AsyncMethodCallback<java.util.List<Status>>
resultHandler) throws org.apache.thrift.TException {
+ public void compactionCompleted(java.lang.String externalCompactionId,
org.apache.accumulo.core.tabletserver.thrift.CompactionStats stats,
org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws
org.apache.thrift.TException {
checkReady();
- getCompactionStatus_call method_call = new
getCompactionStatus_call(externalCompactionId, resultHandler, this,
___protocolFactory, ___transport);
+ compactionCompleted_call method_call = new
compactionCompleted_call(externalCompactionId, stats, resultHandler, this,
___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
- public static class getCompactionStatus_call extends
org.apache.thrift.async.TAsyncMethodCall<java.util.List<Status>> {
+ public static class compactionCompleted_call extends
org.apache.thrift.async.TAsyncMethodCall<Void> {
private java.lang.String externalCompactionId;
- public getCompactionStatus_call(java.lang.String externalCompactionId,
org.apache.thrift.async.AsyncMethodCallback<java.util.List<Status>>
resultHandler, org.apache.thrift.async.TAsyncClient client,
org.apache.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.thrift.transport.TNonblockingTransport transport) throws
org.apache.thrift.TException {
+ private org.apache.accumulo.core.tabletserver.thrift.CompactionStats
stats;
+ public compactionCompleted_call(java.lang.String externalCompactionId,
org.apache.accumulo.core.tabletserver.thrift.CompactionStats stats,
org.apache.thrift.async.AsyncMethodCallback<Void> 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.externalCompactionId = externalCompactionId;
+ this.stats = stats;
}
public void write_args(org.apache.thrift.protocol.TProtocol prot) throws
org.apache.thrift.TException {
- prot.writeMessageBegin(new
org.apache.thrift.protocol.TMessage("getCompactionStatus",
org.apache.thrift.protocol.TMessageType.CALL, 0));
- getCompactionStatus_args args = new getCompactionStatus_args();
+ prot.writeMessageBegin(new
org.apache.thrift.protocol.TMessage("compactionCompleted",
org.apache.thrift.protocol.TMessageType.CALL, 0));
+ compactionCompleted_args args = new compactionCompleted_args();
args.setExternalCompactionId(externalCompactionId);
+ args.setStats(stats);
args.write(prot);
prot.writeMessageEnd();
}
- public java.util.List<Status> getResult() throws
UnknownCompactionIdException, org.apache.thrift.TException {
+ public Void getResult() throws UnknownCompactionIdException,
org.apache.thrift.TException {
if (getState() !=
org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new java.lang.IllegalStateException("Method call not
finished!");
}
org.apache.thrift.transport.TMemoryInputTransport memoryTransport =
new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
org.apache.thrift.protocol.TProtocol prot =
client.getProtocolFactory().getProtocol(memoryTransport);
- return (new Client(prot)).recv_getCompactionStatus();
+ return null;
}
}
@@ -315,38 +318,35 @@ public class CompactionCoordinator {
}
}
- public void compactionCompleted(java.lang.String externalCompactionId,
org.apache.accumulo.core.tabletserver.thrift.CompactionStats stats,
org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws
org.apache.thrift.TException {
+ public void getCompactionStatus(java.lang.String externalCompactionId,
org.apache.thrift.async.AsyncMethodCallback<java.util.List<Status>>
resultHandler) throws org.apache.thrift.TException {
checkReady();
- compactionCompleted_call method_call = new
compactionCompleted_call(externalCompactionId, stats, resultHandler, this,
___protocolFactory, ___transport);
+ getCompactionStatus_call method_call = new
getCompactionStatus_call(externalCompactionId, resultHandler, this,
___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
- public static class compactionCompleted_call extends
org.apache.thrift.async.TAsyncMethodCall<Void> {
+ public static class getCompactionStatus_call extends
org.apache.thrift.async.TAsyncMethodCall<java.util.List<Status>> {
private java.lang.String externalCompactionId;
- private org.apache.accumulo.core.tabletserver.thrift.CompactionStats
stats;
- public compactionCompleted_call(java.lang.String externalCompactionId,
org.apache.accumulo.core.tabletserver.thrift.CompactionStats stats,
org.apache.thrift.async.AsyncMethodCallback<Void> 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 getCompactionStatus_call(java.lang.String externalCompactionId,
org.apache.thrift.async.AsyncMethodCallback<java.util.List<Status>>
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.externalCompactionId = externalCompactionId;
- this.stats = stats;
}
public void write_args(org.apache.thrift.protocol.TProtocol prot) throws
org.apache.thrift.TException {
- prot.writeMessageBegin(new
org.apache.thrift.protocol.TMessage("compactionCompleted",
org.apache.thrift.protocol.TMessageType.CALL, 0));
- compactionCompleted_args args = new compactionCompleted_args();
+ prot.writeMessageBegin(new
org.apache.thrift.protocol.TMessage("getCompactionStatus",
org.apache.thrift.protocol.TMessageType.CALL, 0));
+ getCompactionStatus_args args = new getCompactionStatus_args();
args.setExternalCompactionId(externalCompactionId);
- args.setStats(stats);
args.write(prot);
prot.writeMessageEnd();
}
- public Void getResult() throws UnknownCompactionIdException,
org.apache.thrift.TException {
+ public java.util.List<Status> getResult() throws
UnknownCompactionIdException, org.apache.thrift.TException {
if (getState() !=
org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new java.lang.IllegalStateException("Method call not
finished!");
}
org.apache.thrift.transport.TMemoryInputTransport memoryTransport =
new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
org.apache.thrift.protocol.TProtocol prot =
client.getProtocolFactory().getProtocol(memoryTransport);
- return null;
+ return (new Client(prot)).recv_getCompactionStatus();
}
}
@@ -405,9 +405,9 @@ public class CompactionCoordinator {
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("cancelCompaction", new cancelCompaction());
- processMap.put("getCompactionStatus", new getCompactionStatus());
- processMap.put("getCompactionJob", new getCompactionJob());
processMap.put("compactionCompleted", new compactionCompleted());
+ processMap.put("getCompactionJob", new getCompactionJob());
+ processMap.put("getCompactionStatus", new getCompactionStatus());
processMap.put("updateCompactionStatus", new updateCompactionStatus());
return processMap;
}
@@ -441,13 +441,13 @@ public class CompactionCoordinator {
}
}
- public static class getCompactionStatus<I extends Iface> extends
org.apache.thrift.ProcessFunction<I, getCompactionStatus_args> {
- public getCompactionStatus() {
- super("getCompactionStatus");
+ public static class compactionCompleted<I extends Iface> extends
org.apache.thrift.ProcessFunction<I, compactionCompleted_args> {
+ public compactionCompleted() {
+ super("compactionCompleted");
}
- public getCompactionStatus_args getEmptyArgsInstance() {
- return new getCompactionStatus_args();
+ public compactionCompleted_args getEmptyArgsInstance() {
+ return new compactionCompleted_args();
}
protected boolean isOneway() {
@@ -459,10 +459,10 @@ public class CompactionCoordinator {
return false;
}
- public getCompactionStatus_result getResult(I iface,
getCompactionStatus_args args) throws org.apache.thrift.TException {
- getCompactionStatus_result result = new getCompactionStatus_result();
+ public compactionCompleted_result getResult(I iface,
compactionCompleted_args args) throws org.apache.thrift.TException {
+ compactionCompleted_result result = new compactionCompleted_result();
try {
- result.success =
iface.getCompactionStatus(args.externalCompactionId);
+ iface.compactionCompleted(args.externalCompactionId, args.stats);
} catch (UnknownCompactionIdException e) {
result.e = e;
}
@@ -495,13 +495,13 @@ public class CompactionCoordinator {
}
}
- public static class compactionCompleted<I extends Iface> extends
org.apache.thrift.ProcessFunction<I, compactionCompleted_args> {
- public compactionCompleted() {
- super("compactionCompleted");
+ public static class getCompactionStatus<I extends Iface> extends
org.apache.thrift.ProcessFunction<I, getCompactionStatus_args> {
+ public getCompactionStatus() {
+ super("getCompactionStatus");
}
- public compactionCompleted_args getEmptyArgsInstance() {
- return new compactionCompleted_args();
+ public getCompactionStatus_args getEmptyArgsInstance() {
+ return new getCompactionStatus_args();
}
protected boolean isOneway() {
@@ -513,10 +513,10 @@ public class CompactionCoordinator {
return false;
}
- public compactionCompleted_result getResult(I iface,
compactionCompleted_args args) throws org.apache.thrift.TException {
- compactionCompleted_result result = new compactionCompleted_result();
+ public getCompactionStatus_result getResult(I iface,
getCompactionStatus_args args) throws org.apache.thrift.TException {
+ getCompactionStatus_result result = new getCompactionStatus_result();
try {
- iface.compactionCompleted(args.externalCompactionId, args.stats);
+ result.success =
iface.getCompactionStatus(args.externalCompactionId);
} catch (UnknownCompactionIdException e) {
result.e = e;
}
@@ -567,9 +567,9 @@ public class CompactionCoordinator {
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("cancelCompaction", new cancelCompaction());
- processMap.put("getCompactionStatus", new getCompactionStatus());
- processMap.put("getCompactionJob", new getCompactionJob());
processMap.put("compactionCompleted", new compactionCompleted());
+ processMap.put("getCompactionJob", new getCompactionJob());
+ processMap.put("getCompactionStatus", new getCompactionStatus());
processMap.put("updateCompactionStatus", new updateCompactionStatus());
return processMap;
}
@@ -638,21 +638,20 @@ public class CompactionCoordinator {
}
}
- public static class getCompactionStatus<I extends AsyncIface> extends
org.apache.thrift.AsyncProcessFunction<I, getCompactionStatus_args,
java.util.List<Status>> {
- public getCompactionStatus() {
- super("getCompactionStatus");
+ public static class compactionCompleted<I extends AsyncIface> extends
org.apache.thrift.AsyncProcessFunction<I, compactionCompleted_args, Void> {
+ public compactionCompleted() {
+ super("compactionCompleted");
}
- public getCompactionStatus_args getEmptyArgsInstance() {
- return new getCompactionStatus_args();
+ public compactionCompleted_args getEmptyArgsInstance() {
+ return new compactionCompleted_args();
}
- public
org.apache.thrift.async.AsyncMethodCallback<java.util.List<Status>>
getResultHandler(final
org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final
int seqid) {
+ public org.apache.thrift.async.AsyncMethodCallback<Void>
getResultHandler(final
org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final
int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new
org.apache.thrift.async.AsyncMethodCallback<java.util.List<Status>>() {
- public void onComplete(java.util.List<Status> o) {
- getCompactionStatus_result result = new
getCompactionStatus_result();
- result.success = o;
+ return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
+ public void onComplete(Void o) {
+ compactionCompleted_result result = new
compactionCompleted_result();
try {
fcall.sendResponse(fb, result,
org.apache.thrift.protocol.TMessageType.REPLY,seqid);
} catch (org.apache.thrift.transport.TTransportException e) {
@@ -666,7 +665,7 @@ public class CompactionCoordinator {
public void onError(java.lang.Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TSerializable msg;
- getCompactionStatus_result result = new
getCompactionStatus_result();
+ compactionCompleted_result result = new
compactionCompleted_result();
if (e instanceof UnknownCompactionIdException) {
result.e = (UnknownCompactionIdException) e;
result.setEIsSet(true);
@@ -698,8 +697,8 @@ public class CompactionCoordinator {
return false;
}
- public void start(I iface, getCompactionStatus_args args,
org.apache.thrift.async.AsyncMethodCallback<java.util.List<Status>>
resultHandler) throws org.apache.thrift.TException {
- iface.getCompactionStatus(args.externalCompactionId,resultHandler);
+ public void start(I iface, compactionCompleted_args args,
org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws
org.apache.thrift.TException {
+ iface.compactionCompleted(args.externalCompactionId,
args.stats,resultHandler);
}
}
@@ -764,20 +763,21 @@ public class CompactionCoordinator {
}
}
- public static class compactionCompleted<I extends AsyncIface> extends
org.apache.thrift.AsyncProcessFunction<I, compactionCompleted_args, Void> {
- public compactionCompleted() {
- super("compactionCompleted");
+ public static class getCompactionStatus<I extends AsyncIface> extends
org.apache.thrift.AsyncProcessFunction<I, getCompactionStatus_args,
java.util.List<Status>> {
+ public getCompactionStatus() {
+ super("getCompactionStatus");
}
- public compactionCompleted_args getEmptyArgsInstance() {
- return new compactionCompleted_args();
+ public getCompactionStatus_args getEmptyArgsInstance() {
+ return new getCompactionStatus_args();
}
- public org.apache.thrift.async.AsyncMethodCallback<Void>
getResultHandler(final
org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final
int seqid) {
+ public
org.apache.thrift.async.AsyncMethodCallback<java.util.List<Status>>
getResultHandler(final
org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final
int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
- public void onComplete(Void o) {
- compactionCompleted_result result = new
compactionCompleted_result();
+ return new
org.apache.thrift.async.AsyncMethodCallback<java.util.List<Status>>() {
+ public void onComplete(java.util.List<Status> o) {
+ getCompactionStatus_result result = new
getCompactionStatus_result();
+ result.success = o;
try {
fcall.sendResponse(fb, result,
org.apache.thrift.protocol.TMessageType.REPLY,seqid);
} catch (org.apache.thrift.transport.TTransportException e) {
@@ -791,7 +791,7 @@ public class CompactionCoordinator {
public void onError(java.lang.Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TSerializable msg;
- compactionCompleted_result result = new
compactionCompleted_result();
+ getCompactionStatus_result result = new
getCompactionStatus_result();
if (e instanceof UnknownCompactionIdException) {
result.e = (UnknownCompactionIdException) e;
result.setEIsSet(true);
@@ -823,8 +823,8 @@ public class CompactionCoordinator {
return false;
}
- public void start(I iface, compactionCompleted_args args,
org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws
org.apache.thrift.TException {
- iface.compactionCompleted(args.externalCompactionId,
args.stats,resultHandler);
+ public void start(I iface, getCompactionStatus_args args,
org.apache.thrift.async.AsyncMethodCallback<java.util.List<Status>>
resultHandler) throws org.apache.thrift.TException {
+ iface.getCompactionStatus(args.externalCompactionId,resultHandler);
}
}
@@ -1630,19 +1630,22 @@ public class CompactionCoordinator {
}
}
- public static class getCompactionStatus_args implements
org.apache.thrift.TBase<getCompactionStatus_args,
getCompactionStatus_args._Fields>, java.io.Serializable, Cloneable,
Comparable<getCompactionStatus_args> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new
org.apache.thrift.protocol.TStruct("getCompactionStatus_args");
+ public static class compactionCompleted_args implements
org.apache.thrift.TBase<compactionCompleted_args,
compactionCompleted_args._Fields>, java.io.Serializable, Cloneable,
Comparable<compactionCompleted_args> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new
org.apache.thrift.protocol.TStruct("compactionCompleted_args");
private static final org.apache.thrift.protocol.TField
EXTERNAL_COMPACTION_ID_FIELD_DESC = new
org.apache.thrift.protocol.TField("externalCompactionId",
org.apache.thrift.protocol.TType.STRING, (short)1);
+ private static final org.apache.thrift.protocol.TField STATS_FIELD_DESC =
new org.apache.thrift.protocol.TField("stats",
org.apache.thrift.protocol.TType.STRUCT, (short)2);
- private static final org.apache.thrift.scheme.SchemeFactory
STANDARD_SCHEME_FACTORY = new getCompactionStatus_argsStandardSchemeFactory();
- private static final org.apache.thrift.scheme.SchemeFactory
TUPLE_SCHEME_FACTORY = new getCompactionStatus_argsTupleSchemeFactory();
+ private static final org.apache.thrift.scheme.SchemeFactory
STANDARD_SCHEME_FACTORY = new compactionCompleted_argsStandardSchemeFactory();
+ private static final org.apache.thrift.scheme.SchemeFactory
TUPLE_SCHEME_FACTORY = new compactionCompleted_argsTupleSchemeFactory();
public @org.apache.thrift.annotation.Nullable java.lang.String
externalCompactionId; // required
+ public @org.apache.thrift.annotation.Nullable
org.apache.accumulo.core.tabletserver.thrift.CompactionStats stats; // required
/** The set of fields this struct contains, along with convenience methods
for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
- EXTERNAL_COMPACTION_ID((short)1, "externalCompactionId");
+ EXTERNAL_COMPACTION_ID((short)1, "externalCompactionId"),
+ STATS((short)2, "stats");
private static final java.util.Map<java.lang.String, _Fields> byName =
new java.util.HashMap<java.lang.String, _Fields>();
@@ -1660,6 +1663,8 @@ public class CompactionCoordinator {
switch(fieldId) {
case 1: // EXTERNAL_COMPACTION_ID
return EXTERNAL_COMPACTION_ID;
+ case 2: // STATS
+ return STATS;
default:
return null;
}
@@ -1706,36 +1711,44 @@ public class CompactionCoordinator {
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.EXTERNAL_COMPACTION_ID, new
org.apache.thrift.meta_data.FieldMetaData("externalCompactionId",
org.apache.thrift.TFieldRequirementType.DEFAULT,
new
org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.STATS, new
org.apache.thrift.meta_data.FieldMetaData("stats",
org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new
org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT,
org.apache.accumulo.core.tabletserver.thrift.CompactionStats.class)));
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
-
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getCompactionStatus_args.class,
metaDataMap);
+
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(compactionCompleted_args.class,
metaDataMap);
}
- public getCompactionStatus_args() {
+ public compactionCompleted_args() {
}
- public getCompactionStatus_args(
- java.lang.String externalCompactionId)
+ public compactionCompleted_args(
+ java.lang.String externalCompactionId,
+ org.apache.accumulo.core.tabletserver.thrift.CompactionStats stats)
{
this();
this.externalCompactionId = externalCompactionId;
+ this.stats = stats;
}
/**
* Performs a deep copy on <i>other</i>.
*/
- public getCompactionStatus_args(getCompactionStatus_args other) {
+ public compactionCompleted_args(compactionCompleted_args other) {
if (other.isSetExternalCompactionId()) {
this.externalCompactionId = other.externalCompactionId;
}
+ if (other.isSetStats()) {
+ this.stats = new
org.apache.accumulo.core.tabletserver.thrift.CompactionStats(other.stats);
+ }
}
- public getCompactionStatus_args deepCopy() {
- return new getCompactionStatus_args(this);
+ public compactionCompleted_args deepCopy() {
+ return new compactionCompleted_args(this);
}
@Override
public void clear() {
this.externalCompactionId = null;
+ this.stats = null;
}
@org.apache.thrift.annotation.Nullable
@@ -1743,7 +1756,7 @@ public class CompactionCoordinator {
return this.externalCompactionId;
}
- public getCompactionStatus_args
setExternalCompactionId(@org.apache.thrift.annotation.Nullable java.lang.String
externalCompactionId) {
+ public compactionCompleted_args
setExternalCompactionId(@org.apache.thrift.annotation.Nullable java.lang.String
externalCompactionId) {
this.externalCompactionId = externalCompactionId;
return this;
}
@@ -1763,6 +1776,31 @@ public class CompactionCoordinator {
}
}
+ @org.apache.thrift.annotation.Nullable
+ public org.apache.accumulo.core.tabletserver.thrift.CompactionStats
getStats() {
+ return this.stats;
+ }
+
+ public compactionCompleted_args
setStats(@org.apache.thrift.annotation.Nullable
org.apache.accumulo.core.tabletserver.thrift.CompactionStats stats) {
+ this.stats = stats;
+ return this;
+ }
+
+ public void unsetStats() {
+ this.stats = null;
+ }
+
+ /** Returns true if field stats is set (has been assigned a value) and
false otherwise */
+ public boolean isSetStats() {
+ return this.stats != null;
+ }
+
+ public void setStatsIsSet(boolean value) {
+ if (!value) {
+ this.stats = null;
+ }
+ }
+
public void setFieldValue(_Fields field,
@org.apache.thrift.annotation.Nullable java.lang.Object value) {
switch (field) {
case EXTERNAL_COMPACTION_ID:
@@ -1773,6 +1811,14 @@ public class CompactionCoordinator {
}
break;
+ case STATS:
+ if (value == null) {
+ unsetStats();
+ } else {
+
setStats((org.apache.accumulo.core.tabletserver.thrift.CompactionStats)value);
+ }
+ break;
+
}
}
@@ -1782,6 +1828,9 @@ public class CompactionCoordinator {
case EXTERNAL_COMPACTION_ID:
return getExternalCompactionId();
+ case STATS:
+ return getStats();
+
}
throw new java.lang.IllegalStateException();
}
@@ -1795,6 +1844,8 @@ public class CompactionCoordinator {
switch (field) {
case EXTERNAL_COMPACTION_ID:
return isSetExternalCompactionId();
+ case STATS:
+ return isSetStats();
}
throw new java.lang.IllegalStateException();
}
@@ -1803,12 +1854,12 @@ public class CompactionCoordinator {
public boolean equals(java.lang.Object that) {
if (that == null)
return false;
- if (that instanceof getCompactionStatus_args)
- return this.equals((getCompactionStatus_args)that);
+ if (that instanceof compactionCompleted_args)
+ return this.equals((compactionCompleted_args)that);
return false;
}
- public boolean equals(getCompactionStatus_args that) {
+ public boolean equals(compactionCompleted_args that) {
if (that == null)
return false;
if (this == that)
@@ -1823,6 +1874,15 @@ public class CompactionCoordinator {
return false;
}
+ boolean this_present_stats = true && this.isSetStats();
+ boolean that_present_stats = true && that.isSetStats();
+ if (this_present_stats || that_present_stats) {
+ if (!(this_present_stats && that_present_stats))
+ return false;
+ if (!this.stats.equals(that.stats))
+ return false;
+ }
+
return true;
}
@@ -1834,11 +1894,15 @@ public class CompactionCoordinator {
if (isSetExternalCompactionId())
hashCode = hashCode * 8191 + externalCompactionId.hashCode();
+ hashCode = hashCode * 8191 + ((isSetStats()) ? 131071 : 524287);
+ if (isSetStats())
+ hashCode = hashCode * 8191 + stats.hashCode();
+
return hashCode;
}
@Override
- public int compareTo(getCompactionStatus_args other) {
+ public int compareTo(compactionCompleted_args other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
@@ -1855,6 +1919,16 @@ public class CompactionCoordinator {
return lastComparison;
}
}
+ lastComparison =
java.lang.Boolean.valueOf(isSetStats()).compareTo(other.isSetStats());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetStats()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.stats,
other.stats);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
return 0;
}
@@ -1873,7 +1947,7 @@ public class CompactionCoordinator {
@Override
public java.lang.String toString() {
- java.lang.StringBuilder sb = new
java.lang.StringBuilder("getCompactionStatus_args(");
+ java.lang.StringBuilder sb = new
java.lang.StringBuilder("compactionCompleted_args(");
boolean first = true;
sb.append("externalCompactionId:");
@@ -1883,6 +1957,14 @@ public class CompactionCoordinator {
sb.append(this.externalCompactionId);
}
first = false;
+ if (!first) sb.append(", ");
+ sb.append("stats:");
+ if (this.stats == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.stats);
+ }
+ first = false;
sb.append(")");
return sb.toString();
}
@@ -1890,6 +1972,9 @@ public class CompactionCoordinator {
public void validate() throws org.apache.thrift.TException {
// check for required fields
// check for sub-struct validity
+ if (stats != null) {
+ stats.validate();
+ }
}
private void writeObject(java.io.ObjectOutputStream out) throws
java.io.IOException {
@@ -1908,15 +1993,15 @@ public class CompactionCoordinator {
}
}
- private static class getCompactionStatus_argsStandardSchemeFactory
implements org.apache.thrift.scheme.SchemeFactory {
- public getCompactionStatus_argsStandardScheme getScheme() {
- return new getCompactionStatus_argsStandardScheme();
+ private static class compactionCompleted_argsStandardSchemeFactory
implements org.apache.thrift.scheme.SchemeFactory {
+ public compactionCompleted_argsStandardScheme getScheme() {
+ return new compactionCompleted_argsStandardScheme();
}
}
- private static class getCompactionStatus_argsStandardScheme extends
org.apache.thrift.scheme.StandardScheme<getCompactionStatus_args> {
+ private static class compactionCompleted_argsStandardScheme extends
org.apache.thrift.scheme.StandardScheme<compactionCompleted_args> {
- public void read(org.apache.thrift.protocol.TProtocol iprot,
getCompactionStatus_args struct) throws org.apache.thrift.TException {
+ public void read(org.apache.thrift.protocol.TProtocol iprot,
compactionCompleted_args struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TField schemeField;
iprot.readStructBegin();
while (true)
@@ -1934,6 +2019,15 @@ public class CompactionCoordinator {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot,
schemeField.type);
}
break;
+ case 2: // STATS
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT)
{
+ struct.stats = new
org.apache.accumulo.core.tabletserver.thrift.CompactionStats();
+ struct.stats.read(iprot);
+ struct.setStatsIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot,
schemeField.type);
+ }
+ break;
default:
org.apache.thrift.protocol.TProtocolUtil.skip(iprot,
schemeField.type);
}
@@ -1945,7 +2039,7 @@ public class CompactionCoordinator {
struct.validate();
}
- public void write(org.apache.thrift.protocol.TProtocol oprot,
getCompactionStatus_args struct) throws org.apache.thrift.TException {
+ public void write(org.apache.thrift.protocol.TProtocol oprot,
compactionCompleted_args struct) throws org.apache.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
@@ -1954,41 +2048,57 @@ public class CompactionCoordinator {
oprot.writeString(struct.externalCompactionId);
oprot.writeFieldEnd();
}
+ if (struct.stats != null) {
+ oprot.writeFieldBegin(STATS_FIELD_DESC);
+ struct.stats.write(oprot);
+ oprot.writeFieldEnd();
+ }
oprot.writeFieldStop();
oprot.writeStructEnd();
}
}
- private static class getCompactionStatus_argsTupleSchemeFactory implements
org.apache.thrift.scheme.SchemeFactory {
- public getCompactionStatus_argsTupleScheme getScheme() {
- return new getCompactionStatus_argsTupleScheme();
+ private static class compactionCompleted_argsTupleSchemeFactory implements
org.apache.thrift.scheme.SchemeFactory {
+ public compactionCompleted_argsTupleScheme getScheme() {
+ return new compactionCompleted_argsTupleScheme();
}
}
- private static class getCompactionStatus_argsTupleScheme extends
org.apache.thrift.scheme.TupleScheme<getCompactionStatus_args> {
+ private static class compactionCompleted_argsTupleScheme extends
org.apache.thrift.scheme.TupleScheme<compactionCompleted_args> {
@Override
- public void write(org.apache.thrift.protocol.TProtocol prot,
getCompactionStatus_args struct) throws org.apache.thrift.TException {
+ public void write(org.apache.thrift.protocol.TProtocol prot,
compactionCompleted_args struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TTupleProtocol oprot =
(org.apache.thrift.protocol.TTupleProtocol) prot;
java.util.BitSet optionals = new java.util.BitSet();
if (struct.isSetExternalCompactionId()) {
optionals.set(0);
}
- oprot.writeBitSet(optionals, 1);
+ if (struct.isSetStats()) {
+ optionals.set(1);
+ }
+ oprot.writeBitSet(optionals, 2);
if (struct.isSetExternalCompactionId()) {
oprot.writeString(struct.externalCompactionId);
}
+ if (struct.isSetStats()) {
+ struct.stats.write(oprot);
+ }
}
@Override
- public void read(org.apache.thrift.protocol.TProtocol prot,
getCompactionStatus_args struct) throws org.apache.thrift.TException {
+ public void read(org.apache.thrift.protocol.TProtocol prot,
compactionCompleted_args struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TTupleProtocol iprot =
(org.apache.thrift.protocol.TTupleProtocol) prot;
- java.util.BitSet incoming = iprot.readBitSet(1);
+ java.util.BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
struct.externalCompactionId = iprot.readString();
struct.setExternalCompactionIdIsSet(true);
}
+ if (incoming.get(1)) {
+ struct.stats = new
org.apache.accumulo.core.tabletserver.thrift.CompactionStats();
+ struct.stats.read(iprot);
+ struct.setStatsIsSet(true);
+ }
}
}
@@ -1997,21 +2107,18 @@ public class CompactionCoordinator {
}
}
- public static class getCompactionStatus_result implements
org.apache.thrift.TBase<getCompactionStatus_result,
getCompactionStatus_result._Fields>, java.io.Serializable, Cloneable,
Comparable<getCompactionStatus_result> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new
org.apache.thrift.protocol.TStruct("getCompactionStatus_result");
+ public static class compactionCompleted_result implements
org.apache.thrift.TBase<compactionCompleted_result,
compactionCompleted_result._Fields>, java.io.Serializable, Cloneable,
Comparable<compactionCompleted_result> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new
org.apache.thrift.protocol.TStruct("compactionCompleted_result");
- private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC
= new org.apache.thrift.protocol.TField("success",
org.apache.thrift.protocol.TType.LIST, (short)0);
private static final org.apache.thrift.protocol.TField E_FIELD_DESC = new
org.apache.thrift.protocol.TField("e", org.apache.thrift.protocol.TType.STRUCT,
(short)1);
- private static final org.apache.thrift.scheme.SchemeFactory
STANDARD_SCHEME_FACTORY = new getCompactionStatus_resultStandardSchemeFactory();
- private static final org.apache.thrift.scheme.SchemeFactory
TUPLE_SCHEME_FACTORY = new getCompactionStatus_resultTupleSchemeFactory();
+ private static final org.apache.thrift.scheme.SchemeFactory
STANDARD_SCHEME_FACTORY = new compactionCompleted_resultStandardSchemeFactory();
+ private static final org.apache.thrift.scheme.SchemeFactory
TUPLE_SCHEME_FACTORY = new compactionCompleted_resultTupleSchemeFactory();
- public @org.apache.thrift.annotation.Nullable java.util.List<Status>
success; // required
public @org.apache.thrift.annotation.Nullable UnknownCompactionIdException
e; // required
/** The set of fields this struct contains, along with convenience methods
for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
- SUCCESS((short)0, "success"),
E((short)1, "e");
private static final java.util.Map<java.lang.String, _Fields> byName =
new java.util.HashMap<java.lang.String, _Fields>();
@@ -2028,8 +2135,6 @@ public class CompactionCoordinator {
@org.apache.thrift.annotation.Nullable
public static _Fields findByThriftId(int fieldId) {
switch(fieldId) {
- case 0: // SUCCESS
- return SUCCESS;
case 1: // E
return E;
default:
@@ -2076,100 +2181,46 @@ public class CompactionCoordinator {
public static final java.util.Map<_Fields,
org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
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.ListMetaData(org.apache.thrift.protocol.TType.LIST,
- new
org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT,
Status.class))));
tmpMap.put(_Fields.E, new org.apache.thrift.meta_data.FieldMetaData("e",
org.apache.thrift.TFieldRequirementType.DEFAULT,
new
org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT,
UnknownCompactionIdException.class)));
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
-
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getCompactionStatus_result.class,
metaDataMap);
+
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(compactionCompleted_result.class,
metaDataMap);
}
- public getCompactionStatus_result() {
+ public compactionCompleted_result() {
}
- public getCompactionStatus_result(
- java.util.List<Status> success,
+ public compactionCompleted_result(
UnknownCompactionIdException e)
{
this();
- this.success = success;
this.e = e;
}
/**
* Performs a deep copy on <i>other</i>.
*/
- public getCompactionStatus_result(getCompactionStatus_result other) {
- if (other.isSetSuccess()) {
- java.util.List<Status> __this__success = new
java.util.ArrayList<Status>(other.success.size());
- for (Status other_element : other.success) {
- __this__success.add(new Status(other_element));
- }
- this.success = __this__success;
- }
+ public compactionCompleted_result(compactionCompleted_result other) {
if (other.isSetE()) {
this.e = new UnknownCompactionIdException(other.e);
}
}
- public getCompactionStatus_result deepCopy() {
- return new getCompactionStatus_result(this);
+ public compactionCompleted_result deepCopy() {
+ return new compactionCompleted_result(this);
}
@Override
public void clear() {
- this.success = null;
this.e = null;
}
- public int getSuccessSize() {
- return (this.success == null) ? 0 : this.success.size();
- }
-
- @org.apache.thrift.annotation.Nullable
- public java.util.Iterator<Status> getSuccessIterator() {
- return (this.success == null) ? null : this.success.iterator();
- }
-
- public void addToSuccess(Status elem) {
- if (this.success == null) {
- this.success = new java.util.ArrayList<Status>();
- }
- this.success.add(elem);
- }
-
- @org.apache.thrift.annotation.Nullable
- public java.util.List<Status> getSuccess() {
- return this.success;
- }
-
- public getCompactionStatus_result
setSuccess(@org.apache.thrift.annotation.Nullable java.util.List<Status>
success) {
- this.success = success;
- return this;
- }
-
- public void unsetSuccess() {
- this.success = null;
- }
-
- /** Returns true if field success is set (has been assigned a value) and
false otherwise */
- public boolean isSetSuccess() {
- return this.success != null;
- }
-
- public void setSuccessIsSet(boolean value) {
- if (!value) {
- this.success = null;
- }
- }
-
@org.apache.thrift.annotation.Nullable
public UnknownCompactionIdException getE() {
return this.e;
}
- public getCompactionStatus_result
setE(@org.apache.thrift.annotation.Nullable UnknownCompactionIdException e) {
+ public compactionCompleted_result
setE(@org.apache.thrift.annotation.Nullable UnknownCompactionIdException e) {
this.e = e;
return this;
}
@@ -2191,14 +2242,6 @@ public class CompactionCoordinator {
public void setFieldValue(_Fields field,
@org.apache.thrift.annotation.Nullable java.lang.Object value) {
switch (field) {
- case SUCCESS:
- if (value == null) {
- unsetSuccess();
- } else {
- setSuccess((java.util.List<Status>)value);
- }
- break;
-
case E:
if (value == null) {
unsetE();
@@ -2213,9 +2256,6 @@ public class CompactionCoordinator {
@org.apache.thrift.annotation.Nullable
public java.lang.Object getFieldValue(_Fields field) {
switch (field) {
- case SUCCESS:
- return getSuccess();
-
case E:
return getE();
@@ -2230,8 +2270,6 @@ public class CompactionCoordinator {
}
switch (field) {
- case SUCCESS:
- return isSetSuccess();
case E:
return isSetE();
}
@@ -2242,26 +2280,17 @@ public class CompactionCoordinator {
public boolean equals(java.lang.Object that) {
if (that == null)
return false;
- if (that instanceof getCompactionStatus_result)
- return this.equals((getCompactionStatus_result)that);
+ if (that instanceof compactionCompleted_result)
+ return this.equals((compactionCompleted_result)that);
return false;
}
- public boolean equals(getCompactionStatus_result that) {
+ public boolean equals(compactionCompleted_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();
- if (this_present_success || that_present_success) {
- if (!(this_present_success && that_present_success))
- return false;
- if (!this.success.equals(that.success))
- return false;
- }
-
boolean this_present_e = true && this.isSetE();
boolean that_present_e = true && that.isSetE();
if (this_present_e || that_present_e) {
@@ -2278,10 +2307,6 @@ public class CompactionCoordinator {
public int hashCode() {
int hashCode = 1;
- hashCode = hashCode * 8191 + ((isSetSuccess()) ? 131071 : 524287);
- if (isSetSuccess())
- hashCode = hashCode * 8191 + success.hashCode();
-
hashCode = hashCode * 8191 + ((isSetE()) ? 131071 : 524287);
if (isSetE())
hashCode = hashCode * 8191 + e.hashCode();
@@ -2290,23 +2315,13 @@ public class CompactionCoordinator {
}
@Override
- public int compareTo(getCompactionStatus_result other) {
+ public int compareTo(compactionCompleted_result other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
- lastComparison =
java.lang.Boolean.valueOf(isSetSuccess()).compareTo(other.isSetSuccess());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetSuccess()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success,
other.success);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
lastComparison =
java.lang.Boolean.valueOf(isSetE()).compareTo(other.isSetE());
if (lastComparison != 0) {
return lastComparison;
@@ -2335,17 +2350,9 @@ public class CompactionCoordinator {
@Override
public java.lang.String toString() {
- java.lang.StringBuilder sb = new
java.lang.StringBuilder("getCompactionStatus_result(");
+ java.lang.StringBuilder sb = new
java.lang.StringBuilder("compactionCompleted_result(");
boolean first = true;
- sb.append("success:");
- if (this.success == null) {
- sb.append("null");
- } else {
- sb.append(this.success);
- }
- first = false;
- if (!first) sb.append(", ");
sb.append("e:");
if (this.e == null) {
sb.append("null");
@@ -2378,15 +2385,15 @@ public class CompactionCoordinator {
}
}
- private static class getCompactionStatus_resultStandardSchemeFactory
implements org.apache.thrift.scheme.SchemeFactory {
- public getCompactionStatus_resultStandardScheme getScheme() {
- return new getCompactionStatus_resultStandardScheme();
+ private static class compactionCompleted_resultStandardSchemeFactory
implements org.apache.thrift.scheme.SchemeFactory {
+ public compactionCompleted_resultStandardScheme getScheme() {
+ return new compactionCompleted_resultStandardScheme();
}
}
- private static class getCompactionStatus_resultStandardScheme extends
org.apache.thrift.scheme.StandardScheme<getCompactionStatus_result> {
+ private static class compactionCompleted_resultStandardScheme extends
org.apache.thrift.scheme.StandardScheme<compactionCompleted_result> {
- public void read(org.apache.thrift.protocol.TProtocol iprot,
getCompactionStatus_result struct) throws org.apache.thrift.TException {
+ public void read(org.apache.thrift.protocol.TProtocol iprot,
compactionCompleted_result struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TField schemeField;
iprot.readStructBegin();
while (true)
@@ -2396,25 +2403,6 @@ public class CompactionCoordinator {
break;
}
switch (schemeField.id) {
- case 0: // SUCCESS
- if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
- {
- org.apache.thrift.protocol.TList _list0 =
iprot.readListBegin();
- struct.success = new
java.util.ArrayList<Status>(_list0.size);
- @org.apache.thrift.annotation.Nullable Status _elem1;
- for (int _i2 = 0; _i2 < _list0.size; ++_i2)
- {
- _elem1 = new Status();
- _elem1.read(iprot);
- struct.success.add(_elem1);
- }
- iprot.readListEnd();
- }
- struct.setSuccessIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot,
schemeField.type);
- }
- break;
case 1: // E
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT)
{
struct.e = new UnknownCompactionIdException();
@@ -2435,22 +2423,10 @@ public class CompactionCoordinator {
struct.validate();
}
- public void write(org.apache.thrift.protocol.TProtocol oprot,
getCompactionStatus_result struct) throws org.apache.thrift.TException {
+ public void write(org.apache.thrift.protocol.TProtocol oprot,
compactionCompleted_result struct) throws org.apache.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
- if (struct.success != null) {
- oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
- {
- oprot.writeListBegin(new
org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT,
struct.success.size()));
- for (Status _iter3 : struct.success)
- {
- _iter3.write(oprot);
- }
- oprot.writeListEnd();
- }
- oprot.writeFieldEnd();
- }
if (struct.e != null) {
oprot.writeFieldBegin(E_FIELD_DESC);
struct.e.write(oprot);
@@ -2462,58 +2438,32 @@ public class CompactionCoordinator {
}
- private static class getCompactionStatus_resultTupleSchemeFactory
implements org.apache.thrift.scheme.SchemeFactory {
- public getCompactionStatus_resultTupleScheme getScheme() {
- return new getCompactionStatus_resultTupleScheme();
+ private static class compactionCompleted_resultTupleSchemeFactory
implements org.apache.thrift.scheme.SchemeFactory {
+ public compactionCompleted_resultTupleScheme getScheme() {
+ return new compactionCompleted_resultTupleScheme();
}
}
- private static class getCompactionStatus_resultTupleScheme extends
org.apache.thrift.scheme.TupleScheme<getCompactionStatus_result> {
+ private static class compactionCompleted_resultTupleScheme extends
org.apache.thrift.scheme.TupleScheme<compactionCompleted_result> {
@Override
- public void write(org.apache.thrift.protocol.TProtocol prot,
getCompactionStatus_result struct) throws org.apache.thrift.TException {
+ public void write(org.apache.thrift.protocol.TProtocol prot,
compactionCompleted_result struct) throws org.apache.thrift.TException {
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);
- }
if (struct.isSetE()) {
- optionals.set(1);
- }
- oprot.writeBitSet(optionals, 2);
- if (struct.isSetSuccess()) {
- {
- oprot.writeI32(struct.success.size());
- for (Status _iter4 : struct.success)
- {
- _iter4.write(oprot);
- }
- }
+ optionals.set(0);
}
+ oprot.writeBitSet(optionals, 1);
if (struct.isSetE()) {
struct.e.write(oprot);
}
}
@Override
- public void read(org.apache.thrift.protocol.TProtocol prot,
getCompactionStatus_result struct) throws org.apache.thrift.TException {
+ public void read(org.apache.thrift.protocol.TProtocol prot,
compactionCompleted_result struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TTupleProtocol iprot =
(org.apache.thrift.protocol.TTupleProtocol) prot;
- java.util.BitSet incoming = iprot.readBitSet(2);
+ java.util.BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
- {
- org.apache.thrift.protocol.TList _list5 = new
org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT,
iprot.readI32());
- struct.success = new java.util.ArrayList<Status>(_list5.size);
- @org.apache.thrift.annotation.Nullable Status _elem6;
- for (int _i7 = 0; _i7 < _list5.size; ++_i7)
- {
- _elem6 = new Status();
- _elem6.read(iprot);
- struct.success.add(_elem6);
- }
- }
- struct.setSuccessIsSet(true);
- }
- if (incoming.get(1)) {
struct.e = new UnknownCompactionIdException();
struct.e.read(iprot);
struct.setEIsSet(true);
@@ -3370,22 +3320,19 @@ public class CompactionCoordinator {
}
}
- public static class compactionCompleted_args implements
org.apache.thrift.TBase<compactionCompleted_args,
compactionCompleted_args._Fields>, java.io.Serializable, Cloneable,
Comparable<compactionCompleted_args> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new
org.apache.thrift.protocol.TStruct("compactionCompleted_args");
+ public static class getCompactionStatus_args implements
org.apache.thrift.TBase<getCompactionStatus_args,
getCompactionStatus_args._Fields>, java.io.Serializable, Cloneable,
Comparable<getCompactionStatus_args> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new
org.apache.thrift.protocol.TStruct("getCompactionStatus_args");
private static final org.apache.thrift.protocol.TField
EXTERNAL_COMPACTION_ID_FIELD_DESC = new
org.apache.thrift.protocol.TField("externalCompactionId",
org.apache.thrift.protocol.TType.STRING, (short)1);
- private static final org.apache.thrift.protocol.TField STATS_FIELD_DESC =
new org.apache.thrift.protocol.TField("stats",
org.apache.thrift.protocol.TType.STRUCT, (short)2);
- private static final org.apache.thrift.scheme.SchemeFactory
STANDARD_SCHEME_FACTORY = new compactionCompleted_argsStandardSchemeFactory();
- private static final org.apache.thrift.scheme.SchemeFactory
TUPLE_SCHEME_FACTORY = new compactionCompleted_argsTupleSchemeFactory();
+ private static final org.apache.thrift.scheme.SchemeFactory
STANDARD_SCHEME_FACTORY = new getCompactionStatus_argsStandardSchemeFactory();
+ private static final org.apache.thrift.scheme.SchemeFactory
TUPLE_SCHEME_FACTORY = new getCompactionStatus_argsTupleSchemeFactory();
public @org.apache.thrift.annotation.Nullable java.lang.String
externalCompactionId; // required
- public @org.apache.thrift.annotation.Nullable
org.apache.accumulo.core.tabletserver.thrift.CompactionStats stats; // required
/** The set of fields this struct contains, along with convenience methods
for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
- EXTERNAL_COMPACTION_ID((short)1, "externalCompactionId"),
- STATS((short)2, "stats");
+ EXTERNAL_COMPACTION_ID((short)1, "externalCompactionId");
private static final java.util.Map<java.lang.String, _Fields> byName =
new java.util.HashMap<java.lang.String, _Fields>();
@@ -3403,8 +3350,6 @@ public class CompactionCoordinator {
switch(fieldId) {
case 1: // EXTERNAL_COMPACTION_ID
return EXTERNAL_COMPACTION_ID;
- case 2: // STATS
- return STATS;
default:
return null;
}
@@ -3451,44 +3396,36 @@ public class CompactionCoordinator {
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.EXTERNAL_COMPACTION_ID, new
org.apache.thrift.meta_data.FieldMetaData("externalCompactionId",
org.apache.thrift.TFieldRequirementType.DEFAULT,
new
org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
- tmpMap.put(_Fields.STATS, new
org.apache.thrift.meta_data.FieldMetaData("stats",
org.apache.thrift.TFieldRequirementType.DEFAULT,
- new
org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT,
org.apache.accumulo.core.tabletserver.thrift.CompactionStats.class)));
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
-
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(compactionCompleted_args.class,
metaDataMap);
+
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getCompactionStatus_args.class,
metaDataMap);
}
- public compactionCompleted_args() {
+ public getCompactionStatus_args() {
}
- public compactionCompleted_args(
- java.lang.String externalCompactionId,
- org.apache.accumulo.core.tabletserver.thrift.CompactionStats stats)
+ public getCompactionStatus_args(
+ java.lang.String externalCompactionId)
{
this();
this.externalCompactionId = externalCompactionId;
- this.stats = stats;
}
/**
* Performs a deep copy on <i>other</i>.
*/
- public compactionCompleted_args(compactionCompleted_args other) {
+ public getCompactionStatus_args(getCompactionStatus_args other) {
if (other.isSetExternalCompactionId()) {
this.externalCompactionId = other.externalCompactionId;
}
- if (other.isSetStats()) {
- this.stats = new
org.apache.accumulo.core.tabletserver.thrift.CompactionStats(other.stats);
- }
}
- public compactionCompleted_args deepCopy() {
- return new compactionCompleted_args(this);
+ public getCompactionStatus_args deepCopy() {
+ return new getCompactionStatus_args(this);
}
@Override
public void clear() {
this.externalCompactionId = null;
- this.stats = null;
}
@org.apache.thrift.annotation.Nullable
@@ -3496,7 +3433,7 @@ public class CompactionCoordinator {
return this.externalCompactionId;
}
- public compactionCompleted_args
setExternalCompactionId(@org.apache.thrift.annotation.Nullable java.lang.String
externalCompactionId) {
+ public getCompactionStatus_args
setExternalCompactionId(@org.apache.thrift.annotation.Nullable java.lang.String
externalCompactionId) {
this.externalCompactionId = externalCompactionId;
return this;
}
@@ -3516,31 +3453,6 @@ public class CompactionCoordinator {
}
}
- @org.apache.thrift.annotation.Nullable
- public org.apache.accumulo.core.tabletserver.thrift.CompactionStats
getStats() {
- return this.stats;
- }
-
- public compactionCompleted_args
setStats(@org.apache.thrift.annotation.Nullable
org.apache.accumulo.core.tabletserver.thrift.CompactionStats stats) {
- this.stats = stats;
- return this;
- }
-
- public void unsetStats() {
- this.stats = null;
- }
-
- /** Returns true if field stats is set (has been assigned a value) and
false otherwise */
- public boolean isSetStats() {
- return this.stats != null;
- }
-
- public void setStatsIsSet(boolean value) {
- if (!value) {
- this.stats = null;
- }
- }
-
public void setFieldValue(_Fields field,
@org.apache.thrift.annotation.Nullable java.lang.Object value) {
switch (field) {
case EXTERNAL_COMPACTION_ID:
@@ -3551,14 +3463,6 @@ public class CompactionCoordinator {
}
break;
- case STATS:
- if (value == null) {
- unsetStats();
- } else {
-
setStats((org.apache.accumulo.core.tabletserver.thrift.CompactionStats)value);
- }
- break;
-
}
}
@@ -3568,9 +3472,6 @@ public class CompactionCoordinator {
case EXTERNAL_COMPACTION_ID:
return getExternalCompactionId();
- case STATS:
- return getStats();
-
}
throw new java.lang.IllegalStateException();
}
@@ -3584,8 +3485,6 @@ public class CompactionCoordinator {
switch (field) {
case EXTERNAL_COMPACTION_ID:
return isSetExternalCompactionId();
- case STATS:
- return isSetStats();
}
throw new java.lang.IllegalStateException();
}
@@ -3594,12 +3493,12 @@ public class CompactionCoordinator {
public boolean equals(java.lang.Object that) {
if (that == null)
return false;
- if (that instanceof compactionCompleted_args)
- return this.equals((compactionCompleted_args)that);
+ if (that instanceof getCompactionStatus_args)
+ return this.equals((getCompactionStatus_args)that);
return false;
}
- public boolean equals(compactionCompleted_args that) {
+ public boolean equals(getCompactionStatus_args that) {
if (that == null)
return false;
if (this == that)
@@ -3614,15 +3513,6 @@ public class CompactionCoordinator {
return false;
}
- boolean this_present_stats = true && this.isSetStats();
- boolean that_present_stats = true && that.isSetStats();
- if (this_present_stats || that_present_stats) {
- if (!(this_present_stats && that_present_stats))
- return false;
- if (!this.stats.equals(that.stats))
- return false;
- }
-
return true;
}
@@ -3634,15 +3524,11 @@ public class CompactionCoordinator {
if (isSetExternalCompactionId())
hashCode = hashCode * 8191 + externalCompactionId.hashCode();
- hashCode = hashCode * 8191 + ((isSetStats()) ? 131071 : 524287);
- if (isSetStats())
- hashCode = hashCode * 8191 + stats.hashCode();
-
return hashCode;
}
@Override
- public int compareTo(compactionCompleted_args other) {
+ public int compareTo(getCompactionStatus_args other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
@@ -3659,16 +3545,6 @@ public class CompactionCoordinator {
return lastComparison;
}
}
- lastComparison =
java.lang.Boolean.valueOf(isSetStats()).compareTo(other.isSetStats());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetStats()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.stats,
other.stats);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
return 0;
}
@@ -3687,7 +3563,7 @@ public class CompactionCoordinator {
@Override
public java.lang.String toString() {
- java.lang.StringBuilder sb = new
java.lang.StringBuilder("compactionCompleted_args(");
+ java.lang.StringBuilder sb = new
java.lang.StringBuilder("getCompactionStatus_args(");
boolean first = true;
sb.append("externalCompactionId:");
@@ -3697,14 +3573,6 @@ public class CompactionCoordinator {
sb.append(this.externalCompactionId);
}
first = false;
- if (!first) sb.append(", ");
- sb.append("stats:");
- if (this.stats == null) {
- sb.append("null");
- } else {
- sb.append(this.stats);
- }
- first = false;
sb.append(")");
return sb.toString();
}
@@ -3712,9 +3580,6 @@ public class CompactionCoordinator {
public void validate() throws org.apache.thrift.TException {
// check for required fields
// check for sub-struct validity
- if (stats != null) {
- stats.validate();
- }
}
private void writeObject(java.io.ObjectOutputStream out) throws
java.io.IOException {
@@ -3733,15 +3598,15 @@ public class CompactionCoordinator {
}
}
- private static class compactionCompleted_argsStandardSchemeFactory
implements org.apache.thrift.scheme.SchemeFactory {
- public compactionCompleted_argsStandardScheme getScheme() {
- return new compactionCompleted_argsStandardScheme();
+ private static class getCompactionStatus_argsStandardSchemeFactory
implements org.apache.thrift.scheme.SchemeFactory {
+ public getCompactionStatus_argsStandardScheme getScheme() {
+ return new getCompactionStatus_argsStandardScheme();
}
}
- private static class compactionCompleted_argsStandardScheme extends
org.apache.thrift.scheme.StandardScheme<compactionCompleted_args> {
+ private static class getCompactionStatus_argsStandardScheme extends
org.apache.thrift.scheme.StandardScheme<getCompactionStatus_args> {
- public void read(org.apache.thrift.protocol.TProtocol iprot,
compactionCompleted_args struct) throws org.apache.thrift.TException {
+ public void read(org.apache.thrift.protocol.TProtocol iprot,
getCompactionStatus_args struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TField schemeField;
iprot.readStructBegin();
while (true)
@@ -3759,15 +3624,6 @@ public class CompactionCoordinator {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot,
schemeField.type);
}
break;
- case 2: // STATS
- if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT)
{
- struct.stats = new
org.apache.accumulo.core.tabletserver.thrift.CompactionStats();
- struct.stats.read(iprot);
- struct.setStatsIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot,
schemeField.type);
- }
- break;
default:
org.apache.thrift.protocol.TProtocolUtil.skip(iprot,
schemeField.type);
}
@@ -3779,7 +3635,7 @@ public class CompactionCoordinator {
struct.validate();
}
- public void write(org.apache.thrift.protocol.TProtocol oprot,
compactionCompleted_args struct) throws org.apache.thrift.TException {
+ public void write(org.apache.thrift.protocol.TProtocol oprot,
getCompactionStatus_args struct) throws org.apache.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
@@ -3788,57 +3644,41 @@ public class CompactionCoordinator {
oprot.writeString(struct.externalCompactionId);
oprot.writeFieldEnd();
}
- if (struct.stats != null) {
- oprot.writeFieldBegin(STATS_FIELD_DESC);
- struct.stats.write(oprot);
- oprot.writeFieldEnd();
- }
oprot.writeFieldStop();
oprot.writeStructEnd();
}
}
- private static class compactionCompleted_argsTupleSchemeFactory implements
org.apache.thrift.scheme.SchemeFactory {
- public compactionCompleted_argsTupleScheme getScheme() {
- return new compactionCompleted_argsTupleScheme();
+ private static class getCompactionStatus_argsTupleSchemeFactory implements
org.apache.thrift.scheme.SchemeFactory {
+ public getCompactionStatus_argsTupleScheme getScheme() {
+ return new getCompactionStatus_argsTupleScheme();
}
}
- private static class compactionCompleted_argsTupleScheme extends
org.apache.thrift.scheme.TupleScheme<compactionCompleted_args> {
+ private static class getCompactionStatus_argsTupleScheme extends
org.apache.thrift.scheme.TupleScheme<getCompactionStatus_args> {
@Override
- public void write(org.apache.thrift.protocol.TProtocol prot,
compactionCompleted_args struct) throws org.apache.thrift.TException {
+ public void write(org.apache.thrift.protocol.TProtocol prot,
getCompactionStatus_args struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TTupleProtocol oprot =
(org.apache.thrift.protocol.TTupleProtocol) prot;
java.util.BitSet optionals = new java.util.BitSet();
if (struct.isSetExternalCompactionId()) {
optionals.set(0);
}
- if (struct.isSetStats()) {
- optionals.set(1);
- }
- oprot.writeBitSet(optionals, 2);
+ oprot.writeBitSet(optionals, 1);
if (struct.isSetExternalCompactionId()) {
oprot.writeString(struct.externalCompactionId);
}
- if (struct.isSetStats()) {
- struct.stats.write(oprot);
- }
}
@Override
- public void read(org.apache.thrift.protocol.TProtocol prot,
compactionCompleted_args struct) throws org.apache.thrift.TException {
+ public void read(org.apache.thrift.protocol.TProtocol prot,
getCompactionStatus_args struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TTupleProtocol iprot =
(org.apache.thrift.protocol.TTupleProtocol) prot;
- java.util.BitSet incoming = iprot.readBitSet(2);
+ java.util.BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
struct.externalCompactionId = iprot.readString();
struct.setExternalCompactionIdIsSet(true);
}
- if (incoming.get(1)) {
- struct.stats = new
org.apache.accumulo.core.tabletserver.thrift.CompactionStats();
- struct.stats.read(iprot);
- struct.setStatsIsSet(true);
- }
}
}
@@ -3847,18 +3687,21 @@ public class CompactionCoordinator {
}
}
- public static class compactionCompleted_result implements
org.apache.thrift.TBase<compactionCompleted_result,
compactionCompleted_result._Fields>, java.io.Serializable, Cloneable,
Comparable<compactionCompleted_result> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new
org.apache.thrift.protocol.TStruct("compactionCompleted_result");
+ public static class getCompactionStatus_result implements
org.apache.thrift.TBase<getCompactionStatus_result,
getCompactionStatus_result._Fields>, java.io.Serializable, Cloneable,
Comparable<getCompactionStatus_result> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new
org.apache.thrift.protocol.TStruct("getCompactionStatus_result");
+ private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC
= new org.apache.thrift.protocol.TField("success",
org.apache.thrift.protocol.TType.LIST, (short)0);
private static final org.apache.thrift.protocol.TField E_FIELD_DESC = new
org.apache.thrift.protocol.TField("e", org.apache.thrift.protocol.TType.STRUCT,
(short)1);
- private static final org.apache.thrift.scheme.SchemeFactory
STANDARD_SCHEME_FACTORY = new compactionCompleted_resultStandardSchemeFactory();
- private static final org.apache.thrift.scheme.SchemeFactory
TUPLE_SCHEME_FACTORY = new compactionCompleted_resultTupleSchemeFactory();
+ private static final org.apache.thrift.scheme.SchemeFactory
STANDARD_SCHEME_FACTORY = new getCompactionStatus_resultStandardSchemeFactory();
+ private static final org.apache.thrift.scheme.SchemeFactory
TUPLE_SCHEME_FACTORY = new getCompactionStatus_resultTupleSchemeFactory();
+ public @org.apache.thrift.annotation.Nullable java.util.List<Status>
success; // required
public @org.apache.thrift.annotation.Nullable UnknownCompactionIdException
e; // required
/** The set of fields this struct contains, along with convenience methods
for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+ SUCCESS((short)0, "success"),
E((short)1, "e");
private static final java.util.Map<java.lang.String, _Fields> byName =
new java.util.HashMap<java.lang.String, _Fields>();
@@ -3875,6 +3718,8 @@ public class CompactionCoordinator {
@org.apache.thrift.annotation.Nullable
public static _Fields findByThriftId(int fieldId) {
switch(fieldId) {
+ case 0: // SUCCESS
+ return SUCCESS;
case 1: // E
return E;
default:
@@ -3921,46 +3766,100 @@ public class CompactionCoordinator {
public static final java.util.Map<_Fields,
org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
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.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ new
org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT,
Status.class))));
tmpMap.put(_Fields.E, new org.apache.thrift.meta_data.FieldMetaData("e",
org.apache.thrift.TFieldRequirementType.DEFAULT,
new
org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT,
UnknownCompactionIdException.class)));
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
-
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(compactionCompleted_result.class,
metaDataMap);
+
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getCompactionStatus_result.class,
metaDataMap);
}
- public compactionCompleted_result() {
+ public getCompactionStatus_result() {
}
- public compactionCompleted_result(
+ public getCompactionStatus_result(
+ java.util.List<Status> success,
UnknownCompactionIdException e)
{
this();
+ this.success = success;
this.e = e;
}
/**
* Performs a deep copy on <i>other</i>.
*/
- public compactionCompleted_result(compactionCompleted_result other) {
+ public getCompactionStatus_result(getCompactionStatus_result other) {
+ if (other.isSetSuccess()) {
+ java.util.List<Status> __this__success = new
java.util.ArrayList<Status>(other.success.size());
+ for (Status other_element : other.success) {
+ __this__success.add(new Status(other_element));
+ }
+ this.success = __this__success;
+ }
if (other.isSetE()) {
this.e = new UnknownCompactionIdException(other.e);
}
}
- public compactionCompleted_result deepCopy() {
- return new compactionCompleted_result(this);
+ public getCompactionStatus_result deepCopy() {
+ return new getCompactionStatus_result(this);
}
@Override
public void clear() {
+ this.success = null;
this.e = null;
}
+ public int getSuccessSize() {
+ return (this.success == null) ? 0 : this.success.size();
+ }
+
+ @org.apache.thrift.annotation.Nullable
+ public java.util.Iterator<Status> getSuccessIterator() {
+ return (this.success == null) ? null : this.success.iterator();
+ }
+
+ public void addToSuccess(Status elem) {
+ if (this.success == null) {
+ this.success = new java.util.ArrayList<Status>();
+ }
+ this.success.add(elem);
+ }
+
+ @org.apache.thrift.annotation.Nullable
+ public java.util.List<Status> getSuccess() {
+ return this.success;
+ }
+
+ public getCompactionStatus_result
setSuccess(@org.apache.thrift.annotation.Nullable java.util.List<Status>
success) {
+ this.success = success;
+ return this;
+ }
+
+ public void unsetSuccess() {
+ this.success = null;
+ }
+
+ /** Returns true if field success is set (has been assigned a value) and
false otherwise */
+ public boolean isSetSuccess() {
+ return this.success != null;
+ }
+
+ public void setSuccessIsSet(boolean value) {
+ if (!value) {
+ this.success = null;
+ }
+ }
+
@org.apache.thrift.annotation.Nullable
public UnknownCompactionIdException getE() {
return this.e;
}
- public compactionCompleted_result
setE(@org.apache.thrift.annotation.Nullable UnknownCompactionIdException e) {
+ public getCompactionStatus_result
setE(@org.apache.thrift.annotation.Nullable UnknownCompactionIdException e) {
this.e = e;
return this;
}
@@ -3982,6 +3881,14 @@ public class CompactionCoordinator {
public void setFieldValue(_Fields field,
@org.apache.thrift.annotation.Nullable java.lang.Object value) {
switch (field) {
+ case SUCCESS:
+ if (value == null) {
+ unsetSuccess();
+ } else {
+ setSuccess((java.util.List<Status>)value);
+ }
+ break;
+
case E:
if (value == null) {
unsetE();
@@ -3996,6 +3903,9 @@ public class CompactionCoordinator {
@org.apache.thrift.annotation.Nullable
public java.lang.Object getFieldValue(_Fields field) {
switch (field) {
+ case SUCCESS:
+ return getSuccess();
+
case E:
return getE();
@@ -4010,6 +3920,8 @@ public class CompactionCoordinator {
}
switch (field) {
+ case SUCCESS:
+ return isSetSuccess();
case E:
return isSetE();
}
@@ -4020,17 +3932,26 @@ public class CompactionCoordinator {
public boolean equals(java.lang.Object that) {
if (that == null)
return false;
- if (that instanceof compactionCompleted_result)
- return this.equals((compactionCompleted_result)that);
+ if (that instanceof getCompactionStatus_result)
+ return this.equals((getCompactionStatus_result)that);
return false;
}
- public boolean equals(compactionCompleted_result that) {
+ public boolean equals(getCompactionStatus_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();
+ if (this_present_success || that_present_success) {
+ if (!(this_present_success && that_present_success))
+ return false;
+ if (!this.success.equals(that.success))
+ return false;
+ }
+
boolean this_present_e = true && this.isSetE();
boolean that_present_e = true && that.isSetE();
if (this_present_e || that_present_e) {
@@ -4047,6 +3968,10 @@ public class CompactionCoordinator {
public int hashCode() {
int hashCode = 1;
+ hashCode = hashCode * 8191 + ((isSetSuccess()) ? 131071 : 524287);
+ if (isSetSuccess())
+ hashCode = hashCode * 8191 + success.hashCode();
+
hashCode = hashCode * 8191 + ((isSetE()) ? 131071 : 524287);
if (isSetE())
hashCode = hashCode * 8191 + e.hashCode();
@@ -4055,13 +3980,23 @@ public class CompactionCoordinator {
}
@Override
- public int compareTo(compactionCompleted_result other) {
+ public int compareTo(getCompactionStatus_result other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
+ lastComparison =
java.lang.Boolean.valueOf(isSetSuccess()).compareTo(other.isSetSuccess());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetSuccess()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success,
other.success);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
lastComparison =
java.lang.Boolean.valueOf(isSetE()).compareTo(other.isSetE());
if (lastComparison != 0) {
return lastComparison;
@@ -4090,9 +4025,17 @@ public class CompactionCoordinator {
@Override
public java.lang.String toString() {
- java.lang.StringBuilder sb = new
java.lang.StringBuilder("compactionCompleted_result(");
+ java.lang.StringBuilder sb = new
java.lang.StringBuilder("getCompactionStatus_result(");
boolean first = true;
+ sb.append("success:");
+ if (this.success == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.success);
+ }
+ first = false;
+ if (!first) sb.append(", ");
sb.append("e:");
if (this.e == null) {
sb.append("null");
@@ -4125,15 +4068,15 @@ public class CompactionCoordinator {
}
}
- private static class compactionCompleted_resultStandardSchemeFactory
implements org.apache.thrift.scheme.SchemeFactory {
- public compactionCompleted_resultStandardScheme getScheme() {
- return new compactionCompleted_resultStandardScheme();
+ private static class getCompactionStatus_resultStandardSchemeFactory
implements org.apache.thrift.scheme.SchemeFactory {
+ public getCompactionStatus_resultStandardScheme getScheme() {
+ return new getCompactionStatus_resultStandardScheme();
}
}
- private static class compactionCompleted_resultStandardScheme extends
org.apache.thrift.scheme.StandardScheme<compactionCompleted_result> {
+ private static class getCompactionStatus_resultStandardScheme extends
org.apache.thrift.scheme.StandardScheme<getCompactionStatus_result> {
- public void read(org.apache.thrift.protocol.TProtocol iprot,
compactionCompleted_result struct) throws org.apache.thrift.TException {
+ public void read(org.apache.thrift.protocol.TProtocol iprot,
getCompactionStatus_result struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TField schemeField;
iprot.readStructBegin();
while (true)
@@ -4143,6 +4086,25 @@ public class CompactionCoordinator {
break;
}
switch (schemeField.id) {
+ case 0: // SUCCESS
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list0 =
iprot.readListBegin();
+ struct.success = new
java.util.ArrayList<Status>(_list0.size);
+ @org.apache.thrift.annotation.Nullable Status _elem1;
+ for (int _i2 = 0; _i2 < _list0.size; ++_i2)
+ {
+ _elem1 = new Status();
+ _elem1.read(iprot);
+ struct.success.add(_elem1);
+ }
+ iprot.readListEnd();
+ }
+ struct.setSuccessIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot,
schemeField.type);
+ }
+ break;
case 1: // E
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT)
{
struct.e = new UnknownCompactionIdException();
@@ -4163,10 +4125,22 @@ public class CompactionCoordinator {
struct.validate();
}
- public void write(org.apache.thrift.protocol.TProtocol oprot,
compactionCompleted_result struct) throws org.apache.thrift.TException {
+ public void write(org.apache.thrift.protocol.TProtocol oprot,
getCompactionStatus_result struct) throws org.apache.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.success != null) {
+ oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
+ {
+ oprot.writeListBegin(new
org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT,
struct.success.size()));
+ for (Status _iter3 : struct.success)
+ {
+ _iter3.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
if (struct.e != null) {
oprot.writeFieldBegin(E_FIELD_DESC);
struct.e.write(oprot);
@@ -4178,32 +4152,58 @@ public class CompactionCoordinator {
}
- private static class compactionCompleted_resultTupleSchemeFactory
implements org.apache.thrift.scheme.SchemeFactory {
- public compactionCompleted_resultTupleScheme getScheme() {
- return new compactionCompleted_resultTupleScheme();
+ private static class getCompactionStatus_resultTupleSchemeFactory
implements org.apache.thrift.scheme.SchemeFactory {
+ public getCompactionStatus_resultTupleScheme getScheme() {
+ return new getCompactionStatus_resultTupleScheme();
}
}
- private static class compactionCompleted_resultTupleScheme extends
org.apache.thrift.scheme.TupleScheme<compactionCompleted_result> {
+ private static class getCompactionStatus_resultTupleScheme extends
org.apache.thrift.scheme.TupleScheme<getCompactionStatus_result> {
@Override
- public void write(org.apache.thrift.protocol.TProtocol prot,
compactionCompleted_result struct) throws org.apache.thrift.TException {
+ public void write(org.apache.thrift.protocol.TProtocol prot,
getCompactionStatus_result struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TTupleProtocol oprot =
(org.apache.thrift.protocol.TTupleProtocol) prot;
java.util.BitSet optionals = new java.util.BitSet();
- if (struct.isSetE()) {
+ if (struct.isSetSuccess()) {
optionals.set(0);
}
- oprot.writeBitSet(optionals, 1);
+ if (struct.isSetE()) {
+ optionals.set(1);
+ }
+ oprot.writeBitSet(optionals, 2);
+ if (struct.isSetSuccess()) {
+ {
+ oprot.writeI32(struct.success.size());
+ for (Status _iter4 : struct.success)
+ {
+ _iter4.write(oprot);
+ }
+ }
+ }
if (struct.isSetE()) {
struct.e.write(oprot);
}
}
@Override
- public void read(org.apache.thrift.protocol.TProtocol prot,
compactionCompleted_result struct) throws org.apache.thrift.TException {
+ public void read(org.apache.thrift.protocol.TProtocol prot,
getCompactionStatus_result struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TTupleProtocol iprot =
(org.apache.thrift.protocol.TTupleProtocol) prot;
- java.util.BitSet incoming = iprot.readBitSet(1);
+ java.util.BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
+ {
+ org.apache.thrift.protocol.TList _list5 = new
org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT,
iprot.readI32());
+ struct.success = new java.util.ArrayList<Status>(_list5.size);
+ @org.apache.thrift.annotation.Nullable Status _elem6;
+ for (int _i7 = 0; _i7 < _list5.size; ++_i7)
+ {
+ _elem6 = new Status();
+ _elem6.read(iprot);
+ struct.success.add(_elem6);
+ }
+ }
+ struct.setSuccessIsSet(true);
+ }
+ if (incoming.get(1)) {
struct.e = new UnknownCompactionIdException();
struct.e.read(iprot);
struct.setEIsSet(true);
