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/11/06 19:44:56 UTC
[07/10] hive git commit: HIVE-17907 : enable and apply resource plan
commands in HS2 (Sergey Shelukhin, reviewed by Prasanth Jayachandran)
http://git-wip-us.apache.org/repos/asf/hive/blob/ddce801f/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 1e5bc08..febf304 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
@@ -370,6 +370,8 @@ import org.slf4j.LoggerFactory;
public WMGetResourcePlanResponse get_resource_plan(WMGetResourcePlanRequest request) throws NoSuchObjectException, MetaException, org.apache.thrift.TException;
+ public WMGetActiveResourcePlanResponse get_active_resource_plan(WMGetActiveResourcePlanRequest request) throws MetaException, org.apache.thrift.TException;
+
public WMGetAllResourcePlanResponse get_all_resource_plans(WMGetAllResourcePlanRequest request) throws MetaException, org.apache.thrift.TException;
public WMAlterResourcePlanResponse alter_resource_plan(WMAlterResourcePlanRequest request) throws NoSuchObjectException, InvalidOperationException, MetaException, org.apache.thrift.TException;
@@ -718,6 +720,8 @@ import org.slf4j.LoggerFactory;
public void get_resource_plan(WMGetResourcePlanRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void get_active_resource_plan(WMGetActiveResourcePlanRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
public void get_all_resource_plans(WMGetAllResourcePlanRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void alter_resource_plan(WMAlterResourcePlanRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
@@ -5462,6 +5466,32 @@ import org.slf4j.LoggerFactory;
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "get_resource_plan failed: unknown result");
}
+ public WMGetActiveResourcePlanResponse get_active_resource_plan(WMGetActiveResourcePlanRequest request) throws MetaException, org.apache.thrift.TException
+ {
+ send_get_active_resource_plan(request);
+ return recv_get_active_resource_plan();
+ }
+
+ public void send_get_active_resource_plan(WMGetActiveResourcePlanRequest request) throws org.apache.thrift.TException
+ {
+ get_active_resource_plan_args args = new get_active_resource_plan_args();
+ args.setRequest(request);
+ sendBase("get_active_resource_plan", args);
+ }
+
+ public WMGetActiveResourcePlanResponse recv_get_active_resource_plan() throws MetaException, org.apache.thrift.TException
+ {
+ get_active_resource_plan_result result = new get_active_resource_plan_result();
+ receiveBase(result, "get_active_resource_plan");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.o2 != null) {
+ throw result.o2;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "get_active_resource_plan failed: unknown result");
+ }
+
public WMGetAllResourcePlanResponse get_all_resource_plans(WMGetAllResourcePlanRequest request) throws MetaException, org.apache.thrift.TException
{
send_get_all_resource_plans(request);
@@ -11416,7 +11446,7 @@ import org.slf4j.LoggerFactory;
___manager.call(method_call);
}
- public static class create_resource_plan_call extends org.apache.thrift.async.TAsyncMethodCall {
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class create_resource_plan_call extends org.apache.thrift.async.TAsyncMethodCall {
private WMCreateResourcePlanRequest request;
public create_resource_plan_call(WMCreateResourcePlanRequest 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);
@@ -11448,7 +11478,7 @@ import org.slf4j.LoggerFactory;
___manager.call(method_call);
}
- public static class get_resource_plan_call extends org.apache.thrift.async.TAsyncMethodCall {
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class get_resource_plan_call extends org.apache.thrift.async.TAsyncMethodCall {
private WMGetResourcePlanRequest request;
public get_resource_plan_call(WMGetResourcePlanRequest 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);
@@ -11473,6 +11503,38 @@ import org.slf4j.LoggerFactory;
}
}
+ public void get_active_resource_plan(WMGetActiveResourcePlanRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ get_active_resource_plan_call method_call = new get_active_resource_plan_call(request, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class get_active_resource_plan_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private WMGetActiveResourcePlanRequest request;
+ public get_active_resource_plan_call(WMGetActiveResourcePlanRequest 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_active_resource_plan", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ get_active_resource_plan_args args = new get_active_resource_plan_args();
+ args.setRequest(request);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public WMGetActiveResourcePlanResponse getResult() throws MetaException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ return (new Client(prot)).recv_get_active_resource_plan();
+ }
+ }
+
public void get_all_resource_plans(WMGetAllResourcePlanRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
get_all_resource_plans_call method_call = new get_all_resource_plans_call(request, resultHandler, this, ___protocolFactory, ___transport);
@@ -11480,7 +11542,7 @@ import org.slf4j.LoggerFactory;
___manager.call(method_call);
}
- public static class get_all_resource_plans_call extends org.apache.thrift.async.TAsyncMethodCall {
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class get_all_resource_plans_call extends org.apache.thrift.async.TAsyncMethodCall {
private WMGetAllResourcePlanRequest request;
public get_all_resource_plans_call(WMGetAllResourcePlanRequest 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);
@@ -11512,7 +11574,7 @@ import org.slf4j.LoggerFactory;
___manager.call(method_call);
}
- public static class alter_resource_plan_call extends org.apache.thrift.async.TAsyncMethodCall {
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class alter_resource_plan_call extends org.apache.thrift.async.TAsyncMethodCall {
private WMAlterResourcePlanRequest request;
public alter_resource_plan_call(WMAlterResourcePlanRequest 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);
@@ -11544,7 +11606,7 @@ import org.slf4j.LoggerFactory;
___manager.call(method_call);
}
- public static class validate_resource_plan_call extends org.apache.thrift.async.TAsyncMethodCall {
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class validate_resource_plan_call extends org.apache.thrift.async.TAsyncMethodCall {
private WMValidateResourcePlanRequest request;
public validate_resource_plan_call(WMValidateResourcePlanRequest 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);
@@ -11576,7 +11638,7 @@ import org.slf4j.LoggerFactory;
___manager.call(method_call);
}
- public static class drop_resource_plan_call extends org.apache.thrift.async.TAsyncMethodCall {
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class drop_resource_plan_call extends org.apache.thrift.async.TAsyncMethodCall {
private WMDropResourcePlanRequest request;
public drop_resource_plan_call(WMDropResourcePlanRequest 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);
@@ -11608,7 +11670,7 @@ import org.slf4j.LoggerFactory;
___manager.call(method_call);
}
- public static class create_wm_trigger_call extends org.apache.thrift.async.TAsyncMethodCall {
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable 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);
@@ -11640,7 +11702,7 @@ import org.slf4j.LoggerFactory;
___manager.call(method_call);
}
- public static class alter_wm_trigger_call extends org.apache.thrift.async.TAsyncMethodCall {
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable 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);
@@ -11672,7 +11734,7 @@ import org.slf4j.LoggerFactory;
___manager.call(method_call);
}
- public static class drop_wm_trigger_call extends org.apache.thrift.async.TAsyncMethodCall {
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable 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);
@@ -11704,7 +11766,7 @@ import org.slf4j.LoggerFactory;
___manager.call(method_call);
}
- public static class get_triggers_for_resourceplan_call extends org.apache.thrift.async.TAsyncMethodCall {
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable 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);
@@ -11906,6 +11968,7 @@ import org.slf4j.LoggerFactory;
processMap.put("get_metastore_db_uuid", new get_metastore_db_uuid());
processMap.put("create_resource_plan", new create_resource_plan());
processMap.put("get_resource_plan", new get_resource_plan());
+ processMap.put("get_active_resource_plan", new get_active_resource_plan());
processMap.put("get_all_resource_plans", new get_all_resource_plans());
processMap.put("alter_resource_plan", new alter_resource_plan());
processMap.put("validate_resource_plan", new validate_resource_plan());
@@ -16037,7 +16100,7 @@ import org.slf4j.LoggerFactory;
}
}
- public static class create_resource_plan<I extends Iface> extends org.apache.thrift.ProcessFunction<I, create_resource_plan_args> {
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class create_resource_plan<I extends Iface> extends org.apache.thrift.ProcessFunction<I, create_resource_plan_args> {
public create_resource_plan() {
super("create_resource_plan");
}
@@ -16065,7 +16128,7 @@ import org.slf4j.LoggerFactory;
}
}
- public static class get_resource_plan<I extends Iface> extends org.apache.thrift.ProcessFunction<I, get_resource_plan_args> {
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class get_resource_plan<I extends Iface> extends org.apache.thrift.ProcessFunction<I, get_resource_plan_args> {
public get_resource_plan() {
super("get_resource_plan");
}
@@ -16091,7 +16154,31 @@ import org.slf4j.LoggerFactory;
}
}
- public static class get_all_resource_plans<I extends Iface> extends org.apache.thrift.ProcessFunction<I, get_all_resource_plans_args> {
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class get_active_resource_plan<I extends Iface> extends org.apache.thrift.ProcessFunction<I, get_active_resource_plan_args> {
+ public get_active_resource_plan() {
+ super("get_active_resource_plan");
+ }
+
+ public get_active_resource_plan_args getEmptyArgsInstance() {
+ return new get_active_resource_plan_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public get_active_resource_plan_result getResult(I iface, get_active_resource_plan_args args) throws org.apache.thrift.TException {
+ get_active_resource_plan_result result = new get_active_resource_plan_result();
+ try {
+ result.success = iface.get_active_resource_plan(args.request);
+ } catch (MetaException o2) {
+ result.o2 = o2;
+ }
+ return result;
+ }
+ }
+
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class get_all_resource_plans<I extends Iface> extends org.apache.thrift.ProcessFunction<I, get_all_resource_plans_args> {
public get_all_resource_plans() {
super("get_all_resource_plans");
}
@@ -16115,7 +16202,7 @@ import org.slf4j.LoggerFactory;
}
}
- public static class alter_resource_plan<I extends Iface> extends org.apache.thrift.ProcessFunction<I, alter_resource_plan_args> {
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class alter_resource_plan<I extends Iface> extends org.apache.thrift.ProcessFunction<I, alter_resource_plan_args> {
public alter_resource_plan() {
super("alter_resource_plan");
}
@@ -16143,7 +16230,7 @@ import org.slf4j.LoggerFactory;
}
}
- public static class validate_resource_plan<I extends Iface> extends org.apache.thrift.ProcessFunction<I, validate_resource_plan_args> {
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class validate_resource_plan<I extends Iface> extends org.apache.thrift.ProcessFunction<I, validate_resource_plan_args> {
public validate_resource_plan() {
super("validate_resource_plan");
}
@@ -16169,7 +16256,7 @@ import org.slf4j.LoggerFactory;
}
}
- public static class drop_resource_plan<I extends Iface> extends org.apache.thrift.ProcessFunction<I, drop_resource_plan_args> {
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class drop_resource_plan<I extends Iface> extends org.apache.thrift.ProcessFunction<I, drop_resource_plan_args> {
public drop_resource_plan() {
super("drop_resource_plan");
}
@@ -16197,7 +16284,7 @@ import org.slf4j.LoggerFactory;
}
}
- public static class create_wm_trigger<I extends Iface> extends org.apache.thrift.ProcessFunction<I, create_wm_trigger_args> {
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable 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");
}
@@ -16227,7 +16314,7 @@ import org.slf4j.LoggerFactory;
}
}
- public static class alter_wm_trigger<I extends Iface> extends org.apache.thrift.ProcessFunction<I, alter_wm_trigger_args> {
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable 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");
}
@@ -16255,7 +16342,7 @@ import org.slf4j.LoggerFactory;
}
}
- public static class drop_wm_trigger<I extends Iface> extends org.apache.thrift.ProcessFunction<I, drop_wm_trigger_args> {
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable 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");
}
@@ -16283,7 +16370,7 @@ import org.slf4j.LoggerFactory;
}
}
- public static class get_triggers_for_resourceplan<I extends Iface> extends org.apache.thrift.ProcessFunction<I, get_triggers_for_resourceplan_args> {
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable 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");
}
@@ -16486,6 +16573,7 @@ import org.slf4j.LoggerFactory;
processMap.put("get_metastore_db_uuid", new get_metastore_db_uuid());
processMap.put("create_resource_plan", new create_resource_plan());
processMap.put("get_resource_plan", new get_resource_plan());
+ processMap.put("get_active_resource_plan", new get_active_resource_plan());
processMap.put("get_all_resource_plans", new get_all_resource_plans());
processMap.put("alter_resource_plan", new alter_resource_plan());
processMap.put("validate_resource_plan", new validate_resource_plan());
@@ -26331,7 +26419,7 @@ import org.slf4j.LoggerFactory;
}
}
- public static class create_resource_plan<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, create_resource_plan_args, WMCreateResourcePlanResponse> {
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class create_resource_plan<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, create_resource_plan_args, WMCreateResourcePlanResponse> {
public create_resource_plan() {
super("create_resource_plan");
}
@@ -26398,7 +26486,7 @@ import org.slf4j.LoggerFactory;
}
}
- public static class get_resource_plan<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_resource_plan_args, WMGetResourcePlanResponse> {
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class get_resource_plan<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_resource_plan_args, WMGetResourcePlanResponse> {
public get_resource_plan() {
super("get_resource_plan");
}
@@ -26460,7 +26548,64 @@ import org.slf4j.LoggerFactory;
}
}
- public static class get_all_resource_plans<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_all_resource_plans_args, WMGetAllResourcePlanResponse> {
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class get_active_resource_plan<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_active_resource_plan_args, WMGetActiveResourcePlanResponse> {
+ public get_active_resource_plan() {
+ super("get_active_resource_plan");
+ }
+
+ public get_active_resource_plan_args getEmptyArgsInstance() {
+ return new get_active_resource_plan_args();
+ }
+
+ public AsyncMethodCallback<WMGetActiveResourcePlanResponse> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.thrift.AsyncProcessFunction fcall = this;
+ return new AsyncMethodCallback<WMGetActiveResourcePlanResponse>() {
+ public void onComplete(WMGetActiveResourcePlanResponse o) {
+ get_active_resource_plan_result result = new get_active_resource_plan_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_active_resource_plan_result result = new get_active_resource_plan_result();
+ 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_active_resource_plan_args args, org.apache.thrift.async.AsyncMethodCallback<WMGetActiveResourcePlanResponse> resultHandler) throws TException {
+ iface.get_active_resource_plan(args.request,resultHandler);
+ }
+ }
+
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class get_all_resource_plans<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_all_resource_plans_args, WMGetAllResourcePlanResponse> {
public get_all_resource_plans() {
super("get_all_resource_plans");
}
@@ -26517,7 +26662,7 @@ import org.slf4j.LoggerFactory;
}
}
- public static class alter_resource_plan<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, alter_resource_plan_args, WMAlterResourcePlanResponse> {
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class alter_resource_plan<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, alter_resource_plan_args, WMAlterResourcePlanResponse> {
public alter_resource_plan() {
super("alter_resource_plan");
}
@@ -26584,7 +26729,7 @@ import org.slf4j.LoggerFactory;
}
}
- public static class validate_resource_plan<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, validate_resource_plan_args, WMValidateResourcePlanResponse> {
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class validate_resource_plan<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, validate_resource_plan_args, WMValidateResourcePlanResponse> {
public validate_resource_plan() {
super("validate_resource_plan");
}
@@ -26646,7 +26791,7 @@ import org.slf4j.LoggerFactory;
}
}
- public static class drop_resource_plan<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, drop_resource_plan_args, WMDropResourcePlanResponse> {
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public static class drop_resource_plan<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, drop_resource_plan_args, WMDropResourcePlanResponse> {
public drop_resource_plan() {
super("drop_resource_plan");
}
@@ -26713,7 +26858,7 @@ import org.slf4j.LoggerFactory;
}
}
- public static class create_wm_trigger<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, create_wm_trigger_args, WMCreateTriggerResponse> {
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable 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");
}
@@ -26785,7 +26930,7 @@ import org.slf4j.LoggerFactory;
}
}
- public static class alter_wm_trigger<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, alter_wm_trigger_args, WMAlterTriggerResponse> {
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable 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");
}
@@ -26852,7 +26997,7 @@ import org.slf4j.LoggerFactory;
}
}
- public static class drop_wm_trigger<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, drop_wm_trigger_args, WMDropTriggerResponse> {
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable 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");
}
@@ -26919,7 +27064,7 @@ import org.slf4j.LoggerFactory;
}
}
- public static class get_triggers_for_resourceplan<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_triggers_for_resourceplan_args, WMGetTriggersForResourePlanResponse> {
+ @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable 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");
}
@@ -32376,13 +32521,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 _list786 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list786.size);
+ String _elem787;
+ for (int _i788 = 0; _i788 < _list786.size; ++_i788)
{
- _elem755 = iprot.readString();
- struct.success.add(_elem755);
+ _elem787 = iprot.readString();
+ struct.success.add(_elem787);
}
iprot.readListEnd();
}
@@ -32417,9 +32562,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 _iter789 : struct.success)
{
- oprot.writeString(_iter757);
+ oprot.writeString(_iter789);
}
oprot.writeListEnd();
}
@@ -32458,9 +32603,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter758 : struct.success)
+ for (String _iter790 : struct.success)
{
- oprot.writeString(_iter758);
+ oprot.writeString(_iter790);
}
}
}
@@ -32475,13 +32620,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 _list791 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list791.size);
+ String _elem792;
+ for (int _i793 = 0; _i793 < _list791.size; ++_i793)
{
- _elem760 = iprot.readString();
- struct.success.add(_elem760);
+ _elem792 = iprot.readString();
+ struct.success.add(_elem792);
}
}
struct.setSuccessIsSet(true);
@@ -33135,13 +33280,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- 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)
+ org.apache.thrift.protocol.TList _list794 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list794.size);
+ String _elem795;
+ for (int _i796 = 0; _i796 < _list794.size; ++_i796)
{
- _elem763 = iprot.readString();
- struct.success.add(_elem763);
+ _elem795 = iprot.readString();
+ struct.success.add(_elem795);
}
iprot.readListEnd();
}
@@ -33176,9 +33321,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 _iter765 : struct.success)
+ for (String _iter797 : struct.success)
{
- oprot.writeString(_iter765);
+ oprot.writeString(_iter797);
}
oprot.writeListEnd();
}
@@ -33217,9 +33362,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter766 : struct.success)
+ for (String _iter798 : struct.success)
{
- oprot.writeString(_iter766);
+ oprot.writeString(_iter798);
}
}
}
@@ -33234,13 +33379,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- 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)
+ org.apache.thrift.protocol.TList _list799 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list799.size);
+ String _elem800;
+ for (int _i801 = 0; _i801 < _list799.size; ++_i801)
{
- _elem768 = iprot.readString();
- struct.success.add(_elem768);
+ _elem800 = iprot.readString();
+ struct.success.add(_elem800);
}
}
struct.setSuccessIsSet(true);
@@ -37847,16 +37992,16 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- 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)
+ org.apache.thrift.protocol.TMap _map802 = iprot.readMapBegin();
+ struct.success = new HashMap<String,Type>(2*_map802.size);
+ String _key803;
+ Type _val804;
+ for (int _i805 = 0; _i805 < _map802.size; ++_i805)
{
- _key771 = iprot.readString();
- _val772 = new Type();
- _val772.read(iprot);
- struct.success.put(_key771, _val772);
+ _key803 = iprot.readString();
+ _val804 = new Type();
+ _val804.read(iprot);
+ struct.success.put(_key803, _val804);
}
iprot.readMapEnd();
}
@@ -37891,10 +38036,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> _iter774 : struct.success.entrySet())
+ for (Map.Entry<String, Type> _iter806 : struct.success.entrySet())
{
- oprot.writeString(_iter774.getKey());
- _iter774.getValue().write(oprot);
+ oprot.writeString(_iter806.getKey());
+ _iter806.getValue().write(oprot);
}
oprot.writeMapEnd();
}
@@ -37933,10 +38078,10 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Map.Entry<String, Type> _iter775 : struct.success.entrySet())
+ for (Map.Entry<String, Type> _iter807 : struct.success.entrySet())
{
- oprot.writeString(_iter775.getKey());
- _iter775.getValue().write(oprot);
+ oprot.writeString(_iter807.getKey());
+ _iter807.getValue().write(oprot);
}
}
}
@@ -37951,16 +38096,16 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- 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)
+ org.apache.thrift.protocol.TMap _map808 = 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*_map808.size);
+ String _key809;
+ Type _val810;
+ for (int _i811 = 0; _i811 < _map808.size; ++_i811)
{
- _key777 = iprot.readString();
- _val778 = new Type();
- _val778.read(iprot);
- struct.success.put(_key777, _val778);
+ _key809 = iprot.readString();
+ _val810 = new Type();
+ _val810.read(iprot);
+ struct.success.put(_key809, _val810);
}
}
struct.setSuccessIsSet(true);
@@ -38995,14 +39140,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 _list812 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list812.size);
+ FieldSchema _elem813;
+ for (int _i814 = 0; _i814 < _list812.size; ++_i814)
{
- _elem781 = new FieldSchema();
- _elem781.read(iprot);
- struct.success.add(_elem781);
+ _elem813 = new FieldSchema();
+ _elem813.read(iprot);
+ struct.success.add(_elem813);
}
iprot.readListEnd();
}
@@ -39055,9 +39200,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 _iter815 : struct.success)
{
- _iter783.write(oprot);
+ _iter815.write(oprot);
}
oprot.writeListEnd();
}
@@ -39112,9 +39257,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter784 : struct.success)
+ for (FieldSchema _iter816 : struct.success)
{
- _iter784.write(oprot);
+ _iter816.write(oprot);
}
}
}
@@ -39135,14 +39280,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 _list817 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list817.size);
+ FieldSchema _elem818;
+ for (int _i819 = 0; _i819 < _list817.size; ++_i819)
{
- _elem786 = new FieldSchema();
- _elem786.read(iprot);
- struct.success.add(_elem786);
+ _elem818 = new FieldSchema();
+ _elem818.read(iprot);
+ struct.success.add(_elem818);
}
}
struct.setSuccessIsSet(true);
@@ -40296,14 +40441,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 _list820 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list820.size);
+ FieldSchema _elem821;
+ for (int _i822 = 0; _i822 < _list820.size; ++_i822)
{
- _elem789 = new FieldSchema();
- _elem789.read(iprot);
- struct.success.add(_elem789);
+ _elem821 = new FieldSchema();
+ _elem821.read(iprot);
+ struct.success.add(_elem821);
}
iprot.readListEnd();
}
@@ -40356,9 +40501,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 _iter823 : struct.success)
{
- _iter791.write(oprot);
+ _iter823.write(oprot);
}
oprot.writeListEnd();
}
@@ -40413,9 +40558,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter792 : struct.success)
+ for (FieldSchema _iter824 : struct.success)
{
- _iter792.write(oprot);
+ _iter824.write(oprot);
}
}
}
@@ -40436,14 +40581,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 _list825 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list825.size);
+ FieldSchema _elem826;
+ for (int _i827 = 0; _i827 < _list825.size; ++_i827)
{
- _elem794 = new FieldSchema();
- _elem794.read(iprot);
- struct.success.add(_elem794);
+ _elem826 = new FieldSchema();
+ _elem826.read(iprot);
+ struct.success.add(_elem826);
}
}
struct.setSuccessIsSet(true);
@@ -41488,14 +41633,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 _list828 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list828.size);
+ FieldSchema _elem829;
+ for (int _i830 = 0; _i830 < _list828.size; ++_i830)
{
- _elem797 = new FieldSchema();
- _elem797.read(iprot);
- struct.success.add(_elem797);
+ _elem829 = new FieldSchema();
+ _elem829.read(iprot);
+ struct.success.add(_elem829);
}
iprot.readListEnd();
}
@@ -41548,9 +41693,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 _iter831 : struct.success)
{
- _iter799.write(oprot);
+ _iter831.write(oprot);
}
oprot.writeListEnd();
}
@@ -41605,9 +41750,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter800 : struct.success)
+ for (FieldSchema _iter832 : struct.success)
{
- _iter800.write(oprot);
+ _iter832.write(oprot);
}
}
}
@@ -41628,14 +41773,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 _list833 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list833.size);
+ FieldSchema _elem834;
+ for (int _i835 = 0; _i835 < _list833.size; ++_i835)
{
- _elem802 = new FieldSchema();
- _elem802.read(iprot);
- struct.success.add(_elem802);
+ _elem834 = new FieldSchema();
+ _elem834.read(iprot);
+ struct.success.add(_elem834);
}
}
struct.setSuccessIsSet(true);
@@ -42789,14 +42934,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- 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)
+ org.apache.thrift.protocol.TList _list836 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list836.size);
+ FieldSchema _elem837;
+ for (int _i838 = 0; _i838 < _list836.size; ++_i838)
{
- _elem805 = new FieldSchema();
- _elem805.read(iprot);
- struct.success.add(_elem805);
+ _elem837 = new FieldSchema();
+ _elem837.read(iprot);
+ struct.success.add(_elem837);
}
iprot.readListEnd();
}
@@ -42849,9 +42994,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 _iter807 : struct.success)
+ for (FieldSchema _iter839 : struct.success)
{
- _iter807.write(oprot);
+ _iter839.write(oprot);
}
oprot.writeListEnd();
}
@@ -42906,9 +43051,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter808 : struct.success)
+ for (FieldSchema _iter840 : struct.success)
{
- _iter808.write(oprot);
+ _iter840.write(oprot);
}
}
}
@@ -42929,14 +43074,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- 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)
+ org.apache.thrift.protocol.TList _list841 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list841.size);
+ FieldSchema _elem842;
+ for (int _i843 = 0; _i843 < _list841.size; ++_i843)
{
- _elem810 = new FieldSchema();
- _elem810.read(iprot);
- struct.success.add(_elem810);
+ _elem842 = new FieldSchema();
+ _elem842.read(iprot);
+ struct.success.add(_elem842);
}
}
struct.setSuccessIsSet(true);
@@ -45863,14 +46008,14 @@ import org.slf4j.LoggerFactory;
case 2: // PRIMARY_KEYS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- 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)
+ org.apache.thrift.protocol.TList _list844 = iprot.readListBegin();
+ struct.primaryKeys = new ArrayList<SQLPrimaryKey>(_list844.size);
+ SQLPrimaryKey _elem845;
+ for (int _i846 = 0; _i846 < _list844.size; ++_i846)
{
- _elem813 = new SQLPrimaryKey();
- _elem813.read(iprot);
- struct.primaryKeys.add(_elem813);
+ _elem845 = new SQLPrimaryKey();
+ _elem845.read(iprot);
+ struct.primaryKeys.add(_elem845);
}
iprot.readListEnd();
}
@@ -45882,14 +46027,14 @@ import org.slf4j.LoggerFactory;
case 3: // FOREIGN_KEYS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- 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)
+ org.apache.thrift.protocol.TList _list847 = iprot.readListBegin();
+ struct.foreignKeys = new ArrayList<SQLForeignKey>(_list847.size);
+ SQLForeignKey _elem848;
+ for (int _i849 = 0; _i849 < _list847.size; ++_i849)
{
- _elem816 = new SQLForeignKey();
- _elem816.read(iprot);
- struct.foreignKeys.add(_elem816);
+ _elem848 = new SQLForeignKey();
+ _elem848.read(iprot);
+ struct.foreignKeys.add(_elem848);
}
iprot.readListEnd();
}
@@ -45901,14 +46046,14 @@ import org.slf4j.LoggerFactory;
case 4: // UNIQUE_CONSTRAINTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- 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)
+ org.apache.thrift.protocol.TList _list850 = iprot.readListBegin();
+ struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list850.size);
+ SQLUniqueConstraint _elem851;
+ for (int _i852 = 0; _i852 < _list850.size; ++_i852)
{
- _elem819 = new SQLUniqueConstraint();
- _elem819.read(iprot);
- struct.uniqueConstraints.add(_elem819);
+ _elem851 = new SQLUniqueConstraint();
+ _elem851.read(iprot);
+ struct.uniqueConstraints.add(_elem851);
}
iprot.readListEnd();
}
@@ -45920,14 +46065,14 @@ import org.slf4j.LoggerFactory;
case 5: // NOT_NULL_CONSTRAINTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- 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)
+ org.apache.thrift.protocol.TList _list853 = iprot.readListBegin();
+ struct.notNullConstraints = new ArrayList<SQLNotNullConstraint>(_list853.size);
+ SQLNotNullConstraint _elem854;
+ for (int _i855 = 0; _i855 < _list853.size; ++_i855)
{
- _elem822 = new SQLNotNullConstraint();
- _elem822.read(iprot);
- struct.notNullConstraints.add(_elem822);
+ _elem854 = new SQLNotNullConstraint();
+ _elem854.read(iprot);
+ struct.notNullConstraints.add(_elem854);
}
iprot.readListEnd();
}
@@ -45958,9 +46103,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 _iter824 : struct.primaryKeys)
+ for (SQLPrimaryKey _iter856 : struct.primaryKeys)
{
- _iter824.write(oprot);
+ _iter856.write(oprot);
}
oprot.writeListEnd();
}
@@ -45970,9 +46115,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 _iter825 : struct.foreignKeys)
+ for (SQLForeignKey _iter857 : struct.foreignKeys)
{
- _iter825.write(oprot);
+ _iter857.write(oprot);
}
oprot.writeListEnd();
}
@@ -45982,9 +46127,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 _iter826 : struct.uniqueConstraints)
+ for (SQLUniqueConstraint _iter858 : struct.uniqueConstraints)
{
- _iter826.write(oprot);
+ _iter858.write(oprot);
}
oprot.writeListEnd();
}
@@ -45994,9 +46139,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 _iter827 : struct.notNullConstraints)
+ for (SQLNotNullConstraint _iter859 : struct.notNullConstraints)
{
- _iter827.write(oprot);
+ _iter859.write(oprot);
}
oprot.writeListEnd();
}
@@ -46042,36 +46187,36 @@ import org.slf4j.LoggerFactory;
if (struct.isSetPrimaryKeys()) {
{
oprot.writeI32(struct.primaryKeys.size());
- for (SQLPrimaryKey _iter828 : struct.primaryKeys)
+ for (SQLPrimaryKey _iter860 : struct.primaryKeys)
{
- _iter828.write(oprot);
+ _iter860.write(oprot);
}
}
}
if (struct.isSetForeignKeys()) {
{
oprot.writeI32(struct.foreignKeys.size());
- for (SQLForeignKey _iter829 : struct.foreignKeys)
+ for (SQLForeignKey _iter861 : struct.foreignKeys)
{
- _iter829.write(oprot);
+ _iter861.write(oprot);
}
}
}
if (struct.isSetUniqueConstraints()) {
{
oprot.writeI32(struct.uniqueConstraints.size());
- for (SQLUniqueConstraint _iter830 : struct.uniqueConstraints)
+ for (SQLUniqueConstraint _iter862 : struct.uniqueConstraints)
{
- _iter830.write(oprot);
+ _iter862.write(oprot);
}
}
}
if (struct.isSetNotNullConstraints()) {
{
oprot.writeI32(struct.notNullConstraints.size());
- for (SQLNotNullConstraint _iter831 : struct.notNullConstraints)
+ for (SQLNotNullConstraint _iter863 : struct.notNullConstraints)
{
- _iter831.write(oprot);
+ _iter863.write(oprot);
}
}
}
@@ -46088,56 +46233,56 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(1)) {
{
- 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)
+ org.apache.thrift.protocol.TList _list864 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.primaryKeys = new ArrayList<SQLPrimaryKey>(_list864.size);
+ SQLPrimaryKey _elem865;
+ for (int _i866 = 0; _i866 < _list864.size; ++_i866)
{
- _elem833 = new SQLPrimaryKey();
- _elem833.read(iprot);
- struct.primaryKeys.add(_elem833);
+ _elem865 = new SQLPrimaryKey();
+ _elem865.read(iprot);
+ struct.primaryKeys.add(_elem865);
}
}
struct.setPrimaryKeysIsSet(true);
}
if (incoming.get(2)) {
{
- 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)
+ org.apache.thrift.protocol.TList _list867 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.foreignKeys = new ArrayList<SQLForeignKey>(_list867.size);
+ SQLForeignKey _elem868;
+ for (int _i869 = 0; _i869 < _list867.size; ++_i869)
{
- _elem836 = new SQLForeignKey();
- _elem836.read(iprot);
- struct.foreignKeys.add(_elem836);
+ _elem868 = new SQLForeignKey();
+ _elem868.read(iprot);
+ struct.foreignKeys.add(_elem868);
}
}
struct.setForeignKeysIsSet(true);
}
if (incoming.get(3)) {
{
- 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)
+ org.apache.thrift.protocol.TList _list870 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list870.size);
+ SQLUniqueConstraint _elem871;
+ for (int _i872 = 0; _i872 < _list870.size; ++_i872)
{
- _elem839 = new SQLUniqueConstraint();
- _elem839.read(iprot);
- struct.uniqueConstraints.add(_elem839);
+ _elem871 = new SQLUniqueConstraint();
+ _elem871.read(iprot);
+ struct.uniqueConstraints.add(_elem871);
}
}
struct.setUniqueConstraintsIsSet(true);
}
if (incoming.get(4)) {
{
- 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)
+ org.apache.thrift.protocol.TList _list873 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.notNullConstraints = new ArrayList<SQLNotNullConstraint>(_list873.size);
+ SQLNotNullConstraint _elem874;
+ for (int _i875 = 0; _i875 < _list873.size; ++_i875)
{
- _elem842 = new SQLNotNullConstraint();
- _elem842.read(iprot);
- struct.notNullConstraints.add(_elem842);
+ _elem874 = new SQLNotNullConstraint();
+ _elem874.read(iprot);
+ struct.notNullConstraints.add(_elem874);
}
}
struct.setNotNullConstraintsIsSet(true);
@@ -53629,13 +53774,13 @@ import org.slf4j.LoggerFactory;
case 3: // PART_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- 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)
+ org.apache.thrift.protocol.TList _list876 = iprot.readListBegin();
+ struct.partNames = new ArrayList<String>(_list876.size);
+ String _elem877;
+ for (int _i878 = 0; _i878 < _list876.size; ++_i878)
{
- _elem845 = iprot.readString();
- struct.partNames.add(_elem845);
+ _elem877 = iprot.readString();
+ struct.partNames.add(_elem877);
}
iprot.readListEnd();
}
@@ -53671,9 +53816,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 _iter847 : struct.partNames)
+ for (String _iter879 : struct.partNames)
{
- oprot.writeString(_iter847);
+ oprot.writeString(_iter879);
}
oprot.writeListEnd();
}
@@ -53716,9 +53861,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetPartNames()) {
{
oprot.writeI32(struct.partNames.size());
- for (String _iter848 : struct.partNames)
+ for (String _iter880 : struct.partNames)
{
- oprot.writeString(_iter848);
+ oprot.writeString(_iter880);
}
}
}
@@ -53738,13 +53883,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(2)) {
{
- 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)
+ org.apache.thrift.protocol.TList _list881 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.partNames = new ArrayList<String>(_list881.size);
+ String _elem882;
+ for (int _i883 = 0; _i883 < _list881.size; ++_i883)
{
- _elem850 = iprot.readString();
- struct.partNames.add(_elem850);
+ _elem882 = iprot.readString();
+ struct.partNames.add(_elem882);
}
}
struct.setPartNamesIsSet(true);
@@ -54969,13 +55114,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 _list884 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list884.size);
+ String _elem885;
+ for (int _i886 = 0; _i886 < _list884.size; ++_i886)
{
- _elem853 = iprot.readString();
- struct.success.add(_elem853);
+ _elem885 = iprot.readString();
+ struct.success.add(_elem885);
}
iprot.readListEnd();
}
@@ -55010,9 +55155,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 _iter887 : struct.success)
{
- oprot.writeString(_iter855);
+ oprot.writeString(_iter887);
}
oprot.writeListEnd();
}
@@ -55051,9 +55196,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter856 : struct.success)
+ for (String _iter888 : struct.success)
{
- oprot.writeString(_iter856);
+ oprot.writeString(_iter888);
}
}
}
@@ -55068,13 +55213,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 _list889 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list889.size);
+ String _elem890;
+ for (int _i891 = 0; _i891 < _list889.size; ++_i891)
{
- _elem858 = iprot.readString();
- struct.success.add(_elem858);
+ _elem890 = iprot.readString();
+ struct.success.add(_elem890);
}
}
struct.setSuccessIsSet(true);
@@ -56048,13 +56193,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list860 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list860.size);
- String _elem861;
- for (int _i862 = 0; _i862 < _list860.size; ++_i862)
+ org.apache.thrift.protocol.TList _list892 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list892.size);
+ String _elem893;
+ for (int _i894 = 0; _i894 < _list892.size; ++_i894)
{
- _elem861 = iprot.readString();
- struct.success.add(_elem861);
+ _elem893 = iprot.readString();
+ struct.success.add(_elem893);
}
iprot.readListEnd();
}
@@ -56089,9 +56234,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 _iter863 : struct.success)
+ for (String _iter895 : struct.success)
{
- oprot.writeString(_iter863);
+ oprot.writeString(_iter895);
}
oprot.writeListEnd();
}
@@ -56130,9 +56275,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter864 : struct.success)
+ for (String _iter896 : struct.success)
{
- oprot.writeString(_iter864);
+ oprot.writeString(_iter896);
}
}
}
@@ -56147,13 +56292,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- 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)
+ org.apache.thrift.protocol.TList _list897 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list897.size);
+ String _elem898;
+ for (int _i899 = 0; _i899 < _list897.size; ++_i899)
{
- _elem866 = iprot.readString();
- struct.success.add(_elem866);
+ _elem898 = iprot.readString();
+ struct.success.add(_elem898);
}
}
struct.setSuccessIsSet(true);
@@ -56658,13 +56803,13 @@ import org.slf4j.LoggerFactory;
case 3: // TBL_TYPES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- 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)
+ org.apache.thrift.protocol.TList _list900 = iprot.readListBegin();
+ struct.tbl_types = new ArrayList<String>(_list900.size);
+ String _elem901;
+ for (int _i902 = 0; _i902 < _list900.size; ++_i902)
{
- _elem869 = iprot.readString();
- struct.tbl_types.add(_elem869);
+ _elem901 = iprot.readString();
+ struct.tbl_types.add(_elem901);
}
iprot.readListEnd();
}
@@ -56700,9 +56845,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 _iter871 : struct.tbl_types)
+ for (String _iter903 : struct.tbl_types)
{
- oprot.writeString(_iter871);
+ oprot.writeString(_iter903);
}
oprot.writeListEnd();
}
@@ -56745,9 +56890,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetTbl_types()) {
{
oprot.writeI32(struct.tbl_types.size());
- for (String _iter872 : struct.tbl_types)
+ for (String _iter904 : struct.tbl_types)
{
- oprot.writeString(_iter872);
+ oprot.writeString(_iter904);
}
}
}
@@ -56767,13 +56912,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(2)) {
{
- 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)
+ org.apache.thrift.protocol.TList _list905 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.tbl_types = new ArrayList<String>(_list905.size);
+ String _elem906;
+ for (int _i907 = 0; _i907 < _list905.size; ++_i907)
{
- _elem874 = iprot.readString();
- struct.tbl_types.add(_elem874);
+ _elem906 = iprot.readString();
+ struct.tbl_types.add(_elem906);
}
}
struct.setTbl_typesIsSet(true);
@@ -57179,14 +57324,14 @@ 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<TableMeta>(_list876.size);
- TableMeta _elem877;
- for (int _i878 = 0; _i878 < _list876.size; ++_i878)
+ org.apache.thrift.protocol.TList _list908 = iprot.readListBegin();
+ struct.success = new ArrayList<TableMeta>(_list908.size);
+ TableMeta _elem909;
+ for (int _i910 = 0; _i910 < _list908.size; ++_i910)
{
- _elem877 = new TableMeta();
- _elem877.read(iprot);
- struct.success.add(_elem877);
+ _elem909 = new TableMeta();
+ _elem909.read(iprot);
+ struct.success.add(_elem909);
}
iprot.readListEnd();
}
@@ -57221,9 +57366,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 _iter879 : struct.success)
+ for (TableMeta _iter911 : struct.success)
{
- _iter879.write(oprot);
+ _iter911.write(oprot);
}
oprot.writeListEnd();
}
@@ -57262,9 +57407,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (TableMeta _iter880 : struct.success)
+ for (TableMeta _iter912 : struct.success)
{
- _iter880.write(oprot);
+ _iter912.write(oprot);
}
}
}
@@ -57279,14 +57424,14 @@ 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.STRUCT, iprot.readI32());
- struct.success = new ArrayList<TableMeta>(_list881.size);
- TableMeta _elem882;
- for (int _i883 = 0; _i883 < _list881.size; ++_i883)
+ org.apache.thrift.protocol.TList _list913 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<TableMeta>(_list913.size);
+ TableMeta _elem914;
+ for (int _i915 = 0; _i915 < _list913.size; ++_i915)
{
- _elem882 = new TableMeta();
- _elem882.read(iprot);
- struct.success.add(_elem882);
+ _elem914 = new TableMeta();
+ _elem914.read(iprot);
+ struct.success.add(_elem914);
}
}
struct.setSuccessIsSet(true);
@@ -58052,13 +58197,13 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- 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)
+ org.apache.thrift.protocol.TList _list916 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list916.size);
+ String _elem917;
+ for (int _i918 = 0; _i918 < _list916.size; ++_i918)
{
- _elem885 = iprot.readString();
- struct.success.add(_elem885);
+ _elem917 = iprot.readString();
+ struct.success.add(_elem917);
}
iprot.readListEnd();
}
@@ -58093,9 +58238,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 _iter887 : struct.success)
+ for (String _iter919 : struct.success)
{
- oprot.writeString(_iter887);
+ oprot.writeString(_iter919);
}
oprot.writeListEnd();
}
@@ -58134,9 +58279,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter888 : struct.success)
+ for (String _iter920 : struct.success)
{
- oprot.writeString(_iter888);
+ oprot.writeString(_iter920);
}
}
}
@@ -58151,13 +58296,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list889 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list889.size);
- String _elem890;
- for (int _i891 = 0; _i891 < _list889.size; ++_i891)
+ org.apache.thrift.protocol.TList _list921 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list921.size);
+ String _elem922;
+ for (int _i923 = 0; _i923 < _list921.size; ++_i923)
{
- _elem890 = iprot.readString();
- struct.success.add(_elem890);
+ _elem922 = iprot.readString();
+ struct.success.add(_elem922);
}
}
struct.setSuccessIsSet(true);
@@ -59610,13 +59755,13 @@ import org.slf4j.LoggerFactory;
case 2: // TBL_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list892 = iprot.readListBegin();
- struct.tbl_names = new ArrayList<String>(_list892.size);
- String _elem893;
- for (int _i894 = 0; _i894 < _list892.size; ++_i894)
+ org.apache.thrift.protocol.TList _list924 = iprot.readListBegin();
+ struct.tbl_names = new ArrayList<String>(_list924.size);
+ String _elem925;
+ for (int _i926 = 0; _i926 < _list924.size; ++_i926)
{
- _elem893 = iprot.readString();
- struct.tbl_names.add(_elem893);
+ _elem925 = iprot.readString();
+ struct.tbl_names.add(_elem925);
}
iprot.readListEnd();
}
@@ -59647,9 +59792,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(TBL_NAMES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.tbl_names.size()));
- for (String _iter895 : struct.tbl_names)
+ for (String _iter927 : struct.tbl_names)
{
- oprot.writeString(_iter895);
+ oprot.writeString(_iter927);
}
oprot.writeListEnd();
}
@@ -59686,9 +59831,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetTbl_names()) {
{
oprot.writeI32(struct.tbl_names.size());
- for (String _iter896 : struct.tbl_names)
+ for (String _iter928 : struct.tbl_names)
{
- oprot.writeString(_iter896);
+ oprot.writeString(_iter928);
}
}
}
@@ -59704,13 +59849,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list897 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.tbl_names = new ArrayList<String>(_list897.size);
- String _elem898;
- for (int _i899 = 0; _i899 < _list897.size; ++_i899)
+ org.apache.thrift.protocol.TList _list929 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.tbl_names = new ArrayList<String>(_list929.size);
+ String _elem930;
+ for (int _i931 = 0; _i931 < _list929.size; ++_i931)
{
- _elem898 = iprot.readString();
- struct.tbl_names.add(_elem898);
+ _elem930 = iprot.readString();
+ struct.tbl_names.add(_elem930);
}
}
struct.setTbl_namesIsSet(true);
@@ -60035,14 +60180,14 @@ import org.slf4j.LoggerFactory;
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.
<TRUNCATED>