You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ec...@apache.org on 2012/05/25 21:00:03 UTC
svn commit: r1342773 [2/3] - in /accumulo/branches/ACCUMULO-578:
core/src/main/java/org/apache/accumulo/core/
core/src/main/java/org/apache/accumulo/core/conf/
core/src/main/java/org/apache/accumulo/core/master/thrift/
core/src/main/java/org/apache/acc...
Modified: accumulo/branches/ACCUMULO-578/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/TabletClientService.java
URL: http://svn.apache.org/viewvc/accumulo/branches/ACCUMULO-578/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/TabletClientService.java?rev=1342773&r1=1342772&r2=1342773&view=diff
==============================================================================
--- accumulo/branches/ACCUMULO-578/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/TabletClientService.java (original)
+++ accumulo/branches/ACCUMULO-578/core/src/main/java/org/apache/accumulo/core/tabletserver/thrift/TabletClientService.java Fri May 25 18:59:59 2012
@@ -60,8 +60,6 @@ import org.slf4j.LoggerFactory;
public void compact(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, String tableId, ByteBuffer startRow, ByteBuffer endRow) throws org.apache.thrift.TException;
- public void useLoggers(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, Set<String> loggers) throws org.apache.thrift.TException;
-
public org.apache.accumulo.core.master.thrift.TabletServerStatus getTabletServerStatus(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException;
public List<TabletStats> getTabletStats(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableId) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException;
@@ -76,7 +74,7 @@ import org.slf4j.LoggerFactory;
public double sortLog(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, String path) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException;
- public void removeLogs(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, List<String> filenames) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException;
+ public void removeLogs(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, List<String> filenames) throws org.apache.thrift.TException;
}
@@ -118,8 +116,6 @@ import org.slf4j.LoggerFactory;
public void compact(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String lock, String tableId, ByteBuffer startRow, ByteBuffer endRow, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.compact_call> resultHandler) throws org.apache.thrift.TException;
- public void useLoggers(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, Set<String> loggers, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.useLoggers_call> resultHandler) throws org.apache.thrift.TException;
-
public void getTabletServerStatus(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getTabletServerStatus_call> resultHandler) throws org.apache.thrift.TException;
public void getTabletStats(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableId, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getTabletStats_call> resultHandler) throws org.apache.thrift.TException;
@@ -740,23 +736,6 @@ import org.slf4j.LoggerFactory;
oprot_.getTransport().flush();
}
- public void useLoggers(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, Set<String> loggers) throws org.apache.thrift.TException
- {
- send_useLoggers(tinfo, credentials, loggers);
- }
-
- public void send_useLoggers(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, Set<String> loggers) throws org.apache.thrift.TException
- {
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("useLoggers", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
- useLoggers_args args = new useLoggers_args();
- args.setTinfo(tinfo);
- args.setCredentials(credentials);
- args.setLoggers(loggers);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
- }
-
public org.apache.accumulo.core.master.thrift.TabletServerStatus getTabletServerStatus(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException
{
send_getTabletServerStatus(tinfo, credentials);
@@ -1015,10 +994,9 @@ import org.slf4j.LoggerFactory;
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "sortLog failed: unknown result");
}
- public void removeLogs(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, List<String> filenames) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException
+ public void removeLogs(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, List<String> filenames) throws org.apache.thrift.TException
{
send_removeLogs(tinfo, credentials, filenames);
- recv_removeLogs();
}
public void send_removeLogs(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, List<String> filenames) throws org.apache.thrift.TException
@@ -1033,26 +1011,6 @@ import org.slf4j.LoggerFactory;
oprot_.getTransport().flush();
}
- public void recv_removeLogs() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException
- {
- org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
- if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
- org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
- if (msg.seqid != seqid_) {
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "removeLogs failed: out of sequence response");
- }
- removeLogs_result result = new removeLogs_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
- if (result.sec != null) {
- throw result.sec;
- }
- return;
- }
-
}
public static class AsyncClient extends org.apache.accumulo.core.client.impl.thrift.ClientService.AsyncClient implements AsyncIface {
public static class Factory implements org.apache.thrift.async.TAsyncClientFactory<AsyncClient> {
@@ -1816,43 +1774,6 @@ import org.slf4j.LoggerFactory;
}
}
- public void useLoggers(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, Set<String> loggers, org.apache.thrift.async.AsyncMethodCallback<useLoggers_call> resultHandler) throws org.apache.thrift.TException {
- checkReady();
- useLoggers_call method_call = new useLoggers_call(tinfo, credentials, loggers, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
- }
-
- public static class useLoggers_call extends org.apache.thrift.async.TAsyncMethodCall {
- private org.apache.accumulo.cloudtrace.thrift.TInfo tinfo;
- private org.apache.accumulo.core.security.thrift.AuthInfo credentials;
- private Set<String> loggers;
- public useLoggers_call(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, Set<String> loggers, org.apache.thrift.async.AsyncMethodCallback<useLoggers_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
- super(client, protocolFactory, transport, resultHandler, true);
- this.tinfo = tinfo;
- this.credentials = credentials;
- this.loggers = loggers;
- }
-
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("useLoggers", org.apache.thrift.protocol.TMessageType.CALL, 0));
- useLoggers_args args = new useLoggers_args();
- args.setTinfo(tinfo);
- args.setCredentials(credentials);
- args.setLoggers(loggers);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public void getResult() throws org.apache.thrift.TException {
- if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new 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);
- }
- }
-
public void getTabletServerStatus(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, org.apache.thrift.async.AsyncMethodCallback<getTabletServerStatus_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
getTabletServerStatus_call method_call = new getTabletServerStatus_call(tinfo, credentials, resultHandler, this, protocolFactory, transport);
@@ -2124,7 +2045,7 @@ import org.slf4j.LoggerFactory;
private org.apache.accumulo.core.security.thrift.AuthInfo credentials;
private List<String> filenames;
public removeLogs_call(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, List<String> filenames, org.apache.thrift.async.AsyncMethodCallback<removeLogs_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
- super(client, protocolFactory, transport, resultHandler, false);
+ super(client, protocolFactory, transport, resultHandler, true);
this.tinfo = tinfo;
this.credentials = credentials;
this.filenames = filenames;
@@ -2140,13 +2061,12 @@ import org.slf4j.LoggerFactory;
prot.writeMessageEnd();
}
- public void getResult() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.thrift.TException {
+ public void getResult() throws org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new 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);
- (new Client(prot)).recv_removeLogs();
}
}
@@ -2176,7 +2096,6 @@ import org.slf4j.LoggerFactory;
processMap_.put("flushTablet", new flushTablet());
processMap_.put("chop", new chop());
processMap_.put("compact", new compact());
- processMap_.put("useLoggers", new useLoggers());
processMap_.put("getTabletServerStatus", new getTabletServerStatus());
processMap_.put("getTabletStats", new getTabletStats());
processMap_.put("getHistoricalStats", new getHistoricalStats());
@@ -2770,27 +2689,6 @@ import org.slf4j.LoggerFactory;
}
}
- private class useLoggers implements ProcessFunction {
- public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- useLoggers_args args = new useLoggers_args();
- try {
- args.read(iprot);
- } catch (org.apache.thrift.protocol.TProtocolException e) {
- iprot.readMessageEnd();
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.PROTOCOL_ERROR, e.getMessage());
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("useLoggers", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- iprot.readMessageEnd();
- iface_.useLoggers(args.tinfo, args.credentials, args.loggers);
- return;
- }
- }
-
private class getTabletServerStatus implements ProcessFunction {
public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
{
@@ -3057,26 +2955,9 @@ import org.slf4j.LoggerFactory;
return;
}
iprot.readMessageEnd();
- removeLogs_result result = new removeLogs_result();
- try {
- iface_.removeLogs(args.tinfo, args.credentials, args.filenames);
- } catch (org.apache.accumulo.core.security.thrift.ThriftSecurityException sec) {
- result.sec = sec;
- } catch (Throwable th) {
- LOGGER.error("Internal error processing removeLogs", th);
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing removeLogs");
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("removeLogs", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("removeLogs", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
- result.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
+ iface_.removeLogs(args.tinfo, args.credentials, args.filenames);
+ return;
}
-
}
}
@@ -18537,22 +18418,19 @@ import org.slf4j.LoggerFactory;
}
- public static class useLoggers_args implements org.apache.thrift.TBase<useLoggers_args, useLoggers_args._Fields>, java.io.Serializable, Cloneable {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("useLoggers_args");
+ public static class getTabletServerStatus_args implements org.apache.thrift.TBase<getTabletServerStatus_args, getTabletServerStatus_args._Fields>, java.io.Serializable, Cloneable {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getTabletServerStatus_args");
private static final org.apache.thrift.protocol.TField TINFO_FIELD_DESC = new org.apache.thrift.protocol.TField("tinfo", org.apache.thrift.protocol.TType.STRUCT, (short)3);
private static final org.apache.thrift.protocol.TField CREDENTIALS_FIELD_DESC = new org.apache.thrift.protocol.TField("credentials", org.apache.thrift.protocol.TType.STRUCT, (short)1);
- private static final org.apache.thrift.protocol.TField LOGGERS_FIELD_DESC = new org.apache.thrift.protocol.TField("loggers", org.apache.thrift.protocol.TType.SET, (short)2);
public org.apache.accumulo.cloudtrace.thrift.TInfo tinfo;
public org.apache.accumulo.core.security.thrift.AuthInfo credentials;
- public Set<String> loggers;
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
TINFO((short)3, "tinfo"),
- CREDENTIALS((short)1, "credentials"),
- LOGGERS((short)2, "loggers");
+ CREDENTIALS((short)1, "credentials");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -18571,8 +18449,6 @@ import org.slf4j.LoggerFactory;
return TINFO;
case 1: // CREDENTIALS
return CREDENTIALS;
- case 2: // LOGGERS
- return LOGGERS;
default:
return null;
}
@@ -18621,62 +18497,49 @@ import org.slf4j.LoggerFactory;
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.accumulo.cloudtrace.thrift.TInfo.class)));
tmpMap.put(_Fields.CREDENTIALS, new org.apache.thrift.meta_data.FieldMetaData("credentials", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.accumulo.core.security.thrift.AuthInfo.class)));
- tmpMap.put(_Fields.LOGGERS, new org.apache.thrift.meta_data.FieldMetaData("loggers", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.SetMetaData(org.apache.thrift.protocol.TType.SET,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))));
metaDataMap = Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(useLoggers_args.class, metaDataMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getTabletServerStatus_args.class, metaDataMap);
}
- public useLoggers_args() {
+ public getTabletServerStatus_args() {
}
- public useLoggers_args(
+ public getTabletServerStatus_args(
org.apache.accumulo.cloudtrace.thrift.TInfo tinfo,
- org.apache.accumulo.core.security.thrift.AuthInfo credentials,
- Set<String> loggers)
+ org.apache.accumulo.core.security.thrift.AuthInfo credentials)
{
this();
this.tinfo = tinfo;
this.credentials = credentials;
- this.loggers = loggers;
}
/**
* Performs a deep copy on <i>other</i>.
*/
- public useLoggers_args(useLoggers_args other) {
+ public getTabletServerStatus_args(getTabletServerStatus_args other) {
if (other.isSetTinfo()) {
this.tinfo = new org.apache.accumulo.cloudtrace.thrift.TInfo(other.tinfo);
}
if (other.isSetCredentials()) {
this.credentials = new org.apache.accumulo.core.security.thrift.AuthInfo(other.credentials);
}
- if (other.isSetLoggers()) {
- Set<String> __this__loggers = new HashSet<String>();
- for (String other_element : other.loggers) {
- __this__loggers.add(other_element);
- }
- this.loggers = __this__loggers;
- }
}
- public useLoggers_args deepCopy() {
- return new useLoggers_args(this);
+ public getTabletServerStatus_args deepCopy() {
+ return new getTabletServerStatus_args(this);
}
@Override
public void clear() {
this.tinfo = null;
this.credentials = null;
- this.loggers = null;
}
public org.apache.accumulo.cloudtrace.thrift.TInfo getTinfo() {
return this.tinfo;
}
- public useLoggers_args setTinfo(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo) {
+ public getTabletServerStatus_args setTinfo(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo) {
this.tinfo = tinfo;
return this;
}
@@ -18700,7 +18563,7 @@ import org.slf4j.LoggerFactory;
return this.credentials;
}
- public useLoggers_args setCredentials(org.apache.accumulo.core.security.thrift.AuthInfo credentials) {
+ public getTabletServerStatus_args setCredentials(org.apache.accumulo.core.security.thrift.AuthInfo credentials) {
this.credentials = credentials;
return this;
}
@@ -18720,45 +18583,6 @@ import org.slf4j.LoggerFactory;
}
}
- public int getLoggersSize() {
- return (this.loggers == null) ? 0 : this.loggers.size();
- }
-
- public java.util.Iterator<String> getLoggersIterator() {
- return (this.loggers == null) ? null : this.loggers.iterator();
- }
-
- public void addToLoggers(String elem) {
- if (this.loggers == null) {
- this.loggers = new HashSet<String>();
- }
- this.loggers.add(elem);
- }
-
- public Set<String> getLoggers() {
- return this.loggers;
- }
-
- public useLoggers_args setLoggers(Set<String> loggers) {
- this.loggers = loggers;
- return this;
- }
-
- public void unsetLoggers() {
- this.loggers = null;
- }
-
- /** Returns true if field loggers is set (has been assigned a value) and false otherwise */
- public boolean isSetLoggers() {
- return this.loggers != null;
- }
-
- public void setLoggersIsSet(boolean value) {
- if (!value) {
- this.loggers = null;
- }
- }
-
public void setFieldValue(_Fields field, Object value) {
switch (field) {
case TINFO:
@@ -18777,14 +18601,6 @@ import org.slf4j.LoggerFactory;
}
break;
- case LOGGERS:
- if (value == null) {
- unsetLoggers();
- } else {
- setLoggers((Set<String>)value);
- }
- break;
-
}
}
@@ -18796,9 +18612,6 @@ import org.slf4j.LoggerFactory;
case CREDENTIALS:
return getCredentials();
- case LOGGERS:
- return getLoggers();
-
}
throw new IllegalStateException();
}
@@ -18814,8 +18627,6 @@ import org.slf4j.LoggerFactory;
return isSetTinfo();
case CREDENTIALS:
return isSetCredentials();
- case LOGGERS:
- return isSetLoggers();
}
throw new IllegalStateException();
}
@@ -18824,12 +18635,12 @@ import org.slf4j.LoggerFactory;
public boolean equals(Object that) {
if (that == null)
return false;
- if (that instanceof useLoggers_args)
- return this.equals((useLoggers_args)that);
+ if (that instanceof getTabletServerStatus_args)
+ return this.equals((getTabletServerStatus_args)that);
return false;
}
- public boolean equals(useLoggers_args that) {
+ public boolean equals(getTabletServerStatus_args that) {
if (that == null)
return false;
@@ -18851,15 +18662,6 @@ import org.slf4j.LoggerFactory;
return false;
}
- boolean this_present_loggers = true && this.isSetLoggers();
- boolean that_present_loggers = true && that.isSetLoggers();
- if (this_present_loggers || that_present_loggers) {
- if (!(this_present_loggers && that_present_loggers))
- return false;
- if (!this.loggers.equals(that.loggers))
- return false;
- }
-
return true;
}
@@ -18868,13 +18670,13 @@ import org.slf4j.LoggerFactory;
return 0;
}
- public int compareTo(useLoggers_args other) {
+ public int compareTo(getTabletServerStatus_args other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
- useLoggers_args typedOther = (useLoggers_args)other;
+ getTabletServerStatus_args typedOther = (getTabletServerStatus_args)other;
lastComparison = Boolean.valueOf(isSetTinfo()).compareTo(typedOther.isSetTinfo());
if (lastComparison != 0) {
@@ -18896,16 +18698,6 @@ import org.slf4j.LoggerFactory;
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(isSetLoggers()).compareTo(typedOther.isSetLoggers());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetLoggers()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.loggers, typedOther.loggers);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
return 0;
}
@@ -18939,23 +18731,6 @@ import org.slf4j.LoggerFactory;
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
- case 2: // LOGGERS
- if (field.type == org.apache.thrift.protocol.TType.SET) {
- {
- org.apache.thrift.protocol.TSet _set97 = iprot.readSetBegin();
- this.loggers = new HashSet<String>(2*_set97.size);
- for (int _i98 = 0; _i98 < _set97.size; ++_i98)
- {
- String _elem99;
- _elem99 = iprot.readString();
- this.loggers.add(_elem99);
- }
- iprot.readSetEnd();
- }
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
default:
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
@@ -18976,18 +18751,6 @@ import org.slf4j.LoggerFactory;
this.credentials.write(oprot);
oprot.writeFieldEnd();
}
- if (this.loggers != null) {
- oprot.writeFieldBegin(LOGGERS_FIELD_DESC);
- {
- oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, this.loggers.size()));
- for (String _iter100 : this.loggers)
- {
- oprot.writeString(_iter100);
- }
- oprot.writeSetEnd();
- }
- oprot.writeFieldEnd();
- }
if (this.tinfo != null) {
oprot.writeFieldBegin(TINFO_FIELD_DESC);
this.tinfo.write(oprot);
@@ -18999,7 +18762,7 @@ import org.slf4j.LoggerFactory;
@Override
public String toString() {
- StringBuilder sb = new StringBuilder("useLoggers_args(");
+ StringBuilder sb = new StringBuilder("getTabletServerStatus_args(");
boolean first = true;
sb.append("tinfo:");
@@ -19017,14 +18780,6 @@ import org.slf4j.LoggerFactory;
sb.append(this.credentials);
}
first = false;
- if (!first) sb.append(", ");
- sb.append("loggers:");
- if (this.loggers == null) {
- sb.append("null");
- } else {
- sb.append(this.loggers);
- }
- first = false;
sb.append(")");
return sb.toString();
}
@@ -19051,19 +18806,19 @@ import org.slf4j.LoggerFactory;
}
- public static class getTabletServerStatus_args implements org.apache.thrift.TBase<getTabletServerStatus_args, getTabletServerStatus_args._Fields>, java.io.Serializable, Cloneable {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getTabletServerStatus_args");
+ public static class getTabletServerStatus_result implements org.apache.thrift.TBase<getTabletServerStatus_result, getTabletServerStatus_result._Fields>, java.io.Serializable, Cloneable {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getTabletServerStatus_result");
- private static final org.apache.thrift.protocol.TField TINFO_FIELD_DESC = new org.apache.thrift.protocol.TField("tinfo", org.apache.thrift.protocol.TType.STRUCT, (short)3);
- private static final org.apache.thrift.protocol.TField CREDENTIALS_FIELD_DESC = new org.apache.thrift.protocol.TField("credentials", org.apache.thrift.protocol.TType.STRUCT, (short)1);
+ private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.STRUCT, (short)0);
+ private static final org.apache.thrift.protocol.TField SEC_FIELD_DESC = new org.apache.thrift.protocol.TField("sec", org.apache.thrift.protocol.TType.STRUCT, (short)1);
- public org.apache.accumulo.cloudtrace.thrift.TInfo tinfo;
- public org.apache.accumulo.core.security.thrift.AuthInfo credentials;
+ public org.apache.accumulo.core.master.thrift.TabletServerStatus success;
+ public org.apache.accumulo.core.security.thrift.ThriftSecurityException sec;
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
- TINFO((short)3, "tinfo"),
- CREDENTIALS((short)1, "credentials");
+ SUCCESS((short)0, "success"),
+ SEC((short)1, "sec");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -19078,10 +18833,10 @@ import org.slf4j.LoggerFactory;
*/
public static _Fields findByThriftId(int fieldId) {
switch(fieldId) {
- case 3: // TINFO
- return TINFO;
- case 1: // CREDENTIALS
- return CREDENTIALS;
+ case 0: // SUCCESS
+ return SUCCESS;
+ case 1: // SEC
+ return SEC;
default:
return null;
}
@@ -19126,111 +18881,111 @@ import org.slf4j.LoggerFactory;
public static final 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);
- tmpMap.put(_Fields.TINFO, new org.apache.thrift.meta_data.FieldMetaData("tinfo", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.accumulo.cloudtrace.thrift.TInfo.class)));
- tmpMap.put(_Fields.CREDENTIALS, new org.apache.thrift.meta_data.FieldMetaData("credentials", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.accumulo.core.security.thrift.AuthInfo.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, org.apache.accumulo.core.master.thrift.TabletServerStatus.class)));
+ tmpMap.put(_Fields.SEC, new org.apache.thrift.meta_data.FieldMetaData("sec", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getTabletServerStatus_args.class, metaDataMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getTabletServerStatus_result.class, metaDataMap);
}
- public getTabletServerStatus_args() {
+ public getTabletServerStatus_result() {
}
- public getTabletServerStatus_args(
- org.apache.accumulo.cloudtrace.thrift.TInfo tinfo,
- org.apache.accumulo.core.security.thrift.AuthInfo credentials)
+ public getTabletServerStatus_result(
+ org.apache.accumulo.core.master.thrift.TabletServerStatus success,
+ org.apache.accumulo.core.security.thrift.ThriftSecurityException sec)
{
this();
- this.tinfo = tinfo;
- this.credentials = credentials;
+ this.success = success;
+ this.sec = sec;
}
/**
* Performs a deep copy on <i>other</i>.
*/
- public getTabletServerStatus_args(getTabletServerStatus_args other) {
- if (other.isSetTinfo()) {
- this.tinfo = new org.apache.accumulo.cloudtrace.thrift.TInfo(other.tinfo);
+ public getTabletServerStatus_result(getTabletServerStatus_result other) {
+ if (other.isSetSuccess()) {
+ this.success = new org.apache.accumulo.core.master.thrift.TabletServerStatus(other.success);
}
- if (other.isSetCredentials()) {
- this.credentials = new org.apache.accumulo.core.security.thrift.AuthInfo(other.credentials);
+ if (other.isSetSec()) {
+ this.sec = new org.apache.accumulo.core.security.thrift.ThriftSecurityException(other.sec);
}
}
- public getTabletServerStatus_args deepCopy() {
- return new getTabletServerStatus_args(this);
+ public getTabletServerStatus_result deepCopy() {
+ return new getTabletServerStatus_result(this);
}
@Override
public void clear() {
- this.tinfo = null;
- this.credentials = null;
+ this.success = null;
+ this.sec = null;
}
- public org.apache.accumulo.cloudtrace.thrift.TInfo getTinfo() {
- return this.tinfo;
+ public org.apache.accumulo.core.master.thrift.TabletServerStatus getSuccess() {
+ return this.success;
}
- public getTabletServerStatus_args setTinfo(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo) {
- this.tinfo = tinfo;
+ public getTabletServerStatus_result setSuccess(org.apache.accumulo.core.master.thrift.TabletServerStatus success) {
+ this.success = success;
return this;
}
- public void unsetTinfo() {
- this.tinfo = null;
+ public void unsetSuccess() {
+ this.success = null;
}
- /** Returns true if field tinfo is set (has been assigned a value) and false otherwise */
- public boolean isSetTinfo() {
- return this.tinfo != 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 setTinfoIsSet(boolean value) {
+ public void setSuccessIsSet(boolean value) {
if (!value) {
- this.tinfo = null;
+ this.success = null;
}
}
- public org.apache.accumulo.core.security.thrift.AuthInfo getCredentials() {
- return this.credentials;
+ public org.apache.accumulo.core.security.thrift.ThriftSecurityException getSec() {
+ return this.sec;
}
- public getTabletServerStatus_args setCredentials(org.apache.accumulo.core.security.thrift.AuthInfo credentials) {
- this.credentials = credentials;
+ public getTabletServerStatus_result setSec(org.apache.accumulo.core.security.thrift.ThriftSecurityException sec) {
+ this.sec = sec;
return this;
}
- public void unsetCredentials() {
- this.credentials = null;
+ public void unsetSec() {
+ this.sec = null;
}
- /** Returns true if field credentials is set (has been assigned a value) and false otherwise */
- public boolean isSetCredentials() {
- return this.credentials != null;
+ /** Returns true if field sec is set (has been assigned a value) and false otherwise */
+ public boolean isSetSec() {
+ return this.sec != null;
}
- public void setCredentialsIsSet(boolean value) {
+ public void setSecIsSet(boolean value) {
if (!value) {
- this.credentials = null;
+ this.sec = null;
}
}
public void setFieldValue(_Fields field, Object value) {
switch (field) {
- case TINFO:
+ case SUCCESS:
if (value == null) {
- unsetTinfo();
+ unsetSuccess();
} else {
- setTinfo((org.apache.accumulo.cloudtrace.thrift.TInfo)value);
+ setSuccess((org.apache.accumulo.core.master.thrift.TabletServerStatus)value);
}
break;
- case CREDENTIALS:
+ case SEC:
if (value == null) {
- unsetCredentials();
+ unsetSec();
} else {
- setCredentials((org.apache.accumulo.core.security.thrift.AuthInfo)value);
+ setSec((org.apache.accumulo.core.security.thrift.ThriftSecurityException)value);
}
break;
@@ -19239,11 +18994,11 @@ import org.slf4j.LoggerFactory;
public Object getFieldValue(_Fields field) {
switch (field) {
- case TINFO:
- return getTinfo();
+ case SUCCESS:
+ return getSuccess();
- case CREDENTIALS:
- return getCredentials();
+ case SEC:
+ return getSec();
}
throw new IllegalStateException();
@@ -19256,10 +19011,10 @@ import org.slf4j.LoggerFactory;
}
switch (field) {
- case TINFO:
- return isSetTinfo();
- case CREDENTIALS:
- return isSetCredentials();
+ case SUCCESS:
+ return isSetSuccess();
+ case SEC:
+ return isSetSec();
}
throw new IllegalStateException();
}
@@ -19268,30 +19023,30 @@ import org.slf4j.LoggerFactory;
public boolean equals(Object that) {
if (that == null)
return false;
- if (that instanceof getTabletServerStatus_args)
- return this.equals((getTabletServerStatus_args)that);
+ if (that instanceof getTabletServerStatus_result)
+ return this.equals((getTabletServerStatus_result)that);
return false;
}
- public boolean equals(getTabletServerStatus_args that) {
+ public boolean equals(getTabletServerStatus_result that) {
if (that == null)
return false;
- boolean this_present_tinfo = true && this.isSetTinfo();
- boolean that_present_tinfo = true && that.isSetTinfo();
- if (this_present_tinfo || that_present_tinfo) {
- if (!(this_present_tinfo && that_present_tinfo))
+ 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.tinfo.equals(that.tinfo))
+ if (!this.success.equals(that.success))
return false;
}
- boolean this_present_credentials = true && this.isSetCredentials();
- boolean that_present_credentials = true && that.isSetCredentials();
- if (this_present_credentials || that_present_credentials) {
- if (!(this_present_credentials && that_present_credentials))
+ boolean this_present_sec = true && this.isSetSec();
+ boolean that_present_sec = true && that.isSetSec();
+ if (this_present_sec || that_present_sec) {
+ if (!(this_present_sec && that_present_sec))
return false;
- if (!this.credentials.equals(that.credentials))
+ if (!this.sec.equals(that.sec))
return false;
}
@@ -19303,30 +19058,30 @@ import org.slf4j.LoggerFactory;
return 0;
}
- public int compareTo(getTabletServerStatus_args other) {
+ public int compareTo(getTabletServerStatus_result other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
- getTabletServerStatus_args typedOther = (getTabletServerStatus_args)other;
+ getTabletServerStatus_result typedOther = (getTabletServerStatus_result)other;
- lastComparison = Boolean.valueOf(isSetTinfo()).compareTo(typedOther.isSetTinfo());
+ lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess());
if (lastComparison != 0) {
return lastComparison;
}
- if (isSetTinfo()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tinfo, typedOther.tinfo);
+ if (isSetSuccess()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, typedOther.success);
if (lastComparison != 0) {
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(isSetCredentials()).compareTo(typedOther.isSetCredentials());
+ lastComparison = Boolean.valueOf(isSetSec()).compareTo(typedOther.isSetSec());
if (lastComparison != 0) {
return lastComparison;
}
- if (isSetCredentials()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.credentials, typedOther.credentials);
+ if (isSetSec()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.sec, typedOther.sec);
if (lastComparison != 0) {
return lastComparison;
}
@@ -19348,18 +19103,18 @@ import org.slf4j.LoggerFactory;
break;
}
switch (field.id) {
- case 3: // TINFO
+ case 0: // SUCCESS
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
- this.tinfo = new org.apache.accumulo.cloudtrace.thrift.TInfo();
- this.tinfo.read(iprot);
+ this.success = new org.apache.accumulo.core.master.thrift.TabletServerStatus();
+ this.success.read(iprot);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
- case 1: // CREDENTIALS
+ case 1: // SEC
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
- this.credentials = new org.apache.accumulo.core.security.thrift.AuthInfo();
- this.credentials.read(iprot);
+ this.sec = new org.apache.accumulo.core.security.thrift.ThriftSecurityException();
+ this.sec.read(iprot);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
@@ -19376,17 +19131,15 @@ import org.slf4j.LoggerFactory;
}
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
- validate();
-
oprot.writeStructBegin(STRUCT_DESC);
- if (this.credentials != null) {
- oprot.writeFieldBegin(CREDENTIALS_FIELD_DESC);
- this.credentials.write(oprot);
+
+ if (this.isSetSuccess()) {
+ oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
+ this.success.write(oprot);
oprot.writeFieldEnd();
- }
- if (this.tinfo != null) {
- oprot.writeFieldBegin(TINFO_FIELD_DESC);
- this.tinfo.write(oprot);
+ } else if (this.isSetSec()) {
+ oprot.writeFieldBegin(SEC_FIELD_DESC);
+ this.sec.write(oprot);
oprot.writeFieldEnd();
}
oprot.writeFieldStop();
@@ -19395,22 +19148,22 @@ import org.slf4j.LoggerFactory;
@Override
public String toString() {
- StringBuilder sb = new StringBuilder("getTabletServerStatus_args(");
+ StringBuilder sb = new StringBuilder("getTabletServerStatus_result(");
boolean first = true;
- sb.append("tinfo:");
- if (this.tinfo == null) {
+ sb.append("success:");
+ if (this.success == null) {
sb.append("null");
} else {
- sb.append(this.tinfo);
+ sb.append(this.success);
}
first = false;
if (!first) sb.append(", ");
- sb.append("credentials:");
- if (this.credentials == null) {
+ sb.append("sec:");
+ if (this.sec == null) {
sb.append("null");
} else {
- sb.append(this.credentials);
+ sb.append(this.sec);
}
first = false;
sb.append(")");
@@ -19439,19 +19192,22 @@ import org.slf4j.LoggerFactory;
}
- public static class getTabletServerStatus_result implements org.apache.thrift.TBase<getTabletServerStatus_result, getTabletServerStatus_result._Fields>, java.io.Serializable, Cloneable {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getTabletServerStatus_result");
+ public static class getTabletStats_args implements org.apache.thrift.TBase<getTabletStats_args, getTabletStats_args._Fields>, java.io.Serializable, Cloneable {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getTabletStats_args");
- private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.STRUCT, (short)0);
- private static final org.apache.thrift.protocol.TField SEC_FIELD_DESC = new org.apache.thrift.protocol.TField("sec", org.apache.thrift.protocol.TType.STRUCT, (short)1);
+ private static final org.apache.thrift.protocol.TField TINFO_FIELD_DESC = new org.apache.thrift.protocol.TField("tinfo", org.apache.thrift.protocol.TType.STRUCT, (short)3);
+ private static final org.apache.thrift.protocol.TField CREDENTIALS_FIELD_DESC = new org.apache.thrift.protocol.TField("credentials", org.apache.thrift.protocol.TType.STRUCT, (short)1);
+ private static final org.apache.thrift.protocol.TField TABLE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("tableId", org.apache.thrift.protocol.TType.STRING, (short)2);
- public org.apache.accumulo.core.master.thrift.TabletServerStatus success;
- public org.apache.accumulo.core.security.thrift.ThriftSecurityException sec;
+ public org.apache.accumulo.cloudtrace.thrift.TInfo tinfo;
+ public org.apache.accumulo.core.security.thrift.AuthInfo credentials;
+ public String tableId;
/** 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"),
- SEC((short)1, "sec");
+ TINFO((short)3, "tinfo"),
+ CREDENTIALS((short)1, "credentials"),
+ TABLE_ID((short)2, "tableId");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -19466,10 +19222,12 @@ import org.slf4j.LoggerFactory;
*/
public static _Fields findByThriftId(int fieldId) {
switch(fieldId) {
- case 0: // SUCCESS
- return SUCCESS;
- case 1: // SEC
- return SEC;
+ case 3: // TINFO
+ return TINFO;
+ case 1: // CREDENTIALS
+ return CREDENTIALS;
+ case 2: // TABLE_ID
+ return TABLE_ID;
default:
return null;
}
@@ -19514,111 +19272,151 @@ import org.slf4j.LoggerFactory;
public static final 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);
- 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, org.apache.accumulo.core.master.thrift.TabletServerStatus.class)));
- tmpMap.put(_Fields.SEC, new org.apache.thrift.meta_data.FieldMetaData("sec", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
+ tmpMap.put(_Fields.TINFO, new org.apache.thrift.meta_data.FieldMetaData("tinfo", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.accumulo.cloudtrace.thrift.TInfo.class)));
+ tmpMap.put(_Fields.CREDENTIALS, new org.apache.thrift.meta_data.FieldMetaData("credentials", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.accumulo.core.security.thrift.AuthInfo.class)));
+ tmpMap.put(_Fields.TABLE_ID, new org.apache.thrift.meta_data.FieldMetaData("tableId", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getTabletServerStatus_result.class, metaDataMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getTabletStats_args.class, metaDataMap);
}
- public getTabletServerStatus_result() {
+ public getTabletStats_args() {
}
- public getTabletServerStatus_result(
- org.apache.accumulo.core.master.thrift.TabletServerStatus success,
- org.apache.accumulo.core.security.thrift.ThriftSecurityException sec)
+ public getTabletStats_args(
+ org.apache.accumulo.cloudtrace.thrift.TInfo tinfo,
+ org.apache.accumulo.core.security.thrift.AuthInfo credentials,
+ String tableId)
{
this();
- this.success = success;
- this.sec = sec;
+ this.tinfo = tinfo;
+ this.credentials = credentials;
+ this.tableId = tableId;
}
/**
* Performs a deep copy on <i>other</i>.
*/
- public getTabletServerStatus_result(getTabletServerStatus_result other) {
- if (other.isSetSuccess()) {
- this.success = new org.apache.accumulo.core.master.thrift.TabletServerStatus(other.success);
+ public getTabletStats_args(getTabletStats_args other) {
+ if (other.isSetTinfo()) {
+ this.tinfo = new org.apache.accumulo.cloudtrace.thrift.TInfo(other.tinfo);
}
- if (other.isSetSec()) {
- this.sec = new org.apache.accumulo.core.security.thrift.ThriftSecurityException(other.sec);
+ if (other.isSetCredentials()) {
+ this.credentials = new org.apache.accumulo.core.security.thrift.AuthInfo(other.credentials);
+ }
+ if (other.isSetTableId()) {
+ this.tableId = other.tableId;
}
}
- public getTabletServerStatus_result deepCopy() {
- return new getTabletServerStatus_result(this);
+ public getTabletStats_args deepCopy() {
+ return new getTabletStats_args(this);
}
@Override
public void clear() {
- this.success = null;
- this.sec = null;
+ this.tinfo = null;
+ this.credentials = null;
+ this.tableId = null;
}
- public org.apache.accumulo.core.master.thrift.TabletServerStatus getSuccess() {
- return this.success;
+ public org.apache.accumulo.cloudtrace.thrift.TInfo getTinfo() {
+ return this.tinfo;
}
- public getTabletServerStatus_result setSuccess(org.apache.accumulo.core.master.thrift.TabletServerStatus success) {
- this.success = success;
+ public getTabletStats_args setTinfo(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo) {
+ this.tinfo = tinfo;
return this;
}
- public void unsetSuccess() {
- this.success = null;
+ public void unsetTinfo() {
+ this.tinfo = null;
}
- /** Returns true if field success is set (has been assigned a value) and false otherwise */
- public boolean isSetSuccess() {
- return this.success != null;
+ /** Returns true if field tinfo is set (has been assigned a value) and false otherwise */
+ public boolean isSetTinfo() {
+ return this.tinfo != null;
}
- public void setSuccessIsSet(boolean value) {
+ public void setTinfoIsSet(boolean value) {
if (!value) {
- this.success = null;
+ this.tinfo = null;
}
}
- public org.apache.accumulo.core.security.thrift.ThriftSecurityException getSec() {
- return this.sec;
+ public org.apache.accumulo.core.security.thrift.AuthInfo getCredentials() {
+ return this.credentials;
}
- public getTabletServerStatus_result setSec(org.apache.accumulo.core.security.thrift.ThriftSecurityException sec) {
- this.sec = sec;
+ public getTabletStats_args setCredentials(org.apache.accumulo.core.security.thrift.AuthInfo credentials) {
+ this.credentials = credentials;
return this;
}
- public void unsetSec() {
- this.sec = null;
+ public void unsetCredentials() {
+ this.credentials = null;
}
- /** Returns true if field sec is set (has been assigned a value) and false otherwise */
- public boolean isSetSec() {
- return this.sec != null;
+ /** Returns true if field credentials is set (has been assigned a value) and false otherwise */
+ public boolean isSetCredentials() {
+ return this.credentials != null;
}
- public void setSecIsSet(boolean value) {
+ public void setCredentialsIsSet(boolean value) {
if (!value) {
- this.sec = null;
+ this.credentials = null;
+ }
+ }
+
+ public String getTableId() {
+ return this.tableId;
+ }
+
+ public getTabletStats_args setTableId(String tableId) {
+ this.tableId = tableId;
+ return this;
+ }
+
+ public void unsetTableId() {
+ this.tableId = null;
+ }
+
+ /** Returns true if field tableId is set (has been assigned a value) and false otherwise */
+ public boolean isSetTableId() {
+ return this.tableId != null;
+ }
+
+ public void setTableIdIsSet(boolean value) {
+ if (!value) {
+ this.tableId = null;
}
}
public void setFieldValue(_Fields field, Object value) {
switch (field) {
- case SUCCESS:
+ case TINFO:
if (value == null) {
- unsetSuccess();
+ unsetTinfo();
} else {
- setSuccess((org.apache.accumulo.core.master.thrift.TabletServerStatus)value);
+ setTinfo((org.apache.accumulo.cloudtrace.thrift.TInfo)value);
}
break;
- case SEC:
+ case CREDENTIALS:
if (value == null) {
- unsetSec();
+ unsetCredentials();
} else {
- setSec((org.apache.accumulo.core.security.thrift.ThriftSecurityException)value);
+ setCredentials((org.apache.accumulo.core.security.thrift.AuthInfo)value);
+ }
+ break;
+
+ case TABLE_ID:
+ if (value == null) {
+ unsetTableId();
+ } else {
+ setTableId((String)value);
}
break;
@@ -19627,11 +19425,14 @@ import org.slf4j.LoggerFactory;
public Object getFieldValue(_Fields field) {
switch (field) {
- case SUCCESS:
- return getSuccess();
+ case TINFO:
+ return getTinfo();
- case SEC:
- return getSec();
+ case CREDENTIALS:
+ return getCredentials();
+
+ case TABLE_ID:
+ return getTableId();
}
throw new IllegalStateException();
@@ -19644,10 +19445,12 @@ import org.slf4j.LoggerFactory;
}
switch (field) {
- case SUCCESS:
- return isSetSuccess();
- case SEC:
- return isSetSec();
+ case TINFO:
+ return isSetTinfo();
+ case CREDENTIALS:
+ return isSetCredentials();
+ case TABLE_ID:
+ return isSetTableId();
}
throw new IllegalStateException();
}
@@ -19656,30 +19459,39 @@ import org.slf4j.LoggerFactory;
public boolean equals(Object that) {
if (that == null)
return false;
- if (that instanceof getTabletServerStatus_result)
- return this.equals((getTabletServerStatus_result)that);
+ if (that instanceof getTabletStats_args)
+ return this.equals((getTabletStats_args)that);
return false;
}
- public boolean equals(getTabletServerStatus_result that) {
+ public boolean equals(getTabletStats_args that) {
if (that == null)
return false;
- boolean this_present_success = true && this.isSetSuccess();
- boolean that_present_success = true && that.isSetSuccess();
- if (this_present_success || that_present_success) {
- if (!(this_present_success && that_present_success))
+ boolean this_present_tinfo = true && this.isSetTinfo();
+ boolean that_present_tinfo = true && that.isSetTinfo();
+ if (this_present_tinfo || that_present_tinfo) {
+ if (!(this_present_tinfo && that_present_tinfo))
return false;
- if (!this.success.equals(that.success))
+ if (!this.tinfo.equals(that.tinfo))
return false;
}
- boolean this_present_sec = true && this.isSetSec();
- boolean that_present_sec = true && that.isSetSec();
- if (this_present_sec || that_present_sec) {
- if (!(this_present_sec && that_present_sec))
+ boolean this_present_credentials = true && this.isSetCredentials();
+ boolean that_present_credentials = true && that.isSetCredentials();
+ if (this_present_credentials || that_present_credentials) {
+ if (!(this_present_credentials && that_present_credentials))
return false;
- if (!this.sec.equals(that.sec))
+ if (!this.credentials.equals(that.credentials))
+ return false;
+ }
+
+ boolean this_present_tableId = true && this.isSetTableId();
+ boolean that_present_tableId = true && that.isSetTableId();
+ if (this_present_tableId || that_present_tableId) {
+ if (!(this_present_tableId && that_present_tableId))
+ return false;
+ if (!this.tableId.equals(that.tableId))
return false;
}
@@ -19691,30 +19503,40 @@ import org.slf4j.LoggerFactory;
return 0;
}
- public int compareTo(getTabletServerStatus_result other) {
+ public int compareTo(getTabletStats_args other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
- getTabletServerStatus_result typedOther = (getTabletServerStatus_result)other;
+ getTabletStats_args typedOther = (getTabletStats_args)other;
- lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess());
+ lastComparison = Boolean.valueOf(isSetTinfo()).compareTo(typedOther.isSetTinfo());
if (lastComparison != 0) {
return lastComparison;
}
- if (isSetSuccess()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, typedOther.success);
+ if (isSetTinfo()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tinfo, typedOther.tinfo);
if (lastComparison != 0) {
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(isSetSec()).compareTo(typedOther.isSetSec());
+ lastComparison = Boolean.valueOf(isSetCredentials()).compareTo(typedOther.isSetCredentials());
if (lastComparison != 0) {
return lastComparison;
}
- if (isSetSec()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.sec, typedOther.sec);
+ if (isSetCredentials()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.credentials, typedOther.credentials);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetTableId()).compareTo(typedOther.isSetTableId());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetTableId()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tableId, typedOther.tableId);
if (lastComparison != 0) {
return lastComparison;
}
@@ -19736,18 +19558,25 @@ import org.slf4j.LoggerFactory;
break;
}
switch (field.id) {
- case 0: // SUCCESS
+ case 3: // TINFO
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
- this.success = new org.apache.accumulo.core.master.thrift.TabletServerStatus();
- this.success.read(iprot);
+ this.tinfo = new org.apache.accumulo.cloudtrace.thrift.TInfo();
+ this.tinfo.read(iprot);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
- case 1: // SEC
+ case 1: // CREDENTIALS
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
- this.sec = new org.apache.accumulo.core.security.thrift.ThriftSecurityException();
- this.sec.read(iprot);
+ this.credentials = new org.apache.accumulo.core.security.thrift.AuthInfo();
+ this.credentials.read(iprot);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 2: // TABLE_ID
+ if (field.type == org.apache.thrift.protocol.TType.STRING) {
+ this.tableId = iprot.readString();
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
@@ -19764,15 +19593,22 @@ import org.slf4j.LoggerFactory;
}
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
- oprot.writeStructBegin(STRUCT_DESC);
+ validate();
- if (this.isSetSuccess()) {
- oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
- this.success.write(oprot);
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (this.credentials != null) {
+ oprot.writeFieldBegin(CREDENTIALS_FIELD_DESC);
+ this.credentials.write(oprot);
oprot.writeFieldEnd();
- } else if (this.isSetSec()) {
- oprot.writeFieldBegin(SEC_FIELD_DESC);
- this.sec.write(oprot);
+ }
+ if (this.tableId != null) {
+ oprot.writeFieldBegin(TABLE_ID_FIELD_DESC);
+ oprot.writeString(this.tableId);
+ oprot.writeFieldEnd();
+ }
+ if (this.tinfo != null) {
+ oprot.writeFieldBegin(TINFO_FIELD_DESC);
+ this.tinfo.write(oprot);
oprot.writeFieldEnd();
}
oprot.writeFieldStop();
@@ -19781,22 +19617,30 @@ import org.slf4j.LoggerFactory;
@Override
public String toString() {
- StringBuilder sb = new StringBuilder("getTabletServerStatus_result(");
+ StringBuilder sb = new StringBuilder("getTabletStats_args(");
boolean first = true;
- sb.append("success:");
- if (this.success == null) {
+ sb.append("tinfo:");
+ if (this.tinfo == null) {
sb.append("null");
} else {
- sb.append(this.success);
+ sb.append(this.tinfo);
}
first = false;
if (!first) sb.append(", ");
- sb.append("sec:");
- if (this.sec == null) {
+ sb.append("credentials:");
+ if (this.credentials == null) {
sb.append("null");
} else {
- sb.append(this.sec);
+ sb.append(this.credentials);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("tableId:");
+ if (this.tableId == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.tableId);
}
first = false;
sb.append(")");
@@ -19825,22 +19669,19 @@ import org.slf4j.LoggerFactory;
}
- public static class getTabletStats_args implements org.apache.thrift.TBase<getTabletStats_args, getTabletStats_args._Fields>, java.io.Serializable, Cloneable {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getTabletStats_args");
+ public static class getTabletStats_result implements org.apache.thrift.TBase<getTabletStats_result, getTabletStats_result._Fields>, java.io.Serializable, Cloneable {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getTabletStats_result");
- private static final org.apache.thrift.protocol.TField TINFO_FIELD_DESC = new org.apache.thrift.protocol.TField("tinfo", org.apache.thrift.protocol.TType.STRUCT, (short)3);
- private static final org.apache.thrift.protocol.TField CREDENTIALS_FIELD_DESC = new org.apache.thrift.protocol.TField("credentials", org.apache.thrift.protocol.TType.STRUCT, (short)1);
- private static final org.apache.thrift.protocol.TField TABLE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("tableId", org.apache.thrift.protocol.TType.STRING, (short)2);
+ 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 SEC_FIELD_DESC = new org.apache.thrift.protocol.TField("sec", org.apache.thrift.protocol.TType.STRUCT, (short)1);
- public org.apache.accumulo.cloudtrace.thrift.TInfo tinfo;
- public org.apache.accumulo.core.security.thrift.AuthInfo credentials;
- public String tableId;
+ public List<TabletStats> success;
+ public org.apache.accumulo.core.security.thrift.ThriftSecurityException sec;
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
- TINFO((short)3, "tinfo"),
- CREDENTIALS((short)1, "credentials"),
- TABLE_ID((short)2, "tableId");
+ SUCCESS((short)0, "success"),
+ SEC((short)1, "sec");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -19855,12 +19696,10 @@ import org.slf4j.LoggerFactory;
*/
public static _Fields findByThriftId(int fieldId) {
switch(fieldId) {
- case 3: // TINFO
- return TINFO;
- case 1: // CREDENTIALS
- return CREDENTIALS;
- case 2: // TABLE_ID
- return TABLE_ID;
+ case 0: // SUCCESS
+ return SUCCESS;
+ case 1: // SEC
+ return SEC;
default:
return null;
}
@@ -19905,151 +19744,131 @@ import org.slf4j.LoggerFactory;
public static final 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);
- tmpMap.put(_Fields.TINFO, new org.apache.thrift.meta_data.FieldMetaData("tinfo", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.accumulo.cloudtrace.thrift.TInfo.class)));
- tmpMap.put(_Fields.CREDENTIALS, new org.apache.thrift.meta_data.FieldMetaData("credentials", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.accumulo.core.security.thrift.AuthInfo.class)));
- tmpMap.put(_Fields.TABLE_ID, new org.apache.thrift.meta_data.FieldMetaData("tableId", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ 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, TabletStats.class))));
+ tmpMap.put(_Fields.SEC, new org.apache.thrift.meta_data.FieldMetaData("sec", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getTabletStats_args.class, metaDataMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getTabletStats_result.class, metaDataMap);
}
- public getTabletStats_args() {
+ public getTabletStats_result() {
}
- public getTabletStats_args(
- org.apache.accumulo.cloudtrace.thrift.TInfo tinfo,
- org.apache.accumulo.core.security.thrift.AuthInfo credentials,
- String tableId)
+ public getTabletStats_result(
+ List<TabletStats> success,
+ org.apache.accumulo.core.security.thrift.ThriftSecurityException sec)
{
this();
- this.tinfo = tinfo;
- this.credentials = credentials;
- this.tableId = tableId;
+ this.success = success;
+ this.sec = sec;
}
/**
* Performs a deep copy on <i>other</i>.
*/
- public getTabletStats_args(getTabletStats_args other) {
- if (other.isSetTinfo()) {
- this.tinfo = new org.apache.accumulo.cloudtrace.thrift.TInfo(other.tinfo);
+ public getTabletStats_result(getTabletStats_result other) {
+ if (other.isSetSuccess()) {
+ List<TabletStats> __this__success = new ArrayList<TabletStats>();
+ for (TabletStats other_element : other.success) {
+ __this__success.add(new TabletStats(other_element));
+ }
+ this.success = __this__success;
}
- if (other.isSetCredentials()) {
- this.credentials = new org.apache.accumulo.core.security.thrift.AuthInfo(other.credentials);
- }
- if (other.isSetTableId()) {
- this.tableId = other.tableId;
+ if (other.isSetSec()) {
+ this.sec = new org.apache.accumulo.core.security.thrift.ThriftSecurityException(other.sec);
}
}
- public getTabletStats_args deepCopy() {
- return new getTabletStats_args(this);
+ public getTabletStats_result deepCopy() {
+ return new getTabletStats_result(this);
}
@Override
public void clear() {
- this.tinfo = null;
- this.credentials = null;
- this.tableId = null;
- }
-
- public org.apache.accumulo.cloudtrace.thrift.TInfo getTinfo() {
- return this.tinfo;
- }
-
- public getTabletStats_args setTinfo(org.apache.accumulo.cloudtrace.thrift.TInfo tinfo) {
- this.tinfo = tinfo;
- return this;
+ this.success = null;
+ this.sec = null;
}
- public void unsetTinfo() {
- this.tinfo = null;
+ public int getSuccessSize() {
+ return (this.success == null) ? 0 : this.success.size();
}
- /** Returns true if field tinfo is set (has been assigned a value) and false otherwise */
- public boolean isSetTinfo() {
- return this.tinfo != null;
+ public java.util.Iterator<TabletStats> getSuccessIterator() {
+ return (this.success == null) ? null : this.success.iterator();
}
- public void setTinfoIsSet(boolean value) {
- if (!value) {
- this.tinfo = null;
+ public void addToSuccess(TabletStats elem) {
+ if (this.success == null) {
+ this.success = new ArrayList<TabletStats>();
}
+ this.success.add(elem);
}
- public org.apache.accumulo.core.security.thrift.AuthInfo getCredentials() {
- return this.credentials;
+ public List<TabletStats> getSuccess() {
+ return this.success;
}
- public getTabletStats_args setCredentials(org.apache.accumulo.core.security.thrift.AuthInfo credentials) {
- this.credentials = credentials;
+ public getTabletStats_result setSuccess(List<TabletStats> success) {
+ this.success = success;
return this;
}
- public void unsetCredentials() {
- this.credentials = null;
+ public void unsetSuccess() {
+ this.success = null;
}
- /** Returns true if field credentials is set (has been assigned a value) and false otherwise */
- public boolean isSetCredentials() {
- return this.credentials != 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 setCredentialsIsSet(boolean value) {
+ public void setSuccessIsSet(boolean value) {
if (!value) {
- this.credentials = null;
+ this.success = null;
}
}
- public String getTableId() {
- return this.tableId;
+ public org.apache.accumulo.core.security.thrift.ThriftSecurityException getSec() {
+ return this.sec;
}
- public getTabletStats_args setTableId(String tableId) {
- this.tableId = tableId;
+ public getTabletStats_result setSec(org.apache.accumulo.core.security.thrift.ThriftSecurityException sec) {
+ this.sec = sec;
return this;
}
- public void unsetTableId() {
- this.tableId = null;
+ public void unsetSec() {
+ this.sec = null;
}
- /** Returns true if field tableId is set (has been assigned a value) and false otherwise */
- public boolean isSetTableId() {
- return this.tableId != null;
+ /** Returns true if field sec is set (has been assigned a value) and false otherwise */
+ public boolean isSetSec() {
+ return this.sec != null;
}
- public void setTableIdIsSet(boolean value) {
+ public void setSecIsSet(boolean value) {
if (!value) {
- this.tableId = null;
+ this.sec = null;
}
}
public void setFieldValue(_Fields field, Object value) {
switch (field) {
- case TINFO:
- if (value == null) {
- unsetTinfo();
- } else {
- setTinfo((org.apache.accumulo.cloudtrace.thrift.TInfo)value);
- }
- break;
-
- case CREDENTIALS:
+ case SUCCESS:
if (value == null) {
- unsetCredentials();
+ unsetSuccess();
} else {
- setCredentials((org.apache.accumulo.core.security.thrift.AuthInfo)value);
+ setSuccess((List<TabletStats>)value);
}
break;
- case TABLE_ID:
+ case SEC:
if (value == null) {
- unsetTableId();
+ unsetSec();
} else {
- setTableId((String)value);
+ setSec((org.apache.accumulo.core.security.thrift.ThriftSecurityException)value);
}
break;
@@ -20058,14 +19877,11 @@ import org.slf4j.LoggerFactory;
public Object getFieldValue(_Fields field) {
switch (field) {
- case TINFO:
- return getTinfo();
-
- case CREDENTIALS:
- return getCredentials();
+ case SUCCESS:
+ return getSuccess();
- case TABLE_ID:
- return getTableId();
+ case SEC:
+ return getSec();
}
throw new IllegalStateException();
@@ -20078,12 +19894,10 @@ import org.slf4j.LoggerFactory;
}
switch (field) {
- case TINFO:
- return isSetTinfo();
- case CREDENTIALS:
- return isSetCredentials();
- case TABLE_ID:
- return isSetTableId();
+ case SUCCESS:
+ return isSetSuccess();
+ case SEC:
+ return isSetSec();
}
throw new IllegalStateException();
}
@@ -20092,39 +19906,30 @@ import org.slf4j.LoggerFactory;
public boolean equals(Object that) {
if (that == null)
return false;
- if (that instanceof getTabletStats_args)
- return this.equals((getTabletStats_args)that);
+ if (that instanceof getTabletStats_result)
+ return this.equals((getTabletStats_result)that);
return false;
}
- public boolean equals(getTabletStats_args that) {
+ public boolean equals(getTabletStats_result that) {
if (that == null)
return false;
- boolean this_present_tinfo = true && this.isSetTinfo();
- boolean that_present_tinfo = true && that.isSetTinfo();
- if (this_present_tinfo || that_present_tinfo) {
- if (!(this_present_tinfo && that_present_tinfo))
- return false;
- if (!this.tinfo.equals(that.tinfo))
- return false;
- }
-
- boolean this_present_credentials = true && this.isSetCredentials();
- boolean that_present_credentials = true && that.isSetCredentials();
- if (this_present_credentials || that_present_credentials) {
- if (!(this_present_credentials && that_present_credentials))
+ 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.credentials.equals(that.credentials))
+ if (!this.success.equals(that.success))
return false;
}
- boolean this_present_tableId = true && this.isSetTableId();
- boolean that_present_tableId = true && that.isSetTableId();
- if (this_present_tableId || that_present_tableId) {
- if (!(this_present_tableId && that_present_tableId))
+ boolean this_present_sec = true && this.isSetSec();
+ boolean that_present_sec = true && that.isSetSec();
+ if (this_present_sec || that_present_sec) {
+ if (!(this_present_sec && that_present_sec))
return false;
- if (!this.tableId.equals(that.tableId))
+ if (!this.sec.equals(that.sec))
return false;
}
@@ -20136,40 +19941,30 @@ import org.slf4j.LoggerFactory;
return 0;
}
- public int compareTo(getTabletStats_args other) {
+ public int compareTo(getTabletStats_result other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
- getTabletStats_args typedOther = (getTabletStats_args)other;
+ getTabletStats_result typedOther = (getTabletStats_result)other;
- lastComparison = Boolean.valueOf(isSetTinfo()).compareTo(typedOther.isSetTinfo());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetTinfo()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tinfo, typedOther.tinfo);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(isSetCredentials()).compareTo(typedOther.isSetCredentials());
+ lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess());
if (lastComparison != 0) {
return lastComparison;
}
- if (isSetCredentials()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.credentials, typedOther.credentials);
+ if (isSetSuccess()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, typedOther.success);
if (lastComparison != 0) {
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(isSetTableId()).compareTo(typedOther.isSetTableId());
+ lastComparison = Boolean.valueOf(isSetSec()).compareTo(typedOther.isSetSec());
if (lastComparison != 0) {
return lastComparison;
}
- if (isSetTableId()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tableId, typedOther.tableId);
+ if (isSetSec()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.sec, typedOther.sec);
if (lastComparison != 0) {
return lastComparison;
}
@@ -20191,25 +19986,28 @@ import org.slf4j.LoggerFactory;
break;
}
switch (field.id) {
- case 3: // TINFO
- if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
- this.tinfo = new org.apache.accumulo.cloudtrace.thrift.TInfo();
- this.tinfo.read(iprot);
+ case 0: // SUCCESS
+ if (field.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list97 = iprot.readListBegin();
+ this.success = new ArrayList<TabletStats>(_list97.size);
+ for (int _i98 = 0; _i98 < _list97.size; ++_i98)
+ {
+ TabletStats _elem99;
+ _elem99 = new TabletStats();
+ _elem99.read(iprot);
+ this.success.add(_elem99);
+ }
+ iprot.readListEnd();
+ }
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
- case 1: // CREDENTIALS
+ case 1: // SEC
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
- this.credentials = new org.apache.accumulo.core.security.thrift.AuthInfo();
- this.credentials.read(iprot);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 2: // TABLE_ID
- if (field.type == org.apache.thrift.protocol.TType.STRING) {
- this.tableId = iprot.readString();
+ this.sec = new org.apache.accumulo.core.security.thrift.ThriftSecurityException();
+ this.sec.read(iprot);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
@@ -20226,22 +20024,22 @@ import org.slf4j.LoggerFactory;
}
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
- validate();
-
oprot.writeStructBegin(STRUCT_DESC);
- if (this.credentials != null) {
- oprot.writeFieldBegin(CREDENTIALS_FIELD_DESC);
- this.credentials.write(oprot);
- oprot.writeFieldEnd();
- }
- if (this.tableId != null) {
- oprot.writeFieldBegin(TABLE_ID_FIELD_DESC);
- oprot.writeString(this.tableId);
+
+ if (this.isSetSuccess()) {
+ oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, this.success.size()));
+ for (TabletStats _iter100 : this.success)
+ {
+ _iter100.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
oprot.writeFieldEnd();
- }
- if (this.tinfo != null) {
- oprot.writeFieldBegin(TINFO_FIELD_DESC);
- this.tinfo.write(oprot);
+ } else if (this.isSetSec()) {
+ oprot.writeFieldBegin(SEC_FIELD_DESC);
+ this.sec.write(oprot);
oprot.writeFieldEnd();
}
oprot.writeFieldStop();
@@ -20250,30 +20048,22 @@ import org.slf4j.LoggerFactory;
@Override
public String toString() {
- StringBuilder sb = new StringBuilder("getTabletStats_args(");
+ StringBuilder sb = new StringBuilder("getTabletStats_result(");
boolean first = true;
- sb.append("tinfo:");
- if (this.tinfo == null) {
+ sb.append("success:");
+ if (this.success == null) {
sb.append("null");
} else {
- sb.append(this.tinfo);
+ sb.append(this.success);
}
first = false;
if (!first) sb.append(", ");
- sb.append("credentials:");
- if (this.credentials == null) {
+ sb.append("sec:");
+ if (this.sec == null) {
sb.append("null");
} else {
- sb.append(this.credentials);
- }
- first = false;
- if (!first) sb.append(", ");
- sb.append("tableId:");
- if (this.tableId == null) {
- sb.append("null");
- } else {
- sb.append(this.tableId);
+ sb.append(this.sec);
}
first = false;
sb.append(")");
@@ -20302,19 +20092,19 @@ import org.slf4j.LoggerFactory;
}
- public static class getTabletStats_result implements org.apache.thrift.TBase<getTabletStats_result, getTabletStats_result._Fields>, java.io.Serializable, Cloneable {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getTabletStats_result");
+ public static class getHistoricalStats_args implements org.apache.thrift.TBase<getHistoricalStats_args, getHistoricalStats_args._Fields>, java.io.Serializable, Cloneable {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getHistoricalStats_args");
- 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 SEC_FIELD_DESC = new org.apache.thrift.protocol.TField("sec", org.apache.thrift.protocol.TType.STRUCT, (short)1);
+ private static final org.apache.thrift.protocol.TField TINFO_FIELD_DESC = new org.apache.thrift.protocol.TField("tinfo", org.apache.thrift.protocol.TType.STRUCT, (short)2);
+ private static final org.apache.thrift.protocol.TField CREDENTIALS_FIELD_DESC = new org.apache.thrift.protocol.TField("credentials", org.apache.thrift.protocol.TType.STRUCT, (short)1);
- public List<TabletStats> success;
- public org.apache.accumulo.core.security.thrift.ThriftSecurityException sec;
+ public org.apache.accumulo.cloudtrace.thrift.TInfo tinfo;
+ public org.apache.accumulo.core.security.thrift.AuthInfo credentials;
/** 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"),
- SEC((short)1, "sec");
+ TINFO((short)2, "tinfo"),
+ CREDENTIALS((short)1, "credentials");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -20329,10 +20119,10 @@ import org.slf4j.LoggerFactory;
*/
public static _Fields findByThriftId(int fieldId) {
switch(fieldId) {
- case 0: // SUCCESS
- return SUCCESS;
- case 1: // SEC
- return SEC;
+ case 2: // TINFO
+ return TINFO;
+ case 1: // CREDENTIALS
+ return CREDENTIALS;
default:
return null;
}
@@ -20377,131 +20167,111 @@ import org.slf4j.LoggerFactory;
public static final 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);
- 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, TabletStats.class))));
- tmpMap.put(_Fields.SEC, new org.apache.thrift.meta_data.FieldMetaData("sec", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
+ tmpMap.put(_Fields.TINFO, new org.apache.thrift.meta_data.FieldMetaData("tinfo", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.accumulo.cloudtrace.thrift.TInfo.class)));
+ tmpMap.put(_Fields.CREDENTIALS, new org.apache.thrift.meta_data.FieldMetaData("credentials", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.accumulo.core.security.thrift.AuthInfo.class)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getTabletStats_result.class, metaDataMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getHistoricalStats_args.class, metaDataMap);
}
- public getTabletStats_result() {
+ public getHistoricalStats_args() {
}
- public getTabletStats_result(
- List<TabletStats> success,
- org.apache.accumulo.core.security.thrift.ThriftSecurityException sec)
+ public getHistoricalStats_args(
+ org.apache.accumulo.cloudtrace.thrift.TInfo tinfo,
+ org.apache.accumulo.core.security.thrift.AuthInfo credentials)
{
this();
- this.success = success;
- this.sec = sec;
+ this.tinfo = tinfo;
+ this.credentials = credentials;
}
/**
* Performs a deep copy on <i>other</i>.
*/
- public getTabletStats_result(getTabletStats_result other) {
- if (other.isSetSuccess()) {
- List<TabletStats> __this__success = new ArrayList<TabletStats>();
- for (TabletStats other_element : other.success) {
- __this__success.add(new TabletStats(other_element));
- }
- this.success = __this__success;
+ public getHistoricalStats_args(getHistoricalStats_args other) {
+ if (other.isSetTinfo()) {
+ this.tinfo = new org.apache.accumulo.cloudtrace.thrift.TInfo(other.tinfo);
}
- if (other.isSetSec()) {
- this.sec = new org.apache.accumulo.core.security.thrift.ThriftSecurityException(other.sec);
+ if (other.isSetCredentials()) {
+ this.credentials = new org.apache.accumulo.core.security.thrift.AuthInfo(other.credentials);
}
}
- public getTabletStats_result deepCopy() {
- return new getTabletStats_result(this);
[... 5435 lines stripped ...]