hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nspiegelb...@apache.org
Subject svn commit: r1181930 [2/3] - in /hbase/branches/0.89: ./ src/main/java/org/apache/hadoop/hbase/thrift/ src/main/java/org/apache/hadoop/hbase/thrift/generated/ src/test/java/org/apache/hadoop/hbase/thrift/
Date Tue, 11 Oct 2011 17:42:44 GMT
Modified: hbase/branches/0.89/src/main/java/org/apache/hadoop/hbase/thrift/generated/Hbase.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.89/src/main/java/org/apache/hadoop/hbase/thrift/generated/Hbase.java?rev=1181930&r1=1181929&r2=1181930&view=diff
==============================================================================
--- hbase/branches/0.89/src/main/java/org/apache/hadoop/hbase/thrift/generated/Hbase.java (original)
+++ hbase/branches/0.89/src/main/java/org/apache/hadoop/hbase/thrift/generated/Hbase.java Tue Oct 11 17:42:43 2011
@@ -1,10 +1,23 @@
 /**
- * Autogenerated by Thrift
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
- * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
 package org.apache.hadoop.hbase.thrift.generated;
 
+import org.apache.commons.lang.builder.HashCodeBuilder;
 import java.util.List;
 import java.util.ArrayList;
 import java.util.Map;
@@ -15,15 +28,12 @@ import java.util.HashSet;
 import java.util.EnumSet;
 import java.util.Collections;
 import java.util.BitSet;
-import java.nio.ByteBuffer;
 import java.util.Arrays;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import org.apache.thrift.*;
-import org.apache.thrift.async.*;
 import org.apache.thrift.meta_data.*;
-import org.apache.thrift.transport.*;
 import org.apache.thrift.protocol.*;
 
 public class Hbase {
@@ -35,7 +45,7 @@ public class Hbase {
      *
      * @param tableName name of the table
      */
-    public void enableTable(ByteBuffer tableName) throws IOError, TException;
+    public void enableTable(byte[] tableName) throws IOError, TException;
 
     /**
      * Disables a table (takes it off-line) If it is being served, the master
@@ -43,43 +53,40 @@ public class Hbase {
      *
      * @param tableName name of the table
      */
-    public void disableTable(ByteBuffer tableName) throws IOError, TException;
+    public void disableTable(byte[] tableName) throws IOError, TException;
 
     /**
      * @return true if table is on-line
      *
      * @param tableName name of the table to check
      */
-    public boolean isTableEnabled(ByteBuffer tableName) throws IOError, TException;
+    public boolean isTableEnabled(byte[] tableName) throws IOError, TException;
 
-    public void compact(ByteBuffer tableNameOrRegionName) throws IOError, TException;
+    public void compact(byte[] tableNameOrRegionName) throws IOError, TException;
 
-    public void majorCompact(ByteBuffer tableNameOrRegionName) throws IOError, TException;
+    public void majorCompact(byte[] tableNameOrRegionName) throws IOError, TException;
 
     /**
      * List all the userspace tables.
-     *
      * @return returns a list of names
      */
-    public List<ByteBuffer> getTableNames() throws IOError, TException;
+    public List<byte[]> getTableNames() throws IOError, TException;
 
     /**
      * List all the column families assoicated with a table.
-     *
      * @return list of column family descriptors
      *
      * @param tableName table name
      */
-    public Map<ByteBuffer,ColumnDescriptor> getColumnDescriptors(ByteBuffer tableName) throws IOError, TException;
+    public Map<byte[],ColumnDescriptor> getColumnDescriptors(byte[] tableName) throws IOError, TException;
 
     /**
      * List the regions associated with a table.
-     *
      * @return list of region descriptors
      *
      * @param tableName table name
      */
-    public List<TRegionInfo> getTableRegions(ByteBuffer tableName) throws IOError, TException;
+    public List<TRegionInfo> getTableRegions(byte[] tableName) throws IOError, TException;
 
     /**
      * Create a table with the specified column families.  The name
@@ -88,14 +95,13 @@ public class Hbase {
      * values if not explicitly specified.
      *
      * @throws IllegalArgument if an input parameter is invalid
-     *
      * @throws AlreadyExists if the table name already exists
      *
      * @param tableName name of table to create
      *
      * @param columnFamilies list of column family descriptors
      */
-    public void createTable(ByteBuffer tableName, List<ColumnDescriptor> columnFamilies) throws IOError, IllegalArgument, AlreadyExists, TException;
+    public void createTable(byte[] tableName, List<ColumnDescriptor> columnFamilies) throws IOError, IllegalArgument, AlreadyExists, TException;
 
     /**
      * Deletes a table
@@ -105,7 +111,7 @@ public class Hbase {
      *
      * @param tableName name of table to delete
      */
-    public void deleteTable(ByteBuffer tableName) throws IOError, TException;
+    public void deleteTable(byte[] tableName) throws IOError, TException;
 
     /**
      * Get a single TCell for the specified table, row, and column at the
@@ -119,7 +125,7 @@ public class Hbase {
      *
      * @param column column name
      */
-    public List<TCell> get(ByteBuffer tableName, ByteBuffer row, ByteBuffer column) throws IOError, TException;
+    public List<TCell> get(byte[] tableName, byte[] row, byte[] column) throws IOError, TException;
 
     /**
      * Get the specified number of versions for the specified table,
@@ -135,7 +141,7 @@ public class Hbase {
      *
      * @param numVersions number of versions to retrieve
      */
-    public List<TCell> getVer(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, int numVersions) throws IOError, TException;
+    public List<TCell> getVer(byte[] tableName, byte[] row, byte[] column, int numVersions) throws IOError, TException;
 
     /**
      * Get the specified number of versions for the specified table,
@@ -154,7 +160,7 @@ public class Hbase {
      *
      * @param numVersions number of versions to retrieve
      */
-    public List<TCell> getVerTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, int numVersions) throws IOError, TException;
+    public List<TCell> getVerTs(byte[] tableName, byte[] row, byte[] column, long timestamp, int numVersions) throws IOError, TException;
 
     /**
      * Get all the data for the specified table and row at the latest
@@ -166,7 +172,7 @@ public class Hbase {
      *
      * @param row row key
      */
-    public List<TRowResult> getRow(ByteBuffer tableName, ByteBuffer row) throws IOError, TException;
+    public List<TRowResult> getRow(byte[] tableName, byte[] row) throws IOError, TException;
 
     /**
      * Get the specified columns for the specified table and row at the latest
@@ -180,7 +186,7 @@ public class Hbase {
      *
      * @param columns List of columns to return, null for all columns
      */
-    public List<TRowResult> getRowWithColumns(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns) throws IOError, TException;
+    public List<TRowResult> getRowWithColumns(byte[] tableName, byte[] row, List<byte[]> columns) throws IOError, TException;
 
     /**
      * Get all the data for the specified table and row at the specified
@@ -194,7 +200,7 @@ public class Hbase {
      *
      * @param timestamp timestamp
      */
-    public List<TRowResult> getRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp) throws IOError, TException;
+    public List<TRowResult> getRowTs(byte[] tableName, byte[] row, long timestamp) throws IOError, TException;
 
     /**
      * Get the specified columns for the specified table and row at the specified
@@ -210,7 +216,7 @@ public class Hbase {
      *
      * @param timestamp
      */
-    public List<TRowResult> getRowWithColumnsTs(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, long timestamp) throws IOError, TException;
+    public List<TRowResult> getRowWithColumnsTs(byte[] tableName, byte[] row, List<byte[]> columns, long timestamp) throws IOError, TException;
 
     /**
      * Apply a series of mutations (updates/deletes) to a row in a
@@ -224,7 +230,7 @@ public class Hbase {
      *
      * @param mutations list of mutation commands
      */
-    public void mutateRow(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations) throws IOError, IllegalArgument, TException;
+    public void mutateRow(byte[] tableName, byte[] row, List<Mutation> mutations) throws IOError, IllegalArgument, TException;
 
     /**
      * Apply a series of mutations (updates/deletes) to a row in a
@@ -240,7 +246,7 @@ public class Hbase {
      *
      * @param timestamp timestamp
      */
