You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ha...@apache.org on 2016/05/11 20:31:36 UTC
[06/12] hive git commit: HIVE-13350: Support Alter commands for
Rely/NoRely novalidate for PK/FK constraints (Hari Subramaniyan,
reviewed by Ashutosh Chauhan)
http://git-wip-us.apache.org/repos/asf/hive/blob/b36f6a3a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
index ee40698..13a8b71 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
@@ -82,6 +82,10 @@ public class ThriftHiveMetastore {
public void drop_constraint(DropConstraintRequest req) throws NoSuchObjectException, MetaException, org.apache.thrift.TException;
+ public void add_primary_key(AddPrimaryKeyRequest req) throws NoSuchObjectException, MetaException, org.apache.thrift.TException;
+
+ public void add_foreign_key(AddForeignKeyRequest req) throws NoSuchObjectException, MetaException, org.apache.thrift.TException;
+
public void drop_table(String dbname, String name, boolean deleteData) throws NoSuchObjectException, MetaException, org.apache.thrift.TException;
public void drop_table_with_environment_context(String dbname, String name, boolean deleteData, EnvironmentContext environment_context) throws NoSuchObjectException, MetaException, org.apache.thrift.TException;
@@ -380,6 +384,10 @@ public class ThriftHiveMetastore {
public void drop_constraint(DropConstraintRequest req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void add_primary_key(AddPrimaryKeyRequest req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void add_foreign_key(AddForeignKeyRequest req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
public void drop_table(String dbname, String name, boolean deleteData, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void drop_table_with_environment_context(String dbname, String name, boolean deleteData, EnvironmentContext environment_context, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
@@ -1248,6 +1256,58 @@ public class ThriftHiveMetastore {
return;
}
+ public void add_primary_key(AddPrimaryKeyRequest req) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
+ {
+ send_add_primary_key(req);
+ recv_add_primary_key();
+ }
+
+ public void send_add_primary_key(AddPrimaryKeyRequest req) throws org.apache.thrift.TException
+ {
+ add_primary_key_args args = new add_primary_key_args();
+ args.setReq(req);
+ sendBase("add_primary_key", args);
+ }
+
+ public void recv_add_primary_key() throws NoSuchObjectException, MetaException, org.apache.thrift.TException
+ {
+ add_primary_key_result result = new add_primary_key_result();
+ receiveBase(result, "add_primary_key");
+ if (result.o1 != null) {
+ throw result.o1;
+ }
+ if (result.o2 != null) {
+ throw result.o2;
+ }
+ return;
+ }
+
+ public void add_foreign_key(AddForeignKeyRequest req) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
+ {
+ send_add_foreign_key(req);
+ recv_add_foreign_key();
+ }
+
+ public void send_add_foreign_key(AddForeignKeyRequest req) throws org.apache.thrift.TException
+ {
+ add_foreign_key_args args = new add_foreign_key_args();
+ args.setReq(req);
+ sendBase("add_foreign_key", args);
+ }
+
+ public void recv_add_foreign_key() throws NoSuchObjectException, MetaException, org.apache.thrift.TException
+ {
+ add_foreign_key_result result = new add_foreign_key_result();
+ receiveBase(result, "add_foreign_key");
+ if (result.o1 != null) {
+ throw result.o1;
+ }
+ if (result.o2 != null) {
+ throw result.o2;
+ }
+ return;
+ }
+
public void drop_table(String dbname, String name, boolean deleteData) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
{
send_drop_table(dbname, name, deleteData);
@@ -5597,6 +5657,70 @@ public class ThriftHiveMetastore {
}
}
+ public void add_primary_key(AddPrimaryKeyRequest req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ add_primary_key_call method_call = new add_primary_key_call(req, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class add_primary_key_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private AddPrimaryKeyRequest req;
+ public add_primary_key_call(AddPrimaryKeyRequest req, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.req = req;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("add_primary_key", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ add_primary_key_args args = new add_primary_key_args();
+ args.setReq(req);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public void 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);
+ (new Client(prot)).recv_add_primary_key();
+ }
+ }
+
+ public void add_foreign_key(AddForeignKeyRequest req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ add_foreign_key_call method_call = new add_foreign_key_call(req, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class add_foreign_key_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private AddForeignKeyRequest req;
+ public add_foreign_key_call(AddForeignKeyRequest req, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.req = req;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("add_foreign_key", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ add_foreign_key_args args = new add_foreign_key_args();
+ args.setReq(req);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public void 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);
+ (new Client(prot)).recv_add_foreign_key();
+ }
+ }
+
public void drop_table(String dbname, String name, boolean deleteData, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
drop_table_call method_call = new drop_table_call(dbname, name, deleteData, resultHandler, this, ___protocolFactory, ___transport);
@@ -10141,6 +10265,8 @@ public class ThriftHiveMetastore {
processMap.put("create_table_with_environment_context", new create_table_with_environment_context());
processMap.put("create_table_with_constraints", new create_table_with_constraints());
processMap.put("drop_constraint", new drop_constraint());
+ processMap.put("add_primary_key", new add_primary_key());
+ processMap.put("add_foreign_key", new add_foreign_key());
processMap.put("drop_table", new drop_table());
processMap.put("drop_table_with_environment_context", new drop_table_with_environment_context());
processMap.put("get_tables", new get_tables());
@@ -10809,6 +10935,58 @@ public class ThriftHiveMetastore {
}
}
+ public static class add_primary_key<I extends Iface> extends org.apache.thrift.ProcessFunction<I, add_primary_key_args> {
+ public add_primary_key() {
+ super("add_primary_key");
+ }
+
+ public add_primary_key_args getEmptyArgsInstance() {
+ return new add_primary_key_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public add_primary_key_result getResult(I iface, add_primary_key_args args) throws org.apache.thrift.TException {
+ add_primary_key_result result = new add_primary_key_result();
+ try {
+ iface.add_primary_key(args.req);
+ } catch (NoSuchObjectException o1) {
+ result.o1 = o1;
+ } catch (MetaException o2) {
+ result.o2 = o2;
+ }
+ return result;
+ }
+ }
+
+ public static class add_foreign_key<I extends Iface> extends org.apache.thrift.ProcessFunction<I, add_foreign_key_args> {
+ public add_foreign_key() {
+ super("add_foreign_key");
+ }
+
+ public add_foreign_key_args getEmptyArgsInstance() {
+ return new add_foreign_key_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public add_foreign_key_result getResult(I iface, add_foreign_key_args args) throws org.apache.thrift.TException {
+ add_foreign_key_result result = new add_foreign_key_result();
+ try {
+ iface.add_foreign_key(args.req);
+ } catch (NoSuchObjectException o1) {
+ result.o1 = o1;
+ } catch (MetaException o2) {
+ result.o2 = o2;
+ }
+ return result;
+ }
+ }
+
public static class drop_table<I extends Iface> extends org.apache.thrift.ProcessFunction<I, drop_table_args> {
public drop_table() {
super("drop_table");
@@ -14058,6 +14236,8 @@ public class ThriftHiveMetastore {
processMap.put("create_table_with_environment_context", new create_table_with_environment_context());
processMap.put("create_table_with_constraints", new create_table_with_constraints());
processMap.put("drop_constraint", new drop_constraint());
+ processMap.put("add_primary_key", new add_primary_key());
+ processMap.put("add_foreign_key", new add_foreign_key());
processMap.put("drop_table", new drop_table());
processMap.put("drop_table_with_environment_context", new drop_table_with_environment_context());
processMap.put("get_tables", new get_tables());
@@ -15462,20 +15642,20 @@ public class ThriftHiveMetastore {
}
}
- public static class drop_table<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, drop_table_args, Void> {
- public drop_table() {
- super("drop_table");
+ public static class add_primary_key<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, add_primary_key_args, Void> {
+ public add_primary_key() {
+ super("add_primary_key");
}
- public drop_table_args getEmptyArgsInstance() {
- return new drop_table_args();
+ public add_primary_key_args getEmptyArgsInstance() {
+ return new add_primary_key_args();
}
public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
return new AsyncMethodCallback<Void>() {
public void onComplete(Void o) {
- drop_table_result result = new drop_table_result();
+ add_primary_key_result result = new add_primary_key_result();
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -15487,15 +15667,15 @@ public class ThriftHiveMetastore {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- drop_table_result result = new drop_table_result();
+ add_primary_key_result result = new add_primary_key_result();
if (e instanceof NoSuchObjectException) {
result.o1 = (NoSuchObjectException) e;
result.setO1IsSet(true);
msg = result;
}
else if (e instanceof MetaException) {
- result.o3 = (MetaException) e;
- result.setO3IsSet(true);
+ result.o2 = (MetaException) e;
+ result.setO2IsSet(true);
msg = result;
}
else
@@ -15518,25 +15698,25 @@ public class ThriftHiveMetastore {
return false;
}
- public void start(I iface, drop_table_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
- iface.drop_table(args.dbname, args.name, args.deleteData,resultHandler);
+ public void start(I iface, add_primary_key_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
+ iface.add_primary_key(args.req,resultHandler);
}
}
- public static class drop_table_with_environment_context<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, drop_table_with_environment_context_args, Void> {
- public drop_table_with_environment_context() {
- super("drop_table_with_environment_context");
+ public static class add_foreign_key<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, add_foreign_key_args, Void> {
+ public add_foreign_key() {
+ super("add_foreign_key");
}
- public drop_table_with_environment_context_args getEmptyArgsInstance() {
- return new drop_table_with_environment_context_args();
+ public add_foreign_key_args getEmptyArgsInstance() {
+ return new add_foreign_key_args();
}
public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
return new AsyncMethodCallback<Void>() {
public void onComplete(Void o) {
- drop_table_with_environment_context_result result = new drop_table_with_environment_context_result();
+ add_foreign_key_result result = new add_foreign_key_result();
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -15548,15 +15728,15 @@ public class ThriftHiveMetastore {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- drop_table_with_environment_context_result result = new drop_table_with_environment_context_result();
+ add_foreign_key_result result = new add_foreign_key_result();
if (e instanceof NoSuchObjectException) {
result.o1 = (NoSuchObjectException) e;
result.setO1IsSet(true);
msg = result;
}
else if (e instanceof MetaException) {
- result.o3 = (MetaException) e;
- result.setO3IsSet(true);
+ result.o2 = (MetaException) e;
+ result.setO2IsSet(true);
msg = result;
}
else
@@ -15579,26 +15759,25 @@ public class ThriftHiveMetastore {
return false;
}
- public void start(I iface, drop_table_with_environment_context_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
- iface.drop_table_with_environment_context(args.dbname, args.name, args.deleteData, args.environment_context,resultHandler);
+ public void start(I iface, add_foreign_key_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
+ iface.add_foreign_key(args.req,resultHandler);
}
}
- public static class get_tables<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_tables_args, List<String>> {
- public get_tables() {
- super("get_tables");
+ public static class drop_table<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, drop_table_args, Void> {
+ public drop_table() {
+ super("drop_table");
}
- public get_tables_args getEmptyArgsInstance() {
- return new get_tables_args();
+ public drop_table_args getEmptyArgsInstance() {
+ return new drop_table_args();
}
- public AsyncMethodCallback<List<String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<List<String>>() {
- public void onComplete(List<String> o) {
- get_tables_result result = new get_tables_result();
- result.success = o;
+ return new AsyncMethodCallback<Void>() {
+ public void onComplete(Void o) {
+ drop_table_result result = new drop_table_result();
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -15610,12 +15789,17 @@ public class ThriftHiveMetastore {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- get_tables_result result = new get_tables_result();
- if (e instanceof MetaException) {
- result.o1 = (MetaException) e;
+ drop_table_result result = new drop_table_result();
+ if (e instanceof NoSuchObjectException) {
+ result.o1 = (NoSuchObjectException) e;
result.setO1IsSet(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;
@@ -15636,26 +15820,25 @@ public class ThriftHiveMetastore {
return false;
}
- public void start(I iface, get_tables_args args, org.apache.thrift.async.AsyncMethodCallback<List<String>> resultHandler) throws TException {
- iface.get_tables(args.db_name, args.pattern,resultHandler);
+ public void start(I iface, drop_table_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
+ iface.drop_table(args.dbname, args.name, args.deleteData,resultHandler);
}
}
- public static class get_table_meta<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_table_meta_args, List<TableMeta>> {
- public get_table_meta() {
- super("get_table_meta");
+ public static class drop_table_with_environment_context<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, drop_table_with_environment_context_args, Void> {
+ public drop_table_with_environment_context() {
+ super("drop_table_with_environment_context");
}
- public get_table_meta_args getEmptyArgsInstance() {
- return new get_table_meta_args();
+ public drop_table_with_environment_context_args getEmptyArgsInstance() {
+ return new drop_table_with_environment_context_args();
}
- public AsyncMethodCallback<List<TableMeta>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<List<TableMeta>>() {
- public void onComplete(List<TableMeta> o) {
- get_table_meta_result result = new get_table_meta_result();
- result.success = o;
+ return new AsyncMethodCallback<Void>() {
+ public void onComplete(Void o) {
+ drop_table_with_environment_context_result result = new drop_table_with_environment_context_result();
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -15667,12 +15850,17 @@ public class ThriftHiveMetastore {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- get_table_meta_result result = new get_table_meta_result();
- if (e instanceof MetaException) {
- result.o1 = (MetaException) e;
+ drop_table_with_environment_context_result result = new drop_table_with_environment_context_result();
+ if (e instanceof NoSuchObjectException) {
+ result.o1 = (NoSuchObjectException) e;
result.setO1IsSet(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;
@@ -15693,25 +15881,25 @@ public class ThriftHiveMetastore {
return false;
}
- public void start(I iface, get_table_meta_args args, org.apache.thrift.async.AsyncMethodCallback<List<TableMeta>> resultHandler) throws TException {
- iface.get_table_meta(args.db_patterns, args.tbl_patterns, args.tbl_types,resultHandler);
+ public void start(I iface, drop_table_with_environment_context_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
+ iface.drop_table_with_environment_context(args.dbname, args.name, args.deleteData, args.environment_context,resultHandler);
}
}
- public static class get_all_tables<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_all_tables_args, List<String>> {
- public get_all_tables() {
- super("get_all_tables");
+ public static class get_tables<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_tables_args, List<String>> {
+ public get_tables() {
+ super("get_tables");
}
- public get_all_tables_args getEmptyArgsInstance() {
- return new get_all_tables_args();
+ public get_tables_args getEmptyArgsInstance() {
+ return new get_tables_args();
}
public AsyncMethodCallback<List<String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
return new AsyncMethodCallback<List<String>>() {
public void onComplete(List<String> o) {
- get_all_tables_result result = new get_all_tables_result();
+ get_tables_result result = new get_tables_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -15724,7 +15912,7 @@ public class ThriftHiveMetastore {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- get_all_tables_result result = new get_all_tables_result();
+ get_tables_result result = new get_tables_result();
if (e instanceof MetaException) {
result.o1 = (MetaException) e;
result.setO1IsSet(true);
@@ -15750,25 +15938,25 @@ public class ThriftHiveMetastore {
return false;
}
- public void start(I iface, get_all_tables_args args, org.apache.thrift.async.AsyncMethodCallback<List<String>> resultHandler) throws TException {
- iface.get_all_tables(args.db_name,resultHandler);
+ public void start(I iface, get_tables_args args, org.apache.thrift.async.AsyncMethodCallback<List<String>> resultHandler) throws TException {
+ iface.get_tables(args.db_name, args.pattern,resultHandler);
}
}
- public static class get_table<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_table_args, Table> {
- public get_table() {
- super("get_table");
+ public static class get_table_meta<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_table_meta_args, List<TableMeta>> {
+ public get_table_meta() {
+ super("get_table_meta");
}
- public get_table_args getEmptyArgsInstance() {
- return new get_table_args();
+ public get_table_meta_args getEmptyArgsInstance() {
+ return new get_table_meta_args();
}
- public AsyncMethodCallback<Table> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<TableMeta>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Table>() {
- public void onComplete(Table o) {
- get_table_result result = new get_table_result();
+ return new AsyncMethodCallback<List<TableMeta>>() {
+ public void onComplete(List<TableMeta> o) {
+ get_table_meta_result result = new get_table_meta_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -15781,17 +15969,131 @@ public class ThriftHiveMetastore {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- get_table_result result = new get_table_result();
+ get_table_meta_result result = new get_table_meta_result();
if (e instanceof MetaException) {
result.o1 = (MetaException) e;
result.setO1IsSet(true);
msg = result;
}
- else if (e instanceof NoSuchObjectException) {
- result.o2 = (NoSuchObjectException) 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_table_meta_args args, org.apache.thrift.async.AsyncMethodCallback<List<TableMeta>> resultHandler) throws TException {
+ iface.get_table_meta(args.db_patterns, args.tbl_patterns, args.tbl_types,resultHandler);
+ }
+ }
+
+ public static class get_all_tables<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_all_tables_args, List<String>> {
+ public get_all_tables() {
+ super("get_all_tables");
+ }
+
+ public get_all_tables_args getEmptyArgsInstance() {
+ return new get_all_tables_args();
+ }
+
+ public AsyncMethodCallback<List<String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.thrift.AsyncProcessFunction fcall = this;
+ return new AsyncMethodCallback<List<String>>() {
+ public void onComplete(List<String> o) {
+ get_all_tables_result result = new get_all_tables_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_all_tables_result result = new get_all_tables_result();
+ if (e instanceof MetaException) {
+ result.o1 = (MetaException) e;
+ result.setO1IsSet(true);
+ msg = result;
+ }
+ else
+ {
+ msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
+ msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
+ }
+ try {
+ fcall.sendResponse(fb,msg,msgType,seqid);
+ return;
+ } catch (Exception ex) {
+ LOGGER.error("Exception writing to internal frame buffer", ex);
+ }
+ fb.close();
+ }
+ };
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public void start(I iface, get_all_tables_args args, org.apache.thrift.async.AsyncMethodCallback<List<String>> resultHandler) throws TException {
+ iface.get_all_tables(args.db_name,resultHandler);
+ }
+ }
+
+ public static class get_table<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_table_args, Table> {
+ public get_table() {
+ super("get_table");
+ }
+
+ public get_table_args getEmptyArgsInstance() {
+ return new get_table_args();
+ }
+
+ public AsyncMethodCallback<Table> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.thrift.AsyncProcessFunction fcall = this;
+ return new AsyncMethodCallback<Table>() {
+ public void onComplete(Table o) {
+ get_table_result result = new get_table_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_table_result result = new get_table_result();
+ if (e instanceof MetaException) {
+ result.o1 = (MetaException) e;
+ result.setO1IsSet(true);
+ msg = result;
+ }
+ else if (e instanceof NoSuchObjectException) {
+ result.o2 = (NoSuchObjectException) e;
+ result.setO2IsSet(true);
+ msg = result;
+ }
else
{
msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
@@ -28540,13 +28842,13 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list616 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list616.size);
- String _elem617;
- for (int _i618 = 0; _i618 < _list616.size; ++_i618)
+ org.apache.thrift.protocol.TList _list632 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list632.size);
+ String _elem633;
+ for (int _i634 = 0; _i634 < _list632.size; ++_i634)
{
- _elem617 = iprot.readString();
- struct.success.add(_elem617);
+ _elem633 = iprot.readString();
+ struct.success.add(_elem633);
}
iprot.readListEnd();
}
@@ -28581,9 +28883,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
- for (String _iter619 : struct.success)
+ for (String _iter635 : struct.success)
{
- oprot.writeString(_iter619);
+ oprot.writeString(_iter635);
}
oprot.writeListEnd();
}
@@ -28622,9 +28924,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter620 : struct.success)
+ for (String _iter636 : struct.success)
{
- oprot.writeString(_iter620);
+ oprot.writeString(_iter636);
}
}
}
@@ -28639,13 +28941,13 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list621 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list621.size);
- String _elem622;
- for (int _i623 = 0; _i623 < _list621.size; ++_i623)
+ org.apache.thrift.protocol.TList _list637 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list637.size);
+ String _elem638;
+ for (int _i639 = 0; _i639 < _list637.size; ++_i639)
{
- _elem622 = iprot.readString();
- struct.success.add(_elem622);
+ _elem638 = iprot.readString();
+ struct.success.add(_elem638);
}
}
struct.setSuccessIsSet(true);
@@ -29299,13 +29601,13 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list624 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list624.size);
- String _elem625;
- for (int _i626 = 0; _i626 < _list624.size; ++_i626)
+ org.apache.thrift.protocol.TList _list640 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list640.size);
+ String _elem641;
+ for (int _i642 = 0; _i642 < _list640.size; ++_i642)
{
- _elem625 = iprot.readString();
- struct.success.add(_elem625);
+ _elem641 = iprot.readString();
+ struct.success.add(_elem641);
}
iprot.readListEnd();
}
@@ -29340,9 +29642,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
- for (String _iter627 : struct.success)
+ for (String _iter643 : struct.success)
{
- oprot.writeString(_iter627);
+ oprot.writeString(_iter643);
}
oprot.writeListEnd();
}
@@ -29381,9 +29683,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter628 : struct.success)
+ for (String _iter644 : struct.success)
{
- oprot.writeString(_iter628);
+ oprot.writeString(_iter644);
}
}
}
@@ -29398,13 +29700,13 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list629 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list629.size);
- String _elem630;
- for (int _i631 = 0; _i631 < _list629.size; ++_i631)
+ org.apache.thrift.protocol.TList _list645 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list645.size);
+ String _elem646;
+ for (int _i647 = 0; _i647 < _list645.size; ++_i647)
{
- _elem630 = iprot.readString();
- struct.success.add(_elem630);
+ _elem646 = iprot.readString();
+ struct.success.add(_elem646);
}
}
struct.setSuccessIsSet(true);
@@ -34011,16 +34313,16 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map632 = iprot.readMapBegin();
- struct.success = new HashMap<String,Type>(2*_map632.size);
- String _key633;
- Type _val634;
- for (int _i635 = 0; _i635 < _map632.size; ++_i635)
+ org.apache.thrift.protocol.TMap _map648 = iprot.readMapBegin();
+ struct.success = new HashMap<String,Type>(2*_map648.size);
+ String _key649;
+ Type _val650;
+ for (int _i651 = 0; _i651 < _map648.size; ++_i651)
{
- _key633 = iprot.readString();
- _val634 = new Type();
- _val634.read(iprot);
- struct.success.put(_key633, _val634);
+ _key649 = iprot.readString();
+ _val650 = new Type();
+ _val650.read(iprot);
+ struct.success.put(_key649, _val650);
}
iprot.readMapEnd();
}
@@ -34055,10 +34357,10 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (Map.Entry<String, Type> _iter636 : struct.success.entrySet())
+ for (Map.Entry<String, Type> _iter652 : struct.success.entrySet())
{
- oprot.writeString(_iter636.getKey());
- _iter636.getValue().write(oprot);
+ oprot.writeString(_iter652.getKey());
+ _iter652.getValue().write(oprot);
}
oprot.writeMapEnd();
}
@@ -34097,10 +34399,10 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Map.Entry<String, Type> _iter637 : struct.success.entrySet())
+ for (Map.Entry<String, Type> _iter653 : struct.success.entrySet())
{
- oprot.writeString(_iter637.getKey());
- _iter637.getValue().write(oprot);
+ oprot.writeString(_iter653.getKey());
+ _iter653.getValue().write(oprot);
}
}
}
@@ -34115,16 +34417,16 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TMap _map638 = 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*_map638.size);
- String _key639;
- Type _val640;
- for (int _i641 = 0; _i641 < _map638.size; ++_i641)
+ org.apache.thrift.protocol.TMap _map654 = 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*_map654.size);
+ String _key655;
+ Type _val656;
+ for (int _i657 = 0; _i657 < _map654.size; ++_i657)
{
- _key639 = iprot.readString();
- _val640 = new Type();
- _val640.read(iprot);
- struct.success.put(_key639, _val640);
+ _key655 = iprot.readString();
+ _val656 = new Type();
+ _val656.read(iprot);
+ struct.success.put(_key655, _val656);
}
}
struct.setSuccessIsSet(true);
@@ -35159,14 +35461,14 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list642 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list642.size);
- FieldSchema _elem643;
- for (int _i644 = 0; _i644 < _list642.size; ++_i644)
+ org.apache.thrift.protocol.TList _list658 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list658.size);
+ FieldSchema _elem659;
+ for (int _i660 = 0; _i660 < _list658.size; ++_i660)
{
- _elem643 = new FieldSchema();
- _elem643.read(iprot);
- struct.success.add(_elem643);
+ _elem659 = new FieldSchema();
+ _elem659.read(iprot);
+ struct.success.add(_elem659);
}
iprot.readListEnd();
}
@@ -35219,9 +35521,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (FieldSchema _iter645 : struct.success)
+ for (FieldSchema _iter661 : struct.success)
{
- _iter645.write(oprot);
+ _iter661.write(oprot);
}
oprot.writeListEnd();
}
@@ -35276,9 +35578,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter646 : struct.success)
+ for (FieldSchema _iter662 : struct.success)
{
- _iter646.write(oprot);
+ _iter662.write(oprot);
}
}
}
@@ -35299,14 +35601,14 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list647 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list647.size);
- FieldSchema _elem648;
- for (int _i649 = 0; _i649 < _list647.size; ++_i649)
+ org.apache.thrift.protocol.TList _list663 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list663.size);
+ FieldSchema _elem664;
+ for (int _i665 = 0; _i665 < _list663.size; ++_i665)
{
- _elem648 = new FieldSchema();
- _elem648.read(iprot);
- struct.success.add(_elem648);
+ _elem664 = new FieldSchema();
+ _elem664.read(iprot);
+ struct.success.add(_elem664);
}
}
struct.setSuccessIsSet(true);
@@ -36460,14 +36762,14 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list650 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list650.size);
- FieldSchema _elem651;
- for (int _i652 = 0; _i652 < _list650.size; ++_i652)
+ org.apache.thrift.protocol.TList _list666 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list666.size);
+ FieldSchema _elem667;
+ for (int _i668 = 0; _i668 < _list666.size; ++_i668)
{
- _elem651 = new FieldSchema();
- _elem651.read(iprot);
- struct.success.add(_elem651);
+ _elem667 = new FieldSchema();
+ _elem667.read(iprot);
+ struct.success.add(_elem667);
}
iprot.readListEnd();
}
@@ -36520,9 +36822,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (FieldSchema _iter653 : struct.success)
+ for (FieldSchema _iter669 : struct.success)
{
- _iter653.write(oprot);
+ _iter669.write(oprot);
}
oprot.writeListEnd();
}
@@ -36577,9 +36879,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter654 : struct.success)
+ for (FieldSchema _iter670 : struct.success)
{
- _iter654.write(oprot);
+ _iter670.write(oprot);
}
}
}
@@ -36600,14 +36902,14 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list655 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list655.size);
- FieldSchema _elem656;
- for (int _i657 = 0; _i657 < _list655.size; ++_i657)
+ org.apache.thrift.protocol.TList _list671 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list671.size);
+ FieldSchema _elem672;
+ for (int _i673 = 0; _i673 < _list671.size; ++_i673)
{
- _elem656 = new FieldSchema();
- _elem656.read(iprot);
- struct.success.add(_elem656);
+ _elem672 = new FieldSchema();
+ _elem672.read(iprot);
+ struct.success.add(_elem672);
}
}
struct.setSuccessIsSet(true);
@@ -37652,14 +37954,14 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list658 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list658.size);
- FieldSchema _elem659;
- for (int _i660 = 0; _i660 < _list658.size; ++_i660)
+ org.apache.thrift.protocol.TList _list674 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list674.size);
+ FieldSchema _elem675;
+ for (int _i676 = 0; _i676 < _list674.size; ++_i676)
{
- _elem659 = new FieldSchema();
- _elem659.read(iprot);
- struct.success.add(_elem659);
+ _elem675 = new FieldSchema();
+ _elem675.read(iprot);
+ struct.success.add(_elem675);
}
iprot.readListEnd();
}
@@ -37712,9 +38014,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (FieldSchema _iter661 : struct.success)
+ for (FieldSchema _iter677 : struct.success)
{
- _iter661.write(oprot);
+ _iter677.write(oprot);
}
oprot.writeListEnd();
}
@@ -37769,9 +38071,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter662 : struct.success)
+ for (FieldSchema _iter678 : struct.success)
{
- _iter662.write(oprot);
+ _iter678.write(oprot);
}
}
}
@@ -37792,14 +38094,14 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list663 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list663.size);
- FieldSchema _elem664;
- for (int _i665 = 0; _i665 < _list663.size; ++_i665)
+ org.apache.thrift.protocol.TList _list679 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list679.size);
+ FieldSchema _elem680;
+ for (int _i681 = 0; _i681 < _list679.size; ++_i681)
{
- _elem664 = new FieldSchema();
- _elem664.read(iprot);
- struct.success.add(_elem664);
+ _elem680 = new FieldSchema();
+ _elem680.read(iprot);
+ struct.success.add(_elem680);
}
}
struct.setSuccessIsSet(true);
@@ -38953,14 +39255,14 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list666 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list666.size);
- FieldSchema _elem667;
- for (int _i668 = 0; _i668 < _list666.size; ++_i668)
+ org.apache.thrift.protocol.TList _list682 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list682.size);
+ FieldSchema _elem683;
+ for (int _i684 = 0; _i684 < _list682.size; ++_i684)
{
- _elem667 = new FieldSchema();
- _elem667.read(iprot);
- struct.success.add(_elem667);
+ _elem683 = new FieldSchema();
+ _elem683.read(iprot);
+ struct.success.add(_elem683);
}
iprot.readListEnd();
}
@@ -39013,9 +39315,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (FieldSchema _iter669 : struct.success)
+ for (FieldSchema _iter685 : struct.success)
{
- _iter669.write(oprot);
+ _iter685.write(oprot);
}
oprot.writeListEnd();
}
@@ -39070,9 +39372,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter670 : struct.success)
+ for (FieldSchema _iter686 : struct.success)
{
- _iter670.write(oprot);
+ _iter686.write(oprot);
}
}
}
@@ -39093,14 +39395,14 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list671 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list671.size);
- FieldSchema _elem672;
- for (int _i673 = 0; _i673 < _list671.size; ++_i673)
+ org.apache.thrift.protocol.TList _list687 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list687.size);
+ FieldSchema _elem688;
+ for (int _i689 = 0; _i689 < _list687.size; ++_i689)
{
- _elem672 = new FieldSchema();
- _elem672.read(iprot);
- struct.success.add(_elem672);
+ _elem688 = new FieldSchema();
+ _elem688.read(iprot);
+ struct.success.add(_elem688);
}
}
struct.setSuccessIsSet(true);
@@ -41825,14 +42127,14 @@ public class ThriftHiveMetastore {
case 2: // PRIMARY_KEYS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list674 = iprot.readListBegin();
- struct.primaryKeys = new ArrayList<SQLPrimaryKey>(_list674.size);
- SQLPrimaryKey _elem675;
- for (int _i676 = 0; _i676 < _list674.size; ++_i676)
+ org.apache.thrift.protocol.TList _list690 = iprot.readListBegin();
+ struct.primaryKeys = new ArrayList<SQLPrimaryKey>(_list690.size);
+ SQLPrimaryKey _elem691;
+ for (int _i692 = 0; _i692 < _list690.size; ++_i692)
{
- _elem675 = new SQLPrimaryKey();
- _elem675.read(iprot);
- struct.primaryKeys.add(_elem675);
+ _elem691 = new SQLPrimaryKey();
+ _elem691.read(iprot);
+ struct.primaryKeys.add(_elem691);
}
iprot.readListEnd();
}
@@ -41844,14 +42146,14 @@ public class ThriftHiveMetastore {
case 3: // FOREIGN_KEYS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list677 = iprot.readListBegin();
- struct.foreignKeys = new ArrayList<SQLForeignKey>(_list677.size);
- SQLForeignKey _elem678;
- for (int _i679 = 0; _i679 < _list677.size; ++_i679)
+ org.apache.thrift.protocol.TList _list693 = iprot.readListBegin();
+ struct.foreignKeys = new ArrayList<SQLForeignKey>(_list693.size);
+ SQLForeignKey _elem694;
+ for (int _i695 = 0; _i695 < _list693.size; ++_i695)
{
- _elem678 = new SQLForeignKey();
- _elem678.read(iprot);
- struct.foreignKeys.add(_elem678);
+ _elem694 = new SQLForeignKey();
+ _elem694.read(iprot);
+ struct.foreignKeys.add(_elem694);
}
iprot.readListEnd();
}
@@ -41882,9 +42184,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(PRIMARY_KEYS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.primaryKeys.size()));
- for (SQLPrimaryKey _iter680 : struct.primaryKeys)
+ for (SQLPrimaryKey _iter696 : struct.primaryKeys)
{
- _iter680.write(oprot);
+ _iter696.write(oprot);
}
oprot.writeListEnd();
}
@@ -41894,9 +42196,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(FOREIGN_KEYS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.foreignKeys.size()));
- for (SQLForeignKey _iter681 : struct.foreignKeys)
+ for (SQLForeignKey _iter697 : struct.foreignKeys)
{
- _iter681.write(oprot);
+ _iter697.write(oprot);
}
oprot.writeListEnd();
}
@@ -41936,18 +42238,18 @@ public class ThriftHiveMetastore {
if (struct.isSetPrimaryKeys()) {
{
oprot.writeI32(struct.primaryKeys.size());
- for (SQLPrimaryKey _iter682 : struct.primaryKeys)
+ for (SQLPrimaryKey _iter698 : struct.primaryKeys)
{
- _iter682.write(oprot);
+ _iter698.write(oprot);
}
}
}
if (struct.isSetForeignKeys()) {
{
oprot.writeI32(struct.foreignKeys.size());
- for (SQLForeignKey _iter683 : struct.foreignKeys)
+ for (SQLForeignKey _iter699 : struct.foreignKeys)
{
- _iter683.write(oprot);
+ _iter699.write(oprot);
}
}
}
@@ -41964,28 +42266,28 @@ public class ThriftHiveMetastore {
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list684 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.primaryKeys = new ArrayList<SQLPrimaryKey>(_list684.size);
- SQLPrimaryKey _elem685;
- for (int _i686 = 0; _i686 < _list684.size; ++_i686)
+ org.apache.thrift.protocol.TList _list700 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.primaryKeys = new ArrayList<SQLPrimaryKey>(_list700.size);
+ SQLPrimaryKey _elem701;
+ for (int _i702 = 0; _i702 < _list700.size; ++_i702)
{
- _elem685 = new SQLPrimaryKey();
- _elem685.read(iprot);
- struct.primaryKeys.add(_elem685);
+ _elem701 = new SQLPrimaryKey();
+ _elem701.read(iprot);
+ struct.primaryKeys.add(_elem701);
}
}
struct.setPrimaryKeysIsSet(true);
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list687 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.foreignKeys = new ArrayList<SQLForeignKey>(_list687.size);
- SQLForeignKey _elem688;
- for (int _i689 = 0; _i689 < _list687.size; ++_i689)
+ org.apache.thrift.protocol.TList _list703 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.foreignKeys = new ArrayList<SQLForeignKey>(_list703.size);
+ SQLForeignKey _elem704;
+ for (int _i705 = 0; _i705 < _list703.size; ++_i705)
{
- _elem688 = new SQLForeignKey();
- _elem688.read(iprot);
- struct.foreignKeys.add(_elem688);
+ _elem704 = new SQLForeignKey();
+ _elem704.read(iprot);
+ struct.foreignKeys.add(_elem704);
}
}
struct.setForeignKeysIsSet(true);
@@ -42844,12 +43146,1670 @@ public class ThriftHiveMetastore {
public boolean equals(Object that) {
if (that == null)
return false;
- if (that instanceof drop_constraint_args)
- return this.equals((drop_constraint_args)that);
+ if (that instanceof drop_constraint_args)
+ return this.equals((drop_constraint_args)that);
+ return false;
+ }
+
+ public boolean equals(drop_constraint_args that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_req = true && this.isSetReq();
+ boolean that_present_req = true && that.isSetReq();
+ if (this_present_req || that_present_req) {
+ if (!(this_present_req && that_present_req))
+ return false;
+ if (!this.req.equals(that.req))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_req = true && (isSetReq());
+ list.add(present_req);
+ if (present_req)
+ list.add(req);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(drop_constraint_args other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(isSetReq()).compareTo(other.isSetReq());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetReq()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.req, other.req);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ return 0;
+ }
+
+ public _Fields fieldForId(int fieldId) {
+ return _Fields.findByThriftId(fieldId);
+ }
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder("drop_constraint_args(");
+ boolean first = true;
+
+ sb.append("req:");
+ if (this.req == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.req);
+ }
+ first = false;
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ // check for sub-struct validity
+ if (req != null) {
+ req.validate();
+ }
+ }
+
+ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
+ try {
+ write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
+ try {
+ read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private static class drop_constraint_argsStandardSchemeFactory implements SchemeFactory {
+ public drop_constraint_argsStandardScheme getScheme() {
+ return new drop_constraint_argsStandardScheme();
+ }
+ }
+
+ private static class drop_constraint_argsStandardScheme extends StandardScheme<drop_constraint_args> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, drop_constraint_args struct) throws org.apache.thrift.TException {
+ org.apache.thrift.protocol.TField schemeField;
+ iprot.readStructBegin();
+ while (true)
+ {
+ schemeField = iprot.readFieldBegin();
+ if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
+ break;
+ }
+ switch (schemeField.id) {
+ case 1: // REQ
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+ struct.req = new DropConstraintRequest();
+ struct.req.read(iprot);
+ struct.setReqIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ default:
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ iprot.readFieldEnd();
+ }
+ iprot.readStructEnd();
+ struct.validate();
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot, drop_constraint_args struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.req != null) {
+ oprot.writeFieldBegin(REQ_FIELD_DESC);
+ struct.req.write(oprot);
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class drop_constraint_argsTupleSchemeFactory implements SchemeFactory {
+ public drop_constraint_argsTupleScheme getScheme() {
+ return new drop_constraint_argsTupleScheme();
+ }
+ }
+
+ private static class drop_constraint_argsTupleScheme extends TupleScheme<drop_constraint_args> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, drop_constraint_args struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.isSetReq()) {
+ optionals.set(0);
+ }
+ oprot.writeBitSet(optionals, 1);
+ if (struct.isSetReq()) {
+ struct.req.write(oprot);
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, drop_constraint_args struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(1);
+ if (incoming.get(0)) {
+ struct.req = new DropConstraintRequest();
+ struct.req.read(iprot);
+ struct.setReqIsSet(true);
+ }
+ }
+ }
+
+ }
+
+ public static class drop_constraint_result implements org.apache.thrift.TBase<drop_constraint_result, drop_constraint_result._Fields>, java.io.Serializable, Cloneable, Comparable<drop_constraint_result> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("drop_constraint_result");
+
+ private static final org.apache.thrift.protocol.TField O1_FIELD_DESC = new org.apache.thrift.protocol.TField("o1", org.apache.thrift.protocol.TType.STRUCT, (short)1);
+ private static final org.apache.thrift.protocol.TField O3_FIELD_DESC = new org.apache.thrift.protocol.TField("o3", org.apache.thrift.protocol.TType.STRUCT, (short)2);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new drop_constraint_resultStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new drop_constraint_resultTupleSchemeFactory());
+ }
+
+ private NoSuchObjectException o1; // required
+ private MetaException o3; // required
+
+ /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
+ public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+ O1((short)1, "o1"),
+ O3((short)2, "o3");
+
+ private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+
+ static {
+ for (_Fields field : EnumSet.allOf(_Fields.class)) {
+ byName.put(field.getFieldName(), field);
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, or null if its not found.
+ */
+ public static _Fields findByThriftId(int fieldId) {
+ switch(fieldId) {
+ case 1: // O1
+ return O1;
+ case 2: // O3
+ return O3;
+ default:
+ return null;
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, throwing an exception
+ * if it is not found.
+ */
+ public static _Fields findByThriftIdOrThrow(int fieldId) {
+ _Fields fields = findByThriftId(fieldId);
+ if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+ return fields;
+ }
+
+ /**
+ * Find the _Fields constant that matches name, or null if its not found.
+ */
+ public static _Fields findByName(String name) {
+ return byName.get(name);
+ }
+
+ private final short _thriftId;
+ private final String _fieldName;
+
+ _Fields(short thriftId, String fieldName) {
+ _thriftId = thriftId;
+ _fieldName = fieldName;
+ }
+
+ public short getThriftFieldId() {
+ return _thriftId;
+ }
+
+ public String getFieldName() {
+ return _fieldName;
+ }
+ }
+
+ // isset id assignments
+ public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
+ static {
+ Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
+ tmpMap.put(_Fields.O1, new org.apache.thrift.meta_data.FieldMetaData("o1", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
+ tmpMap.put(_Fields.O3, new org.apache.thrift.meta_data.FieldMetaData("o3", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(drop_constraint_result.class, metaDataMap);
+ }
+
+ public drop_constraint_result() {
+ }
+
+ public drop_constraint_result(
+ NoSuchObjectException o1,
+ MetaException o3)
+ {
+ this();
+ this.o1 = o1;
+ this.o3 = o3;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public drop_constraint_result(drop_constraint_result other) {
+ if (other.isSetO1()) {
+ this.o1 = new NoSuchObjectException(other.o1);
+ }
+ if (other.isSetO3()) {
+ this.o3 = new MetaException(other.o3);
+ }
+ }
+
+ public drop_constraint_result deepCopy() {
+ return new drop_constraint_result(this);
+ }
+
+ @Override
+ public void clear() {
+ this.o1 = null;
+ this.o3 = null;
+ }
+
+ public NoSuchObjectException getO1() {
+ return this.o1;
+ }
+
+ public void setO1(NoSuchObjectException o1) {
+ this.o1 = o1;
+ }
+
+ public void unsetO1() {
+ this.o1 = null;
+ }
+
+ /** Returns true if field o1 is set (has been assigned a value) and false otherwise */
+ public boolean isSetO1() {
+ return this.o1 != null;
+ }
+
+ public void setO1IsSet(boolean value) {
+ if (!value) {
+ this.o1 = null;
+ }
+ }
+
+ public MetaException getO3() {
+ return this.o3;
+ }
+
+ public void setO3(MetaException o3) {
+ this.o3 = o3;
+ }
+
+ public void unsetO3() {
+ this.o3 = null;
+ }
+
+ /** Returns true if field o3 is set (has been assigned a value) and false otherwise */
+ public boolean isSetO3() {
+ return this.o3 != null;
+ }
+
+ public void setO3IsSet(boolean value) {
+ if (!value) {
+ this.o3 = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case O1:
+ if (value == null) {
+ unsetO1();
+ } else {
+ setO1((NoSuchObjectException)value);
+ }
+ break;
+
+ case O3:
+ if (value == null) {
+ unsetO3();
+ } else {
+ setO3((MetaException)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case O1:
+ return getO1();
+
+ case O3:
+ return getO3();
+
+ }
+ throw new IllegalStateException();
+ }
+
+ /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
+ public boolean isSet(_Fields field) {
+ if (field == null) {
+ throw new IllegalArgumentException();
+ }
+
+ switch (field) {
+ case O1:
+ return isSetO1();
+ case O3:
+ return isSetO3();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof drop_constraint_result)
+ return this.equals((drop_constraint_result)that);
+ return false;
+ }
+
+ public boolean equals(drop_constraint_result that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_o1 = true && this.isSetO1();
+ boolean that_present_o1 = true && that.isSetO1();
+ if (this_present_o1 || that_present_o1) {
+ if (!(this_present_o1 && that_present_o1))
+ return false;
+ if (!this.o1.equals(that.o1))
+ return false;
+ }
+
+ boolean this_present_o3 = true && this.isSetO3();
+ boolean that_present_o3 = true && that.isSetO3();
+ if (this_present_o3 || that_present_o3) {
+ if (!(this_present_o3 && that_present_o3))
+ return false;
+ if (!this.o3.equals(that.o3))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_o1 = true && (isSetO1());
+ list.add(present_o1);
+ if (present_o1)
+ list.add(o1);
+
+ boolean present_o3 = true && (isSetO3());
+ list.add(present_o3);
+ if (present_o3)
+ list.add(o3);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(drop_constraint_result other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(isSetO1()).compareTo(other.isSetO1());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetO1()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.o1, other.o1);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetO3()).compareTo(other.isSetO3());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetO3()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.o3, other.o3);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ return 0;
+ }
+
+ public _Fields fieldForId(int fieldId) {
+ return _Fields.findByThriftId(fieldId);
+ }
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder("drop_constraint_result(");
+ boolean first = true;
+
+ sb.append("o1:");
+ if (this.o1 == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.o1);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("o3:");
+ if (this.o3 == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.o3);
+ }
+ first = false;
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ // check for sub-struct validity
+ }
+
+ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
+ try {
+ write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
+ try {
+ read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private static class drop_constraint_resultStandardSchemeFactory implements SchemeFactory {
+ public drop_constraint_resultStandardScheme getScheme() {
+ return new drop_constraint_resultStandardScheme();
+ }
+ }
+
+ private static class drop_constraint_resultStandardScheme extends StandardScheme<drop_constraint_result> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, drop_constraint_result struct) throws org.apache.thrift.TException {
+ org.apache.thrift.protocol.TField schemeField;
+ iprot.readStructBegin();
+ while (true)
+ {
+ schemeField = iprot.readFieldBegin();
+ if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
+ break;
+ }
+ switch (schemeField.id) {
+ case 1: // O1
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+ struct.o1 = new NoSuchObjectException();
+ struct.o1.read(iprot);
+ struct.setO1IsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // O3
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+ struct.o3 = new MetaException();
+ struct.o3.read(iprot);
+ struct.setO3IsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ default:
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ iprot.readFieldEnd();
+ }
+ iprot.readStructEnd();
+ struct.validate();
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot, drop_constraint_result struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.o1 != null) {
+ oprot.writeFieldBegin(O1_FIELD_DESC);
+ struct.o1.write(oprot);
+ oprot.writeFieldEnd();
+ }
+ if (struct.o3 != null) {
+ oprot.writeFieldBegin(O3_FIELD_DESC);
+ struct.o3.write(oprot);
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class drop_constraint_resultTupleSchemeFactory implements SchemeFactory {
+ public drop_constraint_resultTupleScheme getScheme() {
+ return new drop_constraint_resultTupleScheme();
+ }
+ }
+
+ private static class drop_constraint_resultTupleScheme extends TupleScheme<drop_constraint_result> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, drop_constraint_result struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.isSetO1()) {
+ optionals.set(0);
+ }
+ if (struct.isSetO3()) {
+ optionals.set(1);
+ }
+ oprot.writeBitSet(optionals, 2);
+ if (struct.isSetO1()) {
+ struct.o1.write(oprot);
+ }
+ if (struct.isSetO3()) {
+ struct.o3.write(oprot);
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, drop_constraint_result struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(2);
+ if (incoming.get(0)) {
+ struct.o1 = new NoSuchObjectException();
+ struct.o1.read(iprot);
+ struct.setO1IsSet(true);
+ }
+ if (incoming.get(1)) {
+ struct.o3 = new MetaException();
+ struct.o3.read(iprot);
+ struct.setO3IsSet(true);
+ }
+ }
+ }
+
+ }
+
+ public static class add_primary_key_args implements org.apache.thrift.TBase<add_primary_key_args, add_primary_key_args._Fields>, java.io.Serializable, Cloneable, Comparable<add_primary_key_args> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("add_primary_key_args");
+
+ private static final org.apache.thrift.protocol.TField REQ_FIELD_DESC = new org.apache.thrift.protocol.TField("req", org.apache.thrift.protocol.TType.STRUCT, (short)1);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new add_primary_key_argsStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new add_primary_key_argsTupleSchemeFactory());
+ }
+
+ private AddPrimaryKeyRequest req; // required
+
+ /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
+ public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+ REQ((short)1, "req");
+
+ private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+
+ static {
+ for (_Fields field : EnumSet.allOf(_Fields.class)) {
+ byName.put(field.getFieldName(), field);
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, or null if its not found.
+ */
+ public static _Fields findByThriftId(int fieldId) {
+ switch(fieldId) {
+ case 1: // REQ
+ return REQ;
+ default:
+ return null;
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, throwing an exception
+ * if it is not found.
+ */
+ public static _Fields findByThriftIdOrThrow(int fieldId) {
+ _Fields fields = findByThriftId(fieldId);
+ if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+ return fields;
+ }
+
+ /**
+ * Find the _Fields constant that matches name, or null if its not found.
+ */
+ public static _Fields findByName(String name) {
+ return byName.get(name);
+ }
+
+ private final short _thriftId;
+ private final String _fieldName;
+
+ _Fields(short thriftId, String fieldName) {
+ _thriftId = thriftId;
+ _fieldName = fieldName;
+ }
+
+ public short getThriftFieldId() {
+ return _thriftId;
+ }
+
+ public String getFieldName() {
+ return _fieldName;
+ }
+ }
+
+ // isset id assignments
+ public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
+ static {
+ Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
+ tmpMap.put(_Fields.REQ, new org.apache.thrift.meta_data.FieldMetaData("req", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, AddPrimaryKeyRequest.class)));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(add_primary_key_args.class, metaDataMap);
+ }
+
+ public add_primary_key_args() {
+ }
+
+ public add_primary_key_args(
+ AddPrimaryKeyRequest req)
+ {
+ this();
+ this.req = req;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public add_primary_key_args(add_primary_key_args other) {
+ if (other.isSetReq()) {
+ this.req = new AddPrimaryKeyRequest(other.req);
+ }
+ }
+
+ public add_primary_key_args deepCopy() {
+ return new add_primary_key_args(this);
+ }
+
+ @Override
+ public void clear() {
+ this.req = null;
+ }
+
+ public AddPrimaryKeyRequest getReq() {
+ return this.req;
+ }
+
+ public void setReq(AddPrimaryKeyRequest req) {
+ this.req = req;
+ }
+
+ public void unsetReq() {
+ this.req = null;
+ }
+
+ /** Returns true if field req is set (has been assigned a value) and false otherwise */
+ public boolean isSetReq() {
+ return this.req != null;
+ }
+
+ public void setReqIsSet(boolean value) {
+ if (!value) {
+ this.req = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case REQ:
+ if (value == null) {
+ unsetReq();
+ } else {
+ setReq((AddPrimaryKeyRequest)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case REQ:
+ return getReq();
+
+ }
+ throw
<TRUNCATED>