You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by vi...@apache.org on 2011/10/27 17:25:17 UTC
svn commit: r1189806 [3/46] - in /incubator/accumulo: branches/1.3/contrib/
branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/
branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/admin/
branches/1.3/src/core/src/main/j...
Modified: incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/impl/thrift/ClientService.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/impl/thrift/ClientService.java?rev=1189806&r1=1189805&r2=1189806&view=diff
==============================================================================
--- incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/impl/thrift/ClientService.java (original)
+++ incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/impl/thrift/ClientService.java Thu Oct 27 15:24:51 2011
@@ -5,110 +5,119 @@
*/
package org.apache.accumulo.core.client.impl.thrift;
-
-
import org.apache.thrift.*;
import org.apache.thrift.meta_data.*;
import org.apache.thrift.protocol.*;
public class ClientService {
-
+
public interface Iface {
-
+
public String getRootTabletLocation() throws TException;
-
+
public String getInstanceId() throws TException;
-
+
public String getZooKeepers() throws TException;
-
- public String prepareBulkImport(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String dir, String tableName, double errPercent) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, TException;
-
- public void finishBulkImport(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName, String lockFile, boolean disableGC) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, TException;
-
- public void ping(org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
-
- public boolean authenticateUser(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte[] password) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
-
- public java.util.Set<String> listUsers(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
-
- public void createUser(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte[] password, java.util.List<byte[]> authorizations) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
-
- public void dropUser(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
-
- public void changePassword(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte[] password) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
-
- public void changeAuthorizations(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, java.util.List<byte[]> authorizations) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
-
- public java.util.List<byte[]> getUserAuthorizations(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
-
- public boolean hasSystemPermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte sysPerm) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
-
- public boolean hasTablePermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, String tableName, byte tblPerm) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, TException;
-
- public void grantSystemPermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte permission) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
-
- public void revokeSystemPermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte permission) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
-
- public void grantTablePermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, String tableName, byte permission) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, TException;
-
- public void revokeTablePermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, String tableName, byte permission) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, TException;
-
+
+ public String prepareBulkImport(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String dir, String tableName,
+ double errPercent) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, TException;
+
+ public void finishBulkImport(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName,
+ String lockFile, boolean disableGC) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, TException;
+
+ public void ping(org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException,
+ TException;
+
+ public boolean authenticateUser(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte[] password)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
+
+ public java.util.Set<String> listUsers(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
+
+ public void createUser(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte[] password,
+ java.util.List<byte[]> authorizations) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
+
+ public void dropUser(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
+
+ public void changePassword(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte[] password)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
+
+ public void changeAuthorizations(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user,
+ java.util.List<byte[]> authorizations) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
+
+ public java.util.List<byte[]> getUserAuthorizations(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials,
+ String user) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
+
+ public boolean hasSystemPermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte sysPerm)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
+
+ public boolean hasTablePermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user,
+ String tableName, byte tblPerm) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, TException;
+
+ public void grantSystemPermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte permission)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
+
+ public void revokeSystemPermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user,
+ byte permission) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
+
+ public void grantTablePermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user,
+ String tableName, byte permission) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, TException;
+
+ public void revokeTablePermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user,
+ String tableName, byte permission) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, TException;
+
}
-
+
public static class Client implements TServiceClient, Iface {
public static class Factory implements TServiceClientFactory<Client> {
public Factory() {}
+
public Client getClient(TProtocol prot) {
return new Client(prot);
}
+
public Client getClient(TProtocol iprot, TProtocol oprot) {
return new Client(iprot, oprot);
}
}
-
- public Client(TProtocol prot)
- {
+
+ public Client(TProtocol prot) {
this(prot, prot);
}
-
- public Client(TProtocol iprot, TProtocol oprot)
- {
+
+ public Client(TProtocol iprot, TProtocol oprot) {
iprot_ = iprot;
oprot_ = oprot;
}
-
+
protected TProtocol iprot_;
protected TProtocol oprot_;
-
+
protected int seqid_;
-
- public TProtocol getInputProtocol()
- {
+
+ public TProtocol getInputProtocol() {
return this.iprot_;
}
-
- public TProtocol getOutputProtocol()
- {
+
+ public TProtocol getOutputProtocol() {
return this.oprot_;
}
-
- public String getRootTabletLocation() throws TException
- {
+
+ public String getRootTabletLocation() throws TException {
send_getRootTabletLocation();
return recv_getRootTabletLocation();
}
-
- public void send_getRootTabletLocation() throws TException
- {
+
+ public void send_getRootTabletLocation() throws TException {
oprot_.writeMessageBegin(new TMessage("getRootTabletLocation", TMessageType.CALL, ++seqid_));
getRootTabletLocation_args args = new getRootTabletLocation_args();
args.write(oprot_);
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public String recv_getRootTabletLocation() throws TException
- {
+
+ public String recv_getRootTabletLocation() throws TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -126,24 +135,21 @@ public class ClientService {
}
throw new TApplicationException(TApplicationException.MISSING_RESULT, "getRootTabletLocation failed: unknown result");
}
-
- public String getInstanceId() throws TException
- {
+
+ public String getInstanceId() throws TException {
send_getInstanceId();
return recv_getInstanceId();
}
-
- public void send_getInstanceId() throws TException
- {
+
+ public void send_getInstanceId() throws TException {
oprot_.writeMessageBegin(new TMessage("getInstanceId", TMessageType.CALL, ++seqid_));
getInstanceId_args args = new getInstanceId_args();
args.write(oprot_);
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public String recv_getInstanceId() throws TException
- {
+
+ public String recv_getInstanceId() throws TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -161,24 +167,21 @@ public class ClientService {
}
throw new TApplicationException(TApplicationException.MISSING_RESULT, "getInstanceId failed: unknown result");
}
-
- public String getZooKeepers() throws TException
- {
+
+ public String getZooKeepers() throws TException {
send_getZooKeepers();
return recv_getZooKeepers();
}
-
- public void send_getZooKeepers() throws TException
- {
+
+ public void send_getZooKeepers() throws TException {
oprot_.writeMessageBegin(new TMessage("getZooKeepers", TMessageType.CALL, ++seqid_));
getZooKeepers_args args = new getZooKeepers_args();
args.write(oprot_);
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public String recv_getZooKeepers() throws TException
- {
+
+ public String recv_getZooKeepers() throws TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -196,15 +199,15 @@ public class ClientService {
}
throw new TApplicationException(TApplicationException.MISSING_RESULT, "getZooKeepers failed: unknown result");
}
-
- public String prepareBulkImport(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String dir, String tableName, double errPercent) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, TException
- {
+
+ public String prepareBulkImport(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String dir, String tableName,
+ double errPercent) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, TException {
send_prepareBulkImport(tinfo, credentials, dir, tableName, errPercent);
return recv_prepareBulkImport();
}
-
- public void send_prepareBulkImport(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String dir, String tableName, double errPercent) throws TException
- {
+
+ public void send_prepareBulkImport(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String dir,
+ String tableName, double errPercent) throws TException {
oprot_.writeMessageBegin(new TMessage("prepareBulkImport", TMessageType.CALL, ++seqid_));
prepareBulkImport_args args = new prepareBulkImport_args();
args.setTinfo(tinfo);
@@ -216,9 +219,8 @@ public class ClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public String recv_prepareBulkImport() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, TException
- {
+
+ public String recv_prepareBulkImport() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -242,15 +244,15 @@ public class ClientService {
}
throw new TApplicationException(TApplicationException.MISSING_RESULT, "prepareBulkImport failed: unknown result");
}
-
- public void finishBulkImport(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName, String lockFile, boolean disableGC) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, TException
- {
+
+ public void finishBulkImport(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName,
+ String lockFile, boolean disableGC) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, TException {
send_finishBulkImport(tinfo, credentials, tableName, lockFile, disableGC);
recv_finishBulkImport();
}
-
- public void send_finishBulkImport(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName, String lockFile, boolean disableGC) throws TException
- {
+
+ public void send_finishBulkImport(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName,
+ String lockFile, boolean disableGC) throws TException {
oprot_.writeMessageBegin(new TMessage("finishBulkImport", TMessageType.CALL, ++seqid_));
finishBulkImport_args args = new finishBulkImport_args();
args.setTinfo(tinfo);
@@ -262,9 +264,8 @@ public class ClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void recv_finishBulkImport() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, TException
- {
+
+ public void recv_finishBulkImport() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -285,15 +286,14 @@ public class ClientService {
}
return;
}
-
- public void ping(org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public void ping(org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException,
+ TException {
send_ping(credentials);
recv_ping();
}
-
- public void send_ping(org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws TException
- {
+
+ public void send_ping(org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws TException {
oprot_.writeMessageBegin(new TMessage("ping", TMessageType.CALL, ++seqid_));
ping_args args = new ping_args();
args.setCredentials(credentials);
@@ -301,9 +301,8 @@ public class ClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void recv_ping() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public void recv_ping() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -321,15 +320,15 @@ public class ClientService {
}
return;
}
-
- public boolean authenticateUser(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte[] password) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public boolean authenticateUser(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte[] password)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
send_authenticateUser(tinfo, credentials, user, password);
return recv_authenticateUser();
}
-
- public void send_authenticateUser(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte[] password) throws TException
- {
+
+ public void send_authenticateUser(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte[] password)
+ throws TException {
oprot_.writeMessageBegin(new TMessage("authenticateUser", TMessageType.CALL, ++seqid_));
authenticateUser_args args = new authenticateUser_args();
args.setTinfo(tinfo);
@@ -340,9 +339,8 @@ public class ClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public boolean recv_authenticateUser() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public boolean recv_authenticateUser() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -363,15 +361,14 @@ public class ClientService {
}
throw new TApplicationException(TApplicationException.MISSING_RESULT, "authenticateUser failed: unknown result");
}
-
- public java.util.Set<String> listUsers(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public java.util.Set<String> listUsers(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
send_listUsers(tinfo, credentials);
return recv_listUsers();
}
-
- public void send_listUsers(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws TException
- {
+
+ public void send_listUsers(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws TException {
oprot_.writeMessageBegin(new TMessage("listUsers", TMessageType.CALL, ++seqid_));
listUsers_args args = new listUsers_args();
args.setTinfo(tinfo);
@@ -380,9 +377,8 @@ public class ClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public java.util.Set<String> recv_listUsers() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public java.util.Set<String> recv_listUsers() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -403,15 +399,15 @@ public class ClientService {
}
throw new TApplicationException(TApplicationException.MISSING_RESULT, "listUsers failed: unknown result");
}
-
- public void createUser(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte[] password, java.util.List<byte[]> authorizations) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public void createUser(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte[] password,
+ java.util.List<byte[]> authorizations) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
send_createUser(tinfo, credentials, user, password, authorizations);
recv_createUser();
}
-
- public void send_createUser(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte[] password, java.util.List<byte[]> authorizations) throws TException
- {
+
+ public void send_createUser(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte[] password,
+ java.util.List<byte[]> authorizations) throws TException {
oprot_.writeMessageBegin(new TMessage("createUser", TMessageType.CALL, ++seqid_));
createUser_args args = new createUser_args();
args.setTinfo(tinfo);
@@ -423,9 +419,8 @@ public class ClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void recv_createUser() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public void recv_createUser() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -443,15 +438,14 @@ public class ClientService {
}
return;
}
-
- public void dropUser(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public void dropUser(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
send_dropUser(tinfo, credentials, user);
recv_dropUser();
}
-
- public void send_dropUser(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user) throws TException
- {
+
+ public void send_dropUser(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user) throws TException {
oprot_.writeMessageBegin(new TMessage("dropUser", TMessageType.CALL, ++seqid_));
dropUser_args args = new dropUser_args();
args.setTinfo(tinfo);
@@ -461,9 +455,8 @@ public class ClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void recv_dropUser() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public void recv_dropUser() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -481,15 +474,15 @@ public class ClientService {
}
return;
}
-
- public void changePassword(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte[] password) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public void changePassword(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte[] password)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
send_changePassword(tinfo, credentials, user, password);
recv_changePassword();
}
-
- public void send_changePassword(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte[] password) throws TException
- {
+
+ public void send_changePassword(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte[] password)
+ throws TException {
oprot_.writeMessageBegin(new TMessage("changePassword", TMessageType.CALL, ++seqid_));
changePassword_args args = new changePassword_args();
args.setTinfo(tinfo);
@@ -500,9 +493,8 @@ public class ClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void recv_changePassword() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public void recv_changePassword() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -520,15 +512,15 @@ public class ClientService {
}
return;
}
-
- public void changeAuthorizations(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, java.util.List<byte[]> authorizations) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public void changeAuthorizations(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user,
+ java.util.List<byte[]> authorizations) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
send_changeAuthorizations(tinfo, credentials, user, authorizations);
recv_changeAuthorizations();
}
-
- public void send_changeAuthorizations(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, java.util.List<byte[]> authorizations) throws TException
- {
+
+ public void send_changeAuthorizations(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user,
+ java.util.List<byte[]> authorizations) throws TException {
oprot_.writeMessageBegin(new TMessage("changeAuthorizations", TMessageType.CALL, ++seqid_));
changeAuthorizations_args args = new changeAuthorizations_args();
args.setTinfo(tinfo);
@@ -539,9 +531,8 @@ public class ClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void recv_changeAuthorizations() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public void recv_changeAuthorizations() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -559,15 +550,15 @@ public class ClientService {
}
return;
}
-
- public java.util.List<byte[]> getUserAuthorizations(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public java.util.List<byte[]> getUserAuthorizations(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials,
+ String user) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
send_getUserAuthorizations(tinfo, credentials, user);
return recv_getUserAuthorizations();
}
-
- public void send_getUserAuthorizations(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user) throws TException
- {
+
+ public void send_getUserAuthorizations(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user)
+ throws TException {
oprot_.writeMessageBegin(new TMessage("getUserAuthorizations", TMessageType.CALL, ++seqid_));
getUserAuthorizations_args args = new getUserAuthorizations_args();
args.setTinfo(tinfo);
@@ -577,9 +568,8 @@ public class ClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public java.util.List<byte[]> recv_getUserAuthorizations() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public java.util.List<byte[]> recv_getUserAuthorizations() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -600,15 +590,15 @@ public class ClientService {
}
throw new TApplicationException(TApplicationException.MISSING_RESULT, "getUserAuthorizations failed: unknown result");
}
-
- public boolean hasSystemPermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte sysPerm) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public boolean hasSystemPermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte sysPerm)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
send_hasSystemPermission(tinfo, credentials, user, sysPerm);
return recv_hasSystemPermission();
}
-
- public void send_hasSystemPermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte sysPerm) throws TException
- {
+
+ public void send_hasSystemPermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte sysPerm)
+ throws TException {
oprot_.writeMessageBegin(new TMessage("hasSystemPermission", TMessageType.CALL, ++seqid_));
hasSystemPermission_args args = new hasSystemPermission_args();
args.setTinfo(tinfo);
@@ -619,9 +609,8 @@ public class ClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public boolean recv_hasSystemPermission() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public boolean recv_hasSystemPermission() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -642,15 +631,15 @@ public class ClientService {
}
throw new TApplicationException(TApplicationException.MISSING_RESULT, "hasSystemPermission failed: unknown result");
}
-
- public boolean hasTablePermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, String tableName, byte tblPerm) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, TException
- {
+
+ public boolean hasTablePermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user,
+ String tableName, byte tblPerm) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, TException {
send_hasTablePermission(tinfo, credentials, user, tableName, tblPerm);
return recv_hasTablePermission();
}
-
- public void send_hasTablePermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, String tableName, byte tblPerm) throws TException
- {
+
+ public void send_hasTablePermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user,
+ String tableName, byte tblPerm) throws TException {
oprot_.writeMessageBegin(new TMessage("hasTablePermission", TMessageType.CALL, ++seqid_));
hasTablePermission_args args = new hasTablePermission_args();
args.setTinfo(tinfo);
@@ -662,9 +651,8 @@ public class ClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public boolean recv_hasTablePermission() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, TException
- {
+
+ public boolean recv_hasTablePermission() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -688,15 +676,15 @@ public class ClientService {
}
throw new TApplicationException(TApplicationException.MISSING_RESULT, "hasTablePermission failed: unknown result");
}
-
- public void grantSystemPermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte permission) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public void grantSystemPermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte permission)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
send_grantSystemPermission(tinfo, credentials, user, permission);
recv_grantSystemPermission();
}
-
- public void send_grantSystemPermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte permission) throws TException
- {
+
+ public void send_grantSystemPermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user,
+ byte permission) throws TException {
oprot_.writeMessageBegin(new TMessage("grantSystemPermission", TMessageType.CALL, ++seqid_));
grantSystemPermission_args args = new grantSystemPermission_args();
args.setTinfo(tinfo);
@@ -707,9 +695,8 @@ public class ClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void recv_grantSystemPermission() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public void recv_grantSystemPermission() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -727,15 +714,15 @@ public class ClientService {
}
return;
}
-
- public void revokeSystemPermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte permission) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public void revokeSystemPermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user,
+ byte permission) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
send_revokeSystemPermission(tinfo, credentials, user, permission);
recv_revokeSystemPermission();
}
-
- public void send_revokeSystemPermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, byte permission) throws TException
- {
+
+ public void send_revokeSystemPermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user,
+ byte permission) throws TException {
oprot_.writeMessageBegin(new TMessage("revokeSystemPermission", TMessageType.CALL, ++seqid_));
revokeSystemPermission_args args = new revokeSystemPermission_args();
args.setTinfo(tinfo);
@@ -746,9 +733,8 @@ public class ClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void recv_revokeSystemPermission() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public void recv_revokeSystemPermission() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -766,15 +752,15 @@ public class ClientService {
}
return;
}
-
- public void grantTablePermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, String tableName, byte permission) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, TException
- {
+
+ public void grantTablePermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user,
+ String tableName, byte permission) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, TException {
send_grantTablePermission(tinfo, credentials, user, tableName, permission);
recv_grantTablePermission();
}
-
- public void send_grantTablePermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, String tableName, byte permission) throws TException
- {
+
+ public void send_grantTablePermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user,
+ String tableName, byte permission) throws TException {
oprot_.writeMessageBegin(new TMessage("grantTablePermission", TMessageType.CALL, ++seqid_));
grantTablePermission_args args = new grantTablePermission_args();
args.setTinfo(tinfo);
@@ -786,9 +772,8 @@ public class ClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void recv_grantTablePermission() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, TException
- {
+
+ public void recv_grantTablePermission() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -809,15 +794,15 @@ public class ClientService {
}
return;
}
-
- public void revokeTablePermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, String tableName, byte permission) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, TException
- {
+
+ public void revokeTablePermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user,
+ String tableName, byte permission) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, TException {
send_revokeTablePermission(tinfo, credentials, user, tableName, permission);
recv_revokeTablePermission();
}
-
- public void send_revokeTablePermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, String tableName, byte permission) throws TException
- {
+
+ public void send_revokeTablePermission(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user,
+ String tableName, byte permission) throws TException {
oprot_.writeMessageBegin(new TMessage("revokeTablePermission", TMessageType.CALL, ++seqid_));
revokeTablePermission_args args = new revokeTablePermission_args();
args.setTinfo(tinfo);
@@ -829,9 +814,8 @@ public class ClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void recv_revokeTablePermission() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, TException
- {
+
+ public void recv_revokeTablePermission() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, ThriftTableOperationException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -852,12 +836,13 @@ public class ClientService {
}
return;
}
-
+
}
+
public static class Processor implements TProcessor {
private static final org.slf4j.Logger LOGGER = org.slf4j.LoggerFactory.getLogger(Processor.class.getName());
- public Processor(Iface iface)
- {
+
+ public Processor(Iface iface) {
iface_ = iface;
processMap_.put("getRootTabletLocation", new getRootTabletLocation());
processMap_.put("getInstanceId", new getInstanceId());
@@ -879,22 +864,21 @@ public class ClientService {
processMap_.put("grantTablePermission", new grantTablePermission());
processMap_.put("revokeTablePermission", new revokeTablePermission());
}
-
+
protected static interface ProcessFunction {
public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException;
}
-
+
private Iface iface_;
protected final java.util.HashMap<String,ProcessFunction> processMap_ = new java.util.HashMap<String,ProcessFunction>();
-
- public boolean process(TProtocol iprot, TProtocol oprot) throws TException
- {
+
+ public boolean process(TProtocol iprot, TProtocol oprot) throws TException {
TMessage msg = iprot.readMessageBegin();
ProcessFunction fn = processMap_.get(msg.name);
if (fn == null) {
TProtocolUtil.skip(iprot, TType.STRUCT);
iprot.readMessageEnd();
- TApplicationException x = new TApplicationException(TApplicationException.UNKNOWN_METHOD, "Invalid method name: '"+msg.name+"'");
+ TApplicationException x = new TApplicationException(TApplicationException.UNKNOWN_METHOD, "Invalid method name: '" + msg.name + "'");
oprot.writeMessageBegin(new TMessage(msg.name, TMessageType.EXCEPTION, msg.seqid));
x.write(oprot);
oprot.writeMessageEnd();
@@ -904,10 +888,9 @@ public class ClientService {
fn.process(msg.seqid, iprot, oprot);
return true;
}
-
+
private class getRootTabletLocation implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
getRootTabletLocation_args args = new getRootTabletLocation_args();
try {
args.read(iprot);
@@ -928,12 +911,11 @@ public class ClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class getInstanceId implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
getInstanceId_args args = new getInstanceId_args();
try {
args.read(iprot);
@@ -954,12 +936,11 @@ public class ClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class getZooKeepers implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
getZooKeepers_args args = new getZooKeepers_args();
try {
args.read(iprot);
@@ -980,12 +961,11 @@ public class ClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class prepareBulkImport implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
prepareBulkImport_args args = new prepareBulkImport_args();
try {
args.read(iprot);
@@ -1020,12 +1000,11 @@ public class ClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class finishBulkImport implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
finishBulkImport_args args = new finishBulkImport_args();
try {
args.read(iprot);
@@ -1060,12 +1039,11 @@ public class ClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class ping implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
ping_args args = new ping_args();
try {
args.read(iprot);
@@ -1098,12 +1076,11 @@ public class ClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class authenticateUser implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
authenticateUser_args args = new authenticateUser_args();
try {
args.read(iprot);
@@ -1137,12 +1114,11 @@ public class ClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class listUsers implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
listUsers_args args = new listUsers_args();
try {
args.read(iprot);
@@ -1175,12 +1151,11 @@ public class ClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class createUser implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
createUser_args args = new createUser_args();
try {
args.read(iprot);
@@ -1213,12 +1188,11 @@ public class ClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class dropUser implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
dropUser_args args = new dropUser_args();
try {
args.read(iprot);
@@ -1251,12 +1225,11 @@ public class ClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class changePassword implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
changePassword_args args = new changePassword_args();
try {
args.read(iprot);
@@ -1289,12 +1262,11 @@ public class ClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class changeAuthorizations implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
changeAuthorizations_args args = new changeAuthorizations_args();
try {
args.read(iprot);
@@ -1327,12 +1299,11 @@ public class ClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class getUserAuthorizations implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
getUserAuthorizations_args args = new getUserAuthorizations_args();
try {
args.read(iprot);
@@ -1365,12 +1336,11 @@ public class ClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class hasSystemPermission implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
hasSystemPermission_args args = new hasSystemPermission_args();
try {
args.read(iprot);
@@ -1404,12 +1374,11 @@ public class ClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class hasTablePermission implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
hasTablePermission_args args = new hasTablePermission_args();
try {
args.read(iprot);
@@ -1445,12 +1414,11 @@ public class ClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class grantSystemPermission implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
grantSystemPermission_args args = new grantSystemPermission_args();
try {
args.read(iprot);
@@ -1483,12 +1451,11 @@ public class ClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class revokeSystemPermission implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
revokeSystemPermission_args args = new revokeSystemPermission_args();
try {
args.read(iprot);
@@ -1521,12 +1488,11 @@ public class ClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class grantTablePermission implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
grantTablePermission_args args = new grantTablePermission_args();
try {
args.read(iprot);
@@ -1561,12 +1527,11 @@ public class ClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class revokeTablePermission implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
revokeTablePermission_args args = new revokeTablePermission_args();
try {
args.read(iprot);
@@ -1601,163 +1566,160 @@ public class ClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
}
-
+
@SuppressWarnings("serial")
- public static class getRootTabletLocation_args implements TBase<getRootTabletLocation_args, getRootTabletLocation_args._Fields>, java.io.Serializable, Cloneable {
+ public static class getRootTabletLocation_args implements TBase<getRootTabletLocation_args,getRootTabletLocation_args._Fields>, java.io.Serializable,
+ Cloneable {
private static final TStruct STRUCT_DESC = new TStruct("getRootTabletLocation_args");
-
-
-
+
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements TFieldIdEnum {
-;
-
- private static final java.util.Map<String, _Fields> byName = new java.util.HashMap<String, _Fields>();
-
+ ;
+
+ private static final java.util.Map<String,_Fields> byName = new java.util.HashMap<String,_Fields>();
+
static {
for (_Fields field : java.util.EnumSet.allOf(_Fields.class)) {
byName.put(field.getFieldName(), field);
}
}
-
+
/**
* Find the _Fields constant that matches fieldId, or null if its not found.
*/
public static _Fields findByThriftId(int fieldId) {
- switch(fieldId) {
+ switch (fieldId) {
default:
return null;
}
}
-
+
/**
- * Find the _Fields constant that matches fieldId, throwing an exception
- * if it is not found.
+ * Find the _Fields constant that matches fieldId, throwing an exception if it is not found.
*/
public static _Fields findByThriftIdOrThrow(int fieldId) {
_Fields fields = findByThriftId(fieldId);
- if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+ if (fields == null)
+ throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
return fields;
}
-
+
/**
* Find the _Fields constant that matches name, or null if its not found.
*/
public static _Fields findByName(String name) {
return byName.get(name);
}
-
+
private final short _thriftId;
private final String _fieldName;
-
+
_Fields(short thriftId, String fieldName) {
_thriftId = thriftId;
_fieldName = fieldName;
}
-
+
public short getThriftFieldId() {
return _thriftId;
}
-
+
public String getFieldName() {
return _fieldName;
}
}
- public static final java.util.Map<_Fields, FieldMetaData> metaDataMap;
+
+ public static final java.util.Map<_Fields,FieldMetaData> metaDataMap;
static {
- java.util.Map<_Fields, FieldMetaData> tmpMap = new java.util.EnumMap<_Fields, FieldMetaData>(_Fields.class);
+ java.util.Map<_Fields,FieldMetaData> tmpMap = new java.util.EnumMap<_Fields,FieldMetaData>(_Fields.class);
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
FieldMetaData.addStructMetaDataMap(getRootTabletLocation_args.class, metaDataMap);
}
-
- public getRootTabletLocation_args() {
- }
-
+
+ public getRootTabletLocation_args() {}
+
/**
* Performs a deep copy on <i>other</i>.
*/
- public getRootTabletLocation_args(getRootTabletLocation_args other) {
- }
-
+ public getRootTabletLocation_args(getRootTabletLocation_args other) {}
+
public getRootTabletLocation_args deepCopy() {
return new getRootTabletLocation_args(this);
}
-
+
@Deprecated
public getRootTabletLocation_args clone() {
return new getRootTabletLocation_args(this);
}
-
+
public void setFieldValue(_Fields field, Object value) {
switch (field) {
}
}
-
+
public void setFieldValue(int fieldID, Object value) {
setFieldValue(_Fields.findByThriftIdOrThrow(fieldID), value);
}
-
+
public Object getFieldValue(_Fields field) {
switch (field) {
}
throw new IllegalStateException();
}
-
+
public Object getFieldValue(int fieldId) {
return getFieldValue(_Fields.findByThriftIdOrThrow(fieldId));
}
-
+
/** Returns true if field corresponding to fieldID is set (has been asigned a value) and false otherwise */
public boolean isSet(_Fields field) {
switch (field) {
}
throw new IllegalStateException();
}
-
+
public boolean isSet(int fieldID) {
return isSet(_Fields.findByThriftIdOrThrow(fieldID));
}
-
+
@Override
public boolean equals(Object that) {
if (that == null)
return false;
if (that instanceof getRootTabletLocation_args)
- return this.equals((getRootTabletLocation_args)that);
+ return this.equals((getRootTabletLocation_args) that);
return false;
}
-
+
public boolean equals(getRootTabletLocation_args that) {
if (that == null)
return false;
-
+
return true;
}
-
+
@Override
public int hashCode() {
return 0;
}
-
+
public int compareTo(getRootTabletLocation_args other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
-
+
return 0;
}
-
+
public void read(TProtocol iprot) throws TException {
TField field;
iprot.readStructBegin();
- while (true)
- {
+ while (true) {
field = iprot.readFieldBegin();
- if (field.type == TType.STOP) {
+ if (field.type == TType.STOP) {
break;
}
switch (field.id) {
@@ -1767,119 +1729,116 @@ public class ClientService {
iprot.readFieldEnd();
}
iprot.readStructEnd();
-
+
// check for required fields of primitive type, which can't be checked in the validate method
validate();
}
-
+
public void write(TProtocol oprot) throws TException {
validate();
-
+
oprot.writeStructBegin(STRUCT_DESC);
oprot.writeFieldStop();
oprot.writeStructEnd();
}
-
+
@Override
public String toString() {
StringBuilder sb = new StringBuilder("getRootTabletLocation_args(");
sb.append(")");
return sb.toString();
}
-
+
public void validate() throws TException {
// check for required fields
}
-
+
}
-
+
@SuppressWarnings("serial")
- public static class getRootTabletLocation_result implements TBase<getRootTabletLocation_result, getRootTabletLocation_result._Fields>, java.io.Serializable, Cloneable {
+ public static class getRootTabletLocation_result implements TBase<getRootTabletLocation_result,getRootTabletLocation_result._Fields>, java.io.Serializable,
+ Cloneable {
private static final TStruct STRUCT_DESC = new TStruct("getRootTabletLocation_result");
-
- private static final TField SUCCESS_FIELD_DESC = new TField("success", TType.STRING, (short)0);
-
+
+ private static final TField SUCCESS_FIELD_DESC = new TField("success", TType.STRING, (short) 0);
+
public String success;
-
+
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements TFieldIdEnum {
- SUCCESS((short)0, "success");
-
- private static final java.util.Map<String, _Fields> byName = new java.util.HashMap<String, _Fields>();
-
+ SUCCESS((short) 0, "success");
+
+ private static final java.util.Map<String,_Fields> byName = new java.util.HashMap<String,_Fields>();
+
static {
for (_Fields field : java.util.EnumSet.allOf(_Fields.class)) {
byName.put(field.getFieldName(), field);
}
}
-
+
/**
* Find the _Fields constant that matches fieldId, or null if its not found.
*/
public static _Fields findByThriftId(int fieldId) {
- switch(fieldId) {
+ switch (fieldId) {
case 0: // SUCCESS
return SUCCESS;
default:
return null;
}
}
-
+
/**
- * Find the _Fields constant that matches fieldId, throwing an exception
- * if it is not found.
+ * Find the _Fields constant that matches fieldId, throwing an exception if it is not found.
*/
public static _Fields findByThriftIdOrThrow(int fieldId) {
_Fields fields = findByThriftId(fieldId);
- if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+ if (fields == null)
+ throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
return fields;
}
-
+
/**
* Find the _Fields constant that matches name, or null if its not found.
*/
public static _Fields findByName(String name) {
return byName.get(name);
}
-
+
private final short _thriftId;
private final String _fieldName;
-
+
_Fields(short thriftId, String fieldName) {
_thriftId = thriftId;
_fieldName = fieldName;
}
-
+
public short getThriftFieldId() {
return _thriftId;
}
-
+
public String getFieldName() {
return _fieldName;
}
}
-
+
// isset id assignments
-
- public static final java.util.Map<_Fields, FieldMetaData> metaDataMap;
+
+ public static final java.util.Map<_Fields,FieldMetaData> metaDataMap;
static {
- java.util.Map<_Fields, FieldMetaData> tmpMap = new java.util.EnumMap<_Fields, FieldMetaData>(_Fields.class);
- tmpMap.put(_Fields.SUCCESS, new FieldMetaData("success", TFieldRequirementType.DEFAULT,
- new FieldValueMetaData(TType.STRING)));
+ java.util.Map<_Fields,FieldMetaData> tmpMap = new java.util.EnumMap<_Fields,FieldMetaData>(_Fields.class);
+ tmpMap.put(_Fields.SUCCESS, new FieldMetaData("success", TFieldRequirementType.DEFAULT, new FieldValueMetaData(TType.STRING)));
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
FieldMetaData.addStructMetaDataMap(getRootTabletLocation_result.class, metaDataMap);
}
-
- public getRootTabletLocation_result() {
- }
-
- public getRootTabletLocation_result(
- String success)
- {
+
+ public getRootTabletLocation_result() {}
+
+ public getRootTabletLocation_result(String success) {
this();
this.success = success;
}
-
+
/**
* Performs a deep copy on <i>other</i>.
*/
@@ -1888,96 +1847,96 @@ public class ClientService {
this.success = other.success;
}
}
-
+
public getRootTabletLocation_result deepCopy() {
return new getRootTabletLocation_result(this);
}
-
+
@Deprecated
public getRootTabletLocation_result clone() {
return new getRootTabletLocation_result(this);
}
-
+
public String getSuccess() {
return this.success;
}
-
+
public getRootTabletLocation_result setSuccess(String success) {
this.success = success;
return this;
}
-
+
public void unsetSuccess() {
this.success = null;
}
-
+
/** Returns true if field success is set (has been asigned a value) and false otherwise */
public boolean isSetSuccess() {
return this.success != null;
}
-
+
public void setSuccessIsSet(boolean value) {
if (!value) {
this.success = null;
}
}
-
+
public void setFieldValue(_Fields field, Object value) {
switch (field) {
- case SUCCESS:
- if (value == null) {
- unsetSuccess();
- } else {
- setSuccess((String)value);
- }
- break;
-
+ case SUCCESS:
+ if (value == null) {
+ unsetSuccess();
+ } else {
+ setSuccess((String) value);
+ }
+ break;
+
}
}
-
+
public void setFieldValue(int fieldID, Object value) {
setFieldValue(_Fields.findByThriftIdOrThrow(fieldID), value);
}
-
+
public Object getFieldValue(_Fields field) {
switch (field) {
- case SUCCESS:
- return getSuccess();
-
+ case SUCCESS:
+ return getSuccess();
+
}
throw new IllegalStateException();
}
-
+
public Object getFieldValue(int fieldId) {
return getFieldValue(_Fields.findByThriftIdOrThrow(fieldId));
}
-
+
/** Returns true if field corresponding to fieldID is set (has been asigned a value) and false otherwise */
public boolean isSet(_Fields field) {
switch (field) {
- case SUCCESS:
- return isSetSuccess();
+ case SUCCESS:
+ return isSetSuccess();
}
throw new IllegalStateException();
}
-
+
public boolean isSet(int fieldID) {
return isSet(_Fields.findByThriftIdOrThrow(fieldID));
}
-
+
@Override
public boolean equals(Object that) {
if (that == null)
return false;
if (that instanceof getRootTabletLocation_result)
- return this.equals((getRootTabletLocation_result)that);
+ return this.equals((getRootTabletLocation_result) that);
return false;
}
-
+
public boolean equals(getRootTabletLocation_result that) {
if (that == null)
return false;
-
+
boolean this_present_success = true && this.isSetSuccess();
boolean that_present_success = true && that.isSetSuccess();
if (this_present_success || that_present_success) {
@@ -1986,49 +1945,49 @@ public class ClientService {
if (!this.success.equals(that.success))
return false;
}
-
+
return true;
}
-
+
@Override
public int hashCode() {
return 0;
}
-
+
public int compareTo(getRootTabletLocation_result other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
-
+
int lastComparison = 0;
- getRootTabletLocation_result typedOther = (getRootTabletLocation_result)other;
-
+ getRootTabletLocation_result typedOther = (getRootTabletLocation_result) other;
+
lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess());
if (lastComparison != 0) {
return lastComparison;
}
- if (isSetSuccess()) { lastComparison = TBaseHelper.compareTo(this.success, typedOther.success);
+ if (isSetSuccess()) {
+ lastComparison = TBaseHelper.compareTo(this.success, typedOther.success);
if (lastComparison != 0) {
return lastComparison;
}
}
return 0;
}
-
+
public void read(TProtocol iprot) throws TException {
TField field;
iprot.readStructBegin();
- while (true)
- {
+ while (true) {
field = iprot.readFieldBegin();
- if (field.type == TType.STOP) {
+ if (field.type == TType.STOP) {
break;
}
switch (field.id) {
case 0: // SUCCESS
if (field.type == TType.STRING) {
this.success = iprot.readString();
- } else {
+ } else {
TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -2038,14 +1997,14 @@ public class ClientService {
iprot.readFieldEnd();
}
iprot.readStructEnd();
-
+
// check for required fields of primitive type, which can't be checked in the validate method
validate();
}
-
+
public void write(TProtocol oprot) throws TException {
oprot.writeStructBegin(STRUCT_DESC);
-
+
if (this.isSetSuccess()) {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
oprot.writeString(this.success);
@@ -2054,7 +2013,7 @@ public class ClientService {
oprot.writeFieldStop();
oprot.writeStructEnd();
}
-
+
@Override
public String toString() {
StringBuilder sb = new StringBuilder("getRootTabletLocation_result(");
@@ -2067,165 +2026,161 @@ public class ClientService {
sb.append(")");
return sb.toString();
}
-
+
public void validate() throws TException {
// check for required fields
}
-
+
}
-
+
@SuppressWarnings("serial")
- public static class getInstanceId_args implements TBase<getInstanceId_args, getInstanceId_args._Fields>, java.io.Serializable, Cloneable {
+ public static class getInstanceId_args implements TBase<getInstanceId_args,getInstanceId_args._Fields>, java.io.Serializable, Cloneable {
private static final TStruct STRUCT_DESC = new TStruct("getInstanceId_args");
-
-
-
+
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements TFieldIdEnum {
-;
-
- private static final java.util.Map<String, _Fields> byName = new java.util.HashMap<String, _Fields>();
-
+ ;
+
+ private static final java.util.Map<String,_Fields> byName = new java.util.HashMap<String,_Fields>();
+
static {
for (_Fields field : java.util.EnumSet.allOf(_Fields.class)) {
byName.put(field.getFieldName(), field);
}
}
-
+
/**
* Find the _Fields constant that matches fieldId, or null if its not found.
*/
public static _Fields findByThriftId(int fieldId) {
- switch(fieldId) {
+ switch (fieldId) {
default:
return null;
}
}
-
+
/**
- * Find the _Fields constant that matches fieldId, throwing an exception
- * if it is not found.
+ * Find the _Fields constant that matches fieldId, throwing an exception if it is not found.
*/
public static _Fields findByThriftIdOrThrow(int fieldId) {
_Fields fields = findByThriftId(fieldId);
- if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+ if (fields == null)
+ throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
return fields;
}
-
+
/**
* Find the _Fields constant that matches name, or null if its not found.
*/
public static _Fields findByName(String name) {
return byName.get(name);
}
-
+
private final short _thriftId;
private final String _fieldName;
-
+
_Fields(short thriftId, String fieldName) {
_thriftId = thriftId;
_fieldName = fieldName;
}
-
+
public short getThriftFieldId() {
return _thriftId;
}
-
+
public String getFieldName() {
return _fieldName;
}
}
- public static final java.util.Map<_Fields, FieldMetaData> metaDataMap;
+
+ public static final java.util.Map<_Fields,FieldMetaData> metaDataMap;
static {
- java.util.Map<_Fields, FieldMetaData> tmpMap = new java.util.EnumMap<_Fields, FieldMetaData>(_Fields.class);
+ java.util.Map<_Fields,FieldMetaData> tmpMap = new java.util.EnumMap<_Fields,FieldMetaData>(_Fields.class);
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
FieldMetaData.addStructMetaDataMap(getInstanceId_args.class, metaDataMap);
}
-
- public getInstanceId_args() {
- }
-
+
+ public getInstanceId_args() {}
+
/**
* Performs a deep copy on <i>other</i>.
*/
- public getInstanceId_args(getInstanceId_args other) {
- }
-
+ public getInstanceId_args(getInstanceId_args other) {}
+
public getInstanceId_args deepCopy() {
return new getInstanceId_args(this);
}
-
+
@Deprecated
public getInstanceId_args clone() {
return new getInstanceId_args(this);
}
-
+
public void setFieldValue(_Fields field, Object value) {
switch (field) {
}
}
-
+
public void setFieldValue(int fieldID, Object value) {
setFieldValue(_Fields.findByThriftIdOrThrow(fieldID), value);
}
-
+
public Object getFieldValue(_Fields field) {
switch (field) {
}
throw new IllegalStateException();
}
-
+
public Object getFieldValue(int fieldId) {
return getFieldValue(_Fields.findByThriftIdOrThrow(fieldId));
}
-
+
/** Returns true if field corresponding to fieldID is set (has been asigned a value) and false otherwise */
public boolean isSet(_Fields field) {
switch (field) {
}
throw new IllegalStateException();
}
-
+
public boolean isSet(int fieldID) {
return isSet(_Fields.findByThriftIdOrThrow(fieldID));
}
-
+
@Override
public boolean equals(Object that) {
if (that == null)
return false;
if (that instanceof getInstanceId_args)
- return this.equals((getInstanceId_args)that);
+ return this.equals((getInstanceId_args) that);
return false;
}
-
+
public boolean equals(getInstanceId_args that) {
if (that == null)
return false;
-
+
return true;
}
-
+
@Override
public int hashCode() {
return 0;
}
-
+
public int compareTo(getInstanceId_args other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
-
+
return 0;
}
-
+
public void read(TProtocol iprot) throws TException {
TField field;
iprot.readStructBegin();
- while (true)
- {
+ while (true) {
field = iprot.readFieldBegin();
- if (field.type == TType.STOP) {
+ if (field.type == TType.STOP) {
break;
}
switch (field.id) {
@@ -2235,119 +2190,115 @@ public class ClientService {
iprot.readFieldEnd();
}
iprot.readStructEnd();
-
+
// check for required fields of primitive type, which can't be checked in the validate method
validate();
}
-
+
public void write(TProtocol oprot) throws TException {
validate();
-
+
oprot.writeStructBegin(STRUCT_DESC);
oprot.writeFieldStop();
oprot.writeStructEnd();
}
-
+
@Override
public String toString() {
StringBuilder sb = new StringBuilder("getInstanceId_args(");
sb.append(")");
return sb.toString();
}
-
+
public void validate() throws TException {
// check for required fields
}
-
+
}
-
+
@SuppressWarnings("serial")
- public static class getInstanceId_result implements TBase<getInstanceId_result, getInstanceId_result._Fields>, java.io.Serializable, Cloneable {
+ public static class getInstanceId_result implements TBase<getInstanceId_result,getInstanceId_result._Fields>, java.io.Serializable, Cloneable {
private static final TStruct STRUCT_DESC = new TStruct("getInstanceId_result");
-
- private static final TField SUCCESS_FIELD_DESC = new TField("success", TType.STRING, (short)0);
-
+
+ private static final TField SUCCESS_FIELD_DESC = new TField("success", TType.STRING, (short) 0);
+
public String success;
-
+
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements TFieldIdEnum {
- SUCCESS((short)0, "success");
-
- private static final java.util.Map<String, _Fields> byName = new java.util.HashMap<String, _Fields>();
-
+ SUCCESS((short) 0, "success");
+
+ private static final java.util.Map<String,_Fields> byName = new java.util.HashMap<String,_Fields>();
+
static {
for (_Fields field : java.util.EnumSet.allOf(_Fields.class)) {
byName.put(field.getFieldName(), field);
}
}
-
+
/**
* Find the _Fields constant that matches fieldId, or null if its not found.
*/
public static _Fields findByThriftId(int fieldId) {
- switch(fieldId) {
+ switch (fieldId) {
case 0: // SUCCESS
return SUCCESS;
default:
return null;
}
}
-
+
/**
- * Find the _Fields constant that matches fieldId, throwing an exception
- * if it is not found.
+ * Find the _Fields constant that matches fieldId, throwing an exception if it is not found.
*/
public static _Fields findByThriftIdOrThrow(int fieldId) {
_Fields fields = findByThriftId(fieldId);
- if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+ if (fields == null)
+ throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
return fields;
}
-
+
/**
* Find the _Fields constant that matches name, or null if its not found.
*/
public static _Fields findByName(String name) {
return byName.get(name);
}
-
+
private final short _thriftId;
private final String _fieldName;
-
+
_Fields(short thriftId, String fieldName) {
_thriftId = thriftId;
_fieldName = fieldName;
}
-
+
public short getThriftFieldId() {
return _thriftId;
}
-
+
public String getFieldName() {
return _fieldName;
}
}
-
+
// isset id assignments
-
- public static final java.util.Map<_Fields, FieldMetaData> metaDataMap;
+
+ public static final java.util.Map<_Fields,FieldMetaData> metaDataMap;
static {
- java.util.Map<_Fields, FieldMetaData> tmpMap = new java.util.EnumMap<_Fields, FieldMetaData>(_Fields.class);
- tmpMap.put(_Fields.SUCCESS, new FieldMetaData("success", TFieldRequirementType.DEFAULT,
- new FieldValueMetaData(TType.STRING)));
+ java.util.Map<_Fields,FieldMetaData> tmpMap = new java.util.EnumMap<_Fields,FieldMetaData>(_Fields.class);
+ tmpMap.put(_Fields.SUCCESS, new FieldMetaData("success", TFieldRequirementType.DEFAULT, new FieldValueMetaData(TType.STRING)));
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
FieldMetaData.addStructMetaDataMap(getInstanceId_result.class, metaDataMap);
}
-
- public getInstanceId_result() {
- }
-
- public getInstanceId_result(
- String success)
- {
+
+ public getInstanceId_result() {}
+
+ public getInstanceId_result(String success) {
this();
this.success = success;
}
-
+
/**
* Performs a deep copy on <i>other</i>.
*/
@@ -2356,96 +2307,96 @@ public class ClientService {
this.success = other.success;
}
}
-
+
public getInstanceId_result deepCopy() {
return new getInstanceId_result(this);
}
-
+
@Deprecated
public getInstanceId_result clone() {
return new getInstanceId_result(this);
}
-
+
public String getSuccess() {
return this.success;
}
-
+
public getInstanceId_result setSuccess(String success) {
this.success = success;
return this;
}
-
+
public void unsetSuccess() {
this.success = null;
}
-
+
/** Returns true if field success is set (has been asigned a value) and false otherwise */
public boolean isSetSuccess() {
return this.success != null;
}
-
+
public void setSuccessIsSet(boolean value) {
if (!value) {
this.success = null;
}
}
-
+
public void setFieldValue(_Fields field, Object value) {
switch (field) {
- case SUCCESS:
- if (value == null) {
- unsetSuccess();
- } else {
- setSuccess((String)value);
- }
- break;
-
+ case SUCCESS:
+ if (value == null) {
+ unsetSuccess();
+ } else {
+ setSuccess((String) value);
+ }
+ break;
+
}
}
-
+
public void setFieldValue(int fieldID, Object value) {
setFieldValue(_Fields.findByThriftIdOrThrow(fieldID), value);
}
-
+
public Object getFieldValue(_Fields field) {
switch (field) {
- case SUCCESS:
- return getSuccess();
-
+ case SUCCESS:
+ return getSuccess();
+
}
throw new IllegalStateException();
}
-
+
public Object getFieldValue(int fieldId) {
return getFieldValue(_Fields.findByThriftIdOrThrow(fieldId));
}
-
+
/** Returns true if field corresponding to fieldID is set (has been asigned a value) and false otherwise */
public boolean isSet(_Fields field) {
switch (field) {
- case SUCCESS:
- return isSetSuccess();
+ case SUCCESS:
+ return isSetSuccess();
}
throw new IllegalStateException();
}
-
+
public boolean isSet(int fieldID) {
return isSet(_Fields.findByThriftIdOrThrow(fieldID));
}
-
+
@Override
public boolean equals(Object that) {
if (that == null)
return false;
if (that instanceof getInstanceId_result)
- return this.equals((getInstanceId_result)that);
+ return this.equals((getInstanceId_result) that);
return false;
}
-
+
public boolean equals(getInstanceId_result that) {
if (that == null)
return false;
-
+
boolean this_present_success = true && this.isSetSuccess();
boolean that_present_success = true && that.isSetSuccess();
if (this_present_success || that_present_success) {
@@ -2454,49 +2405,49 @@ public class ClientService {
if (!this.success.equals(that.success))
return false;
}
-
+
return true;
}
-
+
@Override
public int hashCode() {
return 0;
}
-
+
public int compareTo(getInstanceId_result other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
-
+
int lastComparison = 0;
- getInstanceId_result typedOther = (getInstanceId_result)other;
-
+ getInstanceId_result typedOther = (getInstanceId_result) other;
+
lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess());
if (lastComparison != 0) {
return lastComparison;
}
- if (isSetSuccess()) { lastComparison = TBaseHelper.compareTo(this.success, typedOther.success);
+ if (isSetSuccess()) {
+ lastComparison = TBaseHelper.compareTo(this.success, typedOther.success);
if (lastComparison != 0) {
return lastComparison;
}
}
return 0;
}
-
+
public void read(TProtocol iprot) throws TException {
TField field;
iprot.readStructBegin();
- while (true)
- {
+ while (true) {
field = iprot.readFieldBegin();
- if (field.type == TType.STOP) {
+ if (field.type == TType.STOP) {
break;
}
switch (field.id) {
case 0: // SUCCESS
if (field.type == TType.STRING) {
this.success = iprot.readString();
- } else {
+ } else {
TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -2506,14 +2457,14 @@ public class ClientService {
iprot.readFieldEnd();
}
iprot.readStructEnd();
-
+
// check for required fields of primitive type, which can't be checked in the validate method
validate();
}
-
+
public void write(TProtocol oprot) throws TException {
oprot.writeStructBegin(STRUCT_DESC);
-
+
if (this.isSetSuccess()) {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
oprot.writeString(this.success);
@@ -2522,7 +2473,7 @@ public class ClientService {
oprot.writeFieldStop();
oprot.writeStructEnd();
}
-
+
@Override
public String toString() {
StringBuilder sb = new StringBuilder("getInstanceId_result(");
@@ -2535,165 +2486,161 @@ public class ClientService {
sb.append(")");
return sb.toString();
}
-
+
public void validate() throws TException {
// check for required fields
}
-
+
}
-
+
@SuppressWarnings("serial")
- public static class getZooKeepers_args implements TBase<getZooKeepers_args, getZooKeepers_args._Fields>, java.io.Serializable, Cloneable {
[... 17431 lines stripped ...]