You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by zh...@apache.org on 2018/12/31 12:46:13 UTC
[37/47] hbase git commit: HBASE-21650 Add DDL operation and some
other miscellaneous to thrift2
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>