You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by we...@apache.org on 2017/05/16 22:53:17 UTC
[12/18] hive git commit: HIVE-14879 : integrate MM tables into ACID:
replace MM metastore calls and structures with ACID ones (Wei Zheng)
http://git-wip-us.apache.org/repos/asf/hive/blob/77511070/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
index cb1bd59..1915150 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
@@ -350,14 +350,6 @@ public class ThriftHiveMetastore {
public CacheFileMetadataResult cache_file_metadata(CacheFileMetadataRequest req) throws org.apache.thrift.TException;
- public GetNextWriteIdResult get_next_write_id(GetNextWriteIdRequest req) throws org.apache.thrift.TException;
-
- public FinalizeWriteIdResult finalize_write_id(FinalizeWriteIdRequest req) throws org.apache.thrift.TException;
-
- public HeartbeatWriteIdResult heartbeat_write_id(HeartbeatWriteIdRequest req) throws org.apache.thrift.TException;
-
- public GetValidWriteIdsResult get_valid_write_ids(GetValidWriteIdsRequest req) throws org.apache.thrift.TException;
-
}
public interface AsyncIface extends com.facebook.fb303.FacebookService .AsyncIface {
@@ -670,14 +662,6 @@ public class ThriftHiveMetastore {
public void cache_file_metadata(CacheFileMetadataRequest req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
- public void get_next_write_id(GetNextWriteIdRequest req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void finalize_write_id(FinalizeWriteIdRequest req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void heartbeat_write_id(HeartbeatWriteIdRequest req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void get_valid_write_ids(GetValidWriteIdsRequest req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
}
public static class Client extends com.facebook.fb303.FacebookService.Client implements Iface {
@@ -5127,98 +5111,6 @@ public class ThriftHiveMetastore {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "cache_file_metadata failed: unknown result");
}
- public GetNextWriteIdResult get_next_write_id(GetNextWriteIdRequest req) throws org.apache.thrift.TException
- {
- send_get_next_write_id(req);
- return recv_get_next_write_id();
- }
-
- public void send_get_next_write_id(GetNextWriteIdRequest req) throws org.apache.thrift.TException
- {
- get_next_write_id_args args = new get_next_write_id_args();
- args.setReq(req);
- sendBase("get_next_write_id", args);
- }
-
- public GetNextWriteIdResult recv_get_next_write_id() throws org.apache.thrift.TException
- {
- get_next_write_id_result result = new get_next_write_id_result();
- receiveBase(result, "get_next_write_id");
- if (result.isSetSuccess()) {
- return result.success;
- }
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "get_next_write_id failed: unknown result");
- }
-
- public FinalizeWriteIdResult finalize_write_id(FinalizeWriteIdRequest req) throws org.apache.thrift.TException
- {
- send_finalize_write_id(req);
- return recv_finalize_write_id();
- }
-
- public void send_finalize_write_id(FinalizeWriteIdRequest req) throws org.apache.thrift.TException
- {
- finalize_write_id_args args = new finalize_write_id_args();
- args.setReq(req);
- sendBase("finalize_write_id", args);
- }
-
- public FinalizeWriteIdResult recv_finalize_write_id() throws org.apache.thrift.TException
- {
- finalize_write_id_result result = new finalize_write_id_result();
- receiveBase(result, "finalize_write_id");
- if (result.isSetSuccess()) {
- return result.success;
- }
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "finalize_write_id failed: unknown result");
- }
-
- public HeartbeatWriteIdResult heartbeat_write_id(HeartbeatWriteIdRequest req) throws org.apache.thrift.TException
- {
- send_heartbeat_write_id(req);
- return recv_heartbeat_write_id();
- }
-
- public void send_heartbeat_write_id(HeartbeatWriteIdRequest req) throws org.apache.thrift.TException
- {
- heartbeat_write_id_args args = new heartbeat_write_id_args();
- args.setReq(req);
- sendBase("heartbeat_write_id", args);
- }
-
- public HeartbeatWriteIdResult recv_heartbeat_write_id() throws org.apache.thrift.TException
- {
- heartbeat_write_id_result result = new heartbeat_write_id_result();
- receiveBase(result, "heartbeat_write_id");
- if (result.isSetSuccess()) {
- return result.success;
- }
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "heartbeat_write_id failed: unknown result");
- }
-
- public GetValidWriteIdsResult get_valid_write_ids(GetValidWriteIdsRequest req) throws org.apache.thrift.TException
- {
- send_get_valid_write_ids(req);
- return recv_get_valid_write_ids();
- }
-
- public void send_get_valid_write_ids(GetValidWriteIdsRequest req) throws org.apache.thrift.TException
- {
- get_valid_write_ids_args args = new get_valid_write_ids_args();
- args.setReq(req);
- sendBase("get_valid_write_ids", args);
- }
-
- public GetValidWriteIdsResult recv_get_valid_write_ids() throws org.apache.thrift.TException
- {
- get_valid_write_ids_result result = new get_valid_write_ids_result();
- receiveBase(result, "get_valid_write_ids");
- if (result.isSetSuccess()) {
- return result.success;
- }
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "get_valid_write_ids failed: unknown result");
- }
-
}
public static class AsyncClient extends com.facebook.fb303.FacebookService.AsyncClient implements AsyncIface {
public static class Factory implements org.apache.thrift.async.TAsyncClientFactory<AsyncClient> {
@@ -10660,134 +10552,6 @@ public class ThriftHiveMetastore {
}
}
- public void get_next_write_id(GetNextWriteIdRequest req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
- checkReady();
- get_next_write_id_call method_call = new get_next_write_id_call(req, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- public static class get_next_write_id_call extends org.apache.thrift.async.TAsyncMethodCall {
- private GetNextWriteIdRequest req;
- public get_next_write_id_call(GetNextWriteIdRequest req, 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.req = req;
- }
-
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("get_next_write_id", org.apache.thrift.protocol.TMessageType.CALL, 0));
- get_next_write_id_args args = new get_next_write_id_args();
- args.setReq(req);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public GetNextWriteIdResult 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_get_next_write_id();
- }
- }
-
- public void finalize_write_id(FinalizeWriteIdRequest req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
- checkReady();
- finalize_write_id_call method_call = new finalize_write_id_call(req, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- public static class finalize_write_id_call extends org.apache.thrift.async.TAsyncMethodCall {
- private FinalizeWriteIdRequest req;
- public finalize_write_id_call(FinalizeWriteIdRequest req, 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.req = req;
- }
-
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("finalize_write_id", org.apache.thrift.protocol.TMessageType.CALL, 0));
- finalize_write_id_args args = new finalize_write_id_args();
- args.setReq(req);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public FinalizeWriteIdResult 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_finalize_write_id();
- }
- }
-
- public void heartbeat_write_id(HeartbeatWriteIdRequest req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
- checkReady();
- heartbeat_write_id_call method_call = new heartbeat_write_id_call(req, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- public static class heartbeat_write_id_call extends org.apache.thrift.async.TAsyncMethodCall {
- private HeartbeatWriteIdRequest req;
- public heartbeat_write_id_call(HeartbeatWriteIdRequest req, 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.req = req;
- }
-
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("heartbeat_write_id", org.apache.thrift.protocol.TMessageType.CALL, 0));
- heartbeat_write_id_args args = new heartbeat_write_id_args();
- args.setReq(req);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public HeartbeatWriteIdResult 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_heartbeat_write_id();
- }
- }
-
- public void get_valid_write_ids(GetValidWriteIdsRequest req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
- checkReady();
- get_valid_write_ids_call method_call = new get_valid_write_ids_call(req, resultHandler, this, ___protocolFactory, ___transport);
- this.___currentMethod = method_call;
- ___manager.call(method_call);
- }
-
- public static class get_valid_write_ids_call extends org.apache.thrift.async.TAsyncMethodCall {
- private GetValidWriteIdsRequest req;
- public get_valid_write_ids_call(GetValidWriteIdsRequest req, 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.req = req;
- }
-
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("get_valid_write_ids", org.apache.thrift.protocol.TMessageType.CALL, 0));
- get_valid_write_ids_args args = new get_valid_write_ids_args();
- args.setReq(req);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public GetValidWriteIdsResult 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_get_valid_write_ids();
- }
- }
-
}
public static class Processor<I extends Iface> extends com.facebook.fb303.FacebookService.Processor<I> implements org.apache.thrift.TProcessor {
@@ -10955,10 +10719,6 @@ public class ThriftHiveMetastore {
processMap.put("put_file_metadata", new put_file_metadata());
processMap.put("clear_file_metadata", new clear_file_metadata());
processMap.put("cache_file_metadata", new cache_file_metadata());
- processMap.put("get_next_write_id", new get_next_write_id());
- processMap.put("finalize_write_id", new finalize_write_id());
- processMap.put("heartbeat_write_id", new heartbeat_write_id());
- processMap.put("get_valid_write_ids", new get_valid_write_ids());
return processMap;
}
@@ -14882,86 +14642,6 @@ public class ThriftHiveMetastore {
}
}
- public static class get_next_write_id<I extends Iface> extends org.apache.thrift.ProcessFunction<I, get_next_write_id_args> {
- public get_next_write_id() {
- super("get_next_write_id");
- }
-
- public get_next_write_id_args getEmptyArgsInstance() {
- return new get_next_write_id_args();
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- public get_next_write_id_result getResult(I iface, get_next_write_id_args args) throws org.apache.thrift.TException {
- get_next_write_id_result result = new get_next_write_id_result();
- result.success = iface.get_next_write_id(args.req);
- return result;
- }
- }
-
- public static class finalize_write_id<I extends Iface> extends org.apache.thrift.ProcessFunction<I, finalize_write_id_args> {
- public finalize_write_id() {
- super("finalize_write_id");
- }
-
- public finalize_write_id_args getEmptyArgsInstance() {
- return new finalize_write_id_args();
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- public finalize_write_id_result getResult(I iface, finalize_write_id_args args) throws org.apache.thrift.TException {
- finalize_write_id_result result = new finalize_write_id_result();
- result.success = iface.finalize_write_id(args.req);
- return result;
- }
- }
-
- public static class heartbeat_write_id<I extends Iface> extends org.apache.thrift.ProcessFunction<I, heartbeat_write_id_args> {
- public heartbeat_write_id() {
- super("heartbeat_write_id");
- }
-
- public heartbeat_write_id_args getEmptyArgsInstance() {
- return new heartbeat_write_id_args();
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- public heartbeat_write_id_result getResult(I iface, heartbeat_write_id_args args) throws org.apache.thrift.TException {
- heartbeat_write_id_result result = new heartbeat_write_id_result();
- result.success = iface.heartbeat_write_id(args.req);
- return result;
- }
- }
-
- public static class get_valid_write_ids<I extends Iface> extends org.apache.thrift.ProcessFunction<I, get_valid_write_ids_args> {
- public get_valid_write_ids() {
- super("get_valid_write_ids");
- }
-
- public get_valid_write_ids_args getEmptyArgsInstance() {
- return new get_valid_write_ids_args();
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- public get_valid_write_ids_result getResult(I iface, get_valid_write_ids_args args) throws org.apache.thrift.TException {
- get_valid_write_ids_result result = new get_valid_write_ids_result();
- result.success = iface.get_valid_write_ids(args.req);
- return result;
- }
- }
-
}
public static class AsyncProcessor<I extends AsyncIface> extends com.facebook.fb303.FacebookService.AsyncProcessor<I> {
@@ -15129,10 +14809,6 @@ public class ThriftHiveMetastore {
processMap.put("put_file_metadata", new put_file_metadata());
processMap.put("clear_file_metadata", new clear_file_metadata());
processMap.put("cache_file_metadata", new cache_file_metadata());
- processMap.put("get_next_write_id", new get_next_write_id());
- processMap.put("finalize_write_id", new finalize_write_id());
- processMap.put("heartbeat_write_id", new heartbeat_write_id());
- processMap.put("get_valid_write_ids", new get_valid_write_ids());
return processMap;
}
@@ -24492,210 +24168,6 @@ public class ThriftHiveMetastore {
}
}
- public static class get_next_write_id<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_next_write_id_args, GetNextWriteIdResult> {
- public get_next_write_id() {
- super("get_next_write_id");
- }
-
- public get_next_write_id_args getEmptyArgsInstance() {
- return new get_next_write_id_args();
- }
-
- public AsyncMethodCallback<GetNextWriteIdResult> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
- final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<GetNextWriteIdResult>() {
- public void onComplete(GetNextWriteIdResult o) {
- get_next_write_id_result result = new get_next_write_id_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_next_write_id_result result = new get_next_write_id_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, get_next_write_id_args args, org.apache.thrift.async.AsyncMethodCallback<GetNextWriteIdResult> resultHandler) throws TException {
- iface.get_next_write_id(args.req,resultHandler);
- }
- }
-
- public static class finalize_write_id<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, finalize_write_id_args, FinalizeWriteIdResult> {
- public finalize_write_id() {
- super("finalize_write_id");
- }
-
- public finalize_write_id_args getEmptyArgsInstance() {
- return new finalize_write_id_args();
- }
-
- public AsyncMethodCallback<FinalizeWriteIdResult> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
- final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<FinalizeWriteIdResult>() {
- public void onComplete(FinalizeWriteIdResult o) {
- finalize_write_id_result result = new finalize_write_id_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;
- finalize_write_id_result result = new finalize_write_id_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, finalize_write_id_args args, org.apache.thrift.async.AsyncMethodCallback<FinalizeWriteIdResult> resultHandler) throws TException {
- iface.finalize_write_id(args.req,resultHandler);
- }
- }
-
- public static class heartbeat_write_id<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, heartbeat_write_id_args, HeartbeatWriteIdResult> {
- public heartbeat_write_id() {
- super("heartbeat_write_id");
- }
-
- public heartbeat_write_id_args getEmptyArgsInstance() {
- return new heartbeat_write_id_args();
- }
-
- public AsyncMethodCallback<HeartbeatWriteIdResult> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
- final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<HeartbeatWriteIdResult>() {
- public void onComplete(HeartbeatWriteIdResult o) {
- heartbeat_write_id_result result = new heartbeat_write_id_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;
- heartbeat_write_id_result result = new heartbeat_write_id_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, heartbeat_write_id_args args, org.apache.thrift.async.AsyncMethodCallback<HeartbeatWriteIdResult> resultHandler) throws TException {
- iface.heartbeat_write_id(args.req,resultHandler);
- }
- }
-
- public static class get_valid_write_ids<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_valid_write_ids_args, GetValidWriteIdsResult> {
- public get_valid_write_ids() {
- super("get_valid_write_ids");
- }
-
- public get_valid_write_ids_args getEmptyArgsInstance() {
- return new get_valid_write_ids_args();
- }
-
- public AsyncMethodCallback<GetValidWriteIdsResult> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
- final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<GetValidWriteIdsResult>() {
- public void onComplete(GetValidWriteIdsResult o) {
- get_valid_write_ids_result result = new get_valid_write_ids_result();
- result.success = o;
- try {
- fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
- return;
- } catch (Exception e) {
- LOGGER.error("Exception writing to internal frame buffer", e);
- }
- fb.close();
- }
- public void onError(Exception e) {
- byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
- org.apache.thrift.TBase msg;
- get_valid_write_ids_result result = new get_valid_write_ids_result();
- {
- msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
- msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
- }
- try {
- fcall.sendResponse(fb,msg,msgType,seqid);
- return;
- } catch (Exception ex) {
- LOGGER.error("Exception writing to internal frame buffer", ex);
- }
- fb.close();
- }
- };
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- public void start(I iface, get_valid_write_ids_args args, org.apache.thrift.async.AsyncMethodCallback<GetValidWriteIdsResult> resultHandler) throws TException {
- iface.get_valid_write_ids(args.req,resultHandler);
- }
- }
-
}
public static class getMetaConf_args implements org.apache.thrift.TBase<getMetaConf_args, getMetaConf_args._Fields>, java.io.Serializable, Cloneable, Comparable<getMetaConf_args> {
@@ -30091,13 +29563,13 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list682 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list682.size);
- String _elem683;
- for (int _i684 = 0; _i684 < _list682.size; ++_i684)
+ org.apache.thrift.protocol.TList _list674 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list674.size);
+ String _elem675;
+ for (int _i676 = 0; _i676 < _list674.size; ++_i676)
{
- _elem683 = iprot.readString();
- struct.success.add(_elem683);
+ _elem675 = iprot.readString();
+ struct.success.add(_elem675);
}
iprot.readListEnd();
}
@@ -30132,9 +29604,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
- for (String _iter685 : struct.success)
+ for (String _iter677 : struct.success)
{
- oprot.writeString(_iter685);
+ oprot.writeString(_iter677);
}
oprot.writeListEnd();
}
@@ -30173,9 +29645,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter686 : struct.success)
+ for (String _iter678 : struct.success)
{
- oprot.writeString(_iter686);
+ oprot.writeString(_iter678);
}
}
}
@@ -30190,13 +29662,13 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list687 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list687.size);
- String _elem688;
- for (int _i689 = 0; _i689 < _list687.size; ++_i689)
+ org.apache.thrift.protocol.TList _list679 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list679.size);
+ String _elem680;
+ for (int _i681 = 0; _i681 < _list679.size; ++_i681)
{
- _elem688 = iprot.readString();
- struct.success.add(_elem688);
+ _elem680 = iprot.readString();
+ struct.success.add(_elem680);
}
}
struct.setSuccessIsSet(true);
@@ -30850,13 +30322,13 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list690 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list690.size);
- String _elem691;
- for (int _i692 = 0; _i692 < _list690.size; ++_i692)
+ org.apache.thrift.protocol.TList _list682 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list682.size);
+ String _elem683;
+ for (int _i684 = 0; _i684 < _list682.size; ++_i684)
{
- _elem691 = iprot.readString();
- struct.success.add(_elem691);
+ _elem683 = iprot.readString();
+ struct.success.add(_elem683);
}
iprot.readListEnd();
}
@@ -30891,9 +30363,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
- for (String _iter693 : struct.success)
+ for (String _iter685 : struct.success)
{
- oprot.writeString(_iter693);
+ oprot.writeString(_iter685);
}
oprot.writeListEnd();
}
@@ -30932,9 +30404,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter694 : struct.success)
+ for (String _iter686 : struct.success)
{
- oprot.writeString(_iter694);
+ oprot.writeString(_iter686);
}
}
}
@@ -30949,13 +30421,13 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list695 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list695.size);
- String _elem696;
- for (int _i697 = 0; _i697 < _list695.size; ++_i697)
+ org.apache.thrift.protocol.TList _list687 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list687.size);
+ String _elem688;
+ for (int _i689 = 0; _i689 < _list687.size; ++_i689)
{
- _elem696 = iprot.readString();
- struct.success.add(_elem696);
+ _elem688 = iprot.readString();
+ struct.success.add(_elem688);
}
}
struct.setSuccessIsSet(true);
@@ -35562,16 +35034,16 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map698 = iprot.readMapBegin();
- struct.success = new HashMap<String,Type>(2*_map698.size);
- String _key699;
- Type _val700;
- for (int _i701 = 0; _i701 < _map698.size; ++_i701)
+ org.apache.thrift.protocol.TMap _map690 = iprot.readMapBegin();
+ struct.success = new HashMap<String,Type>(2*_map690.size);
+ String _key691;
+ Type _val692;
+ for (int _i693 = 0; _i693 < _map690.size; ++_i693)
{
- _key699 = iprot.readString();
- _val700 = new Type();
- _val700.read(iprot);
- struct.success.put(_key699, _val700);
+ _key691 = iprot.readString();
+ _val692 = new Type();
+ _val692.read(iprot);
+ struct.success.put(_key691, _val692);
}
iprot.readMapEnd();
}
@@ -35606,10 +35078,10 @@ public class ThriftHiveMetastore {
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> _iter702 : struct.success.entrySet())
+ for (Map.Entry<String, Type> _iter694 : struct.success.entrySet())
{
- oprot.writeString(_iter702.getKey());
- _iter702.getValue().write(oprot);
+ oprot.writeString(_iter694.getKey());
+ _iter694.getValue().write(oprot);
}
oprot.writeMapEnd();
}
@@ -35648,10 +35120,10 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Map.Entry<String, Type> _iter703 : struct.success.entrySet())
+ for (Map.Entry<String, Type> _iter695 : struct.success.entrySet())
{
- oprot.writeString(_iter703.getKey());
- _iter703.getValue().write(oprot);
+ oprot.writeString(_iter695.getKey());
+ _iter695.getValue().write(oprot);
}
}
}
@@ -35666,16 +35138,16 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TMap _map704 = 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*_map704.size);
- String _key705;
- Type _val706;
- for (int _i707 = 0; _i707 < _map704.size; ++_i707)
+ org.apache.thrift.protocol.TMap _map696 = 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*_map696.size);
+ String _key697;
+ Type _val698;
+ for (int _i699 = 0; _i699 < _map696.size; ++_i699)
{
- _key705 = iprot.readString();
- _val706 = new Type();
- _val706.read(iprot);
- struct.success.put(_key705, _val706);
+ _key697 = iprot.readString();
+ _val698 = new Type();
+ _val698.read(iprot);
+ struct.success.put(_key697, _val698);
}
}
struct.setSuccessIsSet(true);
@@ -36710,14 +36182,14 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list708 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list708.size);
- FieldSchema _elem709;
- for (int _i710 = 0; _i710 < _list708.size; ++_i710)
+ org.apache.thrift.protocol.TList _list700 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list700.size);
+ FieldSchema _elem701;
+ for (int _i702 = 0; _i702 < _list700.size; ++_i702)
{
- _elem709 = new FieldSchema();
- _elem709.read(iprot);
- struct.success.add(_elem709);
+ _elem701 = new FieldSchema();
+ _elem701.read(iprot);
+ struct.success.add(_elem701);
}
iprot.readListEnd();
}
@@ -36770,9 +36242,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (FieldSchema _iter711 : struct.success)
+ for (FieldSchema _iter703 : struct.success)
{
- _iter711.write(oprot);
+ _iter703.write(oprot);
}
oprot.writeListEnd();
}
@@ -36827,9 +36299,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter712 : struct.success)
+ for (FieldSchema _iter704 : struct.success)
{
- _iter712.write(oprot);
+ _iter704.write(oprot);
}
}
}
@@ -36850,14 +36322,14 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list713 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list713.size);
- FieldSchema _elem714;
- for (int _i715 = 0; _i715 < _list713.size; ++_i715)
+ org.apache.thrift.protocol.TList _list705 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list705.size);
+ FieldSchema _elem706;
+ for (int _i707 = 0; _i707 < _list705.size; ++_i707)
{
- _elem714 = new FieldSchema();
- _elem714.read(iprot);
- struct.success.add(_elem714);
+ _elem706 = new FieldSchema();
+ _elem706.read(iprot);
+ struct.success.add(_elem706);
}
}
struct.setSuccessIsSet(true);
@@ -38011,14 +37483,14 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list716 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list716.size);
- FieldSchema _elem717;
- for (int _i718 = 0; _i718 < _list716.size; ++_i718)
+ org.apache.thrift.protocol.TList _list708 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list708.size);
+ FieldSchema _elem709;
+ for (int _i710 = 0; _i710 < _list708.size; ++_i710)
{
- _elem717 = new FieldSchema();
- _elem717.read(iprot);
- struct.success.add(_elem717);
+ _elem709 = new FieldSchema();
+ _elem709.read(iprot);
+ struct.success.add(_elem709);
}
iprot.readListEnd();
}
@@ -38071,9 +37543,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (FieldSchema _iter719 : struct.success)
+ for (FieldSchema _iter711 : struct.success)
{
- _iter719.write(oprot);
+ _iter711.write(oprot);
}
oprot.writeListEnd();
}
@@ -38128,9 +37600,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter720 : struct.success)
+ for (FieldSchema _iter712 : struct.success)
{
- _iter720.write(oprot);
+ _iter712.write(oprot);
}
}
}
@@ -38151,14 +37623,14 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list721 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list721.size);
- FieldSchema _elem722;
- for (int _i723 = 0; _i723 < _list721.size; ++_i723)
+ org.apache.thrift.protocol.TList _list713 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list713.size);
+ FieldSchema _elem714;
+ for (int _i715 = 0; _i715 < _list713.size; ++_i715)
{
- _elem722 = new FieldSchema();
- _elem722.read(iprot);
- struct.success.add(_elem722);
+ _elem714 = new FieldSchema();
+ _elem714.read(iprot);
+ struct.success.add(_elem714);
}
}
struct.setSuccessIsSet(true);
@@ -39203,14 +38675,14 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list724 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list724.size);
- FieldSchema _elem725;
- for (int _i726 = 0; _i726 < _list724.size; ++_i726)
+ org.apache.thrift.protocol.TList _list716 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list716.size);
+ FieldSchema _elem717;
+ for (int _i718 = 0; _i718 < _list716.size; ++_i718)
{
- _elem725 = new FieldSchema();
- _elem725.read(iprot);
- struct.success.add(_elem725);
+ _elem717 = new FieldSchema();
+ _elem717.read(iprot);
+ struct.success.add(_elem717);
}
iprot.readListEnd();
}
@@ -39263,9 +38735,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (FieldSchema _iter727 : struct.success)
+ for (FieldSchema _iter719 : struct.success)
{
- _iter727.write(oprot);
+ _iter719.write(oprot);
}
oprot.writeListEnd();
}
@@ -39320,9 +38792,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter728 : struct.success)
+ for (FieldSchema _iter720 : struct.success)
{
- _iter728.write(oprot);
+ _iter720.write(oprot);
}
}
}
@@ -39343,14 +38815,14 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list729 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list729.size);
- FieldSchema _elem730;
- for (int _i731 = 0; _i731 < _list729.size; ++_i731)
+ org.apache.thrift.protocol.TList _list721 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list721.size);
+ FieldSchema _elem722;
+ for (int _i723 = 0; _i723 < _list721.size; ++_i723)
{
- _elem730 = new FieldSchema();
- _elem730.read(iprot);
- struct.success.add(_elem730);
+ _elem722 = new FieldSchema();
+ _elem722.read(iprot);
+ struct.success.add(_elem722);
}
}
struct.setSuccessIsSet(true);
@@ -40504,14 +39976,14 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list732 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list732.size);
- FieldSchema _elem733;
- for (int _i734 = 0; _i734 < _list732.size; ++_i734)
+ org.apache.thrift.protocol.TList _list724 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list724.size);
+ FieldSchema _elem725;
+ for (int _i726 = 0; _i726 < _list724.size; ++_i726)
{
- _elem733 = new FieldSchema();
- _elem733.read(iprot);
- struct.success.add(_elem733);
+ _elem725 = new FieldSchema();
+ _elem725.read(iprot);
+ struct.success.add(_elem725);
}
iprot.readListEnd();
}
@@ -40564,9 +40036,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (FieldSchema _iter735 : struct.success)
+ for (FieldSchema _iter727 : struct.success)
{
- _iter735.write(oprot);
+ _iter727.write(oprot);
}
oprot.writeListEnd();
}
@@ -40621,9 +40093,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter736 : struct.success)
+ for (FieldSchema _iter728 : struct.success)
{
- _iter736.write(oprot);
+ _iter728.write(oprot);
}
}
}
@@ -40644,14 +40116,14 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list737 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list737.size);
- FieldSchema _elem738;
- for (int _i739 = 0; _i739 < _list737.size; ++_i739)
+ org.apache.thrift.protocol.TList _list729 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list729.size);
+ FieldSchema _elem730;
+ for (int _i731 = 0; _i731 < _list729.size; ++_i731)
{
- _elem738 = new FieldSchema();
- _elem738.read(iprot);
- struct.success.add(_elem738);
+ _elem730 = new FieldSchema();
+ _elem730.read(iprot);
+ struct.success.add(_elem730);
}
}
struct.setSuccessIsSet(true);
@@ -43376,14 +42848,14 @@ public class ThriftHiveMetastore {
case 2: // PRIMARY_KEYS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list740 = iprot.readListBegin();
- struct.primaryKeys = new ArrayList<SQLPrimaryKey>(_list740.size);
- SQLPrimaryKey _elem741;
- for (int _i742 = 0; _i742 < _list740.size; ++_i742)
+ org.apache.thrift.protocol.TList _list732 = iprot.readListBegin();
+ struct.primaryKeys = new ArrayList<SQLPrimaryKey>(_list732.size);
+ SQLPrimaryKey _elem733;
+ for (int _i734 = 0; _i734 < _list732.size; ++_i734)
{
- _elem741 = new SQLPrimaryKey();
- _elem741.read(iprot);
- struct.primaryKeys.add(_elem741);
+ _elem733 = new SQLPrimaryKey();
+ _elem733.read(iprot);
+ struct.primaryKeys.add(_elem733);
}
iprot.readListEnd();
}
@@ -43395,14 +42867,14 @@ public class ThriftHiveMetastore {
case 3: // FOREIGN_KEYS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list743 = iprot.readListBegin();
- struct.foreignKeys = new ArrayList<SQLForeignKey>(_list743.size);
- SQLForeignKey _elem744;
- for (int _i745 = 0; _i745 < _list743.size; ++_i745)
+ org.apache.thrift.protocol.TList _list735 = iprot.readListBegin();
+ struct.foreignKeys = new ArrayList<SQLForeignKey>(_list735.size);
+ SQLForeignKey _elem736;
+ for (int _i737 = 0; _i737 < _list735.size; ++_i737)
{
- _elem744 = new SQLForeignKey();
- _elem744.read(iprot);
- struct.foreignKeys.add(_elem744);
+ _elem736 = new SQLForeignKey();
+ _elem736.read(iprot);
+ struct.foreignKeys.add(_elem736);
}
iprot.readListEnd();
}
@@ -43433,9 +42905,9 @@ public class ThriftHiveMetastore {
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 _iter746 : struct.primaryKeys)
+ for (SQLPrimaryKey _iter738 : struct.primaryKeys)
{
- _iter746.write(oprot);
+ _iter738.write(oprot);
}
oprot.writeListEnd();
}
@@ -43445,9 +42917,9 @@ public class ThriftHiveMetastore {
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 _iter747 : struct.foreignKeys)
+ for (SQLForeignKey _iter739 : struct.foreignKeys)
{
- _iter747.write(oprot);
+ _iter739.write(oprot);
}
oprot.writeListEnd();
}
@@ -43487,18 +42959,18 @@ public class ThriftHiveMetastore {
if (struct.isSetPrimaryKeys()) {
{
oprot.writeI32(struct.primaryKeys.size());
- for (SQLPrimaryKey _iter748 : struct.primaryKeys)
+ for (SQLPrimaryKey _iter740 : struct.primaryKeys)
{
- _iter748.write(oprot);
+ _iter740.write(oprot);
}
}
}
if (struct.isSetForeignKeys()) {
{
oprot.writeI32(struct.foreignKeys.size());
- for (SQLForeignKey _iter749 : struct.foreignKeys)
+ for (SQLForeignKey _iter741 : struct.foreignKeys)
{
- _iter749.write(oprot);
+ _iter741.write(oprot);
}
}
}
@@ -43515,28 +42987,28 @@ public class ThriftHiveMetastore {
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list750 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.primaryKeys = new ArrayList<SQLPrimaryKey>(_list750.size);
- SQLPrimaryKey _elem751;
- for (int _i752 = 0; _i752 < _list750.size; ++_i752)
+ org.apache.thrift.protocol.TList _list742 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.primaryKeys = new ArrayList<SQLPrimaryKey>(_list742.size);
+ SQLPrimaryKey _elem743;
+ for (int _i744 = 0; _i744 < _list742.size; ++_i744)
{
- _elem751 = new SQLPrimaryKey();
- _elem751.read(iprot);
- struct.primaryKeys.add(_elem751);
+ _elem743 = new SQLPrimaryKey();
+ _elem743.read(iprot);
+ struct.primaryKeys.add(_elem743);
}
}
struct.setPrimaryKeysIsSet(true);
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list753 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.foreignKeys = new ArrayList<SQLForeignKey>(_list753.size);
- SQLForeignKey _elem754;
- for (int _i755 = 0; _i755 < _list753.size; ++_i755)
+ org.apache.thrift.protocol.TList _list745 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.foreignKeys = new ArrayList<SQLForeignKey>(_list745.size);
+ SQLForeignKey _elem746;
+ for (int _i747 = 0; _i747 < _list745.size; ++_i747)
{
- _elem754 = new SQLForeignKey();
- _elem754.read(iprot);
- struct.foreignKeys.add(_elem754);
+ _elem746 = new SQLForeignKey();
+ _elem746.read(iprot);
+ struct.foreignKeys.add(_elem746);
}
}
struct.setForeignKeysIsSet(true);
@@ -49370,13 +48842,13 @@ public class ThriftHiveMetastore {
case 3: // PART_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list756 = iprot.readListBegin();
- struct.partNames = new ArrayList<String>(_list756.size);
- String _elem757;
- for (int _i758 = 0; _i758 < _list756.size; ++_i758)
+ org.apache.thrift.protocol.TList _list748 = iprot.readListBegin();
+ struct.partNames = new ArrayList<String>(_list748.size);
+ String _elem749;
+ for (int _i750 = 0; _i750 < _list748.size; ++_i750)
{
- _elem757 = iprot.readString();
- struct.partNames.add(_elem757);
+ _elem749 = iprot.readString();
+ struct.partNames.add(_elem749);
}
iprot.readListEnd();
}
@@ -49412,9 +48884,9 @@ public class ThriftHiveMetastore {
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 _iter759 : struct.partNames)
+ for (String _iter751 : struct.partNames)
{
- oprot.writeString(_iter759);
+ oprot.writeString(_iter751);
}
oprot.writeListEnd();
}
@@ -49457,9 +48929,9 @@ public class ThriftHiveMetastore {
if (struct.isSetPartNames()) {
{
oprot.writeI32(struct.partNames.size());
- for (String _iter760 : struct.partNames)
+ for (String _iter752 : struct.partNames)
{
- oprot.writeString(_iter760);
+ oprot.writeString(_iter752);
}
}
}
@@ -49479,13 +48951,13 @@ public class ThriftHiveMetastore {
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list761 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.partNames = new ArrayList<String>(_list761.size);
- String _elem762;
- for (int _i763 = 0; _i763 < _list761.size; ++_i763)
+ org.apache.thrift.protocol.TList _list753 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.partNames = new ArrayList<String>(_list753.size);
+ String _elem754;
+ for (int _i755 = 0; _i755 < _list753.size; ++_i755)
{
- _elem762 = iprot.readString();
- struct.partNames.add(_elem762);
+ _elem754 = iprot.readString();
+ struct.partNames.add(_elem754);
}
}
struct.setPartNamesIsSet(true);
@@ -50710,13 +50182,13 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list764 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list764.size);
- String _elem765;
- for (int _i766 = 0; _i766 < _list764.size; ++_i766)
+ org.apache.thrift.protocol.TList _list756 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list756.size);
+ String _elem757;
+ for (int _i758 = 0; _i758 < _list756.size; ++_i758)
{
- _elem765 = iprot.readString();
- struct.success.add(_elem765);
+ _elem757 = iprot.readString();
+ struct.success.add(_elem757);
}
iprot.readListEnd();
}
@@ -50751,9 +50223,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
- for (String _iter767 : struct.success)
+ for (String _iter759 : struct.success)
{
- oprot.writeString(_iter767);
+ oprot.writeString(_iter759);
}
oprot.writeListEnd();
}
@@ -50792,9 +50264,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter768 : struct.success)
+ for (String _iter760 : struct.success)
{
- oprot.writeString(_iter768);
+ oprot.writeString(_iter760);
}
}
}
@@ -50809,13 +50281,13 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list769 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list769.size);
- String _elem770;
- for (int _i771 = 0; _i771 < _list769.size; ++_i771)
+ org.apache.thrift.protocol.TList _list761 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list761.size);
+ String _elem762;
+ for (int _i763 = 0; _i763 < _list761.size; ++_i763)
{
- _elem770 = iprot.readString();
- struct.success.add(_elem770);
+ _elem762 = iprot.readString();
+ struct.success.add(_elem762);
}
}
struct.setSuccessIsSet(true);
@@ -51789,13 +51261,13 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list772 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list772.size);
- String _elem773;
- for (int _i774 = 0; _i774 < _list772.size; ++_i774)
+ org.apache.thrift.protocol.TList _list764 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list764.size);
+ String _elem765;
+ for (int _i766 = 0; _i766 < _list764.size; ++_i766)
{
- _elem773 = iprot.readString();
- struct.success.add(_elem773);
+ _elem765 = iprot.readString();
+ struct.success.add(_elem765);
}
iprot.readListEnd();
}
@@ -51830,9 +51302,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
- for (String _iter775 : struct.success)
+ for (String _iter767 : struct.success)
{
- oprot.writeString(_iter775);
+ oprot.writeString(_iter767);
}
oprot.writeListEnd();
}
@@ -51871,9 +51343,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter776 : struct.success)
+ for (String _iter768 : struct.success)
{
- oprot.writeString(_iter776);
+ oprot.writeString(_iter768);
}
}
}
@@ -51888,13 +51360,13 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list777 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list777.size);
- String _elem778;
- for (int _i779 = 0; _i779 < _list777.size; ++_i779)
+ org.apache.thrift.protocol.TList _list769 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list769.size);
+ String _elem770;
+ for (int _i771 = 0; _i771 < _list769.size; ++_i771)
{
- _elem778 = iprot.readString();
- struct.success.add(_elem778);
+ _elem770 = iprot.readString();
+ struct.success.add(_elem770);
}
}
struct.setSuccessIsSet(true);
@@ -52399,13 +51871,13 @@ public class ThriftHiveMetastore {
case 3: // TBL_TYPES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list780 = iprot.readListBegin();
- struct.tbl_types = new ArrayList<String>(_list780.size);
- String _elem781;
- for (int _i782 = 0; _i782 < _list780.size; ++_i782)
+ org.apache.thrift.protocol.TList _list772 = iprot.readListBegin();
+ struct.tbl_types = new ArrayList<String>(_list772.size);
+ String _elem773;
+ for (int _i774 = 0; _i774 < _list772.size; ++_i774)
{
- _elem781 = iprot.readString();
- struct.tbl_types.add(_elem781);
+ _elem773 = iprot.readString();
+ struct.tbl_types.add(_elem773);
}
iprot.readListEnd();
}
@@ -52441,9 +51913,9 @@ public class ThriftHiveMetastore {
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 _iter783 : struct.tbl_types)
+ for (String _iter775 : struct.tbl_types)
{
- oprot.writeString(_iter783);
+ oprot.writeString(_iter775);
}
oprot.writeListEnd();
}
@@ -52486,9 +51958,9 @@ public class ThriftHiveMetastore {
if (struct.isSetTbl_types()) {
{
oprot.writeI32(struct.tbl_types.size());
- for (String _iter784 : struct.tbl_types)
+ for (String _iter776 : struct.tbl_types)
{
- oprot.writeString(_iter784);
+ oprot.writeString(_iter776);
}
}
}
@@ -52508,13 +51980,13 @@ public class ThriftHiveMetastore {
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list785 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.tbl_types = new ArrayList<String>(_list785.size);
- String _elem786;
- for (int _i787 = 0; _i787 < _list785.size; ++_i787)
+ org.apache.thrift.protocol.TList _list777 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.tbl_types = new ArrayList<String>(_list777.size);
+ String _elem778;
+ for (int _i779 = 0; _i779 < _list777.size; ++_i779)
{
- _elem786 = iprot.readString();
- struct.tbl_types.add(_elem786);
+ _elem778 = iprot.readString();
+ struct.tbl_types.add(_elem778);
}
}
struct.setTbl_typesIsSet(true);
@@ -52920,14 +52392,14 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list788 = iprot.readListBegin();
- struct.success = new ArrayList<TableMeta>(_list788.size);
- TableMeta _elem789;
- for (int _i790 = 0; _i790 < _list788.size; ++_i790)
+ org.apache.thrift.protocol.TList _list780 = iprot.readListBegin();
+ struct.success = new ArrayList<TableMeta>(_list780.size);
+ TableMeta _elem781;
+ for (int _i782 = 0; _i782 < _list780.size; ++_i782)
{
- _elem789 = new TableMeta();
- _elem789.read(iprot);
- struct.success.add(_elem789);
+ _elem781 = new TableMeta();
+ _elem781.read(iprot);
+ struct.success.add(_elem781);
}
iprot.readListEnd();
}
@@ -52962,9 +52434,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (TableMeta _iter791 : struct.success)
+ for (TableMeta _iter783 : struct.success)
{
- _iter791.write(oprot);
+ _iter783.write(oprot);
}
oprot.writeListEnd();
}
@@ -53003,9 +52475,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (TableMeta _iter792 : struct.success)
+ for (TableMeta _iter784 : struct.success)
{
- _iter792.write(oprot);
+ _iter784.write(oprot);
}
}
}
@@ -53020,14 +52492,14 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list793 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<TableMeta>(_list793.size);
- TableMeta _elem794;
- for (int _i795 = 0; _i795 < _list793.size; ++_i795)
+ org.apache.thrift.protocol.TList _list785 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<TableMeta>(_list785.size);
+ TableMeta _elem786;
+ for (int _i787 = 0; _i787 < _list785.size; ++_i787)
{
- _elem794 = new TableMeta();
- _elem794.read(iprot);
- struct.success.add(_elem794);
+ _elem786 = new TableMeta();
+ _elem786.read(iprot);
+ struct.success.add(_elem786);
}
}
struct.setSuccessIsSet(true);
@@ -53793,13 +53265,13 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list796 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list796.size);
- String _elem797;
- for (int _i798 = 0; _i798 < _list796.size; ++_i798)
+ org.apache.thrift.protocol.TList _list788 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list788.size);
+ String _elem789;
+ for (int _i790 = 0; _i790 < _list788.size; ++_i790)
{
- _elem797 = iprot.readString();
- struct.success.add(_elem797);
+ _elem789 = iprot.readString();
+ struct.success.add(_elem789);
}
iprot.readListEnd();
}
@@ -53834,9 +53306,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
- for (String _iter799 : struct.success)
+ for (String _iter791 : struct.success)
{
- oprot.writeString(_iter799);
+ oprot.writeString(_iter791);
}
oprot.writeListEnd();
}
@@ -53875,9 +53347,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter800 : struct.success)
+ for (String _iter792 : struct.success)
{
- oprot.writeString(_iter800);
+ oprot.writeString(_iter792);
}
}
}
@@ -53892,13 +53364,13 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list801 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list801.size);
- String _elem802;
- for (int _i803 = 0; _i803 < _list801.size; ++_i803)
+ org.apache.thrift.protocol.TList _list793 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list793.size);
+ String _elem794;
+ for (int _i795 = 0; _i795 < _list793.size; ++_i795)
{
- _elem802 = iprot.readString();
- struct.success.add(_elem802);
+ _elem794 = iprot.readString();
+ struct.success.add(_elem794);
}
}
struct.setSuccessIsSet(true);
@@ -55351,13 +54823,13 @@ public class ThriftHiveMetastore {
case 2: // TBL_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list804 = iprot.readListBegin();
- struct.tbl_names = new ArrayList<String>(_list804.size);
- String _elem805;
- for (int _i806 = 0; _i806 < _list804.size; ++_i806)
+ org.apache.thrift.protocol.TList _list796 = iprot.readListBegin();
+ struct.tbl_names = new ArrayList<String>(_list796.size);
+ String _elem797;
+ for (int _i798 = 0; _i798 < _list796.size; ++_i798)
{
- _elem805 = iprot.readString();
- struct.tbl_names.add(_elem805);
+ _elem797 = iprot.readString();
+ struct.tbl_names.add(_elem797);
}
iprot.readListEnd();
}
@@ -55388,9 +54860,9 @@ public class ThriftHiveMetastore {
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 _iter807 : struct.tbl_names)
+ for (String _iter799 : struct.tbl_names)
{
- oprot.writeString(_iter807);
+ oprot.writeString(_iter799);
}
oprot.writeListEnd();
}
@@ -55427,9 +54899,9 @@ public class ThriftHiveMetastore {
if (struct.isSetTbl_names()) {
{
oprot.writeI32(struct.tbl_names.size());
- for (String _iter808 : struct.tbl_names)
+ for (String _iter800 : struct.tbl_names)
{
- oprot.writeString(_iter808);
+ oprot.writeString(_iter800);
}
}
}
@@ -55445,13 +54917,13 @@ public class ThriftHiveMetastore {
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list809 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.tbl_names = new ArrayList<String>(_list809.size);
- String _elem810;
- for (int _i811 = 0; _i811 < _list809.size; ++_i811)
+ org.apache.thrift.protocol.TList _list801 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.tbl_names = new ArrayList<String>(_list801.size);
+ String _elem802;
+ for (int _i803 = 0; _i803 < _list801.size; ++_i803)
{
- _elem810 = iprot.readString();
- struct.tbl_names.add(_elem810);
+ _elem802 = iprot.readString();
+ struct.tbl_names.add(_elem802);
}
}
struct.setTbl_namesIsSet(true);
@@ -55776,14 +55248,14 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list812 = iprot.readListBegin();
- struct.success = new ArrayList<Table>(_list812.size);
- Table _elem813;
- for (int _i814 = 0; _i814 < _list812.size; ++_i814)
+ org.apache.thrift.protocol.TList _list804 = iprot.readListBegin();
+ struct.success = new ArrayList<Table>(_list804.size);
+ Table _elem805;
+ for (int _i806 = 0; _i806 < _list804.size; ++_i806)
{
- _elem813 = new Table();
- _elem813.read(iprot);
- struct.success.add(_elem813);
+ _elem805 = new Table();
+ _elem805.read(iprot);
+ struct.success.add(_elem805);
}
iprot.readListEnd();
}
@@ -55809,9 +55281,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (Table _iter815 : struct.success)
+ for (Table _iter807 : struct.success)
{
- _iter815.write(oprot);
+ _iter807.write(oprot);
}
oprot.writeListEnd();
}
@@ -55842,9 +55314,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Table _iter816 : struct.success)
+ for (Table _iter808 : struct.success)
{
- _iter816.write(oprot);
+ _iter808.write(oprot);
}
}
}
@@ -55856,14 +55328,14 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list817 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<Table>(_list817.size);
- Table _elem818;
- for (int _i819 = 0; _i819 < _list817.size; ++_i819)
+ org.apache.thrift.protocol.TList _list809 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<Table>(_list809.size);
+ Table _elem810;
+ for (int _i811 = 0; _i811 < _list809.size; ++_i811)
{
- _elem818 = new Table();
- _elem818.read(iprot);
- struct.success.add(_elem818);
+ _elem810 = new Table();
+ _elem810.read(iprot);
+ struct.success.add(_elem810);
}
}
struct.setSuccessIsSet(true);
@@ -58976,13 +58448,13 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list820 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list820.size);
- String _elem821;
- for (int _i822 = 0; _i822 < _list820.size; ++_i822)
+ org.apache.thrift.protocol.TList _list812 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list812.size);
+ String _elem813;
+ for (int _i814 = 0; _i814 < _list812.size; ++_i814)
{
- _elem821 = iprot.readString();
- struct.success.add(_elem821);
+ _elem813 = iprot.readString();
+ struct.success.add(_elem813);
}
iprot.readListEnd();
}
@@ -59035,9 +58507,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
- for (String _iter823 : struct.success)
+ for (String _iter815 : struct.success)
{
- oprot.writeString(_iter823);
+ oprot.writeString(_iter815);
}
oprot.writeListEnd();
}
@@ -59092,9 +58564,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter824 : struct.success)
+ for (String _iter816 : struct.success)
{
- oprot.writeString(_iter824);
+ oprot.writeString(_iter816);
}
}
}
@@ -59115,13 +58587,13 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list825 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list825.size);
- String _elem826;
- for (int _i827 = 0; _i827 < _list825.size; ++_i827)
+ org.apache.thrift.protocol.TList _list817 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list817.size);
+ String _elem818;
+ for (int _i819 = 0; _i819 < _list817.size; ++_i819)
{
- _elem826 = iprot.readString();
- struct.success.add(_elem826);
+ _elem818 = iprot.readString();
+ struct.success.add(_elem818);
}
}
struct.setSuccessIsSet(true);
@@ -64980,14 +64452,14 @@ public class ThriftHiveMetastore {
case 1: // NEW_PARTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list828 = iprot.readListBegin();
- struct.new_parts = new ArrayList<Partition>(_list828.size);
- Partition _elem829;
- for (int _i830 = 0; _i830 < _list828.size; ++_i830)
+ org.apache.thrift.protocol.TList _list820 = iprot.readListBegin();
+ struct.new_parts = new ArrayList<Partition>(_list820.size);
+ Partition _elem821;
+ for (int _i822 = 0; _i822 < _list820.size; ++_i822)
{
- _elem829 = new Partition();
- _elem829.read(iprot);
- struct.new_parts.add(_elem829);
+ _elem821 = new Partition();
+ _elem821.read(iprot);
+ struct.new_parts.add(_elem821);
}
iprot.readListEnd();
}
@@ -65013,9 +64485,9 @@ public class ThriftHiveMetastore {
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 _iter831 : struct.new_parts)
+ for (Partition _iter823 : struct.new_parts)
{
- _iter831.write(oprot);
+ _iter823.write(oprot);
}
oprot.writeListEnd();
}
@@ -65046,9 +64518,9 @@ public class ThriftHiveMetastore {
if (struct.isSetNew_parts()) {
{
oprot.writeI32(struct.new_parts.size());
- for (Partition _iter832 : struct.new_parts)
+ for (Partition _iter824 : struct.new_parts)
{
- _iter832.write(oprot);
+ _iter824.write(oprot);
}
}
}
@@ -65060,14 +64532,14 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list833 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.new_parts = new ArrayList<Partition>(_list833.size);
- Partition _elem834;
- for (int _i835 = 0; _i835 < _list833.size; ++_i835)
+ org.apache.thrift.protocol.TList _list825 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.new_parts = new ArrayList<Partition>(_list825.size);
+ Partition _elem826;
+ for (int _i827 = 0; _i827 < _list825.size; ++_i827)
{
- _elem834 = new Partition();
- _elem834.read(iprot);
- struct.new_parts.add(_elem834);
+ _elem826 = new Partition();
+ _elem826.read(iprot);
+ struct.new_parts.add(_elem826);
}
}
struct.setNew_partsIsSet(true);
@@ -66068,14 +65540,14 @@ public class ThriftHiveMetastore {
case 1: // NEW_PARTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list836 = iprot.readListBegin();
- struct.new_parts = new ArrayList<PartitionSpec>(_list836.size);
- PartitionSpec _elem837;
- for (int _i838 = 0; _i838 < _list836.size; ++_i838)
+ org.apache.thrift.protocol.TList _list828 = iprot.readListBegin();
+ struct.new_parts = new ArrayList<PartitionSpec>(_list828.size);
+ PartitionSpec _elem829;
+ for (int _i830 = 0; _i830 < _list828.size; ++_i830)
{
- _elem837 = new PartitionSpec();
- _elem837.read(iprot);
- struct.new_parts.add(_elem837);
+ _elem829 = new PartitionSpec();
+ _elem829.read(iprot
<TRUNCATED>