You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by sa...@apache.org on 2018/02/23 16:31:06 UTC
[08/21] hive git commit: HIVE-18192: Introduce WriteID per table
rather than using global transaction ID (Sankar Hariappan,
reviewed by Eugene Koifman)
http://git-wip-us.apache.org/repos/asf/hive/blob/cbb9233a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
index 05064cb..adddd07 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
@@ -328,6 +328,10 @@ import org.slf4j.LoggerFactory;
public void commit_txn(CommitTxnRequest rqst) throws NoSuchTxnException, TxnAbortedException, org.apache.thrift.TException;
+ public GetValidWriteIdsResponse get_valid_write_ids(GetValidWriteIdsRequest rqst) throws NoSuchTxnException, MetaException, org.apache.thrift.TException;
+
+ public AllocateTableWriteIdsResponse allocate_table_write_ids(AllocateTableWriteIdsRequest rqst) throws NoSuchTxnException, TxnAbortedException, MetaException, org.apache.thrift.TException;
+
public LockResponse lock(LockRequest rqst) throws NoSuchTxnException, TxnAbortedException, org.apache.thrift.TException;
public LockResponse check_lock(CheckLockRequest rqst) throws NoSuchTxnException, TxnAbortedException, NoSuchLockException, org.apache.thrift.TException;
@@ -696,6 +700,10 @@ import org.slf4j.LoggerFactory;
public void commit_txn(CommitTxnRequest rqst, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void get_valid_write_ids(GetValidWriteIdsRequest rqst, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void allocate_table_write_ids(AllocateTableWriteIdsRequest rqst, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
public void lock(LockRequest rqst, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void check_lock(CheckLockRequest rqst, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
@@ -5001,6 +5009,67 @@ import org.slf4j.LoggerFactory;
return;
}
+ public GetValidWriteIdsResponse get_valid_write_ids(GetValidWriteIdsRequest rqst) throws NoSuchTxnException, MetaException, org.apache.thrift.TException
+ {
+ send_get_valid_write_ids(rqst);
+ return recv_get_valid_write_ids();
+ }
+
+ public void send_get_valid_write_ids(GetValidWriteIdsRequest rqst) throws org.apache.thrift.TException
+ {
+ get_valid_write_ids_args args = new get_valid_write_ids_args();
+ args.setRqst(rqst);
+ sendBase("get_valid_write_ids", args);
+ }
+
+ public GetValidWriteIdsResponse recv_get_valid_write_ids() throws NoSuchTxnException, MetaException, org.apache.thrift.TException
+ {
+ get_valid_write_ids_result result = new get_valid_write_ids_result();
+ receiveBase(result, "get_valid_write_ids");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.o1 != null) {
+ throw result.o1;
+ }
+ if (result.o2 != null) {
+ throw result.o2;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "get_valid_write_ids failed: unknown result");
+ }
+
+ public AllocateTableWriteIdsResponse allocate_table_write_ids(AllocateTableWriteIdsRequest rqst) throws NoSuchTxnException, TxnAbortedException, MetaException, org.apache.thrift.TException
+ {
+ send_allocate_table_write_ids(rqst);
+ return recv_allocate_table_write_ids();
+ }
+
+ public void send_allocate_table_write_ids(AllocateTableWriteIdsRequest rqst) throws org.apache.thrift.TException
+ {
+ allocate_table_write_ids_args args = new allocate_table_write_ids_args();
+ args.setRqst(rqst);
+ sendBase("allocate_table_write_ids", args);
+ }
+
+ public AllocateTableWriteIdsResponse recv_allocate_table_write_ids() throws NoSuchTxnException, TxnAbortedException, MetaException, org.apache.thrift.TException
+ {
+ allocate_table_write_ids_result result = new allocate_table_write_ids_result();
+ receiveBase(result, "allocate_table_write_ids");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.o1 != null) {
+ throw result.o1;
+ }
+ if (result.o2 != null) {
+ throw result.o2;
+ }
+ if (result.o3 != null) {
+ throw result.o3;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "allocate_table_write_ids failed: unknown result");
+ }
+
public LockResponse lock(LockRequest rqst) throws NoSuchTxnException, TxnAbortedException, org.apache.thrift.TException
{
send_lock(rqst);
@@ -11179,6 +11248,70 @@ import org.slf4j.LoggerFactory;
}
}
+ public void get_valid_write_ids(GetValidWriteIdsRequest rqst, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ get_valid_write_ids_call method_call = new get_valid_write_ids_call(rqst, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class get_valid_write_ids_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private GetValidWriteIdsRequest rqst;
+ public get_valid_write_ids_call(GetValidWriteIdsRequest rqst, org.apache.thrift.async.AsyncMethodCallback 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.rqst = rqst;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("get_valid_write_ids", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ get_valid_write_ids_args args = new get_valid_write_ids_args();
+ args.setRqst(rqst);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public GetValidWriteIdsResponse getResult() throws NoSuchTxnException, MetaException, 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_get_valid_write_ids();
+ }
+ }
+
+ public void allocate_table_write_ids(AllocateTableWriteIdsRequest rqst, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ allocate_table_write_ids_call method_call = new allocate_table_write_ids_call(rqst, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class allocate_table_write_ids_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private AllocateTableWriteIdsRequest rqst;
+ public allocate_table_write_ids_call(AllocateTableWriteIdsRequest rqst, org.apache.thrift.async.AsyncMethodCallback 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.rqst = rqst;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("allocate_table_write_ids", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ allocate_table_write_ids_args args = new allocate_table_write_ids_args();
+ args.setRqst(rqst);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public AllocateTableWriteIdsResponse getResult() throws NoSuchTxnException, TxnAbortedException, MetaException, 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_allocate_table_write_ids();
+ }
+ }
+
public void lock(LockRequest rqst, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
lock_call method_call = new lock_call(rqst, resultHandler, this, ___protocolFactory, ___transport);
@@ -12574,6 +12707,8 @@ import org.slf4j.LoggerFactory;
processMap.put("abort_txn", new abort_txn());
processMap.put("abort_txns", new abort_txns());
processMap.put("commit_txn", new commit_txn());
+ processMap.put("get_valid_write_ids", new get_valid_write_ids());
+ processMap.put("allocate_table_write_ids", new allocate_table_write_ids());
processMap.put("lock", new lock());
processMap.put("check_lock", new check_lock());
processMap.put("unlock", new unlock());
@@ -16334,6 +16469,60 @@ import org.slf4j.LoggerFactory;
}
}
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class get_valid_write_ids<I extends Iface> extends org.apache.thrift.ProcessFunction<I, get_valid_write_ids_args> {
+ public get_valid_write_ids() {
+ super("get_valid_write_ids");
+ }
+
+ public get_valid_write_ids_args getEmptyArgsInstance() {
+ return new get_valid_write_ids_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public get_valid_write_ids_result getResult(I iface, get_valid_write_ids_args args) throws org.apache.thrift.TException {
+ get_valid_write_ids_result result = new get_valid_write_ids_result();
+ try {
+ result.success = iface.get_valid_write_ids(args.rqst);
+ } catch (NoSuchTxnException o1) {
+ result.o1 = o1;
+ } catch (MetaException o2) {
+ result.o2 = o2;
+ }
+ return result;
+ }
+ }
+
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class allocate_table_write_ids<I extends Iface> extends org.apache.thrift.ProcessFunction<I, allocate_table_write_ids_args> {
+ public allocate_table_write_ids() {
+ super("allocate_table_write_ids");
+ }
+
+ public allocate_table_write_ids_args getEmptyArgsInstance() {
+ return new allocate_table_write_ids_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public allocate_table_write_ids_result getResult(I iface, allocate_table_write_ids_args args) throws org.apache.thrift.TException {
+ allocate_table_write_ids_result result = new allocate_table_write_ids_result();
+ try {
+ result.success = iface.allocate_table_write_ids(args.rqst);
+ } catch (NoSuchTxnException o1) {
+ result.o1 = o1;
+ } catch (TxnAbortedException o2) {
+ result.o2 = o2;
+ } catch (MetaException o3) {
+ result.o3 = o3;
+ }
+ return result;
+ }
+ }
+
@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class lock<I extends Iface> extends org.apache.thrift.ProcessFunction<I, lock_args> {
public lock() {
super("lock");
@@ -17444,6 +17633,8 @@ import org.slf4j.LoggerFactory;
processMap.put("abort_txn", new abort_txn());
processMap.put("abort_txns", new abort_txns());
processMap.put("commit_txn", new commit_txn());
+ processMap.put("get_valid_write_ids", new get_valid_write_ids());
+ processMap.put("allocate_table_write_ids", new allocate_table_write_ids());
processMap.put("lock", new lock());
processMap.put("check_lock", new check_lock());
processMap.put("unlock", new unlock());
@@ -26316,6 +26507,135 @@ import org.slf4j.LoggerFactory;
}
}
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class get_valid_write_ids<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_valid_write_ids_args, GetValidWriteIdsResponse> {
+ public get_valid_write_ids() {
+ super("get_valid_write_ids");
+ }
+
+ public get_valid_write_ids_args getEmptyArgsInstance() {
+ return new get_valid_write_ids_args();
+ }
+
+ public AsyncMethodCallback<GetValidWriteIdsResponse> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.thrift.AsyncProcessFunction fcall = this;
+ return new AsyncMethodCallback<GetValidWriteIdsResponse>() {
+ public void onComplete(GetValidWriteIdsResponse o) {
+ get_valid_write_ids_result result = new get_valid_write_ids_result();
+ result.success = o;
+ try {
+ fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
+ return;
+ } catch (Exception e) {
+ LOGGER.error("Exception writing to internal frame buffer", e);
+ }
+ fb.close();
+ }
+ public void onError(Exception e) {
+ byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
+ org.apache.thrift.TBase msg;
+ get_valid_write_ids_result result = new get_valid_write_ids_result();
+ if (e instanceof NoSuchTxnException) {
+ result.o1 = (NoSuchTxnException) e;
+ result.setO1IsSet(true);
+ msg = result;
+ }
+ else if (e instanceof MetaException) {
+ result.o2 = (MetaException) e;
+ result.setO2IsSet(true);
+ msg = result;
+ }
+ else
+ {
+ msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
+ msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
+ }
+ try {
+ fcall.sendResponse(fb,msg,msgType,seqid);
+ return;
+ } catch (Exception ex) {
+ LOGGER.error("Exception writing to internal frame buffer", ex);
+ }
+ fb.close();
+ }
+ };
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public void start(I iface, get_valid_write_ids_args args, org.apache.thrift.async.AsyncMethodCallback<GetValidWriteIdsResponse> resultHandler) throws TException {
+ iface.get_valid_write_ids(args.rqst,resultHandler);
+ }
+ }
+
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class allocate_table_write_ids<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, allocate_table_write_ids_args, AllocateTableWriteIdsResponse> {
+ public allocate_table_write_ids() {
+ super("allocate_table_write_ids");
+ }
+
+ public allocate_table_write_ids_args getEmptyArgsInstance() {
+ return new allocate_table_write_ids_args();
+ }
+
+ public AsyncMethodCallback<AllocateTableWriteIdsResponse> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.thrift.AsyncProcessFunction fcall = this;
+ return new AsyncMethodCallback<AllocateTableWriteIdsResponse>() {
+ public void onComplete(AllocateTableWriteIdsResponse o) {
+ allocate_table_write_ids_result result = new allocate_table_write_ids_result();
+ result.success = o;
+ try {
+ fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
+ return;
+ } catch (Exception e) {
+ LOGGER.error("Exception writing to internal frame buffer", e);
+ }
+ fb.close();
+ }
+ public void onError(Exception e) {
+ byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
+ org.apache.thrift.TBase msg;
+ allocate_table_write_ids_result result = new allocate_table_write_ids_result();
+ if (e instanceof NoSuchTxnException) {
+ result.o1 = (NoSuchTxnException) e;
+ result.setO1IsSet(true);
+ msg = result;
+ }
+ else if (e instanceof TxnAbortedException) {
+ result.o2 = (TxnAbortedException) e;
+ result.setO2IsSet(true);
+ msg = result;
+ }
+ else if (e instanceof MetaException) {
+ result.o3 = (MetaException) e;
+ result.setO3IsSet(true);
+ msg = result;
+ }
+ else
+ {
+ msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
+ msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
+ }
+ try {
+ fcall.sendResponse(fb,msg,msgType,seqid);
+ return;
+ } catch (Exception ex) {
+ LOGGER.error("Exception writing to internal frame buffer", ex);
+ }
+ fb.close();
+ }
+ };
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public void start(I iface, allocate_table_write_ids_args args, org.apache.thrift.async.AsyncMethodCallback<AllocateTableWriteIdsResponse> resultHandler) throws TException {
+ iface.allocate_table_write_ids(args.rqst,resultHandler);
+ }
+ }
+
@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class lock<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, lock_args, LockResponse> {
public lock() {
super("lock");
@@ -34034,13 +34354,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list818 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list818.size);
- String _elem819;
- for (int _i820 = 0; _i820 < _list818.size; ++_i820)
+ org.apache.thrift.protocol.TList _list858 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list858.size);
+ String _elem859;
+ for (int _i860 = 0; _i860 < _list858.size; ++_i860)
{
- _elem819 = iprot.readString();
- struct.success.add(_elem819);
+ _elem859 = iprot.readString();
+ struct.success.add(_elem859);
}
iprot.readListEnd();
}
@@ -34075,9 +34395,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
- for (String _iter821 : struct.success)
+ for (String _iter861 : struct.success)
{
- oprot.writeString(_iter821);
+ oprot.writeString(_iter861);
}
oprot.writeListEnd();
}
@@ -34116,9 +34436,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter822 : struct.success)
+ for (String _iter862 : struct.success)
{
- oprot.writeString(_iter822);
+ oprot.writeString(_iter862);
}
}
}
@@ -34133,13 +34453,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list823 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list823.size);
- String _elem824;
- for (int _i825 = 0; _i825 < _list823.size; ++_i825)
+ org.apache.thrift.protocol.TList _list863 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list863.size);
+ String _elem864;
+ for (int _i865 = 0; _i865 < _list863.size; ++_i865)
{
- _elem824 = iprot.readString();
- struct.success.add(_elem824);
+ _elem864 = iprot.readString();
+ struct.success.add(_elem864);
}
}
struct.setSuccessIsSet(true);
@@ -34793,13 +35113,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list826 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list826.size);
- String _elem827;
- for (int _i828 = 0; _i828 < _list826.size; ++_i828)
+ org.apache.thrift.protocol.TList _list866 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list866.size);
+ String _elem867;
+ for (int _i868 = 0; _i868 < _list866.size; ++_i868)
{
- _elem827 = iprot.readString();
- struct.success.add(_elem827);
+ _elem867 = iprot.readString();
+ struct.success.add(_elem867);
}
iprot.readListEnd();
}
@@ -34834,9 +35154,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
- for (String _iter829 : struct.success)
+ for (String _iter869 : struct.success)
{
- oprot.writeString(_iter829);
+ oprot.writeString(_iter869);
}
oprot.writeListEnd();
}
@@ -34875,9 +35195,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter830 : struct.success)
+ for (String _iter870 : struct.success)
{
- oprot.writeString(_iter830);
+ oprot.writeString(_iter870);
}
}
}
@@ -34892,13 +35212,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list831 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list831.size);
- String _elem832;
- for (int _i833 = 0; _i833 < _list831.size; ++_i833)
+ org.apache.thrift.protocol.TList _list871 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list871.size);
+ String _elem872;
+ for (int _i873 = 0; _i873 < _list871.size; ++_i873)
{
- _elem832 = iprot.readString();
- struct.success.add(_elem832);
+ _elem872 = iprot.readString();
+ struct.success.add(_elem872);
}
}
struct.setSuccessIsSet(true);
@@ -39505,16 +39825,16 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map834 = iprot.readMapBegin();
- struct.success = new HashMap<String,Type>(2*_map834.size);
- String _key835;
- Type _val836;
- for (int _i837 = 0; _i837 < _map834.size; ++_i837)
+ org.apache.thrift.protocol.TMap _map874 = iprot.readMapBegin();
+ struct.success = new HashMap<String,Type>(2*_map874.size);
+ String _key875;
+ Type _val876;
+ for (int _i877 = 0; _i877 < _map874.size; ++_i877)
{
- _key835 = iprot.readString();
- _val836 = new Type();
- _val836.read(iprot);
- struct.success.put(_key835, _val836);
+ _key875 = iprot.readString();
+ _val876 = new Type();
+ _val876.read(iprot);
+ struct.success.put(_key875, _val876);
}
iprot.readMapEnd();
}
@@ -39549,10 +39869,10 @@ import org.slf4j.LoggerFactory;
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<String, Type> _iter838 : struct.success.entrySet())
+ for (Map.Entry<String, Type> _iter878 : struct.success.entrySet())
{
- oprot.writeString(_iter838.getKey());
- _iter838.getValue().write(oprot);
+ oprot.writeString(_iter878.getKey());
+ _iter878.getValue().write(oprot);
}
oprot.writeMapEnd();
}
@@ -39591,10 +39911,10 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Map.Entry<String, Type> _iter839 : struct.success.entrySet())
+ for (Map.Entry<String, Type> _iter879 : struct.success.entrySet())
{
- oprot.writeString(_iter839.getKey());
- _iter839.getValue().write(oprot);
+ oprot.writeString(_iter879.getKey());
+ _iter879.getValue().write(oprot);
}
}
}
@@ -39609,16 +39929,16 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TMap _map840 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new HashMap<String,Type>(2*_map840.size);
- String _key841;
- Type _val842;
- for (int _i843 = 0; _i843 < _map840.size; ++_i843)
+ org.apache.thrift.protocol.TMap _map880 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new HashMap<String,Type>(2*_map880.size);
+ String _key881;
+ Type _val882;
+ for (int _i883 = 0; _i883 < _map880.size; ++_i883)
{
- _key841 = iprot.readString();
- _val842 = new Type();
- _val842.read(iprot);
- struct.success.put(_key841, _val842);
+ _key881 = iprot.readString();
+ _val882 = new Type();
+ _val882.read(iprot);
+ struct.success.put(_key881, _val882);
}
}
struct.setSuccessIsSet(true);
@@ -40653,14 +40973,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list844 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list844.size);
- FieldSchema _elem845;
- for (int _i846 = 0; _i846 < _list844.size; ++_i846)
+ org.apache.thrift.protocol.TList _list884 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list884.size);
+ FieldSchema _elem885;
+ for (int _i886 = 0; _i886 < _list884.size; ++_i886)
{
- _elem845 = new FieldSchema();
- _elem845.read(iprot);
- struct.success.add(_elem845);
+ _elem885 = new FieldSchema();
+ _elem885.read(iprot);
+ struct.success.add(_elem885);
}
iprot.readListEnd();
}
@@ -40713,9 +41033,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (FieldSchema _iter847 : struct.success)
+ for (FieldSchema _iter887 : struct.success)
{
- _iter847.write(oprot);
+ _iter887.write(oprot);
}
oprot.writeListEnd();
}
@@ -40770,9 +41090,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter848 : struct.success)
+ for (FieldSchema _iter888 : struct.success)
{
- _iter848.write(oprot);
+ _iter888.write(oprot);
}
}
}
@@ -40793,14 +41113,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list849 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list849.size);
- FieldSchema _elem850;
- for (int _i851 = 0; _i851 < _list849.size; ++_i851)
+ org.apache.thrift.protocol.TList _list889 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list889.size);
+ FieldSchema _elem890;
+ for (int _i891 = 0; _i891 < _list889.size; ++_i891)
{
- _elem850 = new FieldSchema();
- _elem850.read(iprot);
- struct.success.add(_elem850);
+ _elem890 = new FieldSchema();
+ _elem890.read(iprot);
+ struct.success.add(_elem890);
}
}
struct.setSuccessIsSet(true);
@@ -41954,14 +42274,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list852 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list852.size);
- FieldSchema _elem853;
- for (int _i854 = 0; _i854 < _list852.size; ++_i854)
+ org.apache.thrift.protocol.TList _list892 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list892.size);
+ FieldSchema _elem893;
+ for (int _i894 = 0; _i894 < _list892.size; ++_i894)
{
- _elem853 = new FieldSchema();
- _elem853.read(iprot);
- struct.success.add(_elem853);
+ _elem893 = new FieldSchema();
+ _elem893.read(iprot);
+ struct.success.add(_elem893);
}
iprot.readListEnd();
}
@@ -42014,9 +42334,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (FieldSchema _iter855 : struct.success)
+ for (FieldSchema _iter895 : struct.success)
{
- _iter855.write(oprot);
+ _iter895.write(oprot);
}
oprot.writeListEnd();
}
@@ -42071,9 +42391,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter856 : struct.success)
+ for (FieldSchema _iter896 : struct.success)
{
- _iter856.write(oprot);
+ _iter896.write(oprot);
}
}
}
@@ -42094,14 +42414,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list857 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list857.size);
- FieldSchema _elem858;
- for (int _i859 = 0; _i859 < _list857.size; ++_i859)
+ org.apache.thrift.protocol.TList _list897 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list897.size);
+ FieldSchema _elem898;
+ for (int _i899 = 0; _i899 < _list897.size; ++_i899)
{
- _elem858 = new FieldSchema();
- _elem858.read(iprot);
- struct.success.add(_elem858);
+ _elem898 = new FieldSchema();
+ _elem898.read(iprot);
+ struct.success.add(_elem898);
}
}
struct.setSuccessIsSet(true);
@@ -43146,14 +43466,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list860 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list860.size);
- FieldSchema _elem861;
- for (int _i862 = 0; _i862 < _list860.size; ++_i862)
+ org.apache.thrift.protocol.TList _list900 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list900.size);
+ FieldSchema _elem901;
+ for (int _i902 = 0; _i902 < _list900.size; ++_i902)
{
- _elem861 = new FieldSchema();
- _elem861.read(iprot);
- struct.success.add(_elem861);
+ _elem901 = new FieldSchema();
+ _elem901.read(iprot);
+ struct.success.add(_elem901);
}
iprot.readListEnd();
}
@@ -43206,9 +43526,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (FieldSchema _iter863 : struct.success)
+ for (FieldSchema _iter903 : struct.success)
{
- _iter863.write(oprot);
+ _iter903.write(oprot);
}
oprot.writeListEnd();
}
@@ -43263,9 +43583,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter864 : struct.success)
+ for (FieldSchema _iter904 : struct.success)
{
- _iter864.write(oprot);
+ _iter904.write(oprot);
}
}
}
@@ -43286,14 +43606,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list865 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list865.size);
- FieldSchema _elem866;
- for (int _i867 = 0; _i867 < _list865.size; ++_i867)
+ org.apache.thrift.protocol.TList _list905 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list905.size);
+ FieldSchema _elem906;
+ for (int _i907 = 0; _i907 < _list905.size; ++_i907)
{
- _elem866 = new FieldSchema();
- _elem866.read(iprot);
- struct.success.add(_elem866);
+ _elem906 = new FieldSchema();
+ _elem906.read(iprot);
+ struct.success.add(_elem906);
}
}
struct.setSuccessIsSet(true);
@@ -44447,14 +44767,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list868 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list868.size);
- FieldSchema _elem869;
- for (int _i870 = 0; _i870 < _list868.size; ++_i870)
+ org.apache.thrift.protocol.TList _list908 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list908.size);
+ FieldSchema _elem909;
+ for (int _i910 = 0; _i910 < _list908.size; ++_i910)
{
- _elem869 = new FieldSchema();
- _elem869.read(iprot);
- struct.success.add(_elem869);
+ _elem909 = new FieldSchema();
+ _elem909.read(iprot);
+ struct.success.add(_elem909);
}
iprot.readListEnd();
}
@@ -44507,9 +44827,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (FieldSchema _iter871 : struct.success)
+ for (FieldSchema _iter911 : struct.success)
{
- _iter871.write(oprot);
+ _iter911.write(oprot);
}
oprot.writeListEnd();
}
@@ -44564,9 +44884,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter872 : struct.success)
+ for (FieldSchema _iter912 : struct.success)
{
- _iter872.write(oprot);
+ _iter912.write(oprot);
}
}
}
@@ -44587,14 +44907,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list873 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list873.size);
- FieldSchema _elem874;
- for (int _i875 = 0; _i875 < _list873.size; ++_i875)
+ org.apache.thrift.protocol.TList _list913 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list913.size);
+ FieldSchema _elem914;
+ for (int _i915 = 0; _i915 < _list913.size; ++_i915)
{
- _elem874 = new FieldSchema();
- _elem874.read(iprot);
- struct.success.add(_elem874);
+ _elem914 = new FieldSchema();
+ _elem914.read(iprot);
+ struct.success.add(_elem914);
}
}
struct.setSuccessIsSet(true);
@@ -47521,14 +47841,14 @@ import org.slf4j.LoggerFactory;
case 2: // PRIMARY_KEYS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list876 = iprot.readListBegin();
- struct.primaryKeys = new ArrayList<SQLPrimaryKey>(_list876.size);
- SQLPrimaryKey _elem877;
- for (int _i878 = 0; _i878 < _list876.size; ++_i878)
+ org.apache.thrift.protocol.TList _list916 = iprot.readListBegin();
+ struct.primaryKeys = new ArrayList<SQLPrimaryKey>(_list916.size);
+ SQLPrimaryKey _elem917;
+ for (int _i918 = 0; _i918 < _list916.size; ++_i918)
{
- _elem877 = new SQLPrimaryKey();
- _elem877.read(iprot);
- struct.primaryKeys.add(_elem877);
+ _elem917 = new SQLPrimaryKey();
+ _elem917.read(iprot);
+ struct.primaryKeys.add(_elem917);
}
iprot.readListEnd();
}
@@ -47540,14 +47860,14 @@ import org.slf4j.LoggerFactory;
case 3: // FOREIGN_KEYS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list879 = iprot.readListBegin();
- struct.foreignKeys = new ArrayList<SQLForeignKey>(_list879.size);
- SQLForeignKey _elem880;
- for (int _i881 = 0; _i881 < _list879.size; ++_i881)
+ org.apache.thrift.protocol.TList _list919 = iprot.readListBegin();
+ struct.foreignKeys = new ArrayList<SQLForeignKey>(_list919.size);
+ SQLForeignKey _elem920;
+ for (int _i921 = 0; _i921 < _list919.size; ++_i921)
{
- _elem880 = new SQLForeignKey();
- _elem880.read(iprot);
- struct.foreignKeys.add(_elem880);
+ _elem920 = new SQLForeignKey();
+ _elem920.read(iprot);
+ struct.foreignKeys.add(_elem920);
}
iprot.readListEnd();
}
@@ -47559,14 +47879,14 @@ import org.slf4j.LoggerFactory;
case 4: // UNIQUE_CONSTRAINTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list882 = iprot.readListBegin();
- struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list882.size);
- SQLUniqueConstraint _elem883;
- for (int _i884 = 0; _i884 < _list882.size; ++_i884)
+ org.apache.thrift.protocol.TList _list922 = iprot.readListBegin();
+ struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list922.size);
+ SQLUniqueConstraint _elem923;
+ for (int _i924 = 0; _i924 < _list922.size; ++_i924)
{
- _elem883 = new SQLUniqueConstraint();
- _elem883.read(iprot);
- struct.uniqueConstraints.add(_elem883);
+ _elem923 = new SQLUniqueConstraint();
+ _elem923.read(iprot);
+ struct.uniqueConstraints.add(_elem923);
}
iprot.readListEnd();
}
@@ -47578,14 +47898,14 @@ import org.slf4j.LoggerFactory;
case 5: // NOT_NULL_CONSTRAINTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list885 = iprot.readListBegin();
- struct.notNullConstraints = new ArrayList<SQLNotNullConstraint>(_list885.size);
- SQLNotNullConstraint _elem886;
- for (int _i887 = 0; _i887 < _list885.size; ++_i887)
+ org.apache.thrift.protocol.TList _list925 = iprot.readListBegin();
+ struct.notNullConstraints = new ArrayList<SQLNotNullConstraint>(_list925.size);
+ SQLNotNullConstraint _elem926;
+ for (int _i927 = 0; _i927 < _list925.size; ++_i927)
{
- _elem886 = new SQLNotNullConstraint();
- _elem886.read(iprot);
- struct.notNullConstraints.add(_elem886);
+ _elem926 = new SQLNotNullConstraint();
+ _elem926.read(iprot);
+ struct.notNullConstraints.add(_elem926);
}
iprot.readListEnd();
}
@@ -47616,9 +47936,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(PRIMARY_KEYS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.primaryKeys.size()));
- for (SQLPrimaryKey _iter888 : struct.primaryKeys)
+ for (SQLPrimaryKey _iter928 : struct.primaryKeys)
{
- _iter888.write(oprot);
+ _iter928.write(oprot);
}
oprot.writeListEnd();
}
@@ -47628,9 +47948,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(FOREIGN_KEYS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.foreignKeys.size()));
- for (SQLForeignKey _iter889 : struct.foreignKeys)
+ for (SQLForeignKey _iter929 : struct.foreignKeys)
{
- _iter889.write(oprot);
+ _iter929.write(oprot);
}
oprot.writeListEnd();
}
@@ -47640,9 +47960,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(UNIQUE_CONSTRAINTS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.uniqueConstraints.size()));
- for (SQLUniqueConstraint _iter890 : struct.uniqueConstraints)
+ for (SQLUniqueConstraint _iter930 : struct.uniqueConstraints)
{
- _iter890.write(oprot);
+ _iter930.write(oprot);
}
oprot.writeListEnd();
}
@@ -47652,9 +47972,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(NOT_NULL_CONSTRAINTS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.notNullConstraints.size()));
- for (SQLNotNullConstraint _iter891 : struct.notNullConstraints)
+ for (SQLNotNullConstraint _iter931 : struct.notNullConstraints)
{
- _iter891.write(oprot);
+ _iter931.write(oprot);
}
oprot.writeListEnd();
}
@@ -47700,36 +48020,36 @@ import org.slf4j.LoggerFactory;
if (struct.isSetPrimaryKeys()) {
{
oprot.writeI32(struct.primaryKeys.size());
- for (SQLPrimaryKey _iter892 : struct.primaryKeys)
+ for (SQLPrimaryKey _iter932 : struct.primaryKeys)
{
- _iter892.write(oprot);
+ _iter932.write(oprot);
}
}
}
if (struct.isSetForeignKeys()) {
{
oprot.writeI32(struct.foreignKeys.size());
- for (SQLForeignKey _iter893 : struct.foreignKeys)
+ for (SQLForeignKey _iter933 : struct.foreignKeys)
{
- _iter893.write(oprot);
+ _iter933.write(oprot);
}
}
}
if (struct.isSetUniqueConstraints()) {
{
oprot.writeI32(struct.uniqueConstraints.size());
- for (SQLUniqueConstraint _iter894 : struct.uniqueConstraints)
+ for (SQLUniqueConstraint _iter934 : struct.uniqueConstraints)
{
- _iter894.write(oprot);
+ _iter934.write(oprot);
}
}
}
if (struct.isSetNotNullConstraints()) {
{
oprot.writeI32(struct.notNullConstraints.size());
- for (SQLNotNullConstraint _iter895 : struct.notNullConstraints)
+ for (SQLNotNullConstraint _iter935 : struct.notNullConstraints)
{
- _iter895.write(oprot);
+ _iter935.write(oprot);
}
}
}
@@ -47746,56 +48066,56 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list896 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.primaryKeys = new ArrayList<SQLPrimaryKey>(_list896.size);
- SQLPrimaryKey _elem897;
- for (int _i898 = 0; _i898 < _list896.size; ++_i898)
+ org.apache.thrift.protocol.TList _list936 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.primaryKeys = new ArrayList<SQLPrimaryKey>(_list936.size);
+ SQLPrimaryKey _elem937;
+ for (int _i938 = 0; _i938 < _list936.size; ++_i938)
{
- _elem897 = new SQLPrimaryKey();
- _elem897.read(iprot);
- struct.primaryKeys.add(_elem897);
+ _elem937 = new SQLPrimaryKey();
+ _elem937.read(iprot);
+ struct.primaryKeys.add(_elem937);
}
}
struct.setPrimaryKeysIsSet(true);
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list899 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.foreignKeys = new ArrayList<SQLForeignKey>(_list899.size);
- SQLForeignKey _elem900;
- for (int _i901 = 0; _i901 < _list899.size; ++_i901)
+ org.apache.thrift.protocol.TList _list939 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.foreignKeys = new ArrayList<SQLForeignKey>(_list939.size);
+ SQLForeignKey _elem940;
+ for (int _i941 = 0; _i941 < _list939.size; ++_i941)
{
- _elem900 = new SQLForeignKey();
- _elem900.read(iprot);
- struct.foreignKeys.add(_elem900);
+ _elem940 = new SQLForeignKey();
+ _elem940.read(iprot);
+ struct.foreignKeys.add(_elem940);
}
}
struct.setForeignKeysIsSet(true);
}
if (incoming.get(3)) {
{
- org.apache.thrift.protocol.TList _list902 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list902.size);
- SQLUniqueConstraint _elem903;
- for (int _i904 = 0; _i904 < _list902.size; ++_i904)
+ org.apache.thrift.protocol.TList _list942 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list942.size);
+ SQLUniqueConstraint _elem943;
+ for (int _i944 = 0; _i944 < _list942.size; ++_i944)
{
- _elem903 = new SQLUniqueConstraint();
- _elem903.read(iprot);
- struct.uniqueConstraints.add(_elem903);
+ _elem943 = new SQLUniqueConstraint();
+ _elem943.read(iprot);
+ struct.uniqueConstraints.add(_elem943);
}
}
struct.setUniqueConstraintsIsSet(true);
}
if (incoming.get(4)) {
{
- org.apache.thrift.protocol.TList _list905 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.notNullConstraints = new ArrayList<SQLNotNullConstraint>(_list905.size);
- SQLNotNullConstraint _elem906;
- for (int _i907 = 0; _i907 < _list905.size; ++_i907)
+ org.apache.thrift.protocol.TList _list945 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.notNullConstraints = new ArrayList<SQLNotNullConstraint>(_list945.size);
+ SQLNotNullConstraint _elem946;
+ for (int _i947 = 0; _i947 < _list945.size; ++_i947)
{
- _elem906 = new SQLNotNullConstraint();
- _elem906.read(iprot);
- struct.notNullConstraints.add(_elem906);
+ _elem946 = new SQLNotNullConstraint();
+ _elem946.read(iprot);
+ struct.notNullConstraints.add(_elem946);
}
}
struct.setNotNullConstraintsIsSet(true);
@@ -55287,13 +55607,13 @@ import org.slf4j.LoggerFactory;
case 3: // PART_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list908 = iprot.readListBegin();
- struct.partNames = new ArrayList<String>(_list908.size);
- String _elem909;
- for (int _i910 = 0; _i910 < _list908.size; ++_i910)
+ org.apache.thrift.protocol.TList _list948 = iprot.readListBegin();
+ struct.partNames = new ArrayList<String>(_list948.size);
+ String _elem949;
+ for (int _i950 = 0; _i950 < _list948.size; ++_i950)
{
- _elem909 = iprot.readString();
- struct.partNames.add(_elem909);
+ _elem949 = iprot.readString();
+ struct.partNames.add(_elem949);
}
iprot.readListEnd();
}
@@ -55329,9 +55649,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(PART_NAMES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.partNames.size()));
- for (String _iter911 : struct.partNames)
+ for (String _iter951 : struct.partNames)
{
- oprot.writeString(_iter911);
+ oprot.writeString(_iter951);
}
oprot.writeListEnd();
}
@@ -55374,9 +55694,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetPartNames()) {
{
oprot.writeI32(struct.partNames.size());
- for (String _iter912 : struct.partNames)
+ for (String _iter952 : struct.partNames)
{
- oprot.writeString(_iter912);
+ oprot.writeString(_iter952);
}
}
}
@@ -55396,13 +55716,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list913 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.partNames = new ArrayList<String>(_list913.size);
- String _elem914;
- for (int _i915 = 0; _i915 < _list913.size; ++_i915)
+ org.apache.thrift.protocol.TList _list953 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.partNames = new ArrayList<String>(_list953.size);
+ String _elem954;
+ for (int _i955 = 0; _i955 < _list953.size; ++_i955)
{
- _elem914 = iprot.readString();
- struct.partNames.add(_elem914);
+ _elem954 = iprot.readString();
+ struct.partNames.add(_elem954);
}
}
struct.setPartNamesIsSet(true);
@@ -56627,13 +56947,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list916 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list916.size);
- String _elem917;
- for (int _i918 = 0; _i918 < _list916.size; ++_i918)
+ org.apache.thrift.protocol.TList _list956 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list956.size);
+ String _elem957;
+ for (int _i958 = 0; _i958 < _list956.size; ++_i958)
{
- _elem917 = iprot.readString();
- struct.success.add(_elem917);
+ _elem957 = iprot.readString();
+ struct.success.add(_elem957);
}
iprot.readListEnd();
}
@@ -56668,9 +56988,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
- for (String _iter919 : struct.success)
+ for (String _iter959 : struct.success)
{
- oprot.writeString(_iter919);
+ oprot.writeString(_iter959);
}
oprot.writeListEnd();
}
@@ -56709,9 +57029,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter920 : struct.success)
+ for (String _iter960 : struct.success)
{
- oprot.writeString(_iter920);
+ oprot.writeString(_iter960);
}
}
}
@@ -56726,13 +57046,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list921 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list921.size);
- String _elem922;
- for (int _i923 = 0; _i923 < _list921.size; ++_i923)
+ org.apache.thrift.protocol.TList _list961 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list961.size);
+ String _elem962;
+ for (int _i963 = 0; _i963 < _list961.size; ++_i963)
{
- _elem922 = iprot.readString();
- struct.success.add(_elem922);
+ _elem962 = iprot.readString();
+ struct.success.add(_elem962);
}
}
struct.setSuccessIsSet(true);
@@ -57706,13 +58026,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list924 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list924.size);
- String _elem925;
- for (int _i926 = 0; _i926 < _list924.size; ++_i926)
+ org.apache.thrift.protocol.TList _list964 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list964.size);
+ String _elem965;
+ for (int _i966 = 0; _i966 < _list964.size; ++_i966)
{
- _elem925 = iprot.readString();
- struct.success.add(_elem925);
+ _elem965 = iprot.readString();
+ struct.success.add(_elem965);
}
iprot.readListEnd();
}
@@ -57747,9 +58067,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
- for (String _iter927 : struct.success)
+ for (String _iter967 : struct.success)
{
- oprot.writeString(_iter927);
+ oprot.writeString(_iter967);
}
oprot.writeListEnd();
}
@@ -57788,9 +58108,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter928 : struct.success)
+ for (String _iter968 : struct.success)
{
- oprot.writeString(_iter928);
+ oprot.writeString(_iter968);
}
}
}
@@ -57805,13 +58125,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list929 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list929.size);
- String _elem930;
- for (int _i931 = 0; _i931 < _list929.size; ++_i931)
+ org.apache.thrift.protocol.TList _list969 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list969.size);
+ String _elem970;
+ for (int _i971 = 0; _i971 < _list969.size; ++_i971)
{
- _elem930 = iprot.readString();
- struct.success.add(_elem930);
+ _elem970 = iprot.readString();
+ struct.success.add(_elem970);
}
}
struct.setSuccessIsSet(true);
@@ -58577,13 +58897,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list932 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list932.size);
- String _elem933;
- for (int _i934 = 0; _i934 < _list932.size; ++_i934)
+ org.apache.thrift.protocol.TList _list972 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list972.size);
+ String _elem973;
+ for (int _i974 = 0; _i974 < _list972.size; ++_i974)
{
- _elem933 = iprot.readString();
- struct.success.add(_elem933);
+ _elem973 = iprot.readString();
+ struct.success.add(_elem973);
}
iprot.readListEnd();
}
@@ -58618,9 +58938,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
- for (String _iter935 : struct.success)
+ for (String _iter975 : struct.success)
{
- oprot.writeString(_iter935);
+ oprot.writeString(_iter975);
}
oprot.writeListEnd();
}
@@ -58659,9 +58979,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter936 : struct.success)
+ for (String _iter976 : struct.success)
{
- oprot.writeString(_iter936);
+ oprot.writeString(_iter976);
}
}
}
@@ -58676,13 +58996,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list937 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list937.size);
- String _elem938;
- for (int _i939 = 0; _i939 < _list937.size; ++_i939)
+ org.apache.thrift.protocol.TList _list977 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list977.size);
+ String _elem978;
+ for (int _i979 = 0; _i979 < _list977.size; ++_i979)
{
- _elem938 = iprot.readString();
- struct.success.add(_elem938);
+ _elem978 = iprot.readString();
+ struct.success.add(_elem978);
}
}
struct.setSuccessIsSet(true);
@@ -59187,13 +59507,13 @@ import org.slf4j.LoggerFactory;
case 3: // TBL_TYPES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list940 = iprot.readListBegin();
- struct.tbl_types = new ArrayList<String>(_list940.size);
- String _elem941;
- for (int _i942 = 0; _i942 < _list940.size; ++_i942)
+ org.apache.thrift.protocol.TList _list980 = iprot.readListBegin();
+ struct.tbl_types = new ArrayList<String>(_list980.size);
+ String _elem981;
+ for (int _i982 = 0; _i982 < _list980.size; ++_i982)
{
- _elem941 = iprot.readString();
- struct.tbl_types.add(_elem941);
+ _elem981 = iprot.readString();
+ struct.tbl_types.add(_elem981);
}
iprot.readListEnd();
}
@@ -59229,9 +59549,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(TBL_TYPES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.tbl_types.size()));
- for (String _iter943 : struct.tbl_types)
+ for (String _iter983 : struct.tbl_types)
{
- oprot.writeString(_iter943);
+ oprot.writeString(_iter983);
}
oprot.writeListEnd();
}
@@ -59274,9 +59594,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetTbl_types()) {
{
oprot.writeI32(struct.tbl_types.size());
- for (String _iter944 : struct.tbl_types)
+ for (String _iter984 : struct.tbl_types)
{
- oprot.writeString(_iter944);
+ oprot.writeString(_iter984);
}
}
}
@@ -59296,13 +59616,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list945 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.tbl_types = new ArrayList<String>(_list945.size);
- String _elem946;
- for (int _i947 = 0; _i947 < _list945.size; ++_i947)
+ org.apache.thrift.protocol.TList _list985 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.tbl_types = new ArrayList<String>(_list985.size);
+ String _elem986;
+ for (int _i987 = 0; _i987 < _list985.size; ++_i987)
{
- _elem946 = iprot.readString();
- struct.tbl_types.add(_elem946);
+ _elem986 = iprot.readString();
+ struct.tbl_types.add(_elem986);
}
}
struct.setTbl_typesIsSet(true);
@@ -59708,14 +60028,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list948 = iprot.readListBegin();
- struct.success = new ArrayList<TableMeta>(_list948.size);
- TableMeta _elem949;
- for (int _i950 = 0; _i950 < _list948.size; ++_i950)
+ org.apache.thrift.protocol.TList _list988 = iprot.readListBegin();
+ struct.success = new ArrayList<TableMeta>(_list988.size);
+ TableMeta _elem989;
+ for (int _i990 = 0; _i990 < _list988.size; ++_i990)
{
- _elem949 = new TableMeta();
- _elem949.read(iprot);
- struct.success.add(_elem949);
+ _elem989 = new TableMeta();
+ _elem989.read(iprot);
+ struct.success.add(_elem989);
}
iprot.readListEnd();
}
@@ -59750,9 +60070,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (TableMeta _iter951 : struct.success)
+ for (TableMeta _iter991 : struct.success)
{
- _iter951.write(oprot);
+ _iter991.write(oprot);
}
oprot.writeListEnd();
}
@@ -59791,9 +60111,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (TableMeta _iter952 : struct.success)
+ for (TableMeta _iter992 : struct.success)
{
- _iter952.write(oprot);
+ _iter992.write(oprot);
}
}
}
@@ -59808,14 +60128,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list953 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<TableMeta>(_list953.size);
- TableMeta _elem954;
- for (int _i955 = 0; _i955 < _list953.size; ++_i955)
+ org.apache.thrift.protocol.TList _list993 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<TableMeta>(_list993.size);
+ TableMeta _elem994;
+ for (int _i995 = 0; _i995 < _list993.size; ++_i995)
{
- _elem954 = new TableMeta();
- _elem954.read(iprot);
- struct.success.add(_elem954);
+ _elem994 = new TableMeta();
+ _elem994.read(iprot);
+ struct.success.add(_elem994);
}
}
struct.setSuccessIsSet(true);
@@ -60581,13 +60901,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list956 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list956.size);
- String _elem957;
- for (int _i958 = 0; _i958 < _list956.size; ++_i958)
+ org.apache.thrift.protocol.TList _list996 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list996.size);
+ String _elem997;
+ for (int _i998 = 0; _i998 < _list996.size; ++_i998)
{
- _elem957 = iprot.readString();
- struct.success.add(_elem957);
+ _elem997 = iprot.readString();
+ struct.success.add(_elem997);
}
iprot.readListEnd();
}
@@ -60622,9 +60942,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
- for (String _iter959 : struct.success)
+ for (String _iter999 : struct.success)
{
- oprot.writeString(_iter959);
+ oprot.writeString(_iter999);
}
oprot.writeListEnd();
}
@@ -60663,9 +60983,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter960 : struct.success)
+ for (String _iter1000 : struct.success)
{
- oprot.writeString(_iter960);
+ oprot.writeString(_iter1000);
}
}
}
@@ -60680,13 +61000,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list961 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list961.size);
- String _elem962;
- for (int _i963 = 0; _i963 < _list961.size; ++_i963)
+ org.apache.thrift.protocol.TList _list1001 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list1001.size);
+ String _elem1002;
+ for (int _i1003 = 0; _i1003 < _list1001.size; ++_i1003)
{
- _elem962 = iprot.readString();
- struct.success.add(_elem962);
+ _elem1002 = iprot.readString();
+ struct.success.add(_elem1002);
}
}
struct.setSuccessIsSet(true);
@@ -62139,13 +62459,13 @@ import org.slf4j.LoggerFactory;
case 2: // TBL_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list964 = iprot.readListBegin();
- struct.tbl_names = new ArrayList<String>(_list964.size);
- String _elem965;
- for (int _i966 = 0; _i966 < _list964.size; ++_i966)
+ org.apache.thrift.protocol.TList _list1004 = iprot.readListBegin();
+ struct.tbl_names = new ArrayList<String>(_list1004.size);
+ String _elem1005;
+ for (int _i1006 = 0; _i1006 < _list1004.size; ++_i1006)
{
- _elem965 = iprot.readString();
- struct.tbl_names.add(_elem965);
+ _elem1005 = iprot.readString();
+ struct.tbl_names.add(_elem1005);
}
iprot.readListEnd();
}
@@ -62176,9 +62496,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(TBL_NAMES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.tbl_names.size()));
- for (String _iter967 : struct.tbl_names)
+ for (String _iter1007 : struct.tbl_names)
{
- oprot.writeString(_iter967);
+ oprot.writeString(_iter1007);
}
oprot.writeListEnd();
}
@@ -62215,9 +62535,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetTbl_names()) {
{
oprot.writeI32(struct.tbl_names.size());
- for (String _iter968 : struct.tbl_names)
+ for (String _iter1008 : struct.tbl_names)
{
- oprot.writeString(_iter968);
+ oprot.writeString(_iter1008);
}
}
}
@@ -62233,13 +62553,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list969 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.tbl_names = new ArrayList<String>(_list969.size);
- String _elem970;
- for (int _i971 = 0; _i971 < _list969.size; ++_i971)
+ org.apache.thrift.protocol.TList _list1009 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.tbl_names = new ArrayList<String>(_list1009.size);
+ String _elem1010;
+ for (int _i1011 = 0; _i1011 < _list1009.size; ++_i1011)
{
- _elem970 = iprot.readString();
- struct.tbl_names.add(_elem970);
+ _elem1010 = iprot.readString();
+ struct.tbl_names.add(_elem1010);
}
}
struct.setTbl_namesIsSet(true);
@@ -62564,14 +62884,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list972 = iprot.readListBegin();
- struct.success = new ArrayList<Table>(_list972.size);
- Table _elem973;
- for (int _i974 = 0; _i974 < _list972.size; ++_i974)
+ org.apache.thrift.protocol.TList _list1012 = iprot.readListBegin();
+ struct.success = new ArrayList<Table>(_list1012.size);
+ Table _elem1013;
+ for (int _i1014 = 0; _i1014 < _list1012.size; ++_i1014)
{
- _elem973 = new Table();
- _elem973.read(iprot);
- struct.success.add(_elem973);
+ _elem1013 = new Table();
+ _elem1013.read(iprot);
+ struct.success.add(_elem1013);
}
iprot.readListEnd();
}
@@ -62597,9 +62917,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (Table _iter975 : struct.success)
+ for (Table _iter1015 : struct.success)
{
- _iter975.write(oprot);
+ _iter1015.write(oprot);
}
oprot.writeListEnd();
}
@@ -62630,9 +62950,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Table _iter976 : struct.success)
+ for (Table _iter1016 : struct.success)
{
- _iter976.write(oprot);
+ _iter1016.write(oprot);
}
}
}
@@ -62644,14 +62964,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list977 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<Table>(_list977.size);
- Table _elem978;
- for (int _i979 = 0; _i979 < _list977.size; ++_i979)
+ org.apache.thrift.protocol.TList _list1017 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<Table>(_list1017.size);
+ Table _elem1018;
+ for (int _i1019 = 0; _i1019 < _list1017.size; ++_i1019)
{
- _elem978 = new Table();
- _elem978.read(iprot);
- struct.success.add(_elem978);
+ _elem1018 = new Table();
+ _elem1018.read(iprot);
+ struct.success.add(_elem1018);
}
}
struct.setSuccessIsSet(true);
@@ -65044,13 +65364,13 @@ import org.slf4j.LoggerFactory;
case 2: // TBL_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list980 = iprot.readListBegin();
- struct.tbl_names = new ArrayList<String>(_list980.size);
- String _elem981;
- for (int _i982 = 0; _i982 < _list980.size; ++_i982)
+ org.apache.thrift.protocol.TList _list1020 = iprot.readListBegin();
+ struct.tbl_names = new ArrayList<String>(_list1020.size);
+ String _elem1021;
+ for (int _i1022 = 0; _i1022 < _list1020.size; ++_i1022)
{
- _elem981 = iprot.readString();
- struct.tbl_names.add(_elem981);
+ _elem1021 = iprot.readString();
+ struct.tbl_names.add(_elem1021);
}
iprot.readListEnd();
}
@@ -65081,9 +65401,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(TBL_NAMES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.tbl_names.size()));
- for (String _iter983 : struct.tbl_names)
+ for (String _iter1023 : struct.tbl_names)
{
- oprot.writeString(_iter983);
+ oprot.writeString(_iter1023);
}
oprot.writeListEnd();
}
@@ -65120,9 +65440,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetTbl_names()) {
{
oprot.writeI32(struct.tbl_names.size());
- for (String _iter984 : struct.tbl_names)
+ for (String _iter1024 : struct.tbl_names)
{
- oprot.writeString(_iter984);
+ oprot.writeString(_iter1024);
}
}
}
@@ -65138,13 +65458,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list985 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.tbl_names = new ArrayList<String>(_list985.size);
- String _elem986;
- for (int _i987 = 0; _i987 < _list985.size; ++_i987)
+ org.apache.thrift.protocol.TList _list1025 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.tbl_names = new ArrayList<String>(_list1025.size);
+ String _elem1026;
+ for (int _i1027 = 0; _i1027 < _list1025.size; ++_i1027)
{
- _elem986 = iprot.readString();
- struct.tbl_names.add(_elem986);
+ _elem1026 = iprot.readString();
+ struct.tbl_names.add(_elem1026);
}
}
struct.setTbl_namesIsSet(true);
@@ -65717,16 +66037,16 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map988 = iprot.readMapBegin();
- struct.success = new HashMap<String,Materialization>(2*_map988.size);
- String _key989;
- Materialization _val990;
- for (int _i991 = 0; _i991 < _map988.size; ++_i991)
+ org.apache.thrift.protocol.TMap _map1028 = iprot.readMapBegin();
+ struct.success = new HashMap<String,Materialization>(2*_map1028.size);
+ String _key1029;
+ Materialization _val1030;
+ for (int _i1031 = 0; _i1031 < _map1028.size; ++_i1031)
{
- _key989 = iprot.readString();
- _val990 = new Materialization();
- _val990.read(iprot);
- struct.success.put(_key989, _val990);
+ _key1029 = iprot.readString();
+ _val1030 = new Materialization();
+ _val1030.read(iprot);
+ struct.success.put(_key1029, _val1030);
}
iprot.readMapEnd();
}
@@ -65779,10 +66099,10 @@ import org.slf4j.LoggerFactory;
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<String, Materialization> _iter992 : struct.success.entrySet())
+ for (Map.Entry<String, Materialization> _iter1032 : struct.success.entrySet())
{
- oprot.writeString(_iter992.getKey());
- _iter992.getValue().write(oprot);
+ oprot.writeString(_iter1032.getKey());
+ _iter1032.getValue().write(oprot);
}
oprot.writeMapEnd();
}
@@ -65837,10 +66157,10 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Map.Entry<String, Materialization> _iter993 : struct.success.entrySet())
+ for (Map.Entry<String, Materialization> _iter1033 : struct.success.entrySet())
{
- oprot.writeString(_iter993.getKey());
- _iter993.getValue().write(oprot);
+ oprot.writeString(_iter1033.getKey());
+ _iter1033.getValue().write(oprot);
}
}
}
@@ -65861,16 +66181,16 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TMap _map994 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new HashM
<TRUNCATED>