Return-Path: X-Original-To: apmail-incubator-accumulo-commits-archive@minotaur.apache.org Delivered-To: apmail-incubator-accumulo-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 729E29619 for ; Thu, 27 Oct 2011 15:26:48 +0000 (UTC) Received: (qmail 64620 invoked by uid 500); 27 Oct 2011 15:26:48 -0000 Delivered-To: apmail-incubator-accumulo-commits-archive@incubator.apache.org Received: (qmail 64593 invoked by uid 500); 27 Oct 2011 15:26:48 -0000 Mailing-List: contact accumulo-commits-help@incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: accumulo-dev@incubator.apache.org Delivered-To: mailing list accumulo-commits@incubator.apache.org Received: (qmail 64586 invoked by uid 99); 27 Oct 2011 15:26:48 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 27 Oct 2011 15:26:48 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 27 Oct 2011 15:26:36 +0000 Received: from eris.apache.org (localhost [127.0.0.1]) by eris.apache.org (Postfix) with ESMTP id B3BCA23889EA; Thu, 27 Oct 2011 15:26:12 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: 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... Date: Thu, 27 Oct 2011 15:25:17 -0000 To: accumulo-commits@incubator.apache.org From: vines@apache.org X-Mailer: svnmailer-1.0.8-patched Message-Id: <20111027152612.B3BCA23889EA@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org 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 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 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 authorizations) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException; - - public java.util.List 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 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 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 authorizations) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException; + + public java.util.List 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 { 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 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 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 recv_listUsers() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException - { + + public java.util.Set 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 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 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 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 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 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 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 authorizations) throws TException - { + + public void send_changeAuthorizations(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String user, + java.util.List 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 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 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 recv_getUserAuthorizations() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException - { + + public java.util.List 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 processMap_ = new java.util.HashMap(); - - 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, java.io.Serializable, Cloneable { + public static class getRootTabletLocation_args implements TBase, 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 byName = new java.util.HashMap(); - + ; + + private static final java.util.Map byName = new java.util.HashMap(); + 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 other. */ - 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, java.io.Serializable, Cloneable { + public static class getRootTabletLocation_result implements TBase, 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 byName = new java.util.HashMap(); - + SUCCESS((short) 0, "success"); + + private static final java.util.Map byName = new java.util.HashMap(); + 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 other. */ @@ -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, java.io.Serializable, Cloneable { + public static class getInstanceId_args implements TBase, 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 byName = new java.util.HashMap(); - + ; + + private static final java.util.Map byName = new java.util.HashMap(); + 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 other. */ - 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, java.io.Serializable, Cloneable { + public static class getInstanceId_result implements TBase, 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 byName = new java.util.HashMap(); - + SUCCESS((short) 0, "success"); + + private static final java.util.Map byName = new java.util.HashMap(); + 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 other. */ @@ -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, java.io.Serializable, Cloneable { [... 17431 lines stripped ...]