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 [12/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/...
Modified: incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/master/thrift/MasterClientService.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/master/thrift/MasterClientService.java?rev=1189806&r1=1189805&r2=1189806&view=diff
==============================================================================
--- incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/master/thrift/MasterClientService.java (original)
+++ incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/master/thrift/MasterClientService.java Thu Oct 27 15:24:51 2011
@@ -5,79 +5,104 @@
*/
package org.apache.accumulo.core.master.thrift;
-
-
import org.apache.thrift.*;
import org.apache.thrift.meta_data.*;
import org.apache.thrift.protocol.*;
public class MasterClientService {
-
+
public interface Iface extends org.apache.accumulo.core.client.impl.thrift.ClientService.Iface {
-
- public void createTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName, java.util.List<byte[]> splitPoints, java.util.Map<String,String> aggs, TimeType tt) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException;
-
- public void deleteTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException;
-
- public void renameTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String oldTableName, String newTableName) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException;
-
- public void offlineTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException;
-
- public void onlineTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException;
-
- public void flushTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException;
-
- public void setTableProperty(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName, String property, String value) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException;
-
- public void removeTableProperty(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName, String property) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException;
-
- public void setMasterGoalState(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, MasterGoalState state) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
-
- public void shutdown(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, boolean stopTabletServers) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
-
- public void shutdownTabletServer(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tabletServer) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
-
- public void setSystemProperty(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String property, String value) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
-
- public void removeSystemProperty(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String property) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
-
- public MasterMonitorInfo getMasterStats(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
-
- public void reportSplitExtent(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String serverName, TabletSplit split) throws TException;
-
- public void reportTabletStatus(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String serverName, TabletLoadState status, org.apache.accumulo.core.data.thrift.TKeyExtent tablet) throws TException;
-
+
+ public void createTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName,
+ java.util.List<byte[]> splitPoints, java.util.Map<String,String> aggs, TimeType tt)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException,
+ TException;
+
+ public void deleteTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException,
+ TException;
+
+ public void renameTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String oldTableName,
+ String newTableName) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException,
+ org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException;
+
+ public void offlineTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException,
+ TException;
+
+ public void onlineTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException,
+ TException;
+
+ public void flushTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException,
+ TException;
+
+ public void setTableProperty(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName,
+ String property, String value) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException,
+ org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException;
+
+ public void removeTableProperty(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName,
+ String property) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException,
+ org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException;
+
+ public void setMasterGoalState(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, MasterGoalState state)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
+
+ public void shutdown(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, boolean stopTabletServers)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
+
+ public void shutdownTabletServer(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tabletServer)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
+
+ public void setSystemProperty(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String property, String value)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
+
+ public void removeSystemProperty(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String property)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
+
+ public MasterMonitorInfo getMasterStats(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException;
+
+ public void reportSplitExtent(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String serverName,
+ TabletSplit split) throws TException;
+
+ public void reportTabletStatus(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String serverName,
+ TabletLoadState status, org.apache.accumulo.core.data.thrift.TKeyExtent tablet) throws TException;
+
}
-
+
public static class Client extends org.apache.accumulo.core.client.impl.thrift.ClientService.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) {
super(iprot, oprot);
}
-
- public void createTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName, java.util.List<byte[]> splitPoints, java.util.Map<String,String> aggs, TimeType tt) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException
- {
+
+ public void createTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName,
+ java.util.List<byte[]> splitPoints, java.util.Map<String,String> aggs, TimeType tt)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException,
+ TException {
send_createTable(tinfo, credentials, tableName, splitPoints, aggs, tt);
recv_createTable();
}
-
- public void send_createTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName, java.util.List<byte[]> splitPoints, java.util.Map<String,String> aggs, TimeType tt) throws TException
- {
+
+ public void send_createTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName,
+ java.util.List<byte[]> splitPoints, java.util.Map<String,String> aggs, TimeType tt) throws TException {
oprot_.writeMessageBegin(new TMessage("createTable", TMessageType.CALL, ++seqid_));
createTable_args args = new createTable_args();
args.setTinfo(tinfo);
@@ -90,9 +115,9 @@ public class MasterClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void recv_createTable() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException
- {
+
+ public void recv_createTable() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException,
+ org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -113,15 +138,16 @@ public class MasterClientService {
}
return;
}
-
- public void deleteTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException
- {
+
+ public void deleteTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException,
+ TException {
send_deleteTable(tinfo, credentials, tableName);
recv_deleteTable();
}
-
- public void send_deleteTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName) throws TException
- {
+
+ public void send_deleteTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName)
+ throws TException {
oprot_.writeMessageBegin(new TMessage("deleteTable", TMessageType.CALL, ++seqid_));
deleteTable_args args = new deleteTable_args();
args.setTinfo(tinfo);
@@ -131,9 +157,9 @@ public class MasterClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void recv_deleteTable() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException
- {
+
+ public void recv_deleteTable() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException,
+ org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -154,15 +180,16 @@ public class MasterClientService {
}
return;
}
-
- public void renameTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String oldTableName, String newTableName) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException
- {
+
+ public void renameTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String oldTableName,
+ String newTableName) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException,
+ org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException {
send_renameTable(tinfo, credentials, oldTableName, newTableName);
recv_renameTable();
}
-
- public void send_renameTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String oldTableName, String newTableName) throws TException
- {
+
+ public void send_renameTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String oldTableName,
+ String newTableName) throws TException {
oprot_.writeMessageBegin(new TMessage("renameTable", TMessageType.CALL, ++seqid_));
renameTable_args args = new renameTable_args();
args.setTinfo(tinfo);
@@ -173,9 +200,9 @@ public class MasterClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void recv_renameTable() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException
- {
+
+ public void recv_renameTable() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException,
+ org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -196,15 +223,16 @@ public class MasterClientService {
}
return;
}
-
- public void offlineTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException
- {
+
+ public void offlineTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException,
+ TException {
send_offlineTable(tinfo, credentials, tableName);
recv_offlineTable();
}
-
- public void send_offlineTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName) throws TException
- {
+
+ public void send_offlineTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName)
+ throws TException {
oprot_.writeMessageBegin(new TMessage("offlineTable", TMessageType.CALL, ++seqid_));
offlineTable_args args = new offlineTable_args();
args.setTinfo(tinfo);
@@ -214,9 +242,9 @@ public class MasterClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void recv_offlineTable() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException
- {
+
+ public void recv_offlineTable() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException,
+ org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -237,15 +265,16 @@ public class MasterClientService {
}
return;
}
-
- public void onlineTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException
- {
+
+ public void onlineTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException,
+ TException {
send_onlineTable(tinfo, credentials, tableName);
recv_onlineTable();
}
-
- public void send_onlineTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName) throws TException
- {
+
+ public void send_onlineTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName)
+ throws TException {
oprot_.writeMessageBegin(new TMessage("onlineTable", TMessageType.CALL, ++seqid_));
onlineTable_args args = new onlineTable_args();
args.setTinfo(tinfo);
@@ -255,9 +284,9 @@ public class MasterClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void recv_onlineTable() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException
- {
+
+ public void recv_onlineTable() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException,
+ org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -278,15 +307,16 @@ public class MasterClientService {
}
return;
}
-
- public void flushTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException
- {
+
+ public void flushTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException,
+ TException {
send_flushTable(tinfo, credentials, tableName);
recv_flushTable();
}
-
- public void send_flushTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName) throws TException
- {
+
+ public void send_flushTable(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName)
+ throws TException {
oprot_.writeMessageBegin(new TMessage("flushTable", TMessageType.CALL, ++seqid_));
flushTable_args args = new flushTable_args();
args.setTinfo(tinfo);
@@ -296,9 +326,9 @@ public class MasterClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void recv_flushTable() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException
- {
+
+ public void recv_flushTable() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException,
+ org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -319,15 +349,16 @@ public class MasterClientService {
}
return;
}
-
- public void setTableProperty(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName, String property, String value) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException
- {
+
+ public void setTableProperty(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName,
+ String property, String value) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException,
+ org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException {
send_setTableProperty(tinfo, credentials, tableName, property, value);
recv_setTableProperty();
}
-
- public void send_setTableProperty(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName, String property, String value) throws TException
- {
+
+ public void send_setTableProperty(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName,
+ String property, String value) throws TException {
oprot_.writeMessageBegin(new TMessage("setTableProperty", TMessageType.CALL, ++seqid_));
setTableProperty_args args = new setTableProperty_args();
args.setTinfo(tinfo);
@@ -339,9 +370,9 @@ public class MasterClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void recv_setTableProperty() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException
- {
+
+ public void recv_setTableProperty() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException,
+ org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -362,15 +393,16 @@ public class MasterClientService {
}
return;
}
-
- public void removeTableProperty(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName, String property) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException
- {
+
+ public void removeTableProperty(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName,
+ String property) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException,
+ org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException {
send_removeTableProperty(tinfo, credentials, tableName, property);
recv_removeTableProperty();
}
-
- public void send_removeTableProperty(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName, String property) throws TException
- {
+
+ public void send_removeTableProperty(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName,
+ String property) throws TException {
oprot_.writeMessageBegin(new TMessage("removeTableProperty", TMessageType.CALL, ++seqid_));
removeTableProperty_args args = new removeTableProperty_args();
args.setTinfo(tinfo);
@@ -381,9 +413,9 @@ public class MasterClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void recv_removeTableProperty() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException
- {
+
+ public void recv_removeTableProperty() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException,
+ org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -404,15 +436,15 @@ public class MasterClientService {
}
return;
}
-
- public void setMasterGoalState(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, MasterGoalState state) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public void setMasterGoalState(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, MasterGoalState state)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
send_setMasterGoalState(tinfo, credentials, state);
recv_setMasterGoalState();
}
-
- public void send_setMasterGoalState(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, MasterGoalState state) throws TException
- {
+
+ public void send_setMasterGoalState(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, MasterGoalState state)
+ throws TException {
oprot_.writeMessageBegin(new TMessage("setMasterGoalState", TMessageType.CALL, ++seqid_));
setMasterGoalState_args args = new setMasterGoalState_args();
args.setTinfo(tinfo);
@@ -422,9 +454,8 @@ public class MasterClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void recv_setMasterGoalState() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public void recv_setMasterGoalState() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -442,15 +473,15 @@ public class MasterClientService {
}
return;
}
-
- public void shutdown(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, boolean stopTabletServers) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public void shutdown(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, boolean stopTabletServers)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
send_shutdown(tinfo, credentials, stopTabletServers);
recv_shutdown();
}
-
- public void send_shutdown(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, boolean stopTabletServers) throws TException
- {
+
+ public void send_shutdown(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, boolean stopTabletServers)
+ throws TException {
oprot_.writeMessageBegin(new TMessage("shutdown", TMessageType.CALL, ++seqid_));
shutdown_args args = new shutdown_args();
args.setTinfo(tinfo);
@@ -460,9 +491,8 @@ public class MasterClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void recv_shutdown() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public void recv_shutdown() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -480,15 +510,15 @@ public class MasterClientService {
}
return;
}
-
- public void shutdownTabletServer(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tabletServer) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public void shutdownTabletServer(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tabletServer)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
send_shutdownTabletServer(tinfo, credentials, tabletServer);
recv_shutdownTabletServer();
}
-
- public void send_shutdownTabletServer(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tabletServer) throws TException
- {
+
+ public void send_shutdownTabletServer(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tabletServer)
+ throws TException {
oprot_.writeMessageBegin(new TMessage("shutdownTabletServer", TMessageType.CALL, ++seqid_));
shutdownTabletServer_args args = new shutdownTabletServer_args();
args.setTinfo(tinfo);
@@ -498,9 +528,8 @@ public class MasterClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void recv_shutdownTabletServer() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public void recv_shutdownTabletServer() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -518,15 +547,15 @@ public class MasterClientService {
}
return;
}
-
- public void setSystemProperty(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String property, String value) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public void setSystemProperty(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String property, String value)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
send_setSystemProperty(tinfo, credentials, property, value);
recv_setSystemProperty();
}
-
- public void send_setSystemProperty(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String property, String value) throws TException
- {
+
+ public void send_setSystemProperty(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String property,
+ String value) throws TException {
oprot_.writeMessageBegin(new TMessage("setSystemProperty", TMessageType.CALL, ++seqid_));
setSystemProperty_args args = new setSystemProperty_args();
args.setTinfo(tinfo);
@@ -537,9 +566,8 @@ public class MasterClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void recv_setSystemProperty() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public void recv_setSystemProperty() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -557,15 +585,15 @@ public class MasterClientService {
}
return;
}
-
- public void removeSystemProperty(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String property) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public void removeSystemProperty(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String property)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
send_removeSystemProperty(tinfo, credentials, property);
recv_removeSystemProperty();
}
-
- public void send_removeSystemProperty(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String property) throws TException
- {
+
+ public void send_removeSystemProperty(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String property)
+ throws TException {
oprot_.writeMessageBegin(new TMessage("removeSystemProperty", TMessageType.CALL, ++seqid_));
removeSystemProperty_args args = new removeSystemProperty_args();
args.setTinfo(tinfo);
@@ -575,9 +603,8 @@ public class MasterClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void recv_removeSystemProperty() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public void recv_removeSystemProperty() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -595,15 +622,14 @@ public class MasterClientService {
}
return;
}
-
- public MasterMonitorInfo getMasterStats(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public MasterMonitorInfo getMasterStats(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials)
+ throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
send_getMasterStats(tinfo, credentials);
return recv_getMasterStats();
}
-
- public void send_getMasterStats(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws TException
- {
+
+ public void send_getMasterStats(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials) throws TException {
oprot_.writeMessageBegin(new TMessage("getMasterStats", TMessageType.CALL, ++seqid_));
getMasterStats_args args = new getMasterStats_args();
args.setTinfo(tinfo);
@@ -612,9 +638,8 @@ public class MasterClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public MasterMonitorInfo recv_getMasterStats() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException
- {
+
+ public MasterMonitorInfo recv_getMasterStats() throws org.apache.accumulo.core.security.thrift.ThriftSecurityException, TException {
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
TApplicationException x = TApplicationException.read(iprot_);
@@ -635,14 +660,14 @@ public class MasterClientService {
}
throw new TApplicationException(TApplicationException.MISSING_RESULT, "getMasterStats failed: unknown result");
}
-
- public void reportSplitExtent(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String serverName, TabletSplit split) throws TException
- {
+
+ public void reportSplitExtent(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String serverName,
+ TabletSplit split) throws TException {
send_reportSplitExtent(tinfo, credentials, serverName, split);
}
-
- public void send_reportSplitExtent(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String serverName, TabletSplit split) throws TException
- {
+
+ public void send_reportSplitExtent(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String serverName,
+ TabletSplit split) throws TException {
oprot_.writeMessageBegin(new TMessage("reportSplitExtent", TMessageType.CALL, ++seqid_));
reportSplitExtent_args args = new reportSplitExtent_args();
args.setTinfo(tinfo);
@@ -653,14 +678,14 @@ public class MasterClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
- public void reportTabletStatus(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String serverName, TabletLoadState status, org.apache.accumulo.core.data.thrift.TKeyExtent tablet) throws TException
- {
+
+ public void reportTabletStatus(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String serverName,
+ TabletLoadState status, org.apache.accumulo.core.data.thrift.TKeyExtent tablet) throws TException {
send_reportTabletStatus(tinfo, credentials, serverName, status, tablet);
}
-
- public void send_reportTabletStatus(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String serverName, TabletLoadState status, org.apache.accumulo.core.data.thrift.TKeyExtent tablet) throws TException
- {
+
+ public void send_reportTabletStatus(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String serverName,
+ TabletLoadState status, org.apache.accumulo.core.data.thrift.TKeyExtent tablet) throws TException {
oprot_.writeMessageBegin(new TMessage("reportTabletStatus", TMessageType.CALL, ++seqid_));
reportTabletStatus_args args = new reportTabletStatus_args();
args.setTinfo(tinfo);
@@ -672,12 +697,13 @@ public class MasterClientService {
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
-
+
}
+
public static class Processor extends org.apache.accumulo.core.client.impl.thrift.ClientService.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) {
super(iface);
iface_ = iface;
processMap_.put("createTable", new createTable());
@@ -697,17 +723,16 @@ public class MasterClientService {
processMap_.put("reportSplitExtent", new reportSplitExtent());
processMap_.put("reportTabletStatus", new reportTabletStatus());
}
-
+
private Iface iface_;
-
- 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();
@@ -717,10 +742,9 @@ public class MasterClientService {
fn.process(msg.seqid, iprot, oprot);
return true;
}
-
+
private class createTable implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
createTable_args args = new createTable_args();
try {
args.read(iprot);
@@ -755,12 +779,11 @@ public class MasterClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class deleteTable implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
deleteTable_args args = new deleteTable_args();
try {
args.read(iprot);
@@ -795,12 +818,11 @@ public class MasterClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class renameTable implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
renameTable_args args = new renameTable_args();
try {
args.read(iprot);
@@ -835,12 +857,11 @@ public class MasterClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class offlineTable implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
offlineTable_args args = new offlineTable_args();
try {
args.read(iprot);
@@ -875,12 +896,11 @@ public class MasterClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class onlineTable implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
onlineTable_args args = new onlineTable_args();
try {
args.read(iprot);
@@ -915,12 +935,11 @@ public class MasterClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class flushTable implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
flushTable_args args = new flushTable_args();
try {
args.read(iprot);
@@ -955,12 +974,11 @@ public class MasterClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class setTableProperty implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
setTableProperty_args args = new setTableProperty_args();
try {
args.read(iprot);
@@ -995,12 +1013,11 @@ public class MasterClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class removeTableProperty implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
removeTableProperty_args args = new removeTableProperty_args();
try {
args.read(iprot);
@@ -1035,12 +1052,11 @@ public class MasterClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class setMasterGoalState implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
setMasterGoalState_args args = new setMasterGoalState_args();
try {
args.read(iprot);
@@ -1073,12 +1089,11 @@ public class MasterClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class shutdown implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
shutdown_args args = new shutdown_args();
try {
args.read(iprot);
@@ -1111,12 +1126,11 @@ public class MasterClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class shutdownTabletServer implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
shutdownTabletServer_args args = new shutdownTabletServer_args();
try {
args.read(iprot);
@@ -1149,12 +1163,11 @@ public class MasterClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class setSystemProperty implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
setSystemProperty_args args = new setSystemProperty_args();
try {
args.read(iprot);
@@ -1187,12 +1200,11 @@ public class MasterClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class removeSystemProperty implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
removeSystemProperty_args args = new removeSystemProperty_args();
try {
args.read(iprot);
@@ -1225,12 +1237,11 @@ public class MasterClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class getMasterStats implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
getMasterStats_args args = new getMasterStats_args();
try {
args.read(iprot);
@@ -1263,12 +1274,11 @@ public class MasterClientService {
oprot.writeMessageEnd();
oprot.getTransport().flush();
}
-
+
}
-
+
private class reportSplitExtent implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
reportSplitExtent_args args = new reportSplitExtent_args();
try {
args.read(iprot);
@@ -1286,10 +1296,9 @@ public class MasterClientService {
return;
}
}
-
+
private class reportTabletStatus implements ProcessFunction {
- public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
- {
+ public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException {
reportTabletStatus_args args = new reportTabletStatus_args();
try {
args.read(iprot);
@@ -1307,20 +1316,20 @@ public class MasterClientService {
return;
}
}
-
+
}
-
+
@SuppressWarnings("serial")
- public static class createTable_args implements TBase<createTable_args, createTable_args._Fields>, java.io.Serializable, Cloneable {
+ public static class createTable_args implements TBase<createTable_args,createTable_args._Fields>, java.io.Serializable, Cloneable {
private static final TStruct STRUCT_DESC = new TStruct("createTable_args");
-
- private static final TField TINFO_FIELD_DESC = new TField("tinfo", TType.STRUCT, (short)6);
- private static final TField CREDENTIALS_FIELD_DESC = new TField("credentials", TType.STRUCT, (short)1);
- private static final TField TABLE_NAME_FIELD_DESC = new TField("tableName", TType.STRING, (short)2);
- private static final TField SPLIT_POINTS_FIELD_DESC = new TField("splitPoints", TType.LIST, (short)3);
- private static final TField AGGS_FIELD_DESC = new TField("aggs", TType.MAP, (short)4);
- private static final TField TT_FIELD_DESC = new TField("tt", TType.I32, (short)5);
-
+
+ private static final TField TINFO_FIELD_DESC = new TField("tinfo", TType.STRUCT, (short) 6);
+ private static final TField CREDENTIALS_FIELD_DESC = new TField("credentials", TType.STRUCT, (short) 1);
+ private static final TField TABLE_NAME_FIELD_DESC = new TField("tableName", TType.STRING, (short) 2);
+ private static final TField SPLIT_POINTS_FIELD_DESC = new TField("splitPoints", TType.LIST, (short) 3);
+ private static final TField AGGS_FIELD_DESC = new TField("aggs", TType.MAP, (short) 4);
+ private static final TField TT_FIELD_DESC = new TField("tt", TType.I32, (short) 5);
+
public cloudtrace.thrift.TInfo tinfo;
public org.apache.accumulo.core.security.thrift.AuthInfo credentials;
public String tableName;
@@ -1331,33 +1340,30 @@ public class MasterClientService {
* @see TimeType
*/
public TimeType tt;
-
+
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements TFieldIdEnum {
- TINFO((short)6, "tinfo"),
- CREDENTIALS((short)1, "credentials"),
- TABLE_NAME((short)2, "tableName"),
- SPLIT_POINTS((short)3, "splitPoints"),
- AGGS((short)4, "aggs"),
+ TINFO((short) 6, "tinfo"), CREDENTIALS((short) 1, "credentials"), TABLE_NAME((short) 2, "tableName"), SPLIT_POINTS((short) 3, "splitPoints"), AGGS(
+ (short) 4, "aggs"),
/**
*
* @see TimeType
*/
- TT((short)5, "tt");
-
- private static final java.util.Map<String, _Fields> byName = new java.util.HashMap<String, _Fields>();
-
+ TT((short) 5, "tt");
+
+ 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 6: // TINFO
return TINFO;
case 1: // CREDENTIALS
@@ -1374,76 +1380,63 @@ public class MasterClientService {
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.TINFO, new FieldMetaData("tinfo", TFieldRequirementType.DEFAULT,
- new StructMetaData(TType.STRUCT, cloudtrace.thrift.TInfo.class)));
- tmpMap.put(_Fields.CREDENTIALS, new FieldMetaData("credentials", TFieldRequirementType.DEFAULT,
- new StructMetaData(TType.STRUCT, org.apache.accumulo.core.security.thrift.AuthInfo.class)));
- tmpMap.put(_Fields.TABLE_NAME, new FieldMetaData("tableName", TFieldRequirementType.DEFAULT,
- new FieldValueMetaData(TType.STRING)));
- tmpMap.put(_Fields.SPLIT_POINTS, new FieldMetaData("splitPoints", TFieldRequirementType.DEFAULT,
- new ListMetaData(TType.LIST,
- new FieldValueMetaData(TType.STRING))));
- tmpMap.put(_Fields.AGGS, new FieldMetaData("aggs", TFieldRequirementType.DEFAULT,
- new MapMetaData(TType.MAP,
- new FieldValueMetaData(TType.STRING),
- new FieldValueMetaData(TType.STRING))));
- tmpMap.put(_Fields.TT, new FieldMetaData("tt", TFieldRequirementType.DEFAULT,
- new EnumMetaData(TType.ENUM, TimeType.class)));
+ java.util.Map<_Fields,FieldMetaData> tmpMap = new java.util.EnumMap<_Fields,FieldMetaData>(_Fields.class);
+ tmpMap.put(_Fields.TINFO, new FieldMetaData("tinfo", TFieldRequirementType.DEFAULT, new StructMetaData(TType.STRUCT, cloudtrace.thrift.TInfo.class)));
+ tmpMap.put(_Fields.CREDENTIALS, new FieldMetaData("credentials", TFieldRequirementType.DEFAULT, new StructMetaData(TType.STRUCT,
+ org.apache.accumulo.core.security.thrift.AuthInfo.class)));
+ tmpMap.put(_Fields.TABLE_NAME, new FieldMetaData("tableName", TFieldRequirementType.DEFAULT, new FieldValueMetaData(TType.STRING)));
+ tmpMap.put(_Fields.SPLIT_POINTS, new FieldMetaData("splitPoints", TFieldRequirementType.DEFAULT, new ListMetaData(TType.LIST, new FieldValueMetaData(
+ TType.STRING))));
+ tmpMap.put(_Fields.AGGS, new FieldMetaData("aggs", TFieldRequirementType.DEFAULT, new MapMetaData(TType.MAP, new FieldValueMetaData(TType.STRING),
+ new FieldValueMetaData(TType.STRING))));
+ tmpMap.put(_Fields.TT, new FieldMetaData("tt", TFieldRequirementType.DEFAULT, new EnumMetaData(TType.ENUM, TimeType.class)));
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
FieldMetaData.addStructMetaDataMap(createTable_args.class, metaDataMap);
}
-
- public createTable_args() {
- }
-
- public createTable_args(
- cloudtrace.thrift.TInfo tinfo,
- org.apache.accumulo.core.security.thrift.AuthInfo credentials,
- String tableName,
- java.util.List<byte[]> splitPoints,
- java.util.Map<String,String> aggs,
- TimeType tt)
- {
+
+ public createTable_args() {}
+
+ public createTable_args(cloudtrace.thrift.TInfo tinfo, org.apache.accumulo.core.security.thrift.AuthInfo credentials, String tableName,
+ java.util.List<byte[]> splitPoints, java.util.Map<String,String> aggs, TimeType tt) {
this();
this.tinfo = tinfo;
this.credentials = credentials;
@@ -1452,7 +1445,7 @@ public class MasterClientService {
this.aggs = aggs;
this.tt = tt;
}
-
+
/**
* Performs a deep copy on <i>other</i>.
*/
@@ -1477,15 +1470,15 @@ public class MasterClientService {
}
if (other.isSetAggs()) {
java.util.Map<String,String> __this__aggs = new java.util.HashMap<String,String>();
- for (java.util.Map.Entry<String, String> other_element : other.aggs.entrySet()) {
-
+ for (java.util.Map.Entry<String,String> other_element : other.aggs.entrySet()) {
+
String other_element_key = other_element.getKey();
String other_element_value = other_element.getValue();
-
+
String __this__aggs_copy_key = other_element_key;
-
+
String __this__aggs_copy_value = other_element_value;
-
+
__this__aggs.put(__this__aggs_copy_key, __this__aggs_copy_value);
}
this.aggs = __this__aggs;
@@ -1494,162 +1487,162 @@ public class MasterClientService {
this.tt = other.tt;
}
}
-
+
public createTable_args deepCopy() {
return new createTable_args(this);
}
-
+
@Deprecated
public createTable_args clone() {
return new createTable_args(this);
}
-
+
public cloudtrace.thrift.TInfo getTinfo() {
return this.tinfo;
}
-
+
public createTable_args setTinfo(cloudtrace.thrift.TInfo tinfo) {
this.tinfo = tinfo;
return this;
}
-
+
public void unsetTinfo() {
this.tinfo = null;
}
-
+
/** Returns true if field tinfo is set (has been asigned a value) and false otherwise */
public boolean isSetTinfo() {
return this.tinfo != null;
}
-
+
public void setTinfoIsSet(boolean value) {
if (!value) {
this.tinfo = null;
}
}
-
+
public org.apache.accumulo.core.security.thrift.AuthInfo getCredentials() {
return this.credentials;
}
-
+
public createTable_args setCredentials(org.apache.accumulo.core.security.thrift.AuthInfo credentials) {
this.credentials = credentials;
return this;
}
-
+
public void unsetCredentials() {
this.credentials = null;
}
-
+
/** Returns true if field credentials is set (has been asigned a value) and false otherwise */
public boolean isSetCredentials() {
return this.credentials != null;
}
-
+
public void setCredentialsIsSet(boolean value) {
if (!value) {
this.credentials = null;
}
}
-
+
public String getTableName() {
return this.tableName;
}
-
+
public createTable_args setTableName(String tableName) {
this.tableName = tableName;
return this;
}
-
+
public void unsetTableName() {
this.tableName = null;
}
-
+
/** Returns true if field tableName is set (has been asigned a value) and false otherwise */
public boolean isSetTableName() {
return this.tableName != null;
}
-
+
public void setTableNameIsSet(boolean value) {
if (!value) {
this.tableName = null;
}
}
-
+
public int getSplitPointsSize() {
return (this.splitPoints == null) ? 0 : this.splitPoints.size();
}
-
+
public java.util.Iterator<byte[]> getSplitPointsIterator() {
return (this.splitPoints == null) ? null : this.splitPoints.iterator();
}
-
+
public void addToSplitPoints(byte[] elem) {
if (this.splitPoints == null) {
this.splitPoints = new java.util.ArrayList<byte[]>();
}
this.splitPoints.add(elem);
}
-
+
public java.util.List<byte[]> getSplitPoints() {
return this.splitPoints;
}
-
+
public createTable_args setSplitPoints(java.util.List<byte[]> splitPoints) {
this.splitPoints = splitPoints;
return this;
}
-
+
public void unsetSplitPoints() {
this.splitPoints = null;
}
-
+
/** Returns true if field splitPoints is set (has been asigned a value) and false otherwise */
public boolean isSetSplitPoints() {
return this.splitPoints != null;
}
-
+
public void setSplitPointsIsSet(boolean value) {
if (!value) {
this.splitPoints = null;
}
}
-
+
public int getAggsSize() {
return (this.aggs == null) ? 0 : this.aggs.size();
}
-
+
public void putToAggs(String key, String val) {
if (this.aggs == null) {
this.aggs = new java.util.HashMap<String,String>();
}
this.aggs.put(key, val);
}
-
+
public java.util.Map<String,String> getAggs() {
return this.aggs;
}
-
+
public createTable_args setAggs(java.util.Map<String,String> aggs) {
this.aggs = aggs;
return this;
}
-
+
public void unsetAggs() {
this.aggs = null;
}
-
+
/** Returns true if field aggs is set (has been asigned a value) and false otherwise */
public boolean isSetAggs() {
return this.aggs != null;
}
-
+
public void setAggsIsSet(boolean value) {
if (!value) {
this.aggs = null;
}
}
-
+
/**
*
* @see TimeType
@@ -1657,7 +1650,7 @@ public class MasterClientService {
public TimeType getTt() {
return this.tt;
}
-
+
/**
*
* @see TimeType
@@ -1666,144 +1659,144 @@ public class MasterClientService {
this.tt = tt;
return this;
}
-
+
public void unsetTt() {
this.tt = null;
}
-
+
/** Returns true if field tt is set (has been asigned a value) and false otherwise */
public boolean isSetTt() {
return this.tt != null;
}
-
+
public void setTtIsSet(boolean value) {
if (!value) {
this.tt = null;
}
}
-
+
@SuppressWarnings("unchecked")
public void setFieldValue(_Fields field, Object value) {
switch (field) {
- case TINFO:
- if (value == null) {
- unsetTinfo();
- } else {
- setTinfo((cloudtrace.thrift.TInfo)value);
- }
- break;
-
- case CREDENTIALS:
- if (value == null) {
- unsetCredentials();
- } else {
- setCredentials((org.apache.accumulo.core.security.thrift.AuthInfo)value);
- }
- break;
-
- case TABLE_NAME:
- if (value == null) {
- unsetTableName();
- } else {
- setTableName((String)value);
- }
- break;
-
- case SPLIT_POINTS:
- if (value == null) {
- unsetSplitPoints();
- } else {
- setSplitPoints((java.util.List<byte[]>)value);
- }
- break;
-
- case AGGS:
- if (value == null) {
- unsetAggs();
- } else {
- setAggs((java.util.Map<String,String>)value);
- }
- break;
-
- case TT:
- if (value == null) {
- unsetTt();
- } else {
- setTt((TimeType)value);
- }
- break;
-
+ case TINFO:
+ if (value == null) {
+ unsetTinfo();
+ } else {
+ setTinfo((cloudtrace.thrift.TInfo) value);
+ }
+ break;
+
+ case CREDENTIALS:
+ if (value == null) {
+ unsetCredentials();
+ } else {
+ setCredentials((org.apache.accumulo.core.security.thrift.AuthInfo) value);
+ }
+ break;
+
+ case TABLE_NAME:
+ if (value == null) {
+ unsetTableName();
+ } else {
+ setTableName((String) value);
+ }
+ break;
+
+ case SPLIT_POINTS:
+ if (value == null) {
+ unsetSplitPoints();
+ } else {
+ setSplitPoints((java.util.List<byte[]>) value);
+ }
+ break;
+
+ case AGGS:
+ if (value == null) {
+ unsetAggs();
+ } else {
+ setAggs((java.util.Map<String,String>) value);
+ }
+ break;
+
+ case TT:
+ if (value == null) {
+ unsetTt();
+ } else {
+ setTt((TimeType) value);
+ }
+ break;
+
}
}
-
+
public void setFieldValue(int fieldID, Object value) {
setFieldValue(_Fields.findByThriftIdOrThrow(fieldID), value);
}
-
+
public Object getFieldValue(_Fields field) {
switch (field) {
- case TINFO:
- return getTinfo();
-
- case CREDENTIALS:
- return getCredentials();
-
- case TABLE_NAME:
- return getTableName();
-
- case SPLIT_POINTS:
- return getSplitPoints();
-
- case AGGS:
- return getAggs();
-
- case TT:
- return getTt();
-
+ case TINFO:
+ return getTinfo();
+
+ case CREDENTIALS:
+ return getCredentials();
+
+ case TABLE_NAME:
+ return getTableName();
+
+ case SPLIT_POINTS:
+ return getSplitPoints();
+
+ case AGGS:
+ return getAggs();
+
+ case TT:
+ return getTt();
+
}
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 TINFO:
- return isSetTinfo();
- case CREDENTIALS:
- return isSetCredentials();
- case TABLE_NAME:
- return isSetTableName();
- case SPLIT_POINTS:
- return isSetSplitPoints();
- case AGGS:
- return isSetAggs();
- case TT:
- return isSetTt();
+ case TINFO:
+ return isSetTinfo();
+ case CREDENTIALS:
+ return isSetCredentials();
+ case TABLE_NAME:
+ return isSetTableName();
+ case SPLIT_POINTS:
+ return isSetSplitPoints();
+ case AGGS:
+ return isSetAggs();
+ case TT:
+ return isSetTt();
}
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 createTable_args)
- return this.equals((createTable_args)that);
+ return this.equals((createTable_args) that);
return false;
}
-
+
public boolean equals(createTable_args that) {
if (that == null)
return false;
-
+
boolean this_present_tinfo = true && this.isSetTinfo();
boolean that_present_tinfo = true && that.isSetTinfo();
if (this_present_tinfo || that_present_tinfo) {
@@ -1812,7 +1805,7 @@ public class MasterClientService {
if (!this.tinfo.equals(that.tinfo))
return false;
}
-
+
boolean this_present_credentials = true && this.isSetCredentials();
boolean that_present_credentials = true && that.isSetCredentials();
if (this_present_credentials || that_present_credentials) {
@@ -1821,7 +1814,7 @@ public class MasterClientService {
if (!this.credentials.equals(that.credentials))
return false;
}
-
+
boolean this_present_tableName = true && this.isSetTableName();
boolean that_present_tableName = true && that.isSetTableName();
if (this_present_tableName || that_present_tableName) {
@@ -1830,7 +1823,7 @@ public class MasterClientService {
if (!this.tableName.equals(that.tableName))
return false;
}
-
+
boolean this_present_splitPoints = true && this.isSetSplitPoints();
boolean that_present_splitPoints = true && that.isSetSplitPoints();
if (this_present_splitPoints || that_present_splitPoints) {
@@ -1839,7 +1832,7 @@ public class MasterClientService {
if (!this.splitPoints.equals(that.splitPoints))
return false;
}
-
+
boolean this_present_aggs = true && this.isSetAggs();
boolean that_present_aggs = true && that.isSetAggs();
if (this_present_aggs || that_present_aggs) {
@@ -1848,7 +1841,7 @@ public class MasterClientService {
if (!this.aggs.equals(that.aggs))
return false;
}
-
+
boolean this_present_tt = true && this.isSetTt();
boolean that_present_tt = true && that.isSetTt();
if (this_present_tt || that_present_tt) {
@@ -1857,28 +1850,29 @@ public class MasterClientService {
if (!this.tt.equals(that.tt))
return false;
}
-
+
return true;
}
-
+
@Override
public int hashCode() {
return 0;
}
-
+
public int compareTo(createTable_args other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
-
+
int lastComparison = 0;
- createTable_args typedOther = (createTable_args)other;
-
+ createTable_args typedOther = (createTable_args) other;
+
lastComparison = Boolean.valueOf(isSetTinfo()).compareTo(typedOther.isSetTinfo());
if (lastComparison != 0) {
return lastComparison;
}
- if (isSetTinfo()) { lastComparison = TBaseHelper.compareTo(this.tinfo, typedOther.tinfo);
+ if (isSetTinfo()) {
+ lastComparison = TBaseHelper.compareTo(this.tinfo, typedOther.tinfo);
if (lastComparison != 0) {
return lastComparison;
}
@@ -1887,7 +1881,8 @@ public class MasterClientService {
if (lastComparison != 0) {
return lastComparison;
}
- if (isSetCredentials()) { lastComparison = TBaseHelper.compareTo(this.credentials, typedOther.credentials);
+ if (isSetCredentials()) {
+ lastComparison = TBaseHelper.compareTo(this.credentials, typedOther.credentials);
if (lastComparison != 0) {
return lastComparison;
}
@@ -1896,7 +1891,8 @@ public class MasterClientService {
if (lastComparison != 0) {
return lastComparison;
}
- if (isSetTableName()) { lastComparison = TBaseHelper.compareTo(this.tableName, typedOther.tableName);
+ if (isSetTableName()) {
+ lastComparison = TBaseHelper.compareTo(this.tableName, typedOther.tableName);
if (lastComparison != 0) {
return lastComparison;
}
@@ -1905,7 +1901,8 @@ public class MasterClientService {
if (lastComparison != 0) {
return lastComparison;
}
- if (isSetSplitPoints()) { lastComparison = TBaseHelper.compareTo(this.splitPoints, typedOther.splitPoints);
+ if (isSetSplitPoints()) {
+ lastComparison = TBaseHelper.compareTo(this.splitPoints, typedOther.splitPoints);
if (lastComparison != 0) {
return lastComparison;
}
@@ -1914,7 +1911,8 @@ public class MasterClientService {
if (lastComparison != 0) {
return lastComparison;
}
- if (isSetAggs()) { lastComparison = TBaseHelper.compareTo(this.aggs, typedOther.aggs);
+ if (isSetAggs()) {
+ lastComparison = TBaseHelper.compareTo(this.aggs, typedOther.aggs);
if (lastComparison != 0) {
return lastComparison;
}
@@ -1923,21 +1921,21 @@ public class MasterClientService {
if (lastComparison != 0) {
return lastComparison;
}
- if (isSetTt()) { lastComparison = TBaseHelper.compareTo(this.tt, typedOther.tt);
+ if (isSetTt()) {
+ lastComparison = TBaseHelper.compareTo(this.tt, typedOther.tt);
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) {
@@ -1945,7 +1943,7 @@ public class MasterClientService {
if (field.type == TType.STRUCT) {
this.tinfo = new cloudtrace.thrift.TInfo();
this.tinfo.read(iprot);
- } else {
+ } else {
TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -1953,14 +1951,14 @@ public class MasterClientService {
if (field.type == TType.STRUCT) {
this.credentials = new org.apache.accumulo.core.security.thrift.AuthInfo();
this.credentials.read(iprot);
- } else {
+ } else {
TProtocolUtil.skip(iprot, field.type);
}
break;
case 2: // TABLE_NAME
if (field.type == TType.STRING) {
this.tableName = iprot.readString();
- } else {
+ } else {
TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -1969,15 +1967,14 @@ public class MasterClientService {
{
TList _list39 = iprot.readListBegin();
this.splitPoints = new java.util.ArrayList<byte[]>(_list39.size);
- for (int _i40 = 0; _i40 < _list39.size; ++_i40)
- {
+ for (int _i40 = 0; _i40 < _list39.size; ++_i40) {
byte[] _elem41;
_elem41 = iprot.readBinary();
this.splitPoints.add(_elem41);
}
iprot.readListEnd();
}
- } else {
+ } else {
TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -1985,9 +1982,8 @@ public class MasterClientService {
if (field.type == TType.MAP) {
{
TMap _map42 = iprot.readMapBegin();
- this.aggs = new java.util.HashMap<String,String>(2*_map42.size);
- for (int _i43 = 0; _i43 < _map42.size; ++_i43)
- {
+ this.aggs = new java.util.HashMap<String,String>(2 * _map42.size);
+ for (int _i43 = 0; _i43 < _map42.size; ++_i43) {
String _key44;
String _val45;
_key44 = iprot.readString();
@@ -1996,14 +1992,14 @@ public class MasterClientService {
}
iprot.readMapEnd();
}
- } else {
+ } else {
TProtocolUtil.skip(iprot, field.type);
}
break;
case 5: // TT
if (field.type == TType.I32) {
this.tt = TimeType.findByValue(iprot.readI32());
- } else {
+ } else {
TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -2013,14 +2009,14 @@ public class MasterClientService {
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);
if (this.credentials != null) {
oprot.writeFieldBegin(CREDENTIALS_FIELD_DESC);
@@ -2036,8 +2032,7 @@ public class MasterClientService {
oprot.writeFieldBegin(SPLIT_POINTS_FIELD_DESC);
{
oprot.writeListBegin(new TList(TType.STRING, this.splitPoints.size()));
- for (byte[] _iter46 : this.splitPoints)
- {
+ for (byte[] _iter46 : this.splitPoints) {
oprot.writeBinary(_iter46);
}
oprot.writeListEnd();
@@ -2048,8 +2043,7 @@ public class MasterClientService {
oprot.writeFieldBegin(AGGS_FIELD_DESC);
{
oprot.writeMapBegin(new TMap(TType.STRING, TType.STRING, this.aggs.size()));
- for (java.util.Map.Entry<String, String> _iter47 : this.aggs.entrySet())
- {
+ for (java.util.Map.Entry<String,String> _iter47 : this.aggs.entrySet()) {
oprot.writeString(_iter47.getKey());
oprot.writeString(_iter47.getValue());
}
@@ -2070,7 +2064,7 @@ public class MasterClientService {
oprot.writeFieldStop();
oprot.writeStructEnd();
}
-
+
@Override
public String toString() {
StringBuilder sb = new StringBuilder("createTable_args(");
@@ -2118,41 +2112,40 @@ public class MasterClientService {
sb.append(")");
return sb.toString();
}
-
+
public void validate() throws TException {
// check for required fields
}
-
+
}
-
+
@SuppressWarnings("serial")
- public static class createTable_result implements TBase<createTable_result, createTable_result._Fields>, java.io.Serializable, Cloneable {
+ public static class createTable_result implements TBase<createTable_result,createTable_result._Fields>, java.io.Serializable, Cloneable {
private static final TStruct STRUCT_DESC = new TStruct("createTable_result");
-
- private static final TField SEC_FIELD_DESC = new TField("sec", TType.STRUCT, (short)1);
- private static final TField TOPE_FIELD_DESC = new TField("tope", TType.STRUCT, (short)2);
-
+
+ private static final TField SEC_FIELD_DESC = new TField("sec", TType.STRUCT, (short) 1);
+ private static final TField TOPE_FIELD_DESC = new TField("tope", TType.STRUCT, (short) 2);
+
public org.apache.accumulo.core.security.thrift.ThriftSecurityException sec;
public org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException tope;
-
+
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements TFieldIdEnum {
- SEC((short)1, "sec"),
- TOPE((short)2, "tope");
-
- private static final java.util.Map<String, _Fields> byName = new java.util.HashMap<String, _Fields>();
-
+ SEC((short) 1, "sec"), TOPE((short) 2, "tope");
+
+ 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 1: // SEC
return SEC;
case 2: // TOPE
@@ -2161,66 +2154,61 @@ public class MasterClientService {
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.SEC, new FieldMetaData("sec", TFieldRequirementType.DEFAULT,
- new FieldValueMetaData(TType.STRUCT)));
- tmpMap.put(_Fields.TOPE, new FieldMetaData("tope", TFieldRequirementType.DEFAULT,
- new FieldValueMetaData(TType.STRUCT)));
+ java.util.Map<_Fields,FieldMetaData> tmpMap = new java.util.EnumMap<_Fields,FieldMetaData>(_Fields.class);
+ tmpMap.put(_Fields.SEC, new FieldMetaData("sec", TFieldRequirementType.DEFAULT, new FieldValueMetaData(TType.STRUCT)));
+ tmpMap.put(_Fields.TOPE, new FieldMetaData("tope", TFieldRequirementType.DEFAULT, new FieldValueMetaData(TType.STRUCT)));
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
FieldMetaData.addStructMetaDataMap(createTable_result.class, metaDataMap);
}
-
- public createTable_result() {
- }
-
- public createTable_result(
- org.apache.accumulo.core.security.thrift.ThriftSecurityException sec,
- org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException tope)
- {
+
+ public createTable_result() {}
+
+ public createTable_result(org.apache.accumulo.core.security.thrift.ThriftSecurityException sec,
+ org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException tope) {
this();
this.sec = sec;
this.tope = tope;
}
-
+
/**
* Performs a deep copy on <i>other</i>.
*/
@@ -2232,133 +2220,133 @@ public class MasterClientService {
this.tope = new org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException(other.tope);
}
}
-
+
public createTable_result deepCopy() {
return new createTable_result(this);
}
-
+
@Deprecated
public createTable_result clone() {
return new createTable_result(this);
}
-
+
public org.apache.accumulo.core.security.thrift.ThriftSecurityException getSec() {
return this.sec;
}
-
+
public createTable_result setSec(org.apache.accumulo.core.security.thrift.ThriftSecurityException sec) {
this.sec = sec;
return this;
}
-
+
public void unsetSec() {
this.sec = null;
}
-
+
/** Returns true if field sec is set (has been asigned a value) and false otherwise */
public boolean isSetSec() {
return this.sec != null;
}
-
+
public void setSecIsSet(boolean value) {
if (!value) {
this.sec = null;
}
}
-
+
public org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException getTope() {
return this.tope;
}
-
+
public createTable_result setTope(org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException tope) {
this.tope = tope;
return this;
}
-
+
public void unsetTope() {
this.tope = null;
}
-
+
/** Returns true if field tope is set (has been asigned a value) and false otherwise */
public boolean isSetTope() {
return this.tope != null;
}
-
+
public void setTopeIsSet(boolean value) {
if (!value) {
this.tope = null;
}
}
-
+
public void setFieldValue(_Fields field, Object value) {
switch (field) {
- case SEC:
- if (value == null) {
- unsetSec();
- } else {
- setSec((org.apache.accumulo.core.security.thrift.ThriftSecurityException)value);
- }
- break;
-
- case TOPE:
- if (value == null) {
- unsetTope();
- } else {
- setTope((org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException)value);
- }
- break;
-
- }
+ case SEC:
+ if (value == null) {
+ unsetSec();
+ } else {
+ setSec((org.apache.accumulo.core.security.thrift.ThriftSecurityException) value);
+ }
+ break;
+
+ case TOPE:
+ if (value == null) {
+ unsetTope();
+ } else {
+ setTope((org.apache.accumulo.core.client.impl.thrift.ThriftTableOperationException) value);
+ }
+ break;
+
+ }
}
-
+
public void setFieldValue(int fieldID, Object value) {
setFieldValue(_Fields.findByThriftIdOrThrow(fieldID), value);
}
-
+
public Object getFieldValue(_Fields field) {
switch (field) {
- case SEC:
- return getSec();
-
- case TOPE:
- return getTope();
-
+ case SEC:
+ return getSec();
+
+ case TOPE:
+ return getTope();
+
}
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 SEC:
- return isSetSec();
- case TOPE:
- return isSetTope();
+ case SEC:
[... 14202 lines stripped ...]