-    public void mutateRowTs(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, long timestamp) throws IOError, IllegalArgument, TException;
+    public void mutateRowTs(byte[] tableName, byte[] row, List<Mutation> mutations, long timestamp) throws IOError, IllegalArgument, TException;
 
     /**
      * Apply a series of batches (each a series of mutations on a single row)
@@ -252,7 +258,7 @@ public class Hbase {
      *
      * @param rowBatches list of row batches
      */
-    public void mutateRows(ByteBuffer tableName, List<BatchMutation> rowBatches) throws IOError, IllegalArgument, TException;
+    public void mutateRows(byte[] tableName, List<BatchMutation> rowBatches) throws IOError, IllegalArgument, TException;
 
     /**
      * Apply a series of batches (each a series of mutations on a single row)
@@ -266,7 +272,7 @@ public class Hbase {
      *
      * @param timestamp timestamp
      */
-    public void mutateRowsTs(ByteBuffer tableName, List<BatchMutation> rowBatches, long timestamp) throws IOError, IllegalArgument, TException;
+    public void mutateRowsTs(byte[] tableName, List<BatchMutation> rowBatches, long timestamp) throws IOError, IllegalArgument, TException;
 
     /**
      * Atomically increment the column value specified.  Returns the next value post increment.
@@ -279,7 +285,7 @@ public class Hbase {
      *
      * @param value amount to increment by
      */
-    public long atomicIncrement(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long value) throws IOError, IllegalArgument, TException;
+    public long atomicIncrement(byte[] tableName, byte[] row, byte[] column, long value) throws IOError, IllegalArgument, TException;
 
     /**
      * Delete all cells that match the passed row and column.
@@ -290,7 +296,7 @@ public class Hbase {
      *
      * @param column name of column whose value is to be deleted
      */
-    public void deleteAll(ByteBuffer tableName, ByteBuffer row, ByteBuffer column) throws IOError, TException;
+    public void deleteAll(byte[] tableName, byte[] row, byte[] column) throws IOError, TException;
 
     /**
      * Delete all cells that match the passed row and column and whose
@@ -304,7 +310,7 @@ public class Hbase {
      *
      * @param timestamp timestamp
      */
-    public void deleteAllTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp) throws IOError, TException;
+    public void deleteAllTs(byte[] tableName, byte[] row, byte[] column, long timestamp) throws IOError, TException;
 
     /**
      * Completely delete the row's cells.
@@ -313,7 +319,7 @@ public class Hbase {
      *
      * @param row key of the row to be completely deleted.
      */
-    public void deleteAllRow(ByteBuffer tableName, ByteBuffer row) throws IOError, TException;
+    public void deleteAllRow(byte[] tableName, byte[] row) throws IOError, TException;
 
     /**
      * Completely delete the row's cells marked with a timestamp
@@ -325,7 +331,7 @@ public class Hbase {
      *
      * @param timestamp timestamp
      */
-    public void deleteAllRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp) throws IOError, TException;
+    public void deleteAllRowTs(byte[] tableName, byte[] row, long timestamp) throws IOError, TException;
 
     /**
      * Get a scanner on the current table starting at the specified row and
@@ -342,7 +348,7 @@ public class Hbase {
      * columns of the specified column family are returned. It's also possible
      * to pass a regex in the column qualifier.
      */
-    public int scannerOpen(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns) throws IOError, TException;
+    public int scannerOpen(byte[] tableName, byte[] startRow, List<byte[]> columns) throws IOError, TException;
 
     /**
      * Get a scanner on the current table starting and stopping at the
@@ -363,7 +369,7 @@ public class Hbase {
      * columns of the specified column family are returned. It's also possible
      * to pass a regex in the column qualifier.
      */
-    public int scannerOpenWithStop(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns) throws IOError, TException;
+    public int scannerOpenWithStop(byte[] tableName, byte[] startRow, byte[] stopRow, List<byte[]> columns) throws IOError, TException;
 
     /**
      * Open a scanner for a given prefix.  That is all rows will have the specified
@@ -377,7 +383,7 @@ public class Hbase {
      *
      * @param columns the columns you want returned
      */
-    public int scannerOpenWithPrefix(ByteBuffer tableName, ByteBuffer startAndPrefix, List<ByteBuffer> columns) throws IOError, TException;
+    public int scannerOpenWithPrefix(byte[] tableName, byte[] startAndPrefix, List<byte[]> columns) throws IOError, TException;
 
     /**
      * Get a scanner on the current table starting at the specified row and
@@ -397,7 +403,7 @@ public class Hbase {
      *
      * @param timestamp timestamp
      */
-    public int scannerOpenTs(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, long timestamp) throws IOError, TException;
+    public int scannerOpenTs(byte[] tableName, byte[] startRow, List<byte[]> columns, long timestamp) throws IOError, TException;
 
     /**
      * Get a scanner on the current table starting and stopping at the
@@ -421,7 +427,7 @@ public class Hbase {
      *
      * @param timestamp timestamp
      */
