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/07/24 11:43:08 UTC
[12/19] hive git commit: HIVE-19267: Replicate ACID/MM tables write
operations (Mahesh Kumar Behera, reviewed by Sankar Hariappan)
http://git-wip-us.apache.org/repos/asf/hive/blob/bf5791cd/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 b7a9d58..24ffadb 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
@@ -372,6 +372,8 @@ import org.slf4j.LoggerFactory;
public void flushCache() throws org.apache.thrift.TException;
+ public WriteNotificationLogResponse add_write_notification_log(WriteNotificationLogRequest rqst) throws org.apache.thrift.TException;
+
public CmRecycleResponse cm_recycle(CmRecycleRequest request) throws MetaException, org.apache.thrift.TException;
public GetFileMetadataByExprResult get_file_metadata_by_expr(GetFileMetadataByExprRequest req) throws org.apache.thrift.TException;
@@ -790,6 +792,8 @@ import org.slf4j.LoggerFactory;
public void flushCache(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void add_write_notification_log(WriteNotificationLogRequest rqst, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
public void cm_recycle(CmRecycleRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void get_file_metadata_by_expr(GetFileMetadataByExprRequest req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
@@ -5644,6 +5648,29 @@ import org.slf4j.LoggerFactory;
return;
}
+ public WriteNotificationLogResponse add_write_notification_log(WriteNotificationLogRequest rqst) throws org.apache.thrift.TException
+ {
+ send_add_write_notification_log(rqst);
+ return recv_add_write_notification_log();
+ }
+
+ public void send_add_write_notification_log(WriteNotificationLogRequest rqst) throws org.apache.thrift.TException
+ {
+ add_write_notification_log_args args = new add_write_notification_log_args();
+ args.setRqst(rqst);
+ sendBase("add_write_notification_log", args);
+ }
+
+ public WriteNotificationLogResponse recv_add_write_notification_log() throws org.apache.thrift.TException
+ {
+ add_write_notification_log_result result = new add_write_notification_log_result();
+ receiveBase(result, "add_write_notification_log");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "add_write_notification_log failed: unknown result");
+ }
+
public CmRecycleResponse cm_recycle(CmRecycleRequest request) throws MetaException, org.apache.thrift.TException
{
send_cm_recycle(request);
@@ -12619,6 +12646,38 @@ import org.slf4j.LoggerFactory;
}
}
+ public void add_write_notification_log(WriteNotificationLogRequest rqst, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ add_write_notification_log_call method_call = new add_write_notification_log_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 add_write_notification_log_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private WriteNotificationLogRequest rqst;
+ public add_write_notification_log_call(WriteNotificationLogRequest 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("add_write_notification_log", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ add_write_notification_log_args args = new add_write_notification_log_args();
+ args.setRqst(rqst);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public WriteNotificationLogResponse getResult() throws 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_add_write_notification_log();
+ }
+ }
+
public void cm_recycle(CmRecycleRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
cm_recycle_call method_call = new cm_recycle_call(request, resultHandler, this, ___protocolFactory, ___transport);
@@ -14150,6 +14209,7 @@ import org.slf4j.LoggerFactory;
processMap.put("get_notification_events_count", new get_notification_events_count());
processMap.put("fire_listener_event", new fire_listener_event());
processMap.put("flushCache", new flushCache());
+ processMap.put("add_write_notification_log", new add_write_notification_log());
processMap.put("cm_recycle", new cm_recycle());
processMap.put("get_file_metadata_by_expr", new get_file_metadata_by_expr());
processMap.put("get_file_metadata", new get_file_metadata());
@@ -18426,6 +18486,26 @@ import org.slf4j.LoggerFactory;
}
}
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class add_write_notification_log<I extends Iface> extends org.apache.thrift.ProcessFunction<I, add_write_notification_log_args> {
+ public add_write_notification_log() {
+ super("add_write_notification_log");
+ }
+
+ public add_write_notification_log_args getEmptyArgsInstance() {
+ return new add_write_notification_log_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public add_write_notification_log_result getResult(I iface, add_write_notification_log_args args) throws org.apache.thrift.TException {
+ add_write_notification_log_result result = new add_write_notification_log_result();
+ result.success = iface.add_write_notification_log(args.rqst);
+ return result;
+ }
+ }
+
@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class cm_recycle<I extends Iface> extends org.apache.thrift.ProcessFunction<I, cm_recycle_args> {
public cm_recycle() {
super("cm_recycle");
@@ -19683,6 +19763,7 @@ import org.slf4j.LoggerFactory;
processMap.put("get_notification_events_count", new get_notification_events_count());
processMap.put("fire_listener_event", new fire_listener_event());
processMap.put("flushCache", new flushCache());
+ processMap.put("add_write_notification_log", new add_write_notification_log());
processMap.put("cm_recycle", new cm_recycle());
processMap.put("get_file_metadata_by_expr", new get_file_metadata_by_expr());
processMap.put("get_file_metadata", new get_file_metadata());
@@ -29810,6 +29891,57 @@ import org.slf4j.LoggerFactory;
}
}
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class add_write_notification_log<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, add_write_notification_log_args, WriteNotificationLogResponse> {
+ public add_write_notification_log() {
+ super("add_write_notification_log");
+ }
+
+ public add_write_notification_log_args getEmptyArgsInstance() {
+ return new add_write_notification_log_args();
+ }
+
+ public AsyncMethodCallback<WriteNotificationLogResponse> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.thrift.AsyncProcessFunction fcall = this;
+ return new AsyncMethodCallback<WriteNotificationLogResponse>() {
+ public void onComplete(WriteNotificationLogResponse o) {
+ add_write_notification_log_result result = new add_write_notification_log_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;
+ add_write_notification_log_result result = new add_write_notification_log_result();
+ {
+ 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, add_write_notification_log_args args, org.apache.thrift.async.AsyncMethodCallback<WriteNotificationLogResponse> resultHandler) throws TException {
+ iface.add_write_notification_log(args.rqst,resultHandler);
+ }
+ }
+
@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class cm_recycle<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, cm_recycle_args, CmRecycleResponse> {
public cm_recycle() {
super("cm_recycle");
@@ -42252,13 +42384,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list920 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list920.size);
- String _elem921;
- for (int _i922 = 0; _i922 < _list920.size; ++_i922)
+ org.apache.thrift.protocol.TList _list944 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list944.size);
+ String _elem945;
+ for (int _i946 = 0; _i946 < _list944.size; ++_i946)
{
- _elem921 = iprot.readString();
- struct.success.add(_elem921);
+ _elem945 = iprot.readString();
+ struct.success.add(_elem945);
}
iprot.readListEnd();
}
@@ -42293,9 +42425,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 _iter923 : struct.success)
+ for (String _iter947 : struct.success)
{
- oprot.writeString(_iter923);
+ oprot.writeString(_iter947);
}
oprot.writeListEnd();
}
@@ -42334,9 +42466,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter924 : struct.success)
+ for (String _iter948 : struct.success)
{
- oprot.writeString(_iter924);
+ oprot.writeString(_iter948);
}
}
}
@@ -42351,13 +42483,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list925 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list925.size);
- String _elem926;
- for (int _i927 = 0; _i927 < _list925.size; ++_i927)
+ org.apache.thrift.protocol.TList _list949 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list949.size);
+ String _elem950;
+ for (int _i951 = 0; _i951 < _list949.size; ++_i951)
{
- _elem926 = iprot.readString();
- struct.success.add(_elem926);
+ _elem950 = iprot.readString();
+ struct.success.add(_elem950);
}
}
struct.setSuccessIsSet(true);
@@ -43011,13 +43143,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list928 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list928.size);
- String _elem929;
- for (int _i930 = 0; _i930 < _list928.size; ++_i930)
+ org.apache.thrift.protocol.TList _list952 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list952.size);
+ String _elem953;
+ for (int _i954 = 0; _i954 < _list952.size; ++_i954)
{
- _elem929 = iprot.readString();
- struct.success.add(_elem929);
+ _elem953 = iprot.readString();
+ struct.success.add(_elem953);
}
iprot.readListEnd();
}
@@ -43052,9 +43184,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 _iter931 : struct.success)
+ for (String _iter955 : struct.success)
{
- oprot.writeString(_iter931);
+ oprot.writeString(_iter955);
}
oprot.writeListEnd();
}
@@ -43093,9 +43225,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter932 : struct.success)
+ for (String _iter956 : struct.success)
{
- oprot.writeString(_iter932);
+ oprot.writeString(_iter956);
}
}
}
@@ -43110,13 +43242,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list933 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list933.size);
- String _elem934;
- for (int _i935 = 0; _i935 < _list933.size; ++_i935)
+ org.apache.thrift.protocol.TList _list957 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list957.size);
+ String _elem958;
+ for (int _i959 = 0; _i959 < _list957.size; ++_i959)
{
- _elem934 = iprot.readString();
- struct.success.add(_elem934);
+ _elem958 = iprot.readString();
+ struct.success.add(_elem958);
}
}
struct.setSuccessIsSet(true);
@@ -47723,16 +47855,16 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map936 = iprot.readMapBegin();
- struct.success = new HashMap<String,Type>(2*_map936.size);
- String _key937;
- Type _val938;
- for (int _i939 = 0; _i939 < _map936.size; ++_i939)
+ org.apache.thrift.protocol.TMap _map960 = iprot.readMapBegin();
+ struct.success = new HashMap<String,Type>(2*_map960.size);
+ String _key961;
+ Type _val962;
+ for (int _i963 = 0; _i963 < _map960.size; ++_i963)
{
- _key937 = iprot.readString();
- _val938 = new Type();
- _val938.read(iprot);
- struct.success.put(_key937, _val938);
+ _key961 = iprot.readString();
+ _val962 = new Type();
+ _val962.read(iprot);
+ struct.success.put(_key961, _val962);
}
iprot.readMapEnd();
}
@@ -47767,10 +47899,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> _iter940 : struct.success.entrySet())
+ for (Map.Entry<String, Type> _iter964 : struct.success.entrySet())
{
- oprot.writeString(_iter940.getKey());
- _iter940.getValue().write(oprot);
+ oprot.writeString(_iter964.getKey());
+ _iter964.getValue().write(oprot);
}
oprot.writeMapEnd();
}
@@ -47809,10 +47941,10 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Map.Entry<String, Type> _iter941 : struct.success.entrySet())
+ for (Map.Entry<String, Type> _iter965 : struct.success.entrySet())
{
- oprot.writeString(_iter941.getKey());
- _iter941.getValue().write(oprot);
+ oprot.writeString(_iter965.getKey());
+ _iter965.getValue().write(oprot);
}
}
}
@@ -47827,16 +47959,16 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TMap _map942 = 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*_map942.size);
- String _key943;
- Type _val944;
- for (int _i945 = 0; _i945 < _map942.size; ++_i945)
+ org.apache.thrift.protocol.TMap _map966 = 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*_map966.size);
+ String _key967;
+ Type _val968;
+ for (int _i969 = 0; _i969 < _map966.size; ++_i969)
{
- _key943 = iprot.readString();
- _val944 = new Type();
- _val944.read(iprot);
- struct.success.put(_key943, _val944);
+ _key967 = iprot.readString();
+ _val968 = new Type();
+ _val968.read(iprot);
+ struct.success.put(_key967, _val968);
}
}
struct.setSuccessIsSet(true);
@@ -48871,14 +49003,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list946 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list946.size);
- FieldSchema _elem947;
- for (int _i948 = 0; _i948 < _list946.size; ++_i948)
+ org.apache.thrift.protocol.TList _list970 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list970.size);
+ FieldSchema _elem971;
+ for (int _i972 = 0; _i972 < _list970.size; ++_i972)
{
- _elem947 = new FieldSchema();
- _elem947.read(iprot);
- struct.success.add(_elem947);
+ _elem971 = new FieldSchema();
+ _elem971.read(iprot);
+ struct.success.add(_elem971);
}
iprot.readListEnd();
}
@@ -48931,9 +49063,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 _iter949 : struct.success)
+ for (FieldSchema _iter973 : struct.success)
{
- _iter949.write(oprot);
+ _iter973.write(oprot);
}
oprot.writeListEnd();
}
@@ -48988,9 +49120,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter950 : struct.success)
+ for (FieldSchema _iter974 : struct.success)
{
- _iter950.write(oprot);
+ _iter974.write(oprot);
}
}
}
@@ -49011,14 +49143,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list951 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list951.size);
- FieldSchema _elem952;
- for (int _i953 = 0; _i953 < _list951.size; ++_i953)
+ org.apache.thrift.protocol.TList _list975 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list975.size);
+ FieldSchema _elem976;
+ for (int _i977 = 0; _i977 < _list975.size; ++_i977)
{
- _elem952 = new FieldSchema();
- _elem952.read(iprot);
- struct.success.add(_elem952);
+ _elem976 = new FieldSchema();
+ _elem976.read(iprot);
+ struct.success.add(_elem976);
}
}
struct.setSuccessIsSet(true);
@@ -50172,14 +50304,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list954 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list954.size);
- FieldSchema _elem955;
- for (int _i956 = 0; _i956 < _list954.size; ++_i956)
+ org.apache.thrift.protocol.TList _list978 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list978.size);
+ FieldSchema _elem979;
+ for (int _i980 = 0; _i980 < _list978.size; ++_i980)
{
- _elem955 = new FieldSchema();
- _elem955.read(iprot);
- struct.success.add(_elem955);
+ _elem979 = new FieldSchema();
+ _elem979.read(iprot);
+ struct.success.add(_elem979);
}
iprot.readListEnd();
}
@@ -50232,9 +50364,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 _iter957 : struct.success)
+ for (FieldSchema _iter981 : struct.success)
{
- _iter957.write(oprot);
+ _iter981.write(oprot);
}
oprot.writeListEnd();
}
@@ -50289,9 +50421,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter958 : struct.success)
+ for (FieldSchema _iter982 : struct.success)
{
- _iter958.write(oprot);
+ _iter982.write(oprot);
}
}
}
@@ -50312,14 +50444,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list959 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list959.size);
- FieldSchema _elem960;
- for (int _i961 = 0; _i961 < _list959.size; ++_i961)
+ org.apache.thrift.protocol.TList _list983 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list983.size);
+ FieldSchema _elem984;
+ for (int _i985 = 0; _i985 < _list983.size; ++_i985)
{
- _elem960 = new FieldSchema();
- _elem960.read(iprot);
- struct.success.add(_elem960);
+ _elem984 = new FieldSchema();
+ _elem984.read(iprot);
+ struct.success.add(_elem984);
}
}
struct.setSuccessIsSet(true);
@@ -51364,14 +51496,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list962 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list962.size);
- FieldSchema _elem963;
- for (int _i964 = 0; _i964 < _list962.size; ++_i964)
+ org.apache.thrift.protocol.TList _list986 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list986.size);
+ FieldSchema _elem987;
+ for (int _i988 = 0; _i988 < _list986.size; ++_i988)
{
- _elem963 = new FieldSchema();
- _elem963.read(iprot);
- struct.success.add(_elem963);
+ _elem987 = new FieldSchema();
+ _elem987.read(iprot);
+ struct.success.add(_elem987);
}
iprot.readListEnd();
}
@@ -51424,9 +51556,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 _iter965 : struct.success)
+ for (FieldSchema _iter989 : struct.success)
{
- _iter965.write(oprot);
+ _iter989.write(oprot);
}
oprot.writeListEnd();
}
@@ -51481,9 +51613,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter966 : struct.success)
+ for (FieldSchema _iter990 : struct.success)
{
- _iter966.write(oprot);
+ _iter990.write(oprot);
}
}
}
@@ -51504,14 +51636,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list967 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list967.size);
- FieldSchema _elem968;
- for (int _i969 = 0; _i969 < _list967.size; ++_i969)
+ org.apache.thrift.protocol.TList _list991 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list991.size);
+ FieldSchema _elem992;
+ for (int _i993 = 0; _i993 < _list991.size; ++_i993)
{
- _elem968 = new FieldSchema();
- _elem968.read(iprot);
- struct.success.add(_elem968);
+ _elem992 = new FieldSchema();
+ _elem992.read(iprot);
+ struct.success.add(_elem992);
}
}
struct.setSuccessIsSet(true);
@@ -52665,14 +52797,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list970 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list970.size);
- FieldSchema _elem971;
- for (int _i972 = 0; _i972 < _list970.size; ++_i972)
+ 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)
{
- _elem971 = new FieldSchema();
- _elem971.read(iprot);
- struct.success.add(_elem971);
+ _elem995 = new FieldSchema();
+ _elem995.read(iprot);
+ struct.success.add(_elem995);
}
iprot.readListEnd();
}
@@ -52725,9 +52857,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 _iter973 : struct.success)
+ for (FieldSchema _iter997 : struct.success)
{
- _iter973.write(oprot);
+ _iter997.write(oprot);
}
oprot.writeListEnd();
}
@@ -52782,9 +52914,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter974 : struct.success)
+ for (FieldSchema _iter998 : struct.success)
{
- _iter974.write(oprot);
+ _iter998.write(oprot);
}
}
}
@@ -52805,14 +52937,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list975 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list975.size);
- FieldSchema _elem976;
- for (int _i977 = 0; _i977 < _list975.size; ++_i977)
+ 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)
{
- _elem976 = new FieldSchema();
- _elem976.read(iprot);
- struct.success.add(_elem976);
+ _elem1000 = new FieldSchema();
+ _elem1000.read(iprot);
+ struct.success.add(_elem1000);
}
}
struct.setSuccessIsSet(true);
@@ -55941,14 +56073,14 @@ import org.slf4j.LoggerFactory;
case 2: // PRIMARY_KEYS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list978 = iprot.readListBegin();
- struct.primaryKeys = new ArrayList<SQLPrimaryKey>(_list978.size);
- SQLPrimaryKey _elem979;
- for (int _i980 = 0; _i980 < _list978.size; ++_i980)
+ org.apache.thrift.protocol.TList _list1002 = iprot.readListBegin();
+ struct.primaryKeys = new ArrayList<SQLPrimaryKey>(_list1002.size);
+ SQLPrimaryKey _elem1003;
+ for (int _i1004 = 0; _i1004 < _list1002.size; ++_i1004)
{
- _elem979 = new SQLPrimaryKey();
- _elem979.read(iprot);
- struct.primaryKeys.add(_elem979);
+ _elem1003 = new SQLPrimaryKey();
+ _elem1003.read(iprot);
+ struct.primaryKeys.add(_elem1003);
}
iprot.readListEnd();
}
@@ -55960,14 +56092,14 @@ import org.slf4j.LoggerFactory;
case 3: // FOREIGN_KEYS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list981 = iprot.readListBegin();
- struct.foreignKeys = new ArrayList<SQLForeignKey>(_list981.size);
- SQLForeignKey _elem982;
- for (int _i983 = 0; _i983 < _list981.size; ++_i983)
+ org.apache.thrift.protocol.TList _list1005 = iprot.readListBegin();
+ struct.foreignKeys = new ArrayList<SQLForeignKey>(_list1005.size);
+ SQLForeignKey _elem1006;
+ for (int _i1007 = 0; _i1007 < _list1005.size; ++_i1007)
{
- _elem982 = new SQLForeignKey();
- _elem982.read(iprot);
- struct.foreignKeys.add(_elem982);
+ _elem1006 = new SQLForeignKey();
+ _elem1006.read(iprot);
+ struct.foreignKeys.add(_elem1006);
}
iprot.readListEnd();
}
@@ -55979,14 +56111,14 @@ import org.slf4j.LoggerFactory;
case 4: // UNIQUE_CONSTRAINTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list984 = iprot.readListBegin();
- struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list984.size);
- SQLUniqueConstraint _elem985;
- for (int _i986 = 0; _i986 < _list984.size; ++_i986)
+ org.apache.thrift.protocol.TList _list1008 = iprot.readListBegin();
+ struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list1008.size);
+ SQLUniqueConstraint _elem1009;
+ for (int _i1010 = 0; _i1010 < _list1008.size; ++_i1010)
{
- _elem985 = new SQLUniqueConstraint();
- _elem985.read(iprot);
- struct.uniqueConstraints.add(_elem985);
+ _elem1009 = new SQLUniqueConstraint();
+ _elem1009.read(iprot);
+ struct.uniqueConstraints.add(_elem1009);
}
iprot.readListEnd();
}
@@ -55998,14 +56130,14 @@ import org.slf4j.LoggerFactory;
case 5: // NOT_NULL_CONSTRAINTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list987 = iprot.readListBegin();
- struct.notNullConstraints = new ArrayList<SQLNotNullConstraint>(_list987.size);
- SQLNotNullConstraint _elem988;
- for (int _i989 = 0; _i989 < _list987.size; ++_i989)
+ org.apache.thrift.protocol.TList _list1011 = iprot.readListBegin();
+ struct.notNullConstraints = new ArrayList<SQLNotNullConstraint>(_list1011.size);
+ SQLNotNullConstraint _elem1012;
+ for (int _i1013 = 0; _i1013 < _list1011.size; ++_i1013)
{
- _elem988 = new SQLNotNullConstraint();
- _elem988.read(iprot);
- struct.notNullConstraints.add(_elem988);
+ _elem1012 = new SQLNotNullConstraint();
+ _elem1012.read(iprot);
+ struct.notNullConstraints.add(_elem1012);
}
iprot.readListEnd();
}
@@ -56017,14 +56149,14 @@ import org.slf4j.LoggerFactory;
case 6: // DEFAULT_CONSTRAINTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list990 = iprot.readListBegin();
- struct.defaultConstraints = new ArrayList<SQLDefaultConstraint>(_list990.size);
- SQLDefaultConstraint _elem991;
- for (int _i992 = 0; _i992 < _list990.size; ++_i992)
+ org.apache.thrift.protocol.TList _list1014 = iprot.readListBegin();
+ struct.defaultConstraints = new ArrayList<SQLDefaultConstraint>(_list1014.size);
+ SQLDefaultConstraint _elem1015;
+ for (int _i1016 = 0; _i1016 < _list1014.size; ++_i1016)
{
- _elem991 = new SQLDefaultConstraint();
- _elem991.read(iprot);
- struct.defaultConstraints.add(_elem991);
+ _elem1015 = new SQLDefaultConstraint();
+ _elem1015.read(iprot);
+ struct.defaultConstraints.add(_elem1015);
}
iprot.readListEnd();
}
@@ -56036,14 +56168,14 @@ import org.slf4j.LoggerFactory;
case 7: // CHECK_CONSTRAINTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list993 = iprot.readListBegin();
- struct.checkConstraints = new ArrayList<SQLCheckConstraint>(_list993.size);
- SQLCheckConstraint _elem994;
- for (int _i995 = 0; _i995 < _list993.size; ++_i995)
+ org.apache.thrift.protocol.TList _list1017 = iprot.readListBegin();
+ struct.checkConstraints = new ArrayList<SQLCheckConstraint>(_list1017.size);
+ SQLCheckConstraint _elem1018;
+ for (int _i1019 = 0; _i1019 < _list1017.size; ++_i1019)
{
- _elem994 = new SQLCheckConstraint();
- _elem994.read(iprot);
- struct.checkConstraints.add(_elem994);
+ _elem1018 = new SQLCheckConstraint();
+ _elem1018.read(iprot);
+ struct.checkConstraints.add(_elem1018);
}
iprot.readListEnd();
}
@@ -56074,9 +56206,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 _iter996 : struct.primaryKeys)
+ for (SQLPrimaryKey _iter1020 : struct.primaryKeys)
{
- _iter996.write(oprot);
+ _iter1020.write(oprot);
}
oprot.writeListEnd();
}
@@ -56086,9 +56218,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 _iter997 : struct.foreignKeys)
+ for (SQLForeignKey _iter1021 : struct.foreignKeys)
{
- _iter997.write(oprot);
+ _iter1021.write(oprot);
}
oprot.writeListEnd();
}
@@ -56098,9 +56230,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 _iter998 : struct.uniqueConstraints)
+ for (SQLUniqueConstraint _iter1022 : struct.uniqueConstraints)
{
- _iter998.write(oprot);
+ _iter1022.write(oprot);
}
oprot.writeListEnd();
}
@@ -56110,9 +56242,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 _iter999 : struct.notNullConstraints)
+ for (SQLNotNullConstraint _iter1023 : struct.notNullConstraints)
{
- _iter999.write(oprot);
+ _iter1023.write(oprot);
}
oprot.writeListEnd();
}
@@ -56122,9 +56254,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 _iter1000 : struct.defaultConstraints)
+ for (SQLDefaultConstraint _iter1024 : struct.defaultConstraints)
{
- _iter1000.write(oprot);
+ _iter1024.write(oprot);
}
oprot.writeListEnd();
}
@@ -56134,9 +56266,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 _iter1001 : struct.checkConstraints)
+ for (SQLCheckConstraint _iter1025 : struct.checkConstraints)
{
- _iter1001.write(oprot);
+ _iter1025.write(oprot);
}
oprot.writeListEnd();
}
@@ -56188,54 +56320,54 @@ import org.slf4j.LoggerFactory;
if (struct.isSetPrimaryKeys()) {
{
oprot.writeI32(struct.primaryKeys.size());
- for (SQLPrimaryKey _iter1002 : struct.primaryKeys)
+ for (SQLPrimaryKey _iter1026 : struct.primaryKeys)
{
- _iter1002.write(oprot);
+ _iter1026.write(oprot);
}
}
}
if (struct.isSetForeignKeys()) {
{
oprot.writeI32(struct.foreignKeys.size());
- for (SQLForeignKey _iter1003 : struct.foreignKeys)
+ for (SQLForeignKey _iter1027 : struct.foreignKeys)
{
- _iter1003.write(oprot);
+ _iter1027.write(oprot);
}
}
}
if (struct.isSetUniqueConstraints()) {
{
oprot.writeI32(struct.uniqueConstraints.size());
- for (SQLUniqueConstraint _iter1004 : struct.uniqueConstraints)
+ for (SQLUniqueConstraint _iter1028 : struct.uniqueConstraints)
{
- _iter1004.write(oprot);
+ _iter1028.write(oprot);
}
}
}
if (struct.isSetNotNullConstraints()) {
{
oprot.writeI32(struct.notNullConstraints.size());
- for (SQLNotNullConstraint _iter1005 : struct.notNullConstraints)
+ for (SQLNotNullConstraint _iter1029 : struct.notNullConstraints)
{
- _iter1005.write(oprot);
+ _iter1029.write(oprot);
}
}
}
if (struct.isSetDefaultConstraints()) {
{
oprot.writeI32(struct.defaultConstraints.size());
- for (SQLDefaultConstraint _iter1006 : struct.defaultConstraints)
+ for (SQLDefaultConstraint _iter1030 : struct.defaultConstraints)
{
- _iter1006.write(oprot);
+ _iter1030.write(oprot);
}
}
}
if (struct.isSetCheckConstraints()) {
{
oprot.writeI32(struct.checkConstraints.size());
- for (SQLCheckConstraint _iter1007 : struct.checkConstraints)
+ for (SQLCheckConstraint _iter1031 : struct.checkConstraints)
{
- _iter1007.write(oprot);
+ _iter1031.write(oprot);
}
}
}
@@ -56252,84 +56384,84 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list1008 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.primaryKeys = new ArrayList<SQLPrimaryKey>(_list1008.size);
- SQLPrimaryKey _elem1009;
- for (int _i1010 = 0; _i1010 < _list1008.size; ++_i1010)
+ org.apache.thrift.protocol.TList _list1032 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.primaryKeys = new ArrayList<SQLPrimaryKey>(_list1032.size);
+ SQLPrimaryKey _elem1033;
+ for (int _i1034 = 0; _i1034 < _list1032.size; ++_i1034)
{
- _elem1009 = new SQLPrimaryKey();
- _elem1009.read(iprot);
- struct.primaryKeys.add(_elem1009);
+ _elem1033 = new SQLPrimaryKey();
+ _elem1033.read(iprot);
+ struct.primaryKeys.add(_elem1033);
}
}
struct.setPrimaryKeysIsSet(true);
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list1011 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.foreignKeys = new ArrayList<SQLForeignKey>(_list1011.size);
- SQLForeignKey _elem1012;
- for (int _i1013 = 0; _i1013 < _list1011.size; ++_i1013)
+ org.apache.thrift.protocol.TList _list1035 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.foreignKeys = new ArrayList<SQLForeignKey>(_list1035.size);
+ SQLForeignKey _elem1036;
+ for (int _i1037 = 0; _i1037 < _list1035.size; ++_i1037)
{
- _elem1012 = new SQLForeignKey();
- _elem1012.read(iprot);
- struct.foreignKeys.add(_elem1012);
+ _elem1036 = new SQLForeignKey();
+ _elem1036.read(iprot);
+ struct.foreignKeys.add(_elem1036);
}
}
struct.setForeignKeysIsSet(true);
}
if (incoming.get(3)) {
{
- org.apache.thrift.protocol.TList _list1014 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list1014.size);
- SQLUniqueConstraint _elem1015;
- for (int _i1016 = 0; _i1016 < _list1014.size; ++_i1016)
+ org.apache.thrift.protocol.TList _list1038 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list1038.size);
+ SQLUniqueConstraint _elem1039;
+ for (int _i1040 = 0; _i1040 < _list1038.size; ++_i1040)
{
- _elem1015 = new SQLUniqueConstraint();
- _elem1015.read(iprot);
- struct.uniqueConstraints.add(_elem1015);
+ _elem1039 = new SQLUniqueConstraint();
+ _elem1039.read(iprot);
+ struct.uniqueConstraints.add(_elem1039);
}
}
struct.setUniqueConstraintsIsSet(true);
}
if (incoming.get(4)) {
{
- org.apache.thrift.protocol.TList _list1017 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.notNullConstraints = new ArrayList<SQLNotNullConstraint>(_list1017.size);
- SQLNotNullConstraint _elem1018;
- for (int _i1019 = 0; _i1019 < _list1017.size; ++_i1019)
+ org.apache.thrift.protocol.TList _list1041 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.notNullConstraints = new ArrayList<SQLNotNullConstraint>(_list1041.size);
+ SQLNotNullConstraint _elem1042;
+ for (int _i1043 = 0; _i1043 < _list1041.size; ++_i1043)
{
- _elem1018 = new SQLNotNullConstraint();
- _elem1018.read(iprot);
- struct.notNullConstraints.add(_elem1018);
+ _elem1042 = new SQLNotNullConstraint();
+ _elem1042.read(iprot);
+ struct.notNullConstraints.add(_elem1042);
}
}
struct.setNotNullConstraintsIsSet(true);
}
if (incoming.get(5)) {
{
- org.apache.thrift.protocol.TList _list1020 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.defaultConstraints = new ArrayList<SQLDefaultConstraint>(_list1020.size);
- SQLDefaultConstraint _elem1021;
- for (int _i1022 = 0; _i1022 < _list1020.size; ++_i1022)
+ org.apache.thrift.protocol.TList _list1044 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.defaultConstraints = new ArrayList<SQLDefaultConstraint>(_list1044.size);
+ SQLDefaultConstraint _elem1045;
+ for (int _i1046 = 0; _i1046 < _list1044.size; ++_i1046)
{
- _elem1021 = new SQLDefaultConstraint();
- _elem1021.read(iprot);
- struct.defaultConstraints.add(_elem1021);
+ _elem1045 = new SQLDefaultConstraint();
+ _elem1045.read(iprot);
+ struct.defaultConstraints.add(_elem1045);
}
}
struct.setDefaultConstraintsIsSet(true);
}
if (incoming.get(6)) {
{
- org.apache.thrift.protocol.TList _list1023 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.checkConstraints = new ArrayList<SQLCheckConstraint>(_list1023.size);
- SQLCheckConstraint _elem1024;
- for (int _i1025 = 0; _i1025 < _list1023.size; ++_i1025)
+ org.apache.thrift.protocol.TList _list1047 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.checkConstraints = new ArrayList<SQLCheckConstraint>(_list1047.size);
+ SQLCheckConstraint _elem1048;
+ for (int _i1049 = 0; _i1049 < _list1047.size; ++_i1049)
{
- _elem1024 = new SQLCheckConstraint();
- _elem1024.read(iprot);
- struct.checkConstraints.add(_elem1024);
+ _elem1048 = new SQLCheckConstraint();
+ _elem1048.read(iprot);
+ struct.checkConstraints.add(_elem1048);
}
}
struct.setCheckConstraintsIsSet(true);
@@ -65479,13 +65611,13 @@ import org.slf4j.LoggerFactory;
case 3: // PART_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1026 = iprot.readListBegin();
- struct.partNames = new ArrayList<String>(_list1026.size);
- String _elem1027;
- for (int _i1028 = 0; _i1028 < _list1026.size; ++_i1028)
+ org.apache.thrift.protocol.TList _list1050 = iprot.readListBegin();
+ struct.partNames = new ArrayList<String>(_list1050.size);
+ String _elem1051;
+ for (int _i1052 = 0; _i1052 < _list1050.size; ++_i1052)
{
- _elem1027 = iprot.readString();
- struct.partNames.add(_elem1027);
+ _elem1051 = iprot.readString();
+ struct.partNames.add(_elem1051);
}
iprot.readListEnd();
}
@@ -65521,9 +65653,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 _iter1029 : struct.partNames)
+ for (String _iter1053 : struct.partNames)
{
- oprot.writeString(_iter1029);
+ oprot.writeString(_iter1053);
}
oprot.writeListEnd();
}
@@ -65566,9 +65698,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetPartNames()) {
{
oprot.writeI32(struct.partNames.size());
- for (String _iter1030 : struct.partNames)
+ for (String _iter1054 : struct.partNames)
{
- oprot.writeString(_iter1030);
+ oprot.writeString(_iter1054);
}
}
}
@@ -65588,13 +65720,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list1031 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.partNames = new ArrayList<String>(_list1031.size);
- String _elem1032;
- for (int _i1033 = 0; _i1033 < _list1031.size; ++_i1033)
+ org.apache.thrift.protocol.TList _list1055 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.partNames = new ArrayList<String>(_list1055.size);
+ String _elem1056;
+ for (int _i1057 = 0; _i1057 < _list1055.size; ++_i1057)
{
- _elem1032 = iprot.readString();
- struct.partNames.add(_elem1032);
+ _elem1056 = iprot.readString();
+ struct.partNames.add(_elem1056);
}
}
struct.setPartNamesIsSet(true);
@@ -66819,13 +66951,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1034 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list1034.size);
- String _elem1035;
- for (int _i1036 = 0; _i1036 < _list1034.size; ++_i1036)
+ org.apache.thrift.protocol.TList _list1058 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list1058.size);
+ String _elem1059;
+ for (int _i1060 = 0; _i1060 < _list1058.size; ++_i1060)
{
- _elem1035 = iprot.readString();
- struct.success.add(_elem1035);
+ _elem1059 = iprot.readString();
+ struct.success.add(_elem1059);
}
iprot.readListEnd();
}
@@ -66860,9 +66992,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 _iter1037 : struct.success)
+ for (String _iter1061 : struct.success)
{
- oprot.writeString(_iter1037);
+ oprot.writeString(_iter1061);
}
oprot.writeListEnd();
}
@@ -66901,9 +67033,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter1038 : struct.success)
+ for (String _iter1062 : struct.success)
{
- oprot.writeString(_iter1038);
+ oprot.writeString(_iter1062);
}
}
}
@@ -66918,13 +67050,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list1039 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list1039.size);
- String _elem1040;
- for (int _i1041 = 0; _i1041 < _list1039.size; ++_i1041)
+ org.apache.thrift.protocol.TList _list1063 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list1063.size);
+ String _elem1064;
+ for (int _i1065 = 0; _i1065 < _list1063.size; ++_i1065)
{
- _elem1040 = iprot.readString();
- struct.success.add(_elem1040);
+ _elem1064 = iprot.readString();
+ struct.success.add(_elem1064);
}
}
struct.setSuccessIsSet(true);
@@ -67898,13 +68030,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1042 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list1042.size);
- String _elem1043;
- for (int _i1044 = 0; _i1044 < _list1042.size; ++_i1044)
+ org.apache.thrift.protocol.TList _list1066 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list1066.size);
+ String _elem1067;
+ for (int _i1068 = 0; _i1068 < _list1066.size; ++_i1068)
{
- _elem1043 = iprot.readString();
- struct.success.add(_elem1043);
+ _elem1067 = iprot.readString();
+ struct.success.add(_elem1067);
}
iprot.readListEnd();
}
@@ -67939,9 +68071,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 _iter1045 : struct.success)
+ for (String _iter1069 : struct.success)
{
- oprot.writeString(_iter1045);
+ oprot.writeString(_iter1069);
}
oprot.writeListEnd();
}
@@ -67980,9 +68112,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter1046 : struct.success)
+ for (String _iter1070 : struct.success)
{
- oprot.writeString(_iter1046);
+ oprot.writeString(_iter1070);
}
}
}
@@ -67997,13 +68129,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list1047 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list1047.size);
- String _elem1048;
- for (int _i1049 = 0; _i1049 < _list1047.size; ++_i1049)
+ org.apache.thrift.protocol.TList _list1071 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list1071.size);
+ String _elem1072;
+ for (int _i1073 = 0; _i1073 < _list1071.size; ++_i1073)
{
- _elem1048 = iprot.readString();
- struct.success.add(_elem1048);
+ _elem1072 = iprot.readString();
+ struct.success.add(_elem1072);
}
}
struct.setSuccessIsSet(true);
@@ -68769,13 +68901,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1050 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list1050.size);
- String _elem1051;
- for (int _i1052 = 0; _i1052 < _list1050.size; ++_i1052)
+ org.apache.thrift.protocol.TList _list1074 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list1074.size);
+ String _elem1075;
+ for (int _i1076 = 0; _i1076 < _list1074.size; ++_i1076)
{
- _elem1051 = iprot.readString();
- struct.success.add(_elem1051);
+ _elem1075 = iprot.readString();
+ struct.success.add(_elem1075);
}
iprot.readListEnd();
}
@@ -68810,9 +68942,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 _iter1053 : struct.success)
+ for (String _iter1077 : struct.success)
{
- oprot.writeString(_iter1053);
+ oprot.writeString(_iter1077);
}
oprot.writeListEnd();
}
@@ -68851,9 +68983,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter1054 : struct.success)
+ for (String _iter1078 : struct.success)
{
- oprot.writeString(_iter1054);
+ oprot.writeString(_iter1078);
}
}
}
@@ -68868,13 +69000,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list1055 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list1055.size);
- String _elem1056;
- for (int _i1057 = 0; _i1057 < _list1055.size; ++_i1057)
+ org.apache.thrift.protocol.TList _list1079 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list1079.size);
+ String _elem1080;
+ for (int _i1081 = 0; _i1081 < _list1079.size; ++_i1081)
{
- _elem1056 = iprot.readString();
- struct.success.add(_elem1056);
+ _elem1080 = iprot.readString();
+ struct.success.add(_elem1080);
}
}
struct.setSuccessIsSet(true);
@@ -69379,13 +69511,13 @@ import org.slf4j.LoggerFactory;
case 3: // TBL_TYPES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1058 = iprot.readListBegin();
- struct.tbl_types = new ArrayList<String>(_list1058.size);
- String _elem1059;
- for (int _i1060 = 0; _i1060 < _list1058.size; ++_i1060)
+ org.apache.thrift.protocol.TList _list1082 = iprot.readListBegin();
+ struct.tbl_types = new ArrayList<String>(_list1082.size);
+ String _elem1083;
+ for (int _i1084 = 0; _i1084 < _list1082.size; ++_i1084)
{
- _elem1059 = iprot.readString();
- struct.tbl_types.add(_elem1059);
+ _elem1083 = iprot.readString();
+ struct.tbl_types.add(_elem1083);
}
iprot.readListEnd();
}
@@ -69421,9 +69553,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 _iter1061 : struct.tbl_types)
+ for (String _iter1085 : struct.tbl_types)
{
- oprot.writeString(_iter1061);
+ oprot.writeString(_iter1085);
}
oprot.writeListEnd();
}
@@ -69466,9 +69598,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetTbl_types()) {
{
oprot.writeI32(struct.tbl_types.size());
- for (String _iter1062 : struct.tbl_types)
+ for (String _iter1086 : struct.tbl_types)
{
- oprot.writeString(_iter1062);
+ oprot.writeString(_iter1086);
}
}
}
@@ -69488,13 +69620,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list1063 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.tbl_types = new ArrayList<String>(_list1063.size);
- String _elem1064;
- for (int _i1065 = 0; _i1065 < _list1063.size; ++_i1065)
+ org.apache.thrift.protocol.TList _list1087 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.tbl_types = new ArrayList<String>(_list1087.size);
+ String _elem1088;
+ for (int _i1089 = 0; _i1089 < _list1087.size; ++_i1089)
{
- _elem1064 = iprot.readString();
- struct.tbl_types.add(_elem1064);
+ _elem1088 = iprot.readString();
+ struct.tbl_types.add(_elem1088);
}
}
struct.setTbl_typesIsSet(true);
@@ -69900,14 +70032,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1066 = iprot.readListBegin();
- struct.success = new ArrayList<TableMeta>(_list1066.size);
- TableMeta _elem1067;
- for (int _i1068 = 0; _i1068 < _list1066.size; ++_i1068)
+ org.apache.thrift.protocol.TList _list1090 = iprot.readListBegin();
+ struct.success = new ArrayList<TableMeta>(_list1090.size);
+ TableMeta _elem1091;
+ for (int _i1092 = 0; _i1092 < _list1090.size; ++_i1092)
{
- _elem1067 = new TableMeta();
- _elem1067.read(iprot);
- struct.success.add(_elem1067);
+ _elem1091 = new TableMeta();
+ _elem1091.read(iprot);
+ struct.success.add(_elem1091);
}
iprot.readListEnd();
}
@@ -69942,9 +70074,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 _iter1069 : struct.success)
+ for (TableMeta _iter1093 : struct.success)
{
- _iter1069.write(oprot);
+ _iter1093.write(oprot);
}
oprot.writeListEnd();
}
@@ -69983,9 +70115,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (TableMeta _iter1070 : struct.success)
+ for (TableMeta _iter1094 : struct.success)
{
- _iter1070.write(oprot);
+ _iter1094.write(oprot);
}
}
}
@@ -70000,14 +70132,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list1071 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<TableMeta>(_list1071.size);
- TableMeta _elem1072;
- for (int _i1073 = 0; _i1073 < _list1071.size; ++_i1073)
+ org.apache.thrift.protocol.TList _list1095 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<TableMeta>(_list1095.size);
+ TableMeta _elem1096;
+ for (int _i1097 = 0; _i1097 < _list1095.size; ++_i1097)
{
- _elem1072 = new TableMeta();
- _elem1072.read(iprot);
- struct.success.add(_elem1072);
+ _elem1096 = new TableMeta();
+ _elem1096.read(iprot);
+ struct.success.add(_elem1096);
}
}
struct.setSuccessIsSet(true);
@@ -70773,13 +70905,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1074 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list1074.size);
- String _elem1075;
- for (int _i1076 = 0; _i1076 < _list1074.size; ++_i1076)
+ 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)
{
- _elem1075 = iprot.readString();
- struct.success.add(_elem1075);
+ _elem1099 = iprot.readString();
+ struct.success.add(_elem1099);
}
iprot.readListEnd();
}
@@ -70814,9 +70946,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 _iter1077 : struct.success)
+ for (String _iter1101 : struct.success)
{
- oprot.writeString(_iter1077);
+ oprot.writeString(_iter1101);
}
oprot.writeListEnd();
}
@@ -70855,9 +70987,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter1078 : struct.success)
+ for (String _iter1102 : struct.success)
{
- oprot.writeString(_iter1078);
+ oprot.writeString(_iter1102);
}
}
}
@@ -70872,13 +71004,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list1079 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list1079.size);
- String _elem1080;
- for (int _i1081 = 0; _i1081 < _list1079.size; ++_i1081)
+ 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)
{
- _elem1080 = iprot.readString();
- struct.success.add(_elem1080);
+ _elem1104 = iprot.readString();
+ struct.success.add(_elem1104);
}
}
struct.setSuccessIsSet(true);
@@ -72331,13 +72463,13 @@ import org.slf4j.LoggerFactory;
case 2: // TBL_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1082 = iprot.readListBegin();
- struct.tbl_names = new ArrayList<String>(_list1082.size);
- String _elem1083;
- for (int _i1084 = 0; _i1084 < _list1082.size; ++_i1084)
+ org.apache.thrift.protocol.TList _list1106 = iprot.readListBegin();
+ struct.tbl_names = new ArrayList<String>(_list1106.size);
+ String _elem1107;
+ for (int _i1108 = 0; _i1108 < _list1106.size; ++_i1108)
{
- _elem1083 = iprot.readString();
- struct.tbl_names.add(_elem1083);
+ _elem1107 = iprot.readString();
+ struct.tbl_names.add(_elem1107);
}
iprot.readListEnd();
}
@@ -72368,9 +72500,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 _iter1085 : struct.tbl_names)
+ for (String _iter1109 : struct.tbl_names)
{
- oprot.writeString(_iter1085);
+ oprot.writeString(_iter1109);
}
oprot.writeListEnd();
}
@@ -72407,9 +72539,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetTbl_names()) {
{
oprot.writeI32(struct.tbl_names.size());
- for (String _iter1086 : struct.tbl_names)
+ for (String _iter1110 : struct.tbl_names)
{
- oprot.writeString(_iter1086);
+ oprot.writeString(_iter1110);
}
}
}
@@ -72425,13 +72557,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list1087 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.tbl_names = new ArrayList<String>(_list1087.size);
- String _elem1088;
- for (int _i1089 = 0; _i1089 < _list1087.size; ++_i1089)
+ org.apache.thrift.protocol.TList _list1111 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.tbl_names = new ArrayList<String>(_list1111.size);
+ String _elem1112;
+ for (int _i1113 = 0; _i1113 < _list1111.size; ++_i1113)
{
- _elem1088 = iprot.readString();
- struct.tbl_names.add(_elem1088);
+ _elem1112 = iprot.readString();
+ struct.tbl_names.add(_elem1112);
}
}
struct.setTbl_namesIsSet(true);
@@ -72756,14 +72888,14 @@ 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<Table>(_list1090.size);
- Table _elem1091;
- for (int _i1092 = 0; _i1092 < _list1090.size; ++_i1092)
+ org.apache.thrift.protocol.TList _list1114 = iprot.readListBegin();
+ struct.success = new ArrayList<Table>(_list1114.size);
+ Table _elem1115;
+ for (int _i1116 = 0; _i1116 < _list1114.size; ++_i1116)
{
- _elem1091 = new Table();
- _elem1091.read(iprot);
- struct.success.add(_elem1091);
+ _elem1115 = new Table();
+ _elem1115.read(iprot);
+ struct.success.add(_elem1115);
}
iprot.readListEnd();
}
@@ -72789,9 +72921,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 _iter1093 : struct.success)
+ for (Table _iter1117 : struct.success)
{
- _iter1093.write(oprot);
+ _iter1117.write(oprot);
}
oprot.writeListEnd();
}
@@ -72822,9 +72954,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Table _iter1094 : struct.success)
+ for (Table _iter1118 : struct.success)
{
- _iter1094.write(oprot);
+ _iter1118.write(oprot);
}
}
}
@@ -72836,14 +72968,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list1095 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<Table>(_list1095.size);
- Table _elem1096;
- for (int _i1097 = 0; _i1097 < _list1095.size; ++_i1097)
+ org.apache.thrift.protocol.TList _list1119 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<Table>(_list1119.size);
+ Table _elem1120;
+ for (int _i1121 = 0; _i1121 < _list1119.size; ++_i1121)
{
- _elem1096 = new Table();
- _elem1096.read(iprot);
- struct.success.add(_elem1096);
+ _elem1120 = new Table();
+ _elem1120.read(iprot);
+ struct.success.add(_elem1120);
}
}
struct.setSuccessIsSet(true);
@@ -78351,13 +78483,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 _list1122 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list1122.size);
+ String _elem1123;
+ for (int _i1124 = 0; _i1124 < _list1122.size; ++_i1124)
{
- _elem1099 = iprot.readString();
- struct.success.add(_elem1099);
+ _elem1123 = iprot.readString();
+ struct.success.add(_elem1123);
}
iprot.readListEnd();
}
@@ -78410,9 +78542,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 _iter1125 : struct.success)
{
- oprot.writeString(_iter1101);
+ oprot.writeString(_iter1125);
}
oprot.writeListEnd();
}
@@ -78467,9 +78599,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter1102 : struct.success)
+ for (String _iter1126 : struct.success)
{
- oprot.writeString(_iter1102);
+ oprot.writeString(_iter1126);
}
}
}
@@ -78490,13 +78622,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
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 _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)
{
- _elem1104 = iprot.readString();
- struct.success.add(_elem1104);
+ _elem1128 = iprot.readString();
+ struct.success.add(_elem1128);
}
}
struct.setSuccessIsSet(true);
@@ -84355,14 +84487,14 @@ import org.slf4j.LoggerFactory;
case 1: // NEW_PARTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1106 = iprot.readListBegin();
- struct.new_parts = new ArrayList<Partition>(_list1106.size);
- Partition _elem1107;
- for (int _i1108 = 0; _i1108 < _list1106.size; ++_i1108)
+ org.apache.thrift.protocol.TList _list1130 = iprot.readListBegin();
+ struct.new_parts = new ArrayList<Partition>(_list1130.size);
+ Partition _elem1131;
+ for (int _i1132 = 0; _i1132 < _list1130.size; ++_i1132)
{
- _elem1107 = new Partition();
- _elem1107.read(iprot);
- struct.new_parts.add(_elem1107);
+ _elem1131 = new Partition();
+ _elem1131.read(iprot);
+ struct.new_parts.add(_elem1131);
}
iprot.readListEnd();
}
@@ -84388,9 +84520,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 _iter1109 : struct.new_parts)
+ for (Partition _iter1133 : struct.new_parts)
{
- _iter1109.write(oprot);
+ _iter1133.write(oprot);
}
oprot.writeListEnd();
}
@@ -84421,9 +84553,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetNew_parts()) {
{
oprot.writeI32(struct.new_parts.size());
- for (Partition _iter1110 : struct.new_parts)
+ for (Partition _iter1134 : struct.new_parts)
{
- _iter1110.write(oprot);
+ _iter1134.write(oprot);
}
}
}
@@ -84435,14 +84567,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list1111 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.new_parts = new ArrayList<Partition>(_list1111.size);
- Partition _elem1112;
- for (int _i1113 = 0; _i1113 < _list1111.size; ++_i1113)
+ org.apache.thrift.protocol.TList _list1135 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.new_parts = new ArrayList<Partition>(_list1135.size);
+ Partition _elem1136;
+ for (int _i1137 = 0; _i1137 < _list1135.size; ++_i1137)
{
- _elem1112 = new Partition();
- _elem1112.read(iprot);
- struct.new_parts.add(_elem1112);
+ _elem1136 = new Partition();
+ _elem1136.read(iprot);
+ struct.new_parts.add(_elem1136);
}
}
struct.setNew_partsIsSet(true);
@@ -85443,14 +85575,14 @@ import org.slf4j.LoggerFactory;
case 1: // NEW_PARTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list1114 = iprot.readListBegin();
- struct.new_parts = new ArrayList<PartitionSpec>(_list1114.size);
- PartitionSpec _elem1115;
- for (int _i1116 = 0; _i1116 < _list1114.size; ++_i1116)
+ org.apache.thrift.protocol.TList _list1138 = iprot.readListBegin();
+ struct.new_parts = new ArrayList<PartitionSpec>(_list1138.size);
+ PartitionSpec _elem1139;
+ for (int _i1140 = 0; _i1140 < _list1138.size; ++_i1140)
{
- _elem1115 = new PartitionSpec();
- _elem1115.read(iprot);
- struct.new_parts.add(_elem1115);
+ _elem1139 = new PartitionSpec();
+ _elem1139.read(iprot);
+ struct.new_parts.add(_elem1139);
}
iprot.readListEnd();
}
@@ -85476,9 +85608,9 @@ import org.slf4j.LoggerFactory;
<TRUNCATED>