You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2012/11/06 22:22:30 UTC
svn commit: r1406339 [6/17] - in /hbase/trunk: ./ examples/ hbase-examples/
hbase-examples/src/ hbase-examples/src/main/ hbase-examples/src/main/cpp/
hbase-examples/src/main/cpp/gen-cpp/ hbase-examples/src/main/java/
hbase-examples/src/main/java/org/ h...
Added: hbase/trunk/hbase-examples/src/main/java/org/apache/hadoop/hbase/thrift/generated/Hbase.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-examples/src/main/java/org/apache/hadoop/hbase/thrift/generated/Hbase.java?rev=1406339&view=auto
==============================================================================
--- hbase/trunk/hbase-examples/src/main/java/org/apache/hadoop/hbase/thrift/generated/Hbase.java (added)
+++ hbase/trunk/hbase-examples/src/main/java/org/apache/hadoop/hbase/thrift/generated/Hbase.java Tue Nov 6 21:22:27 2012
@@ -0,0 +1,53237 @@
+/**
+ * Autogenerated by Thrift Compiler (0.9.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.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 org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+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;
+
+public class Hbase {
+
+ public interface Iface {
+
+ /**
+ * Brings a table on-line (enables it)
+ *
+ * @param tableName name of the table
+ */
+ 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
+ * will tell the servers to stop serving it.
+ *
+ * @param tableName name of the table
+ */
+ 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(ByteBuffer tableName) throws IOError, org.apache.thrift.TException;
+
+ public void compact(ByteBuffer tableNameOrRegionName) throws IOError, org.apache.thrift.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<ByteBuffer> getTableNames() throws IOError, org.apache.thrift.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, org.apache.thrift.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, org.apache.thrift.TException;
+
+ /**
+ * Create a table with the specified column families. The name
+ * field for each ColumnDescriptor must be set and must end in a
+ * colon (:). All other fields are optional and will get default
+ * 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, org.apache.thrift.TException;
+
+ /**
+ * Deletes a table
+ *
+ * @throws IOError if table doesn't exist on server or there was some other
+ * problem
+ *
+ * @param tableName name of table to delete
+ */
+ public void deleteTable(ByteBuffer tableName) throws IOError, org.apache.thrift.TException;
+
+ /**
+ * Get a single TCell for the specified table, row, and column at the
+ * latest timestamp. Returns an empty list if no such value exists.
+ *
+ * @return value for specified row/column
+ *
+ * @param tableName name of table
+ *
+ * @param row row key
+ *
+ * @param column column name
+ *
+ * @param attributes Get attributes
+ */
+ public List<TCell> get(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
+
+ /**
+ * Get the specified number of versions for the specified table,
+ * row, and column.
+ *
+ * @return list of cells for specified row/column
+ *
+ * @param tableName name of table
+ *
+ * @param row row key
+ *
+ * @param column column name
+ *
+ * @param numVersions number of versions to retrieve
+ *
+ * @param attributes Get attributes
+ */
+ public List<TCell> getVer(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, int numVersions, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
+
+ /**
+ * Get the specified number of versions for the specified table,
+ * row, and column. Only versions less than or equal to the specified
+ * timestamp will be returned.
+ *
+ * @return list of cells for specified row/column
+ *
+ * @param tableName name of table
+ *
+ * @param row row key
+ *
+ * @param column column name
+ *
+ * @param timestamp timestamp
+ *
+ * @param numVersions number of versions to retrieve
+ *
+ * @param attributes Get attributes
+ */
+ public List<TCell> getVerTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, int numVersions, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
+
+ /**
+ * Get all the data for the specified table and row at the latest
+ * timestamp. Returns an empty list if the row does not exist.
+ *
+ * @return TRowResult containing the row and map of columns to TCells
+ *
+ * @param tableName name of table
+ *
+ * @param row row key
+ *
+ * @param attributes Get attributes
+ */
+ public List<TRowResult> getRow(ByteBuffer tableName, ByteBuffer row, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
+
+ /**
+ * Get the specified columns for the specified table and row at the latest
+ * timestamp. Returns an empty list if the row does not exist.
+ *
+ * @return TRowResult containing the row and map of columns to TCells
+ *
+ * @param tableName name of table
+ *
+ * @param row row key
+ *
+ * @param columns List of columns to return, null for all columns
+ *
+ * @param attributes Get attributes
+ */
+ public List<TRowResult> getRowWithColumns(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
+
+ /**
+ * Get all the data for the specified table and row at the specified
+ * timestamp. Returns an empty list if the row does not exist.
+ *
+ * @return TRowResult containing the row and map of columns to TCells
+ *
+ * @param tableName name of the table
+ *
+ * @param row row key
+ *
+ * @param timestamp timestamp
+ *
+ * @param attributes Get attributes
+ */
+ public List<TRowResult> getRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
+
+ /**
+ * Get the specified columns for the specified table and row at the specified
+ * timestamp. Returns an empty list if the row does not exist.
+ *
+ * @return TRowResult containing the row and map of columns to TCells
+ *
+ * @param tableName name of table
+ *
+ * @param row row key
+ *
+ * @param columns List of columns to return, null for all columns
+ *
+ * @param timestamp
+ * @param attributes Get attributes
+ */
+ public List<TRowResult> getRowWithColumnsTs(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
+
+ /**
+ * Get all the data for the specified table and rows at the latest
+ * timestamp. Returns an empty list if no rows exist.
+ *
+ * @return TRowResult containing the rows and map of columns to TCells
+ *
+ * @param tableName name of table
+ *
+ * @param rows row keys
+ *
+ * @param attributes Get attributes
+ */
+ public List<TRowResult> getRows(ByteBuffer tableName, List<ByteBuffer> rows, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
+
+ /**
+ * Get the specified columns for the specified table and rows at the latest
+ * timestamp. Returns an empty list if no rows exist.
+ *
+ * @return TRowResult containing the rows and map of columns to TCells
+ *
+ * @param tableName name of table
+ *
+ * @param rows row keys
+ *
+ * @param columns List of columns to return, null for all columns
+ *
+ * @param attributes Get attributes
+ */
+ public List<TRowResult> getRowsWithColumns(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
+
+ /**
+ * Get all the data for the specified table and rows at the specified
+ * timestamp. Returns an empty list if no rows exist.
+ *
+ * @return TRowResult containing the rows and map of columns to TCells
+ *
+ * @param tableName name of the table
+ *
+ * @param rows row keys
+ *
+ * @param timestamp timestamp
+ *
+ * @param attributes Get attributes
+ */
+ public List<TRowResult> getRowsTs(ByteBuffer tableName, List<ByteBuffer> rows, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
+
+ /**
+ * Get the specified columns for the specified table and rows at the specified
+ * timestamp. Returns an empty list if no rows exist.
+ *
+ * @return TRowResult containing the rows and map of columns to TCells
+ *
+ * @param tableName name of table
+ *
+ * @param rows row keys
+ *
+ * @param columns List of columns to return, null for all columns
+ *
+ * @param timestamp
+ * @param attributes Get attributes
+ */
+ public List<TRowResult> getRowsWithColumnsTs(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
+
+ /**
+ * Apply a series of mutations (updates/deletes) to a row in a
+ * single transaction. If an exception is thrown, then the
+ * transaction is aborted. Default current timestamp is used, and
+ * all entries will have an identical timestamp.
+ *
+ * @param tableName name of table
+ *
+ * @param row row key
+ *
+ * @param mutations list of mutation commands
+ *
+ * @param attributes Mutation attributes
+ */
+ public void mutateRow(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, IllegalArgument, org.apache.thrift.TException;
+
+ /**
+ * Apply a series of mutations (updates/deletes) to a row in a
+ * single transaction. If an exception is thrown, then the
+ * transaction is aborted. The specified timestamp is used, and
+ * all entries will have an identical timestamp.
+ *
+ * @param tableName name of table
+ *
+ * @param row row key
+ *
+ * @param mutations list of mutation commands
+ *
+ * @param timestamp timestamp
+ *
+ * @param attributes Mutation attributes
+ */
+ public void mutateRowTs(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, IllegalArgument, org.apache.thrift.TException;
+
+ /**
+ * Apply a series of batches (each a series of mutations on a single row)
+ * in a single transaction. If an exception is thrown, then the
+ * transaction is aborted. Default current timestamp is used, and
+ * all entries will have an identical timestamp.
+ *
+ * @param tableName name of table
+ *
+ * @param rowBatches list of row batches
+ *
+ * @param attributes Mutation attributes
+ */
+ public void mutateRows(ByteBuffer tableName, List<BatchMutation> rowBatches, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, IllegalArgument, org.apache.thrift.TException;
+
+ /**
+ * Apply a series of batches (each a series of mutations on a single row)
+ * in a single transaction. If an exception is thrown, then the
+ * transaction is aborted. The specified timestamp is used, and
+ * all entries will have an identical timestamp.
+ *
+ * @param tableName name of table
+ *
+ * @param rowBatches list of row batches
+ *
+ * @param timestamp timestamp
+ *
+ * @param attributes Mutation attributes
+ */
+ public void mutateRowsTs(ByteBuffer tableName, List<BatchMutation> rowBatches, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, IllegalArgument, org.apache.thrift.TException;
+
+ /**
+ * Atomically increment the column value specified. Returns the next value post increment.
+ *
+ * @param tableName name of table
+ *
+ * @param row row to increment
+ *
+ * @param column name of column
+ *
+ * @param value amount to increment by
+ */
+ 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.
+ *
+ * @param tableName name of table
+ *
+ * @param row Row to update
+ *
+ * @param column name of column whose value is to be deleted
+ *
+ * @param attributes Delete attributes
+ */
+ public void deleteAll(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
+
+ /**
+ * Delete all cells that match the passed row and column and whose
+ * timestamp is equal-to or older than the passed timestamp.
+ *
+ * @param tableName name of table
+ *
+ * @param row Row to update
+ *
+ * @param column name of column whose value is to be deleted
+ *
+ * @param timestamp timestamp
+ *
+ * @param attributes Delete attributes
+ */
+ public void deleteAllTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
+
+ /**
+ * Completely delete the row's cells.
+ *
+ * @param tableName name of table
+ *
+ * @param row key of the row to be completely deleted.
+ *
+ * @param attributes Delete attributes
+ */
+ public void deleteAllRow(ByteBuffer tableName, ByteBuffer row, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
+
+ /**
+ * Increment a cell by the ammount.
+ * Increments can be applied async if hbase.regionserver.thrift.coalesceIncrement is set to true.
+ * False is the default. Turn to true if you need the extra performance and can accept some
+ * data loss if a thrift server dies with increments still in the queue.
+ *
+ * @param increment The single increment to apply
+ */
+ public void increment(TIncrement increment) throws IOError, org.apache.thrift.TException;
+
+ public void incrementRows(List<TIncrement> increments) throws IOError, org.apache.thrift.TException;
+
+ /**
+ * Completely delete the row's cells marked with a timestamp
+ * equal-to or older than the passed timestamp.
+ *
+ * @param tableName name of table
+ *
+ * @param row key of the row to be completely deleted.
+ *
+ * @param timestamp timestamp
+ *
+ * @param attributes Delete attributes
+ */
+ public void deleteAllRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
+
+ /**
+ * Get a scanner on the current table, using the Scan instance
+ * for the scan parameters.
+ *
+ * @param tableName name of table
+ *
+ * @param scan Scan instance
+ *
+ * @param attributes Scan attributes
+ */
+ public int scannerOpenWithScan(ByteBuffer tableName, TScan scan, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
+
+ /**
+ * Get a scanner on the current table starting at the specified row and
+ * ending at the last row in the table. Return the specified columns.
+ *
+ * @return scanner id to be used with other scanner procedures
+ *
+ * @param tableName name of table
+ *
+ * @param startRow Starting row in table to scan.
+ * Send "" (empty string) to start at the first row.
+ *
+ * @param columns columns to scan. If column name is a column family, all
+ * columns of the specified column family are returned. It's also possible
+ * to pass a regex in the column qualifier.
+ *
+ * @param attributes Scan attributes
+ */
+ public int scannerOpen(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
+
+ /**
+ * Get a scanner on the current table starting and stopping at the
+ * specified rows. ending at the last row in the table. Return the
+ * specified columns.
+ *
+ * @return scanner id to be used with other scanner procedures
+ *
+ * @param tableName name of table
+ *
+ * @param startRow Starting row in table to scan.
+ * Send "" (empty string) to start at the first row.
+ *
+ * @param stopRow row to stop scanning on. This row is *not* included in the
+ * scanner's results
+ *
+ * @param columns columns to scan. If column name is a column family, all
+ * columns of the specified column family are returned. It's also possible
+ * to pass a regex in the column qualifier.
+ *
+ * @param attributes Scan attributes
+ */
+ public int scannerOpenWithStop(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
+
+ /**
+ * Open a scanner for a given prefix. That is all rows will have the specified
+ * prefix. No other rows will be returned.
+ *
+ * @return scanner id to use with other scanner calls
+ *
+ * @param tableName name of table
+ *
+ * @param startAndPrefix the prefix (and thus start row) of the keys you want
+ *
+ * @param columns the columns you want returned
+ *
+ * @param attributes Scan attributes
+ */
+ public int scannerOpenWithPrefix(ByteBuffer tableName, ByteBuffer startAndPrefix, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
+
+ /**
+ * Get a scanner on the current table starting at the specified row and
+ * ending at the last row in the table. Return the specified columns.
+ * Only values with the specified timestamp are returned.
+ *
+ * @return scanner id to be used with other scanner procedures
+ *
+ * @param tableName name of table
+ *
+ * @param startRow Starting row in table to scan.
+ * Send "" (empty string) to start at the first row.
+ *
+ * @param columns columns to scan. If column name is a column family, all
+ * columns of the specified column family are returned. It's also possible
+ * to pass a regex in the column qualifier.
+ *
+ * @param timestamp timestamp
+ *
+ * @param attributes Scan attributes
+ */
+ public int scannerOpenTs(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
+
+ /**
+ * Get a scanner on the current table starting and stopping at the
+ * specified rows. ending at the last row in the table. Return the
+ * specified columns. Only values with the specified timestamp are
+ * returned.
+ *
+ * @return scanner id to be used with other scanner procedures
+ *
+ * @param tableName name of table
+ *
+ * @param startRow Starting row in table to scan.
+ * Send "" (empty string) to start at the first row.
+ *
+ * @param stopRow row to stop scanning on. This row is *not* included in the
+ * scanner's results
+ *
+ * @param columns columns to scan. If column name is a column family, all
+ * columns of the specified column family are returned. It's also possible
+ * to pass a regex in the column qualifier.
+ *
+ * @param timestamp timestamp
+ *
+ * @param attributes Scan attributes
+ */
+ public int scannerOpenWithStopTs(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException;
+
+ /**
+ * Returns the scanner's current row value and advances to the next
+ * row in the table. When there are no more rows in the table, or a key
+ * greater-than-or-equal-to the scanner's 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
+ */
+ 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
+ * rows and advances to the next row in the table. When there are no more
+ * rows in the table, or a key greater-than-or-equal-to the scanner's
+ * 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
+ *
+ * @param nbRows number of results to return
+ */
+ public List<TRowResult> scannerGetList(int id, int nbRows) throws IOError, IllegalArgument, org.apache.thrift.TException;
+
+ /**
+ * Closes the server-state associated with an open scanner.
+ *
+ * @throws IllegalArgument if ScannerID is invalid
+ *
+ * @param id id of a scanner returned by scannerOpen
+ */
+ public void scannerClose(int id) throws IOError, IllegalArgument, org.apache.thrift.TException;
+
+ /**
+ * Get the row just before the specified one.
+ *
+ * @return value for specified row/column
+ *
+ * @param tableName name of table
+ *
+ * @param row row key
+ *
+ * @param family column name
+ */
+ public List<TCell> getRowOrBefore(ByteBuffer tableName, ByteBuffer row, ByteBuffer family) throws IOError, org.apache.thrift.TException;
+
+ /**
+ * Get the regininfo for the specified row. It scans
+ * the metatable to find region's start and end keys.
+ *
+ * @return value for specified row/column
+ *
+ * @param row row key
+ */
+ public TRegionInfo getRegionInfo(ByteBuffer row) throws IOError, org.apache.thrift.TException;
+
+ }
+
+ public interface AsyncIface {
+
+ public void enableTable(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.enableTable_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void disableTable(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.disableTable_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void isTableEnabled(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.isTableEnabled_call> resultHandler) throws org.apache.thrift.TException;
+
+ 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, Map<ByteBuffer,ByteBuffer> attributes, 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, Map<ByteBuffer,ByteBuffer> attributes, 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, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getVerTs_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void getRow(ByteBuffer tableName, ByteBuffer row, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRow_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void getRowWithColumns(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRowWithColumns_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void getRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, 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, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRowWithColumnsTs_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void getRows(ByteBuffer tableName, List<ByteBuffer> rows, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRows_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void getRowsWithColumns(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRowsWithColumns_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void getRowsTs(ByteBuffer tableName, List<ByteBuffer> rows, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRowsTs_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void getRowsWithColumnsTs(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRowsWithColumnsTs_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void mutateRow(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, Map<ByteBuffer,ByteBuffer> attributes, 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, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.mutateRowTs_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void mutateRows(ByteBuffer tableName, List<BatchMutation> rowBatches, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.mutateRows_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void mutateRowsTs(ByteBuffer tableName, List<BatchMutation> rowBatches, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.mutateRowsTs_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, Map<ByteBuffer,ByteBuffer> attributes, 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, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.deleteAllTs_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void deleteAllRow(ByteBuffer tableName, ByteBuffer row, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.deleteAllRow_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void increment(TIncrement increment, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.increment_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void incrementRows(List<TIncrement> increments, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.incrementRows_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void deleteAllRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.deleteAllRowTs_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void scannerOpenWithScan(ByteBuffer tableName, TScan scan, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.scannerOpenWithScan_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void scannerOpen(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.scannerOpen_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void scannerOpenWithStop(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.scannerOpenWithStop_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void scannerOpenWithPrefix(ByteBuffer tableName, ByteBuffer startAndPrefix, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes, 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, Map<ByteBuffer,ByteBuffer> attributes, 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, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.scannerOpenWithStopTs_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 getRowOrBefore(ByteBuffer tableName, ByteBuffer row, ByteBuffer family, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRowOrBefore_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 Client(org.apache.thrift.protocol.TProtocol prot)
+ {
+ super(prot, prot);
+ }
+
+ 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(ByteBuffer tableName) throws org.apache.thrift.TException
+ {
+ enableTable_args args = new enableTable_args();
+ args.setTableName(tableName);
+ sendBase("enableTable", args);
+ }
+
+ public void recv_enableTable() throws IOError, org.apache.thrift.TException
+ {
+ enableTable_result result = new enableTable_result();
+ receiveBase(result, "enableTable");
+ if (result.io != null) {
+ throw result.io;
+ }
+ return;
+ }
+
+ public void disableTable(ByteBuffer tableName) throws IOError, org.apache.thrift.TException
+ {
+ send_disableTable(tableName);
+ recv_disableTable();
+ }
+
+ public void send_disableTable(ByteBuffer tableName) throws org.apache.thrift.TException
+ {
+ disableTable_args args = new disableTable_args();
+ args.setTableName(tableName);
+ sendBase("disableTable", args);
+ }
+
+ public void recv_disableTable() throws IOError, org.apache.thrift.TException
+ {
+ disableTable_result result = new disableTable_result();
+ receiveBase(result, "disableTable");
+ if (result.io != null) {
+ throw result.io;
+ }
+ return;
+ }
+
+ public boolean isTableEnabled(ByteBuffer tableName) throws IOError, org.apache.thrift.TException
+ {
+ send_isTableEnabled(tableName);
+ return recv_isTableEnabled();
+ }
+
+ public void send_isTableEnabled(ByteBuffer tableName) throws org.apache.thrift.TException
+ {
+ isTableEnabled_args args = new isTableEnabled_args();
+ args.setTableName(tableName);
+ sendBase("isTableEnabled", args);
+ }
+
+ public boolean recv_isTableEnabled() throws IOError, org.apache.thrift.TException
+ {
+ isTableEnabled_result result = new isTableEnabled_result();
+ receiveBase(result, "isTableEnabled");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.io != null) {
+ throw result.io;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "isTableEnabled failed: unknown result");
+ }
+
+ public void compact(ByteBuffer tableNameOrRegionName) throws IOError, org.apache.thrift.TException
+ {
+ send_compact(tableNameOrRegionName);
+ recv_compact();
+ }
+
+ public void send_compact(ByteBuffer tableNameOrRegionName) throws org.apache.thrift.TException
+ {
+ compact_args args = new compact_args();
+ args.setTableNameOrRegionName(tableNameOrRegionName);
+ sendBase("compact", args);
+ }
+
+ public void recv_compact() throws IOError, org.apache.thrift.TException
+ {
+ compact_result result = new compact_result();
+ receiveBase(result, "compact");
+ if (result.io != null) {
+ throw result.io;
+ }
+ return;
+ }
+
+ public void majorCompact(ByteBuffer tableNameOrRegionName) throws IOError, org.apache.thrift.TException
+ {
+ send_majorCompact(tableNameOrRegionName);
+ recv_majorCompact();
+ }
+
+ public void send_majorCompact(ByteBuffer tableNameOrRegionName) throws org.apache.thrift.TException
+ {
+ majorCompact_args args = new majorCompact_args();
+ args.setTableNameOrRegionName(tableNameOrRegionName);
+ sendBase("majorCompact", args);
+ }
+
+ public void recv_majorCompact() throws IOError, org.apache.thrift.TException
+ {
+ majorCompact_result result = new majorCompact_result();
+ receiveBase(result, "majorCompact");
+ if (result.io != null) {
+ throw result.io;
+ }
+ return;
+ }
+
+ public List<ByteBuffer> getTableNames() throws IOError, org.apache.thrift.TException
+ {
+ send_getTableNames();
+ return recv_getTableNames();
+ }
+
+ public void send_getTableNames() throws org.apache.thrift.TException
+ {
+ getTableNames_args args = new getTableNames_args();
+ sendBase("getTableNames", args);
+ }
+
+ public List<ByteBuffer> recv_getTableNames() throws IOError, org.apache.thrift.TException
+ {
+ getTableNames_result result = new getTableNames_result();
+ receiveBase(result, "getTableNames");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.io != null) {
+ throw result.io;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTableNames failed: unknown result");
+ }
+
+ public Map<ByteBuffer,ColumnDescriptor> getColumnDescriptors(ByteBuffer tableName) throws IOError, org.apache.thrift.TException
+ {
+ send_getColumnDescriptors(tableName);
+ return recv_getColumnDescriptors();
+ }
+
+ public void send_getColumnDescriptors(ByteBuffer tableName) throws org.apache.thrift.TException
+ {
+ getColumnDescriptors_args args = new getColumnDescriptors_args();
+ args.setTableName(tableName);
+ sendBase("getColumnDescriptors", args);
+ }
+
+ public Map<ByteBuffer,ColumnDescriptor> recv_getColumnDescriptors() throws IOError, org.apache.thrift.TException
+ {
+ getColumnDescriptors_result result = new getColumnDescriptors_result();
+ receiveBase(result, "getColumnDescriptors");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.io != null) {
+ throw result.io;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getColumnDescriptors failed: unknown result");
+ }
+
+ public List<TRegionInfo> getTableRegions(ByteBuffer tableName) throws IOError, org.apache.thrift.TException
+ {
+ send_getTableRegions(tableName);
+ return recv_getTableRegions();
+ }
+
+ public void send_getTableRegions(ByteBuffer tableName) throws org.apache.thrift.TException
+ {
+ getTableRegions_args args = new getTableRegions_args();
+ args.setTableName(tableName);
+ sendBase("getTableRegions", args);
+ }
+
+ public List<TRegionInfo> recv_getTableRegions() throws IOError, org.apache.thrift.TException
+ {
+ getTableRegions_result result = new getTableRegions_result();
+ receiveBase(result, "getTableRegions");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.io != null) {
+ throw result.io;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTableRegions failed: unknown result");
+ }
+
+ 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(ByteBuffer tableName, List<ColumnDescriptor> columnFamilies) throws org.apache.thrift.TException
+ {
+ createTable_args args = new createTable_args();
+ args.setTableName(tableName);
+ args.setColumnFamilies(columnFamilies);
+ sendBase("createTable", args);
+ }
+
+ public void recv_createTable() throws IOError, IllegalArgument, AlreadyExists, org.apache.thrift.TException
+ {
+ createTable_result result = new createTable_result();
+ receiveBase(result, "createTable");
+ if (result.io != null) {
+ throw result.io;
+ }
+ if (result.ia != null) {
+ throw result.ia;
+ }
+ if (result.exist != null) {
+ throw result.exist;
+ }
+ return;
+ }
+
+ public void deleteTable(ByteBuffer tableName) throws IOError, org.apache.thrift.TException
+ {
+ send_deleteTable(tableName);
+ recv_deleteTable();
+ }
+
+ public void send_deleteTable(ByteBuffer tableName) throws org.apache.thrift.TException
+ {
+ deleteTable_args args = new deleteTable_args();
+ args.setTableName(tableName);
+ sendBase("deleteTable", args);
+ }
+
+ public void recv_deleteTable() throws IOError, org.apache.thrift.TException
+ {
+ deleteTable_result result = new deleteTable_result();
+ receiveBase(result, "deleteTable");
+ if (result.io != null) {
+ throw result.io;
+ }
+ return;
+ }
+
+ public List<TCell> get(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
+ {
+ send_get(tableName, row, column, attributes);
+ return recv_get();
+ }
+
+ public void send_get(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
+ {
+ get_args args = new get_args();
+ args.setTableName(tableName);
+ args.setRow(row);
+ args.setColumn(column);
+ args.setAttributes(attributes);
+ sendBase("get", args);
+ }
+
+ public List<TCell> recv_get() throws IOError, org.apache.thrift.TException
+ {
+ get_result result = new get_result();
+ receiveBase(result, "get");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.io != null) {
+ throw result.io;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "get failed: unknown result");
+ }
+
+ public List<TCell> getVer(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, int numVersions, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
+ {
+ send_getVer(tableName, row, column, numVersions, attributes);
+ return recv_getVer();
+ }
+
+ public void send_getVer(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, int numVersions, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
+ {
+ getVer_args args = new getVer_args();
+ args.setTableName(tableName);
+ args.setRow(row);
+ args.setColumn(column);
+ args.setNumVersions(numVersions);
+ args.setAttributes(attributes);
+ sendBase("getVer", args);
+ }
+
+ public List<TCell> recv_getVer() throws IOError, org.apache.thrift.TException
+ {
+ getVer_result result = new getVer_result();
+ receiveBase(result, "getVer");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.io != null) {
+ throw result.io;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getVer failed: unknown result");
+ }
+
+ public List<TCell> getVerTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, int numVersions, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
+ {
+ send_getVerTs(tableName, row, column, timestamp, numVersions, attributes);
+ return recv_getVerTs();
+ }
+
+ public void send_getVerTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, int numVersions, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
+ {
+ getVerTs_args args = new getVerTs_args();
+ args.setTableName(tableName);
+ args.setRow(row);
+ args.setColumn(column);
+ args.setTimestamp(timestamp);
+ args.setNumVersions(numVersions);
+ args.setAttributes(attributes);
+ sendBase("getVerTs", args);
+ }
+
+ public List<TCell> recv_getVerTs() throws IOError, org.apache.thrift.TException
+ {
+ getVerTs_result result = new getVerTs_result();
+ receiveBase(result, "getVerTs");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.io != null) {
+ throw result.io;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getVerTs failed: unknown result");
+ }
+
+ public List<TRowResult> getRow(ByteBuffer tableName, ByteBuffer row, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
+ {
+ send_getRow(tableName, row, attributes);
+ return recv_getRow();
+ }
+
+ public void send_getRow(ByteBuffer tableName, ByteBuffer row, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
+ {
+ getRow_args args = new getRow_args();
+ args.setTableName(tableName);
+ args.setRow(row);
+ args.setAttributes(attributes);
+ sendBase("getRow", args);
+ }
+
+ public List<TRowResult> recv_getRow() throws IOError, org.apache.thrift.TException
+ {
+ getRow_result result = new getRow_result();
+ receiveBase(result, "getRow");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.io != null) {
+ throw result.io;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRow failed: unknown result");
+ }
+
+ public List<TRowResult> getRowWithColumns(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
+ {
+ send_getRowWithColumns(tableName, row, columns, attributes);
+ return recv_getRowWithColumns();
+ }
+
+ public void send_getRowWithColumns(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
+ {
+ getRowWithColumns_args args = new getRowWithColumns_args();
+ args.setTableName(tableName);
+ args.setRow(row);
+ args.setColumns(columns);
+ args.setAttributes(attributes);
+ sendBase("getRowWithColumns", args);
+ }
+
+ public List<TRowResult> recv_getRowWithColumns() throws IOError, org.apache.thrift.TException
+ {
+ getRowWithColumns_result result = new getRowWithColumns_result();
+ receiveBase(result, "getRowWithColumns");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.io != null) {
+ throw result.io;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRowWithColumns failed: unknown result");
+ }
+
+ public List<TRowResult> getRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
+ {
+ send_getRowTs(tableName, row, timestamp, attributes);
+ return recv_getRowTs();
+ }
+
+ public void send_getRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
+ {
+ getRowTs_args args = new getRowTs_args();
+ args.setTableName(tableName);
+ args.setRow(row);
+ args.setTimestamp(timestamp);
+ args.setAttributes(attributes);
+ sendBase("getRowTs", args);
+ }
+
+ public List<TRowResult> recv_getRowTs() throws IOError, org.apache.thrift.TException
+ {
+ getRowTs_result result = new getRowTs_result();
+ receiveBase(result, "getRowTs");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.io != null) {
+ throw result.io;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRowTs failed: unknown result");
+ }
+
+ public List<TRowResult> getRowWithColumnsTs(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
+ {
+ send_getRowWithColumnsTs(tableName, row, columns, timestamp, attributes);
+ return recv_getRowWithColumnsTs();
+ }
+
+ public void send_getRowWithColumnsTs(ByteBuffer tableName, ByteBuffer row, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
+ {
+ getRowWithColumnsTs_args args = new getRowWithColumnsTs_args();
+ args.setTableName(tableName);
+ args.setRow(row);
+ args.setColumns(columns);
+ args.setTimestamp(timestamp);
+ args.setAttributes(attributes);
+ sendBase("getRowWithColumnsTs", args);
+ }
+
+ public List<TRowResult> recv_getRowWithColumnsTs() throws IOError, org.apache.thrift.TException
+ {
+ getRowWithColumnsTs_result result = new getRowWithColumnsTs_result();
+ receiveBase(result, "getRowWithColumnsTs");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.io != null) {
+ throw result.io;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRowWithColumnsTs failed: unknown result");
+ }
+
+ public List<TRowResult> getRows(ByteBuffer tableName, List<ByteBuffer> rows, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
+ {
+ send_getRows(tableName, rows, attributes);
+ return recv_getRows();
+ }
+
+ public void send_getRows(ByteBuffer tableName, List<ByteBuffer> rows, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
+ {
+ getRows_args args = new getRows_args();
+ args.setTableName(tableName);
+ args.setRows(rows);
+ args.setAttributes(attributes);
+ sendBase("getRows", args);
+ }
+
+ public List<TRowResult> recv_getRows() throws IOError, org.apache.thrift.TException
+ {
+ getRows_result result = new getRows_result();
+ receiveBase(result, "getRows");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.io != null) {
+ throw result.io;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRows failed: unknown result");
+ }
+
+ public List<TRowResult> getRowsWithColumns(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
+ {
+ send_getRowsWithColumns(tableName, rows, columns, attributes);
+ return recv_getRowsWithColumns();
+ }
+
+ public void send_getRowsWithColumns(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
+ {
+ getRowsWithColumns_args args = new getRowsWithColumns_args();
+ args.setTableName(tableName);
+ args.setRows(rows);
+ args.setColumns(columns);
+ args.setAttributes(attributes);
+ sendBase("getRowsWithColumns", args);
+ }
+
+ public List<TRowResult> recv_getRowsWithColumns() throws IOError, org.apache.thrift.TException
+ {
+ getRowsWithColumns_result result = new getRowsWithColumns_result();
+ receiveBase(result, "getRowsWithColumns");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.io != null) {
+ throw result.io;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRowsWithColumns failed: unknown result");
+ }
+
+ public List<TRowResult> getRowsTs(ByteBuffer tableName, List<ByteBuffer> rows, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
+ {
+ send_getRowsTs(tableName, rows, timestamp, attributes);
+ return recv_getRowsTs();
+ }
+
+ public void send_getRowsTs(ByteBuffer tableName, List<ByteBuffer> rows, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
+ {
+ getRowsTs_args args = new getRowsTs_args();
+ args.setTableName(tableName);
+ args.setRows(rows);
+ args.setTimestamp(timestamp);
+ args.setAttributes(attributes);
+ sendBase("getRowsTs", args);
+ }
+
+ public List<TRowResult> recv_getRowsTs() throws IOError, org.apache.thrift.TException
+ {
+ getRowsTs_result result = new getRowsTs_result();
+ receiveBase(result, "getRowsTs");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.io != null) {
+ throw result.io;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRowsTs failed: unknown result");
+ }
+
+ public List<TRowResult> getRowsWithColumnsTs(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
+ {
+ send_getRowsWithColumnsTs(tableName, rows, columns, timestamp, attributes);
+ return recv_getRowsWithColumnsTs();
+ }
+
+ public void send_getRowsWithColumnsTs(ByteBuffer tableName, List<ByteBuffer> rows, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
+ {
+ getRowsWithColumnsTs_args args = new getRowsWithColumnsTs_args();
+ args.setTableName(tableName);
+ args.setRows(rows);
+ args.setColumns(columns);
+ args.setTimestamp(timestamp);
+ args.setAttributes(attributes);
+ sendBase("getRowsWithColumnsTs", args);
+ }
+
+ public List<TRowResult> recv_getRowsWithColumnsTs() throws IOError, org.apache.thrift.TException
+ {
+ getRowsWithColumnsTs_result result = new getRowsWithColumnsTs_result();
+ receiveBase(result, "getRowsWithColumnsTs");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.io != null) {
+ throw result.io;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRowsWithColumnsTs failed: unknown result");
+ }
+
+ public void mutateRow(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, IllegalArgument, org.apache.thrift.TException
+ {
+ send_mutateRow(tableName, row, mutations, attributes);
+ recv_mutateRow();
+ }
+
+ public void send_mutateRow(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
+ {
+ mutateRow_args args = new mutateRow_args();
+ args.setTableName(tableName);
+ args.setRow(row);
+ args.setMutations(mutations);
+ args.setAttributes(attributes);
+ sendBase("mutateRow", args);
+ }
+
+ public void recv_mutateRow() throws IOError, IllegalArgument, org.apache.thrift.TException
+ {
+ mutateRow_result result = new mutateRow_result();
+ receiveBase(result, "mutateRow");
+ if (result.io != null) {
+ throw result.io;
+ }
+ if (result.ia != null) {
+ throw result.ia;
+ }
+ return;
+ }
+
+ public void mutateRowTs(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, IllegalArgument, org.apache.thrift.TException
+ {
+ send_mutateRowTs(tableName, row, mutations, timestamp, attributes);
+ recv_mutateRowTs();
+ }
+
+ public void send_mutateRowTs(ByteBuffer tableName, ByteBuffer row, List<Mutation> mutations, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
+ {
+ mutateRowTs_args args = new mutateRowTs_args();
+ args.setTableName(tableName);
+ args.setRow(row);
+ args.setMutations(mutations);
+ args.setTimestamp(timestamp);
+ args.setAttributes(attributes);
+ sendBase("mutateRowTs", args);
+ }
+
+ public void recv_mutateRowTs() throws IOError, IllegalArgument, org.apache.thrift.TException
+ {
+ mutateRowTs_result result = new mutateRowTs_result();
+ receiveBase(result, "mutateRowTs");
+ if (result.io != null) {
+ throw result.io;
+ }
+ if (result.ia != null) {
+ throw result.ia;
+ }
+ return;
+ }
+
+ public void mutateRows(ByteBuffer tableName, List<BatchMutation> rowBatches, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, IllegalArgument, org.apache.thrift.TException
+ {
+ send_mutateRows(tableName, rowBatches, attributes);
+ recv_mutateRows();
+ }
+
+ public void send_mutateRows(ByteBuffer tableName, List<BatchMutation> rowBatches, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
+ {
+ mutateRows_args args = new mutateRows_args();
+ args.setTableName(tableName);
+ args.setRowBatches(rowBatches);
+ args.setAttributes(attributes);
+ sendBase("mutateRows", args);
+ }
+
+ public void recv_mutateRows() throws IOError, IllegalArgument, org.apache.thrift.TException
+ {
+ mutateRows_result result = new mutateRows_result();
+ receiveBase(result, "mutateRows");
+ if (result.io != null) {
+ throw result.io;
+ }
+ if (result.ia != null) {
+ throw result.ia;
+ }
+ return;
+ }
+
+ public void mutateRowsTs(ByteBuffer tableName, List<BatchMutation> rowBatches, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, IllegalArgument, org.apache.thrift.TException
+ {
+ send_mutateRowsTs(tableName, rowBatches, timestamp, attributes);
+ recv_mutateRowsTs();
+ }
+
+ public void send_mutateRowsTs(ByteBuffer tableName, List<BatchMutation> rowBatches, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
+ {
+ mutateRowsTs_args args = new mutateRowsTs_args();
+ args.setTableName(tableName);
+ args.setRowBatches(rowBatches);
+ args.setTimestamp(timestamp);
+ args.setAttributes(attributes);
+ sendBase("mutateRowsTs", args);
+ }
+
+ public void recv_mutateRowsTs() throws IOError, IllegalArgument, org.apache.thrift.TException
+ {
+ mutateRowsTs_result result = new mutateRowsTs_result();
+ receiveBase(result, "mutateRowsTs");
+ if (result.io != null) {
+ throw result.io;
+ }
+ if (result.ia != null) {
+ throw result.ia;
+ }
+ return;
+ }
+
+ public long atomicIncrement(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long value) throws IOError, IllegalArgument, org.apache.thrift.TException
+ {
+ send_atomicIncrement(tableName, row, column, value);
+ return recv_atomicIncrement();
+ }
+
+ public void send_atomicIncrement(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long value) throws org.apache.thrift.TException
+ {
+ atomicIncrement_args args = new atomicIncrement_args();
+ args.setTableName(tableName);
+ args.setRow(row);
+ args.setColumn(column);
+ args.setValue(value);
+ sendBase("atomicIncrement", args);
+ }
+
+ public long recv_atomicIncrement() throws IOError, IllegalArgument, org.apache.thrift.TException
+ {
+ atomicIncrement_result result = new atomicIncrement_result();
+ receiveBase(result, "atomicIncrement");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.io != null) {
+ throw result.io;
+ }
+ if (result.ia != null) {
+ throw result.ia;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "atomicIncrement failed: unknown result");
+ }
+
+ public void deleteAll(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
+ {
+ send_deleteAll(tableName, row, column, attributes);
+ recv_deleteAll();
+ }
+
+ public void send_deleteAll(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
+ {
+ deleteAll_args args = new deleteAll_args();
+ args.setTableName(tableName);
+ args.setRow(row);
+ args.setColumn(column);
+ args.setAttributes(attributes);
+ sendBase("deleteAll", args);
+ }
+
+ public void recv_deleteAll() throws IOError, org.apache.thrift.TException
+ {
+ deleteAll_result result = new deleteAll_result();
+ receiveBase(result, "deleteAll");
+ if (result.io != null) {
+ throw result.io;
+ }
+ return;
+ }
+
+ public void deleteAllTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
+ {
+ send_deleteAllTs(tableName, row, column, timestamp, attributes);
+ recv_deleteAllTs();
+ }
+
+ public void send_deleteAllTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
+ {
+ deleteAllTs_args args = new deleteAllTs_args();
+ args.setTableName(tableName);
+ args.setRow(row);
+ args.setColumn(column);
+ args.setTimestamp(timestamp);
+ args.setAttributes(attributes);
+ sendBase("deleteAllTs", args);
+ }
+
+ public void recv_deleteAllTs() throws IOError, org.apache.thrift.TException
+ {
+ deleteAllTs_result result = new deleteAllTs_result();
+ receiveBase(result, "deleteAllTs");
+ if (result.io != null) {
+ throw result.io;
+ }
+ return;
+ }
+
+ public void deleteAllRow(ByteBuffer tableName, ByteBuffer row, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
+ {
+ send_deleteAllRow(tableName, row, attributes);
+ recv_deleteAllRow();
+ }
+
+ public void send_deleteAllRow(ByteBuffer tableName, ByteBuffer row, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
+ {
+ deleteAllRow_args args = new deleteAllRow_args();
+ args.setTableName(tableName);
+ args.setRow(row);
+ args.setAttributes(attributes);
+ sendBase("deleteAllRow", args);
+ }
+
+ public void recv_deleteAllRow() throws IOError, org.apache.thrift.TException
+ {
+ deleteAllRow_result result = new deleteAllRow_result();
+ receiveBase(result, "deleteAllRow");
+ if (result.io != null) {
+ throw result.io;
+ }
+ return;
+ }
+
+ public void increment(TIncrement increment) throws IOError, org.apache.thrift.TException
+ {
+ send_increment(increment);
+ recv_increment();
+ }
+
+ public void send_increment(TIncrement increment) throws org.apache.thrift.TException
+ {
+ increment_args args = new increment_args();
+ args.setIncrement(increment);
+ sendBase("increment", args);
+ }
+
+ public void recv_increment() throws IOError, org.apache.thrift.TException
+ {
+ increment_result result = new increment_result();
+ receiveBase(result, "increment");
+ if (result.io != null) {
+ throw result.io;
+ }
+ return;
+ }
+
+ public void incrementRows(List<TIncrement> increments) throws IOError, org.apache.thrift.TException
+ {
+ send_incrementRows(increments);
+ recv_incrementRows();
+ }
+
+ public void send_incrementRows(List<TIncrement> increments) throws org.apache.thrift.TException
+ {
+ incrementRows_args args = new incrementRows_args();
+ args.setIncrements(increments);
+ sendBase("incrementRows", args);
+ }
+
+ public void recv_incrementRows() throws IOError, org.apache.thrift.TException
+ {
+ incrementRows_result result = new incrementRows_result();
+ receiveBase(result, "incrementRows");
+ if (result.io != null) {
+ throw result.io;
+ }
+ return;
+ }
+
+ public void deleteAllRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
+ {
+ send_deleteAllRowTs(tableName, row, timestamp, attributes);
+ recv_deleteAllRowTs();
+ }
+
+ public void send_deleteAllRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
+ {
+ deleteAllRowTs_args args = new deleteAllRowTs_args();
+ args.setTableName(tableName);
+ args.setRow(row);
+ args.setTimestamp(timestamp);
+ args.setAttributes(attributes);
+ sendBase("deleteAllRowTs", args);
+ }
+
+ public void recv_deleteAllRowTs() throws IOError, org.apache.thrift.TException
+ {
+ deleteAllRowTs_result result = new deleteAllRowTs_result();
+ receiveBase(result, "deleteAllRowTs");
+ if (result.io != null) {
+ throw result.io;
+ }
+ return;
+ }
+
+ public int scannerOpenWithScan(ByteBuffer tableName, TScan scan, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
+ {
+ send_scannerOpenWithScan(tableName, scan, attributes);
+ return recv_scannerOpenWithScan();
+ }
+
+ public void send_scannerOpenWithScan(ByteBuffer tableName, TScan scan, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
+ {
+ scannerOpenWithScan_args args = new scannerOpenWithScan_args();
+ args.setTableName(tableName);
+ args.setScan(scan);
+ args.setAttributes(attributes);
+ sendBase("scannerOpenWithScan", args);
+ }
+
+ public int recv_scannerOpenWithScan() throws IOError, org.apache.thrift.TException
+ {
+ scannerOpenWithScan_result result = new scannerOpenWithScan_result();
+ receiveBase(result, "scannerOpenWithScan");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.io != null) {
+ throw result.io;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "scannerOpenWithScan failed: unknown result");
+ }
+
+ public int scannerOpen(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
+ {
+ send_scannerOpen(tableName, startRow, columns, attributes);
+ return recv_scannerOpen();
+ }
+
+ public void send_scannerOpen(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
+ {
+ scannerOpen_args args = new scannerOpen_args();
+ args.setTableName(tableName);
+ args.setStartRow(startRow);
+ args.setColumns(columns);
+ args.setAttributes(attributes);
+ sendBase("scannerOpen", args);
+ }
+
+ public int recv_scannerOpen() throws IOError, org.apache.thrift.TException
+ {
+ scannerOpen_result result = new scannerOpen_result();
+ receiveBase(result, "scannerOpen");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.io != null) {
+ throw result.io;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "scannerOpen failed: unknown result");
+ }
+
+ public int scannerOpenWithStop(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
+ {
+ send_scannerOpenWithStop(tableName, startRow, stopRow, columns, attributes);
+ return recv_scannerOpenWithStop();
+ }
+
+ public void send_scannerOpenWithStop(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
+ {
+ scannerOpenWithStop_args args = new scannerOpenWithStop_args();
+ args.setTableName(tableName);
+ args.setStartRow(startRow);
+ args.setStopRow(stopRow);
+ args.setColumns(columns);
+ args.setAttributes(attributes);
+ sendBase("scannerOpenWithStop", args);
+ }
+
+ public int recv_scannerOpenWithStop() throws IOError, org.apache.thrift.TException
+ {
+ scannerOpenWithStop_result result = new scannerOpenWithStop_result();
+ receiveBase(result, "scannerOpenWithStop");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.io != null) {
+ throw result.io;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "scannerOpenWithStop failed: unknown result");
+ }
+
+ public int scannerOpenWithPrefix(ByteBuffer tableName, ByteBuffer startAndPrefix, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
+ {
+ send_scannerOpenWithPrefix(tableName, startAndPrefix, columns, attributes);
+ return recv_scannerOpenWithPrefix();
+ }
+
+ public void send_scannerOpenWithPrefix(ByteBuffer tableName, ByteBuffer startAndPrefix, List<ByteBuffer> columns, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
+ {
+ scannerOpenWithPrefix_args args = new scannerOpenWithPrefix_args();
+ args.setTableName(tableName);
+ args.setStartAndPrefix(startAndPrefix);
+ args.setColumns(columns);
+ args.setAttributes(attributes);
+ sendBase("scannerOpenWithPrefix", args);
+ }
+
+ public int recv_scannerOpenWithPrefix() throws IOError, org.apache.thrift.TException
+ {
+ scannerOpenWithPrefix_result result = new scannerOpenWithPrefix_result();
+ receiveBase(result, "scannerOpenWithPrefix");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.io != null) {
+ throw result.io;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "scannerOpenWithPrefix failed: unknown result");
+ }
+
+ public int scannerOpenTs(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
+ {
+ send_scannerOpenTs(tableName, startRow, columns, timestamp, attributes);
+ return recv_scannerOpenTs();
+ }
+
+ public void send_scannerOpenTs(ByteBuffer tableName, ByteBuffer startRow, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
+ {
+ scannerOpenTs_args args = new scannerOpenTs_args();
+ args.setTableName(tableName);
+ args.setStartRow(startRow);
+ args.setColumns(columns);
+ args.setTimestamp(timestamp);
+ args.setAttributes(attributes);
+ sendBase("scannerOpenTs", args);
+ }
+
+ public int recv_scannerOpenTs() throws IOError, org.apache.thrift.TException
+ {
+ scannerOpenTs_result result = new scannerOpenTs_result();
+ receiveBase(result, "scannerOpenTs");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.io != null) {
+ throw result.io;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "scannerOpenTs failed: unknown result");
+ }
+
+ public int scannerOpenWithStopTs(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, org.apache.thrift.TException
+ {
+ send_scannerOpenWithStopTs(tableName, startRow, stopRow, columns, timestamp, attributes);
+ return recv_scannerOpenWithStopTs();
+ }
+
+ public void send_scannerOpenWithStopTs(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List<ByteBuffer> columns, long timestamp, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
+ {
+ scannerOpenWithStopTs_args args = new scannerOpenWithStopTs_args();
+ args.setTableName(tableName);
+ args.setStartRow(startRow);
+ args.setStopRow(stopRow);
+ args.setColumns(columns);
+ args.setTimestamp(timestamp);
+ args.setAttributes(attributes);
+ sendBase("scannerOpenWithStopTs", args);
+ }
+
+ public int recv_scannerOpenWithStopTs() throws IOError, org.apache.thrift.TException
+ {
+ scannerOpenWithStopTs_result result = new scannerOpenWithStopTs_result();
+ receiveBase(result, "scannerOpenWithStopTs");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.io != null) {
+ throw result.io;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "scannerOpenWithStopTs failed: unknown result");
+ }
+
+ public List<TRowResult> scannerGet(int id) throws IOError, IllegalArgument, org.apache.thrift.TException
+ {
+ send_scannerGet(id);
+ return recv_scannerGet();
+ }
+
+ public void send_scannerGet(int id) throws org.apache.thrift.TException
+ {
+ scannerGet_args args = new scannerGet_args();
+ args.setId(id);
+ sendBase("scannerGet", args);
+ }
+
+ public List<TRowResult> recv_scannerGet() throws IOError, IllegalArgument, org.apache.thrift.TException
+ {
+ scannerGet_result result = new scannerGet_result();
+ receiveBase(result, "scannerGet");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.io != null) {
+ throw result.io;
+ }
+ if (result.ia != null) {
+ throw result.ia;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "scannerGet failed: unknown result");
+ }
+
+ public List<TRowResult> scannerGetList(int id, int nbRows) throws IOError, IllegalArgument, org.apache.thrift.TException
+ {
+ send_scannerGetList(id, nbRows);
+ return recv_scannerGetList();
+ }
+
+ public void send_scannerGetList(int id, int nbRows) throws org.apache.thrift.TException
+ {
+ scannerGetList_args args = new scannerGetList_args();
+ args.setId(id);
+ args.setNbRows(nbRows);
+ sendBase("scannerGetList", args);
+ }
+
+ public List<TRowResult> recv_scannerGetList() throws IOError, IllegalArgument, org.apache.thrift.TException
+ {
+ scannerGetList_result result = new scannerGetList_result();
+ receiveBase(result, "scannerGetList");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.io != null) {
+ throw result.io;
+ }
+ if (result.ia != null) {
+ throw result.ia;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "scannerGetList failed: unknown result");
+ }
+
+ public void scannerClose(int id) throws IOError, IllegalArgument, org.apache.thrift.TException
+ {
+ send_scannerClose(id);
+ recv_scannerClose();
+ }
+
+ public void send_scannerClose(int id) throws org.apache.thrift.TException
+ {
+ scannerClose_args args = new scannerClose_args();
+ args.setId(id);
+ sendBase("scannerClose", args);
+ }
+
+ public void recv_scannerClose() throws IOError, IllegalArgument, org.apache.thrift.TException
+ {
+ scannerClose_result result = new scannerClose_result();
+ receiveBase(result, "scannerClose");
+ if (result.io != null) {
+ throw result.io;
+ }
+ if (result.ia != null) {
+ throw result.ia;
+ }
+ return;
+ }
+
+ public List<TCell> getRowOrBefore(ByteBuffer tableName, ByteBuffer row, ByteBuffer family) throws IOError, org.apache.thrift.TException
+ {
+ send_getRowOrBefore(tableName, row, family);
+ return recv_getRowOrBefore();
+ }
+
+ public void send_getRowOrBefore(ByteBuffer tableName, ByteBuffer row, ByteBuffer family) throws org.apache.thrift.TException
+ {
+ getRowOrBefore_args args = new getRowOrBefore_args();
+ args.setTableName(tableName);
+ args.setRow(row);
+ args.setFamily(family);
+ sendBase("getRowOrBefore", args);
+ }
+
+ public List<TCell> recv_getRowOrBefore() throws IOError, org.apache.thrift.TException
+ {
+ getRowOrBefore_result result = new getRowOrBefore_result();
+ receiveBase(result, "getRowOrBefore");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.io != null) {
+ throw result.io;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRowOrBefore failed: unknown result");
+ }
+
+ public TRegionInfo getRegionInfo(ByteBuffer row) throws IOError, org.apache.thrift.TException
+ {
+ send_getRegionInfo(row);
+ return recv_getRegionInfo();
+ }
+
+ public void send_getRegionInfo(ByteBuffer row) throws org.apache.thrift.TException
+ {
+ getRegionInfo_args args = new getRegionInfo_args();
+ args.setRow(row);
+ sendBase("getRegionInfo", args);
+ }
+
+ public TRegionInfo recv_getRegionInfo() throws IOError, org.apache.thrift.TException
+ {
+ getRegionInfo_result result = new getRegionInfo_result();
+ receiveBase(result, "getRegionInfo");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.io != null) {
+ throw result.io;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRegionInfo failed: unknown result");
+ }
+
+ }
+ public static class AsyncClient extends org.apache.thrift.async.TAsyncClient implements AsyncIface {
+ public static class Factory implements org.apache.thrift.async.TAsyncClientFactory<AsyncClient> {
+ private org.apache.thrift.async.TAsyncClientManager clientManager;
+ private org.apache.thrift.protocol.TProtocolFactory protocolFactory;
+ public Factory(org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.protocol.TProtocolFactory protocolFactory) {
+ this.clientManager = clientManager;
+ this.protocolFactory = protocolFactory;
+ }
+ public AsyncClient getAsyncClient(org.apache.thrift.transport.TNonblockingTransport transport) {
+ return new AsyncClient(protocolFactory, clientManager, transport);
+ }
+ }
+
+ public AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport) {
+ super(protocolFactory, clientManager, transport);
+ }
+
+ public void enableTable(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<enableTable_call> resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ enableTable_call method_call = new enableTable_call(tableName, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class enableTable_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private ByteBuffer tableName;
+ public enableTable_call(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<enableTable_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.tableName = tableName;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("enableTable", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ enableTable_args args = new enableTable_args();
+ args.setTableName(tableName);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public void getResult() throws IOError, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ (new Client(prot)).recv_enableTable();
+ }
+ }
+
+ public void disableTable(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<disableTable_call> resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ disableTable_call method_call = new disableTable_call(tableName, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class disableTable_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private ByteBuffer tableName;
+ public disableTable_call(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<disableTable_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.tableName = tableName;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("disableTable", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ disableTable_args args = new disableTable_args();
+ args.setTableName(tableName);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public void getResult() throws IOError, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ (new Client(prot)).recv_disableTable();
+ }
+ }
+
+ public void isTableEnabled(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<isTableEnabled_call> resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ isTableEnabled_call method_call = new isTableEnabled_call(tableName, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class isTableEnabled_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private ByteBuffer tableName;
+ public isTableEnabled_call(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback<isTableEnabled_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.tableName = tableName;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("isTableEnabled", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ isTableEnabled_args args = new isTableEnabled_args();
+ args.setTableName(tableName);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public boolean getResult() throws IOError, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ return (new Client(prot)).recv_isTableEnabled();
+ }
+ }
+
+ public void compact(ByteBuffer tableNameOrRegionName, org.apache.thrift.async.AsyncMethodCallback<compact_call> resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ compact_call method_call = new compact_call(tableNameOrRegionName, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class compact_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private ByteBuffer tableNameOrRegionName;
+ public compact_call(ByteBuffer tableNameOrRegionName, org.apache.thrift.async.AsyncMethodCallback<compact_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.tableNameOrRegionName = tableNameOrRegionName;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
[... 51192 lines stripped ...]