You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by vi...@apache.org on 2018/10/07 22:47:47 UTC
[11/13] hive git commit: HIVE-20306 : Implement projection spec for
fetching only requested fields from partitions (Vihang Karajgaonkar,
reviewed by Aihua Xu, Andrew Sherman and Alexander Kolbasov)
http://git-wip-us.apache.org/repos/asf/hive/blob/44ef91a6/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
index ae09568..52a2b71 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
@@ -470,6 +470,8 @@ import org.slf4j.LoggerFactory;
public List<RuntimeStat> get_runtime_stats(GetRuntimeStatsRequest rqst) throws MetaException, org.apache.thrift.TException;
+ public GetPartitionsResponse get_partitions_with_specs(GetPartitionsRequest request) throws MetaException, org.apache.thrift.TException;
+
}
@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public interface AsyncIface extends com.facebook.fb303.FacebookService .AsyncIface {
@@ -902,6 +904,8 @@ import org.slf4j.LoggerFactory;
public void get_runtime_stats(GetRuntimeStatsRequest rqst, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void get_partitions_with_specs(GetPartitionsRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
}
@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class Client extends com.facebook.fb303.FacebookService.Client implements Iface {
@@ -7072,6 +7076,32 @@ import org.slf4j.LoggerFactory;
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "get_runtime_stats failed: unknown result");
}
+ public GetPartitionsResponse get_partitions_with_specs(GetPartitionsRequest request) throws MetaException, org.apache.thrift.TException
+ {
+ send_get_partitions_with_specs(request);
+ return recv_get_partitions_with_specs();
+ }
+
+ public void send_get_partitions_with_specs(GetPartitionsRequest request) throws org.apache.thrift.TException
+ {
+ get_partitions_with_specs_args args = new get_partitions_with_specs_args();
+ args.setRequest(request);
+ sendBase("get_partitions_with_specs", args);
+ }
+
+ public GetPartitionsResponse recv_get_partitions_with_specs() throws MetaException, org.apache.thrift.TException
+ {
+ get_partitions_with_specs_result result = new get_partitions_with_specs_result();
+ receiveBase(result, "get_partitions_with_specs");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.o1 != null) {
+ throw result.o1;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "get_partitions_with_specs failed: unknown result");
+ }
+
}
@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class AsyncClient extends com.facebook.fb303.FacebookService.AsyncClient implements AsyncIface {
@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class Factory implements org.apache.thrift.async.TAsyncClientFactory<AsyncClient> {
@@ -14430,6 +14460,38 @@ import org.slf4j.LoggerFactory;
}
}
+ public void get_partitions_with_specs(GetPartitionsRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ get_partitions_with_specs_call method_call = new get_partitions_with_specs_call(request, 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_partitions_with_specs_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private GetPartitionsRequest request;
+ public get_partitions_with_specs_call(GetPartitionsRequest request, 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.request = request;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("get_partitions_with_specs", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ get_partitions_with_specs_args args = new get_partitions_with_specs_args();
+ args.setRequest(request);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public GetPartitionsResponse getResult() throws 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_partitions_with_specs();
+ }
+ }
+
}
@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class Processor<I extends Iface> extends com.facebook.fb303.FacebookService.Processor<I> implements org.apache.thrift.TProcessor {
@@ -14657,6 +14719,7 @@ import org.slf4j.LoggerFactory;
processMap.put("heartbeat_lock_materialization_rebuild", new heartbeat_lock_materialization_rebuild());
processMap.put("add_runtime_stats", new add_runtime_stats());
processMap.put("get_runtime_stats", new get_runtime_stats());
+ processMap.put("get_partitions_with_specs", new get_partitions_with_specs());
return processMap;
}
@@ -20152,6 +20215,30 @@ import org.slf4j.LoggerFactory;
}
}
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class get_partitions_with_specs<I extends Iface> extends org.apache.thrift.ProcessFunction<I, get_partitions_with_specs_args> {
+ public get_partitions_with_specs() {
+ super("get_partitions_with_specs");
+ }
+
+ public get_partitions_with_specs_args getEmptyArgsInstance() {
+ return new get_partitions_with_specs_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public get_partitions_with_specs_result getResult(I iface, get_partitions_with_specs_args args) throws org.apache.thrift.TException {
+ get_partitions_with_specs_result result = new get_partitions_with_specs_result();
+ try {
+ result.success = iface.get_partitions_with_specs(args.request);
+ } catch (MetaException o1) {
+ result.o1 = o1;
+ }
+ return result;
+ }
+ }
+
}
@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class AsyncProcessor<I extends AsyncIface> extends com.facebook.fb303.FacebookService.AsyncProcessor<I> {
@@ -20379,6 +20466,7 @@ import org.slf4j.LoggerFactory;
processMap.put("heartbeat_lock_materialization_rebuild", new heartbeat_lock_materialization_rebuild());
processMap.put("add_runtime_stats", new add_runtime_stats());
processMap.put("get_runtime_stats", new get_runtime_stats());
+ processMap.put("get_partitions_with_specs", new get_partitions_with_specs());
return processMap;
}
@@ -33491,6 +33579,63 @@ import org.slf4j.LoggerFactory;
}
}
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class get_partitions_with_specs<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_partitions_with_specs_args, GetPartitionsResponse> {
+ public get_partitions_with_specs() {
+ super("get_partitions_with_specs");
+ }
+
+ public get_partitions_with_specs_args getEmptyArgsInstance() {
+ return new get_partitions_with_specs_args();
+ }
+
+ public AsyncMethodCallback<GetPartitionsResponse> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.thrift.AsyncProcessFunction fcall = this;
+ return new AsyncMethodCallback<GetPartitionsResponse>() {
+ public void onComplete(GetPartitionsResponse o) {
+ get_partitions_with_specs_result result = new get_partitions_with_specs_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_partitions_with_specs_result result = new get_partitions_with_specs_result();
+ if (e instanceof MetaException) {
+ result.o1 = (MetaException) e;
+ result.setO1IsSet(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_partitions_with_specs_args args, org.apache.thrift.async.AsyncMethodCallback<GetPartitionsResponse> resultHandler) throws TException {
+ iface.get_partitions_with_specs(args.request,resultHandler);
+ }
+ }
+
}
@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class getMetaConf_args implements org.apache.thrift.TBase<getMetaConf_args, getMetaConf_args._Fields>, java.io.Serializable, Cloneable, Comparable<getMetaConf_args> {
@@ -43344,13 +43489,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list968 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list968.size);
- String _elem969;
- for (int _i970 = 0; _i970 < _list968.size; ++_i970)
+ org.apache.thrift.protocol.TList _list1000 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list1000.size);
+ String _elem1001;
+ for (int _i1002 = 0; _i1002 < _list1000.size; ++_i1002)
{
- _elem969 = iprot.readString();
- struct.success.add(_elem969);
+ _elem1001 = iprot.readString();
+ struct.success.add(_elem1001);
}
iprot.readListEnd();
}
@@ -43385,9 +43530,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 _iter971 : struct.success)
+ for (String _iter1003 : struct.success)
{
- oprot.writeString(_iter971);
+ oprot.writeString(_iter1003);
}
oprot.writeListEnd();
}
@@ -43426,9 +43571,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter972 : struct.success)
+ for (String _iter1004 : struct.success)
{
- oprot.writeString(_iter972);
+ oprot.writeString(_iter1004);
}
}
}
@@ -43443,13 +43588,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list973 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list973.size);
- String _elem974;
- for (int _i975 = 0; _i975 < _list973.size; ++_i975)
+ org.apache.thrift.protocol.TList _list1005 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list1005.size);
+ String _elem1006;
+ for (int _i1007 = 0; _i1007 < _list1005.size; ++_i1007)
{
- _elem974 = iprot.readString();
- struct.success.add(_elem974);
+ _elem1006 = iprot.readString();
+ struct.success.add(_elem1006);
}
}
struct.setSuccessIsSet(true);
@@ -44103,13 +44248,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list976 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list976.size);
- String _elem977;
- for (int _i978 = 0; _i978 < _list976.size; ++_i978)
+ org.apache.thrift.protocol.TList _list1008 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list1008.size);
+ String _elem1009;
+ for (int _i1010 = 0; _i1010 < _list1008.size; ++_i1010)
{
- _elem977 = iprot.readString();
- struct.success.add(_elem977);
+ _elem1009 = iprot.readString();
+ struct.success.add(_elem1009);
}
iprot.readListEnd();
}
@@ -44144,9 +44289,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 _iter979 : struct.success)
+ for (String _iter1011 : struct.success)
{
- oprot.writeString(_iter979);
+ oprot.writeString(_iter1011);
}
oprot.writeListEnd();
}
@@ -44185,9 +44330,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter980 : struct.success)
+ for (String _iter1012 : struct.success)
{
- oprot.writeString(_iter980);
+ oprot.writeString(_iter1012);
}
}
}
@@ -44202,13 +44347,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list981 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list981.size);
- String _elem982;
- for (int _i983 = 0; _i983 < _list981.size; ++_i983)
+ org.apache.thrift.protocol.TList _list1013 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list1013.size);
+ String _elem1014;
+ for (int _i1015 = 0; _i1015 < _list1013.size; ++_i1015)
{
- _elem982 = iprot.readString();
- struct.success.add(_elem982);
+ _elem1014 = iprot.readString();
+ struct.success.add(_elem1014);
}
}
struct.setSuccessIsSet(true);
@@ -48815,16 +48960,16 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map984 = iprot.readMapBegin();
- struct.success = new HashMap<String,Type>(2*_map984.size);
- String _key985;
- Type _val986;
- for (int _i987 = 0; _i987 < _map984.size; ++_i987)
+ org.apache.thrift.protocol.TMap _map1016 = iprot.readMapBegin();
+ struct.success = new HashMap<String,Type>(2*_map1016.size);
+ String _key1017;
+ Type _val1018;
+ for (int _i1019 = 0; _i1019 < _map1016.size; ++_i1019)
{
- _key985 = iprot.readString();
- _val986 = new Type();
- _val986.read(iprot);
- struct.success.put(_key985, _val986);
+ _key1017 = iprot.readString();
+ _val1018 = new Type();
+ _val1018.read(iprot);
+ struct.success.put(_key1017, _val1018);
}
iprot.readMapEnd();
}
@@ -48859,10 +49004,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> _iter988 : struct.success.entrySet())
+ for (Map.Entry<String, Type> _iter1020 : struct.success.entrySet())
{
- oprot.writeString(_iter988.getKey());
- _iter988.getValue().write(oprot);
+ oprot.writeString(_iter1020.getKey());
+ _iter1020.getValue().write(oprot);
}
oprot.writeMapEnd();
}
@@ -48901,10 +49046,10 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Map.Entry<String, Type> _iter989 : struct.success.entrySet())
+ for (Map.Entry<String, Type> _iter1021 : struct.success.entrySet())
{
- oprot.writeString(_iter989.getKey());
- _iter989.getValue().write(oprot);
+ oprot.writeString(_iter1021.getKey());
+ _iter1021.getValue().write(oprot);
}
}
}
@@ -48919,16 +49064,16 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TMap _map990 = 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*_map990.size);
- String _key991;
- Type _val992;
- for (int _i993 = 0; _i993 < _map990.size; ++_i993)
+ org.apache.thrift.protocol.TMap _map1022 = 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*_map1022.size);
+ String _key1023;
+ Type _val1024;
+ for (int _i1025 = 0; _i1025 < _map1022.size; ++_i1025)
{
- _key991 = iprot.readString();
- _val992 = new Type();
- _val992.read(iprot);
- struct.success.put(_key991, _val992);
+ _key1023 = iprot.readString();
+ _val1024 = new Type();
+ _val1024.read(iprot);
+ struct.success.put(_key1023, _val1024);
}
}
struct.setSuccessIsSet(true);
@@ -49963,14 +50108,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list994 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list994.size);
- FieldSchema _elem995;
- for (int _i996 = 0; _i996 < _list994.size; ++_i996)
+ org.apache.thrift.protocol.TList _list1026 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list1026.size);
+ FieldSchema _elem1027;
+ for (int _i1028 = 0; _i1028 < _list1026.size; ++_i1028)
{
- _elem995 = new FieldSchema();
- _elem995.read(iprot);
- struct.success.add(_elem995);
+ _elem1027 = new FieldSchema();
+ _elem1027.read(iprot);
+ struct.success.add(_elem1027);
}
iprot.readListEnd();
}
@@ -50023,9 +50168,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 _iter997 : struct.success)
+ for (FieldSchema _iter1029 : struct.success)
{
- _iter997.write(oprot);
+ _iter1029.write(oprot);
}
oprot.writeListEnd();
}
@@ -50080,9 +50225,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter998 : struct.success)
+ for (FieldSchema _iter1030 : struct.success)
{
- _iter998.write(oprot);
+ _iter1030.write(oprot);
}
}
}
@@ -50103,14 +50248,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list999 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list999.size);
- FieldSchema _elem1000;
- for (int _i1001 = 0; _i1001 < _list999.size; ++_i1001)
+ org.apache.thrift.protocol.TList _list1031 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list1031.size);
+ FieldSchema _elem1032;
+ for (int _i1033 = 0; _i1033 < _list1031.size; ++_i1033)
{
- _elem1000 = new FieldSchema();
- _elem1000.read(iprot);
- struct.success.add(_elem1000);
+ _elem1032 = new FieldSchema();
+ _elem1032.read(iprot);
+ struct.success.add(_elem1032);
}
}
struct.setSuccessIsSet(true);
@@ -51264,14 +51409,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1002 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list1002.size);
- FieldSchema _elem1003;
- for (int _i1004 = 0; _i1004 < _list1002.size; ++_i1004)
+ org.apache.thrift.protocol.TList _list1034 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list1034.size);
+ FieldSchema _elem1035;
+ for (int _i1036 = 0; _i1036 < _list1034.size; ++_i1036)
{
- _elem1003 = new FieldSchema();
- _elem1003.read(iprot);
- struct.success.add(_elem1003);
+ _elem1035 = new FieldSchema();
+ _elem1035.read(iprot);
+ struct.success.add(_elem1035);
}
iprot.readListEnd();
}
@@ -51324,9 +51469,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 _iter1005 : struct.success)
+ for (FieldSchema _iter1037 : struct.success)
{
- _iter1005.write(oprot);
+ _iter1037.write(oprot);
}
oprot.writeListEnd();
}
@@ -51381,9 +51526,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter1006 : struct.success)
+ for (FieldSchema _iter1038 : struct.success)
{
- _iter1006.write(oprot);
+ _iter1038.write(oprot);
}
}
}
@@ -51404,14 +51549,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list1007 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list1007.size);
- FieldSchema _elem1008;
- for (int _i1009 = 0; _i1009 < _list1007.size; ++_i1009)
+ org.apache.thrift.protocol.TList _list1039 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list1039.size);
+ FieldSchema _elem1040;
+ for (int _i1041 = 0; _i1041 < _list1039.size; ++_i1041)
{
- _elem1008 = new FieldSchema();
- _elem1008.read(iprot);
- struct.success.add(_elem1008);
+ _elem1040 = new FieldSchema();
+ _elem1040.read(iprot);
+ struct.success.add(_elem1040);
}
}
struct.setSuccessIsSet(true);
@@ -52456,14 +52601,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1010 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list1010.size);
- FieldSchema _elem1011;
- for (int _i1012 = 0; _i1012 < _list1010.size; ++_i1012)
+ org.apache.thrift.protocol.TList _list1042 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list1042.size);
+ FieldSchema _elem1043;
+ for (int _i1044 = 0; _i1044 < _list1042.size; ++_i1044)
{
- _elem1011 = new FieldSchema();
- _elem1011.read(iprot);
- struct.success.add(_elem1011);
+ _elem1043 = new FieldSchema();
+ _elem1043.read(iprot);
+ struct.success.add(_elem1043);
}
iprot.readListEnd();
}
@@ -52516,9 +52661,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 _iter1013 : struct.success)
+ for (FieldSchema _iter1045 : struct.success)
{
- _iter1013.write(oprot);
+ _iter1045.write(oprot);
}
oprot.writeListEnd();
}
@@ -52573,9 +52718,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter1014 : struct.success)
+ for (FieldSchema _iter1046 : struct.success)
{
- _iter1014.write(oprot);
+ _iter1046.write(oprot);
}
}
}
@@ -52596,14 +52741,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list1015 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list1015.size);
- FieldSchema _elem1016;
- for (int _i1017 = 0; _i1017 < _list1015.size; ++_i1017)
+ org.apache.thrift.protocol.TList _list1047 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list1047.size);
+ FieldSchema _elem1048;
+ for (int _i1049 = 0; _i1049 < _list1047.size; ++_i1049)
{
- _elem1016 = new FieldSchema();
- _elem1016.read(iprot);
- struct.success.add(_elem1016);
+ _elem1048 = new FieldSchema();
+ _elem1048.read(iprot);
+ struct.success.add(_elem1048);
}
}
struct.setSuccessIsSet(true);
@@ -53757,14 +53902,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1018 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list1018.size);
- FieldSchema _elem1019;
- for (int _i1020 = 0; _i1020 < _list1018.size; ++_i1020)
+ org.apache.thrift.protocol.TList _list1050 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list1050.size);
+ FieldSchema _elem1051;
+ for (int _i1052 = 0; _i1052 < _list1050.size; ++_i1052)
{
- _elem1019 = new FieldSchema();
- _elem1019.read(iprot);
- struct.success.add(_elem1019);
+ _elem1051 = new FieldSchema();
+ _elem1051.read(iprot);
+ struct.success.add(_elem1051);
}
iprot.readListEnd();
}
@@ -53817,9 +53962,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 _iter1021 : struct.success)
+ for (FieldSchema _iter1053 : struct.success)
{
- _iter1021.write(oprot);
+ _iter1053.write(oprot);
}
oprot.writeListEnd();
}
@@ -53874,9 +54019,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter1022 : struct.success)
+ for (FieldSchema _iter1054 : struct.success)
{
- _iter1022.write(oprot);
+ _iter1054.write(oprot);
}
}
}
@@ -53897,14 +54042,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list1023 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list1023.size);
- FieldSchema _elem1024;
- for (int _i1025 = 0; _i1025 < _list1023.size; ++_i1025)
+ org.apache.thrift.protocol.TList _list1055 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list1055.size);
+ FieldSchema _elem1056;
+ for (int _i1057 = 0; _i1057 < _list1055.size; ++_i1057)
{
- _elem1024 = new FieldSchema();
- _elem1024.read(iprot);
- struct.success.add(_elem1024);
+ _elem1056 = new FieldSchema();
+ _elem1056.read(iprot);
+ struct.success.add(_elem1056);
}
}
struct.setSuccessIsSet(true);
@@ -57033,14 +57178,14 @@ import org.slf4j.LoggerFactory;
case 2: // PRIMARY_KEYS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1026 = iprot.readListBegin();
- struct.primaryKeys = new ArrayList<SQLPrimaryKey>(_list1026.size);
- SQLPrimaryKey _elem1027;
- for (int _i1028 = 0; _i1028 < _list1026.size; ++_i1028)
+ org.apache.thrift.protocol.TList _list1058 = iprot.readListBegin();
+ struct.primaryKeys = new ArrayList<SQLPrimaryKey>(_list1058.size);
+ SQLPrimaryKey _elem1059;
+ for (int _i1060 = 0; _i1060 < _list1058.size; ++_i1060)
{
- _elem1027 = new SQLPrimaryKey();
- _elem1027.read(iprot);
- struct.primaryKeys.add(_elem1027);
+ _elem1059 = new SQLPrimaryKey();
+ _elem1059.read(iprot);
+ struct.primaryKeys.add(_elem1059);
}
iprot.readListEnd();
}
@@ -57052,14 +57197,14 @@ import org.slf4j.LoggerFactory;
case 3: // FOREIGN_KEYS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1029 = iprot.readListBegin();
- struct.foreignKeys = new ArrayList<SQLForeignKey>(_list1029.size);
- SQLForeignKey _elem1030;
- for (int _i1031 = 0; _i1031 < _list1029.size; ++_i1031)
+ org.apache.thrift.protocol.TList _list1061 = iprot.readListBegin();
+ struct.foreignKeys = new ArrayList<SQLForeignKey>(_list1061.size);
+ SQLForeignKey _elem1062;
+ for (int _i1063 = 0; _i1063 < _list1061.size; ++_i1063)
{
- _elem1030 = new SQLForeignKey();
- _elem1030.read(iprot);
- struct.foreignKeys.add(_elem1030);
+ _elem1062 = new SQLForeignKey();
+ _elem1062.read(iprot);
+ struct.foreignKeys.add(_elem1062);
}
iprot.readListEnd();
}
@@ -57071,14 +57216,14 @@ import org.slf4j.LoggerFactory;
case 4: // UNIQUE_CONSTRAINTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1032 = iprot.readListBegin();
- struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list1032.size);
- SQLUniqueConstraint _elem1033;
- for (int _i1034 = 0; _i1034 < _list1032.size; ++_i1034)
+ org.apache.thrift.protocol.TList _list1064 = iprot.readListBegin();
+ struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list1064.size);
+ SQLUniqueConstraint _elem1065;
+ for (int _i1066 = 0; _i1066 < _list1064.size; ++_i1066)
{
- _elem1033 = new SQLUniqueConstraint();
- _elem1033.read(iprot);
- struct.uniqueConstraints.add(_elem1033);
+ _elem1065 = new SQLUniqueConstraint();
+ _elem1065.read(iprot);
+ struct.uniqueConstraints.add(_elem1065);
}
iprot.readListEnd();
}
@@ -57090,14 +57235,14 @@ import org.slf4j.LoggerFactory;
case 5: // NOT_NULL_CONSTRAINTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1035 = iprot.readListBegin();
- struct.notNullConstraints = new ArrayList<SQLNotNullConstraint>(_list1035.size);
- SQLNotNullConstraint _elem1036;
- for (int _i1037 = 0; _i1037 < _list1035.size; ++_i1037)
+ org.apache.thrift.protocol.TList _list1067 = iprot.readListBegin();
+ struct.notNullConstraints = new ArrayList<SQLNotNullConstraint>(_list1067.size);
+ SQLNotNullConstraint _elem1068;
+ for (int _i1069 = 0; _i1069 < _list1067.size; ++_i1069)
{
- _elem1036 = new SQLNotNullConstraint();
- _elem1036.read(iprot);
- struct.notNullConstraints.add(_elem1036);
+ _elem1068 = new SQLNotNullConstraint();
+ _elem1068.read(iprot);
+ struct.notNullConstraints.add(_elem1068);
}
iprot.readListEnd();
}
@@ -57109,14 +57254,14 @@ import org.slf4j.LoggerFactory;
case 6: // DEFAULT_CONSTRAINTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1038 = iprot.readListBegin();
- struct.defaultConstraints = new ArrayList<SQLDefaultConstraint>(_list1038.size);
- SQLDefaultConstraint _elem1039;
- for (int _i1040 = 0; _i1040 < _list1038.size; ++_i1040)
+ org.apache.thrift.protocol.TList _list1070 = iprot.readListBegin();
+ struct.defaultConstraints = new ArrayList<SQLDefaultConstraint>(_list1070.size);
+ SQLDefaultConstraint _elem1071;
+ for (int _i1072 = 0; _i1072 < _list1070.size; ++_i1072)
{
- _elem1039 = new SQLDefaultConstraint();
- _elem1039.read(iprot);
- struct.defaultConstraints.add(_elem1039);
+ _elem1071 = new SQLDefaultConstraint();
+ _elem1071.read(iprot);
+ struct.defaultConstraints.add(_elem1071);
}
iprot.readListEnd();
}
@@ -57128,14 +57273,14 @@ import org.slf4j.LoggerFactory;
case 7: // CHECK_CONSTRAINTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1041 = iprot.readListBegin();
- struct.checkConstraints = new ArrayList<SQLCheckConstraint>(_list1041.size);
- SQLCheckConstraint _elem1042;
- for (int _i1043 = 0; _i1043 < _list1041.size; ++_i1043)
+ org.apache.thrift.protocol.TList _list1073 = iprot.readListBegin();
+ struct.checkConstraints = new ArrayList<SQLCheckConstraint>(_list1073.size);
+ SQLCheckConstraint _elem1074;
+ for (int _i1075 = 0; _i1075 < _list1073.size; ++_i1075)
{
- _elem1042 = new SQLCheckConstraint();
- _elem1042.read(iprot);
- struct.checkConstraints.add(_elem1042);
+ _elem1074 = new SQLCheckConstraint();
+ _elem1074.read(iprot);
+ struct.checkConstraints.add(_elem1074);
}
iprot.readListEnd();
}
@@ -57166,9 +57311,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 _iter1044 : struct.primaryKeys)
+ for (SQLPrimaryKey _iter1076 : struct.primaryKeys)
{
- _iter1044.write(oprot);
+ _iter1076.write(oprot);
}
oprot.writeListEnd();
}
@@ -57178,9 +57323,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 _iter1045 : struct.foreignKeys)
+ for (SQLForeignKey _iter1077 : struct.foreignKeys)
{
- _iter1045.write(oprot);
+ _iter1077.write(oprot);
}
oprot.writeListEnd();
}
@@ -57190,9 +57335,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 _iter1046 : struct.uniqueConstraints)
+ for (SQLUniqueConstraint _iter1078 : struct.uniqueConstraints)
{
- _iter1046.write(oprot);
+ _iter1078.write(oprot);
}
oprot.writeListEnd();
}
@@ -57202,9 +57347,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 _iter1047 : struct.notNullConstraints)
+ for (SQLNotNullConstraint _iter1079 : struct.notNullConstraints)
{
- _iter1047.write(oprot);
+ _iter1079.write(oprot);
}
oprot.writeListEnd();
}
@@ -57214,9 +57359,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(DEFAULT_CONSTRAINTS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.defaultConstraints.size()));
- for (SQLDefaultConstraint _iter1048 : struct.defaultConstraints)
+ for (SQLDefaultConstraint _iter1080 : struct.defaultConstraints)
{
- _iter1048.write(oprot);
+ _iter1080.write(oprot);
}
oprot.writeListEnd();
}
@@ -57226,9 +57371,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(CHECK_CONSTRAINTS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.checkConstraints.size()));
- for (SQLCheckConstraint _iter1049 : struct.checkConstraints)
+ for (SQLCheckConstraint _iter1081 : struct.checkConstraints)
{
- _iter1049.write(oprot);
+ _iter1081.write(oprot);
}
oprot.writeListEnd();
}
@@ -57280,54 +57425,54 @@ import org.slf4j.LoggerFactory;
if (struct.isSetPrimaryKeys()) {
{
oprot.writeI32(struct.primaryKeys.size());
- for (SQLPrimaryKey _iter1050 : struct.primaryKeys)
+ for (SQLPrimaryKey _iter1082 : struct.primaryKeys)
{
- _iter1050.write(oprot);
+ _iter1082.write(oprot);
}
}
}
if (struct.isSetForeignKeys()) {
{
oprot.writeI32(struct.foreignKeys.size());
- for (SQLForeignKey _iter1051 : struct.foreignKeys)
+ for (SQLForeignKey _iter1083 : struct.foreignKeys)
{
- _iter1051.write(oprot);
+ _iter1083.write(oprot);
}
}
}
if (struct.isSetUniqueConstraints()) {
{
oprot.writeI32(struct.uniqueConstraints.size());
- for (SQLUniqueConstraint _iter1052 : struct.uniqueConstraints)
+ for (SQLUniqueConstraint _iter1084 : struct.uniqueConstraints)
{
- _iter1052.write(oprot);
+ _iter1084.write(oprot);
}
}
}
if (struct.isSetNotNullConstraints()) {
{
oprot.writeI32(struct.notNullConstraints.size());
- for (SQLNotNullConstraint _iter1053 : struct.notNullConstraints)
+ for (SQLNotNullConstraint _iter1085 : struct.notNullConstraints)
{
- _iter1053.write(oprot);
+ _iter1085.write(oprot);
}
}
}
if (struct.isSetDefaultConstraints()) {
{
oprot.writeI32(struct.defaultConstraints.size());
- for (SQLDefaultConstraint _iter1054 : struct.defaultConstraints)
+ for (SQLDefaultConstraint _iter1086 : struct.defaultConstraints)
{
- _iter1054.write(oprot);
+ _iter1086.write(oprot);
}
}
}
if (struct.isSetCheckConstraints()) {
{
oprot.writeI32(struct.checkConstraints.size());
- for (SQLCheckConstraint _iter1055 : struct.checkConstraints)
+ for (SQLCheckConstraint _iter1087 : struct.checkConstraints)
{
- _iter1055.write(oprot);
+ _iter1087.write(oprot);
}
}
}
@@ -57344,84 +57489,84 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list1056 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.primaryKeys = new ArrayList<SQLPrimaryKey>(_list1056.size);
- SQLPrimaryKey _elem1057;
- for (int _i1058 = 0; _i1058 < _list1056.size; ++_i1058)
+ org.apache.thrift.protocol.TList _list1088 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.primaryKeys = new ArrayList<SQLPrimaryKey>(_list1088.size);
+ SQLPrimaryKey _elem1089;
+ for (int _i1090 = 0; _i1090 < _list1088.size; ++_i1090)
{
- _elem1057 = new SQLPrimaryKey();
- _elem1057.read(iprot);
- struct.primaryKeys.add(_elem1057);
+ _elem1089 = new SQLPrimaryKey();
+ _elem1089.read(iprot);
+ struct.primaryKeys.add(_elem1089);
}
}
struct.setPrimaryKeysIsSet(true);
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list1059 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.foreignKeys = new ArrayList<SQLForeignKey>(_list1059.size);
- SQLForeignKey _elem1060;
- for (int _i1061 = 0; _i1061 < _list1059.size; ++_i1061)
+ org.apache.thrift.protocol.TList _list1091 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.foreignKeys = new ArrayList<SQLForeignKey>(_list1091.size);
+ SQLForeignKey _elem1092;
+ for (int _i1093 = 0; _i1093 < _list1091.size; ++_i1093)
{
- _elem1060 = new SQLForeignKey();
- _elem1060.read(iprot);
- struct.foreignKeys.add(_elem1060);
+ _elem1092 = new SQLForeignKey();
+ _elem1092.read(iprot);
+ struct.foreignKeys.add(_elem1092);
}
}
struct.setForeignKeysIsSet(true);
}
if (incoming.get(3)) {
{
- org.apache.thrift.protocol.TList _list1062 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list1062.size);
- SQLUniqueConstraint _elem1063;
- for (int _i1064 = 0; _i1064 < _list1062.size; ++_i1064)
+ org.apache.thrift.protocol.TList _list1094 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list1094.size);
+ SQLUniqueConstraint _elem1095;
+ for (int _i1096 = 0; _i1096 < _list1094.size; ++_i1096)
{
- _elem1063 = new SQLUniqueConstraint();
- _elem1063.read(iprot);
- struct.uniqueConstraints.add(_elem1063);
+ _elem1095 = new SQLUniqueConstraint();
+ _elem1095.read(iprot);
+ struct.uniqueConstraints.add(_elem1095);
}
}
struct.setUniqueConstraintsIsSet(true);
}
if (incoming.get(4)) {
{
- org.apache.thrift.protocol.TList _list1065 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.notNullConstraints = new ArrayList<SQLNotNullConstraint>(_list1065.size);
- SQLNotNullConstraint _elem1066;
- for (int _i1067 = 0; _i1067 < _list1065.size; ++_i1067)
+ org.apache.thrift.protocol.TList _list1097 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.notNullConstraints = new ArrayList<SQLNotNullConstraint>(_list1097.size);
+ SQLNotNullConstraint _elem1098;
+ for (int _i1099 = 0; _i1099 < _list1097.size; ++_i1099)
{
- _elem1066 = new SQLNotNullConstraint();
- _elem1066.read(iprot);
- struct.notNullConstraints.add(_elem1066);
+ _elem1098 = new SQLNotNullConstraint();
+ _elem1098.read(iprot);
+ struct.notNullConstraints.add(_elem1098);
}
}
struct.setNotNullConstraintsIsSet(true);
}
if (incoming.get(5)) {
{
- org.apache.thrift.protocol.TList _list1068 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.defaultConstraints = new ArrayList<SQLDefaultConstraint>(_list1068.size);
- SQLDefaultConstraint _elem1069;
- for (int _i1070 = 0; _i1070 < _list1068.size; ++_i1070)
+ org.apache.thrift.protocol.TList _list1100 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.defaultConstraints = new ArrayList<SQLDefaultConstraint>(_list1100.size);
+ SQLDefaultConstraint _elem1101;
+ for (int _i1102 = 0; _i1102 < _list1100.size; ++_i1102)
{
- _elem1069 = new SQLDefaultConstraint();
- _elem1069.read(iprot);
- struct.defaultConstraints.add(_elem1069);
+ _elem1101 = new SQLDefaultConstraint();
+ _elem1101.read(iprot);
+ struct.defaultConstraints.add(_elem1101);
}
}
struct.setDefaultConstraintsIsSet(true);
}
if (incoming.get(6)) {
{
- org.apache.thrift.protocol.TList _list1071 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.checkConstraints = new ArrayList<SQLCheckConstraint>(_list1071.size);
- SQLCheckConstraint _elem1072;
- for (int _i1073 = 0; _i1073 < _list1071.size; ++_i1073)
+ org.apache.thrift.protocol.TList _list1103 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.checkConstraints = new ArrayList<SQLCheckConstraint>(_list1103.size);
+ SQLCheckConstraint _elem1104;
+ for (int _i1105 = 0; _i1105 < _list1103.size; ++_i1105)
{
- _elem1072 = new SQLCheckConstraint();
- _elem1072.read(iprot);
- struct.checkConstraints.add(_elem1072);
+ _elem1104 = new SQLCheckConstraint();
+ _elem1104.read(iprot);
+ struct.checkConstraints.add(_elem1104);
}
}
struct.setCheckConstraintsIsSet(true);
@@ -66571,13 +66716,13 @@ import org.slf4j.LoggerFactory;
case 3: // PART_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1074 = iprot.readListBegin();
- struct.partNames = new ArrayList<String>(_list1074.size);
- String _elem1075;
- for (int _i1076 = 0; _i1076 < _list1074.size; ++_i1076)
+ org.apache.thrift.protocol.TList _list1106 = iprot.readListBegin();
+ struct.partNames = new ArrayList<String>(_list1106.size);
+ String _elem1107;
+ for (int _i1108 = 0; _i1108 < _list1106.size; ++_i1108)
{
- _elem1075 = iprot.readString();
- struct.partNames.add(_elem1075);
+ _elem1107 = iprot.readString();
+ struct.partNames.add(_elem1107);
}
iprot.readListEnd();
}
@@ -66613,9 +66758,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 _iter1077 : struct.partNames)
+ for (String _iter1109 : struct.partNames)
{
- oprot.writeString(_iter1077);
+ oprot.writeString(_iter1109);
}
oprot.writeListEnd();
}
@@ -66658,9 +66803,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetPartNames()) {
{
oprot.writeI32(struct.partNames.size());
- for (String _iter1078 : struct.partNames)
+ for (String _iter1110 : struct.partNames)
{
- oprot.writeString(_iter1078);
+ oprot.writeString(_iter1110);
}
}
}
@@ -66680,13 +66825,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list1079 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.partNames = new ArrayList<String>(_list1079.size);
- String _elem1080;
- for (int _i1081 = 0; _i1081 < _list1079.size; ++_i1081)
+ org.apache.thrift.protocol.TList _list1111 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.partNames = new ArrayList<String>(_list1111.size);
+ String _elem1112;
+ for (int _i1113 = 0; _i1113 < _list1111.size; ++_i1113)
{
- _elem1080 = iprot.readString();
- struct.partNames.add(_elem1080);
+ _elem1112 = iprot.readString();
+ struct.partNames.add(_elem1112);
}
}
struct.setPartNamesIsSet(true);
@@ -68743,13 +68888,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1082 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list1082.size);
- String _elem1083;
- for (int _i1084 = 0; _i1084 < _list1082.size; ++_i1084)
+ org.apache.thrift.protocol.TList _list1114 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list1114.size);
+ String _elem1115;
+ for (int _i1116 = 0; _i1116 < _list1114.size; ++_i1116)
{
- _elem1083 = iprot.readString();
- struct.success.add(_elem1083);
+ _elem1115 = iprot.readString();
+ struct.success.add(_elem1115);
}
iprot.readListEnd();
}
@@ -68784,9 +68929,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 _iter1085 : struct.success)
+ for (String _iter1117 : struct.success)
{
- oprot.writeString(_iter1085);
+ oprot.writeString(_iter1117);
}
oprot.writeListEnd();
}
@@ -68825,9 +68970,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter1086 : struct.success)
+ for (String _iter1118 : struct.success)
{
- oprot.writeString(_iter1086);
+ oprot.writeString(_iter1118);
}
}
}
@@ -68842,13 +68987,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list1087 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list1087.size);
- String _elem1088;
- for (int _i1089 = 0; _i1089 < _list1087.size; ++_i1089)
+ org.apache.thrift.protocol.TList _list1119 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list1119.size);
+ String _elem1120;
+ for (int _i1121 = 0; _i1121 < _list1119.size; ++_i1121)
{
- _elem1088 = iprot.readString();
- struct.success.add(_elem1088);
+ _elem1120 = iprot.readString();
+ struct.success.add(_elem1120);
}
}
struct.setSuccessIsSet(true);
@@ -69822,13 +69967,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1090 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list1090.size);
- String _elem1091;
- for (int _i1092 = 0; _i1092 < _list1090.size; ++_i1092)
+ org.apache.thrift.protocol.TList _list1122 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list1122.size);
+ String _elem1123;
+ for (int _i1124 = 0; _i1124 < _list1122.size; ++_i1124)
{
- _elem1091 = iprot.readString();
- struct.success.add(_elem1091);
+ _elem1123 = iprot.readString();
+ struct.success.add(_elem1123);
}
iprot.readListEnd();
}
@@ -69863,9 +70008,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 _iter1093 : struct.success)
+ for (String _iter1125 : struct.success)
{
- oprot.writeString(_iter1093);
+ oprot.writeString(_iter1125);
}
oprot.writeListEnd();
}
@@ -69904,9 +70049,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter1094 : struct.success)
+ for (String _iter1126 : struct.success)
{
- oprot.writeString(_iter1094);
+ oprot.writeString(_iter1126);
}
}
}
@@ -69921,13 +70066,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list1095 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list1095.size);
- String _elem1096;
- for (int _i1097 = 0; _i1097 < _list1095.size; ++_i1097)
+ org.apache.thrift.protocol.TList _list1127 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list1127.size);
+ String _elem1128;
+ for (int _i1129 = 0; _i1129 < _list1127.size; ++_i1129)
{
- _elem1096 = iprot.readString();
- struct.success.add(_elem1096);
+ _elem1128 = iprot.readString();
+ struct.success.add(_elem1128);
}
}
struct.setSuccessIsSet(true);
@@ -70693,13 +70838,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1098 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list1098.size);
- String _elem1099;
- for (int _i1100 = 0; _i1100 < _list1098.size; ++_i1100)
+ org.apache.thrift.protocol.TList _list1130 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list1130.size);
+ String _elem1131;
+ for (int _i1132 = 0; _i1132 < _list1130.size; ++_i1132)
{
- _elem1099 = iprot.readString();
- struct.success.add(_elem1099);
+ _elem1131 = iprot.readString();
+ struct.success.add(_elem1131);
}
iprot.readListEnd();
}
@@ -70734,9 +70879,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 _iter1101 : struct.success)
+ for (String _iter1133 : struct.success)
{
- oprot.writeString(_iter1101);
+ oprot.writeString(_iter1133);
}
oprot.writeListEnd();
}
@@ -70775,9 +70920,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter1102 : struct.success)
+ for (String _iter1134 : struct.success)
{
- oprot.writeString(_iter1102);
+ oprot.writeString(_iter1134);
}
}
}
@@ -70792,13 +70937,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list1103 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list1103.size);
- String _elem1104;
- for (int _i1105 = 0; _i1105 < _list1103.size; ++_i1105)
+ org.apache.thrift.protocol.TList _list1135 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list1135.size);
+ String _elem1136;
+ for (int _i1137 = 0; _i1137 < _list1135.size; ++_i1137)
{
- _elem1104 = iprot.readString();
- struct.success.add(_elem1104);
+ _elem1136 = iprot.readString();
+ struct.success.add(_elem1136);
}
}
struct.setSuccessIsSet(true);
@@ -71303,13 +71448,13 @@ import org.slf4j.LoggerFactory;
case 3: // TBL_TYPES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1106 = iprot.readListBegin();
- struct.tbl_types = new ArrayList<String>(_list1106.size);
- String _elem1107;
- for (int _i1108 = 0; _i1108 < _list1106.size; ++_i1108)
+ org.apache.thrift.protocol.TList _list1138 = iprot.readListBegin();
+ struct.tbl_types = new ArrayList<String>(_list1138.size);
+ String _elem1139;
+ for (int _i1140 = 0; _i1140 < _list1138.size; ++_i1140)
{
- _elem1107 = iprot.readString();
- struct.tbl_types.add(_elem1107);
+ _elem1139 = iprot.readString();
+ struct.tbl_types.add(_elem1139);
}
iprot.readListEnd();
}
@@ -71345,9 +71490,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 _iter1109 : struct.tbl_types)
+ for (String _iter1141 : struct.tbl_types)
{
- oprot.writeString(_iter1109);
+ oprot.writeString(_iter1141);
}
oprot.writeListEnd();
}
@@ -71390,9 +71535,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetTbl_types()) {
{
oprot.writeI32(struct.tbl_types.size());
- for (String _iter1110 : struct.tbl_types)
+ for (String _iter1142 : struct.tbl_types)
{
- oprot.writeString(_iter1110);
+ oprot.writeString(_iter1142);
}
}
}
@@ -71412,13 +71557,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list1111 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.tbl_types = new ArrayList<String>(_list1111.size);
- String _elem1112;
- for (int _i1113 = 0; _i1113 < _list1111.size; ++_i1113)
+ org.apache.thrift.protocol.TList _list1143 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.tbl_types = new ArrayList<String>(_list1143.size);
+ String _elem1144;
+ for (int _i1145 = 0; _i1145 < _list1143.size; ++_i1145)
{
- _elem1112 = iprot.readString();
- struct.tbl_types.add(_elem1112);
+ _elem1144 = iprot.readString();
+ struct.tbl_types.add(_elem1144);
}
}
struct.setTbl_typesIsSet(true);
@@ -71824,14 +71969,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1114 = iprot.readListBegin();
- struct.success = new ArrayList<TableMeta>(_list1114.size);
- TableMeta _elem1115;
- for (int _i1116 = 0; _i1116 < _list1114.size; ++_i1116)
+ org.apache.thrift.protocol.TList _list1146 = iprot.readListBegin();
+ struct.success = new ArrayList<TableMeta>(_list1146.size);
+ TableMeta _elem1147;
+ for (int _i1148 = 0; _i1148 < _list1146.size; ++_i1148)
{
- _elem1115 = new TableMeta();
- _elem1115.read(iprot);
- struct.success.add(_elem1115);
+ _elem1147 = new TableMeta();
+ _elem1147.read(iprot);
+ struct.success.add(_elem1147);
}
iprot.readListEnd();
}
@@ -71866,9 +72011,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 _iter1117 : struct.success)
+ for (TableMeta _iter1149 : struct.success)
{
- _iter1117.write(oprot);
+ _iter1149.write(oprot);
}
oprot.writeListEnd();
}
@@ -71907,9 +72052,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (TableMeta _iter1118 : struct.success)
+ for (TableMeta _iter1150 : struct.success)
{
- _iter1118.write(oprot);
+ _iter1150.write(oprot);
}
}
}
@@ -71924,14 +72069,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list1119 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<TableMeta>(_list1119.size);
- TableMeta _elem1120;
- for (int _i1121 = 0; _i1121 < _list1119.size; ++_i1121)
+ org.apache.thrift.protocol.TList _list1151 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<TableMeta>(_list1151.size);
+ TableMeta _elem1152;
+ for (int _i1153 = 0; _i1153 < _list1151.size; ++_i1153)
{
- _elem1120 = new TableMeta();
- _elem1120.read(iprot);
- struct.success.add(_elem1120);
+ _elem1152 = new TableMeta();
+ _elem1152.read(iprot);
+ struct.success.add(_elem1152);
}
}
struct.setSuccessIsSet(true);
@@ -72697,13 +72842,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1122 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list1122.size);
- String _elem1123;
- for (int _i1124 = 0; _i1124 < _list1122.size; ++_i1124)
+ org.apache.thrift.protocol.TList _list1154 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list1154.size);
+ String _elem1155;
+ for (int _i1156 = 0; _i1156 < _list1154.size; ++_i1156)
{
- _elem1123 = iprot.readString();
- struct.success.add(_elem1123);
+ _elem1155 = iprot.readString();
+ struct.success.add(_elem1155);
}
iprot.readListEnd();
}
@@ -72738,9 +72883,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 _iter1125 : struct.success)
+ for (String _iter1157 : struct.success)
{
- oprot.writeString(_iter1125);
+ oprot.writeString(_iter1157);
}
oprot.writeListEnd();
}
@@ -72779,9 +72924,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter1126 : struct.success)
+ for (String _iter1158 : struct.success)
{
- oprot.writeString(_iter1126);
+ oprot.writeString(_iter1158);
}
}
}
@@ -72796,13 +72941,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list1127 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list1127.size);
- String _elem1128;
- for (int _i1129 = 0; _i1129 < _list1127.size; ++_i1129)
+ org.apache.thrift.protocol.TList _list1159 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list1159.size);
+ String _elem1160;
+ for (int _i1161 = 0; _i1161 < _list1159.size; ++_i1161)
{
- _elem1128 = iprot.readString();
- struct.success.add(_elem1128);
+ _elem1160 = iprot.readString();
+ struct.success.add(_elem1160);
}
}
struct.setSuccessIsSet(true);
@@ -74255,13 +74400,13 @@ import org.slf4j.LoggerFactory;
case 2: // TBL_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1130 = iprot.readListBegin();
- struct.tbl_names = new ArrayList<String>(_list1130.size);
- String _elem1131;
- for (int _i1132 = 0; _i1132 < _list1130.size; ++_i1132)
+ org.apache.thrift.protocol.TList _list1162 = iprot.readListBegin();
+ struct.tbl_names = new ArrayList<String>(_list1162.size);
+ String _elem1163;
+ for (int _i1164 = 0; _i1164 < _list1162.size; ++_i1164)
{
- _elem1131 = iprot.readString();
- struct.tbl_names.add(_elem1131);
+ _elem1163 = iprot.readString();
+ struct.tbl_names.add(_elem1163);
}
iprot.readListEnd();
}
@@ -74292,9 +74437,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 _iter1133 : struct.tbl_names)
+ for (String _iter1165 : struct.tbl_names)
{
- oprot.writeString(_iter1133);
+ oprot.writeString(_iter1165);
}
oprot.writeListEnd();
}
@@ -74331,9 +74476,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetTbl_names()) {
{
oprot.writeI32(struct.tbl_names.size());
- for (String _iter1134 : struct.tbl_names)
+ for (String _iter1166 : struct.tbl_names)
{
- oprot.writeString(_iter1134);
+ oprot.writeString(_iter1166);
}
}
}
@@ -74349,13 +74494,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list1135 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.tbl_names = new ArrayList<String>(_list1135.size);
- String _elem1136;
- for (int _i1137 = 0; _i1137 < _list1135.size; ++_i1137)
+ org.apache.thrift.protocol.TList _list1167 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.tbl_names = new ArrayList<String>(_list1167.size);
+ String _elem1168;
+ for (int _i1169 = 0; _i1169 < _list1167.size; ++_i1169)
{
- _elem1136 = iprot.readString();
- struct.tbl_names.add(_elem1136);
+ _elem1168 = iprot.readString();
+ struct.tbl_names.add(_elem1168);
}
}
struct.setTbl_namesIsSet(true);
@@ -74680,14 +74825,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1138 = iprot.readListBegin();
- struct.success = new ArrayList<Table>(_list1138.size);
- Table _elem1139;
- for (int _i1140 = 0; _i1140 < _list1138.size; ++_i1140)
+ org.apache.thrift.protocol.TList _list1170 = iprot.readListBegin();
+ struct.success = new ArrayList<Table>(_list1170.size);
+ Table _elem1171;
+ for (int _i1172 = 0; _i1172 < _list1170.size; ++_i1172)
{
- _elem1139 = new Table();
- _elem1139.read(iprot);
- struct.success.add(_elem1139);
+ _elem1171 = new Table();
+ _elem1171.read(iprot);
+ struct.success.add(_elem1171);
}
iprot.readListEnd();
}
@@ -74713,9 +74858,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 _iter1141 : struct.success)
+ for (Table _iter1173 : struct.success)
{
- _iter1141.write(oprot);
+ _iter1173.write(oprot);
}
oprot.writeListEnd();
}
@@ -74746,9 +74891,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Table _iter1142 : struct.success)
+ for (Table _iter1174 : struct.success)
{
- _iter1142.write(oprot);
+ _iter1174.write(oprot);
}
}
}
@@ -74760,14 +74905,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list1143 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<Table>(_list1143.size);
- Table _elem1144;
- for (int _i1145 = 0; _i1145 < _list1143.size; ++_i1145)
+ org.apache.thrift.protocol.TList _list1175 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<Table>(_list1175.size);
+ Table _elem1176;
+ for (int _i1177 = 0; _i1177 < _list1175.size; ++_i1177)
{
- _elem1144 = new Table();
- _elem1144.read(iprot);
- struct.success.add(_elem1144);
+ _elem1176 = new Table();
+ _elem1176.read(iprot);
+ struct.success.add(_elem1176);
}
}
struct.setSuccessIsSet(true);
@@ -80275,13 +80420,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1146 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list1146.size);
- String _elem1147;
- for (int _i1148 = 0; _i1148 < _list1146.size; ++_i1148)
+ org.apache.thrift.protocol.TList _list1178 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list1178.size);
+ String _elem1179;
+ for (int _i1180 = 0; _i1180 < _list1178.size; ++_i1180)
{
- _elem1147 = iprot.readString();
- struct.success.add(_elem1147);
+ _elem1179 = iprot.readString();
+ struct.success.add(_elem1179);
}
iprot.readListEnd();
}
@@ -80334,9 +80479,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 _iter1149 : struct.success)
+ for (String _iter1181 : struct.success)
{
- oprot.writeString(_iter1149);
+ oprot.writeString(_iter1181);
}
oprot.writeListEnd();
}
@@ -80391,9 +80536,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter1150 : struct.success)
+ for (String _iter1182 : struct.success)
{
- oprot.writeString(_iter1150);
+ oprot.writeString(_iter1182);
}
}
}
@@ -80414,13 +80559,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list1151 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list1151.size);
- String _elem1152;
- for (int _i1153 = 0; _i1153 < _list1151.size; ++_i1153)
+ org.apache.thrift.protocol.TList _list1183 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list1183.size);
+ String _elem1184;
+ for (int _i1185 = 0; _i1185 < _list1183.size; ++_i1185)
{
- _elem1152 = iprot.readString();
- struct.success.add(_elem1152);
+ _elem1184 = iprot.readString();
+ struct.success.add(_elem1184);
}
}
struct.setSuccessIsSet(true);
@@ -87217,14 +87362,14 @@ import org.slf4j.LoggerFactory;
case 1: // NEW_PARTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1154 = iprot.readListBegin();
- struct.new_parts = new ArrayList<Partition>(_list1154.size);
- Partition _elem1155;
- for (int _i1156 = 0; _i1156 < _list1154.size; ++_i1156)
+ org.apache.thrift.protocol.TList _list1186 = iprot.readListBegin();
+ struct.new_parts = new ArrayList<Partition>(_list1186.size);
+ Partition _elem1187;
+ for (int _i1188 = 0; _i1188 < _list1186.size; ++_i1188)
{
- _elem1155 = new Partition();
- _elem1155.read(iprot);
- struct.new_parts.add(_elem1155);
+ _elem1187 = new Partition();
+ _elem1187.read(iprot);
+ struct.new_parts.add(_elem1187);
}
iprot.readListEnd();
}
@@ -87250,9 +87395,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(NEW_PARTS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.new_parts.size()));
- for (Partition _iter1157 : struct.new_parts)
+ for (Partition _iter1189 : struct.new_parts)
{
- _iter1157.write(oprot);
+ _iter1189.write(oprot);
}
oprot.writeListEnd();
}
@@ -87283,9 +87428,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetNew_parts()) {
{
oprot.writeI32(struct.new_parts.size());
- for (Partition _iter1158 : struct.new_parts)
+ for (Partition _iter1190 : struct.new_parts)
{
- _iter1158.write(oprot);
+ _iter1190.write(oprot);
}
}
}
@@ -87297,14 +87442,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list1159 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.new_parts = new ArrayList<Partition>(_list1159.size);
- Partition _elem1160;
- for (int _i1161 = 0; _i1161 < _list1159.size; ++_i1161)
+ org.apache.thrift.protocol.TList _list1191 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.new_parts = new ArrayList<Partition>(_list1191.size);
+ Partition _elem1192;
+ for (int _i1193 = 0; _i1193 < _list1191.size; ++_i1193)
{
- _elem1160 = new Partition();
- _elem1160.read(iprot);
- struct.new_parts.add(_elem1160);
+ _elem1192 = new Partition();
+ _elem1192.read(iprot);
+ struct.new_parts.add(_elem1192);
}
}
struct.setNew_partsIsSet(true);
@@ -88305,14 +88450,14 @@ import org.slf4j.LoggerFactory;
case 1: // NEW_PARTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1162 = iprot.readListBegin();
- struct.new_parts = new ArrayList<PartitionSpec>(_list1162.size);
- PartitionSpec _elem1163;
- for (int _i1164 = 0; _i1164 < _list1162.size; ++_i1164)
<TRUNCATED>