-    public int scannerOpenWithStopTs(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, long timestamp) throws IOError, TException;
+    public int scannerOpenWithStopTs(byte[] tableName, byte[] startRow, byte[] stopRow, List<byte[]> columns, long timestamp) throws IOError, TException;
 
     /**
      * Returns the scanner's current row value and advances to the next
@@ -430,9 +436,7 @@ public class Hbase {
      * an empty list is returned.
      *
      * @return a TRowResult containing the current row and a map of the columns to TCells.
-     *
      * @throws IllegalArgument if ScannerID is invalid
-     *
      * @throws NotFound when the scanner reaches the end
      *
      * @param id id of a scanner returned by scannerOpen
@@ -446,9 +450,7 @@ public class Hbase {
      * specified stopRow is reached,  an empty list is returned.
      *
      * @return a TRowResult containing the current row and a map of the columns to TCells.
-     *
      * @throws IllegalArgument if ScannerID is invalid
-     *
      * @throws NotFound when the scanner reaches the end
      *
      * @param id id of a scanner returned by scannerOpen
@@ -468,89 +470,7 @@ public class Hbase {
 
   }
 
-  public interface AsyncIface {
-
-    public void enableTable(ByteBuffer tableName, AsyncMethodCallback<AsyncClient.enableTable_call> resultHandler) throws TException;
-
-    public void disableTable(ByteBuffer tableName, AsyncMethodCallback<AsyncClient.disableTable_call> resultHandler) throws TException;
-
-    public void isTableEnabled(ByteBuffer tableName, AsyncMethodCallback<AsyncClient.isTableEnabled_call> resultHandler) throws TException;
-
-    public void compact(ByteBuffer tableNameOrRegionName, AsyncMethodCallback<AsyncClient.compact_call> resultHandler) throws TException;
-
-    public void majorCompact(ByteBuffer tableNameOrRegionName, AsyncMethodCallback<AsyncClient.majorCompact_call> resultHandler) throws TException;
-
-    public void getTableNames(AsyncMethodCallback<AsyncClient.getTableNames_call> resultHandler) throws TException;
-
-    public void getColumnDescriptors(ByteBuffer tableName, AsyncMethodCallback<AsyncClient.getColumnDescriptors_call> resultHandler) throws TException;
-
-    public void getTableRegions(ByteBuffer tableName, AsyncMethodCallback<AsyncClient.getTableRegions_call> resultHandler) throws TException;
-
-    public void createTable(ByteBuffer tableName, List<ColumnDescriptor> columnFamilies, AsyncMethodCallback<AsyncClient.createTable_call> resultHandler) throws TException;
-
-    public void deleteTable(ByteBuffer tableName, AsyncMethodCallback<AsyncClient.deleteTable_call> resultHandler) throws TException;
-
-    public void get(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, AsyncMethodCallback<AsyncClient.get_call> resultHandler) throws TException;
-
-    public void getVer(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, int numVersions, AsyncMethodCallback<AsyncClient.getVer_call> resultHandler) throws TException;
-
-    public void getVerTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, int numVersions, AsyncMethodCallback<AsyncClient.getVerTs_call> resultHandler) throws TException;
-
-    public void getRow(ByteBuffer tableName, ByteBuffer row, AsyncMethodCallback<AsyncClient.getRow_call> resultHandler) throws TException;
-
-    public void getRowWithColumns(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, AsyncMethodCallback<AsyncClient.getRowWithColumns_call> resultHandler) throws TException;
-
-    public void getRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, AsyncMethodCallback<AsyncClient.getRowTs_call> resultHandler) throws TException;
-
-    public void getRowWithColumnsTs(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, long timestamp, AsyncMethodCallback<AsyncClient.getRowWithColumnsTs_call> resultHandler) throws TException;
-
-    public void mutateRow(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, AsyncMethodCallback<AsyncClient.mutateRow_call> resultHandler) throws TException;
-
-    public void mutateRowTs(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, long timestamp, AsyncMethodCallback<AsyncClient.mutateRowTs_call> resultHandler) throws TException;
-
-    public void mutateRows(ByteBuffer tableName, List<BatchMutation> rowBatches, AsyncMethodCallback<AsyncClient.mutateRows_call> resultHandler) throws TException;
-
-    public void mutateRowsTs(ByteBuffer tableName, List<BatchMutation> rowBatches, long timestamp, AsyncMethodCallback<AsyncClient.mutateRowsTs_call> resultHandler) throws TException;
-
-    public void atomicIncrement(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long value, AsyncMethodCallback<AsyncClient.atomicIncrement_call> resultHandler) throws TException;
-
-    public void deleteAll(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, AsyncMethodCallback<AsyncClient.deleteAll_call> resultHandler) throws TException;
-
-    public void deleteAllTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, AsyncMethodCallback<AsyncClient.deleteAllTs_call> resultHandler) throws TException;
-
-    public void deleteAllRow(ByteBuffer tableName, ByteBuffer row, AsyncMethodCallback<AsyncClient.deleteAllRow_call> resultHandler) throws TException;
-
-    public void deleteAllRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, AsyncMethodCallback<AsyncClient.deleteAllRowTs_call> resultHandler) throws TException;
-
-    public void scannerOpen(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, AsyncMethodCallback<AsyncClient.scannerOpen_call> resultHandler) throws TException;
-
-    public void scannerOpenWithStop(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, AsyncMethodCallback<AsyncClient.scannerOpenWithStop_call> resultHandler) throws TException;
-
-    public void scannerOpenWithPrefix(ByteBuffer tableName, ByteBuffer startAndPrefix, List<ByteBuffer> columns, AsyncMethodCallback<AsyncClient.scannerOpenWithPrefix_call> resultHandler) throws TException;
-
-    public void scannerOpenTs(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, long timestamp, AsyncMethodCallback<AsyncClient.scannerOpenTs_call> resultHandler) throws TException;
-
-    public void scannerOpenWithStopTs(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, long timestamp, AsyncMethodCallback<AsyncClient.scannerOpenWithStopTs_call> resultHandler) throws TException;
-
-    public void scannerGet(int id, AsyncMethodCallback<AsyncClient.scannerGet_call> resultHandler) throws TException;
-
-    public void scannerGetList(int id, int nbRows, AsyncMethodCallback<AsyncClient.scannerGetList_call> resultHandler) throws TException;
-
-    public void scannerClose(int id, AsyncMethodCallback<AsyncClient.scannerClose_call> resultHandler) throws TException;
-
-  }
-
-  public static class Client implements TServiceClient, Iface {
-    public static class Factory implements TServiceClientFactory<Client> {
-      public Factory() {}
-      public Client getClient(TProtocol prot) {
-        return new Client(prot);
-      }
-      public Client getClient(TProtocol iprot, TProtocol oprot) {
-        return new Client(iprot, oprot);
-      }
-    }
-
+  public static class Client implements Iface {
     public Client(TProtocol prot)
     {
       this(prot, prot);
@@ -577,17 +497,17 @@ public class Hbase {
       return this.oprot_;
     }
 
-    public void enableTable(ByteBuffer tableName) throws IOError, TException
+    public void enableTable(byte[] tableName) throws IOError, TException
     {
       send_enableTable(tableName);
       recv_enableTable();
     }
 
-    public void send_enableTable(ByteBuffer tableName) throws TException
+    public void send_enableTable(byte[] tableName) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("enableTable", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("enableTable", TMessageType.CALL, seqid_));
       enableTable_args args = new enableTable_args();
-      args.setTableName(tableName);
+      args.tableName = tableName;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -601,9 +521,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "enableTable failed: out of sequence response");
-      }
       enableTable_result result = new enableTable_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -613,17 +530,17 @@ public class Hbase {
       return;
     }
 
-    public void disableTable(ByteBuffer tableName) throws IOError, TException
+    public void disableTable(byte[] tableName) throws IOError, TException
     {
       send_disableTable(tableName);
       recv_disableTable();
     }
 
-    public void send_disableTable(ByteBuffer tableName) throws TException
+    public void send_disableTable(byte[] tableName) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("disableTable", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("disableTable", TMessageType.CALL, seqid_));
       disableTable_args args = new disableTable_args();
-      args.setTableName(tableName);
+      args.tableName = tableName;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -637,9 +554,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "disableTable failed: out of sequence response");
-      }
       disableTable_result result = new disableTable_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -649,17 +563,17 @@ public class Hbase {
       return;
     }
 
-    public boolean isTableEnabled(ByteBuffer tableName) throws IOError, TException
+    public boolean isTableEnabled(byte[] tableName) throws IOError, TException
     {
       send_isTableEnabled(tableName);
       return recv_isTableEnabled();
     }
 
-    public void send_isTableEnabled(ByteBuffer tableName) throws TException
+    public void send_isTableEnabled(byte[] tableName) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("isTableEnabled", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("isTableEnabled", TMessageType.CALL, seqid_));
       isTableEnabled_args args = new isTableEnabled_args();
-      args.setTableName(tableName);
+      args.tableName = tableName;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -673,9 +587,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "isTableEnabled failed: out of sequence response");
-      }
       isTableEnabled_result result = new isTableEnabled_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -688,17 +599,17 @@ public class Hbase {
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "isTableEnabled failed: unknown result");
     }
 
-    public void compact(ByteBuffer tableNameOrRegionName) throws IOError, TException
+    public void compact(byte[] tableNameOrRegionName) throws IOError, TException
     {
       send_compact(tableNameOrRegionName);
       recv_compact();
     }
 
-    public void send_compact(ByteBuffer tableNameOrRegionName) throws TException
+    public void send_compact(byte[] tableNameOrRegionName) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("compact", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("compact", TMessageType.CALL, seqid_));
       compact_args args = new compact_args();
-      args.setTableNameOrRegionName(tableNameOrRegionName);
+      args.tableNameOrRegionName = tableNameOrRegionName;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -712,9 +623,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "compact failed: out of sequence response");
-      }
       compact_result result = new compact_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -724,17 +632,17 @@ public class Hbase {
       return;
     }
 
-    public void majorCompact(ByteBuffer tableNameOrRegionName) throws IOError, TException
+    public void majorCompact(byte[] tableNameOrRegionName) throws IOError, TException
     {
       send_majorCompact(tableNameOrRegionName);
       recv_majorCompact();
     }
 
-    public void send_majorCompact(ByteBuffer tableNameOrRegionName) throws TException
+    public void send_majorCompact(byte[] tableNameOrRegionName) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("majorCompact", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("majorCompact", TMessageType.CALL, seqid_));
       majorCompact_args args = new majorCompact_args();
-      args.setTableNameOrRegionName(tableNameOrRegionName);
+      args.tableNameOrRegionName = tableNameOrRegionName;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -748,9 +656,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "majorCompact failed: out of sequence response");
-      }
       majorCompact_result result = new majorCompact_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -760,7 +665,7 @@ public class Hbase {
       return;
     }
 
-    public List<ByteBuffer> getTableNames() throws IOError, TException
+    public List<byte[]> getTableNames() throws IOError, TException
     {
       send_getTableNames();
       return recv_getTableNames();
@@ -768,14 +673,14 @@ public class Hbase {
 
     public void send_getTableNames() throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("getTableNames", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("getTableNames", TMessageType.CALL, seqid_));
       getTableNames_args args = new getTableNames_args();
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
     }
 
-    public List<ByteBuffer> recv_getTableNames() throws IOError, TException
+    public List<byte[]> recv_getTableNames() throws IOError, TException
     {
       TMessage msg = iprot_.readMessageBegin();
       if (msg.type == TMessageType.EXCEPTION) {
@@ -783,9 +688,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "getTableNames failed: out of sequence response");
-      }
       getTableNames_result result = new getTableNames_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -798,23 +700,23 @@ public class Hbase {
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "getTableNames failed: unknown result");
     }
 
-    public Map<ByteBuffer,ColumnDescriptor> getColumnDescriptors(ByteBuffer tableName) throws IOError, TException
+    public Map<byte[],ColumnDescriptor> getColumnDescriptors(byte[] tableName) throws IOError, TException
     {
       send_getColumnDescriptors(tableName);
       return recv_getColumnDescriptors();
     }
 
-    public void send_getColumnDescriptors(ByteBuffer tableName) throws TException
+    public void send_getColumnDescriptors(byte[] tableName) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("getColumnDescriptors", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("getColumnDescriptors", TMessageType.CALL, seqid_));
       getColumnDescriptors_args args = new getColumnDescriptors_args();
-      args.setTableName(tableName);
+      args.tableName = tableName;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
     }
 
-    public Map<ByteBuffer,ColumnDescriptor> recv_getColumnDescriptors() throws IOError, TException
+    public Map<byte[],ColumnDescriptor> recv_getColumnDescriptors() throws IOError, TException
     {
       TMessage msg = iprot_.readMessageBegin();
       if (msg.type == TMessageType.EXCEPTION) {
@@ -822,9 +724,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "getColumnDescriptors failed: out of sequence response");
-      }
       getColumnDescriptors_result result = new getColumnDescriptors_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -837,17 +736,17 @@ public class Hbase {
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "getColumnDescriptors failed: unknown result");
     }
 
-    public List<TRegionInfo> getTableRegions(ByteBuffer tableName) throws IOError, TException
+    public List<TRegionInfo> getTableRegions(byte[] tableName) throws IOError, TException
     {
       send_getTableRegions(tableName);
       return recv_getTableRegions();
     }
 
-    public void send_getTableRegions(ByteBuffer tableName) throws TException
+    public void send_getTableRegions(byte[] tableName) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("getTableRegions", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("getTableRegions", TMessageType.CALL, seqid_));
       getTableRegions_args args = new getTableRegions_args();
-      args.setTableName(tableName);
+      args.tableName = tableName;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -861,9 +760,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "getTableRegions failed: out of sequence response");
-      }
       getTableRegions_result result = new getTableRegions_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -876,18 +772,18 @@ public class Hbase {
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "getTableRegions failed: unknown result");
     }
 
-    public void createTable(ByteBuffer tableName, List<ColumnDescriptor> columnFamilies) throws IOError, IllegalArgument, AlreadyExists, TException
+    public void createTable(byte[] tableName, List<ColumnDescriptor> columnFamilies) throws IOError, IllegalArgument, AlreadyExists, TException
     {
       send_createTable(tableName, columnFamilies);
       recv_createTable();
     }
 
-    public void send_createTable(ByteBuffer tableName, List<ColumnDescriptor> columnFamilies) throws TException
+    public void send_createTable(byte[] tableName, List<ColumnDescriptor> columnFamilies) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("createTable", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("createTable", TMessageType.CALL, seqid_));
       createTable_args args = new createTable_args();
-      args.setTableName(tableName);
-      args.setColumnFamilies(columnFamilies);
+      args.tableName = tableName;
+      args.columnFamilies = columnFamilies;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -901,9 +797,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "createTable failed: out of sequence response");
-      }
       createTable_result result = new createTable_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -919,17 +812,17 @@ public class Hbase {
       return;
     }
 
-    public void deleteTable(ByteBuffer tableName) throws IOError, TException
+    public void deleteTable(byte[] tableName) throws IOError, TException
     {
       send_deleteTable(tableName);
       recv_deleteTable();
     }
 
-    public void send_deleteTable(ByteBuffer tableName) throws TException
+    public void send_deleteTable(byte[] tableName) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("deleteTable", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("deleteTable", TMessageType.CALL, seqid_));
       deleteTable_args args = new deleteTable_args();
-      args.setTableName(tableName);
+      args.tableName = tableName;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -943,9 +836,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "deleteTable failed: out of sequence response");
-      }
       deleteTable_result result = new deleteTable_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -955,19 +845,19 @@ public class Hbase {
       return;
     }
 
-    public List<TCell> get(ByteBuffer tableName, ByteBuffer row, ByteBuffer column) throws IOError, TException
+    public List<TCell> get(byte[] tableName, byte[] row, byte[] column) throws IOError, TException
     {
       send_get(tableName, row, column);
       return recv_get();
     }
 
-    public void send_get(ByteBuffer tableName, ByteBuffer row, ByteBuffer column) throws TException
+    public void send_get(byte[] tableName, byte[] row, byte[] column) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("get", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("get", TMessageType.CALL, seqid_));
       get_args args = new get_args();
-      args.setTableName(tableName);
-      args.setRow(row);
-      args.setColumn(column);
+      args.tableName = tableName;
+      args.row = row;
+      args.column = column;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -981,9 +871,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "get failed: out of sequence response");
-      }
       get_result result = new get_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -996,20 +883,20 @@ public class Hbase {
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "get failed: unknown result");
     }
 
-    public List<TCell> getVer(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, int numVersions) throws IOError, TException
+    public List<TCell> getVer(byte[] tableName, byte[] row, byte[] column, int numVersions) throws IOError, TException
     {
       send_getVer(tableName, row, column, numVersions);
       return recv_getVer();
     }
 
-    public void send_getVer(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, int numVersions) throws TException
+    public void send_getVer(byte[] tableName, byte[] row, byte[] column, int numVersions) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("getVer", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("getVer", TMessageType.CALL, seqid_));
       getVer_args args = new getVer_args();
-      args.setTableName(tableName);
-      args.setRow(row);
-      args.setColumn(column);
-      args.setNumVersions(numVersions);
+      args.tableName = tableName;
+      args.row = row;
+      args.column = column;
+      args.numVersions = numVersions;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -1023,9 +910,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "getVer failed: out of sequence response");
-      }
       getVer_result result = new getVer_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -1038,21 +922,21 @@ public class Hbase {
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "getVer failed: unknown result");
     }
 
-    public List<TCell> getVerTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, int numVersions) throws IOError, TException
+    public List<TCell> getVerTs(byte[] tableName, byte[] row, byte[] column, long timestamp, int numVersions) throws IOError, TException
     {
       send_getVerTs(tableName, row, column, timestamp, numVersions);
       return recv_getVerTs();
     }
 
-    public void send_getVerTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, int numVersions) throws TException
+    public void send_getVerTs(byte[] tableName, byte[] row, byte[] column, long timestamp, int numVersions) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("getVerTs", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("getVerTs", TMessageType.CALL, seqid_));
       getVerTs_args args = new getVerTs_args();
-      args.setTableName(tableName);
-      args.setRow(row);
-      args.setColumn(column);
-      args.setTimestamp(timestamp);
-      args.setNumVersions(numVersions);
+      args.tableName = tableName;
+      args.row = row;
+      args.column = column;
+      args.timestamp = timestamp;
+      args.numVersions = numVersions;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -1066,9 +950,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "getVerTs failed: out of sequence response");
-      }
       getVerTs_result result = new getVerTs_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -1081,18 +962,18 @@ public class Hbase {
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "getVerTs failed: unknown result");
     }
 
-    public List<TRowResult> getRow(ByteBuffer tableName, ByteBuffer row) throws IOError, TException
+    public List<TRowResult> getRow(byte[] tableName, byte[] row) throws IOError, TException
     {
       send_getRow(tableName, row);
       return recv_getRow();
     }
 
-    public void send_getRow(ByteBuffer tableName, ByteBuffer row) throws TException
+    public void send_getRow(byte[] tableName, byte[] row) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("getRow", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("getRow", TMessageType.CALL, seqid_));
       getRow_args args = new getRow_args();
-      args.setTableName(tableName);
-      args.setRow(row);
+      args.tableName = tableName;
+      args.row = row;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -1106,9 +987,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "getRow failed: out of sequence response");
-      }
       getRow_result result = new getRow_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -1121,19 +999,19 @@ public class Hbase {
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "getRow failed: unknown result");
     }
 
-    public List<TRowResult> getRowWithColumns(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns) throws IOError, TException
+    public List<TRowResult> getRowWithColumns(byte[] tableName, byte[] row, List<byte[]> columns) throws IOError, TException
     {
       send_getRowWithColumns(tableName, row, columns);
       return recv_getRowWithColumns();
     }
 
-    public void send_getRowWithColumns(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns) throws TException
+    public void send_getRowWithColumns(byte[] tableName, byte[] row, List<byte[]> columns) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("getRowWithColumns", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("getRowWithColumns", TMessageType.CALL, seqid_));
       getRowWithColumns_args args = new getRowWithColumns_args();
-      args.setTableName(tableName);
-      args.setRow(row);
-      args.setColumns(columns);
+      args.tableName = tableName;
+      args.row = row;
+      args.columns = columns;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -1147,9 +1025,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "getRowWithColumns failed: out of sequence response");
-      }
       getRowWithColumns_result result = new getRowWithColumns_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -1162,19 +1037,19 @@ public class Hbase {
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "getRowWithColumns failed: unknown result");
     }
 
-    public List<TRowResult> getRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp) throws IOError, TException
+    public List<TRowResult> getRowTs(byte[] tableName, byte[] row, long timestamp) throws IOError, TException
     {
       send_getRowTs(tableName, row, timestamp);
       return recv_getRowTs();
     }
 
-    public void send_getRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp) throws TException
+    public void send_getRowTs(byte[] tableName, byte[] row, long timestamp) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("getRowTs", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("getRowTs", TMessageType.CALL, seqid_));
       getRowTs_args args = new getRowTs_args();
-      args.setTableName(tableName);
-      args.setRow(row);
-      args.setTimestamp(timestamp);
+      args.tableName = tableName;
+      args.row = row;
+      args.timestamp = timestamp;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -1188,9 +1063,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "getRowTs failed: out of sequence response");
-      }
       getRowTs_result result = new getRowTs_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -1203,20 +1075,20 @@ public class Hbase {
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "getRowTs failed: unknown result");
     }
 
-    public List<TRowResult> getRowWithColumnsTs(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, long timestamp) throws IOError, TException
+    public List<TRowResult> getRowWithColumnsTs(byte[] tableName, byte[] row, List<byte[]> columns, long timestamp) throws IOError, TException
     {
       send_getRowWithColumnsTs(tableName, row, columns, timestamp);
       return recv_getRowWithColumnsTs();
     }
 
-    public void send_getRowWithColumnsTs(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, long timestamp) throws TException
+    public void send_getRowWithColumnsTs(byte[] tableName, byte[] row, List<byte[]> columns, long timestamp) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("getRowWithColumnsTs", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("getRowWithColumnsTs", TMessageType.CALL, seqid_));
       getRowWithColumnsTs_args args = new getRowWithColumnsTs_args();
-      args.setTableName(tableName);
-      args.setRow(row);
-      args.setColumns(columns);
-      args.setTimestamp(timestamp);
+      args.tableName = tableName;
+      args.row = row;
+      args.columns = columns;
+      args.timestamp = timestamp;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -1230,9 +1102,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "getRowWithColumnsTs failed: out of sequence response");
-      }
       getRowWithColumnsTs_result result = new getRowWithColumnsTs_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -1245,19 +1114,19 @@ public class Hbase {
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "getRowWithColumnsTs failed: unknown result");
     }
 
-    public void mutateRow(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations) throws IOError, IllegalArgument, TException
+    public void mutateRow(byte[] tableName, byte[] row, List<Mutation> mutations) throws IOError, IllegalArgument, TException
     {
       send_mutateRow(tableName, row, mutations);
       recv_mutateRow();
     }
 
-    public void send_mutateRow(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations) throws TException
+    public void send_mutateRow(byte[] tableName, byte[] row, List<Mutation> mutations) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("mutateRow", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("mutateRow", TMessageType.CALL, seqid_));
       mutateRow_args args = new mutateRow_args();
-      args.setTableName(tableName);
-      args.setRow(row);
-      args.setMutations(mutations);
+      args.tableName = tableName;
+      args.row = row;
+      args.mutations = mutations;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -1271,9 +1140,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "mutateRow failed: out of sequence response");
-      }
       mutateRow_result result = new mutateRow_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -1286,20 +1152,20 @@ public class Hbase {
       return;
     }
 
-    public void mutateRowTs(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, long timestamp) throws IOError, IllegalArgument, TException
+    public void mutateRowTs(byte[] tableName, byte[] row, List<Mutation> mutations, long timestamp) throws IOError, IllegalArgument, TException
     {
       send_mutateRowTs(tableName, row, mutations, timestamp);
       recv_mutateRowTs();
     }
 
-    public void send_mutateRowTs(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, long timestamp) throws TException
+    public void send_mutateRowTs(byte[] tableName, byte[] row, List<Mutation> mutations, long timestamp) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("mutateRowTs", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("mutateRowTs", TMessageType.CALL, seqid_));
       mutateRowTs_args args = new mutateRowTs_args();
-      args.setTableName(tableName);
-      args.setRow(row);
-      args.setMutations(mutations);
-      args.setTimestamp(timestamp);
+      args.tableName = tableName;
+      args.row = row;
+      args.mutations = mutations;
+      args.timestamp = timestamp;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -1313,9 +1179,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "mutateRowTs failed: out of sequence response");
-      }
       mutateRowTs_result result = new mutateRowTs_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -1328,18 +1191,18 @@ public class Hbase {
       return;
     }
 
-    public void mutateRows(ByteBuffer tableName, List<BatchMutation> rowBatches) throws IOError, IllegalArgument, TException
+    public void mutateRows(byte[] tableName, List<BatchMutation> rowBatches) throws IOError, IllegalArgument, TException
     {
       send_mutateRows(tableName, rowBatches);
       recv_mutateRows();
     }
 
-    public void send_mutateRows(ByteBuffer tableName, List<BatchMutation> rowBatches) throws TException
+    public void send_mutateRows(byte[] tableName, List<BatchMutation> rowBatches) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("mutateRows", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("mutateRows", TMessageType.CALL, seqid_));
       mutateRows_args args = new mutateRows_args();
-      args.setTableName(tableName);
-      args.setRowBatches(rowBatches);
+      args.tableName = tableName;
+      args.rowBatches = rowBatches;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -1353,9 +1216,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "mutateRows failed: out of sequence response");
-      }
       mutateRows_result result = new mutateRows_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -1368,19 +1228,19 @@ public class Hbase {
       return;
     }
 
-    public void mutateRowsTs(ByteBuffer tableName, List<BatchMutation> rowBatches, long timestamp) throws IOError, IllegalArgument, TException
+    public void mutateRowsTs(byte[] tableName, List<BatchMutation> rowBatches, long timestamp) throws IOError, IllegalArgument, TException
     {
       send_mutateRowsTs(tableName, rowBatches, timestamp);
       recv_mutateRowsTs();
     }
 
-    public void send_mutateRowsTs(ByteBuffer tableName, List<BatchMutation> rowBatches, long timestamp) throws TException
+    public void send_mutateRowsTs(byte[] tableName, List<BatchMutation> rowBatches, long timestamp) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("mutateRowsTs", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("mutateRowsTs", TMessageType.CALL, seqid_));
       mutateRowsTs_args args = new mutateRowsTs_args();
-      args.setTableName(tableName);
-      args.setRowBatches(rowBatches);
-      args.setTimestamp(timestamp);
+      args.tableName = tableName;
+      args.rowBatches = rowBatches;
+      args.timestamp = timestamp;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -1394,9 +1254,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "mutateRowsTs failed: out of sequence response");
-      }
       mutateRowsTs_result result = new mutateRowsTs_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -1409,20 +1266,20 @@ public class Hbase {
       return;
     }
 
-    public long atomicIncrement(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long value) throws IOError, IllegalArgument, TException
+    public long atomicIncrement(byte[] tableName, byte[] row, byte[] column, long value) throws IOError, IllegalArgument, TException
     {
       send_atomicIncrement(tableName, row, column, value);
       return recv_atomicIncrement();
     }
 
-    public void send_atomicIncrement(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long value) throws TException
+    public void send_atomicIncrement(byte[] tableName, byte[] row, byte[] column, long value) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("atomicIncrement", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("atomicIncrement", TMessageType.CALL, seqid_));
       atomicIncrement_args args = new atomicIncrement_args();
-      args.setTableName(tableName);
-      args.setRow(row);
-      args.setColumn(column);
-      args.setValue(value);
+      args.tableName = tableName;
+      args.row = row;
+      args.column = column;
+      args.value = value;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -1436,9 +1293,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "atomicIncrement failed: out of sequence response");
-      }
       atomicIncrement_result result = new atomicIncrement_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -1454,19 +1308,19 @@ public class Hbase {
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "atomicIncrement failed: unknown result");
     }
 
-    public void deleteAll(ByteBuffer tableName, ByteBuffer row, ByteBuffer column) throws IOError, TException
+    public void deleteAll(byte[] tableName, byte[] row, byte[] column) throws IOError, TException
     {
       send_deleteAll(tableName, row, column);
       recv_deleteAll();
     }
 
-    public void send_deleteAll(ByteBuffer tableName, ByteBuffer row, ByteBuffer column) throws TException
+    public void send_deleteAll(byte[] tableName, byte[] row, byte[] column) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("deleteAll", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("deleteAll", TMessageType.CALL, seqid_));
       deleteAll_args args = new deleteAll_args();
-      args.setTableName(tableName);
-      args.setRow(row);
-      args.setColumn(column);
+      args.tableName = tableName;
+      args.row = row;
+      args.column = column;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -1480,9 +1334,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "deleteAll failed: out of sequence response");
-      }
       deleteAll_result result = new deleteAll_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -1492,20 +1343,20 @@ public class Hbase {
       return;
     }
 
-    public void deleteAllTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp) throws IOError, TException
+    public void deleteAllTs(byte[] tableName, byte[] row, byte[] column, long timestamp) throws IOError, TException
     {
       send_deleteAllTs(tableName, row, column, timestamp);
       recv_deleteAllTs();
     }
 
-    public void send_deleteAllTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp) throws TException
+    public void send_deleteAllTs(byte[] tableName, byte[] row, byte[] column, long timestamp) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("deleteAllTs", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("deleteAllTs", TMessageType.CALL, seqid_));
       deleteAllTs_args args = new deleteAllTs_args();
-      args.setTableName(tableName);
-      args.setRow(row);
-      args.setColumn(column);
-      args.setTimestamp(timestamp);
+      args.tableName = tableName;
+      args.row = row;
+      args.column = column;
+      args.timestamp = timestamp;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -1519,9 +1370,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "deleteAllTs failed: out of sequence response");
-      }
       deleteAllTs_result result = new deleteAllTs_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -1531,18 +1379,18 @@ public class Hbase {
       return;
     }
 
-    public void deleteAllRow(ByteBuffer tableName, ByteBuffer row) throws IOError, TException
+    public void deleteAllRow(byte[] tableName, byte[] row) throws IOError, TException
     {
       send_deleteAllRow(tableName, row);
       recv_deleteAllRow();
     }
 
-    public void send_deleteAllRow(ByteBuffer tableName, ByteBuffer row) throws TException
+    public void send_deleteAllRow(byte[] tableName, byte[] row) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("deleteAllRow", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("deleteAllRow", TMessageType.CALL, seqid_));
       deleteAllRow_args args = new deleteAllRow_args();
-      args.setTableName(tableName);
-      args.setRow(row);
+      args.tableName = tableName;
+      args.row = row;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -1556,9 +1404,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "deleteAllRow failed: out of sequence response");
-      }
       deleteAllRow_result result = new deleteAllRow_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -1568,19 +1413,19 @@ public class Hbase {
       return;
     }
 
-    public void deleteAllRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp) throws IOError, TException
+    public void deleteAllRowTs(byte[] tableName, byte[] row, long timestamp) throws IOError, TException
     {
       send_deleteAllRowTs(tableName, row, timestamp);
       recv_deleteAllRowTs();
     }
 
-    public void send_deleteAllRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp) throws TException
+    public void send_deleteAllRowTs(byte[] tableName, byte[] row, long timestamp) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("deleteAllRowTs", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("deleteAllRowTs", TMessageType.CALL, seqid_));
       deleteAllRowTs_args args = new deleteAllRowTs_args();
-      args.setTableName(tableName);
-      args.setRow(row);
-      args.setTimestamp(timestamp);
+      args.tableName = tableName;
+      args.row = row;
+      args.timestamp = timestamp;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -1594,9 +1439,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "deleteAllRowTs failed: out of sequence response");
-      }
       deleteAllRowTs_result result = new deleteAllRowTs_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -1606,19 +1448,19 @@ public class Hbase {
       return;
     }
 
-    public int scannerOpen(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns) throws IOError, TException
+    public int scannerOpen(byte[] tableName, byte[] startRow, List<byte[]> columns) throws IOError, TException
     {
       send_scannerOpen(tableName, startRow, columns);
       return recv_scannerOpen();
     }
 
-    public void send_scannerOpen(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns) throws TException
+    public void send_scannerOpen(byte[] tableName, byte[] startRow, List<byte[]> columns) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("scannerOpen", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("scannerOpen", TMessageType.CALL, seqid_));
       scannerOpen_args args = new scannerOpen_args();
-      args.setTableName(tableName);
-      args.setStartRow(startRow);
-      args.setColumns(columns);
+      args.tableName = tableName;
+      args.startRow = startRow;
+      args.columns = columns;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -1632,9 +1474,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "scannerOpen failed: out of sequence response");
-      }
       scannerOpen_result result = new scannerOpen_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -1647,20 +1486,20 @@ public class Hbase {
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "scannerOpen failed: unknown result");
     }
 
-    public int scannerOpenWithStop(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns) throws IOError, TException
+    public int scannerOpenWithStop(byte[] tableName, byte[] startRow, byte[] stopRow, List<byte[]> columns) throws IOError, TException
     {
       send_scannerOpenWithStop(tableName, startRow, stopRow, columns);
       return recv_scannerOpenWithStop();
     }
 
-    public void send_scannerOpenWithStop(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns) throws TException
+    public void send_scannerOpenWithStop(byte[] tableName, byte[] startRow, byte[] stopRow, List<byte[]> columns) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("scannerOpenWithStop", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("scannerOpenWithStop", TMessageType.CALL, seqid_));
       scannerOpenWithStop_args args = new scannerOpenWithStop_args();
-      args.setTableName(tableName);
-      args.setStartRow(startRow);
-      args.setStopRow(stopRow);
-      args.setColumns(columns);
+      args.tableName = tableName;
+      args.startRow = startRow;
+      args.stopRow = stopRow;
+      args.columns = columns;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -1674,9 +1513,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "scannerOpenWithStop failed: out of sequence response");
-      }
       scannerOpenWithStop_result result = new scannerOpenWithStop_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -1689,19 +1525,19 @@ public class Hbase {
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "scannerOpenWithStop failed: unknown result");
     }
 
-    public int scannerOpenWithPrefix(ByteBuffer tableName, ByteBuffer startAndPrefix, List<ByteBuffer> columns) throws IOError, TException
+    public int scannerOpenWithPrefix(byte[] tableName, byte[] startAndPrefix, List<byte[]> columns) throws IOError, TException
     {
       send_scannerOpenWithPrefix(tableName, startAndPrefix, columns);
       return recv_scannerOpenWithPrefix();
     }
 
-    public void send_scannerOpenWithPrefix(ByteBuffer tableName, ByteBuffer startAndPrefix, List<ByteBuffer> columns) throws TException
+    public void send_scannerOpenWithPrefix(byte[] tableName, byte[] startAndPrefix, List<byte[]> columns) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("scannerOpenWithPrefix", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("scannerOpenWithPrefix", TMessageType.CALL, seqid_));
       scannerOpenWithPrefix_args args = new scannerOpenWithPrefix_args();
-      args.setTableName(tableName);
-      args.setStartAndPrefix(startAndPrefix);
-      args.setColumns(columns);
+      args.tableName = tableName;
+      args.startAndPrefix = startAndPrefix;
+      args.columns = columns;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -1715,9 +1551,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "scannerOpenWithPrefix failed: out of sequence response");
-      }
       scannerOpenWithPrefix_result result = new scannerOpenWithPrefix_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -1730,20 +1563,20 @@ public class Hbase {
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "scannerOpenWithPrefix failed: unknown result");
     }
 
-    public int scannerOpenTs(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, long timestamp) throws IOError, TException
+    public int scannerOpenTs(byte[] tableName, byte[] startRow, List<byte[]> columns, long timestamp) throws IOError, TException
     {
       send_scannerOpenTs(tableName, startRow, columns, timestamp);
       return recv_scannerOpenTs();
     }
 
-    public void send_scannerOpenTs(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, long timestamp) throws TException
+    public void send_scannerOpenTs(byte[] tableName, byte[] startRow, List<byte[]> columns, long timestamp) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("scannerOpenTs", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("scannerOpenTs", TMessageType.CALL, seqid_));
       scannerOpenTs_args args = new scannerOpenTs_args();
-      args.setTableName(tableName);
-      args.setStartRow(startRow);
-      args.setColumns(columns);
-      args.setTimestamp(timestamp);
+      args.tableName = tableName;
+      args.startRow = startRow;
+      args.columns = columns;
+      args.timestamp = timestamp;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -1757,9 +1590,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "scannerOpenTs failed: out of sequence response");
-      }
       scannerOpenTs_result result = new scannerOpenTs_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -1772,21 +1602,21 @@ public class Hbase {
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "scannerOpenTs failed: unknown result");
     }
 
-    public int scannerOpenWithStopTs(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, long timestamp) throws IOError, TException
+    public int scannerOpenWithStopTs(byte[] tableName, byte[] startRow, byte[] stopRow, List<byte[]> columns, long timestamp) throws IOError, TException
     {
       send_scannerOpenWithStopTs(tableName, startRow, stopRow, columns, timestamp);
       return recv_scannerOpenWithStopTs();
     }
 
-    public void send_scannerOpenWithStopTs(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, long timestamp) throws TException
+    public void send_scannerOpenWithStopTs(byte[] tableName, byte[] startRow, byte[] stopRow, List<byte[]> columns, long timestamp) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("scannerOpenWithStopTs", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("scannerOpenWithStopTs", TMessageType.CALL, seqid_));
       scannerOpenWithStopTs_args args = new scannerOpenWithStopTs_args();
-      args.setTableName(tableName);
-      args.setStartRow(startRow);
-      args.setStopRow(stopRow);
-      args.setColumns(columns);
-      args.setTimestamp(timestamp);
+      args.tableName = tableName;
+      args.startRow = startRow;
+      args.stopRow = stopRow;
+      args.columns = columns;
+      args.timestamp = timestamp;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -1800,9 +1630,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "scannerOpenWithStopTs failed: out of sequence response");
-      }
       scannerOpenWithStopTs_result result = new scannerOpenWithStopTs_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -1823,9 +1650,9 @@ public class Hbase {
 
     public void send_scannerGet(int id) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("scannerGet", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("scannerGet", TMessageType.CALL, seqid_));
       scannerGet_args args = new scannerGet_args();
-      args.setId(id);
+      args.id = id;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -1839,9 +1666,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "scannerGet failed: out of sequence response");
-      }
       scannerGet_result result = new scannerGet_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -1865,10 +1689,10 @@ public class Hbase {
 
     public void send_scannerGetList(int id, int nbRows) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("scannerGetList", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("scannerGetList", TMessageType.CALL, seqid_));
       scannerGetList_args args = new scannerGetList_args();
-      args.setId(id);
-      args.setNbRows(nbRows);
+      args.id = id;
+      args.nbRows = nbRows;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -1882,9 +1706,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "scannerGetList failed: out of sequence response");
-      }
       scannerGetList_result result = new scannerGetList_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -1908,9 +1729,9 @@ public class Hbase {
 
     public void send_scannerClose(int id) throws TException
     {
-      oprot_.writeMessageBegin(new TMessage("scannerClose", TMessageType.CALL, ++seqid_));
+      oprot_.writeMessageBegin(new TMessage("scannerClose", TMessageType.CALL, seqid_));
       scannerClose_args args = new scannerClose_args();
-      args.setId(id);
+      args.id = id;
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
@@ -1924,9 +1745,6 @@ public class Hbase {
         iprot_.readMessageEnd();
         throw x;
       }
-      if (msg.seqid != seqid_) {
-        throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "scannerClose failed: out of sequence response");
-      }
       scannerClose_result result = new scannerClose_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
@@ -1940,1466 +1758,190 @@ public class Hbase {
     }
 
   }
-  public static class AsyncClient extends TAsyncClient implements AsyncIface {
-    public static class Factory implements TAsyncClientFactory<AsyncClient> {
-      private TAsyncClientManager clientManager;
-      private TProtocolFactory protocolFactory;
-      public Factory(TAsyncClientManager clientManager, TProtocolFactory protocolFactory) {
-        this.clientManager = clientManager;
-        this.protocolFactory = protocolFactory;
-      }
-      public AsyncClient getAsyncClient(TNonblockingTransport transport) {
-        return new AsyncClient(protocolFactory, clientManager, transport);
-      }
+  public static class Processor implements TProcessor {
+    private static final Logger LOGGER = LoggerFactory.getLogger(Processor.class.getName());
+    public Processor(Iface iface)
+    {
+      iface_ = iface;
+      processMap_.put("enableTable", new enableTable());
+      processMap_.put("disableTable", new disableTable());
+      processMap_.put("isTableEnabled", new isTableEnabled());
+      processMap_.put("compact", new compact());
+      processMap_.put("majorCompact", new majorCompact());
+      processMap_.put("getTableNames", new getTableNames());
+      processMap_.put("getColumnDescriptors", new getColumnDescriptors());
+      processMap_.put("getTableRegions", new getTableRegions());
+      processMap_.put("createTable", new createTable());
+      processMap_.put("deleteTable", new deleteTable());
+      processMap_.put("get", new get());
+      processMap_.put("getVer", new getVer());
+      processMap_.put("getVerTs", new getVerTs());
+      processMap_.put("getRow", new getRow());
+      processMap_.put("getRowWithColumns", new getRowWithColumns());
+      processMap_.put("getRowTs", new getRowTs());
+      processMap_.put("getRowWithColumnsTs", new getRowWithColumnsTs());
+      processMap_.put("mutateRow", new mutateRow());
+      processMap_.put("mutateRowTs", new mutateRowTs());
+      processMap_.put("mutateRows", new mutateRows());
+      processMap_.put("mutateRowsTs", new mutateRowsTs());
+      processMap_.put("atomicIncrement", new atomicIncrement());
+      processMap_.put("deleteAll", new deleteAll());
+      processMap_.put("deleteAllTs", new deleteAllTs());
+      processMap_.put("deleteAllRow", new deleteAllRow());
+      processMap_.put("deleteAllRowTs", new deleteAllRowTs());
+      processMap_.put("scannerOpen", new scannerOpen());
+      processMap_.put("scannerOpenWithStop", new scannerOpenWithStop());
+      processMap_.put("scannerOpenWithPrefix", new scannerOpenWithPrefix());
+      processMap_.put("scannerOpenTs", new scannerOpenTs());
+      processMap_.put("scannerOpenWithStopTs", new scannerOpenWithStopTs());
+      processMap_.put("scannerGet", new scannerGet());
+      processMap_.put("scannerGetList", new scannerGetList());
+      processMap_.put("scannerClose", new scannerClose());
     }
 
-    public AsyncClient(TProtocolFactory protocolFactory, TAsyncClientManager clientManager, TNonblockingTransport transport) {
-      super(protocolFactory, clientManager, transport);
+    protected static interface ProcessFunction {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException;
     }
 
-    public void enableTable(ByteBuffer tableName, AsyncMethodCallback<enableTable_call> resultHandler) throws TException {
-      checkReady();
-      enableTable_call method_call = new enableTable_call(tableName, resultHandler, this, protocolFactory, transport);
-      manager.call(method_call);
-    }
+    private Iface iface_;
+    protected final HashMap<String,ProcessFunction> processMap_ = new HashMap<String,ProcessFunction>();
 
-    public static class enableTable_call extends TAsyncMethodCall {
-      private ByteBuffer tableName;
-      public enableTable_call(ByteBuffer tableName, AsyncMethodCallback<enableTable_call> resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-        this.tableName = tableName;
+    public boolean process(TProtocol iprot, TProtocol oprot) throws TException
+    {
+      TMessage msg = iprot.readMessageBegin();
+      ProcessFunction fn = processMap_.get(msg.name);
+      if (fn == null) {
+        TProtocolUtil.skip(iprot, TType.STRUCT);
+        iprot.readMessageEnd();
+        TApplicationException x = new TApplicationException(TApplicationException.UNKNOWN_METHOD, "Invalid method name: '"+msg.name+"'");
+        oprot.writeMessageBegin(new TMessage(msg.name, TMessageType.EXCEPTION, msg.seqid));
+        x.write(oprot);
+        oprot.writeMessageEnd();
+        oprot.getTransport().flush();
+        return true;
       }
+      fn.process(msg.seqid, iprot, oprot);
+      return true;
+    }
 
-      public void write_args(TProtocol prot) throws TException {
-        prot.writeMessageBegin(new TMessage("enableTable", TMessageType.CALL, 0));
+    private class enableTable implements ProcessFunction {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
+      {
         enableTable_args args = new enableTable_args();
-        args.setTableName(tableName);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public void getResult() throws IOError, TException {
-        if (getState() != State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
+        args.read(iprot);
+        iprot.readMessageEnd();
+        enableTable_result result = new enableTable_result();
+        try {
+          iface_.enableTable(args.tableName);
+        } catch (IOError io) {
+          result.io = io;
+        } catch (Throwable th) {
+          LOGGER.error("Internal error processing enableTable", th);
+          TApplicationException x = new TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error processing enableTable");
+          oprot.writeMessageBegin(new TMessage("enableTable", TMessageType.EXCEPTION, seqid));
+          x.write(oprot);
+          oprot.writeMessageEnd();
+          oprot.getTransport().flush();
+          return;
         }
-        TMemoryInputTransport memoryTransport = new TMemoryInputTransport(getFrameBuffer().array());
-        TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        (new Client(prot)).recv_enableTable();
+        oprot.writeMessageBegin(new TMessage("enableTable", TMessageType.REPLY, seqid));
+        result.write(oprot);
+        oprot.writeMessageEnd();
+        oprot.getTransport().flush();
       }
-    }
 
-    public void disableTable(ByteBuffer tableName, AsyncMethodCallback<disableTable_call> resultHandler) throws TException {
-      checkReady();
-      disableTable_call method_call = new disableTable_call(tableName, resultHandler, this, protocolFactory, transport);
-      manager.call(method_call);
     }
 
-    public static class disableTable_call extends TAsyncMethodCall {
-      private ByteBuffer tableName;
-      public disableTable_call(ByteBuffer tableName, AsyncMethodCallback<disableTable_call> resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-        this.tableName = tableName;
-      }
-
-      public void write_args(TProtocol prot) throws TException {
-        prot.writeMessageBegin(new TMessage("disableTable", TMessageType.CALL, 0));
+    private class disableTable implements ProcessFunction {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
+      {
         disableTable_args args = new disableTable_args();
-        args.setTableName(tableName);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public void getResult() throws IOError, TException {
-        if (getState() != State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
+        args.read(iprot);
+        iprot.readMessageEnd();
+        disableTable_result result = new disableTable_result();
+        try {
+          iface_.disableTable(args.tableName);
+        } catch (IOError io) {
+          result.io = io;
+        } catch (Throwable th) {
+          LOGGER.error("Internal error processing disableTable", th);
+          TApplicationException x = new TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error processing disableTable");
+          oprot.writeMessageBegin(new TMessage("disableTable", TMessageType.EXCEPTION, seqid));
+          x.write(oprot);
+          oprot.writeMessageEnd();
+          oprot.getTransport().flush();
+          return;
         }
-        TMemoryInputTransport memoryTransport = new TMemoryInputTransport(getFrameBuffer().array());
-        TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        (new Client(prot)).recv_disableTable();
+        oprot.writeMessageBegin(new TMessage("disableTable", TMessageType.REPLY, seqid));
+        result.write(oprot);
+        oprot.writeMessageEnd();
+        oprot.getTransport().flush();
       }
-    }
 
-    public void isTableEnabled(ByteBuffer tableName, AsyncMethodCallback<isTableEnabled_call> resultHandler) throws TException {
-      checkReady();
-      isTableEnabled_call method_call = new isTableEnabled_call(tableName, resultHandler, this, protocolFactory, transport);
-      manager.call(method_call);
     }
 
-    public static class isTableEnabled_call extends TAsyncMethodCall {
-      private ByteBuffer tableName;
-      public isTableEnabled_call(ByteBuffer tableName, AsyncMethodCallback<isTableEnabled_call> resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-        this.tableName = tableName;
-      }
-
-      public void write_args(TProtocol prot) throws TException {
-        prot.writeMessageBegin(new TMessage("isTableEnabled", TMessageType.CALL, 0));
+    private class isTableEnabled implements ProcessFunction {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
+      {
         isTableEnabled_args args = new isTableEnabled_args();
-        args.setTableName(tableName);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public boolean getResult() throws IOError, TException {
-        if (getState() != State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
+        args.read(iprot);
+        iprot.readMessageEnd();
+        isTableEnabled_result result = new isTableEnabled_result();
+        try {
+          result.success = iface_.isTableEnabled(args.tableName);
+          result.setSuccessIsSet(true);
+        } catch (IOError io) {
+          result.io = io;
+        } catch (Throwable th) {
+          LOGGER.error("Internal error processing isTableEnabled", th);
+          TApplicationException x = new TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error processing isTableEnabled");
+          oprot.writeMessageBegin(new TMessage("isTableEnabled", TMessageType.EXCEPTION, seqid));
+          x.write(oprot);
+          oprot.writeMessageEnd();
+          oprot.getTransport().flush();
+          return;
         }
-        TMemoryInputTransport memoryTransport = new TMemoryInputTransport(getFrameBuffer().array());
-        TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        return (new Client(prot)).recv_isTableEnabled();
+        oprot.writeMessageBegin(new TMessage("isTableEnabled", TMessageType.REPLY, seqid));
+        result.write(oprot);
+        oprot.writeMessageEnd();
+        oprot.getTransport().flush();
       }
-    }
 
-    public void compact(ByteBuffer tableNameOrRegionName, AsyncMethodCallback<compact_call> resultHandler) throws TException {
-      checkReady();
-      compact_call method_call = new compact_call(tableNameOrRegionName, resultHandler, this, protocolFactory, transport);
-      manager.call(method_call);
     }
 
-    public static class compact_call extends TAsyncMethodCall {
-      private ByteBuffer tableNameOrRegionName;
-      public compact_call(ByteBuffer tableNameOrRegionName, AsyncMethodCallback<compact_call> resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-        this.tableNameOrRegionName = tableNameOrRegionName;
-      }
-
-      public void write_args(TProtocol prot) throws TException {
-        prot.writeMessageBegin(new TMessage("compact", TMessageType.CALL, 0));
+    private class compact implements ProcessFunction {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
+      {
         compact_args args = new compact_args();
-        args.setTableNameOrRegionName(tableNameOrRegionName);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public void getResult() throws IOError, TException {
-        if (getState() != State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
+        args.read(iprot);
+        iprot.readMessageEnd();
+        compact_result result = new compact_result();
+        try {
+          iface_.compact(args.tableNameOrRegionName);
+        } catch (IOError io) {
+          result.io = io;
+        } catch (Throwable th) {
+          LOGGER.error("Internal error processing compact", th);
+          TApplicationException x = new TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error processing compact");
+          oprot.writeMessageBegin(new TMessage("compact", TMessageType.EXCEPTION, seqid));
+          x.write(oprot);
+          oprot.writeMessageEnd();
+          oprot.getTransport().flush();
+          return;
         }
-        TMemoryInputTransport memoryTransport = new TMemoryInputTransport(getFrameBuffer().array());
-        TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        (new Client(prot)).recv_compact();
+        oprot.writeMessageBegin(new TMessage("compact", TMessageType.REPLY, seqid));
+        result.write(oprot);
+        oprot.writeMessageEnd();
+        oprot.getTransport().flush();
       }
-    }
 
-    public void majorCompact(ByteBuffer tableNameOrRegionName, AsyncMethodCallback<majorCompact_call> resultHandler) throws TException {
-      checkReady();
-      majorCompact_call method_call = new majorCompact_call(tableNameOrRegionName, resultHandler, this, protocolFactory, transport);
-      manager.call(method_call);
     }
 
-    public static class majorCompact_call extends TAsyncMethodCall {
-      private ByteBuffer tableNameOrRegionName;
-      public majorCompact_call(ByteBuffer tableNameOrRegionName, AsyncMethodCallback<majorCompact_call> resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-        this.tableNameOrRegionName = tableNameOrRegionName;
-      }
-
-      public void write_args(TProtocol prot) throws TException {

[... 21823 lines stripped ...]


Mime
View raw message