You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by dl...@apache.org on 2016/04/12 15:58:38 UTC
[21/39] accumulo git commit: ACCUMULO-4147 Add Accumulo Namespace
Operations to Proxy
http://git-wip-us.apache.org/repos/asf/accumulo/blob/8839fe51/proxy/src/main/java/org/apache/accumulo/proxy/thrift/AccumuloProxy.java
----------------------------------------------------------------------
diff --git a/proxy/src/main/java/org/apache/accumulo/proxy/thrift/AccumuloProxy.java b/proxy/src/main/java/org/apache/accumulo/proxy/thrift/AccumuloProxy.java
index 1f4777f..150de3e 100644
--- a/proxy/src/main/java/org/apache/accumulo/proxy/thrift/AccumuloProxy.java
+++ b/proxy/src/main/java/org/apache/accumulo/proxy/thrift/AccumuloProxy.java
@@ -175,6 +175,12 @@ public class AccumuloProxy {
public void revokeTablePermission(ByteBuffer login, String user, String table, TablePermission perm) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException;
+ public void grantNamespacePermission(ByteBuffer login, String user, String namespaceName, NamespacePermission perm) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException;
+
+ public boolean hasNamespacePermission(ByteBuffer login, String user, String namespaceName, NamespacePermission perm) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException;
+
+ public void revokeNamespacePermission(ByteBuffer login, String user, String namespaceName, NamespacePermission perm) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException;
+
public String createBatchScanner(ByteBuffer login, String tableName, BatchScanOptions options) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException;
public String createScanner(ByteBuffer login, String tableName, ScanOptions options) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException;
@@ -209,6 +215,46 @@ public class AccumuloProxy {
public Key getFollowing(Key key, PartialKey part) throws org.apache.thrift.TException;
+ public String systemNamespace() throws org.apache.thrift.TException;
+
+ public String defaultNamespace() throws org.apache.thrift.TException;
+
+ public List<String> listNamespaces(ByteBuffer login) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException;
+
+ public boolean namespaceExists(ByteBuffer login, String namespaceName) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException;
+
+ public void createNamespace(ByteBuffer login, String namespaceName) throws AccumuloException, AccumuloSecurityException, NamespaceExistsException, org.apache.thrift.TException;
+
+ public void deleteNamespace(ByteBuffer login, String namespaceName) throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, NamespaceNotEmptyException, org.apache.thrift.TException;
+
+ public void renameNamespace(ByteBuffer login, String oldNamespaceName, String newNamespaceName) throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, NamespaceExistsException, org.apache.thrift.TException;
+
+ public void setNamespaceProperty(ByteBuffer login, String namespaceName, String property, String value) throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException;
+
+ public void removeNamespaceProperty(ByteBuffer login, String namespaceName, String property) throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException;
+
+ public Map<String,String> getNamespaceProperties(ByteBuffer login, String namespaceName) throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException;
+
+ public Map<String,String> namespaceIdMap(ByteBuffer login) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException;
+
+ public void attachNamespaceIterator(ByteBuffer login, String namespaceName, IteratorSetting setting, Set<IteratorScope> scopes) throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException;
+
+ public void removeNamespaceIterator(ByteBuffer login, String namespaceName, String name, Set<IteratorScope> scopes) throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException;
+
+ public IteratorSetting getNamespaceIteratorSetting(ByteBuffer login, String namespaceName, String name, IteratorScope scope) throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException;
+
+ public Map<String,Set<IteratorScope>> listNamespaceIterators(ByteBuffer login, String namespaceName) throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException;
+
+ public void checkNamespaceIteratorConflicts(ByteBuffer login, String namespaceName, IteratorSetting setting, Set<IteratorScope> scopes) throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException;
+
+ public int addNamespaceConstraint(ByteBuffer login, String namespaceName, String constraintClassName) throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException;
+
+ public void removeNamespaceConstraint(ByteBuffer login, String namespaceName, int id) throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException;
+
+ public Map<String,Integer> listNamespaceConstraints(ByteBuffer login, String namespaceName) throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException;
+
+ public boolean testNamespaceClassLoad(ByteBuffer login, String namespaceName, String className, String asTypeName) throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException;
+
}
public interface AsyncIface {
@@ -333,6 +379,12 @@ public class AccumuloProxy {
public void revokeTablePermission(ByteBuffer login, String user, String table, TablePermission perm, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void grantNamespacePermission(ByteBuffer login, String user, String namespaceName, NamespacePermission perm, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void hasNamespacePermission(ByteBuffer login, String user, String namespaceName, NamespacePermission perm, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void revokeNamespacePermission(ByteBuffer login, String user, String namespaceName, NamespacePermission perm, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
public void createBatchScanner(ByteBuffer login, String tableName, BatchScanOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void createScanner(ByteBuffer login, String tableName, ScanOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
@@ -367,6 +419,46 @@ public class AccumuloProxy {
public void getFollowing(Key key, PartialKey part, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void systemNamespace(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void defaultNamespace(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void listNamespaces(ByteBuffer login, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void namespaceExists(ByteBuffer login, String namespaceName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void createNamespace(ByteBuffer login, String namespaceName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void deleteNamespace(ByteBuffer login, String namespaceName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void renameNamespace(ByteBuffer login, String oldNamespaceName, String newNamespaceName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void setNamespaceProperty(ByteBuffer login, String namespaceName, String property, String value, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void removeNamespaceProperty(ByteBuffer login, String namespaceName, String property, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void getNamespaceProperties(ByteBuffer login, String namespaceName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void namespaceIdMap(ByteBuffer login, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void attachNamespaceIterator(ByteBuffer login, String namespaceName, IteratorSetting setting, Set<IteratorScope> scopes, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void removeNamespaceIterator(ByteBuffer login, String namespaceName, String name, Set<IteratorScope> scopes, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void getNamespaceIteratorSetting(ByteBuffer login, String namespaceName, String name, IteratorScope scope, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void listNamespaceIterators(ByteBuffer login, String namespaceName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void checkNamespaceIteratorConflicts(ByteBuffer login, String namespaceName, IteratorSetting setting, Set<IteratorScope> scopes, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void addNamespaceConstraint(ByteBuffer login, String namespaceName, String constraintClassName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void removeNamespaceConstraint(ByteBuffer login, String namespaceName, int id, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void listNamespaceConstraints(ByteBuffer login, String namespaceName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void testNamespaceClassLoad(ByteBuffer login, String namespaceName, String className, String asTypeName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
}
public static class Client extends org.apache.thrift.TServiceClient implements Iface {
@@ -2235,6 +2327,96 @@ public class AccumuloProxy {
return;
}
+ public void grantNamespacePermission(ByteBuffer login, String user, String namespaceName, NamespacePermission perm) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
+ {
+ send_grantNamespacePermission(login, user, namespaceName, perm);
+ recv_grantNamespacePermission();
+ }
+
+ public void send_grantNamespacePermission(ByteBuffer login, String user, String namespaceName, NamespacePermission perm) throws org.apache.thrift.TException
+ {
+ grantNamespacePermission_args args = new grantNamespacePermission_args();
+ args.setLogin(login);
+ args.setUser(user);
+ args.setNamespaceName(namespaceName);
+ args.setPerm(perm);
+ sendBase("grantNamespacePermission", args);
+ }
+
+ public void recv_grantNamespacePermission() throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
+ {
+ grantNamespacePermission_result result = new grantNamespacePermission_result();
+ receiveBase(result, "grantNamespacePermission");
+ if (result.ouch1 != null) {
+ throw result.ouch1;
+ }
+ if (result.ouch2 != null) {
+ throw result.ouch2;
+ }
+ return;
+ }
+
+ public boolean hasNamespacePermission(ByteBuffer login, String user, String namespaceName, NamespacePermission perm) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
+ {
+ send_hasNamespacePermission(login, user, namespaceName, perm);
+ return recv_hasNamespacePermission();
+ }
+
+ public void send_hasNamespacePermission(ByteBuffer login, String user, String namespaceName, NamespacePermission perm) throws org.apache.thrift.TException
+ {
+ hasNamespacePermission_args args = new hasNamespacePermission_args();
+ args.setLogin(login);
+ args.setUser(user);
+ args.setNamespaceName(namespaceName);
+ args.setPerm(perm);
+ sendBase("hasNamespacePermission", args);
+ }
+
+ public boolean recv_hasNamespacePermission() throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
+ {
+ hasNamespacePermission_result result = new hasNamespacePermission_result();
+ receiveBase(result, "hasNamespacePermission");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.ouch1 != null) {
+ throw result.ouch1;
+ }
+ if (result.ouch2 != null) {
+ throw result.ouch2;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "hasNamespacePermission failed: unknown result");
+ }
+
+ public void revokeNamespacePermission(ByteBuffer login, String user, String namespaceName, NamespacePermission perm) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
+ {
+ send_revokeNamespacePermission(login, user, namespaceName, perm);
+ recv_revokeNamespacePermission();
+ }
+
+ public void send_revokeNamespacePermission(ByteBuffer login, String user, String namespaceName, NamespacePermission perm) throws org.apache.thrift.TException
+ {
+ revokeNamespacePermission_args args = new revokeNamespacePermission_args();
+ args.setLogin(login);
+ args.setUser(user);
+ args.setNamespaceName(namespaceName);
+ args.setPerm(perm);
+ sendBase("revokeNamespacePermission", args);
+ }
+
+ public void recv_revokeNamespacePermission() throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
+ {
+ revokeNamespacePermission_result result = new revokeNamespacePermission_result();
+ receiveBase(result, "revokeNamespacePermission");
+ if (result.ouch1 != null) {
+ throw result.ouch1;
+ }
+ if (result.ouch2 != null) {
+ throw result.ouch2;
+ }
+ return;
+ }
+
public String createBatchScanner(ByteBuffer login, String tableName, BatchScanOptions options) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
{
send_createBatchScanner(login, tableName, options);
@@ -2719,449 +2901,743 @@ public class AccumuloProxy {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getFollowing failed: unknown result");
}
- }
- public static class AsyncClient extends org.apache.thrift.async.TAsyncClient implements AsyncIface {
- public static class Factory implements org.apache.thrift.async.TAsyncClientFactory<AsyncClient> {
- private org.apache.thrift.async.TAsyncClientManager clientManager;
- private org.apache.thrift.protocol.TProtocolFactory protocolFactory;
- public Factory(org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.protocol.TProtocolFactory protocolFactory) {
- this.clientManager = clientManager;
- this.protocolFactory = protocolFactory;
- }
- public AsyncClient getAsyncClient(org.apache.thrift.transport.TNonblockingTransport transport) {
- return new AsyncClient(protocolFactory, clientManager, transport);
- }
+ public String systemNamespace() throws org.apache.thrift.TException
+ {
+ send_systemNamespace();
+ return recv_systemNamespace();
}
- public AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport) {
- super(protocolFactory, clientManager, transport);
+ public void send_systemNamespace() throws org.apache.thrift.TException
+ {
+ systemNamespace_args args = new systemNamespace_args();
+ sendBase("systemNamespace", args);
}
- public void login(String principal, Map<String,String> loginProperties, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
- checkReady();
- login_call method_call = new login_call(principal, loginProperties, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
+ public String recv_systemNamespace() throws org.apache.thrift.TException
+ {
+ systemNamespace_result result = new systemNamespace_result();
+ receiveBase(result, "systemNamespace");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "systemNamespace failed: unknown result");
}
- public static class login_call extends org.apache.thrift.async.TAsyncMethodCall {
- private String principal;
- private Map<String,String> loginProperties;
- public login_call(String principal, Map<String,String> loginProperties, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.principal = principal;
- this.loginProperties = loginProperties;
- }
+ public String defaultNamespace() throws org.apache.thrift.TException
+ {
+ send_defaultNamespace();
+ return recv_defaultNamespace();
+ }
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("login", org.apache.thrift.protocol.TMessageType.CALL, 0));
- login_args args = new login_args();
- args.setPrincipal(principal);
- args.setLoginProperties(loginProperties);
- args.write(prot);
- prot.writeMessageEnd();
- }
+ public void send_defaultNamespace() throws org.apache.thrift.TException
+ {
+ defaultNamespace_args args = new defaultNamespace_args();
+ sendBase("defaultNamespace", args);
+ }
- public ByteBuffer getResult() throws AccumuloSecurityException, org.apache.thrift.TException {
- if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- return (new Client(prot)).recv_login();
+ public String recv_defaultNamespace() throws org.apache.thrift.TException
+ {
+ defaultNamespace_result result = new defaultNamespace_result();
+ receiveBase(result, "defaultNamespace");
+ if (result.isSetSuccess()) {
+ return result.success;
}
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "defaultNamespace failed: unknown result");
}
- public void addConstraint(ByteBuffer login, String tableName, String constraintClassName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
- checkReady();
- addConstraint_call method_call = new addConstraint_call(login, tableName, constraintClassName, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
+ public List<String> listNamespaces(ByteBuffer login) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
+ {
+ send_listNamespaces(login);
+ return recv_listNamespaces();
}
- public static class addConstraint_call extends org.apache.thrift.async.TAsyncMethodCall {
- private ByteBuffer login;
- private String tableName;
- private String constraintClassName;
- public addConstraint_call(ByteBuffer login, String tableName, String constraintClassName, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.login = login;
- this.tableName = tableName;
- this.constraintClassName = constraintClassName;
- }
+ public void send_listNamespaces(ByteBuffer login) throws org.apache.thrift.TException
+ {
+ listNamespaces_args args = new listNamespaces_args();
+ args.setLogin(login);
+ sendBase("listNamespaces", args);
+ }
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("addConstraint", org.apache.thrift.protocol.TMessageType.CALL, 0));
- addConstraint_args args = new addConstraint_args();
- args.setLogin(login);
- args.setTableName(tableName);
- args.setConstraintClassName(constraintClassName);
- args.write(prot);
- prot.writeMessageEnd();
+ public List<String> recv_listNamespaces() throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
+ {
+ listNamespaces_result result = new listNamespaces_result();
+ receiveBase(result, "listNamespaces");
+ if (result.isSetSuccess()) {
+ return result.success;
}
-
- public int getResult() throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException {
- if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- return (new Client(prot)).recv_addConstraint();
+ if (result.ouch1 != null) {
+ throw result.ouch1;
}
+ if (result.ouch2 != null) {
+ throw result.ouch2;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "listNamespaces failed: unknown result");
}
- public void addSplits(ByteBuffer login, String tableName, Set<ByteBuffer> splits, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
- checkReady();
- addSplits_call method_call = new addSplits_call(login, tableName, splits, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
+ public boolean namespaceExists(ByteBuffer login, String namespaceName) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
+ {
+ send_namespaceExists(login, namespaceName);
+ return recv_namespaceExists();
}
- public static class addSplits_call extends org.apache.thrift.async.TAsyncMethodCall {
- private ByteBuffer login;
- private String tableName;
- private Set<ByteBuffer> splits;
- public addSplits_call(ByteBuffer login, String tableName, Set<ByteBuffer> splits, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.login = login;
- this.tableName = tableName;
- this.splits = splits;
- }
+ public void send_namespaceExists(ByteBuffer login, String namespaceName) throws org.apache.thrift.TException
+ {
+ namespaceExists_args args = new namespaceExists_args();
+ args.setLogin(login);
+ args.setNamespaceName(namespaceName);
+ sendBase("namespaceExists", args);
+ }
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("addSplits", org.apache.thrift.protocol.TMessageType.CALL, 0));
- addSplits_args args = new addSplits_args();
- args.setLogin(login);
- args.setTableName(tableName);
- args.setSplits(splits);
- args.write(prot);
- prot.writeMessageEnd();
+ public boolean recv_namespaceExists() throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
+ {
+ namespaceExists_result result = new namespaceExists_result();
+ receiveBase(result, "namespaceExists");
+ if (result.isSetSuccess()) {
+ return result.success;
}
-
- public void getResult() throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException {
- if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_addSplits();
+ if (result.ouch1 != null) {
+ throw result.ouch1;
+ }
+ if (result.ouch2 != null) {
+ throw result.ouch2;
}
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "namespaceExists failed: unknown result");
}
- public void attachIterator(ByteBuffer login, String tableName, IteratorSetting setting, Set<IteratorScope> scopes, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
- checkReady();
- attachIterator_call method_call = new attachIterator_call(login, tableName, setting, scopes, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
+ public void createNamespace(ByteBuffer login, String namespaceName) throws AccumuloException, AccumuloSecurityException, NamespaceExistsException, org.apache.thrift.TException
+ {
+ send_createNamespace(login, namespaceName);
+ recv_createNamespace();
}
- public static class attachIterator_call extends org.apache.thrift.async.TAsyncMethodCall {
- private ByteBuffer login;
- private String tableName;
- private IteratorSetting setting;
- private Set<IteratorScope> scopes;
- public attachIterator_call(ByteBuffer login, String tableName, IteratorSetting setting, Set<IteratorScope> scopes, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.login = login;
- this.tableName = tableName;
- this.setting = setting;
- this.scopes = scopes;
- }
+ public void send_createNamespace(ByteBuffer login, String namespaceName) throws org.apache.thrift.TException
+ {
+ createNamespace_args args = new createNamespace_args();
+ args.setLogin(login);
+ args.setNamespaceName(namespaceName);
+ sendBase("createNamespace", args);
+ }
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("attachIterator", org.apache.thrift.protocol.TMessageType.CALL, 0));
- attachIterator_args args = new attachIterator_args();
- args.setLogin(login);
- args.setTableName(tableName);
- args.setSetting(setting);
- args.setScopes(scopes);
- args.write(prot);
- prot.writeMessageEnd();
+ public void recv_createNamespace() throws AccumuloException, AccumuloSecurityException, NamespaceExistsException, org.apache.thrift.TException
+ {
+ createNamespace_result result = new createNamespace_result();
+ receiveBase(result, "createNamespace");
+ if (result.ouch1 != null) {
+ throw result.ouch1;
}
-
- public void getResult() throws AccumuloSecurityException, AccumuloException, TableNotFoundException, org.apache.thrift.TException {
- if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_attachIterator();
+ if (result.ouch2 != null) {
+ throw result.ouch2;
+ }
+ if (result.ouch3 != null) {
+ throw result.ouch3;
}
+ return;
}
- public void checkIteratorConflicts(ByteBuffer login, String tableName, IteratorSetting setting, Set<IteratorScope> scopes, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
- checkReady();
- checkIteratorConflicts_call method_call = new checkIteratorConflicts_call(login, tableName, setting, scopes, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
+ public void deleteNamespace(ByteBuffer login, String namespaceName) throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, NamespaceNotEmptyException, org.apache.thrift.TException
+ {
+ send_deleteNamespace(login, namespaceName);
+ recv_deleteNamespace();
}
- public static class checkIteratorConflicts_call extends org.apache.thrift.async.TAsyncMethodCall {
- private ByteBuffer login;
- private String tableName;
- private IteratorSetting setting;
- private Set<IteratorScope> scopes;
- public checkIteratorConflicts_call(ByteBuffer login, String tableName, IteratorSetting setting, Set<IteratorScope> scopes, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.login = login;
- this.tableName = tableName;
- this.setting = setting;
- this.scopes = scopes;
- }
+ public void send_deleteNamespace(ByteBuffer login, String namespaceName) throws org.apache.thrift.TException
+ {
+ deleteNamespace_args args = new deleteNamespace_args();
+ args.setLogin(login);
+ args.setNamespaceName(namespaceName);
+ sendBase("deleteNamespace", args);
+ }
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("checkIteratorConflicts", org.apache.thrift.protocol.TMessageType.CALL, 0));
- checkIteratorConflicts_args args = new checkIteratorConflicts_args();
- args.setLogin(login);
- args.setTableName(tableName);
- args.setSetting(setting);
- args.setScopes(scopes);
- args.write(prot);
- prot.writeMessageEnd();
+ public void recv_deleteNamespace() throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, NamespaceNotEmptyException, org.apache.thrift.TException
+ {
+ deleteNamespace_result result = new deleteNamespace_result();
+ receiveBase(result, "deleteNamespace");
+ if (result.ouch1 != null) {
+ throw result.ouch1;
}
-
- public void getResult() throws AccumuloSecurityException, AccumuloException, TableNotFoundException, org.apache.thrift.TException {
- if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_checkIteratorConflicts();
+ if (result.ouch2 != null) {
+ throw result.ouch2;
}
+ if (result.ouch3 != null) {
+ throw result.ouch3;
+ }
+ if (result.ouch4 != null) {
+ throw result.ouch4;
+ }
+ return;
}
- public void clearLocatorCache(ByteBuffer login, String tableName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
- checkReady();
- clearLocatorCache_call method_call = new clearLocatorCache_call(login, tableName, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
+ public void renameNamespace(ByteBuffer login, String oldNamespaceName, String newNamespaceName) throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, NamespaceExistsException, org.apache.thrift.TException
+ {
+ send_renameNamespace(login, oldNamespaceName, newNamespaceName);
+ recv_renameNamespace();
}
- public static class clearLocatorCache_call extends org.apache.thrift.async.TAsyncMethodCall {
- private ByteBuffer login;
- private String tableName;
- public clearLocatorCache_call(ByteBuffer login, String tableName, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.login = login;
- this.tableName = tableName;
- }
+ public void send_renameNamespace(ByteBuffer login, String oldNamespaceName, String newNamespaceName) throws org.apache.thrift.TException
+ {
+ renameNamespace_args args = new renameNamespace_args();
+ args.setLogin(login);
+ args.setOldNamespaceName(oldNamespaceName);
+ args.setNewNamespaceName(newNamespaceName);
+ sendBase("renameNamespace", args);
+ }
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("clearLocatorCache", org.apache.thrift.protocol.TMessageType.CALL, 0));
- clearLocatorCache_args args = new clearLocatorCache_args();
- args.setLogin(login);
- args.setTableName(tableName);
- args.write(prot);
- prot.writeMessageEnd();
+ public void recv_renameNamespace() throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, NamespaceExistsException, org.apache.thrift.TException
+ {
+ renameNamespace_result result = new renameNamespace_result();
+ receiveBase(result, "renameNamespace");
+ if (result.ouch1 != null) {
+ throw result.ouch1;
}
-
- public void getResult() throws TableNotFoundException, org.apache.thrift.TException {
- if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_clearLocatorCache();
+ if (result.ouch2 != null) {
+ throw result.ouch2;
+ }
+ if (result.ouch3 != null) {
+ throw result.ouch3;
+ }
+ if (result.ouch4 != null) {
+ throw result.ouch4;
}
+ return;
}
- public void cloneTable(ByteBuffer login, String tableName, String newTableName, boolean flush, Map<String,String> propertiesToSet, Set<String> propertiesToExclude, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
- checkReady();
- cloneTable_call method_call = new cloneTable_call(login, tableName, newTableName, flush, propertiesToSet, propertiesToExclude, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
+ public void setNamespaceProperty(ByteBuffer login, String namespaceName, String property, String value) throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException
+ {
+ send_setNamespaceProperty(login, namespaceName, property, value);
+ recv_setNamespaceProperty();
}
- public static class cloneTable_call extends org.apache.thrift.async.TAsyncMethodCall {
- private ByteBuffer login;
- private String tableName;
- private String newTableName;
- private boolean flush;
- private Map<String,String> propertiesToSet;
- private Set<String> propertiesToExclude;
- public cloneTable_call(ByteBuffer login, String tableName, String newTableName, boolean flush, Map<String,String> propertiesToSet, Set<String> propertiesToExclude, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.login = login;
- this.tableName = tableName;
- this.newTableName = newTableName;
- this.flush = flush;
- this.propertiesToSet = propertiesToSet;
- this.propertiesToExclude = propertiesToExclude;
- }
+ public void send_setNamespaceProperty(ByteBuffer login, String namespaceName, String property, String value) throws org.apache.thrift.TException
+ {
+ setNamespaceProperty_args args = new setNamespaceProperty_args();
+ args.setLogin(login);
+ args.setNamespaceName(namespaceName);
+ args.setProperty(property);
+ args.setValue(value);
+ sendBase("setNamespaceProperty", args);
+ }
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("cloneTable", org.apache.thrift.protocol.TMessageType.CALL, 0));
- cloneTable_args args = new cloneTable_args();
- args.setLogin(login);
- args.setTableName(tableName);
- args.setNewTableName(newTableName);
- args.setFlush(flush);
- args.setPropertiesToSet(propertiesToSet);
- args.setPropertiesToExclude(propertiesToExclude);
- args.write(prot);
- prot.writeMessageEnd();
+ public void recv_setNamespaceProperty() throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException
+ {
+ setNamespaceProperty_result result = new setNamespaceProperty_result();
+ receiveBase(result, "setNamespaceProperty");
+ if (result.ouch1 != null) {
+ throw result.ouch1;
}
-
- public void getResult() throws AccumuloException, AccumuloSecurityException, TableNotFoundException, TableExistsException, org.apache.thrift.TException {
- if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_cloneTable();
+ if (result.ouch2 != null) {
+ throw result.ouch2;
+ }
+ if (result.ouch3 != null) {
+ throw result.ouch3;
}
+ return;
}
- public void compactTable(ByteBuffer login, String tableName, ByteBuffer startRow, ByteBuffer endRow, List<IteratorSetting> iterators, boolean flush, boolean wait, CompactionStrategyConfig compactionStrategy, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
- checkReady();
- compactTable_call method_call = new compactTable_call(login, tableName, startRow, endRow, iterators, flush, wait, compactionStrategy, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
+ public void removeNamespaceProperty(ByteBuffer login, String namespaceName, String property) throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException
+ {
+ send_removeNamespaceProperty(login, namespaceName, property);
+ recv_removeNamespaceProperty();
}
- public static class compactTable_call extends org.apache.thrift.async.TAsyncMethodCall {
- private ByteBuffer login;
- private String tableName;
- private ByteBuffer startRow;
- private ByteBuffer endRow;
- private List<IteratorSetting> iterators;
- private boolean flush;
- private boolean wait;
- private CompactionStrategyConfig compactionStrategy;
- public compactTable_call(ByteBuffer login, String tableName, ByteBuffer startRow, ByteBuffer endRow, List<IteratorSetting> iterators, boolean flush, boolean wait, CompactionStrategyConfig compactionStrategy, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.login = login;
- this.tableName = tableName;
- this.startRow = startRow;
- this.endRow = endRow;
- this.iterators = iterators;
- this.flush = flush;
- this.wait = wait;
- this.compactionStrategy = compactionStrategy;
- }
+ public void send_removeNamespaceProperty(ByteBuffer login, String namespaceName, String property) throws org.apache.thrift.TException
+ {
+ removeNamespaceProperty_args args = new removeNamespaceProperty_args();
+ args.setLogin(login);
+ args.setNamespaceName(namespaceName);
+ args.setProperty(property);
+ sendBase("removeNamespaceProperty", args);
+ }
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("compactTable", org.apache.thrift.protocol.TMessageType.CALL, 0));
- compactTable_args args = new compactTable_args();
- args.setLogin(login);
- args.setTableName(tableName);
- args.setStartRow(startRow);
- args.setEndRow(endRow);
- args.setIterators(iterators);
- args.setFlush(flush);
- args.setWait(wait);
- args.setCompactionStrategy(compactionStrategy);
- args.write(prot);
- prot.writeMessageEnd();
+ public void recv_removeNamespaceProperty() throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException
+ {
+ removeNamespaceProperty_result result = new removeNamespaceProperty_result();
+ receiveBase(result, "removeNamespaceProperty");
+ if (result.ouch1 != null) {
+ throw result.ouch1;
}
-
- public void getResult() throws AccumuloSecurityException, TableNotFoundException, AccumuloException, org.apache.thrift.TException {
- if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_compactTable();
+ if (result.ouch2 != null) {
+ throw result.ouch2;
+ }
+ if (result.ouch3 != null) {
+ throw result.ouch3;
}
+ return;
}
- public void cancelCompaction(ByteBuffer login, String tableName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
- checkReady();
- cancelCompaction_call method_call = new cancelCompaction_call(login, tableName, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
+ public Map<String,String> getNamespaceProperties(ByteBuffer login, String namespaceName) throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException
+ {
+ send_getNamespaceProperties(login, namespaceName);
+ return recv_getNamespaceProperties();
}
- public static class cancelCompaction_call extends org.apache.thrift.async.TAsyncMethodCall {
- private ByteBuffer login;
- private String tableName;
- public cancelCompaction_call(ByteBuffer login, String tableName, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ public void send_getNamespaceProperties(ByteBuffer login, String namespaceName) throws org.apache.thrift.TException
+ {
+ getNamespaceProperties_args args = new getNamespaceProperties_args();
+ args.setLogin(login);
+ args.setNamespaceName(namespaceName);
+ sendBase("getNamespaceProperties", args);
+ }
+
+ public Map<String,String> recv_getNamespaceProperties() throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException
+ {
+ getNamespaceProperties_result result = new getNamespaceProperties_result();
+ receiveBase(result, "getNamespaceProperties");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.ouch1 != null) {
+ throw result.ouch1;
+ }
+ if (result.ouch2 != null) {
+ throw result.ouch2;
+ }
+ if (result.ouch3 != null) {
+ throw result.ouch3;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getNamespaceProperties failed: unknown result");
+ }
+
+ public Map<String,String> namespaceIdMap(ByteBuffer login) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
+ {
+ send_namespaceIdMap(login);
+ return recv_namespaceIdMap();
+ }
+
+ public void send_namespaceIdMap(ByteBuffer login) throws org.apache.thrift.TException
+ {
+ namespaceIdMap_args args = new namespaceIdMap_args();
+ args.setLogin(login);
+ sendBase("namespaceIdMap", args);
+ }
+
+ public Map<String,String> recv_namespaceIdMap() throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
+ {
+ namespaceIdMap_result result = new namespaceIdMap_result();
+ receiveBase(result, "namespaceIdMap");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.ouch1 != null) {
+ throw result.ouch1;
+ }
+ if (result.ouch2 != null) {
+ throw result.ouch2;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "namespaceIdMap failed: unknown result");
+ }
+
+ public void attachNamespaceIterator(ByteBuffer login, String namespaceName, IteratorSetting setting, Set<IteratorScope> scopes) throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException
+ {
+ send_attachNamespaceIterator(login, namespaceName, setting, scopes);
+ recv_attachNamespaceIterator();
+ }
+
+ public void send_attachNamespaceIterator(ByteBuffer login, String namespaceName, IteratorSetting setting, Set<IteratorScope> scopes) throws org.apache.thrift.TException
+ {
+ attachNamespaceIterator_args args = new attachNamespaceIterator_args();
+ args.setLogin(login);
+ args.setNamespaceName(namespaceName);
+ args.setSetting(setting);
+ args.setScopes(scopes);
+ sendBase("attachNamespaceIterator", args);
+ }
+
+ public void recv_attachNamespaceIterator() throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException
+ {
+ attachNamespaceIterator_result result = new attachNamespaceIterator_result();
+ receiveBase(result, "attachNamespaceIterator");
+ if (result.ouch1 != null) {
+ throw result.ouch1;
+ }
+ if (result.ouch2 != null) {
+ throw result.ouch2;
+ }
+ if (result.ouch3 != null) {
+ throw result.ouch3;
+ }
+ return;
+ }
+
+ public void removeNamespaceIterator(ByteBuffer login, String namespaceName, String name, Set<IteratorScope> scopes) throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException
+ {
+ send_removeNamespaceIterator(login, namespaceName, name, scopes);
+ recv_removeNamespaceIterator();
+ }
+
+ public void send_removeNamespaceIterator(ByteBuffer login, String namespaceName, String name, Set<IteratorScope> scopes) throws org.apache.thrift.TException
+ {
+ removeNamespaceIterator_args args = new removeNamespaceIterator_args();
+ args.setLogin(login);
+ args.setNamespaceName(namespaceName);
+ args.setName(name);
+ args.setScopes(scopes);
+ sendBase("removeNamespaceIterator", args);
+ }
+
+ public void recv_removeNamespaceIterator() throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException
+ {
+ removeNamespaceIterator_result result = new removeNamespaceIterator_result();
+ receiveBase(result, "removeNamespaceIterator");
+ if (result.ouch1 != null) {
+ throw result.ouch1;
+ }
+ if (result.ouch2 != null) {
+ throw result.ouch2;
+ }
+ if (result.ouch3 != null) {
+ throw result.ouch3;
+ }
+ return;
+ }
+
+ public IteratorSetting getNamespaceIteratorSetting(ByteBuffer login, String namespaceName, String name, IteratorScope scope) throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException
+ {
+ send_getNamespaceIteratorSetting(login, namespaceName, name, scope);
+ return recv_getNamespaceIteratorSetting();
+ }
+
+ public void send_getNamespaceIteratorSetting(ByteBuffer login, String namespaceName, String name, IteratorScope scope) throws org.apache.thrift.TException
+ {
+ getNamespaceIteratorSetting_args args = new getNamespaceIteratorSetting_args();
+ args.setLogin(login);
+ args.setNamespaceName(namespaceName);
+ args.setName(name);
+ args.setScope(scope);
+ sendBase("getNamespaceIteratorSetting", args);
+ }
+
+ public IteratorSetting recv_getNamespaceIteratorSetting() throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException
+ {
+ getNamespaceIteratorSetting_result result = new getNamespaceIteratorSetting_result();
+ receiveBase(result, "getNamespaceIteratorSetting");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.ouch1 != null) {
+ throw result.ouch1;
+ }
+ if (result.ouch2 != null) {
+ throw result.ouch2;
+ }
+ if (result.ouch3 != null) {
+ throw result.ouch3;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getNamespaceIteratorSetting failed: unknown result");
+ }
+
+ public Map<String,Set<IteratorScope>> listNamespaceIterators(ByteBuffer login, String namespaceName) throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException
+ {
+ send_listNamespaceIterators(login, namespaceName);
+ return recv_listNamespaceIterators();
+ }
+
+ public void send_listNamespaceIterators(ByteBuffer login, String namespaceName) throws org.apache.thrift.TException
+ {
+ listNamespaceIterators_args args = new listNamespaceIterators_args();
+ args.setLogin(login);
+ args.setNamespaceName(namespaceName);
+ sendBase("listNamespaceIterators", args);
+ }
+
+ public Map<String,Set<IteratorScope>> recv_listNamespaceIterators() throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException
+ {
+ listNamespaceIterators_result result = new listNamespaceIterators_result();
+ receiveBase(result, "listNamespaceIterators");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.ouch1 != null) {
+ throw result.ouch1;
+ }
+ if (result.ouch2 != null) {
+ throw result.ouch2;
+ }
+ if (result.ouch3 != null) {
+ throw result.ouch3;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "listNamespaceIterators failed: unknown result");
+ }
+
+ public void checkNamespaceIteratorConflicts(ByteBuffer login, String namespaceName, IteratorSetting setting, Set<IteratorScope> scopes) throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException
+ {
+ send_checkNamespaceIteratorConflicts(login, namespaceName, setting, scopes);
+ recv_checkNamespaceIteratorConflicts();
+ }
+
+ public void send_checkNamespaceIteratorConflicts(ByteBuffer login, String namespaceName, IteratorSetting setting, Set<IteratorScope> scopes) throws org.apache.thrift.TException
+ {
+ checkNamespaceIteratorConflicts_args args = new checkNamespaceIteratorConflicts_args();
+ args.setLogin(login);
+ args.setNamespaceName(namespaceName);
+ args.setSetting(setting);
+ args.setScopes(scopes);
+ sendBase("checkNamespaceIteratorConflicts", args);
+ }
+
+ public void recv_checkNamespaceIteratorConflicts() throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException
+ {
+ checkNamespaceIteratorConflicts_result result = new checkNamespaceIteratorConflicts_result();
+ receiveBase(result, "checkNamespaceIteratorConflicts");
+ if (result.ouch1 != null) {
+ throw result.ouch1;
+ }
+ if (result.ouch2 != null) {
+ throw result.ouch2;
+ }
+ if (result.ouch3 != null) {
+ throw result.ouch3;
+ }
+ return;
+ }
+
+ public int addNamespaceConstraint(ByteBuffer login, String namespaceName, String constraintClassName) throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException
+ {
+ send_addNamespaceConstraint(login, namespaceName, constraintClassName);
+ return recv_addNamespaceConstraint();
+ }
+
+ public void send_addNamespaceConstraint(ByteBuffer login, String namespaceName, String constraintClassName) throws org.apache.thrift.TException
+ {
+ addNamespaceConstraint_args args = new addNamespaceConstraint_args();
+ args.setLogin(login);
+ args.setNamespaceName(namespaceName);
+ args.setConstraintClassName(constraintClassName);
+ sendBase("addNamespaceConstraint", args);
+ }
+
+ public int recv_addNamespaceConstraint() throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException
+ {
+ addNamespaceConstraint_result result = new addNamespaceConstraint_result();
+ receiveBase(result, "addNamespaceConstraint");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.ouch1 != null) {
+ throw result.ouch1;
+ }
+ if (result.ouch2 != null) {
+ throw result.ouch2;
+ }
+ if (result.ouch3 != null) {
+ throw result.ouch3;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "addNamespaceConstraint failed: unknown result");
+ }
+
+ public void removeNamespaceConstraint(ByteBuffer login, String namespaceName, int id) throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException
+ {
+ send_removeNamespaceConstraint(login, namespaceName, id);
+ recv_removeNamespaceConstraint();
+ }
+
+ public void send_removeNamespaceConstraint(ByteBuffer login, String namespaceName, int id) throws org.apache.thrift.TException
+ {
+ removeNamespaceConstraint_args args = new removeNamespaceConstraint_args();
+ args.setLogin(login);
+ args.setNamespaceName(namespaceName);
+ args.setId(id);
+ sendBase("removeNamespaceConstraint", args);
+ }
+
+ public void recv_removeNamespaceConstraint() throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException
+ {
+ removeNamespaceConstraint_result result = new removeNamespaceConstraint_result();
+ receiveBase(result, "removeNamespaceConstraint");
+ if (result.ouch1 != null) {
+ throw result.ouch1;
+ }
+ if (result.ouch2 != null) {
+ throw result.ouch2;
+ }
+ if (result.ouch3 != null) {
+ throw result.ouch3;
+ }
+ return;
+ }
+
+ public Map<String,Integer> listNamespaceConstraints(ByteBuffer login, String namespaceName) throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException
+ {
+ send_listNamespaceConstraints(login, namespaceName);
+ return recv_listNamespaceConstraints();
+ }
+
+ public void send_listNamespaceConstraints(ByteBuffer login, String namespaceName) throws org.apache.thrift.TException
+ {
+ listNamespaceConstraints_args args = new listNamespaceConstraints_args();
+ args.setLogin(login);
+ args.setNamespaceName(namespaceName);
+ sendBase("listNamespaceConstraints", args);
+ }
+
+ public Map<String,Integer> recv_listNamespaceConstraints() throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException
+ {
+ listNamespaceConstraints_result result = new listNamespaceConstraints_result();
+ receiveBase(result, "listNamespaceConstraints");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.ouch1 != null) {
+ throw result.ouch1;
+ }
+ if (result.ouch2 != null) {
+ throw result.ouch2;
+ }
+ if (result.ouch3 != null) {
+ throw result.ouch3;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "listNamespaceConstraints failed: unknown result");
+ }
+
+ public boolean testNamespaceClassLoad(ByteBuffer login, String namespaceName, String className, String asTypeName) throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException
+ {
+ send_testNamespaceClassLoad(login, namespaceName, className, asTypeName);
+ return recv_testNamespaceClassLoad();
+ }
+
+ public void send_testNamespaceClassLoad(ByteBuffer login, String namespaceName, String className, String asTypeName) throws org.apache.thrift.TException
+ {
+ testNamespaceClassLoad_args args = new testNamespaceClassLoad_args();
+ args.setLogin(login);
+ args.setNamespaceName(namespaceName);
+ args.setClassName(className);
+ args.setAsTypeName(asTypeName);
+ sendBase("testNamespaceClassLoad", args);
+ }
+
+ public boolean recv_testNamespaceClassLoad() throws AccumuloException, AccumuloSecurityException, NamespaceNotFoundException, org.apache.thrift.TException
+ {
+ testNamespaceClassLoad_result result = new testNamespaceClassLoad_result();
+ receiveBase(result, "testNamespaceClassLoad");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.ouch1 != null) {
+ throw result.ouch1;
+ }
+ if (result.ouch2 != null) {
+ throw result.ouch2;
+ }
+ if (result.ouch3 != null) {
+ throw result.ouch3;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "testNamespaceClassLoad failed: unknown result");
+ }
+
+ }
+ public static class AsyncClient extends org.apache.thrift.async.TAsyncClient implements AsyncIface {
+ public static class Factory implements org.apache.thrift.async.TAsyncClientFactory<AsyncClient> {
+ private org.apache.thrift.async.TAsyncClientManager clientManager;
+ private org.apache.thrift.protocol.TProtocolFactory protocolFactory;
+ public Factory(org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.protocol.TProtocolFactory protocolFactory) {
+ this.clientManager = clientManager;
+ this.protocolFactory = protocolFactory;
+ }
+ public AsyncClient getAsyncClient(org.apache.thrift.transport.TNonblockingTransport transport) {
+ return new AsyncClient(protocolFactory, clientManager, transport);
+ }
+ }
+
+ public AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport) {
+ super(protocolFactory, clientManager, transport);
+ }
+
+ public void login(String principal, Map<String,String> loginProperties, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ login_call method_call = new login_call(principal, loginProperties, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class login_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private String principal;
+ private Map<String,String> loginProperties;
+ public login_call(String principal, Map<String,String> loginProperties, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
- this.login = login;
- this.tableName = tableName;
+ this.principal = principal;
+ this.loginProperties = loginProperties;
}
public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("cancelCompaction", org.apache.thrift.protocol.TMessageType.CALL, 0));
- cancelCompaction_args args = new cancelCompaction_args();
- args.setLogin(login);
- args.setTableName(tableName);
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("login", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ login_args args = new login_args();
+ args.setPrincipal(principal);
+ args.setLoginProperties(loginProperties);
args.write(prot);
prot.writeMessageEnd();
}
- public void getResult() throws AccumuloSecurityException, TableNotFoundException, AccumuloException, org.apache.thrift.TException {
+ public ByteBuffer getResult() throws AccumuloSecurityException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_cancelCompaction();
+ return (new Client(prot)).recv_login();
}
}
- public void createTable(ByteBuffer login, String tableName, boolean versioningIter, TimeType type, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void addConstraint(ByteBuffer login, String tableName, String constraintClassName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
- createTable_call method_call = new createTable_call(login, tableName, versioningIter, type, resultHandler, this, ___protocolFactory, ___transport);
+ addConstraint_call method_call = new addConstraint_call(login, tableName, constraintClassName, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
- public static class createTable_call extends org.apache.thrift.async.TAsyncMethodCall {
+ public static class addConstraint_call extends org.apache.thrift.async.TAsyncMethodCall {
private ByteBuffer login;
private String tableName;
- private boolean versioningIter;
- private TimeType type;
- public createTable_call(ByteBuffer login, String tableName, boolean versioningIter, TimeType type, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ private String constraintClassName;
+ public addConstraint_call(ByteBuffer login, String tableName, String constraintClassName, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
this.login = login;
this.tableName = tableName;
- this.versioningIter = versioningIter;
- this.type = type;
+ this.constraintClassName = constraintClassName;
}
public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("createTable", org.apache.thrift.protocol.TMessageType.CALL, 0));
- createTable_args args = new createTable_args();
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("addConstraint", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ addConstraint_args args = new addConstraint_args();
args.setLogin(login);
args.setTableName(tableName);
- args.setVersioningIter(versioningIter);
- args.setType(type);
+ args.setConstraintClassName(constraintClassName);
args.write(prot);
prot.writeMessageEnd();
}
- public void getResult() throws AccumuloException, AccumuloSecurityException, TableExistsException, org.apache.thrift.TException {
+ public int getResult() throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_createTable();
+ return (new Client(prot)).recv_addConstraint();
}
}
- public void deleteTable(ByteBuffer login, String tableName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void addSplits(ByteBuffer login, String tableName, Set<ByteBuffer> splits, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
- deleteTable_call method_call = new deleteTable_call(login, tableName, resultHandler, this, ___protocolFactory, ___transport);
+ addSplits_call method_call = new addSplits_call(login, tableName, splits, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
- public static class deleteTable_call extends org.apache.thrift.async.TAsyncMethodCall {
+ public static class addSplits_call extends org.apache.thrift.async.TAsyncMethodCall {
private ByteBuffer login;
private String tableName;
- public deleteTable_call(ByteBuffer login, String tableName, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ private Set<ByteBuffer> splits;
+ public addSplits_call(ByteBuffer login, String tableName, Set<ByteBuffer> splits, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
this.login = login;
this.tableName = tableName;
+ this.splits = splits;
}
public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("deleteTable", org.apache.thrift.protocol.TMessageType.CALL, 0));
- deleteTable_args args = new deleteTable_args();
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("addSplits", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ addSplits_args args = new addSplits_args();
args.setLogin(login);
args.setTableName(tableName);
+ args.setSplits(splits);
args.write(prot);
prot.writeMessageEnd();
}
@@ -3172,268 +3648,596 @@ public class AccumuloProxy {
}
org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_deleteTable();
+ (new Client(prot)).recv_addSplits();
}
}
- public void deleteRows(ByteBuffer login, String tableName, ByteBuffer startRow, ByteBuffer endRow, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void attachIterator(ByteBuffer login, String tableName, IteratorSetting setting, Set<IteratorScope> scopes, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
- deleteRows_call method_call = new deleteRows_call(login, tableName, startRow, endRow, resultHandler, this, ___protocolFactory, ___transport);
+ attachIterator_call method_call = new attachIterator_call(login, tableName, setting, scopes, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
- public static class deleteRows_call extends org.apache.thrift.async.TAsyncMethodCall {
+ public static class attachIterator_call extends org.apache.thrift.async.TAsyncMethodCall {
private ByteBuffer login;
private String tableName;
- private ByteBuffer startRow;
- private ByteBuffer endRow;
- public deleteRows_call(ByteBuffer login, String tableName, ByteBuffer startRow, ByteBuffer endRow, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ private IteratorSetting setting;
+ private Set<IteratorScope> scopes;
+ public attachIterator_call(ByteBuffer login, String tableName, IteratorSetting setting, Set<IteratorScope> scopes, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
this.login = login;
this.tableName = tableName;
- this.startRow = startRow;
- this.endRow = endRow;
+ this.setting = setting;
+ this.scopes = scopes;
}
public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("deleteRows", org.apache.thrift.protocol.TMessageType.CALL, 0));
- deleteRows_args args = new deleteRows_args();
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("attachIterator", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ attachIterator_args args = new attachIterator_args();
args.setLogin(login);
args.setTableName(tableName);
- args.setStartRow(startRow);
- args.setEndRow(endRow);
+ args.setSetting(setting);
+ args.setScopes(scopes);
args.write(prot);
prot.writeMessageEnd();
}
- public void getResult() throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException {
+ public void getResult() throws AccumuloSecurityException, AccumuloException, TableNotFoundException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_deleteRows();
+ (new Client(prot)).recv_attachIterator();
}
}
- public void exportTable(ByteBuffer login, String tableName, String exportDir, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void checkIteratorConflicts(ByteBuffer login, String tableName, IteratorSetting setting, Set<IteratorScope> scopes, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
- exportTable_call method_call = new exportTable_call(login, tableName, exportDir, resultHandler, this, ___protocolFactory, ___transport);
+ checkIteratorConflicts_call method_call = new checkIteratorConflicts_call(login, tableName, setting, scopes, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
- public static class exportTable_call extends org.apache.thrift.async.TAsyncMethodCall {
+ public static class checkIteratorConflicts_call extends org.apache.thrift.async.TAsyncMethodCall {
private ByteBuffer login;
private String tableName;
- private String exportDir;
- public exportTable_call(ByteBuffer login, String tableName, String exportDir, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ private IteratorSetting setting;
+ private Set<IteratorScope> scopes;
+ public checkIteratorConflicts_call(ByteBuffer login, String tableName, IteratorSetting setting, Set<IteratorScope> scopes, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
this.login = login;
this.tableName = tableName;
- this.exportDir = exportDir;
+ this.setting = setting;
+ this.scopes = scopes;
}
public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("exportTable", org.apache.thrift.protocol.TMessageType.CALL, 0));
- exportTable_args args = new exportTable_args();
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("checkIteratorConflicts", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ checkIteratorConflicts_args args = new checkIteratorConflicts_args();
args.setLogin(login);
args.setTableName(tableName);
- args.setExportDir(exportDir);
+ args.setSetting(setting);
+ args.setScopes(scopes);
args.write(prot);
prot.writeMessageEnd();
}
- public void getResult() throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException {
+ public void getResult() throws AccumuloSecurityException, AccumuloException, TableNotFoundException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_exportTable();
+ (new Client(prot)).recv_checkIteratorConflicts();
}
}
- public void flushTable(ByteBuffer login, String tableName, ByteBuffer startRow, ByteBuffer endRow, boolean wait, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void clearLocatorCache(ByteBuffer login, String tableName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
- flushTable_call method_call = new flushTable_call(login, tableName, startRow, endRow, wait, resultHandler, this, ___protocolFactory, ___transport);
+ clearLocatorCache_call method_call = new clearLocatorCache_call(login, tableName, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
- public static class flushTable_call extends org.apache.thrift.async.TAsyncMethodCall {
+ public static class clearLocatorCache_call extends org.apache.thrift.async.TAsyncMethodCall {
private ByteBuffer login;
private String tableName;
- private ByteBuffer startRow;
- private ByteBuffer endRow;
- private boolean wait;
- public flushTable_call(ByteBuffer login, String tableName, ByteBuffer startRow, ByteBuffer endRow, boolean wait, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ public clearLocatorCache_call(ByteBuffer login, String tableName, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
this.login = login;
this.tableName = tableName;
- this.startRow = startRow;
- this.endRow = endRow;
- this.wait = wait;
}
public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("flushTable", org.apache.thrift.protocol.TMessageType.CALL, 0));
- flushTable_args args = new flushTable_args();
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("clearLocatorCache", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ clearLocatorCache_args args = new clearLocatorCache_args();
args.setLogin(login);
args.setTableName(tableName);
- args.setStartRow(startRow);
- args.setEndRow(endRow);
- args.setWait(wait);
args.write(prot);
prot.writeMessageEnd();
}
- public void getResult() throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException {
+ public void getResult() throws TableNotFoundException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_flushTable();
+ (new Client(prot)).recv_clearLocatorCache();
}
}
- public void getDiskUsage(ByteBuffer login, Set<String> tables, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void cloneTable(ByteBuffer login, String tableName, String newTableName, boolean flush, Map<String,String> propertiesToSet, Set<String> propertiesToExclude, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
- getDiskUsage_call method_call = new getDiskUsage_call(login, tables, resultHandler, this, ___protocolFactory, ___transport);
+ cloneTable_call method_call = new cloneTable_call(login, tableName, newTableName, flush, propertiesToSet, propertiesToExclude, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
- public static class getDiskUsage_call extends org.apache.thrift.async.TAsyncMethodCall {
+ public static class cloneTable_call extends org.apache.thrift.async.TAsyncMethodCall {
private ByteBuffer login;
- private Set<String> tables;
- public getDiskUsage_call(ByteBuffer login, Set<String> tables, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ private String tableName;
+ private String newTableName;
+ private boolean flush;
+ private Map<String,String> propertiesToSet;
+ private Set<String> propertiesToExclude;
+ public cloneTable_call(ByteBuffer login, String tableName, String newTableName, boolean flush, Map<String,String> propertiesToSet, Set<String> propertiesToExclude, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
this.login = login;
- this.tables = tables;
+ this.tableName = tableName;
+ this.newTableName = newTableName;
+ this.flush = flush;
+ this.propertiesToSet = propertiesToSet;
+ this.propertiesToExclude = propertiesToExclude;
}
public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getDiskUsage", org.apache.thrift.protocol.TMessageType.CALL, 0));
- getDiskUsage_args args = new getDiskUsage_args();
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("cloneTable", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ cloneTable_args args = new cloneTable_args();
args.setLogin(login);
- args.setTables(tables);
+ args.setTableName(tableName);
+ args.setNewTableName(newTableName);
+ args.setFlush(flush);
+ args.setPropertiesToSet(propertiesToSet);
+ args.setPropertiesToExclude(propertiesToExclude);
args.write(prot);
prot.writeMessageEnd();
}
- public List<DiskUsage> getResult() throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException {
+ public void getResult() throws AccumuloException, AccumuloSecurityException, TableNotFoundException, TableExistsException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(
<TRUNCATED>