http://git-wip-us.apache.org/repos/asf/hive/blob/212077b8/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 051c1f2..2a81c4b 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 @@ -80,6 +80,8 @@ public class ThriftHiveMetastore { public void create_table_with_constraints(Table tbl, List<SQLPrimaryKey> primaryKeys, List<SQLForeignKey> foreignKeys) throws AlreadyExistsException, InvalidObjectException, MetaException, NoSuchObjectException, org.apache.thrift.TException; + public void drop_constraint(DropConstraintRequest 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; @@ -376,6 +378,8 @@ public class ThriftHiveMetastore { public void create_table_with_constraints(Table tbl, List<SQLPrimaryKey> primaryKeys, List<SQLForeignKey> foreignKeys, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void drop_constraint(DropConstraintRequest 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; @@ -1218,6 +1222,32 @@ public class ThriftHiveMetastore { return; } + public void drop_constraint(DropConstraintRequest req) throws NoSuchObjectException, MetaException, org.apache.thrift.TException + { + send_drop_constraint(req); + recv_drop_constraint(); + } + + public void send_drop_constraint(DropConstraintRequest req) throws org.apache.thrift.TException + { + drop_constraint_args args = new drop_constraint_args(); + args.setReq(req); + sendBase("drop_constraint", args); + } + + public void recv_drop_constraint() throws NoSuchObjectException, MetaException, org.apache.thrift.TException + { + drop_constraint_result result = new drop_constraint_result(); + receiveBase(result, "drop_constraint"); + if (result.o1 != null) { + throw result.o1; + } + if (result.o3 != null) { + throw result.o3; + } + return; + } + public void drop_table(String dbname, String name, boolean deleteData) throws NoSuchObjectException, MetaException, org.apache.thrift.TException { send_drop_table(dbname, name, deleteData); @@ -5535,6 +5565,38 @@ public class ThriftHiveMetastore { } } + public void drop_constraint(DropConstraintRequest req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + drop_constraint_call method_call = new drop_constraint_call(req, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class drop_constraint_call extends org.apache.thrift.async.TAsyncMethodCall { + private DropConstraintRequest req; + public drop_constraint_call(DropConstraintRequest 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("drop_constraint", org.apache.thrift.protocol.TMessageType.CALL, 0)); + drop_constraint_args args = new drop_constraint_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_drop_constraint(); + } + } + 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); @@ -10078,6 +10140,7 @@ public class ThriftHiveMetastore { processMap.put("create_table", new create_table()); 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("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()); @@ -10720,6 +10783,32 @@ public class ThriftHiveMetastore { } } + public static class drop_constraint<I extends Iface> extends org.apache.thrift.ProcessFunction<I, drop_constraint_args> { + public drop_constraint() { + super("drop_constraint"); + } + + public drop_constraint_args getEmptyArgsInstance() { + return new drop_constraint_args(); + } + + protected boolean isOneway() { + return false; + } + + public drop_constraint_result getResult(I iface, drop_constraint_args args) throws org.apache.thrift.TException { + drop_constraint_result result = new drop_constraint_result(); + try { + iface.drop_constraint(args.req); + } catch (NoSuchObjectException o1) { + result.o1 = o1; + } catch (MetaException o3) { + result.o3 = o3; + } + 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"); @@ -13964,6 +14053,7 @@ public class ThriftHiveMetastore { processMap.put("create_table", new create_table()); 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("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()); @@ -15307,20 +15397,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 drop_constraint<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, drop_constraint_args, Void> { + public drop_constraint() { + super("drop_constraint"); } - public drop_table_args getEmptyArgsInstance() { - return new drop_table_args(); + public drop_constraint_args getEmptyArgsInstance() { + return new drop_constraint_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(); + drop_constraint_result result = new drop_constraint_result(); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -15332,7 +15422,7 @@ 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(); + drop_constraint_result result = new drop_constraint_result(); if (e instanceof NoSuchObjectException) { result.o1 = (NoSuchObjectException) e; result.setO1IsSet(true); @@ -15363,25 +15453,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, drop_constraint_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.drop_constraint(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 drop_table<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, drop_table_args, Void> { + public drop_table() { + super("drop_table"); } - public drop_table_with_environment_context_args getEmptyArgsInstance() { - return new drop_table_with_environment_context_args(); + public drop_table_args getEmptyArgsInstance() { + return new drop_table_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(); + drop_table_result result = new drop_table_result(); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -15393,7 +15483,7 @@ 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(); + drop_table_result result = new drop_table_result(); if (e instanceof NoSuchObjectException) { result.o1 = (NoSuchObjectException) e; result.setO1IsSet(true); @@ -15424,259 +15514,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 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_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_tables_result result = new get_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_tables_result result = new get_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_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_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_meta_args getEmptyArgsInstance() { - return new get_table_meta_args(); - } - - public AsyncMethodCallback<List<TableMeta>> 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; - 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_meta_result result = new get_table_meta_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_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; - 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_args args, org.apache.thrift.async.AsyncMethodCallback<Table> resultHandler) throws TException { - iface.get_table(args.dbname, args.tbl_name,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_objects_by_name<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_table_objects_by_name_args, List<Table>> { - public get_table_objects_by_name() { - super("get_table_objects_by_name"); + 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_objects_by_name_args getEmptyArgsInstance() { - return new get_table_objects_by_name_args(); + public drop_table_with_environment_context_args getEmptyArgsInstance() { + return new drop_table_with_environment_context_args(); } - public AsyncMethodCallback<List<Table>> 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<Table>>() { - public void onComplete(List<Table> o) { - get_table_objects_by_name_result result = new get_table_objects_by_name_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; @@ -15688,19 +15544,14 @@ public class ThriftHiveMetastore { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - get_table_objects_by_name_result result = new get_table_objects_by_name_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 InvalidOperationException) { - result.o2 = (InvalidOperationException) e; - result.setO2IsSet(true); - msg = result; - } - else if (e instanceof UnknownDBException) { - result.o3 = (UnknownDBException) e; + else if (e instanceof MetaException) { + result.o3 = (MetaException) e; result.setO3IsSet(true); msg = result; } @@ -15724,25 +15575,25 @@ public class ThriftHiveMetastore { return false; } - public void start(I iface, get_table_objects_by_name_args args, org.apache.thrift.async.AsyncMethodCallback<List<Table>> resultHandler) throws TException { - iface.get_table_objects_by_name(args.dbname, args.tbl_names,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_table_names_by_filter<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_table_names_by_filter_args, List<String>> { - public get_table_names_by_filter() { - super("get_table_names_by_filter"); + 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_table_names_by_filter_args getEmptyArgsInstance() { - return new get_table_names_by_filter_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_table_names_by_filter_result result = new get_table_names_by_filter_result(); + get_tables_result result = new get_tables_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -15755,22 +15606,12 @@ public class ThriftHiveMetastore { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - get_table_names_by_filter_result result = new get_table_names_by_filter_result(); + get_tables_result result = new get_tables_result(); if (e instanceof MetaException) { result.o1 = (MetaException) e; result.setO1IsSet(true); msg = result; } - else if (e instanceof InvalidOperationException) { - result.o2 = (InvalidOperationException) e; - result.setO2IsSet(true); - msg = result; - } - else if (e instanceof UnknownDBException) { - result.o3 = (UnknownDBException) e; - result.setO3IsSet(true); - msg = result; - } else { msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; @@ -15791,25 +15632,26 @@ public class ThriftHiveMetastore { return false; } - public void start(I iface, get_table_names_by_filter_args args, org.apache.thrift.async.AsyncMethodCallback<List<String>> resultHandler) throws TException { - iface.get_table_names_by_filter(args.dbname, args.filter, args.max_tables,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 alter_table<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, alter_table_args, Void> { - public alter_table() { - super("alter_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 alter_table_args getEmptyArgsInstance() { - return new alter_table_args(); + public get_table_meta_args getEmptyArgsInstance() { + return new get_table_meta_args(); } - public AsyncMethodCallback<Void> 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<Void>() { - public void onComplete(Void o) { - alter_table_result result = new alter_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); return; @@ -15821,17 +15663,12 @@ public class ThriftHiveMetastore { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - alter_table_result result = new alter_table_result(); - if (e instanceof InvalidOperationException) { - result.o1 = (InvalidOperationException) e; + 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 MetaException) { - result.o2 = (MetaException) e; - result.setO2IsSet(true); - msg = result; - } else { msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; @@ -15852,25 +15689,26 @@ public class ThriftHiveMetastore { return false; } - public void start(I iface, alter_table_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { - iface.alter_table(args.dbname, args.tbl_name, args.new_tbl,resultHandler); + 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 alter_table_with_environment_context<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, alter_table_with_environment_context_args, Void> { - public alter_table_with_environment_context() { - super("alter_table_with_environment_context"); + 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 alter_table_with_environment_context_args getEmptyArgsInstance() { - return new alter_table_with_environment_context_args(); + public get_all_tables_args getEmptyArgsInstance() { + return new get_all_tables_args(); } - public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Void>() { - public void onComplete(Void o) { - alter_table_with_environment_context_result result = new alter_table_with_environment_context_result(); + 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; @@ -15882,17 +15720,12 @@ public class ThriftHiveMetastore { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - alter_table_with_environment_context_result result = new alter_table_with_environment_context_result(); - if (e instanceof InvalidOperationException) { - result.o1 = (InvalidOperationException) e; + get_all_tables_result result = new get_all_tables_result(); + if (e instanceof MetaException) { + result.o1 = (MetaException) e; result.setO1IsSet(true); msg = result; } - else if (e instanceof MetaException) { - result.o2 = (MetaException) e; - result.setO2IsSet(true); - msg = result; - } else { msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; @@ -15913,25 +15746,26 @@ public class ThriftHiveMetastore { return false; } - public void start(I iface, alter_table_with_environment_context_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { - iface.alter_table_with_environment_context(args.dbname, args.tbl_name, args.new_tbl, args.environment_context,resultHandler); + 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 alter_table_with_cascade<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, alter_table_with_cascade_args, Void> { - public alter_table_with_cascade() { - super("alter_table_with_cascade"); + 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 alter_table_with_cascade_args getEmptyArgsInstance() { - return new alter_table_with_cascade_args(); + public get_table_args getEmptyArgsInstance() { + return new get_table_args(); } - public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<Table> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Void>() { - public void onComplete(Void o) { - alter_table_with_cascade_result result = new alter_table_with_cascade_result(); + 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; @@ -15943,14 +15777,14 @@ public class ThriftHiveMetastore { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - alter_table_with_cascade_result result = new alter_table_with_cascade_result(); - if (e instanceof InvalidOperationException) { - result.o1 = (InvalidOperationException) e; + 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 MetaException) { - result.o2 = (MetaException) e; + else if (e instanceof NoSuchObjectException) { + result.o2 = (NoSuchObjectException) e; result.setO2IsSet(true); msg = result; } @@ -15974,25 +15808,25 @@ public class ThriftHiveMetastore { return false; } - public void start(I iface, alter_table_with_cascade_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { - iface.alter_table_with_cascade(args.dbname, args.tbl_name, args.new_tbl, args.cascade,resultHandler); + public void start(I iface, get_table_args args, org.apache.thrift.async.AsyncMethodCallback<Table> resultHandler) throws TException { + iface.get_table(args.dbname, args.tbl_name,resultHandler); } } - public static class add_partition<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, add_partition_args, Partition> { - public add_partition() { - super("add_partition"); + public static class get_table_objects_by_name<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_table_objects_by_name_args, List<Table>> { + public get_table_objects_by_name() { + super("get_table_objects_by_name"); } - public add_partition_args getEmptyArgsInstance() { - return new add_partition_args(); + public get_table_objects_by_name_args getEmptyArgsInstance() { + return new get_table_objects_by_name_args(); } - public AsyncMethodCallback<Partition> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<Table>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Partition>() { - public void onComplete(Partition o) { - add_partition_result result = new add_partition_result(); + return new AsyncMethodCallback<List<Table>>() { + public void onComplete(List<Table> o) { + get_table_objects_by_name_result result = new get_table_objects_by_name_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -16005,19 +15839,19 @@ public class ThriftHiveMetastore { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - add_partition_result result = new add_partition_result(); - if (e instanceof InvalidObjectException) { - result.o1 = (InvalidObjectException) e; + get_table_objects_by_name_result result = new get_table_objects_by_name_result(); + if (e instanceof MetaException) { + result.o1 = (MetaException) e; result.setO1IsSet(true); msg = result; } - else if (e instanceof AlreadyExistsException) { - result.o2 = (AlreadyExistsException) e; + else if (e instanceof InvalidOperationException) { + result.o2 = (InvalidOperationException) e; result.setO2IsSet(true); msg = result; } - else if (e instanceof MetaException) { - result.o3 = (MetaException) e; + else if (e instanceof UnknownDBException) { + result.o3 = (UnknownDBException) e; result.setO3IsSet(true); msg = result; } @@ -16041,25 +15875,25 @@ public class ThriftHiveMetastore { return false; } - public void start(I iface, add_partition_args args, org.apache.thrift.async.AsyncMethodCallback<Partition> resultHandler) throws TException { - iface.add_partition(args.new_part,resultHandler); + public void start(I iface, get_table_objects_by_name_args args, org.apache.thrift.async.AsyncMethodCallback<List<Table>> resultHandler) throws TException { + iface.get_table_objects_by_name(args.dbname, args.tbl_names,resultHandler); } } - public static class add_partition_with_environment_context<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, add_partition_with_environment_context_args, Partition> { - public add_partition_with_environment_context() { - super("add_partition_with_environment_context"); + public static class get_table_names_by_filter<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_table_names_by_filter_args, List<String>> { + public get_table_names_by_filter() { + super("get_table_names_by_filter"); } - public add_partition_with_environment_context_args getEmptyArgsInstance() { - return new add_partition_with_environment_context_args(); + public get_table_names_by_filter_args getEmptyArgsInstance() { + return new get_table_names_by_filter_args(); } - public AsyncMethodCallback<Partition> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Partition>() { - public void onComplete(Partition o) { - add_partition_with_environment_context_result result = new add_partition_with_environment_context_result(); + return new AsyncMethodCallback<List<String>>() { + public void onComplete(List<String> o) { + get_table_names_by_filter_result result = new get_table_names_by_filter_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -16072,19 +15906,19 @@ public class ThriftHiveMetastore { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - add_partition_with_environment_context_result result = new add_partition_with_environment_context_result(); - if (e instanceof InvalidObjectException) { - result.o1 = (InvalidObjectException) e; + get_table_names_by_filter_result result = new get_table_names_by_filter_result(); + if (e instanceof MetaException) { + result.o1 = (MetaException) e; result.setO1IsSet(true); msg = result; } - else if (e instanceof AlreadyExistsException) { - result.o2 = (AlreadyExistsException) e; + else if (e instanceof InvalidOperationException) { + result.o2 = (InvalidOperationException) e; result.setO2IsSet(true); msg = result; } - else if (e instanceof MetaException) { - result.o3 = (MetaException) e; + else if (e instanceof UnknownDBException) { + result.o3 = (UnknownDBException) e; result.setO3IsSet(true); msg = result; } @@ -16108,27 +15942,25 @@ public class ThriftHiveMetastore { return false; } - public void start(I iface, add_partition_with_environment_context_args args, org.apache.thrift.async.AsyncMethodCallback<Partition> resultHandler) throws TException { - iface.add_partition_with_environment_context(args.new_part, args.environment_context,resultHandler); + public void start(I iface, get_table_names_by_filter_args args, org.apache.thrift.async.AsyncMethodCallback<List<String>> resultHandler) throws TException { + iface.get_table_names_by_filter(args.dbname, args.filter, args.max_tables,resultHandler); } } - public static class add_partitions<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, add_partitions_args, Integer> { - public add_partitions() { - super("add_partitions"); + public static class alter_table<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, alter_table_args, Void> { + public alter_table() { + super("alter_table"); } - public add_partitions_args getEmptyArgsInstance() { - return new add_partitions_args(); + public alter_table_args getEmptyArgsInstance() { + return new alter_table_args(); } - public AsyncMethodCallback<Integer> 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<Integer>() { - public void onComplete(Integer o) { - add_partitions_result result = new add_partitions_result(); - result.success = o; - result.setSuccessIsSet(true); + return new AsyncMethodCallback<Void>() { + public void onComplete(Void o) { + alter_table_result result = new alter_table_result(); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -16140,20 +15972,15 @@ public class ThriftHiveMetastore { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - add_partitions_result result = new add_partitions_result(); - if (e instanceof InvalidObjectException) { - result.o1 = (InvalidObjectException) e; + alter_table_result result = new alter_table_result(); + if (e instanceof InvalidOperationException) { + result.o1 = (InvalidOperationException) e; result.setO1IsSet(true); msg = result; } - else if (e instanceof AlreadyExistsException) { - result.o2 = (AlreadyExistsException) e; - result.setO2IsSet(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 @@ -16176,27 +16003,25 @@ public class ThriftHiveMetastore { return false; } - public void start(I iface, add_partitions_args args, org.apache.thrift.async.AsyncMethodCallback<Integer> resultHandler) throws TException { - iface.add_partitions(args.new_parts,resultHandler); + public void start(I iface, alter_table_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.alter_table(args.dbname, args.tbl_name, args.new_tbl,resultHandler); } } - public static class add_partitions_pspec<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, add_partitions_pspec_args, Integer> { - public add_partitions_pspec() { - super("add_partitions_pspec"); + public static class alter_table_with_environment_context<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, alter_table_with_environment_context_args, Void> { + public alter_table_with_environment_context() { + super("alter_table_with_environment_context"); } - public add_partitions_pspec_args getEmptyArgsInstance() { - return new add_partitions_pspec_args(); + public alter_table_with_environment_context_args getEmptyArgsInstance() { + return new alter_table_with_environment_context_args(); } - public AsyncMethodCallback<Integer> 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<Integer>() { - public void onComplete(Integer o) { - add_partitions_pspec_result result = new add_partitions_pspec_result(); - result.success = o; - result.setSuccessIsSet(true); + return new AsyncMethodCallback<Void>() { + public void onComplete(Void o) { + alter_table_with_environment_context_result result = new alter_table_with_environment_context_result(); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -16208,20 +16033,15 @@ public class ThriftHiveMetastore { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - add_partitions_pspec_result result = new add_partitions_pspec_result(); - if (e instanceof InvalidObjectException) { - result.o1 = (InvalidObjectException) e; + alter_table_with_environment_context_result result = new alter_table_with_environment_context_result(); + if (e instanceof InvalidOperationException) { + result.o1 = (InvalidOperationException) e; result.setO1IsSet(true); msg = result; } - else if (e instanceof AlreadyExistsException) { - result.o2 = (AlreadyExistsException) e; - result.setO2IsSet(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 @@ -16244,26 +16064,25 @@ public class ThriftHiveMetastore { return false; } - public void start(I iface, add_partitions_pspec_args args, org.apache.thrift.async.AsyncMethodCallback<Integer> resultHandler) throws TException { - iface.add_partitions_pspec(args.new_parts,resultHandler); + public void start(I iface, alter_table_with_environment_context_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.alter_table_with_environment_context(args.dbname, args.tbl_name, args.new_tbl, args.environment_context,resultHandler); } } - public static class append_partition<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, append_partition_args, Partition> { - public append_partition() { - super("append_partition"); + public static class alter_table_with_cascade<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, alter_table_with_cascade_args, Void> { + public alter_table_with_cascade() { + super("alter_table_with_cascade"); } - public append_partition_args getEmptyArgsInstance() { - return new append_partition_args(); + public alter_table_with_cascade_args getEmptyArgsInstance() { + return new alter_table_with_cascade_args(); } - public AsyncMethodCallback<Partition> 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<Partition>() { - public void onComplete(Partition o) { - append_partition_result result = new append_partition_result(); - result.success = o; + return new AsyncMethodCallback<Void>() { + public void onComplete(Void o) { + alter_table_with_cascade_result result = new alter_table_with_cascade_result(); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -16275,20 +16094,15 @@ public class ThriftHiveMetastore { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - append_partition_result result = new append_partition_result(); - if (e instanceof InvalidObjectException) { - result.o1 = (InvalidObjectException) e; + alter_table_with_cascade_result result = new alter_table_with_cascade_result(); + if (e instanceof InvalidOperationException) { + result.o1 = (InvalidOperationException) e; result.setO1IsSet(true); msg = result; } - else if (e instanceof AlreadyExistsException) { - result.o2 = (AlreadyExistsException) e; - result.setO2IsSet(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 @@ -16311,25 +16125,25 @@ public class ThriftHiveMetastore { return false; } - public void start(I iface, append_partition_args args, org.apache.thrift.async.AsyncMethodCallback<Partition> resultHandler) throws TException { - iface.append_partition(args.db_name, args.tbl_name, args.part_vals,resultHandler); + public void start(I iface, alter_table_with_cascade_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.alter_table_with_cascade(args.dbname, args.tbl_name, args.new_tbl, args.cascade,resultHandler); } } - public static class add_partitions_req<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, add_partitions_req_args, AddPartitionsResult> { - public add_partitions_req() { - super("add_partitions_req"); + public static class add_partition<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, add_partition_args, Partition> { + public add_partition() { + super("add_partition"); } - public add_partitions_req_args getEmptyArgsInstance() { - return new add_partitions_req_args(); + public add_partition_args getEmptyArgsInstance() { + return new add_partition_args(); } - public AsyncMethodCallback<AddPartitionsResult> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<Partition> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<AddPartitionsResult>() { - public void onComplete(AddPartitionsResult o) { - add_partitions_req_result result = new add_partitions_req_result(); + return new AsyncMethodCallback<Partition>() { + public void onComplete(Partition o) { + add_partition_result result = new add_partition_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -16342,7 +16156,7 @@ public class ThriftHiveMetastore { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - add_partitions_req_result result = new add_partitions_req_result(); + add_partition_result result = new add_partition_result(); if (e instanceof InvalidObjectException) { result.o1 = (InvalidObjectException) e; result.setO1IsSet(true); @@ -16378,25 +16192,25 @@ public class ThriftHiveMetastore { return false; } - public void start(I iface, add_partitions_req_args args, org.apache.thrift.async.AsyncMethodCallback<AddPartitionsResult> resultHandler) throws TException { - iface.add_partitions_req(args.request,resultHandler); + public void start(I iface, add_partition_args args, org.apache.thrift.async.AsyncMethodCallback<Partition> resultHandler) throws TException { + iface.add_partition(args.new_part,resultHandler); } } - public static class append_partition_with_environment_context<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, append_partition_with_environment_context_args, Partition> { - public append_partition_with_environment_context() { - super("append_partition_with_environment_context"); + public static class add_partition_with_environment_context<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, add_partition_with_environment_context_args, Partition> { + public add_partition_with_environment_context() { + super("add_partition_with_environment_context"); } - public append_partition_with_environment_context_args getEmptyArgsInstance() { - return new append_partition_with_environment_context_args(); + public add_partition_with_environment_context_args getEmptyArgsInstance() { + return new add_partition_with_environment_context_args(); } public AsyncMethodCallback<Partition> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; return new AsyncMethodCallback<Partition>() { public void onComplete(Partition o) { - append_partition_with_environment_context_result result = new append_partition_with_environment_context_result(); + add_partition_with_environment_context_result result = new add_partition_with_environment_context_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -16409,7 +16223,7 @@ public class ThriftHiveMetastore { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - append_partition_with_environment_context_result result = new append_partition_with_environment_context_result(); + add_partition_with_environment_context_result result = new add_partition_with_environment_context_result(); if (e instanceof InvalidObjectException) { result.o1 = (InvalidObjectException) e; result.setO1IsSet(true); @@ -16445,26 +16259,27 @@ public class ThriftHiveMetastore { return false; } - public void start(I iface, append_partition_with_environment_context_args args, org.apache.thrift.async.AsyncMethodCallback<Partition> resultHandler) throws TException { - iface.append_partition_with_environment_context(args.db_name, args.tbl_name, args.part_vals, args.environment_context,resultHandler); + public void start(I iface, add_partition_with_environment_context_args args, org.apache.thrift.async.AsyncMethodCallback<Partition> resultHandler) throws TException { + iface.add_partition_with_environment_context(args.new_part, args.environment_context,resultHandler); } } - public static class append_partition_by_name<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, append_partition_by_name_args, Partition> { - public append_partition_by_name() { - super("append_partition_by_name"); + public static class add_partitions<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, add_partitions_args, Integer> { + public add_partitions() { + super("add_partitions"); } - public append_partition_by_name_args getEmptyArgsInstance() { - return new append_partition_by_name_args(); + public add_partitions_args getEmptyArgsInstance() { + return new add_partitions_args(); } - public AsyncMethodCallback<Partition> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<Integer> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Partition>() { - public void onComplete(Partition o) { - append_partition_by_name_result result = new append_partition_by_name_result(); + return new AsyncMethodCallback<Integer>() { + public void onComplete(Integer o) { + add_partitions_result result = new add_partitions_result(); result.success = o; + result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -16476,7 +16291,7 @@ public class ThriftHiveMetastore { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - append_partition_by_name_result result = new append_partition_by_name_result(); + add_partitions_result result = new add_partitions_result(); if (e instanceof InvalidObjectException) { result.o1 = (InvalidObjectException) e; result.setO1IsSet(true); @@ -16512,26 +16327,27 @@ public class ThriftHiveMetastore { return false; } - public void start(I iface, append_partition_by_name_args args, org.apache.thrift.async.AsyncMethodCallback<Partition> resultHandler) throws TException { - iface.append_partition_by_name(args.db_name, args.tbl_name, args.part_name,resultHandler); + public void start(I iface, add_partitions_args args, org.apache.thrift.async.AsyncMethodCallback<Integer> resultHandler) throws TException { + iface.add_partitions(args.new_parts,resultHandler); } } - public static class append_partition_by_name_with_environment_context<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, append_partition_by_name_with_environment_context_args, Partition> { - public append_partition_by_name_with_environment_context() { - super("append_partition_by_name_with_environment_context"); + public static class add_partitions_pspec<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, add_partitions_pspec_args, Integer> { + public add_partitions_pspec() { + super("add_partitions_pspec"); } - public append_partition_by_name_with_environment_context_args getEmptyArgsInstance() { - return new append_partition_by_name_with_environment_context_args(); + public add_partitions_pspec_args getEmptyArgsInstance() { + return new add_partitions_pspec_args(); } - public AsyncMethodCallback<Partition> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<Integer> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Partition>() { - public void onComplete(Partition o) { - append_partition_by_name_with_environment_context_result result = new append_partition_by_name_with_environment_context_result(); + return new AsyncMethodCallback<Integer>() { + public void onComplete(Integer o) { + add_partitions_pspec_result result = new add_partitions_pspec_result(); result.success = o; + result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -16543,7 +16359,342 @@ public class ThriftHiveMetastore { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - append_partition_by_name_with_environment_context_result result = new append_partition_by_name_with_environment_context_result(); + add_partitions_pspec_result result = new add_partitions_pspec_result(); + if (e instanceof InvalidObjectException) { + result.o1 = (InvalidObjectException) e; + result.setO1IsSet(true); + msg = result; + } + else if (e instanceof AlreadyExistsException) { + result.o2 = (AlreadyExistsException) e; + result.setO2IsSet(true); + msg = result; + } + else if (e instanceof MetaException) { + result.o3 = (MetaException) e; + result.setO3IsSet(true); + msg = result; + } + else + { + msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; + msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); + } + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); + } + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, add_partitions_pspec_args args, org.apache.thrift.async.AsyncMethodCallback<Integer> resultHandler) throws TException { + iface.add_partitions_pspec(args.new_parts,resultHandler); + } + } + + public static class append_partition<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, append_partition_args, Partition> { + public append_partition() { + super("append_partition"); + } + + public append_partition_args getEmptyArgsInstance() { + return new append_partition_args(); + } + + public AsyncMethodCallback<Partition> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Partition>() { + public void onComplete(Partition o) { + append_partition_result result = new append_partition_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; + append_partition_result result = new append_partition_result(); + if (e instanceof InvalidObjectException) { + result.o1 = (InvalidObjectException) e; + result.setO1IsSet(true); + msg = result; + } + else if (e instanceof AlreadyExistsException) { + result.o2 = (AlreadyExistsException) e; + result.setO2IsSet(true); + msg = result; + } + else if (e instanceof MetaException) { + result.o3 = (MetaException) e; + result.setO3IsSet(true); + msg = result; + } + else + { + msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; + msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); + } + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); + } + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, append_partition_args args, org.apache.thrift.async.AsyncMethodCallback<Partition> resultHandler) throws TException { + iface.append_partition(args.db_name, args.tbl_name, args.part_vals,resultHandler); + } + } + + public static class add_partitions_req<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, add_partitions_req_args, AddPartitionsResult> { + public add_partitions_req() { + super("add_partitions_req"); + } + + public add_partitions_req_args getEmptyArgsInstance() { + return new add_partitions_req_args(); + } + + public AsyncMethodCallback<AddPartitionsResult> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<AddPartitionsResult>() { + public void onComplete(AddPartitionsResult o) { + add_partitions_req_result result = new add_partitions_req_result(); + result.success = o; + try { + fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); + return; + } catch (Exception e) { + LOGGER.error("Exception writing to internal frame buffer", e); + } + fb.close(); + } + public void onError(Exception e) { + byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; + org.apache.thrift.TBase msg; + add_partitions_req_result result = new add_partitions_req_result(); + if (e instanceof InvalidObjectException) { + result.o1 = (InvalidObjectException) e; + result.setO1IsSet(true); + msg = result; + } + else if (e instanceof AlreadyExistsException) { + result.o2 = (AlreadyExistsException) e; + result.setO2IsSet(true); + msg = result; + } + else if (e instanceof MetaException) { + result.o3 = (MetaException) e; + result.setO3IsSet(true); + msg = result; + } + else + { + msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; + msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); + } + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); + } + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, add_partitions_req_args args, org.apache.thrift.async.AsyncMethodCallback<AddPartitionsResult> resultHandler) throws TException { + iface.add_partitions_req(args.request,resultHandler); + } + } + + public static class append_partition_with_environment_context<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, append_partition_with_environment_context_args, Partition> { + public append_partition_with_environment_context() { + super("append_partition_with_environment_context"); + } + + public append_partition_with_environment_context_args getEmptyArgsInstance() { + return new append_partition_with_environment_context_args(); + } + + public AsyncMethodCallback<Partition> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Partition>() { + public void onComplete(Partition o) { + append_partition_with_environment_context_result result = new append_partition_with_environment_context_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; + append_partition_with_environment_context_result result = new append_partition_with_environment_context_result(); + if (e instanceof InvalidObjectException) { + result.o1 = (InvalidObjectException) e; + result.setO1IsSet(true); + msg = result; + } + else if (e instanceof AlreadyExistsException) { + result.o2 = (AlreadyExistsException) e; + result.setO2IsSet(true); + msg = result; + } + else if (e instanceof MetaException) { + result.o3 = (MetaException) e; + result.setO3IsSet(true); + msg = result; + } + else + { + msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; + msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); + } + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); + } + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, append_partition_with_environment_context_args args, org.apache.thrift.async.AsyncMethodCallback<Partition> resultHandler) throws TException { + iface.append_partition_with_environment_context(args.db_name, args.tbl_name, args.part_vals, args.environment_context,resultHandler); + } + } + + public static class append_partition_by_name<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, append_partition_by_name_args, Partition> { + public append_partition_by_name() { + super("append_partition_by_name"); + } + + public append_partition_by_name_args getEmptyArgsInstance() { + return new append_partition_by_name_args(); + } + + public AsyncMethodCallback<Partition> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Partition>() { + public void onComplete(Partition o) { + append_partition_by_name_result result = new append_partition_by_name_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; + append_partition_by_name_result result = new append_partition_by_name_result(); + if (e instanceof InvalidObjectException) { + result.o1 = (InvalidObjectException) e; + result.setO1IsSet(true); + msg = result; + } + else if (e instanceof AlreadyExistsException) { + result.o2 = (AlreadyExistsException) e; + result.setO2IsSet(true); + msg = result; + } + else if (e instanceof MetaException) { + result.o3 = (MetaException) e; + result.setO3IsSet(true); + msg = result; + } + else + { + msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; + msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); + } + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); + } + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, append_partition_by_name_args args, org.apache.thrift.async.AsyncMethodCallback<Partition> resultHandler) throws TException { + iface.append_partition_by_name(args.db_name, args.tbl_name, args.part_name,resultHandler); + } + } + + public static class append_partition_by_name_with_environment_context<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, append_partition_by_name_with_environment_context_args, Partition> { + public append_partition_by_name_with_environment_context() { + super("append_partition_by_name_with_environment_context"); + } + + public append_partition_by_name_with_environment_context_args getEmptyArgsInstance() { + return new append_partition_by_name_with_environment_context_args(); + } + + public AsyncMethodCallback<Partition> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Partition>() { + public void onComplete(Partition o) { + append_partition_by_name_with_environment_context_result result = new append_partition_by_name_with_environment_context_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; + append_partition_by_name_with_environment_context_result result = new append_partition_by_name_with_environment_context_result(); if (e instanceof InvalidObjectException) { result.o1 = (InvalidObjectException) e; result.setO1IsSet(true); @@ -42513,6 +42664,835 @@ public class ThriftHiveMetastore { } + public static class drop_constraint_args implements org.apache.thrift.TBase<drop_constraint_args, drop_constraint_args._Fields>, java.io.Serializable, Cloneable, Comparable<drop_constraint_args> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("drop_constraint_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 drop_constraint_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new drop_constraint_argsTupleSchemeFactory()); + } + + private DropConstraintRequest 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, DropConstraintRequest.class))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(drop_constraint_args.class, metaDataMap); + } + + public drop_constraint_args() { + } + + public drop_constraint_args( + DropConstraintRequest req) + { + this(); + this.req = req; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public drop_constraint_args(drop_constraint_args other) { + if (other.isSetReq()) { + this.req = new DropConstraintRequest(other.req); + } + } + + public drop_constraint_args deepCopy() { + return new drop_constraint_args(this); + } + + @Override + public void clear() { + this.req = null; + } + + public DropConstraintRequest getReq() { + return this.req; + } + + public void setReq(DropConstraintRequest 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((DropConstraintRequest)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case REQ: + return getReq(); + + } + 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 REQ: + return isSetReq(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + 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 (!getCl
<TRUNCATED>