You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by jm...@apache.org on 2014/04/25 23:22:56 UTC
svn commit: r1590152 [2/3] - in /hbase/trunk/hbase-thrift/src:
main/java/org/apache/hadoop/hbase/thrift/
main/java/org/apache/hadoop/hbase/thrift/generated/
main/resources/org/apache/hadoop/hbase/thrift/
test/java/org/apache/hadoop/hbase/thrift/
Modified: hbase/trunk/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/Hbase.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/Hbase.java?rev=1590152&r1=1590151&r2=1590152&view=diff
==============================================================================
--- hbase/trunk/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/Hbase.java (original)
+++ hbase/trunk/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/Hbase.java Fri Apr 25 21:22:55 2014
@@ -619,6 +619,35 @@ public class Hbase {
*/
public TRegionInfo getRegionInfo(ByteBuffer row) throws IOError, org.apache.thrift.TException;
+ /**
+ * Appends values to one or more columns within a single row.
+ *
+ * @return values of columns after the append operation.
+ *
+ * @param append The single append operation to apply
+ */
+ public List<TCell> append(TAppend append) throws IOError, org.apache.thrift.TException;
+
+ /**
+ * Atomically checks if a row/family/qualifier value matches the expected
+ * value. If it does, it adds the corresponding mutation operation for put.
+ *
+ * @return true if the new put was executed, false otherwise
+ *
+ * @param tableName name of table
+ *
+ * @param row row key
+ *
+ * @param column column name
+ *
+ * @param value value for perfomring the check
+ *
+ * @param mput mutation for the put
+ *
+ * @param attributes Mutation attributes
+ */
+ public boolean checkAndPut(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, ByteBuffer value, Mutation mput, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, IllegalArgument, org.apache.thrift.TException;
+
}
public interface AsyncIface {
@@ -709,6 +738,10 @@ public class Hbase {
public void getRegionInfo(ByteBuffer row, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRegionInfo_call> resultHandler) throws org.apache.thrift.TException;
+ public void append(TAppend append, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.append_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void checkAndPut(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, ByteBuffer value, Mutation mput, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.checkAndPut_call> resultHandler) throws org.apache.thrift.TException;
+
}
public static class Client extends org.apache.thrift.TServiceClient implements Iface {
@@ -1915,6 +1948,66 @@ public class Hbase {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRegionInfo failed: unknown result");
}
+ public List<TCell> append(TAppend append) throws IOError, org.apache.thrift.TException
+ {
+ send_append(append);
+ return recv_append();
+ }
+
+ public void send_append(TAppend append) throws org.apache.thrift.TException
+ {
+ append_args args = new append_args();
+ args.setAppend(append);
+ sendBase("append", args);
+ }
+
+ public List<TCell> recv_append() throws IOError, org.apache.thrift.TException
+ {
+ append_result result = new append_result();
+ receiveBase(result, "append");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.io != null) {
+ throw result.io;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "append failed: unknown result");
+ }
+
+ public boolean checkAndPut(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, ByteBuffer value, Mutation mput, Map<ByteBuffer,ByteBuffer> attributes) throws IOError, IllegalArgument, org.apache.thrift.TException
+ {
+ send_checkAndPut(tableName, row, column, value, mput, attributes);
+ return recv_checkAndPut();
+ }
+
+ public void send_checkAndPut(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, ByteBuffer value, Mutation mput, Map<ByteBuffer,ByteBuffer> attributes) throws org.apache.thrift.TException
+ {
+ checkAndPut_args args = new checkAndPut_args();
+ args.setTableName(tableName);
+ args.setRow(row);
+ args.setColumn(column);
+ args.setValue(value);
+ args.setMput(mput);
+ args.setAttributes(attributes);
+ sendBase("checkAndPut", args);
+ }
+
+ public boolean recv_checkAndPut() throws IOError, IllegalArgument, org.apache.thrift.TException
+ {
+ checkAndPut_result result = new checkAndPut_result();
+ receiveBase(result, "checkAndPut");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.io != null) {
+ throw result.io;
+ }
+ if (result.ia != null) {
+ throw result.ia;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "checkAndPut failed: unknown result");
+ }
+
}
public static class AsyncClient extends org.apache.thrift.async.TAsyncClient implements AsyncIface {
public static class Factory implements org.apache.thrift.async.TAsyncClientFactory<AsyncClient> {
@@ -3570,6 +3663,85 @@ public class Hbase {
}
}
+ public void append(TAppend append, org.apache.thrift.async.AsyncMethodCallback<append_call> resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ append_call method_call = new append_call(append, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class append_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private TAppend append;
+ public append_call(TAppend append, org.apache.thrift.async.AsyncMethodCallback<append_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.append = append;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("append", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ append_args args = new append_args();
+ args.setAppend(append);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public List<TCell> getResult() throws IOError, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ return (new Client(prot)).recv_append();
+ }
+ }
+
+ public void checkAndPut(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, ByteBuffer value, Mutation mput, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<checkAndPut_call> resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ checkAndPut_call method_call = new checkAndPut_call(tableName, row, column, value, mput, attributes, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class checkAndPut_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private ByteBuffer tableName;
+ private ByteBuffer row;
+ private ByteBuffer column;
+ private ByteBuffer value;
+ private Mutation mput;
+ private Map<ByteBuffer,ByteBuffer> attributes;
+ public checkAndPut_call(ByteBuffer tableName, ByteBuffer row, ByteBuffer column, ByteBuffer value, Mutation mput, Map<ByteBuffer,ByteBuffer> attributes, org.apache.thrift.async.AsyncMethodCallback<checkAndPut_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.tableName = tableName;
+ this.row = row;
+ this.column = column;
+ this.value = value;
+ this.mput = mput;
+ this.attributes = attributes;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("checkAndPut", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ checkAndPut_args args = new checkAndPut_args();
+ args.setTableName(tableName);
+ args.setRow(row);
+ args.setColumn(column);
+ args.setValue(value);
+ args.setMput(mput);
+ args.setAttributes(attributes);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public boolean getResult() throws IOError, IllegalArgument, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ return (new Client(prot)).recv_checkAndPut();
+ }
+ }
+
}
public static class Processor<I extends Iface> extends org.apache.thrift.TBaseProcessor<I> implements org.apache.thrift.TProcessor {
@@ -3626,6 +3798,8 @@ public class Hbase {
processMap.put("scannerClose", new scannerClose());
processMap.put("getRowOrBefore", new getRowOrBefore());
processMap.put("getRegionInfo", new getRegionInfo());
+ processMap.put("append", new append());
+ processMap.put("checkAndPut", new checkAndPut());
return processMap;
}
@@ -3822,8 +3996,7 @@ public class Hbase {
}
}
- public static class
- createTable<I extends Iface> extends org.apache.thrift.ProcessFunction<I, createTable_args> {
+ public static class createTable<I extends Iface> extends org.apache.thrift.ProcessFunction<I, createTable_args> {
public createTable() {
super("createTable");
}
@@ -4690,6 +4863,57 @@ public class Hbase {
}
}
+ public static class append<I extends Iface> extends org.apache.thrift.ProcessFunction<I, append_args> {
+ public append() {
+ super("append");
+ }
+
+ public append_args getEmptyArgsInstance() {
+ return new append_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public append_result getResult(I iface, append_args args) throws org.apache.thrift.TException {
+ append_result result = new append_result();
+ try {
+ result.success = iface.append(args.append);
+ } catch (IOError io) {
+ result.io = io;
+ }
+ return result;
+ }
+ }
+
+ public static class checkAndPut<I extends Iface> extends org.apache.thrift.ProcessFunction<I, checkAndPut_args> {
+ public checkAndPut() {
+ super("checkAndPut");
+ }
+
+ public checkAndPut_args getEmptyArgsInstance() {
+ return new checkAndPut_args();
+ }
+
+ 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.tableName, args.row, args.column, args.value, args.mput, args.attributes);
+ result.setSuccessIsSet(true);
+ } catch (IOError io) {
+ result.io = io;
+ } catch (IllegalArgument ia) {
+ result.ia = ia;
+ }
+ return result;
+ }
+ }
+
}
public static class enableTable_args implements org.apache.thrift.TBase<enableTable_args, enableTable_args._Fields>, java.io.Serializable, Cloneable {
@@ -9060,13 +9284,13 @@ public class Hbase {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list26 = iprot.readListBegin();
- struct.success = new ArrayList<ByteBuffer>(_list26.size);
- for (int _i27 = 0; _i27 < _list26.size; ++_i27)
+ org.apache.thrift.protocol.TList _list50 = iprot.readListBegin();
+ struct.success = new ArrayList<ByteBuffer>(_list50.size);
+ for (int _i51 = 0; _i51 < _list50.size; ++_i51)
{
- ByteBuffer _elem28; // required
- _elem28 = iprot.readBinary();
- struct.success.add(_elem28);
+ ByteBuffer _elem52; // required
+ _elem52 = iprot.readBinary();
+ struct.success.add(_elem52);
}
iprot.readListEnd();
}
@@ -9103,9 +9327,9 @@ public class Hbase {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
- for (ByteBuffer _iter29 : struct.success)
+ for (ByteBuffer _iter53 : struct.success)
{
- oprot.writeBinary(_iter29);
+ oprot.writeBinary(_iter53);
}
oprot.writeListEnd();
}
@@ -9144,9 +9368,9 @@ public class Hbase {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (ByteBuffer _iter30 : struct.success)
+ for (ByteBuffer _iter54 : struct.success)
{
- oprot.writeBinary(_iter30);
+ oprot.writeBinary(_iter54);
}
}
}
@@ -9161,13 +9385,13 @@ public class Hbase {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list31 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<ByteBuffer>(_list31.size);
- for (int _i32 = 0; _i32 < _list31.size; ++_i32)
- {
- ByteBuffer _elem33; // required
- _elem33 = iprot.readBinary();
- struct.success.add(_elem33);
+ org.apache.thrift.protocol.TList _list55 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<ByteBuffer>(_list55.size);
+ for (int _i56 = 0; _i56 < _list55.size; ++_i56)
+ {
+ ByteBuffer _elem57; // required
+ _elem57 = iprot.readBinary();
+ struct.success.add(_elem57);
}
}
struct.setSuccessIsSet(true);
@@ -9949,16 +10173,16 @@ public class Hbase {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map34 = iprot.readMapBegin();
- struct.success = new HashMap<ByteBuffer,ColumnDescriptor>(2*_map34.size);
- for (int _i35 = 0; _i35 < _map34.size; ++_i35)
+ org.apache.thrift.protocol.TMap _map58 = iprot.readMapBegin();
+ struct.success = new HashMap<ByteBuffer,ColumnDescriptor>(2*_map58.size);
+ for (int _i59 = 0; _i59 < _map58.size; ++_i59)
{
- ByteBuffer _key36; // required
- ColumnDescriptor _val37; // optional
- _key36 = iprot.readBinary();
- _val37 = new ColumnDescriptor();
- _val37.read(iprot);
- struct.success.put(_key36, _val37);
+ ByteBuffer _key60; // required
+ ColumnDescriptor _val61; // required
+ _key60 = iprot.readBinary();
+ _val61 = new ColumnDescriptor();
+ _val61.read(iprot);
+ struct.success.put(_key60, _val61);
}
iprot.readMapEnd();
}
@@ -9995,10 +10219,10 @@ public class Hbase {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (Map.Entry<ByteBuffer, ColumnDescriptor> _iter38 : struct.success.entrySet())
+ for (Map.Entry<ByteBuffer, ColumnDescriptor> _iter62 : struct.success.entrySet())
{
- oprot.writeBinary(_iter38.getKey());
- _iter38.getValue().write(oprot);
+ oprot.writeBinary(_iter62.getKey());
+ _iter62.getValue().write(oprot);
}
oprot.writeMapEnd();
}
@@ -10037,10 +10261,10 @@ public class Hbase {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Map.Entry<ByteBuffer, ColumnDescriptor> _iter39 : struct.success.entrySet())
+ for (Map.Entry<ByteBuffer, ColumnDescriptor> _iter63 : struct.success.entrySet())
{
- oprot.writeBinary(_iter39.getKey());
- _iter39.getValue().write(oprot);
+ oprot.writeBinary(_iter63.getKey());
+ _iter63.getValue().write(oprot);
}
}
}
@@ -10055,16 +10279,16 @@ public class Hbase {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TMap _map40 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new HashMap<ByteBuffer,ColumnDescriptor>(2*_map40.size);
- for (int _i41 = 0; _i41 < _map40.size; ++_i41)
- {
- ByteBuffer _key42; // required
- ColumnDescriptor _val43; // optional
- _key42 = iprot.readBinary();
- _val43 = new ColumnDescriptor();
- _val43.read(iprot);
- struct.success.put(_key42, _val43);
+ org.apache.thrift.protocol.TMap _map64 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new HashMap<ByteBuffer,ColumnDescriptor>(2*_map64.size);
+ for (int _i65 = 0; _i65 < _map64.size; ++_i65)
+ {
+ ByteBuffer _key66; // required
+ ColumnDescriptor _val67; // required
+ _key66 = iprot.readBinary();
+ _val67 = new ColumnDescriptor();
+ _val67.read(iprot);
+ struct.success.put(_key66, _val67);
}
}
struct.setSuccessIsSet(true);
@@ -10841,14 +11065,14 @@ public class Hbase {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list44 = iprot.readListBegin();
- struct.success = new ArrayList<TRegionInfo>(_list44.size);
- for (int _i45 = 0; _i45 < _list44.size; ++_i45)
+ org.apache.thrift.protocol.TList _list68 = iprot.readListBegin();
+ struct.success = new ArrayList<TRegionInfo>(_list68.size);
+ for (int _i69 = 0; _i69 < _list68.size; ++_i69)
{
- TRegionInfo _elem46; // required
- _elem46 = new TRegionInfo();
- _elem46.read(iprot);
- struct.success.add(_elem46);
+ TRegionInfo _elem70; // required
+ _elem70 = new TRegionInfo();
+ _elem70.read(iprot);
+ struct.success.add(_elem70);
}
iprot.readListEnd();
}
@@ -10885,9 +11109,9 @@ public class Hbase {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (TRegionInfo _iter47 : struct.success)
+ for (TRegionInfo _iter71 : struct.success)
{
- _iter47.write(oprot);
+ _iter71.write(oprot);
}
oprot.writeListEnd();
}
@@ -10926,9 +11150,9 @@ public class Hbase {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (TRegionInfo _iter48 : struct.success)
+ for (TRegionInfo _iter72 : struct.success)
{
- _iter48.write(oprot);
+ _iter72.write(oprot);
}
}
}
@@ -10943,14 +11167,14 @@ public class Hbase {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list49 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<TRegionInfo>(_list49.size);
- for (int _i50 = 0; _i50 < _list49.size; ++_i50)
- {
- TRegionInfo _elem51; // required
- _elem51 = new TRegionInfo();
- _elem51.read(iprot);
- struct.success.add(_elem51);
+ org.apache.thrift.protocol.TList _list73 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<TRegionInfo>(_list73.size);
+ for (int _i74 = 0; _i74 < _list73.size; ++_i74)
+ {
+ TRegionInfo _elem75; // required
+ _elem75 = new TRegionInfo();
+ _elem75.read(iprot);
+ struct.success.add(_elem75);
}
}
struct.setSuccessIsSet(true);
@@ -11393,14 +11617,14 @@ public class Hbase {
case 2: // COLUMN_FAMILIES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list52 = iprot.readListBegin();
- struct.columnFamilies = new ArrayList<ColumnDescriptor>(_list52.size);
- for (int _i53 = 0; _i53 < _list52.size; ++_i53)
+ org.apache.thrift.protocol.TList _list76 = iprot.readListBegin();
+ struct.columnFamilies = new ArrayList<ColumnDescriptor>(_list76.size);
+ for (int _i77 = 0; _i77 < _list76.size; ++_i77)
{
- ColumnDescriptor _elem54; // required
- _elem54 = new ColumnDescriptor();
- _elem54.read(iprot);
- struct.columnFamilies.add(_elem54);
+ ColumnDescriptor _elem78; // required
+ _elem78 = new ColumnDescriptor();
+ _elem78.read(iprot);
+ struct.columnFamilies.add(_elem78);
}
iprot.readListEnd();
}
@@ -11433,9 +11657,9 @@ public class Hbase {
oprot.writeFieldBegin(COLUMN_FAMILIES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.columnFamilies.size()));
- for (ColumnDescriptor _iter55 : struct.columnFamilies)
+ for (ColumnDescriptor _iter79 : struct.columnFamilies)
{
- _iter55.write(oprot);
+ _iter79.write(oprot);
}
oprot.writeListEnd();
}
@@ -11472,9 +11696,9 @@ public class Hbase {
if (struct.isSetColumnFamilies()) {
{
oprot.writeI32(struct.columnFamilies.size());
- for (ColumnDescriptor _iter56 : struct.columnFamilies)
+ for (ColumnDescriptor _iter80 : struct.columnFamilies)
{
- _iter56.write(oprot);
+ _iter80.write(oprot);
}
}
}
@@ -11490,14 +11714,14 @@ public class Hbase {
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list57 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.columnFamilies = new ArrayList<ColumnDescriptor>(_list57.size);
- for (int _i58 = 0; _i58 < _list57.size; ++_i58)
- {
- ColumnDescriptor _elem59; // required
- _elem59 = new ColumnDescriptor();
- _elem59.read(iprot);
- struct.columnFamilies.add(_elem59);
+ org.apache.thrift.protocol.TList _list81 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.columnFamilies = new ArrayList<ColumnDescriptor>(_list81.size);
+ for (int _i82 = 0; _i82 < _list81.size; ++_i82)
+ {
+ ColumnDescriptor _elem83; // required
+ _elem83 = new ColumnDescriptor();
+ _elem83.read(iprot);
+ struct.columnFamilies.add(_elem83);
}
}
struct.setColumnFamiliesIsSet(true);
@@ -13446,15 +13670,15 @@ public class Hbase {
case 4: // ATTRIBUTES
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map60 = iprot.readMapBegin();
- struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map60.size);
- for (int _i61 = 0; _i61 < _map60.size; ++_i61)
+ org.apache.thrift.protocol.TMap _map84 = iprot.readMapBegin();
+ struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map84.size);
+ for (int _i85 = 0; _i85 < _map84.size; ++_i85)
{
- ByteBuffer _key62; // required
- ByteBuffer _val63; // optional
- _key62 = iprot.readBinary();
- _val63 = iprot.readBinary();
- struct.attributes.put(_key62, _val63);
+ ByteBuffer _key86; // required
+ ByteBuffer _val87; // required
+ _key86 = iprot.readBinary();
+ _val87 = iprot.readBinary();
+ struct.attributes.put(_key86, _val87);
}
iprot.readMapEnd();
}
@@ -13497,10 +13721,10 @@ public class Hbase {
oprot.writeFieldBegin(ATTRIBUTES_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.attributes.size()));
- for (Map.Entry<ByteBuffer, ByteBuffer> _iter64 : struct.attributes.entrySet())
+ for (Map.Entry<ByteBuffer, ByteBuffer> _iter88 : struct.attributes.entrySet())
{
- oprot.writeBinary(_iter64.getKey());
- oprot.writeBinary(_iter64.getValue());
+ oprot.writeBinary(_iter88.getKey());
+ oprot.writeBinary(_iter88.getValue());
}
oprot.writeMapEnd();
}
@@ -13549,10 +13773,10 @@ public class Hbase {
if (struct.isSetAttributes()) {
{
oprot.writeI32(struct.attributes.size());
- for (Map.Entry<ByteBuffer, ByteBuffer> _iter65 : struct.attributes.entrySet())
+ for (Map.Entry<ByteBuffer, ByteBuffer> _iter89 : struct.attributes.entrySet())
{
- oprot.writeBinary(_iter65.getKey());
- oprot.writeBinary(_iter65.getValue());
+ oprot.writeBinary(_iter89.getKey());
+ oprot.writeBinary(_iter89.getValue());
}
}
}
@@ -13576,15 +13800,15 @@ public class Hbase {
}
if (incoming.get(3)) {
{
- org.apache.thrift.protocol.TMap _map66 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map66.size);
- for (int _i67 = 0; _i67 < _map66.size; ++_i67)
- {
- ByteBuffer _key68; // required
- ByteBuffer _val69; // optional
- _key68 = iprot.readBinary();
- _val69 = iprot.readBinary();
- struct.attributes.put(_key68, _val69);
+ org.apache.thrift.protocol.TMap _map90 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map90.size);
+ for (int _i91 = 0; _i91 < _map90.size; ++_i91)
+ {
+ ByteBuffer _key92; // required
+ ByteBuffer _val93; // required
+ _key92 = iprot.readBinary();
+ _val93 = iprot.readBinary();
+ struct.attributes.put(_key92, _val93);
}
}
struct.setAttributesIsSet(true);
@@ -13980,14 +14204,14 @@ public class Hbase {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list70 = iprot.readListBegin();
- struct.success = new ArrayList<TCell>(_list70.size);
- for (int _i71 = 0; _i71 < _list70.size; ++_i71)
+ org.apache.thrift.protocol.TList _list94 = iprot.readListBegin();
+ struct.success = new ArrayList<TCell>(_list94.size);
+ for (int _i95 = 0; _i95 < _list94.size; ++_i95)
{
- TCell _elem72; // required
- _elem72 = new TCell();
- _elem72.read(iprot);
- struct.success.add(_elem72);
+ TCell _elem96; // required
+ _elem96 = new TCell();
+ _elem96.read(iprot);
+ struct.success.add(_elem96);
}
iprot.readListEnd();
}
@@ -14024,9 +14248,9 @@ public class Hbase {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (TCell _iter73 : struct.success)
+ for (TCell _iter97 : struct.success)
{
- _iter73.write(oprot);
+ _iter97.write(oprot);
}
oprot.writeListEnd();
}
@@ -14065,9 +14289,9 @@ public class Hbase {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (TCell _iter74 : struct.success)
+ for (TCell _iter98 : struct.success)
{
- _iter74.write(oprot);
+ _iter98.write(oprot);
}
}
}
@@ -14082,14 +14306,14 @@ public class Hbase {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list75 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<TCell>(_list75.size);
- for (int _i76 = 0; _i76 < _list75.size; ++_i76)
- {
- TCell _elem77; // required
- _elem77 = new TCell();
- _elem77.read(iprot);
- struct.success.add(_elem77);
+ org.apache.thrift.protocol.TList _list99 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<TCell>(_list99.size);
+ for (int _i100 = 0; _i100 < _list99.size; ++_i100)
+ {
+ TCell _elem101; // required
+ _elem101 = new TCell();
+ _elem101.read(iprot);
+ struct.success.add(_elem101);
}
}
struct.setSuccessIsSet(true);
@@ -14848,15 +15072,15 @@ public class Hbase {
case 5: // ATTRIBUTES
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map78 = iprot.readMapBegin();
- struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map78.size);
- for (int _i79 = 0; _i79 < _map78.size; ++_i79)
+ org.apache.thrift.protocol.TMap _map102 = iprot.readMapBegin();
+ struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map102.size);
+ for (int _i103 = 0; _i103 < _map102.size; ++_i103)
{
- ByteBuffer _key80; // required
- ByteBuffer _val81; // optional
- _key80 = iprot.readBinary();
- _val81 = iprot.readBinary();
- struct.attributes.put(_key80, _val81);
+ ByteBuffer _key104; // required
+ ByteBuffer _val105; // required
+ _key104 = iprot.readBinary();
+ _val105 = iprot.readBinary();
+ struct.attributes.put(_key104, _val105);
}
iprot.readMapEnd();
}
@@ -14902,10 +15126,10 @@ public class Hbase {
oprot.writeFieldBegin(ATTRIBUTES_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.attributes.size()));
- for (Map.Entry<ByteBuffer, ByteBuffer> _iter82 : struct.attributes.entrySet())
+ for (Map.Entry<ByteBuffer, ByteBuffer> _iter106 : struct.attributes.entrySet())
{
- oprot.writeBinary(_iter82.getKey());
- oprot.writeBinary(_iter82.getValue());
+ oprot.writeBinary(_iter106.getKey());
+ oprot.writeBinary(_iter106.getValue());
}
oprot.writeMapEnd();
}
@@ -14960,10 +15184,10 @@ public class Hbase {
if (struct.isSetAttributes()) {
{
oprot.writeI32(struct.attributes.size());
- for (Map.Entry<ByteBuffer, ByteBuffer> _iter83 : struct.attributes.entrySet())
+ for (Map.Entry<ByteBuffer, ByteBuffer> _iter107 : struct.attributes.entrySet())
{
- oprot.writeBinary(_iter83.getKey());
- oprot.writeBinary(_iter83.getValue());
+ oprot.writeBinary(_iter107.getKey());
+ oprot.writeBinary(_iter107.getValue());
}
}
}
@@ -14991,15 +15215,15 @@ public class Hbase {
}
if (incoming.get(4)) {
{
- org.apache.thrift.protocol.TMap _map84 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map84.size);
- for (int _i85 = 0; _i85 < _map84.size; ++_i85)
- {
- ByteBuffer _key86; // required
- ByteBuffer _val87; // optional
- _key86 = iprot.readBinary();
- _val87 = iprot.readBinary();
- struct.attributes.put(_key86, _val87);
+ org.apache.thrift.protocol.TMap _map108 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map108.size);
+ for (int _i109 = 0; _i109 < _map108.size; ++_i109)
+ {
+ ByteBuffer _key110; // required
+ ByteBuffer _val111; // required
+ _key110 = iprot.readBinary();
+ _val111 = iprot.readBinary();
+ struct.attributes.put(_key110, _val111);
}
}
struct.setAttributesIsSet(true);
@@ -15395,14 +15619,14 @@ public class Hbase {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list88 = iprot.readListBegin();
- struct.success = new ArrayList<TCell>(_list88.size);
- for (int _i89 = 0; _i89 < _list88.size; ++_i89)
+ org.apache.thrift.protocol.TList _list112 = iprot.readListBegin();
+ struct.success = new ArrayList<TCell>(_list112.size);
+ for (int _i113 = 0; _i113 < _list112.size; ++_i113)
{
- TCell _elem90; // required
- _elem90 = new TCell();
- _elem90.read(iprot);
- struct.success.add(_elem90);
+ TCell _elem114; // required
+ _elem114 = new TCell();
+ _elem114.read(iprot);
+ struct.success.add(_elem114);
}
iprot.readListEnd();
}
@@ -15439,9 +15663,9 @@ public class Hbase {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (TCell _iter91 : struct.success)
+ for (TCell _iter115 : struct.success)
{
- _iter91.write(oprot);
+ _iter115.write(oprot);
}
oprot.writeListEnd();
}
@@ -15480,9 +15704,9 @@ public class Hbase {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (TCell _iter92 : struct.success)
+ for (TCell _iter116 : struct.success)
{
- _iter92.write(oprot);
+ _iter116.write(oprot);
}
}
}
@@ -15497,14 +15721,14 @@ public class Hbase {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list93 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<TCell>(_list93.size);
- for (int _i94 = 0; _i94 < _list93.size; ++_i94)
- {
- TCell _elem95; // required
- _elem95 = new TCell();
- _elem95.read(iprot);
- struct.success.add(_elem95);
+ org.apache.thrift.protocol.TList _list117 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<TCell>(_list117.size);
+ for (int _i118 = 0; _i118 < _list117.size; ++_i118)
+ {
+ TCell _elem119; // required
+ _elem119 = new TCell();
+ _elem119.read(iprot);
+ struct.success.add(_elem119);
}
}
struct.setSuccessIsSet(true);
@@ -16356,15 +16580,15 @@ public class Hbase {
case 6: // ATTRIBUTES
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map96 = iprot.readMapBegin();
- struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map96.size);
- for (int _i97 = 0; _i97 < _map96.size; ++_i97)
+ org.apache.thrift.protocol.TMap _map120 = iprot.readMapBegin();
+ struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map120.size);
+ for (int _i121 = 0; _i121 < _map120.size; ++_i121)
{
- ByteBuffer _key98; // required
- ByteBuffer _val99; // optional
- _key98 = iprot.readBinary();
- _val99 = iprot.readBinary();
- struct.attributes.put(_key98, _val99);
+ ByteBuffer _key122; // required
+ ByteBuffer _val123; // required
+ _key122 = iprot.readBinary();
+ _val123 = iprot.readBinary();
+ struct.attributes.put(_key122, _val123);
}
iprot.readMapEnd();
}
@@ -16413,10 +16637,10 @@ public class Hbase {
oprot.writeFieldBegin(ATTRIBUTES_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.attributes.size()));
- for (Map.Entry<ByteBuffer, ByteBuffer> _iter100 : struct.attributes.entrySet())
+ for (Map.Entry<ByteBuffer, ByteBuffer> _iter124 : struct.attributes.entrySet())
{
- oprot.writeBinary(_iter100.getKey());
- oprot.writeBinary(_iter100.getValue());
+ oprot.writeBinary(_iter124.getKey());
+ oprot.writeBinary(_iter124.getValue());
}
oprot.writeMapEnd();
}
@@ -16477,10 +16701,10 @@ public class Hbase {
if (struct.isSetAttributes()) {
{
oprot.writeI32(struct.attributes.size());
- for (Map.Entry<ByteBuffer, ByteBuffer> _iter101 : struct.attributes.entrySet())
+ for (Map.Entry<ByteBuffer, ByteBuffer> _iter125 : struct.attributes.entrySet())
{
- oprot.writeBinary(_iter101.getKey());
- oprot.writeBinary(_iter101.getValue());
+ oprot.writeBinary(_iter125.getKey());
+ oprot.writeBinary(_iter125.getValue());
}
}
}
@@ -16512,15 +16736,15 @@ public class Hbase {
}
if (incoming.get(5)) {
{
- org.apache.thrift.protocol.TMap _map102 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map102.size);
- for (int _i103 = 0; _i103 < _map102.size; ++_i103)
- {
- ByteBuffer _key104; // required
- ByteBuffer _val105; // optional
- _key104 = iprot.readBinary();
- _val105 = iprot.readBinary();
- struct.attributes.put(_key104, _val105);
+ org.apache.thrift.protocol.TMap _map126 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map126.size);
+ for (int _i127 = 0; _i127 < _map126.size; ++_i127)
+ {
+ ByteBuffer _key128; // required
+ ByteBuffer _val129; // required
+ _key128 = iprot.readBinary();
+ _val129 = iprot.readBinary();
+ struct.attributes.put(_key128, _val129);
}
}
struct.setAttributesIsSet(true);
@@ -16916,14 +17140,14 @@ public class Hbase {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list106 = iprot.readListBegin();
- struct.success = new ArrayList<TCell>(_list106.size);
- for (int _i107 = 0; _i107 < _list106.size; ++_i107)
+ org.apache.thrift.protocol.TList _list130 = iprot.readListBegin();
+ struct.success = new ArrayList<TCell>(_list130.size);
+ for (int _i131 = 0; _i131 < _list130.size; ++_i131)
{
- TCell _elem108; // required
- _elem108 = new TCell();
- _elem108.read(iprot);
- struct.success.add(_elem108);
+ TCell _elem132; // required
+ _elem132 = new TCell();
+ _elem132.read(iprot);
+ struct.success.add(_elem132);
}
iprot.readListEnd();
}
@@ -16960,9 +17184,9 @@ public class Hbase {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (TCell _iter109 : struct.success)
+ for (TCell _iter133 : struct.success)
{
- _iter109.write(oprot);
+ _iter133.write(oprot);
}
oprot.writeListEnd();
}
@@ -17001,9 +17225,9 @@ public class Hbase {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (TCell _iter110 : struct.success)
+ for (TCell _iter134 : struct.success)
{
- _iter110.write(oprot);
+ _iter134.write(oprot);
}
}
}
@@ -17018,14 +17242,14 @@ public class Hbase {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list111 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<TCell>(_list111.size);
- for (int _i112 = 0; _i112 < _list111.size; ++_i112)
- {
- TCell _elem113; // required
- _elem113 = new TCell();
- _elem113.read(iprot);
- struct.success.add(_elem113);
+ org.apache.thrift.protocol.TList _list135 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<TCell>(_list135.size);
+ for (int _i136 = 0; _i136 < _list135.size; ++_i136)
+ {
+ TCell _elem137; // required
+ _elem137 = new TCell();
+ _elem137.read(iprot);
+ struct.success.add(_elem137);
}
}
struct.setSuccessIsSet(true);
@@ -17580,15 +17804,15 @@ public class Hbase {
case 3: // ATTRIBUTES
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map114 = iprot.readMapBegin();
- struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map114.size);
- for (int _i115 = 0; _i115 < _map114.size; ++_i115)
+ org.apache.thrift.protocol.TMap _map138 = iprot.readMapBegin();
+ struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map138.size);
+ for (int _i139 = 0; _i139 < _map138.size; ++_i139)
{
- ByteBuffer _key116; // required
- ByteBuffer _val117; // optional
- _key116 = iprot.readBinary();
- _val117 = iprot.readBinary();
- struct.attributes.put(_key116, _val117);
+ ByteBuffer _key140; // required
+ ByteBuffer _val141; // required
+ _key140 = iprot.readBinary();
+ _val141 = iprot.readBinary();
+ struct.attributes.put(_key140, _val141);
}
iprot.readMapEnd();
}
@@ -17626,10 +17850,10 @@ public class Hbase {
oprot.writeFieldBegin(ATTRIBUTES_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.attributes.size()));
- for (Map.Entry<ByteBuffer, ByteBuffer> _iter118 : struct.attributes.entrySet())
+ for (Map.Entry<ByteBuffer, ByteBuffer> _iter142 : struct.attributes.entrySet())
{
- oprot.writeBinary(_iter118.getKey());
- oprot.writeBinary(_iter118.getValue());
+ oprot.writeBinary(_iter142.getKey());
+ oprot.writeBinary(_iter142.getValue());
}
oprot.writeMapEnd();
}
@@ -17672,10 +17896,10 @@ public class Hbase {
if (struct.isSetAttributes()) {
{
oprot.writeI32(struct.attributes.size());
- for (Map.Entry<ByteBuffer, ByteBuffer> _iter119 : struct.attributes.entrySet())
+ for (Map.Entry<ByteBuffer, ByteBuffer> _iter143 : struct.attributes.entrySet())
{
- oprot.writeBinary(_iter119.getKey());
- oprot.writeBinary(_iter119.getValue());
+ oprot.writeBinary(_iter143.getKey());
+ oprot.writeBinary(_iter143.getValue());
}
}
}
@@ -17695,15 +17919,15 @@ public class Hbase {
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TMap _map120 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map120.size);
- for (int _i121 = 0; _i121 < _map120.size; ++_i121)
- {
- ByteBuffer _key122; // required
- ByteBuffer _val123; // optional
- _key122 = iprot.readBinary();
- _val123 = iprot.readBinary();
- struct.attributes.put(_key122, _val123);
+ org.apache.thrift.protocol.TMap _map144 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map144.size);
+ for (int _i145 = 0; _i145 < _map144.size; ++_i145)
+ {
+ ByteBuffer _key146; // required
+ ByteBuffer _val147; // required
+ _key146 = iprot.readBinary();
+ _val147 = iprot.readBinary();
+ struct.attributes.put(_key146, _val147);
}
}
struct.setAttributesIsSet(true);
@@ -18099,14 +18323,14 @@ public class Hbase {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list124 = iprot.readListBegin();
- struct.success = new ArrayList<TRowResult>(_list124.size);
- for (int _i125 = 0; _i125 < _list124.size; ++_i125)
+ org.apache.thrift.protocol.TList _list148 = iprot.readListBegin();
+ struct.success = new ArrayList<TRowResult>(_list148.size);
+ for (int _i149 = 0; _i149 < _list148.size; ++_i149)
{
- TRowResult _elem126; // required
- _elem126 = new TRowResult();
- _elem126.read(iprot);
- struct.success.add(_elem126);
+ TRowResult _elem150; // required
+ _elem150 = new TRowResult();
+ _elem150.read(iprot);
+ struct.success.add(_elem150);
}
iprot.readListEnd();
}
@@ -18143,9 +18367,9 @@ public class Hbase {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (TRowResult _iter127 : struct.success)
+ for (TRowResult _iter151 : struct.success)
{
- _iter127.write(oprot);
+ _iter151.write(oprot);
}
oprot.writeListEnd();
}
@@ -18184,9 +18408,9 @@ public class Hbase {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (TRowResult _iter128 : struct.success)
+ for (TRowResult _iter152 : struct.success)
{
- _iter128.write(oprot);
+ _iter152.write(oprot);
}
}
}
@@ -18201,14 +18425,14 @@ public class Hbase {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list129 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<TRowResult>(_list129.size);
- for (int _i130 = 0; _i130 < _list129.size; ++_i130)
- {
- TRowResult _elem131; // required
- _elem131 = new TRowResult();
- _elem131.read(iprot);
- struct.success.add(_elem131);
+ org.apache.thrift.protocol.TList _list153 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<TRowResult>(_list153.size);
+ for (int _i154 = 0; _i154 < _list153.size; ++_i154)
+ {
+ TRowResult _elem155; // required
+ _elem155 = new TRowResult();
+ _elem155.read(iprot);
+ struct.success.add(_elem155);
}
}
struct.setSuccessIsSet(true);
@@ -18872,13 +19096,13 @@ public class Hbase {
case 3: // COLUMNS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list132 = iprot.readListBegin();
- struct.columns = new ArrayList<ByteBuffer>(_list132.size);
- for (int _i133 = 0; _i133 < _list132.size; ++_i133)
+ org.apache.thrift.protocol.TList _list156 = iprot.readListBegin();
+ struct.columns = new ArrayList<ByteBuffer>(_list156.size);
+ for (int _i157 = 0; _i157 < _list156.size; ++_i157)
{
- ByteBuffer _elem134; // required
- _elem134 = iprot.readBinary();
- struct.columns.add(_elem134);
+ ByteBuffer _elem158; // required
+ _elem158 = iprot.readBinary();
+ struct.columns.add(_elem158);
}
iprot.readListEnd();
}
@@ -18890,15 +19114,15 @@ public class Hbase {
case 4: // ATTRIBUTES
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map135 = iprot.readMapBegin();
- struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map135.size);
- for (int _i136 = 0; _i136 < _map135.size; ++_i136)
+ org.apache.thrift.protocol.TMap _map159 = iprot.readMapBegin();
+ struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map159.size);
+ for (int _i160 = 0; _i160 < _map159.size; ++_i160)
{
- ByteBuffer _key137; // required
- ByteBuffer _val138; // optional
- _key137 = iprot.readBinary();
- _val138 = iprot.readBinary();
- struct.attributes.put(_key137, _val138);
+ ByteBuffer _key161; // required
+ ByteBuffer _val162; // required
+ _key161 = iprot.readBinary();
+ _val162 = iprot.readBinary();
+ struct.attributes.put(_key161, _val162);
}
iprot.readMapEnd();
}
@@ -18936,9 +19160,9 @@ public class Hbase {
oprot.writeFieldBegin(COLUMNS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.columns.size()));
- for (ByteBuffer _iter139 : struct.columns)
+ for (ByteBuffer _iter163 : struct.columns)
{
- oprot.writeBinary(_iter139);
+ oprot.writeBinary(_iter163);
}
oprot.writeListEnd();
}
@@ -18948,10 +19172,10 @@ public class Hbase {
oprot.writeFieldBegin(ATTRIBUTES_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.attributes.size()));
- for (Map.Entry<ByteBuffer, ByteBuffer> _iter140 : struct.attributes.entrySet())
+ for (Map.Entry<ByteBuffer, ByteBuffer> _iter164 : struct.attributes.entrySet())
{
- oprot.writeBinary(_iter140.getKey());
- oprot.writeBinary(_iter140.getValue());
+ oprot.writeBinary(_iter164.getKey());
+ oprot.writeBinary(_iter164.getValue());
}
oprot.writeMapEnd();
}
@@ -18997,19 +19221,19 @@ public class Hbase {
if (struct.isSetColumns()) {
{
oprot.writeI32(struct.columns.size());
- for (ByteBuffer _iter141 : struct.columns)
+ for (ByteBuffer _iter165 : struct.columns)
{
- oprot.writeBinary(_iter141);
+ oprot.writeBinary(_iter165);
}
}
}
if (struct.isSetAttributes()) {
{
oprot.writeI32(struct.attributes.size());
- for (Map.Entry<ByteBuffer, ByteBuffer> _iter142 : struct.attributes.entrySet())
+ for (Map.Entry<ByteBuffer, ByteBuffer> _iter166 : struct.attributes.entrySet())
{
- oprot.writeBinary(_iter142.getKey());
- oprot.writeBinary(_iter142.getValue());
+ oprot.writeBinary(_iter166.getKey());
+ oprot.writeBinary(_iter166.getValue());
}
}
}
@@ -19029,28 +19253,28 @@ public class Hbase {
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list143 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.columns = new ArrayList<ByteBuffer>(_list143.size);
- for (int _i144 = 0; _i144 < _list143.size; ++_i144)
- {
- ByteBuffer _elem145; // required
- _elem145 = iprot.readBinary();
- struct.columns.add(_elem145);
+ org.apache.thrift.protocol.TList _list167 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.columns = new ArrayList<ByteBuffer>(_list167.size);
+ for (int _i168 = 0; _i168 < _list167.size; ++_i168)
+ {
+ ByteBuffer _elem169; // required
+ _elem169 = iprot.readBinary();
+ struct.columns.add(_elem169);
}
}
struct.setColumnsIsSet(true);
}
if (incoming.get(3)) {
{
- org.apache.thrift.protocol.TMap _map146 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map146.size);
- for (int _i147 = 0; _i147 < _map146.size; ++_i147)
- {
- ByteBuffer _key148; // required
- ByteBuffer _val149; // optional
- _key148 = iprot.readBinary();
- _val149 = iprot.readBinary();
- struct.attributes.put(_key148, _val149);
+ org.apache.thrift.protocol.TMap _map170 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map170.size);
+ for (int _i171 = 0; _i171 < _map170.size; ++_i171)
+ {
+ ByteBuffer _key172; // required
+ ByteBuffer _val173; // required
+ _key172 = iprot.readBinary();
+ _val173 = iprot.readBinary();
+ struct.attributes.put(_key172, _val173);
}
}
struct.setAttributesIsSet(true);
@@ -19446,14 +19670,14 @@ public class Hbase {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list150 = iprot.readListBegin();
- struct.success = new ArrayList<TRowResult>(_list150.size);
- for (int _i151 = 0; _i151 < _list150.size; ++_i151)
+ org.apache.thrift.protocol.TList _list174 = iprot.readListBegin();
+ struct.success = new ArrayList<TRowResult>(_list174.size);
+ for (int _i175 = 0; _i175 < _list174.size; ++_i175)
{
- TRowResult _elem152; // required
- _elem152 = new TRowResult();
- _elem152.read(iprot);
- struct.success.add(_elem152);
+ TRowResult _elem176; // required
+ _elem176 = new TRowResult();
+ _elem176.read(iprot);
+ struct.success.add(_elem176);
}
iprot.readListEnd();
}
@@ -19490,9 +19714,9 @@ public class Hbase {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (TRowResult _iter153 : struct.success)
+ for (TRowResult _iter177 : struct.success)
{
- _iter153.write(oprot);
+ _iter177.write(oprot);
}
oprot.writeListEnd();
}
@@ -19531,9 +19755,9 @@ public class Hbase {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (TRowResult _iter154 : struct.success)
+ for (TRowResult _iter178 : struct.success)
{
- _iter154.write(oprot);
+ _iter178.write(oprot);
}
}
}
@@ -19548,14 +19772,14 @@ public class Hbase {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list155 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<TRowResult>(_list155.size);
- for (int _i156 = 0; _i156 < _list155.size; ++_i156)
- {
- TRowResult _elem157; // required
- _elem157 = new TRowResult();
- _elem157.read(iprot);
- struct.success.add(_elem157);
+ org.apache.thrift.protocol.TList _list179 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<TRowResult>(_list179.size);
+ for (int _i180 = 0; _i180 < _list179.size; ++_i180)
+ {
+ TRowResult _elem181; // required
+ _elem181 = new TRowResult();
+ _elem181.read(iprot);
+ struct.success.add(_elem181);
}
}
struct.setSuccessIsSet(true);
@@ -20207,15 +20431,15 @@ public class Hbase {
case 4: // ATTRIBUTES
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map158 = iprot.readMapBegin();
- struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map158.size);
- for (int _i159 = 0; _i159 < _map158.size; ++_i159)
+ org.apache.thrift.protocol.TMap _map182 = iprot.readMapBegin();
+ struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map182.size);
+ for (int _i183 = 0; _i183 < _map182.size; ++_i183)
{
- ByteBuffer _key160; // required
- ByteBuffer _val161; // optional
- _key160 = iprot.readBinary();
- _val161 = iprot.readBinary();
- struct.attributes.put(_key160, _val161);
+ ByteBuffer _key184; // required
+ ByteBuffer _val185; // required
+ _key184 = iprot.readBinary();
+ _val185 = iprot.readBinary();
+ struct.attributes.put(_key184, _val185);
}
iprot.readMapEnd();
}
@@ -20256,10 +20480,10 @@ public class Hbase {
oprot.writeFieldBegin(ATTRIBUTES_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.attributes.size()));
- for (Map.Entry<ByteBuffer, ByteBuffer> _iter162 : struct.attributes.entrySet())
+ for (Map.Entry<ByteBuffer, ByteBuffer> _iter186 : struct.attributes.entrySet())
{
- oprot.writeBinary(_iter162.getKey());
- oprot.writeBinary(_iter162.getValue());
+ oprot.writeBinary(_iter186.getKey());
+ oprot.writeBinary(_iter186.getValue());
}
oprot.writeMapEnd();
}
@@ -20308,10 +20532,10 @@ public class Hbase {
if (struct.isSetAttributes()) {
{
oprot.writeI32(struct.attributes.size());
- for (Map.Entry<ByteBuffer, ByteBuffer> _iter163 : struct.attributes.entrySet())
+ for (Map.Entry<ByteBuffer, ByteBuffer> _iter187 : struct.attributes.entrySet())
{
- oprot.writeBinary(_iter163.getKey());
- oprot.writeBinary(_iter163.getValue());
+ oprot.writeBinary(_iter187.getKey());
+ oprot.writeBinary(_iter187.getValue());
}
}
}
@@ -20335,15 +20559,15 @@ public class Hbase {
}
if (incoming.get(3)) {
{
- org.apache.thrift.protocol.TMap _map164 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map164.size);
- for (int _i165 = 0; _i165 < _map164.size; ++_i165)
- {
- ByteBuffer _key166; // required
- ByteBuffer _val167; // optional
- _key166 = iprot.readBinary();
- _val167 = iprot.readBinary();
- struct.attributes.put(_key166, _val167);
+ org.apache.thrift.protocol.TMap _map188 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map188.size);
+ for (int _i189 = 0; _i189 < _map188.size; ++_i189)
+ {
+ ByteBuffer _key190; // required
+ ByteBuffer _val191; // required
+ _key190 = iprot.readBinary();
+ _val191 = iprot.readBinary();
+ struct.attributes.put(_key190, _val191);
}
}
struct.setAttributesIsSet(true);
@@ -20739,14 +20963,14 @@ public class Hbase {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list168 = iprot.readListBegin();
- struct.success = new ArrayList<TRowResult>(_list168.size);
- for (int _i169 = 0; _i169 < _list168.size; ++_i169)
+ org.apache.thrift.protocol.TList _list192 = iprot.readListBegin();
+ struct.success = new ArrayList<TRowResult>(_list192.size);
+ for (int _i193 = 0; _i193 < _list192.size; ++_i193)
{
- TRowResult _elem170; // required
- _elem170 = new TRowResult();
- _elem170.read(iprot);
- struct.success.add(_elem170);
+ TRowResult _elem194; // required
+ _elem194 = new TRowResult();
+ _elem194.read(iprot);
+ struct.success.add(_elem194);
}
iprot.readListEnd();
}
@@ -20783,9 +21007,9 @@ public class Hbase {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (TRowResult _iter171 : struct.success)
+ for (TRowResult _iter195 : struct.success)
{
- _iter171.write(oprot);
+ _iter195.write(oprot);
}
oprot.writeListEnd();
}
@@ -20824,9 +21048,9 @@ public class Hbase {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (TRowResult _iter172 : struct.success)
+ for (TRowResult _iter196 : struct.success)
{
- _iter172.write(oprot);
+ _iter196.write(oprot);
}
}
}
@@ -20841,14 +21065,14 @@ public class Hbase {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list173 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<TRowResult>(_list173.size);
- for (int _i174 = 0; _i174 < _list173.size; ++_i174)
- {
- TRowResult _elem175; // required
- _elem175 = new TRowResult();
- _elem175.read(iprot);
- struct.success.add(_elem175);
+ org.apache.thrift.protocol.TList _list197 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<TRowResult>(_list197.size);
+ for (int _i198 = 0; _i198 < _list197.size; ++_i198)
+ {
+ TRowResult _elem199; // required
+ _elem199 = new TRowResult();
+ _elem199.read(iprot);
+ struct.success.add(_elem199);
}
}
struct.setSuccessIsSet(true);
@@ -21589,13 +21813,13 @@ public class Hbase {
case 3: // COLUMNS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list176 = iprot.readListBegin();
- struct.columns = new ArrayList<ByteBuffer>(_list176.size);
- for (int _i177 = 0; _i177 < _list176.size; ++_i177)
+ org.apache.thrift.protocol.TList _list200 = iprot.readListBegin();
+ struct.columns = new ArrayList<ByteBuffer>(_list200.size);
+ for (int _i201 = 0; _i201 < _list200.size; ++_i201)
{
- ByteBuffer _elem178; // required
- _elem178 = iprot.readBinary();
- struct.columns.add(_elem178);
+ ByteBuffer _elem202; // required
+ _elem202 = iprot.readBinary();
+ struct.columns.add(_elem202);
}
iprot.readListEnd();
}
@@ -21615,15 +21839,15 @@ public class Hbase {
case 5: // ATTRIBUTES
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map179 = iprot.readMapBegin();
- struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map179.size);
- for (int _i180 = 0; _i180 < _map179.size; ++_i180)
+ org.apache.thrift.protocol.TMap _map203 = iprot.readMapBegin();
+ struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map203.size);
+ for (int _i204 = 0; _i204 < _map203.size; ++_i204)
{
- ByteBuffer _key181; // required
- ByteBuffer _val182; // optional
- _key181 = iprot.readBinary();
- _val182 = iprot.readBinary();
- struct.attributes.put(_key181, _val182);
+ ByteBuffer _key205; // required
+ ByteBuffer _val206; // required
+ _key205 = iprot.readBinary();
+ _val206 = iprot.readBinary();
+ struct.attributes.put(_key205, _val206);
}
iprot.readMapEnd();
}
@@ -21661,9 +21885,9 @@ public class Hbase {
oprot.writeFieldBegin(COLUMNS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.columns.size()));
- for (ByteBuffer _iter183 : struct.columns)
+ for (ByteBuffer _iter207 : struct.columns)
{
- oprot.writeBinary(_iter183);
+ oprot.writeBinary(_iter207);
}
oprot.writeListEnd();
}
@@ -21676,10 +21900,10 @@ public class Hbase {
oprot.writeFieldBegin(ATTRIBUTES_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.attributes.size()));
- for (Map.Entry<ByteBuffer, ByteBuffer> _iter184 : struct.attributes.entrySet())
+ for (Map.Entry<ByteBuffer, ByteBuffer> _iter208 : struct.attributes.entrySet())
{
- oprot.writeBinary(_iter184.getKey());
- oprot.writeBinary(_iter184.getValue());
+ oprot.writeBinary(_iter208.getKey());
+ oprot.writeBinary(_iter208.getValue());
}
oprot.writeMapEnd();
}
@@ -21728,9 +21952,9 @@ public class Hbase {
if (struct.isSetColumns()) {
{
oprot.writeI32(struct.columns.size());
- for (ByteBuffer _iter185 : struct.columns)
+ for (ByteBuffer _iter209 : struct.columns)
{
- oprot.writeBinary(_iter185);
+ oprot.writeBinary(_iter209);
}
}
}
@@ -21740,10 +21964,10 @@ public class Hbase {
if (struct.isSetAttributes()) {
{
oprot.writeI32(struct.attributes.size());
- for (Map.Entry<ByteBuffer, ByteBuffer> _iter186 : struct.attributes.entrySet())
+ for (Map.Entry<ByteBuffer, ByteBuffer> _iter210 : struct.attributes.entrySet())
{
- oprot.writeBinary(_iter186.getKey());
- oprot.writeBinary(_iter186.getValue());
+ oprot.writeBinary(_iter210.getKey());
+ oprot.writeBinary(_iter210.getValue());
}
}
}
@@ -21763,13 +21987,13 @@ public class Hbase {
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list187 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.columns = new ArrayList<ByteBuffer>(_list187.size);
- for (int _i188 = 0; _i188 < _list187.size; ++_i188)
- {
- ByteBuffer _elem189; // required
- _elem189 = iprot.readBinary();
- struct.columns.add(_elem189);
+ org.apache.thrift.protocol.TList _list211 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.columns = new ArrayList<ByteBuffer>(_list211.size);
+ for (int _i212 = 0; _i212 < _list211.size; ++_i212)
+ {
+ ByteBuffer _elem213; // required
+ _elem213 = iprot.readBinary();
+ struct.columns.add(_elem213);
}
}
struct.setColumnsIsSet(true);
@@ -21780,15 +22004,15 @@ public class Hbase {
}
if (incoming.get(4)) {
{
- org.apache.thrift.protocol.TMap _map190 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map190.size);
- for (int _i191 = 0; _i191 < _map190.size; ++_i191)
- {
- ByteBuffer _key192; // required
- ByteBuffer _val193; // optional
- _key192 = iprot.readBinary();
- _val193 = iprot.readBinary();
- struct.attributes.put(_key192, _val193);
+ org.apache.thrift.protocol.TMap _map214 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map214.size);
+ for (int _i215 = 0; _i215 < _map214.size; ++_i215)
+ {
+ ByteBuffer _key216; // required
+ ByteBuffer _val217; // required
+ _key216 = iprot.readBinary();
+ _val217 = iprot.readBinary();
+ struct.attributes.put(_key216, _val217);
}
}
struct.setAttributesIsSet(true);
@@ -22184,14 +22408,14 @@ public class Hbase {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list194 = iprot.readListBegin();
- struct.success = new ArrayList<TRowResult>(_list194.size);
- for (int _i195 = 0; _i195 < _list194.size; ++_i195)
+ org.apache.thrift.protocol.TList _list218 = iprot.readListBegin();
+ struct.success = new ArrayList<TRowResult>(_list218.size);
+ for (int _i219 = 0; _i219 < _list218.size; ++_i219)
{
- TRowResult _elem196; // required
- _elem196 = new TRowResult();
- _elem196.read(iprot);
- struct.success.add(_elem196);
+ TRowResult _elem220; // required
+ _elem220 = new TRowResult();
+ _elem220.read(iprot);
+ struct.success.add(_elem220);
}
iprot.readListEnd();
}
@@ -22228,9 +22452,9 @@ public class Hbase {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (TRowResult _iter197 : struct.success)
+ for (TRowResult _iter221 : struct.success)
{
- _iter197.write(oprot);
+ _iter221.write(oprot);
}
oprot.writeListEnd();
}
@@ -22269,9 +22493,9 @@ public class Hbase {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (TRowResult _iter198 : struct.success)
+ for (TRowResult _iter222 : struct.success)
{
- _iter198.write(oprot);
+ _iter222.write(oprot);
}
}
}
@@ -22286,14 +22510,14 @@ public class Hbase {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list199 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<TRowResult>(_list199.size);
- for (int _i200 = 0; _i200 < _list199.size; ++_i200)
- {
- TRowResult _elem201; // required
- _elem201 = new TRowResult();
- _elem201.read(iprot);
- struct.success.add(_elem201);
+ org.apache.thrift.protocol.TList _list223 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<TRowResult>(_list223.size);
+ for (int _i224 = 0; _i224 < _list223.size; ++_i224)
+ {
+ TRowResult _elem225; // required
+ _elem225 = new TRowResult();
+ _elem225.read(iprot);
+ struct.success.add(_elem225);
}
}
struct.setSuccessIsSet(true);
@@ -22850,13 +23074,13 @@ public class Hbase {
case 2: // ROWS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list202 = iprot.readListBegin();
- struct.rows = new ArrayList<ByteBuffer>(_list202.size);
- for (int _i203 = 0; _i203 < _list202.size; ++_i203)
+ org.apache.thrift.protocol.TList _list226 = iprot.readListBegin();
+ struct.rows = new ArrayList<ByteBuffer>(_list226.size);
+ for (int _i227 = 0; _i227 < _list226.size; ++_i227)
{
- ByteBuffer _elem204; // required
- _elem204 = iprot.readBinary();
- struct.rows.add(_elem204);
+ ByteBuffer _elem228; // required
+ _elem228 = iprot.readBinary();
+ struct.rows.add(_elem228);
}
iprot.readListEnd();
}
@@ -22868,15 +23092,15 @@ public class Hbase {
case 3: // ATTRIBUTES
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map205 = iprot.readMapBegin();
- struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map205.size);
- for (int _i206 = 0; _i206 < _map205.size; ++_i206)
+ org.apache.thrift.protocol.TMap _map229 = iprot.readMapBegin();
+ struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map229.size);
+ for (int _i230 = 0; _i230 < _map229.size; ++_i230)
{
- ByteBuffer _key207; // required
- ByteBuffer _val208; // optional
- _key207 = iprot.readBinary();
- _val208 = iprot.readBinary();
- struct.attributes.put(_key207, _val208);
+ ByteBuffer _key231; // required
+ ByteBuffer _val232; // required
+ _key231 = iprot.readBinary();
+ _val232 = iprot.readBinary();
+ struct.attributes.put(_key231, _val232);
}
iprot.readMapEnd();
}
@@ -22909,9 +23133,9 @@ public class Hbase {
oprot.writeFieldBegin(ROWS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.rows.size()));
- for (ByteBuffer _iter209 : struct.rows)
+ for (ByteBuffer _iter233 : struct.rows)
{
- oprot.writeBinary(_iter209);
+ oprot.writeBinary(_iter233);
}
oprot.writeListEnd();
}
@@ -22921,10 +23145,10 @@ public class Hbase {
oprot.writeFieldBegin(ATTRIBUTES_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.attributes.size()));
- for (Map.Entry<ByteBuffer, ByteBuffer> _iter210 : struct.attributes.entrySet())
+ for (Map.Entry<ByteBuffer, ByteBuffer> _iter234 : struct.attributes.entrySet())
{
- oprot.writeBinary(_iter210.getKey());
- oprot.writeBinary(_iter210.getValue());
+ oprot.writeBinary(_iter234.getKey());
+ oprot.writeBinary(_iter234.getValue());
}
oprot.writeMapEnd();
}
@@ -22964,19 +23188,19 @@ public class Hbase {
if (struct.isSetRows()) {
{
oprot.writeI32(struct.rows.size());
- for (ByteBuffer _iter211 : struct.rows)
+ for (ByteBuffer _iter235 : struct.rows)
{
- oprot.writeBinary(_iter211);
+ oprot.writeBinary(_iter235);
}
}
}
if (struct.isSetAttributes()) {
{
oprot.writeI32(struct.attributes.size());
- for (Map.Entry<ByteBuffer, ByteBuffer> _iter212 : struct.attributes.entrySet())
+ for (Map.Entry<ByteBuffer, ByteBuffer> _iter236 : struct.attributes.entrySet())
{
- oprot.writeBinary(_iter212.getKey());
- oprot.writeBinary(_iter212.getValue());
+ oprot.writeBinary(_iter236.getKey());
+ oprot.writeBinary(_iter236.getValue());
}
}
}
@@ -22992,28 +23216,28 @@ public class Hbase {
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list213 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.rows = new ArrayList<ByteBuffer>(_list213.size);
- for (int _i214 = 0; _i214 < _list213.size; ++_i214)
- {
- ByteBuffer _elem215; // required
- _elem215 = iprot.readBinary();
- struct.rows.add(_elem215);
+ org.apache.thrift.protocol.TList _list237 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.rows = new ArrayList<ByteBuffer>(_list237.size);
+ for (int _i238 = 0; _i238 < _list237.size; ++_i238)
+ {
+ ByteBuffer _elem239; // required
+ _elem239 = iprot.readBinary();
+ struct.rows.add(_elem239);
}
}
struct.setRowsIsSet(true);
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TMap _map216 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map216.size);
- for (int _i217 = 0; _i217 < _map216.size; ++_i217)
- {
- ByteBuffer _key218; // required
- ByteBuffer _val219; // optional
- _key218 = iprot.readBinary();
- _val219 = iprot.readBinary();
- struct.attributes.put(_key218, _val219);
+ org.apache.thrift.protocol.TMap _map240 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.attributes = new HashMap<ByteBuffer,ByteBuffer>(2*_map240.size);
+ for (int _i241 = 0; _i241 < _map240.size; ++_i241)
+ {
+ ByteBuffer _key242; // required
+ ByteBuffer _val243; // required
+ _key242 = iprot.readBinary();
+ _val243 = iprot.readBinary();
+ struct.attributes.put(_key242, _val243);
}
[... 5252 lines stripped ...]