You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by mb...@apache.org on 2012/04/21 03:37:16 UTC
svn commit: r1328562 [5/9] - in /hbase/branches/0.89-fb: ./
src/main/java/org/apache/hadoop/hbase/
src/main/java/org/apache/hadoop/hbase/filter/
src/main/java/org/apache/hadoop/hbase/regionserver/
src/main/java/org/apache/hadoop/hbase/thrift/ src/main/...
Modified: hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/thrift/generated/Hbase.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/thrift/generated/Hbase.java?rev=1328562&r1=1328561&r2=1328562&view=diff
==============================================================================
--- hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/thrift/generated/Hbase.java (original)
+++ hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/thrift/generated/Hbase.java Sat Apr 21 01:37:15 2012
@@ -1,11 +1,17 @@
/**
- * Autogenerated by Thrift
+ * Autogenerated by Thrift Compiler (0.8.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
*/
package org.apache.hadoop.hbase.thrift.generated;
-import org.apache.commons.lang.builder.HashCodeBuilder;
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
@@ -16,14 +22,11 @@ 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.meta_data.*;
-import org.apache.thrift.protocol.*;
-
public class Hbase {
public interface Iface {
@@ -33,7 +36,7 @@ public class Hbase {
*
* @param tableName name of the table
*/
- public void enableTable(byte[] tableName) throws IOError, TException;
+ public void enableTable(ByteBuffer tableName) throws IOError, org.apache.thrift.TException;
/**
* Disables a table (takes it off-line) If it is being served, the master
@@ -41,25 +44,25 @@ public class Hbase {
*
* @param tableName name of the table
*/
- public void disableTable(byte[] tableName) throws IOError, TException;
+ public void disableTable(ByteBuffer tableName) throws IOError, org.apache.thrift.TException;
/**
* @return true if table is on-line
*
* @param tableName name of the table to check
*/
- public boolean isTableEnabled(byte[] tableName) throws IOError, TException;
+ public boolean isTableEnabled(ByteBuffer tableName) throws IOError, org.apache.thrift.TException;
- public void compact(byte[] tableNameOrRegionName) throws IOError, TException;
+ public void compact(ByteBuffer tableNameOrRegionName) throws IOError, org.apache.thrift.TException;
- public void majorCompact(byte[] tableNameOrRegionName) throws IOError, TException;
+ public void majorCompact(ByteBuffer tableNameOrRegionName) throws IOError, org.apache.thrift.TException;
/**
* List all the userspace tables.
*
* @return returns a list of names
*/
- public List<byte[]> getTableNames() throws IOError, TException;
+ public List<ByteBuffer> getTableNames() throws IOError, org.apache.thrift.TException;
/**
* List all the column families assoicated with a table.
@@ -68,7 +71,7 @@ public class Hbase {
*
* @param tableName table name
*/
- public Map<byte[],ColumnDescriptor> getColumnDescriptors(byte[] tableName) throws IOError, TException;
+ public Map<ByteBuffer,ColumnDescriptor> getColumnDescriptors(ByteBuffer tableName) throws IOError, org.apache.thrift.TException;
/**
* List the regions associated with a table.
@@ -77,7 +80,7 @@ public class Hbase {
*
* @param tableName table name
*/
- public List<TRegionInfo> getTableRegions(byte[] tableName) throws IOError, TException;
+ public List<TRegionInfo> getTableRegions(ByteBuffer tableName) throws IOError, org.apache.thrift.TException;
/**
* Create a table with the specified column families. The name
@@ -93,7 +96,7 @@ public class Hbase {
*
* @param columnFamilies list of column family descriptors
*/
- public void createTable(byte[] tableName, List<ColumnDescriptor> columnFamilies) throws IOError, IllegalArgument, AlreadyExists, TException;
+ public void createTable(ByteBuffer tableName, List<ColumnDescriptor> columnFamilies) throws IOError, IllegalArgument, AlreadyExists, org.apache.thrift.TException;
/**
* Deletes a table
@@ -103,7 +106,7 @@ public class Hbase {
*
* @param tableName name of table to delete
*/
- public void deleteTable(byte[] tableName) throws IOError, TException;
+ public void deleteTable(ByteBuffer tableName) throws IOError, org.apache.thrift.TException;
/**
* Get a single TCell for the specified table, row, and column at the
@@ -117,7 +120,7 @@ public class Hbase {
*
* @param column column name
*/
- public List<TCell> get(byte[] tableName, byte[] row, byte[] column) throws IOError, TException;
+ public List<TCell> get(ByteBuffer tableName, ByteBuffer row, ByteBuffer column) throws IOError, org.apache.thrift.TException;
/**
* Get the specified number of versions for the specified table,
@@ -133,7 +136,7 @@ public class Hbase {
*
* @param numVersions number of versions to retrieve
*/
- public List<TCell> getVer(byte[] tableName, byte[] row, byte[] column, int numVersions) throws IOError, TException;
+ public List<TCell> getVer(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, int numVersions) throws IOError, org.apache.thrift.TException;
/**
* Get the specified number of versions for the specified table,
@@ -152,7 +155,7 @@ public class Hbase {
*
* @param numVersions number of versions to retrieve
*/
- public List<TCell> getVerTs(byte[] tableName, byte[] row, byte[] column, long timestamp, int numVersions) throws IOError, TException;
+ public List<TCell> getVerTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, int numVersions) throws IOError, org.apache.thrift.TException;
/**
* Get all the data for the specified table and row at the latest
@@ -164,7 +167,7 @@ public class Hbase {
*
* @param row row key
*/
- public List<TRowResult> getRow(byte[] tableName, byte[] row) throws IOError, TException;
+ public List<TRowResult> getRow(ByteBuffer tableName, ByteBuffer row) throws IOError, org.apache.thrift.TException;
/**
* Get the specified columns for the specified table and row at the latest
@@ -178,7 +181,7 @@ public class Hbase {
*
* @param columns List of columns to return, null for all columns
*/
- public List<TRowResult> getRowWithColumns(byte[] tableName, byte[] row, List<byte[]> columns) throws IOError, TException;
+ public List<TRowResult> getRowWithColumns(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns) throws IOError, org.apache.thrift.TException;
/**
* Get all the data for the specified table and row at the specified
@@ -192,7 +195,7 @@ public class Hbase {
*
* @param timestamp timestamp
*/
- public List<TRowResult> getRowTs(byte[] tableName, byte[] row, long timestamp) throws IOError, TException;
+ public List<TRowResult> getRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp) throws IOError, org.apache.thrift.TException;
/**
* Get the specified columns for the specified table and row at the specified
@@ -208,7 +211,7 @@ public class Hbase {
*
* @param timestamp
*/
- public List<TRowResult> getRowWithColumnsTs(byte[] tableName, byte[] row, List<byte[]> columns, long timestamp) throws IOError, TException;
+ public List<TRowResult> getRowWithColumnsTs(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, long timestamp) throws IOError, org.apache.thrift.TException;
/**
* Get the columns with the specified prefix for the specified table and
@@ -226,7 +229,7 @@ public class Hbase {
* If only <qualifier prefix> provided then all families are
* searched
*/
- public List<TRowResult> getRowWithColumnPrefix(byte[] tableName, byte[] row, byte[] prefix) throws IOError, TException;
+ public List<TRowResult> getRowWithColumnPrefix(ByteBuffer tableName, ByteBuffer row, ByteBuffer prefix) throws IOError, org.apache.thrift.TException;
/**
* Get the columns with the specified prefix for the specified table and
@@ -246,7 +249,7 @@ public class Hbase {
*
* @param timestamp
*/
- public List<TRowResult> getRowWithColumnPrefixTs(byte[] tableName, byte[] row, byte[] prefix, long timestamp) throws IOError, TException;
+ public List<TRowResult> getRowWithColumnPrefixTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer prefix, long timestamp) throws IOError, org.apache.thrift.TException;
/**
* Get multiple rows with the same columns or timestamps for all.
@@ -257,7 +260,7 @@ public class Hbase {
* @param tableName
* @param rows
*/
- public List<TRowResult> getRows(byte[] tableName, List<byte[]> rows) throws IOError, TException;
+ public List<TRowResult> getRows(ByteBuffer tableName, List<ByteBuffer> rows) throws IOError, org.apache.thrift.TException;
/**
* Get multiple rows only up to a certain timestamp
@@ -268,7 +271,7 @@ public class Hbase {
* @param rows
* @param timestamp
*/
- public List<TRowResult> getRowsTs(byte[] tableName, List<byte[]> rows, long timestamp) throws IOError, TException;
+ public List<TRowResult> getRowsTs(ByteBuffer tableName, List<ByteBuffer> rows, long timestamp) throws IOError, org.apache.thrift.TException;
/**
* Get multiple rows only with particular cf:qualifier pairs on all rows
@@ -279,7 +282,7 @@ public class Hbase {
* @param rows
* @param families
*/
- public List<TRowResult> getRowsWithColumns(byte[] tableName, List<byte[]> rows, List<byte[]> families) throws IOError, TException;
+ public List<TRowResult> getRowsWithColumns(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> families) throws IOError, org.apache.thrift.TException;
/**
* Get multiple rows only with particular cf:qualifier pairs on all rows
@@ -292,7 +295,7 @@ public class Hbase {
* @param families
* @param timestamp
*/
- public List<TRowResult> getRowsWithColumnsTs(byte[] tableName, List<byte[]> rows, List<byte[]> families, long timestamp) throws IOError, TException;
+ public List<TRowResult> getRowsWithColumnsTs(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> families, long timestamp) throws IOError, org.apache.thrift.TException;
/**
* Apply a series of mutations (updates/deletes) to a row in a
@@ -306,7 +309,7 @@ public class Hbase {
*
* @param mutations list of mutation commands
*/
- public void mutateRow(byte[] tableName, byte[] row, List<Mutation> mutations) throws IOError, IllegalArgument, TException;
+ public void mutateRow(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations) throws IOError, IllegalArgument, org.apache.thrift.TException;
/**
* Apply a series of mutations (updates/deletes) to a row in a
@@ -322,7 +325,7 @@ public class Hbase {
*
* @param timestamp timestamp
*/
- public void mutateRowTs(byte[] tableName, byte[] row, List<Mutation> mutations, long timestamp) throws IOError, IllegalArgument, TException;
+ public void mutateRowTs(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, long timestamp) throws IOError, IllegalArgument, org.apache.thrift.TException;
/**
* Apply a series of batches (each a series of mutations on a single row)
@@ -334,7 +337,7 @@ public class Hbase {
*
* @param rowBatches list of row batches
*/
- public void mutateRows(byte[] tableName, List<BatchMutation> rowBatches) throws IOError, IllegalArgument, TException;
+ public void mutateRows(ByteBuffer tableName, List<BatchMutation> rowBatches) throws IOError, IllegalArgument, org.apache.thrift.TException;
/**
* Apply a series of batches (each a series of mutations on a single row)
@@ -348,7 +351,7 @@ public class Hbase {
*
* @param timestamp timestamp
*/
- public void mutateRowsTs(byte[] tableName, List<BatchMutation> rowBatches, long timestamp) throws IOError, IllegalArgument, TException;
+ public void mutateRowsTs(ByteBuffer tableName, List<BatchMutation> rowBatches, long timestamp) throws IOError, IllegalArgument, org.apache.thrift.TException;
/**
* Applies a list of mutations to a single row only if the value for
@@ -367,7 +370,7 @@ public class Hbase {
* @param valueCheck
* @param mutations list of mutation commands
*/
- public boolean checkAndMutateRow(byte[] tableName, byte[] row, byte[] columnCheck, byte[] valueCheck, List<Mutation> mutations) throws IOError, IllegalArgument, TException;
+ public boolean checkAndMutateRow(ByteBuffer tableName, ByteBuffer row, ByteBuffer columnCheck, ByteBuffer valueCheck, List<Mutation> mutations) throws IOError, IllegalArgument, org.apache.thrift.TException;
/**
* Same as above, but the puts and deletes are added at specified timestamp.
@@ -385,7 +388,7 @@ public class Hbase {
*
* @param timestamp timestamp
*/
- public boolean checkAndMutateRowTs(byte[] tableName, byte[] row, byte[] columnCheck, byte[] valueCheck, List<Mutation> mutations, long timestamp) throws IOError, IllegalArgument, TException;
+ public boolean checkAndMutateRowTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer columnCheck, ByteBuffer valueCheck, List<Mutation> mutations, long timestamp) throws IOError, IllegalArgument, org.apache.thrift.TException;
/**
* Atomically increment the column value specified. Returns the next value post increment.
@@ -398,7 +401,7 @@ public class Hbase {
*
* @param value amount to increment by
*/
- public long atomicIncrement(byte[] tableName, byte[] row, byte[] column, long value) throws IOError, IllegalArgument, TException;
+ public long atomicIncrement(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long value) throws IOError, IllegalArgument, org.apache.thrift.TException;
/**
* Delete all cells that match the passed row and column.
@@ -409,7 +412,7 @@ public class Hbase {
*
* @param column name of column whose value is to be deleted
*/
- public void deleteAll(byte[] tableName, byte[] row, byte[] column) throws IOError, TException;
+ public void deleteAll(ByteBuffer tableName, ByteBuffer row, ByteBuffer column) throws IOError, org.apache.thrift.TException;
/**
* Delete all cells that match the passed row and column and whose
@@ -423,7 +426,7 @@ public class Hbase {
*
* @param timestamp timestamp
*/
- public void deleteAllTs(byte[] tableName, byte[] row, byte[] column, long timestamp) throws IOError, TException;
+ public void deleteAllTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp) throws IOError, org.apache.thrift.TException;
/**
* Completely delete the row's cells.
@@ -432,7 +435,7 @@ public class Hbase {
*
* @param row key of the row to be completely deleted.
*/
- public void deleteAllRow(byte[] tableName, byte[] row) throws IOError, TException;
+ public void deleteAllRow(ByteBuffer tableName, ByteBuffer row) throws IOError, org.apache.thrift.TException;
/**
* Completely delete the row's cells marked with a timestamp
@@ -444,7 +447,7 @@ public class Hbase {
*
* @param timestamp timestamp
*/
- public void deleteAllRowTs(byte[] tableName, byte[] row, long timestamp) throws IOError, TException;
+ public void deleteAllRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp) throws IOError, org.apache.thrift.TException;
/**
* Get a scanner on the current table starting at the specified row and
@@ -461,7 +464,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(byte[] tableName, byte[] startRow, List<byte[]> columns) throws IOError, TException;
+ public int scannerOpen(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns) throws IOError, org.apache.thrift.TException;
/**
* Get a scanner on the current table, using the Scan instance
@@ -471,7 +474,7 @@ public class Hbase {
*
* @param scan Scan instance
*/
- public int scannerOpenWithScan(byte[] tableName, TScan scan) throws IOError, TException;
+ public int scannerOpenWithScan(ByteBuffer tableName, TScan scan) throws IOError, org.apache.thrift.TException;
/**
* Get a scanner on the current table starting and stopping at the
@@ -492,7 +495,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(byte[] tableName, byte[] startRow, byte[] stopRow, List<byte[]> columns) throws IOError, TException;
+ public int scannerOpenWithStop(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns) throws IOError, org.apache.thrift.TException;
/**
* Open a scanner for a given prefix. That is all rows will have the specified
@@ -506,7 +509,7 @@ public class Hbase {
*
* @param columns the columns you want returned
*/
- public int scannerOpenWithPrefix(byte[] tableName, byte[] startAndPrefix, List<byte[]> columns) throws IOError, TException;
+ public int scannerOpenWithPrefix(ByteBuffer tableName, ByteBuffer startAndPrefix, List<ByteBuffer> columns) throws IOError, org.apache.thrift.TException;
/**
* Get a scanner on the current table starting at the specified row and
@@ -526,7 +529,7 @@ public class Hbase {
*
* @param timestamp timestamp
*/
- public int scannerOpenTs(byte[] tableName, byte[] startRow, List<byte[]> columns, long timestamp) throws IOError, TException;
+ public int scannerOpenTs(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, long timestamp) throws IOError, org.apache.thrift.TException;
/**
* Get a scanner on the current table starting and stopping at the
@@ -550,7 +553,7 @@ public class Hbase {
*
* @param timestamp timestamp
*/
- public int scannerOpenWithStopTs(byte[] tableName, byte[] startRow, byte[] stopRow, List<byte[]> columns, long timestamp) throws IOError, TException;
+ public int scannerOpenWithStopTs(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, long timestamp) throws IOError, org.apache.thrift.TException;
/**
* Get a scanner on the current table starting at the first row and
@@ -565,7 +568,7 @@ public class Hbase {
*
* @param filterString Filter string
*/
- public int scannerOpenWithFilterString(byte[] tableName, byte[] filterString) throws IOError, TException;
+ public int scannerOpenWithFilterString(ByteBuffer tableName, ByteBuffer filterString) throws IOError, org.apache.thrift.TException;
/**
* Get a scanner on the current table starting at the first row and
@@ -585,7 +588,7 @@ public class Hbase {
*
* @param timestamp timestamp
*/
- public int scannerOpenWithFilterStringTs(byte[] tableName, byte[] filterString, long timestamp) throws IOError, TException;
+ public int scannerOpenWithFilterStringTs(ByteBuffer tableName, ByteBuffer filterString, long timestamp) throws IOError, org.apache.thrift.TException;
/**
* Get a scanner on the current table starting and stopping at the
@@ -607,7 +610,7 @@ public class Hbase {
*
* @param filterString Filter string
*/
- public int scannerOpenWithStopAndFilterString(byte[] tableName, byte[] startRow, byte[] stopRow, byte[] filterString) throws IOError, TException;
+ public int scannerOpenWithStopAndFilterString(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, ByteBuffer filterString) throws IOError, org.apache.thrift.TException;
/**
* Get a scanner on the current table starting and stopping at the
@@ -634,7 +637,7 @@ public class Hbase {
*
* @param timestamp timestamp
*/
- public int scannerOpenWithStopAndFilterStringTs(byte[] tableName, byte[] startRow, byte[] stopRow, byte[] filterString, long timestamp) throws IOError, TException;
+ public int scannerOpenWithStopAndFilterStringTs(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, ByteBuffer filterString, long timestamp) throws IOError, org.apache.thrift.TException;
/**
* Returns the scanner's current row value and advances to the next
@@ -650,7 +653,7 @@ public class Hbase {
*
* @param id id of a scanner returned by scannerOpen
*/
- public List<TRowResult> scannerGet(int id) throws IOError, IllegalArgument, TException;
+ public List<TRowResult> scannerGet(int id) throws IOError, IllegalArgument, org.apache.thrift.TException;
/**
* Returns, starting at the scanner's current row value nbRows worth of
@@ -668,7 +671,7 @@ public class Hbase {
*
* @param nbRows number of results to return
*/
- public List<TRowResult> scannerGetList(int id, int nbRows) throws IOError, IllegalArgument, TException;
+ public List<TRowResult> scannerGetList(int id, int nbRows) throws IOError, IllegalArgument, org.apache.thrift.TException;
/**
* Closes the server-state associated with an open scanner.
@@ -677,7 +680,7 @@ public class Hbase {
*
* @param id id of a scanner returned by scannerOpen
*/
- public void scannerClose(int id) throws IOError, IllegalArgument, TException;
+ public void scannerClose(int id) throws IOError, IllegalArgument, org.apache.thrift.TException;
/**
* Get the regininfo for the specified row. It scans
@@ -687,340 +690,343 @@ public class Hbase {
*
* @param row row key
*/
- public TRegionInfo getRegionInfo(byte[] row) throws IOError, TException;
+ public TRegionInfo getRegionInfo(ByteBuffer row) throws IOError, org.apache.thrift.TException;
}
- public static class Client implements Iface {
- public Client(TProtocol prot)
- {
- this(prot, prot);
- }
+ public interface AsyncIface {
- public Client(TProtocol iprot, TProtocol oprot)
- {
- iprot_ = iprot;
- oprot_ = oprot;
- }
+ public void enableTable(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.enableTable_call> resultHandler) throws org.apache.thrift.TException;
- protected TProtocol iprot_;
- protected TProtocol oprot_;
+ public void disableTable(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.disableTable_call> resultHandler) throws org.apache.thrift.TException;
- protected int seqid_;
+ public void isTableEnabled(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.isTableEnabled_call> resultHandler) throws org.apache.thrift.TException;
- public TProtocol getInputProtocol()
- {
- return this.iprot_;
+ public void compact(ByteBuffer tableNameOrRegionName, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.compact_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void majorCompact(ByteBuffer tableNameOrRegionName, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.majorCompact_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void getTableNames(org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getTableNames_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void getColumnDescriptors(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getColumnDescriptors_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void getTableRegions(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getTableRegions_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void createTable(ByteBuffer tableName, List<ColumnDescriptor> columnFamilies, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.createTable_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void deleteTable(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.deleteTable_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void get(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.get_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void getVer(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, int numVersions, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getVer_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void getVerTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, int numVersions, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getVerTs_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void getRow(ByteBuffer tableName, ByteBuffer row, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRow_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void getRowWithColumns(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRowWithColumns_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void getRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRowTs_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void getRowWithColumnsTs(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, long timestamp, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRowWithColumnsTs_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void getRowWithColumnPrefix(ByteBuffer tableName, ByteBuffer row, ByteBuffer prefix, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRowWithColumnPrefix_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void getRowWithColumnPrefixTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer prefix, long timestamp, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRowWithColumnPrefixTs_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void getRows(ByteBuffer tableName, List<ByteBuffer> rows, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRows_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void getRowsTs(ByteBuffer tableName, List<ByteBuffer> rows, long timestamp, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRowsTs_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void getRowsWithColumns(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> families, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRowsWithColumns_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void getRowsWithColumnsTs(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> families, long timestamp, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRowsWithColumnsTs_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void mutateRow(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.mutateRow_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void mutateRowTs(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, long timestamp, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.mutateRowTs_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void mutateRows(ByteBuffer tableName, List<BatchMutation> rowBatches, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.mutateRows_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void mutateRowsTs(ByteBuffer tableName, List<BatchMutation> rowBatches, long timestamp, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.mutateRowsTs_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void checkAndMutateRow(ByteBuffer tableName, ByteBuffer row, ByteBuffer columnCheck, ByteBuffer valueCheck, List<Mutation> mutations, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.checkAndMutateRow_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void checkAndMutateRowTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer columnCheck, ByteBuffer valueCheck, List<Mutation> mutations, long timestamp, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.checkAndMutateRowTs_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void atomicIncrement(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long value, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.atomicIncrement_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void deleteAll(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.deleteAll_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void deleteAllTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.deleteAllTs_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void deleteAllRow(ByteBuffer tableName, ByteBuffer row, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.deleteAllRow_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void deleteAllRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.deleteAllRowTs_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void scannerOpen(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.scannerOpen_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void scannerOpenWithScan(ByteBuffer tableName, TScan scan, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.scannerOpenWithScan_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void scannerOpenWithStop(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.scannerOpenWithStop_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void scannerOpenWithPrefix(ByteBuffer tableName, ByteBuffer startAndPrefix, List<ByteBuffer> columns, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.scannerOpenWithPrefix_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void scannerOpenTs(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, long timestamp, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.scannerOpenTs_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void scannerOpenWithStopTs(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, long timestamp, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.scannerOpenWithStopTs_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void scannerOpenWithFilterString(ByteBuffer tableName, ByteBuffer filterString, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.scannerOpenWithFilterString_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void scannerOpenWithFilterStringTs(ByteBuffer tableName, ByteBuffer filterString, long timestamp, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.scannerOpenWithFilterStringTs_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void scannerOpenWithStopAndFilterString(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, ByteBuffer filterString, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.scannerOpenWithStopAndFilterString_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void scannerOpenWithStopAndFilterStringTs(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, ByteBuffer filterString, long timestamp, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.scannerOpenWithStopAndFilterStringTs_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void scannerGet(int id, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.scannerGet_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void scannerGetList(int id, int nbRows, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.scannerGetList_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void scannerClose(int id, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.scannerClose_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void getRegionInfo(ByteBuffer row, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRegionInfo_call> resultHandler) throws org.apache.thrift.TException;
+
+ }
+
+ public static class Client extends org.apache.thrift.TServiceClient implements Iface {
+ public static class Factory implements org.apache.thrift.TServiceClientFactory<Client> {
+ public Factory() {}
+ public Client getClient(org.apache.thrift.protocol.TProtocol prot) {
+ return new Client(prot);
+ }
+ public Client getClient(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) {
+ return new Client(iprot, oprot);
+ }
}
- public TProtocol getOutputProtocol()
+ public Client(org.apache.thrift.protocol.TProtocol prot)
{
- return this.oprot_;
+ super(prot, prot);
}
- public void enableTable(byte[] tableName) throws IOError, TException
+ public Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) {
+ super(iprot, oprot);
+ }
+
+ public void enableTable(ByteBuffer tableName) throws IOError, org.apache.thrift.TException
{
send_enableTable(tableName);
recv_enableTable();
}
- public void send_enableTable(byte[] tableName) throws TException
+ public void send_enableTable(ByteBuffer tableName) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("enableTable", TMessageType.CALL, seqid_));
enableTable_args args = new enableTable_args();
- args.tableName = tableName;
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ args.setTableName(tableName);
+ sendBase("enableTable", args);
}
- public void recv_enableTable() throws IOError, TException
- {
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
+ public void recv_enableTable() throws IOError, org.apache.thrift.TException
+ {
enableTable_result result = new enableTable_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "enableTable");
if (result.io != null) {
throw result.io;
}
return;
}
- public void disableTable(byte[] tableName) throws IOError, TException
+ public void disableTable(ByteBuffer tableName) throws IOError, org.apache.thrift.TException
{
send_disableTable(tableName);
recv_disableTable();
}
- public void send_disableTable(byte[] tableName) throws TException
+ public void send_disableTable(ByteBuffer tableName) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("disableTable", TMessageType.CALL, seqid_));
disableTable_args args = new disableTable_args();
- args.tableName = tableName;
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ args.setTableName(tableName);
+ sendBase("disableTable", args);
}
- public void recv_disableTable() throws IOError, TException
- {
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
+ public void recv_disableTable() throws IOError, org.apache.thrift.TException
+ {
disableTable_result result = new disableTable_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "disableTable");
if (result.io != null) {
throw result.io;
}
return;
}
- public boolean isTableEnabled(byte[] tableName) throws IOError, TException
+ public boolean isTableEnabled(ByteBuffer tableName) throws IOError, org.apache.thrift.TException
{
send_isTableEnabled(tableName);
return recv_isTableEnabled();
}
- public void send_isTableEnabled(byte[] tableName) throws TException
+ public void send_isTableEnabled(ByteBuffer tableName) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("isTableEnabled", TMessageType.CALL, seqid_));
isTableEnabled_args args = new isTableEnabled_args();
- args.tableName = tableName;
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ args.setTableName(tableName);
+ sendBase("isTableEnabled", args);
}
- public boolean recv_isTableEnabled() throws IOError, TException
- {
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
+ public boolean recv_isTableEnabled() throws IOError, org.apache.thrift.TException
+ {
isTableEnabled_result result = new isTableEnabled_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "isTableEnabled");
if (result.isSetSuccess()) {
return result.success;
}
if (result.io != null) {
throw result.io;
}
- throw new TApplicationException(TApplicationException.MISSING_RESULT, "isTableEnabled failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "isTableEnabled failed: unknown result");
}
- public void compact(byte[] tableNameOrRegionName) throws IOError, TException
+ public void compact(ByteBuffer tableNameOrRegionName) throws IOError, org.apache.thrift.TException
{
send_compact(tableNameOrRegionName);
recv_compact();
}
- public void send_compact(byte[] tableNameOrRegionName) throws TException
+ public void send_compact(ByteBuffer tableNameOrRegionName) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("compact", TMessageType.CALL, seqid_));
compact_args args = new compact_args();
- args.tableNameOrRegionName = tableNameOrRegionName;
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ args.setTableNameOrRegionName(tableNameOrRegionName);
+ sendBase("compact", args);
}
- public void recv_compact() throws IOError, TException
- {
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
+ public void recv_compact() throws IOError, org.apache.thrift.TException
+ {
compact_result result = new compact_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "compact");
if (result.io != null) {
throw result.io;
}
return;
}
- public void majorCompact(byte[] tableNameOrRegionName) throws IOError, TException
+ public void majorCompact(ByteBuffer tableNameOrRegionName) throws IOError, org.apache.thrift.TException
{
send_majorCompact(tableNameOrRegionName);
recv_majorCompact();
}
- public void send_majorCompact(byte[] tableNameOrRegionName) throws TException
+ public void send_majorCompact(ByteBuffer tableNameOrRegionName) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("majorCompact", TMessageType.CALL, seqid_));
majorCompact_args args = new majorCompact_args();
- args.tableNameOrRegionName = tableNameOrRegionName;
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ args.setTableNameOrRegionName(tableNameOrRegionName);
+ sendBase("majorCompact", args);
}
- public void recv_majorCompact() throws IOError, TException
- {
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
+ public void recv_majorCompact() throws IOError, org.apache.thrift.TException
+ {
majorCompact_result result = new majorCompact_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "majorCompact");
if (result.io != null) {
throw result.io;
}
return;
}
- public List<byte[]> getTableNames() throws IOError, TException
+ public List<ByteBuffer> getTableNames() throws IOError, org.apache.thrift.TException
{
send_getTableNames();
return recv_getTableNames();
}
- public void send_getTableNames() throws TException
+ public void send_getTableNames() throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("getTableNames", TMessageType.CALL, seqid_));
getTableNames_args args = new getTableNames_args();
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ sendBase("getTableNames", args);
}
- public List<byte[]> recv_getTableNames() throws IOError, TException
- {
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
+ public List<ByteBuffer> recv_getTableNames() throws IOError, org.apache.thrift.TException
+ {
getTableNames_result result = new getTableNames_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "getTableNames");
if (result.isSetSuccess()) {
return result.success;
}
if (result.io != null) {
throw result.io;
}
- throw new TApplicationException(TApplicationException.MISSING_RESULT, "getTableNames failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTableNames failed: unknown result");
}
- public Map<byte[],ColumnDescriptor> getColumnDescriptors(byte[] tableName) throws IOError, TException
+ public Map<ByteBuffer,ColumnDescriptor> getColumnDescriptors(ByteBuffer tableName) throws IOError, org.apache.thrift.TException
{
send_getColumnDescriptors(tableName);
return recv_getColumnDescriptors();
}
- public void send_getColumnDescriptors(byte[] tableName) throws TException
+ public void send_getColumnDescriptors(ByteBuffer tableName) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("getColumnDescriptors", TMessageType.CALL, seqid_));
getColumnDescriptors_args args = new getColumnDescriptors_args();
- args.tableName = tableName;
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ args.setTableName(tableName);
+ sendBase("getColumnDescriptors", args);
}
- public Map<byte[],ColumnDescriptor> recv_getColumnDescriptors() throws IOError, TException
- {
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
+ public Map<ByteBuffer,ColumnDescriptor> recv_getColumnDescriptors() throws IOError, org.apache.thrift.TException
+ {
getColumnDescriptors_result result = new getColumnDescriptors_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "getColumnDescriptors");
if (result.isSetSuccess()) {
return result.success;
}
if (result.io != null) {
throw result.io;
}
- throw new TApplicationException(TApplicationException.MISSING_RESULT, "getColumnDescriptors failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getColumnDescriptors failed: unknown result");
}
- public List<TRegionInfo> getTableRegions(byte[] tableName) throws IOError, TException
+ public List<TRegionInfo> getTableRegions(ByteBuffer tableName) throws IOError, org.apache.thrift.TException
{
send_getTableRegions(tableName);
return recv_getTableRegions();
}
- public void send_getTableRegions(byte[] tableName) throws TException
+ public void send_getTableRegions(ByteBuffer tableName) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("getTableRegions", TMessageType.CALL, seqid_));
getTableRegions_args args = new getTableRegions_args();
- args.tableName = tableName;
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ args.setTableName(tableName);
+ sendBase("getTableRegions", args);
}
- public List<TRegionInfo> recv_getTableRegions() throws IOError, TException
- {
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
+ public List<TRegionInfo> recv_getTableRegions() throws IOError, org.apache.thrift.TException
+ {
getTableRegions_result result = new getTableRegions_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "getTableRegions");
if (result.isSetSuccess()) {
return result.success;
}
if (result.io != null) {
throw result.io;
}
- throw new TApplicationException(TApplicationException.MISSING_RESULT, "getTableRegions failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTableRegions failed: unknown result");
}
- public void createTable(byte[] tableName, List<ColumnDescriptor> columnFamilies) throws IOError, IllegalArgument, AlreadyExists, TException
+ public void createTable(ByteBuffer tableName, List<ColumnDescriptor> columnFamilies) throws IOError, IllegalArgument, AlreadyExists, org.apache.thrift.TException
{
send_createTable(tableName, columnFamilies);
recv_createTable();
}
- public void send_createTable(byte[] tableName, List<ColumnDescriptor> columnFamilies) throws TException
+ public void send_createTable(ByteBuffer tableName, List<ColumnDescriptor> columnFamilies) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("createTable", TMessageType.CALL, seqid_));
createTable_args args = new createTable_args();
- args.tableName = tableName;
- args.columnFamilies = columnFamilies;
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ args.setTableName(tableName);
+ args.setColumnFamilies(columnFamilies);
+ sendBase("createTable", args);
}
- public void recv_createTable() throws IOError, IllegalArgument, AlreadyExists, TException
- {
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
+ public void recv_createTable() throws IOError, IllegalArgument, AlreadyExists, org.apache.thrift.TException
+ {
createTable_result result = new createTable_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "createTable");
if (result.io != null) {
throw result.io;
}
@@ -1033,566 +1039,416 @@ public class Hbase {
return;
}
- public void deleteTable(byte[] tableName) throws IOError, TException
+ public void deleteTable(ByteBuffer tableName) throws IOError, org.apache.thrift.TException
{
send_deleteTable(tableName);
recv_deleteTable();
}
- public void send_deleteTable(byte[] tableName) throws TException
+ public void send_deleteTable(ByteBuffer tableName) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("deleteTable", TMessageType.CALL, seqid_));
deleteTable_args args = new deleteTable_args();
- args.tableName = tableName;
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ args.setTableName(tableName);
+ sendBase("deleteTable", args);
}
- public void recv_deleteTable() throws IOError, TException
- {
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
+ public void recv_deleteTable() throws IOError, org.apache.thrift.TException
+ {
deleteTable_result result = new deleteTable_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "deleteTable");
if (result.io != null) {
throw result.io;
}
return;
}
- public List<TCell> get(byte[] tableName, byte[] row, byte[] column) throws IOError, TException
+ public List<TCell> get(ByteBuffer tableName, ByteBuffer row, ByteBuffer column) throws IOError, org.apache.thrift.TException
{
send_get(tableName, row, column);
return recv_get();
}
- public void send_get(byte[] tableName, byte[] row, byte[] column) throws TException
+ public void send_get(ByteBuffer tableName, ByteBuffer row, ByteBuffer column) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("get", TMessageType.CALL, seqid_));
get_args args = new get_args();
- args.tableName = tableName;
- args.row = row;
- args.column = column;
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ args.setTableName(tableName);
+ args.setRow(row);
+ args.setColumn(column);
+ sendBase("get", args);
}
- public List<TCell> recv_get() throws IOError, TException
- {
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
+ public List<TCell> recv_get() throws IOError, org.apache.thrift.TException
+ {
get_result result = new get_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "get");
if (result.isSetSuccess()) {
return result.success;
}
if (result.io != null) {
throw result.io;
}
- throw new TApplicationException(TApplicationException.MISSING_RESULT, "get failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "get failed: unknown result");
}
- public List<TCell> getVer(byte[] tableName, byte[] row, byte[] column, int numVersions) throws IOError, TException
+ public List<TCell> getVer(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, int numVersions) throws IOError, org.apache.thrift.TException
{
send_getVer(tableName, row, column, numVersions);
return recv_getVer();
}
- public void send_getVer(byte[] tableName, byte[] row, byte[] column, int numVersions) throws TException
+ public void send_getVer(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, int numVersions) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("getVer", TMessageType.CALL, seqid_));
getVer_args args = new getVer_args();
- args.tableName = tableName;
- args.row = row;
- args.column = column;
- args.numVersions = numVersions;
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
- }
-
- public List<TCell> recv_getVer() throws IOError, TException
- {
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
+ args.setTableName(tableName);
+ args.setRow(row);
+ args.setColumn(column);
+ args.setNumVersions(numVersions);
+ sendBase("getVer", args);
+ }
+
+ public List<TCell> recv_getVer() throws IOError, org.apache.thrift.TException
+ {
getVer_result result = new getVer_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "getVer");
if (result.isSetSuccess()) {
return result.success;
}
if (result.io != null) {
throw result.io;
}
- throw new TApplicationException(TApplicationException.MISSING_RESULT, "getVer failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getVer failed: unknown result");
}
- public List<TCell> getVerTs(byte[] tableName, byte[] row, byte[] column, long timestamp, int numVersions) throws IOError, TException
+ public List<TCell> getVerTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, int numVersions) throws IOError, org.apache.thrift.TException
{
send_getVerTs(tableName, row, column, timestamp, numVersions);
return recv_getVerTs();
}
- public void send_getVerTs(byte[] tableName, byte[] row, byte[] column, long timestamp, int numVersions) throws TException
+ public void send_getVerTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, int numVersions) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("getVerTs", TMessageType.CALL, seqid_));
getVerTs_args args = new getVerTs_args();
- args.tableName = tableName;
- args.row = row;
- args.column = column;
- args.timestamp = timestamp;
- args.numVersions = numVersions;
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
- }
-
- public List<TCell> recv_getVerTs() throws IOError, TException
- {
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
+ args.setTableName(tableName);
+ args.setRow(row);
+ args.setColumn(column);
+ args.setTimestamp(timestamp);
+ args.setNumVersions(numVersions);
+ sendBase("getVerTs", args);
+ }
+
+ public List<TCell> recv_getVerTs() throws IOError, org.apache.thrift.TException
+ {
getVerTs_result result = new getVerTs_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "getVerTs");
if (result.isSetSuccess()) {
return result.success;
}
if (result.io != null) {
throw result.io;
}
- throw new TApplicationException(TApplicationException.MISSING_RESULT, "getVerTs failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getVerTs failed: unknown result");
}
- public List<TRowResult> getRow(byte[] tableName, byte[] row) throws IOError, TException
+ public List<TRowResult> getRow(ByteBuffer tableName, ByteBuffer row) throws IOError, org.apache.thrift.TException
{
send_getRow(tableName, row);
return recv_getRow();
}
- public void send_getRow(byte[] tableName, byte[] row) throws TException
+ public void send_getRow(ByteBuffer tableName, ByteBuffer row) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("getRow", TMessageType.CALL, seqid_));
getRow_args args = new getRow_args();
- args.tableName = tableName;
- args.row = row;
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ args.setTableName(tableName);
+ args.setRow(row);
+ sendBase("getRow", args);
}
- public List<TRowResult> recv_getRow() throws IOError, TException
- {
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
+ public List<TRowResult> recv_getRow() throws IOError, org.apache.thrift.TException
+ {
getRow_result result = new getRow_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "getRow");
if (result.isSetSuccess()) {
return result.success;
}
if (result.io != null) {
throw result.io;
}
- throw new TApplicationException(TApplicationException.MISSING_RESULT, "getRow failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRow failed: unknown result");
}
- public List<TRowResult> getRowWithColumns(byte[] tableName, byte[] row, List<byte[]> columns) throws IOError, TException
+ public List<TRowResult> getRowWithColumns(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns) throws IOError, org.apache.thrift.TException
{
send_getRowWithColumns(tableName, row, columns);
return recv_getRowWithColumns();
}
- public void send_getRowWithColumns(byte[] tableName, byte[] row, List<byte[]> columns) throws TException
+ public void send_getRowWithColumns(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("getRowWithColumns", TMessageType.CALL, seqid_));
getRowWithColumns_args args = new getRowWithColumns_args();
- args.tableName = tableName;
- args.row = row;
- args.columns = columns;
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ args.setTableName(tableName);
+ args.setRow(row);
+ args.setColumns(columns);
+ sendBase("getRowWithColumns", args);
}
- public List<TRowResult> recv_getRowWithColumns() throws IOError, TException
- {
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
+ public List<TRowResult> recv_getRowWithColumns() throws IOError, org.apache.thrift.TException
+ {
getRowWithColumns_result result = new getRowWithColumns_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "getRowWithColumns");
if (result.isSetSuccess()) {
return result.success;
}
if (result.io != null) {
throw result.io;
}
- throw new TApplicationException(TApplicationException.MISSING_RESULT, "getRowWithColumns failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRowWithColumns failed: unknown result");
}
- public List<TRowResult> getRowTs(byte[] tableName, byte[] row, long timestamp) throws IOError, TException
+ public List<TRowResult> getRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp) throws IOError, org.apache.thrift.TException
{
send_getRowTs(tableName, row, timestamp);
return recv_getRowTs();
}
- public void send_getRowTs(byte[] tableName, byte[] row, long timestamp) throws TException
+ public void send_getRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("getRowTs", TMessageType.CALL, seqid_));
getRowTs_args args = new getRowTs_args();
- args.tableName = tableName;
- args.row = row;
- args.timestamp = timestamp;
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ args.setTableName(tableName);
+ args.setRow(row);
+ args.setTimestamp(timestamp);
+ sendBase("getRowTs", args);
}
- public List<TRowResult> recv_getRowTs() throws IOError, TException
- {
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
+ public List<TRowResult> recv_getRowTs() throws IOError, org.apache.thrift.TException
+ {
getRowTs_result result = new getRowTs_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "getRowTs");
if (result.isSetSuccess()) {
return result.success;
}
if (result.io != null) {
throw result.io;
}
- throw new TApplicationException(TApplicationException.MISSING_RESULT, "getRowTs failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRowTs failed: unknown result");
}
- public List<TRowResult> getRowWithColumnsTs(byte[] tableName, byte[] row, List<byte[]> columns, long timestamp) throws IOError, TException
+ public List<TRowResult> getRowWithColumnsTs(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, long timestamp) throws IOError, org.apache.thrift.TException
{
send_getRowWithColumnsTs(tableName, row, columns, timestamp);
return recv_getRowWithColumnsTs();
}
- public void send_getRowWithColumnsTs(byte[] tableName, byte[] row, List<byte[]> columns, long timestamp) throws TException
+ public void send_getRowWithColumnsTs(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, long timestamp) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("getRowWithColumnsTs", TMessageType.CALL, seqid_));
getRowWithColumnsTs_args args = new getRowWithColumnsTs_args();
- args.tableName = tableName;
- args.row = row;
- args.columns = columns;
- args.timestamp = timestamp;
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
- }
-
- public List<TRowResult> recv_getRowWithColumnsTs() throws IOError, TException
- {
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
+ args.setTableName(tableName);
+ args.setRow(row);
+ args.setColumns(columns);
+ args.setTimestamp(timestamp);
+ sendBase("getRowWithColumnsTs", args);
+ }
+
+ public List<TRowResult> recv_getRowWithColumnsTs() throws IOError, org.apache.thrift.TException
+ {
getRowWithColumnsTs_result result = new getRowWithColumnsTs_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "getRowWithColumnsTs");
if (result.isSetSuccess()) {
return result.success;
}
if (result.io != null) {
throw result.io;
}
- throw new TApplicationException(TApplicationException.MISSING_RESULT, "getRowWithColumnsTs failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRowWithColumnsTs failed: unknown result");
}
- public List<TRowResult> getRowWithColumnPrefix(byte[] tableName, byte[] row, byte[] prefix) throws IOError, TException
+ public List<TRowResult> getRowWithColumnPrefix(ByteBuffer tableName, ByteBuffer row, ByteBuffer prefix) throws IOError, org.apache.thrift.TException
{
send_getRowWithColumnPrefix(tableName, row, prefix);
return recv_getRowWithColumnPrefix();
}
- public void send_getRowWithColumnPrefix(byte[] tableName, byte[] row, byte[] prefix) throws TException
+ public void send_getRowWithColumnPrefix(ByteBuffer tableName, ByteBuffer row, ByteBuffer prefix) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("getRowWithColumnPrefix", TMessageType.CALL, seqid_));
getRowWithColumnPrefix_args args = new getRowWithColumnPrefix_args();
- args.tableName = tableName;
- args.row = row;
- args.prefix = prefix;
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ args.setTableName(tableName);
+ args.setRow(row);
+ args.setPrefix(prefix);
+ sendBase("getRowWithColumnPrefix", args);
}
- public List<TRowResult> recv_getRowWithColumnPrefix() throws IOError, TException
- {
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
+ public List<TRowResult> recv_getRowWithColumnPrefix() throws IOError, org.apache.thrift.TException
+ {
getRowWithColumnPrefix_result result = new getRowWithColumnPrefix_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "getRowWithColumnPrefix");
if (result.isSetSuccess()) {
return result.success;
}
if (result.io != null) {
throw result.io;
}
- throw new TApplicationException(TApplicationException.MISSING_RESULT, "getRowWithColumnPrefix failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRowWithColumnPrefix failed: unknown result");
}
- public List<TRowResult> getRowWithColumnPrefixTs(byte[] tableName, byte[] row, byte[] prefix, long timestamp) throws IOError, TException
+ public List<TRowResult> getRowWithColumnPrefixTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer prefix, long timestamp) throws IOError, org.apache.thrift.TException
{
send_getRowWithColumnPrefixTs(tableName, row, prefix, timestamp);
return recv_getRowWithColumnPrefixTs();
}
- public void send_getRowWithColumnPrefixTs(byte[] tableName, byte[] row, byte[] prefix, long timestamp) throws TException
+ public void send_getRowWithColumnPrefixTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer prefix, long timestamp) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("getRowWithColumnPrefixTs", TMessageType.CALL, seqid_));
getRowWithColumnPrefixTs_args args = new getRowWithColumnPrefixTs_args();
- args.tableName = tableName;
- args.row = row;
- args.prefix = prefix;
- args.timestamp = timestamp;
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
- }
-
- public List<TRowResult> recv_getRowWithColumnPrefixTs() throws IOError, TException
- {
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
+ args.setTableName(tableName);
+ args.setRow(row);
+ args.setPrefix(prefix);
+ args.setTimestamp(timestamp);
+ sendBase("getRowWithColumnPrefixTs", args);
+ }
+
+ public List<TRowResult> recv_getRowWithColumnPrefixTs() throws IOError, org.apache.thrift.TException
+ {
getRowWithColumnPrefixTs_result result = new getRowWithColumnPrefixTs_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "getRowWithColumnPrefixTs");
if (result.isSetSuccess()) {
return result.success;
}
if (result.io != null) {
throw result.io;
}
- throw new TApplicationException(TApplicationException.MISSING_RESULT, "getRowWithColumnPrefixTs failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRowWithColumnPrefixTs failed: unknown result");
}
- public List<TRowResult> getRows(byte[] tableName, List<byte[]> rows) throws IOError, TException
+ public List<TRowResult> getRows(ByteBuffer tableName, List<ByteBuffer> rows) throws IOError, org.apache.thrift.TException
{
send_getRows(tableName, rows);
return recv_getRows();
}
- public void send_getRows(byte[] tableName, List<byte[]> rows) throws TException
+ public void send_getRows(ByteBuffer tableName, List<ByteBuffer> rows) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("getRows", TMessageType.CALL, seqid_));
getRows_args args = new getRows_args();
- args.tableName = tableName;
- args.rows = rows;
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ args.setTableName(tableName);
+ args.setRows(rows);
+ sendBase("getRows", args);
}
- public List<TRowResult> recv_getRows() throws IOError, TException
- {
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
+ public List<TRowResult> recv_getRows() throws IOError, org.apache.thrift.TException
+ {
getRows_result result = new getRows_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "getRows");
if (result.isSetSuccess()) {
return result.success;
}
if (result.io != null) {
throw result.io;
}
- throw new TApplicationException(TApplicationException.MISSING_RESULT, "getRows failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRows failed: unknown result");
}
- public List<TRowResult> getRowsTs(byte[] tableName, List<byte[]> rows, long timestamp) throws IOError, TException
+ public List<TRowResult> getRowsTs(ByteBuffer tableName, List<ByteBuffer> rows, long timestamp) throws IOError, org.apache.thrift.TException
{
send_getRowsTs(tableName, rows, timestamp);
return recv_getRowsTs();
}
- public void send_getRowsTs(byte[] tableName, List<byte[]> rows, long timestamp) throws TException
+ public void send_getRowsTs(ByteBuffer tableName, List<ByteBuffer> rows, long timestamp) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("getRowsTs", TMessageType.CALL, seqid_));
getRowsTs_args args = new getRowsTs_args();
- args.tableName = tableName;
- args.rows = rows;
- args.timestamp = timestamp;
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ args.setTableName(tableName);
+ args.setRows(rows);
+ args.setTimestamp(timestamp);
+ sendBase("getRowsTs", args);
}
- public List<TRowResult> recv_getRowsTs() throws IOError, TException
- {
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
+ public List<TRowResult> recv_getRowsTs() throws IOError, org.apache.thrift.TException
+ {
getRowsTs_result result = new getRowsTs_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "getRowsTs");
if (result.isSetSuccess()) {
return result.success;
}
if (result.io != null) {
throw result.io;
}
- throw new TApplicationException(TApplicationException.MISSING_RESULT, "getRowsTs failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRowsTs failed: unknown result");
}
- public List<TRowResult> getRowsWithColumns(byte[] tableName, List<byte[]> rows, List<byte[]> families) throws IOError, TException
+ public List<TRowResult> getRowsWithColumns(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> families) throws IOError, org.apache.thrift.TException
{
send_getRowsWithColumns(tableName, rows, families);
return recv_getRowsWithColumns();
}
- public void send_getRowsWithColumns(byte[] tableName, List<byte[]> rows, List<byte[]> families) throws TException
+ public void send_getRowsWithColumns(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> families) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("getRowsWithColumns", TMessageType.CALL, seqid_));
getRowsWithColumns_args args = new getRowsWithColumns_args();
- args.tableName = tableName;
- args.rows = rows;
- args.families = families;
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ args.setTableName(tableName);
+ args.setRows(rows);
+ args.setFamilies(families);
+ sendBase("getRowsWithColumns", args);
}
- public List<TRowResult> recv_getRowsWithColumns() throws IOError, TException
- {
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
+ public List<TRowResult> recv_getRowsWithColumns() throws IOError, org.apache.thrift.TException
+ {
getRowsWithColumns_result result = new getRowsWithColumns_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "getRowsWithColumns");
if (result.isSetSuccess()) {
return result.success;
}
if (result.io != null) {
throw result.io;
}
- throw new TApplicationException(TApplicationException.MISSING_RESULT, "getRowsWithColumns failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRowsWithColumns failed: unknown result");
}
- public List<TRowResult> getRowsWithColumnsTs(byte[] tableName, List<byte[]> rows, List<byte[]> families, long timestamp) throws IOError, TException
+ public List<TRowResult> getRowsWithColumnsTs(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> families, long timestamp) throws IOError, org.apache.thrift.TException
{
send_getRowsWithColumnsTs(tableName, rows, families, timestamp);
return recv_getRowsWithColumnsTs();
}
- public void send_getRowsWithColumnsTs(byte[] tableName, List<byte[]> rows, List<byte[]> families, long timestamp) throws TException
+ public void send_getRowsWithColumnsTs(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> families, long timestamp) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("getRowsWithColumnsTs", TMessageType.CALL, seqid_));
getRowsWithColumnsTs_args args = new getRowsWithColumnsTs_args();
- args.tableName = tableName;
- args.rows = rows;
- args.families = families;
- args.timestamp = timestamp;
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
- }
-
- public List<TRowResult> recv_getRowsWithColumnsTs() throws IOError, TException
- {
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
+ args.setTableName(tableName);
+ args.setRows(rows);
+ args.setFamilies(families);
+ args.setTimestamp(timestamp);
+ sendBase("getRowsWithColumnsTs", args);
+ }
+
+ public List<TRowResult> recv_getRowsWithColumnsTs() throws IOError, org.apache.thrift.TException
+ {
getRowsWithColumnsTs_result result = new getRowsWithColumnsTs_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "getRowsWithColumnsTs");
if (result.isSetSuccess()) {
return result.success;
}
if (result.io != null) {
throw result.io;
}
- throw new TApplicationException(TApplicationException.MISSING_RESULT, "getRowsWithColumnsTs failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRowsWithColumnsTs failed: unknown result");
}
- public void mutateRow(byte[] tableName, byte[] row, List<Mutation> mutations) throws IOError, IllegalArgument, TException
+ public void mutateRow(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations) throws IOError, IllegalArgument, org.apache.thrift.TException
{
send_mutateRow(tableName, row, mutations);
recv_mutateRow();
}
- public void send_mutateRow(byte[] tableName, byte[] row, List<Mutation> mutations) throws TException
+ public void send_mutateRow(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("mutateRow", TMessageType.CALL, seqid_));
mutateRow_args args = new mutateRow_args();
- args.tableName = tableName;
- args.row = row;
- args.mutations = mutations;
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ args.setTableName(tableName);
+ args.setRow(row);
+ args.setMutations(mutations);
+ sendBase("mutateRow", args);
}
- public void recv_mutateRow() throws IOError, IllegalArgument, TException
- {
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
+ public void recv_mutateRow() throws IOError, IllegalArgument, org.apache.thrift.TException
+ {
mutateRow_result result = new mutateRow_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "mutateRow");
if (result.io != null) {
throw result.io;
}
@@ -1602,36 +1458,26 @@ public class Hbase {
return;
}
- public void mutateRowTs(byte[] tableName, byte[] row, List<Mutation> mutations, long timestamp) throws IOError, IllegalArgument, TException
+ public void mutateRowTs(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, long timestamp) throws IOError, IllegalArgument, org.apache.thrift.TException
{
send_mutateRowTs(tableName, row, mutations, timestamp);
recv_mutateRowTs();
}
- public void send_mutateRowTs(byte[] tableName, byte[] row, List<Mutation> mutations, long timestamp) throws TException
+ public void send_mutateRowTs(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, long timestamp) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("mutateRowTs", TMessageType.CALL, seqid_));
mutateRowTs_args args = new mutateRowTs_args();
- args.tableName = tableName;
- args.row = row;
- args.mutations = mutations;
- args.timestamp = timestamp;
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
- }
-
- public void recv_mutateRowTs() throws IOError, IllegalArgument, TException
- {
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
+ args.setTableName(tableName);
+ args.setRow(row);
+ args.setMutations(mutations);
+ args.setTimestamp(timestamp);
+ sendBase("mutateRowTs", args);
+ }
+
+ public void recv_mutateRowTs() throws IOError, IllegalArgument, org.apache.thrift.TException
+ {
mutateRowTs_result result = new mutateRowTs_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "mutateRowTs");
if (result.io != null) {
throw result.io;
}
@@ -1641,34 +1487,24 @@ public class Hbase {
return;
}
- public void mutateRows(byte[] tableName, List<BatchMutation> rowBatches) throws IOError, IllegalArgument, TException
+ public void mutateRows(ByteBuffer tableName, List<BatchMutation> rowBatches) throws IOError, IllegalArgument, org.apache.thrift.TException
{
send_mutateRows(tableName, rowBatches);
recv_mutateRows();
}
- public void send_mutateRows(byte[] tableName, List<BatchMutation> rowBatches) throws TException
+ public void send_mutateRows(ByteBuffer tableName, List<BatchMutation> rowBatches) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("mutateRows", TMessageType.CALL, seqid_));
mutateRows_args args = new mutateRows_args();
- args.tableName = tableName;
- args.rowBatches = rowBatches;
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ args.setTableName(tableName);
+ args.setRowBatches(rowBatches);
+ sendBase("mutateRows", args);
}
- public void recv_mutateRows() throws IOError, IllegalArgument, TException
- {
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
+ public void recv_mutateRows() throws IOError, IllegalArgument, org.apache.thrift.TException
+ {
mutateRows_result result = new mutateRows_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "mutateRows");
if (result.io != null) {
throw result.io;
}
@@ -1678,35 +1514,25 @@ public class Hbase {
return;
}
- public void mutateRowsTs(byte[] tableName, List<BatchMutation> rowBatches, long timestamp) throws IOError, IllegalArgument, TException
+ public void mutateRowsTs(ByteBuffer tableName, List<BatchMutation> rowBatches, long timestamp) throws IOError, IllegalArgument, org.apache.thrift.TException
{
send_mutateRowsTs(tableName, rowBatches, timestamp);
recv_mutateRowsTs();
}
- public void send_mutateRowsTs(byte[] tableName, List<BatchMutation> rowBatches, long timestamp) throws TException
+ public void send_mutateRowsTs(ByteBuffer tableName, List<BatchMutation> rowBatches, long timestamp) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("mutateRowsTs", TMessageType.CALL, seqid_));
mutateRowsTs_args args = new mutateRowsTs_args();
- args.tableName = tableName;
- args.rowBatches = rowBatches;
- args.timestamp = timestamp;
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
+ args.setTableName(tableName);
+ args.setRowBatches(rowBatches);
+ args.setTimestamp(timestamp);
+ sendBase("mutateRowsTs", args);
}
- public void recv_mutateRowsTs() throws IOError, IllegalArgument, TException
- {
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
+ public void recv_mutateRowsTs() throws IOError, IllegalArgument, org.apache.thrift.TException
+ {
mutateRowsTs_result result = new mutateRowsTs_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "mutateRowsTs");
if (result.io != null) {
throw result.io;
}
@@ -1716,37 +1542,27 @@ public class Hbase {
return;
}
- public boolean checkAndMutateRow(byte[] tableName, byte[] row, byte[] columnCheck, byte[] valueCheck, List<Mutation> mutations) throws IOError, IllegalArgument, TException
+ public boolean checkAndMutateRow(ByteBuffer tableName, ByteBuffer row, ByteBuffer columnCheck, ByteBuffer valueCheck, List<Mutation> mutations) throws IOError, IllegalArgument, org.apache.thrift.TException
{
send_checkAndMutateRow(tableName, row, columnCheck, valueCheck, mutations);
return recv_checkAndMutateRow();
}
- public void send_checkAndMutateRow(byte[] tableName, byte[] row, byte[] columnCheck, byte[] valueCheck, List<Mutation> mutations) throws TException
+ public void send_checkAndMutateRow(ByteBuffer tableName, ByteBuffer row, ByteBuffer columnCheck, ByteBuffer valueCheck, List<Mutation> mutations) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("checkAndMutateRow", TMessageType.CALL, seqid_));
checkAndMutateRow_args args = new checkAndMutateRow_args();
- args.tableName = tableName;
- args.row = row;
- args.columnCheck = columnCheck;
- args.valueCheck = valueCheck;
- args.mutations = mutations;
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
- }
-
- public boolean recv_checkAndMutateRow() throws IOError, IllegalArgument, TException
- {
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
+ args.setTableName(tableName);
+ args.setRow(row);
+ args.setColumnCheck(columnCheck);
+ args.setValueCheck(valueCheck);
+ args.setMutations(mutations);
+ sendBase("checkAndMutateRow", args);
+ }
+
+ public boolean recv_checkAndMutateRow() throws IOError, IllegalArgument, org.apache.thrift.TException
+ {
checkAndMutateRow_result result = new checkAndMutateRow_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
+ receiveBase(result, "checkAndMutateRow");
if (result.isSetSuccess()) {
return result.success;
}
@@ -1756,41 +1572,31 @@ public class Hbase {
if (result.ia != null) {
throw result.ia;
}
- throw new TApplicationException(TApplicationException.MISSING_RESULT, "checkAndMutateRow failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "checkAndMutateRow failed: unknown result");
}
- public boolean checkAndMutateRowTs(byte[] tableName, byte[] row, byte[] columnCheck, byte[] valueCheck, List<Mutation> mutations, long timestamp) throws IOError, IllegalArgument, TException
+ public boolean checkAndMutateRowTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer columnCheck, ByteBuffer valueCheck, List<Mutation> mutations, long timestamp) throws IOError, IllegalArgument, org.apache.thrift.TException
{
send_checkAndMutateRowTs(tableName, row, columnCheck, valueCheck, mutations, timestamp);
return recv_checkAndMutateRowTs();
}
- public void send_checkAndMutateRowTs(byte[] tableName, byte[] row, byte[] columnCheck, byte[] valueCheck, List<Mutation> mutations, long timestamp) throws TException
[... 54266 lines stripped ...]