http://git-wip-us.apache.org/repos/asf/hbase/blob/7820ba1d/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/THBaseService.java ---------------------------------------------------------------------- diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/THBaseService.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/THBaseService.java index e8f36a0..7388443 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/THBaseService.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/THBaseService.java @@ -34,7 +34,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2018-07-04") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2018-12-27") public class THBaseService { public interface Iface { @@ -282,6 +282,56 @@ public class THBaseService { */ public boolean checkAndMutate(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, TCompareOp compareOp, ByteBuffer value, TRowMutations rowMutations) throws TIOError, org.apache.thrift.TException; + public TTableDescriptor getTableDescriptor(TTableName table) throws TIOError, org.apache.thrift.TException; + + public List<TTableDescriptor> getTableDescriptors(List<TTableName> tables) throws TIOError, org.apache.thrift.TException; + + public boolean tableExists(TTableName tableName) throws TIOError, org.apache.thrift.TException; + + public List<TTableDescriptor> getTableDescriptorsByPattern(String regex, boolean includeSysTables) throws TIOError, org.apache.thrift.TException; + + public List<TTableDescriptor> getTableDescriptorsByNamespace(String name) throws TIOError, org.apache.thrift.TException; + + public List<TTableName> getTableNamesByPattern(String regex, boolean includeSysTables) throws TIOError, org.apache.thrift.TException; + + public List<TTableName> getTableNamesByNamespace(String name) throws TIOError, org.apache.thrift.TException; + + public void createTable(TTableDescriptor desc, List<ByteBuffer> splitKeys) throws TIOError, org.apache.thrift.TException; + + public void deleteTable(TTableName tableName) throws TIOError, org.apache.thrift.TException; + + public void truncateTable(TTableName tableName, boolean preserveSplits) throws TIOError, org.apache.thrift.TException; + + public void enableTable(TTableName tableName) throws TIOError, org.apache.thrift.TException; + + public void disableTable(TTableName tableName) throws TIOError, org.apache.thrift.TException; + + public boolean isTableEnabled(TTableName tableName) throws TIOError, org.apache.thrift.TException; + + public boolean isTableDisabled(TTableName tableName) throws TIOError, org.apache.thrift.TException; + + public boolean isTableAvailable(TTableName tableName) throws TIOError, org.apache.thrift.TException; + + public boolean isTableAvailableWithSplit(TTableName tableName, List<ByteBuffer> splitKeys) throws TIOError, org.apache.thrift.TException; + + public void addColumnFamily(TTableName tableName, TColumnFamilyDescriptor column) throws TIOError, org.apache.thrift.TException; + + public void deleteColumnFamily(TTableName tableName, ByteBuffer column) throws TIOError, org.apache.thrift.TException; + + public void modifyColumnFamily(TTableName tableName, TColumnFamilyDescriptor column) throws TIOError, org.apache.thrift.TException; + + public void modifyTable(TTableDescriptor desc) throws TIOError, org.apache.thrift.TException; + + public void createNamespace(TNamespaceDescriptor namespaceDesc) throws TIOError, org.apache.thrift.TException; + + public void modifyNamespace(TNamespaceDescriptor namespaceDesc) throws TIOError, org.apache.thrift.TException; + + public void deleteNamespace(String name) throws TIOError, org.apache.thrift.TException; + + public TNamespaceDescriptor getNamespaceDescriptor(String name) throws TIOError, org.apache.thrift.TException; + + public List<TNamespaceDescriptor> listNamespaceDescriptors() throws TIOError, org.apache.thrift.TException; + } public interface AsyncIface { @@ -326,6 +376,56 @@ public class THBaseService { public void checkAndMutate(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, TCompareOp compareOp, ByteBuffer value, TRowMutations rowMutations, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getTableDescriptor(TTableName table, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void getTableDescriptors(List<TTableName> tables, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void tableExists(TTableName tableName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void getTableDescriptorsByPattern(String regex, boolean includeSysTables, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void getTableDescriptorsByNamespace(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void getTableNamesByPattern(String regex, boolean includeSysTables, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void getTableNamesByNamespace(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void createTable(TTableDescriptor desc, List<ByteBuffer> splitKeys, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void deleteTable(TTableName tableName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void truncateTable(TTableName tableName, boolean preserveSplits, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void enableTable(TTableName tableName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void disableTable(TTableName tableName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void isTableEnabled(TTableName tableName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void isTableDisabled(TTableName tableName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void isTableAvailable(TTableName tableName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void isTableAvailableWithSplit(TTableName tableName, List<ByteBuffer> splitKeys, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void addColumnFamily(TTableName tableName, TColumnFamilyDescriptor column, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void deleteColumnFamily(TTableName tableName, ByteBuffer column, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void modifyColumnFamily(TTableName tableName, TColumnFamilyDescriptor column, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void modifyTable(TTableDescriptor desc, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void createNamespace(TNamespaceDescriptor namespaceDesc, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void modifyNamespace(TNamespaceDescriptor namespaceDesc, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void deleteNamespace(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void getNamespaceDescriptor(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void listNamespaceDescriptors(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + } public static class Client extends org.apache.thrift.TServiceClient implements Iface { @@ -892,6 +992,627 @@ public class THBaseService { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "checkAndMutate failed: unknown result"); } + public TTableDescriptor getTableDescriptor(TTableName table) throws TIOError, org.apache.thrift.TException + { + send_getTableDescriptor(table); + return recv_getTableDescriptor(); + } + + public void send_getTableDescriptor(TTableName table) throws org.apache.thrift.TException + { + getTableDescriptor_args args = new getTableDescriptor_args(); + args.setTable(table); + sendBase("getTableDescriptor", args); + } + + public TTableDescriptor recv_getTableDescriptor() throws TIOError, org.apache.thrift.TException + { + getTableDescriptor_result result = new getTableDescriptor_result(); + receiveBase(result, "getTableDescriptor"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.io != null) { + throw result.io; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTableDescriptor failed: unknown result"); + } + + public List<TTableDescriptor> getTableDescriptors(List<TTableName> tables) throws TIOError, org.apache.thrift.TException + { + send_getTableDescriptors(tables); + return recv_getTableDescriptors(); + } + + public void send_getTableDescriptors(List<TTableName> tables) throws org.apache.thrift.TException + { + getTableDescriptors_args args = new getTableDescriptors_args(); + args.setTables(tables); + sendBase("getTableDescriptors", args); + } + + public List<TTableDescriptor> recv_getTableDescriptors() throws TIOError, org.apache.thrift.TException + { + getTableDescriptors_result result = new getTableDescriptors_result(); + receiveBase(result, "getTableDescriptors"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.io != null) { + throw result.io; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTableDescriptors failed: unknown result"); + } + + public boolean tableExists(TTableName tableName) throws TIOError, org.apache.thrift.TException + { + send_tableExists(tableName); + return recv_tableExists(); + } + + public void send_tableExists(TTableName tableName) throws org.apache.thrift.TException + { + tableExists_args args = new tableExists_args(); + args.setTableName(tableName); + sendBase("tableExists", args); + } + + public boolean recv_tableExists() throws TIOError, org.apache.thrift.TException + { + tableExists_result result = new tableExists_result(); + receiveBase(result, "tableExists"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.io != null) { + throw result.io; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "tableExists failed: unknown result"); + } + + public List<TTableDescriptor> getTableDescriptorsByPattern(String regex, boolean includeSysTables) throws TIOError, org.apache.thrift.TException + { + send_getTableDescriptorsByPattern(regex, includeSysTables); + return recv_getTableDescriptorsByPattern(); + } + + public void send_getTableDescriptorsByPattern(String regex, boolean includeSysTables) throws org.apache.thrift.TException + { + getTableDescriptorsByPattern_args args = new getTableDescriptorsByPattern_args(); + args.setRegex(regex); + args.setIncludeSysTables(includeSysTables); + sendBase("getTableDescriptorsByPattern", args); + } + + public List<TTableDescriptor> recv_getTableDescriptorsByPattern() throws TIOError, org.apache.thrift.TException + { + getTableDescriptorsByPattern_result result = new getTableDescriptorsByPattern_result(); + receiveBase(result, "getTableDescriptorsByPattern"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.io != null) { + throw result.io; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTableDescriptorsByPattern failed: unknown result"); + } + + public List<TTableDescriptor> getTableDescriptorsByNamespace(String name) throws TIOError, org.apache.thrift.TException + { + send_getTableDescriptorsByNamespace(name); + return recv_getTableDescriptorsByNamespace(); + } + + public void send_getTableDescriptorsByNamespace(String name) throws org.apache.thrift.TException + { + getTableDescriptorsByNamespace_args args = new getTableDescriptorsByNamespace_args(); + args.setName(name); + sendBase("getTableDescriptorsByNamespace", args); + } + + public List<TTableDescriptor> recv_getTableDescriptorsByNamespace() throws TIOError, org.apache.thrift.TException + { + getTableDescriptorsByNamespace_result result = new getTableDescriptorsByNamespace_result(); + receiveBase(result, "getTableDescriptorsByNamespace"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.io != null) { + throw result.io; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTableDescriptorsByNamespace failed: unknown result"); + } + + public List<TTableName> getTableNamesByPattern(String regex, boolean includeSysTables) throws TIOError, org.apache.thrift.TException + { + send_getTableNamesByPattern(regex, includeSysTables); + return recv_getTableNamesByPattern(); + } + + public void send_getTableNamesByPattern(String regex, boolean includeSysTables) throws org.apache.thrift.TException + { + getTableNamesByPattern_args args = new getTableNamesByPattern_args(); + args.setRegex(regex); + args.setIncludeSysTables(includeSysTables); + sendBase("getTableNamesByPattern", args); + } + + public List<TTableName> recv_getTableNamesByPattern() throws TIOError, org.apache.thrift.TException + { + getTableNamesByPattern_result result = new getTableNamesByPattern_result(); + receiveBase(result, "getTableNamesByPattern"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.io != null) { + throw result.io; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTableNamesByPattern failed: unknown result"); + } + + public List<TTableName> getTableNamesByNamespace(String name) throws TIOError, org.apache.thrift.TException + { + send_getTableNamesByNamespace(name); + return recv_getTableNamesByNamespace(); + } + + public void send_getTableNamesByNamespace(String name) throws org.apache.thrift.TException + { + getTableNamesByNamespace_args args = new getTableNamesByNamespace_args(); + args.setName(name); + sendBase("getTableNamesByNamespace", args); + } + + public List<TTableName> recv_getTableNamesByNamespace() throws TIOError, org.apache.thrift.TException + { + getTableNamesByNamespace_result result = new getTableNamesByNamespace_result(); + receiveBase(result, "getTableNamesByNamespace"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.io != null) { + throw result.io; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTableNamesByNamespace failed: unknown result"); + } + + public void createTable(TTableDescriptor desc, List<ByteBuffer> splitKeys) throws TIOError, org.apache.thrift.TException + { + send_createTable(desc, splitKeys); + recv_createTable(); + } + + public void send_createTable(TTableDescriptor desc, List<ByteBuffer> splitKeys) throws org.apache.thrift.TException + { + createTable_args args = new createTable_args(); + args.setDesc(desc); + args.setSplitKeys(splitKeys); + sendBase("createTable", args); + } + + public void recv_createTable() throws TIOError, org.apache.thrift.TException + { + createTable_result result = new createTable_result(); + receiveBase(result, "createTable"); + if (result.io != null) { + throw result.io; + } + return; + } + + public void deleteTable(TTableName tableName) throws TIOError, org.apache.thrift.TException + { + send_deleteTable(tableName); + recv_deleteTable(); + } + + public void send_deleteTable(TTableName tableName) throws org.apache.thrift.TException + { + deleteTable_args args = new deleteTable_args(); + args.setTableName(tableName); + sendBase("deleteTable", args); + } + + public void recv_deleteTable() throws TIOError, org.apache.thrift.TException + { + deleteTable_result result = new deleteTable_result(); + receiveBase(result, "deleteTable"); + if (result.io != null) { + throw result.io; + } + return; + } + + public void truncateTable(TTableName tableName, boolean preserveSplits) throws TIOError, org.apache.thrift.TException + { + send_truncateTable(tableName, preserveSplits); + recv_truncateTable(); + } + + public void send_truncateTable(TTableName tableName, boolean preserveSplits) throws org.apache.thrift.TException + { + truncateTable_args args = new truncateTable_args(); + args.setTableName(tableName); + args.setPreserveSplits(preserveSplits); + sendBase("truncateTable", args); + } + + public void recv_truncateTable() throws TIOError, org.apache.thrift.TException + { + truncateTable_result result = new truncateTable_result(); + receiveBase(result, "truncateTable"); + if (result.io != null) { + throw result.io; + } + return; + } + + public void enableTable(TTableName tableName) throws TIOError, org.apache.thrift.TException + { + send_enableTable(tableName); + recv_enableTable(); + } + + public void send_enableTable(TTableName tableName) throws org.apache.thrift.TException + { + enableTable_args args = new enableTable_args(); + args.setTableName(tableName); + sendBase("enableTable", args); + } + + public void recv_enableTable() throws TIOError, org.apache.thrift.TException + { + enableTable_result result = new enableTable_result(); + receiveBase(result, "enableTable"); + if (result.io != null) { + throw result.io; + } + return; + } + + public void disableTable(TTableName tableName) throws TIOError, org.apache.thrift.TException + { + send_disableTable(tableName); + recv_disableTable(); + } + + public void send_disableTable(TTableName tableName) throws org.apache.thrift.TException + { + disableTable_args args = new disableTable_args(); + args.setTableName(tableName); + sendBase("disableTable", args); + } + + public void recv_disableTable() throws TIOError, org.apache.thrift.TException + { + disableTable_result result = new disableTable_result(); + receiveBase(result, "disableTable"); + if (result.io != null) { + throw result.io; + } + return; + } + + public boolean isTableEnabled(TTableName tableName) throws TIOError, org.apache.thrift.TException + { + send_isTableEnabled(tableName); + return recv_isTableEnabled(); + } + + public void send_isTableEnabled(TTableName tableName) throws org.apache.thrift.TException + { + isTableEnabled_args args = new isTableEnabled_args(); + args.setTableName(tableName); + sendBase("isTableEnabled", args); + } + + public boolean recv_isTableEnabled() throws TIOError, org.apache.thrift.TException + { + isTableEnabled_result result = new isTableEnabled_result(); + receiveBase(result, "isTableEnabled"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.io != null) { + throw result.io; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "isTableEnabled failed: unknown result"); + } + + public boolean isTableDisabled(TTableName tableName) throws TIOError, org.apache.thrift.TException + { + send_isTableDisabled(tableName); + return recv_isTableDisabled(); + } + + public void send_isTableDisabled(TTableName tableName) throws org.apache.thrift.TException + { + isTableDisabled_args args = new isTableDisabled_args(); + args.setTableName(tableName); + sendBase("isTableDisabled", args); + } + + public boolean recv_isTableDisabled() throws TIOError, org.apache.thrift.TException + { + isTableDisabled_result result = new isTableDisabled_result(); + receiveBase(result, "isTableDisabled"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.io != null) { + throw result.io; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "isTableDisabled failed: unknown result"); + } + + public boolean isTableAvailable(TTableName tableName) throws TIOError, org.apache.thrift.TException + { + send_isTableAvailable(tableName); + return recv_isTableAvailable(); + } + + public void send_isTableAvailable(TTableName tableName) throws org.apache.thrift.TException + { + isTableAvailable_args args = new isTableAvailable_args(); + args.setTableName(tableName); + sendBase("isTableAvailable", args); + } + + public boolean recv_isTableAvailable() throws TIOError, org.apache.thrift.TException + { + isTableAvailable_result result = new isTableAvailable_result(); + receiveBase(result, "isTableAvailable"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.io != null) { + throw result.io; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "isTableAvailable failed: unknown result"); + } + + public boolean isTableAvailableWithSplit(TTableName tableName, List<ByteBuffer> splitKeys) throws TIOError, org.apache.thrift.TException + { + send_isTableAvailableWithSplit(tableName, splitKeys); + return recv_isTableAvailableWithSplit(); + } + + public void send_isTableAvailableWithSplit(TTableName tableName, List<ByteBuffer> splitKeys) throws org.apache.thrift.TException + { + isTableAvailableWithSplit_args args = new isTableAvailableWithSplit_args(); + args.setTableName(tableName); + args.setSplitKeys(splitKeys); + sendBase("isTableAvailableWithSplit", args); + } + + public boolean recv_isTableAvailableWithSplit() throws TIOError, org.apache.thrift.TException + { + isTableAvailableWithSplit_result result = new isTableAvailableWithSplit_result(); + receiveBase(result, "isTableAvailableWithSplit"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.io != null) { + throw result.io; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "isTableAvailableWithSplit failed: unknown result"); + } + + public void addColumnFamily(TTableName tableName, TColumnFamilyDescriptor column) throws TIOError, org.apache.thrift.TException + { + send_addColumnFamily(tableName, column); + recv_addColumnFamily(); + } + + public void send_addColumnFamily(TTableName tableName, TColumnFamilyDescriptor column) throws org.apache.thrift.TException + { + addColumnFamily_args args = new addColumnFamily_args(); + args.setTableName(tableName); + args.setColumn(column); + sendBase("addColumnFamily", args); + } + + public void recv_addColumnFamily() throws TIOError, org.apache.thrift.TException + { + addColumnFamily_result result = new addColumnFamily_result(); + receiveBase(result, "addColumnFamily"); + if (result.io != null) { + throw result.io; + } + return; + } + + public void deleteColumnFamily(TTableName tableName, ByteBuffer column) throws TIOError, org.apache.thrift.TException + { + send_deleteColumnFamily(tableName, column); + recv_deleteColumnFamily(); + } + + public void send_deleteColumnFamily(TTableName tableName, ByteBuffer column) throws org.apache.thrift.TException + { + deleteColumnFamily_args args = new deleteColumnFamily_args(); + args.setTableName(tableName); + args.setColumn(column); + sendBase("deleteColumnFamily", args); + } + + public void recv_deleteColumnFamily() throws TIOError, org.apache.thrift.TException + { + deleteColumnFamily_result result = new deleteColumnFamily_result(); + receiveBase(result, "deleteColumnFamily"); + if (result.io != null) { + throw result.io; + } + return; + } + + public void modifyColumnFamily(TTableName tableName, TColumnFamilyDescriptor column) throws TIOError, org.apache.thrift.TException + { + send_modifyColumnFamily(tableName, column); + recv_modifyColumnFamily(); + } + + public void send_modifyColumnFamily(TTableName tableName, TColumnFamilyDescriptor column) throws org.apache.thrift.TException + { + modifyColumnFamily_args args = new modifyColumnFamily_args(); + args.setTableName(tableName); + args.setColumn(column); + sendBase("modifyColumnFamily", args); + } + + public void recv_modifyColumnFamily() throws TIOError, org.apache.thrift.TException + { + modifyColumnFamily_result result = new modifyColumnFamily_result(); + receiveBase(result, "modifyColumnFamily"); + if (result.io != null) { + throw result.io; + } + return; + } + + public void modifyTable(TTableDescriptor desc) throws TIOError, org.apache.thrift.TException + { + send_modifyTable(desc); + recv_modifyTable(); + } + + public void send_modifyTable(TTableDescriptor desc) throws org.apache.thrift.TException + { + modifyTable_args args = new modifyTable_args(); + args.setDesc(desc); + sendBase("modifyTable", args); + } + + public void recv_modifyTable() throws TIOError, org.apache.thrift.TException + { + modifyTable_result result = new modifyTable_result(); + receiveBase(result, "modifyTable"); + if (result.io != null) { + throw result.io; + } + return; + } + + public void createNamespace(TNamespaceDescriptor namespaceDesc) throws TIOError, org.apache.thrift.TException + { + send_createNamespace(namespaceDesc); + recv_createNamespace(); + } + + public void send_createNamespace(TNamespaceDescriptor namespaceDesc) throws org.apache.thrift.TException + { + createNamespace_args args = new createNamespace_args(); + args.setNamespaceDesc(namespaceDesc); + sendBase("createNamespace", args); + } + + public void recv_createNamespace() throws TIOError, org.apache.thrift.TException + { + createNamespace_result result = new createNamespace_result(); + receiveBase(result, "createNamespace"); + if (result.io != null) { + throw result.io; + } + return; + } + + public void modifyNamespace(TNamespaceDescriptor namespaceDesc) throws TIOError, org.apache.thrift.TException + { + send_modifyNamespace(namespaceDesc); + recv_modifyNamespace(); + } + + public void send_modifyNamespace(TNamespaceDescriptor namespaceDesc) throws org.apache.thrift.TException + { + modifyNamespace_args args = new modifyNamespace_args(); + args.setNamespaceDesc(namespaceDesc); + sendBase("modifyNamespace", args); + } + + public void recv_modifyNamespace() throws TIOError, org.apache.thrift.TException + { + modifyNamespace_result result = new modifyNamespace_result(); + receiveBase(result, "modifyNamespace"); + if (result.io != null) { + throw result.io; + } + return; + } + + public void deleteNamespace(String name) throws TIOError, org.apache.thrift.TException + { + send_deleteNamespace(name); + recv_deleteNamespace(); + } + + public void send_deleteNamespace(String name) throws org.apache.thrift.TException + { + deleteNamespace_args args = new deleteNamespace_args(); + args.setName(name); + sendBase("deleteNamespace", args); + } + + public void recv_deleteNamespace() throws TIOError, org.apache.thrift.TException + { + deleteNamespace_result result = new deleteNamespace_result(); + receiveBase(result, "deleteNamespace"); + if (result.io != null) { + throw result.io; + } + return; + } + + public TNamespaceDescriptor getNamespaceDescriptor(String name) throws TIOError, org.apache.thrift.TException + { + send_getNamespaceDescriptor(name); + return recv_getNamespaceDescriptor(); + } + + public void send_getNamespaceDescriptor(String name) throws org.apache.thrift.TException + { + getNamespaceDescriptor_args args = new getNamespaceDescriptor_args(); + args.setName(name); + sendBase("getNamespaceDescriptor", args); + } + + public TNamespaceDescriptor recv_getNamespaceDescriptor() throws TIOError, org.apache.thrift.TException + { + getNamespaceDescriptor_result result = new getNamespaceDescriptor_result(); + receiveBase(result, "getNamespaceDescriptor"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.io != null) { + throw result.io; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getNamespaceDescriptor failed: unknown result"); + } + + public List<TNamespaceDescriptor> listNamespaceDescriptors() throws TIOError, org.apache.thrift.TException + { + send_listNamespaceDescriptors(); + return recv_listNamespaceDescriptors(); + } + + public void send_listNamespaceDescriptors() throws org.apache.thrift.TException + { + listNamespaceDescriptors_args args = new listNamespaceDescriptors_args(); + sendBase("listNamespaceDescriptors", args); + } + + public List<TNamespaceDescriptor> recv_listNamespaceDescriptors() throws TIOError, org.apache.thrift.TException + { + listNamespaceDescriptors_result result = new listNamespaceDescriptors_result(); + receiveBase(result, "listNamespaceDescriptors"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.io != null) { + throw result.io; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "listNamespaceDescriptors 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> { @@ -1649,544 +2370,840 @@ public class THBaseService { } } - } - - public static class Processor<I extends Iface> extends org.apache.thrift.TBaseProcessor<I> implements org.apache.thrift.TProcessor { - private static final Logger LOGGER = LoggerFactory.getLogger(Processor.class.getName()); - public Processor(I iface) { - super(iface, getProcessMap(new HashMap<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>>())); + public void getTableDescriptor(TTableName table, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + getTableDescriptor_call method_call = new getTableDescriptor_call(table, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); } - protected Processor(I iface, Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) { - super(iface, getProcessMap(processMap)); - } + public static class getTableDescriptor_call extends org.apache.thrift.async.TAsyncMethodCall { + private TTableName table; + public getTableDescriptor_call(TTableName table, 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.table = table; + } - private static <I extends Iface> Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> getProcessMap(Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) { - processMap.put("exists", new exists()); - processMap.put("existsAll", new existsAll()); - processMap.put("get", new get()); - processMap.put("getMultiple", new getMultiple()); - processMap.put("put", new put()); - processMap.put("checkAndPut", new checkAndPut()); - processMap.put("putMultiple", new putMultiple()); - processMap.put("deleteSingle", new deleteSingle()); - processMap.put("deleteMultiple", new deleteMultiple()); - processMap.put("checkAndDelete", new checkAndDelete()); - processMap.put("increment", new increment()); - processMap.put("append", new append()); - processMap.put("openScanner", new openScanner()); - processMap.put("getScannerRows", new getScannerRows()); - processMap.put("closeScanner", new closeScanner()); - processMap.put("mutateRow", new mutateRow()); - processMap.put("getScannerResults", new getScannerResults()); - processMap.put("getRegionLocation", new getRegionLocation()); - processMap.put("getAllRegionLocations", new getAllRegionLocations()); - processMap.put("checkAndMutate", new checkAndMutate()); - return processMap; - } + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getTableDescriptor", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getTableDescriptor_args args = new getTableDescriptor_args(); + args.setTable(table); + args.write(prot); + prot.writeMessageEnd(); + } - public static class exists<I extends Iface> extends org.apache.thrift.ProcessFunction<I, exists_args> { - public exists() { - super("exists"); + public TTableDescriptor getResult() throws TIOError, 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_getTableDescriptor(); } + } - public exists_args getEmptyArgsInstance() { - return new exists_args(); + public void getTableDescriptors(List<TTableName> tables, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + getTableDescriptors_call method_call = new getTableDescriptors_call(tables, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class getTableDescriptors_call extends org.apache.thrift.async.TAsyncMethodCall { + private List<TTableName> tables; + public getTableDescriptors_call(List<TTableName> 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 { + super(client, protocolFactory, transport, resultHandler, false); + this.tables = tables; } - protected boolean isOneway() { - return false; + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getTableDescriptors", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getTableDescriptors_args args = new getTableDescriptors_args(); + args.setTables(tables); + args.write(prot); + prot.writeMessageEnd(); } - public exists_result getResult(I iface, exists_args args) throws org.apache.thrift.TException { - exists_result result = new exists_result(); - try { - result.success = iface.exists(args.table, args.tget); - result.setSuccessIsSet(true); - } catch (TIOError io) { - result.io = io; + public List<TTableDescriptor> getResult() throws TIOError, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); } - return result; + 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_getTableDescriptors(); } } - public static class existsAll<I extends Iface> extends org.apache.thrift.ProcessFunction<I, existsAll_args> { - public existsAll() { - super("existsAll"); - } + public void tableExists(TTableName tableName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + tableExists_call method_call = new tableExists_call(tableName, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } - public existsAll_args getEmptyArgsInstance() { - return new existsAll_args(); + public static class tableExists_call extends org.apache.thrift.async.TAsyncMethodCall { + private TTableName tableName; + public tableExists_call(TTableName 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.tableName = tableName; } - protected boolean isOneway() { - return false; + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("tableExists", org.apache.thrift.protocol.TMessageType.CALL, 0)); + tableExists_args args = new tableExists_args(); + args.setTableName(tableName); + args.write(prot); + prot.writeMessageEnd(); } - public existsAll_result getResult(I iface, existsAll_args args) throws org.apache.thrift.TException { - existsAll_result result = new existsAll_result(); - try { - result.success = iface.existsAll(args.table, args.tgets); - } catch (TIOError io) { - result.io = io; + public boolean getResult() throws TIOError, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); } - return result; + 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_tableExists(); } } - public static class get<I extends Iface> extends org.apache.thrift.ProcessFunction<I, get_args> { - public get() { - super("get"); - } + public void getTableDescriptorsByPattern(String regex, boolean includeSysTables, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + getTableDescriptorsByPattern_call method_call = new getTableDescriptorsByPattern_call(regex, includeSysTables, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } - public get_args getEmptyArgsInstance() { - return new get_args(); + public static class getTableDescriptorsByPattern_call extends org.apache.thrift.async.TAsyncMethodCall { + private String regex; + private boolean includeSysTables; + public getTableDescriptorsByPattern_call(String regex, boolean includeSysTables, 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.regex = regex; + this.includeSysTables = includeSysTables; } - protected boolean isOneway() { - return false; + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getTableDescriptorsByPattern", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getTableDescriptorsByPattern_args args = new getTableDescriptorsByPattern_args(); + args.setRegex(regex); + args.setIncludeSysTables(includeSysTables); + args.write(prot); + prot.writeMessageEnd(); } - public get_result getResult(I iface, get_args args) throws org.apache.thrift.TException { - get_result result = new get_result(); - try { - result.success = iface.get(args.table, args.tget); - } catch (TIOError io) { - result.io = io; + public List<TTableDescriptor> getResult() throws TIOError, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); } - return result; + 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_getTableDescriptorsByPattern(); } } - public static class getMultiple<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getMultiple_args> { - public getMultiple() { - super("getMultiple"); - } + public void getTableDescriptorsByNamespace(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + getTableDescriptorsByNamespace_call method_call = new getTableDescriptorsByNamespace_call(name, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } - public getMultiple_args getEmptyArgsInstance() { - return new getMultiple_args(); + public static class getTableDescriptorsByNamespace_call extends org.apache.thrift.async.TAsyncMethodCall { + private String name; + public getTableDescriptorsByNamespace_call(String name, 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.name = name; } - protected boolean isOneway() { - return false; + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getTableDescriptorsByNamespace", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getTableDescriptorsByNamespace_args args = new getTableDescriptorsByNamespace_args(); + args.setName(name); + args.write(prot); + prot.writeMessageEnd(); } - public getMultiple_result getResult(I iface, getMultiple_args args) throws org.apache.thrift.TException { - getMultiple_result result = new getMultiple_result(); - try { - result.success = iface.getMultiple(args.table, args.tgets); - } catch (TIOError io) { - result.io = io; + public List<TTableDescriptor> getResult() throws TIOError, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); } - return result; + 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_getTableDescriptorsByNamespace(); } } - public static class put<I extends Iface> extends org.apache.thrift.ProcessFunction<I, put_args> { - public put() { - super("put"); - } + public void getTableNamesByPattern(String regex, boolean includeSysTables, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + getTableNamesByPattern_call method_call = new getTableNamesByPattern_call(regex, includeSysTables, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } - public put_args getEmptyArgsInstance() { - return new put_args(); + public static class getTableNamesByPattern_call extends org.apache.thrift.async.TAsyncMethodCall { + private String regex; + private boolean includeSysTables; + public getTableNamesByPattern_call(String regex, boolean includeSysTables, 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.regex = regex; + this.includeSysTables = includeSysTables; } - protected boolean isOneway() { - return false; + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getTableNamesByPattern", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getTableNamesByPattern_args args = new getTableNamesByPattern_args(); + args.setRegex(regex); + args.setIncludeSysTables(includeSysTables); + args.write(prot); + prot.writeMessageEnd(); } - public put_result getResult(I iface, put_args args) throws org.apache.thrift.TException { - put_result result = new put_result(); - try { - iface.put(args.table, args.tput); - } catch (TIOError io) { - result.io = io; + public List<TTableName> getResult() throws TIOError, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); } - return result; + 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_getTableNamesByPattern(); } } - public static class checkAndPut<I extends Iface> extends org.apache.thrift.ProcessFunction<I, checkAndPut_args> { - public checkAndPut() { - super("checkAndPut"); - } + public void getTableNamesByNamespace(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + getTableNamesByNamespace_call method_call = new getTableNamesByNamespace_call(name, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } - public checkAndPut_args getEmptyArgsInstance() { - return new checkAndPut_args(); + public static class getTableNamesByNamespace_call extends org.apache.thrift.async.TAsyncMethodCall { + private String name; + public getTableNamesByNamespace_call(String name, 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.name = name; } - protected boolean isOneway() { - return false; + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getTableNamesByNamespace", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getTableNamesByNamespace_args args = new getTableNamesByNamespace_args(); + args.setName(name); + args.write(prot); + prot.writeMessageEnd(); } - public checkAndPut_result getResult(I iface, checkAndPut_args args) throws org.apache.thrift.TException { - checkAndPut_result result = new checkAndPut_result(); - try { - result.success = iface.checkAndPut(args.table, args.row, args.family, args.qualifier, args.value, args.tput); - result.setSuccessIsSet(true); - } catch (TIOError io) { - result.io = io; + public List<TTableName> getResult() throws TIOError, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); } - return result; + 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_getTableNamesByNamespace(); } } - public static class putMultiple<I extends Iface> extends org.apache.thrift.ProcessFunction<I, putMultiple_args> { - public putMultiple() { - super("putMultiple"); - } + public void createTable(TTableDescriptor desc, List<ByteBuffer> splitKeys, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + createTable_call method_call = new createTable_call(desc, splitKeys, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } - public putMultiple_args getEmptyArgsInstance() { - return new putMultiple_args(); + public static class createTable_call extends org.apache.thrift.async.TAsyncMethodCall { + private TTableDescriptor desc; + private List<ByteBuffer> splitKeys; + public createTable_call(TTableDescriptor desc, List<ByteBuffer> splitKeys, 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.desc = desc; + this.splitKeys = splitKeys; } - protected boolean isOneway() { - return false; + 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(); + args.setDesc(desc); + args.setSplitKeys(splitKeys); + args.write(prot); + prot.writeMessageEnd(); } - public putMultiple_result getResult(I iface, putMultiple_args args) throws org.apache.thrift.TException { - putMultiple_result result = new putMultiple_result(); - try { - iface.putMultiple(args.table, args.tputs); - } catch (TIOError io) { - result.io = io; + public void getResult() throws TIOError, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); } - return result; + 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(); } } - public static class deleteSingle<I extends Iface> extends org.apache.thrift.ProcessFunction<I, deleteSingle_args> { - public deleteSingle() { - super("deleteSingle"); - } + public void deleteTable(TTableName tableName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + deleteTable_call method_call = new deleteTable_call(tableName, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } - public deleteSingle_args getEmptyArgsInstance() { - return new deleteSingle_args(); + public static class deleteTable_call extends org.apache.thrift.async.TAsyncMethodCall { + private TTableName tableName; + public deleteTable_call(TTableName 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.tableName = tableName; } - protected boolean isOneway() { - return false; + 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(); + args.setTableName(tableName); + args.write(prot); + prot.writeMessageEnd(); } - public deleteSingle_result getResult(I iface, deleteSingle_args args) throws org.apache.thrift.TException { - deleteSingle_result result = new deleteSingle_result(); - try { - iface.deleteSingle(args.table, args.tdelete); - } catch (TIOError io) { - result.io = io; + public void getResult() throws TIOError, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); } - return result; + 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(); } } - public static class deleteMultiple<I extends Iface> extends org.apache.thrift.ProcessFunction<I, deleteMultiple_args> { - public deleteMultiple() { - super("deleteMultiple"); - } + public void truncateTable(TTableName tableName, boolean preserveSplits, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + truncateTable_call method_call = new truncateTable_call(tableName, preserveSplits, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } - public deleteMultiple_args getEmptyArgsInstance() { - return new deleteMultiple_args(); + public static class truncateTable_call extends org.apache.thrift.async.TAsyncMethodCall { + private TTableName tableName; + private boolean preserveSplits; + public truncateTable_call(TTableName tableName, boolean preserveSplits, 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.tableName = tableName; + this.preserveSplits = preserveSplits; } - protected boolean isOneway() { - return false; + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("truncateTable", org.apache.thrift.protocol.TMessageType.CALL, 0)); + truncateTable_args args = new truncateTable_args(); + args.setTableName(tableName); + args.setPreserveSplits(preserveSplits); + args.write(prot); + prot.writeMessageEnd(); } - public deleteMultiple_result getResult(I iface, deleteMultiple_args args) throws org.apache.thrift.TException { - deleteMultiple_result result = new deleteMultiple_result(); - try { - result.success = iface.deleteMultiple(args.table, args.tdeletes); - } catch (TIOError io) { - result.io = io; + public void getResult() throws TIOError, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); } - return result; + 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_truncateTable(); } } - public static class checkAndDelete<I extends Iface> extends org.apache.thrift.ProcessFunction<I, checkAndDelete_args> { - public checkAndDelete() { - super("checkAndDelete"); - } + public void enableTable(TTableName tableName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + enableTable_call method_call = new enableTable_call(tableName, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } - public checkAndDelete_args getEmptyArgsInstance() { - return new checkAndDelete_args(); + public static class enableTable_call extends org.apache.thrift.async.TAsyncMethodCall { + private TTableName tableName; + public enableTable_call(TTableName 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.tableName = tableName; } - protected boolean isOneway() { - return false; + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("enableTable", org.apache.thrift.protocol.TMessageType.CALL, 0)); + enableTable_args args = new enableTable_args(); + args.setTableName(tableName); + args.write(prot); + prot.writeMessageEnd(); } - public checkAndDelete_result getResult(I iface, checkAndDelete_args args) throws org.apache.thrift.TException { - checkAndDelete_result result = new checkAndDelete_result(); - try { - result.success = iface.checkAndDelete(args.table, args.row, args.family, args.qualifier, args.value, args.tdelete); - result.setSuccessIsSet(true); - } catch (TIOError io) { - result.io = io; + public void getResult() throws TIOError, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); } - return result; + 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_enableTable(); } } - public static class increment<I extends Iface> extends org.apache.thrift.ProcessFunction<I, increment_args> { - public increment() { - super("increment"); - } + public void disableTable(TTableName tableName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + disableTable_call method_call = new disableTable_call(tableName, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } - public increment_args getEmptyArgsInstance() { - return new increment_args(); + public static class disableTable_call extends org.apache.thrift.async.TAsyncMethodCall { + private TTableName tableName; + public disableTable_call(TTableName 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.tableName = tableName; } - protected boolean isOneway() { - return false; + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("disableTable", org.apache.thrift.protocol.TMessageType.CALL, 0)); + disableTable_args args = new disableTable_args(); + args.setTableName(tableName); + args.write(prot); + prot.writeMessageEnd(); } - public increment_result getResult(I iface, increment_args args) throws org.apache.thrift.TException { - increment_result result = new increment_result(); - try { - result.success = iface.increment(args.table, args.tincrement); - } catch (TIOError io) { - result.io = io; + public void getResult() throws TIOError, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); } - return result; + 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_disableTable(); } } - public static class append<I extends Iface> extends org.apache.thrift.ProcessFunction<I, append_args> { - public append() { - super("append"); - } + public void isTableEnabled(TTableName tableName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + isTableEnabled_call method_call = new isTableEnabled_call(tableName, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } - public append_args getEmptyArgsInstance() { - return new append_args(); + public static class isTableEnabled_call extends org.apache.thrift.async.TAsyncMethodCall { + private TTableName tableName; + public isTableEnabled_call(TTableName 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.tableName = tableName; } - protected boolean isOneway() { - return false; + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("isTableEnabled", org.apache.thrift.protocol.TMessageType.CALL, 0)); + isTableEnabled_args args = new isTableEnabled_args(); + args.setTableName(tableName); + args.write(prot); + prot.writeMessageEnd(); } - public append_result getResult(I iface, append_args args) throws org.apache.thrift.TException { - append_result result = new append_result(); - try { - result.success = iface.append(args.table, args.tappend); - } catch (TIOError io) { - result.io = io; + public boolean getResult() throws TIOError, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); } - return result; + 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_isTableEnabled(); } } - public static class openScanner<I extends Iface> extends org.apache.thrift.ProcessFunction<I, openScanner_args> { - public openScanner() { - super("openScanner"); - } + public void isTableDisabled(TTableName tableName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + isTableDisabled_call method_call = new isTableDisabled_call(tableName, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } - public openScanner_args getEmptyArgsInstance() { - return new openScanner_args(); + public static class isTableDisabled_call extends org.apache.thrift.async.TAsyncMethodCall { + private TTableName tableName; + public isTableDisabled_call(TTableName 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.tableName = tableName; } - protected boolean isOneway() { - return false; + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("isTableDisabled", org.apache.thrift.protocol.TMessageType.CALL, 0)); + isTableDisabled_args args = new isTableDisabled_args(); + args.setTableName(tableName); + args.write(prot); + prot.writeMessageEnd(); } - public openScanner_result getResult(I iface, openScanner_args args) throws org.apache.thrift.TException { - openScanner_result result = new openScanner_result(); - try { - result.success = iface.openScanner(args.table, args.tscan); - result.setSuccessIsSet(true); - } catch (TIOError io) { - result.io = io; + public boolean getResult() throws TIOError, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); } - return result; + 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_isTableDisabled(); } } - public static class getScannerRows<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getScannerRows_args> { - public getScannerRows() { - super("getScannerRows"); - } + public void isTableAvailable(TTableName tableName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + isTableAvailable_call method_call = new isTableAvailable_call(tableName, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } - public getScannerRows_args getEmptyArgsInstance() { - return new getScannerRows_args(); + public static class isTableAvailable_call extends org.apache.thrift.async.TAsyncMethodCall { + private TTableName tableName; + public isTableAvailable_call(TTableName 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.tableName = tableName; } - protected boolean isOneway() { - return false; + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("isTableAvailable", org.apache.thrift.protocol.TMessageType.CALL, 0)); + isTableAvailable_args args = new isTableAvailable_args(); + args.setTableName(tableName); + args.write(prot); + prot.writeMessageEnd(); } - public getScannerRows_result getResult(I iface, getScannerRows_args args) throws org.apache.thrift.TException { - getScannerRows_result result = new getScannerRows_result(); - try { - result.success = iface.getScannerRows(args.scannerId, args.numRows); - } catch (TIOError io) { - result.io = io; - } catch (TIllegalArgument ia) { - result.ia = ia; + public boolean getResult() throws TIOError, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); } - return result; + 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_isTableAvailable(); } } - public static class closeScanner<I extends Iface> extends org.apache.thrift.ProcessFunction<I, closeScanner_args> { - public closeScanner() { - super("closeScanner"); - } + public void isTableAvailableWithSplit(TTableName tableName, List<ByteBuffer> splitKeys, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + isTableAvailableWithSplit_call method_call = new isTableAvailableWithSplit_call(tableName, splitKeys, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } - public closeScanner_args getEmptyArgsInstance() { - return new closeScanner_args(); + public static class isTableAvailableWithSplit_call extends org.apache.thrift.async.TAsyncMethodCall { + private TTableName tableName; + private List<ByteBuffer> splitKeys; + public isTableAvailableWithSplit_call(TTableName tableName, List<ByteBuffer> splitKeys, 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.tableName = tableName; + this.splitKeys = splitKeys; } - protected boolean isOneway() { - return false; + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("isTableAvailableWithSplit", org.apache.thrift.protocol.TMessageType.CALL, 0)); + isTableAvailableWithSplit_args args = new isTableAvailableWithSplit_args(); + args.setTableName(tableName); + args.setSplitKeys(splitKeys); + args.write(prot); + prot.writeMessageEnd(); } - public closeScanner_result getResult(I iface, closeScanner_args args) throws org.apache.thrift.TException { - closeScanner_result result = new closeScanner_result(); - try { - iface.closeScanner(args.scannerId); - } catch (TIOError io) { - result.io = io; - } catch (TIllegalArgument ia) { - result.ia = ia; + public boolean getResult() throws TIOError, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); } - return result; + 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_isTableAvailableWithSplit(); } } - public static class mutateRow<I extends Iface> extends org.apache.thrift.ProcessFunction<I, mutateRow_args> { - public mutateRow() { - super("mutateRow"); - } + public void addColumnFamily(TTableName tableName, TColumnFamilyDescriptor column, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + addColumnFamily_call method_call = new addColumnFamily_call(tableName, column, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } - public mutateRow_args getEmptyArgsInstance() { - return new mutateRow_args(); + public static class addColumnFamily_call extends org.apache.thrift.async.TAsyncMethodCall { + private TTableName tableName; + private TColumnFamilyDescriptor column; + public addColumnFamily_call(TTableName tableName, TColumnFamilyDescriptor column, 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.tableName = tableName; + this.column = column; } - protected boolean isOneway() { - return false; + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("addColumnFamily", org.apache.thrift.protocol.TMessageType.CALL, 0)); + addColumnFamily_args args = new addColumnFamily_args(); + args.setTableName(tableName); + args.setColumn(column); + args.write(prot); + prot.writeMessageEnd(); } - public mutateRow_result getResult(I iface, mutateRow_args args) throws org.apache.thrift.TException { - mutateRow_result result = new mutateRow_result(); - try { - iface.mutateRow(args.table, args.trowMutations); - } catch (TIOError io) { - result.io = io; + public void getResult() throws TIOError, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); } - return result; + 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_addColumnFamily(); } } - public static class getScannerResults<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getScannerResults_args> { - public getScannerResults() { - super("getScannerResults"); - } + public void deleteColumnFamily(TTableName tableName, ByteBuffer column, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + deleteColumnFamily_call method_call = new deleteColumnFamily_call(tableName, column, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } - public getScannerResults_args getEmptyArgsInstance() { - return new getScannerResults_args(); + public static class deleteColumnFamily_call extends org.apache.thrift.async.TAsyncMethodCall { + private TTableName tableName; + private ByteBuffer column; + public deleteColumnFamily_call(TTableName tableName, ByteBuffer column, 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.tableName = tableName; + this.column = column; } - protected boolean isOneway() { - return false; + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("deleteColumnFamily", org.apache.thrift.protocol.TMessageType.CALL, 0)); + deleteColumnFamily_args args = new deleteColumnFamily_args(); + args.setTableName(tableName); + args.setColumn(column); + args.write(prot); + prot.writeMessageEnd(); } - public getScannerResults_result getResult(I iface, getScannerResults_args args) throws org.apache.thrift.TException { - getScannerResults_result result = new getScannerResults_result(); - try { - result.success = iface.getScannerResults(args.table, args.tscan, args.numRows); - } catch (TIOError io) { - result.io = io; + public void getResult() throws TIOError, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); } - return result; + 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_deleteColumnFamily(); } } - public static class getRegionLocation<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getRegionLocation_args> { - public getRegionLocation() { - super("getRegionLocation"); + public void modifyColumnFamily(TTableName tableName, TColumnFamilyDescriptor column, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + modifyColumnFamily_call method_call = new modifyColumnFamily_call(tableName, column, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class modifyColumnFamily_call extends org.apache.thrift.async.TAsyncMethodCall { + private TTableName tableName; + private TColumnFamilyDescriptor column; + public modifyColumnFamily_call(TTableName tableName, TColumnFamilyDescriptor column, 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.tableName = tableName; + this.column = column; } - public getRegionLocation_args getEmptyArgsInstance() { - return new getRegionLocation_args(); + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("modifyColumnFamily", org.apache.thrift.protocol.TMessageType.CALL, 0)); + modifyColumnFamily_args args = new modifyColumnFamily_args(); + args.setTableName(tableName); + args.setColumn(column); + args.write(prot); + prot.writeMessageEnd(); } - protected boolean isOneway() { - return false; + public void getResult() throws TIOError, 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_modifyColumnFamily(); } + } - public getRegionLocation_result getResult(I iface, getRegionLocation_args args) throws org.apache.thrift.TException { - getRegionLocation_result result = new getRegionLocation_result(); - try { - result.success = iface.getRegionLocation(args.table, args.row, args.reload); - } catch (TIOError io) { - result.io = io; + public void modifyTable(TTableDescriptor desc, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + modifyTable_call method_call = new modifyTable_call(desc, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class modifyTable_call extends org.apache.thrift.async.TAsyncMethodCall { + private TTableDescriptor desc; + public modifyTable_call(TTableDescriptor desc, 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.desc = desc; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("modifyTable", org.apache.thrift.protocol.TMessageType.CALL, 0)); + modifyTable_args args = new modifyTable_args(); + args.setDesc(desc); + args.write(prot); + prot.writeMessageEnd(); + } + + public void getResult() throws TIOError, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); } - return result; + 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_modifyTable(); } } - public static class getAllRegionLocations<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getAllRegionLocations_args> { - public getAllRegionLocations() { - super("getAllRegionLocations"); + public void createNamespace(TNamespaceDescriptor namespaceDesc, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + createNamespace_call method_call = new createNamespace_call(namespaceDesc, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class createNamespace_call extends org.apache.thrift.async.TAsyncMethodCall { +
<TRUNCATED>
