Index: hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TTimeRange.java
===================================================================
--- hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TTimeRange.java (revision 1399390)
+++ hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TTimeRange.java (working copy)
@@ -1,5 +1,5 @@
/**
- * Autogenerated by Thrift Compiler (0.8.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -12,6 +12,9 @@
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;
@@ -106,7 +109,7 @@
// isset id assignments
private static final int __MINSTAMP_ISSET_ID = 0;
private static final int __MAXSTAMP_ISSET_ID = 1;
- private BitSet __isset_bit_vector = new BitSet(2);
+ private byte __isset_bitfield = 0;
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
@@ -136,8 +139,7 @@
* Performs a deep copy on other.
*/
public TTimeRange(TTimeRange other) {
- __isset_bit_vector.clear();
- __isset_bit_vector.or(other.__isset_bit_vector);
+ __isset_bitfield = other.__isset_bitfield;
this.minStamp = other.minStamp;
this.maxStamp = other.maxStamp;
}
@@ -165,16 +167,16 @@
}
public void unsetMinStamp() {
- __isset_bit_vector.clear(__MINSTAMP_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __MINSTAMP_ISSET_ID);
}
/** Returns true if field minStamp is set (has been assigned a value) and false otherwise */
public boolean isSetMinStamp() {
- return __isset_bit_vector.get(__MINSTAMP_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __MINSTAMP_ISSET_ID);
}
public void setMinStampIsSet(boolean value) {
- __isset_bit_vector.set(__MINSTAMP_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __MINSTAMP_ISSET_ID, value);
}
public long getMaxStamp() {
@@ -188,16 +190,16 @@
}
public void unsetMaxStamp() {
- __isset_bit_vector.clear(__MAXSTAMP_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __MAXSTAMP_ISSET_ID);
}
/** Returns true if field maxStamp is set (has been assigned a value) and false otherwise */
public boolean isSetMaxStamp() {
- return __isset_bit_vector.get(__MAXSTAMP_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __MAXSTAMP_ISSET_ID);
}
public void setMaxStampIsSet(boolean value) {
- __isset_bit_vector.set(__MAXSTAMP_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __MAXSTAMP_ISSET_ID, value);
}
public void setFieldValue(_Fields field, Object value) {
@@ -350,6 +352,7 @@
// check for required fields
// alas, we cannot check 'minStamp' because it's a primitive and you chose the non-beans generator.
// alas, we cannot check 'maxStamp' because it's a primitive and you chose the non-beans generator.
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -363,7 +366,7 @@
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
try {
// it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
- __isset_bit_vector = new BitSet(1);
+ __isset_bitfield = 0;
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
Index: hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TIllegalArgument.java
===================================================================
--- hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TIllegalArgument.java (revision 1399390)
+++ hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TIllegalArgument.java (working copy)
@@ -1,5 +1,5 @@
/**
- * Autogenerated by Thrift Compiler (0.8.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -12,6 +12,9 @@
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;
@@ -31,7 +34,7 @@
* A TIllegalArgument exception indicates an illegal or invalid
* argument was passed into a procedure.
*/
-public class TIllegalArgument extends Exception implements org.apache.thrift.TBase, java.io.Serializable, Cloneable {
+public class TIllegalArgument extends TException 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("TIllegalArgument");
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);
@@ -276,6 +279,7 @@
public void validate() throws org.apache.thrift.TException {
// check for required fields
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
Index: hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TColumn.java
===================================================================
--- hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TColumn.java (revision 1399390)
+++ hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TColumn.java (working copy)
@@ -1,5 +1,5 @@
/**
- * Autogenerated by Thrift Compiler (0.8.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -12,6 +12,9 @@
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;
@@ -115,7 +118,7 @@
// isset id assignments
private static final int __TIMESTAMP_ISSET_ID = 0;
- private BitSet __isset_bit_vector = new BitSet(1);
+ private byte __isset_bitfield = 0;
private _Fields optionals[] = {_Fields.QUALIFIER,_Fields.TIMESTAMP};
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
@@ -144,8 +147,7 @@
* Performs a deep copy on other.
*/
public TColumn(TColumn other) {
- __isset_bit_vector.clear();
- __isset_bit_vector.or(other.__isset_bit_vector);
+ __isset_bitfield = other.__isset_bitfield;
if (other.isSetFamily()) {
this.family = org.apache.thrift.TBaseHelper.copyBinary(other.family);
;
@@ -248,16 +250,16 @@
}
public void unsetTimestamp() {
- __isset_bit_vector.clear(__TIMESTAMP_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TIMESTAMP_ISSET_ID);
}
/** Returns true if field timestamp is set (has been assigned a value) and false otherwise */
public boolean isSetTimestamp() {
- return __isset_bit_vector.get(__TIMESTAMP_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __TIMESTAMP_ISSET_ID);
}
public void setTimestampIsSet(boolean value) {
- __isset_bit_vector.set(__TIMESTAMP_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TIMESTAMP_ISSET_ID, value);
}
public void setFieldValue(_Fields field, Object value) {
@@ -459,6 +461,7 @@
if (family == null) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'family' was not present! Struct: " + toString());
}
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -472,7 +475,7 @@
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
try {
// it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
- __isset_bit_vector = new BitSet(1);
+ __isset_bitfield = 0;
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
Index: hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TResult.java
===================================================================
--- hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TResult.java (revision 1399390)
+++ hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TResult.java (working copy)
@@ -1,5 +1,5 @@
/**
- * Autogenerated by Thrift Compiler (0.8.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -12,6 +12,9 @@
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;
@@ -391,6 +394,7 @@
if (columnValues == null) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'columnValues' was not present! Struct: " + toString());
}
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -442,7 +446,7 @@
struct.columnValues = new ArrayList(_list0.size);
for (int _i1 = 0; _i1 < _list0.size; ++_i1)
{
- TColumnValue _elem2; // optional
+ TColumnValue _elem2; // required
_elem2 = new TColumnValue();
_elem2.read(iprot);
struct.columnValues.add(_elem2);
@@ -530,7 +534,7 @@
struct.columnValues = new ArrayList(_list5.size);
for (int _i6 = 0; _i6 < _list5.size; ++_i6)
{
- TColumnValue _elem7; // optional
+ TColumnValue _elem7; // required
_elem7 = new TColumnValue();
_elem7.read(iprot);
struct.columnValues.add(_elem7);
Index: hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TGet.java
===================================================================
--- hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TGet.java (revision 1399390)
+++ hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TGet.java (working copy)
@@ -1,5 +1,5 @@
/**
- * Autogenerated by Thrift Compiler (0.8.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -12,6 +12,9 @@
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;
@@ -136,7 +139,7 @@
// isset id assignments
private static final int __TIMESTAMP_ISSET_ID = 0;
private static final int __MAXVERSIONS_ISSET_ID = 1;
- private BitSet __isset_bit_vector = new BitSet(2);
+ private byte __isset_bitfield = 0;
private _Fields optionals[] = {_Fields.COLUMNS,_Fields.TIMESTAMP,_Fields.TIME_RANGE,_Fields.MAX_VERSIONS};
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
@@ -170,8 +173,7 @@
* Performs a deep copy on other.
*/
public TGet(TGet other) {
- __isset_bit_vector.clear();
- __isset_bit_vector.or(other.__isset_bit_vector);
+ __isset_bitfield = other.__isset_bitfield;
if (other.isSetRow()) {
this.row = org.apache.thrift.TBaseHelper.copyBinary(other.row);
;
@@ -289,16 +291,16 @@
}
public void unsetTimestamp() {
- __isset_bit_vector.clear(__TIMESTAMP_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TIMESTAMP_ISSET_ID);
}
/** Returns true if field timestamp is set (has been assigned a value) and false otherwise */
public boolean isSetTimestamp() {
- return __isset_bit_vector.get(__TIMESTAMP_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __TIMESTAMP_ISSET_ID);
}
public void setTimestampIsSet(boolean value) {
- __isset_bit_vector.set(__TIMESTAMP_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TIMESTAMP_ISSET_ID, value);
}
public TTimeRange getTimeRange() {
@@ -336,16 +338,16 @@
}
public void unsetMaxVersions() {
- __isset_bit_vector.clear(__MAXVERSIONS_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __MAXVERSIONS_ISSET_ID);
}
/** Returns true if field maxVersions is set (has been assigned a value) and false otherwise */
public boolean isSetMaxVersions() {
- return __isset_bit_vector.get(__MAXVERSIONS_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __MAXVERSIONS_ISSET_ID);
}
public void setMaxVersionsIsSet(boolean value) {
- __isset_bit_vector.set(__MAXVERSIONS_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __MAXVERSIONS_ISSET_ID, value);
}
public void setFieldValue(_Fields field, Object value) {
@@ -627,6 +629,10 @@
if (row == null) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'row' was not present! Struct: " + toString());
}
+ // check for sub-struct validity
+ if (timeRange != null) {
+ timeRange.validate();
+ }
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -640,7 +646,7 @@
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
try {
// it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
- __isset_bit_vector = new BitSet(1);
+ __isset_bitfield = 0;
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
@@ -680,7 +686,7 @@
struct.columns = new ArrayList(_list8.size);
for (int _i9 = 0; _i9 < _list8.size; ++_i9)
{
- TColumn _elem10; // optional
+ TColumn _elem10; // required
_elem10 = new TColumn();
_elem10.read(iprot);
struct.columns.add(_elem10);
@@ -832,7 +838,7 @@
struct.columns = new ArrayList(_list13.size);
for (int _i14 = 0; _i14 < _list13.size; ++_i14)
{
- TColumn _elem15; // optional
+ TColumn _elem15; // required
_elem15 = new TColumn();
_elem15.read(iprot);
struct.columns.add(_elem15);
Index: hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TIOError.java
===================================================================
--- hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TIOError.java (revision 1399390)
+++ hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TIOError.java (working copy)
@@ -1,5 +1,5 @@
/**
- * Autogenerated by Thrift Compiler (0.8.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -12,6 +12,9 @@
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;
@@ -32,7 +35,7 @@
* to the HBase master or a HBase region server. Also used to return
* more general HBase error conditions.
*/
-public class TIOError extends Exception implements org.apache.thrift.TBase, java.io.Serializable, Cloneable {
+public class TIOError extends TException 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("TIOError");
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);
@@ -277,6 +280,7 @@
public void validate() throws org.apache.thrift.TException {
// check for required fields
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
Index: hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TColumnIncrement.java
===================================================================
--- hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TColumnIncrement.java (revision 1399390)
+++ hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TColumnIncrement.java (working copy)
@@ -1,5 +1,5 @@
/**
- * Autogenerated by Thrift Compiler (0.8.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -12,6 +12,9 @@
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;
@@ -113,7 +116,7 @@
// isset id assignments
private static final int __AMOUNT_ISSET_ID = 0;
- private BitSet __isset_bit_vector = new BitSet(1);
+ private byte __isset_bitfield = 0;
private _Fields optionals[] = {_Fields.AMOUNT};
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
@@ -146,8 +149,7 @@
* Performs a deep copy on other.
*/
public TColumnIncrement(TColumnIncrement other) {
- __isset_bit_vector.clear();
- __isset_bit_vector.or(other.__isset_bit_vector);
+ __isset_bitfield = other.__isset_bitfield;
if (other.isSetFamily()) {
this.family = org.apache.thrift.TBaseHelper.copyBinary(other.family);
;
@@ -250,16 +252,16 @@
}
public void unsetAmount() {
- __isset_bit_vector.clear(__AMOUNT_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __AMOUNT_ISSET_ID);
}
/** Returns true if field amount is set (has been assigned a value) and false otherwise */
public boolean isSetAmount() {
- return __isset_bit_vector.get(__AMOUNT_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __AMOUNT_ISSET_ID);
}
public void setAmountIsSet(boolean value) {
- __isset_bit_vector.set(__AMOUNT_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __AMOUNT_ISSET_ID, value);
}
public void setFieldValue(_Fields field, Object value) {
@@ -462,6 +464,7 @@
if (qualifier == null) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'qualifier' was not present! Struct: " + toString());
}
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -475,7 +478,7 @@
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
try {
// it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
- __isset_bit_vector = new BitSet(1);
+ __isset_bitfield = 0;
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
Index: hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TDelete.java
===================================================================
--- hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TDelete.java (revision 1399390)
+++ hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TDelete.java (working copy)
@@ -1,5 +1,5 @@
/**
- * Autogenerated by Thrift Compiler (0.8.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -12,6 +12,9 @@
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;
@@ -152,7 +155,7 @@
// isset id assignments
private static final int __TIMESTAMP_ISSET_ID = 0;
private static final int __WRITETOWAL_ISSET_ID = 1;
- private BitSet __isset_bit_vector = new BitSet(2);
+ private byte __isset_bitfield = 0;
private _Fields optionals[] = {_Fields.COLUMNS,_Fields.TIMESTAMP,_Fields.DELETE_TYPE,_Fields.WRITE_TO_WAL};
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
@@ -190,8 +193,7 @@
* Performs a deep copy on other.
*/
public TDelete(TDelete other) {
- __isset_bit_vector.clear();
- __isset_bit_vector.or(other.__isset_bit_vector);
+ __isset_bitfield = other.__isset_bitfield;
if (other.isSetRow()) {
this.row = org.apache.thrift.TBaseHelper.copyBinary(other.row);
;
@@ -310,16 +312,16 @@
}
public void unsetTimestamp() {
- __isset_bit_vector.clear(__TIMESTAMP_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TIMESTAMP_ISSET_ID);
}
/** Returns true if field timestamp is set (has been assigned a value) and false otherwise */
public boolean isSetTimestamp() {
- return __isset_bit_vector.get(__TIMESTAMP_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __TIMESTAMP_ISSET_ID);
}
public void setTimestampIsSet(boolean value) {
- __isset_bit_vector.set(__TIMESTAMP_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TIMESTAMP_ISSET_ID, value);
}
/**
@@ -365,16 +367,16 @@
}
public void unsetWriteToWal() {
- __isset_bit_vector.clear(__WRITETOWAL_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __WRITETOWAL_ISSET_ID);
}
/** Returns true if field writeToWal is set (has been assigned a value) and false otherwise */
public boolean isSetWriteToWal() {
- return __isset_bit_vector.get(__WRITETOWAL_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __WRITETOWAL_ISSET_ID);
}
public void setWriteToWalIsSet(boolean value) {
- __isset_bit_vector.set(__WRITETOWAL_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __WRITETOWAL_ISSET_ID, value);
}
public void setFieldValue(_Fields field, Object value) {
@@ -656,6 +658,7 @@
if (row == null) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'row' was not present! Struct: " + toString());
}
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -669,7 +672,7 @@
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
try {
// it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
- __isset_bit_vector = new BitSet(1);
+ __isset_bitfield = 0;
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
@@ -709,7 +712,7 @@
struct.columns = new ArrayList(_list24.size);
for (int _i25 = 0; _i25 < _list24.size; ++_i25)
{
- TColumn _elem26; // optional
+ TColumn _elem26; // required
_elem26 = new TColumn();
_elem26.read(iprot);
struct.columns.add(_elem26);
@@ -860,7 +863,7 @@
struct.columns = new ArrayList(_list29.size);
for (int _i30 = 0; _i30 < _list29.size; ++_i30)
{
- TColumn _elem31; // optional
+ TColumn _elem31; // required
_elem31 = new TColumn();
_elem31.read(iprot);
struct.columns.add(_elem31);
Index: hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/THBaseService.java
===================================================================
--- hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/THBaseService.java (revision 1399390)
+++ hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/THBaseService.java (working copy)
@@ -1,5 +1,5 @@
/**
- * Autogenerated by Thrift Compiler (0.8.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -12,6 +12,9 @@
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;
@@ -1121,16 +1124,20 @@
return processMap;
}
- private static class exists extends org.apache.thrift.ProcessFunction {
+ public static class exists extends org.apache.thrift.ProcessFunction {
public exists() {
super("exists");
}
- protected exists_args getEmptyArgsInstance() {
+ public exists_args getEmptyArgsInstance() {
return new exists_args();
}
- protected exists_result getResult(I iface, exists_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public exists_result getResult(I iface, exists_args args) throws org.apache.thrift.TException {
exists_result result = new exists_result();
try {
result.success = iface.exists(args.table, args.get);
@@ -1142,16 +1149,20 @@
}
}
- private static class get extends org.apache.thrift.ProcessFunction {
+ public static class get extends org.apache.thrift.ProcessFunction {
public get() {
super("get");
}
- protected get_args getEmptyArgsInstance() {
+ public get_args getEmptyArgsInstance() {
return new get_args();
}
- protected get_result getResult(I iface, get_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public get_result getResult(I iface, get_args args) throws org.apache.thrift.TException {
get_result result = new get_result();
try {
result.success = iface.get(args.table, args.get);
@@ -1162,16 +1173,20 @@
}
}
- private static class getMultiple extends org.apache.thrift.ProcessFunction {
+ public static class getMultiple extends org.apache.thrift.ProcessFunction {
public getMultiple() {
super("getMultiple");
}
- protected getMultiple_args getEmptyArgsInstance() {
+ public getMultiple_args getEmptyArgsInstance() {
return new getMultiple_args();
}
- protected getMultiple_result getResult(I iface, getMultiple_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public getMultiple_result getResult(I iface, getMultiple_args args) throws org.apache.thrift.TException {
getMultiple_result result = new getMultiple_result();
try {
result.success = iface.getMultiple(args.table, args.gets);
@@ -1182,16 +1197,20 @@
}
}
- private static class put extends org.apache.thrift.ProcessFunction {
+ public static class put extends org.apache.thrift.ProcessFunction {
public put() {
super("put");
}
- protected put_args getEmptyArgsInstance() {
+ public put_args getEmptyArgsInstance() {
return new put_args();
}
- protected put_result getResult(I iface, put_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public put_result getResult(I iface, put_args args) throws org.apache.thrift.TException {
put_result result = new put_result();
try {
iface.put(args.table, args.put);
@@ -1202,16 +1221,20 @@
}
}
- private static class checkAndPut extends org.apache.thrift.ProcessFunction {
+ public static class checkAndPut extends org.apache.thrift.ProcessFunction {
public checkAndPut() {
super("checkAndPut");
}
- protected checkAndPut_args getEmptyArgsInstance() {
+ public checkAndPut_args getEmptyArgsInstance() {
return new checkAndPut_args();
}
- protected checkAndPut_result getResult(I iface, checkAndPut_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public checkAndPut_result getResult(I iface, checkAndPut_args args) throws org.apache.thrift.TException {
checkAndPut_result result = new checkAndPut_result();
try {
result.success = iface.checkAndPut(args.table, args.row, args.family, args.qualifier, args.value, args.put);
@@ -1223,16 +1246,20 @@
}
}
- private static class putMultiple extends org.apache.thrift.ProcessFunction {
+ public static class putMultiple extends org.apache.thrift.ProcessFunction {
public putMultiple() {
super("putMultiple");
}
- protected putMultiple_args getEmptyArgsInstance() {
+ public putMultiple_args getEmptyArgsInstance() {
return new putMultiple_args();
}
- protected putMultiple_result getResult(I iface, putMultiple_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public putMultiple_result getResult(I iface, putMultiple_args args) throws org.apache.thrift.TException {
putMultiple_result result = new putMultiple_result();
try {
iface.putMultiple(args.table, args.puts);
@@ -1243,16 +1270,20 @@
}
}
- private static class deleteSingle extends org.apache.thrift.ProcessFunction {
+ public static class deleteSingle extends org.apache.thrift.ProcessFunction {
public deleteSingle() {
super("deleteSingle");
}
- protected deleteSingle_args getEmptyArgsInstance() {
+ public deleteSingle_args getEmptyArgsInstance() {
return new deleteSingle_args();
}
- protected deleteSingle_result getResult(I iface, deleteSingle_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public deleteSingle_result getResult(I iface, deleteSingle_args args) throws org.apache.thrift.TException {
deleteSingle_result result = new deleteSingle_result();
try {
iface.deleteSingle(args.table, args.deleteSingle);
@@ -1263,16 +1294,20 @@
}
}
- private static class deleteMultiple extends org.apache.thrift.ProcessFunction {
+ public static class deleteMultiple extends org.apache.thrift.ProcessFunction {
public deleteMultiple() {
super("deleteMultiple");
}
- protected deleteMultiple_args getEmptyArgsInstance() {
+ public deleteMultiple_args getEmptyArgsInstance() {
return new deleteMultiple_args();
}
- protected deleteMultiple_result getResult(I iface, deleteMultiple_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public deleteMultiple_result getResult(I iface, deleteMultiple_args args) throws org.apache.thrift.TException {
deleteMultiple_result result = new deleteMultiple_result();
try {
result.success = iface.deleteMultiple(args.table, args.deletes);
@@ -1283,16 +1318,20 @@
}
}
- private static class checkAndDelete extends org.apache.thrift.ProcessFunction {
+ public static class checkAndDelete extends org.apache.thrift.ProcessFunction {
public checkAndDelete() {
super("checkAndDelete");
}
- protected checkAndDelete_args getEmptyArgsInstance() {
+ public checkAndDelete_args getEmptyArgsInstance() {
return new checkAndDelete_args();
}
- protected checkAndDelete_result getResult(I iface, checkAndDelete_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public checkAndDelete_result getResult(I iface, checkAndDelete_args args) throws org.apache.thrift.TException {
checkAndDelete_result result = new checkAndDelete_result();
try {
result.success = iface.checkAndDelete(args.table, args.row, args.family, args.qualifier, args.value, args.deleteSingle);
@@ -1304,16 +1343,20 @@
}
}
- private static class increment extends org.apache.thrift.ProcessFunction {
+ public static class increment extends org.apache.thrift.ProcessFunction {
public increment() {
super("increment");
}
- protected increment_args getEmptyArgsInstance() {
+ public increment_args getEmptyArgsInstance() {
return new increment_args();
}
- protected increment_result getResult(I iface, increment_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public increment_result getResult(I iface, increment_args args) throws org.apache.thrift.TException {
increment_result result = new increment_result();
try {
result.success = iface.increment(args.table, args.increment);
@@ -1324,16 +1367,20 @@
}
}
- private static class openScanner extends org.apache.thrift.ProcessFunction {
+ public static class openScanner extends org.apache.thrift.ProcessFunction {
public openScanner() {
super("openScanner");
}
- protected openScanner_args getEmptyArgsInstance() {
+ public openScanner_args getEmptyArgsInstance() {
return new openScanner_args();
}
- protected openScanner_result getResult(I iface, openScanner_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public openScanner_result getResult(I iface, openScanner_args args) throws org.apache.thrift.TException {
openScanner_result result = new openScanner_result();
try {
result.success = iface.openScanner(args.table, args.scan);
@@ -1345,16 +1392,20 @@
}
}
- private static class getScannerRows extends org.apache.thrift.ProcessFunction {
+ public static class getScannerRows extends org.apache.thrift.ProcessFunction {
public getScannerRows() {
super("getScannerRows");
}
- protected getScannerRows_args getEmptyArgsInstance() {
+ public getScannerRows_args getEmptyArgsInstance() {
return new getScannerRows_args();
}
- protected getScannerRows_result getResult(I iface, getScannerRows_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public getScannerRows_result getResult(I iface, getScannerRows_args args) throws org.apache.thrift.TException {
getScannerRows_result result = new getScannerRows_result();
try {
result.success = iface.getScannerRows(args.scannerId, args.numRows);
@@ -1367,16 +1418,20 @@
}
}
- private static class closeScanner extends org.apache.thrift.ProcessFunction {
+ public static class closeScanner extends org.apache.thrift.ProcessFunction {
public closeScanner() {
super("closeScanner");
}
- protected closeScanner_args getEmptyArgsInstance() {
+ public closeScanner_args getEmptyArgsInstance() {
return new closeScanner_args();
}
- protected closeScanner_result getResult(I iface, closeScanner_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public closeScanner_result getResult(I iface, closeScanner_args args) throws org.apache.thrift.TException {
closeScanner_result result = new closeScanner_result();
try {
iface.closeScanner(args.scannerId);
@@ -1758,6 +1813,10 @@
if (get == null) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'get' was not present! Struct: " + toString());
}
+ // check for sub-struct validity
+ if (get != null) {
+ get.validate();
+ }
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -1948,7 +2007,7 @@
// isset id assignments
private static final int __SUCCESS_ISSET_ID = 0;
- private BitSet __isset_bit_vector = new BitSet(1);
+ private byte __isset_bitfield = 0;
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
@@ -1977,8 +2036,7 @@
* Performs a deep copy on other.
*/
public exists_result(exists_result other) {
- __isset_bit_vector.clear();
- __isset_bit_vector.or(other.__isset_bit_vector);
+ __isset_bitfield = other.__isset_bitfield;
this.success = other.success;
if (other.isSetIo()) {
this.io = new TIOError(other.io);
@@ -2007,16 +2065,16 @@
}
public void unsetSuccess() {
- __isset_bit_vector.clear(__SUCCESS_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __SUCCESS_ISSET_ID);
}
/** Returns true if field success is set (has been assigned a value) and false otherwise */
public boolean isSetSuccess() {
- return __isset_bit_vector.get(__SUCCESS_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __SUCCESS_ISSET_ID);
}
public void setSuccessIsSet(boolean value) {
- __isset_bit_vector.set(__SUCCESS_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __SUCCESS_ISSET_ID, value);
}
public TIOError getIo() {
@@ -2195,6 +2253,7 @@
public void validate() throws org.apache.thrift.TException {
// check for required fields
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -2207,6 +2266,8 @@
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
try {
+ // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
+ __isset_bitfield = 0;
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
@@ -2263,9 +2324,11 @@
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
- oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
- oprot.writeBool(struct.success);
- oprot.writeFieldEnd();
+ if (struct.isSetSuccess()) {
+ oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
+ oprot.writeBool(struct.success);
+ oprot.writeFieldEnd();
+ }
if (struct.io != null) {
oprot.writeFieldBegin(IO_FIELD_DESC);
struct.io.write(oprot);
@@ -2689,6 +2752,10 @@
if (get == null) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'get' was not present! Struct: " + toString());
}
+ // check for sub-struct validity
+ if (get != null) {
+ get.validate();
+ }
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -3127,6 +3194,10 @@
public void validate() throws org.apache.thrift.TException {
// check for required fields
+ // check for sub-struct validity
+ if (success != null) {
+ success.validate();
+ }
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -3653,6 +3724,7 @@
if (gets == null) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'gets' was not present! Struct: " + toString());
}
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -3704,7 +3776,7 @@
struct.gets = new ArrayList(_list48.size);
for (int _i49 = 0; _i49 < _list48.size; ++_i49)
{
- TGet _elem50; // optional
+ TGet _elem50; // required
_elem50 = new TGet();
_elem50.read(iprot);
struct.gets.add(_elem50);
@@ -3785,7 +3857,7 @@
struct.gets = new ArrayList(_list53.size);
for (int _i54 = 0; _i54 < _list53.size; ++_i54)
{
- TGet _elem55; // optional
+ TGet _elem55; // required
_elem55 = new TGet();
_elem55.read(iprot);
struct.gets.add(_elem55);
@@ -4143,6 +4215,7 @@
public void validate() throws org.apache.thrift.TException {
// check for required fields
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -4186,7 +4259,7 @@
struct.success = new ArrayList(_list56.size);
for (int _i57 = 0; _i57 < _list56.size; ++_i57)
{
- TResult _elem58; // optional
+ TResult _elem58; // required
_elem58 = new TResult();
_elem58.read(iprot);
struct.success.add(_elem58);
@@ -4288,7 +4361,7 @@
struct.success = new ArrayList(_list61.size);
for (int _i62 = 0; _i62 < _list61.size; ++_i62)
{
- TResult _elem63; // optional
+ TResult _elem63; // required
_elem63 = new TResult();
_elem63.read(iprot);
struct.success.add(_elem63);
@@ -4673,6 +4746,10 @@
if (put == null) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'put' was not present! Struct: " + toString());
}
+ // check for sub-struct validity
+ if (put != null) {
+ put.validate();
+ }
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -5034,6 +5111,7 @@
public void validate() throws org.apache.thrift.TException {
// check for required fields
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -5924,6 +6002,10 @@
if (put == null) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'put' was not present! Struct: " + toString());
}
+ // check for sub-struct validity
+ if (put != null) {
+ put.validate();
+ }
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -6188,7 +6270,7 @@
// isset id assignments
private static final int __SUCCESS_ISSET_ID = 0;
- private BitSet __isset_bit_vector = new BitSet(1);
+ private byte __isset_bitfield = 0;
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
@@ -6217,8 +6299,7 @@
* Performs a deep copy on other.
*/
public checkAndPut_result(checkAndPut_result other) {
- __isset_bit_vector.clear();
- __isset_bit_vector.or(other.__isset_bit_vector);
+ __isset_bitfield = other.__isset_bitfield;
this.success = other.success;
if (other.isSetIo()) {
this.io = new TIOError(other.io);
@@ -6247,16 +6328,16 @@
}
public void unsetSuccess() {
- __isset_bit_vector.clear(__SUCCESS_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __SUCCESS_ISSET_ID);
}
/** Returns true if field success is set (has been assigned a value) and false otherwise */
public boolean isSetSuccess() {
- return __isset_bit_vector.get(__SUCCESS_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __SUCCESS_ISSET_ID);
}
public void setSuccessIsSet(boolean value) {
- __isset_bit_vector.set(__SUCCESS_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __SUCCESS_ISSET_ID, value);
}
public TIOError getIo() {
@@ -6435,6 +6516,7 @@
public void validate() throws org.apache.thrift.TException {
// check for required fields
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -6447,6 +6529,8 @@
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
try {
+ // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
+ __isset_bitfield = 0;
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
@@ -6503,9 +6587,11 @@
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
- oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
- oprot.writeBool(struct.success);
- oprot.writeFieldEnd();
+ if (struct.isSetSuccess()) {
+ oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
+ oprot.writeBool(struct.success);
+ oprot.writeFieldEnd();
+ }
if (struct.io != null) {
oprot.writeFieldBegin(IO_FIELD_DESC);
struct.io.write(oprot);
@@ -6949,6 +7035,7 @@
if (puts == null) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'puts' was not present! Struct: " + toString());
}
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -7000,7 +7087,7 @@
struct.puts = new ArrayList(_list64.size);
for (int _i65 = 0; _i65 < _list64.size; ++_i65)
{
- TPut _elem66; // optional
+ TPut _elem66; // required
_elem66 = new TPut();
_elem66.read(iprot);
struct.puts.add(_elem66);
@@ -7081,7 +7168,7 @@
struct.puts = new ArrayList(_list69.size);
for (int _i70 = 0; _i70 < _list69.size; ++_i70)
{
- TPut _elem71; // optional
+ TPut _elem71; // required
_elem71 = new TPut();
_elem71.read(iprot);
struct.puts.add(_elem71);
@@ -7342,6 +7429,7 @@
public void validate() throws org.apache.thrift.TException {
// check for required fields
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -7815,6 +7903,10 @@
if (deleteSingle == null) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'deleteSingle' was not present! Struct: " + toString());
}
+ // check for sub-struct validity
+ if (deleteSingle != null) {
+ deleteSingle.validate();
+ }
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -8176,6 +8268,7 @@
public void validate() throws org.apache.thrift.TException {
// check for required fields
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -8669,6 +8762,7 @@
if (deletes == null) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'deletes' was not present! Struct: " + toString());
}
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -8720,7 +8814,7 @@
struct.deletes = new ArrayList(_list72.size);
for (int _i73 = 0; _i73 < _list72.size; ++_i73)
{
- TDelete _elem74; // optional
+ TDelete _elem74; // required
_elem74 = new TDelete();
_elem74.read(iprot);
struct.deletes.add(_elem74);
@@ -8801,7 +8895,7 @@
struct.deletes = new ArrayList(_list77.size);
for (int _i78 = 0; _i78 < _list77.size; ++_i78)
{
- TDelete _elem79; // optional
+ TDelete _elem79; // required
_elem79 = new TDelete();
_elem79.read(iprot);
struct.deletes.add(_elem79);
@@ -9159,6 +9253,7 @@
public void validate() throws org.apache.thrift.TException {
// check for required fields
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -9202,7 +9297,7 @@
struct.success = new ArrayList(_list80.size);
for (int _i81 = 0; _i81 < _list80.size; ++_i81)
{
- TDelete _elem82; // optional
+ TDelete _elem82; // required
_elem82 = new TDelete();
_elem82.read(iprot);
struct.success.add(_elem82);
@@ -9304,7 +9399,7 @@
struct.success = new ArrayList(_list85.size);
for (int _i86 = 0; _i86 < _list85.size; ++_i86)
{
- TDelete _elem87; // optional
+ TDelete _elem87; // required
_elem87 = new TDelete();
_elem87.read(iprot);
struct.success.add(_elem87);
@@ -10106,6 +10201,10 @@
if (deleteSingle == null) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'deleteSingle' was not present! Struct: " + toString());
}
+ // check for sub-struct validity
+ if (deleteSingle != null) {
+ deleteSingle.validate();
+ }
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -10370,7 +10469,7 @@
// isset id assignments
private static final int __SUCCESS_ISSET_ID = 0;
- private BitSet __isset_bit_vector = new BitSet(1);
+ private byte __isset_bitfield = 0;
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
@@ -10399,8 +10498,7 @@
* Performs a deep copy on other.
*/
public checkAndDelete_result(checkAndDelete_result other) {
- __isset_bit_vector.clear();
- __isset_bit_vector.or(other.__isset_bit_vector);
+ __isset_bitfield = other.__isset_bitfield;
this.success = other.success;
if (other.isSetIo()) {
this.io = new TIOError(other.io);
@@ -10429,16 +10527,16 @@
}
public void unsetSuccess() {
- __isset_bit_vector.clear(__SUCCESS_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __SUCCESS_ISSET_ID);
}
/** Returns true if field success is set (has been assigned a value) and false otherwise */
public boolean isSetSuccess() {
- return __isset_bit_vector.get(__SUCCESS_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __SUCCESS_ISSET_ID);
}
public void setSuccessIsSet(boolean value) {
- __isset_bit_vector.set(__SUCCESS_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __SUCCESS_ISSET_ID, value);
}
public TIOError getIo() {
@@ -10617,6 +10715,7 @@
public void validate() throws org.apache.thrift.TException {
// check for required fields
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -10629,6 +10728,8 @@
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
try {
+ // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
+ __isset_bitfield = 0;
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
@@ -10685,9 +10786,11 @@
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
- oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
- oprot.writeBool(struct.success);
- oprot.writeFieldEnd();
+ if (struct.isSetSuccess()) {
+ oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
+ oprot.writeBool(struct.success);
+ oprot.writeFieldEnd();
+ }
if (struct.io != null) {
oprot.writeFieldBegin(IO_FIELD_DESC);
struct.io.write(oprot);
@@ -11111,6 +11214,10 @@
if (increment == null) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'increment' was not present! Struct: " + toString());
}
+ // check for sub-struct validity
+ if (increment != null) {
+ increment.validate();
+ }
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -11549,6 +11656,10 @@
public void validate() throws org.apache.thrift.TException {
// check for required fields
+ // check for sub-struct validity
+ if (success != null) {
+ success.validate();
+ }
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -12047,6 +12158,10 @@
if (scan == null) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'scan' was not present! Struct: " + toString());
}
+ // check for sub-struct validity
+ if (scan != null) {
+ scan.validate();
+ }
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -12237,7 +12352,7 @@
// isset id assignments
private static final int __SUCCESS_ISSET_ID = 0;
- private BitSet __isset_bit_vector = new BitSet(1);
+ private byte __isset_bitfield = 0;
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
@@ -12266,8 +12381,7 @@
* Performs a deep copy on other.
*/
public openScanner_result(openScanner_result other) {
- __isset_bit_vector.clear();
- __isset_bit_vector.or(other.__isset_bit_vector);
+ __isset_bitfield = other.__isset_bitfield;
this.success = other.success;
if (other.isSetIo()) {
this.io = new TIOError(other.io);
@@ -12296,16 +12410,16 @@
}
public void unsetSuccess() {
- __isset_bit_vector.clear(__SUCCESS_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __SUCCESS_ISSET_ID);
}
/** Returns true if field success is set (has been assigned a value) and false otherwise */
public boolean isSetSuccess() {
- return __isset_bit_vector.get(__SUCCESS_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __SUCCESS_ISSET_ID);
}
public void setSuccessIsSet(boolean value) {
- __isset_bit_vector.set(__SUCCESS_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __SUCCESS_ISSET_ID, value);
}
public TIOError getIo() {
@@ -12484,6 +12598,7 @@
public void validate() throws org.apache.thrift.TException {
// check for required fields
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -12496,6 +12611,8 @@
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
try {
+ // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
+ __isset_bitfield = 0;
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
@@ -12552,9 +12669,11 @@
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
- oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
- oprot.writeI32(struct.success);
- oprot.writeFieldEnd();
+ if (struct.isSetSuccess()) {
+ oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
+ oprot.writeI32(struct.success);
+ oprot.writeFieldEnd();
+ }
if (struct.io != null) {
oprot.writeFieldBegin(IO_FIELD_DESC);
struct.io.write(oprot);
@@ -12702,7 +12821,7 @@
// isset id assignments
private static final int __SCANNERID_ISSET_ID = 0;
private static final int __NUMROWS_ISSET_ID = 1;
- private BitSet __isset_bit_vector = new BitSet(2);
+ private byte __isset_bitfield = 0;
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
@@ -12734,8 +12853,7 @@
* Performs a deep copy on other.
*/
public getScannerRows_args(getScannerRows_args other) {
- __isset_bit_vector.clear();
- __isset_bit_vector.or(other.__isset_bit_vector);
+ __isset_bitfield = other.__isset_bitfield;
this.scannerId = other.scannerId;
this.numRows = other.numRows;
}
@@ -12769,16 +12887,16 @@
}
public void unsetScannerId() {
- __isset_bit_vector.clear(__SCANNERID_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __SCANNERID_ISSET_ID);
}
/** Returns true if field scannerId is set (has been assigned a value) and false otherwise */
public boolean isSetScannerId() {
- return __isset_bit_vector.get(__SCANNERID_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __SCANNERID_ISSET_ID);
}
public void setScannerIdIsSet(boolean value) {
- __isset_bit_vector.set(__SCANNERID_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __SCANNERID_ISSET_ID, value);
}
/**
@@ -12798,16 +12916,16 @@
}
public void unsetNumRows() {
- __isset_bit_vector.clear(__NUMROWS_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NUMROWS_ISSET_ID);
}
/** Returns true if field numRows is set (has been assigned a value) and false otherwise */
public boolean isSetNumRows() {
- return __isset_bit_vector.get(__NUMROWS_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __NUMROWS_ISSET_ID);
}
public void setNumRowsIsSet(boolean value) {
- __isset_bit_vector.set(__NUMROWS_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NUMROWS_ISSET_ID, value);
}
public void setFieldValue(_Fields field, Object value) {
@@ -12959,6 +13077,7 @@
public void validate() throws org.apache.thrift.TException {
// check for required fields
// alas, we cannot check 'scannerId' because it's a primitive and you chose the non-beans generator.
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -12972,7 +13091,7 @@
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
try {
// it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
- __isset_bit_vector = new BitSet(1);
+ __isset_bitfield = 0;
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
@@ -13515,6 +13634,7 @@
public void validate() throws org.apache.thrift.TException {
// check for required fields
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -13558,7 +13678,7 @@
struct.success = new ArrayList(_list88.size);
for (int _i89 = 0; _i89 < _list88.size; ++_i89)
{
- TResult _elem90; // optional
+ TResult _elem90; // required
_elem90 = new TResult();
_elem90.read(iprot);
struct.success.add(_elem90);
@@ -13680,7 +13800,7 @@
struct.success = new ArrayList(_list93.size);
for (int _i94 = 0; _i94 < _list93.size; ++_i94)
{
- TResult _elem95; // optional
+ TResult _elem95; // required
_elem95 = new TResult();
_elem95.read(iprot);
struct.success.add(_elem95);
@@ -13782,7 +13902,7 @@
// isset id assignments
private static final int __SCANNERID_ISSET_ID = 0;
- private BitSet __isset_bit_vector = new BitSet(1);
+ private byte __isset_bitfield = 0;
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
@@ -13807,8 +13927,7 @@
* Performs a deep copy on other.
*/
public closeScanner_args(closeScanner_args other) {
- __isset_bit_vector.clear();
- __isset_bit_vector.or(other.__isset_bit_vector);
+ __isset_bitfield = other.__isset_bitfield;
this.scannerId = other.scannerId;
}
@@ -13839,16 +13958,16 @@
}
public void unsetScannerId() {
- __isset_bit_vector.clear(__SCANNERID_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __SCANNERID_ISSET_ID);
}
/** Returns true if field scannerId is set (has been assigned a value) and false otherwise */
public boolean isSetScannerId() {
- return __isset_bit_vector.get(__SCANNERID_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __SCANNERID_ISSET_ID);
}
public void setScannerIdIsSet(boolean value) {
- __isset_bit_vector.set(__SCANNERID_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __SCANNERID_ISSET_ID, value);
}
public void setFieldValue(_Fields field, Object value) {
@@ -13964,6 +14083,7 @@
public void validate() throws org.apache.thrift.TException {
// check for required fields
// alas, we cannot check 'scannerId' because it's a primitive and you chose the non-beans generator.
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -13977,7 +14097,7 @@
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
try {
// it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
- __isset_bit_vector = new BitSet(1);
+ __isset_bitfield = 0;
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
@@ -14399,6 +14519,7 @@
public void validate() throws org.apache.thrift.TException {
// check for required fields
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
Index: hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TDeleteType.java
===================================================================
--- hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TDeleteType.java (revision 1399390)
+++ hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TDeleteType.java (working copy)
@@ -1,5 +1,5 @@
/**
- * Autogenerated by Thrift Compiler (0.8.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
Index: hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TIncrement.java
===================================================================
--- hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TIncrement.java (revision 1399390)
+++ hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TIncrement.java (working copy)
@@ -1,5 +1,5 @@
/**
- * Autogenerated by Thrift Compiler (0.8.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -12,6 +12,9 @@
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;
@@ -116,7 +119,7 @@
// isset id assignments
private static final int __WRITETOWAL_ISSET_ID = 0;
- private BitSet __isset_bit_vector = new BitSet(1);
+ private byte __isset_bitfield = 0;
private _Fields optionals[] = {_Fields.WRITE_TO_WAL};
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
@@ -150,8 +153,7 @@
* Performs a deep copy on other.
*/
public TIncrement(TIncrement other) {
- __isset_bit_vector.clear();
- __isset_bit_vector.or(other.__isset_bit_vector);
+ __isset_bitfield = other.__isset_bitfield;
if (other.isSetRow()) {
this.row = org.apache.thrift.TBaseHelper.copyBinary(other.row);
;
@@ -262,16 +264,16 @@
}
public void unsetWriteToWal() {
- __isset_bit_vector.clear(__WRITETOWAL_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __WRITETOWAL_ISSET_ID);
}
/** Returns true if field writeToWal is set (has been assigned a value) and false otherwise */
public boolean isSetWriteToWal() {
- return __isset_bit_vector.get(__WRITETOWAL_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __WRITETOWAL_ISSET_ID);
}
public void setWriteToWalIsSet(boolean value) {
- __isset_bit_vector.set(__WRITETOWAL_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __WRITETOWAL_ISSET_ID, value);
}
public void setFieldValue(_Fields field, Object value) {
@@ -474,6 +476,7 @@
if (columns == null) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'columns' was not present! Struct: " + toString());
}
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -487,7 +490,7 @@
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
try {
// it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
- __isset_bit_vector = new BitSet(1);
+ __isset_bitfield = 0;
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
@@ -527,7 +530,7 @@
struct.columns = new ArrayList(_list32.size);
for (int _i33 = 0; _i33 < _list32.size; ++_i33)
{
- TColumnIncrement _elem34; // optional
+ TColumnIncrement _elem34; // required
_elem34 = new TColumnIncrement();
_elem34.read(iprot);
struct.columns.add(_elem34);
@@ -629,7 +632,7 @@
struct.columns = new ArrayList(_list37.size);
for (int _i38 = 0; _i38 < _list37.size; ++_i38)
{
- TColumnIncrement _elem39; // optional
+ TColumnIncrement _elem39; // required
_elem39 = new TColumnIncrement();
_elem39.read(iprot);
struct.columns.add(_elem39);
Index: hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TScan.java
===================================================================
--- hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TScan.java (revision 1399390)
+++ hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TScan.java (working copy)
@@ -1,5 +1,5 @@
/**
- * Autogenerated by Thrift Compiler (0.8.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -12,6 +12,9 @@
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;
@@ -130,7 +133,7 @@
// isset id assignments
private static final int __CACHING_ISSET_ID = 0;
private static final int __MAXVERSIONS_ISSET_ID = 1;
- private BitSet __isset_bit_vector = new BitSet(2);
+ private byte __isset_bitfield = 0;
private _Fields optionals[] = {_Fields.START_ROW,_Fields.STOP_ROW,_Fields.COLUMNS,_Fields.CACHING,_Fields.MAX_VERSIONS,_Fields.TIME_RANGE};
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
@@ -161,8 +164,7 @@
* Performs a deep copy on other.
*/
public TScan(TScan other) {
- __isset_bit_vector.clear();
- __isset_bit_vector.or(other.__isset_bit_vector);
+ __isset_bitfield = other.__isset_bitfield;
if (other.isSetStartRow()) {
this.startRow = org.apache.thrift.TBaseHelper.copyBinary(other.startRow);
;
@@ -319,16 +321,16 @@
}
public void unsetCaching() {
- __isset_bit_vector.clear(__CACHING_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __CACHING_ISSET_ID);
}
/** Returns true if field caching is set (has been assigned a value) and false otherwise */
public boolean isSetCaching() {
- return __isset_bit_vector.get(__CACHING_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __CACHING_ISSET_ID);
}
public void setCachingIsSet(boolean value) {
- __isset_bit_vector.set(__CACHING_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __CACHING_ISSET_ID, value);
}
public int getMaxVersions() {
@@ -342,16 +344,16 @@
}
public void unsetMaxVersions() {
- __isset_bit_vector.clear(__MAXVERSIONS_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __MAXVERSIONS_ISSET_ID);
}
/** Returns true if field maxVersions is set (has been assigned a value) and false otherwise */
public boolean isSetMaxVersions() {
- return __isset_bit_vector.get(__MAXVERSIONS_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __MAXVERSIONS_ISSET_ID);
}
public void setMaxVersionsIsSet(boolean value) {
- __isset_bit_vector.set(__MAXVERSIONS_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __MAXVERSIONS_ISSET_ID, value);
}
public TTimeRange getTimeRange() {
@@ -698,6 +700,10 @@
public void validate() throws org.apache.thrift.TException {
// check for required fields
+ // check for sub-struct validity
+ if (timeRange != null) {
+ timeRange.validate();
+ }
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -711,7 +717,7 @@
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
try {
// it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
- __isset_bit_vector = new BitSet(1);
+ __isset_bitfield = 0;
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
@@ -759,7 +765,7 @@
struct.columns = new ArrayList(_list40.size);
for (int _i41 = 0; _i41 < _list40.size; ++_i41)
{
- TColumn _elem42; // optional
+ TColumn _elem42; // required
_elem42 = new TColumn();
_elem42.read(iprot);
struct.columns.add(_elem42);
@@ -937,7 +943,7 @@
struct.columns = new ArrayList(_list45.size);
for (int _i46 = 0; _i46 < _list45.size; ++_i46)
{
- TColumn _elem47; // optional
+ TColumn _elem47; // required
_elem47 = new TColumn();
_elem47.read(iprot);
struct.columns.add(_elem47);
Index: hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TPut.java
===================================================================
--- hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TPut.java (revision 1399390)
+++ hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TPut.java (working copy)
@@ -1,5 +1,5 @@
/**
- * Autogenerated by Thrift Compiler (0.8.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -12,6 +12,9 @@
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;
@@ -127,7 +130,7 @@
// isset id assignments
private static final int __TIMESTAMP_ISSET_ID = 0;
private static final int __WRITETOWAL_ISSET_ID = 1;
- private BitSet __isset_bit_vector = new BitSet(2);
+ private byte __isset_bitfield = 0;
private _Fields optionals[] = {_Fields.TIMESTAMP,_Fields.WRITE_TO_WAL};
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
@@ -163,8 +166,7 @@
* Performs a deep copy on other.
*/
public TPut(TPut other) {
- __isset_bit_vector.clear();
- __isset_bit_vector.or(other.__isset_bit_vector);
+ __isset_bitfield = other.__isset_bitfield;
if (other.isSetRow()) {
this.row = org.apache.thrift.TBaseHelper.copyBinary(other.row);
;
@@ -278,16 +280,16 @@
}
public void unsetTimestamp() {
- __isset_bit_vector.clear(__TIMESTAMP_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TIMESTAMP_ISSET_ID);
}
/** Returns true if field timestamp is set (has been assigned a value) and false otherwise */
public boolean isSetTimestamp() {
- return __isset_bit_vector.get(__TIMESTAMP_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __TIMESTAMP_ISSET_ID);
}
public void setTimestampIsSet(boolean value) {
- __isset_bit_vector.set(__TIMESTAMP_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TIMESTAMP_ISSET_ID, value);
}
public boolean isWriteToWal() {
@@ -301,16 +303,16 @@
}
public void unsetWriteToWal() {
- __isset_bit_vector.clear(__WRITETOWAL_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __WRITETOWAL_ISSET_ID);
}
/** Returns true if field writeToWal is set (has been assigned a value) and false otherwise */
public boolean isSetWriteToWal() {
- return __isset_bit_vector.get(__WRITETOWAL_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __WRITETOWAL_ISSET_ID);
}
public void setWriteToWalIsSet(boolean value) {
- __isset_bit_vector.set(__WRITETOWAL_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __WRITETOWAL_ISSET_ID, value);
}
public void setFieldValue(_Fields field, Object value) {
@@ -551,6 +553,7 @@
if (columnValues == null) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'columnValues' was not present! Struct: " + toString());
}
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -564,7 +567,7 @@
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
try {
// it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
- __isset_bit_vector = new BitSet(1);
+ __isset_bitfield = 0;
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
@@ -604,7 +607,7 @@
struct.columnValues = new ArrayList(_list16.size);
for (int _i17 = 0; _i17 < _list16.size; ++_i17)
{
- TColumnValue _elem18; // optional
+ TColumnValue _elem18; // required
_elem18 = new TColumnValue();
_elem18.read(iprot);
struct.columnValues.add(_elem18);
@@ -725,7 +728,7 @@
struct.columnValues = new ArrayList(_list21.size);
for (int _i22 = 0; _i22 < _list21.size; ++_i22)
{
- TColumnValue _elem23; // optional
+ TColumnValue _elem23; // required
_elem23 = new TColumnValue();
_elem23.read(iprot);
struct.columnValues.add(_elem23);
Index: hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TColumnValue.java
===================================================================
--- hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TColumnValue.java (revision 1399390)
+++ hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TColumnValue.java (working copy)
@@ -1,5 +1,5 @@
/**
- * Autogenerated by Thrift Compiler (0.8.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -12,6 +12,9 @@
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;
@@ -118,7 +121,7 @@
// isset id assignments
private static final int __TIMESTAMP_ISSET_ID = 0;
- private BitSet __isset_bit_vector = new BitSet(1);
+ private byte __isset_bitfield = 0;
private _Fields optionals[] = {_Fields.TIMESTAMP};
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
@@ -153,8 +156,7 @@
* Performs a deep copy on other.
*/
public TColumnValue(TColumnValue other) {
- __isset_bit_vector.clear();
- __isset_bit_vector.or(other.__isset_bit_vector);
+ __isset_bitfield = other.__isset_bitfield;
if (other.isSetFamily()) {
this.family = org.apache.thrift.TBaseHelper.copyBinary(other.family);
;
@@ -296,16 +298,16 @@
}
public void unsetTimestamp() {
- __isset_bit_vector.clear(__TIMESTAMP_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TIMESTAMP_ISSET_ID);
}
/** Returns true if field timestamp is set (has been assigned a value) and false otherwise */
public boolean isSetTimestamp() {
- return __isset_bit_vector.get(__TIMESTAMP_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __TIMESTAMP_ISSET_ID);
}
public void setTimestampIsSet(boolean value) {
- __isset_bit_vector.set(__TIMESTAMP_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TIMESTAMP_ISSET_ID, value);
}
public void setFieldValue(_Fields field, Object value) {
@@ -551,6 +553,7 @@
if (value == null) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'value' was not present! Struct: " + toString());
}
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -564,7 +567,7 @@
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
try {
// it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
- __isset_bit_vector = new BitSet(1);
+ __isset_bitfield = 0;
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
Index: hbase-server/src/main/java/org/apache/hadoop/hbase/thrift/generated/Mutation.java
===================================================================
--- hbase-server/src/main/java/org/apache/hadoop/hbase/thrift/generated/Mutation.java (revision 1399390)
+++ hbase-server/src/main/java/org/apache/hadoop/hbase/thrift/generated/Mutation.java (working copy)
@@ -1,5 +1,5 @@
/**
- * Autogenerated by Thrift Compiler (0.8.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -12,6 +12,9 @@
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;
@@ -119,7 +122,7 @@
// isset id assignments
private static final int __ISDELETE_ISSET_ID = 0;
private static final int __WRITETOWAL_ISSET_ID = 1;
- private BitSet __isset_bit_vector = new BitSet(2);
+ private byte __isset_bitfield = 0;
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
@@ -161,8 +164,7 @@
* Performs a deep copy on other.
*/
public Mutation(Mutation other) {
- __isset_bit_vector.clear();
- __isset_bit_vector.or(other.__isset_bit_vector);
+ __isset_bitfield = other.__isset_bitfield;
this.isDelete = other.isDelete;
if (other.isSetColumn()) {
this.column = other.column;
@@ -198,16 +200,16 @@
}
public void unsetIsDelete() {
- __isset_bit_vector.clear(__ISDELETE_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ISDELETE_ISSET_ID);
}
/** Returns true if field isDelete is set (has been assigned a value) and false otherwise */
public boolean isSetIsDelete() {
- return __isset_bit_vector.get(__ISDELETE_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __ISDELETE_ISSET_ID);
}
public void setIsDeleteIsSet(boolean value) {
- __isset_bit_vector.set(__ISDELETE_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ISDELETE_ISSET_ID, value);
}
public byte[] getColumn() {
@@ -289,16 +291,16 @@
}
public void unsetWriteToWAL() {
- __isset_bit_vector.clear(__WRITETOWAL_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __WRITETOWAL_ISSET_ID);
}
/** Returns true if field writeToWAL is set (has been assigned a value) and false otherwise */
public boolean isSetWriteToWAL() {
- return __isset_bit_vector.get(__WRITETOWAL_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __WRITETOWAL_ISSET_ID);
}
public void setWriteToWALIsSet(boolean value) {
- __isset_bit_vector.set(__WRITETOWAL_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __WRITETOWAL_ISSET_ID, value);
}
public void setFieldValue(_Fields field, Object value) {
@@ -529,6 +531,7 @@
public void validate() throws org.apache.thrift.TException {
// check for required fields
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -542,7 +545,7 @@
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
try {
// it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
- __isset_bit_vector = new BitSet(1);
+ __isset_bitfield = 0;
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
Index: hbase-server/src/main/java/org/apache/hadoop/hbase/thrift/generated/AlreadyExists.java
===================================================================
--- hbase-server/src/main/java/org/apache/hadoop/hbase/thrift/generated/AlreadyExists.java (revision 1399390)
+++ hbase-server/src/main/java/org/apache/hadoop/hbase/thrift/generated/AlreadyExists.java (working copy)
@@ -1,5 +1,5 @@
/**
- * Autogenerated by Thrift Compiler (0.8.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -12,6 +12,9 @@
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;
@@ -31,7 +34,7 @@
* An AlreadyExists exceptions signals that a table with the specified
* name already exists
*/
-public class AlreadyExists extends Exception implements org.apache.thrift.TBase, java.io.Serializable, Cloneable {
+public class AlreadyExists extends TException 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 org.apache.thrift.protocol.TField MESSAGE_FIELD_DESC = new org.apache.thrift.protocol.TField("message", org.apache.thrift.protocol.TType.STRING, (short)1);
@@ -280,6 +283,7 @@
public void validate() throws org.apache.thrift.TException {
// check for required fields
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
Index: hbase-server/src/main/java/org/apache/hadoop/hbase/thrift/generated/IOError.java
===================================================================
--- hbase-server/src/main/java/org/apache/hadoop/hbase/thrift/generated/IOError.java (revision 1399390)
+++ hbase-server/src/main/java/org/apache/hadoop/hbase/thrift/generated/IOError.java (working copy)
@@ -1,5 +1,5 @@
/**
- * Autogenerated by Thrift Compiler (0.8.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -12,6 +12,9 @@
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;
@@ -32,7 +35,7 @@
* to the Hbase master or an Hbase region server. Also used to return
* more general Hbase error conditions.
*/
-public class IOError extends Exception implements org.apache.thrift.TBase, java.io.Serializable, Cloneable {
+public class IOError extends TException 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("IOError");
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);
@@ -281,6 +284,7 @@
public void validate() throws org.apache.thrift.TException {
// check for required fields
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
Index: hbase-server/src/main/java/org/apache/hadoop/hbase/thrift/generated/BatchMutation.java
===================================================================
--- hbase-server/src/main/java/org/apache/hadoop/hbase/thrift/generated/BatchMutation.java (revision 1399390)
+++ hbase-server/src/main/java/org/apache/hadoop/hbase/thrift/generated/BatchMutation.java (working copy)
@@ -1,5 +1,5 @@
/**
- * Autogenerated by Thrift Compiler (0.8.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -12,6 +12,9 @@
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;
@@ -386,6 +389,7 @@
public void validate() throws org.apache.thrift.TException {
// check for required fields
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -437,7 +441,7 @@
struct.mutations = new ArrayList(_list0.size);
for (int _i1 = 0; _i1 < _list0.size; ++_i1)
{
- Mutation _elem2; // optional
+ Mutation _elem2; // required
_elem2 = new Mutation();
_elem2.read(iprot);
struct.mutations.add(_elem2);
@@ -534,7 +538,7 @@
struct.mutations = new ArrayList(_list5.size);
for (int _i6 = 0; _i6 < _list5.size; ++_i6)
{
- Mutation _elem7; // optional
+ Mutation _elem7; // required
_elem7 = new Mutation();
_elem7.read(iprot);
struct.mutations.add(_elem7);
Index: hbase-server/src/main/java/org/apache/hadoop/hbase/thrift/generated/Hbase.java
===================================================================
--- hbase-server/src/main/java/org/apache/hadoop/hbase/thrift/generated/Hbase.java (revision 1399390)
+++ hbase-server/src/main/java/org/apache/hadoop/hbase/thrift/generated/Hbase.java (working copy)
@@ -1,5 +1,5 @@
/**
- * Autogenerated by Thrift Compiler (0.8.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -12,6 +12,9 @@
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;
@@ -3626,16 +3629,20 @@
return processMap;
}
- private static class enableTable extends org.apache.thrift.ProcessFunction {
+ public static class enableTable extends org.apache.thrift.ProcessFunction {
public enableTable() {
super("enableTable");
}
- protected enableTable_args getEmptyArgsInstance() {
+ public enableTable_args getEmptyArgsInstance() {
return new enableTable_args();
}
- protected enableTable_result getResult(I iface, enableTable_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public enableTable_result getResult(I iface, enableTable_args args) throws org.apache.thrift.TException {
enableTable_result result = new enableTable_result();
try {
iface.enableTable(args.tableName);
@@ -3646,16 +3653,20 @@
}
}
- private static class disableTable extends org.apache.thrift.ProcessFunction {
+ public static class disableTable extends org.apache.thrift.ProcessFunction {
public disableTable() {
super("disableTable");
}
- protected disableTable_args getEmptyArgsInstance() {
+ public disableTable_args getEmptyArgsInstance() {
return new disableTable_args();
}
- protected disableTable_result getResult(I iface, disableTable_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public disableTable_result getResult(I iface, disableTable_args args) throws org.apache.thrift.TException {
disableTable_result result = new disableTable_result();
try {
iface.disableTable(args.tableName);
@@ -3666,16 +3677,20 @@
}
}
- private static class isTableEnabled extends org.apache.thrift.ProcessFunction {
+ public static class isTableEnabled extends org.apache.thrift.ProcessFunction {
public isTableEnabled() {
super("isTableEnabled");
}
- protected isTableEnabled_args getEmptyArgsInstance() {
+ public isTableEnabled_args getEmptyArgsInstance() {
return new isTableEnabled_args();
}
- protected isTableEnabled_result getResult(I iface, isTableEnabled_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public isTableEnabled_result getResult(I iface, isTableEnabled_args args) throws org.apache.thrift.TException {
isTableEnabled_result result = new isTableEnabled_result();
try {
result.success = iface.isTableEnabled(args.tableName);
@@ -3687,16 +3702,20 @@
}
}
- private static class compact extends org.apache.thrift.ProcessFunction {
+ public static class compact extends org.apache.thrift.ProcessFunction {
public compact() {
super("compact");
}
- protected compact_args getEmptyArgsInstance() {
+ public compact_args getEmptyArgsInstance() {
return new compact_args();
}
- protected compact_result getResult(I iface, compact_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public compact_result getResult(I iface, compact_args args) throws org.apache.thrift.TException {
compact_result result = new compact_result();
try {
iface.compact(args.tableNameOrRegionName);
@@ -3707,16 +3726,20 @@
}
}
- private static class majorCompact extends org.apache.thrift.ProcessFunction {
+ public static class majorCompact extends org.apache.thrift.ProcessFunction {
public majorCompact() {
super("majorCompact");
}
- protected majorCompact_args getEmptyArgsInstance() {
+ public majorCompact_args getEmptyArgsInstance() {
return new majorCompact_args();
}
- protected majorCompact_result getResult(I iface, majorCompact_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public majorCompact_result getResult(I iface, majorCompact_args args) throws org.apache.thrift.TException {
majorCompact_result result = new majorCompact_result();
try {
iface.majorCompact(args.tableNameOrRegionName);
@@ -3727,16 +3750,20 @@
}
}
- private static class getTableNames extends org.apache.thrift.ProcessFunction {
+ public static class getTableNames extends org.apache.thrift.ProcessFunction {
public getTableNames() {
super("getTableNames");
}
- protected getTableNames_args getEmptyArgsInstance() {
+ public getTableNames_args getEmptyArgsInstance() {
return new getTableNames_args();
}
- protected getTableNames_result getResult(I iface, getTableNames_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public getTableNames_result getResult(I iface, getTableNames_args args) throws org.apache.thrift.TException {
getTableNames_result result = new getTableNames_result();
try {
result.success = iface.getTableNames();
@@ -3747,16 +3774,20 @@
}
}
- private static class getColumnDescriptors extends org.apache.thrift.ProcessFunction {
+ public static class getColumnDescriptors extends org.apache.thrift.ProcessFunction {
public getColumnDescriptors() {
super("getColumnDescriptors");
}
- protected getColumnDescriptors_args getEmptyArgsInstance() {
+ public getColumnDescriptors_args getEmptyArgsInstance() {
return new getColumnDescriptors_args();
}
- protected getColumnDescriptors_result getResult(I iface, getColumnDescriptors_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public getColumnDescriptors_result getResult(I iface, getColumnDescriptors_args args) throws org.apache.thrift.TException {
getColumnDescriptors_result result = new getColumnDescriptors_result();
try {
result.success = iface.getColumnDescriptors(args.tableName);
@@ -3767,16 +3798,20 @@
}
}
- private static class getTableRegions extends org.apache.thrift.ProcessFunction {
+ public static class getTableRegions extends org.apache.thrift.ProcessFunction {
public getTableRegions() {
super("getTableRegions");
}
- protected getTableRegions_args getEmptyArgsInstance() {
+ public getTableRegions_args getEmptyArgsInstance() {
return new getTableRegions_args();
}
- protected getTableRegions_result getResult(I iface, getTableRegions_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public getTableRegions_result getResult(I iface, getTableRegions_args args) throws org.apache.thrift.TException {
getTableRegions_result result = new getTableRegions_result();
try {
result.success = iface.getTableRegions(args.tableName);
@@ -3787,16 +3822,20 @@
}
}
- private static class createTable extends org.apache.thrift.ProcessFunction {
+ public static class createTable extends org.apache.thrift.ProcessFunction {
public createTable() {
super("createTable");
}
- protected createTable_args getEmptyArgsInstance() {
+ public createTable_args getEmptyArgsInstance() {
return new createTable_args();
}
- protected createTable_result getResult(I iface, createTable_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public createTable_result getResult(I iface, createTable_args args) throws org.apache.thrift.TException {
createTable_result result = new createTable_result();
try {
iface.createTable(args.tableName, args.columnFamilies);
@@ -3811,16 +3850,20 @@
}
}
- private static class deleteTable extends org.apache.thrift.ProcessFunction {
+ public static class deleteTable extends org.apache.thrift.ProcessFunction {
public deleteTable() {
super("deleteTable");
}
- protected deleteTable_args getEmptyArgsInstance() {
+ public deleteTable_args getEmptyArgsInstance() {
return new deleteTable_args();
}
- protected deleteTable_result getResult(I iface, deleteTable_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public deleteTable_result getResult(I iface, deleteTable_args args) throws org.apache.thrift.TException {
deleteTable_result result = new deleteTable_result();
try {
iface.deleteTable(args.tableName);
@@ -3831,16 +3874,20 @@
}
}
- private static class get extends org.apache.thrift.ProcessFunction {
+ public static class get extends org.apache.thrift.ProcessFunction {
public get() {
super("get");
}
- protected get_args getEmptyArgsInstance() {
+ public get_args getEmptyArgsInstance() {
return new get_args();
}
- protected get_result getResult(I iface, get_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public get_result getResult(I iface, get_args args) throws org.apache.thrift.TException {
get_result result = new get_result();
try {
result.success = iface.get(args.tableName, args.row, args.column, args.attributes);
@@ -3851,16 +3898,20 @@
}
}
- private static class getVer extends org.apache.thrift.ProcessFunction {
+ public static class getVer extends org.apache.thrift.ProcessFunction {
public getVer() {
super("getVer");
}
- protected getVer_args getEmptyArgsInstance() {
+ public getVer_args getEmptyArgsInstance() {
return new getVer_args();
}
- protected getVer_result getResult(I iface, getVer_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public getVer_result getResult(I iface, getVer_args args) throws org.apache.thrift.TException {
getVer_result result = new getVer_result();
try {
result.success = iface.getVer(args.tableName, args.row, args.column, args.numVersions, args.attributes);
@@ -3871,16 +3922,20 @@
}
}
- private static class getVerTs extends org.apache.thrift.ProcessFunction {
+ public static class getVerTs extends org.apache.thrift.ProcessFunction {
public getVerTs() {
super("getVerTs");
}
- protected getVerTs_args getEmptyArgsInstance() {
+ public getVerTs_args getEmptyArgsInstance() {
return new getVerTs_args();
}
- protected getVerTs_result getResult(I iface, getVerTs_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public getVerTs_result getResult(I iface, getVerTs_args args) throws org.apache.thrift.TException {
getVerTs_result result = new getVerTs_result();
try {
result.success = iface.getVerTs(args.tableName, args.row, args.column, args.timestamp, args.numVersions, args.attributes);
@@ -3891,16 +3946,20 @@
}
}
- private static class getRow extends org.apache.thrift.ProcessFunction {
+ public static class getRow extends org.apache.thrift.ProcessFunction {
public getRow() {
super("getRow");
}
- protected getRow_args getEmptyArgsInstance() {
+ public getRow_args getEmptyArgsInstance() {
return new getRow_args();
}
- protected getRow_result getResult(I iface, getRow_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public getRow_result getResult(I iface, getRow_args args) throws org.apache.thrift.TException {
getRow_result result = new getRow_result();
try {
result.success = iface.getRow(args.tableName, args.row, args.attributes);
@@ -3911,16 +3970,20 @@
}
}
- private static class getRowWithColumns extends org.apache.thrift.ProcessFunction {
+ public static class getRowWithColumns extends org.apache.thrift.ProcessFunction {
public getRowWithColumns() {
super("getRowWithColumns");
}
- protected getRowWithColumns_args getEmptyArgsInstance() {
+ public getRowWithColumns_args getEmptyArgsInstance() {
return new getRowWithColumns_args();
}
- protected getRowWithColumns_result getResult(I iface, getRowWithColumns_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public getRowWithColumns_result getResult(I iface, getRowWithColumns_args args) throws org.apache.thrift.TException {
getRowWithColumns_result result = new getRowWithColumns_result();
try {
result.success = iface.getRowWithColumns(args.tableName, args.row, args.columns, args.attributes);
@@ -3931,16 +3994,20 @@
}
}
- private static class getRowTs extends org.apache.thrift.ProcessFunction {
+ public static class getRowTs extends org.apache.thrift.ProcessFunction {
public getRowTs() {
super("getRowTs");
}
- protected getRowTs_args getEmptyArgsInstance() {
+ public getRowTs_args getEmptyArgsInstance() {
return new getRowTs_args();
}
- protected getRowTs_result getResult(I iface, getRowTs_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public getRowTs_result getResult(I iface, getRowTs_args args) throws org.apache.thrift.TException {
getRowTs_result result = new getRowTs_result();
try {
result.success = iface.getRowTs(args.tableName, args.row, args.timestamp, args.attributes);
@@ -3951,16 +4018,20 @@
}
}
- private static class getRowWithColumnsTs extends org.apache.thrift.ProcessFunction {
+ public static class getRowWithColumnsTs extends org.apache.thrift.ProcessFunction {
public getRowWithColumnsTs() {
super("getRowWithColumnsTs");
}
- protected getRowWithColumnsTs_args getEmptyArgsInstance() {
+ public getRowWithColumnsTs_args getEmptyArgsInstance() {
return new getRowWithColumnsTs_args();
}
- protected getRowWithColumnsTs_result getResult(I iface, getRowWithColumnsTs_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public getRowWithColumnsTs_result getResult(I iface, getRowWithColumnsTs_args args) throws org.apache.thrift.TException {
getRowWithColumnsTs_result result = new getRowWithColumnsTs_result();
try {
result.success = iface.getRowWithColumnsTs(args.tableName, args.row, args.columns, args.timestamp, args.attributes);
@@ -3971,16 +4042,20 @@
}
}
- private static class getRows extends org.apache.thrift.ProcessFunction {
+ public static class getRows extends org.apache.thrift.ProcessFunction {
public getRows() {
super("getRows");
}
- protected getRows_args getEmptyArgsInstance() {
+ public getRows_args getEmptyArgsInstance() {
return new getRows_args();
}
- protected getRows_result getResult(I iface, getRows_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public getRows_result getResult(I iface, getRows_args args) throws org.apache.thrift.TException {
getRows_result result = new getRows_result();
try {
result.success = iface.getRows(args.tableName, args.rows, args.attributes);
@@ -3991,16 +4066,20 @@
}
}
- private static class getRowsWithColumns extends org.apache.thrift.ProcessFunction {
+ public static class getRowsWithColumns extends org.apache.thrift.ProcessFunction {
public getRowsWithColumns() {
super("getRowsWithColumns");
}
- protected getRowsWithColumns_args getEmptyArgsInstance() {
+ public getRowsWithColumns_args getEmptyArgsInstance() {
return new getRowsWithColumns_args();
}
- protected getRowsWithColumns_result getResult(I iface, getRowsWithColumns_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public getRowsWithColumns_result getResult(I iface, getRowsWithColumns_args args) throws org.apache.thrift.TException {
getRowsWithColumns_result result = new getRowsWithColumns_result();
try {
result.success = iface.getRowsWithColumns(args.tableName, args.rows, args.columns, args.attributes);
@@ -4011,16 +4090,20 @@
}
}
- private static class getRowsTs extends org.apache.thrift.ProcessFunction {
+ public static class getRowsTs extends org.apache.thrift.ProcessFunction {
public getRowsTs() {
super("getRowsTs");
}
- protected getRowsTs_args getEmptyArgsInstance() {
+ public getRowsTs_args getEmptyArgsInstance() {
return new getRowsTs_args();
}
- protected getRowsTs_result getResult(I iface, getRowsTs_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public getRowsTs_result getResult(I iface, getRowsTs_args args) throws org.apache.thrift.TException {
getRowsTs_result result = new getRowsTs_result();
try {
result.success = iface.getRowsTs(args.tableName, args.rows, args.timestamp, args.attributes);
@@ -4031,16 +4114,20 @@
}
}
- private static class getRowsWithColumnsTs extends org.apache.thrift.ProcessFunction {
+ public static class getRowsWithColumnsTs extends org.apache.thrift.ProcessFunction {
public getRowsWithColumnsTs() {
super("getRowsWithColumnsTs");
}
- protected getRowsWithColumnsTs_args getEmptyArgsInstance() {
+ public getRowsWithColumnsTs_args getEmptyArgsInstance() {
return new getRowsWithColumnsTs_args();
}
- protected getRowsWithColumnsTs_result getResult(I iface, getRowsWithColumnsTs_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public getRowsWithColumnsTs_result getResult(I iface, getRowsWithColumnsTs_args args) throws org.apache.thrift.TException {
getRowsWithColumnsTs_result result = new getRowsWithColumnsTs_result();
try {
result.success = iface.getRowsWithColumnsTs(args.tableName, args.rows, args.columns, args.timestamp, args.attributes);
@@ -4051,16 +4138,20 @@
}
}
- private static class mutateRow extends org.apache.thrift.ProcessFunction {
+ public static class mutateRow extends org.apache.thrift.ProcessFunction {
public mutateRow() {
super("mutateRow");
}
- protected mutateRow_args getEmptyArgsInstance() {
+ public mutateRow_args getEmptyArgsInstance() {
return new mutateRow_args();
}
- protected mutateRow_result getResult(I iface, mutateRow_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public mutateRow_result getResult(I iface, mutateRow_args args) throws org.apache.thrift.TException {
mutateRow_result result = new mutateRow_result();
try {
iface.mutateRow(args.tableName, args.row, args.mutations, args.attributes);
@@ -4073,16 +4164,20 @@
}
}
- private static class mutateRowTs extends org.apache.thrift.ProcessFunction {
+ public static class mutateRowTs extends org.apache.thrift.ProcessFunction {
public mutateRowTs() {
super("mutateRowTs");
}
- protected mutateRowTs_args getEmptyArgsInstance() {
+ public mutateRowTs_args getEmptyArgsInstance() {
return new mutateRowTs_args();
}
- protected mutateRowTs_result getResult(I iface, mutateRowTs_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public mutateRowTs_result getResult(I iface, mutateRowTs_args args) throws org.apache.thrift.TException {
mutateRowTs_result result = new mutateRowTs_result();
try {
iface.mutateRowTs(args.tableName, args.row, args.mutations, args.timestamp, args.attributes);
@@ -4095,16 +4190,20 @@
}
}
- private static class mutateRows extends org.apache.thrift.ProcessFunction {
+ public static class mutateRows extends org.apache.thrift.ProcessFunction {
public mutateRows() {
super("mutateRows");
}
- protected mutateRows_args getEmptyArgsInstance() {
+ public mutateRows_args getEmptyArgsInstance() {
return new mutateRows_args();
}
- protected mutateRows_result getResult(I iface, mutateRows_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public mutateRows_result getResult(I iface, mutateRows_args args) throws org.apache.thrift.TException {
mutateRows_result result = new mutateRows_result();
try {
iface.mutateRows(args.tableName, args.rowBatches, args.attributes);
@@ -4117,16 +4216,20 @@
}
}
- private static class mutateRowsTs extends org.apache.thrift.ProcessFunction {
+ public static class mutateRowsTs extends org.apache.thrift.ProcessFunction {
public mutateRowsTs() {
super("mutateRowsTs");
}
- protected mutateRowsTs_args getEmptyArgsInstance() {
+ public mutateRowsTs_args getEmptyArgsInstance() {
return new mutateRowsTs_args();
}
- protected mutateRowsTs_result getResult(I iface, mutateRowsTs_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public mutateRowsTs_result getResult(I iface, mutateRowsTs_args args) throws org.apache.thrift.TException {
mutateRowsTs_result result = new mutateRowsTs_result();
try {
iface.mutateRowsTs(args.tableName, args.rowBatches, args.timestamp, args.attributes);
@@ -4139,16 +4242,20 @@
}
}
- private static class atomicIncrement extends org.apache.thrift.ProcessFunction {
+ public static class atomicIncrement extends org.apache.thrift.ProcessFunction {
public atomicIncrement() {
super("atomicIncrement");
}
- protected atomicIncrement_args getEmptyArgsInstance() {
+ public atomicIncrement_args getEmptyArgsInstance() {
return new atomicIncrement_args();
}
- protected atomicIncrement_result getResult(I iface, atomicIncrement_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public atomicIncrement_result getResult(I iface, atomicIncrement_args args) throws org.apache.thrift.TException {
atomicIncrement_result result = new atomicIncrement_result();
try {
result.success = iface.atomicIncrement(args.tableName, args.row, args.column, args.value);
@@ -4162,16 +4269,20 @@
}
}
- private static class deleteAll extends org.apache.thrift.ProcessFunction {
+ public static class deleteAll extends org.apache.thrift.ProcessFunction {
public deleteAll() {
super("deleteAll");
}
- protected deleteAll_args getEmptyArgsInstance() {
+ public deleteAll_args getEmptyArgsInstance() {
return new deleteAll_args();
}
- protected deleteAll_result getResult(I iface, deleteAll_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public deleteAll_result getResult(I iface, deleteAll_args args) throws org.apache.thrift.TException {
deleteAll_result result = new deleteAll_result();
try {
iface.deleteAll(args.tableName, args.row, args.column, args.attributes);
@@ -4182,16 +4293,20 @@
}
}
- private static class deleteAllTs extends org.apache.thrift.ProcessFunction {
+ public static class deleteAllTs extends org.apache.thrift.ProcessFunction {
public deleteAllTs() {
super("deleteAllTs");
}
- protected deleteAllTs_args getEmptyArgsInstance() {
+ public deleteAllTs_args getEmptyArgsInstance() {
return new deleteAllTs_args();
}
- protected deleteAllTs_result getResult(I iface, deleteAllTs_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public deleteAllTs_result getResult(I iface, deleteAllTs_args args) throws org.apache.thrift.TException {
deleteAllTs_result result = new deleteAllTs_result();
try {
iface.deleteAllTs(args.tableName, args.row, args.column, args.timestamp, args.attributes);
@@ -4202,16 +4317,20 @@
}
}
- private static class deleteAllRow extends org.apache.thrift.ProcessFunction {
+ public static class deleteAllRow extends org.apache.thrift.ProcessFunction {
public deleteAllRow() {
super("deleteAllRow");
}
- protected deleteAllRow_args getEmptyArgsInstance() {
+ public deleteAllRow_args getEmptyArgsInstance() {
return new deleteAllRow_args();
}
- protected deleteAllRow_result getResult(I iface, deleteAllRow_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public deleteAllRow_result getResult(I iface, deleteAllRow_args args) throws org.apache.thrift.TException {
deleteAllRow_result result = new deleteAllRow_result();
try {
iface.deleteAllRow(args.tableName, args.row, args.attributes);
@@ -4222,16 +4341,20 @@
}
}
- private static class increment extends org.apache.thrift.ProcessFunction {
+ public static class increment extends org.apache.thrift.ProcessFunction {
public increment() {
super("increment");
}
- protected increment_args getEmptyArgsInstance() {
+ public increment_args getEmptyArgsInstance() {
return new increment_args();
}
- protected increment_result getResult(I iface, increment_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public increment_result getResult(I iface, increment_args args) throws org.apache.thrift.TException {
increment_result result = new increment_result();
try {
iface.increment(args.increment);
@@ -4242,16 +4365,20 @@
}
}
- private static class incrementRows extends org.apache.thrift.ProcessFunction {
+ public static class incrementRows extends org.apache.thrift.ProcessFunction {
public incrementRows() {
super("incrementRows");
}
- protected incrementRows_args getEmptyArgsInstance() {
+ public incrementRows_args getEmptyArgsInstance() {
return new incrementRows_args();
}
- protected incrementRows_result getResult(I iface, incrementRows_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public incrementRows_result getResult(I iface, incrementRows_args args) throws org.apache.thrift.TException {
incrementRows_result result = new incrementRows_result();
try {
iface.incrementRows(args.increments);
@@ -4262,16 +4389,20 @@
}
}
- private static class deleteAllRowTs extends org.apache.thrift.ProcessFunction {
+ public static class deleteAllRowTs extends org.apache.thrift.ProcessFunction {
public deleteAllRowTs() {
super("deleteAllRowTs");
}
- protected deleteAllRowTs_args getEmptyArgsInstance() {
+ public deleteAllRowTs_args getEmptyArgsInstance() {
return new deleteAllRowTs_args();
}
- protected deleteAllRowTs_result getResult(I iface, deleteAllRowTs_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public deleteAllRowTs_result getResult(I iface, deleteAllRowTs_args args) throws org.apache.thrift.TException {
deleteAllRowTs_result result = new deleteAllRowTs_result();
try {
iface.deleteAllRowTs(args.tableName, args.row, args.timestamp, args.attributes);
@@ -4282,16 +4413,20 @@
}
}
- private static class scannerOpenWithScan extends org.apache.thrift.ProcessFunction {
+ public static class scannerOpenWithScan extends org.apache.thrift.ProcessFunction {
public scannerOpenWithScan() {
super("scannerOpenWithScan");
}
- protected scannerOpenWithScan_args getEmptyArgsInstance() {
+ public scannerOpenWithScan_args getEmptyArgsInstance() {
return new scannerOpenWithScan_args();
}
- protected scannerOpenWithScan_result getResult(I iface, scannerOpenWithScan_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public scannerOpenWithScan_result getResult(I iface, scannerOpenWithScan_args args) throws org.apache.thrift.TException {
scannerOpenWithScan_result result = new scannerOpenWithScan_result();
try {
result.success = iface.scannerOpenWithScan(args.tableName, args.scan, args.attributes);
@@ -4303,16 +4438,20 @@
}
}
- private static class scannerOpen extends org.apache.thrift.ProcessFunction {
+ public static class scannerOpen extends org.apache.thrift.ProcessFunction {
public scannerOpen() {
super("scannerOpen");
}
- protected scannerOpen_args getEmptyArgsInstance() {
+ public scannerOpen_args getEmptyArgsInstance() {
return new scannerOpen_args();
}
- protected scannerOpen_result getResult(I iface, scannerOpen_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public scannerOpen_result getResult(I iface, scannerOpen_args args) throws org.apache.thrift.TException {
scannerOpen_result result = new scannerOpen_result();
try {
result.success = iface.scannerOpen(args.tableName, args.startRow, args.columns, args.attributes);
@@ -4324,16 +4463,20 @@
}
}
- private static class scannerOpenWithStop extends org.apache.thrift.ProcessFunction {
+ public static class scannerOpenWithStop extends org.apache.thrift.ProcessFunction {
public scannerOpenWithStop() {
super("scannerOpenWithStop");
}
- protected scannerOpenWithStop_args getEmptyArgsInstance() {
+ public scannerOpenWithStop_args getEmptyArgsInstance() {
return new scannerOpenWithStop_args();
}
- protected scannerOpenWithStop_result getResult(I iface, scannerOpenWithStop_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public scannerOpenWithStop_result getResult(I iface, scannerOpenWithStop_args args) throws org.apache.thrift.TException {
scannerOpenWithStop_result result = new scannerOpenWithStop_result();
try {
result.success = iface.scannerOpenWithStop(args.tableName, args.startRow, args.stopRow, args.columns, args.attributes);
@@ -4345,16 +4488,20 @@
}
}
- private static class scannerOpenWithPrefix extends org.apache.thrift.ProcessFunction {
+ public static class scannerOpenWithPrefix extends org.apache.thrift.ProcessFunction {
public scannerOpenWithPrefix() {
super("scannerOpenWithPrefix");
}
- protected scannerOpenWithPrefix_args getEmptyArgsInstance() {
+ public scannerOpenWithPrefix_args getEmptyArgsInstance() {
return new scannerOpenWithPrefix_args();
}
- protected scannerOpenWithPrefix_result getResult(I iface, scannerOpenWithPrefix_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public scannerOpenWithPrefix_result getResult(I iface, scannerOpenWithPrefix_args args) throws org.apache.thrift.TException {
scannerOpenWithPrefix_result result = new scannerOpenWithPrefix_result();
try {
result.success = iface.scannerOpenWithPrefix(args.tableName, args.startAndPrefix, args.columns, args.attributes);
@@ -4366,16 +4513,20 @@
}
}
- private static class scannerOpenTs extends org.apache.thrift.ProcessFunction {
+ public static class scannerOpenTs extends org.apache.thrift.ProcessFunction {
public scannerOpenTs() {
super("scannerOpenTs");
}
- protected scannerOpenTs_args getEmptyArgsInstance() {
+ public scannerOpenTs_args getEmptyArgsInstance() {
return new scannerOpenTs_args();
}
- protected scannerOpenTs_result getResult(I iface, scannerOpenTs_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public scannerOpenTs_result getResult(I iface, scannerOpenTs_args args) throws org.apache.thrift.TException {
scannerOpenTs_result result = new scannerOpenTs_result();
try {
result.success = iface.scannerOpenTs(args.tableName, args.startRow, args.columns, args.timestamp, args.attributes);
@@ -4387,16 +4538,20 @@
}
}
- private static class scannerOpenWithStopTs extends org.apache.thrift.ProcessFunction {
+ public static class scannerOpenWithStopTs extends org.apache.thrift.ProcessFunction {
public scannerOpenWithStopTs() {
super("scannerOpenWithStopTs");
}
- protected scannerOpenWithStopTs_args getEmptyArgsInstance() {
+ public scannerOpenWithStopTs_args getEmptyArgsInstance() {
return new scannerOpenWithStopTs_args();
}
- protected scannerOpenWithStopTs_result getResult(I iface, scannerOpenWithStopTs_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public scannerOpenWithStopTs_result getResult(I iface, scannerOpenWithStopTs_args args) throws org.apache.thrift.TException {
scannerOpenWithStopTs_result result = new scannerOpenWithStopTs_result();
try {
result.success = iface.scannerOpenWithStopTs(args.tableName, args.startRow, args.stopRow, args.columns, args.timestamp, args.attributes);
@@ -4408,16 +4563,20 @@
}
}
- private static class scannerGet extends org.apache.thrift.ProcessFunction {
+ public static class scannerGet extends org.apache.thrift.ProcessFunction {
public scannerGet() {
super("scannerGet");
}
- protected scannerGet_args getEmptyArgsInstance() {
+ public scannerGet_args getEmptyArgsInstance() {
return new scannerGet_args();
}
- protected scannerGet_result getResult(I iface, scannerGet_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public scannerGet_result getResult(I iface, scannerGet_args args) throws org.apache.thrift.TException {
scannerGet_result result = new scannerGet_result();
try {
result.success = iface.scannerGet(args.id);
@@ -4430,16 +4589,20 @@
}
}
- private static class scannerGetList extends org.apache.thrift.ProcessFunction {
+ public static class scannerGetList extends org.apache.thrift.ProcessFunction {
public scannerGetList() {
super("scannerGetList");
}
- protected scannerGetList_args getEmptyArgsInstance() {
+ public scannerGetList_args getEmptyArgsInstance() {
return new scannerGetList_args();
}
- protected scannerGetList_result getResult(I iface, scannerGetList_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public scannerGetList_result getResult(I iface, scannerGetList_args args) throws org.apache.thrift.TException {
scannerGetList_result result = new scannerGetList_result();
try {
result.success = iface.scannerGetList(args.id, args.nbRows);
@@ -4452,16 +4615,20 @@
}
}
- private static class scannerClose extends org.apache.thrift.ProcessFunction {
+ public static class scannerClose extends org.apache.thrift.ProcessFunction {
public scannerClose() {
super("scannerClose");
}
- protected scannerClose_args getEmptyArgsInstance() {
+ public scannerClose_args getEmptyArgsInstance() {
return new scannerClose_args();
}
- protected scannerClose_result getResult(I iface, scannerClose_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public scannerClose_result getResult(I iface, scannerClose_args args) throws org.apache.thrift.TException {
scannerClose_result result = new scannerClose_result();
try {
iface.scannerClose(args.id);
@@ -4474,16 +4641,20 @@
}
}
- private static class getRowOrBefore extends org.apache.thrift.ProcessFunction {
+ public static class getRowOrBefore extends org.apache.thrift.ProcessFunction {
public getRowOrBefore() {
super("getRowOrBefore");
}
- protected getRowOrBefore_args getEmptyArgsInstance() {
+ public getRowOrBefore_args getEmptyArgsInstance() {
return new getRowOrBefore_args();
}
- protected getRowOrBefore_result getResult(I iface, getRowOrBefore_args args) throws org.apache.thrift.TException {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public getRowOrBefore_result getResult(I iface, getRowOrBefore_args args) throws org.apache.thrift.TException {
getRowOrBefore_result result = new getRowOrBefore_result();
try {
result.success = iface.getRowOrBefore(args.tableName, args.row, args.family);
@@ -4494,16 +4665,20 @@
}
}
- private static class getRegionInfo