You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by se...@apache.org on 2017/10/30 19:13:31 UTC
[12/16] hive git commit: HIVE-17884 : Implement create,
alter and drop workload management triggers (Harish Jaiprakash,
reviewed by Prasanth Jayachandran, Sergey Shelukhin)
http://git-wip-us.apache.org/repos/asf/hive/blob/c29df540/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 48bfb05..1e5bc08 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
@@ -378,6 +378,14 @@ import org.slf4j.LoggerFactory;
public WMDropResourcePlanResponse drop_resource_plan(WMDropResourcePlanRequest request) throws NoSuchObjectException, InvalidOperationException, MetaException, org.apache.thrift.TException;
+ public WMCreateTriggerResponse create_wm_trigger(WMCreateTriggerRequest request) throws AlreadyExistsException, NoSuchObjectException, InvalidObjectException, MetaException, org.apache.thrift.TException;
+
+ public WMAlterTriggerResponse alter_wm_trigger(WMAlterTriggerRequest request) throws NoSuchObjectException, InvalidObjectException, MetaException, org.apache.thrift.TException;
+
+ public WMDropTriggerResponse drop_wm_trigger(WMDropTriggerRequest request) throws NoSuchObjectException, InvalidOperationException, MetaException, org.apache.thrift.TException;
+
+ public WMGetTriggersForResourePlanResponse get_triggers_for_resourceplan(WMGetTriggersForResourePlanRequest request) throws NoSuchObjectException, MetaException, org.apache.thrift.TException;
+
}
@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public interface AsyncIface extends com.facebook.fb303.FacebookService .AsyncIface {
@@ -718,6 +726,14 @@ import org.slf4j.LoggerFactory;
public void drop_resource_plan(WMDropResourcePlanRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void create_wm_trigger(WMCreateTriggerRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void alter_wm_trigger(WMAlterTriggerRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void drop_wm_trigger(WMDropTriggerRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void get_triggers_for_resourceplan(WMGetTriggersForResourePlanRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
}
@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class Client extends com.facebook.fb303.FacebookService.Client implements Iface {
@@ -5565,6 +5581,134 @@ import org.slf4j.LoggerFactory;
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "drop_resource_plan failed: unknown result");
}
+ public WMCreateTriggerResponse create_wm_trigger(WMCreateTriggerRequest request) throws AlreadyExistsException, NoSuchObjectException, InvalidObjectException, MetaException, org.apache.thrift.TException
+ {
+ send_create_wm_trigger(request);
+ return recv_create_wm_trigger();
+ }
+
+ public void send_create_wm_trigger(WMCreateTriggerRequest request) throws org.apache.thrift.TException
+ {
+ create_wm_trigger_args args = new create_wm_trigger_args();
+ args.setRequest(request);
+ sendBase("create_wm_trigger", args);
+ }
+
+ public WMCreateTriggerResponse recv_create_wm_trigger() throws AlreadyExistsException, NoSuchObjectException, InvalidObjectException, MetaException, org.apache.thrift.TException
+ {
+ create_wm_trigger_result result = new create_wm_trigger_result();
+ receiveBase(result, "create_wm_trigger");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.o1 != null) {
+ throw result.o1;
+ }
+ if (result.o2 != null) {
+ throw result.o2;
+ }
+ if (result.o3 != null) {
+ throw result.o3;
+ }
+ if (result.o4 != null) {
+ throw result.o4;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "create_wm_trigger failed: unknown result");
+ }
+
+ public WMAlterTriggerResponse alter_wm_trigger(WMAlterTriggerRequest request) throws NoSuchObjectException, InvalidObjectException, MetaException, org.apache.thrift.TException
+ {
+ send_alter_wm_trigger(request);
+ return recv_alter_wm_trigger();
+ }
+
+ public void send_alter_wm_trigger(WMAlterTriggerRequest request) throws org.apache.thrift.TException
+ {
+ alter_wm_trigger_args args = new alter_wm_trigger_args();
+ args.setRequest(request);
+ sendBase("alter_wm_trigger", args);
+ }
+
+ public WMAlterTriggerResponse recv_alter_wm_trigger() throws NoSuchObjectException, InvalidObjectException, MetaException, org.apache.thrift.TException
+ {
+ alter_wm_trigger_result result = new alter_wm_trigger_result();
+ receiveBase(result, "alter_wm_trigger");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.o1 != null) {
+ throw result.o1;
+ }
+ if (result.o2 != null) {
+ throw result.o2;
+ }
+ if (result.o3 != null) {
+ throw result.o3;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "alter_wm_trigger failed: unknown result");
+ }
+
+ public WMDropTriggerResponse drop_wm_trigger(WMDropTriggerRequest request) throws NoSuchObjectException, InvalidOperationException, MetaException, org.apache.thrift.TException
+ {
+ send_drop_wm_trigger(request);
+ return recv_drop_wm_trigger();
+ }
+
+ public void send_drop_wm_trigger(WMDropTriggerRequest request) throws org.apache.thrift.TException
+ {
+ drop_wm_trigger_args args = new drop_wm_trigger_args();
+ args.setRequest(request);
+ sendBase("drop_wm_trigger", args);
+ }
+
+ public WMDropTriggerResponse recv_drop_wm_trigger() throws NoSuchObjectException, InvalidOperationException, MetaException, org.apache.thrift.TException
+ {
+ drop_wm_trigger_result result = new drop_wm_trigger_result();
+ receiveBase(result, "drop_wm_trigger");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.o1 != null) {
+ throw result.o1;
+ }
+ if (result.o2 != null) {
+ throw result.o2;
+ }
+ if (result.o3 != null) {
+ throw result.o3;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "drop_wm_trigger failed: unknown result");
+ }
+
+ public WMGetTriggersForResourePlanResponse get_triggers_for_resourceplan(WMGetTriggersForResourePlanRequest request) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
+ {
+ send_get_triggers_for_resourceplan(request);
+ return recv_get_triggers_for_resourceplan();
+ }
+
+ public void send_get_triggers_for_resourceplan(WMGetTriggersForResourePlanRequest request) throws org.apache.thrift.TException
+ {
+ get_triggers_for_resourceplan_args args = new get_triggers_for_resourceplan_args();
+ args.setRequest(request);
+ sendBase("get_triggers_for_resourceplan", args);
+ }
+
+ public WMGetTriggersForResourePlanResponse recv_get_triggers_for_resourceplan() throws NoSuchObjectException, MetaException, org.apache.thrift.TException
+ {
+ get_triggers_for_resourceplan_result result = new get_triggers_for_resourceplan_result();
+ receiveBase(result, "get_triggers_for_resourceplan");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.o1 != null) {
+ throw result.o1;
+ }
+ if (result.o2 != null) {
+ throw result.o2;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "get_triggers_for_resourceplan failed: unknown result");
+ }
+
}
@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class AsyncClient extends com.facebook.fb303.FacebookService.AsyncClient implements AsyncIface {
@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class Factory implements org.apache.thrift.async.TAsyncClientFactory<AsyncClient> {
@@ -11457,6 +11601,134 @@ import org.slf4j.LoggerFactory;
}
}
+ public void create_wm_trigger(WMCreateTriggerRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ create_wm_trigger_call method_call = new create_wm_trigger_call(request, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class create_wm_trigger_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private WMCreateTriggerRequest request;
+ public create_wm_trigger_call(WMCreateTriggerRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.request = request;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("create_wm_trigger", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ create_wm_trigger_args args = new create_wm_trigger_args();
+ args.setRequest(request);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public WMCreateTriggerResponse getResult() throws AlreadyExistsException, NoSuchObjectException, InvalidObjectException, MetaException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ return (new Client(prot)).recv_create_wm_trigger();
+ }
+ }
+
+ public void alter_wm_trigger(WMAlterTriggerRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ alter_wm_trigger_call method_call = new alter_wm_trigger_call(request, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class alter_wm_trigger_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private WMAlterTriggerRequest request;
+ public alter_wm_trigger_call(WMAlterTriggerRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.request = request;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("alter_wm_trigger", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ alter_wm_trigger_args args = new alter_wm_trigger_args();
+ args.setRequest(request);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public WMAlterTriggerResponse getResult() throws NoSuchObjectException, InvalidObjectException, MetaException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ return (new Client(prot)).recv_alter_wm_trigger();
+ }
+ }
+
+ public void drop_wm_trigger(WMDropTriggerRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ drop_wm_trigger_call method_call = new drop_wm_trigger_call(request, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class drop_wm_trigger_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private WMDropTriggerRequest request;
+ public drop_wm_trigger_call(WMDropTriggerRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.request = request;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("drop_wm_trigger", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ drop_wm_trigger_args args = new drop_wm_trigger_args();
+ args.setRequest(request);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public WMDropTriggerResponse getResult() throws NoSuchObjectException, InvalidOperationException, MetaException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ return (new Client(prot)).recv_drop_wm_trigger();
+ }
+ }
+
+ public void get_triggers_for_resourceplan(WMGetTriggersForResourePlanRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ get_triggers_for_resourceplan_call method_call = new get_triggers_for_resourceplan_call(request, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class get_triggers_for_resourceplan_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private WMGetTriggersForResourePlanRequest request;
+ public get_triggers_for_resourceplan_call(WMGetTriggersForResourePlanRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.request = request;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("get_triggers_for_resourceplan", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ get_triggers_for_resourceplan_args args = new get_triggers_for_resourceplan_args();
+ args.setRequest(request);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public WMGetTriggersForResourePlanResponse getResult() throws NoSuchObjectException, MetaException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ return (new Client(prot)).recv_get_triggers_for_resourceplan();
+ }
+ }
+
}
@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class Processor<I extends Iface> extends com.facebook.fb303.FacebookService.Processor<I> implements org.apache.thrift.TProcessor {
@@ -11638,6 +11910,10 @@ import org.slf4j.LoggerFactory;
processMap.put("alter_resource_plan", new alter_resource_plan());
processMap.put("validate_resource_plan", new validate_resource_plan());
processMap.put("drop_resource_plan", new drop_resource_plan());
+ processMap.put("create_wm_trigger", new create_wm_trigger());
+ processMap.put("alter_wm_trigger", new alter_wm_trigger());
+ processMap.put("drop_wm_trigger", new drop_wm_trigger());
+ processMap.put("get_triggers_for_resourceplan", new get_triggers_for_resourceplan());
return processMap;
}
@@ -15921,6 +16197,118 @@ import org.slf4j.LoggerFactory;
}
}
+ public static class create_wm_trigger<I extends Iface> extends org.apache.thrift.ProcessFunction<I, create_wm_trigger_args> {
+ public create_wm_trigger() {
+ super("create_wm_trigger");
+ }
+
+ public create_wm_trigger_args getEmptyArgsInstance() {
+ return new create_wm_trigger_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public create_wm_trigger_result getResult(I iface, create_wm_trigger_args args) throws org.apache.thrift.TException {
+ create_wm_trigger_result result = new create_wm_trigger_result();
+ try {
+ result.success = iface.create_wm_trigger(args.request);
+ } catch (AlreadyExistsException o1) {
+ result.o1 = o1;
+ } catch (NoSuchObjectException o2) {
+ result.o2 = o2;
+ } catch (InvalidObjectException o3) {
+ result.o3 = o3;
+ } catch (MetaException o4) {
+ result.o4 = o4;
+ }
+ return result;
+ }
+ }
+
+ public static class alter_wm_trigger<I extends Iface> extends org.apache.thrift.ProcessFunction<I, alter_wm_trigger_args> {
+ public alter_wm_trigger() {
+ super("alter_wm_trigger");
+ }
+
+ public alter_wm_trigger_args getEmptyArgsInstance() {
+ return new alter_wm_trigger_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public alter_wm_trigger_result getResult(I iface, alter_wm_trigger_args args) throws org.apache.thrift.TException {
+ alter_wm_trigger_result result = new alter_wm_trigger_result();
+ try {
+ result.success = iface.alter_wm_trigger(args.request);
+ } catch (NoSuchObjectException o1) {
+ result.o1 = o1;
+ } catch (InvalidObjectException o2) {
+ result.o2 = o2;
+ } catch (MetaException o3) {
+ result.o3 = o3;
+ }
+ return result;
+ }
+ }
+
+ public static class drop_wm_trigger<I extends Iface> extends org.apache.thrift.ProcessFunction<I, drop_wm_trigger_args> {
+ public drop_wm_trigger() {
+ super("drop_wm_trigger");
+ }
+
+ public drop_wm_trigger_args getEmptyArgsInstance() {
+ return new drop_wm_trigger_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public drop_wm_trigger_result getResult(I iface, drop_wm_trigger_args args) throws org.apache.thrift.TException {
+ drop_wm_trigger_result result = new drop_wm_trigger_result();
+ try {
+ result.success = iface.drop_wm_trigger(args.request);
+ } catch (NoSuchObjectException o1) {
+ result.o1 = o1;
+ } catch (InvalidOperationException o2) {
+ result.o2 = o2;
+ } catch (MetaException o3) {
+ result.o3 = o3;
+ }
+ return result;
+ }
+ }
+
+ public static class get_triggers_for_resourceplan<I extends Iface> extends org.apache.thrift.ProcessFunction<I, get_triggers_for_resourceplan_args> {
+ public get_triggers_for_resourceplan() {
+ super("get_triggers_for_resourceplan");
+ }
+
+ public get_triggers_for_resourceplan_args getEmptyArgsInstance() {
+ return new get_triggers_for_resourceplan_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public get_triggers_for_resourceplan_result getResult(I iface, get_triggers_for_resourceplan_args args) throws org.apache.thrift.TException {
+ get_triggers_for_resourceplan_result result = new get_triggers_for_resourceplan_result();
+ try {
+ result.success = iface.get_triggers_for_resourceplan(args.request);
+ } catch (NoSuchObjectException o1) {
+ result.o1 = o1;
+ } catch (MetaException o2) {
+ result.o2 = o2;
+ }
+ return result;
+ }
+ }
+
}
@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class AsyncProcessor<I extends AsyncIface> extends com.facebook.fb303.FacebookService.AsyncProcessor<I> {
@@ -16102,6 +16490,10 @@ import org.slf4j.LoggerFactory;
processMap.put("alter_resource_plan", new alter_resource_plan());
processMap.put("validate_resource_plan", new validate_resource_plan());
processMap.put("drop_resource_plan", new drop_resource_plan());
+ processMap.put("create_wm_trigger", new create_wm_trigger());
+ processMap.put("alter_wm_trigger", new alter_wm_trigger());
+ processMap.put("drop_wm_trigger", new drop_wm_trigger());
+ processMap.put("get_triggers_for_resourceplan", new get_triggers_for_resourceplan());
return processMap;
}
@@ -26321,6 +26713,274 @@ import org.slf4j.LoggerFactory;
}
}
+ public static class create_wm_trigger<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, create_wm_trigger_args, WMCreateTriggerResponse> {
+ public create_wm_trigger() {
+ super("create_wm_trigger");
+ }
+
+ public create_wm_trigger_args getEmptyArgsInstance() {
+ return new create_wm_trigger_args();
+ }
+
+ public AsyncMethodCallback<WMCreateTriggerResponse> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.thrift.AsyncProcessFunction fcall = this;
+ return new AsyncMethodCallback<WMCreateTriggerResponse>() {
+ public void onComplete(WMCreateTriggerResponse o) {
+ create_wm_trigger_result result = new create_wm_trigger_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;
+ create_wm_trigger_result result = new create_wm_trigger_result();
+ if (e instanceof AlreadyExistsException) {
+ result.o1 = (AlreadyExistsException) e;
+ result.setO1IsSet(true);
+ msg = result;
+ }
+ else if (e instanceof NoSuchObjectException) {
+ result.o2 = (NoSuchObjectException) e;
+ result.setO2IsSet(true);
+ msg = result;
+ }
+ else if (e instanceof InvalidObjectException) {
+ result.o3 = (InvalidObjectException) e;
+ result.setO3IsSet(true);
+ msg = result;
+ }
+ else if (e instanceof MetaException) {
+ result.o4 = (MetaException) e;
+ result.setO4IsSet(true);
+ msg = result;
+ }
+ else
+ {
+ msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
+ msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
+ }
+ try {
+ fcall.sendResponse(fb,msg,msgType,seqid);
+ return;
+ } catch (Exception ex) {
+ LOGGER.error("Exception writing to internal frame buffer", ex);
+ }
+ fb.close();
+ }
+ };
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public void start(I iface, create_wm_trigger_args args, org.apache.thrift.async.AsyncMethodCallback<WMCreateTriggerResponse> resultHandler) throws TException {
+ iface.create_wm_trigger(args.request,resultHandler);
+ }
+ }
+
+ public static class alter_wm_trigger<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, alter_wm_trigger_args, WMAlterTriggerResponse> {
+ public alter_wm_trigger() {
+ super("alter_wm_trigger");
+ }
+
+ public alter_wm_trigger_args getEmptyArgsInstance() {
+ return new alter_wm_trigger_args();
+ }
+
+ public AsyncMethodCallback<WMAlterTriggerResponse> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.thrift.AsyncProcessFunction fcall = this;
+ return new AsyncMethodCallback<WMAlterTriggerResponse>() {
+ public void onComplete(WMAlterTriggerResponse o) {
+ alter_wm_trigger_result result = new alter_wm_trigger_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;
+ alter_wm_trigger_result result = new alter_wm_trigger_result();
+ if (e instanceof NoSuchObjectException) {
+ result.o1 = (NoSuchObjectException) e;
+ result.setO1IsSet(true);
+ msg = result;
+ }
+ else if (e instanceof InvalidObjectException) {
+ result.o2 = (InvalidObjectException) e;
+ result.setO2IsSet(true);
+ msg = result;
+ }
+ else if (e instanceof MetaException) {
+ result.o3 = (MetaException) e;
+ result.setO3IsSet(true);
+ msg = result;
+ }
+ else
+ {
+ msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
+ msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
+ }
+ try {
+ fcall.sendResponse(fb,msg,msgType,seqid);
+ return;
+ } catch (Exception ex) {
+ LOGGER.error("Exception writing to internal frame buffer", ex);
+ }
+ fb.close();
+ }
+ };
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public void start(I iface, alter_wm_trigger_args args, org.apache.thrift.async.AsyncMethodCallback<WMAlterTriggerResponse> resultHandler) throws TException {
+ iface.alter_wm_trigger(args.request,resultHandler);
+ }
+ }
+
+ public static class drop_wm_trigger<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, drop_wm_trigger_args, WMDropTriggerResponse> {
+ public drop_wm_trigger() {
+ super("drop_wm_trigger");
+ }
+
+ public drop_wm_trigger_args getEmptyArgsInstance() {
+ return new drop_wm_trigger_args();
+ }
+
+ public AsyncMethodCallback<WMDropTriggerResponse> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.thrift.AsyncProcessFunction fcall = this;
+ return new AsyncMethodCallback<WMDropTriggerResponse>() {
+ public void onComplete(WMDropTriggerResponse o) {
+ drop_wm_trigger_result result = new drop_wm_trigger_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;
+ drop_wm_trigger_result result = new drop_wm_trigger_result();
+ if (e instanceof NoSuchObjectException) {
+ result.o1 = (NoSuchObjectException) e;
+ result.setO1IsSet(true);
+ msg = result;
+ }
+ else if (e instanceof InvalidOperationException) {
+ result.o2 = (InvalidOperationException) e;
+ result.setO2IsSet(true);
+ msg = result;
+ }
+ else if (e instanceof MetaException) {
+ result.o3 = (MetaException) e;
+ result.setO3IsSet(true);
+ msg = result;
+ }
+ else
+ {
+ msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
+ msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
+ }
+ try {
+ fcall.sendResponse(fb,msg,msgType,seqid);
+ return;
+ } catch (Exception ex) {
+ LOGGER.error("Exception writing to internal frame buffer", ex);
+ }
+ fb.close();
+ }
+ };
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public void start(I iface, drop_wm_trigger_args args, org.apache.thrift.async.AsyncMethodCallback<WMDropTriggerResponse> resultHandler) throws TException {
+ iface.drop_wm_trigger(args.request,resultHandler);
+ }
+ }
+
+ public static class get_triggers_for_resourceplan<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_triggers_for_resourceplan_args, WMGetTriggersForResourePlanResponse> {
+ public get_triggers_for_resourceplan() {
+ super("get_triggers_for_resourceplan");
+ }
+
+ public get_triggers_for_resourceplan_args getEmptyArgsInstance() {
+ return new get_triggers_for_resourceplan_args();
+ }
+
+ public AsyncMethodCallback<WMGetTriggersForResourePlanResponse> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.thrift.AsyncProcessFunction fcall = this;
+ return new AsyncMethodCallback<WMGetTriggersForResourePlanResponse>() {
+ public void onComplete(WMGetTriggersForResourePlanResponse o) {
+ get_triggers_for_resourceplan_result result = new get_triggers_for_resourceplan_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_triggers_for_resourceplan_result result = new get_triggers_for_resourceplan_result();
+ if (e instanceof NoSuchObjectException) {
+ result.o1 = (NoSuchObjectException) e;
+ result.setO1IsSet(true);
+ msg = result;
+ }
+ else if (e instanceof MetaException) {
+ result.o2 = (MetaException) e;
+ result.setO2IsSet(true);
+ msg = result;
+ }
+ else
+ {
+ msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
+ msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
+ }
+ try {
+ fcall.sendResponse(fb,msg,msgType,seqid);
+ return;
+ } catch (Exception ex) {
+ LOGGER.error("Exception writing to internal frame buffer", ex);
+ }
+ fb.close();
+ }
+ };
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public void start(I iface, get_triggers_for_resourceplan_args args, org.apache.thrift.async.AsyncMethodCallback<WMGetTriggersForResourePlanResponse> resultHandler) throws TException {
+ iface.get_triggers_for_resourceplan(args.request,resultHandler);
+ }
+ }
+
}
@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class getMetaConf_args implements org.apache.thrift.TBase<getMetaConf_args, getMetaConf_args._Fields>, java.io.Serializable, Cloneable, Comparable<getMetaConf_args> {
@@ -31716,13 +32376,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list746 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list746.size);
- String _elem747;
- for (int _i748 = 0; _i748 < _list746.size; ++_i748)
+ org.apache.thrift.protocol.TList _list754 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list754.size);
+ String _elem755;
+ for (int _i756 = 0; _i756 < _list754.size; ++_i756)
{
- _elem747 = iprot.readString();
- struct.success.add(_elem747);
+ _elem755 = iprot.readString();
+ struct.success.add(_elem755);
}
iprot.readListEnd();
}
@@ -31757,9 +32417,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 _iter749 : struct.success)
+ for (String _iter757 : struct.success)
{
- oprot.writeString(_iter749);
+ oprot.writeString(_iter757);
}
oprot.writeListEnd();
}
@@ -31798,9 +32458,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter750 : struct.success)
+ for (String _iter758 : struct.success)
{
- oprot.writeString(_iter750);
+ oprot.writeString(_iter758);
}
}
}
@@ -31815,13 +32475,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list751 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list751.size);
- String _elem752;
- for (int _i753 = 0; _i753 < _list751.size; ++_i753)
+ org.apache.thrift.protocol.TList _list759 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list759.size);
+ String _elem760;
+ for (int _i761 = 0; _i761 < _list759.size; ++_i761)
{
- _elem752 = iprot.readString();
- struct.success.add(_elem752);
+ _elem760 = iprot.readString();
+ struct.success.add(_elem760);
}
}
struct.setSuccessIsSet(true);
@@ -32475,13 +33135,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list754 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list754.size);
- String _elem755;
- for (int _i756 = 0; _i756 < _list754.size; ++_i756)
+ org.apache.thrift.protocol.TList _list762 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list762.size);
+ String _elem763;
+ for (int _i764 = 0; _i764 < _list762.size; ++_i764)
{
- _elem755 = iprot.readString();
- struct.success.add(_elem755);
+ _elem763 = iprot.readString();
+ struct.success.add(_elem763);
}
iprot.readListEnd();
}
@@ -32516,9 +33176,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 _iter757 : struct.success)
+ for (String _iter765 : struct.success)
{
- oprot.writeString(_iter757);
+ oprot.writeString(_iter765);
}
oprot.writeListEnd();
}
@@ -32557,9 +33217,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter758 : struct.success)
+ for (String _iter766 : struct.success)
{
- oprot.writeString(_iter758);
+ oprot.writeString(_iter766);
}
}
}
@@ -32574,13 +33234,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list759 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list759.size);
- String _elem760;
- for (int _i761 = 0; _i761 < _list759.size; ++_i761)
+ org.apache.thrift.protocol.TList _list767 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list767.size);
+ String _elem768;
+ for (int _i769 = 0; _i769 < _list767.size; ++_i769)
{
- _elem760 = iprot.readString();
- struct.success.add(_elem760);
+ _elem768 = iprot.readString();
+ struct.success.add(_elem768);
}
}
struct.setSuccessIsSet(true);
@@ -37187,16 +37847,16 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map762 = iprot.readMapBegin();
- struct.success = new HashMap<String,Type>(2*_map762.size);
- String _key763;
- Type _val764;
- for (int _i765 = 0; _i765 < _map762.size; ++_i765)
+ org.apache.thrift.protocol.TMap _map770 = iprot.readMapBegin();
+ struct.success = new HashMap<String,Type>(2*_map770.size);
+ String _key771;
+ Type _val772;
+ for (int _i773 = 0; _i773 < _map770.size; ++_i773)
{
- _key763 = iprot.readString();
- _val764 = new Type();
- _val764.read(iprot);
- struct.success.put(_key763, _val764);
+ _key771 = iprot.readString();
+ _val772 = new Type();
+ _val772.read(iprot);
+ struct.success.put(_key771, _val772);
}
iprot.readMapEnd();
}
@@ -37231,10 +37891,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> _iter766 : struct.success.entrySet())
+ for (Map.Entry<String, Type> _iter774 : struct.success.entrySet())
{
- oprot.writeString(_iter766.getKey());
- _iter766.getValue().write(oprot);
+ oprot.writeString(_iter774.getKey());
+ _iter774.getValue().write(oprot);
}
oprot.writeMapEnd();
}
@@ -37273,10 +37933,10 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Map.Entry<String, Type> _iter767 : struct.success.entrySet())
+ for (Map.Entry<String, Type> _iter775 : struct.success.entrySet())
{
- oprot.writeString(_iter767.getKey());
- _iter767.getValue().write(oprot);
+ oprot.writeString(_iter775.getKey());
+ _iter775.getValue().write(oprot);
}
}
}
@@ -37291,16 +37951,16 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TMap _map768 = 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*_map768.size);
- String _key769;
- Type _val770;
- for (int _i771 = 0; _i771 < _map768.size; ++_i771)
+ org.apache.thrift.protocol.TMap _map776 = 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*_map776.size);
+ String _key777;
+ Type _val778;
+ for (int _i779 = 0; _i779 < _map776.size; ++_i779)
{
- _key769 = iprot.readString();
- _val770 = new Type();
- _val770.read(iprot);
- struct.success.put(_key769, _val770);
+ _key777 = iprot.readString();
+ _val778 = new Type();
+ _val778.read(iprot);
+ struct.success.put(_key777, _val778);
}
}
struct.setSuccessIsSet(true);
@@ -38335,14 +38995,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list772 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list772.size);
- FieldSchema _elem773;
- for (int _i774 = 0; _i774 < _list772.size; ++_i774)
+ org.apache.thrift.protocol.TList _list780 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list780.size);
+ FieldSchema _elem781;
+ for (int _i782 = 0; _i782 < _list780.size; ++_i782)
{
- _elem773 = new FieldSchema();
- _elem773.read(iprot);
- struct.success.add(_elem773);
+ _elem781 = new FieldSchema();
+ _elem781.read(iprot);
+ struct.success.add(_elem781);
}
iprot.readListEnd();
}
@@ -38395,9 +39055,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 _iter775 : struct.success)
+ for (FieldSchema _iter783 : struct.success)
{
- _iter775.write(oprot);
+ _iter783.write(oprot);
}
oprot.writeListEnd();
}
@@ -38452,9 +39112,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter776 : struct.success)
+ for (FieldSchema _iter784 : struct.success)
{
- _iter776.write(oprot);
+ _iter784.write(oprot);
}
}
}
@@ -38475,14 +39135,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list777 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list777.size);
- FieldSchema _elem778;
- for (int _i779 = 0; _i779 < _list777.size; ++_i779)
+ org.apache.thrift.protocol.TList _list785 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list785.size);
+ FieldSchema _elem786;
+ for (int _i787 = 0; _i787 < _list785.size; ++_i787)
{
- _elem778 = new FieldSchema();
- _elem778.read(iprot);
- struct.success.add(_elem778);
+ _elem786 = new FieldSchema();
+ _elem786.read(iprot);
+ struct.success.add(_elem786);
}
}
struct.setSuccessIsSet(true);
@@ -39636,14 +40296,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list780 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list780.size);
- FieldSchema _elem781;
- for (int _i782 = 0; _i782 < _list780.size; ++_i782)
+ org.apache.thrift.protocol.TList _list788 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list788.size);
+ FieldSchema _elem789;
+ for (int _i790 = 0; _i790 < _list788.size; ++_i790)
{
- _elem781 = new FieldSchema();
- _elem781.read(iprot);
- struct.success.add(_elem781);
+ _elem789 = new FieldSchema();
+ _elem789.read(iprot);
+ struct.success.add(_elem789);
}
iprot.readListEnd();
}
@@ -39696,9 +40356,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 _iter783 : struct.success)
+ for (FieldSchema _iter791 : struct.success)
{
- _iter783.write(oprot);
+ _iter791.write(oprot);
}
oprot.writeListEnd();
}
@@ -39753,9 +40413,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter784 : struct.success)
+ for (FieldSchema _iter792 : struct.success)
{
- _iter784.write(oprot);
+ _iter792.write(oprot);
}
}
}
@@ -39776,14 +40436,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list785 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list785.size);
- FieldSchema _elem786;
- for (int _i787 = 0; _i787 < _list785.size; ++_i787)
+ org.apache.thrift.protocol.TList _list793 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list793.size);
+ FieldSchema _elem794;
+ for (int _i795 = 0; _i795 < _list793.size; ++_i795)
{
- _elem786 = new FieldSchema();
- _elem786.read(iprot);
- struct.success.add(_elem786);
+ _elem794 = new FieldSchema();
+ _elem794.read(iprot);
+ struct.success.add(_elem794);
}
}
struct.setSuccessIsSet(true);
@@ -40828,14 +41488,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list788 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list788.size);
- FieldSchema _elem789;
- for (int _i790 = 0; _i790 < _list788.size; ++_i790)
+ org.apache.thrift.protocol.TList _list796 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list796.size);
+ FieldSchema _elem797;
+ for (int _i798 = 0; _i798 < _list796.size; ++_i798)
{
- _elem789 = new FieldSchema();
- _elem789.read(iprot);
- struct.success.add(_elem789);
+ _elem797 = new FieldSchema();
+ _elem797.read(iprot);
+ struct.success.add(_elem797);
}
iprot.readListEnd();
}
@@ -40888,9 +41548,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 _iter791 : struct.success)
+ for (FieldSchema _iter799 : struct.success)
{
- _iter791.write(oprot);
+ _iter799.write(oprot);
}
oprot.writeListEnd();
}
@@ -40945,9 +41605,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter792 : struct.success)
+ for (FieldSchema _iter800 : struct.success)
{
- _iter792.write(oprot);
+ _iter800.write(oprot);
}
}
}
@@ -40968,14 +41628,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
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<FieldSchema>(_list793.size);
- FieldSchema _elem794;
- for (int _i795 = 0; _i795 < _list793.size; ++_i795)
+ org.apache.thrift.protocol.TList _list801 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list801.size);
+ FieldSchema _elem802;
+ for (int _i803 = 0; _i803 < _list801.size; ++_i803)
{
- _elem794 = new FieldSchema();
- _elem794.read(iprot);
- struct.success.add(_elem794);
+ _elem802 = new FieldSchema();
+ _elem802.read(iprot);
+ struct.success.add(_elem802);
}
}
struct.setSuccessIsSet(true);
@@ -42129,14 +42789,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list796 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list796.size);
- FieldSchema _elem797;
- for (int _i798 = 0; _i798 < _list796.size; ++_i798)
+ org.apache.thrift.protocol.TList _list804 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list804.size);
+ FieldSchema _elem805;
+ for (int _i806 = 0; _i806 < _list804.size; ++_i806)
{
- _elem797 = new FieldSchema();
- _elem797.read(iprot);
- struct.success.add(_elem797);
+ _elem805 = new FieldSchema();
+ _elem805.read(iprot);
+ struct.success.add(_elem805);
}
iprot.readListEnd();
}
@@ -42189,9 +42849,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 _iter799 : struct.success)
+ for (FieldSchema _iter807 : struct.success)
{
- _iter799.write(oprot);
+ _iter807.write(oprot);
}
oprot.writeListEnd();
}
@@ -42246,9 +42906,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter800 : struct.success)
+ for (FieldSchema _iter808 : struct.success)
{
- _iter800.write(oprot);
+ _iter808.write(oprot);
}
}
}
@@ -42269,14 +42929,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list801 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list801.size);
- FieldSchema _elem802;
- for (int _i803 = 0; _i803 < _list801.size; ++_i803)
+ org.apache.thrift.protocol.TList _list809 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list809.size);
+ FieldSchema _elem810;
+ for (int _i811 = 0; _i811 < _list809.size; ++_i811)
{
- _elem802 = new FieldSchema();
- _elem802.read(iprot);
- struct.success.add(_elem802);
+ _elem810 = new FieldSchema();
+ _elem810.read(iprot);
+ struct.success.add(_elem810);
}
}
struct.setSuccessIsSet(true);
@@ -45203,14 +45863,14 @@ import org.slf4j.LoggerFactory;
case 2: // PRIMARY_KEYS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list804 = iprot.readListBegin();
- struct.primaryKeys = new ArrayList<SQLPrimaryKey>(_list804.size);
- SQLPrimaryKey _elem805;
- for (int _i806 = 0; _i806 < _list804.size; ++_i806)
+ org.apache.thrift.protocol.TList _list812 = iprot.readListBegin();
+ struct.primaryKeys = new ArrayList<SQLPrimaryKey>(_list812.size);
+ SQLPrimaryKey _elem813;
+ for (int _i814 = 0; _i814 < _list812.size; ++_i814)
{
- _elem805 = new SQLPrimaryKey();
- _elem805.read(iprot);
- struct.primaryKeys.add(_elem805);
+ _elem813 = new SQLPrimaryKey();
+ _elem813.read(iprot);
+ struct.primaryKeys.add(_elem813);
}
iprot.readListEnd();
}
@@ -45222,14 +45882,14 @@ import org.slf4j.LoggerFactory;
case 3: // FOREIGN_KEYS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list807 = iprot.readListBegin();
- struct.foreignKeys = new ArrayList<SQLForeignKey>(_list807.size);
- SQLForeignKey _elem808;
- for (int _i809 = 0; _i809 < _list807.size; ++_i809)
+ org.apache.thrift.protocol.TList _list815 = iprot.readListBegin();
+ struct.foreignKeys = new ArrayList<SQLForeignKey>(_list815.size);
+ SQLForeignKey _elem816;
+ for (int _i817 = 0; _i817 < _list815.size; ++_i817)
{
- _elem808 = new SQLForeignKey();
- _elem808.read(iprot);
- struct.foreignKeys.add(_elem808);
+ _elem816 = new SQLForeignKey();
+ _elem816.read(iprot);
+ struct.foreignKeys.add(_elem816);
}
iprot.readListEnd();
}
@@ -45241,14 +45901,14 @@ import org.slf4j.LoggerFactory;
case 4: // UNIQUE_CONSTRAINTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list810 = iprot.readListBegin();
- struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list810.size);
- SQLUniqueConstraint _elem811;
- for (int _i812 = 0; _i812 < _list810.size; ++_i812)
+ org.apache.thrift.protocol.TList _list818 = iprot.readListBegin();
+ struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list818.size);
+ SQLUniqueConstraint _elem819;
+ for (int _i820 = 0; _i820 < _list818.size; ++_i820)
{
- _elem811 = new SQLUniqueConstraint();
- _elem811.read(iprot);
- struct.uniqueConstraints.add(_elem811);
+ _elem819 = new SQLUniqueConstraint();
+ _elem819.read(iprot);
+ struct.uniqueConstraints.add(_elem819);
}
iprot.readListEnd();
}
@@ -45260,14 +45920,14 @@ import org.slf4j.LoggerFactory;
case 5: // NOT_NULL_CONSTRAINTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list813 = iprot.readListBegin();
- struct.notNullConstraints = new ArrayList<SQLNotNullConstraint>(_list813.size);
- SQLNotNullConstraint _elem814;
- for (int _i815 = 0; _i815 < _list813.size; ++_i815)
+ org.apache.thrift.protocol.TList _list821 = iprot.readListBegin();
+ struct.notNullConstraints = new ArrayList<SQLNotNullConstraint>(_list821.size);
+ SQLNotNullConstraint _elem822;
+ for (int _i823 = 0; _i823 < _list821.size; ++_i823)
{
- _elem814 = new SQLNotNullConstraint();
- _elem814.read(iprot);
- struct.notNullConstraints.add(_elem814);
+ _elem822 = new SQLNotNullConstraint();
+ _elem822.read(iprot);
+ struct.notNullConstraints.add(_elem822);
}
iprot.readListEnd();
}
@@ -45298,9 +45958,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 _iter816 : struct.primaryKeys)
+ for (SQLPrimaryKey _iter824 : struct.primaryKeys)
{
- _iter816.write(oprot);
+ _iter824.write(oprot);
}
oprot.writeListEnd();
}
@@ -45310,9 +45970,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 _iter817 : struct.foreignKeys)
+ for (SQLForeignKey _iter825 : struct.foreignKeys)
{
- _iter817.write(oprot);
+ _iter825.write(oprot);
}
oprot.writeListEnd();
}
@@ -45322,9 +45982,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 _iter818 : struct.uniqueConstraints)
+ for (SQLUniqueConstraint _iter826 : struct.uniqueConstraints)
{
- _iter818.write(oprot);
+ _iter826.write(oprot);
}
oprot.writeListEnd();
}
@@ -45334,9 +45994,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 _iter819 : struct.notNullConstraints)
+ for (SQLNotNullConstraint _iter827 : struct.notNullConstraints)
{
- _iter819.write(oprot);
+ _iter827.write(oprot);
}
oprot.writeListEnd();
}
@@ -45382,36 +46042,36 @@ import org.slf4j.LoggerFactory;
if (struct.isSetPrimaryKeys()) {
{
oprot.writeI32(struct.primaryKeys.size());
- for (SQLPrimaryKey _iter820 : struct.primaryKeys)
+ for (SQLPrimaryKey _iter828 : struct.primaryKeys)
{
- _iter820.write(oprot);
+ _iter828.write(oprot);
}
}
}
if (struct.isSetForeignKeys()) {
{
oprot.writeI32(struct.foreignKeys.size());
- for (SQLForeignKey _iter821 : struct.foreignKeys)
+ for (SQLForeignKey _iter829 : struct.foreignKeys)
{
- _iter821.write(oprot);
+ _iter829.write(oprot);
}
}
}
if (struct.isSetUniqueConstraints()) {
{
oprot.writeI32(struct.uniqueConstraints.size());
- for (SQLUniqueConstraint _iter822 : struct.uniqueConstraints)
+ for (SQLUniqueConstraint _iter830 : struct.uniqueConstraints)
{
- _iter822.write(oprot);
+ _iter830.write(oprot);
}
}
}
if (struct.isSetNotNullConstraints()) {
{
oprot.writeI32(struct.notNullConstraints.size());
- for (SQLNotNullConstraint _iter823 : struct.notNullConstraints)
+ for (SQLNotNullConstraint _iter831 : struct.notNullConstraints)
{
- _iter823.write(oprot);
+ _iter831.write(oprot);
}
}
}
@@ -45428,56 +46088,56 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list824 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.primaryKeys = new ArrayList<SQLPrimaryKey>(_list824.size);
- SQLPrimaryKey _elem825;
- for (int _i826 = 0; _i826 < _list824.size; ++_i826)
+ org.apache.thrift.protocol.TList _list832 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.primaryKeys = new ArrayList<SQLPrimaryKey>(_list832.size);
+ SQLPrimaryKey _elem833;
+ for (int _i834 = 0; _i834 < _list832.size; ++_i834)
{
- _elem825 = new SQLPrimaryKey();
- _elem825.read(iprot);
- struct.primaryKeys.add(_elem825);
+ _elem833 = new SQLPrimaryKey();
+ _elem833.read(iprot);
+ struct.primaryKeys.add(_elem833);
}
}
struct.setPrimaryKeysIsSet(true);
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list827 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.foreignKeys = new ArrayList<SQLForeignKey>(_list827.size);
- SQLForeignKey _elem828;
- for (int _i829 = 0; _i829 < _list827.size; ++_i829)
+ org.apache.thrift.protocol.TList _list835 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.foreignKeys = new ArrayList<SQLForeignKey>(_list835.size);
+ SQLForeignKey _elem836;
+ for (int _i837 = 0; _i837 < _list835.size; ++_i837)
{
- _elem828 = new SQLForeignKey();
- _elem828.read(iprot);
- struct.foreignKeys.add(_elem828);
+ _elem836 = new SQLForeignKey();
+ _elem836.read(iprot);
+ struct.foreignKeys.add(_elem836);
}
}
struct.setForeignKeysIsSet(true);
}
if (incoming.get(3)) {
{
- org.apache.thrift.protocol.TList _list830 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list830.size);
- SQLUniqueConstraint _elem831;
- for (int _i832 = 0; _i832 < _list830.size; ++_i832)
+ org.apache.thrift.protocol.TList _list838 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list838.size);
+ SQLUniqueConstraint _elem839;
+ for (int _i840 = 0; _i840 < _list838.size; ++_i840)
{
- _elem831 = new SQLUniqueConstraint();
- _elem831.read(iprot);
- struct.uniqueConstraints.add(_elem831);
+ _elem839 = new SQLUniqueConstraint();
+ _elem839.read(iprot);
+ struct.uniqueConstraints.add(_elem839);
}
}
struct.setUniqueConstraintsIsSet(true);
}
if (incoming.get(4)) {
{
- org.apache.thrift.protocol.TList _list833 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.notNullConstraints = new ArrayList<SQLNotNullConstraint>(_list833.size);
- SQLNotNullConstraint _elem834;
- for (int _i835 = 0; _i835 < _list833.size; ++_i835)
+ org.apache.thrift.protocol.TList _list841 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.notNullConstraints = new ArrayList<SQLNotNullConstraint>(_list841.size);
+ SQLNotNullConstraint _elem842;
+ for (int _i843 = 0; _i843 < _list841.size; ++_i843)
{
- _elem834 = new SQLNotNullConstraint();
- _elem834.read(iprot);
- struct.notNullConstraints.add(_elem834);
+ _elem842 = new SQLNotNullConstraint();
+ _elem842.read(iprot);
+ struct.notNullConstraints.add(_elem842);
}
}
struct.setNotNullConstraintsIsSet(true);
@@ -52969,13 +53629,13 @@ import org.slf4j.LoggerFactory;
case 3: // PART_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list836 = iprot.readListBegin();
- struct.partNames = new ArrayList<String>(_list836.size);
- String _elem837;
- for (int _i838 = 0; _i838 < _list836.size; ++_i838)
+ org.apache.thrift.protocol.TList _list844 = iprot.readListBegin();
+ struct.partNames = new ArrayList<String>(_list844.size);
+ String _elem845;
+ for (int _i846 = 0; _i846 < _list844.size; ++_i846)
{
- _elem837 = iprot.readString();
- struct.partNames.add(_elem837);
+ _elem845 = iprot.readString();
+ struct.partNames.add(_elem845);
}
iprot.readListEnd();
}
@@ -53011,9 +53671,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 _iter839 : struct.partNames)
+ for (String _iter847 : struct.partNames)
{
- oprot.writeString(_iter839);
+ oprot.writeString(_iter847);
}
oprot.writeListEnd();
}
@@ -53056,9 +53716,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetPartNames()) {
{
oprot.writeI32(struct.partNames.size());
- for (String _iter840 : struct.partNames)
+ for (String _iter848 : struct.partNames)
{
- oprot.writeString(_iter840);
+ oprot.writeString(_iter848);
}
}
}
@@ -53078,13 +53738,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list841 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.partNames = new ArrayList<String>(_list841.size);
- String _elem842;
- for (int _i843 = 0; _i843 < _list841.size; ++_i843)
+ org.apache.thrift.protocol.TList _list849 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.partNames = new ArrayList<String>(_list849.size);
+ String _elem850;
+ for (int _i851 = 0; _i851 < _list849.size; ++_i851)
{
- _elem842 = iprot.readString();
- struct.partNames.add(_elem842);
+ _elem850 = iprot.readString();
+ struct.partNames.add(_elem850);
}
}
struct.setPartNamesIsSet(true);
@@ -54309,13 +54969,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list844 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list844.size);
- String _elem845;
- for (int _i846 = 0; _i846 < _list844.size; ++_i846)
+ org.apache.thrift.protocol.TList _list852 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list852.size);
+ String _elem853;
+ for (int _i854 = 0; _i854 < _list852.size; ++_i854)
{
- _elem845 = iprot.readString();
- struct.success.add(_elem845);
+ _elem853 = iprot.readString();
+ struct.success.add(_elem853);
}
iprot.readListEnd();
}
@@ -54350,9 +55010,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 _iter847 : struct.success)
+ for (String _iter855 : struct.success)
{
- oprot.writeString(_iter847);
+ oprot.writeString(_iter855);
}
oprot.writeListEnd();
}
@@ -54391,9 +55051,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter848 : struct.success)
+ for (String _iter856 : struct.success)
{
- oprot.writeString(_iter848);
+ oprot.writeString(_iter856);
}
}
}
@@ -54408,13 +55068,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list849 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list849.size);
- String _elem850;
- for (int _i851 = 0; _i851 < _list849.size; ++_i851)
+ org.apache.thrift.protocol.TList _list857 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list857.size);
+ String _elem858;
+ for (int _i859 = 0; _i859 < _list857.size; ++_i859)
{
- _elem850 = iprot.readString();
- struct.success.add(_elem850);
+ _elem858 = iprot.readString();
+ struct.success.add(_elem858);
}
}
struct.setSuccessIsSet(true);
@@ -55388,13 +56048,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list852 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list852.size);
- String _elem853;
- for (int _i854 = 0; _i854 < _list852.size; ++_i854)
+ org.apache.thrift.protocol.TList _list860 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list860.size);
+ String _elem861;
+ for (int _i862 = 0; _i862 < _list860.size; ++_i862)
{
- _elem853 = iprot.readString();
- struct.success.add(_elem853);
+ _elem861 = iprot.readString();
+ struct.success.add(_elem861);
}
iprot.readListEnd();
}
@@ -55429,9 +56089,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 _iter855 : struct.success)
+ for (String _iter863 : struct.success)
{
- oprot.writeString(_iter855);
+ oprot.writeString(_iter863);
}
oprot.writeListEnd();
}
@@ -55470,9 +56130,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter856 : struct.success)
+ for (String _iter864 : struct.success)
{
- oprot.writeString(_iter856);
+ oprot.writeString(_iter864);
}
}
}
@@ -55487,13 +56147,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list857 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list857.size);
- String _elem858;
- for (int _i859 = 0; _i859 < _list857.size; ++_i859)
+ org.apache.thrift.protocol.TList _list865 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list865.size);
+ String _elem866;
+ for (int _i867 = 0; _i867 < _list865.size; ++_i867)
{
- _elem858 = iprot.readString();
- struct.success.add(_elem858);
+ _elem866 = iprot.readString();
+ struct.success.add(_elem866);
}
}
struct.setSuccessIsSet(true);
@@ -55998,13 +56658,13 @@ import org.slf4j.LoggerFactory;
case 3: // TBL_TYPES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list860 = iprot.readListBegin();
- struct.tbl_types = new ArrayList<String>(_list860.size);
- String _elem861;
- for (int _i862 = 0; _i862 < _list860.size; ++_i862)
+ org.apache.thrift.protocol.TList _list868 = iprot.readListBegin();
+ struct.tbl_types = new ArrayList<String>(_list868.size);
+ String _elem869;
+ for (int _i870 = 0; _i870 < _list868.size; ++_i870)
{
- _elem861 = iprot.readString();
- struct.tbl_types.add(_elem861);
+ _elem869 = iprot.readString();
+ struct.tbl_types.add(_elem869);
}
iprot.readListEnd();
}
@@ -56040,9 +56700,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 _iter863 : struct.tbl_types)
+ for (String _iter871 : struct.tbl_types)
{
- oprot.writeString(_iter863);
+ oprot.writeString(_iter871);
}
oprot.writeListEnd();
}
@@ -56085,9 +56745,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetTbl_types()) {
{
oprot.writeI32(struct.tbl_types.size());
- for (String _iter864 : struct.tbl_types)
+ for (String _iter872 : struct.tbl_types)
{
- oprot.writeString(_iter864);
+ oprot.writeString(_iter872);
}
}
}
@@ -56107,13 +56767,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list865 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.tbl_types = new ArrayList<String>(_list865.size);
- String _elem866;
- for (int _i867 = 0; _i867 < _list865.size; ++_i867)
+ org.apache.thrift.protocol.TList _list873 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.tbl_types = new ArrayList<String>(_list873.size);
+ String _elem874;
+ for (int _i875 = 0; _i875 < _list873.size; ++_i875)
{
- _elem866 = iprot.readString();
- struct.tbl_types.add(_elem866);
+ _elem874 = iprot.readString();
+ struct.tbl_types.add(_elem874);
}
}
struct.setTbl_typesIsSet(true);
@@ -56519,14 +57179,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list868 = iprot.readListBegin();
- struct.success = new ArrayList<TableMeta>(_list868.size);
- TableMeta _elem869;
- for (int _i870 = 0; _i870 < _list868.size; ++_i870)
+ org.apache.thrift.protocol.TList _list876 = iprot.readListBegin();
+ struct.success = new ArrayList<TableMeta>(_list876.size);
+ TableMeta _elem877;
+ for (int _i878 = 0; _i878 < _list876.size; ++_i878)
{
- _elem869 = new TableMeta();
- _elem869.read(iprot);
- struct.success.add(_elem869);
+ _elem877 = new TableMeta();
+ _elem877.read(iprot);
+ struct.success.add(_elem877);
}
iprot.readListEnd();
}
@@ -56561,9 +57221,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 _iter871 : struct.success)
+ for (TableMeta _iter879 : struct.success)
{
- _iter871.write(oprot);
+ _iter879.write(oprot);
}
oprot.writeListEnd();
}
@@ -56602,9 +57262,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (TableMeta _iter872 : struct.success)
+ for (TableMeta _iter880 : struct.success)
{
- _iter872.write(oprot);
+ _iter880.write(oprot);
}
}
}
@@ -56619,14 +57279,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list873 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<TableMeta>(_list873.size);
- TableMeta _elem874;
- for (int _i875 = 0; _i875 < _list873.size; ++_i875)
+ org.apache.thrift.protocol.TList _list881 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<TableMeta>(_list881.size);
+ TableMeta _elem882;
+ for (int _i883 = 0; _i883 < _list881.size; ++_i883)
{
- _elem874 = new TableMeta();
- _elem874.read(iprot);
- struct.success.add(_elem874);
+ _elem882 = new TableMeta();
+ _elem882.read(iprot);
+ struct.success.add(_elem882);
}
}
struct.setSuccessIsSet(true);
@@ -57392,13 +58052,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list876 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list876.size);
- String _elem877;
- for (int _i878 = 0; _i878 < _list876.size; ++_i878)
+ org.apache.thrift.protocol.TList _list884 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list884.size);
+ String _elem885;
+ for (int _i886 = 0; _i886 < _list884.size; ++_i886)
{
- _elem877 = iprot.readString();
- struct.success.add(_elem877);
+ _elem885 = iprot.readString();
+ struct.success.add(_elem885);
}
iprot.readListEnd();
}
@@ -57433,9 +58093,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 _iter879 : struct.success)
+ for (String _iter887 : struct.success)
{
- oprot.writeString(_iter879);
+ oprot.writeString(_iter887);
}
oprot.writeListEnd();
}
@@ -57474,9 +58134,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter880 : struct.success)
+ for (String _iter888 : struct.success)
{
- oprot.writeString(_iter880);
+ oprot.writeString(_iter888);
}
}
}
@@ -57491,13 +58151,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list881 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list881.size);
- String _elem882;
- for (int _i883 = 0; _i883 < _list881.size; ++_i883)
+ org.apache.thrift.protocol.TList _list889 = new org.a
<TRUNCATED>