diff --git a/CHANGES.txt b/CHANGES.txt
index 47ea432cae6..883bf3ca387 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -8,6 +8,7 @@ Release 0.91.0 - Unreleased
ClusterStatus serialization)
HBASE-3762 HTableFactory.releaseHTableInterface() should throw IOException
instead of wrapping in RuntimeException (Ted Yu via garyh)
+ HBASE-3629 Update our thrift to 0.6 (Moaz Reyad)
BUG FIXES
HBASE-3280 YouAreDeadException being swallowed in HRS getMaster
diff --git a/pom.xml b/pom.xml
index 61e3afc47ad..7e6b493410b 100644
--- a/pom.xml
+++ b/pom.xml
@@ -544,7 +544,7 @@
2.3.0
1.5.8
1.0.1
- 0.5.0
+ 0.6.1
3.3.3
/usr
@@ -554,7 +554,6 @@
1
0.91.0
- ${artifactId}-${version}
@@ -670,7 +669,7 @@
- org.apache.hadoop
+ org.apache.thrift
libthrift
${thrift.version}
@@ -909,7 +908,7 @@
package
-
+
diff --git a/src/main/java/org/apache/hadoop/hbase/thrift/ThriftServer.java b/src/main/java/org/apache/hadoop/hbase/thrift/ThriftServer.java
index 3b7f377cab5..cedf538c199 100644
--- a/src/main/java/org/apache/hadoop/hbase/thrift/ThriftServer.java
+++ b/src/main/java/org/apache/hadoop/hbase/thrift/ThriftServer.java
@@ -944,12 +944,22 @@ public class ThriftServer {
TNonblockingServerTransport serverTransport = new TNonblockingServerSocket(listenPort);
TFramedTransport.Factory transportFactory = new TFramedTransport.Factory();
- if (cmd.hasOption("nonblocking")) {
+ if (cmd.hasOption("nonblocking")) {
+ TNonblockingServer.Args serverArgs = new TNonblockingServer.Args(serverTransport);
+ serverArgs.processor(processor);
+ serverArgs.transportFactory(transportFactory);
+ serverArgs.protocolFactory(protocolFactory);
+
LOG.info("starting HBase Nonblocking Thrift server on " + Integer.toString(listenPort));
- server = new TNonblockingServer(processor, serverTransport, transportFactory, protocolFactory);
+ server = new TNonblockingServer(serverArgs);
} else {
+ THsHaServer.Args serverArgs = new THsHaServer.Args(serverTransport);
+ serverArgs.processor(processor);
+ serverArgs.transportFactory(transportFactory);
+ serverArgs.protocolFactory(protocolFactory);
+
LOG.info("starting HBase HsHA Thrift server on " + Integer.toString(listenPort));
- server = new THsHaServer(processor, serverTransport, transportFactory, protocolFactory);
+ server = new THsHaServer(serverArgs);
}
} else {
// Get IP address to bind to
@@ -975,8 +985,13 @@ public class ThriftServer {
transportFactory = new TTransportFactory();
}
+ TThreadPoolServer.Args serverArgs = new TThreadPoolServer.Args(serverTransport);
+ serverArgs.processor(processor);
+ serverArgs.protocolFactory(protocolFactory);
+ serverArgs.transportFactory(transportFactory);
+
LOG.info("starting HBase ThreadPool Thrift server on " + listenAddress + ":" + Integer.toString(listenPort));
- server = new TThreadPoolServer(processor, serverTransport, transportFactory, protocolFactory);
+ server = new TThreadPoolServer(serverArgs);
}
server.serve();
diff --git a/src/main/java/org/apache/hadoop/hbase/thrift/generated/AlreadyExists.java b/src/main/java/org/apache/hadoop/hbase/thrift/generated/AlreadyExists.java
index 4ac89f09b4f..04f6fb3b807 100644
--- a/src/main/java/org/apache/hadoop/hbase/thrift/generated/AlreadyExists.java
+++ b/src/main/java/org/apache/hadoop/hbase/thrift/generated/AlreadyExists.java
@@ -1,19 +1,7 @@
/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
+ * Autogenerated by Thrift
*
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
*/
package org.apache.hadoop.hbase.thrift.generated;
@@ -32,25 +20,19 @@ import java.util.Arrays;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import org.apache.thrift.*;
-import org.apache.thrift.async.*;
-import org.apache.thrift.meta_data.*;
-import org.apache.thrift.transport.*;
-import org.apache.thrift.protocol.*;
-
/**
* An AlreadyExists exceptions signals that a table with the specified
* name already exists
*/
-public class AlreadyExists extends Exception implements TBase, java.io.Serializable, Cloneable {
- private static final TStruct STRUCT_DESC = new TStruct("AlreadyExists");
+public class AlreadyExists extends Exception implements org.apache.thrift.TBase, java.io.Serializable, Cloneable {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("AlreadyExists");
- private static final TField MESSAGE_FIELD_DESC = new TField("message", TType.STRING, (short)1);
+ private static final org.apache.thrift.protocol.TField MESSAGE_FIELD_DESC = new org.apache.thrift.protocol.TField("message", org.apache.thrift.protocol.TType.STRING, (short)1);
public String message;
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
- public enum _Fields implements TFieldIdEnum {
+ public enum _Fields implements org.apache.thrift.TFieldIdEnum {
MESSAGE((short)1, "message");
private static final Map byName = new HashMap();
@@ -109,13 +91,13 @@ public class AlreadyExists extends Exception implements TBase metaDataMap;
+ public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
- Map<_Fields, FieldMetaData> tmpMap = new EnumMap<_Fields, FieldMetaData>(_Fields.class);
- tmpMap.put(_Fields.MESSAGE, new FieldMetaData("message", TFieldRequirementType.DEFAULT,
- new FieldValueMetaData(TType.STRING)));
+ Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
+ tmpMap.put(_Fields.MESSAGE, new org.apache.thrift.meta_data.FieldMetaData("message", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
- FieldMetaData.addStructMetaDataMap(AlreadyExists.class, metaDataMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(AlreadyExists.class, metaDataMap);
}
public AlreadyExists() {
@@ -159,7 +141,7 @@ public class AlreadyExists extends Exception implements TBase, java.io.Serializable, Cloneable {
- private static final TStruct STRUCT_DESC = new TStruct("BatchMutation");
+public class BatchMutation implements org.apache.thrift.TBase, java.io.Serializable, Cloneable {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("BatchMutation");
- private static final TField ROW_FIELD_DESC = new TField("row", TType.STRING, (short)1);
- private static final TField MUTATIONS_FIELD_DESC = new TField("mutations", TType.LIST, (short)2);
+ private static final org.apache.thrift.protocol.TField ROW_FIELD_DESC = new org.apache.thrift.protocol.TField("row", org.apache.thrift.protocol.TType.STRING, (short)1);
+ private static final org.apache.thrift.protocol.TField MUTATIONS_FIELD_DESC = new org.apache.thrift.protocol.TField("mutations", org.apache.thrift.protocol.TType.LIST, (short)2);
public ByteBuffer row;
public List mutations;
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
- public enum _Fields implements TFieldIdEnum {
+ public enum _Fields implements org.apache.thrift.TFieldIdEnum {
ROW((short)1, "row"),
MUTATIONS((short)2, "mutations");
@@ -113,16 +95,16 @@ public class BatchMutation implements TBase metaDataMap;
+ public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
- Map<_Fields, FieldMetaData> tmpMap = new EnumMap<_Fields, FieldMetaData>(_Fields.class);
- tmpMap.put(_Fields.ROW, new FieldMetaData("row", TFieldRequirementType.DEFAULT,
- new FieldValueMetaData(TType.STRING , "Text")));
- tmpMap.put(_Fields.MUTATIONS, new FieldMetaData("mutations", TFieldRequirementType.DEFAULT,
- new ListMetaData(TType.LIST,
- new StructMetaData(TType.STRUCT, Mutation.class))));
+ Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
+ tmpMap.put(_Fields.ROW, new org.apache.thrift.meta_data.FieldMetaData("row", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , "Text")));
+ tmpMap.put(_Fields.MUTATIONS, new org.apache.thrift.meta_data.FieldMetaData("mutations", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Mutation.class))));
metaDataMap = Collections.unmodifiableMap(tmpMap);
- FieldMetaData.addStructMetaDataMap(BatchMutation.class, metaDataMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(BatchMutation.class, metaDataMap);
}
public BatchMutation() {
@@ -164,16 +146,16 @@ public class BatchMutation implements TBase(_list0.size);
for (int _i1 = 0; _i1 < _list0.size; ++_i1)
{
@@ -389,12 +371,12 @@ public class BatchMutation implements TBase, java.io.Serializable, Cloneable {
- private static final TStruct STRUCT_DESC = new TStruct("ColumnDescriptor");
+public class ColumnDescriptor implements org.apache.thrift.TBase, java.io.Serializable, Cloneable {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ColumnDescriptor");
- private static final TField NAME_FIELD_DESC = new TField("name", TType.STRING, (short)1);
- private static final TField MAX_VERSIONS_FIELD_DESC = new TField("maxVersions", TType.I32, (short)2);
- private static final TField COMPRESSION_FIELD_DESC = new TField("compression", TType.STRING, (short)3);
- private static final TField IN_MEMORY_FIELD_DESC = new TField("inMemory", TType.BOOL, (short)4);
- private static final TField BLOOM_FILTER_TYPE_FIELD_DESC = new TField("bloomFilterType", TType.STRING, (short)5);
- private static final TField BLOOM_FILTER_VECTOR_SIZE_FIELD_DESC = new TField("bloomFilterVectorSize", TType.I32, (short)6);
- private static final TField BLOOM_FILTER_NB_HASHES_FIELD_DESC = new TField("bloomFilterNbHashes", TType.I32, (short)7);
- private static final TField BLOCK_CACHE_ENABLED_FIELD_DESC = new TField("blockCacheEnabled", TType.BOOL, (short)8);
- private static final TField TIME_TO_LIVE_FIELD_DESC = new TField("timeToLive", TType.I32, (short)9);
+ private static final org.apache.thrift.protocol.TField NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("name", org.apache.thrift.protocol.TType.STRING, (short)1);
+ private static final org.apache.thrift.protocol.TField MAX_VERSIONS_FIELD_DESC = new org.apache.thrift.protocol.TField("maxVersions", org.apache.thrift.protocol.TType.I32, (short)2);
+ private static final org.apache.thrift.protocol.TField COMPRESSION_FIELD_DESC = new org.apache.thrift.protocol.TField("compression", org.apache.thrift.protocol.TType.STRING, (short)3);
+ private static final org.apache.thrift.protocol.TField IN_MEMORY_FIELD_DESC = new org.apache.thrift.protocol.TField("inMemory", org.apache.thrift.protocol.TType.BOOL, (short)4);
+ private static final org.apache.thrift.protocol.TField BLOOM_FILTER_TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("bloomFilterType", org.apache.thrift.protocol.TType.STRING, (short)5);
+ private static final org.apache.thrift.protocol.TField BLOOM_FILTER_VECTOR_SIZE_FIELD_DESC = new org.apache.thrift.protocol.TField("bloomFilterVectorSize", org.apache.thrift.protocol.TType.I32, (short)6);
+ private static final org.apache.thrift.protocol.TField BLOOM_FILTER_NB_HASHES_FIELD_DESC = new org.apache.thrift.protocol.TField("bloomFilterNbHashes", org.apache.thrift.protocol.TType.I32, (short)7);
+ private static final org.apache.thrift.protocol.TField BLOCK_CACHE_ENABLED_FIELD_DESC = new org.apache.thrift.protocol.TField("blockCacheEnabled", org.apache.thrift.protocol.TType.BOOL, (short)8);
+ private static final org.apache.thrift.protocol.TField TIME_TO_LIVE_FIELD_DESC = new org.apache.thrift.protocol.TField("timeToLive", org.apache.thrift.protocol.TType.I32, (short)9);
public ByteBuffer name;
public int maxVersions;
@@ -67,7 +49,7 @@ public class ColumnDescriptor implements TBase metaDataMap;
+ public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
- Map<_Fields, FieldMetaData> tmpMap = new EnumMap<_Fields, FieldMetaData>(_Fields.class);
- tmpMap.put(_Fields.NAME, new FieldMetaData("name", TFieldRequirementType.DEFAULT,
- new FieldValueMetaData(TType.STRING , "Text")));
- tmpMap.put(_Fields.MAX_VERSIONS, new FieldMetaData("maxVersions", TFieldRequirementType.DEFAULT,
- new FieldValueMetaData(TType.I32)));
- tmpMap.put(_Fields.COMPRESSION, new FieldMetaData("compression", TFieldRequirementType.DEFAULT,
- new FieldValueMetaData(TType.STRING)));
- tmpMap.put(_Fields.IN_MEMORY, new FieldMetaData("inMemory", TFieldRequirementType.DEFAULT,
- new FieldValueMetaData(TType.BOOL)));
- tmpMap.put(_Fields.BLOOM_FILTER_TYPE, new FieldMetaData("bloomFilterType", TFieldRequirementType.DEFAULT,
- new FieldValueMetaData(TType.STRING)));
- tmpMap.put(_Fields.BLOOM_FILTER_VECTOR_SIZE, new FieldMetaData("bloomFilterVectorSize", TFieldRequirementType.DEFAULT,
- new FieldValueMetaData(TType.I32)));
- tmpMap.put(_Fields.BLOOM_FILTER_NB_HASHES, new FieldMetaData("bloomFilterNbHashes", TFieldRequirementType.DEFAULT,
- new FieldValueMetaData(TType.I32)));
- tmpMap.put(_Fields.BLOCK_CACHE_ENABLED, new FieldMetaData("blockCacheEnabled", TFieldRequirementType.DEFAULT,
- new FieldValueMetaData(TType.BOOL)));
- tmpMap.put(_Fields.TIME_TO_LIVE, new FieldMetaData("timeToLive", TFieldRequirementType.DEFAULT,
- new FieldValueMetaData(TType.I32)));
+ Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
+ tmpMap.put(_Fields.NAME, new org.apache.thrift.meta_data.FieldMetaData("name", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , "Text")));
+ tmpMap.put(_Fields.MAX_VERSIONS, new org.apache.thrift.meta_data.FieldMetaData("maxVersions", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
+ tmpMap.put(_Fields.COMPRESSION, new org.apache.thrift.meta_data.FieldMetaData("compression", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.IN_MEMORY, new org.apache.thrift.meta_data.FieldMetaData("inMemory", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
+ tmpMap.put(_Fields.BLOOM_FILTER_TYPE, new org.apache.thrift.meta_data.FieldMetaData("bloomFilterType", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.BLOOM_FILTER_VECTOR_SIZE, new org.apache.thrift.meta_data.FieldMetaData("bloomFilterVectorSize", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
+ tmpMap.put(_Fields.BLOOM_FILTER_NB_HASHES, new org.apache.thrift.meta_data.FieldMetaData("bloomFilterNbHashes", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
+ tmpMap.put(_Fields.BLOCK_CACHE_ENABLED, new org.apache.thrift.meta_data.FieldMetaData("blockCacheEnabled", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
+ tmpMap.put(_Fields.TIME_TO_LIVE, new org.apache.thrift.meta_data.FieldMetaData("timeToLive", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
- FieldMetaData.addStructMetaDataMap(ColumnDescriptor.class, metaDataMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ColumnDescriptor.class, metaDataMap);
}
public ColumnDescriptor() {
@@ -279,16 +261,16 @@ public class ColumnDescriptor implements TBase getTableNames() throws IOError, TException;
+ public List 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 getColumnDescriptors(ByteBuffer tableName) throws IOError, TException;
+ public Map 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 getTableRegions(ByteBuffer tableName) throws IOError, TException;
+ public List 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 columnFamilies) throws IOError, IllegalArgument, AlreadyExists, TException;
+ public void createTable(ByteBuffer tableName, List 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, 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
* 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
*/
- public List get(ByteBuffer tableName, ByteBuffer row, ByteBuffer column) throws IOError, TException;
+ public List get(ByteBuffer tableName, ByteBuffer row, ByteBuffer column) 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
*/
- public List getVer(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, int numVersions) throws IOError, TException;
+ public List 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,
* 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
*/
- public List getVerTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, int numVersions) throws IOError, TException;
+ public List 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
* 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
*/
- public List getRow(ByteBuffer tableName, ByteBuffer row) throws IOError, TException;
+ public List getRow(ByteBuffer tableName, ByteBuffer row) 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
*/
- public List getRowWithColumns(ByteBuffer tableName, ByteBuffer row, List columns) throws IOError, TException;
+ public List getRowWithColumns(ByteBuffer tableName, ByteBuffer row, List columns) 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
*/
- public List getRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp) throws IOError, TException;
+ public List 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
* 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
*/
- public List getRowWithColumnsTs(ByteBuffer tableName, ByteBuffer row, List columns, long timestamp) throws IOError, TException;
+ public List getRowWithColumnsTs(ByteBuffer tableName, ByteBuffer row, List columns, long timestamp) 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
*/
- public List getRows(ByteBuffer tableName, List rows) throws IOError, TException;
+ public List getRows(ByteBuffer tableName, List rows) 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
*/
- public List getRowsWithColumns(ByteBuffer tableName, List rows, List columns) throws IOError, TException;
+ public List getRowsWithColumns(ByteBuffer tableName, List rows, List columns) 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
*/
- public List getRowsTs(ByteBuffer tableName, List rows, long timestamp) throws IOError, TException;
+ public List getRowsTs(ByteBuffer tableName, List rows, long timestamp) 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
*/
- public List getRowsWithColumnsTs(ByteBuffer tableName, List rows, List columns, long timestamp) throws IOError, TException;
+ public List getRowsWithColumnsTs(ByteBuffer tableName, List rows, List columns, long timestamp) 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
*/
- public void mutateRow(ByteBuffer tableName, ByteBuffer row, List mutations) throws IOError, IllegalArgument, TException;
+ public void mutateRow(ByteBuffer tableName, ByteBuffer row, List mutations) 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
*/
- public void mutateRowTs(ByteBuffer tableName, ByteBuffer row, List mutations, long timestamp) throws IOError, IllegalArgument, TException;
+ public void mutateRowTs(ByteBuffer tableName, ByteBuffer row, List mutations, long timestamp) 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
*/
- public void mutateRows(ByteBuffer tableName, List rowBatches) throws IOError, IllegalArgument, TException;
+ public void mutateRows(ByteBuffer tableName, List rowBatches) 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
*/
- public void mutateRowsTs(ByteBuffer tableName, List rowBatches, long timestamp) throws IOError, IllegalArgument, TException;
+ public void mutateRowsTs(ByteBuffer tableName, List rowBatches, long timestamp) 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, 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.
- *
+ *
* @param tableName name of table
- *
+ *
* @param row Row to update
- *
+ *
* @param column name of column whose value is to be deleted
*/
- public void deleteAll(ByteBuffer tableName, ByteBuffer row, ByteBuffer column) throws IOError, TException;
+ public void deleteAll(ByteBuffer tableName, ByteBuffer row, ByteBuffer column) 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
*/
- public void deleteAllTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer 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.
- *
+ *
* @param tableName name of table
- *
+ *
* @param row key of the row to be completely deleted.
*/
- public void deleteAllRow(ByteBuffer tableName, ByteBuffer 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
* 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
*/
- public void deleteAllRowTs(ByteBuffer tableName, ByteBuffer 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
* 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.
*/
- public int scannerOpen(ByteBuffer tableName, ByteBuffer startRow, List columns) throws IOError, TException;
+ public int scannerOpen(ByteBuffer tableName, ByteBuffer startRow, List columns) 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.
*/
- public int scannerOpenWithStop(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List columns) throws IOError, TException;
+ public int scannerOpenWithStop(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List columns) 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
*/
- public int scannerOpenWithPrefix(ByteBuffer tableName, ByteBuffer startAndPrefix, List columns) throws IOError, TException;
+ public int scannerOpenWithPrefix(ByteBuffer tableName, ByteBuffer startAndPrefix, List columns) 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
*/
- public int scannerOpenTs(ByteBuffer tableName, ByteBuffer startRow, List columns, long timestamp) throws IOError, TException;
+ public int scannerOpenTs(ByteBuffer tableName, ByteBuffer startRow, List columns, long timestamp) 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
*/
- public int scannerOpenWithStopTs(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List columns, long timestamp) throws IOError, TException;
+ public int scannerOpenWithStopTs(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List columns, long timestamp) 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 scannerGet(int id) throws IOError, IllegalArgument, TException;
+ public List 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 scannerGetList(int id, int nbRows) throws IOError, IllegalArgument, TException;
+ public List 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, TException;
+ public void scannerClose(int id) throws IOError, IllegalArgument, org.apache.thrift.TException;
}
public interface AsyncIface {
- public void enableTable(ByteBuffer tableName, AsyncMethodCallback resultHandler) throws TException;
+ public void enableTable(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void disableTable(ByteBuffer tableName, AsyncMethodCallback resultHandler) throws TException;
+ public void disableTable(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void isTableEnabled(ByteBuffer tableName, AsyncMethodCallback resultHandler) throws TException;
+ public void isTableEnabled(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void compact(ByteBuffer tableNameOrRegionName, AsyncMethodCallback resultHandler) throws TException;
+ public void compact(ByteBuffer tableNameOrRegionName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void majorCompact(ByteBuffer tableNameOrRegionName, AsyncMethodCallback resultHandler) throws TException;
+ public void majorCompact(ByteBuffer tableNameOrRegionName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void getTableNames(AsyncMethodCallback resultHandler) throws TException;
+ public void getTableNames(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void getColumnDescriptors(ByteBuffer tableName, AsyncMethodCallback resultHandler) throws TException;
+ public void getColumnDescriptors(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void getTableRegions(ByteBuffer tableName, AsyncMethodCallback resultHandler) throws TException;
+ public void getTableRegions(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void createTable(ByteBuffer tableName, List columnFamilies, AsyncMethodCallback resultHandler) throws TException;
+ public void createTable(ByteBuffer tableName, List columnFamilies, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void deleteTable(ByteBuffer tableName, AsyncMethodCallback resultHandler) throws TException;
+ public void deleteTable(ByteBuffer tableName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void get(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, AsyncMethodCallback resultHandler) throws TException;
+ public void get(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void getVer(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, int numVersions, AsyncMethodCallback resultHandler) throws TException;
+ public void getVer(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, int numVersions, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void getVerTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, int numVersions, AsyncMethodCallback resultHandler) throws TException;
+ public void getVerTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, int numVersions, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void getRow(ByteBuffer tableName, ByteBuffer row, AsyncMethodCallback resultHandler) throws TException;
+ public void getRow(ByteBuffer tableName, ByteBuffer row, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void getRowWithColumns(ByteBuffer tableName, ByteBuffer row, List columns, AsyncMethodCallback resultHandler) throws TException;
+ public void getRowWithColumns(ByteBuffer tableName, ByteBuffer row, List columns, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void getRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, AsyncMethodCallback resultHandler) throws TException;
+ public void getRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void getRowWithColumnsTs(ByteBuffer tableName, ByteBuffer row, List columns, long timestamp, AsyncMethodCallback resultHandler) throws TException;
+ public void getRowWithColumnsTs(ByteBuffer tableName, ByteBuffer row, List columns, long timestamp, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void getRows(ByteBuffer tableName, List rows, AsyncMethodCallback resultHandler) throws TException;
+ public void getRows(ByteBuffer tableName, List rows, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void getRowsWithColumns(ByteBuffer tableName, List rows, List columns, AsyncMethodCallback resultHandler) throws TException;
+ public void getRowsWithColumns(ByteBuffer tableName, List rows, List columns, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void getRowsTs(ByteBuffer tableName, List rows, long timestamp, AsyncMethodCallback resultHandler) throws TException;
+ public void getRowsTs(ByteBuffer tableName, List rows, long timestamp, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void getRowsWithColumnsTs(ByteBuffer tableName, List rows, List columns, long timestamp, AsyncMethodCallback resultHandler) throws TException;
+ public void getRowsWithColumnsTs(ByteBuffer tableName, List rows, List columns, long timestamp, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void mutateRow(ByteBuffer tableName, ByteBuffer row, List mutations, AsyncMethodCallback resultHandler) throws TException;
+ public void mutateRow(ByteBuffer tableName, ByteBuffer row, List mutations, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void mutateRowTs(ByteBuffer tableName, ByteBuffer row, List mutations, long timestamp, AsyncMethodCallback resultHandler) throws TException;
+ public void mutateRowTs(ByteBuffer tableName, ByteBuffer row, List mutations, long timestamp, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void mutateRows(ByteBuffer tableName, List rowBatches, AsyncMethodCallback resultHandler) throws TException;
+ public void mutateRows(ByteBuffer tableName, List rowBatches, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void mutateRowsTs(ByteBuffer tableName, List rowBatches, long timestamp, AsyncMethodCallback resultHandler) throws TException;
+ public void mutateRowsTs(ByteBuffer tableName, List rowBatches, long timestamp, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void atomicIncrement(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long value, AsyncMethodCallback resultHandler) throws TException;
+ public void atomicIncrement(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long value, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void deleteAll(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, AsyncMethodCallback resultHandler) throws TException;
+ public void deleteAll(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void deleteAllTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, AsyncMethodCallback resultHandler) throws TException;
+ public void deleteAllTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void deleteAllRow(ByteBuffer tableName, ByteBuffer row, AsyncMethodCallback resultHandler) throws TException;
+ public void deleteAllRow(ByteBuffer tableName, ByteBuffer row, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void deleteAllRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, AsyncMethodCallback resultHandler) throws TException;
+ public void deleteAllRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void scannerOpen(ByteBuffer tableName, ByteBuffer startRow, List columns, AsyncMethodCallback resultHandler) throws TException;
+ public void scannerOpen(ByteBuffer tableName, ByteBuffer startRow, List columns, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void scannerOpenWithStop(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List columns, AsyncMethodCallback resultHandler) throws TException;
+ public void scannerOpenWithStop(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List columns, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void scannerOpenWithPrefix(ByteBuffer tableName, ByteBuffer startAndPrefix, List columns, AsyncMethodCallback resultHandler) throws TException;
+ public void scannerOpenWithPrefix(ByteBuffer tableName, ByteBuffer startAndPrefix, List columns, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void scannerOpenTs(ByteBuffer tableName, ByteBuffer startRow, List columns, long timestamp, AsyncMethodCallback resultHandler) throws TException;
+ public void scannerOpenTs(ByteBuffer tableName, ByteBuffer startRow, List columns, long timestamp, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void scannerOpenWithStopTs(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List columns, long timestamp, AsyncMethodCallback resultHandler) throws TException;
+ public void scannerOpenWithStopTs(ByteBuffer tableName, ByteBuffer startRow, ByteBuffer stopRow, List columns, long timestamp, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void scannerGet(int id, AsyncMethodCallback resultHandler) throws TException;
+ public void scannerGet(int id, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void scannerGetList(int id, int nbRows, AsyncMethodCallback resultHandler) throws TException;
+ public void scannerGetList(int id, int nbRows, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void scannerClose(int id, AsyncMethodCallback resultHandler) throws TException;
+ public void scannerClose(int id, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
}
- public static class Client implements TServiceClient, Iface {
- public static class Factory implements TServiceClientFactory {
+ public static class Client implements org.apache.thrift.TServiceClient, Iface {
+ public static class Factory implements org.apache.thrift.TServiceClientFactory {
public Factory() {}
- public Client getClient(TProtocol prot) {
+ public Client getClient(org.apache.thrift.protocol.TProtocol prot) {
return new Client(prot);
}
- public Client getClient(TProtocol iprot, TProtocol oprot) {
+ public Client getClient(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) {
return new Client(iprot, oprot);
}
}
- public Client(TProtocol prot)
+ public Client(org.apache.thrift.protocol.TProtocol prot)
{
this(prot, prot);
}
- public Client(TProtocol iprot, TProtocol oprot)
+ public Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot)
{
iprot_ = iprot;
oprot_ = oprot;
}
- protected TProtocol iprot_;
- protected TProtocol oprot_;
+ protected org.apache.thrift.protocol.TProtocol iprot_;
+ protected org.apache.thrift.protocol.TProtocol oprot_;
protected int seqid_;
- public TProtocol getInputProtocol()
+ public org.apache.thrift.protocol.TProtocol getInputProtocol()
{
return this.iprot_;
}
- public TProtocol getOutputProtocol()
+ public org.apache.thrift.protocol.TProtocol getOutputProtocol()
{
return this.oprot_;
}
- public void enableTable(ByteBuffer tableName) throws IOError, TException
+ public void enableTable(ByteBuffer tableName) throws IOError, org.apache.thrift.TException
{
send_enableTable(tableName);
recv_enableTable();
}
- public void send_enableTable(ByteBuffer tableName) throws TException
+ public void send_enableTable(ByteBuffer tableName) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("enableTable", TMessageType.CALL, ++seqid_));
+ oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("enableTable", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
enableTable_args args = new enableTable_args();
args.setTableName(tableName);
args.write(oprot_);
@@ -669,16 +651,16 @@ public class Hbase {
oprot_.getTransport().flush();
}
- public void recv_enableTable() throws IOError, TException
+ public void recv_enableTable() throws IOError, org.apache.thrift.TException
{
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
+ org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
+ if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
+ org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
iprot_.readMessageEnd();
throw x;
}
if (msg.seqid != seqid_) {
- throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "enableTable failed: out of sequence response");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "enableTable failed: out of sequence response");
}
enableTable_result result = new enableTable_result();
result.read(iprot_);
@@ -689,15 +671,15 @@ public class Hbase {
return;
}
- public void disableTable(ByteBuffer tableName) throws IOError, TException
+ public void disableTable(ByteBuffer tableName) throws IOError, org.apache.thrift.TException
{
send_disableTable(tableName);
recv_disableTable();
}
- public void send_disableTable(ByteBuffer tableName) throws TException
+ public void send_disableTable(ByteBuffer tableName) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("disableTable", TMessageType.CALL, ++seqid_));
+ oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("disableTable", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
disableTable_args args = new disableTable_args();
args.setTableName(tableName);
args.write(oprot_);
@@ -705,16 +687,16 @@ public class Hbase {
oprot_.getTransport().flush();
}
- public void recv_disableTable() throws IOError, TException
+ public void recv_disableTable() throws IOError, org.apache.thrift.TException
{
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
+ org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
+ if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
+ org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
iprot_.readMessageEnd();
throw x;
}
if (msg.seqid != seqid_) {
- throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "disableTable failed: out of sequence response");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "disableTable failed: out of sequence response");
}
disableTable_result result = new disableTable_result();
result.read(iprot_);
@@ -725,15 +707,15 @@ public class Hbase {
return;
}
- public boolean isTableEnabled(ByteBuffer 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(ByteBuffer tableName) throws TException
+ public void send_isTableEnabled(ByteBuffer tableName) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("isTableEnabled", TMessageType.CALL, ++seqid_));
+ oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("isTableEnabled", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
isTableEnabled_args args = new isTableEnabled_args();
args.setTableName(tableName);
args.write(oprot_);
@@ -741,16 +723,16 @@ public class Hbase {
oprot_.getTransport().flush();
}
- public boolean recv_isTableEnabled() throws IOError, TException
+ public boolean recv_isTableEnabled() throws IOError, org.apache.thrift.TException
{
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
+ org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
+ if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
+ org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
iprot_.readMessageEnd();
throw x;
}
if (msg.seqid != seqid_) {
- throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "isTableEnabled failed: out of sequence response");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "isTableEnabled failed: out of sequence response");
}
isTableEnabled_result result = new isTableEnabled_result();
result.read(iprot_);
@@ -761,18 +743,18 @@ public class Hbase {
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(ByteBuffer tableNameOrRegionName) throws IOError, TException
+ public void compact(ByteBuffer tableNameOrRegionName) throws IOError, org.apache.thrift.TException
{
send_compact(tableNameOrRegionName);
recv_compact();
}
- public void send_compact(ByteBuffer tableNameOrRegionName) throws TException
+ public void send_compact(ByteBuffer tableNameOrRegionName) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("compact", TMessageType.CALL, ++seqid_));
+ oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("compact", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
compact_args args = new compact_args();
args.setTableNameOrRegionName(tableNameOrRegionName);
args.write(oprot_);
@@ -780,16 +762,16 @@ public class Hbase {
oprot_.getTransport().flush();
}
- public void recv_compact() throws IOError, TException
+ public void recv_compact() throws IOError, org.apache.thrift.TException
{
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
+ org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
+ if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
+ org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
iprot_.readMessageEnd();
throw x;
}
if (msg.seqid != seqid_) {
- throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "compact failed: out of sequence response");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "compact failed: out of sequence response");
}
compact_result result = new compact_result();
result.read(iprot_);
@@ -800,15 +782,15 @@ public class Hbase {
return;
}
- public void majorCompact(ByteBuffer tableNameOrRegionName) throws IOError, TException
+ public void majorCompact(ByteBuffer tableNameOrRegionName) throws IOError, org.apache.thrift.TException
{
send_majorCompact(tableNameOrRegionName);
recv_majorCompact();
}
- public void send_majorCompact(ByteBuffer tableNameOrRegionName) throws TException
+ public void send_majorCompact(ByteBuffer tableNameOrRegionName) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("majorCompact", TMessageType.CALL, ++seqid_));
+ oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("majorCompact", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
majorCompact_args args = new majorCompact_args();
args.setTableNameOrRegionName(tableNameOrRegionName);
args.write(oprot_);
@@ -816,16 +798,16 @@ public class Hbase {
oprot_.getTransport().flush();
}
- public void recv_majorCompact() throws IOError, TException
+ public void recv_majorCompact() throws IOError, org.apache.thrift.TException
{
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
+ org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
+ if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
+ org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
iprot_.readMessageEnd();
throw x;
}
if (msg.seqid != seqid_) {
- throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "majorCompact failed: out of sequence response");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "majorCompact failed: out of sequence response");
}
majorCompact_result result = new majorCompact_result();
result.read(iprot_);
@@ -836,31 +818,31 @@ public class Hbase {
return;
}
- public List getTableNames() throws IOError, TException
+ public List 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_));
+ oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getTableNames", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
getTableNames_args args = new getTableNames_args();
args.write(oprot_);
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
- public List recv_getTableNames() throws IOError, TException
+ public List recv_getTableNames() throws IOError, org.apache.thrift.TException
{
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
+ org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
+ if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
+ org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
iprot_.readMessageEnd();
throw x;
}
if (msg.seqid != seqid_) {
- throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "getTableNames failed: out of sequence response");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "getTableNames failed: out of sequence response");
}
getTableNames_result result = new getTableNames_result();
result.read(iprot_);
@@ -871,18 +853,18 @@ public class Hbase {
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 getColumnDescriptors(ByteBuffer tableName) throws IOError, TException
+ public Map getColumnDescriptors(ByteBuffer tableName) throws IOError, org.apache.thrift.TException
{
send_getColumnDescriptors(tableName);
return recv_getColumnDescriptors();
}
- public void send_getColumnDescriptors(ByteBuffer tableName) throws TException
+ public void send_getColumnDescriptors(ByteBuffer tableName) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("getColumnDescriptors", TMessageType.CALL, ++seqid_));
+ oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getColumnDescriptors", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
getColumnDescriptors_args args = new getColumnDescriptors_args();
args.setTableName(tableName);
args.write(oprot_);
@@ -890,16 +872,16 @@ public class Hbase {
oprot_.getTransport().flush();
}
- public Map recv_getColumnDescriptors() throws IOError, TException
+ public Map recv_getColumnDescriptors() throws IOError, org.apache.thrift.TException
{
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
+ org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
+ if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
+ org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
iprot_.readMessageEnd();
throw x;
}
if (msg.seqid != seqid_) {
- throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "getColumnDescriptors failed: out of sequence response");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "getColumnDescriptors failed: out of sequence response");
}
getColumnDescriptors_result result = new getColumnDescriptors_result();
result.read(iprot_);
@@ -910,18 +892,18 @@ public class Hbase {
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 getTableRegions(ByteBuffer tableName) throws IOError, TException
+ public List getTableRegions(ByteBuffer tableName) throws IOError, org.apache.thrift.TException
{
send_getTableRegions(tableName);
return recv_getTableRegions();
}
- public void send_getTableRegions(ByteBuffer tableName) throws TException
+ public void send_getTableRegions(ByteBuffer tableName) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("getTableRegions", TMessageType.CALL, ++seqid_));
+ oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getTableRegions", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
getTableRegions_args args = new getTableRegions_args();
args.setTableName(tableName);
args.write(oprot_);
@@ -929,16 +911,16 @@ public class Hbase {
oprot_.getTransport().flush();
}
- public List recv_getTableRegions() throws IOError, TException
+ public List recv_getTableRegions() throws IOError, org.apache.thrift.TException
{
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
+ org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
+ if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
+ org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
iprot_.readMessageEnd();
throw x;
}
if (msg.seqid != seqid_) {
- throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "getTableRegions failed: out of sequence response");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "getTableRegions failed: out of sequence response");
}
getTableRegions_result result = new getTableRegions_result();
result.read(iprot_);
@@ -949,18 +931,18 @@ public class Hbase {
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(ByteBuffer tableName, List columnFamilies) throws IOError, IllegalArgument, AlreadyExists, TException
+ public void createTable(ByteBuffer tableName, List columnFamilies) throws IOError, IllegalArgument, AlreadyExists, org.apache.thrift.TException
{
send_createTable(tableName, columnFamilies);
recv_createTable();
}
- public void send_createTable(ByteBuffer tableName, List columnFamilies) throws TException
+ public void send_createTable(ByteBuffer tableName, List columnFamilies) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("createTable", TMessageType.CALL, ++seqid_));
+ oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("createTable", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
createTable_args args = new createTable_args();
args.setTableName(tableName);
args.setColumnFamilies(columnFamilies);
@@ -969,16 +951,16 @@ public class Hbase {
oprot_.getTransport().flush();
}
- public void recv_createTable() throws IOError, IllegalArgument, AlreadyExists, TException
+ public void recv_createTable() throws IOError, IllegalArgument, AlreadyExists, org.apache.thrift.TException
{
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
+ org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
+ if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
+ org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
iprot_.readMessageEnd();
throw x;
}
if (msg.seqid != seqid_) {
- throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "createTable failed: out of sequence response");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "createTable failed: out of sequence response");
}
createTable_result result = new createTable_result();
result.read(iprot_);
@@ -995,15 +977,15 @@ public class Hbase {
return;
}
- public void deleteTable(ByteBuffer tableName) throws IOError, TException
+ public void deleteTable(ByteBuffer tableName) throws IOError, org.apache.thrift.TException
{
send_deleteTable(tableName);
recv_deleteTable();
}
- public void send_deleteTable(ByteBuffer tableName) throws TException
+ public void send_deleteTable(ByteBuffer tableName) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("deleteTable", TMessageType.CALL, ++seqid_));
+ oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("deleteTable", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
deleteTable_args args = new deleteTable_args();
args.setTableName(tableName);
args.write(oprot_);
@@ -1011,16 +993,16 @@ public class Hbase {
oprot_.getTransport().flush();
}
- public void recv_deleteTable() throws IOError, TException
+ public void recv_deleteTable() throws IOError, org.apache.thrift.TException
{
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
+ org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
+ if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
+ org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
iprot_.readMessageEnd();
throw x;
}
if (msg.seqid != seqid_) {
- throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "deleteTable failed: out of sequence response");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "deleteTable failed: out of sequence response");
}
deleteTable_result result = new deleteTable_result();
result.read(iprot_);
@@ -1031,15 +1013,15 @@ public class Hbase {
return;
}
- public List get(ByteBuffer tableName, ByteBuffer row, ByteBuffer column) throws IOError, TException
+ public List 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(ByteBuffer tableName, ByteBuffer row, ByteBuffer 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_));
+ oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("get", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
get_args args = new get_args();
args.setTableName(tableName);
args.setRow(row);
@@ -1049,16 +1031,16 @@ public class Hbase {
oprot_.getTransport().flush();
}
- public List recv_get() throws IOError, TException
+ public List recv_get() throws IOError, org.apache.thrift.TException
{
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
+ org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
+ if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
+ org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
iprot_.readMessageEnd();
throw x;
}
if (msg.seqid != seqid_) {
- throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "get failed: out of sequence response");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "get failed: out of sequence response");
}
get_result result = new get_result();
result.read(iprot_);
@@ -1069,18 +1051,18 @@ public class Hbase {
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 getVer(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, int numVersions) throws IOError, TException
+ public List 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(ByteBuffer tableName, ByteBuffer row, ByteBuffer 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_));
+ oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getVer", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
getVer_args args = new getVer_args();
args.setTableName(tableName);
args.setRow(row);
@@ -1091,16 +1073,16 @@ public class Hbase {
oprot_.getTransport().flush();
}
- public List recv_getVer() throws IOError, TException
+ public List recv_getVer() throws IOError, org.apache.thrift.TException
{
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
+ org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
+ if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
+ org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
iprot_.readMessageEnd();
throw x;
}
if (msg.seqid != seqid_) {
- throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "getVer failed: out of sequence response");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "getVer failed: out of sequence response");
}
getVer_result result = new getVer_result();
result.read(iprot_);
@@ -1111,18 +1093,18 @@ public class Hbase {
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 getVerTs(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, long timestamp, int numVersions) throws IOError, TException
+ public List 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(ByteBuffer tableName, ByteBuffer row, ByteBuffer 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_));
+ oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getVerTs", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
getVerTs_args args = new getVerTs_args();
args.setTableName(tableName);
args.setRow(row);
@@ -1134,16 +1116,16 @@ public class Hbase {
oprot_.getTransport().flush();
}
- public List recv_getVerTs() throws IOError, TException
+ public List recv_getVerTs() throws IOError, org.apache.thrift.TException
{
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
+ org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
+ if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
+ org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
iprot_.readMessageEnd();
throw x;
}
if (msg.seqid != seqid_) {
- throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "getVerTs failed: out of sequence response");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "getVerTs failed: out of sequence response");
}
getVerTs_result result = new getVerTs_result();
result.read(iprot_);
@@ -1154,18 +1136,18 @@ public class Hbase {
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 getRow(ByteBuffer tableName, ByteBuffer row) throws IOError, TException
+ public List getRow(ByteBuffer tableName, ByteBuffer row) throws IOError, org.apache.thrift.TException
{
send_getRow(tableName, row);
return recv_getRow();
}
- public void send_getRow(ByteBuffer tableName, ByteBuffer row) throws TException
+ public void send_getRow(ByteBuffer tableName, ByteBuffer row) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("getRow", TMessageType.CALL, ++seqid_));
+ oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getRow", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
getRow_args args = new getRow_args();
args.setTableName(tableName);
args.setRow(row);
@@ -1174,16 +1156,16 @@ public class Hbase {
oprot_.getTransport().flush();
}
- public List recv_getRow() throws IOError, TException
+ public List recv_getRow() throws IOError, org.apache.thrift.TException
{
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
+ org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
+ if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
+ org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
iprot_.readMessageEnd();
throw x;
}
if (msg.seqid != seqid_) {
- throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "getRow failed: out of sequence response");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "getRow failed: out of sequence response");
}
getRow_result result = new getRow_result();
result.read(iprot_);
@@ -1194,18 +1176,18 @@ public class Hbase {
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 getRowWithColumns(ByteBuffer tableName, ByteBuffer row, List columns) throws IOError, TException
+ public List getRowWithColumns(ByteBuffer tableName, ByteBuffer row, List columns) throws IOError, org.apache.thrift.TException
{
send_getRowWithColumns(tableName, row, columns);
return recv_getRowWithColumns();
}
- public void send_getRowWithColumns(ByteBuffer tableName, ByteBuffer row, List columns) throws TException
+ public void send_getRowWithColumns(ByteBuffer tableName, ByteBuffer row, List columns) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("getRowWithColumns", TMessageType.CALL, ++seqid_));
+ oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getRowWithColumns", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
getRowWithColumns_args args = new getRowWithColumns_args();
args.setTableName(tableName);
args.setRow(row);
@@ -1215,16 +1197,16 @@ public class Hbase {
oprot_.getTransport().flush();
}
- public List recv_getRowWithColumns() throws IOError, TException
+ public List recv_getRowWithColumns() throws IOError, org.apache.thrift.TException
{
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
+ org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
+ if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
+ org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
iprot_.readMessageEnd();
throw x;
}
if (msg.seqid != seqid_) {
- throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "getRowWithColumns failed: out of sequence response");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "getRowWithColumns failed: out of sequence response");
}
getRowWithColumns_result result = new getRowWithColumns_result();
result.read(iprot_);
@@ -1235,18 +1217,18 @@ public class Hbase {
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 getRowTs(ByteBuffer tableName, ByteBuffer row, long timestamp) throws IOError, TException
+ public List 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(ByteBuffer tableName, ByteBuffer 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_));
+ oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getRowTs", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
getRowTs_args args = new getRowTs_args();
args.setTableName(tableName);
args.setRow(row);
@@ -1256,16 +1238,16 @@ public class Hbase {
oprot_.getTransport().flush();
}
- public List recv_getRowTs() throws IOError, TException
+ public List recv_getRowTs() throws IOError, org.apache.thrift.TException
{
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
+ org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
+ if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
+ org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
iprot_.readMessageEnd();
throw x;
}
if (msg.seqid != seqid_) {
- throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "getRowTs failed: out of sequence response");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "getRowTs failed: out of sequence response");
}
getRowTs_result result = new getRowTs_result();
result.read(iprot_);
@@ -1276,18 +1258,18 @@ public class Hbase {
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 getRowWithColumnsTs(ByteBuffer tableName, ByteBuffer row, List columns, long timestamp) throws IOError, TException
+ public List getRowWithColumnsTs(ByteBuffer tableName, ByteBuffer row, List columns, long timestamp) throws IOError, org.apache.thrift.TException
{
send_getRowWithColumnsTs(tableName, row, columns, timestamp);
return recv_getRowWithColumnsTs();
}
- public void send_getRowWithColumnsTs(ByteBuffer tableName, ByteBuffer row, List columns, long timestamp) throws TException
+ public void send_getRowWithColumnsTs(ByteBuffer tableName, ByteBuffer row, List columns, long timestamp) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new TMessage("getRowWithColumnsTs", TMessageType.CALL, ++seqid_));
+ oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getRowWithColumnsTs", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
getRowWithColumnsTs_args args = new getRowWithColumnsTs_args();
args.setTableName(tableName);
args.setRow(row);
@@ -1298,16 +1280,16 @@ public class Hbase {
oprot_.getTransport().flush();
}
- public List recv_getRowWithColumnsTs() throws IOError, TException
+ public List recv_getRowWithColumnsTs() throws IOError, org.apache.thrift.TException
{
- TMessage msg = iprot_.readMessageBegin();
- if (msg.type == TMessageType.EXCEPTION) {
- TApplicationException x = TApplicationException.read(iprot_);
+ org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
+ if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
+ org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
iprot_.readMessageEnd();
throw x;
}
if (msg.seqid != seqid_) {
- throw new TApplicationException(TApplicationException.BAD_SEQUENCE_ID, "getRowWithColumnsTs failed: out of sequence response");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "getRowWithColumnsTs failed: out of sequence response");
}
getRowWithColumnsTs_result result = new getRowWithColumnsTs_result();
result.read(iprot_);
@@ -1318,18 +1300,18 @@ public class Hbase {
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 getRows(ByteBuffer tableName, List rows) throws IOError, TException
+ public List