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>
